using FastEndpoints; using FrameworkBLL.EIPConversation.EIPAdmin.EIPFlowAdmin; using GB5Shared.DTO.Framework.Login; using GB5Shared.DTO.Framework.ResponseStandard; using GB5Shared.FastEndPoint; using static GB5Shared.GB5Constant.Constant; namespace FrameworkSL.Endpoints.EIPAdmin { public class GetEIPFlow : BaseEndpoint> { private readonly IEIPFlowAdminBLL _bll; public GetEIPFlow(IEIPFlowAdminBLL bll) => _bll = bll; public override void Configure() { Get("/EIPAdmin/GetFlow"); AllowAnonymous(); Description(b => b.WithTags("EIPAdmin")); } protected override string? GetCacheKey(Parameters req, LoginDTO login) => $"EIPFlow:{login.ClientId}:{req.FlowDefinitionId}"; protected override async Task> ExecuteAsync( Parameters req, LoginDTO login, CancellationToken ct) { var result = await _bll.GetFlowAsync(req.FlowDefinitionId, login, ct) .ConfigureAwait(false); return await GB5Shared.ResponseStandard.Response.CreateSuccessResponse( result, CacheKeyLevel.CLIENT_LEVEL, login); } public record Parameters( [property: FromHeader] string? Login, [property: QueryParam] int FlowDefinitionId); } }