Update checked in version of gsutil to version 4.6

gslib/commands/mb.py

+# -*- coding: utf-8 -*-
 # Copyright 2011 Google Inc. All Rights Reserved.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
 #     http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+"""Implementation of mb command for creating cloud storage buckets."""
 
-import boto
+from __future__ import absolute_import
+
 import textwrap
 
+from gslib.cloud_api import BadRequestException
 from gslib.command import Command
-from gslib.command import COMMAND_NAME
-from gslib.command import COMMAND_NAME_ALIASES
-from gslib.command import FILE_URIS_OK
-from gslib.command import MAX_ARGS
-from gslib.command import MIN_ARGS
-from gslib.command import PROVIDER_URIS_OK
-from gslib.command import SUPPORTED_SUB_ARGS
-from gslib.command import URIS_START_ARG
+from gslib.cs_api_map import ApiSelector
 from gslib.exception import CommandException
-from gslib.help_provider import HELP_NAME
-from gslib.help_provider import HELP_NAME_ALIASES
-from gslib.help_provider import HELP_ONE_LINE_SUMMARY
-from gslib.help_provider import HELP_TEXT
-from gslib.help_provider import HelpType
-from gslib.help_provider import HELP_TYPE
+from gslib.storage_url import StorageUrlFromString
+from gslib.third_party.storage_apitools import storage_v1_messages as apitools_messages
 from gslib.util import NO_MAX
 
-_detailed_help_text = ("""
+
+_DETAILED_HELP_TEXT = ("""
 <B>SYNOPSIS</B>
   gsutil mb [-c class] [-l location] [-p proj_id] uri...
 
 
 <B>DESCRIPTION</B>
   The mb command creates a new bucket. Google Cloud Storage has a single
   namespace, so you will not be allowed to create a bucket with a name already
   in use by another user. You can, however, carve out parts of the bucket name
   space corresponding to your company's domain name (see "gsutil help naming").
 
@@ skipping 21 matching lines @@
   lower availability is acceptable. Durable Reduced Availability storage would
   not be appropriate for "hot" objects (i.e., objects being accessed frequently)
   or for interactive workloads; however, it might be appropriate for other types
   of applications. See the online documentation for pricing and SLA details.
 
 
 <B>BUCKET LOCATIONS</B>
   If you don't specify a -l option, the bucket will be created in the default
   location (US). Otherwise, you can specify one of the available locations:
 
+  - ASIA (Asia)
+  - ASIA-EAST1 (Eastern Asia-Pacific)
   - EU (European Union)
-  - US (United States
+  - US (United States)
   - US-EAST1 (Eastern United States) [1]_
   - US-EAST2 (Eastern United States) [1]_
   - US-EAST3 (Eastern United States) [1]_
   - US-CENTRAL1 (Central United States) [1]_
   - US-CENTRAL2 (Central United States) [1]_
   - US-WEST1 (Western United States) [1]_
 
   .. [1] These locations are for `Regional Buckets <https://developers.google.com/storage/docs/regional-buckets>`_.
      Regional Buckets is an experimental feature and data stored in these
      locations is not subject to the usual SLA. See the documentation for
@@ skipping 12 matching lines @@
   -l location       Can be any of the locations described above. Default is US.
                     Locations are case insensitive.
 
   -p proj_id        Specifies the project ID under which to create the bucket.
 """)
 
 
 class MbCommand(Command):
   """Implementation of gsutil mb command."""
 
-  # Command specification (processed by parent class).
-  command_spec = {
-    # Name of command.
-    COMMAND_NAME : 'mb',
-    # List of command name aliases.
-    COMMAND_NAME_ALIASES : ['makebucket', 'createbucket', 'md', 'mkdir'],
-    # Min number of args required by this command.
-    MIN_ARGS : 1,
-    # Max number of args required by this command, or NO_MAX.
-    MAX_ARGS : NO_MAX,
-    # Getopt-style string specifying acceptable sub args.
-    SUPPORTED_SUB_ARGS : 'c:l:p:',
-    # True if file URIs acceptable for this command.
-    FILE_URIS_OK : False,
-    # True if provider-only URIs acceptable for this command.
-    PROVIDER_URIS_OK : False,
-    # Index in args of first URI arg.
-    URIS_START_ARG : 0,
-  }
-  help_spec = {
-    # Name of command or auxiliary help info for which this help applies.
-    HELP_NAME : 'mb',
-    # List of help name aliases.
-    HELP_NAME_ALIASES : ['createbucket', 'makebucket', 'md', 'mkdir',
-                         'location', 'dra', 'dras', 'reduced_availability',
-                         'durable_reduced_availability',
-                         'rr', 'reduced_redundancy',
-                         'standard', 'storage class' ],
-    # Type of help:
-    HELP_TYPE : HelpType.COMMAND_HELP,
-    # One line summary of this help.
-    HELP_ONE_LINE_SUMMARY : 'Make buckets',
-    # The full help text.
-    HELP_TEXT : _detailed_help_text,
-  }
+  # Command specification. See base class for documentation.
+  command_spec = Command.CreateCommandSpec(
+      'mb',
+      command_name_aliases=['makebucket', 'createbucket', 'md', 'mkdir'],
+      min_args=1,
+      max_args=NO_MAX,
+      supported_sub_args='c:l:p:',
+      file_url_ok=False,
+      provider_url_ok=False,
+      urls_start_arg=0,
+      gs_api_support=[ApiSelector.XML, ApiSelector.JSON],
+      gs_default_api=ApiSelector.JSON,
+  )
+  # Help specification. See help_provider.py for documentation.
+  help_spec = Command.HelpSpec(
+      help_name='mb',
+      help_name_aliases=[
+          'createbucket', 'makebucket', 'md', 'mkdir', 'location', 'dra',
+          'dras', 'reduced_availability', 'durable_reduced_availability', 'rr',
+          'reduced_redundancy', 'standard', 'storage class'],
+      help_type='command_help',
+      help_one_line_summary='Make buckets',
+      help_text=_DETAILED_HELP_TEXT,
+      subcommand_help_text={},
+  )
 
-  # Command entry point.
   def RunCommand(self):
-    location = ''
-    storage_class = ''
+    """Command entry point for the mb command."""
+    location = None
+    storage_class = None
     if self.sub_opts:
       for o, a in self.sub_opts:
         if o == '-l':
           location = a
         elif o == '-p':
-          self.proj_id_handler.SetProjectId(a)
+          self.project_id = a
         elif o == '-c':
           storage_class = self._Normalize_Storage_Class(a)
 
-    if not self.headers:
-      headers = {}
-    else:
-      headers = self.headers.copy()
+    bucket_metadata = apitools_messages.Bucket(location=location,
+                                               storageClass=storage_class)
 
     for bucket_uri_str in self.args:
-      bucket_uri = self.suri_builder.StorageUri(bucket_uri_str)
-      if not bucket_uri.names_bucket():
+      bucket_uri = StorageUrlFromString(bucket_uri_str)
+      if not bucket_uri.IsBucket():
         raise CommandException('The mb command requires a URI that specifies a '
                                'bucket.\n"%s" is not valid.' % bucket_uri)
-      self.proj_id_handler.FillInProjectHeaderIfNeeded('mb', bucket_uri,
-                                                       headers)
+
       self.logger.info('Creating %s...', bucket_uri)
       # Pass storage_class param only if this is a GCS bucket. (In S3 the
       # storage class is specified on the key object.)
-      if bucket_uri.scheme == 'gs':
-        try:
-          bucket_uri.create_bucket(headers=headers, location=location,
-                                   storage_class=storage_class)
-        except boto.exception.StorageResponseError as e:
-          if e.status == 400 and e.code == 'DotfulBucketNameNotUnderTld':
-            bucket_name = bucket_uri.bucket_name
-            final_comp = bucket_name[bucket_name.rfind('.')+1:]
-            raise CommandException('\n'.join(textwrap.wrap(
+      try:
+        self.gsutil_api.CreateBucket(
+            bucket_uri.bucket_name, project_id=self.project_id,
+            metadata=bucket_metadata, provider=bucket_uri.scheme)
+      except BadRequestException as e:
+        if (e.status == 400 and e.reason == 'DotfulBucketNameNotUnderTld' and
+            bucket_uri.scheme == 'gs'):
+          bucket_name = bucket_uri.bucket_name
+          final_comp = bucket_name[bucket_name.rfind('.')+1:]
+          raise CommandException('\n'.join(textwrap.wrap(
               'Buckets with "." in the name must be valid DNS names. The bucket'
               ' you are attempting to create (%s) is not a valid DNS name,'
               ' because the final component (%s) is not currently a valid part'
               ' of the top-level DNS tree.' % (bucket_name, final_comp))))
-          else:
-            raise
-      else:
-        bucket_uri.create_bucket(headers=headers, location=location)
+        else:
+          raise
 
     return 0
 
   def _Normalize_Storage_Class(self, sc):
     sc = sc.upper()
     if sc in ('DRA', 'DURABLE_REDUCED_AVAILABILITY'):
       return 'DURABLE_REDUCED_AVAILABILITY'
     if sc in ('S', 'STD', 'STANDARD'):
       return 'STANDARD'
     return sc