Wire up hubservice status reporting back to UI

Author: webprofusion-chrisc

src/Certify.Server/Certify.Server.Hub.Api/SignalR/UserInterfaceStatusHub.cs

@@ -12,6 +12,16 @@ public class UserInterfaceStatusHubReporting : IStatusReporting
     {
         private IHubContext<UserInterfaceStatusHub> _hubContext;
 
+        /// <summary>
+        /// Event raised when a progress update is available
+        /// </summary>
+        public event Action<RequestProgressState>? OnRequestProgressStateUpdated;
+
+        /// <summary>
+        /// Event raised when a managed certificate has been updated
+        /// </summary>
+        public event Action<ManagedCertificate>? OnManagedCertificateUpdated;
+
         /// <summary>
         /// constructor
         /// </summary>
@@ -29,6 +39,11 @@ public UserInterfaceStatusHubReporting(IHubContext<UserInterfaceStatusHub> hubCo
         public async Task ReportRequestProgress(RequestProgressState state)
         {
             Debug.WriteLine($"Sending progress update message to UI: {state.Message}");
+            if (OnRequestProgressStateUpdated != null)
+            {
+                OnRequestProgressStateUpdated.Invoke(state);
+            }
+
             await _hubContext.Clients.All.SendAsync(StatusHubMessages.SendProgressStateMsg, state);
 
         }
@@ -41,6 +56,12 @@ public async Task ReportRequestProgress(RequestProgressState state)
         public async Task ReportManagedCertificateUpdated(ManagedCertificate item)
         {
             Debug.WriteLine($"Sending updated managed cert message to UI: {item.Name}");
+
+            if (OnManagedCertificateUpdated != null)
+            {
+                OnManagedCertificateUpdated.Invoke(item);
+            }
+
             await _hubContext.Clients.All.SendAsync(StatusHubMessages.SendManagedCertificateUpdateMsg, item);
         }
     }

src/Certify.Server/Certify.Server.HubService/Program.cs

@@ -1,4 +1,4 @@
-using Certify.Client;
+using Certify.Client;
 using Certify.Management;
 using Certify.Models;
 using Certify.Server.Hub.Api.Middleware;
@@ -132,10 +132,26 @@
 var statusReporting = new UserInterfaceStatusHubReporting(statusHubContext);
 
 // wire up internal service to our hub
+var managementServerClient = app.Services.GetService<DirectManagementServerClient>();
 
 var certifyManager = app.Services.GetRequiredService<ICertifyManager>();
 await certifyManager.Init();
 
+// wire up status reporting, include management hub cached state ahndlers for request progress state updates and item updates
+certifyManager.SetStatusReporting(statusReporting);
+
+statusReporting.OnRequestProgressStateUpdated += (RequestProgressState state) =>
+{
+
+};
+
+statusReporting.OnManagedCertificateUpdated += (ManagedCertificate item) =>
+{
+    var mgmtHubState = app.Services.GetRequiredService<IInstanceManagementStateProvider>();
+    mgmtHubState.UpdateCachedManagedInstanceItem(item.InstanceId, item);
+
+};
+
 var directServerClient = app.Services.GetRequiredService<IManagementServerClient>();
 certifyManager.SetDirectManagementClient(directServerClient);
 

src/Certify.Server/Certify.Server.HubService/Services/DirectManagementServerClient.cs

@@ -47,7 +47,18 @@ void IManagementServerClient.SendInstanceInfo(Guid commandId, bool isCommandResp
         }
         void IManagementServerClient.SendNotificationToManagementHub(string msgCommandType, object updateMsg)
         {
-            System.Diagnostics.Debug.WriteLine("SendInstanceInfo");
+            var result = new InstanceCommandResult
+            {
+                CommandId = Guid.NewGuid(),
+                InstanceId = _instanceInfo.InstanceId,
+                CommandType = msgCommandType,
+                Value = System.Text.Json.JsonSerializer.Serialize(updateMsg),
+                ObjectValue = updateMsg,
+                IsCommandResponse = false
+            };
+
+            result.ObjectValue = updateMsg;
+            _managementHub.ReceiveCommandResult(result);
 
         }
     }