summaryrefslogtreecommitdiff
path: root/tests/server/test_blobs_server.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/server/test_blobs_server.py')
-rw-r--r--tests/server/test_blobs_server.py17
1 files changed, 17 insertions, 0 deletions
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
@@ -258,6 +258,23 @@ class BlobServerTestCase(unittest.TestCase):
@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):
manager = BlobManager('', self.uri, self.secret,
self.secret, uuid4().hex)