using AyCode.Core.Extensions;
using AyCode.Core.Loggers;
using AyCode.Core.Serializers.Binaries;
using AyCode.Core.Serializers.Jsons;
using AyCode.Models.Server.DynamicMethods;
using AyCode.Services.SignalRs;
using FruitBank.Common.Interfaces;
using FruitBank.Common.Loggers;
using FruitBank.Common.Server.Interfaces;
using FruitBank.Common.SignalRs;
using Mango.Nop.Core.Loggers;
using Microsoft.Extensions.Configuration;

namespace FruitBank.Common.Server.Services.SignalRs;

//public class DevAdminSignalRHub : AcWebSignalRHubWithSessionBase<SignalRTags, Logger<DevAdminSignalRHub>>
//{
//    public DevAdminSignalRHub(IConfiguration configuration, IEnumerable<IAcLogWriterBase> logWriters) 
//        : base(configuration, new Logger<DevAdminSignalRHub>(logWriters.ToArray()))
//    {
//        Logger.Info("DevAdminSignalRHub");
//    }

//    public Task ReceiveMessage(int messageTag, byte[]? message, int? requestId)
//    {
        
//        Clients.All.SendAsync("TestMessage", "Hello from server");
//    }

//}

public class DevAdminSignalRHub : AcWebSignalRHubWithSessionBase<SignalRTags, Logger<DevAdminSignalRHub>>
{
    public DevAdminSignalRHub(IConfiguration configuration, IFruitBankDataControllerServer fruitBankDataController/*, SessionService sessionService*/, 
        ICustomOrderSignalREndpointServer customOrderSignalREndpoint, IStockSignalREndpointServer stockSignalREndpointServer, IEnumerable<IAcLogWriterBase> logWriters)
        : base(configuration, new Logger<DevAdminSignalRHub>(logWriters.ToArray()))
    {
        EnableBinaryDiagnostics = FruitBankConstClient.SignalRSerializerDiagnosticLog;
        SerializerOptions = new AcBinarySerializerOptions();
        //SerializerOptions = new AcJsonSerializerOptions();

        DynamicMethodCallModels.Add(new AcDynamicMethodCallModel<SignalRAttribute>(fruitBankDataController));
        DynamicMethodCallModels.Add(new AcDynamicMethodCallModel<SignalRAttribute>(customOrderSignalREndpoint));
        DynamicMethodCallModels.Add(new AcDynamicMethodCallModel<SignalRAttribute>(stockSignalREndpointServer));
    }

    protected override void LogContextUserNameAndId()
    {
        return;
        base.LogContextUserNameAndId();
    }
    //public override Task OnReceiveMessage(int messageTag, byte[]? message, int? requestId)
    //{
    //    return ProcessOnReceiveMessage(messageTag, message, requestId, async tagName =>
    //    {
    //        switch (messageTag)
    //        {
    //            case SignalRTags.GetAddress:
    //                //var id = Guid.Parse((string)message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0]);
    //                var id = message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0].JsonTo<Guid[]>()![0];

    //                var address = await _adminDal.GetAddressByIdAsync(id);
    //                await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, address), requestId);

    //                return;

    //            case SignalRTags.GetAddressesByContextId:
    //                //id = Guid.Parse((string)message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0]);
    //                id = message!.MessagePackTo<SignalPostJsonDataMessage<IdMessage>>().PostData.Ids[0].JsonTo<Guid[]>()![0];

    //                address = await _adminDal.GetAddressByIdAsync(id);
    //                await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, new List<Address> { address! }), requestId);

    //                return;

    //            case SignalRTags.UpdateAddress:
    //                address = message!.MessagePackTo<SignalPostJsonDataMessage<Address>>().PostData;

    //                await _adminDal.UpdateAddressAsync(address);
    //                await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, address), requestId);

    //                return;

    //            case SignalRTags.UpdateProfile:
    //                var profile = message!.MessagePackTo<SignalPostJsonDataMessage<Profile>>().PostData;

    //                await _adminDal.UpdateProfileAsync(profile);
    //                await ResponseToCaller(messageTag, new SignalResponseJsonMessage(messageTag, SignalResponseStatus.Success, profile), requestId);

    //                return;

    //            //case SignalRTags.GetTransfersAsync:
    //            //    await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await _transferDataApiController.GetTransfers()), requestId);

    //            //    return;

    //            //case SignalRTags.GetPropertiesByOwnerIdAsync:
    //            //    var ownerId = message!.MessagePackTo<SignalRequestByIdMessage>().Id;

    //            //    await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await _serviceProviderApiController.GetServiceProvidersByOwnerId(ownerId)), requestId);

    //            //    return;

    //            //case SignalRTags.UpdateTransferAsync:
    //            //    var transfer = message!.MessagePackTo<SignalPostJsonDataMessage<Transfer>>().PostData;

    //            //    await _transferDataApiController.UpdateTransfer(transfer);
    //            //    await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, transfer), requestId);

    //            //    return;

    //            //case SignalRTags.GetCompaniesAsync:
    //            //    await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await _serviceProviderApiController.GetServiceProviders()), requestId);

    //            //    return;
    //            //case SignalRTags.UpdateCompanyAsync:

    //            //    var updateCompany = message!.MessagePackTo<SignalPostJsonDataMessage<Company>>().PostData;

    //            //    await _serviceProviderApiController.UpdateServiceProvider(updateCompany);
    //            //    await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, updateCompany), requestId);

    //            //    return; 

    //            default:
    //                Logger.Error($"Server OnReceiveMessage; messageTag not found! {tagName}");
    //                break;
    //        }
    //    });
    //}
}