Concurrency supported in Smoke Tests

samples/SmokeTest/SmokeTest/BlobStorageTest.cs

@@ -1,4 +1,8 @@
-using Azure.Storage.Blobs;
+// ------------------------------------
+// Copyright(c) Microsoft Corporation.
+// Licensed under the MIT License.
+// ------------------------------------
+using Azure.Storage.Blobs;
 using System;
 using System.IO;
 using System.Runtime.CompilerServices;
@@ -27,7 +31,7 @@ public static async Task RunTests()
 
             string connectionString = Environment.GetEnvironmentVariable("BLOB_CONNECTION_STRING");
             string containerName = "mycontainer"; //The container must exists, this sample is not creating it.
-            string blobName = "netSmokeTestBlob";
+            string blobName = $"netSmokeTestBlob-{Guid.NewGuid()}.txt";
             serviceClient = new BlobServiceClient(connectionString);
             blobClient = serviceClient.GetBlobContainerClient(containerName).GetBlockBlobClient(blobName);
 

samples/SmokeTest/SmokeTest/CosmosDBTest.cs

@@ -1,4 +1,8 @@
-using Azure.Storage.Blobs.Models;
+// ------------------------------------
+// Copyright(c) Microsoft Corporation.
+// Licensed under the MIT License.
+// ------------------------------------
+using Azure.Storage.Blobs.Models;
 using Microsoft.Azure.Documents;
 using Microsoft.Azure.Documents.Client;
 using Newtonsoft.Json;
@@ -34,7 +38,7 @@ public class Moon
     class CosmosDBTest
     {
         private static DocumentClient client;
-        private const string DataBaseName = "netSolarSystemDB";
+        private static string DataBaseName = $"netSolarSystemDB-{Guid.NewGuid()}";
         private const string CollectionName = "PlanetsCollection";
         private static List<Planet> planets = new List<Planet>();
 

samples/SmokeTest/SmokeTest/EventHubsTest.cs

@@ -1,4 +1,8 @@
-using Azure;
+// ------------------------------------
+// Copyright(c) Microsoft Corporation.
+// Licensed under the MIT License.
+// ------------------------------------
+using Azure;
 using Azure.Messaging.EventHubs;
 using Microsoft.Azure.Amqp.Framing;
 using System;
@@ -79,35 +83,16 @@ private static async Task SendAndReceiveEvents()
             {
                 receivedEvents.AddRange(await receiver.ReceiveAsync(eventBatch.Length + 10, TimeSpan.FromMilliseconds(25)));
             }
-            index = 0;
 
-            //Check if at least one event was received in order to start validation
             if (receivedEvents.Count == 0)
             {
                 throw new Exception(String.Format("Error, No events received."));
             }
             Console.Write(receivedEvents.Count() + " events received.\n");
 
-            Console.WriteLine("Beginning validation...");
-            foreach (var receivedEvent in receivedEvents)
+            if (receivedEvents.Count() < eventBatch.Count())
             {
-                var receivedEventMessage = Encoding.UTF8.GetString(receivedEvent.Body.ToArray());
-                var sentEventMessage = Encoding.UTF8.GetString(eventBatch[index].Body.ToArray());
-
-                if (receivedEventMessage == sentEventMessage)
-                {
-                    Console.WriteLine("\tEvent '" + receivedEventMessage + "' correctly validated.");
-                }
-                else
-                {
-                    throw new Exception(String.Format("Error, Event: '" + receivedEventMessage + "' was not expected."));                
-                }
-                index++;
-            }
-
-            if (index < eventBatch.Count())
-            {
-                throw new Exception(String.Format("Error, expecting " + eventBatch.Count().ToString() + " events, but only got " + index.ToString() + "."));
+                throw new Exception(String.Format($"Error, expecting {eventBatch.Count()} events, but only got {receivedEvents.Count().ToString()}."));
             }
 
             Console.WriteLine("done");

samples/SmokeTest/SmokeTest/KeyVaultTest.cs

@@ -1,4 +1,8 @@
-using Azure.Identity;
+// ------------------------------------
+// Copyright(c) Microsoft Corporation.
+// Licensed under the MIT License.
+// ------------------------------------
+using Azure.Identity;
 using Azure.Security.KeyVault.Secrets;
 using System;
 using System.Threading.Tasks;
@@ -7,7 +11,7 @@ namespace SmokeTest
 {
     class KeyVaultTest
     {
-        private const string SecretName = "SmokeTestSecret";
+        private static string SecretName = $"SmokeTestSecret-{Guid.NewGuid()}";
         private const string SecretValue = "smokeTestValue";
         private static SecretClient client;
 

samples/SmokeTest/SmokeTest/Program.cs

@@ -1,4 +1,9 @@
-using Azure.Messaging.EventHubs;
+// ------------------------------------
+// Copyright(c) Microsoft Corporation.
+// Licensed under the MIT License.
+// ------------------------------------
+// ------------------------------------
+using Azure.Messaging.EventHubs;
 using System;
 using System.Reflection.Metadata;
 using System.Threading.Tasks;