Feature/cancel dispatched workflows (#5136)

* Made cancel API call dispatch the request

* Added ParentWorkflowInstanceId

* Recursively cancel child workflows

* Made single workflow cancellation include child workflows

* Updated migrations

* Processed comments

src/modules/Elsa.Common/Extensions/EnumerableExtensions.cs

@@ -58,4 +58,5 @@ public static Page<T> Paginate<T>(this IEnumerable<T> enumerable, PageArgs? page
     /// <typeparam name="T">The type of the items in the lists.</typeparam>
     /// <returns>True if the lists are equal, otherwise false.</returns>
     public static bool IsEqualTo<T>(this IEnumerable<T> list1, IEnumerable<T> list2) => list1.OrderBy(g => g).SequenceEqual(list2.OrderBy(g => g));
+
 }

src/modules/Elsa.Dapper/Modules/Management/Stores/DapperWorkflowInstanceStore.cs

@@ -163,6 +163,7 @@ private void ApplyFilter(ParameterizedQuery query, WorkflowInstanceFilter filter
             .In(nameof(WorkflowInstance.DefinitionId), filter.DefinitionIds)
             .Is(nameof(WorkflowInstance.DefinitionVersionId), filter.DefinitionVersionId)
             .In(nameof(WorkflowInstance.DefinitionVersionId), filter.DefinitionVersionIds)
+            .In(nameof(WorkflowInstance.ParentWorkflowInstanceId), filter.ParentWorkflowInstanceIds)
             .Is(nameof(WorkflowInstance.Status), filter.WorkflowStatus?.ToString())
             .Is(nameof(WorkflowInstance.SubStatus), filter.WorkflowSubStatus?.ToString())
             .Is(nameof(WorkflowInstance.Name), filter.Version)

src/modules/Elsa.Elasticsearch/Modules/Management/WorkflowInstanceStore.cs

@@ -146,6 +146,7 @@ private static QueryDescriptor<WorkflowInstance> Filter(QueryDescriptor<Workflow
         // TODO: filter by IDs
         // TODO: filter by DefinitionIDs
         // TODO: filter by DefinitionVersionIDs
+        // TODO: filter by ParentWorkflowInstanceIds
         // TODO: filter by CorrelationIDs
         // TODO: filter by WorkflowStatuses
         // TODO: filter by WorkflowSubStatuses

src/modules/Elsa.EntityFrameworkCore.MySql/Migrations/Management/20240312145152_V3_1.cs → src/modules/Elsa.EntityFrameworkCore.MySql/Migrations/Management/20240326133145_V3_1.cs

@@ -26,6 +26,14 @@ protected override void Up(MigrationBuilder migrationBuilder)
                 nullable: false,
                 defaultValue: false);
 
+            migrationBuilder.AddColumn<string>(
+                name: "ParentWorkflowInstanceId",
+                schema: "Elsa",
+                table: "WorkflowInstances",
+                type: "longtext",
+                nullable: true)
+                .Annotation("MySql:CharSet", "utf8mb4");
+
             migrationBuilder.AddColumn<bool>(
                 name: "IsSystem",
                 schema: "Elsa",
@@ -70,6 +78,11 @@ protected override void Down(MigrationBuilder migrationBuilder)
                 schema: "Elsa",
                 table: "WorkflowInstances");
 
+            migrationBuilder.DropColumn(
+                name: "ParentWorkflowInstanceId",
+                schema: "Elsa",
+                table: "WorkflowInstances");
+
             migrationBuilder.DropColumn(
                 name: "IsSystem",
                 schema: "Elsa",

src/modules/Elsa.EntityFrameworkCore.MySql/Migrations/Management/ManagementElsaDbContextModelSnapshot.cs

@@ -142,6 +142,9 @@ protected override void BuildModel(ModelBuilder modelBuilder)
                     b.Property<string>("Name")
                         .HasColumnType("varchar(255)");
 
+                    b.Property<string>("ParentWorkflowInstanceId")
+                        .HasColumnType("longtext");
+
                     b.Property<string>("Status")
                         .IsRequired()
                         .HasColumnType("varchar(255)");