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

Add query by version ID

Browse source
This commit is contained in:
Sipke Schoorstra 2020-11-17 20:12:42 +01:00
parent c193b28ba1
commit 1447265994
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs
View file

@ -12,6 +12,9 @@ namespace Elsa.Extensions
{
public static IQuery<WorkflowDefinition> QueryByIdAndVersion(this IWorkflowDefinitionManager manager, string workflowDefinitionId, VersionOptions versionOptions) =>
manager.Query<WorkflowDefinitionIndex>(x => x.WorkflowDefinitionId == workflowDefinitionId).WithVersion(versionOptions);
public static IQuery<WorkflowDefinition> QueryByVersionId(this IWorkflowDefinitionManager manager, string workflowDefinitionVersionId) =>
manager.Query<WorkflowDefinitionIndex>(x => x.WorkflowDefinitionVersionId == workflowDefinitionVersionId);
public static async Task<WorkflowDefinition?> GetAsync(
this IWorkflowDefinitionManager manager,
@ -19,6 +22,12 @@ namespace Elsa.Extensions
VersionOptions versionOptions,
CancellationToken cancellationToken = default) =>
await manager.QueryByIdAndVersion(workflowDefinitionId, versionOptions).FirstOrDefaultAsync();
public static async Task<WorkflowDefinition?> GetByVersionIdAsync(
this IWorkflowDefinitionManager manager,
string workflowDefinitionVersionId,
CancellationToken cancellationToken = default) =>
await manager.QueryByVersionId(workflowDefinitionVersionId).FirstOrDefaultAsync();
public static Task<IEnumerable<WorkflowInstance>> ListByStatusAsync(
this IWorkflowInstanceManager manager,