Azure Cloud storage

global.json

@@ -1,5 +1,5 @@
 {
   "sdk": {
-    "version": "3.0.100"
+    "version": "3.1.401"
   }
 }

src/AzureCloud/AzureResource.cs

@@ -1,47 +1,37 @@
-using System;
-using System.Collections.Generic;
-using System.Diagnostics;
-using System.IO;
-using System.Text;
-using System.Threading.Tasks;
-using Xunit;
-using Xunit.Abstractions;
-
-namespace Squadron.AzureCloud
-{
-    /// <summary>
-    /// Base class to use with Azure Cloud resources
-    /// </summary>
-    /// <typeparam name="TOptions"></typeparam>
-    public class AzureResource<TOptions>
-        where TOptions : AzureResourceOptions, new()
-    {
-        /// <summary>
-        /// Azure configuration to work with Azure management api
-        /// </summary>
-        protected AzureResourceConfiguration AzureConfig { get; private set; }
-
-        /// <summary>
-        /// Initialize the resource
-        /// </summary>
-        /// <returns></returns>
-        public virtual Task InitializeAsync()
-        {
-            //var options = new TOptions();
-            //AzureResourceOptionsBuilder builder = new AzureResourceOptionsBuilder();
-            //AzureResourceOptions options = builder.Build();
-            //AzureConfig = options.ConfigResolver();
-            Trace.WriteLine("Loading Azure Configuration");
-            return Task.CompletedTask;
-        }
-
+using System.Diagnostics;
+using System.Threading.Tasks;
+
+namespace Squadron.AzureCloud
+{
+    /// <summary>
+    /// Base class to use with Azure Cloud resources
+    /// </summary>
+    /// <typeparam name="TOptions"></typeparam>
+    public class AzureResource<TOptions>
+        where TOptions : AzureResourceOptions, new()
+    {
+        /// <summary>
+        /// Azure configuration to work with Azure management api
+        /// </summary>
+        protected AzureResourceConfiguration AzureConfig { get; private set; }
+
+        /// <summary>
+        /// Initialize the resource
+        /// </summary>
+        /// <returns></returns>
+        public virtual Task InitializeAsync()
+        {
+            Trace.WriteLine("Loading Azure Configuration");
+            return Task.CompletedTask;
+        }
+
         /// <summary>
         /// Loads the azure resource configuration.
         /// </summary>
         /// <param name="builder">The builder.</param>
-        protected void LoadResourceConfiguration(AzureResourceOptionsBuilder builder)
-        {
-           AzureConfig = builder.ConfigResolver();
-        }
-    }
-}
+        protected void LoadResourceConfiguration(AzureResourceOptionsBuilder builder)
+        {
+           AzureConfig = builder.ConfigResolver();
+        }
+    }
+}

src/AzureCloud/AzureResourceIdentifier.cs

@@ -1,37 +1,36 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace Squadron.AzureCloud
-{
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Squadron.AzureCloud
+{
     /// <summary>
     /// Azure resource identifier
     /// </summary>
-    public class AzureResourceIdentifier
-    {
+    public class AzureResourceIdentifier
+    {
         /// <summary>
         /// Gets or sets the Azure subscriptionId.
         /// </summary>
         /// <value>
         /// The subscriptionId.
         /// </value>
-        public string SubscriptionId { get; set; }
-
+        public string SubscriptionId { get; set; }
+
         /// <summary>
         /// Gets or sets the name of the resource group.
         /// </summary>
         /// <value>
         /// The name of the resource group.
         /// </value>
-        public string ResourceGroupName { get; set; }
-
-
+        public string ResourceGroupName { get; set; }
+
         /// <summary>
         /// Gets or sets the name of the resource
         /// </summary>
         /// <value>
         /// The name.
         /// </value>
-        public string Name { get; set; }
-    }
-}
+        public string Name { get; set; }
+    }
+}

src/AzureCloud/Model/AzureResourceProvisioningMode.cs

