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 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'src/leap/soledad/client/_db/blobs/sql.py') 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 = ?' -- cgit v1.2.3