Add ServiceBus and SQL

app/v3-oldConfig/cosmosDBTrigger/function.json

@@ -6,7 +6,7 @@
             "direction": "in",
             "leaseCollectionName": "leases",
             "connectionStringSetting": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "collectionName": "e2eTestContainerTrigger",
             "createLeaseCollectionIfNotExists": true,
             "leaseCollectionPrefix": "2"

app/v3-oldConfig/cosmosDBTriggerAndOutput/function.json

@@ -6,7 +6,7 @@
             "direction": "in",
             "leaseCollectionName": "leases",
             "connectionStringSetting": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "collectionName": "e2eTestContainerTriggerAndOutput",
             "createLeaseCollectionIfNotExists": true,
             "leaseCollectionPrefix": "1"
@@ -16,7 +16,7 @@
             "name": "$return",
             "direction": "out",
             "connectionStringSetting": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "collectionName": "e2eTestContainerTrigger"
         }
     ],

app/v3-oldConfig/httpTriggerCosmosDBInput/function.json

@@ -17,7 +17,7 @@
             "name": "inputDoc",
             "direction": "in",
             "connectionStringSetting": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "collectionName": "e2eTestContainerTriggerAndOutput",
             "partitionKey": "testPartKey",
             "id": "{Query.id}"

app/v3-oldConfig/httpTriggerCosmosDBOutput/function.json

@@ -17,7 +17,7 @@
             "name": "outputDoc",
             "direction": "out",
             "connectionStringSetting": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "collectionName": "e2eTestContainerTriggerAndOutput"
         }
     ],

app/v3/cosmosDBTrigger/function.json

@@ -6,7 +6,7 @@
             "direction": "in",
             "leaseContainerName": "leases",
             "connection": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "containerName": "e2eTestContainerTrigger",
             "createLeaseContainerIfNotExists": true,
             "leaseContainerPrefix": "2"

app/v3/cosmosDBTriggerAndOutput/function.json

@@ -6,7 +6,7 @@
             "direction": "in",
             "leaseContainerName": "leases",
             "connection": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "containerName": "e2eTestContainerTriggerAndOutput",
             "createLeaseContainerIfNotExists": true,
             "leaseContainerPrefix": "1"
@@ -16,7 +16,7 @@
             "name": "$return",
             "direction": "out",
             "connection": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "containerName": "e2eTestContainerTrigger"
         }
     ],

app/v3/httpTriggerCosmosDBInput/function.json

@@ -17,7 +17,7 @@
             "name": "inputDoc",
             "direction": "in",
             "connection": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "containerName": "e2eTestContainerTriggerAndOutput",
             "partitionKey": "testPartKey",
             "id": "{Query.id}"

app/v3/httpTriggerCosmosDBOutput/function.json

@@ -17,7 +17,7 @@
             "name": "outputDoc",
             "direction": "out",
             "connection": "CosmosDBConnection",
-            "databaseName": "e2eTestDB",
+            "databaseName": "e2eTestCosmosDB",
             "containerName": "e2eTestContainerTriggerAndOutput"
         }
     ],

app/v3/httpTriggerServiceBusOutput/function.json

@@ -16,8 +16,8 @@
             "type": "serviceBus",
             "name": "outputMsg",
             "direction": "out",
-            "connection": "e2eTest_serviceBus",
-            "queueName": "e2eTestQueueOneTrigger"
+            "connection": "ServiceBusConnection",
+            "queueName": "e2e-test-queue-one-trigger"
         }
     ],
     "scriptFile": "../dist/httpTriggerServiceBusOutput/index.js"

app/v3/httpTriggerServiceBusOutput/index.ts

@@ -1,14 +1,14 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context, HttpRequest } from '@azure/functions';
+import { AzureFunction, Context, HttpRequest } from '@azure/functions';
 
-// const httpTriggerServiceBusOutput: AzureFunction = async function (
-//     context: Context,
-//     request: HttpRequest
-// ): Promise<void> {
-//     context.bindings.outputMsg = request.body.output;
-//     context.res = { body: 'done' };
-// };
+const httpTriggerServiceBusOutput: AzureFunction = async function (
+    context: Context,
+    request: HttpRequest
+): Promise<void> {
+    context.bindings.outputMsg = request.body.output;
+    context.res = { body: 'done' };
+};
 
-// export default httpTriggerServiceBusOutput;
+export default httpTriggerServiceBusOutput;

app/v3/httpTriggerSqlInput/function.json

@@ -16,11 +16,11 @@
             "type": "sql",
             "name": "inputItem",
             "direction": "in",