@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Squadron.AzureCloud
+{
+    /// <summary>
+    /// Defines ServiceBUs provisioning modes
+    /// </summary>
+    public enum AzureResourceProvisioningMode
+    {
+        /// <summary>
+        /// Use an existing Azure resource
+        /// </summary>
+        UseExisting,
+
+        /// <summary>
+        /// Provision and delete resource
+        /// </summary>
+        CreateAndDelete
+    }
+}

src/AzureCloudServiceBus.Tests/AzureExistingServiceBusResourceTests.cs

@@ -1,42 +1,42 @@
 using System;
 using System.IO;
-using System.Text;
-using System.Threading.Tasks;
-using Microsoft.Azure.ServiceBus;
-using Xunit;
-using Xunit.Abstractions;
-
-namespace Squadron.AzureServiceBus.Tests
-{
-    public class AzureExistingServiceBusResourceTests
-        : IClassFixture<AzureCloudServiceBusResource<TestExistingNamespaceAzureServiceBusOptions>>
-    {
-        private readonly AzureCloudServiceBusResource<TestExistingNamespaceAzureServiceBusOptions> _resource;
-
-        public AzureExistingServiceBusResourceTests(
-            AzureCloudServiceBusResource<TestExistingNamespaceAzureServiceBusOptions> resource,
-            ITestOutputHelper outputHelper)
-        {
-            _resource = resource;
-        }
-
-
-        [Fact( Skip ="Can not run without Azure credentials")]
-        public async Task PrepareAzureServiceBusResource_ExistingNamespace_NoError()
-        {
-            ITopicClient topicClient = _resource.GetTopicClient("foo");
-            ISubscriptionClient subscriptionClient =
-                _resource.GetSubscriptionClient("foo", "test1");
-
-            IQueueClient queueClient = _resource.GetQueueClient("bar");
-
-            //subscriptionClient.RegisterMessageHandler()
-
-            await topicClient.SendAsync(new Message(Encoding.UTF8.GetBytes("Hello")));
-
-            ITopicClient newTopic = await _resource.CreateTopicAsync(b => b
-                                            .Name("adhoc")
-                                            .AddSubscription("test1"));
-        }   
-    }
-}
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.Azure.ServiceBus;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Squadron.AzureServiceBus.Tests
+{
+    public class AzureExistingServiceBusResourceTests
+        : IClassFixture<AzureCloudServiceBusResource<TestExistingNamespaceAzureServiceBusOptions>>
+    {
+        private readonly AzureCloudServiceBusResource<TestExistingNamespaceAzureServiceBusOptions> _resource;
+
+        public AzureExistingServiceBusResourceTests(
+            AzureCloudServiceBusResource<TestExistingNamespaceAzureServiceBusOptions> resource,
+            ITestOutputHelper outputHelper)
+        {
+            _resource = resource;
+        }
+
+
+        [Fact( Skip ="Can not run without Azure credentials")]
+        public async Task PrepareAzureServiceBusResource_ExistingNamespace_NoError()
+        {
+            ITopicClient topicClient = _resource.GetTopicClient("foo");
+            ISubscriptionClient subscriptionClient =
+                _resource.GetSubscriptionClient("foo", "test1");
+
+            IQueueClient queueClient = _resource.GetQueueClient("bar");
+
+            //subscriptionClient.RegisterMessageHandler()
+
+            await topicClient.SendAsync(new Message(Encoding.UTF8.GetBytes("Hello")));
+
+            ITopicClient newTopic = await _resource.CreateTopicAsync(b => b
+                                            .Name("adhoc")
+                                            .AddSubscription("test1"));
+        }   
+    }
+}

src/AzureCloudServiceBus.Tests/AzureNewServiceBusResourceTests.cs

@@ -1,28 +1,27 @@
 using System.Text;
