| | | 1 | | using Elsa.Workflows.Models; |
| | | 2 | | using Elsa.Workflows.Options; |
| | | 3 | | |
| | | 4 | | namespace Elsa.Workflows; |
| | | 5 | | |
| | | 6 | | /// <inheritdoc /> |
| | | 7 | | public class WorkflowExecutionContextSchedulerStrategy : IWorkflowExecutionContextSchedulerStrategy |
| | | 8 | | { |
| | | 9 | | /// <inheritdoc /> |
| | | 10 | | public ActivityWorkItem Schedule(WorkflowExecutionContext context, ActivityNode activityNode, ActivityExecutionConte |
| | | 11 | | { |
| | | 12 | | // Validate that the specified activity is part of the workflow. |
| | 2924 | 13 | | if (!context.NodeActivityLookup.ContainsKey(activityNode.Activity)) |
| | 0 | 14 | | throw new InvalidOperationException("The specified activity is not part of the workflow."); |
| | | 15 | | |
| | 2924 | 16 | | var scheduler = context.Scheduler; |
| | | 17 | | |
| | 2924 | 18 | | if (options?.PreventDuplicateScheduling == true) |
| | | 19 | | { |
| | | 20 | | // Check if the activity is already scheduled for the specified owner. |
| | 0 | 21 | | var existingWorkItem = scheduler.Find(x => x.Activity.NodeId == activityNode.NodeId && x.Owner == owner); |
| | | 22 | | |
| | 0 | 23 | | if (existingWorkItem != null) |
| | 0 | 24 | | return existingWorkItem; |
| | | 25 | | } |
| | | 26 | | |
| | 2924 | 27 | | var activity = activityNode.Activity; |
| | 2924 | 28 | | var tag = options?.Tag; |
| | | 29 | | |
| | | 30 | | // Use explicit SchedulingActivityExecutionId from options, or fall back to owner context. |
| | 2924 | 31 | | var schedulingActivityExecutionId = options?.SchedulingActivityExecutionId ?? owner.Id; |
| | | 32 | | |
| | | 33 | | // Use explicit SchedulingWorkflowInstanceId from options, if any. |
| | 2924 | 34 | | var schedulingWorkflowInstanceId = options?.SchedulingWorkflowInstanceId; |
| | | 35 | | |
| | 2924 | 36 | | var workItem = new ActivityWorkItem( |
| | 2924 | 37 | | activity, |
| | 2924 | 38 | | owner, |
| | 2924 | 39 | | tag, |
| | 2924 | 40 | | options?.Variables, |
| | 2924 | 41 | | options?.ExistingActivityExecutionContext, |
| | 2924 | 42 | | options?.Input, |
| | 2924 | 43 | | schedulingActivityExecutionId, |
| | 2924 | 44 | | schedulingWorkflowInstanceId); |
| | 2924 | 45 | | var completionCallback = options?.CompletionCallback; |
| | | 46 | | |
| | 2924 | 47 | | context.AddCompletionCallback(owner, activityNode, completionCallback, tag); |
| | 2924 | 48 | | scheduler.Schedule(workItem); |
| | | 49 | | |
| | 2924 | 50 | | return workItem; |
| | | 51 | | } |
| | | 52 | | } |