| | | 1 | | using Elsa.Extensions; |
| | | 2 | | using Elsa.Workflows.Models; |
| | | 3 | | |
| | | 4 | | namespace Elsa.Workflows; |
| | | 5 | | |
| | | 6 | | public static class ActivityExecutionContextExtensions |
| | | 7 | | { |
| | | 8 | | extension(ActivityExecutionContext context) |
| | | 9 | | { |
| | | 10 | | public IDictionary<string, object> GetInputs() |
| | | 11 | | { |
| | 3429 | 12 | | return context.ActivityState!; |
| | | 13 | | } |
| | | 14 | | |
| | | 15 | | public IDictionary<string, object> GetOutputs() |
| | | 16 | | { |
| | 3429 | 17 | | var activity = context.Activity; |
| | 3429 | 18 | | var expressionExecutionContext = context.ExpressionExecutionContext; |
| | 3429 | 19 | | var activityDescriptor = context.ActivityDescriptor; |
| | 3429 | 20 | | var outputDescriptors = activityDescriptor.Outputs; |
| | | 21 | | |
| | 6371 | 22 | | var outputs = outputDescriptors.ToDictionary(x => x.Name, x => |
| | 3429 | 23 | | { |
| | 2942 | 24 | | if (x.IsSerializable == false) |
| | 842 | 25 | | return "(not serializable)"; |
| | 3429 | 26 | | |
| | 2100 | 27 | | var cachedValue = activity.GetOutput(expressionExecutionContext, x.Name); |
| | 3429 | 28 | | |
| | 2100 | 29 | | if (cachedValue != null) |
| | 1087 | 30 | | return cachedValue; |
| | 3429 | 31 | | |
| | 1013 | 32 | | if (x.ValueGetter(activity) is Output output && context.TryGet(output.MemoryBlockReference(), out var ou |
| | 178 | 33 | | return outputValue!; |
| | 3429 | 34 | | |
| | 835 | 35 | | return null!; |
| | 3429 | 36 | | }); |
| | | 37 | | |
| | 3429 | 38 | | return outputs; |
| | | 39 | | } |
| | | 40 | | } |
| | | 41 | | } |