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

Add GoBackResult + sample

Browse source
This commit is contained in:
Sipke Schoorstra 2020-11-03 12:14:25 +01:00
parent deb08deb04
commit 70d3569343
7 changed files with 145 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
Samples.sln
View file

@ -114,6 +114,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Samples.ProgrammaticCo
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Samples.DeclarativeCompositeActivitiesConsole", "src\samples\Elsa.Samples.DeclarativeCompositeActivitiesConsole\Elsa.Samples.DeclarativeCompositeActivitiesConsole.csproj", "{E422689B-9F82-45B6-BE14-62B4EEF43B57}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Samples.GoBackConsole", "src\samples\Elsa.Samples.GoBackConsole\Elsa.Samples.GoBackConsole.csproj", "{F4454030-8295-4575-A54C-D816235173C5}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
@ -273,6 +275,10 @@ Global
{E422689B-9F82-45B6-BE14-62B4EEF43B57}.Debug|Any CPU.Build.0 = Debug|Any CPU
{E422689B-9F82-45B6-BE14-62B4EEF43B57}.Release|Any CPU.ActiveCfg = Release|Any CPU
{E422689B-9F82-45B6-BE14-62B4EEF43B57}.Release|Any CPU.Build.0 = Release|Any CPU
{F4454030-8295-4575-A54C-D816235173C5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{F4454030-8295-4575-A54C-D816235173C5}.Debug|Any CPU.Build.0 = Debug|Any CPU
{F4454030-8295-4575-A54C-D816235173C5}.Release|Any CPU.ActiveCfg = Release|Any CPU
{F4454030-8295-4575-A54C-D816235173C5}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
@ -326,6 +332,7 @@ Global
{1E5E1669-AEC9-4DA9-9A3D-3D405101A246} = {5E5E1E84-DDBC-40D6-B891-0D563A15A44A}
{CC39E9F8-72D2-4A5B-846B-E2764DFE1C19} = {5E5E1E84-DDBC-40D6-B891-0D563A15A44A}
{E422689B-9F82-45B6-BE14-62B4EEF43B57} = {5E5E1E84-DDBC-40D6-B891-0D563A15A44A}
{F4454030-8295-4575-A54C-D816235173C5} = {5E5E1E84-DDBC-40D6-B891-0D563A15A44A}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {8B0975FD-7050-48B0-88C5-48C33378E158}

13
src/core/Elsa.Core/Activities/ControlFlow/IfElse/IfElseBuilderExtensions.cs
View file

@ -7,16 +7,15 @@ namespace Elsa.Activities.ControlFlow
{
public static class IfElseBuilderExtensions
{
public static IActivityBuilder IfElse(this IBuilder builder, Action<ISetupActivity<IfElse>>? setup = default, Action<IActivityBuilder>? ifElse = default)
public static IActivityBuilder IfElse(this IBuilder builder, Action<ISetupActivity<IfElse>>? setup = default, Action<IActivityBuilder>? activity = default)
{
var activityBuilder = builder.Then(setup);
ifElse?.Invoke(activityBuilder);
activity?.Invoke(activityBuilder);
return activityBuilder;
}
public static IActivityBuilder IfElse(this IBuilder builder, Action<ISetupActivity<IfElse>>? setup = default, string? name = default) => builder.Then(setup).WithName(name);
public static IActivityBuilder IfElse(this IBuilder builder, Func<ActivityExecutionContext, bool> condition, string? name = default) => builder.IfElse(activity => activity.Set(x => x.Condition, condition), name);
public static IActivityBuilder IfElse(this IBuilder builder, Func<bool> condition, string? name = default) => builder.IfElse(activity => activity.Set(x => x.Condition, condition), name);
public static IActivityBuilder IfElse(this IBuilder builder, bool condition, string? name = default) => builder.IfElse(activity => activity.Set(x => x.Condition, condition), name);
public static IActivityBuilder IfElse(this IBuilder builder, Func<ActivityExecutionContext, bool> condition, Action<IActivityBuilder>? activity = default) => builder.IfElse(x => x.WithCondition(condition), activity);
public static IActivityBuilder IfElse(this IBuilder builder, Func<bool> condition, Action<IActivityBuilder>? activity = default) => builder.IfElse(x => x.WithCondition(condition), activity);
public static IActivityBuilder IfElse(this IBuilder builder, bool condition, Action<IActivityBuilder>? activity = default) => builder.IfElse(x => x.WithCondition(condition), activity);
}
}

32
src/core/Elsa.Core/ActivityResults/GoBackResult.cs Normal file
View file

@ -0,0 +1,32 @@
using System.Linq;
using Elsa.Services.Models;
namespace Elsa.ActivityResults
{
/// <summary>
/// Schedules the previously executed activity, effectively going back one step.
/// </summary>
public class GoBackResult : ActivityExecutionResult
{
private readonly int _steps;
private readonly object? _input;
public GoBackResult(object? input = default, int steps = 1)
{
_input = input;
_steps = steps;
}
protected override void Execute(ActivityExecutionContext activityExecutionContext)
{
var workflowExecutionContext = activityExecutionContext.WorkflowExecutionContext;
var previousEntry = workflowExecutionContext.ExecutionLog.Skip(_steps).FirstOrDefault();
if (previousEntry == null)
return;
var activityId = previousEntry.ActivityId;
workflowExecutionContext.ScheduleActivity(activityId, _input);
}
}
}

18
src/samples/Elsa.Samples.GoBackConsole/Activities/BrickWallActivity.cs Normal file
View file

@ -0,0 +1,18 @@
using Elsa.ActivityResults;
using Elsa.Services;
using Elsa.Services.Models;
namespace Elsa.Samples.GoBackConsole.Activities
{
/// <summary>
/// A custom activity that instructs the workflow runner to go back one step under certain conditions.
/// </summary>
public class BrickWallActivity : Activity
{
protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context)
{
// Tell the workflow that it hit a brick wall.
return new GoBackResult("Brick Wall");
}
}
}

