< 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: 152
Uncovered lines: 0
Coverable lines: 152
Total lines: 205
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%
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<BookmarkQueueDeadLetterItem>,
 18    IEntityTypeConfiguration<SerializedKeyValuePair>,
 19    IEntityTypeConfiguration<WorkflowInboxMessage>
 20{
 21    /// <inheritdoc />
 22    public void Configure(EntityTypeBuilder<ActivityExecutionRecord> builder)
 23    {
 124        builder.Ignore(x => x.ActivityState);
 125        builder.Ignore(x => x.Exception);
 126        builder.Ignore(x => x.Payload);
 127        builder.Ignore(x => x.Outputs);
 128        builder.Ignore(x => x.Metadata);
 129        builder.Ignore(x => x.Properties);
 130        builder.Property<string>("SerializedActivityState");
 131        builder.Property<string>("SerializedActivityStateCompressionAlgorithm");
 132        builder.Property<string>("SerializedException");
 133        builder.Property<string>("SerializedPayload");
 134        builder.Property<string>("SerializedOutputs");
 135        builder.Property<string>("SerializedProperties");
 136        builder.Property<string>("SerializedMetadata");
 137        builder.Property(x => x.Status).HasConversion<string>();
 138        builder.HasIndex(x => x.WorkflowInstanceId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Activ
 139        builder.HasIndex(x => x.ActivityId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecu
 140        builder.HasIndex(x => x.ActivityType).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 141        builder.HasIndex(x => x.ActivityTypeVersion).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Acti
 142        builder.HasIndex(x => new
 143        {
 144            x.ActivityType,
 145            x.ActivityTypeVersion
 146        }).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecutionRecord.ActivityType)}_{nameof
 147        builder.HasIndex(x => x.ActivityName).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 148        builder.HasIndex(x => x.StartedAt).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecut
 149        builder.HasIndex(x => x.HasBookmarks).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 150        builder.HasIndex(x => x.Status).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecution
 151        builder.HasIndex(x => x.CompletedAt).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExec
 152        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecuti
 153        builder.HasIndex(x => x.SchedulingActivityExecutionId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{n
 154        builder.HasIndex(x => x.SchedulingActivityId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Act
 155        builder.HasIndex(x => x.SchedulingWorkflowInstanceId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{na
 156    }
 57
 58    public void Configure(EntityTypeBuilder<BookmarkQueueItem> builder)
 59    {
 160        builder.Ignore(x => x.Options);
 161        builder.Property<string>("SerializedOptions");
 162        builder.HasIndex(x => x.StimulusHash, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.StimulusHash)}"
 163        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.WorkflowI
 164        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.CorrelationId)
 165        builder.HasIndex(x => x.BookmarkId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.BookmarkId)}");
 166        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.ActivityI
 167        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.ActivityTyp
 168        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.CreatedAt)}");
 169        builder.HasIndex(x => x.TenantId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.TenantId)}");
 170    }
 71
 72    /// <inheritdoc />
 73    public void Configure(EntityTypeBuilder<BookmarkQueueDeadLetterItem> builder)
 74    {
 175        builder.Ignore(x => x.Options);
 176        builder.Property<string>("SerializedOptions");
 177        builder.HasIndex(x => x.OriginalQueueItemId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDea
 178        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDead
 179        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLette
 180        builder.HasIndex(x => x.BookmarkId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLetterIt
 181        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDead
 182        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLe
 183        builder.HasIndex(x => x.DeadLetteredAt, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLett
 184        builder.HasIndex(x => x.TenantId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLetterItem
 185    }
 86
 87    /// <inheritdoc />
 88    public void Configure(EntityTypeBuilder<SerializedKeyValuePair> builder)
 89    {
 190        builder.HasKey(x => x.Id);
 191        builder.Ignore(x => x.Key);
 192        builder.HasIndex(x => x.TenantId, $"IX_{nameof(SerializedKeyValuePair)}_{nameof(SerializedKeyValuePair.TenantId)
 193    }
 94
 95    /// <inheritdoc />
 96    public void Configure(EntityTypeBuilder<StoredBookmark> builder)
 97    {
 198        builder.Ignore(x => x.Payload);
 199        builder.Ignore(x => x.Metadata);
 1100        builder.HasKey(b => b.Id);
 1101        builder.Property<string>("SerializedPayload");
 1102        builder.Property<string>("SerializedMetadata");
 1103        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)
 1104        builder.HasIndex(x => x.Name, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}");
 1105        builder.HasIndex(x => x.Hash, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Hash)}");
 1106        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.WorkflowInstanc
 1107        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityInstanc
 1108        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.CreatedAt)}");
 1109        builder.HasIndex(x => new
 1110            {
 1111                x.ActivityTypeName,
 1112                x.Hash
 1113            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)}_{nameof(StoredBookmark.Hash)}");
 1114        builder.HasIndex(x => new
 1115            {
 1116                x.ActivityTypeName,
 1117                x.Hash,
 1118                x.WorkflowInstanceId
 1119            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)}_{nameof(StoredBookmark.Hash)}_{na
 1120        builder.HasIndex(x => new
 1121            {
 1122                ActivityTypeName = x.Name,
 1123                x.Hash
 1124            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}_{nameof(StoredBookmark.Hash)}");
 1125        builder.HasIndex(x => new
 1126            {
 1127                ActivityTypeName = x.Name,
 1128                x.Hash,
 1129                x.WorkflowInstanceId
 1130            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}_{nameof(StoredBookmark.Hash)}_{nameof(StoredB
 1131        builder.HasIndex(x => x.TenantId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.TenantId)}");
 1132    }
 133
 134    /// <inheritdoc />
 135    public void Configure(EntityTypeBuilder<StoredTrigger> builder)
 136    {
 1137        builder.Ignore(x => x.Payload);
 1138        builder.Property<string>("SerializedPayload");
 1139        builder.HasIndex(x => x.WorkflowDefinitionId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger
 1140        builder.HasIndex(x => x.WorkflowDefinitionVersionId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(Stored
 1141        builder.HasIndex(x => x.Name).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.Name)}");
 1142        builder.HasIndex(x => x.Hash).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.Hash)}");
 1143        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.TenantId)}"
 144
 145        // Add unique constraint to prevent duplicate trigger registrations in multi-engine environments
 146        // A trigger is uniquely identified by WorkflowDefinitionId + Hash + ActivityId + TenantId
 1147        builder.HasIndex(x => new
 1148            {
 1149                x.WorkflowDefinitionId,
 1150                x.Hash,
 1151                x.ActivityId,
 1152                x.TenantId
 1153            })
 1154            .IsUnique()
 1155            .HasDatabaseName($"IX_{nameof(StoredTrigger)}_Unique_{nameof(StoredTrigger.WorkflowDefinitionId)}_{nameof(St
 1156    }
 157
 158    /// <inheritdoc />
 159    public void Configure(EntityTypeBuilder<WorkflowExecutionLogRecord> builder)
 160    {
 1161        builder.Ignore(x => x.ActivityState);
 1162        builder.Ignore(x => x.Payload);
 1163        builder.Property<string>("SerializedActivityState");
 1164        builder.Property<string>("SerializedPayload");
 1165        builder.HasIndex(x => x.Timestamp).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExe
 1166        builder.HasIndex(x => x.Sequence).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExec
 1167        builder.HasIndex(x => new
 1168        {
 1169            x.Timestamp,
 1170            x.Sequence
 1171        }).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExecutionLogRecord.Timestamp)}_{nam
 1172        builder.HasIndex(x => x.ActivityInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Wo
 1173        builder.HasIndex(x => x.ParentActivityInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nam
 1174        builder.HasIndex(x => x.ActivityId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowEx
 1175        builder.HasIndex(x => x.ActivityType).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workflow
 1176        builder.HasIndex(x => x.ActivityTypeVersion).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(W
 1177        builder.HasIndex(x => new
 1178        {
 1179            x.ActivityType,
 1180            x.ActivityTypeVersion
 1181        }).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExecutionLogRecord.ActivityType)}_{
 1182        builder.HasIndex(x => x.ActivityName).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workflow
 1183        builder.HasIndex(x => x.EventName).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExe
 1184        builder.HasIndex(x => x.WorkflowDefinitionId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(
 1185        builder.HasIndex(x => x.WorkflowDefinitionVersionId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{
 1186        builder.HasIndex(x => x.WorkflowInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Wo
 1187        builder.HasIndex(x => x.WorkflowVersion).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workf
 1188        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExec
 1189    }
 190
 191    public void Configure(EntityTypeBuilder<WorkflowInboxMessage> builder)
 192    {
 1193        builder.Ignore(x => x.Input);
 1194        builder.Ignore(x => x.BookmarkPayload);
 1195        builder.Property<string>("SerializedInput");
 1196        builder.Property<string>("SerializedBookmarkPayload");
 1197        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Activ
 1198        builder.HasIndex(x => x.Hash, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Hash)}");
 1199        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Wor
 1200        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Correlat
 1201        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Act
 1202        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.CreatedAt)}"
 1203        builder.HasIndex(x => x.ExpiresAt, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.ExpiresAt)}"
 1204    }
 205}
Generated by: ReportGenerator 5.5.10.0
05/31/2026 - 13:48:39
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.Workflows.Runtime.Entities.BookmarkQueueDeadLetterItem>)
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>)