SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Allow access to parent activity state from child activity

Browse source
This commit is contained in:
Sipke Schoorstra 2020-12-05 11:15:27 +01:00
parent 0cdd46f8ca
commit e23cf08f81
4 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/core/Elsa.Abstractions/Models/WorkflowInstance.cs
View file

@ -15,6 +15,7 @@ namespace Elsa.Models
ExecutionLog = new List<ExecutionLogEntry>();
ScheduledActivities = new Stack<ScheduledActivity>();
PostScheduledActivities = new Stack<ScheduledActivity>();
ParentActivities = new Stack<string>();
}
public int Id { get; set; }
@ -40,5 +41,6 @@ namespace Elsa.Models
public WorkflowFault? Fault { get; set; }
public Stack<ScheduledActivity> ScheduledActivities { get; set; }
public Stack<ScheduledActivity> PostScheduledActivities { get; set; }
public Stack<string> ParentActivities { get; set; }
}
}

4
src/core/Elsa.Abstractions/Services/CompositeActivity.cs
View file

@ -20,10 +20,14 @@ namespace Elsa.Services
protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context)
{
if (IsScheduled)
{
context.WorkflowExecutionContext.WorkflowInstance.ParentActivities.Pop();
return Complete(context);
}
var compositeActivityBlueprint = (ICompositeActivityBlueprint)context.ActivityBlueprint;
var startActivities = compositeActivityBlueprint.GetStartActivities().Select(x => x.Id).ToList();
context.WorkflowExecutionContext.WorkflowInstance.ParentActivities.Push(Id);
context.WorkflowExecutionContext.PostScheduleActivity(Id);
IsScheduled = true;
return Schedule(startActivities, context.Input);

4
src/core/Elsa.Abstractions/Services/Models/ActivityBlueprintWrapper.cs
View file

@ -30,12 +30,12 @@ namespace Elsa.Services.Models
var workflowBlueprint = ActivityExecutionContext.WorkflowExecutionContext.WorkflowBlueprint;
var activityId = ActivityExecutionContext.ActivityBlueprint.Id;
// Computed property setters that depend on actual workflow state might fault, since we are using a fake activity execution context.
// Computed property setters that depend on actual workflow state might fault, since we might be using a fake activity execution context.
try
{
return await workflowBlueprint.GetActivityPropertyValue(activityId, propertyExpression, ActivityExecutionContext, cancellationToken);
}
catch (Exception e)
catch (Exception)
{
return default;
}

4
src/core/Elsa.Abstractions/Services/Models/ActivityExecutionContext.cs
View file

@ -42,6 +42,10 @@ namespace Elsa.Services.Models
set => ActivityInstance.Output = value;
}
public ActivityBlueprintWrapper<T> Parent<T>() where T : IActivity => new(new ActivityExecutionContext(ServiceScope, WorkflowExecutionContext,
WorkflowExecutionContext.GetActivityBlueprintById(WorkflowExecutionContext.WorkflowInstance.ParentActivities.Peek()),
null, CancellationToken));
public void SetVariable(string name, object? value) => WorkflowExecutionContext.SetVariable(name, value);
public object? GetVariable(string name) => WorkflowExecutionContext.GetVariable(name);
public T GetVariable<T>(string name) => WorkflowExecutionContext.GetVariable<T>(name);