resource: support generic resource create (#2849)

* resource: add generic create

* address review feedback

Author: yugangw-msft

src/command_modules/azure-cli-resource/HISTORY.rst

@@ -2,6 +2,9 @@
 
 Release History
 ===============
+2.0.3 (unreleased)
+
+* Support generic resource create (#2606)
 
 2.0.3 (2017-04-17)
 ++++++++++++++++++

src/command_modules/azure-cli-resource/azure/cli/command_modules/resource/_help.py

@@ -160,6 +160,18 @@
             az resource tag --tags vmlist=vm1 --id /subscriptions/0b1f6471-1bf0-4dda-aec3-111111111111/resourceGroups/MyResourceGroup/providers/Microsoft.Web/sites/MyWebapp
 """
 
+helps['resource create'] = """
+    type: command
+    short-summary: create a resource.
+    examples:
+       - name: Create a resource by providing a full resource object json. Note, you can also use "@<file>" to load from a json file.
+         text: >
+            az resource create -g myRG -n myPlan --resource-type Microsoft.web/serverFarms --is-full-object --properties "{ \\"location\\":\\"westus\\",\\"sku\\":{\\"name\\":\\"B1\\",\\"tier\\":\\"BASIC\\"}}"
+       - name: Create a resource by only providing resource properties
+         text: >
+            az resource create -g myRG -n myWeb --resource-type Microsoft.web/sites --properties "{\\"serverFarmId\\":\\"myPlan\\"}"
+"""
+
 helps['resource update'] = """
     type: command
     short-summary: Update a resource.

src/command_modules/azure-cli-resource/azure/cli/command_modules/resource/_params.py

@@ -38,6 +38,10 @@
 register_cli_argument('resource', 'tags', tags_type)
 register_cli_argument('resource list', 'name', resource_name_type)
 register_cli_argument('resource move', 'ids', nargs='+')
+register_cli_argument('resource create', 'properties', options_list=('--properties', '-p'),
+                      help='a JSON-formatted string containing resource properties')
+register_cli_argument('resource create', 'is_full_object', action='store_true',
+                      help='Indicates that the properties object includes other options such as location, tags, sku, and/or plan.')
 
 register_cli_argument('provider', 'top', ignore_type)
 register_cli_argument('provider', 'resource_provider_namespace', options_list=('--namespace', '-n'), completer=get_providers_completion_list,

src/command_modules/azure-cli-resource/azure/cli/command_modules/resource/commands.py

@@ -47,6 +47,7 @@ def transform_resource_list(result):
         transformed.append(res)
     return transformed
 
+cli_command(__name__, 'resource create', 'azure.cli.command_modules.resource.custom#create_resource')
 cli_command(__name__, 'resource delete', 'azure.cli.command_modules.resource.custom#delete_resource')
 cli_command(__name__, 'resource show', 'azure.cli.command_modules.resource.custom#show_resource', exception_handler=empty_on_404)
 cli_command(__name__, 'resource list', 'azure.cli.command_modules.resource.custom#list_resources', table_transformer=transform_resource_list)

src/command_modules/azure-cli-resource/azure/cli/command_modules/resource/custom.py

@@ -208,6 +208,14 @@ def export_deployment_as_template(resource_group_name, deployment_name):
     result = smc.deployments.export_template(resource_group_name, deployment_name)
     print(json.dumps(result.template, indent=2))#pylint: disable=no-member
 
+def create_resource(properties, resource_group_name=None, resource_provider_namespace=None,
+                    parent_resource_path=None, resource_type=None, resource_name=None,
+                    resource_id=None, api_version=None, location=None, is_full_object=False):
+    res = _ResourceUtils(resource_group_name, resource_provider_namespace,
+                         parent_resource_path, resource_type, resource_name,
+                         resource_id, api_version)
+    return res.create_resource(properties, location, is_full_object)
+
 def show_resource(resource_group_name=None, resource_provider_namespace=None,
                   parent_resource_path=None, resource_type=None, resource_name=None,
                   resource_id=None, api_version=None):
@@ -747,6 +755,34 @@ def __init__(self, resource_group_name=None, resource_provider_namespace=None,
         self.resource_id = resource_id
         self.api_version = api_version
 
+    def create_resource(self, properties, location, is_full_object):
+        res = json.loads(properties)
+        if not is_full_object:
+            if not location:
+                if self.resource_id:
+                    rg_name = parse_resource_id(self.resource_id)['resource_group']
+                else:
+                    rg_name = self.resource_group_name
+                location = self.rcf.resource_groups.get(rg_name).location
+
+            res = GenericResource(location=location, properties=res)
+        elif res.get('location', None) is None:
+            raise IncorrectUsageError("location of the resource is required")
+
+        if self.resource_id:
+            resource = self.rcf.resources.create_or_update_by_id(self.resource_id,
+                                                                 self.api_version,
+                                                                 res)
+        else:
+            resource = self.rcf.resources.create_or_update(self.resource_group_name,
+                                                           self.resource_provider_namespace,
+                                                           self.parent_resource_path or '',
+                                                           self.resource_type,
+                                                           self.resource_name,
+                                                           self.api_version,
+                                                           res)
+        return resource
+
     def get_resource(self):
         if self.resource_id:
             resource = self.rcf.resources.get_by_id(self.resource_id, self.api_version)