Add initialization tasks and procedure finding

functions

src/orchestration/initialize/initialize-tasks.ts → src/orchestration/initialize/create-tasks.ts

@@ -1,7 +1,7 @@
 /**
  * @author WMXPY
  * @namespace Orchestration_Initialize
- * @description Initialize Tasks
+ * @description Create Tasks
  */
 
 import { Optional } from "@sudoo/optional";

src/orchestration/initialize/recursive-add-task.ts

@@ -0,0 +1,32 @@
+/**
+ * @author WMXPY
+ * @namespace Orchestration_Initialize
+ * @description Recursive Add Task
+ */
+
+import { PubProcedureConfiguration } from "../../procedure/definition/configuration";
+import { PubTask } from "../../task/task";
+import { PubCachedWorkflowConfiguration } from "../../workflow/cache/configuration";
+import { findNextProcedures } from "../procedure/find-next-procedure";
+
+export const initializeRecursiveAddTask = (
+    configuration: PubCachedWorkflowConfiguration,
+    currentProcedure: PubProcedureConfiguration,
+    tasks: PubTask[],
+): PubTask[] => {
+
+    const nextProcedures: PubProcedureConfiguration[] = findNextProcedures(
+        currentProcedure,
+        configuration,
+    );
+
+    const nextTasks: PubTask[] = nextProcedures.map((procedure: PubProcedureConfiguration) => {
+
+        return PubTask.fromIdentifier(procedure.identifier);
+    });
+
+    return [
+        ...tasks,
+        ...nextTasks,
+    ];
+};

src/orchestration/procedure/find-next-procedure.ts

@@ -0,0 +1,38 @@
+/**
+ * @author WMXPY
+ * @namespace Orchestration_Procedure
+ * @description Find Next Procedure
+ */
+
+import { PUB_CONNECTION_WAYPOINT_TYPE } from "../../connection/definition/configuration";
+import { PubProcedureConfiguration } from "../../procedure/definition/configuration";
+import { PubCachedWorkflowConfiguration } from "../../workflow/cache/configuration";
+
+export const findNextProcedures = (
+    currentProcedure: PubProcedureConfiguration,
+    configuration: PubCachedWorkflowConfiguration,
+): PubProcedureConfiguration[] => {
+
+    const triggerConnections = configuration.configuration.connections
+        .filter((connection) => {
+
+            return connection.triggerProcedureIdentifier ===
+                currentProcedure.identifier
+                && connection.triggerProcedureWaypointType ===
+                PUB_CONNECTION_WAYPOINT_TYPE.PROCEDURE_SELF_END;
+        });
+
+    const nextProcedures: PubProcedureConfiguration[] = triggerConnections
+        .filter((connection) => {
+            return connection.nextProcedureWaypointType ===
+                PUB_CONNECTION_WAYPOINT_TYPE.PROCEDURE_SELF_START;
+        })
+        .map((connection) => {
+            return configuration.getProcedureByIdentifier(connection.nextProcedureIdentifier);
+        })
+        .filter((procedure): procedure is PubProcedureConfiguration => {
+            return Boolean(procedure);
+        });
+
+    return nextProcedures;
+};

src/procedure/definition/configuration.ts

@@ -19,7 +19,7 @@ export enum PUB_PROCEDURE_TYPE {
     MAP = "MAP",
 }
 
-export type PubProcedureConfiguration<T extends PUB_PROCEDURE_TYPE> = {
+export type PubProcedureConfiguration<T extends PUB_PROCEDURE_TYPE = PUB_PROCEDURE_TYPE> = {
 
     readonly identifier: string;
     readonly type: T;