using System.Reflection;
using GB5Shared.DaprCache;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.Export;
using GB5Shared.Hosting;
using GB5Shared.PubSub.OutBox;
using JobEngineBLL.Interfaces;
using JobEngineSL.Hubs;
using JobEngineSL.Services;
using Newtonsoft.Json;
using Quartz;

namespace JobEngineSL;

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

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

        services.AddHttpClient("jobengine", c => c.Timeout = TimeSpan.FromMinutes(5));

        services.AddScoped<GB5Shared.Export.CSVExport.ICSVExport, GB5Shared.Export.CSVExport.CSVExport>();
        services.AddScoped<GB5Shared.Export.HybridReport.PdfRenderer>();
        services.AddScoped<GB5Shared.Export.Pivot.IDataPivotEngine, GB5Shared.Export.Pivot.DataPivotEngine>();
        services.AddScoped<GB5Shared.Export.Pivot.IPivotExcelExport, GB5Shared.Export.Pivot.PivotExcelExport>();
        services.AddScoped<GB5Shared.Export.Pivot.IPivotPdfExport, GB5Shared.Export.Pivot.PivotPdfExport>();
        services.AddScoped<IReportExport, ReportExport>();
        services.AddScoped<GB5Shared.CriteriaConfig.ICriteriaConfigFastSave, GB5Shared.CriteriaConfig.CriteriaConfigFastSave>();
        services.AddScoped<GB5Shared.Export.NativePdf.INativePdfExport, GB5Shared.Export.NativePdf.NativePdfExport>();
        services.AddScoped<IOutBox, OutBox>();

        services.AddSignalR(options =>
        {
            options.EnableDetailedErrors = true;
            options.MaximumReceiveMessageSize = 32 * 1024;
            options.ClientTimeoutInterval = TimeSpan.FromSeconds(60);
            options.KeepAliveInterval = TimeSpan.FromSeconds(15);
        });

        var quartzConnStr = configuration.GetConnectionString("QuartzStore")
            ?? throw new InvalidOperationException("ConnectionStrings:QuartzStore is required");

        services.AddQuartz(q =>
        {
            q.UseSimpleTypeLoader();
            q.UseDefaultThreadPool(tp => tp.MaxConcurrency = 20);
            q.UsePersistentStore(s =>
            {
                s.UseProperties = true;
                s.RetryInterval = TimeSpan.FromSeconds(15);
                s.UseSqlServer(quartzConnStr);
                s.UseJsonSerializer();
                s.UseClustering();
            });
        });
        services.AddQuartzHostedService(opt => opt.WaitForJobsToComplete = true);

        services.AddSingleton<QuartzSyncService>();
        services.AddSingleton<IQuartzSyncService>(sp => sp.GetRequiredService<QuartzSyncService>());
        services.AddHostedService<OutBoxPollerService>();
        services.AddHostedService<JobEngineStartupService>();

        var bll = Assembly.Load("JobEngineBLL");
        var dal = Assembly.Load("JobEngineDAL");
        services.Scan(scan => scan
            .FromAssemblies(bll, dal)
            .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());
    }

    public void MapEndpoints(WebApplication app)
    {
        app.MapHub<JobEngineHub>("/hubs/jobengine");
    }
}