diff --git a/gcloud/storage/__init__.py b/gcloud/storage/__init__.py index 141218850140..ffb42c53f2b9 100644 --- a/gcloud/storage/__init__.py +++ b/gcloud/storage/__init__.py @@ -82,7 +82,7 @@ def set_default_bucket(bucket=None): connection = get_default_connection() if bucket_name is not None and connection is not None: - bucket = Bucket(connection=connection, name=bucket_name) + bucket = Bucket(bucket_name, connection=connection) if bucket is not None: _implicit_environ._DEFAULTS.bucket = bucket diff --git a/gcloud/storage/bucket.py b/gcloud/storage/bucket.py index 4c27950ffe53..67fec046514d 100644 --- a/gcloud/storage/bucket.py +++ b/gcloud/storage/bucket.py @@ -75,11 +75,14 @@ def get_items_from_response(self, response): class Bucket(_PropertyMixin): """A class representing a Bucket on Cloud Storage. + :type name: string + :param name: The name of the bucket. + :type connection: :class:`gcloud.storage.connection.Connection` :param connection: The connection to use when sending requests. - :type name: string - :param name: The name of the bucket. + :type properties: dictionary or ``NoneType`` + :param properties: The properties associated with the bucket. """ _iterator_class = _BlobIterator @@ -89,7 +92,7 @@ class Bucket(_PropertyMixin): # ACL rules are lazily retrieved. _acl = _default_object_acl = None - def __init__(self, connection=None, name=None, properties=None): + def __init__(self, name=None, connection=None, properties=None): if name is None and properties is not None: name = properties.get('name') super(Bucket, self).__init__(name=name, properties=properties) diff --git a/gcloud/storage/test_acl.py b/gcloud/storage/test_acl.py index c9a69daf9346..2991aa427168 100644 --- a/gcloud/storage/test_acl.py +++ b/gcloud/storage/test_acl.py @@ -541,7 +541,7 @@ def test_reload_eager_missing(self): NAME = 'name' ROLE = 'role' connection = _Connection({}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True acl.entity('allUsers', ROLE) @@ -556,7 +556,7 @@ def test_reload_eager_empty(self): NAME = 'name' ROLE = 'role' connection = _Connection({'items': []}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True acl.entity('allUsers', ROLE) @@ -572,7 +572,7 @@ def test_reload_eager_nonempty(self): ROLE = 'role' connection = _Connection( {'items': [{'entity': 'allUsers', 'role': ROLE}]}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True self.assertTrue(acl.reload() is acl) @@ -587,7 +587,7 @@ def test_reload_lazy(self): ROLE = 'role' connection = _Connection( {'items': [{'entity': 'allUsers', 'role': ROLE}]}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) self.assertTrue(acl.reload() is acl) self.assertEqual(list(acl), [{'entity': 'allUsers', 'role': ROLE}]) @@ -599,7 +599,7 @@ def test_reload_lazy(self): def test_save_none_set_none_passed(self): NAME = 'name' connection = _Connection() - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) self.assertTrue(acl.save() is acl) kw = connection._requested @@ -608,7 +608,7 @@ def test_save_none_set_none_passed(self): def test_save_existing_missing_none_passed(self): NAME = 'name' connection = _Connection({}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True self.assertTrue(acl.save() is acl) @@ -625,7 +625,7 @@ def test_save_no_arg(self): ROLE = 'role' AFTER = [{'entity': 'allUsers', 'role': ROLE}] connection = _Connection({'acl': AFTER}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True acl.entity('allUsers').grant(ROLE) @@ -645,7 +645,7 @@ def test_save_w_arg(self): STICKY = {'entity': 'allUsers', 'role': ROLE2} new_acl = [{'entity': 'allUsers', 'role': ROLE1}] connection = _Connection({'acl': [STICKY] + new_acl}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True self.assertTrue(acl.save(new_acl) is acl) @@ -666,7 +666,7 @@ def test_clear(self): ROLE2 = 'role2' STICKY = {'entity': 'allUsers', 'role': ROLE2} connection = _Connection({'acl': [STICKY]}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) acl = self._makeOne(bucket) acl.loaded = True acl.entity('allUsers', ROLE1) @@ -703,7 +703,7 @@ def test_reload_eager_missing(self): ROLE = 'role' after = {} connection = _Connection(after) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -717,7 +717,7 @@ def test_reload_eager_empty(self): ROLE = 'role' after = {'items': []} connection = _Connection(after) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -731,7 +731,7 @@ def test_reload_eager_nonempty(self): ROLE = 'role' after = {'items': [{'entity': 'allUsers', 'role': ROLE}]} connection = _Connection(after) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -748,7 +748,7 @@ def test_reload_lazy(self): ROLE = 'role' after = {'items': [{'entity': 'allUsers', 'role': ROLE}]} connection = _Connection(after) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) self.assertTrue(acl.reload() is acl) @@ -763,7 +763,7 @@ def test_save_none_set_none_passed(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection() - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) self.assertTrue(acl.save() is acl) @@ -775,7 +775,7 @@ def test_save_existing_missing_none_passed(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({'foo': 'Foo'}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -791,7 +791,7 @@ def test_save_existing_set_none_passed(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({'foo': 'Foo', 'acl': []}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -809,7 +809,7 @@ def test_save_existing_set_new_passed(self): ROLE = 'role' new_acl = [{'entity': 'allUsers', 'role': ROLE}] connection = _Connection({'foo': 'Foo', 'acl': new_acl}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -828,7 +828,7 @@ def test_clear(self): BLOB_NAME = 'blob-name' ROLE = 'role' connection = _Connection({'foo': 'Foo', 'acl': []}) - bucket = _Bucket(connection, NAME) + bucket = _Bucket(NAME, connection) blob = _Blob(bucket, BLOB_NAME) acl = self._makeOne(blob) acl.loaded = True @@ -860,9 +860,9 @@ def path(self): class _Bucket(object): - def __init__(self, connection, name): - self.connection = connection + def __init__(self, name, connection): self.name = name + self.connection = connection @property def path(self): diff --git a/gcloud/storage/test_bucket.py b/gcloud/storage/test_bucket.py index 1a0cc2460394..f2f32a6c6cc7 100644 --- a/gcloud/storage/test_bucket.py +++ b/gcloud/storage/test_bucket.py @@ -78,7 +78,7 @@ def test_ctor_explicit(self): NAME = 'name' connection = _Connection() properties = {'key': 'value'} - bucket = self._makeOne(connection, NAME, properties) + bucket = self._makeOne(NAME, connection, properties) self.assertTrue(bucket.connection is connection) self.assertEqual(bucket.name, NAME) self.assertEqual(bucket._properties, properties) @@ -109,7 +109,7 @@ def test_ctor_no_name_explicit(self): def test___iter___empty(self): NAME = 'name' connection = _Connection({'items': []}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) blobs = list(bucket) self.assertEqual(blobs, []) kw, = connection._requested @@ -121,7 +121,7 @@ def test___iter___non_empty(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({'items': [{'name': BLOB_NAME}]}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) blobs = list(bucket) blob, = blobs self.assertTrue(blob.bucket is bucket) @@ -135,7 +135,7 @@ def test___contains___miss(self): NAME = 'name' NONESUCH = 'nonesuch' connection = _Connection() - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertFalse(NONESUCH in bucket) kw, = connection._requested self.assertEqual(kw['method'], 'GET') @@ -145,7 +145,7 @@ def test___contains___hit(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({'name': BLOB_NAME}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertTrue(BLOB_NAME in bucket) kw, = connection._requested self.assertEqual(kw['method'], 'GET') @@ -221,14 +221,14 @@ def test_path_no_name(self): def test_path_w_name(self): NAME = 'name' connection = _Connection() - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertEqual(bucket.path, '/b/%s' % NAME) def test_get_blob_miss(self): NAME = 'name' NONESUCH = 'nonesuch' connection = _Connection() - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertTrue(bucket.get_blob(NONESUCH) is None) kw, = connection._requested self.assertEqual(kw['method'], 'GET') @@ -238,7 +238,7 @@ def test_get_blob_hit(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({'name': BLOB_NAME}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) blob = bucket.get_blob(BLOB_NAME) self.assertTrue(blob.bucket is bucket) self.assertEqual(blob.name, BLOB_NAME) @@ -249,7 +249,7 @@ def test_get_blob_hit(self): def test_get_all_blobs_empty(self): NAME = 'name' connection = _Connection({'items': []}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) blobs = bucket.get_all_blobs() self.assertEqual(blobs, []) kw, = connection._requested @@ -261,7 +261,7 @@ def test_get_all_blobs_non_empty(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({'items': [{'name': BLOB_NAME}]}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) blobs = bucket.get_all_blobs() blob, = blobs self.assertTrue(blob.bucket is bucket) @@ -274,7 +274,7 @@ def test_get_all_blobs_non_empty(self): def test_iterator_defaults(self): NAME = 'name' connection = _Connection({'items': []}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) iterator = bucket.iterator() blobs = list(iterator) self.assertEqual(blobs, []) @@ -292,7 +292,7 @@ def test_iterator_explicit(self): 'versions': True, } connection = _Connection({'items': []}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) iterator = bucket.iterator( prefix='subfolder', delimiter='/', @@ -310,7 +310,7 @@ def test_delete_default_miss(self): from gcloud.exceptions import NotFound NAME = 'name' connection = _Connection() - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertRaises(NotFound, bucket.delete) expected_cw = [{'method': 'DELETE', 'path': bucket.path}] self.assertEqual(connection._deleted_buckets, expected_cw) @@ -320,7 +320,7 @@ def test_delete_explicit_hit(self): GET_BLOBS_RESP = {'items': []} connection = _Connection(GET_BLOBS_RESP) connection._delete_bucket = True - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertEqual(bucket.delete(force=True), None) expected_cw = [{'method': 'DELETE', 'path': bucket.path}] self.assertEqual(connection._deleted_buckets, expected_cw) @@ -339,7 +339,7 @@ def test_delete_explicit_force_delete_blobs(self): connection = _Connection(GET_BLOBS_RESP, DELETE_BLOB1_RESP, DELETE_BLOB2_RESP) connection._delete_bucket = True - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertEqual(bucket.delete(force=True), None) expected_cw = [{'method': 'DELETE', 'path': bucket.path}] self.assertEqual(connection._deleted_buckets, expected_cw) @@ -351,7 +351,7 @@ def test_delete_explicit_force_miss_blobs(self): # Note the connection does not have a response for the blob. connection = _Connection(GET_BLOBS_RESP) connection._delete_bucket = True - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertEqual(bucket.delete(force=True), None) expected_cw = [{'method': 'DELETE', 'path': bucket.path}] self.assertEqual(connection._deleted_buckets, expected_cw) @@ -368,7 +368,7 @@ def test_delete_explicit_too_many(self): } connection = _Connection(GET_BLOBS_RESP) connection._delete_bucket = True - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) # Make the Bucket refuse to delete with 2 objects. bucket._MAX_OBJECTS_FOR_BUCKET_DELETE = 1 @@ -380,7 +380,7 @@ def test_delete_blob_miss(self): NAME = 'name' NONESUCH = 'nonesuch' connection = _Connection() - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertRaises(NotFound, bucket.delete_blob, NONESUCH) kw, = connection._requested self.assertEqual(kw['method'], 'DELETE') @@ -390,7 +390,7 @@ def test_delete_blob_hit(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) result = bucket.delete_blob(BLOB_NAME) self.assertTrue(result is None) kw, = connection._requested @@ -400,7 +400,7 @@ def test_delete_blob_hit(self): def test_delete_blobs_empty(self): NAME = 'name' connection = _Connection() - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.delete_blobs([]) self.assertEqual(connection._requested, []) @@ -408,7 +408,7 @@ def test_delete_blobs_hit(self): NAME = 'name' BLOB_NAME = 'blob-name' connection = _Connection({}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.delete_blobs([BLOB_NAME]) kw = connection._requested self.assertEqual(len(kw), 1) @@ -421,7 +421,7 @@ def test_delete_blobs_miss_no_on_error(self): BLOB_NAME = 'blob-name' NONESUCH = 'nonesuch' connection = _Connection({}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertRaises(NotFound, bucket.delete_blobs, [BLOB_NAME, NONESUCH]) kw = connection._requested self.assertEqual(len(kw), 2) @@ -435,7 +435,7 @@ def test_delete_blobs_miss_w_on_error(self): BLOB_NAME = 'blob-name' NONESUCH = 'nonesuch' connection = _Connection({}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) errors = [] bucket.delete_blobs([BLOB_NAME, NONESUCH], errors.append) self.assertEqual(errors, [NONESUCH]) @@ -456,8 +456,8 @@ class _Blob(object): path = '/b/%s/o/%s' % (SOURCE, BLOB_NAME) connection = _Connection({}) - source = self._makeOne(connection, SOURCE) - dest = self._makeOne(connection, DEST) + source = self._makeOne(SOURCE, connection) + dest = self._makeOne(DEST, connection) blob = _Blob() new_blob = source.copy_blob(blob, dest) self.assertTrue(new_blob.bucket is dest) @@ -479,8 +479,8 @@ class _Blob(object): path = '/b/%s/o/%s' % (SOURCE, BLOB_NAME) connection = _Connection({}) - source = self._makeOne(connection, SOURCE) - dest = self._makeOne(connection, DEST) + source = self._makeOne(SOURCE, connection) + dest = self._makeOne(DEST, connection) blob = _Blob() new_blob = source.copy_blob(blob, dest, NEW_NAME) self.assertTrue(new_blob.bucket is dest) @@ -592,7 +592,7 @@ def test_get_cors_eager(self): } before = {'cors': [CORS_ENTRY, {}]} connection = _Connection() - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) entries = bucket.get_cors() self.assertEqual(len(entries), 2) self.assertEqual(entries[0]['maxAgeSeconds'], @@ -617,7 +617,7 @@ def test_get_cors_lazy(self): } after = {'cors': [CORS_ENTRY]} connection = _Connection(after) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket._reload_properties() entries = bucket.get_cors() self.assertEqual(len(entries), 1) @@ -645,7 +645,7 @@ def test_update_cors(self): } after = {'cors': [CORS_ENTRY, {}]} connection = _Connection(after) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.update_cors([CORS_ENTRY, {}]) kw = connection._requested self.assertEqual(len(kw), 1) @@ -660,7 +660,7 @@ def test_get_default_object_acl_lazy(self): from gcloud.storage.acl import BucketACL NAME = 'name' connection = _Connection({'items': []}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) acl = bucket.get_default_object_acl() self.assertTrue(acl is bucket.default_object_acl) self.assertTrue(isinstance(acl, BucketACL)) @@ -697,7 +697,7 @@ def test_get_lifecycle_eager(self): LC_RULE = {'action': {'type': 'Delete'}, 'condition': {'age': 42}} before = {'lifecycle': {'rule': [LC_RULE]}} connection = _Connection() - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) entries = bucket.get_lifecycle() self.assertEqual(len(entries), 1) self.assertEqual(entries[0]['action']['type'], 'Delete') @@ -710,7 +710,7 @@ def test_get_lifecycle_lazy(self): LC_RULE = {'action': {'type': 'Delete'}, 'condition': {'age': 42}} after = {'lifecycle': {'rule': [LC_RULE]}} connection = _Connection(after) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket._reload_properties() entries = bucket.get_lifecycle() self.assertEqual(len(entries), 1) @@ -727,7 +727,7 @@ def test_update_lifecycle(self): LC_RULE = {'action': {'type': 'Delete'}, 'condition': {'age': 42}} after = {'lifecycle': {'rule': [LC_RULE]}} connection = _Connection(after) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.update_lifecycle([LC_RULE]) kw = connection._requested self.assertEqual(len(kw), 1) @@ -744,7 +744,7 @@ def test_location_getter(self): NAME = 'name' connection = _Connection() before = {'location': 'AS'} - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) self.assertEqual(bucket.location, 'AS') kw = connection._requested self.assertEqual(len(kw), 0) @@ -752,7 +752,7 @@ def test_location_getter(self): def test_location_setter(self): NAME = 'name' connection = _Connection({'location': 'AS'}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.location = 'AS' bucket.patch() self.assertEqual(bucket.location, 'AS') @@ -775,7 +775,7 @@ def test_get_logging_w_prefix(self): } resp_to_reload = before connection = _Connection(resp_to_reload) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) info = bucket.get_logging() self.assertEqual(info['logBucket'], LOG_BUCKET) self.assertEqual(info['logObjectPrefix'], LOG_PREFIX) @@ -795,7 +795,7 @@ def test_enable_logging_defaults(self): } connection = _Connection(resp_to_reload, resp_to_enable_logging, resp_to_enable_logging) - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) self.assertTrue(bucket.get_logging() is None) bucket.enable_logging(LOG_BUCKET) info = bucket.get_logging() @@ -826,7 +826,7 @@ def test_enable_logging_explicit(self): connection = _Connection(resp_to_reload, resp_to_enable_logging, resp_to_enable_logging) - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) self.assertTrue(bucket.get_logging() is None) bucket.enable_logging(LOG_BUCKET, LOG_PFX) info = bucket.get_logging() @@ -852,7 +852,7 @@ def test_disable_logging(self): resp_to_disable_logging = {'logging': None} connection = _Connection(resp_to_reload, resp_to_disable_logging, resp_to_disable_logging) - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) self.assertTrue(bucket.get_logging() is not None) bucket.disable_logging() self.assertTrue(bucket.get_logging() is None) @@ -910,7 +910,7 @@ def test_time_created(self): def test_versioning_enabled_getter_missing(self): NAME = 'name' connection = _Connection({}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket._reload_properties() self.assertEqual(bucket.versioning_enabled, False) kw = connection._requested @@ -923,7 +923,7 @@ def test_versioning_enabled_getter(self): NAME = 'name' before = {'versioning': {'enabled': True}} connection = _Connection() - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) self.assertEqual(bucket.versioning_enabled, True) kw = connection._requested self.assertEqual(len(kw), 0) @@ -933,7 +933,7 @@ def test_versioning_enabled_setter(self): before = {'versioning': {'enabled': False}} after = {'versioning': {'enabled': True}} connection = _Connection(after) - bucket = self._makeOne(connection, NAME, before) + bucket = self._makeOne(NAME, connection, before) self.assertFalse(bucket.versioning_enabled) bucket.versioning_enabled = True bucket.patch() @@ -949,7 +949,7 @@ def test_configure_website_defaults(self): patched = {'website': {'mainPageSuffix': None, 'notFoundPage': None}} connection = _Connection(patched) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertTrue(bucket.configure_website() is bucket) self.assertEqual(bucket.properties, patched) kw = connection._requested @@ -964,7 +964,7 @@ def test_configure_website_explicit(self): patched = {'website': {'mainPageSuffix': 'html', 'notFoundPage': '404.html'}} connection = _Connection(patched) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertTrue(bucket.configure_website('html', '404.html') is bucket) self.assertEqual(bucket.properties, patched) kw = connection._requested @@ -979,7 +979,7 @@ def test_disable_website(self): patched = {'website': {'mainPageSuffix': None, 'notFoundPage': None}} connection = _Connection(patched) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) self.assertTrue(bucket.disable_website() is bucket) self.assertEqual(bucket.properties, patched) kw = connection._requested @@ -995,7 +995,7 @@ def test_make_public_defaults(self): permissive = [{'entity': 'allUsers', 'role': _ACLEntity.READER_ROLE}] after = {'acl': permissive, 'defaultObjectAcl': []} connection = _Connection(after) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.acl.loaded = True bucket.default_object_acl.loaded = True bucket.make_public() @@ -1015,7 +1015,7 @@ def test_make_public_w_future(self): after1 = {'acl': permissive, 'defaultObjectAcl': []} after2 = {'acl': permissive, 'defaultObjectAcl': permissive} connection = _Connection(after1, after2) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.acl.loaded = True bucket.default_object_acl.loaded = True bucket.make_public(future=True) @@ -1067,7 +1067,7 @@ def get_items_from_response(self, response): permissive = [{'entity': 'allUsers', 'role': _ACLEntity.READER_ROLE}] after = {'acl': permissive, 'defaultObjectAcl': []} connection = _Connection(after, {'items': [{'name': BLOB_NAME}]}) - bucket = self._makeOne(connection, NAME) + bucket = self._makeOne(NAME, connection) bucket.acl.loaded = True bucket.default_object_acl.loaded = True bucket._iterator_class = _Iterator diff --git a/regression/storage.py b/regression/storage.py index 9d2aaec2aa14..85919c517f74 100644 --- a/regression/storage.py +++ b/regression/storage.py @@ -53,7 +53,7 @@ def setUp(self): def tearDown(self): with Batch() as batch: for bucket_name in self.case_buckets_to_delete: - storage.Bucket(connection=batch, name=bucket_name).delete() + storage.Bucket(bucket_name, connection=batch).delete() def test_create_bucket(self): new_bucket_name = 'a-new-bucket'