Emulate Storage and CosmosDB E2E Tests

app/v3-oldConfig/cosmosDBTrigger/function.json

@@ -5,7 +5,7 @@
             "name": "documents",
             "direction": "in",
             "leaseCollectionName": "leases",
-            "connectionStringSetting": "e2eTest_cosmosDB",
+            "connectionStringSetting": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "collectionName": "e2eTestContainerTrigger",
             "createLeaseCollectionIfNotExists": true,

app/v3-oldConfig/cosmosDBTriggerAndOutput/function.json

@@ -5,7 +5,7 @@
             "name": "documents",
             "direction": "in",
             "leaseCollectionName": "leases",
-            "connectionStringSetting": "e2eTest_cosmosDB",
+            "connectionStringSetting": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "collectionName": "e2eTestContainerTriggerAndOutput",
             "createLeaseCollectionIfNotExists": true,
@@ -15,7 +15,7 @@
             "type": "cosmosDB",
             "name": "$return",
             "direction": "out",
-            "connectionStringSetting": "e2eTest_cosmosDB",
+            "connectionStringSetting": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "collectionName": "e2eTestContainerTrigger"
         }

app/v3-oldConfig/httpTriggerCosmosDBInput/function.json

@@ -16,7 +16,7 @@
             "type": "cosmosDB",
             "name": "inputDoc",
             "direction": "in",
-            "connectionStringSetting": "e2eTest_cosmosDB",
+            "connectionStringSetting": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "collectionName": "e2eTestContainerTriggerAndOutput",
             "partitionKey": "testPartKey",

app/v3-oldConfig/httpTriggerCosmosDBOutput/function.json

@@ -16,7 +16,7 @@
             "type": "cosmosDB",
             "name": "outputDoc",
             "direction": "out",
-            "connectionStringSetting": "e2eTest_cosmosDB",
+            "connectionStringSetting": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "collectionName": "e2eTestContainerTriggerAndOutput"
         }

app/v3/cosmosDBTrigger/function.json

@@ -5,7 +5,7 @@
             "name": "documents",
             "direction": "in",
             "leaseContainerName": "leases",
-            "connection": "e2eTest_cosmosDB",
+            "connection": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "containerName": "e2eTestContainerTrigger",
             "createLeaseContainerIfNotExists": true,

app/v3/cosmosDBTrigger/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 } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const cosmosDBTrigger: AzureFunction = async function (context: Context, documents: any[]): Promise<void> {
-//     context.log(`cosmosDBTrigger processed ${documents.length} documents`);
-//     for (const document of documents) {
-//         context.log(`cosmosDBTrigger was triggered by "${document.testData}"`);
-//     }
-// };
+const cosmosDBTrigger: AzureFunction = async function (context: Context, documents: any[]): Promise<void> {
+    context.log(`cosmosDBTrigger processed ${documents.length} documents`);
+    for (const document of documents) {
+        context.log(`cosmosDBTrigger was triggered by "${document.testData}"`);
+    }
+};
 
-// export default cosmosDBTrigger;
+export default cosmosDBTrigger;

app/v3/cosmosDBTriggerAndOutput/function.json

@@ -5,7 +5,7 @@
             "name": "documents",
             "direction": "in",
             "leaseContainerName": "leases",
-            "connection": "e2eTest_cosmosDB",
+            "connection": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "containerName": "e2eTestContainerTriggerAndOutput",
             "createLeaseContainerIfNotExists": true,
@@ -15,7 +15,7 @@
             "type": "cosmosDB",
             "name": "$return",
             "direction": "out",
-            "connection": "e2eTest_cosmosDB",
+            "connection": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "containerName": "e2eTestContainerTrigger"
         }

app/v3/cosmosDBTriggerAndOutput/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 } from '@azure/functions';
+import { AzureFunction, Context } from '@azure/functions';
 
-// const cosmosDBTrigger: AzureFunction = async function (context: Context, documents: any[]): Promise<any[]> {
-//     context.log(`cosmosDBTriggerAndOutput processed ${documents.length} documents`);
-//     for (const document of documents) {
-//         context.log(`cosmosDBTriggerAndOutput was triggered by "${document.testData}"`);
-//     }
-//     return documents;
-// };
+const cosmosDBTrigger: AzureFunction = async function (context: Context, documents: any[]): Promise<any[]> {
+    context.log(`cosmosDBTriggerAndOutput processed ${documents.length} documents`);
+    for (const document of documents) {
+        context.log(`cosmosDBTriggerAndOutput was triggered by "${document.testData}"`);
+    }
+    return documents;
+};
 
