add appservice-kube extension

.github/CODEOWNERS

@@ -132,6 +132,8 @@
 
 /src/kusto/ @ilayr @orhasban @astauben
 
+/src/appservice-kube/ @ebencarek @calcha
+
 /src/custom-providers/ @jsntcy
 
 /src/costmanagement/ @haroldrandom

src/appservice-kube/HISTORY.rst

@@ -0,0 +1,8 @@
+.. :changelog:
+
+Release History
+===============
+
+0.1.0
+++++++
+* Initial release.

src/appservice-kube/README.rst

@@ -0,0 +1,5 @@
+Microsoft Azure CLI 'appservice-kube' Extension
+==========================================
+
+This package is for the 'appservice-kube' extension.
+i.e. 'az appservice-kube'

src/appservice-kube/azext_appservice_kube/__init__.py

@@ -0,0 +1,37 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+from azure.cli.core import AzCommandsLoader
+from azure.cli.core.profiles import register_resource_type
+
+from azext_appservice_kube._help import helps  # pylint: disable=unused-import
+from azext_appservice_kube._client_factory import CUSTOM_MGMT_APPSERVICE
+
+
+class AppserviceCommandsLoader(AzCommandsLoader):
+
+    def __init__(self, cli_ctx=None):
+        from azure.cli.core.commands import CliCommandType
+        register_resource_type('latest', CUSTOM_MGMT_APPSERVICE, '2019-08-01')
+
+        appservice_kube_custom = CliCommandType(
+            operations_tmpl='azext_appservice_kube.custom#{}')
+        super(AppserviceCommandsLoader, self).__init__(cli_ctx=cli_ctx,
+                                                       custom_command_type=appservice_kube_custom,
+                                                       resource_type=CUSTOM_MGMT_APPSERVICE)
+
+    def load_command_table(self, args):
+        super(AppserviceCommandsLoader, self).load_command_table(args)
+        from azext_appservice_kube.commands import load_command_table
+        load_command_table(self, args)
+        return self.command_table
+
+    def load_arguments(self, command):
+        super(AppserviceCommandsLoader, self).load_arguments(command)
+        from azext_appservice_kube._params import load_arguments
+        load_arguments(self, command)
+
+
+COMMAND_LOADER_CLS = AppserviceCommandsLoader

src/appservice-kube/azext_appservice_kube/_client_factory.py

@@ -0,0 +1,56 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+from azure.cli.core.commands.client_factory import get_mgmt_service_client
+from azure.cli.core.profiles import ResourceType, CustomResourceType
+
+CUSTOM_MGMT_APPSERVICE = CustomResourceType('azext_appservice_kube.vendored_sdks.azure_mgmt_web',
+                                            'WebSiteManagementClient')
+
+
+# pylint: disable=inconsistent-return-statements
+def ex_handler_factory(creating_plan=False, no_throw=False):
+    def _polish_bad_errors(ex):
+        import json
+        from knack.util import CLIError
+        try:
+            detail = json.loads(ex.response.text)['Message']
+            if creating_plan:
+                if 'Requested features are not supported in region' in detail:
+                    detail = ("Plan with linux worker is not supported in current region. For " +
+                              "supported regions, please refer to https://docs.microsoft.com/"
+                              "azure/app-service-web/app-service-linux-intro")
+                elif 'Not enough available reserved instance servers to satisfy' in detail:
+                    detail = ("Plan with Linux worker can only be created in a group " +
+                              "which has never contained a Windows worker, and vice versa. " +
+                              "Please use a new resource group. Original error:" + detail)
+            ex = CLIError(detail)
+        except Exception:  # pylint: disable=broad-except
+            pass
+        if no_throw:
+            return ex
+        raise ex
+    return _polish_bad_errors
+
+
+def web_client_factory(cli_ctx, **_):
+    return get_mgmt_service_client(cli_ctx, CUSTOM_MGMT_APPSERVICE)
+
+
+def cf_kube_environments(cli_ctx, *_):
+    return web_client_factory(cli_ctx).kube_environments
+
+
+def cf_plans(cli_ctx, *_):
+    return web_client_factory(cli_ctx).app_service_plans
+
+
+def cf_compute_service(cli_ctx, *_):
+    return get_mgmt_service_client(cli_ctx, ResourceType.MGMT_COMPUTE)
+
+
+def cf_resource_groups(cli_ctx, subscription_id=None):
+    return get_mgmt_service_client(cli_ctx, ResourceType.MGMT_RESOURCE_RESOURCES,
+                                   subscription_id=subscription_id).resource_groups

