Merge pull request #198 from cnblogs/support-oss-signed-url

feat: support aliyun oss download link generation

Author: ikesnowy

src/Cnblogs.Architecture.Ddd.Cqrs.Dapper.SqlServer/Cnblogs.Architecture.Ddd.Cqrs.Dapper.SqlServer.csproj

@@ -11,7 +11,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.Data.SqlClient" Version="5.1.2"/>
+    <PackageReference Include="Microsoft.Data.SqlClient" Version="5.1.4" />
   </ItemGroup>
 
 </Project>

src/Cnblogs.Architecture.Ddd.Cqrs.DependencyInjection/CqrsInjector.cs

@@ -128,6 +128,18 @@ public CqrsInjector AddFileProvider<TProvider>()
         return this;
     }
 
+    /// <summary>
+    ///     Use given implementation of <see cref="IFileDeliveryProvider"/>.
+    /// </summary>
+    /// <typeparam name="TProvider">The type of implementation.</typeparam>
+    /// <returns></returns>
+    public CqrsInjector AddFileDeliveryProvider<TProvider>()
+        where TProvider : class, IFileDeliveryProvider
+    {
+        Services.AddScoped<IFileDeliveryProvider, TProvider>();
+        return this;
+    }
+
     /// <summary>
     ///     添加自定义随机数提供器。
     /// </summary>

src/Cnblogs.Architecture.Ddd.Cqrs.ServiceAgent/Cnblogs.Architecture.Ddd.Cqrs.ServiceAgent.csproj

@@ -9,7 +9,7 @@
   </ItemGroup>
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.Http" Version="8.0.0" />
-    <PackageReference Include="Microsoft.Extensions.Http.Polly" Version="8.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Http.Polly" Version="8.0.1" />
   </ItemGroup>
   <ItemGroup>
     <Compile Include="..\Cnblogs.Architecture.Ddd.Cqrs.AspNetCore\CqrsHeaderNames.cs">

src/Cnblogs.Architecture.Ddd.EventBus.Dapr/DaprEventBusProvider.cs

@@ -40,7 +40,7 @@ public async Task PublishAsync(string eventName, IntegrationEvent @event)
             eventName,
             @event,
             @event.TraceId ?? @event.Id);
-        object data = @event;   // do not provide type information to serializer since it's base class.
+        object data = @event; // do not provide type information to serializer since it's base class.
         await _daprClient.PublishEventAsync(
             DaprOptions.PubSubName,
             DaprUtils.GetDaprTopicName(_daprOptions.AppName, eventName),

src/Cnblogs.Architecture.Ddd.Infrastructure.Abstractions/IFileDeliveryProvider.cs

@@ -0,0 +1,15 @@
+namespace Cnblogs.Architecture.Ddd.Infrastructure.Abstractions;
+
+/// <summary>
+///     File provider that can create public url for user to download
+/// </summary>
+public interface IFileDeliveryProvider
+{
+    /// <summary>
+    ///     Get public url to download with validate time.
+    /// </summary>
+    /// <param name="filename">The file filename.</param>
+    /// <param name="duration">Duration of url availability.</param>
+    /// <returns></returns>
+    public Task<string> GetDownloadUrlAsync(string filename, TimeSpan duration);
+}

src/Cnblogs.Architecture.Ddd.Infrastructure.Dapper.Clickhouse/Cnblogs.Architecture.Ddd.Infrastructure.Dapper.Clickhouse.csproj

@@ -13,7 +13,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="ClickHouse.Client" Version="6.8.1" />
+    <PackageReference Include="ClickHouse.Client" Version="7.0.0" />
   </ItemGroup>
 
 </Project>

src/Cnblogs.Architecture.Ddd.Infrastructure.Dapper/Cnblogs.Architecture.Ddd.Infrastructure.Dapper.csproj

@@ -10,7 +10,7 @@
 
   <ItemGroup>
     <PackageReference Include="Dapper" Version="2.1.28" />
-    <PackageReference Include="Microsoft.Extensions.Options" Version="8.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Options" Version="8.0.1" />
   </ItemGroup>
 
 </Project>

src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework.csproj

@@ -9,7 +9,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.1" />
   </ItemGroup>
 
   <ItemGroup>

src/Cnblogs.Architecture.Ddd.Infrastructure.FileProviders.AliyunOss/AliyunOssFileDeliveryProvider.cs

@@ -0,0 +1,40 @@
+using Cnblogs.Architecture.Ddd.Infrastructure.Abstractions;
+using Cuiliang.AliyunOssSdk;
+using Microsoft.Extensions.Options;
+
+namespace Cnblogs.Architecture.Ddd.Infrastructure.FileProviders.AliyunOss;
+
+/// <summary>
+///     Aliyun OSS implementation of <see cref="IFileDeliveryProvider"/>.
+/// </summary>
+public class AliyunOssFileDeliveryProvider : IFileDeliveryProvider
+{
+    private readonly OssClient _client;
+    private readonly AliyunOssOptions _options;
+
+    /// <summary>
+    ///     Create a <see cref="AliyunOssFileDeliveryProvider"/>.
+    /// </summary>
+    /// <param name="client">The oss client.</param>
+    /// <param name="options">The options for oss client.</param>
+    public AliyunOssFileDeliveryProvider(OssClient client, IOptions<AliyunOssOptions> options)
+    {
+        _client = client;
+        _options = options.Value;
+    }
+
+    /// <inheritdoc />
+    public async Task<string> GetDownloadUrlAsync(string filename, TimeSpan duration)
+    {
+        var meta = await _client.GetObjectMetaAsync(_options.BucketInfo, filename);
+        if (meta.IsSuccess == false)
+        {
+            throw new FileNotFoundException(meta.ErrorMessage, filename, meta.InnerException);
+        }
+
+        return _client.GetFileDownloadLink(
+            _options.BucketInfo,
+            filename,
+            (int)Math.Ceiling(duration.TotalSeconds));
+    }
+}

src/Cnblogs.Architecture.Ddd.Infrastructure.FileProviders.AliyunOss/CqrsInjectorExtensions.cs

@@ -11,7 +11,7 @@ namespace Cnblogs.Architecture.Ddd.Infrastructure.FileProviders.AliyunOss;
 public static class CqrsInjectorExtensions
 {
     /// <summary>
-    ///     Use aliyun oss as default implementation of <see cref="IFileProvider"/>.
+    ///     Use aliyun oss as default implementation of <see cref="IFileProvider"/> and <see cref="IFileDeliveryProvider"/>.
     /// </summary>
     /// <param name="injector"></param>
     /// <param name="configuration"></param>
@@ -24,6 +24,7 @@ public static CqrsInjector UseAliyunOssFileProvider(
     {
         injector.Services.AddOssClient(configuration, configurationSectionName);
         injector.Services.Configure<AliyunOssOptions>(configuration.GetSection(configurationSectionName));
-        return injector.AddFileProvider<AliyunOssFileProvider>();
+        return injector.AddFileProvider<AliyunOssFileProvider>()
+            .AddFileDeliveryProvider<AliyunOssFileDeliveryProvider>();
     }
 }