-using System.Threading.Tasks;
-using Microsoft.Azure.ServiceBus;
-using Xunit;
-
+using System.Threading.Tasks;
+using Microsoft.Azure.ServiceBus;
+using Xunit;
+
 namespace Squadron.AzureServiceBus.Tests
 {
-    public class AzureNewServiceBusResourceTests
+    public class AzureNewServiceBusResourceTests
         : IClassFixture<AzureCloudServiceBusResource<TestNewNamespaceAzureServiceBusOptions>>
-    {
-        private readonly AzureCloudServiceBusResource<TestNewNamespaceAzureServiceBusOptions> _resource;
-
-        public AzureNewServiceBusResourceTests(
-            AzureCloudServiceBusResource<TestNewNamespaceAzureServiceBusOptions> resource)
-        {
-            _resource = resource;
-        }
-
-
-        [Fact(Skip = "Can not run without Azure credentials")]
-        public async Task PrepareAzureServiceBusResource_NewNamespace_NoError()
-        {
-            ITopicClient topicClient = _resource.GetTopicClient("foo");
-            await topicClient.SendAsync(new Message(Encoding.UTF8.GetBytes("Hello")));
-            IQueueClient queueClient = _resource.GetQueueClient("bar");
-        }
+    {
+        private readonly AzureCloudServiceBusResource<TestNewNamespaceAzureServiceBusOptions> _resource;
+
+        public AzureNewServiceBusResourceTests(
+            AzureCloudServiceBusResource<TestNewNamespaceAzureServiceBusOptions> resource)
+        {
+            _resource = resource;
+        }
+
+        [Fact(Skip = "Can not run without Azure credentials")]
+        public async Task PrepareAzureServiceBusResource_NewNamespace_NoError()
+        {
+            ITopicClient topicClient = _resource.GetTopicClient("foo");
+            await topicClient.SendAsync(new Message(Encoding.UTF8.GetBytes("Hello")));
+            IQueueClient queueClient = _resource.GetQueueClient("bar");
+        }
     }
 }

src/AzureCloudServiceBus.Tests/TestExistingNamespaceAzureServiceBusOptions.cs

@@ -1,15 +1,15 @@
 using System;
-
-namespace Squadron.AzureServiceBus.Tests
-{
-    public class TestExistingNamespaceAzureServiceBusOptions : AzureCloudServiceBusOptions
-    {
-        public override void Configure(ServiceBusOptionsBuilder builder)
-        {
-            builder.Namespace("spc-a-squadron-sb01")
-                   .AddTopic("foo")
-                   .AddSubscription("test1", "EventType = 'test1'");
-            builder.AddQueue("bar");
-        }
-    }
-}
+
+namespace Squadron.AzureServiceBus.Tests
+{
+    public class TestExistingNamespaceAzureServiceBusOptions : AzureCloudServiceBusOptions
+    {
+        public override void Configure(ServiceBusOptionsBuilder builder)
+        {
+            builder.Namespace("spc-a-squadron-sb01")
+                   .AddTopic("foo")
+                   .AddSubscription("test1", "EventType = 'test1'");
+            builder.AddQueue("bar");
+        }
+    }
+}

src/AzureCloudServiceBus/AzureCloudServiceBusOptions.cs

@@ -1,22 +1,21 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-using Microsoft.Extensions.Configuration;
-using Squadron.AzureCloud;
-
-namespace Squadron
-{
+using System;
+using System.Collections.Generic;
+using System.Text;
+using Microsoft.Extensions.Configuration;
+using Squadron.AzureCloud;
+
+namespace Squadron
+{
     /// <summary>
     /// ServiceBus resources options
     /// </summary>
     /// <seealso cref="Squadron.AzureCloud.AzureResourceOptions" />
-    public abstract class AzureCloudServiceBusOptions : AzureResourceOptions
-    {
+    public abstract class AzureCloudServiceBusOptions : AzureResourceOptions
+    {
         /// <summary>
         /// Configures the ServiceBus
         /// </summary>
         /// <param name="builder">The builder.</param>
-        public abstract void Configure(ServiceBusOptionsBuilder builder);
-
-    }
-}
+        public abstract void Configure(ServiceBusOptionsBuilder builder);
+    }
+}