[feature] apply deletions from server

Sync method to propagate deletions in batch locally.

-- Resolves: #8961

1 files changed, 19 insertions, 0 deletions

diff --git a/tests/server/test_blobs_server.py b/tests/server/test_blobs_server.py
index ba4a03d7..4e7b4a3b 100644
--- a/tests/server/test_blobs_server.py
+++ b/tests/server/test_blobs_server.py
@@ -37,6 +37,7 @@ from leap.soledad.client._db.blobs import SyncStatus
 from leap.soledad.client._db.blobs import RetriableTransferError
 from leap.soledad.client._db.blobs import MaximumRetriesError
 from leap.soledad.client._db import blobs as client_blobs
+from leap.soledad.client._document import BlobDoc
 
 
 def sleep(x):
@@ -324,6 +325,24 @@ class BlobServerTestCase(unittest.TestCase):
 
     @defer.inlineCallbacks
     @pytest.mark.usefixtures("method_tmpdir")
+    def test_refresh_deletions_from_server(self):
+        manager = BlobManager(self.tempdir, self.uri, self.secret,
+                              self.secret, uuid4().hex)
+        self.addCleanup(manager.close)
+        blob_id, content = 'delete_me', 'content'
+        blob_id2 = 'dont_delete_me'
+        doc1 = BlobDoc(BytesIO(content), blob_id)
+        doc2 = BlobDoc(BytesIO(content), blob_id2)
+        yield manager.put(doc1, len(content))
+        yield manager.put(doc2, len(content))
+        yield manager._delete_from_remote(blob_id)  # remote only deletion
+        self.assertTrue((yield manager.local.exists(blob_id)))
+        yield manager.sync()
+        self.assertFalse((yield manager.local.exists(blob_id)))
+        self.assertTrue((yield manager.local.exists(blob_id2)))
+
+    @defer.inlineCallbacks
+    @pytest.mark.usefixtures("method_tmpdir")
     def test_download_corrupted_tag_marks_blob_as_failed(self):
         user_id = uuid4().hex
         manager = BlobManager(self.tempdir, self.uri, self.secret,