-// export default cosmosDBTrigger;
+export default cosmosDBTrigger;

app/v3/httpTriggerCosmosDBInput/function.json

@@ -16,7 +16,7 @@
             "type": "cosmosDB",
             "name": "inputDoc",
             "direction": "in",
-            "connection": "e2eTest_cosmosDB",
+            "connection": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "containerName": "e2eTestContainerTriggerAndOutput",
             "partitionKey": "testPartKey",

app/v3/httpTriggerCosmosDBInput/index.ts

@@ -1,15 +1,15 @@
-// // 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 httpTriggerCosmosDBInput: AzureFunction = async function (
-//     context: Context,
-//     _request: HttpRequest
-// ): Promise<void> {
-//     context.res = {
-//         body: context.bindings.inputDoc.testData,
-//     };
-// };
+const httpTriggerCosmosDBInput: AzureFunction = async function (
+    context: Context,
+    _request: HttpRequest
+): Promise<void> {
+    context.res = {
+        body: context.bindings.inputDoc.testData,
+    };
+};
 
-// export default httpTriggerCosmosDBInput;
+export default httpTriggerCosmosDBInput;

app/v3/httpTriggerCosmosDBOutput/function.json

@@ -16,7 +16,7 @@
             "type": "cosmosDB",
             "name": "outputDoc",
             "direction": "out",
-            "connection": "e2eTest_cosmosDB",
+            "connection": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "containerName": "e2eTestContainerTriggerAndOutput"
         }

