using Dpz.Core.Infrastructure;
using Microsoft.AspNetCore.SignalR.Client;

namespace Dpz.Core.Web.Jobs;

public static class WebExtensions
{
    public static async Task PushLogMessageAsync(this HubConnection? connection, int level, string message)
    {
        if (connection == null || connection.State != HubConnectionState.Connected) return;

        await connection.InvokeCoreAsync("PushLogMessage", new object[] { level, message });
    }

    public static async Task PushCnBetaMessageAsync(this HubConnection? connection, ProgressMessage message)
    {
        if (connection == null || connection.State != HubConnectionState.Connected) return;
        
        await connection.InvokeCoreAsync("PushCnBetaMessage", new object[] { message });
    }
}