AWS storage

src/platform/mix.constant/Enums/MixStorageProvider.cs

@@ -3,6 +3,7 @@
     public enum MixStorageProvider
     {
         CLOUDFLARE,
-        MIX
+        MIX,
+        AWS
     }
 }

src/platform/mix.storage.lib/Engines/Aws/AwsSetting.cs

@@ -0,0 +1,17 @@
+namespace Mix.Storage.Lib.Engines.Aws
+{
+    public class AwsSetting
+    {
+        public string BucketName { get; set; }
+
+        public string CloudFrontUrl { get; set; }
+
+        public string BucketUrl { get; set; }
+
+        public string AccessKeyId { get; set; }
+
+        public string SecretAccessKey { get; set; }
+
+        public string Region { get; set; }
+    }
+}

src/platform/mix.storage.lib/Engines/Aws/AwsUploader.cs

@@ -0,0 +1,78 @@
+using System.Net;
+using Amazon;
+using Amazon.S3;
+using Amazon.S3.Model;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Configuration;
+using Mix.Storage.Lib.Engines.Base;
+
+namespace Mix.Storage.Lib.Engines.Aws
+{
+    public class AwsUploader : UploaderBase
+    {
+        private readonly AwsSetting _setting;
+
+        private readonly IAmazonS3 _client;
+
+        public AwsUploader(IHttpContextAccessor httpContextAccessor, IConfiguration configuration, UnitOfWorkInfo<MixCmsContext> cmsUow) : base(httpContextAccessor, configuration, cmsUow)
+        {
+            _setting = new AwsSetting();
+            Configuration.Bind("StorageSetting:AwsSetting", _setting);
+            _client = new AmazonS3Client(
+                _setting.AccessKeyId,
+                _setting.SecretAccessKey,
+                new AmazonS3Config
+                {
+                    RegionEndpoint = RegionEndpoint.GetBySystemName(_setting.Region)
+                });
+        }
+
+        public override async Task<string?> Upload(IFormFile file, string? themeName, string? createdBy, CancellationToken cancellationToken = default)
+        {
+            using (var inputStream = new MemoryStream())
+            {
+                await file.CopyToAsync(inputStream, cancellationToken);
+
+                var request = new PutObjectRequest
+                {
+                    BucketName = _setting.BucketName,
+                    Key = string.IsNullOrEmpty(themeName) ? file.FileName : Path.Combine(themeName, file.FileName),
+                    InputStream = inputStream,
+                    CannedACL = S3CannedACL.PublicRead
+                };
+
+                return await GetStorageUrl(request, cancellationToken);
+            }
+        }
+
+        public override async Task<string?> UploadStream(FileModel file, string? createdBy, CancellationToken cancellationToken = default)
+        {
+            var base64String = file.FileBase64.Split(',')[1];
+            var bytes = Convert.FromBase64String(base64String);
+            using (var inputStream = new MemoryStream(bytes))
+            {
+                var request = new PutObjectRequest
+                {
+                    BucketName = _setting.BucketName,
+                    Key = string.IsNullOrEmpty(file.FileFolder) ? $"{file.Filename}{file.Extension}" : file.FullPath,
+                    InputStream = inputStream,
+                    CannedACL = S3CannedACL.PublicRead
+                };
+
+                return await GetStorageUrl(request, cancellationToken);
+            }
+        }
+
+        private async Task<string> GetStorageUrl(PutObjectRequest request, CancellationToken cancellationToken = default)
+        {
+            var response = await _client.PutObjectAsync(request, cancellationToken);
+            if (response.HttpStatusCode != HttpStatusCode.OK)
+            {
+                return string.Empty;
+            }
+
+            var storageUrl = string.IsNullOrEmpty(_setting.CloudFrontUrl) ? _setting.BucketUrl : _setting.CloudFrontUrl;
+            return $"{storageUrl}/{request.Key}";
+        }
+    }
+}