app/v3/httpTriggerCosmosDBOutput/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 httpTriggerCosmosDBOutput: AzureFunction = async function (
-//     context: Context,
-//     request: HttpRequest
-// ): Promise<void> {
-//     context.bindings.outputDoc = request.body;
-//     context.res = { body: 'done' };
-// };
+const httpTriggerCosmosDBOutput: AzureFunction = async function (
+    context: Context,
+    request: HttpRequest
+): Promise<void> {
+    context.bindings.outputDoc = request.body;
+    context.res = { body: 'done' };
+};
 
-// export default httpTriggerCosmosDBOutput;
+export default httpTriggerCosmosDBOutput;

app/v3/httpTriggerStorageQueueOutput/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 httpTriggerStorageQueueOutput: AzureFunction = async function (
-//     context: Context,
-//     request: HttpRequest
-// ): Promise<void> {
-//     context.bindings.outputMsg = request.body.output;
-//     context.res = { body: 'done' };
-// };
+const httpTriggerStorageQueueOutput: AzureFunction = async function (
+    context: Context,
+    request: HttpRequest
+): Promise<void> {
+    context.bindings.outputMsg = request.body.output;
+    context.res = { body: 'done' };
+};
 
-// export default httpTriggerStorageQueueOutput;
+export default httpTriggerStorageQueueOutput;

app/v3/httpTriggerTableInput/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 httpTriggerTableInput: AzureFunction = async function (context: Context, request: HttpRequest): Promise<void> {
-//     context.log(`httpTriggerTableInput was triggered`);
-//     context.res = {
-//         body: context.bindings.inputItem,
-//     };
-// };
+const httpTriggerTableInput: AzureFunction = async function (context: Context, request: HttpRequest): Promise<void> {
+    context.log(`httpTriggerTableInput was triggered`);
+    context.res = {
+        body: context.bindings.inputItem,
+    };
+};
 
-// export default httpTriggerTableInput;
+export default httpTriggerTableInput;

app/v3/httpTriggerTableOutput/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 httpTriggerTableOutput: AzureFunction = async function (context: Context, request: HttpRequest): Promise<void> {
-//     context.log(`httpTriggerTableOutput was triggered`);
-//     context.bindings.outputItem = request.body;
-//     context.res = {
-//         status: 201,
-//     };
-// };
+const httpTriggerTableOutput: AzureFunction = async function (context: Context, request: HttpRequest): Promise<void> {
+    context.log(`httpTriggerTableOutput was triggered`);
+    context.bindings.outputItem = request.body;
+    context.res = {
+        status: 201,
+    };
+};
 
-// export default httpTriggerTableOutput;
+export default httpTriggerTableOutput;

app/v3/storageBlobTrigger/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 blobTrigger: AzureFunction = async function (context: Context, myBlob: any): Promise<void> {
-//     const blobPath = context.bindingData.blobTrigger;
-//     context.log(`storageBlobTrigger was triggered by blob "${blobPath}" with content "${myBlob.toString()}"`);
-// };
+const blobTrigger: AzureFunction = async function (context: Context, myBlob: any): Promise<void> {
+    const blobPath = context.bindingData.blobTrigger;
+    context.log(`storageBlobTrigger was triggered by blob "${blobPath}" with content "${myBlob.toString()}"`);
+};
 
-// export default blobTrigger;
+export default blobTrigger;

app/v3/storageBlobTriggerAndOutput/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 blobTrigger: AzureFunction = async function (context: Context, myBlob: any): Promise<any> {
-//     const blobPath = context.bindingData.blobTrigger;
-//     context.log(`storageBlobTriggerAndOutput was triggered by blob "${blobPath}" with content "${myBlob.toString()}"`);
-//     return myBlob;
-// };
+const blobTrigger: AzureFunction = async function (context: Context, myBlob: any): Promise<any> {
+    const blobPath = context.bindingData.blobTrigger;
+    context.log(`storageBlobTriggerAndOutput was triggered by blob "${blobPath}" with content "${myBlob.toString()}"`);
+    return myBlob;
+};
 
-// export default blobTrigger;
+export default blobTrigger;

app/v3/storageQueueTrigger/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 queueTrigger: AzureFunction = async function (context: Context, myQueueItem: string): Promise<void> {
-//     context.log(`storageQueueTrigger was triggered by "${myQueueItem}"`);
-// };
+const queueTrigger: AzureFunction = async function (context: Context, myQueueItem: string): Promise<void> {
+    context.log(`storageQueueTrigger was triggered by "${myQueueItem}"`);
+};
 
-// export default queueTrigger;
+export default queueTrigger;

app/v3/storageQueueTriggerAndOutput/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 queueTrigger: AzureFunction = async function (context: Context, myQueueItem: string): Promise<string> {
-//     context.log(`storageQueueTriggerAndOutput was triggered by "${myQueueItem}"`);
-//     return myQueueItem;
-// };
+const queueTrigger: AzureFunction = async function (context: Context, myQueueItem: string): Promise<string> {
+    context.log(`storageQueueTriggerAndOutput was triggered by "${myQueueItem}"`);
+    return myQueueItem;
+};
 
-// export default queueTrigger;
+export default queueTrigger;

app/v4-oldConfig/src/functions/cosmosDBTrigger.ts

@@ -1,20 +1,20 @@
-// // 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 { app, InvocationContext } from '@azure/functions';
+import { app, InvocationContext } from '@azure/functions';
 
-// export async function cosmosDBTrigger(documents: unknown[], context: InvocationContext): Promise<void> {
-//     context.log(`cosmosDBTrigger processed ${documents.length} documents`);
-//     for (const document of documents) {
-//         context.log(`cosmosDBTrigger was triggered by "${(<any>document).testData}"`);
-//     }
-// }
+export async function cosmosDBTrigger(documents: unknown[], context: InvocationContext): Promise<void> {
+    context.log(`cosmosDBTrigger processed ${documents.length} documents`);
+    for (const document of documents) {
+        context.log(`cosmosDBTrigger was triggered by "${(<any>document).testData}"`);
+    }
+}
 
-// app.cosmosDB('cosmosDBTrigger', {
-//     connectionStringSetting: 'e2eTest_cosmosDB',
-//     databaseName: 'e2eTestDB',
-//     collectionName: 'e2eTestContainerTrigger',
-//     createLeaseCollectionIfNotExists: true,
-//     leaseCollectionPrefix: '2',
-//     handler: cosmosDBTrigger,
-// });
+app.cosmosDB('cosmosDBTrigger', {
+    connectionStringSetting: 'CosmosDBConnection',
+    databaseName: 'e2eTestDB',
+    collectionName: 'e2eTestContainerTrigger',
+    createLeaseCollectionIfNotExists: true,
+    leaseCollectionPrefix: '2',
+    handler: cosmosDBTrigger,
+});