-            "connectionStringSetting": "e2eTest_sql",
+            "connectionStringSetting": "SqlConnection",
             "commandText": "select * from dbo.e2eSqlNonTriggerTable where id = @id",
             "commandType": "Text",
             "parameters": "@id={Query.id}"
         }
     ],
     "scriptFile": "../dist/httpTriggerSqlInput/index.js"
-}
+}

app/v3/httpTriggerSqlInput/index.ts

@@ -1,13 +1,13 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context, HttpRequest } from '@azure/functions';
+import { AzureFunction, Context, HttpRequest } from '@azure/functions';
 
-// const httpTriggerSqlInput: AzureFunction = async function (context: Context, _request: HttpRequest): Promise<void> {
-//     context.log(`httpTriggerSqlInput was triggered`);
-//     context.res = {
-//         body: context.bindings.inputItem,
-//     };
-// };
+const httpTriggerSqlInput: AzureFunction = async function (context: Context, _request: HttpRequest): Promise<void> {
+    context.log(`httpTriggerSqlInput was triggered`);
+    context.res = {
+        body: context.bindings.inputItem,
+    };
+};
 
-// export default httpTriggerSqlInput;
+export default httpTriggerSqlInput;

app/v3/httpTriggerSqlOutput/function.json

@@ -16,9 +16,9 @@
             "type": "sql",
             "name": "outputItem",
             "direction": "out",
-            "connectionStringSetting": "e2eTest_sql",
+            "connectionStringSetting": "SqlConnection",
             "commandText": "dbo.e2eSqlNonTriggerTable"
         }
     ],
     "scriptFile": "../dist/httpTriggerSqlOutput/index.js"
-}
+}

app/v3/httpTriggerSqlOutput/index.ts

@@ -1,14 +1,14 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context, HttpRequest } from '@azure/functions';
+import { AzureFunction, Context, HttpRequest } from '@azure/functions';
 
-// const httpTriggerSqlOutput: AzureFunction = async function (context: Context, request: HttpRequest): Promise<void> {
-//     context.log(`httpTriggerSqlOutput was triggered`);
-//     context.bindings.outputItem = request.body;
-//     context.res = {
-//         status: 201,
-//     };
-// };
+const httpTriggerSqlOutput: AzureFunction = async function (context: Context, request: HttpRequest): Promise<void> {
+    context.log(`httpTriggerSqlOutput was triggered`);
+    context.bindings.outputItem = request.body;
+    context.res = {
+        status: 201,
+    };
+};
 
-// export default httpTriggerSqlOutput;
+export default httpTriggerSqlOutput;

app/v3/serviceBusQueueManyTrigger/function.json

@@ -4,8 +4,8 @@
             "name": "mySbMsg",
             "type": "serviceBusTrigger",
             "direction": "in",
-            "queueName": "e2eTestQueueManyTrigger",
-            "connection": "e2eTest_serviceBus",
+            "queueName": "e2e-test-queue-many-trigger",
+            "connection": "ServiceBusConnection",
             "cardinality": "many"
         }
     ],

app/v3/serviceBusQueueManyTrigger/index.ts

@@ -1,12 +1,12 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const serviceBusQueueTrigger: AzureFunction = async function (context: Context, messages: any): Promise<void> {
-//     for (const message of messages) {
-//         context.log(`serviceBusQueueManyTrigger was triggered by "${message}"`);
-//     }
-// };
+const serviceBusQueueTrigger: AzureFunction = async function (context: Context, messages: any): Promise<void> {
+    for (const message of messages) {
+        context.log(`serviceBusQueueManyTrigger was triggered by "${message}"`);
+    }
+};
 
-// export default serviceBusQueueTrigger;
+export default serviceBusQueueTrigger;

app/v3/serviceBusQueueManyTriggerAndOutput/function.json

@@ -4,16 +4,16 @@
             "name": "mySbMsg",
             "type": "serviceBusTrigger",
             "direction": "in",
-            "queueName": "e2eTestQueueManyTriggerAndOutput",
-            "connection": "e2eTest_serviceBus",
+            "queueName": "e2e-test-queue-many-trigger-and-output",
+            "connection": "ServiceBusConnection",
             "cardinality": "many"
         },
         {
             "name": "$return",
             "type": "serviceBus",
             "direction": "out",
-            "topicName": "e2eTestQueueManyTrigger",
-            "connection": "e2eTest_serviceBus"
+            "topicName": "e2e-test-queue-many-trigger",
+            "connection": "ServiceBusConnection"
         }
     ],
     "scriptFile": "../dist/serviceBusQueueManyTriggerAndOutput/index.js"

app/v3/serviceBusQueueManyTriggerAndOutput/index.ts

