YD_TrainingCompetition_Api/Services/SignalRRealtimeNotifier.cs

using Microsoft.AspNetCore.SignalR;
using YD_TrainingCompetition_Api.Competition;
using YD_TrainingCompetition_Api.Hubs;
using YD_TrainingCompetition_Api.Models;

namespace YD_TrainingCompetition_Api.Services;

public sealed class SignalRRealtimeNotifier : IRealtimeNotifier
{
    private readonly IHubContext<ScoringHub> _hubContext;

    public SignalRRealtimeNotifier(IHubContext<ScoringHub> hubContext)
    {
        _hubContext = hubContext;
    }

    public Task BroadcastTelemetryAsync(DeviceSnapshot snapshot, CancellationToken cancellationToken = default)
    {
        return _hubContext.Clients.All.SendAsync("telemetry-updated", snapshot, cancellationToken);
    }

    public Task BroadcastCompetitionStateAsync(CompetitionSessionState state, CancellationToken cancellationToken = default)
    {
        return _hubContext.Clients.All.SendAsync("competition-state", state, cancellationToken);
    }

    public Task SendAsync(string method, object? payload, CancellationToken cancellationToken = default)
    {
        return _hubContext.Clients.All.SendAsync(method, payload ?? new { }, cancellationToken);
    }

    public Task BroadcastHikvisionAlarmAsync(AlarmRecord record, CancellationToken cancellationToken = default)
    {
        return _hubContext.Clients.All.SendAsync("HikvisionAlarmReceived", record, cancellationToken);
    }

    public Task BroadcastHikvisionCameraStatusAsync(HikvisionCameraStatus status, CancellationToken cancellationToken = default)
    {
        return _hubContext.Clients.All.SendAsync("HikvisionCameraStatusChanged", status, cancellationToken);
    }
}