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