Live Updates (SignalR)

import { HubConnectionBuilder } from "@microsoft/signalr";

const connection = new HubConnectionBuilder()
  .withUrl("http://localhost:5100/hubs/loft", {
    accessTokenFactory: () => "YOUR_JWT_TOKEN"
  })
  .withAutomaticReconnect()
  .build();

// Listen for alerts
connection.on("AlertReceived", (alert) => {
  console.log("Alert:", alert.severity, alert.message);
});

// Listen for metric updates
connection.on("MetricUpdate", (metric) => {
  console.log("Metrics:", metric.interfaceId, metric.messagesTotal);
});

// Listen for status changes
connection.on("InterfaceStatusChanged", (status) => {
  console.log("Status:", status.interfaceId, status.newStatus);
});

// Connect and subscribe
await connection.start();
await connection.invoke("SubscribeToInterface", "intf-001");

// Or subscribe to all interfaces
await connection.invoke("SubscribeToAll");

var connection = new HubConnectionBuilder()
    .WithUrl("http://localhost:5100/hubs/loft", options =>
    {
        options.AccessTokenProvider = () => Task.FromResult("YOUR_JWT_TOKEN");
    })
    .WithAutomaticReconnect()
    .Build();

connection.On<AlertResponse>("AlertReceived", alert =>
{
    Console.WriteLine($"Alert: {alert.Severity} - {alert.Message}");
});

await connection.StartAsync();
await connection.InvokeAsync("SubscribeToAll");