| | | 1 | | using Elsa.Extensions; |
| | | 2 | | using Elsa.Workflows.Management.Entities; |
| | | 3 | | using Elsa.Workflows.Models; |
| | | 4 | | using Humanizer; |
| | | 5 | | |
| | | 6 | | namespace Elsa.Workflows.Management.Activities.WorkflowDefinitionActivity; |
| | | 7 | | |
| | | 8 | | public class WorkflowDefinitionActivityDescriptorFactory |
| | | 9 | | { |
| | | 10 | | public ActivityDescriptor CreateDescriptor(WorkflowDefinition definition, WorkflowDefinition? latestPublishedDefinit |
| | | 11 | | { |
| | 1715 | 12 | | var typeName = definition.Name!.Pascalize(); |
| | 1715 | 13 | | var tenantId = definition.TenantId; |
| | | 14 | | |
| | 1715 | 15 | | var ports = definition.Outcomes.Select(outcome => new Port |
| | 1715 | 16 | | { |
| | 1715 | 17 | | Name = outcome, |
| | 1715 | 18 | | DisplayName = outcome, |
| | 1715 | 19 | | IsBrowsable = true, |
| | 1715 | 20 | | Type = PortType.Flow |
| | 1715 | 21 | | }).ToList(); |
| | | 22 | | |
| | 1715 | 23 | | var rootPort = new Port |
| | 1715 | 24 | | { |
| | 1715 | 25 | | Name = nameof(WorkflowDefinitionActivity.Root), |
| | 1715 | 26 | | DisplayName = "Root", |
| | 1715 | 27 | | IsBrowsable = false, |
| | 1715 | 28 | | Type = PortType.Embedded |
| | 1715 | 29 | | }; |
| | | 30 | | |
| | 1715 | 31 | | ports.Insert(0, rootPort); |
| | | 32 | | |
| | 1715 | 33 | | return new() |
| | 1715 | 34 | | { |
| | 1715 | 35 | | TenantId = tenantId, |
| | 1715 | 36 | | TypeName = typeName, |
| | 1715 | 37 | | ClrType = typeof(WorkflowDefinitionActivity), |
| | 1715 | 38 | | Name = typeName, |
| | 1715 | 39 | | Version = definition.Version, |
| | 1715 | 40 | | DisplayName = definition.Name, |
| | 1715 | 41 | | Description = definition.Description, |
| | 1715 | 42 | | Category = definition.Options.ActivityCategory ?? "Workflows", |
| | 1715 | 43 | | Kind = ActivityKind.Action, |
| | 1715 | 44 | | IsBrowsable = definition.IsPublished, |
| | 1715 | 45 | | Inputs = DescribeInputs(definition).ToList(), |
| | 1715 | 46 | | Outputs = DescribeOutputs(definition).ToList(), |
| | 1715 | 47 | | Ports = ports, |
| | 1715 | 48 | | CustomProperties = |
| | 1715 | 49 | | { |
| | 1715 | 50 | | ["RootType"] = nameof(WorkflowDefinitionActivity), |
| | 1715 | 51 | | ["WorkflowDefinitionId"] = definition.DefinitionId, |
| | 1715 | 52 | | ["WorkflowDefinitionVersionId"] = definition.Id |
| | 1715 | 53 | | }, |
| | 1715 | 54 | | ConstructionProperties = new Dictionary<string, object> |
| | 1715 | 55 | | { |
| | 1715 | 56 | | [nameof(WorkflowDefinitionActivity.WorkflowDefinitionId)] = definition.DefinitionId, |
| | 1715 | 57 | | [nameof(WorkflowDefinitionActivity.WorkflowDefinitionVersionId)] = definition.Id, |
| | 1715 | 58 | | [nameof(WorkflowDefinitionActivity.Version)] = definition.Version, |
| | 1715 | 59 | | }, |
| | 1715 | 60 | | Constructor = context => |
| | 1715 | 61 | | { |
| | 710 | 62 | | var activityResult = context.CreateActivity<WorkflowDefinitionActivity>(); |
| | 710 | 63 | | var activity = activityResult.Activity; |
| | 710 | 64 | | activity.Type = typeName; |
| | 710 | 65 | | activity.WorkflowDefinitionId = definition.DefinitionId; |
| | 710 | 66 | | activity.WorkflowDefinitionVersionId = definition.Id; |
| | 710 | 67 | | activity.Version = definition.Version; |
| | 710 | 68 | | activity.LatestAvailablePublishedVersion = latestPublishedDefinition?.Version ?? definition.Version; |
| | 710 | 69 | | activity.LatestAvailablePublishedVersionId = latestPublishedDefinition?.Id ?? definition.Id; |
| | 1715 | 70 | | |
| | 710 | 71 | | return activityResult; |
| | 1715 | 72 | | } |
| | 1715 | 73 | | }; |
| | | 74 | | } |
| | | 75 | | |
| | | 76 | | private static IEnumerable<InputDescriptor> DescribeInputs(WorkflowDefinition definition) |
| | | 77 | | { |
| | 1715 | 78 | | var inputs = definition.Inputs.Select(inputDefinition => |
| | 1715 | 79 | | { |
| | 126 | 80 | | var nakedType = inputDefinition.Type; |
| | 126 | 81 | | var inputName = inputDefinition.Name; |
| | 126 | 82 | | var safeInputName = PropertyNameHelper.GetSafePropertyName(typeof(WorkflowDefinitionActivity), inputName); |
| | 1715 | 83 | | |
| | 126 | 84 | | return new InputDescriptor |
| | 126 | 85 | | { |
| | 126 | 86 | | Type = nakedType, |
| | 126 | 87 | | IsWrapped = true, |
| | 29 | 88 | | ValueGetter = activity => activity.SyntheticProperties.GetValueOrDefault(safeInputName), |
| | 0 | 89 | | ValueSetter = (activity, value) => activity.SyntheticProperties[safeInputName] = value!, |
| | 126 | 90 | | Name = safeInputName, |
| | 126 | 91 | | DisplayName = inputDefinition.DisplayName, |
| | 126 | 92 | | Description = inputDefinition.Description, |
| | 126 | 93 | | Category = inputDefinition.Category, |
| | 126 | 94 | | UIHint = inputDefinition.UIHint, |
| | 126 | 95 | | StorageDriverType = inputDefinition.StorageDriverType, |
| | 126 | 96 | | IsSynthetic = true |
| | 126 | 97 | | }; |
| | 1715 | 98 | | }); |
| | | 99 | | |
| | 3682 | 100 | | foreach (var input in inputs) |
| | 126 | 101 | | yield return input; |
| | 1715 | 102 | | } |
| | | 103 | | |
| | | 104 | | private static IEnumerable<OutputDescriptor> DescribeOutputs(WorkflowDefinition definition) |
| | | 105 | | { |
| | 1715 | 106 | | return definition.Outputs.Select(outputDefinition => |
| | 1715 | 107 | | { |
| | 378 | 108 | | var nakedType = outputDefinition.Type; |
| | 378 | 109 | | var outputName = outputDefinition.Name; |
| | 378 | 110 | | var safeOutputName = PropertyNameHelper.GetSafePropertyName(typeof(WorkflowDefinitionActivity), outputName); |
| | 1715 | 111 | | |
| | 378 | 112 | | return new OutputDescriptor |
| | 378 | 113 | | { |
| | 378 | 114 | | Type = nakedType, |
| | 9 | 115 | | ValueGetter = activity => activity.SyntheticProperties.GetValueOrDefault(safeOutputName), |
| | 0 | 116 | | ValueSetter = (activity, value) => activity.SyntheticProperties[safeOutputName] = value!, |
| | 378 | 117 | | Name = safeOutputName, |
| | 378 | 118 | | DisplayName = outputDefinition.DisplayName, |
| | 378 | 119 | | Description = outputDefinition.Description, |
| | 378 | 120 | | IsSynthetic = true |
| | 378 | 121 | | }; |
| | 1715 | 122 | | }); |
| | | 123 | | } |
| | | 124 | | } |