add cosmos

Evan Roman · Evan Roman · commit ad22cf5586fc · 2025-07-21T16:48:23.000-05:00
diff --git a/app/v3-oldConfig/cosmosDBTrigger/function.json b/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,
diff --git a/app/v3-oldConfig/cosmosDBTriggerAndOutput/function.json b/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"
         }
diff --git a/app/v3-oldConfig/httpTriggerCosmosDBInput/function.json b/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",
diff --git a/app/v3-oldConfig/httpTriggerCosmosDBOutput/function.json b/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"
         }
diff --git a/app/v3/cosmosDBTrigger/function.json b/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,
diff --git a/app/v3/cosmosDBTrigger/index.ts b/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;
diff --git a/app/v3/cosmosDBTriggerAndOutput/function.json b/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"
         }
diff --git a/app/v3/cosmosDBTriggerAndOutput/index.ts b/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;
diff --git a/app/v3/httpTriggerCosmosDBInput/function.json b/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",
diff --git a/app/v3/httpTriggerCosmosDBInput/index.ts b/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;
diff --git a/app/v3/httpTriggerCosmosDBOutput/function.json b/app/v3/httpTriggerCosmosDBOutput/function.json
@@ -16,7 +16,7 @@
             "type": "cosmosDB",
             "name": "outputDoc",
             "direction": "out",
-            "connection": "e2eTest_cosmosDB",
+            "connection": "CosmosDBConnection",
             "databaseName": "e2eTestDB",
             "containerName": "e2eTestContainerTriggerAndOutput"
         }
diff --git a/app/v4-oldConfig/src/functions/cosmosDBTrigger.ts b/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,
+});
diff --git a/app/v4-oldConfig/src/functions/cosmosDBTriggerAndOutput.ts b/app/v4-oldConfig/src/functions/cosmosDBTriggerAndOutput.ts
@@ -1,26 +1,26 @@
-// // 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, output } from '@azure/functions';
+import { app, InvocationContext, output } from '@azure/functions';
 
-// export async function cosmosDBTriggerAndOutput(documents: unknown[], context: InvocationContext): Promise<unknown[]> {
-//     context.log(`cosmosDBTriggerAndOutput processed ${documents.length} documents`);
-//     for (const document of documents) {
-//         context.log(`cosmosDBTriggerAndOutput was triggered by "${(<any>document).testData}"`);
-//     }
-//     return documents;
-// }
+export async function cosmosDBTriggerAndOutput(documents: unknown[], context: InvocationContext): Promise<unknown[]> {
+    context.log(`cosmosDBTriggerAndOutput processed ${documents.length} documents`);
+    for (const document of documents) {
+        context.log(`cosmosDBTriggerAndOutput was triggered by "${(<any>document).testData}"`);
+    }
+    return documents;
+}
 
-// app.cosmosDB('cosmosDBTriggerAndOutput', {
-//     connectionStringSetting: 'e2eTest_cosmosDB',
-//     databaseName: 'e2eTestDB',
-//     collectionName: 'e2eTestContainerTriggerAndOutput',
-//     createLeaseCollectionIfNotExists: true,
-//     leaseCollectionPrefix: '1',
-//     return: output.cosmosDB({
-//         connectionStringSetting: 'e2eTest_cosmosDB',
-//         databaseName: 'e2eTestDB',
-//         collectionName: 'e2eTestContainerTrigger',
-//     }),
-//     handler: cosmosDBTriggerAndOutput,
-// });
+app.cosmosDB('cosmosDBTriggerAndOutput', {
+    connectionStringSetting: 'CosmosDBConnection',
+    databaseName: 'e2eTestDB',
+    collectionName: 'e2eTestContainerTriggerAndOutput',
+    createLeaseCollectionIfNotExists: true,
+    leaseCollectionPrefix: '1',
+    return: output.cosmosDB({
+        connectionStringSetting: 'CosmosDBConnection',
+        databaseName: 'e2eTestDB',
+        collectionName: 'e2eTestContainerTrigger',
+    }),
+    handler: cosmosDBTriggerAndOutput,
+});
diff --git a/app/v4-oldConfig/src/functions/httpTriggerCosmosDBInput.ts b/app/v4-oldConfig/src/functions/httpTriggerCosmosDBInput.ts
@@ -8,7 +8,7 @@
 //     collectionName: 'e2eTestContainerTriggerAndOutput',
 //     id: '{Query.id}',
 //     partitionKey: 'testPartKey',
-//     connectionStringSetting: 'e2eTest_cosmosDB',
+//     connectionStringSetting: 'CosmosDBConnection',
 // });
 
 // export async function httpTriggerCosmosDBInput(
