Support for new pipeline format

Author: phpp28

src/main/resources/static/js/pages/editor/Editor.js

@@ -5,7 +5,6 @@ import {
   createSource,
   createWidget,
   loadSources,
-  saveSources,
 } from "./utils/editorActions.js";
 import { debounce } from "../../shared/modules/utils.js";
 import {
@@ -30,7 +29,7 @@ export default class Editor {
     this.initGrid();
 
     // Load existing data
-    loadSources(config.sources || []);
+    loadSources(config.sources || [], config.generators || []);
     state.grid.load(config.widgets || []);
 
     // Replace whitespaces in the id with dashes
@@ -133,7 +132,8 @@ export default class Editor {
     const pipelines = await getPipelines();
     const config = {
       id: id,
-      sources: saveSources(),
+      sources: state.sources,
+      generators: state.generators,
       widgets: state.grid.save(false),
     };
 

src/main/resources/static/js/pages/editor/controller/SourceController.js

@@ -14,7 +14,7 @@ export default class SourceController {
     this.item = item;
   }
 
-  init() {
+  init(generators) {
     const buttons = this.root.querySelectorAll("button");
     const options = this.root.querySelector(".dv-dropdown-menu");
     const body = this.root.querySelector(".dv-source-card-body");
@@ -26,10 +26,13 @@ export default class SourceController {
     );
 
     // Load existing generators
-    for (const config of this.item.createsGenerators) {
+    for (const config of [
+      ...(this.item.createsGenerators || []),
+      ...generators,
+    ]) {
       this.appendGenerator(body, config);
     }
-    this.item.createsGenerators = [];
+    delete this.item.createsGenerators;
 
     // Append available generator options
     Object.values(configs).forEach((Generator) => {

src/main/resources/static/js/pages/editor/utils/editorActions.js

@@ -4,30 +4,17 @@ import WidgetController from "../controller/WidgetController.js";
 import SourceController from "../controller/SourceController.js";
 import GeneratorController from "../controller/GeneratorController.js";
 
-export function loadSources(configs) {
+export function loadSources(sources, generators) {
   const container = document.querySelector(".dv-sources-container");
 
-  for (const config of configs) {
+  for (const config of sources) {
     const controller = createSource(config);
 
     container.prepend(controller.root);
-    controller.init();
+    controller.init(generators);
   }
 }
 
-export function saveSources() {
-  const sources = structuredClone(state.sources);
-
-  for (const generator of state.generators) {
-    const { source: id, ...rest } = generator;
-    const source = sources.find((item) => item.id === id);
-
-    source.createsGenerators.push(rest);
-  }
-
-  return sources;
-}
-
 export function createSource(config) {
   const source = deepClone(config);
   source.id = source.id || randomId("Source");