Sync resumption for SoUD syncs and cleanup handling

kolibri/core/auth/constants/morango_sync.py

@@ -1,7 +1,10 @@
 from __future__ import unicode_literals
 
+from kolibri.utils import conf
+
 
 PROFILE_FACILITY_DATA = "facilitydata"
+DATA_PORTAL_SYNCING_BASE_URL = conf.OPTIONS["Urls"]["DATA_PORTAL_SYNCING_BASE_URL"]
 
 
 class ScopeDefinitions(object):

kolibri/core/auth/management/commands/resumesync.py

@@ -0,0 +1,57 @@
+from kolibri.core.auth.constants.morango_sync import DATA_PORTAL_SYNCING_BASE_URL
+from kolibri.core.auth.management.utils import get_network_connection
+from kolibri.core.auth.management.utils import MorangoSyncCommand
+
+
+class Command(MorangoSyncCommand):
+    help = "Allow the syncing of facility data with Kolibri Data Portal or another Kolibri device."
+
+    def add_arguments(self, parser):
+        parser.add_argument(
+            "--id", type=str, help="ID of an incomplete session to resume sync"
+        )
+        parser.add_argument(
+            "--baseurl", type=str, default=DATA_PORTAL_SYNCING_BASE_URL, dest="baseurl"
+        )
+        parser.add_argument("--noninteractive", action="store_true")
+        parser.add_argument(
+            "--chunk-size",
+            type=int,
+            default=500,
+            help="Chunk size of records to send/retrieve per request",
+        )
+        parser.add_argument(
+            "--no-push", action="store_true", help="Do not push data to the server"
+        )
+        parser.add_argument(
+            "--no-pull", action="store_true", help="Do not pull data from the server"
+        )
+        parser.add_argument(
+            "--no-provision",
+            action="store_true",
+            help="do not create a facility and temporary superuser",
+        )
+        parser.add_argument(
+            "--user",
+            type=str,
+            help="for single-user syncing, the user ID of the account to be synced",
+        )
+        parser.add_argument(
+            "--keep-alive",
+            action="store_true",
+            help="do not close the sync session",
+        )
+
+    def handle_async(self, *args, **options):
+        (baseurl, sync_session_id, chunk_size,) = (
+            options["baseurl"],
+            options["id"],
+            options["chunk_size"],
+        )
+
+        # try to connect to server
+        network_connection = get_network_connection(baseurl)
+        sync_session_client = network_connection.resume_sync_session(
+            sync_session_id, chunk_size=chunk_size
+        )
+        self._sync(sync_session_client, **options)