using AyCode.Core.Loggers;
using Microsoft.AspNetCore.SignalR;
using System.ServiceModel.Channels;
using AyCode.Services.Server.SignalRs;
using AyCode.Services.SignalRs;
using TIAM.Database.DataLayers.Admins;

namespace TIAMWebApp.Server.Services;

public class DevAdminSignalRHub(AdminDal adminDal, IEnumerable<IAcLogWriterBase> logWriters) : Hub<ISignalRHubServer>, ISignalRHubServer
{
    private TIAM.Core.Loggers.Logger<DevAdminSignalRHub> _logger = new(logWriters.ToArray());

    // https://docs.microsoft.com/en-us/aspnet/core/signalr/hubs?view=aspnetcore-3.1#strongly-typed-hubs
    public override async Task OnConnectedAsync()
    {
        //await Groups.AddToGroupAsync(Context.ConnectionId, "SignalR Users");
        await base.OnConnectedAsync();
    }

    public override async Task OnDisconnectedAsync(Exception exception)
    {
        _logger.Error($"OnDisconnectedAsync", exception);

        //await Groups.RemoveFromGroupAsync(Context.ConnectionId, "SignalR Users");
        await base.OnDisconnectedAsync(exception);
    }

    public async Task SendMessageToGroup(string groupId, int messageTag, string message)
    {
        //await Clients.Group(groupId).Post("", messageTag, message);
    }

    public async Task Get(string user, int messageTag)
    {
        _logger.Info($"{nameof(user)}: {user}; {nameof(messageTag)}: {messageTag}");

        if (messageTag == SignalRTags.GetTransfersAsync)
            await Post("", SignalRTags.PostTransfersAsync, await adminDal.GetTransfersJsonAsync());
    }

    public async Task Post(string user, int messageTag, object? message)
    {
        _logger.Info($"{nameof(user)}: {user}; {nameof(messageTag)}: {messageTag}");

        await Clients.Caller.Post("", messageTag, message);
    }
}