| | | 1 | | using Elsa.Authorization; |
| | | 2 | | using Elsa.Abstractions; |
| | | 3 | | using Elsa.Workflows.Runtime; |
| | | 4 | | using FastEndpoints; |
| | | 5 | | using JetBrains.Annotations; |
| | | 6 | | using Microsoft.AspNetCore.Http; |
| | | 7 | | |
| | | 8 | | namespace Elsa.Workflows.Api.Endpoints.RuntimeAdmin.Resume; |
| | | 9 | | |
| | | 10 | | /// <summary> |
| | | 11 | | /// <c>POST /admin/workflow-runtime/resume</c> — clears <see cref="QuiescenceReason.AdministrativePause"/>. |
| | | 12 | | /// Returns 409 Conflict when a drain is in progress (resume is meaningless mid-drain — see edge case in spec). |
| | | 13 | | /// Idempotent on the success path. |
| | | 14 | | /// </summary> |
| | | 15 | | [PublicAPI] |
| | 4 | 16 | | internal sealed class ResumeEndpoint(IWorkflowRuntimeAdminService admin) : ElsaEndpoint<EmptyRequest, StatusResponse> |
| | | 17 | | { |
| | | 18 | | public override void Configure() |
| | | 19 | | { |
| | 4 | 20 | | Post("/admin/workflow-runtime/resume"); |
| | 4 | 21 | | RequirePermission(Elsa.Workflows.Api.Permissions.WorkflowPermissions.Runtime, "control"); |
| | 4 | 22 | | } |
| | | 23 | | |
| | | 24 | | public override async Task HandleAsync(EmptyRequest _, CancellationToken ct) |
| | | 25 | | { |
| | 0 | 26 | | var status = admin.GetStatus(); |
| | 0 | 27 | | if ((status.State.Reason & QuiescenceReason.Drain) != 0) |
| | | 28 | | { |
| | | 29 | | // Use the discriminated ConflictResponse shape to match ForceDrain's 409 contract; routed via |
| | | 30 | | // HttpContext.Response.WriteAsJsonAsync because Send.ResponseAsync is constrained to TResponse. |
| | 0 | 31 | | HttpContext.Response.StatusCode = StatusCodes.Status409Conflict; |
| | 0 | 32 | | await HttpContext.Response.WriteAsJsonAsync( |
| | 0 | 33 | | new ConflictResponse { Code = "runtime-draining", State = StatusResponseFactory.Build(status) }, |
| | 0 | 34 | | ct); |
| | 0 | 35 | | return; |
| | | 36 | | } |
| | | 37 | | |
| | 0 | 38 | | await admin.ResumeAsync(HttpContext.User.Identity?.Name, ct); |
| | 0 | 39 | | await Send.OkAsync(StatusResponseFactory.Build(admin.GetStatus()), ct); |
| | 0 | 40 | | } |
| | | 41 | | } |