完善推送升级订阅

Author: JusterZhu

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

@@ -1,6 +1,7 @@
 using System.Diagnostics;
 using System.Text;
 using GeneralUpdate.ClientCore;
+using GeneralUpdate.ClientCore.Hubs;
 using GeneralUpdate.Common.Download;
 using GeneralUpdate.Common.Internal;
 using GeneralUpdate.Common.Internal.Bootstrap;
@@ -68,17 +69,28 @@ private static void Main(string[] args)
                     .LaunchAsync();
             });*/
 
-            var paramsOSS = new GlobalConfigInfoOSS();
+            /*var paramsOSS = new GlobalConfigInfoOSS();
             paramsOSS.Url = "http://192.168.50.203/versions.json";
             paramsOSS.CurrentVersion = "1.0.0.0";
             paramsOSS.VersionFileName = "versions.json";
             paramsOSS.AppName = "GeneralUpdate.Client.exe";
             paramsOSS.Encoding = Encoding.UTF8.WebName;
-            GeneralClientOSS.Start(paramsOSS);
+            GeneralClientOSS.Start(paramsOSS);*/
+            
+
+            var hub = new UpgradeHubService("http://localhost:5008/UpgradeHub");
+            hub.AddReceiveListener(Receive);
+            hub.StartAsync().Wait();
 
             Console.Read();
         }
 
+        private static void Receive(string arg1, string arg2)
+        {
+            throw new NotImplementedException();
+        }
+
+
         private static void OnMultiDownloadError(object arg1, MultiDownloadErrorEventArgs arg2)
         {
             Debug.WriteLine(arg2.Exception);

src/c#/GeneralUpdate.ClientCore/Hubs/IUpgradeHubService.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Threading.Tasks;
+
+namespace GeneralUpdate.ClientCore.Hubs;
+
+public interface IUpgradeHubService
+{
+        /// <summary>
+    /// Add a listener to receive upgrade information pushed from the server.
+    /// </summary>
+    /// <param name="receiveMessageCallback">string : group name , string :  received message content.</param>
+    public void AddReceiveListener(Action<string, string> receiveMessageCallback);
+
+    /// <summary>
+    /// Add a listener to receive online and offline notifications.
+    /// </summary>
+    /// <param name="onlineMessageCallback">string : Offline or online information.</param>
+    public void AddOnlineListener(Action<string> onlineMessageCallback);
+
+    /// <summary>
+    /// Add a listener to receive reconnection notifications.
+    /// </summary>
+    /// <param name="reconnectedCallback">string? : Reconnection information.</param>
+    public void AddReconnectedListener(Func<string?, Task>? reconnectedCallback);
+
+    /// <summary>
+    /// Add a listener to receive disconnection notifications.
+    /// </summary>
+    /// <param name="closeCallback">Exception? : Offline exception information.</param>
+    public void AddClosedListener(Func<Exception?, Task> closeCallback);
+    
+    /// <summary>
+    /// Start subscribing to upgrade push notifications, and the content of the notifications should be agreed upon independently (it is recommended to use JSON data format).
+    /// </summary>
+    public Task StartAsync();
+    
+    /// <summary>
+    /// When closing the connection, any ongoing message processing will be completed, but no new messages will be accepted.
+    /// This should be called before the application closes or goes to sleep, so it can reconnect when it resumes next time.
+    /// </summary>
+    public Task StopAsync();
+
+    /// <summary>
+    /// The Hub instance will be completely disposed of and cannot be used for reconnection.
+    /// </summary>
+    public Task DisposeAsync();
+}

src/c#/GeneralUpdate.ClientCore/Hubs/UpgradeHubService.cs

@@ -0,0 +1,41 @@
+using System;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.SignalR.Client;
+
+namespace GeneralUpdate.ClientCore.Hubs;
+
+/// <summary>
+/// Upgrade the push notification service.
+/// </summary>
+/// <param name="url">Subscription address, for example: http://127.0.0.1/UpgradeHub</param>
+public class UpgradeHubService(string url) : IUpgradeHubService
+{
+    private const string Onlineflag = "Online";
+    private const string ReceiveMessageflag = "ReceiveMessage";
+    
+    private readonly HubConnection? _connection = new HubConnectionBuilder()
+        .WithUrl(url)
+        .WithAutomaticReconnect(new RandomRetryPolicy())
+        .Build();
+    
+    public void AddReceiveListener(Action<string, string> receiveMessageCallback)
+        => _connection?.On(ReceiveMessageflag, receiveMessageCallback);
+
+    public void AddOnlineListener(Action<string> onlineMessageCallback)
+        => _connection?.On(Onlineflag, onlineMessageCallback);
+
+    public void AddReconnectedListener(Func<string?, Task>? reconnectedCallback)
+        => _connection!.Reconnected += reconnectedCallback;
+
+    public void AddClosedListener(Func<Exception?, Task> closeCallback)
+        => _connection!.Closed += closeCallback;
+    
+    public async Task StartAsync()
+        => await _connection!.StartAsync();
+    
+    public async Task StopAsync()
+        => await _connection!.StopAsync();
+
+    public async Task DisposeAsync()
+        => await _connection!.DisposeAsync();
+}

src/c#/GeneralUpdate.ClientCore/Hubs/VersionHub.cs

@@ -1,7 +1,6 @@
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
-using System.IO;
 using System.Runtime.InteropServices;
 using System.Text;
 using System.Text.Json;

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

@@ -9,25 +9,19 @@ class Program
 {
     static void Main(string[] args)
     {
-        var processInfo = TestProcessInfo();
-        Bowl.Launch(processInfo);
-        Console.Read();
-    }
-    
-    private static MonitorParameter TestProcessInfo()
-    {
-        var path = @"D:\packet\test.json";
-        var json = File.ReadAllText(path);
-        var processInfo = JsonSerializer.Deserialize<ProcessInfo>(json);
-        return new MonitorParameter
+        var installPath = @"D:\github_project\GeneralUpdate\src\c#\GeneralUpdate.CatBowl\bin\Debug\net8.0\";
+        var lastVersion = "1.0.0.3";
+        var processInfo = new MonitorParameter
         {
-            ProcessNameOrId = processInfo.AppName,
-            DumpFileName = $"{processInfo.LastVersion}_fail.dmp",
-            FailFileName = $"{processInfo.LastVersion}_fail.json",
-            TargetPath = processInfo.InstallPath,
-            FailDirectory = Path.Combine(processInfo.InstallPath, "fail", processInfo.LastVersion),
-            BackupDirectory = Path.Combine(processInfo.InstallPath, processInfo.LastVersion),
+            ProcessNameOrId = "JsonTest.exe",
+            DumpFileName = $"{lastVersion}_fail.dmp",
+            FailFileName = $"{lastVersion}_fail.json",
+            TargetPath = installPath,
+            FailDirectory = Path.Combine(installPath, "fail", lastVersion),
+            BackupDirectory = Path.Combine(installPath, lastVersion),
             WorkModel = "Normal"
         };
+        Bowl.Launch(processInfo);
+        Console.Read();
     }
 }