Skip to content
Snippets Groups Projects
Commit 6e8737fa authored by Robin Leber's avatar Robin Leber
Browse files

Queue Anpassung

parent 648d1e4f
No related branches found
No related tags found
No related merge requests found
...@@ -15,14 +15,14 @@ const severalEndpointsLeft = { ...@@ -15,14 +15,14 @@ const severalEndpointsLeft = {
anchor: ["LeftMiddle"], anchor: ["LeftMiddle"],
isTarget: true, isTarget: true,
connectionType: "flow", connectionType: "flow",
maxConnections: 3, maxConnections: 5,
}; };
const severalEndpointsRight = { const severalEndpointsRight = {
endpoint: ["Dot", { radius: 5 }], endpoint: ["Dot", { radius: 5 }],
anchor: ["RightMiddle"], anchor: ["RightMiddle"],
isSource: true, isSource: true,
connectionType: "flow", connectionType: "flow",
maxConnections: 3, maxConnections: 5,
}; };
export const createEndpoints = (instance, id, type) => { export const createEndpoints = (instance, id, type) => {
......
...@@ -9,16 +9,14 @@ export const getPipesForFilter = (instance) => { ...@@ -9,16 +9,14 @@ export const getPipesForFilter = (instance) => {
.filter((connection) => connection.targetId === filter) .filter((connection) => connection.targetId === filter)
.map((connection) => ({ .map((connection) => ({
pipeId: connection.sourceId, pipeId: connection.sourceId,
pipeType: pipeType: connection.source.dataset.pipetype,
connection.source.dataset.type === "Default" ? "Queue" : "Topic",
pipeDirection: "in", pipeDirection: "in",
})); }));
const outgoingConnections = allConnections const outgoingConnections = allConnections
.filter((connection) => connection.sourceId === filter) .filter((connection) => connection.sourceId === filter)
.map((connection) => ({ .map((connection) => ({
pipeId: connection.targetId, pipeId: connection.targetId,
pipeType: pipeType: connection.target.dataset.pipetype,
connection.target.dataset.type === "Default" ? "Queue" : "Topic",
pipeDirection: "out", pipeDirection: "out",
})); }));
...@@ -60,14 +58,11 @@ export const handlePipeBinding = (pipeMapping, editor) => { ...@@ -60,14 +58,11 @@ export const handlePipeBinding = (pipeMapping, editor) => {
) { ) {
return; return;
} else { } else {
let queue = pipe.pipeType === "Queue" ? true : false;
let line = editor.state.doc.line(lineNumber); let line = editor.state.doc.line(lineNumber);
let position = line.from; let position = line.from;
let pipeNameUserGiven = pipe.pipeName; let pipeNameUserGiven = pipe.pipeName;
let pipeNameDeklaration = makeValidConstName(pipeNameUserGiven); let pipeNameDeklaration = makeValidConstName(pipeNameUserGiven);
let insertCode = `\t\tconst ${pipeNameDeklaration} = "${pipeNameUserGiven}";\n\t\tawait channel.${ let insertCode = `\t\tconst ${pipeNameDeklaration} = "${pipeNameUserGiven}";\n\t\tawait channel.assert${pipe.pipeType}(${pipeNameDeklaration}, {\n\t\t\tdurable: false\n\t\t});\n`;
queue ? "assertQueue" : "assertTopic"
}(${pipeNameDeklaration}, {\n\t\t\tdurable: false\n\t\t});\n`;
let transaction = editor.state.update({ let transaction = editor.state.update({
changes: { changes: {
from: position, from: position,
......
...@@ -25,7 +25,7 @@ ...@@ -25,7 +25,7 @@
<h4>TOOLBOX</h4> <h4>TOOLBOX</h4>
<div> <div>
<h5>PIPES</h5> <h5>PIPES</h5>
<div class="Pipe" data-type="Default"> <div class="Pipe" data-type="Distributor" data-pipetype="Queue">
Queue Queue
<br /> <br />
<span id="PipeName"></span> <span id="PipeName"></span>
...@@ -36,7 +36,7 @@ ...@@ -36,7 +36,7 @@
<i id="Check" class="fa-sharp fa-xl fa-solid fa-circle-check"></i> <i id="Check" class="fa-sharp fa-xl fa-solid fa-circle-check"></i>
<i id="Docker" class="fa-brands fa-xl fa-docker"></i> <i id="Docker" class="fa-brands fa-xl fa-docker"></i>
</div> </div>
<div class="Pipe" data-type="Distributor"> <div class="Pipe" data-type="Distributor" data-pipetype="Topic">
Topic Topic
<br /> <br />
<span id="PipeName"></span> <span id="PipeName"></span>
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment