更新最新C# 语法

Author: JusterZhu

src/c#/GeneralUpdate.Client/Program.cs

@@ -1,43 +1,48 @@
-using System.Text;
+using System.Diagnostics;
+using System.Text;
 using GeneralUpdate.ClientCore;
 using GeneralUpdate.Common.Download;
 using GeneralUpdate.Common.Internal;
 using GeneralUpdate.Common.Internal.Bootstrap;
 using GeneralUpdate.Common.Shared.Object;
-using GeneralUpdate.Differential;
 
 namespace GeneralUpdate.Client
 {
     internal class Progra
     {
         private static void Main(string[] args)
         {
-            Task.Run(async () =>
+            /*Task.Run(async () =>
             {
                 var source = @"D:\packet\app";
                 var target = @"D:\packet\release";
                 var patch = @"D:\packet\patch";
 
                 await DifferentialCore.Instance?.Clean(source, target, patch);
                 await DifferentialCore.Instance?.Dirty(source, patch);
-            });
+            });*/
 
-            /*Task.Run(() =>
+            Task.Run(() =>
             {
                 var configinfo = new Configinfo();
                 configinfo.UpdateLogUrl = "https://www.baidu.com";
                 configinfo.ReportUrl = "http://127.0.0.1:5008/Upgrade/Report";
                 configinfo.UpdateUrl = "http://127.0.0.1:5008/Upgrade/Verification";
 
-                configinfo.AppName = "GeneralUpdate.Upgrade";
-                configinfo.MainAppName = "GeneralUpdate.Client";
+                configinfo.AppName = "GeneralUpdate.Upgrade.exe";
+                configinfo.MainAppName = "GeneralUpdate.Client.exe";
                 configinfo.InstallPath = Thread.GetDomain().BaseDirectory;
 
+                //当前客户端的版本号
                 configinfo.ClientVersion = "1.0.0.0";
+                //当前升级端的版本号
                 configinfo.UpgradeClientVersion = "1.0.0.0";
 
+                //平台
                 configinfo.Platform = 1;
-                configinfo.ProductId = "9999";
+                //产品id
+                configinfo.ProductId = "a77c9df5-45f8-4ee9-b3ad-b9431ce0b51c";
+                //应用密钥
                 configinfo.AppSecretKey = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
 
                 _ = new GeneralClientBootstrap()//单个或多个更新包下载通知事件
@@ -58,33 +63,40 @@ private static void Main(string[] args)
                     .Option(UpdateOption.Format, Format.ZIP)
                     .Option(UpdateOption.Drive, false)
                     .LaunchAsync();
-            });*/
+            });
 
             Console.Read();
         }
 
         private static void OnMultiDownloadError(object arg1, MultiDownloadErrorEventArgs arg2)
         {
+            Debug.WriteLine(arg2.Exception);
         }
 
         private static void OnMultiAllDownloadCompleted(object arg1, MultiAllDownloadCompletedEventArgs arg2)
         {
+            Debug.WriteLine(arg2.IsAllDownloadCompleted);
         }
 
         private static void OnMultiDownloadCompleted(object arg1, MultiDownloadCompletedEventArgs arg2)
         {
+            var v = arg2.Version as VersionInfo;
+            Debug.WriteLine(v.Version);
         }
 
         private static void OnMultiDownloadStatistics(object arg1, MultiDownloadStatisticsEventArgs arg2)
         {
+            Debug.WriteLine(arg2.Speed);
         }
 
         private static void OnMultiDownloadProgressChanged(object arg1, MultiDownloadProgressChangedEventArgs arg2)
         {
+            Debug.WriteLine(arg2.ProgressValue);
         }
 
         private static void OnException(object arg1, ExceptionEventArgs arg2)
         {
+            Debug.WriteLine(arg2.Exception);
         }
     }
 }

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

@@ -19,7 +19,7 @@
 namespace GeneralUpdate.ClientCore;
 
 /// <summary>
