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

Comment out TriggerRequestHandler (temporary)

Browse source
This commit is contained in:
Sipke Schoorstra 2020-10-06 15:15:06 +02:00
parent 7e7e19e1e3
commit d8848f372a
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/activities/Elsa.Activities.Http/RequestHandlers/Handlers/TriggerRequestHandler.cs
View file

@ -47,24 +47,24 @@ namespace Elsa.Activities.Http.RequestHandlers.Handlers
var workflowsToStart = Filter(httpWorkflows, requestPath, method).ToList();
var suspendedWorkflows = await workflowInstanceStore.ListByBlockingActivityAsync<ReceiveHttpRequest>(cancellationToken: cancellationToken);
var workflowsToResume = Filter(suspendedWorkflows, requestPath, method).ToList();
//var workflowsToResume = Filter(suspendedWorkflows, requestPath, method).ToList();
if (!workflowsToStart.Any() && !workflowsToResume.Any())
return new NextResult();
await InvokeWorkflowsToStartAsync(workflowsToStart);
await InvokeWorkflowsToResumeAsync(workflowsToResume);
// if (!workflowsToStart.Any() && !workflowsToResume.Any())
// return new NextResult();
//
// await InvokeWorkflowsToStartAsync(workflowsToStart);
// await InvokeWorkflowsToResumeAsync(workflowsToResume);
return !httpContext.Items.ContainsKey(WorkflowHttpResult.Instance)
? (IRequestHandlerResult)new AcceptedResult()
: new EmptyResult();
}
private IEnumerable<(WorkflowInstance WorkflowInstance, ActivityInstanceRecord BlockingActivity)> Filter(
IEnumerable<(WorkflowInstance WorkflowInstance, ActivityInstanceRecord BlockingActivity)> items,
PathString path,
string method) =>
items.Where(x => IsMatch(x.BlockingActivity, path, method));
// private IEnumerable<(WorkflowInstance WorkflowInstance, ActivityInstanceRecord BlockingActivity)> Filter(
// IEnumerable<(WorkflowInstance WorkflowInstance, ActivityInstanceRecord BlockingActivity)> items,
// PathString path,
// string method) =>
// items.Where(x => IsMatch(x.BlockingActivity, path, method));
private IEnumerable<(Workflow Workflow, ReceiveHttpRequest Activity)> Filter(
IEnumerable<(Workflow Workflow, ReceiveHttpRequest Activity)> items,