src/appservice-kube/azext_appservice_kube/_completers.py

@@ -0,0 +1,53 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+from azure.cli.core.decorators import Completer
+from ._utils import _get_location_from_resource_group
+from ._constants import KUBE_DEFAULT_SKU
+
+
+@Completer
+def get_vm_size_completion_list(cmd, prefix, namespace):    # pylint: disable=unused-argument
+    """Return the intersection of the VM sizes allowed by the ACS SDK with those returned by the Compute Service."""
+    from azure.mgmt.containerservice.models import ContainerServiceVMSizeTypes
+
+    location = _get_location(cmd.cli_ctx, namespace)
+    result = get_vm_sizes(cmd.cli_ctx, location)
+    return set(r.name for r in result) & set(c.value for c in ContainerServiceVMSizeTypes)
+
+
+@Completer
+def get_kube_sku_completion_list(cmd, prefix, namespace):   # pylint: disable=unused-argument
+    """
+    Return the VM sizes allowed by AKS, or 'ANY'
+    """
+    return get_vm_size_completion_list(cmd, prefix, namespace) & set(KUBE_DEFAULT_SKU)
+
+
+def get_vm_sizes(cli_ctx, location):
+    from ._client_factory import cf_compute_service
+    return cf_compute_service(cli_ctx).virtual_machine_sizes.list(location)
+
+
+def _get_location(cli_ctx, namespace):
+    """
+    Return an Azure location by using an explicit `--location` argument, then by `--resource-group`, and
+    finally by the subscription if neither argument was provided.
+    """
+    from msrestazure.azure_exceptions import CloudError
+    from azure.cli.core.commands.parameters import get_one_of_subscription_locations
+
+    location = None
+    if getattr(namespace, 'location', None):
+        location = namespace.location
+    elif getattr(namespace, 'resource_group_name', None):
+        try:
+            location = _get_location_from_resource_group(cli_ctx, namespace.resource_group_name)
+        except CloudError as err:
+            from argcomplete import warn
+            warn('Warning: {}'.format(err.message))
+    if not location:
+        location = get_one_of_subscription_locations(cli_ctx)
+    return location

src/appservice-kube/azext_appservice_kube/_constants.py

@@ -0,0 +1,65 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+
+KUBE_DEFAULT_SKU = "ANY"
+KUBE_ASP_KIND = "K8SE"
+KUBE_APP_KIND = "kubeapp"
+
+LINUX_RUNTIMES = ['dotnet', 'node', 'python', 'java']
+WINDOWS_RUNTIMES = ['dotnet', 'node', 'java', 'powershell']
+
+NODE_VERSION_DEFAULT = "10.14"
+
+FUNCTIONS_VERSIONS = ['2', '3']
+
+# functions version : default node version
+FUNCTIONS_VERSION_TO_DEFAULT_NODE_VERSION = {
+    '2': '~10',
+    '3': '~12'
+}
+# functions version -> runtime : default runtime version
+FUNCTIONS_VERSION_TO_DEFAULT_RUNTIME_VERSION = {
+    '2': {
+        'node': '8',
+        'dotnet': '2',
+        'python': '3.7',
+        'java': '8'
+    },
+    '3': {
+        'node': '12',
+        'dotnet': '3',
+        'python': '3.7',
+        'java': '8'
+    }
+}
+# functions version -> runtime : runtime versions
+FUNCTIONS_VERSION_TO_SUPPORTED_RUNTIME_VERSIONS = {
+    '2': {
+        'node': ['8', '10'],
+        'python': ['3.6', '3.7'],
+        'dotnet': ['2'],
+        'java': ['8']
+    },
+    '3': {
+        'node': ['10', '12'],
+        'python': ['3.6', '3.7', '3.8'],
+        'dotnet': ['3'],
+        'java': ['8']
+    }
+}
+# dotnet runtime version : dotnet linuxFxVersion
+DOTNET_RUNTIME_VERSION_TO_DOTNET_LINUX_FX_VERSION = {
+    '2': '2.2',
+    '3': '3.1'
+}
+
+MULTI_CONTAINER_TYPES = ['COMPOSE', 'KUBE']
+
+OS_TYPES = ['Windows', 'Linux']
+
+CONTAINER_APPSETTING_NAMES = ['DOCKER_REGISTRY_SERVER_URL', 'DOCKER_REGISTRY_SERVER_USERNAME',
+                              'DOCKER_REGISTRY_SERVER_PASSWORD', "WEBSITES_ENABLE_APP_SERVICE_STORAGE"]
+APPSETTINGS_TO_MASK = ['DOCKER_REGISTRY_SERVER_PASSWORD']

