feat: allow yaml_utils to insert conditions on a trigger (#468)

Author: elevatebart

.github/workflows/test.yml

@@ -7,7 +7,7 @@ on: push
 
 jobs:
   npm:
-    name: Publish to Npm
+    name: Test the package
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4

package-lock.json

@@ -19,7 +19,15 @@
       },
       "require": "./dist/kestra-ui.umd.cjs"
     },
-    "./style.css": "./dist/kestra-ui.css",
+    "./flow-yaml-utils": {
+      "types": "./dist/utils/FlowYamlUtils.d.ts",
+      "import": {
+        "types": "./dist/utils/FlowYamlUtils.d.ts",
+        "default": "./dist/kestra-flowyamlutils.es.js"
+      },
+      "require": "./dist/kestra-flowyamlutils.cjs.js"
+    },
+    "./style.css": "./dist/ui-libs.css",
     "./src/*": "./src/*"
   },
   "scripts": {

package.json

@@ -116,7 +116,7 @@
     import {CLUSTER_PREFIX, EVENTS} from "../../utils/constants"
     import Utils from "../../utils/Utils"
     import VueFlowUtils, {type FlowGraph} from "../../utils/VueFlowUtils";
-    import {YamlUtils} from "../../utils/YamlUtils";
+    import {isParentChildrenRelation, swapBlocks} from "../../utils/FlowYamlUtils";
     import {useScreenshot} from "./export/useScreenshot";
 
     const props = defineProps({
@@ -295,7 +295,12 @@
                 try {
                     if(props.source){
                         emit("swapped-task", {
-                            newSource: YamlUtils.swapTasks(props.source, Utils.afterLastDot(taskNode1.id) ?? "", Utils.afterLastDot(taskNode2.id) ?? ""),
+                            newSource: swapBlocks({
+                                source:props.source, 
+                                section: "tasks", 
+                                key1: Utils.afterLastDot(taskNode1.id) ?? "",
+                                key2: Utils.afterLastDot(taskNode2.id) ?? ""
+                            }),
                             swappedTasks: [taskNode1.id, taskNode2.id]
                         })
                     }
@@ -354,7 +359,15 @@
             return "toomuchtaskerror";
         }
         try {
-            if (tasksMeet.length === 1 && props.source && YamlUtils.isParentChildrenRelation(props.source, Utils.afterLastDot(tasksMeet[0]) ?? "", Utils.afterLastDot(node.id) ?? "")) {
+            if (tasksMeet.length === 1 && props.source 
+                && isParentChildrenRelation({
+                    source:props.source, 
+                    sections:["tasks", "triggers"], 
+                    key1: Utils.afterLastDot(tasksMeet[0]) ?? "", 
+                    key2: Utils.afterLastDot(node.id) ?? "",
+                    keyName: "id"
+                }) 
+            ) {
                 return "parentchildrenerror";
             }
         } catch {

src/components/topology/Topology.vue

@@ -1,4 +1,4 @@
-export {YamlUtils} from "./utils/YamlUtils";
+export {YamlUtils} from "./utils/YamlUtilsLegacy";
 export {cssVariable} from "./utils/global";
 export {default as State, STATES} from "./utils/state";
 export {default as Utils} from "./utils/Utils";
@@ -8,7 +8,7 @@ export * from "./utils/constants";
 export * from "./utils/url";
 export * from "./utils/plugins";
 
-export type {YamlElement} from "./utils/YamlUtils";
+export type {YamlElement} from "./utils/YamlUtilsLegacy";
 export type {Plugin} from "./utils/plugins";
 export type {JSONSchema, JSONProperty} from "./utils/schemaUtils";