add another test

Author: satvu

test/WebJobs.Script.Tests.Integration/CosmosDB/CosmosDBEndToEndTestsBase.cs

@@ -94,6 +94,21 @@ protected async Task CosmosDBMultipleItemsTest()
             await _fixture.DeleteCosmosDbResources(dbName);
         }
 
+        protected async Task TestConnectionToEmulator()
+        {
+            var dbName = "ConnectionTestDb";
+
+            var cosmosClient = new CosmosClient("AccountEndpoint=https://localhost:8081/;AccountKey=C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw==");
+            await cosmosClient.CreateDatabaseIfNotExistsAsync(dbName);
+            var container = await cosmosClient.GetDatabase(dbName).CreateContainerIfNotExistsAsync("ItemCollection", "/id");
+
+            string id = Guid.NewGuid().ToString();
+            var documentToTest = new { id, text = "Connection test" };
+            await container.Container.CreateItemAsync(documentToTest, new PartitionKey(id));
+            var response = await container.Container.ReadItemAsync<dynamic>(id, new PartitionKey(id));
+            Assert.Equal((string)response.Resource.id, id);
+        }
+
         protected async Task<dynamic> WaitForItemAsync(string itemId, string itemDb, string textToMatch = null)
         {
             var container = _fixture.CosmosClient.GetContainer(itemDb, "ItemCollection");

test/WebJobs.Script.Tests.Integration/CosmosDB/CosmosDBNodeEndToEndTests.cs

@@ -32,6 +32,12 @@ public Task CosmosDBMultipleItems()
             return CosmosDBMultipleItemsTest();
         }
 
+        [Fact]
+        public Task TestConnection()
+        {
+            return TestConnectionToEmulator();
+        }
+
         public class TestFixture : CosmosDBEndtoEndTestFixture
         {
             private const string ScriptRoot = @"TestScripts\Node";