Refactor application

Author: jackton1

github_deploy/commands/_http_utils.py

@@ -0,0 +1,64 @@
+import ssl
+import certifi
+
+import asyncclick as click
+
+from github_deploy.commands._constants import REPOS_URL
+
+
+async def get(*, session, url, headers=None, skip_missing=False):
+    ssl_context = ssl.create_default_context(cafile=certifi.where())
+
+    async with session.get(
+            url,
+            headers=headers,
+            timeout=70,
+            ssl_context=ssl_context,
+            raise_for_status=not skip_missing,
+    ) as response:
+        if skip_missing and response.status == 404:
+            return {}
+
+        value = await response.json()
+        return value
+
+
+async def put(*, session, url, data, headers=None):
+    ssl_context = ssl.create_default_context(cafile=certifi.where())
+
+    async with session.put(
+            url,
+            json=data,
+            headers=headers,
+            timeout=70,
+            ssl_context=ssl_context,
+            raise_for_status=True,
+    ) as response:
+        value = await response.json()
+        return value
+
+
+async def delete(*, session, url, data, headers=None):
+    ssl_context = ssl.create_default_context(cafile=certifi.where())
+
+    async with session.delete(
+            url,
+            json=data,
+            headers=headers,
+            timeout=70,
+            ssl_context=ssl_context,
+            raise_for_status=True,
+    ) as response:
+        value = await response.json()
+        return value
+
+
+async def list_repos(*, session, org, token):
+    headers = {
+        "Authorization": "token {token}".format(token=token),
+        "Accept": "application/vnd.github.v3+json",
+    }
+    url = REPOS_URL.format(org=org)
+    click.echo("Retrieving repos at {}".format(url))
+    response = await get(session=session, url=url, headers=headers)
+    return response

github_deploy/commands/_utils.py

@@ -5,6 +5,6 @@ def get_repo(*, org, project):
 def can_upload(*, repo, include_private):
     return (
         True
-        if include_private and repo["private"] == True
+        if include_private and repo["private"] is True
         else not repo["private"]
     )

github_deploy/commands/delete.py

@@ -1,46 +1,13 @@
 import asyncio
-import ssl
 
 import aiohttp
 import asyncclick as click
-import certifi
 
-from github_deploy.commands._constants import BASE_URL, REPOS_URL
+from github_deploy.commands._constants import BASE_URL
+from github_deploy.commands._http_utils import delete, get, list_repos
 from github_deploy.commands._utils import get_repo
 
 
-async def get(*, session, url, headers=None, skip_missing=False):
-    ssl_context = ssl.create_default_context(cafile=certifi.where())
-
-    async with session.get(
-        url,
-        headers=headers,
-        timeout=70,
-        ssl_context=ssl_context,
-        raise_for_status=not skip_missing,
-    ) as response:
-        if skip_missing and response.status == 404:
-            return {}
-
-        value = await response.json()
-        return value
-
-
-async def delete(*, session, url, data, headers=None):
-    ssl_context = ssl.create_default_context(cafile=certifi.where())
-
-    async with session.delete(
-        url,
-        json=data,
-        headers=headers,
-        timeout=70,
-        ssl_context=ssl_context,
-        raise_for_status=True,
-    ) as response:
-        value = await response.json()
-        return value
-
-
 async def delete_content(
     *,
     session,
@@ -135,17 +102,6 @@ async def handle_file_delete(*, repo, dest, token, semaphore, session):
     )
 
 
-async def list_repos(*, session, org, token):
-    headers = {
-        "Authorization": "token {token}".format(token=token),
-        "Accept": "application/vnd.github.v3+json",
-    }
-    url = REPOS_URL.format(org=org)
-    click.echo("Retrieving repos at {}".format(url))
-    response = await get(session=session, url=url, headers=headers)
-    return response
-
-
 @click.command()
 @click.option(
     "--org",

github_deploy/commands/upload.py

@@ -1,48 +1,15 @@
 import asyncio
 import base64
-import ssl
 
 import aiofiles
 import aiohttp
 import asyncclick as click
-import certifi
 
-from github_deploy.commands._constants import BASE_URL, REPOS_URL
+from github_deploy.commands._constants import BASE_URL
+from github_deploy.commands._http_utils import put, list_repos, get
 from github_deploy.commands._utils import get_repo, can_upload
 
 
-async def get(*, session, url, headers=None, skip_missing=False):
-    ssl_context = ssl.create_default_context(cafile=certifi.where())
-
-    async with session.get(
-        url,
-        headers=headers,
-        timeout=70,
-        ssl_context=ssl_context,
-        raise_for_status=not skip_missing,
-    ) as response:
-        if skip_missing and response.status == 404:
-            return {}
-
-        value = await response.json()
-        return value
-
-
-async def put(*, session, url, data, headers=None):
-    ssl_context = ssl.create_default_context(cafile=certifi.where())
-
-    async with session.put(
-        url,
-        json=data,
-        headers=headers,
-        timeout=70,
-        ssl_context=ssl_context,
-        raise_for_status=True,
-    ) as response:
-        value = await response.json()
-        return value
-
-
 async def upload_content(
     *,
     session,
@@ -165,17 +132,6 @@ async def handle_file_upload(
             )
 
 
-async def list_repos(*, session, org, token):
-    headers = {
-        "Authorization": "token {token}".format(token=token),
-        "Accept": "application/vnd.github.v3+json",
-    }
-    url = REPOS_URL.format(org=org)
-    click.echo("Retrieving repos at {}".format(url))
-    response = await get(session=session, url=url, headers=headers)
-    return response
-
-
 @click.command()
 @click.option(
     "--org",