Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(82)

Unified Diff: tools/telemetry/third_party/gsutil/third_party/boto/tests/unit/glacier/test_layer1.py

Issue 1260493004: Revert "Add gsutil 4.13 to telemetry/third_party" (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: tools/telemetry/third_party/gsutil/third_party/boto/tests/unit/glacier/test_layer1.py
diff --git a/tools/telemetry/third_party/gsutil/third_party/boto/tests/unit/glacier/test_layer1.py b/tools/telemetry/third_party/gsutil/third_party/boto/tests/unit/glacier/test_layer1.py
deleted file mode 100644
index 4c8f0cf75169f575c05e4179b4f43563bf08dd0f..0000000000000000000000000000000000000000
--- a/tools/telemetry/third_party/gsutil/third_party/boto/tests/unit/glacier/test_layer1.py
+++ /dev/null
@@ -1,98 +0,0 @@
-import json
-import copy
-import tempfile
-
-from tests.unit import AWSMockServiceTestCase
-from boto.glacier.layer1 import Layer1
-
-
-class GlacierLayer1ConnectionBase(AWSMockServiceTestCase):
- connection_class = Layer1
-
- def setUp(self):
- super(GlacierLayer1ConnectionBase, self).setUp()
- self.json_header = [('Content-Type', 'application/json')]
- self.vault_name = u'examplevault'
- self.vault_arn = 'arn:aws:glacier:us-east-1:012345678901:vaults/' + \
- self.vault_name
- self.vault_info = {u'CreationDate': u'2012-03-16T22:22:47.214Z',
- u'LastInventoryDate': u'2012-03-21T22:06:51.218Z',
- u'NumberOfArchives': 2,
- u'SizeInBytes': 12334,
- u'VaultARN': self.vault_arn,
- u'VaultName': self.vault_name}
-
-
-class GlacierVaultsOperations(GlacierLayer1ConnectionBase):
-
- def test_create_vault_parameters(self):
- self.set_http_response(status_code=201)
- self.service_connection.create_vault(self.vault_name)
-
- def test_list_vaults(self):
- content = {u'Marker': None,
- u'RequestId': None,
- u'VaultList': [self.vault_info]}
- self.set_http_response(status_code=200, header=self.json_header,
- body=json.dumps(content).encode('utf-8'))
- api_response = self.service_connection.list_vaults()
- self.assertDictEqual(content, api_response)
-
- def test_describe_vaults(self):
- content = copy.copy(self.vault_info)
- content[u'RequestId'] = None
- self.set_http_response(status_code=200, header=self.json_header,
- body=json.dumps(content).encode('utf-8'))
- api_response = self.service_connection.describe_vault(self.vault_name)
- self.assertDictEqual(content, api_response)
-
- def test_delete_vault(self):
- self.set_http_response(status_code=204)
- self.service_connection.delete_vault(self.vault_name)
-
-
-class GlacierJobOperations(GlacierLayer1ConnectionBase):
-
- def setUp(self):
- super(GlacierJobOperations, self).setUp()
- self.job_content = 'abc' * 1024
-
- def test_initiate_archive_job(self):
- content = {u'Type': u'archive-retrieval',
- u'ArchiveId': u'AAABZpJrTyioDC_HsOmHae8EZp_uBSJr6cnGOLKp_XJCl-Q',
- u'Description': u'Test Archive',
- u'SNSTopic': u'Topic',
- u'JobId': None,
- u'Location': None,
- u'RequestId': None}
- self.set_http_response(status_code=202, header=self.json_header,
- body=json.dumps(content).encode('utf-8'))
- api_response = self.service_connection.initiate_job(self.vault_name,
- self.job_content)
- self.assertDictEqual(content, api_response)
-
- def test_get_archive_output(self):
- header = [('Content-Type', 'application/octet-stream')]
- self.set_http_response(status_code=200, header=header,
- body=self.job_content)
- response = self.service_connection.get_job_output(self.vault_name,
- 'example-job-id')
- self.assertEqual(self.job_content, response.read())
-
-
-class GlacierUploadArchiveResets(GlacierLayer1ConnectionBase):
- def test_upload_archive(self):
- fake_data = tempfile.NamedTemporaryFile()
- fake_data.write(b'foobarbaz')
- # First seek to a non zero offset.
- fake_data.seek(2)
- self.set_http_response(status_code=201)
- # Simulate reading the request body when we send the request.
- self.service_connection.connection.request.side_effect = \
- lambda *args: fake_data.read()
- self.service_connection.upload_archive('vault_name', fake_data, 'linear_hash',
- 'tree_hash')
- # Verify that we seek back to the original offset after making
- # a request. This ensures that if we need to resend the request we're
- # back at the correct location within the file.
- self.assertEqual(fake_data.tell(), 2)

Powered by Google App Engine
This is Rietveld 408576698