-///     This component is used only for client application bootstrapping classes.
+/// This component is used only for client application bootstrapping classes.
 /// </summary>
 public class GeneralClientBootstrap : AbstractBootstrap<GeneralClientBootstrap, IStrategy>
 {
@@ -41,19 +41,7 @@ public override async Task<GeneralClientBootstrap> LaunchAsync()
     {
         ExecuteCustomOptions();
         ClearEnvironmentVariable();
-        await InitializeDataAsync();
-        
-        var manager = new DownloadManager(_configinfo.TempPath, _configinfo.Format, _configinfo.DownloadTimeOut);
-        manager.MultiAllDownloadCompleted += OnMultiAllDownloadCompleted;
-        manager.MultiDownloadCompleted += OnMultiDownloadCompleted;
-        manager.MultiDownloadError += OnMultiDownloadError;
-        manager.MultiDownloadProgressChanged += OnMultiDownloadProgressChanged;
-        manager.MultiDownloadStatistics += OnMultiDownloadStatistics;
-        foreach (var versionInfo in _configinfo.UpdateVersions)
-        {
-            manager.Add(new DownloadTask(manager, versionInfo));
-        }
-        await manager.LaunchTasksAsync();
+        await ExecuteWorkflowAsync();
         return this;
     }
 
@@ -144,7 +132,7 @@ public GeneralClientBootstrap AddListenerException(Action<object, ExceptionEvent
 
     #region Private Methods
 
-    private async Task InitializeDataAsync()
+    private async Task ExecuteWorkflowAsync()
     {
         //Request the upgrade information needed by the client and upgrade end, and determine if an upgrade is necessary.
         var mainResp = await VersionService.Validate(_configinfo.UpdateUrl
@@ -160,40 +148,95 @@ private async Task InitializeDataAsync()
             ,_configinfo.AppSecretKey
             ,_configinfo.Platform
             ,_configinfo.ProductId);
-
-        _configinfo.IsUpgradeUpdate = upgradeResp.Body.Count > 0;
-        _configinfo.IsMainUpdate = mainResp.Body.Count > 0;
-        //No need to update, return directly.
-        if (!_configinfo.IsMainUpdate && !_configinfo.IsUpgradeUpdate) return;
-
+        
+        _configinfo.IsUpgradeUpdate = CheckUpgrade(upgradeResp);
+        _configinfo.IsMainUpdate = CheckUpgrade(mainResp);
+        
         //If the main program needs to be forced to update, the skip will not take effect.
         var isForcibly = CheckForcibly(mainResp.Body) || CheckForcibly(upgradeResp.Body);
         if (CanSkip(isForcibly)) return;
 
-        _configinfo.UpdateVersions = upgradeResp.Body.OrderBy(x => x.ReleaseDate).ToList();
-        _configinfo.LastVersion = _configinfo.UpdateVersions.Last().Version;
         _configinfo.Encoding = GetOption(UpdateOption.Encoding) ?? Encoding.Default;
-        _configinfo.Format = GetOption(UpdateOption.Format)?? "zip";
+        _configinfo.Format = GetOption(UpdateOption.Format) ?? ".zip";
         _configinfo.DownloadTimeOut = GetOption(UpdateOption.DownloadTimeOut) == 0 ? 60 : GetOption(UpdateOption.DownloadTimeOut);
         _configinfo.DriveEnabled = GetOption(UpdateOption.Drive);
-        _configinfo.TempPath = GeneralFileManager.GetTempDirectory(_configinfo.LastVersion);
+        _configinfo.TempPath = GeneralFileManager.GetTempDirectory("main_temp");
+
+        if (_configinfo.IsMainUpdate)
+        {
+            _configinfo.UpdateVersions = mainResp.Body.OrderBy(x => x.ReleaseDate).ToList();
+            _configinfo.LastVersion = _configinfo.UpdateVersions.Last().Version;
+            
+            //Initialize the process transfer parameter object.
+            var processInfo = new ProcessInfo(_configinfo.MainAppName
+                , _configinfo.InstallPath
+                , _configinfo.ClientVersion
+                , _configinfo.LastVersion
+                , _configinfo.UpdateLogUrl
+                , _configinfo.Encoding
+                , _configinfo.Format
+                , _configinfo.DownloadTimeOut
+                , _configinfo.AppSecretKey
+                , mainResp.Body
+                , _configinfo.ReportUrl);
+            
+            _configinfo.ProcessInfo = JsonSerializer.Serialize(processInfo);
+        }
+
+        StrategyFactory();
 
-        //Initialize the process transfer parameter object.
-        var processInfo = new ProcessInfo(_configinfo.MainAppName
-            , _configinfo.InstallPath
-            , _configinfo.ClientVersion
-            , _configinfo.LastVersion
-            , _configinfo.UpdateLogUrl
-            , _configinfo.Encoding
-            , _configinfo.Format
-            , _configinfo.DownloadTimeOut
-            , _configinfo.AppSecretKey
-            , mainResp.Body);
-        _configinfo.ProcessInfo = JsonSerializer.Serialize(processInfo);
+        switch (_configinfo.IsUpgradeUpdate)
+        {
+            case true when _configinfo.IsMainUpdate:
+                //Both upgrade and main program update.
+                await Download();
+                await _strategy?.ExecuteAsync()!;
+                _strategy?.StartApp();
+                break;
+            case true when !_configinfo.IsMainUpdate:
+                //Upgrade program update.
+                await Download();
+                await _strategy?.ExecuteAsync()!;
+                break;
+            case false when _configinfo.IsMainUpdate:
+                //Main program update.
+                _strategy?.StartApp();
+                break;
+        }
     }
+    
+    private async Task Download()
+    {
+        var manager = new DownloadManager(_configinfo.TempPath, _configinfo.Format, _configinfo.DownloadTimeOut);
+        manager.MultiAllDownloadCompleted += OnMultiAllDownloadCompleted;
+        manager.MultiDownloadCompleted += OnMultiDownloadCompleted;
+        manager.MultiDownloadError += OnMultiDownloadError;
+        manager.MultiDownloadProgressChanged += OnMultiDownloadProgressChanged;
+        manager.MultiDownloadStatistics += OnMultiDownloadStatistics;
+        foreach (var versionInfo in _configinfo.UpdateVersions)
+        {
+            manager.Add(new DownloadTask(manager, versionInfo));
+        }
+        await manager.LaunchTasksAsync();
+    }
+
+    private bool CheckUpgrade(VersionRespDTO? response)
+    {
+        if (response == null)
+        {
+            return false;
+        }
 
+        if (response.Code == HttpStatus.OK)
+        {
+            return response.Body.Count > 0;
+        }
+        
+        return false;
+    }
+    
     /// <summary>
-    ///     User decides if update is required.
+    /// User decides if update is required.
     /// </summary>
     /// <returns>is false to continue execution.</returns>
     private bool CanSkip(bool isForcibly)
@@ -221,7 +264,7 @@ private void ExecuteCustomOptions()
     }
 
     /// <summary>
-    ///     Clear the environment variable information needed to start the upgrade assistant process.
+    /// Clear the environment variable information needed to start the upgrade assistant process.
     /// </summary>
     private void ClearEnvironmentVariable()
     {
@@ -237,11 +280,25 @@ private void ClearEnvironmentVariable()
         }
     }
 
