| | | 1 | | using Elsa.Authorization; |
| | | 2 | | using Elsa.Abstractions; |
| | | 3 | | using Elsa.Common.Entities; |
| | | 4 | | using Elsa.Common.Models; |
| | | 5 | | using Elsa.Workflows.Api.Endpoints.BookmarkQueueDeadLetters; |
| | | 6 | | using Elsa.Workflows.Runtime; |
| | | 7 | | using Elsa.Workflows.Runtime.Filters; |
| | | 8 | | using Elsa.Workflows.Runtime.OrderDefinitions; |
| | | 9 | | using JetBrains.Annotations; |
| | | 10 | | |
| | | 11 | | namespace Elsa.Workflows.Api.Endpoints.BookmarkQueueDeadLetters.List; |
| | | 12 | | |
| | | 13 | | [UsedImplicitly] |
| | 3 | 14 | | internal class Endpoint(IBookmarkQueueDeadLetterStore store) : ElsaEndpoint<ListRequest, ListResponse> |
| | | 15 | | { |
| | | 16 | | public override void Configure() |
| | | 17 | | { |
| | 3 | 18 | | Verbs(FastEndpoints.Http.GET, FastEndpoints.Http.POST); |
| | 3 | 19 | | Routes("/bookmark-queue/dead-letters"); |
| | 3 | 20 | | RequirePermission(Elsa.Workflows.Api.Permissions.WorkflowPermissions.BookmarkQueueDeadLetters, CoreVerbs.View); |
| | 3 | 21 | | } |
| | | 22 | | |
| | | 23 | | public override async Task HandleAsync(ListRequest request, CancellationToken cancellationToken) |
| | | 24 | | { |
| | 0 | 25 | | var pageArgs = PageArgs.FromPage(request.Page ?? 0, request.PageSize ?? 50); |
| | 0 | 26 | | var filter = new BookmarkQueueDeadLetterFilter |
| | 0 | 27 | | { |
| | 0 | 28 | | WorkflowInstanceId = request.WorkflowInstanceId |
| | 0 | 29 | | }; |
| | 0 | 30 | | var order = new BookmarkQueueDeadLetterItemOrder<DateTimeOffset>(x => x.DeadLetteredAt, OrderDirection.Descendin |
| | 0 | 31 | | var page = await store.PageAsync(pageArgs, filter, order, cancellationToken); |
| | 0 | 32 | | var response = new ListResponse(page.Items.Select(BookmarkQueueDeadLetterModel.FromEntity).ToList(), page.TotalC |
| | | 33 | | |
| | 0 | 34 | | await Send.OkAsync(response, cancellationToken); |
| | 0 | 35 | | } |
| | | 36 | | } |