Merge pull request 'Refactored service to internalise the CDN' (#32) from s3service into master

Reviewed-on: #32

LiteCharms.Features/Extensions/S3.cs

@@ -1,6 +1,6 @@
-using Amazon.Runtime;
+using LiteCharms.Features.S3;
-using LiteCharms.Features.S3;
+using LiteCharms.Features.S3.Abstractions;
-using LiteCharms.Features.S3.Configuration;
+using static LiteCharms.Features.S3.Constants;
 
 namespace LiteCharms.Features.Extensions;
 
@@ -8,23 +8,50 @@ public static class S3
 {
     public static IServiceCollection AddGarageS3(this IServiceCollection services, IConfiguration configuration)
     {
-        var optionsSection = configuration.GetSection(nameof(S3Settings));
+        if (configuration.GetSection(BookshopBucketName) is not null)
-        services.Configure<S3Settings>(optionsSection);
-
-        var options = optionsSection.Get<S3Settings>()
-            ?? throw new InvalidOperationException("S3 configuration section is missing.");
-
-        var credentials = new BasicAWSCredentials(options.AccessKey, options.SecretKey);
-
-        var s3Config = new AmazonS3Config
         {
-            ServiceURL = options.ServiceUrl,
+            services.AddKeyedSingleton<IAmazonS3, AmazonS3Client>(BookshopBucketName, (provider, client) =>
-            AuthenticationRegion = options.Region,            
+                new AmazonS3Client(new BasicAWSCredentials(configuration.GetSection($"{BookshopS3SettingsSection}:AccessKey").Value,
-            ForcePathStyle = true,
+                configuration.GetSection($"{BookshopS3SettingsSection}:SecretKey").Value),
-        };
+                new AmazonS3Config
+                {
+                    ServiceURL = configuration.GetSection($"{BookshopS3SettingsSection}:ServiceUrl").Value,
+                    AuthenticationRegion = configuration.GetSection($"{BookshopS3SettingsSection}:Region").Value,
+                    ForcePathStyle = true,
+                }));
 
-        services.AddSingleton<IAmazonS3>(new AmazonS3Client(credentials, s3Config));
+            services.AddKeyedScoped<IS3Service, BookstoreS3Service>(BookshopBucketName); 
-        services.AddScoped<S3Service>();
+        }
+
+        if (configuration.GetSection(BookshopInvoicesBucketName) is not null)
+        {
+            services.AddKeyedSingleton<IAmazonS3, AmazonS3Client>(BookshopInvoicesBucketName, (provider, client) =>
+                new AmazonS3Client(new BasicAWSCredentials(configuration.GetSection($"{BookshopInvoicesBucketName}:AccessKey").Value,
+                configuration.GetSection($"{BookshopInvoicesBucketName}:SecretKey").Value),
+                new AmazonS3Config
+                {
+                    ServiceURL = configuration.GetSection($"{BookshopInvoicesBucketName}:ServiceUrl").Value,
+                AuthenticationRegion = configuration.GetSection($"{BookshopInvoicesBucketName}:Region").Value,
+                ForcePathStyle = true,
+            }));
+
+            services.AddKeyedScoped<IS3Service, BookstoreInvoicesS3Service>(BookshopInvoicesBucketName);
+        }
+
+        if (configuration.GetSection(BookshopQuotesBucketName) is not null)
+        {
+            services.AddKeyedSingleton<IAmazonS3, AmazonS3Client>(BookshopQuotesBucketName, (provider, client) =>
+                new AmazonS3Client(new BasicAWSCredentials(configuration.GetSection($"{BookshopQuotesBucketName}:AccessKey").Value,
+                configuration.GetSection($"{BookshopQuotesBucketName}:SecretKey").Value),
+                new AmazonS3Config
+                {
+                    ServiceURL = configuration.GetSection($"{BookshopQuotesBucketName}:ServiceUrl").Value,
+                    AuthenticationRegion = configuration.GetSection($"{BookshopQuotesBucketName}:Region").Value,
+                    ForcePathStyle = true,
+                }));
+
+            services.AddKeyedScoped<IS3Service, BookstoreQuotesS3Service>(BookshopQuotesBucketName);
+        }
 
         return services;
     }

LiteCharms.Features/LiteCharms.Features.csproj

@@ -137,6 +137,7 @@
     <!-- global Usings -->
     <Using Include="Amazon.S3" />
     <Using Include="Amazon.S3.Model" />
+    <Using Include="Amazon.Runtime" />
   </ItemGroup>
 
   <!-- Shared Usings -->

LiteCharms.Features/S3/Abstractions/IS3Service.cs

@@ -0,0 +1,6 @@
+namespace LiteCharms.Features.S3.Abstractions;
+
+public interface IS3Service
+{
+    Task<Result<string>> UploadFileAsync(string fileName, Stream fileStream, string contentType, CancellationToken cancellationToken = default);
+}

LiteCharms.Features/S3/Abstractions/S3ServiceBase.cs

@@ -0,0 +1,8 @@
+namespace LiteCharms.Features.S3.Abstractions;
+
+public abstract class S3ServiceBase(IAmazonS3 amazonS3)
+{
+    protected readonly IAmazonS3 client = amazonS3;
+
+    public abstract Task<Result<string>> UploadFileAsync(string fileName, Stream fileStream, string contentType, CancellationToken cancellationToken = default);
+}

LiteCharms.Features/S3/BookstoreInvoicesS3Service.cs

@@ -0,0 +1,38 @@
+using LiteCharms.Features.S3.Abstractions;
+
+namespace LiteCharms.Features.S3;
+
+public class BookstoreInvoicesS3Service(IConfiguration configuration, [FromKeyedServices(Constants.BookshopInvoicesBucketName)] IAmazonS3 amazonS3) : 
+    S3ServiceBase(amazonS3), IS3Service
+{
+    public override async Task<Result<string>> UploadFileAsync(string fileName, Stream fileStream, string contentType, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            var bucketName = configuration.GetSection($"{Constants.BookshopInvoicesS3SettingsSection}:BucketName").Value!;
+            var cdnBaseUrl = configuration.GetSection($"{Constants.BookshopInvoicesS3SettingsSection}:CdnBaseUrl").Value!;
+
+            if(string.IsNullOrWhiteSpace(bucketName)) 
+                return Result.Fail<string>("Bucket name is not configured.");
+
+            if (string.IsNullOrWhiteSpace(cdnBaseUrl))
+                return Result.Fail<string>("CDN base URL is not configured.");
+
+            var response = await client.PutObjectAsync(new PutObjectRequest
+            {
+                BucketName = bucketName,
+                Key = fileName,
+                InputStream = fileStream,
+                ContentType = contentType
+            }, cancellationToken);
+
+            return response.HttpStatusCode != System.Net.HttpStatusCode.OK
+                ? Result.Fail<string>($"Failed to upload {fileName} to S3.")
+                : Result.Ok(string.Format(cdnBaseUrl, bucketName, fileName));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<string>(new Error($"Error uploading {fileName} to S3: {ex.Message}").CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/S3/BookstoreQuotesS3Service.cs

@@ -0,0 +1,38 @@
+using LiteCharms.Features.S3.Abstractions;
+
+namespace LiteCharms.Features.S3;
+
+public class BookstoreQuotesS3Service(IConfiguration configuration, [FromKeyedServices(Constants.BookshopQuotesBucketName)] IAmazonS3 amazonS3) : 
+    S3ServiceBase(amazonS3), IS3Service
+{
+    public override async Task<Result<string>> UploadFileAsync(string fileName, Stream fileStream, string contentType, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            var bucketName = configuration.GetSection($"{Constants.BookshopQuotesS3SettingsSection}:BucketName").Value!;
+            var cdnBaseUrl = configuration.GetSection($"{Constants.BookshopQuotesS3SettingsSection}:CdnBaseUrl").Value!;
+
+            if(string.IsNullOrWhiteSpace(bucketName)) 
+                return Result.Fail<string>("Bucket name is not configured.");
+
+            if (string.IsNullOrWhiteSpace(cdnBaseUrl))
+                return Result.Fail<string>("CDN base URL is not configured.");
+
+            var response = await client.PutObjectAsync(new PutObjectRequest
+            {
+                BucketName = bucketName,
+                Key = fileName,
+                InputStream = fileStream,
+                ContentType = contentType
+            }, cancellationToken);
+
+            return response.HttpStatusCode != System.Net.HttpStatusCode.OK
+                ? Result.Fail<string>($"Failed to upload {fileName} to S3.")
+                : Result.Ok(string.Format(cdnBaseUrl, bucketName, fileName));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<string>(new Error($"Error uploading {fileName} to S3: {ex.Message}").CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/S3/BookstoreS3Service.cs

@@ -0,0 +1,38 @@
+using LiteCharms.Features.S3.Abstractions;
+
+namespace LiteCharms.Features.S3;
+
+public class BookstoreS3Service(IConfiguration configuration, [FromKeyedServices(Constants.BookshopBucketName)] IAmazonS3 amazonS3) : 
+    S3ServiceBase(amazonS3), IS3Service
+{
+    public override async Task<Result<string>> UploadFileAsync(string fileName, Stream fileStream, string contentType, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            var bucketName = configuration.GetSection($"{Constants.BookshopS3SettingsSection}:BucketName").Value!;
+            var cdnBaseUrl = configuration.GetSection($"{Constants.BookshopS3SettingsSection}:CdnBaseUrl").Value!;
+
+            if(string.IsNullOrWhiteSpace(bucketName)) 
+                return Result.Fail<string>("Bucket name is not configured.");
+
+            if (string.IsNullOrWhiteSpace(cdnBaseUrl))
+                return Result.Fail<string>("CDN base URL is not configured.");
+
+            var response = await client.PutObjectAsync(new PutObjectRequest
+            {
+                BucketName = bucketName,
+                Key = fileName,
+                InputStream = fileStream,
+                ContentType = contentType
+            }, cancellationToken);
+
+            return response.HttpStatusCode != System.Net.HttpStatusCode.OK
+                ? Result.Fail<string>($"Failed to upload {fileName} to S3.")
+                : Result.Ok(string.Format(cdnBaseUrl, bucketName, fileName));
+        }
+        catch (Exception ex)
+        {
+            return Result.Fail<string>(new Error($"Error uploading {fileName} to S3: {ex.Message}").CausedBy(ex));
+        }
+    }
+}

LiteCharms.Features/S3/Configuration/S3Settings.cs

@@ -11,4 +11,6 @@ public class S3Settings
     public string? BucketName { get; set; }
 
     public string? Region { get; set; }
+
+    public string? CdnBaseUrl { get; set; }
 }

LiteCharms.Features/S3/Constants.cs

@@ -0,0 +1,12 @@
+namespace LiteCharms.Features.S3;
+
+public static class Constants
+{
+    public const string BookshopS3SettingsSection = "BookshopS3Settings";
+    public const string BookshopInvoicesS3SettingsSection = "BookshopInvoicesS3Settings";
+    public const string BookshopQuotesS3SettingsSection = "BookshopQuotesS3Settings";
+
+    public const string BookshopBucketName = "bookshop";
+    public const string BookshopInvoicesBucketName = "bookshop.invoices";
+    public const string BookshopQuotesBucketName = "bookshop.quotes";
+}

LiteCharms.Features/S3/S3Service.cs

@@ -1,28 +0,0 @@
-namespace LiteCharms.Features.S3;
-
-public class S3Service(IAmazonS3 amazonS3)
-{
-    public async Task<Result<string>> UploadFileAsync(string bucketName, string fileName, Stream fileStream, string contentType, string cdnBaseUrl, CancellationToken cancellationToken = default)
-    {
-        try
-        {
-            var putRequest = new PutObjectRequest
-            {
-                BucketName = bucketName,
-                Key = fileName,
-                InputStream = fileStream,
-                ContentType = contentType
-            };
-
-            var response = await amazonS3.PutObjectAsync(putRequest, cancellationToken);
-
-            return response.HttpStatusCode != System.Net.HttpStatusCode.OK
-                ? Result.Fail<string>($"Failed to upload {fileName} to S3.")
-                : Result.Ok(string.Format(cdnBaseUrl, bucketName, fileName));
-        }
-        catch (Exception ex)
-        {
-            return Result.Fail<string>(new Error($"Error uploading {fileName} to S3: {ex.Message}").CausedBy(ex));
-        }
-    }
-}