using System.Net.Http;
using Dpz.Core.Infrastructure.BotProtection;
using Dpz.Core.MessageQueue.Extensions;
using Dpz.Core.Public.ViewModel.Messages;
using Dpz.Core.Service.Network;
using Dpz.Core.Service.ObjectStorage;
using Dpz.Core.Shard.Implement.Service;
using Dpz.Core.Shard.Service;
using Dpz.Core.Web.EventHandlers;
using Dpz.Core.Web.Library.Api;
using Dpz.Core.Web.Library.Api.Service;

namespace Dpz.Core.Web.Library;

public static class DependencyInjectionExtensions
{
    public static IServiceCollection AddInject(this IServiceCollection services)
    {
        services.AddDpzAspNetCoreServices();
        services.AddShardCloudFileService();

        services.AddScoped<IHomeCacheService, HomeCacheService>();
        services.AddScoped<IApplicationSignInManager, ApplicationSignInManager>();
        services.AddScoped<
            IUserClaimsPrincipalFactory<VmUserInfo>,
            UserInfoClaimsPrincipalFactory
        >();
        services.AddHttpClient();

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

        services
            .AddHttpClient(
                "WebAPI",
                (sp, httpClient) =>
                {
                    var configuration = sp.GetService<IConfiguration>();
                    var apiAddress =
                        configuration?["WebApi"] ?? throw new Exception("web api address is null");
                    httpClient.BaseAddress = new Uri(apiAddress);
                }
            )
            .ConfigurePrimaryHttpMessageHandler(_ => new HttpClientHandler
            {
                ServerCertificateCustomValidationCallback = (_, _, _, _) => true,
            });

        //添加 腾讯云COS储存 S3兼容
        services.AddS3ObjectStorage();

        services.AddNetworkServices();

        services.AddScoped<IVideoShardService, VideoShardService>();
        services.AddScoped<ToolService>();
        services.AddScoped<MumbleViewHelper>();
        services.AddSingleton<AssetService>();

        // services.AddHostedService<AssetUploadHostedService>();
        services.AddHostedService<PageRouteCatalogScannerService>();

        // 机器人拦截：Web 面向现代浏览器，启用浏览器版本判定
        services.AddBotProtection(o => o.CheckBrowserVersion = true);
        return services;
    }

    /// <summary>
    /// 注册需要消费的消息队列处理器和 Outbox 后台补发服务。
    /// </summary>
    /// <param name="services">服务集合。</param>
    /// <returns>注册后的服务集合。</returns>
    public static IServiceCollection AddMessageQueueServices(this IServiceCollection services)
    {
        // 注册消息消费者
        // 注册消息消费者
        services.AddMessageConsumer<ClearCacheMessage, ClearCacheMessageHandler>();
        services.AddMessageConsumer<RefreshUserProfileMessage, RefreshUserProfileMessageHandler>();

        services.AddMessageOutboxRetryWorker();

        return services;
    }
}