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

Introduce NonPersistableAttribute to control what gets persisted in state

Browse source
This commit is contained in:
Sipke Schoorstra 2021-05-31 19:50:42 +02:00
parent 3eaefab72f
commit 79131e2dde
4 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/core/Elsa.Abstractions/Attributes/NonPersistableAttribute.cs Normal file
View file

@ -0,0 +1,9 @@
using System;
namespace Elsa.Attributes
{
[AttributeUsage(AttributeTargets.Property)]
public class NonPersistableAttribute : Attribute
{
}
}

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

@ -71,6 +71,10 @@ namespace Elsa.Services
if (value != null)
{
property.SetValue(activity, value);
if (property.GetCustomAttribute<NonPersistableAttribute>() is not null)
return;
activityExecutionContext.SetState(property.Name, value);
}
}

2
src/core/Elsa.Core/Activities/Primitives/Inline.cs
View file

@ -15,7 +15,7 @@ namespace Elsa.Activities.Primitives
public class Inline : Activity
{
public Inline() => Function = context => new ValueTask<IActivityExecutionResult>(Done());
[ActivityInput] public Func<ActivityExecutionContext, ValueTask<IActivityExecutionResult>> Function { get; set; }
[ActivityInput, NonPersistable] public Func<ActivityExecutionContext, ValueTask<IActivityExecutionResult>> Function { get; set; }
protected override ValueTask<IActivityExecutionResult> OnExecuteAsync(ActivityExecutionContext context) => Function(context);
}
}

7
src/core/Elsa.Core/Handlers/PersistActivityPropertyState.cs
View file

@ -17,17 +17,18 @@ namespace Elsa.Handlers
{
var activity = notification.Activity;
var activityType = activity.GetType();
var properties = activityType.GetProperties().Where(x => x.GetCustomAttribute<ActivityInputAttribute>() != null || x.GetCustomAttribute<ActivityOutputAttribute>() != null);
var properties = activityType.GetProperties()
.Where(x => (x.GetCustomAttribute<ActivityInputAttribute>() != null || x.GetCustomAttribute<ActivityOutputAttribute>() != null) && x.GetCustomAttribute<NonPersistableAttribute>() == null);
var activityExecutionContext = notification.ActivityExecutionContext;
foreach (var property in properties)
{
var value = property.GetValue(activity);
// TODO: Implement #898 (activity persistence providers).
activityExecutionContext.SetState(property.Name, value);
}
return Task.CompletedTask;
}
}