using FastEndpoints; using GB5Shared.DTO.Framework.Login; using GB5Shared.DTO.Framework.ResponseStandard; using GB5Shared.FastEndPoint; using MMBLL.MRPRun; using static GB5Shared.GB5Constant.Constant; namespace MMSL.EndPoints.MRPRun { // Poll endpoint for clients that don't use SignalR — returns the latest run status. public class GetMRPRunStatus : BaseEndpoint> { private readonly IMRPRunBLL _MRPRunBLL; public GetMRPRunStatus(IMRPRunBLL mrpRunBLL) => _MRPRunBLL = mrpRunBLL; public override void Configure() { Get("/MRPRun/GetMRPRunStatus"); AllowAnonymous(); } public record Params( [property: FromHeader] string Login, [property: QueryParam] int MRPRunId ); protected override string? GetCacheKey(Params req, LoginDTO login) => null; protected override async Task> ExecuteAsync(Params req, LoginDTO loginDTO, CancellationToken ct) { try { var status = await _MRPRunBLL.GetMRPRunStatus(req.MRPRunId, loginDTO, ct); return await GB5Shared.ResponseStandard.Response.CreateSuccessResponse( status, CacheKeyLevel.NOT_REQUIRED, loginDTO); } catch (Exception ex) { return await GB5Shared.ResponseStandard.Response.CreateExceptionError( ex, CacheKeyLevel.NOT_REQUIRED, loginDTO, ex.Message, 500); } } } }