catapult/third_party/gsutil/third_party/apitools/samples/storage_sample/storage/storage_v1.py

#!/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

import protorpc
from protorpc import message_types
from protorpc import messages

from google.apputils import appcommands
import gflags as flags

import apitools.base.py as apitools_base
from apitools.base.py import cli as apitools_base_cli
import storage_v1_client as client_lib
import storage_v1_messages as messages


def _DeclareStorageFlags():
  """Declare global flags in an idempotent way."""
  if 'api_endpoint' in flags.FLAGS:
    return
  flags.DEFINE_string(
      'api_endpoint',
      u'https://www.googleapis.com/storage/v1/',
      'URL of the API endpoint to use.',
      short_name='storage_url')
  flags.DEFINE_string(
      'history_file',
      u'~/.storage.v1.history',
      'File with interactive shell history.')
  flags.DEFINE_multistring(
      'add_header', [],
      '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',
      [u'json'],
      u'Data format for the response.')
  flags.DEFINE_string(
      'fields',
      None,
      u'Selector specifying which fields to include in a partial response.')
  flags.DEFINE_string(
      'key',
      None,
      u'API key. Your API key identifies your project and provides you with '
      u'API access, quota, and reports. Required unless you provide an OAuth '
      u'2.0 token.')
  flags.DEFINE_string(
      'oauth_token',
      None,
      u'OAuth 2.0 token for the current user.')
  flags.DEFINE_boolean(
      'prettyPrint',
      'True',
      u'Returns response with indentations and line breaks.')
  flags.DEFINE_string(
      'quotaUser',
      None,
      u'Available to use for quota purposes for server-side applications. Can'
      u' be any arbitrary string assigned to a user, but should not exceed 40'
      u' characters. Overrides userIp if both are provided.')
  flags.DEFINE_string(
      'trace',
      None,
      'A tracing token of the form "token:<tokenid>" to include in api '
      'requests.')
  flags.DEFINE_string(
      'userIp',
      None,
      u'IP address of the site where the request originates. Use this if you '
      u'want to enforce per-user limits.')


FLAGS = flags.FLAGS
apitools_base_cli.DeclareBaseFlags()
_DeclareStorageFlags()


def GetGlobalParamsFromFlags():
  """Return a StandardQueryParameters based on flags."""
  result = messages.StandardQueryParameters()
  if FLAGS['alt'].present:
    result.alt = messages.StandardQueryParameters.AltValueValuesEnum(FLAGS.alt)
  if FLAGS['fields'].present:
    result.fields = FLAGS.fields.decode('utf8')
  if FLAGS['key'].present:
    result.key = FLAGS.key.decode('utf8')
  if FLAGS['oauth_token'].present:
    result.oauth_token = FLAGS.oauth_token.decode('utf8')
  if FLAGS['prettyPrint'].present:
    result.prettyPrint = FLAGS.prettyPrint
  if FLAGS['quotaUser'].present:
    result.quotaUser = FLAGS.quotaUser.decode('utf8')
  if FLAGS['trace'].present:
    result.trace = FLAGS.trace.decode('utf8')
  if FLAGS['userIp'].present:
    result.userIp = FLAGS.userIp.decode('utf8')
  return result


def GetClientFromFlags():
  """Return a client object, configured from flags."""
  log_request = FLAGS.log_request or FLAGS.log_request_response
  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
    sys.exit(1)
  return client


class PyShell(appcommands.Cmd):

  def Run(self, _):
    """Run an interactive python shell with the client."""
    client = GetClientFromFlags()
    params = GetGlobalParamsFromFlags()
    for field in params.all_fields():
      value = params.get_assigned_value(field.name)
      if value != field.default:
        client.AddGlobalParam(field.name, value)
    banner = """
           == storage interactive console ==
                 client: a storage client
          apitools_base: base apitools module
         messages: the generated messages module
    """
    local_vars = {
        'apitools_base': apitools_base,
        'client': client,
        'client_lib': client_lib,
        'messages': messages,
    }
    if platform.system() == 'Linux':
      console = apitools_base_cli.ConsoleWithReadline(
          local_vars, histfile=FLAGS.history_file)
    else:
      console = code.InteractiveConsole(local_vars)
    try:
      console.interact(banner)
    except SystemExit as e:
      return e.code


