move service and make end to end working (#17227)

Author: VasuBhog

src/azureFunction/azureFunctionProjectService.ts

@@ -32,7 +32,6 @@ import { QueryHistoryProvider } from '../queryHistory/queryHistoryProvider';
 import { QueryHistoryNode } from '../queryHistory/queryHistoryNode';
 import { DacFxService } from '../services/dacFxService';
 import { IConnectionInfo } from 'vscode-mssql';
-import { AzureFunctionProjectService } from '../azureFunction/azureFunctionProjectService';
 import { getConnectionString } from '../utils/connectionStringUtil';
 import { SchemaCompareService } from '../services/schemaCompareService';
 import { SqlTasksService } from '../services/sqlTasksService';
@@ -442,7 +441,6 @@ export default class MainController implements vscode.Disposable {
 				}
 			}));
 
-		const afService = new AzureFunctionProjectService(this.azureFunctionsService);
 		// Generate Azure Function command
 		this._context.subscriptions.push(vscode.commands.registerCommand(Constants.cmdCreateAzureFunction, async (node: TreeNodeInfo) => {
 			const database = ObjectExplorerUtils.getDatabaseName(node);
@@ -452,7 +450,7 @@ export default class MainController implements vscode.Disposable {
 				database,
 				node.connectionInfo.user,
 				node.connectionInfo.password);
-			await afService.createAzureFunction(connStr, node.metadata.schema, node.metadata.name);
+			await this.azureFunctionsService.createAzureFunction(connStr, node.metadata.schema, node.metadata.name);
 		}));
 	}
 

src/controllers/mainController.ts

@@ -4,8 +4,13 @@
  * ------------------------------------------------------------------------------------------ */
 
 import SqlToolsServiceClient from '../languageservice/serviceclient';
+import * as vscode from 'vscode';
 import * as mssql from 'vscode-mssql';
 import * as azureFunctionsContracts from '../models/contracts/azureFunctions/azureFunctionsContracts';
+import * as azureFunctionUtils from '../azureFunction/azureFunctionUtils';
+import * as constants from '../constants/constants';
+import { generateQuotedFullName } from '../utils/utils';
+import * as LocalizedConstants from '../constants/localizedConstants';
 
 export const hostFileName: string = 'host.json';
 
@@ -55,4 +60,53 @@ export class AzureFunctionsService implements mssql.IAzureFunctionsService {
 
 		return this._client.sendRequest(azureFunctionsContracts.GetAzureFunctionsRequest.type, params);
 	}
+
+	public async createAzureFunction(connectionString: string, schema: string, table: string): Promise<void> {
+		const azureFunctionApi = await azureFunctionUtils.getAzureFunctionsExtensionApi();
+		if (!azureFunctionApi) {
+			return;
+		}
+		let projectFile = await azureFunctionUtils.getAzureFunctionProject();
+		if (!projectFile) {
+			vscode.window.showErrorMessage(LocalizedConstants.azureFunctionsProjectMustBeOpened);
+			return;
+		}
+
+		// because of an AF extension API issue, we have to get the newly created file by adding
+		// a watcher: https://github.com/microsoft/vscode-azurefunctions/issues/2908
+		const newFilePromise = azureFunctionUtils.waitForNewFunctionFile(projectFile);
+
+		// get function name from user
+		const functionName = await vscode.window.showInputBox({
+			title: constants.functionNameTitle,
+			value: table,
+			ignoreFocusOut: true
+		});
+		if (!functionName) {
+			return;
+		}
+
+		// create C# HttpTrigger
+		await azureFunctionApi.createFunction({
+			language: 'C#',
+			templateId: 'HttpTrigger',
+			functionName: functionName,
+			folderPath: projectFile
+		});
+
+		await azureFunctionUtils.addNugetReferenceToProjectFile(projectFile);
+		await azureFunctionUtils.addConnectionStringToConfig(connectionString, projectFile);
+		const functionFile = await newFilePromise;
+
+		let objectName = generateQuotedFullName(schema, table);
+		await this.addSqlBinding(
+			mssql.BindingType.input,
+			functionFile,
+			functionName,
+			objectName,
+			constants.sqlConnectionString
+		);
+
+		azureFunctionUtils.overwriteAzureFunctionMethodBody(functionFile);
+	}
 }