From 1447265994d3e95aec29a4c2aa57349eaad7c13e Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Tue, 17 Nov 2020 20:12:42 +0100
Subject: [PATCH] Add query by version ID

---
 .../Extensions/WorkflowDefinitionManagerExtensions.cs    | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs b/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs
index 516158706..54ce96ecd 100644
--- a/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs
+++ b/src/core/Elsa.Core/Extensions/WorkflowDefinitionManagerExtensions.cs
@@ -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,