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

Update HttpEndpoint to not block when input is received

Browse source
This commit is contained in:
Sipke Schoorstra 2022-03-07 15:08:01 +01:00
parent 37843a7de4
commit 5b7bc894f0
1 changed files with 17 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/modules/Elsa.Modules.Http/Activities/HttpEndpoint.cs
View file

@ -2,6 +2,7 @@
using System.Linq;
using System.Net.Http;
using Elsa.Attributes;
using Elsa.Extensions;
using Elsa.Management.Models;
using Elsa.Models;
using Elsa.Modules.Http.Models;
@ -10,6 +11,8 @@ namespace Elsa.Modules.Http;
public class HttpEndpoint : Trigger
{
public const string InputKey = "HttpRequest";
[Input] public Input<string> Path { get; set; } = default!;
[Input(
@ -18,10 +21,22 @@ public class HttpEndpoint : Trigger
)]
public Input<ICollection<string>> SupportedMethods { get; set; } = new(new[] { HttpMethod.Get.Method });
[Output] public Output<HttpRequestModel>? Result { get; set; }
[Output] public Output<HttpRequestModel>? Request { get; set; }
protected override IEnumerable<object> GetTriggerData(TriggerIndexingContext context) => GetBookmarkData(context.ExpressionExecutionContext);
protected override void Execute(ActivityExecutionContext context) => context.SetBookmarks(GetBookmarkData(context.ExpressionExecutionContext));
protected override void Execute(ActivityExecutionContext context)
{
// If we did not receive external input, it means we are just now encountering this activity.
if (!context.TryGetInput<HttpRequestModel>(InputKey, out var request ))
{
// Create bookmarks for when we receive the expected HTTP request.
context.CreateBookmarks(GetBookmarkData(context.ExpressionExecutionContext));
return;
}
// Provide the received HTTP request as output.
context.Set(Request, request);
}
private IEnumerable<object> GetBookmarkData(ExpressionExecutionContext context)
{