From 8f3fdc2f9c3d4360669c2c7fd89dbd95e0f8dd22 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Sat, 11 Nov 2017 00:37:01 -0300 Subject: [feature] apply deletions from server Sync method to propagate deletions in batch locally. -- Resolves: #8961 --- src/leap/soledad/client/_db/blobs/sync.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'src/leap/soledad/client/_db/blobs/sync.py') diff --git a/src/leap/soledad/client/_db/blobs/sync.py b/src/leap/soledad/client/_db/blobs/sync.py index bfdc5fbe..bdfbb983 100644 --- a/src/leap/soledad/client/_db/blobs/sync.py +++ b/src/leap/soledad/client/_db/blobs/sync.py @@ -72,6 +72,12 @@ class BlobsSynchronizer(object): SyncStatus.PENDING_UPLOAD, namespace=namespace) + @defer.inlineCallbacks + def _apply_deletions_from_server(self, namespace=''): + remote_deletions = self.remote_list(namespace=namespace, deleted=True) + remote_deletions = yield remote_deletions + yield self.local.batch_delete(remote_deletions) + @defer.inlineCallbacks def send_missing(self, namespace=''): """ @@ -131,6 +137,7 @@ class BlobsSynchronizer(object): @defer.inlineCallbacks def sync(self, namespace=''): try: + yield self._apply_deletions_from_server(namespace) yield self.refresh_sync_status_from_server(namespace) yield self.fetch_missing(namespace) yield self.send_missing(namespace) -- cgit v1.2.3