17
src/samples/Elsa.Samples.GoBackConsole/Elsa.Samples.GoBackConsole.csproj Normal file
View file

@ -0,0 +1,17 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>netcoreapp3.1</TargetFramework>
<Nullable>enable</Nullable>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="3.1.9" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\..\core\Elsa\Elsa.csproj" />
</ItemGroup>
</Project>

35
src/samples/Elsa.Samples.GoBackConsole/Program.cs Normal file
View file

@ -0,0 +1,35 @@
using System.Threading.Tasks;
using Elsa.Samples.GoBackConsole.Activities;
using Elsa.Samples.GoBackConsole.Workflows;
using Elsa.Services;
using Microsoft.Extensions.DependencyInjection;
namespace Elsa.Samples.GoBackConsole
{
/// <summary>
/// Demonstrates a workflow with a While looping construct.
/// </summary>
static class Program
{
private static async Task Main()
{
// Create a service container with Elsa services.
var services = new ServiceCollection()
.AddElsa()
.AddConsoleActivities()
.AddActivity<BrickWallActivity>()
.AddWorkflow<WalkAroundWorkflow>()
.BuildServiceProvider();
// Run startup actions (not needed when registering Elsa with a Host).
var startupRunner = services.GetRequiredService<IStartupRunner>();
await startupRunner.StartupAsync();
// Get a workflow runner.
var workflowRunner = services.GetService<IWorkflowRunner>();
// Execute the workflow.
await workflowRunner.RunWorkflowAsync<WalkAroundWorkflow>();
}
}
}

30
src/samples/Elsa.Samples.GoBackConsole/Workflows/WalkAroundWorkflow.cs Normal file
View file

@ -0,0 +1,30 @@
using Elsa.Activities.Console;
using Elsa.Activities.ControlFlow;
using Elsa.Builders;
using Elsa.Samples.GoBackConsole.Activities;
using Elsa.Services.Models;
namespace Elsa.Samples.GoBackConsole.Workflows
{
public class WalkAroundWorkflow : IWorkflow
{
public void Build(IWorkflowBuilder workflow)
{
workflow
.WriteLine("Taking a stroll...")
.IfElse(context => (string?)context.Input == "Brick Wall",
ifElse =>
{
ifElse
.When(IfElse.False)
.WriteLine("Hitting a wall...")
.Then<BrickWallActivity>();
ifElse
.When(IfElse.True)
.WriteLine("Going around the wall...")
.WriteLine("Made it!");
});
}
}
}