src/platform/mix.storage.lib/Engines/Base/UploaderBase.cs

@@ -24,9 +24,9 @@ protected MixTenantSystemModel CurrentTenant
             }
         }
 
-        protected UploaderBase(IHttpContextAccessor httpContextAccessor, IConfiguration configuration, UnitOfWorkInfo<MixCmsContext> cmsUOW)
+        protected UploaderBase(IHttpContextAccessor httpContextAccessor, IConfiguration configuration, UnitOfWorkInfo<MixCmsContext> cmsUow)
         {
-            CmsUow = cmsUOW;
+            CmsUow = cmsUow;
             Configuration = configuration;
             Session = httpContextAccessor?.HttpContext?.Session;
         }
@@ -60,7 +60,7 @@ public async Task CreateMedia(string fullname, int tenantId, string? createdBy,
             var result = await Upload(file, folder, createdBy, cancellationToken);
             if (!string.IsNullOrEmpty(result))
             {
-                await CreateMedia(result, _currentTenant.Id, createdBy, cancellationToken);
+                await CreateMedia(result, CurrentTenant.Id, createdBy, cancellationToken);
             }
 
             return result;
@@ -71,7 +71,7 @@ public async Task CreateMedia(string fullname, int tenantId, string? createdBy,
             var result = await UploadStream(file, createdBy, cancellationToken);
             if (!string.IsNullOrEmpty(result))
             {
-                await CreateMedia(result, _currentTenant.Id, createdBy, cancellationToken);
+                await CreateMedia(result, CurrentTenant.Id, createdBy, cancellationToken);
             }
 
             return result;

src/platform/mix.storage.lib/Engines/Mix/MixUploader.cs

@@ -61,7 +61,7 @@ private string GetUploadFolder(string filename, string? fileFolder, string? crea
                 folder = $"{folder}/{createdBy}";
             }
 
-            return $"{folder}/{DateTime.Now.ToString("yyyy-MM")}";
+            return $"{folder}/{DateTime.Now:yyyy-MM}";
         }
     }
 }

src/platform/mix.storage.lib/Services/MixStorageService.cs

@@ -1,5 +1,7 @@
-using Microsoft.AspNetCore.Http;
+using Amazon.S3;
+using Microsoft.AspNetCore.Http;
 using Microsoft.Extensions.Configuration;
+using Mix.Storage.Lib.Engines.Aws;
 using Mix.Storage.Lib.Engines.Base;
 using Mix.Storage.Lib.Engines.CloudFlare;
 using Mix.Storage.Lib.Engines.Mix;
@@ -22,14 +24,14 @@ private IMixUploader CreateUploader(IHttpContextAccessor httpContext, UnitOfWork
         {
             var providerSetting = _configuration["StorageSetting:Provider"];
             var provider = Enum.Parse<MixStorageProvider>(providerSetting);
-            switch (provider)
+            return provider switch
             {
-                case MixStorageProvider.CLOUDFLARE:
-                    return new CloudFlareUploader(httpContext, _configuration, cmsUow, _httpService);
-                case MixStorageProvider.MIX:
-                default:
-                    return new MixUploader(httpContext, _configuration, cmsUow);
-            }
+                MixStorageProvider.CLOUDFLARE => new CloudFlareUploader(httpContext, _configuration, cmsUow,
+                    _httpService),
+                MixStorageProvider.AWS => new AwsUploader(httpContext, _configuration, cmsUow),
+                MixStorageProvider.MIX => new MixUploader(httpContext, _configuration, cmsUow),
+                _ => new MixUploader(httpContext, _configuration, cmsUow)
+            };
         }
         #region Methods
 

src/platform/mix.storage.lib/mix.storage.lib.csproj

@@ -7,6 +7,10 @@
     <RootNamespace>Mix.Storage.Lib</RootNamespace>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="AWSSDK.S3" Version="3.7.104.15" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\mix.library\mix.library.csproj" />
   </ItemGroup>