-    protected override void ExecuteStrategy()
+    private bool CheckForcibly(List<VersionBodyDTO>? versions)
     {
-        _strategy?.Create(_configinfo!);
-        _strategy?.Execute();
+        if (versions == null) 
+            return false;
+        
+        foreach (var item in versions)
+        {
+            if (item.IsForcibly == true)
+            {
+                return true;
+            }
+        }
+
+        return false;
     }
+    
+    protected override void ExecuteStrategy()=> throw new NotImplementedException();
+    
+    protected override Task ExecuteStrategyAsync()=> throw new NotImplementedException();
 
     protected override GeneralClientBootstrap StrategyFactory()
     {
@@ -252,22 +309,10 @@ protected override GeneralClientBootstrap StrategyFactory()
         else
             throw new PlatformNotSupportedException("The current operating system is not supported!");
 
+        _strategy?.Create(_configinfo!);
         return this;
     }
 
-    private bool CheckForcibly(List<VersionBodyDTO> versions)
-    {
-        foreach (var item in versions)
-        {
-            if (item.IsForcibly == true)
-            {
-                return true;
-            }
-        }
-
-        return false;
-    }
-
     private GeneralClientBootstrap AddListener<TArgs>(Action<object, TArgs> callbackAction) where TArgs : EventArgs
     {
         Debug.Assert(callbackAction != null);
@@ -288,11 +333,7 @@ private void OnMultiDownloadError(object sender, MultiDownloadErrorEventArgs e)
         => EventManager.Instance.Dispatch(sender, e);
 
     private void OnMultiAllDownloadCompleted(object sender, MultiAllDownloadCompletedEventArgs e)
-    {
-        EventManager.Instance.Dispatch(sender, e);
-        StrategyFactory();
-        ExecuteStrategy();
-    }
+        => EventManager.Instance.Dispatch(sender, e);
 
     #endregion Private Methods
 }

src/c#/GeneralUpdate.ClientCore/Pipeline/ZipMiddleware.cs

@@ -11,7 +11,7 @@ namespace GeneralUpdate.ClientCore.Pipeline;
 
 public class ZipMiddleware : IMiddleware
 {
-    public Task InvokeAsync(PipelineContext context)
+    public Task InvokeAsync(PipelineContext? context)
     {
         return Task.Run(() =>
         {