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

Add CorrelationIds query specification

Browse source
This commit is contained in:
Sipke Schoorstra 2021-07-23 16:18:17 +02:00
parent 8367fe0ef2
commit 641c6f9257
1 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
src/core/Elsa.Core/Persistence/Specifications/WorkflowInstances/CorrelationIdsSpecification.cs Normal file
View file

@ -0,0 +1,21 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using Elsa.Models;
namespace Elsa.Persistence.Specifications.WorkflowInstances
{
public class CorrelationIdsSpecification : Specification<WorkflowInstance>
{
public CorrelationIdsSpecification(string workflowDefinitionId, IEnumerable<string> correlationIds)
{
WorkflowDefinitionId = workflowDefinitionId;
CorrelationIds = correlationIds;
}
public string WorkflowDefinitionId { get; }
public IEnumerable<string> CorrelationIds { get; }
public override Expression<Func<WorkflowInstance, bool>> ToExpression() => workflowInstance => workflowInstance.DefinitionId == WorkflowDefinitionId && CorrelationIds.Contains(workflowInstance.CorrelationId);
}
}