< 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    {
 424        builder.Ignore(x => x.ActivityState);
 425        builder.Ignore(x => x.Exception);
 426        builder.Ignore(x => x.Payload);
 427        builder.Ignore(x => x.Outputs);
 428        builder.Ignore(x => x.Metadata);
 429        builder.Ignore(x => x.Properties);
 430        builder.Property<string>("SerializedActivityState");
 431        builder.Property<string>("SerializedActivityStateCompressionAlgorithm");
 432        builder.Property<string>("SerializedException");
 433        builder.Property<string>("SerializedPayload");
 434        builder.Property<string>("SerializedOutputs");
 435        builder.Property<string>("SerializedProperties");
 436        builder.Property<string>("SerializedMetadata");
 437        builder.Property(x => x.Status).HasConversion<string>();
 438        builder.HasIndex(x => x.WorkflowInstanceId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Activ
 439        builder.HasIndex(x => x.ActivityId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecu
 440        builder.HasIndex(x => x.ActivityType).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 441        builder.HasIndex(x => x.ActivityTypeVersion).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Acti
 442        builder.HasIndex(x => new
 443        {
 444            x.ActivityType,
 445            x.ActivityTypeVersion
 446        }).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecutionRecord.ActivityType)}_{nameof
 447        builder.HasIndex(x => x.ActivityName).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 448        builder.HasIndex(x => x.StartedAt).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecut
 449        builder.HasIndex(x => x.HasBookmarks).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExe
 450        builder.HasIndex(x => x.Status).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecution
 451        builder.HasIndex(x => x.CompletedAt).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExec
 452        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(ActivityExecuti
 453        builder.HasIndex(x => x.SchedulingActivityExecutionId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{n
 454        builder.HasIndex(x => x.SchedulingActivityId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{nameof(Act
 455        builder.HasIndex(x => x.SchedulingWorkflowInstanceId).HasDatabaseName($"IX_{nameof(ActivityExecutionRecord)}_{na
 456    }
 57
 58    public void Configure(EntityTypeBuilder<BookmarkQueueItem> builder)
 59    {
 460        builder.Ignore(x => x.Options);
 461        builder.Property<string>("SerializedOptions");
 462        builder.HasIndex(x => x.StimulusHash, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.StimulusHash)}"
 463        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.WorkflowI
 464        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.CorrelationId)
 465        builder.HasIndex(x => x.BookmarkId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.BookmarkId)}");
 466        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.ActivityI
 467        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.ActivityTyp
 468        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.CreatedAt)}");
 469        builder.HasIndex(x => x.TenantId, $"IX_{nameof(BookmarkQueueItem)}_{nameof(BookmarkQueueItem.TenantId)}");
 470    }
 71
 72    /// <inheritdoc />
 73    public void Configure(EntityTypeBuilder<BookmarkQueueDeadLetterItem> builder)
 74    {
 475        builder.Ignore(x => x.Options);
 476        builder.Property<string>("SerializedOptions");
 477        builder.HasIndex(x => x.OriginalQueueItemId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDea
 478        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDead
 479        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLette
 480        builder.HasIndex(x => x.BookmarkId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLetterIt
 481        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDead
 482        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLe
 483        builder.HasIndex(x => x.DeadLetteredAt, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLett
 484        builder.HasIndex(x => x.TenantId, $"IX_{nameof(BookmarkQueueDeadLetterItem)}_{nameof(BookmarkQueueDeadLetterItem
 485    }
 86
 87    /// <inheritdoc />
 88    public void Configure(EntityTypeBuilder<SerializedKeyValuePair> builder)
 89    {
 490        builder.HasKey(x => x.Id);
 491        builder.Ignore(x => x.Key);
 492        builder.HasIndex(x => x.TenantId, $"IX_{nameof(SerializedKeyValuePair)}_{nameof(SerializedKeyValuePair.TenantId)
 493    }
 94
 95    /// <inheritdoc />
 96    public void Configure(EntityTypeBuilder<StoredBookmark> builder)
 97    {
 498        builder.Ignore(x => x.Payload);
 499        builder.Ignore(x => x.Metadata);
 4100        builder.HasKey(b => b.Id);
 4101        builder.Property<string>("SerializedPayload");
 4102        builder.Property<string>("SerializedMetadata");
 4103        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)
 4104        builder.HasIndex(x => x.Name, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}");
 4105        builder.HasIndex(x => x.Hash, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Hash)}");
 4106        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.WorkflowInstanc
 4107        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityInstanc
 4108        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.CreatedAt)}");
 4109        builder.HasIndex(x => new
 4110            {
 4111                x.ActivityTypeName,
 4112                x.Hash
 4113            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)}_{nameof(StoredBookmark.Hash)}");
 4114        builder.HasIndex(x => new
 4115            {
 4116                x.ActivityTypeName,
 4117                x.Hash,
 4118                x.WorkflowInstanceId
 4119            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.ActivityTypeName)}_{nameof(StoredBookmark.Hash)}_{na
 4120        builder.HasIndex(x => new
 4121            {
 4122                ActivityTypeName = x.Name,
 4123                x.Hash
 4124            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}_{nameof(StoredBookmark.Hash)}");
 4125        builder.HasIndex(x => new
 4126            {
 4127                ActivityTypeName = x.Name,
 4128                x.Hash,
 4129                x.WorkflowInstanceId
 4130            }, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.Name)}_{nameof(StoredBookmark.Hash)}_{nameof(StoredB
 4131        builder.HasIndex(x => x.TenantId, $"IX_{nameof(StoredBookmark)}_{nameof(StoredBookmark.TenantId)}");
 4132    }
 133
 134    /// <inheritdoc />
 135    public void Configure(EntityTypeBuilder<StoredTrigger> builder)
 136    {
 4137        builder.Ignore(x => x.Payload);
 4138        builder.Property<string>("SerializedPayload");
 4139        builder.HasIndex(x => x.WorkflowDefinitionId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger
 4140        builder.HasIndex(x => x.WorkflowDefinitionVersionId).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(Stored
 4141        builder.HasIndex(x => x.Name).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.Name)}");
 4142        builder.HasIndex(x => x.Hash).HasDatabaseName($"IX_{nameof(StoredTrigger)}_{nameof(StoredTrigger.Hash)}");
 4143        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
 4147        builder.HasIndex(x => new
 4148            {
 4149                x.WorkflowDefinitionId,
 4150                x.Hash,
 4151                x.ActivityId,
 4152                x.TenantId
 4153            })
 4154            .IsUnique()
 4155            .HasDatabaseName($"IX_{nameof(StoredTrigger)}_Unique_{nameof(StoredTrigger.WorkflowDefinitionId)}_{nameof(St
 4156    }
 157
 158    /// <inheritdoc />
 159    public void Configure(EntityTypeBuilder<WorkflowExecutionLogRecord> builder)
 160    {
 4161        builder.Ignore(x => x.ActivityState);
 4162        builder.Ignore(x => x.Payload);
 4163        builder.Property<string>("SerializedActivityState");
 4164        builder.Property<string>("SerializedPayload");
 4165        builder.HasIndex(x => x.Timestamp).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExe
 4166        builder.HasIndex(x => x.Sequence).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExec
 4167        builder.HasIndex(x => new
 4168        {
 4169            x.Timestamp,
 4170            x.Sequence
 4171        }).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExecutionLogRecord.Timestamp)}_{nam
 4172        builder.HasIndex(x => x.ActivityInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Wo
 4173        builder.HasIndex(x => x.ParentActivityInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nam
 4174        builder.HasIndex(x => x.ActivityId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowEx
 4175        builder.HasIndex(x => x.ActivityType).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workflow
 4176        builder.HasIndex(x => x.ActivityTypeVersion).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(W
 4177        builder.HasIndex(x => new
 4178        {
 4179            x.ActivityType,
 4180            x.ActivityTypeVersion
 4181        }).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExecutionLogRecord.ActivityType)}_{
 4182        builder.HasIndex(x => x.ActivityName).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workflow
 4183        builder.HasIndex(x => x.EventName).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExe
 4184        builder.HasIndex(x => x.WorkflowDefinitionId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(
 4185        builder.HasIndex(x => x.WorkflowDefinitionVersionId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{
 4186        builder.HasIndex(x => x.WorkflowInstanceId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Wo
 4187        builder.HasIndex(x => x.WorkflowVersion).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(Workf
 4188        builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(WorkflowExecutionLogRecord)}_{nameof(WorkflowExec
 4189    }
 190
 191    public void Configure(EntityTypeBuilder<WorkflowInboxMessage> builder)
 192    {
 4193        builder.Ignore(x => x.Input);
 4194        builder.Ignore(x => x.BookmarkPayload);
 4195        builder.Property<string>("SerializedInput");
 4196        builder.Property<string>("SerializedBookmarkPayload");
 4197        builder.HasIndex(x => x.ActivityTypeName, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Activ
 4198        builder.HasIndex(x => x.Hash, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Hash)}");
 4199        builder.HasIndex(x => x.WorkflowInstanceId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Wor
 4200        builder.HasIndex(x => x.CorrelationId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Correlat
 4201        builder.HasIndex(x => x.ActivityInstanceId, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.Act
 4202        builder.HasIndex(x => x.CreatedAt, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.CreatedAt)}"
 4203        builder.HasIndex(x => x.ExpiresAt, $"IX_{nameof(WorkflowInboxMessage)}_{nameof(WorkflowInboxMessage.ExpiresAt)}"
 4204    }
 205}
Generated by: ReportGenerator 5.5.11.0
09/09/2026 - 11:01:42
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>)