< Summary

Information
Class: Elsa.Persistence.EFCore.Modules.Runtime.Configurations
Assembly: Elsa.Persistence.EFCore
File(s): /home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Persistence.EFCore/Modules/Runtime/Configurations.cs
Line coverage
100%
Covered lines: 138
Uncovered lines: 0
Coverable lines: 138
Total lines: 186
Line coverage: 100%
Branch coverage
N/A
Covered branches: 0
Total branches: 0
Branch coverage: N/A
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
Configure(...)100%11100%
Configure(...)100%11100%
Configure(...)100%11100%
Configure(...)100%11100%
Configure(...)100%11100%
Configure(...)100%11100%
Configure(...)100%11100%

File(s)

/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Persistence.EFCore/Modules/Runtime/Configurations.cs

#LineLine coverage
 1using Elsa.KeyValues.Entities;
 2using Elsa.Workflows.Runtime.Entities;
 3using Microsoft.EntityFrameworkCore;
 4using Microsoft.EntityFrameworkCore.Metadata.Builders;
 5
 6namespace Elsa.Persistence.EFCore.Modules.Runtime;
 7
 8/// <summary>
 9/// EF Core configuration for various sets of <see cref="DbContext"/>.
 10/// </summary>
 11public class Configurations :
 12    IEntityTypeConfiguration<StoredTrigger>,
 13    IEntityTypeConfiguration<WorkflowExecutionLogRecord>,
 14    IEntityTypeConfiguration<ActivityExecutionRecord>,
 15    IEntityTypeConfiguration<StoredBookmark>,
 16    IEntityTypeConfiguration<BookmarkQueueItem>,
 17    IEntityTypeConfiguration<SerializedKeyValuePair>,
 18    IEntityTypeConfiguration<WorkflowInboxMessage>
 19{
 20    /// <inheritdoc />
 21    public void Configure(EntityTypeBuilder<ActivityExecutionRecord> builder)
 22    {
 123        builder.Ignore(x => x.ActivityState);
 124        builder.Ignore(x => x.Exception);
 125        builder.Ignore(x => x.Payload);
 126        builder.Ignore(x => x.Outputs);
 127        builder.Ignore(x => x.Metadata);
 128        builder.Ignore(x => x.Properties);
 129        builder.Property<string>("SerializedActivityState");
 130        builder.Property<string>("SerializedActivityStateCompressionAlgorithm");
 131        builder.Property<string>("SerializedException");
 132        builder.Property<string>("SerializedPayload");
 133        builder.Property<string>("SerializedOutputs");
 134        builder.Property<string>("SerializedProperties");
 135        builder.Property<string>("SerializedMetadata");
 136        builder.Property(x => x.Status).HasConversion<string>();
 137        builder.HasIndex(x => x.WorkflowInstanceId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Activ
 138        builder.HasIndex(x => x.ActivityId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecu
 139        builder.HasIndex(x => x.ActivityType).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 140        builder.HasIndex(x => x.ActivityTypeVersion).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Acti
 141        builder.HasIndex(x => new
 142        {
 143            x.ActivityType,
 144            x.ActivityTypeVersion
 145        }).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecutionRecord.ActivityType)}_{nameof
 146        builder.HasIndex(x => x.ActivityName).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 147        builder.HasIndex(x => x.StartedAt).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecut
 148        builder.HasIndex(x => x.HasBookmarks).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 149        builder.HasIndex(x => x.Status).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecution
 150        builder.HasIndex(x => x.CompletedAt).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExec
 151        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecuti
 152    }
 53
 54    public void Configure(EntityTypeBuilder<BookmarkQueueItem> builder)
 55    {
 156        builder.Ignore(x => x.Options);
 157        builder.Property<string>("SerializedOptions");
 158        builder.HasIndex(x => x.StimulusHash, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.StimulusHash)}"
 159        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.WorkflowI
 160        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.CorrelationId)
 161        builder.HasIndex(x => x.BookmarkId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.BookmarkId)}");
 162        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.ActivityI
 163        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.ActivityTyp
 164        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.CreatedAt)}");
 165        builder.HasIndex(x => x.TenantId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.TenantId)}");
 166    }
 67
 68    /// <inheritdoc />
 69    public void Configure(EntityTypeBuilder<SerializedKeyValuePair> builder)
 70    {
 171        builder.HasKey(x => x.Id);
 172        builder.Ignore(x => x.Key);
 173        builder.HasIndex(x => x.TenantId, $"IX_{nameof(SerializedKeyValuePair)}_{nameof(SerializedKeyValuePair.TenantId)
 174    }
 75
 76    /// <inheritdoc />
 77    public void Configure(EntityTypeBuilder<StoredBookmark> builder)
 78    {
 179        builder.Ignore(x => x.Payload);
 180        builder.Ignore(x => x.Metadata);
 181        builder.HasKey(b => b.Id);
 182        builder.Property<string>("SerializedPayload");
 183        builder.Property<string>("SerializedMetadata");
 184        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)
 185        builder.HasIndex(x => x.Name, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}");
 186        builder.HasIndex(x => x.Hash, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Hash)}");
 187        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.WorkflowInstanc
 188        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityInstanc
 189        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.CreatedAt)}");
 190        builder.HasIndex(x => new
 191            {
 192                x.ActivityTypeName,
 193                x.Hash
 194            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)}_{nameof(StoredBookmark.Hash)}");
 195        builder.HasIndex(x => new
 196            {
 197                x.ActivityTypeName,
 198                x.Hash,
 199                x.WorkflowInstanceId
 1100            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)}_{nameof(StoredBookmark.Hash)}_{na
 1101        builder.HasIndex(x => new
 1102            {
 1103                ActivityTypeName = x.Name,
 1104                x.Hash
 1105            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}_{nameof(StoredBookmark.Hash)}");
 1106        builder.HasIndex(x => new
 1107            {
 1108                ActivityTypeName = x.Name,
 1109                x.Hash,
 1110                x.WorkflowInstanceId
 1111            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}_{nameof(StoredBookmark.Hash)}_{nameof(StoredB
 1112        builder.HasIndex(x => x.TenantId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.TenantId)}");
 1113    }
 114
 115    /// <inheritdoc />
 116    public void Configure(EntityTypeBuilder<StoredTrigger> builder)
 117    {
 1118        builder.Ignore(x => x.Payload);
 1119        builder.Property<string>("SerializedPayload");
 1120        builder.HasIndex(x => x.WorkflowDefinitionId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger
 1121        builder.HasIndex(x => x.WorkflowDefinitionVersionId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(Stored
 1122        builder.HasIndex(x => x.Name).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.Name)}");
 1123        builder.HasIndex(x => x.Hash).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.Hash)}");
 1124        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.TenantId)}"
 125
 126        // Add unique constraint to prevent duplicate trigger registrations in multi-engine environments
 127        // A trigger is uniquely identified by WorkflowDefinitionId + Hash + ActivityId + TenantId
 1128        builder.HasIndex(x => new
 1129            {
 1130                x.WorkflowDefinitionId,
 1131                x.Hash,
 1132                x.ActivityId,
 1133                x.TenantId
 1134            })
 1135            .IsUnique()
 1136            .HasDatabaseName($"IX_{nameof(StoredTrigger)}_Unique_{nameof(StoredTrigger.WorkflowDefinitionId)}_{nameof(St
 1137    }
 138
 139    /// <inheritdoc />
 140    public void Configure(EntityTypeBuilder<WorkflowExecutionLogRecord> builder)
 141    {
 1142        builder.Ignore(x => x.ActivityState);
 1143        builder.Ignore(x => x.Payload);
 1144        builder.Property<string>("SerializedActivityState");
 1145        builder.Property<string>("SerializedPayload");
 1146        builder.HasIndex(x => x.Timestamp).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExe
 1147        builder.HasIndex(x => x.Sequence).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExec
 1148        builder.HasIndex(x => new
 1149        {
 1150            x.Timestamp,
 1151            x.Sequence
 1152        }).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExecutionLogRecord.Timestamp)}_{nam
 1153        builder.HasIndex(x => x.ActivityInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Wo
 1154        builder.HasIndex(x => x.ParentActivityInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nam
 1155        builder.HasIndex(x => x.ActivityId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowEx
 1156        builder.HasIndex(x => x.ActivityType).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workflow
 1157        builder.HasIndex(x => x.ActivityTypeVersion).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(W
 1158        builder.HasIndex(x => new
 1159        {
 1160            x.ActivityType,
 1161            x.ActivityTypeVersion
 1162        }).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExecutionLogRecord.ActivityType)}_{
 1163        builder.HasIndex(x => x.ActivityName).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workflow
 1164        builder.HasIndex(x => x.EventName).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExe
 1165        builder.HasIndex(x => x.WorkflowDefinitionId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(
 1166        builder.HasIndex(x => x.WorkflowDefinitionVersionId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{
 1167        builder.HasIndex(x => x.WorkflowInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Wo
 1168        builder.HasIndex(x => x.WorkflowVersion).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workf
 1169        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExec
 1170    }
 171
 172    public void Configure(EntityTypeBuilder<WorkflowInboxMessage> builder)
 173    {
 1174        builder.Ignore(x => x.Input);
 1175        builder.Ignore(x => x.BookmarkPayload);
 1176        builder.Property<string>("SerializedInput");
 1177        builder.Property<string>("SerializedBookmarkPayload");
 1178        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Activ
 1179        builder.HasIndex(x => x.Hash, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Hash)}");
 1180        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Wor
 1181        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Correlat
 1182        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Act
 1183        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.CreatedAt)}"
 1184        builder.HasIndex(x => x.ExpiresAt, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.ExpiresAt)}"
 1185    }
 186}
Generated by: ReportGenerator 5.5.3.0
03/10/2026 - 11:51:10
GitHub | reportgenerator.io

Methods/Properties

Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.Workflows.Runtime.Entities.ActivityExecutionRecord>)
Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.Workflows.Runtime.Entities.BookmarkQueueItem>)
Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.KeyValues.Entities.SerializedKeyValuePair>)
Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.Workflows.Runtime.Entities.StoredBookmark>)
Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.Workflows.Runtime.Entities.StoredTrigger>)
Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.Workflows.Runtime.Entities.WorkflowExecutionLogRecord>)
Configure(Microsoft.EntityFrameworkCore.Metadata.Builders.EntityTypeBuilder`1<Elsa.Workflows.Runtime.Entities.WorkflowInboxMessage>)