Mgmt Hub: perform commands directly if in-process instance present

Author: webprofusion-chrisc

src/Certify.Server/Certify.Server.Hub.Api/Services/ManagementAPI.cs

@@ -1,4 +1,4 @@
-using System.Text.Json;
+using System.Text.Json;
 using Certify.Client;
 using Certify.Models;
 using Certify.Models.Config;
@@ -17,19 +17,25 @@ public partial class ManagementAPI
     {
         IInstanceManagementStateProvider _mgmtStateProvider;
         IHubContext<InstanceManagementHub, IInstanceManagementHub> _mgmtHubContext;
-        ICertifyInternalApiClient _backendAPIClient;
+        Certify.Management.ICertifyManager _certifyManager;
 
         /// <summary>
         /// Constructor for Management Hub API
         /// </summary>
         /// <param name="mgmtStateProvider"></param>
         /// <param name="mgmtHubContext"></param>
         /// <param name="backendAPIClient"></param>
-        public ManagementAPI(IInstanceManagementStateProvider mgmtStateProvider, IHubContext<InstanceManagementHub, IInstanceManagementHub> mgmtHubContext, ICertifyInternalApiClient backendAPIClient)
+        public ManagementAPI(IInstanceManagementStateProvider mgmtStateProvider, IHubContext<InstanceManagementHub, IInstanceManagementHub> mgmtHubContext)
         {
             _mgmtStateProvider = mgmtStateProvider;
             _mgmtHubContext = mgmtHubContext;
-            _backendAPIClient = backendAPIClient;
+        }
+
+        public ManagementAPI(IInstanceManagementStateProvider mgmtStateProvider, IHubContext<InstanceManagementHub, IInstanceManagementHub> mgmtHubContext, Certify.Management.ICertifyManager certifyManager)
+        {
+            _mgmtStateProvider = mgmtStateProvider;
+            _mgmtHubContext = mgmtHubContext;
+            _certifyManager = certifyManager;
         }
 
         private async Task<InstanceCommandResult?> GetCommandResult(string instanceId, InstanceCommandRequest cmd)
@@ -64,9 +70,20 @@ private async Task SendCommandWithNoResult(string instanceId, InstanceCommandReq
 
         private async Task<T?> PerformInstanceCommandTaskWithResult<T>(string instanceId, KeyValuePair<string, string>[] args, string commandType)
         {
+            InstanceCommandResult result;
             var cmd = new InstanceCommandRequest(commandType, args);
 
             var result = await GetCommandResult(instanceId, cmd);
+            if (_certifyManager != null && instanceId == _mgmtStateProvider.GetManagementHubInstanceId())
+            {
+                // get command result directly from in-process instance
+                result = await _certifyManager.PerformDirectHubCommandWithResult(cmd);
+            }
+            else
+            {
+                // get command result via SignalR
+                result = await GetCommandResult(instanceId, cmd);
+            }
 
             if (result?.Value != null)
             {