@@ -1,16 +1,16 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const serviceBusQueueTrigger: AzureFunction = async function (context: Context, messages: any): Promise<string> {
-//     for (const message of messages) {
-//         context.log(`serviceBusQueueManyTriggerAndOutput was triggered by "${message}"`);
-//     }
+const serviceBusQueueTrigger: AzureFunction = async function (context: Context, messages: any): Promise<string> {
+    for (const message of messages) {
+        context.log(`serviceBusQueueManyTriggerAndOutput was triggered by "${message}"`);
+    }
 
-//     // do an extra stringify to make sure the values are JSON-parse-able otherwise it'll hit this bug:
-//     // https://github.com/Azure/azure-functions-eventhubs-extension/issues/118
-//     return messages.map((m) => JSON.stringify(m));
-// };
+    // do an extra stringify to make sure the values are JSON-parse-able otherwise it'll hit this bug:
+    // https://github.com/Azure/azure-functions-eventhubs-extension/issues/118
+    return messages.map((m) => JSON.stringify(m));
+};
 
-// export default serviceBusQueueTrigger;
+export default serviceBusQueueTrigger;

app/v3/serviceBusQueueTrigger/function.json

@@ -4,8 +4,8 @@
             "name": "mySbMsg",
             "type": "serviceBusTrigger",
             "direction": "in",
-            "queueName": "e2eTestQueueOneTrigger",
-            "connection": "e2eTest_serviceBus"
+            "queueName": "e2e-test-queue-one-trigger",
+            "connection": "ServiceBusConnection"
         }
     ],
     "scriptFile": "../dist/serviceBusQueueTrigger/index.js"

app/v3/serviceBusQueueTrigger/index.ts

@@ -1,10 +1,10 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const serviceBusQueueTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<void> {
-//     context.log(`serviceBusQueueTrigger was triggered by "${mySbMsg}"`);
-// };
+const serviceBusQueueTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<void> {
+    context.log(`serviceBusQueueTrigger was triggered by "${mySbMsg}"`);
+};
 
-// export default serviceBusQueueTrigger;
+export default serviceBusQueueTrigger;

app/v3/serviceBusQueueTriggerAndOutput/function.json

@@ -4,15 +4,15 @@
             "name": "mySbMsg",
             "type": "serviceBusTrigger",
             "direction": "in",
-            "queueName": "e2eTestQueueOneTriggerAndOutput",
-            "connection": "e2eTest_serviceBus"
+            "queueName": "e2e-test-queue-one-trigger-and-output",
+            "connection": "ServiceBusConnection"
         },
         {
             "name": "$return",
             "type": "serviceBus",
             "direction": "out",
-            "topicName": "e2eTestQueueOneTrigger",
-            "connection": "e2eTest_serviceBus"
+            "topicName": "e2e-test-queue-one-trigger",
+            "connection": "ServiceBusConnection"
         }
     ],
     "scriptFile": "../dist/serviceBusQueueTriggerAndOutput/index.js"

app/v3/serviceBusQueueTriggerAndOutput/index.ts

@@ -1,11 +1,11 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const serviceBusQueueTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<string> {
-//     context.log(`serviceBusQueueTriggerAndOutput was triggered by "${mySbMsg}"`);
-//     return mySbMsg;
-// };
+const serviceBusQueueTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<string> {
+    context.log(`serviceBusQueueTriggerAndOutput was triggered by "${mySbMsg}"`);
+    return mySbMsg;
+};
 
-// export default serviceBusQueueTrigger;
+export default serviceBusQueueTrigger;

app/v3/serviceBusTopicTrigger/function.json

@@ -4,9 +4,9 @@
             "name": "mySbMsg",
             "type": "serviceBusTrigger",
             "direction": "in",
-            "topicName": "e2eTestTopicTrigger",
-            "subscriptionName": "e2etestsub",
-            "connection": "e2eTest_serviceBus"
+            "topicName": "e2e-test-topic-trigger",
+            "subscriptionName": "e2e-test-sub",
+            "connection": "ServiceBusConnection"
         }
     ],
     "scriptFile": "../dist/serviceBusTopicTrigger/index.js"

app/v3/serviceBusTopicTrigger/index.ts

@@ -1,10 +1,10 @@
-// // Copyright (c) .NET Foundation. All rights reserved.
-// // Licensed under the MIT License.
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
 
-// import { AzureFunction, Context } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const serviceBusTopicTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<void> {
-//     context.log(`serviceBusTopicTrigger was triggered by "${mySbMsg}"`);
-// };
+const serviceBusTopicTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<void> {
+    context.log(`serviceBusTopicTrigger was triggered by "${mySbMsg}"`);
+};
 
-// export default serviceBusTopicTrigger;
+export default serviceBusTopicTrigger;