using Microsoft.Extensions.DependencyInjection;
using Pole.Core;
using Pole.Core.Channels;
using Pole.Core.EventBus;
using Pole.Core.Processor;
using Pole.Core.Processor.Server;
using Pole.Core.Serialization;
using Pole.Core.UnitOfWork;
using Pole.Core.Utils;
using Pole.Core.Utils.Abstraction;
using System;
using System.Collections.Generic;
using System.Text;

namespace Microsoft.Extensions.DependencyInjection
{
    public static class PoleServiceCollectionExtensions
    {
        public static IServiceCollection AddPole(this IServiceCollection services, Action<StartupConfig> config)
        {
            StartupConfig startupOption = new StartupConfig(services);
            if (startupOption.PoleOptionsConfig == null)
            {
                services.Configure<PoleOptions>(option => { });
            }
            services.AddSingleton<IEventTypeFinder, EventTypeFinder>();
            services.AddTransient(typeof(IMpscChannel<>), typeof(MpscChannel<>));
            services.AddScoped<IBus, Bus>();
            services.AddScoped<IUnitOfWork, Pole.Core.UnitOfWork.UnitOfWork>();
            services.AddSingleton<ISerializer, DefaultJsonSerializer>();
            services.AddSingleton<IGeneratorIdSolver, InstanceIPV4_16IdGeneratorIdSolver>();
            services.AddSingleton<IObserverUnitContainer, ObserverUnitContainer>();
            using (var serviceProvider = services.BuildServiceProvider())
            {
                var generatorIdSolver = serviceProvider.GetService<IGeneratorIdSolver>();
                services.AddSingleton(typeof(ISnowflakeIdGenerator), factory => new SnowflakeIdGenerator(new DateTime(2020, 1, 1), 16, generatorIdSolver.GetGeneratorId()));
            }

            services.AddSingleton<IProcessor, PendingMessageRetryProcessor>();
            services.AddSingleton<IProcessor, ExpiredEventsCollectorProcessor>();
            services.AddHostedService<BackgroundServiceBasedProcessorServer>();

            config(startupOption);
            return services;
        }
    }
}