src/appservice-kube/azext_appservice_kube/_help.py

@@ -0,0 +1,107 @@
+# coding=utf-8
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+from knack.help_files import helps
+# pylint: disable=line-too-long, too-many-lines
+
+helps['appservice plan create'] = """
+type: command
+short-summary: Create an app service plan.
+examples:
+  - name: Create a basic app service plan.
+    text: >
+        az appservice plan create -g MyResourceGroup -n MyPlan
+  - name: Create a standard app service plan with with four Linux workers.
+    text: >
+        az appservice plan create -g MyResourceGroup -n MyPlan \\
+            --is-linux --number-of-workers 4 --sku S1
+  - name: Create an app service plan for app service environment.
+    text: >
+        az appservice plan create -g MyResourceGroup -n MyPlan \\
+            --app-service-environment MyAppServiceEnvironment --sku I1
+  - name: Create an app service plan for a kubernetes environment.
+    text: >
+        az appservice plan create -g MyResourceGroup -n MyPlan \\
+            --kube-environment MyKubeEnvironment --kube-sku ANY
+"""
+
+helps['appservice plan update'] = """
+type: command
+short-summary: Update an app service plan. See https://docs.microsoft.com/azure/app-service/app-service-plan-manage#move-an-app-to-another-app-service-plan to learn more
+examples:
+  - name: Update an app service plan. (autogenerated)
+    text: az appservice plan update --name MyAppServicePlan --resource-group MyResourceGroup --sku F1
+    crafted: true
+  - name: Update a kubernetes app service plan.
+    text: >
+        az appservice plan update --name MyAppServicePlan --resource-group MyResourceGroup \\
+            --kube-sku Standard_DS2_v2 --number-of-workers 3
+"""
+
+helps['appservice kube'] = """
+    type: group
+    short-summary: Manage Kubernetes Environments
+"""
+
+helps['appservice kube create'] = """
+    type: command
+    short-summary: Create a Kubernetes Environment.
+    examples:
+    - name: Create Kubernetes Environment with default values.
+      text: |
+          az appservice kube create -n MyKubeEnvironment -g MyResourceGroup \\
+              --client-id MyServicePrincipalClientId \\
+              --client-secret MyServicePrincipalClientSecret
+"""
+
+helps['appservice kube update'] = """
+    type: command
+    short-summary: Update a Kubernetes Environment.
+    examples:
+    - name: Update the Kubernetes Environment's Log Analytics workspace ID.
+      text: |
+          az appservice kube update -n MyKubeEnvironment -g MyResourceGroup \\
+              --workspace-id MyLogAnalyticsWorkspaceResourceId
+"""
+
+helps['appservice kube show'] = """
+    type: command
+    short-summary: Show the details of a kubernetes environment.
+    examples:
+    - name: Show the details of a Kubernetes Environment.
+      text: |
+          az appservice kube show -n MyKubeEnvironment -g MyResourceGroup
+"""
+
+helps['appservice kube list'] = """
+    type: command
+    short-summary: List kubernetes environments by subscription or resource group.
+    examples:
+    - name: List Kubernetes Environments by subscription.
+      text: |
+          az appservice kube list
+    - name: List Kubernetes Environments by resource group.
+      text: |
+          az appservice kube list -g MyResourceGroup
+"""
+
+helps['appservice kube delete'] = """
+    type: command
+    short-summary: Delete kubernetes environment.
+    examples:
+    - name: Delete Kubernetes Environment.
+      text: az appservice kube delete -g MyResourceGroup -n MyKubeEnvironment
+"""
+
+helps['appservice kube wait'] = """
+    type: command
+    short-summary: Wait for a Kubernetes Environment to reach a desired state.
+    examples:
+    - name: Wait for a Kubernetes Environment to be provisioned, polling every 60 seconds.
+      text: |
+          az appservice kube wait -g MyResourceGroup -n MyKubeEnvironment \\
+              --created --interval 60
+"""