From 91da999132b9c7afbbd9259915556c61f49497ba Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Thu, 14 Dec 2017 14:30:20 -0300 Subject: [test] test upstream from namespace --- tests/server/test_blobs_server.py | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/tests/server/test_blobs_server.py b/tests/server/test_blobs_server.py index 5a895ddc..bf929386 100644 --- a/tests/server/test_blobs_server.py +++ b/tests/server/test_blobs_server.py @@ -256,6 +256,23 @@ class BlobServerTestCase(unittest.TestCase): result = yield manager.local.get(blob_id2, namespace) self.assertEquals(content2, result.getvalue()) + @defer.inlineCallbacks + @pytest.mark.usefixtures("method_tmpdir") + def test_upstream_from_namespace(self): + manager = BlobManager(self.tempdir, self.uri, self.secret, + self.secret, uuid4().hex, + remote_stream=self.stream_uri) + self.addCleanup(manager.close) + blob_ids = [uuid4().hex for _ in range(5)] + for i, blob_id in enumerate(blob_ids): + yield manager.local.put(blob_id, BytesIO("X" * i), size=i, + namespace='test') + yield manager._upstream(blob_ids, namespace='test') + for i, blob_id in enumerate(blob_ids): + got_blob = yield manager._download_and_decrypt(blob_id, + namespace='test') + self.assertEquals(got_blob[0].getvalue(), "X" * i) + @defer.inlineCallbacks @pytest.mark.usefixtures("method_tmpdir") def test_download_from_namespace(self): -- cgit v1.2.3