parent
7958ecf49a
commit
1c20b8fbb4
|
|
@ -2,7 +2,7 @@ using System.ComponentModel.DataAnnotations;
|
|||
|
||||
namespace Elsa.Activities.Webhooks.Endpoints.WebhookDefinitions
|
||||
{
|
||||
public sealed record SaveRequest
|
||||
public sealed record SaveWebhookDefinitionRequest
|
||||
{
|
||||
public string? Id { get; init; }
|
||||
[Required] public string Path { get; init; } = default!;
|
||||
|
|
|
|||
|
|
@ -33,12 +33,11 @@ namespace Elsa.Activities.Webhooks.Endpoints.WebhookDefinitions
|
|||
[SwaggerResponseExample(StatusCodes.Status200OK, typeof(WebhookDefinitionExample))]
|
||||
[SwaggerOperation(
|
||||
Summary = "Creates a new webhook definition or updates an existing one.",
|
||||
Description =
|
||||
"Creates a new webhook definition or updates an existing one.",
|
||||
Description = "Creates a new webhook definition or updates an existing one.",
|
||||
OperationId = "WebhookDefinitions.Post",
|
||||
Tags = new[] { "WebhookDefinitions" })
|
||||
]
|
||||
public async Task<ActionResult<WebhookDefinition>> Handle([FromBody] SaveRequest request, [FromRoute] ApiVersion apiVersion, CancellationToken cancellationToken)
|
||||
public async Task<ActionResult<WebhookDefinition>> Handle([FromBody] SaveWebhookDefinitionRequest request, [FromRoute] ApiVersion apiVersion, CancellationToken cancellationToken)
|
||||
{
|
||||
var webhookId = request.Id;
|
||||
var webhookDefinition = !string.IsNullOrWhiteSpace(webhookId) ? await _store.FindAsync(new EntityIdSpecification<WebhookDefinition>(webhookId), cancellationToken) : default;
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ namespace Elsa.Activities.Webhooks.Endpoints.WebhookDefinitions
|
|||
OperationId = "WebhookDefinitions.Put",
|
||||
Tags = new[] { "WebhookDefinitions" })
|
||||
]
|
||||
public async Task<ActionResult<WebhookDefinition>> Handle([FromBody] SaveRequest request, [FromRoute] ApiVersion apiVersion, CancellationToken cancellationToken)
|
||||
public async Task<ActionResult<WebhookDefinition>> Handle([FromBody] SaveWebhookDefinitionRequest request, [FromRoute] ApiVersion apiVersion, CancellationToken cancellationToken)
|
||||
{
|
||||
var webhookId = request.Id;
|
||||
var webhookDefinition = await _store.FindAsync(new EntityIdSpecification<WebhookDefinition>(webhookId), cancellationToken);
|
||||
|
|
|
|||
|
|
@ -5,7 +5,7 @@ namespace Elsa.Server.Api.Endpoints.WorkflowDefinitions
|
|||
{
|
||||
public partial class Save
|
||||
{
|
||||
public sealed record SaveRequest
|
||||
public sealed record SaveWorkflowDefinitionRequest
|
||||
{
|
||||
public string? WorkflowDefinitionId { get; init; }
|
||||
public string? Name { get; init; }
|
||||
|
|
|
|||
|
|
@ -35,7 +35,7 @@ namespace Elsa.Server.Api.Endpoints.WorkflowDefinitions
|
|||
OperationId = "WorkflowDefinitions.Post",
|
||||
Tags = new[] { "WorkflowDefinitions" })
|
||||
]
|
||||
public async Task<ActionResult<WorkflowDefinition>> Handle([FromBody]SaveRequest request, [FromRoute]ApiVersion apiVersion, CancellationToken cancellationToken)
|
||||
public async Task<ActionResult<WorkflowDefinition>> Handle([FromBody]SaveWorkflowDefinitionRequest request, [FromRoute]ApiVersion apiVersion, CancellationToken cancellationToken)
|
||||
{
|
||||
var workflowDefinitionId = request.WorkflowDefinitionId;
|
||||
var workflowDefinition = !string.IsNullOrWhiteSpace(workflowDefinitionId) ? await _workflowPublisher.GetDraftAsync(workflowDefinitionId, cancellationToken) : default;
|
||||
|
|
@ -68,7 +68,7 @@ namespace Elsa.Server.Api.Endpoints.WorkflowDefinitions
|
|||
return CreatedAtAction("Handle", "GetByVersionId", new { versionId = workflowDefinition.Id, apiVersion = apiVersion.ToString() }, workflowDefinition);
|
||||
}
|
||||
|
||||
private IEnumerable<ConnectionDefinition> FilterInvalidConnections(SaveRequest request)
|
||||
private IEnumerable<ConnectionDefinition> FilterInvalidConnections(SaveWorkflowDefinitionRequest request)
|
||||
{
|
||||
var validConnections =
|
||||
from connection in request.Connections
|
||||
|
|
|
|||
Loading…
Reference in a new issue