Add Service Connector

package.json

@@ -165,6 +165,21 @@
                 "command": "containerApps.stopStreamingLogs",
                 "title": "%containerApps.stopStreamingLogs%",
                 "category": "Azure Container Apps"
+            },
+            {
+                "command": "containerApps.createServiceConnector",
+                "title": "%containerApps.createServiceConnector%",
+                "category": "Azure Container Apps"
+            },
+            {
+                "command": "containerApps.deleteServiceConnector",
+                "title": "%containerApps.deleteServiceConnector%",
+                "category": "Azure Container Apps"
+            },
+            {
+                "command": "containerApps.validateServiceConnector",
+                "title": "%containerApps.validateServiceConnector%",
+                "category": "Azure Container Apps"
             }
         ],
         "menus": {
@@ -277,6 +292,21 @@
                     "command": "containerApps.stopStreamingLogs",
                     "when": "view == azureResourceGroups && viewItem =~ /containerApp[^s]/i",
                     "group": "4@2"
+                },
+                {
+                    "command": "containerApps.createServiceConnector",
+                    "when": "view == azureResourceGroups && viewItem =~ /containerApp[^s]/i",
+                    "group": "4@3"
+                },
+                {
+                    "command": "containerApps.deleteServiceConnector",
+                    "when": "view == azureResourceGroups && viewItem =~ /containerApp[^s]/i",
+                    "group": "4@4"
+                },
+                {
+                    "command": "containerApps.validateServiceConnector",
+                    "when": "view == azureResourceGroups && viewItem =~ /containerApp[^s]/i",
+                    "group": "4@5"
                 }
             ],
             "commandPalette": [
@@ -374,9 +404,10 @@
         "@azure/arm-operationalinsights": "^8.0.0",
         "@azure/arm-resources": "^5.0.1",
         "@azure/container-registry": "1.0.0-beta.5",
-        "@azure/storage-blob": "^12.4.1",
         "@azure/core-rest-pipeline": "1.10.3",
+        "@azure/storage-blob": "^12.4.1",
         "@microsoft/vscode-azext-azureutils": "^1.0.1",
+        "@microsoft/vscode-azext-serviceconnector": "file:../vscode-azuretools/serviceconnector/microsoft-vscode-azext-serviceconnector-0.0.1.tgz",
         "@microsoft/vscode-azext-utils": "^1.2.0",
         "@microsoft/vscode-azureresources-api": "^2.0.2",
         "@octokit/rest": "^18.5.2",

package.nls.json

@@ -29,5 +29,8 @@
     "containerApps.addScaleRule": "Add Scale Rule...",
     "containerApps.connectToGitHub": "Connect to GitHub Repository...",
     "containerApps.startStreamingLogs": "Start Streaming Logs...",
-    "containerApps.stopStreamingLogs": "Stop Streaming Logs..."
+    "containerApps.stopStreamingLogs": "Stop Streaming Logs...",
+    "containerApps.createServiceConnector": "Create Service Connector...",
+    "containerApps.deleteServiceConnector": "Delete Service Connector...",
+    "containerApps.validateServiceConnector": "Validate Service Connector..."
 }

src/commands/registerCommands.ts

@@ -25,6 +25,9 @@ import { deactivateRevision } from './revisionCommands/deactivateRevision';
 import { restartRevision } from './revisionCommands/restartRevision';
 import { addScaleRule } from './scaling/addScaleRule/addScaleRule';
 import { editScalingRange } from './scaling/editScalingRange';
