From c8234da89b198064f1d1f14bec6811c0883e705c Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Tue, 31 Oct 2017 06:15:06 -0300 Subject: [feature] add sync progress attribute --Resolves: #8848 --- tests/blobs/test_blob_manager.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) (limited to 'tests') diff --git a/tests/blobs/test_blob_manager.py b/tests/blobs/test_blob_manager.py index f1872ab1..d36b3cda 100644 --- a/tests/blobs/test_blob_manager.py +++ b/tests/blobs/test_blob_manager.py @@ -126,6 +126,22 @@ class BlobManagerTestCase(unittest.TestCase): self.assertEquals(missing_id, call_blob_id) self.assertEquals('test', call_fd.getvalue()) + @defer.inlineCallbacks + @pytest.mark.usefixtures("method_tmpdir") + def test_sync_progress(self): + deferreds = [] + local = self.manager.local + pending_download = SyncStatus.PENDING_DOWNLOAD + pending_upload = SyncStatus.PENDING_UPLOAD + synced = SyncStatus.SYNCED + for status in [pending_download, pending_upload, synced, synced]: + deferreds.append(local.update_sync_status(uuid4().hex, status)) + yield defer.gatherResults(deferreds) + + progress = yield self.manager.sync_progress + self.assertEquals(progress, { + 'PENDING_DOWNLOAD': 1, 'PENDING_UPLOAD': 1, 'SYNCED': 2}) + @defer.inlineCallbacks @pytest.mark.usefixtures("method_tmpdir") def test_duplicated_blob_error_on_put(self): -- cgit v1.2.3