using Dpz.Core.Backup;
using Dpz.Core.Infrastructure;
using Dpz.Core.MessageQueue.Extensions;
using Dpz.Core.Public.ViewModel.Messages;
using Dpz.Core.Service.Mcp;
using Dpz.Core.Service.Network;
using Dpz.Core.Service.ObjectStorage;
using Dpz.Core.Service.RepositoryService;
using Dpz.Core.Service.RepositoryServiceImpl;
using Dpz.Core.Web.Jobs.Hangfire;
using Dpz.Core.Web.Jobs.Hangfire.Build;
using Dpz.Core.Web.Jobs.MessageHandlers;
using Dpz.Core.Web.Jobs.Services;
using Dpz.Core.Web.Jobs.Services.FileTransfer;
using Dpz.Core.Web.Jobs.Services.Implements;

namespace Dpz.Core.Web.Jobs;

/// <summary>
/// Web.Jobs 宿主的服务注册扩展方法。
/// </summary>
public static class RegisterDependencyInjectionExtensions
{
    /// <summary>
    /// 注册 Web.Jobs 运行所需的默认业务服务。
    /// </summary>
    /// <param name="services">服务集合。</param>
    /// <returns>注册后的服务集合。</returns>
    public static IServiceCollection AddDefaultInjectServices(this IServiceCollection services)
    {
        services.AddSingleton<IPushMessage, PushMessage>();
        // 文件传输：房间存储（单例，内存存储）
        services.AddSingleton<IFileTransferRoomStore, FileTransferRoomStore>();
        services.AddSingleton<IFileTransferSessionService, FileTransferSessionService>();
        // 文件传输：过期房间后台清理
        services.AddHostedService<FileTransferRoomCleanupService>();
        services.AddScoped<IBackupRecordService, BackupRecordService>();

        services
            .AddHttpClient(
                "edge",
                (_, httpClient) =>
                {
                    httpClient.DefaultRequestHeaders.Add("User-Agent", EnvironmentInfo.UserAgent);
                    httpClient.Timeout = TimeSpan.FromMinutes(5);
                }
            )
            .ConfigurePrimaryHttpMessageHandler(_ => new HttpClientHandler
            {
                ServerCertificateCustomValidationCallback = (_, _, _, _) => true,
                MaxConnectionsPerServer = 10,
            });

        // 音乐同步下载的大文件耗时较长，使用独立的超时和连接策略
        services
            .AddHttpClient(
                MusicSyncActivator.HttpClientName,
                (_, httpClient) =>
                {
                    httpClient.DefaultRequestHeaders.Add("User-Agent", EnvironmentInfo.UserAgent);
                    httpClient.Timeout = TimeSpan.FromMinutes(30);
                }
            )
            .ConfigurePrimaryHttpMessageHandler(_ => new SocketsHttpHandler
            {
                ConnectTimeout = TimeSpan.FromSeconds(30),
                PooledConnectionLifetime = TimeSpan.FromMinutes(10),
                MaxConnectionsPerServer = 4,
            });

        services.AddNetworkServices();
        services.AddInProcessCodeMcp();
        services.AddS3ObjectStorage();
        services.AddBackupRestoreService();

        // 注册邮件发送辅助服务
        services.AddScoped<EmailSenderHelper>();

        // 获取ssh配置和校验服务
        services.AddScoped<SshConfigurationService>();
        services.AddHttpClient(
            PipelineVersionProbe.HttpClientName,
            (_, httpClient) =>
            {
                httpClient.Timeout = TimeSpan.FromSeconds(5);
                httpClient.DefaultRequestHeaders.Add("User-Agent", EnvironmentInfo.UserAgent);
            }
        );
        services.AddScoped<PipelineVersionProbe>();
        return services;
    }

    /// <summary>
    /// 注册 Web.Jobs 需要消费的消息队列处理器和 Outbox 后台补发服务
    /// </summary>
    /// <param name="services">服务集合。</param>
    /// <returns>注册后的服务集合。</returns>
    public static IServiceCollection AddMessageQueueServices(this IServiceCollection services)
    {
        // 注册消息消费者
        services.AddMessageConsumer<DeleteMarkdownMessage, DeleteMarkdownHandler>();
        services.AddMessageConsumer<RemoveImagesMessage, RemoveImagesHandler>();
        services.AddMessageConsumer<AddCommentCountMessage, AddCommentCountHandler>();
        services.AddMessageConsumer<AddDanmakuCountMessage, AddDanmakuCountHandler>();
        services.AddMessageConsumer<AnalyzeCodeMessage, AnalyzeCodeHandler>();
        services.AddMessageConsumer<SendMasterEmailMessage, SendMasterEmailHandler>();
        services.AddMessageConsumer<SendReplyEmailMessage, SendReplyEmailHandler>();
        services.AddMessageConsumer<SendEmailVerifyCodeMessage, SendEmailVerifyCodeHandler>();
        services.AddMessageConsumer<GetImageMetadataMessage, GetImageMetadataHandler>();
        services.AddMessageOutboxRetryWorker();

        return services;
    }
}