feat: 加入更新客户端和命令行启动参数

AliCdnSSLWorker.csproj

@@ -7,7 +7,7 @@
     <UserSecretsId>dotnet-AliCdnSSLWorker-69cd49e9-faf0-424c-980f-751b97c9a16a</UserSecretsId>
     <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
     <DockerfileContext>.</DockerfileContext>
-    <AssemblyVersion>6.0.1.1</AssemblyVersion>
+    <AssemblyVersion>6.0.2.1</AssemblyVersion>
     <FileVersion>6.0.1.1</FileVersion>
   </PropertyGroup>
 
@@ -16,6 +16,7 @@
     <PackageReference Include="Aliyun.Credentials" Version="1.3.3" />
     <PackageReference Include="Macross.Json.Extensions" Version="3.0.0" />
     <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.0" />
+    <PackageReference Include="Microsoft.Extensions.Http" Version="8.0.0" />
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.5" />
   </ItemGroup>
 </Project>

Clients/RefreshRequestClient.cs

@@ -0,0 +1,31 @@
+using System.Net;
+using AliCdnSSLWorker.Configs;
+using Microsoft.Extensions.Options;
+
+namespace AliCdnSSLWorker.Clients;
+public class RefreshRequestClient
+{
+    public HttpClient Client { get; }
+
+    public RefreshRequestClient(HttpClient httpClient, IOptions<ApiConfig> options)
+    {
+        var ip = options.Value.IpAddress.ToString();
+        if (options.Value.IpAddress.Equals(IPAddress.Any))
+        {
+            ip = IPAddress.Loopback.ToString();
+        }
+
+        httpClient.BaseAddress = new($"http://{ip}:{options.Value.Port}/");
+        httpClient.DefaultRequestHeaders.Add(
+            "User-Agent",
+            $"AliCdnSSLWorker/{GetType().Assembly.GetName().Version}"
+        );
+
+        Client = httpClient;
+    }
+
+    public async Task<HttpResponseMessage> RequestAsync()
+    {
+        return await Client.GetAsync("/force_refresh/");
+    }
+}

Program.cs

@@ -1,3 +1,4 @@
+using AliCdnSSLWorker.Clients;
 using AliCdnSSLWorker.Configs;
 using AliCdnSSLWorker.Services;
 using AliCdnSSLWorker.Workers;
@@ -10,11 +11,39 @@
 builder.Services.Configure<CertConfig>(
     builder.Configuration.GetSection(nameof(CertConfig))
 );
+builder.Services.Configure<ApiConfig>(
+    builder.Configuration.GetSection(nameof(ApiConfig))
+);
 
+builder.Services.AddHttpClient<RefreshRequestClient>();
+builder.Services.AddSingleton<RefreshRequestService>();
 builder.Services.AddSingleton<AliCdnService>();
 builder.Services.AddSingleton<CertScanService>();
+
 builder.Services.AddHostedService<SSLWorker>();
 builder.Services.AddHostedService<ApiWorker>();
 
 var host = builder.Build();
+
+if (args.Length > 0)
+{
+    var logger = host.Services.GetRequiredService<ILogger<Program>>();
+
+    if (args[0] == "-r" || args[0] == "--refresh")
+    {
+        logger.LogWarning("Quick update mode. `-r` will request a refresh to running worker.");
+
+        var requestService = host.Services.GetRequiredService<RefreshRequestService>();
+        await requestService.Update();
+
+        logger.LogInformation("Request force refresh success.");
+    }
+    else
+    {
+        logger.LogInformation("Usage: AliCdnSSLWorker [options]\n"
+                              + "\t --refresh, -r \tRequest a refresh to running worker."
+                              + "Notes: other arguments will pass to .NET Host.");
+    }
+}
+
 host.Run();

Services/AliCdnService.cs

@@ -4,21 +4,21 @@
 using AliCdnSSLWorker.Configs;
 using Tea;
 using AliCdnSSLWorker.Models;
+using Aliyun.Credentials;
 
 namespace AliCdnSSLWorker.Services;
 
 public class AliCdnService
 {
     private readonly ILogger<AliCdnService> _logger;
     private readonly AlibabaCloud.SDK.Cdn20180510.Client _apiClient;
-    private readonly Aliyun.Credentials.Client _credentialClient;
     private readonly RuntimeOptions _runtimeOptions = new();
 
     public AliCdnService(ILogger<AliCdnService> logger, IOptions<AliCdnConfig> options)
     {
         ArgumentNullException.ThrowIfNull(options);
 
-        _credentialClient = new(new()
+        Client credentialClient = new(new()
         {
             AccessKeyId = options.Value.AccessKeyId,
             AccessKeySecret = options.Value.AccessKeySecret,
@@ -28,7 +28,7 @@ public AliCdnService(ILogger<AliCdnService> logger, IOptions<AliCdnConfig> optio
         _apiClient = new(new()
         {
             Endpoint = options.Value.Endpoint,
-            Credential = _credentialClient,
+            Credential = credentialClient,
         });
 
         _logger = logger;

Services/RefreshRequestService.cs

@@ -0,0 +1,11 @@
+using AliCdnSSLWorker.Clients;
+
+namespace AliCdnSSLWorker.Services;
+
+public class RefreshRequestService(RefreshRequestClient client)
+{
+    public async Task Update()
+        => (await client.RequestAsync())
+            .EnsureSuccessStatusCode();
+
+}