class BucketAccessControlsDelete(apitools_base_cli.NewCmd):
  """Command wrapping bucketAccessControls.Delete."""

  usage = """bucketAccessControls_delete <bucket> <entity>"""

  def __init__(self, name, fv):
    super(BucketAccessControlsDelete, self).__init__(name, fv)

  def RunWithArgs(self, bucket, entity):
    """Permanently deletes 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.StorageBucketAccessControlsDeleteRequest(
        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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class BucketAccessControlsInsert(apitools_base_cli.NewCmd):
  """Command wrapping bucketAccessControls.Insert."""

  usage = """bucketAccessControls_insert <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)
    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.',
        flag_values=fv)

  def RunWithArgs(self, bucket):
    """Creates a new ACL entry on the specified bucket.

    Args:
      bucket: The name of the 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.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.BucketAccessControl(
        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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class BucketAccessControlsList(apitools_base_cli.NewCmd):
  """Command wrapping bucketAccessControls.List."""

  usage = """bucketAccessControls_list <bucket>"""

  def __init__(self, name, fv):
    super(BucketAccessControlsList, self).__init__(name, fv)

  def RunWithArgs(self, bucket):
    """Retrieves ACL entries on the specified bucket.

    Args:
      bucket: Name of a bucket.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageBucketAccessControlsListRequest(
        bucket=bucket.decode('utf8'),
        )
    result = client.bucketAccessControls.List(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class BucketAccessControlsPatch(apitools_base_cli.NewCmd):
  """Command wrapping bucketAccessControls.Patch."""

  usage = """bucketAccessControls_patch <bucket> <entity>"""

  def __init__(self, name, fv):
    super(BucketAccessControlsPatch, 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(
        '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)
    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.',
        flag_values=fv)

  def RunWithArgs(self, bucket, entity):
    """Updates an ACL entry on the specified 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.

    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.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.BucketAccessControl(
        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.Patch(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class BucketAccessControlsUpdate(apitools_base_cli.NewCmd):
  """Command wrapping bucketAccessControls.Update."""

  usage = """bucketAccessControls_update <bucket> <entity>"""

  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)
    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)
    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.',
        flag_values=fv)

  def RunWithArgs(self, bucket, entity):
    """Updates an ACL entry on the specified bucket.

    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.

    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.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.BucketAccessControl(
        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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class BucketsDelete(apitools_base_cli.NewCmd):
  """Command wrapping buckets.Delete."""

  usage = """buckets_delete <bucket>"""

  def __init__(self, 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):
    """Permanently deletes an empty bucket.

    Args:
      bucket: Name of a bucket.

    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.StorageBucketsDeleteRequest(
        bucket=bucket.decode('utf8'),
        )
    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 BucketsGet(apitools_base_cli.NewCmd):
  """Command wrapping buckets.Get."""

  usage = """buckets_get <bucket>"""

  def __init__(self, name, fv):
    super(BucketsGet, self).__init__(name, 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.",
        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.",
        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)

  def RunWithArgs(self, bucket):
    """Returns metadata for the specified bucket.

    Args:
      bucket: Name of a bucket.

    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.
      projection: Set of properties to return. Defaults to noAcl.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageBucketsGetRequest(
        bucket=bucket.decode('utf8'),
        )
    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 BucketsInsert(apitools_base_cli.NewCmd):
  """Command wrapping buckets.Insert."""

  usage = """buckets_insert <project>"""

  def __init__(self, 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, project):
    """Creates a new bucket.

    Args:
      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.StorageBucketsInsertRequest(
        project=project.decode('utf8'),
        )
    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 BucketsList(apitools_base_cli.NewCmd):
  """Command wrapping buckets.List."""

  usage = """buckets_list <project>"""

  def __init__(self, name, fv):
    super(BucketsList, self).__init__(name, fv)
    flags.DEFINE_integer(
        'maxResults',
        None,
        u'Maximum number of buckets to return.',
        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)
    flags.DEFINE_string(
        'prefix',
        None,
        u'Filter results to buckets 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)

  def RunWithArgs(self, project):
    """Retrieves a list of buckets for a given project.

    Args:
      project: A valid API project identifier.

    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.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageBucketsListRequest(
        project=project.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.StorageBucketsListRequest.ProjectionValueValuesEnum(FLAGS.projection)
    result = client.buckets.List(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class BucketsPatch(apitools_base_cli.NewCmd):
  """Command wrapping buckets.Patch."""

  usage = """buckets_patch <bucket>"""

  def __init__(self, name, fv):
    super(BucketsPatch, self).__init__(name, fv)
    flags.DEFINE_string(
        'bucketResource',
        None,
        u'A Bucket resource to be passed as the request body.',
        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.",
        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.",
        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 full.',
        flag_values=fv)

  def RunWithArgs(self, bucket):
    """Updates a bucket. This method supports patch semantics.

    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.StorageBucketsPatchRequest(
        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.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 BucketsUpdate(apitools_base_cli.NewCmd):
  """Command wrapping buckets.Update."""

  usage = """buckets_update <bucket>"""

  def __init__(self, name, fv):
    super(BucketsUpdate, self).__init__(name, fv)
    flags.DEFINE_string(
        'bucketResource',
        None,
        u'A Bucket resource to be passed as the request body.',
        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.",
        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.",
        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 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',
        None,
        u'Additional parameters controlling delivery channel behavior. '
        u'Optional.',
        flag_values=fv)
    flags.DEFINE_boolean(
        'payload',
        None,
        u'A Boolean value to indicate whether payload is wanted. Optional.',
        flag_values=fv)
    flags.DEFINE_string(
        'resourceId',
        None,
        u'An opaque ID that identifies the resource being watched on this '
        u'channel. Stable across different API versions.',
        flag_values=fv)
    flags.DEFINE_string(
        'resourceUri',
        None,
        u'A version-specific identifier for the watched resource.',
        flag_values=fv)
    flags.DEFINE_string(
        'token',
        None,
        u'An arbitrary string delivered to the target address with each '
        u'notification delivered over this channel. Optional.',
        flag_values=fv)
    flags.DEFINE_string(
        'type',
        None,
        u'The type of delivery mechanism used for this channel.',
        flag_values=fv)

  def RunWithArgs(self):
    """Stop watching resources through this channel

    Flags:
      address: The address where notifications are delivered for this channel.
      expiration: Date and time of notification channel expiration, expressed
        as a Unix timestamp, in milliseconds. Optional.
      id: A UUID or similar unique string that identifies this channel.
      kind: Identifies this as a notification channel used to watch for
        changes to a resource. Value: the fixed string "api#channel".
      params: Additional parameters controlling delivery channel behavior.
        Optional.
      payload: A Boolean value to indicate whether payload is wanted.
        Optional.
      resourceId: An opaque ID that identifies the resource being watched on
        this channel. Stable across different API versions.
      resourceUri: A version-specific identifier for the watched resource.
      token: An arbitrary string delivered to the target address with each
        notification delivered over this channel. Optional.
      type: The type of delivery mechanism used for this channel.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.Channel(
        )
    if FLAGS['address'].present:
      request.address = FLAGS.address.decode('utf8')
    if FLAGS['expiration'].present:
      request.expiration = int(FLAGS.expiration)
    if FLAGS['id'].present:
      request.id = FLAGS.id.decode('utf8')
    if FLAGS['kind'].present:
      request.kind = FLAGS.kind.decode('utf8')
    if FLAGS['params'].present:
      request.params = apitools_base.JsonToMessage(messages.Channel.ParamsValue, FLAGS.params)
    if FLAGS['payload'].present:
      request.payload = FLAGS.payload
    if FLAGS['resourceId'].present:
      request.resourceId = FLAGS.resourceId.decode('utf8')
    if FLAGS['resourceUri'].present:
      request.resourceUri = FLAGS.resourceUri.decode('utf8')
    if FLAGS['token'].present:
      request.token = FLAGS.token.decode('utf8')
    if FLAGS['type'].present:
      request.type = FLAGS.type.decode('utf8')
    result = client.channels.Stop(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class DefaultObjectAccessControlsDelete(apitools_base_cli.NewCmd):
  """Command wrapping defaultObjectAccessControls.Delete."""

  usage = """defaultObjectAccessControls_delete <bucket> <entity>"""

  def __init__(self, name, fv):
    super(DefaultObjectAccessControlsDelete, self).__init__(name, fv)

  def RunWithArgs(self, bucket, entity):
    """Permanently deletes 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.StorageDefaultObjectAccessControlsDeleteRequest(
        bucket=bucket.decode('utf8'),
        entity=entity.decode('utf8'),
        )
    result = client.defaultObjectAccessControls.Delete(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


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.StorageDefaultObjectAccessControlsGetRequest(
        bucket=bucket.decode('utf8'),
        entity=entity.decode('utf8'),
        )
    result = client.defaultObjectAccessControls.Get(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class DefaultObjectAccessControlsInsert(apitools_base_cli.NewCmd):
  """Command wrapping defaultObjectAccessControls.Insert."""

  usage = """defaultObjectAccessControls_insert <bucket>"""

  def __init__(self, name, fv):
    super(DefaultObjectAccessControlsInsert, 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(
        '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.',
        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):
    """Creates a new default object ACL entry on the specified bucket.

    Args:
      bucket: The name of the 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.
      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'),
        )
    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 = 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 DefaultObjectAccessControlsList(apitools_base_cli.NewCmd):
  """Command wrapping defaultObjectAccessControls.List."""

  usage = """defaultObjectAccessControls_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)

  def RunWithArgs(self, bucket):
    """Retrieves default object 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(
        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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class DefaultObjectAccessControlsPatch(apitools_base_cli.NewCmd):
  """Command wrapping defaultObjectAccessControls.Patch."""

  usage = """defaultObjectAccessControls_patch <bucket> <entity>"""

  def __init__(self, name, fv):
    super(DefaultObjectAccessControlsPatch, 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(
        '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(
        '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.',
        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, entity):
    """Updates a default object ACL entry on the specified 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.

    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.
      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['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 = 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 DefaultObjectAccessControlsUpdate(apitools_base_cli.NewCmd):
  """Command wrapping defaultObjectAccessControls.Update."""

  usage = """defaultObjectAccessControls_update <bucket> <entity>"""

  def __init__(self, name, fv):
    super(DefaultObjectAccessControlsUpdate, 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(
        '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(
        '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.',
        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, entity):
    """Updates a default object ACL entry on the specified bucket.

    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.

    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.
      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['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 = 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 ObjectAccessControlsDelete(apitools_base_cli.NewCmd):
  """Command wrapping objectAccessControls.Delete."""

  usage = """objectAccessControls_delete <bucket> <object> <entity>"""

  def __init__(self, name, fv):
    super(ObjectAccessControlsDelete, 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)

  def RunWithArgs(self, bucket, object, entity):
    """Permanently deletes the ACL entry for the specified entity on the
    specified object.

    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).
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageObjectAccessControlsDeleteRequest(
        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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class ObjectAccessControlsGet(apitools_base_cli.NewCmd):
  """Command wrapping objectAccessControls.Get."""

  usage = """objectAccessControls_get <bucket> <object> <entity>"""

  def __init__(self, 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)

  def RunWithArgs(self, bucket, object, entity):
    """Returns the ACL entry for the specified entity on the specified object.

    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).
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageObjectAccessControlsGetRequest(
        bucket=bucket.decode('utf8'),
        object=object.decode('utf8'),
        entity=entity.decode('utf8'),
        )
    if FLAGS['generation'].present:
      request.generation = int(FLAGS.generation)
    result = client.objectAccessControls.Get(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class ObjectAccessControlsInsert(apitools_base_cli.NewCmd):
  """Command wrapping objectAccessControls.Insert."""

  usage = """objectAccessControls_insert <bucket> <object>"""

  def __init__(self, name, fv):
    super(ObjectAccessControlsInsert, 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):
    """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',
        None,
        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, object):
    """Retrieves ACL entries 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).
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageObjectAccessControlsListRequest(
        bucket=bucket.decode('utf8'),
        object=object.decode('utf8'),
        )
    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 ObjectAccessControlsPatch(apitools_base_cli.NewCmd):
  """Command wrapping objectAccessControls.Patch."""

  usage = """objectAccessControls_patch <bucket> <object> <entity>"""

  def __init__(self, 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):
    """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',
        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):
    """Updates an ACL entry on the specified object.

    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.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.StorageObjectsCopyRequest(
        sourceBucket=sourceBucket.decode('utf8'),
        sourceObject=sourceObject.decode('utf8'),
        destinationBucket=destinationBucket.decode('utf8'),
        destinationObject=destinationObject.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['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 ObjectsDelete(apitools_base_cli.NewCmd):
  """Command wrapping objects.Delete."""

  usage = """objects_delete <bucket> <object>"""

  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)
    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):
    """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 the bucket in which the object resides.
      object: Name of the object.

    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.
    """
    client = GetClientFromFlags()
    global_params = GetGlobalParamsFromFlags()
    request = messages.StorageObjectsDeleteRequest(
        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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class ObjectsGet(apitools_base_cli.NewCmd):
  """Command wrapping objects.Get."""

  usage = """objects_get <bucket> <object>"""

  def __init__(self, name, fv):
    super(ObjectsGet, 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 generation "
        u'matches the given value.',
        flag_values=fv)
    flags.DEFINE_string(
        'ifGenerationNotMatch',
        None,
        u"Makes the operation conditional on whether the object's generation "
        u'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_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):
    """Retrieves an object or its metadata.

    Args:
      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).
      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.StorageObjectsGetRequest(
        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['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 ObjectsInsert(apitools_base_cli.NewCmd):
  """Command wrapping objects.Insert."""

  usage = """objects_insert <bucket>"""

  def __init__(self, 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"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(
        '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):
    """Stores a new object and metadata.

    Args:
      bucket: Name of the bucket in which to store the new object. Overrides
        the provided object metadata's bucket value, if any.

    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(
        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)
    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 ObjectsList(apitools_base_cli.NewCmd):
  """Command wrapping objects.List."""

  usage = """objects_list <bucket>"""

  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. The default value of this parameter is 1,000 items.',
        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)
    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',
        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):
    """Retrieves a list of objects matching the criteria.

    Args:
      bucket: Name of the bucket in which to look for objects.

    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. 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.StorageObjectsListRequest(
        bucket=bucket.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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class ObjectsPatch(apitools_base_cli.NewCmd):
  """Command wrapping objects.Patch."""

  usage = """objects_patch <bucket> <object>"""

  def __init__(self, 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(
        '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.

    Args:
      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).
      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(
        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.StorageObjectsPatchRequest.PredefinedAclValueValuesEnum(FLAGS.predefinedAcl)
    if FLAGS['projection'].present:
      request.projection = messages.StorageObjectsPatchRequest.ProjectionValueValuesEnum(FLAGS.projection)
    result = client.objects.Patch(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


class ObjectsRewrite(apitools_base_cli.NewCmd):
  """Command wrapping objects.Rewrite."""

  usage = """objects_rewrite <sourceBucket> <sourceObject> <destinationBucket> <destinationObject>"""

  def __init__(self, name, fv):
    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"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(
        '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, 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, sourceBucket, sourceObject, destinationBucket, destinationObject):
    """Rewrites 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.
      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.StorageObjectsRewriteRequest(
        sourceBucket=sourceBucket.decode('utf8'),
        sourceObject=sourceObject.decode('utf8'),
        destinationBucket=destinationBucket.decode('utf8'),
        destinationObject=destinationObject.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.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 ObjectsUpdate(apitools_base_cli.NewCmd):
  """Command wrapping objects.Update."""

  usage = """objects_update <bucket> <object>"""

  def __init__(self, name, fv):
    super(ObjectsUpdate, 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)
    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):
    """Updates an object's metadata.

    Args:
      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).
      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.StorageObjectsUpdateRequest(
        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,
          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 ObjectsWatchAll(apitools_base_cli.NewCmd):
  """Command wrapping objects.WatchAll."""

  usage = """objects_watchAll <bucket>"""

  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. The default value of this parameter is 1,000 items.',
        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)
    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',
        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):
    """Watch for changes on all objects in a bucket.

    Args:
      bucket: Name of the bucket in which to look for objects.

    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. 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.StorageObjectsWatchAllRequest(
        bucket=bucket.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(
        request, global_params=global_params)
    print apitools_base_cli.FormatOutput(result)


def main(_):
  appcommands.AddCmd('pyshell', PyShell)
  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)
  appcommands.AddCmd('objects_get', ObjectsGet)
  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)

  apitools_base_cli.SetupLogger()
  if hasattr(appcommands, 'SetDefaultCommand'):
    appcommands.SetDefaultCommand('pyshell')


run_main = apitools_base_cli.run_main

if __name__ == '__main__':
  appcommands.Run()