add http token

Author: JusterZhu

src/c#/GeneralUpdate.ClientCore/GeneralClientBootstrap.cs

@@ -78,7 +78,9 @@ public GeneralClientBootstrap SetConfig(Configinfo configInfo)
             BlackFiles = configInfo.BlackFiles,
             ProductId = configInfo.ProductId,
             UpgradeClientVersion = configInfo.UpgradeClientVersion,
-            Bowl = configInfo.Bowl
+            Bowl = configInfo.Bowl,
+            Scheme = configInfo.Scheme,
+            Token = configInfo.Token
         };
         return this;
     }
@@ -144,14 +146,18 @@ private async Task ExecuteWorkflowAsync()
                 , AppType.ClientApp
                 , _configInfo.AppSecretKey
                 , GetPlatform()
-                , _configInfo.ProductId);
+                , _configInfo.ProductId
+                , _configInfo.Scheme
+                , _configInfo.Token);
 
             var upgradeResp = await VersionService.Validate(_configInfo.UpdateUrl
                 , _configInfo.UpgradeClientVersion
                 , AppType.UpgradeApp
                 , _configInfo.AppSecretKey
                 , GetPlatform()
-                , _configInfo.ProductId);
+                , _configInfo.ProductId
+                , _configInfo.Scheme
+                , _configInfo.Token);
 
             _configInfo.IsUpgradeUpdate = CheckUpgrade(upgradeResp);
             _configInfo.IsMainUpdate = CheckUpgrade(mainResp);
@@ -191,7 +197,9 @@ private async Task ExecuteWorkflowAsync()
                     , mainResp.Body
                     , _configInfo.ReportUrl
                     , _configInfo.BackupDirectory
-                    , _configInfo.Bowl);
+                    , _configInfo.Bowl
+                    , _configInfo.Scheme
+                    , _configInfo.Token);
 
                 _configInfo.ProcessInfo =
                     JsonSerializer.Serialize(processInfo, ProcessInfoJsonContext.Default.ProcessInfo);

src/c#/GeneralUpdate.ClientCore/Strategys/LinuxStrategy.cs

@@ -64,7 +64,12 @@ public override async Task ExecuteAsync()
                 }
                 finally
                 {
-                    await VersionService.Report(_configinfo.ReportUrl, version.RecordId, status, version.AppType);
+                    await VersionService.Report(_configinfo.ReportUrl
+                        , version.RecordId
+                        , status
+                        , version.AppType
+                        , _configinfo.Scheme
+                        , _configinfo.Token);
                 }
             }
 

src/c#/GeneralUpdate.ClientCore/Strategys/WindowsStrategy.cs

@@ -63,7 +63,12 @@ public override async Task ExecuteAsync()
                 }
                 finally
                 {
-                    await VersionService.Report(_configinfo.ReportUrl, version.RecordId, status, version.AppType);
+                    await VersionService.Report(_configinfo.ReportUrl
+                        , version.RecordId
+                        , status
+                        , version.AppType
+                        , _configinfo.Scheme
+                        , _configinfo.Token);
                 }
             }
 

src/c#/GeneralUpdate.Common/Shared/Object/Configinfo.cs

@@ -69,6 +69,10 @@ public class Configinfo
         public string ProductId { get; set; }
 
         public string Bowl { get; set; }
+        
+        public string Scheme { get; set; }
+    
+        public string Token { get; set; }
 
         public void Validate()
         {

src/c#/GeneralUpdate.Common/Shared/Object/GlobalConfigInfo.cs

@@ -117,4 +117,8 @@ public class GlobalConfigInfo
     public string BackupDirectory { get; set; }
 
     public string Bowl { get; set; }
+
+    public string Scheme { get; set; }
+    
+    public string Token { get; set; }
 }

src/c#/GeneralUpdate.Common/Shared/Object/ProcessInfo.cs

@@ -22,7 +22,9 @@ public ProcessInfo(string appName
             , List<VersionInfo> updateVersions
             , string reportUrl
             , string backupDirectory
-            , string bowl)
+            , string bowl
+            , string scheme
+            , string token)
         {
             AppName = appName ?? throw new ArgumentNullException(nameof(appName));
             if (!Directory.Exists(installPath)) throw new ArgumentException($"{nameof(installPath)} path does not exist ! {installPath}.");
@@ -40,6 +42,8 @@ public ProcessInfo(string appName
             ReportUrl = reportUrl ?? throw new ArgumentNullException(nameof(reportUrl));
             BackupDirectory = backupDirectory ?? throw new ArgumentNullException(nameof(backupDirectory));
             Bowl = bowl;
+            Scheme = scheme;
+            Token = token;
         }
 
         /// <summary>
@@ -116,5 +120,11 @@ public ProcessInfo(string appName
 
         [JsonPropertyName("Bowl")]
         public string Bowl { get; set; }
+        
+        [JsonPropertyName("Scheme")]
+        public string Scheme { get; set; }
+    
+        [JsonPropertyName("Token")]
+        public string Token { get; set; }
     }
 }

