Support assistant sending over vmix config

Author: NixFey

Controllers/AssistantController.cs

@@ -35,4 +35,19 @@ public async Task<Results<Ok, NotFound>> PushStreamKeys([FromRoute] Guid cartId,
         await assistantService.PushStreamKeys(cart);
         return TypedResults.Ok();
     }
+    
+    [HttpGet("VmixConfig/{cartId:guid:required}")]
+    public async Task<Results<Ok<string>, NoContent>> GetVmixConfig([FromRoute] Guid cartId)
+    {
+        try
+        {
+            var resp = await assistantService.GetVmixConfig(cartId);
+            if (resp is null) return TypedResults.NoContent();
+            return TypedResults.Ok(resp);
+        }
+        catch (OperationCanceledException)
+        {
+            return TypedResults.NoContent();
+        }
+    }
 }

Hubs/AssistantHub.cs

@@ -14,9 +14,12 @@ public class AssistantHub(FimDbContext dbContext, FimRepository repository, Assi
 {
     private Guid CartId => Guid.Parse(Context.User?.FindFirst(ClaimTypes.CartId)?.Value ??
                                       throw new ApplicationException("No cart id"));
+
+    public static Dictionary<Guid, string> CartConnectionMap { get; set; } = new();
 
     public override async Task OnConnectedAsync()
     {
+        CartConnectionMap[CartId] = Context.ConnectionId;
         var log = new EquipmentLog
         {
             EquipmentId = CartId,
@@ -33,6 +36,9 @@ public override async Task OnConnectedAsync()
 
     public override async Task OnDisconnectedAsync(Exception? exception)
     {
+        if (CartConnectionMap.TryGetValue(CartId, out var mappedConn) && mappedConn == Context.ConnectionId)
+            CartConnectionMap.Remove(CartId);
+        
         var log = new EquipmentLog
         {
             EquipmentId = CartId,

Services/AssistantService.cs

@@ -1,8 +1,6 @@
 using fim_queueing_admin.Data;
 using fim_queueing_admin.Hubs;
 using fim_queueing_admin.Models;
-using Firebase.Database;
-using Firebase.Database.Query;
 using Microsoft.AspNetCore.SignalR;
 using Microsoft.EntityFrameworkCore;
 
@@ -73,4 +71,12 @@ public async Task PushStreamKeys(Cart cart, IClientProxy? clients = null)
             i.RtmpKey
         }).ToList());
     }
+
+    public async Task<string?> GetVmixConfig(Guid cartId)
+    {
+        if (!AssistantHub.CartConnectionMap.TryGetValue(cartId, out var connId)) return null;
+
+        var cancelSource = new CancellationTokenSource(TimeSpan.FromSeconds(15));
+        return await hubContext.Clients.Client(connId).InvokeAsync<string>("GetVmixConfig", cancelSource.Token);
+    }
 }