diff --git a/app/v4-oldConfig/src/functions/httpTriggerCosmosDBOutput.ts b/app/v4-oldConfig/src/functions/httpTriggerCosmosDBOutput.ts
@@ -6,7 +6,7 @@
 // const cosmosOutput = output.cosmosDB({
 //     databaseName: 'e2eTestDB',
 //     collectionName: 'e2eTestContainerTrigger',
-//     connectionStringSetting: 'e2eTest_cosmosDB',
+//     connectionStringSetting: 'CosmosDBConnection',
 // });
 
 // export async function httpTriggerCosmosDBOutput(
diff --git a/app/v4/src/functions/cosmosDBTrigger.ts b/app/v4/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', {
-//     connection: 'e2eTest_cosmosDB',
-//     databaseName: 'e2eTestDB',
-//     containerName: 'e2eTestContainerTrigger',
-//     createLeaseContainerIfNotExists: true,
-//     leaseContainerPrefix: '2',
-//     handler: cosmosDBTrigger,
-// });
+app.cosmosDB('cosmosDBTrigger', {
+    connection: 'CosmosDBConnection',
+    databaseName: 'e2eTestDB',
+    containerName: 'e2eTestContainerTrigger',
+    createLeaseContainerIfNotExists: true,
+    leaseContainerPrefix: '2',
+    handler: cosmosDBTrigger,
+});
diff --git a/app/v4/src/functions/cosmosDBTriggerAndOutput.ts b/app/v4/src/functions/cosmosDBTriggerAndOutput.ts
@@ -1,26 +1,26 @@
-// // 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, output } from '@azure/functions';
+import { app, InvocationContext, output } from '@azure/functions';
 
-// export async function cosmosDBTriggerAndOutput(documents: unknown[], context: InvocationContext): Promise<unknown[]> {
-//     context.log(`cosmosDBTriggerAndOutput processed ${documents.length} documents`);
-//     for (const document of documents) {
-//         context.log(`cosmosDBTriggerAndOutput was triggered by "${(<any>document).testData}"`);
-//     }
-//     return documents;
-// }
+export async function cosmosDBTriggerAndOutput(documents: unknown[], context: InvocationContext): Promise<unknown[]> {
+    context.log(`cosmosDBTriggerAndOutput processed ${documents.length} documents`);
+    for (const document of documents) {
+        context.log(`cosmosDBTriggerAndOutput was triggered by "${(<any>document).testData}"`);
+    }
+    return documents;
+}
 
-// app.cosmosDB('cosmosDBTriggerAndOutput', {
-//     connection: 'e2eTest_cosmosDB',
-//     databaseName: 'e2eTestDB',
-//     containerName: 'e2eTestContainerTriggerAndOutput',
-//     createLeaseContainerIfNotExists: true,
-//     leaseContainerPrefix: '1',
-//     return: output.cosmosDB({
-//         connection: 'e2eTest_cosmosDB',
-//         databaseName: 'e2eTestDB',
-//         containerName: 'e2eTestContainerTrigger',
-//     }),
-//     handler: cosmosDBTriggerAndOutput,
-// });
+app.cosmosDB('cosmosDBTriggerAndOutput', {
+    connection: 'CosmosDBConnection',
+    databaseName: 'e2eTestDB',
+    containerName: 'e2eTestContainerTriggerAndOutput',
+    createLeaseContainerIfNotExists: true,
+    leaseContainerPrefix: '1',
+    return: output.cosmosDB({
+        connection: 'CosmosDBConnection',
+        databaseName: 'e2eTestDB',
+        containerName: 'e2eTestContainerTrigger',
+    }),
+    handler: cosmosDBTriggerAndOutput,
+});
diff --git a/app/v4/src/functions/httpTriggerCosmosDBInput.ts b/app/v4/src/functions/httpTriggerCosmosDBInput.ts
diff --git a/app/v4/src/functions/httpTriggerCosmosDBOutput.ts b/app/v4/src/functions/httpTriggerCosmosDBOutput.ts
diff --git a/azure-pipelines/templates/test-node-version.yml b/azure-pipelines/templates/test-node-version.yml
diff --git a/src/constants.ts b/src/constants.ts
diff --git a/src/cosmosDB.test.ts b/src/cosmosDB.test.ts
diff --git a/src/global.test.ts b/src/global.test.ts
diff --git a/src/utils/connectionStrings.ts b/src/utils/connectionStrings.ts

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@`
`16`	`16`	`"type": "cosmosDB",`
`17`	`17`	`"name": "outputDoc",`
`18`	`18`	`"direction": "out",`
`19`		`- "connectionStringSetting": "e2eTest_cosmosDB",`
	`19`	`+ "connectionStringSetting": "CosmosDBConnection",`
`20`	`20`	`"databaseName": "e2eTestDB",`
`21`	`21`	`"collectionName": "e2eTestContainerTriggerAndOutput"`
`22`	`22`	`}`