Refactor HubClient with factory pattern

Refactored the `HubClient` class to use a new `IHubConnectionFactory` interface for creating `HubConnection` instances, improving separation of concerns and testability. Updated `DependencyInjection.cs` to register `IHubConnectionFactory` and `HubClient` with the DI container. Introduced `IHubConnectionFactory` and its implementation `HubConnectionFactory` to handle connection creation logic, utilizing `NavigationManager` and `IHttpContextAccessor` for configuration.

Author: neozhu

src/Server.UI/DependencyInjection.cs

@@ -96,7 +96,8 @@ public static IServiceCollection AddServerUI(this IServiceCollection services, I
             c.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
         });
         services.AddScoped<LocalTimeOffset>();
-        services.AddScoped<HubClient>();
+        services.AddScoped<IHubConnectionFactory, HubConnectionFactory>()
+            .AddScoped<HubClient>();
         services
             .AddScoped<AuthenticationStateProvider, IdentityRevalidatingAuthenticationStateProvider>()
             .AddScoped<LayoutService>()

src/Server.UI/Hubs/HubClient.cs

@@ -9,29 +9,10 @@ public sealed class HubClient : IAsyncDisposable
 {
     private readonly HubConnection _hubConnection;
     private bool _started;
-    public HubClient(NavigationManager navigationManager, IHttpContextAccessor httpContextAccessor)
+    public HubClient(IHubConnectionFactory hubConnectionFactory)
     {
-        var uri = new UriBuilder(navigationManager.Uri);
-        var container = new CookieContainer();
-        if (httpContextAccessor.HttpContext != null)
-        {
-            foreach (var c in httpContextAccessor.HttpContext.Request.Cookies)
-            {
-                container.Add(new Cookie(c.Key, c.Value)
-                {
-                    Domain = uri.Host,
-                    Path = "/"
-                });
-            }
-        }
 
-        var hubUrl = navigationManager.BaseUri.TrimEnd('/') + ISignalRHub.Url;
-        _hubConnection = new HubConnectionBuilder()
-            .WithUrl(hubUrl, options =>
-            {
-                options.Transports = HttpTransportType.WebSockets;
-                options.Cookies = container;
-            }).WithAutomaticReconnect().Build();
+        _hubConnection = hubConnectionFactory.CreateForCurrentUser(ISignalRHub.Url);
 
         _hubConnection.ServerTimeout = TimeSpan.FromSeconds(20);
         _hubConnection.KeepAliveInterval = TimeSpan.FromSeconds(10);

src/Server.UI/Hubs/IHubConnectionFactory.cs

@@ -0,0 +1,51 @@
+using System.Net;
+using Microsoft.AspNetCore.Http.Connections;
+using Microsoft.AspNetCore.SignalR.Client;
+
+namespace CleanArchitecture.Blazor.Server.UI.Hubs;
+
+public interface IHubConnectionFactory
+{
+    HubConnection CreateForCurrentUser(string relativeHubUrl);
+}
+public class HubConnectionFactory : IHubConnectionFactory
+{
+    private readonly NavigationManager _navigationManager;
+    private readonly IHttpContextAccessor _httpContextAccessor;
+
+    public HubConnectionFactory(
+        NavigationManager navigationManager,
+        IHttpContextAccessor httpContextAccessor)
+    {
+        _navigationManager = navigationManager;
+        _httpContextAccessor = httpContextAccessor;
+    }
+
+    public HubConnection CreateForCurrentUser(string relativeHubUrl)
+    {
+        var uri = new UriBuilder(_navigationManager.Uri);
+        var container = new CookieContainer();
+
+        var httpContext = _httpContextAccessor.HttpContext;
+        if (httpContext != null &&
+            httpContext.Request.Cookies.TryGetValue(".AspNetCore.Identity.Application", out var authCookie))
+        {
+            container.Add(new Cookie(".AspNetCore.Identity.Application", authCookie)
+            {
+                Domain = uri.Host,
+                Path = "/"
+            });
+        }
+
+        var hubUrl = _navigationManager.BaseUri.TrimEnd('/') + relativeHubUrl;
+
+        return new HubConnectionBuilder()
+            .WithUrl(hubUrl, options =>
+            {
+                options.Transports = HttpTransportType.WebSockets;
+                options.Cookies = container;
+            })
+            .WithAutomaticReconnect()
+            .Build();
+    }
+}