namespace Dpz.Core.Web.Library.Hub;

public class BarrageHub(IBarrageService barrageService) : Microsoft.AspNetCore.SignalR.Hub
{
    public async Task Send(VmBarrage? barrage)
    {
        if (string.IsNullOrEmpty(barrage?.Text))
        {
            return;
        }

        await Clients.All.SendCoreAsync("ReceiveMessage", [barrage]);
        barrage.SendTime = DateTime.Now;
        await barrageService.AddBarrageAsync(barrage);
    }
}