Skip to content

Commit b9a269f

Browse files
committed
fix: Added outputsbody function
1 parent 589ce2a commit b9a269f

File tree

3 files changed

+24
-1
lines changed

3 files changed

+24
-1
lines changed

src/WorkflowEngine.Core/ExpressionEngineExtensions.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ public static IServiceCollection AddFunctions(this IServiceCollection services)
2020
services.RegisterScopedFunctionAlias<TriggerBodyFunction>("triggerBody");
2121
services.RegisterScopedFunctionAlias<TriggerOutputsFunction>("triggerOutputs");
2222
services.RegisterScopedFunctionAlias<OutputsFunction>("outputs");
23+
services.RegisterScopedFunctionAlias<OutputsBodyFunction>("outputsBody");
2324
services.RegisterScopedFunctionAlias<ItemsFunction>("items");
2425

2526

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
using ExpressionEngine;
2+
using ExpressionEngine.Functions.Base;
3+
using System.Threading.Tasks;
4+
5+
namespace WorkflowEngine.Core.Expressions
6+
{
7+
public class OutputsBodyFunction : IFunction
8+
{
9+
private readonly OutputsFunction _outputsFunction;
10+
11+
public OutputsBodyFunction(OutputsFunction outputsFunction)
12+
{
13+
_outputsFunction = outputsFunction;
14+
}
15+
public async ValueTask<ValueContainer> ExecuteFunction(params ValueContainer[] parameters)
16+
{
17+
var output = await _outputsFunction.ExecuteFunction(parameters);
18+
19+
return output?["body"];
20+
}
21+
}
22+
}

src/WorkflowEngine.Core/Expressions/OutputsFunction.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
using ExpressionEngine;
1+
using ExpressionEngine;
22
using ExpressionEngine.Functions.Base;
33
using Newtonsoft.Json.Linq;
44
using System.Threading.Tasks;

0 commit comments

Comments
 (0)