using FastEndpoints;
using FrameworkBLL.SchedulerTaskGenerator;
using FrameworkDAL.CustomCode.SchedulerTaskGenerator;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.DTO.Framework.ResponseStandard;
using GB5Shared.FastEndPoint;
using System;
using System.Threading;
using System.Threading.Tasks;
using static GB5Shared.GB5Constant.Constant;

namespace FrameworkSL.Endpoints.SchedulerTaskGenerator
{
    /// <summary>
    /// Returns a full scheduler monitor view — all active jobs with:
    ///   - Latest execution status (Pending / Running / Success / Failed / DLQ)
    ///   - Next run countdown (computed in BLL)
    ///   - Action types (Mail, SMS, WebService, WhatsApp, etc.)
    ///   - Retry count and last error message
    ///   - Duration in milliseconds
    ///   - Summary counts by status
    ///
    /// GET /Scheduler/Monitor
    ///
    /// ✅ This endpoint ONLY calls ISchedulerMonitorBLL.GetMonitorAsync.
    ///    It never calls BLL internals (ComputeNextRun etc.) — CS0122 fixed.
    /// </summary>
    public sealed class GetSchedulerMonitorEndpoint
        : BaseEndpoint<
            GetSchedulerMonitorEndpoint.GetSchedulerMonitorParameters,
            ResponseStandardDTO<object>>
    {
        private readonly ISchedulerMonitorBLL _monitorBLL;
        private readonly ILoginContextProvider _loginProvider;

        public GetSchedulerMonitorEndpoint(
            ISchedulerMonitorBLL monitorBLL,
            ILoginContextProvider loginProvider)
        {
            _monitorBLL = monitorBLL ?? throw new ArgumentNullException(nameof(monitorBLL));
            _loginProvider = loginProvider ?? throw new ArgumentNullException(nameof(loginProvider));
        }

        public override void Configure()
        {
            Get("/Scheduler/Monitor");
            AllowAnonymous();
        }

        public sealed record GetSchedulerMonitorParameters(
            [property: FromHeader] string Login
        );

        protected override async Task<ResponseStandardDTO<object>> ExecuteAsync(
            GetSchedulerMonitorParameters req,
            LoginDTO loginDTO,
            CancellationToken ct)
        {
            try
            {
                // Fallback to ambient login context if header is absent or incomplete
                if (string.IsNullOrWhiteSpace(loginDTO?.DatabaseName))
                    loginDTO = _loginProvider.GetLogin();

                // ✅ All logic lives in BLL — SL just calls and returns
                var result = await _monitorBLL.GetMonitorAsync(loginDTO, ct)
                    .ConfigureAwait(false);

                return await GB5Shared.ResponseStandard.Response.CreateSuccessResponse(
                    result,
                    CacheKeyLevel.USER_LEVEL,
                    loginDTO
                );
            }
            catch (Exception ex)
            {
                return await GB5Shared.ResponseStandard.Response.CreateExceptionError<object>(
                    ex,
                    CacheKeyLevel.USER_LEVEL,
                    loginDTO,
                    ex.Message,
                    500
                );
            }
        }
    }
}