feat: 向主控请求证书

fix: Config.byoc 字段应为 bool 而不是 string

CSharp-OpenBMCLAPI/DefaultConfig.json5

@@ -1,6 +1,14 @@
 {
-    // 指示 token 应当在距离其失效前的多少毫秒进行刷新
-    "refreshTokenTime": 1800000,
-    // 指示应该将要服务的文件放在哪里（服务路径）
-    "clusterFileDirectory": "./"
+  // 指示 token 应当在距离其失效前的多少毫秒进行刷新
+  "refreshTokenTime": 1800000,
+  // 指示应该将要服务的文件放在哪里（服务路径）
+  "clusterFileDirectory": "./",
+  // 用户访问时使用的 IP 或域名
+  "host": "",
+  // 对外服务端口
+  "port": 4000,
+  // 是否使用自定义域名
+  "byoc": false,
+  // 指示是否执行快速上线，若为 true 则每次都不执行
+  "noFastEnable": false
 }

CSharp-OpenBMCLAPI/Modules/Cluster.cs

@@ -14,6 +14,8 @@
 using SocketIOClient;
 using SocketIO.Core;
 using TeraIO.Extension;
+using System.Diagnostics;
+using System.Text.Json;
 
 namespace CSharpOpenBMCLAPI.Modules
 {
@@ -66,6 +68,8 @@ protected async Task<int> AsyncRun()
 
             Connect();
 
+            await RequestCertification();
+
             await Enable();
 
             _keepAlive = Task.Run(() =>
@@ -74,6 +78,7 @@ protected async Task<int> AsyncRun()
                 {
                     Thread.Sleep(25 * 1000);
                     KeepAlive().Wait();
+                    this.token.FetchToken().Wait();
                 }
             });
 
@@ -114,8 +119,8 @@ await socket.EmitAsync("enable",
                 },
                 new
                 {
-                    host = SharedData.Config.host,
-                    port = SharedData.Config.port,
+                    host = SharedData.Config.HOST,
+                    port = SharedData.Config.PORT,
                     version = SharedData.Config.clusterVersion,
                     byoc = SharedData.Config.byoc,
                     noFastEnable = SharedData.Config.noFastEnable
@@ -133,8 +138,8 @@ await socket.EmitAsync("disable",
 
         public async Task KeepAlive()
         {
-            string time = DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss.fffZ");
-            socket.Connected.Dump();
+            string time = DateTime.Now.ToStandardTimeString();
+            // socket.Connected.Dump();
             await socket.EmitAsync("keep-alive",
                 (SocketIOResponse resp) =>
                 {
@@ -148,6 +153,7 @@ await socket.EmitAsync("keep-alive",
 
         protected async Task CheckFiles()
         {
+            SharedData.Logger.LogInfo("开始检查文件");
             var resp = await client.GetAsync("openbmclapi/files");
             byte[] buffer = await resp.Content.ReadAsByteArrayAsync();
             var decomporess = new Decompressor();
@@ -227,5 +233,35 @@ private void CheckFileAfterDownload(string path, string hash, DownloadService se
                 service.DownloadFileTaskAsync($"{client.BaseAddress}openbmclapi/download/{hash}").Wait();
             }
         }
+
+        public async Task RequestCertification()
+        {
+            await socket.EmitAsync("request-cert", (SocketIOResponse resp) =>
+            {
+                var data = resp;
+                //Debugger.Break();
+                var json = data.GetValue<JsonElement>(0)[1];
+                JsonElement cert; json.TryGetProperty("cert", out cert);
+                JsonElement key; json.TryGetProperty("key", out key);
+
+                string? certString = cert.GetString();
+                string? keyString = key.GetString();
+
+                string certPath = $"{SharedData.Config.clusterFileDirectory}certifications/cert.pem";
+                string keyPath = $"{SharedData.Config.clusterFileDirectory}certifications/key.pem";
+
+                Directory.CreateDirectory($"{SharedData.Config.clusterFileDirectory}certifications");
+
+                using (var file = File.Create(certPath))
+                {
+                    if (certString != null) file.Write(Encoding.UTF8.GetBytes(certString));
+                }
+
+                using (var file = File.Create(keyPath))
+                {
+                    if (keyString != null) file.Write(Encoding.UTF8.GetBytes(keyString));
+                }
+            });
+        }
     }
 }

CSharp-OpenBMCLAPI/Modules/Config.cs

@@ -1,4 +1,5 @@
-using System;
+using Newtonsoft.Json;
+using System;
 using System.Collections.Generic;
 using System.ComponentModel;
 using System.Linq;
@@ -16,21 +17,28 @@ public class Config
         // 指示节点端的版本，不应由用户更改
         [Browsable(false)]
         public string clusterVersion;
-        // Host
-        public string host;
-        public int port;
-        public string byoc;
+        // 用户访问时使用的 IP 或域名
+        [JsonProperty("host")]
+        public string HOST { get; set; }
+        // 对外服务端口
+        [JsonProperty("port")]
+        public int PORT { get; set; }
+        // 是否使用自定义域名
+        public bool byoc;
+        // 指示是否执行快速上线，若为 true 则每次都不执行
         public bool noFastEnable;
 
+        private string _host = "";
+
         public Config()
         {
             this.refreshTokenTime = 1800000;
             this.clusterFileDirectory = "./";
             this.clusterVersion = "1.9.7";
 
-            this.host = "";
-            this.port = 4000;
-            this.byoc = "";
+            this.HOST = "";
+            this.PORT = 4000;
+            this.byoc = false;
             this.noFastEnable = false;
         }
     }

CSharp-OpenBMCLAPI/Modules/ExtensionMethods.cs

@@ -15,6 +15,8 @@ public static T ThrowIfNull<T>(this T? item)
             return item;
         }
 
+        public static string ToStandardTimeString(this DateTime dt) => dt.ToString("yyyy-MM-ddTHH:mm:ss.fffZ");
+
         public static void PrintTypeInfo<T>(T instance)
         {
             Type type = typeof(T);