[Service Connector] az webapp connection create fabric-sql: Fix interactive mode & allow new parameters --fabric-workspace-uuid and fabric-sql-db-uuid

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

@@ -11,6 +11,7 @@
 from azure.cli.core.commands.validators import get_default_location_from_resource_group
 
 from ._validators import (
+    validate_connstr_props,
     validate_params,
     validate_kafka_params,
     validate_local_params,
@@ -34,7 +35,7 @@
 )
 from ._addon_factory import AddonFactory
 from knack.arguments import CLIArgumentType
-from .action import AddCustomizedKeys, AddAdditionalConnectionStringProperties
+from .action import AddAdditionalConnectionStringProperties, AddCustomizedKeys
 
 
 def add_source_resource_block(context, source, enable_id=True, target=None):
@@ -184,8 +185,9 @@ def add_connstr_props_argument(context):
     # linter: length '--additional-connection-string-properties' longer than 22, so use abbreviation
     context.argument('connstr_props', options_list=['--connstr-props'],
                      action=AddAdditionalConnectionStringProperties, nargs='*',
-                     help='The addtional connection string properties used to for building connection string.')
-
+                     help='The additional connection string properties used to build connection string.',
+                     validator=validate_connstr_props)
+
 
 def add_target_type_argument(context, source):
     TARGET_TYPES = [
@@ -317,6 +319,7 @@ def load_arguments(self, _):  # pylint: disable=too-many-statements
                 add_customized_keys_argument(c)
                 add_opt_out_argument(c)
                 add_connstr_props_argument(c)
+
             with self.argument_context('{} connection update {}'.format(source.value, target.value)) as c:
                 add_client_type_argument(c, source, target)
                 add_connection_name_argument(c, source)

src/azure-cli/azure/cli/command_modules/serviceconnector/_resource_config.py

@@ -155,7 +155,7 @@ class CLIENT_TYPE(Enum):
 
     RESOURCE.ContainerApp: '/subscriptions/{subscription}/resourceGroups/{target_resource_group}/providers/Microsoft.App/containerApps/{target_app_name}',
 
-    RESOURCE.FabricSql: 'https://api.fabric.microsoft.com/v1/workspaces/{workspace_id}/SqlDatabases/{sql_id}'
+    RESOURCE.FabricSql: 'https://api.fabric.microsoft.com/v1/workspaces/{fabric_workspace_uuid}/SqlDatabases/{fabric_sql_db_uuid}'
 }
 
 
@@ -670,6 +670,16 @@ class CLIENT_TYPE(Enum):
         }
     },
     RESOURCE.FabricSql: {
+        'fabric_workspace_uuid': {
+            'options': ['--fabric-workspace-uuid'],
+            'help': 'UUID of Fabric workspace which contains the target SQL database',
+            'placeholder': 'TargetFabricWorkspaceUUID'
+        },
+        'fabric_sql_db_uuid': {
+            'options': ['--fabric-sql-db-uuid'],
+            'help': 'UUID of the target Fabric SQL database',
+            'placeholder': 'TargetFabricSQLDatabaseUUID'
+        }
     }
 }
 

src/azure-cli/azure/cli/command_modules/serviceconnector/_validators.py

@@ -3,6 +3,7 @@
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
 
+import json
 import re
 import random
 import string
@@ -22,6 +23,7 @@
     InvalidArgumentValueError,
     RequiredArgumentMissingError,
 )
+import requests
 
 from ._utils import (
     run_cli_cmd,
@@ -100,17 +102,42 @@ def get_resource_regex(resource):
     return regex
 
 
-def check_required_args(resource, cmd_arg_values):
+def check_required_args(resource, cmd_arg_values, is_azure_resource=True):
     '''Check whether a resource's required arguments are in cmd_arg_values
     '''
     args = re.findall(r'\{([^\{\}]*)\}', resource)
-    args.remove('subscription')
+
+    if is_azure_resource:
+        args.remove('subscription')
     for arg in args:
         if not cmd_arg_values.get(arg, None):
             return False
     return True
 
 
+def get_fabric_access_token():
+    return run_cli_cmd('az account get-access-token --output json --resource https://api.fabric.microsoft.com/').get('accessToken')
+
+
+def generate_fabric_connstr_props(target_id):
+    fabric_token = get_fabric_access_token()
+    headers = {"Authorization": "Bearer {}".format(fabric_token)}
+    response = requests.get(target_id, headers=headers)
+
+    if response:
+        response_json = response.json()
+
+        if "properties" in response_json:
+            properties = response_json["properties"]
+            if "databaseName" in properties and "serverFqdn" in properties:
+                return {
+                    "Server": properties["serverFqdn"],
+                    "Database": properties["databaseName"]
+                }
+
+    return None
+
+
 def generate_connection_name(cmd):
     '''Generate connection name for users if not provided
     '''
@@ -747,7 +774,7 @@ def apply_target_args(cmd, namespace, arg_values):
     '''
     target = get_target_resource_name(cmd)
     resource = TARGET_RESOURCES.get(target)
-    if check_required_args(resource, arg_values):
+    if check_required_args(resource, arg_values, target not in [RESOURCE.FabricSql]):
         namespace.target_id = resource.format(
             subscription=get_subscription_id(cmd.cli_ctx),
             **arg_values
@@ -942,6 +969,20 @@ def _validate_and_apply(validate, apply):
             namespace.client_type = get_client_type(cmd, namespace)
 
 
+def validate_connstr_props(cmd, namespace):
+    if 'create {}'.format(RESOURCE.FabricSql.value) in cmd.name:
+        if getattr(namespace, 'connstr_props', None) is None:
+            namespace.connstr_props = generate_fabric_connstr_props(namespace.target_id)
+        else:
+            fabric_server = namespace.connstr_props.get('Server') or namespace.connstr_props.get('Data Source')
+            fabric_database = namespace.connstr_props.get('Database') or namespace.connstr_props.get('Initial Catalog')
+
+            if not fabric_server or not fabric_database:
+                e = InvalidArgumentValueError("Fabric Connection String Properties must contain Server and Database")
+                telemetry.set_exception('fabric-connstr-props-invalid')
+                raise e
+
+
 def validate_service_state(linker_parameters):
     '''Validate whether user provided params are applicable to service state
     '''