< Summary

Information
Class: Elsa.Workflows.Api.Endpoints.WorkflowDefinitions.Post.Post
Assembly: Elsa.Workflows.Api
File(s): /home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Post/Endpoint.cs
Line coverage
17%
Covered lines: 11
Uncovered lines: 52
Coverable lines: 63
Total lines: 123
Line coverage: 17.4%
Branch coverage
0%
Covered branches: 0
Total branches: 40
Branch coverage: 0%
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.ctor(...)100%11100%
Configure()100%11100%
HandleAsync()0%1640400%

File(s)

/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Post/Endpoint.cs

#LineLine coverage
 1using System.Text.Json;
 2using Elsa.Abstractions;
 3using Elsa.Common.Models;
 4using Elsa.Workflows.Activities;
 5using Elsa.Workflows.Api.Constants;
 6using Elsa.Workflows.Api.Models;
 7using Elsa.Workflows.Api.Requirements;
 8using Elsa.Workflows.Api.Security;
 9using Elsa.Workflows.Management;
 10using Elsa.Workflows.Management.Mappers;
 11using Elsa.Workflows.Management.Materializers;
 12using Elsa.Workflows.Management.Models;
 13using Elsa.Workflows.Models;
 14using JetBrains.Annotations;
 15using Medallion.Threading;
 16using Microsoft.AspNetCore.Authorization;
 17using Microsoft.AspNetCore.Http;
 18
 19namespace Elsa.Workflows.Api.Endpoints.WorkflowDefinitions.Post;
 20
 21[PublicAPI]
 322internal class Post(
 323    IApiSerializer serializer,
 324    IWorkflowDefinitionPublisher workflowDefinitionPublisher,
 325    VariableDefinitionMapper variableDefinitionMapper,
 326    IDistributedLockProvider distributedLockProvider,
 327    IWorkflowDefinitionLinker linker,
 328    IAuthorizationService authorizationService,
 329    WorkflowDefinitionScriptAuthorizationService scriptAuthorizationService)
 30    : ElsaEndpoint<SaveWorkflowDefinitionRequest, LinkedWorkflowDefinitionModel>
 31{
 32    public override void Configure()
 33    {
 334        Post("/workflow-definitions");
 335        ConfigurePermissions("write:workflow-definitions");
 336    }
 37
 38    public override async Task HandleAsync(SaveWorkflowDefinitionRequest request, CancellationToken cancellationToken)
 39    {
 040        var model = request.Model;
 041        var definitionId = model.DefinitionId;
 042        var resourceName = $"{GetType().FullName}:{(!string.IsNullOrWhiteSpace(definitionId) ? definitionId : Guid.NewGu
 43
 044        await using var handle = await distributedLockProvider.AcquireLockAsync(resourceName, TimeSpan.FromMinutes(1), c
 45
 046        var draft = !string.IsNullOrWhiteSpace(definitionId)
 047            ? await workflowDefinitionPublisher.GetDraftAsync(definitionId, VersionOptions.Latest, cancellationToken)
 048            : null;
 49
 050        var isNew = draft == null;
 51
 52        // Create a new workflow in case no existing definition was found.
 053        if (isNew)
 54        {
 055            draft = await workflowDefinitionPublisher.NewAsync(cancellationToken: cancellationToken);
 56
 057            if (!string.IsNullOrWhiteSpace(definitionId))
 058                draft.DefinitionId = definitionId;
 59        }
 60
 061        var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(draft), Author
 62
 063        if (!authorizationResult.Succeeded)
 64        {
 065            await Send.ForbiddenAsync(cancellationToken);
 066            return;
 67        }
 68
 069        var scriptAuthorizationResult = await scriptAuthorizationService.AuthorizeAsync(model, User, cancellationToken);
 070        if (!scriptAuthorizationResult.Succeeded)
 71        {
 072            await WorkflowDefinitionScriptAuthorizationFailure.SendAsync(scriptAuthorizationResult, Send.ForbiddenAsync,
 073            return;
 74        }
 75
 76        // Update the draft with the received model.
 077        var root = model.Root ?? new Sequence();
 078        var serializerOptions = serializer.GetOptions();
 079        var stringData = JsonSerializer.Serialize(root, serializerOptions);
 080        var variables = variableDefinitionMapper.Map(model.Variables).ToList();
 081        var inputs = model.Inputs ?? new List<InputDefinition>();
 082        var outputs = model.Outputs ?? new List<OutputDefinition>();
 083        var outcomes = model.Outcomes ?? new List<string>();
 84
 085        draft!.StringData = stringData;
 086        draft.MaterializerName = JsonWorkflowMaterializer.MaterializerName;
 087        draft.Name = model.Name?.Trim();
 088        draft.ToolVersion = model.ToolVersion;
 089        draft.Description = model.Description?.Trim();
 090        draft.CustomProperties = model.CustomProperties ?? new Dictionary<string, object>();
 091        draft.Variables = variables;
 092        draft.Inputs = inputs;
 093        draft.Outputs = outputs;
 094        draft.Outcomes = outcomes;
 095        draft.Options = model.Options ?? new WorkflowOptions();
 96
 097        PublishWorkflowDefinitionResult? result = null;
 98
 099        if (request.Publish == true)
 100        {
 0101            result = await workflowDefinitionPublisher.PublishAsync(draft, cancellationToken);
 102
 0103            if (!result.Succeeded)
 104            {
 0105                foreach (var validationError in result.ValidationErrors)
 0106                    AddError(validationError.Message);
 107
 0108                await Send.ErrorsAsync(400, cancellationToken);
 0109                return;
 110            }
 111        }
 112        else
 113        {
 0114            await workflowDefinitionPublisher.SaveDraftAsync(draft, cancellationToken);
 115        }
 116
 0117        var mappedDefinition = await linker.MapAsync(draft, cancellationToken);
 0118        var affectedWorkflows = result?.AffectedWorkflows?.WorkflowDefinitions ?? [];
 0119        var response = new Response(mappedDefinition, false, affectedWorkflows.Count);
 0120        await HttpContext.Response.WriteAsJsonAsync(response, serializerOptions, cancellationToken);
 0121    }
 122
 123}
Generated by: ReportGenerator 5.5.10.0
05/31/2026 - 13:48:39
GitHub | reportgenerator.io

Methods/Properties

.ctor(Elsa.Workflows.IApiSerializer,Elsa.Workflows.Management.IWorkflowDefinitionPublisher,Elsa.Workflows.Management.Mappers.VariableDefinitionMapper,Medallion.Threading.IDistributedLockProvider,Elsa.Workflows.Api.IWorkflowDefinitionLinker,Microsoft.AspNetCore.Authorization.IAuthorizationService,Elsa.Workflows.Api.Security.WorkflowDefinitionScriptAuthorizationService)
Configure()
HandleAsync()