| Index: third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| diff --git a/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py b/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| old mode 100755
|
| new mode 100644
|
| index 97627e255001b4c3375405c7095bd3637a27de91..5b9e5a2c61ae34a30ee58ece23cb6feb80eede69
|
| --- a/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| +++ b/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py
|
| @@ -1,7 +1,9 @@
|
| #!/usr/bin/env python
|
| """CLI for storage, version v1."""
|
| +# NOTE: This file is autogenerated and should not be edited by hand.
|
|
|
| import code
|
| +import os
|
| import platform
|
| import sys
|
|
|
| @@ -33,8 +35,12 @@ def _DeclareStorageFlags():
|
| 'File with interactive shell history.')
|
| flags.DEFINE_multistring(
|
| 'add_header', [],
|
| - 'Additional http headers (as key=value strings). Can be '
|
| - 'specified multiple times.')
|
| + 'Additional http headers (as key=value strings). '
|
| + 'Can be specified multiple times.')
|
| + flags.DEFINE_string(
|
| + 'service_account_json_keyfile', '',
|
| + 'Filename for a JSON service account key downloaded'
|
| + ' from the Developer Console.')
|
| flags.DEFINE_enum(
|
| 'alt',
|
| u'json',
|
| @@ -109,10 +115,14 @@ def GetClientFromFlags():
|
| log_response = FLAGS.log_response or FLAGS.log_request_response
|
| api_endpoint = apitools_base.NormalizeApiEndpoint(FLAGS.api_endpoint)
|
| additional_http_headers = dict(x.split('=', 1) for x in FLAGS.add_header)
|
| + credentials_args = {
|
| + 'service_account_json_keyfile': os.path.expanduser(FLAGS.service_account_json_keyfile)
|
| + }
|
| try:
|
| client = client_lib.StorageV1(
|
| api_endpoint, log_request=log_request,
|
| log_response=log_response,
|
| + credentials_args=credentials_args,
|
| additional_http_headers=additional_http_headers)
|
| except apitools_base.CredentialsError as e:
|
| print 'Error creating credentials: %s' % e
|
| @@ -153,17 +163,17 @@ class PyShell(appcommands.Cmd):
|
| return e.code
|
|
|
|
|
| -class DefaultObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Delete."""
|
| +class BucketAccessControlsDelete(apitools_base_cli.NewCmd):
|
| + """Command wrapping bucketAccessControls.Delete."""
|
|
|
| - usage = """defaultObjectAccessControls_delete <bucket> <entity>"""
|
| + usage = """bucketAccessControls_delete <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsDelete, self).__init__(name, fv)
|
| + super(BucketAccessControlsDelete, self).__init__(name, fv)
|
|
|
| def RunWithArgs(self, bucket, entity):
|
| - """Permanently deletes the default object ACL entry for the specified
|
| - entity on the specified bucket.
|
| + """Permanently deletes the ACL entry for the specified entity on the
|
| + specified bucket.
|
|
|
| Args:
|
| bucket: Name of a bucket.
|
| @@ -173,26 +183,25 @@ class DefaultObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageDefaultObjectAccessControlsDeleteRequest(
|
| + request = messages.StorageBucketAccessControlsDeleteRequest(
|
| bucket=bucket.decode('utf8'),
|
| entity=entity.decode('utf8'),
|
| )
|
| - result = client.defaultObjectAccessControls.Delete(
|
| + result = client.bucketAccessControls.Delete(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class DefaultObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Get."""
|
| +class BucketAccessControlsGet(apitools_base_cli.NewCmd):
|
| + """Command wrapping bucketAccessControls.Get."""
|
|
|
| - usage = """defaultObjectAccessControls_get <bucket> <entity>"""
|
| + usage = """bucketAccessControls_get <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsGet, self).__init__(name, fv)
|
| + super(BucketAccessControlsGet, self).__init__(name, fv)
|
|
|
| def RunWithArgs(self, bucket, entity):
|
| - """Returns the default object ACL entry for the specified entity on the
|
| - specified bucket.
|
| + """Returns the ACL entry for the specified entity on the specified bucket.
|
|
|
| Args:
|
| bucket: Name of a bucket.
|
| @@ -202,22 +211,22 @@ class DefaultObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageDefaultObjectAccessControlsGetRequest(
|
| + request = messages.StorageBucketAccessControlsGetRequest(
|
| bucket=bucket.decode('utf8'),
|
| entity=entity.decode('utf8'),
|
| )
|
| - result = client.defaultObjectAccessControls.Get(
|
| + result = client.bucketAccessControls.Get(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Insert."""
|
| +class BucketAccessControlsInsert(apitools_base_cli.NewCmd):
|
| + """Command wrapping bucketAccessControls.Insert."""
|
|
|
| - usage = """defaultObjectAccessControls_insert <bucket>"""
|
| + usage = """bucketAccessControls_insert <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsInsert, self).__init__(name, fv)
|
| + super(BucketAccessControlsInsert, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'domain',
|
| None,
|
| @@ -251,25 +260,15 @@ class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| u'HTTP 1.1 Entity tag for the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'The content generation of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| 'id',
|
| None,
|
| u'The ID of the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'kind',
|
| - u'storage#objectAccessControl',
|
| - u'The kind of item this is. For object access control entries, this '
|
| - u'is always storage#objectAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'The name of the object.',
|
| + u'storage#bucketAccessControl',
|
| + u'The kind of item this is. For bucket access control entries, this '
|
| + u'is always storage#bucketAccessControl.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'projectTeam',
|
| @@ -279,7 +278,8 @@ class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| flags.DEFINE_string(
|
| 'role',
|
| None,
|
| - u'The access permission for the entity. Can be READER or OWNER.',
|
| + u'The access permission for the entity. Can be READER, WRITER, or '
|
| + u'OWNER.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'selfLink',
|
| @@ -288,7 +288,7 @@ class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket):
|
| - """Creates a new default object ACL entry on the specified bucket.
|
| + """Creates a new ACL entry on the specified bucket.
|
|
|
| Args:
|
| bucket: The name of the bucket.
|
| @@ -306,18 +306,17 @@ class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| domain-example.com.
|
| entityId: The ID for the entity, if any.
|
| etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - generation: The content generation of the object.
|
| id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For object access control entries, this
|
| - is always storage#objectAccessControl.
|
| - object: The name of the object.
|
| + kind: The kind of item this is. For bucket access control entries, this
|
| + is always storage#bucketAccessControl.
|
| projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER or OWNER.
|
| + role: The access permission for the entity. Can be READER, WRITER, or
|
| + OWNER.
|
| selfLink: The link to this access-control entry.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.ObjectAccessControl(
|
| + request = messages.BucketAccessControl(
|
| bucket=bucket.decode('utf8'),
|
| )
|
| if FLAGS['domain'].present:
|
| @@ -330,78 +329,52 @@ class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| request.entityId = FLAGS.entityId.decode('utf8')
|
| if FLAGS['etag'].present:
|
| request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| if FLAGS['id'].present:
|
| request.id = FLAGS.id.decode('utf8')
|
| if FLAGS['kind'].present:
|
| request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = FLAGS.object.decode('utf8')
|
| if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| + request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| if FLAGS['role'].present:
|
| request.role = FLAGS.role.decode('utf8')
|
| if FLAGS['selfLink'].present:
|
| request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.defaultObjectAccessControls.Insert(
|
| + result = client.bucketAccessControls.Insert(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class DefaultObjectAccessControlsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.List."""
|
| +class BucketAccessControlsList(apitools_base_cli.NewCmd):
|
| + """Command wrapping bucketAccessControls.List."""
|
|
|
| - usage = """defaultObjectAccessControls_list <bucket>"""
|
| + usage = """bucketAccessControls_list <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsList, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"If present, only return default ACL listing if the bucket's current"
|
| - u' metageneration matches this value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"If present, only return default ACL listing if the bucket's current"
|
| - u' metageneration does not match the given value.',
|
| - flag_values=fv)
|
| + super(BucketAccessControlsList, self).__init__(name, fv)
|
|
|
| def RunWithArgs(self, bucket):
|
| - """Retrieves default object ACL entries on the specified bucket.
|
| + """Retrieves ACL entries on the specified bucket.
|
|
|
| Args:
|
| bucket: Name of a bucket.
|
| -
|
| - Flags:
|
| - ifMetagenerationMatch: If present, only return default ACL listing if
|
| - the bucket's current metageneration matches this value.
|
| - ifMetagenerationNotMatch: If present, only return default ACL listing if
|
| - the bucket's current metageneration does not match the given value.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageDefaultObjectAccessControlsListRequest(
|
| + request = messages.StorageBucketAccessControlsListRequest(
|
| bucket=bucket.decode('utf8'),
|
| )
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - result = client.defaultObjectAccessControls.List(
|
| + result = client.bucketAccessControls.List(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Patch."""
|
| +class BucketAccessControlsPatch(apitools_base_cli.NewCmd):
|
| + """Command wrapping bucketAccessControls.Patch."""
|
|
|
| - usage = """defaultObjectAccessControls_patch <bucket> <entity>"""
|
| + usage = """bucketAccessControls_patch <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsPatch, self).__init__(name, fv)
|
| + super(BucketAccessControlsPatch, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'domain',
|
| None,
|
| @@ -423,25 +396,15 @@ class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| u'HTTP 1.1 Entity tag for the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'The content generation of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| 'id',
|
| None,
|
| u'The ID of the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'kind',
|
| - u'storage#objectAccessControl',
|
| - u'The kind of item this is. For object access control entries, this '
|
| - u'is always storage#objectAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'The name of the object.',
|
| + u'storage#bucketAccessControl',
|
| + u'The kind of item this is. For bucket access control entries, this '
|
| + u'is always storage#bucketAccessControl.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'projectTeam',
|
| @@ -451,7 +414,8 @@ class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| flags.DEFINE_string(
|
| 'role',
|
| None,
|
| - u'The access permission for the entity. Can be READER or OWNER.',
|
| + u'The access permission for the entity. Can be READER, WRITER, or '
|
| + u'OWNER.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'selfLink',
|
| @@ -460,8 +424,8 @@ class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket, entity):
|
| - """Updates a default object ACL entry on the specified bucket. This method
|
| - supports patch semantics.
|
| + """Updates an ACL entry on the specified bucket. This method supports
|
| + patch semantics.
|
|
|
| Args:
|
| bucket: The name of the bucket.
|
| @@ -479,18 +443,17 @@ class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| email: The email address associated with the entity, if any.
|
| entityId: The ID for the entity, if any.
|
| etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - generation: The content generation of the object.
|
| id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For object access control entries, this
|
| - is always storage#objectAccessControl.
|
| - object: The name of the object.
|
| + kind: The kind of item this is. For bucket access control entries, this
|
| + is always storage#bucketAccessControl.
|
| projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER or OWNER.
|
| + role: The access permission for the entity. Can be READER, WRITER, or
|
| + OWNER.
|
| selfLink: The link to this access-control entry.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.ObjectAccessControl(
|
| + request = messages.BucketAccessControl(
|
| bucket=bucket.decode('utf8'),
|
| entity=entity.decode('utf8'),
|
| )
|
| @@ -502,32 +465,28 @@ class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| request.entityId = FLAGS.entityId.decode('utf8')
|
| if FLAGS['etag'].present:
|
| request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| if FLAGS['id'].present:
|
| request.id = FLAGS.id.decode('utf8')
|
| if FLAGS['kind'].present:
|
| request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = FLAGS.object.decode('utf8')
|
| if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| + request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| if FLAGS['role'].present:
|
| request.role = FLAGS.role.decode('utf8')
|
| if FLAGS['selfLink'].present:
|
| request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.defaultObjectAccessControls.Patch(
|
| + result = client.bucketAccessControls.Patch(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping defaultObjectAccessControls.Update."""
|
| +class BucketAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| + """Command wrapping bucketAccessControls.Update."""
|
|
|
| - usage = """defaultObjectAccessControls_update <bucket> <entity>"""
|
| + usage = """bucketAccessControls_update <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(DefaultObjectAccessControlsUpdate, self).__init__(name, fv)
|
| + super(BucketAccessControlsUpdate, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'domain',
|
| None,
|
| @@ -549,25 +508,15 @@ class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| u'HTTP 1.1 Entity tag for the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'The content generation of the object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| 'id',
|
| None,
|
| u'The ID of the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'kind',
|
| - u'storage#objectAccessControl',
|
| - u'The kind of item this is. For object access control entries, this '
|
| - u'is always storage#objectAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'object',
|
| - None,
|
| - u'The name of the object.',
|
| + u'storage#bucketAccessControl',
|
| + u'The kind of item this is. For bucket access control entries, this '
|
| + u'is always storage#bucketAccessControl.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'projectTeam',
|
| @@ -577,7 +526,8 @@ class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| flags.DEFINE_string(
|
| 'role',
|
| None,
|
| - u'The access permission for the entity. Can be READER or OWNER.',
|
| + u'The access permission for the entity. Can be READER, WRITER, or '
|
| + u'OWNER.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'selfLink',
|
| @@ -586,7 +536,7 @@ class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket, entity):
|
| - """Updates a default object ACL entry on the specified bucket.
|
| + """Updates an ACL entry on the specified bucket.
|
|
|
| Args:
|
| bucket: The name of the bucket.
|
| @@ -604,18 +554,17 @@ class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| email: The email address associated with the entity, if any.
|
| entityId: The ID for the entity, if any.
|
| etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - generation: The content generation of the object.
|
| id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For object access control entries, this
|
| - is always storage#objectAccessControl.
|
| - object: The name of the object.
|
| + kind: The kind of item this is. For bucket access control entries, this
|
| + is always storage#bucketAccessControl.
|
| projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER or OWNER.
|
| + role: The access permission for the entity. Can be READER, WRITER, or
|
| + OWNER.
|
| selfLink: The link to this access-control entry.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.ObjectAccessControl(
|
| + request = messages.BucketAccessControl(
|
| bucket=bucket.decode('utf8'),
|
| entity=entity.decode('utf8'),
|
| )
|
| @@ -627,481 +576,450 @@ class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| request.entityId = FLAGS.entityId.decode('utf8')
|
| if FLAGS['etag'].present:
|
| request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| if FLAGS['id'].present:
|
| request.id = FLAGS.id.decode('utf8')
|
| if FLAGS['kind'].present:
|
| request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['object'].present:
|
| - request.object = FLAGS.object.decode('utf8')
|
| if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| + request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| if FLAGS['role'].present:
|
| request.role = FLAGS.role.decode('utf8')
|
| if FLAGS['selfLink'].present:
|
| request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.defaultObjectAccessControls.Update(
|
| + result = client.bucketAccessControls.Update(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketAccessControlsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Delete."""
|
| +class BucketsDelete(apitools_base_cli.NewCmd):
|
| + """Command wrapping buckets.Delete."""
|
|
|
| - usage = """bucketAccessControls_delete <bucket> <entity>"""
|
| + usage = """buckets_delete <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketAccessControlsDelete, self).__init__(name, fv)
|
| + super(BucketsDelete, self).__init__(name, fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationMatch',
|
| + None,
|
| + u'If set, only deletes the bucket if its metageneration matches this '
|
| + u'value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationNotMatch',
|
| + None,
|
| + u'If set, only deletes the bucket if its metageneration does not '
|
| + u'match this value.',
|
| + flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Permanently deletes the ACL entry for the specified entity on the
|
| - specified bucket.
|
| + def RunWithArgs(self, bucket):
|
| + """Permanently deletes an empty bucket.
|
|
|
| Args:
|
| bucket: Name of a bucket.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| +
|
| + Flags:
|
| + ifMetagenerationMatch: If set, only deletes the bucket if its
|
| + metageneration matches this value.
|
| + ifMetagenerationNotMatch: If set, only deletes the bucket if its
|
| + metageneration does not match this value.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketAccessControlsDeleteRequest(
|
| + request = messages.StorageBucketsDeleteRequest(
|
| bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| )
|
| - result = client.bucketAccessControls.Delete(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class BucketAccessControlsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Get."""
|
| -
|
| - usage = """bucketAccessControls_get <bucket> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(BucketAccessControlsGet, self).__init__(name, fv)
|
| -
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Returns the ACL entry for the specified entity on the specified bucket.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketAccessControlsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - result = client.bucketAccessControls.Get(
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + result = client.buckets.Delete(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketAccessControlsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Insert."""
|
| +class BucketsGet(apitools_base_cli.NewCmd):
|
| + """Command wrapping buckets.Get."""
|
|
|
| - usage = """bucketAccessControls_insert <bucket>"""
|
| + usage = """buckets_get <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketAccessControlsInsert, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entity',
|
| - None,
|
| - u'The entity holding the permission, in one of the following forms: '
|
| - u'- user-userId - user-email - group-groupId - group-email - '
|
| - u'domain-domain - project-team-projectId - allUsers - '
|
| - u'allAuthenticatedUsers Examples: - The user liz@example.com would '
|
| - u'be user-liz@example.com. - The group example@googlegroups.com '
|
| - u'would be group-example@googlegroups.com. - To refer to all members'
|
| - u' of the Google Apps for Business domain example.com, the entity '
|
| - u'would be domain-example.com.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'entityId',
|
| - None,
|
| - u'The ID for the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#bucketAccessControl',
|
| - u'The kind of item this is. For bucket access control entries, this '
|
| - u'is always storage#bucketAccessControl.',
|
| - flag_values=fv)
|
| + super(BucketsGet, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'projectTeam',
|
| + 'ifMetagenerationMatch',
|
| None,
|
| - u'The project team associated with the entity, if any.',
|
| + u'Makes the return of the bucket metadata conditional on whether the '
|
| + u"bucket's current metageneration matches the given value.",
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'role',
|
| + 'ifMetagenerationNotMatch',
|
| None,
|
| - u'The access permission for the entity. Can be READER, WRITER, or '
|
| - u'OWNER.',
|
| + u'Makes the return of the bucket metadata conditional on whether the '
|
| + u"bucket's current metageneration does not match the given value.",
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to noAcl.',
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket):
|
| - """Creates a new ACL entry on the specified bucket.
|
| + """Returns metadata for the specified bucket.
|
|
|
| Args:
|
| - bucket: The name of the bucket.
|
| + bucket: Name of a bucket.
|
|
|
| Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For bucket access control entries, this
|
| - is always storage#bucketAccessControl.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER, WRITER, or
|
| - OWNER.
|
| - selfLink: The link to this access-control entry.
|
| + ifMetagenerationMatch: Makes the return of the bucket metadata
|
| + conditional on whether the bucket's current metageneration matches the
|
| + given value.
|
| + ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| + conditional on whether the bucket's current metageneration does not
|
| + match the given value.
|
| + projection: Set of properties to return. Defaults to noAcl.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.BucketAccessControl(
|
| + request = messages.StorageBucketsGetRequest(
|
| bucket=bucket.decode('utf8'),
|
| )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entity'].present:
|
| - request.entity = FLAGS.entity.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.bucketAccessControls.Insert(
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageBucketsGetRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + result = client.buckets.Get(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketAccessControlsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.List."""
|
| +class BucketsInsert(apitools_base_cli.NewCmd):
|
| + """Command wrapping buckets.Insert."""
|
|
|
| - usage = """bucketAccessControls_list <bucket>"""
|
| + usage = """buckets_insert <project>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketAccessControlsList, self).__init__(name, fv)
|
| + super(BucketsInsert, self).__init__(name, fv)
|
| + flags.DEFINE_string(
|
| + 'bucket',
|
| + None,
|
| + u'A Bucket resource to be passed as the request body.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'predefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| + u'Apply a predefined set of access controls to this bucket.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'predefinedDefaultObjectAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of default object access controls to this '
|
| + u'bucket.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to noAcl, unless the bucket '
|
| + u'resource specifies acl or defaultObjectAcl properties, when it '
|
| + u'defaults to full.',
|
| + flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket):
|
| - """Retrieves ACL entries on the specified bucket.
|
| + def RunWithArgs(self, project):
|
| + """Creates a new bucket.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + project: A valid API project identifier.
|
| +
|
| + Flags:
|
| + bucket: A Bucket resource to be passed as the request body.
|
| + predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| + predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| + access controls to this bucket.
|
| + projection: Set of properties to return. Defaults to noAcl, unless the
|
| + bucket resource specifies acl or defaultObjectAcl properties, when it
|
| + defaults to full.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketAccessControlsListRequest(
|
| - bucket=bucket.decode('utf8'),
|
| + request = messages.StorageBucketsInsertRequest(
|
| + project=project.decode('utf8'),
|
| )
|
| - result = client.bucketAccessControls.List(
|
| + if FLAGS['bucket'].present:
|
| + request.bucket = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucket)
|
| + if FLAGS['predefinedAcl'].present:
|
| + request.predefinedAcl = messages.StorageBucketsInsertRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| + if FLAGS['predefinedDefaultObjectAcl'].present:
|
| + request.predefinedDefaultObjectAcl = messages.StorageBucketsInsertRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageBucketsInsertRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + result = client.buckets.Insert(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketAccessControlsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Patch."""
|
| +class BucketsList(apitools_base_cli.NewCmd):
|
| + """Command wrapping buckets.List."""
|
|
|
| - usage = """bucketAccessControls_patch <bucket> <entity>"""
|
| + usage = """buckets_list <project>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketAccessControlsPatch, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| + super(BucketsList, self).__init__(name, fv)
|
| + flags.DEFINE_integer(
|
| + 'maxResults',
|
| None,
|
| - u'The domain associated with the entity, if any.',
|
| + u'Maximum number of buckets to return.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'email',
|
| + 'pageToken',
|
| None,
|
| - u'The email address associated with the entity, if any.',
|
| + u'A previously-returned page token representing part of the larger '
|
| + u'set of results to view.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'entityId',
|
| + 'prefix',
|
| None,
|
| - u'The ID for the entity, if any.',
|
| + u'Filter results to buckets whose names begin with this prefix.',
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'etag',
|
| - None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'id',
|
| - None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#bucketAccessControl',
|
| - u'The kind of item this is. For bucket access control entries, this '
|
| - u'is always storage#bucketAccessControl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER, WRITER, or '
|
| - u'OWNER.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to noAcl.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Updates an ACL entry on the specified bucket. This method supports
|
| - patch semantics.
|
| + def RunWithArgs(self, project):
|
| + """Retrieves a list of buckets for a given project.
|
|
|
| Args:
|
| - bucket: The name of the bucket.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| + project: A valid API project identifier.
|
|
|
| Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For bucket access control entries, this
|
| - is always storage#bucketAccessControl.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER, WRITER, or
|
| - OWNER.
|
| - selfLink: The link to this access-control entry.
|
| + maxResults: Maximum number of buckets to return.
|
| + pageToken: A previously-returned page token representing part of the
|
| + larger set of results to view.
|
| + prefix: Filter results to buckets whose names begin with this prefix.
|
| + projection: Set of properties to return. Defaults to noAcl.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.BucketAccessControl(
|
| - bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| + request = messages.StorageBucketsListRequest(
|
| + project=project.decode('utf8'),
|
| )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.bucketAccessControls.Patch(
|
| + if FLAGS['maxResults'].present:
|
| + request.maxResults = FLAGS.maxResults
|
| + if FLAGS['pageToken'].present:
|
| + request.pageToken = FLAGS.pageToken.decode('utf8')
|
| + if FLAGS['prefix'].present:
|
| + request.prefix = FLAGS.prefix.decode('utf8')
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageBucketsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + result = client.buckets.List(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping bucketAccessControls.Update."""
|
| +class BucketsPatch(apitools_base_cli.NewCmd):
|
| + """Command wrapping buckets.Patch."""
|
|
|
| - usage = """bucketAccessControls_update <bucket> <entity>"""
|
| + usage = """buckets_patch <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketAccessControlsUpdate, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'domain',
|
| - None,
|
| - u'The domain associated with the entity, if any.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'email',
|
| - None,
|
| - u'The email address associated with the entity, if any.',
|
| - flag_values=fv)
|
| + super(BucketsPatch, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'entityId',
|
| + 'bucketResource',
|
| None,
|
| - u'The ID for the entity, if any.',
|
| + u'A Bucket resource to be passed as the request body.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'etag',
|
| + 'ifMetagenerationMatch',
|
| None,
|
| - u'HTTP 1.1 Entity tag for the access-control entry.',
|
| + u'Makes the return of the bucket metadata conditional on whether the '
|
| + u"bucket's current metageneration matches the given value.",
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'id',
|
| + 'ifMetagenerationNotMatch',
|
| None,
|
| - u'The ID of the access-control entry.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'storage#bucketAccessControl',
|
| - u'The kind of item this is. For bucket access control entries, this '
|
| - u'is always storage#bucketAccessControl.',
|
| + u'Makes the return of the bucket metadata conditional on whether the '
|
| + u"bucket's current metageneration does not match the given value.",
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'projectTeam',
|
| - None,
|
| - u'The project team associated with the entity, if any.',
|
| + flags.DEFINE_enum(
|
| + 'predefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| + u'Apply a predefined set of access controls to this bucket.',
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'role',
|
| - None,
|
| - u'The access permission for the entity. Can be READER, WRITER, or '
|
| - u'OWNER.',
|
| + flags.DEFINE_enum(
|
| + 'predefinedDefaultObjectAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of default object access controls to this '
|
| + u'bucket.',
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'selfLink',
|
| - None,
|
| - u'The link to this access-control entry.',
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to full.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, entity):
|
| - """Updates an ACL entry on the specified bucket.
|
| + def RunWithArgs(self, bucket):
|
| + """Updates a bucket. This method supports patch semantics.
|
|
|
| Args:
|
| - bucket: The name of the bucket.
|
| - entity: The entity holding the permission, in one of the following
|
| - forms: - user-userId - user-email - group-groupId - group-email -
|
| - domain-domain - project-team-projectId - allUsers -
|
| - allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| - user-liz@example.com. - The group example@googlegroups.com would be
|
| - group-example@googlegroups.com. - To refer to all members of the
|
| - Google Apps for Business domain example.com, the entity would be
|
| - domain-example.com.
|
| + bucket: Name of a bucket.
|
|
|
| Flags:
|
| - domain: The domain associated with the entity, if any.
|
| - email: The email address associated with the entity, if any.
|
| - entityId: The ID for the entity, if any.
|
| - etag: HTTP 1.1 Entity tag for the access-control entry.
|
| - id: The ID of the access-control entry.
|
| - kind: The kind of item this is. For bucket access control entries, this
|
| - is always storage#bucketAccessControl.
|
| - projectTeam: The project team associated with the entity, if any.
|
| - role: The access permission for the entity. Can be READER, WRITER, or
|
| - OWNER.
|
| - selfLink: The link to this access-control entry.
|
| + bucketResource: A Bucket resource to be passed as the request body.
|
| + ifMetagenerationMatch: Makes the return of the bucket metadata
|
| + conditional on whether the bucket's current metageneration matches the
|
| + given value.
|
| + ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| + conditional on whether the bucket's current metageneration does not
|
| + match the given value.
|
| + predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| + predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| + access controls to this bucket.
|
| + projection: Set of properties to return. Defaults to full.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.BucketAccessControl(
|
| + request = messages.StorageBucketsPatchRequest(
|
| bucket=bucket.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| )
|
| - if FLAGS['domain'].present:
|
| - request.domain = FLAGS.domain.decode('utf8')
|
| - if FLAGS['email'].present:
|
| - request.email = FLAGS.email.decode('utf8')
|
| - if FLAGS['entityId'].present:
|
| - request.entityId = FLAGS.entityId.decode('utf8')
|
| - if FLAGS['etag'].present:
|
| - request.etag = FLAGS.etag.decode('utf8')
|
| - if FLAGS['id'].present:
|
| - request.id = FLAGS.id.decode('utf8')
|
| - if FLAGS['kind'].present:
|
| - request.kind = FLAGS.kind.decode('utf8')
|
| - if FLAGS['projectTeam'].present:
|
| - request.projectTeam = apitools_base.JsonToMessage(messages.BucketAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| - if FLAGS['role'].present:
|
| - request.role = FLAGS.role.decode('utf8')
|
| - if FLAGS['selfLink'].present:
|
| - request.selfLink = FLAGS.selfLink.decode('utf8')
|
| - result = client.bucketAccessControls.Update(
|
| + if FLAGS['bucketResource'].present:
|
| + request.bucketResource = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucketResource)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['predefinedAcl'].present:
|
| + request.predefinedAcl = messages.StorageBucketsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| + if FLAGS['predefinedDefaultObjectAcl'].present:
|
| + request.predefinedDefaultObjectAcl = messages.StorageBucketsPatchRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageBucketsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + result = client.buckets.Patch(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ChannelsStop(apitools_base_cli.NewCmd):
|
| - """Command wrapping channels.Stop."""
|
| +class BucketsUpdate(apitools_base_cli.NewCmd):
|
| + """Command wrapping buckets.Update."""
|
|
|
| - usage = """channels_stop"""
|
| + usage = """buckets_update <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ChannelsStop, self).__init__(name, fv)
|
| + super(BucketsUpdate, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'address',
|
| + 'bucketResource',
|
| None,
|
| - u'The address where notifications are delivered for this channel.',
|
| + u'A Bucket resource to be passed as the request body.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'expiration',
|
| + 'ifMetagenerationMatch',
|
| None,
|
| - u'Date and time of notification channel expiration, expressed as a '
|
| - u'Unix timestamp, in milliseconds. Optional.',
|
| + u'Makes the return of the bucket metadata conditional on whether the '
|
| + u"bucket's current metageneration matches the given value.",
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'id',
|
| + 'ifMetagenerationNotMatch',
|
| None,
|
| - u'A UUID or similar unique string that identifies this channel.',
|
| + u'Makes the return of the bucket metadata conditional on whether the '
|
| + u"bucket's current metageneration does not match the given value.",
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'kind',
|
| - u'api#channel',
|
| - u'Identifies this as a notification channel used to watch for changes'
|
| - u' to a resource. Value: the fixed string "api#channel".',
|
| + flags.DEFINE_enum(
|
| + 'predefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| + u'Apply a predefined set of access controls to this bucket.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'predefinedDefaultObjectAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of default object access controls to this '
|
| + u'bucket.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to full.',
|
| + flag_values=fv)
|
| +
|
| + def RunWithArgs(self, bucket):
|
| + """Updates a bucket.
|
| +
|
| + Args:
|
| + bucket: Name of a bucket.
|
| +
|
| + Flags:
|
| + bucketResource: A Bucket resource to be passed as the request body.
|
| + ifMetagenerationMatch: Makes the return of the bucket metadata
|
| + conditional on whether the bucket's current metageneration matches the
|
| + given value.
|
| + ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| + conditional on whether the bucket's current metageneration does not
|
| + match the given value.
|
| + predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| + predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| + access controls to this bucket.
|
| + projection: Set of properties to return. Defaults to full.
|
| + """
|
| + client = GetClientFromFlags()
|
| + global_params = GetGlobalParamsFromFlags()
|
| + request = messages.StorageBucketsUpdateRequest(
|
| + bucket=bucket.decode('utf8'),
|
| + )
|
| + if FLAGS['bucketResource'].present:
|
| + request.bucketResource = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucketResource)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['predefinedAcl'].present:
|
| + request.predefinedAcl = messages.StorageBucketsUpdateRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| + if FLAGS['predefinedDefaultObjectAcl'].present:
|
| + request.predefinedDefaultObjectAcl = messages.StorageBucketsUpdateRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageBucketsUpdateRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + result = client.buckets.Update(
|
| + request, global_params=global_params)
|
| + print apitools_base_cli.FormatOutput(result)
|
| +
|
| +
|
| +class ChannelsStop(apitools_base_cli.NewCmd):
|
| + """Command wrapping channels.Stop."""
|
| +
|
| + usage = """channels_stop"""
|
| +
|
| + def __init__(self, name, fv):
|
| + super(ChannelsStop, self).__init__(name, fv)
|
| + flags.DEFINE_string(
|
| + 'address',
|
| + None,
|
| + u'The address where notifications are delivered for this channel.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'expiration',
|
| + None,
|
| + u'Date and time of notification channel expiration, expressed as a '
|
| + u'Unix timestamp, in milliseconds. Optional.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'id',
|
| + None,
|
| + u'A UUID or similar unique string that identifies this channel.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'kind',
|
| + u'api#channel',
|
| + u'Identifies this as a notification channel used to watch for changes'
|
| + u' to a resource. Value: the fixed string "api#channel".',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'params',
|
| @@ -1187,804 +1105,591 @@ class ChannelsStop(apitools_base_cli.NewCmd):
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsCompose(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Compose."""
|
| +class DefaultObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| + """Command wrapping defaultObjectAccessControls.Delete."""
|
|
|
| - usage = """objects_compose <destinationBucket> <destinationObject>"""
|
| + usage = """defaultObjectAccessControls_delete <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsCompose, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'composeRequest',
|
| - None,
|
| - u'A ComposeRequest resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'destinationPredefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to the destination '
|
| - u'object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| - flag_values=fv)
|
| + super(DefaultObjectAccessControlsDelete, self).__init__(name, fv)
|
|
|
| - def RunWithArgs(self, destinationBucket, destinationObject):
|
| - """Concatenates a list of existing objects into a new object in the same
|
| - bucket.
|
| + def RunWithArgs(self, bucket, entity):
|
| + """Permanently deletes the default object ACL entry for the specified
|
| + entity on the specified bucket.
|
|
|
| Args:
|
| - destinationBucket: Name of the bucket in which to store the new object.
|
| - destinationObject: Name of the new object.
|
| + bucket: Name of a bucket.
|
| + entity: The entity holding the permission. Can be user-userId, user-
|
| + emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| + allAuthenticatedUsers.
|
| + """
|
| + client = GetClientFromFlags()
|
| + global_params = GetGlobalParamsFromFlags()
|
| + request = messages.StorageDefaultObjectAccessControlsDeleteRequest(
|
| + bucket=bucket.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| + )
|
| + result = client.defaultObjectAccessControls.Delete(
|
| + request, global_params=global_params)
|
| + print apitools_base_cli.FormatOutput(result)
|
|
|
| - Flags:
|
| - composeRequest: A ComposeRequest resource to be passed as the request
|
| - body.
|
| - destinationPredefinedAcl: Apply a predefined set of access controls to
|
| - the destination object.
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| +
|
| +class DefaultObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| + """Command wrapping defaultObjectAccessControls.Get."""
|
| +
|
| + usage = """defaultObjectAccessControls_get <bucket> <entity>"""
|
| +
|
| + def __init__(self, name, fv):
|
| + super(DefaultObjectAccessControlsGet, self).__init__(name, fv)
|
| +
|
| + def RunWithArgs(self, bucket, entity):
|
| + """Returns the default object ACL entry for the specified entity on the
|
| + specified bucket.
|
| +
|
| + Args:
|
| + bucket: Name of a bucket.
|
| + entity: The entity holding the permission. Can be user-userId, user-
|
| + emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| + allAuthenticatedUsers.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsComposeRequest(
|
| - destinationBucket=destinationBucket.decode('utf8'),
|
| - destinationObject=destinationObject.decode('utf8'),
|
| + request = messages.StorageDefaultObjectAccessControlsGetRequest(
|
| + bucket=bucket.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| )
|
| - if FLAGS['composeRequest'].present:
|
| - request.composeRequest = apitools_base.JsonToMessage(messages.ComposeRequest, FLAGS.composeRequest)
|
| - if FLAGS['destinationPredefinedAcl'].present:
|
| - request.destinationPredefinedAcl = messages.StorageObjectsComposeRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Compose(
|
| - request, global_params=global_params, download=download)
|
| + result = client.defaultObjectAccessControls.Get(
|
| + request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsCopy(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Copy."""
|
| +class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| + """Command wrapping defaultObjectAccessControls.Insert."""
|
|
|
| - usage = """objects_copy <sourceBucket> <sourceObject> <destinationBucket> <destinationObject>"""
|
| + usage = """defaultObjectAccessControls_insert <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsCopy, self).__init__(name, fv)
|
| - flags.DEFINE_enum(
|
| - 'destinationPredefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to the destination '
|
| - u'object.',
|
| - flag_values=fv)
|
| + super(DefaultObjectAccessControlsInsert, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| + 'domain',
|
| None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current generation matches the given value.',
|
| + u'The domain associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| + 'email',
|
| None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current generation does not match the given value.',
|
| + u'The email address associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| + 'entity',
|
| None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current metageneration matches the given value.',
|
| + u'The entity holding the permission, in one of the following forms: '
|
| + u'- user-userId - user-email - group-groupId - group-email - '
|
| + u'domain-domain - project-team-projectId - allUsers - '
|
| + u'allAuthenticatedUsers Examples: - The user liz@example.com would '
|
| + u'be user-liz@example.com. - The group example@googlegroups.com '
|
| + u'would be group-example@googlegroups.com. - To refer to all members'
|
| + u' of the Google Apps for Business domain example.com, the entity '
|
| + u'would be domain-example.com.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| + 'entityId',
|
| None,
|
| - u"Makes the operation conditional on whether the destination object's"
|
| - u' current metageneration does not match the given value.',
|
| + u'The ID for the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifSourceGenerationMatch',
|
| + 'etag',
|
| None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'generation matches the given value.',
|
| + u'HTTP 1.1 Entity tag for the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifSourceGenerationNotMatch',
|
| + 'generation',
|
| None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'generation does not match the given value.',
|
| + u'The content generation of the object.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifSourceMetagenerationMatch',
|
| + 'id',
|
| None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'current metageneration matches the given value.',
|
| + u'The ID of the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifSourceMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the source object's "
|
| - u'current metageneration does not match the given value.',
|
| + 'kind',
|
| + u'storage#objectAccessControl',
|
| + u'The kind of item this is. For object access control entries, this '
|
| + u'is always storage#objectAccessControl.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'object',
|
| None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl, unless the object '
|
| - u'resource specifies the acl property, when it defaults to full.',
|
| + u'The name of the object.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'sourceGeneration',
|
| + 'projectTeam',
|
| None,
|
| - u'If present, selects a specific revision of the source object (as '
|
| - u'opposed to the latest version, the default).',
|
| + u'The project team associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| + 'role',
|
| + None,
|
| + u'The access permission for the entity. Can be READER or OWNER.',
|
| flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| + flags.DEFINE_string(
|
| + 'selfLink',
|
| + None,
|
| + u'The link to this access-control entry.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, sourceBucket, sourceObject, destinationBucket, destinationObject):
|
| - """Copies an object to a specified location. Optionally overrides
|
| - metadata.
|
| + def RunWithArgs(self, bucket):
|
| + """Creates a new default object ACL entry on the specified bucket.
|
|
|
| Args:
|
| - sourceBucket: Name of the bucket in which to find the source object.
|
| - sourceObject: Name of the source object.
|
| - destinationBucket: Name of the bucket in which to store the new object.
|
| - Overrides the provided object metadata's bucket value, if any.
|
| - destinationObject: Name of the new object. Required when the object
|
| - metadata is not otherwise provided. Overrides the object metadata's
|
| - name value, if any.
|
| + bucket: The name of the bucket.
|
|
|
| Flags:
|
| - destinationPredefinedAcl: Apply a predefined set of access controls to
|
| - the destination object.
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - destination object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - destination object's current generation does not match the given
|
| - value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - destination object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - destination object's current metageneration does not match the given
|
| - value.
|
| - ifSourceGenerationMatch: Makes the operation conditional on whether the
|
| - source object's generation matches the given value.
|
| - ifSourceGenerationNotMatch: Makes the operation conditional on whether
|
| - the source object's generation does not match the given value.
|
| - ifSourceMetagenerationMatch: Makes the operation conditional on whether
|
| - the source object's current metageneration matches the given value.
|
| - ifSourceMetagenerationNotMatch: Makes the operation conditional on
|
| - whether the source object's current metageneration does not match the
|
| - given value.
|
| - object: A Object resource to be passed as the request body.
|
| - projection: Set of properties to return. Defaults to noAcl, unless the
|
| - object resource specifies the acl property, when it defaults to full.
|
| - sourceGeneration: If present, selects a specific revision of the source
|
| - object (as opposed to the latest version, the default).
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| + domain: The domain associated with the entity, if any.
|
| + email: The email address associated with the entity, if any.
|
| + entity: The entity holding the permission, in one of the following
|
| + forms: - user-userId - user-email - group-groupId - group-email -
|
| + domain-domain - project-team-projectId - allUsers -
|
| + allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| + user-liz@example.com. - The group example@googlegroups.com would be
|
| + group-example@googlegroups.com. - To refer to all members of the
|
| + Google Apps for Business domain example.com, the entity would be
|
| + domain-example.com.
|
| + entityId: The ID for the entity, if any.
|
| + etag: HTTP 1.1 Entity tag for the access-control entry.
|
| + generation: The content generation of the object.
|
| + id: The ID of the access-control entry.
|
| + kind: The kind of item this is. For object access control entries, this
|
| + is always storage#objectAccessControl.
|
| + object: The name of the object.
|
| + projectTeam: The project team associated with the entity, if any.
|
| + role: The access permission for the entity. Can be READER or OWNER.
|
| + selfLink: The link to this access-control entry.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsCopyRequest(
|
| - sourceBucket=sourceBucket.decode('utf8'),
|
| - sourceObject=sourceObject.decode('utf8'),
|
| - destinationBucket=destinationBucket.decode('utf8'),
|
| - destinationObject=destinationObject.decode('utf8'),
|
| + request = messages.ObjectAccessControl(
|
| + bucket=bucket.decode('utf8'),
|
| )
|
| - if FLAGS['destinationPredefinedAcl'].present:
|
| - request.destinationPredefinedAcl = messages.StorageObjectsCopyRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['ifSourceGenerationMatch'].present:
|
| - request.ifSourceGenerationMatch = int(FLAGS.ifSourceGenerationMatch)
|
| - if FLAGS['ifSourceGenerationNotMatch'].present:
|
| - request.ifSourceGenerationNotMatch = int(FLAGS.ifSourceGenerationNotMatch)
|
| - if FLAGS['ifSourceMetagenerationMatch'].present:
|
| - request.ifSourceMetagenerationMatch = int(FLAGS.ifSourceMetagenerationMatch)
|
| - if FLAGS['ifSourceMetagenerationNotMatch'].present:
|
| - request.ifSourceMetagenerationNotMatch = int(FLAGS.ifSourceMetagenerationNotMatch)
|
| + if FLAGS['domain'].present:
|
| + request.domain = FLAGS.domain.decode('utf8')
|
| + if FLAGS['email'].present:
|
| + request.email = FLAGS.email.decode('utf8')
|
| + if FLAGS['entity'].present:
|
| + request.entity = FLAGS.entity.decode('utf8')
|
| + if FLAGS['entityId'].present:
|
| + request.entityId = FLAGS.entityId.decode('utf8')
|
| + if FLAGS['etag'].present:
|
| + request.etag = FLAGS.etag.decode('utf8')
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + if FLAGS['id'].present:
|
| + request.id = FLAGS.id.decode('utf8')
|
| + if FLAGS['kind'].present:
|
| + request.kind = FLAGS.kind.decode('utf8')
|
| if FLAGS['object'].present:
|
| - request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsCopyRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - if FLAGS['sourceGeneration'].present:
|
| - request.sourceGeneration = int(FLAGS.sourceGeneration)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Copy(
|
| - request, global_params=global_params, download=download)
|
| + request.object = FLAGS.object.decode('utf8')
|
| + if FLAGS['projectTeam'].present:
|
| + request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| + if FLAGS['role'].present:
|
| + request.role = FLAGS.role.decode('utf8')
|
| + if FLAGS['selfLink'].present:
|
| + request.selfLink = FLAGS.selfLink.decode('utf8')
|
| + result = client.defaultObjectAccessControls.Insert(
|
| + request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Delete."""
|
| +class DefaultObjectAccessControlsList(apitools_base_cli.NewCmd):
|
| + """Command wrapping defaultObjectAccessControls.List."""
|
|
|
| - usage = """objects_delete <bucket> <object>"""
|
| + usage = """defaultObjectAccessControls_list <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsDelete, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'generation',
|
| - None,
|
| - u'If present, permanently deletes a specific revision of this object '
|
| - u'(as opposed to the latest version, the default).',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| + super(DefaultObjectAccessControlsList, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'ifMetagenerationMatch',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| + u"If present, only return default ACL listing if the bucket's current"
|
| + u' metageneration matches this value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'ifMetagenerationNotMatch',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| + u"If present, only return default ACL listing if the bucket's current"
|
| + u' metageneration does not match the given value.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, object):
|
| - """Deletes an object and its metadata. Deletions are permanent if
|
| - versioning is not enabled for the bucket, or if the generation parameter
|
| - is used.
|
| + def RunWithArgs(self, bucket):
|
| + """Retrieves default object ACL entries on the specified bucket.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| - object: Name of the object.
|
| + bucket: Name of a bucket.
|
|
|
| Flags:
|
| - generation: If present, permanently deletes a specific revision of this
|
| - object (as opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| + ifMetagenerationMatch: If present, only return default ACL listing if
|
| + the bucket's current metageneration matches this value.
|
| + ifMetagenerationNotMatch: If present, only return default ACL listing if
|
| + the bucket's current metageneration does not match the given value.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsDeleteRequest(
|
| + request = messages.StorageDefaultObjectAccessControlsListRequest(
|
| bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| if FLAGS['ifMetagenerationMatch'].present:
|
| request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| if FLAGS['ifMetagenerationNotMatch'].present:
|
| request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - result = client.objects.Delete(
|
| + result = client.defaultObjectAccessControls.List(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Get."""
|
| +class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| + """Command wrapping defaultObjectAccessControls.Patch."""
|
|
|
| - usage = """objects_get <bucket> <object>"""
|
| + usage = """defaultObjectAccessControls_patch <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsGet, self).__init__(name, fv)
|
| + super(DefaultObjectAccessControlsPatch, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'generation',
|
| + 'domain',
|
| None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| + u'The domain associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| + 'email',
|
| None,
|
| - u"Makes the operation conditional on whether the object's generation "
|
| - u'matches the given value.',
|
| + u'The email address associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| + 'entityId',
|
| None,
|
| - u"Makes the operation conditional on whether the object's generation "
|
| - u'does not match the given value.',
|
| + u'The ID for the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| + 'etag',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| + u'HTTP 1.1 Entity tag for the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| + 'generation',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| + u'The content generation of the object.',
|
| flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| + flags.DEFINE_string(
|
| + 'id',
|
| + None,
|
| + u'The ID of the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| + 'kind',
|
| + u'storage#objectAccessControl',
|
| + u'The kind of item this is. For object access control entries, this '
|
| + u'is always storage#objectAccessControl.',
|
| flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| + flags.DEFINE_string(
|
| + 'object',
|
| + None,
|
| + u'The name of the object.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'projectTeam',
|
| + None,
|
| + u'The project team associated with the entity, if any.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'role',
|
| + None,
|
| + u'The access permission for the entity. Can be READER or OWNER.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'selfLink',
|
| + None,
|
| + u'The link to this access-control entry.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, object):
|
| - """Retrieves an object or its metadata.
|
| + def RunWithArgs(self, bucket, entity):
|
| + """Updates a default object ACL entry on the specified bucket. This method
|
| + supports patch semantics.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| - object: Name of the object.
|
| + bucket: The name of the bucket.
|
| + entity: The entity holding the permission, in one of the following
|
| + forms: - user-userId - user-email - group-groupId - group-email -
|
| + domain-domain - project-team-projectId - allUsers -
|
| + allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| + user-liz@example.com. - The group example@googlegroups.com would be
|
| + group-example@googlegroups.com. - To refer to all members of the
|
| + Google Apps for Business domain example.com, the entity would be
|
| + domain-example.com.
|
|
|
| Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| + domain: The domain associated with the entity, if any.
|
| + email: The email address associated with the entity, if any.
|
| + entityId: The ID for the entity, if any.
|
| + etag: HTTP 1.1 Entity tag for the access-control entry.
|
| + generation: The content generation of the object.
|
| + id: The ID of the access-control entry.
|
| + kind: The kind of item this is. For object access control entries, this
|
| + is always storage#objectAccessControl.
|
| + object: The name of the object.
|
| + projectTeam: The project team associated with the entity, if any.
|
| + role: The access permission for the entity. Can be READER or OWNER.
|
| + selfLink: The link to this access-control entry.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsGetRequest(
|
| + request = messages.ObjectAccessControl(
|
| bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| )
|
| + if FLAGS['domain'].present:
|
| + request.domain = FLAGS.domain.decode('utf8')
|
| + if FLAGS['email'].present:
|
| + request.email = FLAGS.email.decode('utf8')
|
| + if FLAGS['entityId'].present:
|
| + request.entityId = FLAGS.entityId.decode('utf8')
|
| + if FLAGS['etag'].present:
|
| + request.etag = FLAGS.etag.decode('utf8')
|
| if FLAGS['generation'].present:
|
| request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsGetRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Get(
|
| - request, global_params=global_params, download=download)
|
| + if FLAGS['id'].present:
|
| + request.id = FLAGS.id.decode('utf8')
|
| + if FLAGS['kind'].present:
|
| + request.kind = FLAGS.kind.decode('utf8')
|
| + if FLAGS['object'].present:
|
| + request.object = FLAGS.object.decode('utf8')
|
| + if FLAGS['projectTeam'].present:
|
| + request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| + if FLAGS['role'].present:
|
| + request.role = FLAGS.role.decode('utf8')
|
| + if FLAGS['selfLink'].present:
|
| + request.selfLink = FLAGS.selfLink.decode('utf8')
|
| + result = client.defaultObjectAccessControls.Patch(
|
| + request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Insert."""
|
| +class DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| + """Command wrapping defaultObjectAccessControls.Update."""
|
|
|
| - usage = """objects_insert <bucket>"""
|
| + usage = """defaultObjectAccessControls_update <bucket> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsInsert, self).__init__(name, fv)
|
| + super(DefaultObjectAccessControlsUpdate, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'contentEncoding',
|
| + 'domain',
|
| None,
|
| - u'If set, sets the contentEncoding property of the final object to '
|
| - u'this value. Setting this parameter is equivalent to setting the '
|
| - u'contentEncoding metadata property. This can be useful when '
|
| - u'uploading an object with uploadType=media to indicate the encoding '
|
| - u'of the content being uploaded.',
|
| + u'The domain associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| + 'email',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| + u'The email address associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| + 'entityId',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| + u'The ID for the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| + 'etag',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| + u'HTTP 1.1 Entity tag for the access-control entry.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| + 'generation',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| + u'The content generation of the object.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'name',
|
| + 'id',
|
| None,
|
| - u'Name of the object. Required when the object metadata is not '
|
| - u"otherwise provided. Overrides the object metadata's name value, if "
|
| - u'any.',
|
| + u'The ID of the access-control entry.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'kind',
|
| + u'storage#objectAccessControl',
|
| + u'The kind of item this is. For object access control entries, this '
|
| + u'is always storage#objectAccessControl.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'object',
|
| None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to this object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl, unless the object '
|
| - u'resource specifies the acl property, when it defaults to full.',
|
| + u'The name of the object.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'upload_filename',
|
| - '',
|
| - 'Filename to use for upload.',
|
| + 'projectTeam',
|
| + None,
|
| + u'The project team associated with the entity, if any.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'upload_mime_type',
|
| - '',
|
| - 'MIME type to use for the upload. Only needed if the extension on '
|
| - '--upload_filename does not determine the correct (or any) MIME '
|
| - 'type.',
|
| + 'role',
|
| + None,
|
| + u'The access permission for the entity. Can be READER or OWNER.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| + 'selfLink',
|
| + None,
|
| + u'The link to this access-control entry.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket):
|
| - """Stores a new object and metadata.
|
| + def RunWithArgs(self, bucket, entity):
|
| + """Updates a default object ACL entry on the specified bucket.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which to store the new object. Overrides
|
| - the provided object metadata's bucket value, if any.
|
| + bucket: The name of the bucket.
|
| + entity: The entity holding the permission, in one of the following
|
| + forms: - user-userId - user-email - group-groupId - group-email -
|
| + domain-domain - project-team-projectId - allUsers -
|
| + allAuthenticatedUsers Examples: - The user liz@example.com would be
|
| + user-liz@example.com. - The group example@googlegroups.com would be
|
| + group-example@googlegroups.com. - To refer to all members of the
|
| + Google Apps for Business domain example.com, the entity would be
|
| + domain-example.com.
|
|
|
| Flags:
|
| - contentEncoding: If set, sets the contentEncoding property of the final
|
| - object to this value. Setting this parameter is equivalent to setting
|
| - the contentEncoding metadata property. This can be useful when
|
| - uploading an object with uploadType=media to indicate the encoding of
|
| - the content being uploaded.
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - name: Name of the object. Required when the object metadata is not
|
| - otherwise provided. Overrides the object metadata's name value, if
|
| - any.
|
| - object: A Object resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this object.
|
| - projection: Set of properties to return. Defaults to noAcl, unless the
|
| - object resource specifies the acl property, when it defaults to full.
|
| - upload_filename: Filename to use for upload.
|
| - upload_mime_type: MIME type to use for the upload. Only needed if the
|
| - extension on --upload_filename does not determine the correct (or any)
|
| - MIME type.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsInsertRequest(
|
| + domain: The domain associated with the entity, if any.
|
| + email: The email address associated with the entity, if any.
|
| + entityId: The ID for the entity, if any.
|
| + etag: HTTP 1.1 Entity tag for the access-control entry.
|
| + generation: The content generation of the object.
|
| + id: The ID of the access-control entry.
|
| + kind: The kind of item this is. For object access control entries, this
|
| + is always storage#objectAccessControl.
|
| + object: The name of the object.
|
| + projectTeam: The project team associated with the entity, if any.
|
| + role: The access permission for the entity. Can be READER or OWNER.
|
| + selfLink: The link to this access-control entry.
|
| + """
|
| + client = GetClientFromFlags()
|
| + global_params = GetGlobalParamsFromFlags()
|
| + request = messages.ObjectAccessControl(
|
| bucket=bucket.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| )
|
| - if FLAGS['contentEncoding'].present:
|
| - request.contentEncoding = FLAGS.contentEncoding.decode('utf8')
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['name'].present:
|
| - request.name = FLAGS.name.decode('utf8')
|
| + if FLAGS['domain'].present:
|
| + request.domain = FLAGS.domain.decode('utf8')
|
| + if FLAGS['email'].present:
|
| + request.email = FLAGS.email.decode('utf8')
|
| + if FLAGS['entityId'].present:
|
| + request.entityId = FLAGS.entityId.decode('utf8')
|
| + if FLAGS['etag'].present:
|
| + request.etag = FLAGS.etag.decode('utf8')
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + if FLAGS['id'].present:
|
| + request.id = FLAGS.id.decode('utf8')
|
| + if FLAGS['kind'].present:
|
| + request.kind = FLAGS.kind.decode('utf8')
|
| if FLAGS['object'].present:
|
| - request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageObjectsInsertRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsInsertRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - upload = None
|
| - if FLAGS.upload_filename:
|
| - upload = apitools_base.Upload.FromFile(
|
| - FLAGS.upload_filename, FLAGS.upload_mime_type)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Insert(
|
| - request, global_params=global_params, upload=upload, download=download)
|
| + request.object = FLAGS.object.decode('utf8')
|
| + if FLAGS['projectTeam'].present:
|
| + request.projectTeam = apitools_base.JsonToMessage(messages.ObjectAccessControl.ProjectTeamValue, FLAGS.projectTeam)
|
| + if FLAGS['role'].present:
|
| + request.role = FLAGS.role.decode('utf8')
|
| + if FLAGS['selfLink'].present:
|
| + request.selfLink = FLAGS.selfLink.decode('utf8')
|
| + result = client.defaultObjectAccessControls.Update(
|
| + request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.List."""
|
| +class ObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| + """Command wrapping objectAccessControls.Delete."""
|
|
|
| - usage = """objects_list <bucket>"""
|
| + usage = """objectAccessControls_delete <bucket> <object> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsList, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'delimiter',
|
| - None,
|
| - u'Returns results in a directory-like mode. items will contain only '
|
| - u'objects whose names, aside from the prefix, do not contain '
|
| - u'delimiter. Objects whose names, aside from the prefix, contain '
|
| - u'delimiter will have their name, truncated after the delimiter, '
|
| - u'returned in prefixes. Duplicate prefixes are omitted.',
|
| - flag_values=fv)
|
| - flags.DEFINE_integer(
|
| - 'maxResults',
|
| - None,
|
| - u'Maximum number of items plus prefixes to return. As duplicate '
|
| - u'prefixes are omitted, fewer total results may be returned than '
|
| - u'requested.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'pageToken',
|
| - None,
|
| - u'A previously-returned page token representing part of the larger '
|
| - u'set of results to view.',
|
| - flag_values=fv)
|
| + super(ObjectAccessControlsDelete, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'prefix',
|
| - None,
|
| - u'Filter results to objects whose names begin with this prefix.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'versions',
|
| + 'generation',
|
| None,
|
| - u'If true, lists all versions of a file as distinct results.',
|
| + u'If present, selects a specific revision of this object (as opposed '
|
| + u'to the latest version, the default).',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket):
|
| - """Retrieves a list of objects matching the criteria.
|
| + def RunWithArgs(self, bucket, object, entity):
|
| + """Permanently deletes the ACL entry for the specified entity on the
|
| + specified object.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which to look for objects.
|
| + bucket: Name of a bucket.
|
| + object: Name of the object.
|
| + entity: The entity holding the permission. Can be user-userId, user-
|
| + emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| + allAuthenticatedUsers.
|
|
|
| Flags:
|
| - delimiter: Returns results in a directory-like mode. items will contain
|
| - only objects whose names, aside from the prefix, do not contain
|
| - delimiter. Objects whose names, aside from the prefix, contain
|
| - delimiter will have their name, truncated after the delimiter,
|
| - returned in prefixes. Duplicate prefixes are omitted.
|
| - maxResults: Maximum number of items plus prefixes to return. As
|
| - duplicate prefixes are omitted, fewer total results may be returned
|
| - than requested.
|
| - pageToken: A previously-returned page token representing part of the
|
| - larger set of results to view.
|
| - prefix: Filter results to objects whose names begin with this prefix.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - versions: If true, lists all versions of a file as distinct results.
|
| + generation: If present, selects a specific revision of this object (as
|
| + opposed to the latest version, the default).
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsListRequest(
|
| + request = messages.StorageObjectAccessControlsDeleteRequest(
|
| bucket=bucket.decode('utf8'),
|
| + object=object.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| )
|
| - if FLAGS['delimiter'].present:
|
| - request.delimiter = FLAGS.delimiter.decode('utf8')
|
| - if FLAGS['maxResults'].present:
|
| - request.maxResults = FLAGS.maxResults
|
| - if FLAGS['pageToken'].present:
|
| - request.pageToken = FLAGS.pageToken.decode('utf8')
|
| - if FLAGS['prefix'].present:
|
| - request.prefix = FLAGS.prefix.decode('utf8')
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - if FLAGS['versions'].present:
|
| - request.versions = FLAGS.versions
|
| - result = client.objects.List(
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + result = client.objectAccessControls.Delete(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Patch."""
|
| +class ObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| + """Command wrapping objectAccessControls.Get."""
|
|
|
| - usage = """objects_patch <bucket> <object>"""
|
| + usage = """objectAccessControls_get <bucket> <object> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsPatch, self).__init__(name, fv)
|
| + super(ObjectAccessControlsGet, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'generation',
|
| None,
|
| u'If present, selects a specific revision of this object (as opposed '
|
| u'to the latest version, the default).',
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectResource',
|
| - None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to this object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| - flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, object):
|
| - """Updates an object's metadata. This method supports patch semantics.
|
| + def RunWithArgs(self, bucket, object, entity):
|
| + """Returns the ACL entry for the specified entity on the specified object.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| + bucket: Name of a bucket.
|
| object: Name of the object.
|
| + entity: The entity holding the permission. Can be user-userId, user-
|
| + emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| + allAuthenticatedUsers.
|
|
|
| Flags:
|
| generation: If present, selects a specific revision of this object (as
|
| opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - objectResource: A Object resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this object.
|
| - projection: Set of properties to return. Defaults to full.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsPatchRequest(
|
| + request = messages.StorageObjectAccessControlsGetRequest(
|
| bucket=bucket.decode('utf8'),
|
| object=object.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| )
|
| if FLAGS['generation'].present:
|
| request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['objectResource'].present:
|
| - request.objectResource = apitools_base.JsonToMessage(messages.Object, FLAGS.objectResource)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageObjectsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.objects.Patch(
|
| + result = client.objectAccessControls.Get(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.Update."""
|
| +class ObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| + """Command wrapping objectAccessControls.Insert."""
|
|
|
| - usage = """objects_update <bucket> <object>"""
|
| + usage = """objectAccessControls_insert <bucket> <object>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsUpdate, self).__init__(name, fv)
|
| + super(ObjectAccessControlsInsert, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'generation',
|
| None,
|
| @@ -1992,225 +1697,99 @@ class ObjectsUpdate(apitools_base_cli.NewCmd):
|
| u'to the latest version, the default).',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifGenerationMatch',
|
| + 'objectAccessControl',
|
| None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifGenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'generation does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration matches the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| - None,
|
| - u"Makes the operation conditional on whether the object's current "
|
| - u'metageneration does not match the given value.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'objectResource',
|
| - None,
|
| - u'A Object resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of access controls to this object.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'download_filename',
|
| - '',
|
| - 'Filename to use for download.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'overwrite',
|
| - 'False',
|
| - 'If True, overwrite the existing file when downloading.',
|
| + u'A ObjectAccessControl resource to be passed as the request body.',
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket, object):
|
| - """Updates an object's metadata.
|
| + """Creates a new ACL entry on the specified object.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which the object resides.
|
| + bucket: Name of a bucket.
|
| object: Name of the object.
|
|
|
| Flags:
|
| generation: If present, selects a specific revision of this object (as
|
| opposed to the latest version, the default).
|
| - ifGenerationMatch: Makes the operation conditional on whether the
|
| - object's current generation matches the given value.
|
| - ifGenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current generation does not match the given value.
|
| - ifMetagenerationMatch: Makes the operation conditional on whether the
|
| - object's current metageneration matches the given value.
|
| - ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| - object's current metageneration does not match the given value.
|
| - objectResource: A Object resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this object.
|
| - projection: Set of properties to return. Defaults to full.
|
| - download_filename: Filename to use for download.
|
| - overwrite: If True, overwrite the existing file when downloading.
|
| + objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| + request body.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsUpdateRequest(
|
| + request = messages.StorageObjectAccessControlsInsertRequest(
|
| bucket=bucket.decode('utf8'),
|
| object=object.decode('utf8'),
|
| )
|
| if FLAGS['generation'].present:
|
| request.generation = int(FLAGS.generation)
|
| - if FLAGS['ifGenerationMatch'].present:
|
| - request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| - if FLAGS['ifGenerationNotMatch'].present:
|
| - request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['objectResource'].present:
|
| - request.objectResource = apitools_base.JsonToMessage(messages.Object, FLAGS.objectResource)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageObjectsUpdateRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsUpdateRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - download = None
|
| - if FLAGS.download_filename:
|
| - download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite)
|
| - result = client.objects.Update(
|
| - request, global_params=global_params, download=download)
|
| + if FLAGS['objectAccessControl'].present:
|
| + request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| + result = client.objectAccessControls.Insert(
|
| + request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectsWatchAll(apitools_base_cli.NewCmd):
|
| - """Command wrapping objects.WatchAll."""
|
| +class ObjectAccessControlsList(apitools_base_cli.NewCmd):
|
| + """Command wrapping objectAccessControls.List."""
|
|
|
| - usage = """objects_watchAll <bucket>"""
|
| + usage = """objectAccessControls_list <bucket> <object>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectsWatchAll, self).__init__(name, fv)
|
| - flags.DEFINE_string(
|
| - 'channel',
|
| - None,
|
| - u'A Channel resource to be passed as the request body.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'delimiter',
|
| - None,
|
| - u'Returns results in a directory-like mode. items will contain only '
|
| - u'objects whose names, aside from the prefix, do not contain '
|
| - u'delimiter. Objects whose names, aside from the prefix, contain '
|
| - u'delimiter will have their name, truncated after the delimiter, '
|
| - u'returned in prefixes. Duplicate prefixes are omitted.',
|
| - flag_values=fv)
|
| - flags.DEFINE_integer(
|
| - 'maxResults',
|
| - None,
|
| - u'Maximum number of items plus prefixes to return. As duplicate '
|
| - u'prefixes are omitted, fewer total results may be returned than '
|
| - u'requested.',
|
| - flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'pageToken',
|
| - None,
|
| - u'A previously-returned page token representing part of the larger '
|
| - u'set of results to view.',
|
| - flag_values=fv)
|
| + super(ObjectAccessControlsList, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'prefix',
|
| - None,
|
| - u'Filter results to objects whose names begin with this prefix.',
|
| - flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'projection',
|
| - u'full',
|
| - [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| - flag_values=fv)
|
| - flags.DEFINE_boolean(
|
| - 'versions',
|
| + 'generation',
|
| None,
|
| - u'If true, lists all versions of a file as distinct results.',
|
| + u'If present, selects a specific revision of this object (as opposed '
|
| + u'to the latest version, the default).',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket):
|
| - """Watch for changes on all objects in a bucket.
|
| + def RunWithArgs(self, bucket, object):
|
| + """Retrieves ACL entries on the specified object.
|
|
|
| Args:
|
| - bucket: Name of the bucket in which to look for objects.
|
| + bucket: Name of a bucket.
|
| + object: Name of the object.
|
|
|
| Flags:
|
| - channel: A Channel resource to be passed as the request body.
|
| - delimiter: Returns results in a directory-like mode. items will contain
|
| - only objects whose names, aside from the prefix, do not contain
|
| - delimiter. Objects whose names, aside from the prefix, contain
|
| - delimiter will have their name, truncated after the delimiter,
|
| - returned in prefixes. Duplicate prefixes are omitted.
|
| - maxResults: Maximum number of items plus prefixes to return. As
|
| - duplicate prefixes are omitted, fewer total results may be returned
|
| - than requested.
|
| - pageToken: A previously-returned page token representing part of the
|
| - larger set of results to view.
|
| - prefix: Filter results to objects whose names begin with this prefix.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| - versions: If true, lists all versions of a file as distinct results.
|
| + generation: If present, selects a specific revision of this object (as
|
| + opposed to the latest version, the default).
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectsWatchAllRequest(
|
| + request = messages.StorageObjectAccessControlsListRequest(
|
| bucket=bucket.decode('utf8'),
|
| + object=object.decode('utf8'),
|
| )
|
| - if FLAGS['channel'].present:
|
| - request.channel = apitools_base.JsonToMessage(messages.Channel, FLAGS.channel)
|
| - if FLAGS['delimiter'].present:
|
| - request.delimiter = FLAGS.delimiter.decode('utf8')
|
| - if FLAGS['maxResults'].present:
|
| - request.maxResults = FLAGS.maxResults
|
| - if FLAGS['pageToken'].present:
|
| - request.pageToken = FLAGS.pageToken.decode('utf8')
|
| - if FLAGS['prefix'].present:
|
| - request.prefix = FLAGS.prefix.decode('utf8')
|
| - if FLAGS['projection'].present:
|
| - request.projection = messages.StorageObjectsWatchAllRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - if FLAGS['versions'].present:
|
| - request.versions = FLAGS.versions
|
| - result = client.objects.WatchAll(
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + result = client.objectAccessControls.List(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Delete."""
|
| +class ObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| + """Command wrapping objectAccessControls.Patch."""
|
|
|
| - usage = """objectAccessControls_delete <bucket> <object> <entity>"""
|
| + usage = """objectAccessControls_patch <bucket> <object> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectAccessControlsDelete, self).__init__(name, fv)
|
| + super(ObjectAccessControlsPatch, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'generation',
|
| None,
|
| u'If present, selects a specific revision of this object (as opposed '
|
| u'to the latest version, the default).',
|
| flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'objectAccessControl',
|
| + None,
|
| + u'A ObjectAccessControl resource to be passed as the request body.',
|
| + flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket, object, entity):
|
| - """Permanently deletes the ACL entry for the specified entity on the
|
| - specified object.
|
| + """Updates an ACL entry on the specified object. This method supports
|
| + patch semantics.
|
|
|
| Args:
|
| bucket: Name of a bucket.
|
| @@ -2222,37 +1801,46 @@ class ObjectAccessControlsDelete(apitools_base_cli.NewCmd):
|
| Flags:
|
| generation: If present, selects a specific revision of this object (as
|
| opposed to the latest version, the default).
|
| + objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| + request body.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsDeleteRequest(
|
| + request = messages.StorageObjectAccessControlsPatchRequest(
|
| bucket=bucket.decode('utf8'),
|
| object=object.decode('utf8'),
|
| entity=entity.decode('utf8'),
|
| )
|
| if FLAGS['generation'].present:
|
| request.generation = int(FLAGS.generation)
|
| - result = client.objectAccessControls.Delete(
|
| + if FLAGS['objectAccessControl'].present:
|
| + request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| + result = client.objectAccessControls.Patch(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Get."""
|
| +class ObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| + """Command wrapping objectAccessControls.Update."""
|
|
|
| - usage = """objectAccessControls_get <bucket> <object> <entity>"""
|
| + usage = """objectAccessControls_update <bucket> <object> <entity>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectAccessControlsGet, self).__init__(name, fv)
|
| + super(ObjectAccessControlsUpdate, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'generation',
|
| None,
|
| u'If present, selects a specific revision of this object (as opposed '
|
| u'to the latest version, the default).',
|
| flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'objectAccessControl',
|
| + None,
|
| + u'A ObjectAccessControl resource to be passed as the request body.',
|
| + flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket, object, entity):
|
| - """Returns the ACL entry for the specified entity on the specified object.
|
| + """Updates an ACL entry on the specified object.
|
|
|
| Args:
|
| bucket: Name of a bucket.
|
| @@ -2264,113 +1852,374 @@ class ObjectAccessControlsGet(apitools_base_cli.NewCmd):
|
| Flags:
|
| generation: If present, selects a specific revision of this object (as
|
| opposed to the latest version, the default).
|
| + objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| + request body.
|
| + """
|
| + client = GetClientFromFlags()
|
| + global_params = GetGlobalParamsFromFlags()
|
| + request = messages.StorageObjectAccessControlsUpdateRequest(
|
| + bucket=bucket.decode('utf8'),
|
| + object=object.decode('utf8'),
|
| + entity=entity.decode('utf8'),
|
| + )
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + if FLAGS['objectAccessControl'].present:
|
| + request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| + result = client.objectAccessControls.Update(
|
| + request, global_params=global_params)
|
| + print apitools_base_cli.FormatOutput(result)
|
| +
|
| +
|
| +class ObjectsCompose(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Compose."""
|
| +
|
| + usage = """objects_compose <destinationBucket> <destinationObject>"""
|
| +
|
| + def __init__(self, name, fv):
|
| + super(ObjectsCompose, self).__init__(name, fv)
|
| + flags.DEFINE_string(
|
| + 'composeRequest',
|
| + None,
|
| + u'A ComposeRequest resource to be passed as the request body.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'destinationPredefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of access controls to the destination '
|
| + u'object.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'download_filename',
|
| + '',
|
| + 'Filename to use for download.',
|
| + flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'overwrite',
|
| + 'False',
|
| + 'If True, overwrite the existing file when downloading.',
|
| + flag_values=fv)
|
| +
|
| + def RunWithArgs(self, destinationBucket, destinationObject):
|
| + """Concatenates a list of existing objects into a new object in the same
|
| + bucket.
|
| +
|
| + Args:
|
| + destinationBucket: Name of the bucket in which to store the new object.
|
| + destinationObject: Name of the new object.
|
| +
|
| + Flags:
|
| + composeRequest: A ComposeRequest resource to be passed as the request
|
| + body.
|
| + destinationPredefinedAcl: Apply a predefined set of access controls to
|
| + the destination object.
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + object's current generation matches the given value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + object's current metageneration matches the given value.
|
| + download_filename: Filename to use for download.
|
| + overwrite: If True, overwrite the existing file when downloading.
|
| + """
|
| + client = GetClientFromFlags()
|
| + global_params = GetGlobalParamsFromFlags()
|
| + request = messages.StorageObjectsComposeRequest(
|
| + destinationBucket=destinationBucket.decode('utf8'),
|
| + destinationObject=destinationObject.decode('utf8'),
|
| + )
|
| + if FLAGS['composeRequest'].present:
|
| + request.composeRequest = apitools_base.JsonToMessage(messages.ComposeRequest, FLAGS.composeRequest)
|
| + if FLAGS['destinationPredefinedAcl'].present:
|
| + request.destinationPredefinedAcl = messages.StorageObjectsComposeRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + download = None
|
| + if FLAGS.download_filename:
|
| + download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite,
|
| + progress_callback=apitools_base.DownloadProgressPrinter,
|
| + finish_callback=apitools_base.DownloadCompletePrinter)
|
| + result = client.objects.Compose(
|
| + request, global_params=global_params, download=download)
|
| + print apitools_base_cli.FormatOutput(result)
|
| +
|
| +
|
| +class ObjectsCopy(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Copy."""
|
| +
|
| + usage = """objects_copy <sourceBucket> <sourceObject> <destinationBucket> <destinationObject>"""
|
| +
|
| + def __init__(self, name, fv):
|
| + super(ObjectsCopy, self).__init__(name, fv)
|
| + flags.DEFINE_enum(
|
| + 'destinationPredefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of access controls to the destination '
|
| + u'object.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current generation matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current generation does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceGenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'generation matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceGenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'generation does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceMetagenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'current metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'current metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'object',
|
| + None,
|
| + u'A Object resource to be passed as the request body.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to noAcl, unless the object '
|
| + u'resource specifies the acl property, when it defaults to full.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'sourceGeneration',
|
| + None,
|
| + u'If present, selects a specific revision of the source object (as '
|
| + u'opposed to the latest version, the default).',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'download_filename',
|
| + '',
|
| + 'Filename to use for download.',
|
| + flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'overwrite',
|
| + 'False',
|
| + 'If True, overwrite the existing file when downloading.',
|
| + flag_values=fv)
|
| +
|
| + def RunWithArgs(self, sourceBucket, sourceObject, destinationBucket, destinationObject):
|
| + """Copies a source object to a destination object. Optionally overrides
|
| + metadata.
|
| +
|
| + Args:
|
| + sourceBucket: Name of the bucket in which to find the source object.
|
| + sourceObject: Name of the source object.
|
| + destinationBucket: Name of the bucket in which to store the new object.
|
| + Overrides the provided object metadata's bucket value, if any.
|
| + destinationObject: Name of the new object. Required when the object
|
| + metadata is not otherwise provided. Overrides the object metadata's
|
| + name value, if any.
|
| +
|
| + Flags:
|
| + destinationPredefinedAcl: Apply a predefined set of access controls to
|
| + the destination object.
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + destination object's current generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + destination object's current generation does not match the given
|
| + value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + destination object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + destination object's current metageneration does not match the given
|
| + value.
|
| + ifSourceGenerationMatch: Makes the operation conditional on whether the
|
| + source object's generation matches the given value.
|
| + ifSourceGenerationNotMatch: Makes the operation conditional on whether
|
| + the source object's generation does not match the given value.
|
| + ifSourceMetagenerationMatch: Makes the operation conditional on whether
|
| + the source object's current metageneration matches the given value.
|
| + ifSourceMetagenerationNotMatch: Makes the operation conditional on
|
| + whether the source object's current metageneration does not match the
|
| + given value.
|
| + object: A Object resource to be passed as the request body.
|
| + projection: Set of properties to return. Defaults to noAcl, unless the
|
| + object resource specifies the acl property, when it defaults to full.
|
| + sourceGeneration: If present, selects a specific revision of the source
|
| + object (as opposed to the latest version, the default).
|
| + download_filename: Filename to use for download.
|
| + overwrite: If True, overwrite the existing file when downloading.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsGetRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| + request = messages.StorageObjectsCopyRequest(
|
| + sourceBucket=sourceBucket.decode('utf8'),
|
| + sourceObject=sourceObject.decode('utf8'),
|
| + destinationBucket=destinationBucket.decode('utf8'),
|
| + destinationObject=destinationObject.decode('utf8'),
|
| )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - result = client.objectAccessControls.Get(
|
| - request, global_params=global_params)
|
| + if FLAGS['destinationPredefinedAcl'].present:
|
| + request.destinationPredefinedAcl = messages.StorageObjectsCopyRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['ifSourceGenerationMatch'].present:
|
| + request.ifSourceGenerationMatch = int(FLAGS.ifSourceGenerationMatch)
|
| + if FLAGS['ifSourceGenerationNotMatch'].present:
|
| + request.ifSourceGenerationNotMatch = int(FLAGS.ifSourceGenerationNotMatch)
|
| + if FLAGS['ifSourceMetagenerationMatch'].present:
|
| + request.ifSourceMetagenerationMatch = int(FLAGS.ifSourceMetagenerationMatch)
|
| + if FLAGS['ifSourceMetagenerationNotMatch'].present:
|
| + request.ifSourceMetagenerationNotMatch = int(FLAGS.ifSourceMetagenerationNotMatch)
|
| + if FLAGS['object'].present:
|
| + request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageObjectsCopyRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + if FLAGS['sourceGeneration'].present:
|
| + request.sourceGeneration = int(FLAGS.sourceGeneration)
|
| + download = None
|
| + if FLAGS.download_filename:
|
| + download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite,
|
| + progress_callback=apitools_base.DownloadProgressPrinter,
|
| + finish_callback=apitools_base.DownloadCompletePrinter)
|
| + result = client.objects.Copy(
|
| + request, global_params=global_params, download=download)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectAccessControlsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Insert."""
|
| +class ObjectsDelete(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Delete."""
|
|
|
| - usage = """objectAccessControls_insert <bucket> <object>"""
|
| + usage = """objects_delete <bucket> <object>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectAccessControlsInsert, self).__init__(name, fv)
|
| + super(ObjectsDelete, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'generation',
|
| None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| + u'If present, permanently deletes a specific revision of this object '
|
| + u'(as opposed to the latest version, the default).',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'objectAccessControl',
|
| + 'ifGenerationMatch',
|
| None,
|
| - u'A ObjectAccessControl resource to be passed as the request body.',
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation matches the given value.',
|
| flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object):
|
| - """Creates a new ACL entry on the specified object.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| - request body.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsInsertRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['objectAccessControl'].present:
|
| - request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| - result = client.objectAccessControls.Insert(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.List."""
|
| -
|
| - usage = """objectAccessControls_list <bucket> <object>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsList, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'generation',
|
| + 'ifGenerationNotMatch',
|
| None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration does not match the given value.',
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket, object):
|
| - """Retrieves ACL entries on the specified object.
|
| + """Deletes an object and its metadata. Deletions are permanent if
|
| + versioning is not enabled for the bucket, or if the generation parameter
|
| + is used.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + bucket: Name of the bucket in which the object resides.
|
| object: Name of the object.
|
|
|
| Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| + generation: If present, permanently deletes a specific revision of this
|
| + object (as opposed to the latest version, the default).
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + object's current generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current generation does not match the given value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current metageneration does not match the given value.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsListRequest(
|
| + request = messages.StorageObjectsDeleteRequest(
|
| bucket=bucket.decode('utf8'),
|
| object=object.decode('utf8'),
|
| )
|
| if FLAGS['generation'].present:
|
| request.generation = int(FLAGS.generation)
|
| - result = client.objectAccessControls.List(
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + result = client.objects.Delete(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class ObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Patch."""
|
| +class ObjectsGet(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Get."""
|
|
|
| - usage = """objectAccessControls_patch <bucket> <object> <entity>"""
|
| + usage = """objects_get <bucket> <object>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(ObjectAccessControlsPatch, self).__init__(name, fv)
|
| + super(ObjectsGet, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| 'generation',
|
| None,
|
| @@ -2378,159 +2227,291 @@ class ObjectAccessControlsPatch(apitools_base_cli.NewCmd):
|
| u'to the latest version, the default).',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'objectAccessControl',
|
| + 'ifGenerationMatch',
|
| None,
|
| - u'A ObjectAccessControl resource to be passed as the request body.',
|
| + u"Makes the operation conditional on whether the object's generation "
|
| + u'matches the given value.',
|
| flag_values=fv)
|
| -
|
| - def RunWithArgs(self, bucket, object, entity):
|
| - """Updates an ACL entry on the specified object. This method supports
|
| - patch semantics.
|
| -
|
| - Args:
|
| - bucket: Name of a bucket.
|
| - object: Name of the object.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
| -
|
| - Flags:
|
| - generation: If present, selects a specific revision of this object (as
|
| - opposed to the latest version, the default).
|
| - objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| - request body.
|
| - """
|
| - client = GetClientFromFlags()
|
| - global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsPatchRequest(
|
| - bucket=bucket.decode('utf8'),
|
| - object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| - )
|
| - if FLAGS['generation'].present:
|
| - request.generation = int(FLAGS.generation)
|
| - if FLAGS['objectAccessControl'].present:
|
| - request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| - result = client.objectAccessControls.Patch(
|
| - request, global_params=global_params)
|
| - print apitools_base_cli.FormatOutput(result)
|
| -
|
| -
|
| -class ObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping objectAccessControls.Update."""
|
| -
|
| - usage = """objectAccessControls_update <bucket> <object> <entity>"""
|
| -
|
| - def __init__(self, name, fv):
|
| - super(ObjectAccessControlsUpdate, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'generation',
|
| + 'ifGenerationNotMatch',
|
| None,
|
| - u'If present, selects a specific revision of this object (as opposed '
|
| - u'to the latest version, the default).',
|
| + u"Makes the operation conditional on whether the object's generation "
|
| + u'does not match the given value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'objectAccessControl',
|
| + 'ifMetagenerationMatch',
|
| None,
|
| - u'A ObjectAccessControl resource to be passed as the request body.',
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to noAcl.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'download_filename',
|
| + '',
|
| + 'Filename to use for download.',
|
| + flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'overwrite',
|
| + 'False',
|
| + 'If True, overwrite the existing file when downloading.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket, object, entity):
|
| - """Updates an ACL entry on the specified object.
|
| + def RunWithArgs(self, bucket, object):
|
| + """Retrieves an object or its metadata.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + bucket: Name of the bucket in which the object resides.
|
| object: Name of the object.
|
| - entity: The entity holding the permission. Can be user-userId, user-
|
| - emailAddress, group-groupId, group-emailAddress, allUsers, or
|
| - allAuthenticatedUsers.
|
|
|
| Flags:
|
| generation: If present, selects a specific revision of this object (as
|
| opposed to the latest version, the default).
|
| - objectAccessControl: A ObjectAccessControl resource to be passed as the
|
| - request body.
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + object's generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + object's generation does not match the given value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current metageneration does not match the given value.
|
| + projection: Set of properties to return. Defaults to noAcl.
|
| + download_filename: Filename to use for download.
|
| + overwrite: If True, overwrite the existing file when downloading.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageObjectAccessControlsUpdateRequest(
|
| + request = messages.StorageObjectsGetRequest(
|
| bucket=bucket.decode('utf8'),
|
| object=object.decode('utf8'),
|
| - entity=entity.decode('utf8'),
|
| )
|
| if FLAGS['generation'].present:
|
| request.generation = int(FLAGS.generation)
|
| - if FLAGS['objectAccessControl'].present:
|
| - request.objectAccessControl = apitools_base.JsonToMessage(messages.ObjectAccessControl, FLAGS.objectAccessControl)
|
| - result = client.objectAccessControls.Update(
|
| - request, global_params=global_params)
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageObjectsGetRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + download = None
|
| + if FLAGS.download_filename:
|
| + download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite,
|
| + progress_callback=apitools_base.DownloadProgressPrinter,
|
| + finish_callback=apitools_base.DownloadCompletePrinter)
|
| + result = client.objects.Get(
|
| + request, global_params=global_params, download=download)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketsDelete(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Delete."""
|
| +class ObjectsInsert(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Insert."""
|
|
|
| - usage = """buckets_delete <bucket>"""
|
| + usage = """objects_insert <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketsDelete, self).__init__(name, fv)
|
| + super(ObjectsInsert, self).__init__(name, fv)
|
| + flags.DEFINE_string(
|
| + 'contentEncoding',
|
| + None,
|
| + u'If set, sets the contentEncoding property of the final object to '
|
| + u'this value. Setting this parameter is equivalent to setting the '
|
| + u'contentEncoding metadata property. This can be useful when '
|
| + u'uploading an object with uploadType=media to indicate the encoding '
|
| + u'of the content being uploaded.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation does not match the given value.',
|
| + flag_values=fv)
|
| flags.DEFINE_string(
|
| 'ifMetagenerationMatch',
|
| None,
|
| - u'If set, only deletes the bucket if its metageneration matches this '
|
| - u'value.',
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration matches the given value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'ifMetagenerationNotMatch',
|
| None,
|
| - u'If set, only deletes the bucket if its metageneration does not '
|
| - u'match this value.',
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'name',
|
| + None,
|
| + u'Name of the object. Required when the object metadata is not '
|
| + u"otherwise provided. Overrides the object metadata's name value, if "
|
| + u'any.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'object',
|
| + None,
|
| + u'A Object resource to be passed as the request body.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'predefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of access controls to this object.',
|
| + flag_values=fv)
|
| + flags.DEFINE_enum(
|
| + 'projection',
|
| + u'full',
|
| + [u'full', u'noAcl'],
|
| + u'Set of properties to return. Defaults to noAcl, unless the object '
|
| + u'resource specifies the acl property, when it defaults to full.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'upload_filename',
|
| + '',
|
| + 'Filename to use for upload.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'upload_mime_type',
|
| + '',
|
| + 'MIME type to use for the upload. Only needed if the extension on '
|
| + '--upload_filename does not determine the correct (or any) MIME '
|
| + 'type.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'download_filename',
|
| + '',
|
| + 'Filename to use for download.',
|
| + flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'overwrite',
|
| + 'False',
|
| + 'If True, overwrite the existing file when downloading.',
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket):
|
| - """Permanently deletes an empty bucket.
|
| + """Stores a new object and metadata.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + bucket: Name of the bucket in which to store the new object. Overrides
|
| + the provided object metadata's bucket value, if any.
|
|
|
| Flags:
|
| - ifMetagenerationMatch: If set, only deletes the bucket if its
|
| - metageneration matches this value.
|
| - ifMetagenerationNotMatch: If set, only deletes the bucket if its
|
| - metageneration does not match this value.
|
| + contentEncoding: If set, sets the contentEncoding property of the final
|
| + object to this value. Setting this parameter is equivalent to setting
|
| + the contentEncoding metadata property. This can be useful when
|
| + uploading an object with uploadType=media to indicate the encoding of
|
| + the content being uploaded.
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + object's current generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current generation does not match the given value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current metageneration does not match the given value.
|
| + name: Name of the object. Required when the object metadata is not
|
| + otherwise provided. Overrides the object metadata's name value, if
|
| + any.
|
| + object: A Object resource to be passed as the request body.
|
| + predefinedAcl: Apply a predefined set of access controls to this object.
|
| + projection: Set of properties to return. Defaults to noAcl, unless the
|
| + object resource specifies the acl property, when it defaults to full.
|
| + upload_filename: Filename to use for upload.
|
| + upload_mime_type: MIME type to use for the upload. Only needed if the
|
| + extension on --upload_filename does not determine the correct (or any)
|
| + MIME type.
|
| + download_filename: Filename to use for download.
|
| + overwrite: If True, overwrite the existing file when downloading.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsDeleteRequest(
|
| + request = messages.StorageObjectsInsertRequest(
|
| bucket=bucket.decode('utf8'),
|
| )
|
| + if FLAGS['contentEncoding'].present:
|
| + request.contentEncoding = FLAGS.contentEncoding.decode('utf8')
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| if FLAGS['ifMetagenerationMatch'].present:
|
| request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| if FLAGS['ifMetagenerationNotMatch'].present:
|
| request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - result = client.buckets.Delete(
|
| - request, global_params=global_params)
|
| + if FLAGS['name'].present:
|
| + request.name = FLAGS.name.decode('utf8')
|
| + if FLAGS['object'].present:
|
| + request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| + if FLAGS['predefinedAcl'].present:
|
| + request.predefinedAcl = messages.StorageObjectsInsertRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| + if FLAGS['projection'].present:
|
| + request.projection = messages.StorageObjectsInsertRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + upload = None
|
| + if FLAGS.upload_filename:
|
| + upload = apitools_base.Upload.FromFile(
|
| + FLAGS.upload_filename, FLAGS.upload_mime_type,
|
| + progress_callback=apitools_base.UploadProgressPrinter,
|
| + finish_callback=apitools_base.UploadCompletePrinter)
|
| + download = None
|
| + if FLAGS.download_filename:
|
| + download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite,
|
| + progress_callback=apitools_base.DownloadProgressPrinter,
|
| + finish_callback=apitools_base.DownloadCompletePrinter)
|
| + result = client.objects.Insert(
|
| + request, global_params=global_params, upload=upload, download=download)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketsGet(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Get."""
|
| +class ObjectsList(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.List."""
|
|
|
| - usage = """buckets_get <bucket>"""
|
| + usage = """objects_list <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketsGet, self).__init__(name, fv)
|
| + super(ObjectsList, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| + 'delimiter',
|
| None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration matches the given value.",
|
| + u'Returns results in a directory-like mode. items will contain only '
|
| + u'objects whose names, aside from the prefix, do not contain '
|
| + u'delimiter. Objects whose names, aside from the prefix, contain '
|
| + u'delimiter will have their name, truncated after the delimiter, '
|
| + u'returned in prefixes. Duplicate prefixes are omitted.',
|
| + flag_values=fv)
|
| + flags.DEFINE_integer(
|
| + 'maxResults',
|
| + None,
|
| + u'Maximum number of items plus prefixes to return. As duplicate '
|
| + u'prefixes are omitted, fewer total results may be returned than '
|
| + u'requested. The default value of this parameter is 1,000 items.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| + 'pageToken',
|
| None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration does not match the given value.",
|
| + u'A previously-returned page token representing part of the larger '
|
| + u'set of results to view.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'prefix',
|
| + None,
|
| + u'Filter results to objects whose names begin with this prefix.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| 'projection',
|
| @@ -2538,202 +2519,405 @@ class BucketsGet(apitools_base_cli.NewCmd):
|
| [u'full', u'noAcl'],
|
| u'Set of properties to return. Defaults to noAcl.',
|
| flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'versions',
|
| + None,
|
| + u'If true, lists all versions of an object as distinct results. The '
|
| + u'default is false. For more information, see Object Versioning.',
|
| + flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket):
|
| - """Returns metadata for the specified bucket.
|
| + """Retrieves a list of objects matching the criteria.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + bucket: Name of the bucket in which to look for objects.
|
|
|
| Flags:
|
| - ifMetagenerationMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration matches the
|
| - given value.
|
| - ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration does not
|
| - match the given value.
|
| + delimiter: Returns results in a directory-like mode. items will contain
|
| + only objects whose names, aside from the prefix, do not contain
|
| + delimiter. Objects whose names, aside from the prefix, contain
|
| + delimiter will have their name, truncated after the delimiter,
|
| + returned in prefixes. Duplicate prefixes are omitted.
|
| + maxResults: Maximum number of items plus prefixes to return. As
|
| + duplicate prefixes are omitted, fewer total results may be returned
|
| + than requested. The default value of this parameter is 1,000 items.
|
| + pageToken: A previously-returned page token representing part of the
|
| + larger set of results to view.
|
| + prefix: Filter results to objects whose names begin with this prefix.
|
| projection: Set of properties to return. Defaults to noAcl.
|
| + versions: If true, lists all versions of an object as distinct results.
|
| + The default is false. For more information, see Object Versioning.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsGetRequest(
|
| + request = messages.StorageObjectsListRequest(
|
| bucket=bucket.decode('utf8'),
|
| )
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['delimiter'].present:
|
| + request.delimiter = FLAGS.delimiter.decode('utf8')
|
| + if FLAGS['maxResults'].present:
|
| + request.maxResults = FLAGS.maxResults
|
| + if FLAGS['pageToken'].present:
|
| + request.pageToken = FLAGS.pageToken.decode('utf8')
|
| + if FLAGS['prefix'].present:
|
| + request.prefix = FLAGS.prefix.decode('utf8')
|
| if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsGetRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Get(
|
| + request.projection = messages.StorageObjectsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + if FLAGS['versions'].present:
|
| + request.versions = FLAGS.versions
|
| + result = client.objects.List(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketsInsert(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Insert."""
|
| +class ObjectsPatch(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Patch."""
|
|
|
| - usage = """buckets_insert <project>"""
|
| + usage = """objects_patch <bucket> <object>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketsInsert, self).__init__(name, fv)
|
| + super(ObjectsPatch, self).__init__(name, fv)
|
| + flags.DEFINE_string(
|
| + 'generation',
|
| + None,
|
| + u'If present, selects a specific revision of this object (as opposed '
|
| + u'to the latest version, the default).',
|
| + flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'bucket',
|
| + 'ifGenerationMatch',
|
| None,
|
| - u'A Bucket resource to be passed as the request body.',
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation matches the given value.',
|
| flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| - u'Apply a predefined set of access controls to this bucket.',
|
| + flags.DEFINE_string(
|
| + 'ifGenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'objectResource',
|
| + None,
|
| + u'A Object resource to be passed as the request body.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| - 'predefinedDefaultObjectAcl',
|
| + 'predefinedAcl',
|
| u'authenticatedRead',
|
| [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of default object access controls to this '
|
| - u'bucket.',
|
| + u'Apply a predefined set of access controls to this object.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| 'projection',
|
| u'full',
|
| [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl, unless the bucket '
|
| - u'resource specifies acl or defaultObjectAcl properties, when it '
|
| - u'defaults to full.',
|
| + u'Set of properties to return. Defaults to full.',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, project):
|
| - """Creates a new bucket.
|
| + def RunWithArgs(self, bucket, object):
|
| + """Updates an object's metadata. This method supports patch semantics.
|
|
|
| Args:
|
| - project: A valid API project identifier.
|
| + bucket: Name of the bucket in which the object resides.
|
| + object: Name of the object.
|
|
|
| Flags:
|
| - bucket: A Bucket resource to be passed as the request body.
|
| - predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| - predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| - access controls to this bucket.
|
| - projection: Set of properties to return. Defaults to noAcl, unless the
|
| - bucket resource specifies acl or defaultObjectAcl properties, when it
|
| - defaults to full.
|
| + generation: If present, selects a specific revision of this object (as
|
| + opposed to the latest version, the default).
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + object's current generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current generation does not match the given value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current metageneration does not match the given value.
|
| + objectResource: A Object resource to be passed as the request body.
|
| + predefinedAcl: Apply a predefined set of access controls to this object.
|
| + projection: Set of properties to return. Defaults to full.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsInsertRequest(
|
| - project=project.decode('utf8'),
|
| + request = messages.StorageObjectsPatchRequest(
|
| + bucket=bucket.decode('utf8'),
|
| + object=object.decode('utf8'),
|
| )
|
| - if FLAGS['bucket'].present:
|
| - request.bucket = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucket)
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['objectResource'].present:
|
| + request.objectResource = apitools_base.JsonToMessage(messages.Object, FLAGS.objectResource)
|
| if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageBucketsInsertRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['predefinedDefaultObjectAcl'].present:
|
| - request.predefinedDefaultObjectAcl = messages.StorageBucketsInsertRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| + request.predefinedAcl = messages.StorageObjectsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsInsertRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Insert(
|
| + request.projection = messages.StorageObjectsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + result = client.objects.Patch(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketsList(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.List."""
|
| +class ObjectsRewrite(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Rewrite."""
|
|
|
| - usage = """buckets_list <project>"""
|
| + usage = """objects_rewrite <sourceBucket> <sourceObject> <destinationBucket> <destinationObject>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketsList, self).__init__(name, fv)
|
| - flags.DEFINE_integer(
|
| - 'maxResults',
|
| + super(ObjectsRewrite, self).__init__(name, fv)
|
| + flags.DEFINE_enum(
|
| + 'destinationPredefinedAcl',
|
| + u'authenticatedRead',
|
| + [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| + u'Apply a predefined set of access controls to the destination '
|
| + u'object.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationMatch',
|
| None,
|
| - u'Maximum number of buckets to return.',
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current generation matches the given value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'pageToken',
|
| + 'ifGenerationNotMatch',
|
| None,
|
| - u'A previously-returned page token representing part of the larger '
|
| - u'set of results to view.',
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current generation does not match the given value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'prefix',
|
| + 'ifMetagenerationMatch',
|
| None,
|
| - u'Filter results to buckets whose names begin with this prefix.',
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the destination object's"
|
| + u' current metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceGenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'generation matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceGenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'generation does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceMetagenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'current metageneration matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifSourceMetagenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the source object's "
|
| + u'current metageneration does not match the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'maxBytesRewrittenPerCall',
|
| + None,
|
| + u'The maximum number of bytes that will be rewritten per rewrite '
|
| + u"request. Most callers shouldn't need to specify this parameter - it"
|
| + u' is primarily in place to support testing. If specified the value '
|
| + u'must be an integral multiple of 1 MiB (1048576). Also, this only '
|
| + u'applies to requests where the source and destination span locations'
|
| + u' and/or storage classes. Finally, this value must not change across'
|
| + u" rewrite calls else you'll get an error that the rewriteToken is "
|
| + u'invalid.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'object',
|
| + None,
|
| + u'A Object resource to be passed as the request body.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| 'projection',
|
| u'full',
|
| [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to noAcl.',
|
| + u'Set of properties to return. Defaults to noAcl, unless the object '
|
| + u'resource specifies the acl property, when it defaults to full.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'rewriteToken',
|
| + None,
|
| + u'Include this field (from the previous rewrite response) on each '
|
| + u'rewrite request after the first one, until the rewrite response '
|
| + u"'done' flag is true. Calls that provide a rewriteToken can omit all"
|
| + u' other request fields, but if included those fields must match the '
|
| + u'values provided in the first rewrite request.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'sourceGeneration',
|
| + None,
|
| + u'If present, selects a specific revision of the source object (as '
|
| + u'opposed to the latest version, the default).',
|
| flag_values=fv)
|
|
|
| - def RunWithArgs(self, project):
|
| - """Retrieves a list of buckets for a given project.
|
| + def RunWithArgs(self, sourceBucket, sourceObject, destinationBucket, destinationObject):
|
| + """Rewrites a source object to a destination object. Optionally overrides
|
| + metadata.
|
|
|
| Args:
|
| - project: A valid API project identifier.
|
| + sourceBucket: Name of the bucket in which to find the source object.
|
| + sourceObject: Name of the source object.
|
| + destinationBucket: Name of the bucket in which to store the new object.
|
| + Overrides the provided object metadata's bucket value, if any.
|
| + destinationObject: Name of the new object. Required when the object
|
| + metadata is not otherwise provided. Overrides the object metadata's
|
| + name value, if any.
|
|
|
| Flags:
|
| - maxResults: Maximum number of buckets to return.
|
| - pageToken: A previously-returned page token representing part of the
|
| - larger set of results to view.
|
| - prefix: Filter results to buckets whose names begin with this prefix.
|
| - projection: Set of properties to return. Defaults to noAcl.
|
| + destinationPredefinedAcl: Apply a predefined set of access controls to
|
| + the destination object.
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + destination object's current generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + destination object's current generation does not match the given
|
| + value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + destination object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + destination object's current metageneration does not match the given
|
| + value.
|
| + ifSourceGenerationMatch: Makes the operation conditional on whether the
|
| + source object's generation matches the given value.
|
| + ifSourceGenerationNotMatch: Makes the operation conditional on whether
|
| + the source object's generation does not match the given value.
|
| + ifSourceMetagenerationMatch: Makes the operation conditional on whether
|
| + the source object's current metageneration matches the given value.
|
| + ifSourceMetagenerationNotMatch: Makes the operation conditional on
|
| + whether the source object's current metageneration does not match the
|
| + given value.
|
| + maxBytesRewrittenPerCall: The maximum number of bytes that will be
|
| + rewritten per rewrite request. Most callers shouldn't need to specify
|
| + this parameter - it is primarily in place to support testing. If
|
| + specified the value must be an integral multiple of 1 MiB (1048576).
|
| + Also, this only applies to requests where the source and destination
|
| + span locations and/or storage classes. Finally, this value must not
|
| + change across rewrite calls else you'll get an error that the
|
| + rewriteToken is invalid.
|
| + object: A Object resource to be passed as the request body.
|
| + projection: Set of properties to return. Defaults to noAcl, unless the
|
| + object resource specifies the acl property, when it defaults to full.
|
| + rewriteToken: Include this field (from the previous rewrite response) on
|
| + each rewrite request after the first one, until the rewrite response
|
| + 'done' flag is true. Calls that provide a rewriteToken can omit all
|
| + other request fields, but if included those fields must match the
|
| + values provided in the first rewrite request.
|
| + sourceGeneration: If present, selects a specific revision of the source
|
| + object (as opposed to the latest version, the default).
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsListRequest(
|
| - project=project.decode('utf8'),
|
| + request = messages.StorageObjectsRewriteRequest(
|
| + sourceBucket=sourceBucket.decode('utf8'),
|
| + sourceObject=sourceObject.decode('utf8'),
|
| + destinationBucket=destinationBucket.decode('utf8'),
|
| + destinationObject=destinationObject.decode('utf8'),
|
| )
|
| - if FLAGS['maxResults'].present:
|
| - request.maxResults = FLAGS.maxResults
|
| - if FLAGS['pageToken'].present:
|
| - request.pageToken = FLAGS.pageToken.decode('utf8')
|
| - if FLAGS['prefix'].present:
|
| - request.prefix = FLAGS.prefix.decode('utf8')
|
| + if FLAGS['destinationPredefinedAcl'].present:
|
| + request.destinationPredefinedAcl = messages.StorageObjectsRewriteRequest.DestinationPredefinedAclValueValuesEnum(FLAGS.destinationPredefinedAcl)
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| + if FLAGS['ifMetagenerationMatch'].present:
|
| + request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| + if FLAGS['ifMetagenerationNotMatch'].present:
|
| + request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['ifSourceGenerationMatch'].present:
|
| + request.ifSourceGenerationMatch = int(FLAGS.ifSourceGenerationMatch)
|
| + if FLAGS['ifSourceGenerationNotMatch'].present:
|
| + request.ifSourceGenerationNotMatch = int(FLAGS.ifSourceGenerationNotMatch)
|
| + if FLAGS['ifSourceMetagenerationMatch'].present:
|
| + request.ifSourceMetagenerationMatch = int(FLAGS.ifSourceMetagenerationMatch)
|
| + if FLAGS['ifSourceMetagenerationNotMatch'].present:
|
| + request.ifSourceMetagenerationNotMatch = int(FLAGS.ifSourceMetagenerationNotMatch)
|
| + if FLAGS['maxBytesRewrittenPerCall'].present:
|
| + request.maxBytesRewrittenPerCall = int(FLAGS.maxBytesRewrittenPerCall)
|
| + if FLAGS['object'].present:
|
| + request.object = apitools_base.JsonToMessage(messages.Object, FLAGS.object)
|
| if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.List(
|
| + request.projection = messages.StorageObjectsRewriteRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + if FLAGS['rewriteToken'].present:
|
| + request.rewriteToken = FLAGS.rewriteToken.decode('utf8')
|
| + if FLAGS['sourceGeneration'].present:
|
| + request.sourceGeneration = int(FLAGS.sourceGeneration)
|
| + result = client.objects.Rewrite(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketsPatch(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Patch."""
|
| +class ObjectsUpdate(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.Update."""
|
|
|
| - usage = """buckets_patch <bucket>"""
|
| + usage = """objects_update <bucket> <object>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketsPatch, self).__init__(name, fv)
|
| + super(ObjectsUpdate, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'bucketResource',
|
| + 'generation',
|
| None,
|
| - u'A Bucket resource to be passed as the request body.',
|
| + u'If present, selects a specific revision of this object (as opposed '
|
| + u'to the latest version, the default).',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation matches the given value.',
|
| + flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'ifGenerationNotMatch',
|
| + None,
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'generation does not match the given value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'ifMetagenerationMatch',
|
| None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration matches the given value.",
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration matches the given value.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| 'ifMetagenerationNotMatch',
|
| None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration does not match the given value.",
|
| + u"Makes the operation conditional on whether the object's current "
|
| + u'metageneration does not match the given value.',
|
| flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| - u'Apply a predefined set of access controls to this bucket.',
|
| + flags.DEFINE_string(
|
| + 'objectResource',
|
| + None,
|
| + u'A Object resource to be passed as the request body.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| - 'predefinedDefaultObjectAcl',
|
| + 'predefinedAcl',
|
| u'authenticatedRead',
|
| [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of default object access controls to this '
|
| - u'bucket.',
|
| + u'Apply a predefined set of access controls to this object.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| 'projection',
|
| @@ -2741,148 +2925,199 @@ class BucketsPatch(apitools_base_cli.NewCmd):
|
| [u'full', u'noAcl'],
|
| u'Set of properties to return. Defaults to full.',
|
| flag_values=fv)
|
| + flags.DEFINE_string(
|
| + 'download_filename',
|
| + '',
|
| + 'Filename to use for download.',
|
| + flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'overwrite',
|
| + 'False',
|
| + 'If True, overwrite the existing file when downloading.',
|
| + flag_values=fv)
|
|
|
| - def RunWithArgs(self, bucket):
|
| - """Updates a bucket. This method supports patch semantics.
|
| + def RunWithArgs(self, bucket, object):
|
| + """Updates an object's metadata.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + bucket: Name of the bucket in which the object resides.
|
| + object: Name of the object.
|
|
|
| Flags:
|
| - bucketResource: A Bucket resource to be passed as the request body.
|
| - ifMetagenerationMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration matches the
|
| - given value.
|
| - ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration does not
|
| - match the given value.
|
| - predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| - predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| - access controls to this bucket.
|
| + generation: If present, selects a specific revision of this object (as
|
| + opposed to the latest version, the default).
|
| + ifGenerationMatch: Makes the operation conditional on whether the
|
| + object's current generation matches the given value.
|
| + ifGenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current generation does not match the given value.
|
| + ifMetagenerationMatch: Makes the operation conditional on whether the
|
| + object's current metageneration matches the given value.
|
| + ifMetagenerationNotMatch: Makes the operation conditional on whether the
|
| + object's current metageneration does not match the given value.
|
| + objectResource: A Object resource to be passed as the request body.
|
| + predefinedAcl: Apply a predefined set of access controls to this object.
|
| projection: Set of properties to return. Defaults to full.
|
| + download_filename: Filename to use for download.
|
| + overwrite: If True, overwrite the existing file when downloading.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsPatchRequest(
|
| + request = messages.StorageObjectsUpdateRequest(
|
| bucket=bucket.decode('utf8'),
|
| + object=object.decode('utf8'),
|
| )
|
| - if FLAGS['bucketResource'].present:
|
| - request.bucketResource = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucketResource)
|
| + if FLAGS['generation'].present:
|
| + request.generation = int(FLAGS.generation)
|
| + if FLAGS['ifGenerationMatch'].present:
|
| + request.ifGenerationMatch = int(FLAGS.ifGenerationMatch)
|
| + if FLAGS['ifGenerationNotMatch'].present:
|
| + request.ifGenerationNotMatch = int(FLAGS.ifGenerationNotMatch)
|
| if FLAGS['ifMetagenerationMatch'].present:
|
| request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| if FLAGS['ifMetagenerationNotMatch'].present:
|
| request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| + if FLAGS['objectResource'].present:
|
| + request.objectResource = apitools_base.JsonToMessage(messages.Object, FLAGS.objectResource)
|
| if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageBucketsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['predefinedDefaultObjectAcl'].present:
|
| - request.predefinedDefaultObjectAcl = messages.StorageBucketsPatchRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| + request.predefinedAcl = messages.StorageObjectsUpdateRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Patch(
|
| - request, global_params=global_params)
|
| + request.projection = messages.StorageObjectsUpdateRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + download = None
|
| + if FLAGS.download_filename:
|
| + download = apitools_base.Download.FromFile(FLAGS.download_filename, overwrite=FLAGS.overwrite,
|
| + progress_callback=apitools_base.DownloadProgressPrinter,
|
| + finish_callback=apitools_base.DownloadCompletePrinter)
|
| + result = client.objects.Update(
|
| + request, global_params=global_params, download=download)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| -class BucketsUpdate(apitools_base_cli.NewCmd):
|
| - """Command wrapping buckets.Update."""
|
| +class ObjectsWatchAll(apitools_base_cli.NewCmd):
|
| + """Command wrapping objects.WatchAll."""
|
|
|
| - usage = """buckets_update <bucket>"""
|
| + usage = """objects_watchAll <bucket>"""
|
|
|
| def __init__(self, name, fv):
|
| - super(BucketsUpdate, self).__init__(name, fv)
|
| + super(ObjectsWatchAll, self).__init__(name, fv)
|
| flags.DEFINE_string(
|
| - 'bucketResource',
|
| + 'channel',
|
| None,
|
| - u'A Bucket resource to be passed as the request body.',
|
| + u'A Channel resource to be passed as the request body.',
|
| flag_values=fv)
|
| flags.DEFINE_string(
|
| - 'ifMetagenerationMatch',
|
| + 'delimiter',
|
| None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration matches the given value.",
|
| + u'Returns results in a directory-like mode. items will contain only '
|
| + u'objects whose names, aside from the prefix, do not contain '
|
| + u'delimiter. Objects whose names, aside from the prefix, contain '
|
| + u'delimiter will have their name, truncated after the delimiter, '
|
| + u'returned in prefixes. Duplicate prefixes are omitted.',
|
| flag_values=fv)
|
| - flags.DEFINE_string(
|
| - 'ifMetagenerationNotMatch',
|
| + flags.DEFINE_integer(
|
| + 'maxResults',
|
| None,
|
| - u'Makes the return of the bucket metadata conditional on whether the '
|
| - u"bucket's current metageneration does not match the given value.",
|
| + u'Maximum number of items plus prefixes to return. As duplicate '
|
| + u'prefixes are omitted, fewer total results may be returned than '
|
| + u'requested. The default value of this parameter is 1,000 items.',
|
| flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'private', u'projectPrivate', u'publicRead', u'publicReadWrite'],
|
| - u'Apply a predefined set of access controls to this bucket.',
|
| + flags.DEFINE_string(
|
| + 'pageToken',
|
| + None,
|
| + u'A previously-returned page token representing part of the larger '
|
| + u'set of results to view.',
|
| flag_values=fv)
|
| - flags.DEFINE_enum(
|
| - 'predefinedDefaultObjectAcl',
|
| - u'authenticatedRead',
|
| - [u'authenticatedRead', u'bucketOwnerFullControl', u'bucketOwnerRead', u'private', u'projectPrivate', u'publicRead'],
|
| - u'Apply a predefined set of default object access controls to this '
|
| - u'bucket.',
|
| + flags.DEFINE_string(
|
| + 'prefix',
|
| + None,
|
| + u'Filter results to objects whose names begin with this prefix.',
|
| flag_values=fv)
|
| flags.DEFINE_enum(
|
| 'projection',
|
| u'full',
|
| [u'full', u'noAcl'],
|
| - u'Set of properties to return. Defaults to full.',
|
| + u'Set of properties to return. Defaults to noAcl.',
|
| + flag_values=fv)
|
| + flags.DEFINE_boolean(
|
| + 'versions',
|
| + None,
|
| + u'If true, lists all versions of an object as distinct results. The '
|
| + u'default is false. For more information, see Object Versioning.',
|
| flag_values=fv)
|
|
|
| def RunWithArgs(self, bucket):
|
| - """Updates a bucket.
|
| + """Watch for changes on all objects in a bucket.
|
|
|
| Args:
|
| - bucket: Name of a bucket.
|
| + bucket: Name of the bucket in which to look for objects.
|
|
|
| Flags:
|
| - bucketResource: A Bucket resource to be passed as the request body.
|
| - ifMetagenerationMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration matches the
|
| - given value.
|
| - ifMetagenerationNotMatch: Makes the return of the bucket metadata
|
| - conditional on whether the bucket's current metageneration does not
|
| - match the given value.
|
| - predefinedAcl: Apply a predefined set of access controls to this bucket.
|
| - predefinedDefaultObjectAcl: Apply a predefined set of default object
|
| - access controls to this bucket.
|
| - projection: Set of properties to return. Defaults to full.
|
| + channel: A Channel resource to be passed as the request body.
|
| + delimiter: Returns results in a directory-like mode. items will contain
|
| + only objects whose names, aside from the prefix, do not contain
|
| + delimiter. Objects whose names, aside from the prefix, contain
|
| + delimiter will have their name, truncated after the delimiter,
|
| + returned in prefixes. Duplicate prefixes are omitted.
|
| + maxResults: Maximum number of items plus prefixes to return. As
|
| + duplicate prefixes are omitted, fewer total results may be returned
|
| + than requested. The default value of this parameter is 1,000 items.
|
| + pageToken: A previously-returned page token representing part of the
|
| + larger set of results to view.
|
| + prefix: Filter results to objects whose names begin with this prefix.
|
| + projection: Set of properties to return. Defaults to noAcl.
|
| + versions: If true, lists all versions of an object as distinct results.
|
| + The default is false. For more information, see Object Versioning.
|
| """
|
| client = GetClientFromFlags()
|
| global_params = GetGlobalParamsFromFlags()
|
| - request = messages.StorageBucketsUpdateRequest(
|
| + request = messages.StorageObjectsWatchAllRequest(
|
| bucket=bucket.decode('utf8'),
|
| )
|
| - if FLAGS['bucketResource'].present:
|
| - request.bucketResource = apitools_base.JsonToMessage(messages.Bucket, FLAGS.bucketResource)
|
| - if FLAGS['ifMetagenerationMatch'].present:
|
| - request.ifMetagenerationMatch = int(FLAGS.ifMetagenerationMatch)
|
| - if FLAGS['ifMetagenerationNotMatch'].present:
|
| - request.ifMetagenerationNotMatch = int(FLAGS.ifMetagenerationNotMatch)
|
| - if FLAGS['predefinedAcl'].present:
|
| - request.predefinedAcl = messages.StorageBucketsUpdateRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
|
| - if FLAGS['predefinedDefaultObjectAcl'].present:
|
| - request.predefinedDefaultObjectAcl = messages.StorageBucketsUpdateRequest.PredefinedDefaultObjectAclValueValuesEnum(FLAGS.predefinedDefaultObjectAcl)
|
| + if FLAGS['channel'].present:
|
| + request.channel = apitools_base.JsonToMessage(messages.Channel, FLAGS.channel)
|
| + if FLAGS['delimiter'].present:
|
| + request.delimiter = FLAGS.delimiter.decode('utf8')
|
| + if FLAGS['maxResults'].present:
|
| + request.maxResults = FLAGS.maxResults
|
| + if FLAGS['pageToken'].present:
|
| + request.pageToken = FLAGS.pageToken.decode('utf8')
|
| + if FLAGS['prefix'].present:
|
| + request.prefix = FLAGS.prefix.decode('utf8')
|
| if FLAGS['projection'].present:
|
| - request.projection = messages.StorageBucketsUpdateRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| - result = client.buckets.Update(
|
| + request.projection = messages.StorageObjectsWatchAllRequest.ProjectionValueValuesEnum(FLAGS.projection)
|
| + if FLAGS['versions'].present:
|
| + request.versions = FLAGS.versions
|
| + result = client.objects.WatchAll(
|
| request, global_params=global_params)
|
| print apitools_base_cli.FormatOutput(result)
|
|
|
|
|
| def main(_):
|
| appcommands.AddCmd('pyshell', PyShell)
|
| - appcommands.AddCmd('defaultObjectAccessControls_delete', DefaultObjectAccessControlsDelete)
|
| - appcommands.AddCmd('defaultObjectAccessControls_get', DefaultObjectAccessControlsGet)
|
| - appcommands.AddCmd('defaultObjectAccessControls_insert', DefaultObjectAccessControlsInsert)
|
| - appcommands.AddCmd('defaultObjectAccessControls_list', DefaultObjectAccessControlsList)
|
| - appcommands.AddCmd('defaultObjectAccessControls_patch', DefaultObjectAccessControlsPatch)
|
| - appcommands.AddCmd('defaultObjectAccessControls_update', DefaultObjectAccessControlsUpdate)
|
| appcommands.AddCmd('bucketAccessControls_delete', BucketAccessControlsDelete)
|
| appcommands.AddCmd('bucketAccessControls_get', BucketAccessControlsGet)
|
| appcommands.AddCmd('bucketAccessControls_insert', BucketAccessControlsInsert)
|
| appcommands.AddCmd('bucketAccessControls_list', BucketAccessControlsList)
|
| appcommands.AddCmd('bucketAccessControls_patch', BucketAccessControlsPatch)
|
| appcommands.AddCmd('bucketAccessControls_update', BucketAccessControlsUpdate)
|
| + appcommands.AddCmd('buckets_delete', BucketsDelete)
|
| + appcommands.AddCmd('buckets_get', BucketsGet)
|
| + appcommands.AddCmd('buckets_insert', BucketsInsert)
|
| + appcommands.AddCmd('buckets_list', BucketsList)
|
| + appcommands.AddCmd('buckets_patch', BucketsPatch)
|
| + appcommands.AddCmd('buckets_update', BucketsUpdate)
|
| appcommands.AddCmd('channels_stop', ChannelsStop)
|
| + appcommands.AddCmd('defaultObjectAccessControls_delete', DefaultObjectAccessControlsDelete)
|
| + appcommands.AddCmd('defaultObjectAccessControls_get', DefaultObjectAccessControlsGet)
|
| + appcommands.AddCmd('defaultObjectAccessControls_insert', DefaultObjectAccessControlsInsert)
|
| + appcommands.AddCmd('defaultObjectAccessControls_list', DefaultObjectAccessControlsList)
|
| + appcommands.AddCmd('defaultObjectAccessControls_patch', DefaultObjectAccessControlsPatch)
|
| + appcommands.AddCmd('defaultObjectAccessControls_update', DefaultObjectAccessControlsUpdate)
|
| + appcommands.AddCmd('objectAccessControls_delete', ObjectAccessControlsDelete)
|
| + appcommands.AddCmd('objectAccessControls_get', ObjectAccessControlsGet)
|
| + appcommands.AddCmd('objectAccessControls_insert', ObjectAccessControlsInsert)
|
| + appcommands.AddCmd('objectAccessControls_list', ObjectAccessControlsList)
|
| + appcommands.AddCmd('objectAccessControls_patch', ObjectAccessControlsPatch)
|
| + appcommands.AddCmd('objectAccessControls_update', ObjectAccessControlsUpdate)
|
| appcommands.AddCmd('objects_compose', ObjectsCompose)
|
| appcommands.AddCmd('objects_copy', ObjectsCopy)
|
| appcommands.AddCmd('objects_delete', ObjectsDelete)
|
| @@ -2890,20 +3125,9 @@ def main(_):
|
| appcommands.AddCmd('objects_insert', ObjectsInsert)
|
| appcommands.AddCmd('objects_list', ObjectsList)
|
| appcommands.AddCmd('objects_patch', ObjectsPatch)
|
| + appcommands.AddCmd('objects_rewrite', ObjectsRewrite)
|
| appcommands.AddCmd('objects_update', ObjectsUpdate)
|
| appcommands.AddCmd('objects_watchAll', ObjectsWatchAll)
|
| - appcommands.AddCmd('objectAccessControls_delete', ObjectAccessControlsDelete)
|
| - appcommands.AddCmd('objectAccessControls_get', ObjectAccessControlsGet)
|
| - appcommands.AddCmd('objectAccessControls_insert', ObjectAccessControlsInsert)
|
| - appcommands.AddCmd('objectAccessControls_list', ObjectAccessControlsList)
|
| - appcommands.AddCmd('objectAccessControls_patch', ObjectAccessControlsPatch)
|
| - appcommands.AddCmd('objectAccessControls_update', ObjectAccessControlsUpdate)
|
| - appcommands.AddCmd('buckets_delete', BucketsDelete)
|
| - appcommands.AddCmd('buckets_get', BucketsGet)
|
| - appcommands.AddCmd('buckets_insert', BucketsInsert)
|
| - appcommands.AddCmd('buckets_list', BucketsList)
|
| - appcommands.AddCmd('buckets_patch', BucketsPatch)
|
| - appcommands.AddCmd('buckets_update', BucketsUpdate)
|
|
|
| apitools_base_cli.SetupLogger()
|
| if hasattr(appcommands, 'SetDefaultCommand'):
|
|
|
Chromium Code Reviews
Issue 1380943003:
Roll version of gsutil to 4.15. (Closed)
Base URL: https://github.com/catapult-project/catapult.git@master