clear blob containers before tests

Author: brettsam

test/WebJobs.Script.Tests/BashEndToEndTests.cs

@@ -31,7 +31,7 @@ public async Task BlobTriggerToBlobTest()
         public class TestFixture : EndToEndTestFixture
         {
             public TestFixture() : base(@"TestScripts\Bash", "bash")
-            { 
+            {
             }
 
             public string TestBlobContents { get; private set; }
@@ -40,16 +40,15 @@ public TestFixture() : base(@"TestScripts\Bash", "bash")
 
             protected override void CreateTestStorageEntities()
             {
+                // This will ensure the input container is created.
                 base.CreateTestStorageEntities();
 
                 TestBlobContents = "My Test Blob";
                 TestBlobName = Guid.NewGuid().ToString();
 
                 // write the test blob before the host starts, so it gets picked
                 // up relatively quickly by the blob trigger test
-                CloudBlobContainer inputContainer = BlobClient.GetContainerReference("test-input-bash");
-                inputContainer.CreateIfNotExists();
-                CloudBlockBlob inputBlob = inputContainer.GetBlockBlobReference(TestBlobName);
+                CloudBlockBlob inputBlob = TestInputContainer.GetBlockBlobReference(TestBlobName);
                 inputBlob.UploadText(TestBlobContents);
             }
         }

test/WebJobs.Script.Tests/EndToEndTestFixture.cs

@@ -83,6 +83,9 @@ protected virtual void CreateTestStorageEntities()
 
             TestInputContainer = BlobClient.GetContainerReference(string.Format("test-input-{0}", _testId));
             TestInputContainer.CreateIfNotExists();
+            // Processing a large number of blobs on startup can take a while,
+            // so let's start with an empty container.
+            TestHelpers.ClearContainer(TestInputContainer);
 
             TestOutputContainer = BlobClient.GetContainerReference(string.Format("test-output-{0}", _testId));
             TestOutputContainer.CreateIfNotExists();

test/WebJobs.Script.Tests/PowerShellEndToEndTests.cs

@@ -144,16 +144,15 @@ public TestFixture() : base(@"TestScripts\PowerShell", "powershell")
 
             protected override void CreateTestStorageEntities()
             {
+                // This will ensure the input container is created.
                 base.CreateTestStorageEntities();
 
                 TestBlobContents = "My Test Blob";
                 TestBlobName = Guid.NewGuid().ToString();
 
                 // write the test blob before the host starts, so it gets picked
-                // up relatively quickly by the blob trigger test
-                CloudBlobContainer inputContainer = BlobClient.GetContainerReference("test-input-powershell");
-                inputContainer.CreateIfNotExists();
-                CloudBlockBlob inputBlob = inputContainer.GetBlockBlobReference(TestBlobName);
+                // up relatively quickly by the blob trigger test               
+                CloudBlockBlob inputBlob = TestInputContainer.GetBlockBlobReference(TestBlobName);
                 inputBlob.UploadText(TestBlobContents);
             }
         }

test/WebJobs.Script.Tests/SamplesEndToEndTests.cs

@@ -305,6 +305,11 @@ public async Task BlobTriggerBatch_Succeeds()
         {
             // write input blob
             CloudBlobContainer inputContainer = _fixture.BlobClient.GetContainerReference("samples-batch");
+            await inputContainer.CreateIfNotExistsAsync();
+            // Processing a large number of blobs on startup can take a while,
+            // so let's start with an empty container.
+            TestHelpers.ClearContainer(inputContainer);
+
             string blobName = Guid.NewGuid().ToString();
             string testData = "This is a test";
             CloudBlockBlob inputBlob = inputContainer.GetBlockBlobReference(blobName);

test/WebJobs.Script.Tests/TestHelpers.cs

@@ -95,6 +95,20 @@ public static async Task<Collection<string>> GetFunctionLogsAsync(string functio
             return null;
         }
 
+        // Deleting and recreating a container can result in a 409 as the container name is not
+        // immediately available. Instead, use this helper to clear a container.
+        public static void ClearContainer(CloudBlobContainer container)
+        {
+            foreach (IListBlobItem blobItem in container.ListBlobs())
+            {
+                CloudBlockBlob blockBlob = blobItem as CloudBlockBlob;
+                if (blockBlob != null)
+                {
+                    container.GetBlobReference(blockBlob.Name).DeleteIfExists();
+                }
+            }
+        }
+
         public static DirectoryInfo GetFunctionLogFileDirectory(string functionName)
         {
             string functionLogsPath = Path.Combine(Path.GetTempPath(), "Functions", "Function", functionName);