using DevExpress.ExpressApp.Blazor.Services;
using Microsoft.AspNetCore.Connections;
using Microsoft.AspNetCore.SignalR;
using Microsoft.Extensions.Options;

namespace DurnyklyYol.Blazor.Server.Services;

internal class ProxyHubConnectionHandler<THub> : HubConnectionHandler<THub> where THub : Hub {
    private readonly IValueManagerStorageContainerInitializer storageContainerInitializer;
    public ProxyHubConnectionHandler(
        HubLifetimeManager<THub> lifetimeManager,
        IHubProtocolResolver protocolResolver,
        IOptions<HubOptions> globalHubOptions,
        IOptions<HubOptions<THub>> hubOptions,
        ILoggerFactory loggerFactory,
        IUserIdProvider userIdProvider,
        IServiceScopeFactory serviceScopeFactory,
        IValueManagerStorageContainerInitializer storageContainerAccessor)
        : base(lifetimeManager, protocolResolver, globalHubOptions, hubOptions, loggerFactory, userIdProvider, serviceScopeFactory) {
        this.storageContainerInitializer = storageContainerAccessor;
    }

    public override Task OnConnectedAsync(ConnectionContext connection) {
        storageContainerInitializer.Initialize();
        return base.OnConnectedAsync(connection);
    }
}