using System.Reflection;
using GB5Shared.GOP.Qualifier;
using Dapr;
using GB5Shared.DaprCache;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.EntityHandler;
using GB5Shared.ExcelExport;
using GB5Shared.Export;
using GB5Shared.Export.CSVExport;
using GB5Shared.Export.HybridReport;
using GB5Shared.Export.Pivot;
using GB5Shared.GB5Library.Qualifier;
using GB5Shared.GenerateAutoNumber;
using GB5Shared.Hosting;
using GB5Shared.ListQuery;
using GB5Shared.ScanIdentifier;
using GB5Shared.PubSub.OutBox;
using GB5Shared.WorkFlow.WorkFlowEngine;
using GB5Shared.WorkFlow.WorkFlowRunTime;
using Microsoft.AspNetCore.ResponseCompression;
using MMDAL.DTO.Scheduling;
using MMSL.Hubs;
using MMSL.Services;
using Newtonsoft.Json;

namespace MMSL;

public class MMModule : IModule
{
    public void Register(IServiceCollection services, IConfiguration configuration)
    {
        services.AddHttpContextAccessor();
        services.AddHttpClient();

        services.AddScoped<LoginDTO>(sp =>
        {
            var httpContext = sp.GetRequiredService<IHttpContextAccessor>().HttpContext;
            if (httpContext != null &&
                httpContext.Request.Headers.TryGetValue("Login", out var loginHeader))
                return JsonConvert.DeserializeObject<LoginDTO>(loginHeader!)!;
            return new LoginDTO();
        });

        services.AddScoped<VoucherNumberService>();
        services.AddScoped<DocumentNumberService>();
        services.AddScoped<KeyInvalidate>();
        services.AddScoped(typeof(BaseEntityAppService<>), typeof(BaseEntityAppService<>));
        services.AddScoped<IExcelExport, ExcelExport>();
        services.AddScoped<CodeGeneration>();
        services.AddScoped<ICSVExport, CSVExport>();
        services.AddScoped<PdfRenderer>();
        services.AddScoped<IDataPivotEngine, DataPivotEngine>();
        services.AddScoped<IPivotExcelExport, PivotExcelExport>();
        services.AddScoped<IPivotPdfExport, PivotPdfExport>();
        services.AddScoped<IReportExport, ReportExport>();
        services.AddScoped<GB5Shared.Export.NativePdf.INativePdfExport, GB5Shared.Export.NativePdf.NativePdfExport>();
        services.AddScoped<IOutBox, OutBox>();
        services.AddScoped<IWorkFlowRunTime, WorkFlowRunTime>();
        services.AddScoped<IUserDelegationResolver, UserDelegationResolver>();
        services.AddScoped<IWorkFlowEngine, WorkFlowEngine>();
        services.AddScoped<IQualifierFacade, QualifierFacade>();
        services.AddGB5QualifierEngine();
        services.AddScoped<GB5Shared.Draft.IDraftRowBLL, GB5Shared.Draft.DraftRowBLL>();
        services.AddScoped<GB5Shared.Draft.IDraftRowDAL, GB5Shared.Draft.DraftRowDAL>();

        // Generic Scan-Identifier & Label Platform (GB5Shared/ScanIdentifier) — the dispatcher
        // only; MM's own IScanTargetResolver implementations (IndentDetailResolver) are picked up
        // by the broader MMBLL/MMDAL assembly Scan() below already, so passing an assembly here
        // would double-register them (same gotcha found/fixed in WiModule.Register()).
        services.AddScanTargetResolvers();
        services.AddScoped<IScanIdentifierEngine, ScanIdentifierEngine>();
        services.AddSignalR(options =>
        {
            options.EnableDetailedErrors    = true;
            options.MaximumReceiveMessageSize = 32 * 1024;
            options.ClientTimeoutInterval   = TimeSpan.FromSeconds(60);
            options.KeepAliveInterval       = TimeSpan.FromSeconds(15);
        });

        services.AddSingleton<MRPRunProcessingService>();
        services.AddSingleton<SchedulingRunProcessingService>();
        services.AddHostedService<MMJobQueueProcessor>();

        services.AddResponseCompression(o =>
        {
            o.EnableForHttps = true;
            o.Providers.Add<GzipCompressionProvider>();
        });

        var mmBLLAssembly    = Assembly.Load("MMBLL");
        var mmDALAssembly    = Assembly.Load("MMDAL");
        var adminBLLAssembly = Assembly.Load("AdminBLL");
        var adminDALAssembly = Assembly.Load("AdminDAL");

        services.Scan(scan => scan
            .FromAssemblies(mmBLLAssembly, mmDALAssembly, adminBLLAssembly, adminDALAssembly)
            .AddClasses(c => c.Where(t =>
                !t.IsAbstract &&
                !t.IsInterface &&
                t.Namespace != null &&
                !t.Namespace.Contains(".DTO") &&
                !typeof(Exception).IsAssignableFrom(t) &&
                t.GetMethod("<Clone>$") == null))
            .AsImplementedInterfaces()
            .WithScopedLifetime());

        services.AddListInfrastructure(mmDALAssembly);
    }

    public void MapEndpoints(WebApplication app)
    {
        app.MapHub<MRPRunHub>("/hubs/mrprun");
        app.MapHub<SchedulingRunHub>("/hubs/schedulingrun");
        app.MapHub<OperatorConsoleHub>("/hubs/operatorconsole");

        app.MapPost("/scheduling/trigger",
            [Topic("pubsub", "schedulingrun.trigger")]
            async (SchedulingRunTriggerDTO dto, SchedulingRunProcessingService svc, CancellationToken ct)
                => await svc.ProcessAsync(dto, ct));
    }
}