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 --- src/leap/soledad/client/_db/blobs/sql.py | 14 ++++++++++++++ src/leap/soledad/client/_db/blobs/sync.py | 4 ++++ 2 files changed, 18 insertions(+) (limited to 'src/leap') diff --git a/src/leap/soledad/client/_db/blobs/sql.py b/src/leap/soledad/client/_db/blobs/sql.py index 72fc250b..e81580a7 100644 --- a/src/leap/soledad/client/_db/blobs/sql.py +++ b/src/leap/soledad/client/_db/blobs/sql.py @@ -104,6 +104,20 @@ class SQLiteBlobBackend(object): if result: defer.returnValue((result[0][0], result[0][1])) + @defer.inlineCallbacks + def get_sync_progress(self): + query = 'SELECT sync_status, COUNT(sync_status) FROM sync_state' + query += ' GROUP BY sync_status' + + def by_value(value): + statuses = SyncStatus.__dict__.items() + return filter(lambda x: x[1] == value, statuses)[0][0] + result = yield self.dbpool.runQuery(query) + if result: + defer.returnValue(dict([(by_value(r[0]), r[1]) for r in result])) + else: + defer.returnValue([]) + @defer.inlineCallbacks def list(self, namespace=''): query = 'select blob_id from blobs where namespace = ?' diff --git a/src/leap/soledad/client/_db/blobs/sync.py b/src/leap/soledad/client/_db/blobs/sync.py index ee10443d..d47033b2 100644 --- a/src/leap/soledad/client/_db/blobs/sync.py +++ b/src/leap/soledad/client/_db/blobs/sync.py @@ -126,3 +126,7 @@ class BlobsSynchronizer(object): yield self.send_missing(namespace) except defer.FirstError as e: e.subFailure.raiseException() + + @property + def sync_progress(self): + return self.local.get_sync_progress() -- cgit v1.2.3