From 3fe71d50842371e0be6b939ba249f5a7284c0f55 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Sun, 24 Dec 2017 20:25:31 -0300 Subject: [refactor] use explicit stream direction argument download was being inferred. It's now being set on each and will raise an error if node is provided. Also removed a duplication on params variable. --- src/leap/soledad/client/_db/blobs/__init__.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/leap/soledad/client/_db') diff --git a/src/leap/soledad/client/_db/blobs/__init__.py b/src/leap/soledad/client/_db/blobs/__init__.py index 8d469760..d4eddb8f 100644 --- a/src/leap/soledad/client/_db/blobs/__init__.py +++ b/src/leap/soledad/client/_db/blobs/__init__.py @@ -483,7 +483,8 @@ class BlobManager(BlobsSynchronizer): @defer.inlineCallbacks def _downstream(self, blobs_id_list, namespace=''): uri = urljoin(self.remote_stream, self.user) - params = {'namespace': namespace} if namespace else None + params = {'namespace': namespace} if namespace else {} + params['direction'] = 'download' data = BytesIO(json.dumps(blobs_id_list)) response = yield self._client.post(uri, params=params, data=data) deferreds = [] @@ -501,7 +502,6 @@ class BlobManager(BlobsSynchronizer): def _upstream(self, blobs_id_list, namespace=''): local, secret = self.local, self.secret uri = urljoin(self.remote_stream, self.user) - params = {'namespace': namespace} if namespace else None sizes = yield self.local.get_size_list(blobs_id_list, namespace) convert = get_unarmored_ciphertext_size sizes = map(lambda (blob_id, size): (blob_id, convert(size)), sizes) -- cgit v1.2.3