src/c#/GeneralUpdate.Common/Shared/Service/VersionService.cs

@@ -28,15 +28,17 @@ private VersionService() { }
         public static async Task Report(string httpUrl
             , int recordId
             , int status
-            , int? type)
+            , int? type
+            , string scheme = null
+            , string token = null)
         {
             var parameters = new Dictionary<string, object>
             {
                 { "RecordId", recordId },
                 { "Status", status },
                 { "Type", type }
             };
-            await PostTaskAsync<BaseResponseDTO<bool>>(httpUrl, parameters, ReportRespJsonContext.Default.BaseResponseDTOBoolean);
+            await PostTaskAsync<BaseResponseDTO<bool>>(httpUrl, parameters, ReportRespJsonContext.Default.BaseResponseDTOBoolean, scheme, token);
         }
 
         /// <summary>
@@ -54,7 +56,9 @@ public static async Task<VersionRespDTO> Validate(string httpUrl
             , int appType
             , string appKey
             , int platform
-            , string productId)
+            , string productId
+            , string scheme = null
+            , string token = null)
         {
             var parameters = new Dictionary<string, object>
             {
@@ -64,10 +68,10 @@ public static async Task<VersionRespDTO> Validate(string httpUrl
                 { "Platform", platform },
                 { "ProductId", productId }
             };
-            return await PostTaskAsync<VersionRespDTO>(httpUrl, parameters, VersionRespJsonContext.Default.VersionRespDTO);
+            return await PostTaskAsync<VersionRespDTO>(httpUrl, parameters, VersionRespJsonContext.Default.VersionRespDTO, scheme, token);
         }
 
-        private static async Task<T> PostTaskAsync<T>(string httpUrl, Dictionary<string, object> parameters, JsonTypeInfo<T>? typeInfo = null)
+        private static async Task<T> PostTaskAsync<T>(string httpUrl, Dictionary<string, object> parameters, JsonTypeInfo<T>? typeInfo = null, string scheme = null, string token = null)
         {
             try
             {
@@ -78,6 +82,13 @@ private static async Task<T> PostTaskAsync<T>(string httpUrl, Dictionary<string,
                 });
                 httpClient.Timeout = TimeSpan.FromSeconds(15);
                 httpClient.DefaultRequestHeaders.Accept.ParseAdd("text/html, application/xhtml+xml, */*");
+                
+                if (!string.IsNullOrEmpty(scheme) && !string.IsNullOrEmpty(token))
+                {
+                    httpClient.DefaultRequestHeaders.Authorization = 
+                        new System.Net.Http.Headers.AuthenticationHeaderValue(scheme, token);
+                }
+                
                 var parametersJson =
                     JsonSerializer.Serialize(parameters, HttpParameterJsonContext.Default.DictionaryStringObject);
                 var stringContent = new StringContent(parametersJson, Encoding.UTF8, "application/json");

src/c#/GeneralUpdate.Core/GeneralUpdateBootstrap.cs

@@ -47,7 +47,9 @@ public GeneralUpdateBootstrap()
                 UpdateVersions = processInfo.UpdateVersions,
                 TempPath = StorageManager.GetTempDirectory("upgrade_temp"),
                 ReportUrl = processInfo.ReportUrl,
-                BackupDirectory = processInfo.BackupDirectory
+                BackupDirectory = processInfo.BackupDirectory,
+                Scheme = processInfo.Scheme,
+                Token = processInfo.Token
             };
         }
 

src/c#/GeneralUpdate.Core/Strategys/WindowsStrategy.cs

@@ -73,8 +73,12 @@ public override void Execute()
                         }
                         finally
                         {
-                            await VersionService.Report(_configinfo.ReportUrl, version.RecordId, status,
-                                version.AppType);
+                            await VersionService.Report(_configinfo.ReportUrl
+                                , version.RecordId
+                                , status
+                                , version.AppType
+                                , _configinfo.Scheme
+                                , _configinfo.Token);
                         }
                     }