< Summary

Information
Class: Elsa.Workflows.Runtime.DefaultActivityExecutionMapper
Assembly: Elsa.Workflows.Runtime
File(s): /home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Runtime/Services/DefaultActivityExecutionMapper.cs
Line coverage
100%
Covered lines: 76
Uncovered lines: 0
Coverable lines: 76
Total lines: 107
Line coverage: 100%
Branch coverage
90%
Covered branches: 27
Total branches: 30
Branch coverage: 90%
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.ctor(...)100%11100%
MapAsync()81.81%2222100%
GetPersistableInputOutput(...)100%66100%
GetPersistableDictionary(...)100%22100%

File(s)

/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Runtime/Services/DefaultActivityExecutionMapper.cs

#LineLine coverage
 1using Elsa.Common;
 2using Elsa.Common.Codecs;
 3using Elsa.Workflows.LogPersistence;
 4using Elsa.Workflows.Management.Options;
 5using Elsa.Workflows.Runtime.Entities;
 6using Elsa.Workflows.Runtime.Extensions;
 7using Elsa.Workflows.State;
 8using Microsoft.Extensions.Options;
 9
 10namespace Elsa.Workflows.Runtime;
 11
 12/// <inheritdoc />
 51413public class DefaultActivityExecutionMapper(
 51414    ISafeSerializer safeSerializer,
 51415    IPayloadSerializer payloadSerializer,
 51416    ICompressionCodecResolver compressionCodecResolver,
 51417    IOptions<ManagementOptions> options) : IActivityExecutionMapper
 18{
 19    /// <inheritdoc />
 20    public async Task<ActivityExecutionRecord> MapAsync(ActivityExecutionContext source)
 21    {
 425122        var outputs = source.GetOutputs();
 425123        var inputs = source.GetInputs();
 425124        var persistenceMap = source.GetLogPersistenceModeMap();
 425125        var persistableInputs = GetPersistableInputOutput(inputs, persistenceMap.Inputs);
 425126        var persistableOutputs = GetPersistableInputOutput(outputs, persistenceMap.Outputs);
 425127        var persistableProperties = GetPersistableDictionary(source.Properties!, persistenceMap.InternalState);
 425128        var persistableJournalData = GetPersistableDictionary(source.JournalData!, persistenceMap.InternalState);
 425129        var cancellationToken = source.CancellationToken;
 30
 425131        var record = new ActivityExecutionRecord
 425132        {
 425133            Id = source.Id,
 425134            ActivityId = source.Activity.Id,
 425135            ActivityNodeId = source.NodeId,
 425136            WorkflowInstanceId = source.WorkflowExecutionContext.Id,
 425137            ActivityType = source.Activity.Type,
 425138            ActivityName = source.Activity.Name,
 425139            ActivityState = persistableInputs,
 425140            Outputs = persistableOutputs,
 425141            Properties = persistableProperties!,
 425142            Metadata = new Dictionary<string, object>(source.Metadata),
 425143            Payload = persistableJournalData!,
 425144            Exception = ExceptionState.FromException(source.Exception),
 425145            ActivityTypeVersion = source.Activity.Version,
 425146            StartedAt = source.StartedAt,
 425147            HasBookmarks = source.Bookmarks.Any(),
 425148            Status = source.Status,
 425149            AggregateFaultCount = source.AggregateFaultCount,
 425150            CompletedAt = source.CompletedAt,
 425151            SchedulingActivityExecutionId = source.SchedulingActivityExecutionId,
 425152            SchedulingActivityId = source.SchedulingActivityId,
 425153            SchedulingWorkflowInstanceId = source.SchedulingWorkflowInstanceId,
 425154            CallStackDepth = source.CallStackDepth
 425155        };
 56
 425157        record = record.SanitizeLogMessage();
 425158        var compressionAlgorithm = options.Value.CompressionAlgorithm ?? nameof(None);
 425159        var serializedActivityState = record.ActivityState?.Count > 0 ? safeSerializer.Serialize(record.ActivityState) :
 425160        var compressedSerializedActivityState = serializedActivityState != null ? await compressionCodecResolver.Resolve
 425161        var serializedProperties = record.Properties != null ? payloadSerializer.Serialize(record.Properties) : null;
 425162        var serializedMetadata = record.Metadata != null ? payloadSerializer.Serialize(record.Metadata) : null;
 425163        record.SerializedSnapshot = new()
 425164        {
 425165            Id = record.Id,
 425166            TenantId = record.TenantId,
 425167            WorkflowInstanceId = record.WorkflowInstanceId,
 425168            ActivityId = record.ActivityId,
 425169            ActivityNodeId = record.ActivityNodeId,
 425170            ActivityType = record.ActivityType,
 425171            ActivityTypeVersion = record.ActivityTypeVersion,
 425172            ActivityName = record.ActivityName,
 425173            StartedAt = record.StartedAt,
 425174            HasBookmarks = record.HasBookmarks,
 425175            Status = record.Status,
 425176            AggregateFaultCount = record.AggregateFaultCount,
 425177            CompletedAt = record.CompletedAt,
 425178            SerializedActivityState = compressedSerializedActivityState,
 425179            SerializedActivityStateCompressionAlgorithm = compressionAlgorithm,
 425180            SerializedOutputs = record.Outputs?.Any() == true ? safeSerializer.Serialize(record.Outputs) : null,
 425181            SerializedProperties = serializedProperties,
 425182            SerializedMetadata = serializedMetadata,
 425183            SerializedException = record.Exception != null ? payloadSerializer.Serialize(record.Exception) : null,
 425184            SerializedPayload = record.Payload?.Any() == true ? payloadSerializer.Serialize(record.Payload) : null
 425185        };
 86
 425187        return record;
 425188    }
 89
 90    private IDictionary<string, object?> GetPersistableInputOutput(IDictionary<string, object> state, IDictionary<string
 91    {
 850292        var result = new Dictionary<string, object?>();
 3489093        foreach (var stateEntry in state)
 94        {
 894395            var mode = map.TryGetValue(stateEntry.Key, out var value) ? value : LogPersistenceMode.Include;
 894396            if (mode == LogPersistenceMode.Include)
 893597                result.Add(stateEntry.Key, stateEntry.Value);
 98        }
 99
 8502100        return result;
 101    }
 102
 103    private IDictionary<string, object?>? GetPersistableDictionary(IDictionary<string, object?> dictionary, LogPersisten
 104    {
 8502105        return mode == LogPersistenceMode.Include ? new Dictionary<string, object?>(dictionary) : null;
 106    }
 107}
Generated by: ReportGenerator 5.5.6.0
04/21/2026 - 10:26:40
GitHub | reportgenerator.io

Methods/Properties

.ctor(Elsa.Workflows.ISafeSerializer,Elsa.Workflows.IPayloadSerializer,Elsa.Common.ICompressionCodecResolver,Microsoft.Extensions.Options.IOptions`1<Elsa.Workflows.Management.Options.ManagementOptions>)
MapAsync()
GetPersistableInputOutput(System.Collections.Generic.IDictionary`2<System.String,System.Object>,System.Collections.Generic.IDictionary`2<System.String,Elsa.Workflows.LogPersistence.LogPersistenceMode>,System.Boolean)
GetPersistableDictionary(System.Collections.Generic.IDictionary`2<System.String,System.Object>,Elsa.Workflows.LogPersistence.LogPersistenceMode)