+import { createServiceConnector } from './serviceConnector/createServiceConnector';
+import { deleteServiceConnector } from './serviceConnector/deleteServiceConnector';
+import { validateServiceConnector } from './serviceConnector/validateServiceConnector';
 
 export function registerCommands(): void {
     // managed environments
@@ -62,6 +65,11 @@ export function registerCommands(): void {
     registerCommandWithTreeNodeUnwrapping('containerApps.startStreamingLogs', startStreamingLogs);
     registerCommandWithTreeNodeUnwrapping('containerApps.stopStreamingLogs', stopStreamingLogs);
 
+    // service connector
+    registerCommandWithTreeNodeUnwrapping('containerApps.createServiceConnector', createServiceConnector);
+    registerCommandWithTreeNodeUnwrapping('containerApps.deleteServiceConnector', deleteServiceConnector);
+    registerCommandWithTreeNodeUnwrapping('containerApps.validateServiceConnector', validateServiceConnector);
+
     // Suppress "Report an Issue" button for all errors in favor of the command
     registerErrorHandler(c => c.errorHandling.suppressReportIssue = true);
     registerReportIssueCommand('containerApps.reportIssue');

src/commands/serviceConnector/ContainerPickStep.ts

@@ -0,0 +1,36 @@
+/*---------------------------------------------------------------------------------------------
+*  Copyright (c) Microsoft Corporation. All rights reserved.
+*  Licensed under the MIT License. See License.md in the project root for license information.
+*--------------------------------------------------------------------------------------------*/
+
+import { AzureWizardPromptStep, IAzureQuickPickItem, nonNullValue } from "@microsoft/vscode-azext-utils";
+import { localize } from "../../utils/localize";
+import { IServiceConnectorContext } from "./IServiceConnectorContext";
+
+export class ContainerPickStep extends AzureWizardPromptStep<IServiceConnectorContext> {
+    public async prompt(context: IServiceConnectorContext): Promise<void> {
+        const placeHolder: string = localize('selectStream', 'Select a container');
+        context.scope = (await context.ui.showQuickPick(this.getPicks(context), { placeHolder })).data;
+    }
+
+    public shouldPrompt(context: IServiceConnectorContext): boolean {
+        return !context.scope;
+    }
+
+    public async configureBeforePrompt(context: IServiceConnectorContext): Promise<void> {
+        const picks = await this.getPicks(context);
+        if (picks.length === 1) {
+            context.scope = picks[0].data;
+        }
+    }
+
+    private async getPicks(context: IServiceConnectorContext): Promise<IAzureQuickPickItem<string>[]> {
+        const containers = nonNullValue(context.containerApp.template?.containers);
+        return containers.map(c => {
+            return {
+                label: nonNullValue(c.name),
+                data: nonNullValue(c.name)
+            }
+        })
+    }
+}

src/commands/serviceConnector/IServiceConnectorContext.ts

@@ -0,0 +1,11 @@
+/*---------------------------------------------------------------------------------------------
+*  Copyright (c) Microsoft Corporation. All rights reserved.
+*  Licensed under the MIT License. See License.md in the project root for license information.
+*--------------------------------------------------------------------------------------------*/
+
+import { ICreateLinkerContext } from "@microsoft/vscode-azext-serviceconnector";
+import { ContainerAppModel } from "../../tree/ContainerAppItem";
+
+export interface IServiceConnectorContext extends ICreateLinkerContext {
+    containerApp: ContainerAppModel;
+}

src/commands/serviceConnector/createServiceConnector.ts

@@ -0,0 +1,31 @@
+/*---------------------------------------------------------------------------------------------
+*  Copyright (c) Microsoft Corporation. All rights reserved.
+*  Licensed under the MIT License. See License.md in the project root for license information.
+*--------------------------------------------------------------------------------------------*/
+
+import { ICreateLinkerContext, createLinker } from "@microsoft/vscode-azext-serviceconnector";
+import { AzureWizardPromptStep } from "@microsoft/vscode-azext-utils";
+import { ContainerAppItem } from "../../tree/ContainerAppItem";
+import { createActivityContext } from "../../utils/activityUtils";
+import { localize } from "../../utils/localize";
+import { pickContainerApp } from "../../utils/pickContainerApp";
+import { ContainerPickStep } from "./ContainerPickStep";
+import { IServiceConnectorContext } from "./IServiceConnectorContext";
+
+export async function createServiceConnector(context: ICreateLinkerContext, item?: ContainerAppItem): Promise<void> {
+    item ??= await pickContainerApp(context);
+    const { subscription, containerApp } = item;
+
+    const activityContext = {
+        ...context,
+        ...await createActivityContext(),
+        containerApp: containerApp,
+        activityTitle: localize('createServiceConnector', 'Create Service Connector'),
+    }
+
+    const promptSteps: AzureWizardPromptStep<IServiceConnectorContext>[] = [
+        new ContainerPickStep(),
+    ];
+
+    await createLinker(activityContext, { id: containerApp.id, subscription }, promptSteps);
+}