| | | 1 | | using System.Linq.Expressions; |
| | | 2 | | using Elsa.Workflows.Management.Entities; |
| | | 3 | | using Microsoft.EntityFrameworkCore; |
| | | 4 | | using Microsoft.EntityFrameworkCore.Metadata.Builders; |
| | | 5 | | |
| | | 6 | | namespace Elsa.Persistence.EFCore.Modules.Management; |
| | | 7 | | |
| | | 8 | | internal class Configurations : IEntityTypeConfiguration<WorkflowDefinition>, IEntityTypeConfiguration<WorkflowInstance> |
| | | 9 | | { |
| | 2 | 10 | | private static Expression<Func<Version?, string?>> VersionToStringConverter => v => v != null ? v.ToString() : null; |
| | 2 | 11 | | private static Expression<Func<string?, Version?>> StringToVersionConverter => v => v != null ? Version.Parse(v) : n |
| | | 12 | | |
| | | 13 | | public void Configure(EntityTypeBuilder<WorkflowDefinition> builder) |
| | | 14 | | { |
| | 2 | 15 | | builder.Ignore(x => x.Variables); |
| | 2 | 16 | | builder.Ignore(x => x.Inputs); |
| | 2 | 17 | | builder.Ignore(x => x.Outputs); |
| | 2 | 18 | | builder.Ignore(x => x.Outcomes); |
| | 2 | 19 | | builder.Ignore(x => x.CustomProperties); |
| | 2 | 20 | | builder.Ignore(x => x.Options); |
| | 2 | 21 | | builder.Property<string>("Data"); |
| | 2 | 22 | | builder.Property<bool?>("UsableAsActivity"); |
| | 2 | 23 | | builder.Property(x => x.ToolVersion).HasConversion(VersionToStringConverter, StringToVersionConverter); |
| | 2 | 24 | | builder.HasIndex(x => new {x.DefinitionId, x.Version}).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof |
| | 2 | 25 | | builder.HasIndex(x => x.Version).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof(WorkflowDefinition.Ve |
| | 2 | 26 | | builder.HasIndex(x => x.Name).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof(WorkflowDefinition.Name) |
| | 2 | 27 | | builder.HasIndex(x => x.IsLatest).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof(WorkflowDefinition.I |
| | 2 | 28 | | builder.HasIndex(x => x.IsPublished).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof(WorkflowDefinitio |
| | 2 | 29 | | builder.HasIndex(x => x.IsSystem).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof(WorkflowDefinition.I |
| | 2 | 30 | | builder.HasIndex("UsableAsActivity").HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_UsableAsActivity"); |
| | 2 | 31 | | builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(WorkflowDefinition)}_{nameof(WorkflowDefinition.T |
| | 2 | 32 | | } |
| | | 33 | | |
| | | 34 | | public void Configure(EntityTypeBuilder<WorkflowInstance> builder) |
| | | 35 | | { |
| | 2 | 36 | | builder.Ignore(x => x.WorkflowState); |
| | 2 | 37 | | builder.Property<string>("Data"); |
| | 2 | 38 | | builder.Property<string>("DataCompressionAlgorithm"); |
| | 2 | 39 | | builder.Property(x => x.Status).HasConversion<string>(); |
| | 2 | 40 | | builder.Property(x => x.SubStatus).HasConversion<string>(); |
| | 2 | 41 | | builder.HasIndex(x => new { x.Status, x.SubStatus, x.DefinitionId, x.Version }).HasDatabaseName($"IX_{nameof(Wor |
| | 2 | 42 | | builder.HasIndex(x => new { x.Status, x.SubStatus }).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(Wor |
| | 2 | 43 | | builder.HasIndex(x => new { x.Status, x.DefinitionId }).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof( |
| | 2 | 44 | | builder.HasIndex(x => new { x.SubStatus, x.DefinitionId }).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{name |
| | 2 | 45 | | builder.HasIndex(x => new { x.IsExecuting }).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowIns |
| | 2 | 46 | | builder.HasIndex(x => x.DefinitionId).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.D |
| | 2 | 47 | | builder.HasIndex(x => x.Status).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.Status) |
| | 2 | 48 | | builder.HasIndex(x => x.SubStatus).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.SubS |
| | 2 | 49 | | builder.HasIndex(x => x.CorrelationId).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance. |
| | 2 | 50 | | builder.HasIndex(x => x.Name).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.Name)}"); |
| | 2 | 51 | | builder.HasIndex(x => x.CreatedAt).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.Crea |
| | 2 | 52 | | builder.HasIndex(x => x.UpdatedAt).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.Upda |
| | 2 | 53 | | builder.HasIndex(x => x.FinishedAt).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.Fin |
| | 2 | 54 | | builder.HasIndex(x => x.IsSystem).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.IsSys |
| | 2 | 55 | | builder.HasIndex(x => x.TenantId).HasDatabaseName($"IX_{nameof(WorkflowInstance)}_{nameof(WorkflowInstance.Tenan |
| | 2 | 56 | | } |
| | | 57 | | } |