added comms

outpostcli/constants.py

@@ -1,2 +1,2 @@
-cli_version = "0.0.40"
+cli_version = "0.0.41"
 CLI_BINARY_NAME = "outpostcli"

outpostcli/lfs/commands.py

@@ -3,12 +3,12 @@
 import os
 import subprocess
 import sys
-from typing import Dict, Optional
 
 import click
 from outpostkit.repository.lfs.logger import create_lfs_logger
 
 from outpostcli.constants import CLI_BINARY_NAME
+from outpostcli.lfs.comms import read_msg, write_msg
 from outpostcli.lfs.storage_class.gcs import gcs_multipart_upload
 from outpostcli.lfs.storage_class.s3 import aws_multipart_upload
 from outpostcli.utils import click_group
@@ -73,26 +73,6 @@ def enable_largefiles(path):
     click.echo("Local repository set up for largefiles")
 
 
-def write_msg(msg: Dict):
-    """Write out the message in Line delimited JSON."""
-    msg_str = json.dumps(msg) + "\n"
-    sys.stdout.write(msg_str)
-    sys.stdout.flush()
-
-def read_msg() -> Optional[Dict]:
-    """Read Line delimited JSON from stdin."""
-    msg = json.loads(sys.stdin.readline().strip())
-    _log.info(msg)
-    if "terminate" in (msg.get("type"), msg.get("event")):
-        # terminate message received
-        return None
-
-    if msg.get("event") not in ("download", "upload"):
-        # logger.critical("Received unexpected message")
-        sys.exit(1)
-
-    return msg
-
 @lfs.command(name=MULTIPART_UPLOAD_COMMAND_NAME)
 def multipart_upload():
     try:

outpostcli/lfs/comms.py

@@ -0,0 +1,29 @@
+import json
+import sys
+from typing import Dict, Optional
+
+from outpostkit.repository.lfs.logger import create_lfs_logger
+
+_log = create_lfs_logger(__name__)
+
+
+def write_msg(msg: Dict):
+    """Write out the message in Line delimited JSON."""
+    msg_str = json.dumps(msg) + "\n"
+    sys.stdout.write(msg_str)
+    sys.stdout.flush()
+
+
+def read_msg() -> Optional[Dict]:
+    """Read Line delimited JSON from stdin."""
+    msg = json.loads(sys.stdin.readline().strip())
+    _log.info(msg)
+    if "terminate" in (msg.get("type"), msg.get("event")):
+        # terminate message received
+        return None
+
+    if msg.get("event") not in ("download", "upload"):
+        # logger.critical("Received unexpected message")
+        sys.exit(1)
+
+    return msg

outpostcli/lfs/storage_class/gcs.py

@@ -6,7 +6,7 @@
 import requests
 from outpostkit.repository.lfs.logger import create_lfs_logger
 
-from outpostcli.lfs.commands import write_msg
+from outpostcli.lfs.comms import write_msg
 from outpostcli.lfs.exc import LFSException, ProxyLFSException
 from outpostcli.lfs.parallel import multimap
 from outpostcli.lfs.part import PartInfo, transfer_part

outpostcli/lfs/storage_class/s3.py

@@ -4,7 +4,7 @@
 import requests
 from outpostkit.repository.lfs.logger import create_lfs_logger
 
-from outpostcli.lfs.commands import write_msg
+from outpostcli.lfs.comms import write_msg
 from outpostcli.lfs.exc import LFSException, ProxyLFSException
 from outpostcli.lfs.parallel import multimap
 from outpostcli.lfs.part import PartInfo, transfer_part

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "outpostcli"
-version = "0.0.40"
+version = "0.0.41"
 description = "CLI for Outpost"
 readme = "README.md"
 license = { file = "LICENSE" }

setup.py

@@ -2,7 +2,7 @@
 
 setup(
     name="outpostcli",
-    version="0.0.40",
+    version="0.0.41",
     py_modules=["outpostcli"],
     install_requires=["Click", "outpostkit"],
     entry_points={