vorbereitung für pipe binding

src/functions/codeEditor.js

@@ -42,13 +42,13 @@ export const codeEditor = (instance) => {
     let editorValues;
     if (filterToCode.type.includes("Sender"))
       editorValues = {
-        doc: "// publisher.js\nconst amqp = require('amqplib/callback_api');\n\nconst rabbitmqUrl = 'amqp://mquser:mqpass@rabbit:5672';\n\namqp.connect(rabbitmqUrl, (error0, connection) => {\n    if (error0) {\n        throw error0;\n    }\n    connection.createChannel((error1, channel) => {\n        if (error1) {\n            throw error1;\n        }\n\n        const queue = 'hello';\n\n        channel.assertQueue(queue, {\n            durable: false\n        });\n\n        const sendMessage = () => {\n            const msg = 'Hello World! ' + new Date().toISOString();\n            channel.sendToQueue(queue, Buffer.from(msg));\n            console.log(\" [x] Sent '%s'\", msg);\n        };\n\n        setInterval(sendMessage, 1000);\n    });\n});\n",
+        doc: "// publisher.js\nconst amqp = require('amqplib/callback_api');\n\nconst rabbitmqUrl = 'amqp://mquser:mqpass@rabbit:5672';\n\namqp.connect(rabbitmqUrl, (error0, connection) => {\n    if (error0) {\n        throw error0;\n    }\n    connection.createChannel((error1, channel) => {\n        if (error1) {\n            throw error1;\n        }\n\n        // DO NOT CHANGE \n        const queue = process.env.QUEUE_NAME\n\n        channel.assertQueue(queue, {\n            durable: false\n        });\n\n        const sendMessage = () => {\n            const msg = 'Hello World! ' + new Date().toISOString();\n            channel.sendToQueue(queue, Buffer.from(msg));\n            console.log(\" [x] Sent '%s'\", msg);\n        };\n\n        setInterval(sendMessage, 1000);\n    });\n});\n",
         extensions: [basicSetup, javascript()],
         parent: editorContainer,
       };
     else if (filterToCode.type.includes("Receiver")) {
       editorValues = {
-        doc: "// consumer.js\nconst amqp = require('amqplib/callback_api');\n\nconst rabbitmqUrl = 'amqp://mquser:mqpass@rabbit:5672';\n\namqp.connect(rabbitmqUrl, (error0, connection) => {\n\tif (error0) {\n\t\tthrow error0;\n\t}\n\tconnection.createChannel((error1, channel) => {\n\t\tif (error1) {\n\t\t\tthrow error1;\n\t\t}\n\n\t\tconst queue = 'hello';\n\n\t\tchannel.assertQueue(queue, {\n\t\t\tdurable: false\n\t\t});\n\n\t\tconsole.log(\" [*] Waiting for messages in %s. To exit press CTRL+C\", queue);\n\n\t\t// Funktion, um eine Nachricht aus der Queue zu konsumieren\n\t\tconst consumeMessage = () => {\n\t\t\tchannel.get(queue, { noAck: false }, (error, msg) => {\n\t\t\t\tif (error) {\n\t\t\t\t\tthrow error;\n\t\t\t\t}\n\t\t\t\tif (msg) {\n\t\t\t\t\tconsole.log(\" [x] Received '%s'\", msg.content.toString());\n\t\t\t\t\t// Nachricht bestätigen (acknowledge)\n\t\t\t\t\tchannel.ack(msg);\n\t\t\t\t} else {\n\t\t\t\t\tconsole.log(\" [x] No message received at this interval.\");\n\t\t\t\t}\n\t\t\t});\n\t\t};\n\n\t\t// Setze ein Intervall von 3 Sekunden\n\t\tsetInterval(consumeMessage, 3000);\n\t});\n});\n",
+        doc: "// consumer.js\nconst amqp = require('amqplib/callback_api');\n\nconst rabbitmqUrl = 'amqp://mquser:mqpass@rabbit:5672';\n\namqp.connect(rabbitmqUrl, (error0, connection) => {\n\tif (error0) {\n\t\tthrow error0;\n\t}\n\tconnection.createChannel((error1, channel) => {\n\t\tif (error1) {\n\t\t\tthrow error1;\n\t\t}\n\n\t\t// DO NOT CHANGE \n        const queue = process.env.QUEUE_NAME\n\n\t\tchannel.assertQueue(queue, {\n\t\t\tdurable: false\n\t\t});\n\n\t\tconsole.log(\" [*] Waiting for messages in %s. To exit press CTRL+C\", queue);\n\n\t\t// Funktion, um eine Nachricht aus der Queue zu konsumieren\n\t\tconst consumeMessage = () => {\n\t\t\tchannel.get(queue, { noAck: false }, (error, msg) => {\n\t\t\t\tif (error) {\n\t\t\t\t\tthrow error;\n\t\t\t\t}\n\t\t\t\tif (msg) {\n\t\t\t\t\tconsole.log(\" [x] Received '%s'\", msg.content.toString());\n\t\t\t\t\t// Nachricht bestätigen (acknowledge)\n\t\t\t\t\tchannel.ack(msg);\n\t\t\t\t} else {\n\t\t\t\t\tconsole.log(\" [x] No message received at this interval.\");\n\t\t\t\t}\n\t\t\t});\n\t\t};\n\n\t\t// Setze ein Intervall von 3 Sekunden\n\t\tsetInterval(consumeMessage, 3000);\n\t});\n});\n",
         extensions: [basicSetup, javascript()],
         parent: editorContainer,
       };
@@ -95,6 +95,7 @@ const handleSubmit = (node, code) => {
       .innerHTML.split("\n")[1],
     id: window.selectedFilter,
     code: code,
+    pipe: "",
     isDeployed: false,
     isPaused: false,
     isScaled: "",

src/functions/duplication.js

@@ -55,7 +55,7 @@ export const duplicateFilter = (instance) => {
 };
 
 export const extendPipe = () => {
-  let pipeName = prompt("Bitte geben Sie einen Pipe Namen ein:");
+  let newPipeName = prompt("Bitte geben Sie einen Pipe Namen ein:");
   const pipeToName = document.getElementById(window.selectedPipe);
   if (pipeToName) {
     var textIndex = pipeToName.innerHTML.indexOf("Queue");
@@ -70,9 +70,10 @@ export const extendPipe = () => {
       );
       var afterQueue = pipeToName.innerHTML.slice(textIndex + "Queue".length);
 
-      var newContent = beforeQueue + `<br> "${pipeName}"` + afterQueue;
+      var newContent = beforeQueue + `<br> "${newPipeName}"` + afterQueue;
 
       pipeToName.innerHTML = newContent;
     }
+    appState.addPipe(pipeToName.id, newPipeName);
   }
 };

src/main.js

@@ -33,6 +33,11 @@ function App() {
       if (!isConnectionAllowed(source, target)) {
         return false;
       }
+      if (source.getAttribute("class").includes("Filter")) {
+        appState.addConnection(source.id, target.id);
+      } else {
+        appState.addConnection(target.id, source.id);
+      }
       return true;
     });