defined base approach to connect blob services

Author: dudchenko610

ManagedCode.Storage.Azure/AzureBlobStorage.cs

@@ -8,11 +8,11 @@
 
 namespace ManagedCode.Storage.Azure
 {
-    public class AzureBlobStorage : IBlobStorage
+    public class AzureBlobStorage : IAzureBlobStorage
     {
-        public AzureBlobStorage()
+        public AzureBlobStorage(/*AzureBlobStorageConnectionOptions connectionOptions*/)
         {
-            
+        //    var blobServiceClient = new BlobServiceClient(connectionOptions.ConnectionString);
         }
 
         public Task DeleteAsync(string blob, CancellationToken cancellationToken = default)

ManagedCode.Storage.Azure/AzureBlobStorageConnectionOptions.cs

@@ -3,5 +3,6 @@
     public class AzureBlobStorageConnectionOptions
     {
         public string ConnectionString { get; set; }
+        public string Container { get; set; }
     }
 }

ManagedCode.Storage.Azure/Extensions/ProviderExtensions.cs

@@ -2,19 +2,42 @@
 using Microsoft.Extensions.DependencyInjection;
 using Azure.Storage.Blobs;
 using ManagedCode.Storage.Core.Builders;
+using System.Reflection.Emit;
+using System.Reflection;
 
 namespace ManagedCode.Storage.Azure.Extensions
 {
     public static class ProviderExtensions
     {
-        public static ProviderBuilder AddAzureBlobStorage(this ProviderBuilder providerBuilder, Action<AzureBlobStorageConnectionOptions> action)
+        public static ProviderBuilder AddAzureBlobStorage<TAzureStorage>(
+            this ProviderBuilder providerBuilder, 
+            Action<AzureBlobStorageConnectionOptions> action)
+            where TAzureStorage : IAzureBlobStorage
         {
             var connectionOptions = new AzureBlobStorageConnectionOptions();
             action.Invoke(connectionOptions);
 
-            var blobServiceClient = new BlobServiceClient(connectionOptions.ConnectionString);
-            providerBuilder.ServiceCollection.AddSingleton(blobServiceClient);
+            var typeSignature = typeof(TAzureStorage).Name;
+            var an = new AssemblyName(typeSignature);
+            AssemblyBuilder assemblyBuilder = AssemblyBuilder.DefineDynamicAssembly(an, AssemblyBuilderAccess.Run);
+            ModuleBuilder moduleBuilder = assemblyBuilder.DefineDynamicModule("MainModule");
+            TypeBuilder tb = moduleBuilder.DefineType(typeSignature,
+                    TypeAttributes.Public |
+                    TypeAttributes.Class |
+                    TypeAttributes.AutoClass |
+                    TypeAttributes.AnsiClass |
+                    TypeAttributes.BeforeFieldInit |
+                    TypeAttributes.AutoLayout,
+                    null);
 
+            tb.SetParent(typeof(AzureBlobStorage));
+            tb.AddInterfaceImplementation(typeof(TAzureStorage));
+
+            ConstructorBuilder constructor = tb.DefineDefaultConstructor(MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.RTSpecialName);
+            Type implType = tb.CreateType();
+
+            providerBuilder.ServiceCollection.AddScoped(typeof(TAzureStorage), implType);
+            
             return providerBuilder;
         }
     }

ManagedCode.Storage.Azure/IAzureBlobStorage.cs

@@ -0,0 +1,8 @@
+using ManagedCode.Storage.Core;
+
+namespace ManagedCode.Storage.Azure
+{
+    public interface IAzureBlobStorage : IBlobStorage
+    {
+    }
+}

ManagedCode.Storage.Core/ManagedCode.Storage.Core.csproj

@@ -30,4 +30,8 @@
         <None Include="..\logo.png" Pack="true" Visible="false" PackagePath="" />
     </ItemGroup>
 
+    <ItemGroup>
+      <Folder Include="Helpers\" />
+    </ItemGroup>
+
 </Project>

ManagedCode.Storage.Tests/Azure/DependencyInjectionTests.cs

@@ -1,8 +1,44 @@
-
+using ManagedCode.Storage.Core.Extensions;
+using ManagedCode.Storage.Azure.Extensions;
+using Microsoft.Extensions.DependencyInjection;
+using System.Threading.Tasks;
+using Xunit;
+using FluentAssertions;
+
 namespace ManagedCode.Storage.Tests.Azure
 {
     public class DependencyInjectionTests
     {
+        private IPhotoStorage _photoStorage;
+        private IDocumentStorage _documentStorage;
+
+        public DependencyInjectionTests()
+        {
+           
+        }
+
+        [Fact]
+        public void WhenDIInitialized()
+        {
+            var services = new ServiceCollection();
+
+            services.AddManagedCodeStorage()
+                .AddAzureBlobStorage<IPhotoStorage>(opt => {
+                    opt.ConnectionString = "";
+                    opt.Container = "photos";
+                })
+                .AddAzureBlobStorage<IDocumentStorage>(opt => {
+                    opt.ConnectionString = "";
+                    opt.Container = "documents";
+                });
+
+            var provider = services.BuildServiceProvider();
+
+            _photoStorage = provider.GetService<IPhotoStorage>();
+            _documentStorage = provider.GetService<IDocumentStorage>();
 
+            _photoStorage.Should().NotBeNull();
+            _documentStorage.Should().NotBeNull();
+        }
     }
 }

ManagedCode.Storage.Tests/Azure/IDocumentStorage.cs

@@ -0,0 +1,8 @@
+using ManagedCode.Storage.Azure;
+
+namespace ManagedCode.Storage.Tests.Azure
+{
+    public interface IDocumentStorage : IAzureBlobStorage
+    {
+    }
+}

ManagedCode.Storage.Tests/Azure/IPhotoStorage.cs

@@ -0,0 +1,8 @@
+using ManagedCode.Storage.Azure;
+
+namespace ManagedCode.Storage.Tests.Azure
+{
+    public interface IPhotoStorage : IAzureBlobStorage
+    {
+    }
+}

ManagedCode.Storage.Tests/ManagedCode.Storage.Tests.csproj

@@ -9,6 +9,7 @@
 
     <ItemGroup>
         <PackageReference Include="FluentAssertions" Version="5.10.3" />
+        <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="6.0.0" />
         <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.9.1" />
         <PackageReference Include="System.Linq.Async" Version="5.0.0" />
         <PackageReference Include="xunit" Version="2.4.1" />