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

Add SetContextId activity

Browse source
This commit is contained in:
Sipke Schoorstra 2020-11-24 20:25:37 +01:00
parent d890c668cc
commit 4b85142bd1
3 changed files with 47 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/core/Elsa.Core/Activities/Primitives/SetContextId/SetContextId.cs Normal file
View file

@ -0,0 +1,26 @@
using Elsa.ActivityResults;
using Elsa.Attributes;
using Elsa.Services;
using Elsa.Services.Models;
// ReSharper disable once CheckNamespace
namespace Elsa.Activities.Primitives
{
[Activity(
DisplayName = "Set Context ID",
Description = "Set context ID on the workflow.",
Category = "Primitives",
Outcomes = new[] { OutcomeNames.Done }
)]
public class SetContextId : Activity
{
[ActivityProperty(Hint = "The context ID to set.")]
public string ContextId { get; set; } = default!;
protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context)
{
context.WorkflowExecutionContext.WorkflowInstance.ContextId = ContextId;
return Done();
}
}
}

19
src/core/Elsa.Core/Activities/Primitives/SetContextId/SetContextIdBuilderExtensions.cs Normal file
View file

@ -0,0 +1,19 @@
using System;
using System.Threading.Tasks;
using Elsa.Activities.Primitives;
using Elsa.Builders;
using Elsa.Services.Models;
// ReSharper disable once CheckNamespace
namespace Elsa.Activities.ControlFlow
{
public static class SetContextIdBuilderExtensions
{
public static IOutcomeBuilder SetContextId(this IBuilder builder, Action<ISetupActivity<SetContextId>> setup) => builder.Then(setup).When(OutcomeNames.Done);
public static IOutcomeBuilder SetContextId(this IBuilder builder, Func<ActivityExecutionContext, ValueTask<string>> value) => builder.SetContextId(activity => activity.Set(x => x.ContextId, value!));
public static IOutcomeBuilder SetContextId(this IBuilder builder, Func<ActivityExecutionContext, string> value) => builder.SetContextId(activity => activity.Set(x => x.ContextId, value!));
public static IOutcomeBuilder SetContextId(this IBuilder builder, Func<ValueTask<string>> value) => builder.SetContextId(activity => activity.Set(x => x.ContextId, value!));
public static IOutcomeBuilder SetContextId(this IBuilder builder, Func<string> value) => builder.SetContextId(activity => activity.Set(x => x.ContextId, value!));
public static IOutcomeBuilder SetContextId(this IBuilder builder, string value) => builder.SetContextId(activity => activity.Set(x => x.ContextId, value!));
}
}

3
src/core/Elsa.Core/Extensions/ElsaServiceCollectionExtensions.cs
View file

@ -149,11 +149,12 @@ namespace Microsoft.Extensions.DependencyInjection
.AddActivity<While>()
.AddActivity<Correlate>()
.AddActivity<SetVariable>()
.AddActivity<SetContextId>()
.AddActivity<ReceiveSignal>()
.AddTriggerProvider<ReceiveSignalTriggerProvider>()
.AddActivity<SendSignal>()
.AddScoped<ISignaler, Signaler>()
.AddActivity<Elsa.Activities.Workflows.RunWorkflow>()
.AddActivity<RunWorkflow>()
.AddTriggerProvider<RunWorkflowTriggerProvider>();
}
}