< 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: 53
Coverable lines: 64
Total lines: 125
Line coverage: 17.1%
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%1980440%

File(s)

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

#LineLine coverage
 1using Elsa.Authorization;
 2using System.Text.Json;
 3using Elsa.Abstractions;
 4using Elsa.Common.Models;
 5using Elsa.Workflows.Activities;
 6using Elsa.Workflows.Api.Constants;
 7using Elsa.Workflows.Api.Models;
 8using Elsa.Workflows.Api.Requirements;
 9using Elsa.Workflows.Api.Security;
 10using Elsa.Workflows.Management;
 11using Elsa.Workflows.Management.Mappers;
 12using Elsa.Workflows.Management.Materializers;
 13using Elsa.Workflows.Management.Models;
 14using Elsa.Workflows.Models;
 15using JetBrains.Annotations;
 16using Medallion.Threading;
 17using Microsoft.AspNetCore.Authorization;
 18using Microsoft.AspNetCore.Http;
 19
 20namespace Elsa.Workflows.Api.Endpoints.WorkflowDefinitions.Post;
 21
 22[PublicAPI]
 323internal class Post(
 324    IApiSerializer serializer,
 325    IWorkflowDefinitionPublisher workflowDefinitionPublisher,
 326    VariableDefinitionMapper variableDefinitionMapper,
 327    IDistributedLockProvider distributedLockProvider,
 328    IWorkflowDefinitionLinker linker,
 329    IAuthorizationService authorizationService,
 330    WorkflowDefinitionScriptAuthorizationService scriptAuthorizationService)
 31    : ElsaEndpoint<SaveWorkflowDefinitionRequest, LinkedWorkflowDefinitionModel>
 32{
 33    public override void Configure()
 34    {
 335        Post("/workflow-definitions");
 336        RequirePermission(Elsa.Workflows.Api.Permissions.WorkflowPermissions.Definitions, CoreVerbs.Write);
 337    }
 38
 39    public override async Task HandleAsync(SaveWorkflowDefinitionRequest request, CancellationToken cancellationToken)
 40    {
 041        var model = request.Model;
 042        var definitionId = model.DefinitionId;
 043        var resourceName = $"{GetType().FullName}:{(!string.IsNullOrWhiteSpace(definitionId) ? definitionId : Guid.NewGu
 44
 045        await using var handle = await distributedLockProvider.AcquireLockAsync(resourceName, TimeSpan.FromMinutes(1), c
 46
 047        var draft = !string.IsNullOrWhiteSpace(definitionId)
 048            ? await workflowDefinitionPublisher.GetDraftAsync(definitionId, VersionOptions.Latest, cancellationToken)
 049            : null;
 50
 051        var isNew = draft == null;
 52
 53        // Create a new workflow in case no existing definition was found.
 054        if (isNew)
 55        {
 056            draft = await workflowDefinitionPublisher.NewAsync(cancellationToken: cancellationToken);
 57
 058            if (!string.IsNullOrWhiteSpace(definitionId))
 059                draft.DefinitionId = definitionId;
 60        }
 61
 062        var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(draft), Author
 63
 064        if (!authorizationResult.Succeeded)
 65        {
 066            await Send.ForbiddenAsync(cancellationToken);
 067            return;
 68        }
 69
 070        var scriptAuthorizationResult = await scriptAuthorizationService.AuthorizeAsync(model, cancellationToken);
 071        if (!scriptAuthorizationResult.Succeeded)
 72        {
 073            await WorkflowDefinitionScriptAuthorizationFailure.SendAsync(scriptAuthorizationResult, message => AddError(
 074            return;
 75        }
 76
 77        // Update the draft with the received model.
 078        var root = model.Root ?? new Sequence();
 079        var serializerOptions = serializer.GetOptions();
 080        var stringData = JsonSerializer.Serialize(root, serializerOptions);
 081        var variables = variableDefinitionMapper.Map(model.Variables).ToList();
 082        var inputs = model.Inputs ?? new List<InputDefinition>();
 083        var outputs = model.Outputs ?? new List<OutputDefinition>();
 084        var outcomes = model.Outcomes ?? new List<string>();
 85
 086        draft!.StringData = stringData;
 087        draft.MaterializerName = JsonWorkflowMaterializer.MaterializerName;
 088        draft.Name = model.Name?.Trim();
 089        draft.ToolVersion = model.ToolVersion;
 090        draft.Description = model.Description?.Trim();
 091        draft.CustomProperties = model.CustomProperties ?? new Dictionary<string, object>();
 092        draft.Variables = variables;
 093        draft.Inputs = inputs;
 094        draft.Outputs = outputs;
 095        draft.Outcomes = outcomes;
 096        draft.Options = model.Options ?? new WorkflowOptions();
 97
 098        PublishWorkflowDefinitionResult? result = null;
 99
 0100        if (request.Publish == true)
 101        {
 0102            result = await workflowDefinitionPublisher.PublishAsync(draft, cancellationToken);
 103
 0104            if (!result.Succeeded)
 105            {
 0106                foreach (var validationError in result.ValidationErrors)
 0107                    AddError(validationError.Message);
 108
 0109                await Send.ErrorsAsync(400, cancellationToken);
 0110                return;
 111            }
 112        }
 113        else
 114        {
 0115            await workflowDefinitionPublisher.SaveDraftAsync(draft, cancellationToken);
 116        }
 117
 0118        var mappedDefinition = await linker.MapAsync(draft, cancellationToken);
 0119        var affectedWorkflows = result?.AffectedWorkflows?.WorkflowDefinitions ?? [];
 0120        var validationErrors = result?.ValidationErrors.Select(e => e.Message).ToList() ?? [];
 0121        var response = new Response(mappedDefinition, false, affectedWorkflows.Count, validationErrors);
 0122        await HttpContext.Response.WriteAsJsonAsync(response, serializerOptions, cancellationToken);
 0123    }
 124
 125}
Generated by: ReportGenerator 5.5.11.0
09/09/2026 - 11:01:44
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()