From 0a847a7a672cb0f4c42efe6484279771c07b2b4b Mon Sep 17 00:00:00 2001 From: Dave Conway-Jones Date: Mon, 21 Apr 2025 12:47:07 +0100 Subject: [PATCH 1/5] Fix complete node to not feedback immendiately connected nodes --- .../@node-red/nodes/core/common/24-complete.js | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/packages/node_modules/@node-red/nodes/core/common/24-complete.js b/packages/node_modules/@node-red/nodes/core/common/24-complete.js index ea665a265..4e361fa5b 100644 --- a/packages/node_modules/@node-red/nodes/core/common/24-complete.js +++ b/packages/node_modules/@node-red/nodes/core/common/24-complete.js @@ -21,6 +21,15 @@ module.exports = function(RED) { RED.nodes.createNode(this,n); var node = this; this.scope = n.scope; + + // auto-filter out any directly connected nodes to avoid simple loopback + const w = node.wires.flat().toString(); + for (let i=0; i < this.scope.length; i++) { + if (w.includes(this.scope[i])) { + this.scope.splice(i, 1); + } + } + this.on("input",function(msg, send, done) { send(msg); done(); From 316eb7c9ef84e6f3fe61f38b1d7b5de39fc1f95a Mon Sep 17 00:00:00 2001 From: Dave Conway-Jones Date: Mon, 21 Apr 2025 14:42:34 +0100 Subject: [PATCH 2/5] Also apply same fix to status node --- .../@node-red/nodes/core/common/25-status.js | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/packages/node_modules/@node-red/nodes/core/common/25-status.js b/packages/node_modules/@node-red/nodes/core/common/25-status.js index fc6ccbe29..1fe0f9fe5 100644 --- a/packages/node_modules/@node-red/nodes/core/common/25-status.js +++ b/packages/node_modules/@node-red/nodes/core/common/25-status.js @@ -21,6 +21,15 @@ module.exports = function(RED) { RED.nodes.createNode(this,n); var node = this; this.scope = n.scope; + + // auto-filter out any directly connected nodes to avoid simple loopback + const w = node.wires.flat().toString(); + for (let i=0; i < this.scope.length; i++) { + if (w.includes(this.scope[i])) { + this.scope.splice(i, 1); + } + } + this.on("input", function(msg, send, done) { send(msg); done(); From c771b175b1accece719e8642d289172dd245172b Mon Sep 17 00:00:00 2001 From: Dave Conway-Jones Date: Mon, 21 Apr 2025 14:58:25 +0100 Subject: [PATCH 3/5] Add complete test, and fix tests --- .../nodes/core/common/24-complete.js | 2 +- .../@node-red/nodes/core/common/25-status.js | 2 +- test/nodes/core/common/24-complete_spec.js | 54 +++++++++++++++++++ test/nodes/core/common/25-status_spec.js | 2 +- 4 files changed, 57 insertions(+), 3 deletions(-) create mode 100644 test/nodes/core/common/24-complete_spec.js diff --git a/packages/node_modules/@node-red/nodes/core/common/24-complete.js b/packages/node_modules/@node-red/nodes/core/common/24-complete.js index 4e361fa5b..0eefa6692 100644 --- a/packages/node_modules/@node-red/nodes/core/common/24-complete.js +++ b/packages/node_modules/@node-red/nodes/core/common/24-complete.js @@ -23,7 +23,7 @@ module.exports = function(RED) { this.scope = n.scope; // auto-filter out any directly connected nodes to avoid simple loopback - const w = node.wires.flat().toString(); + const w = this.wires.flat().toString(); for (let i=0; i < this.scope.length; i++) { if (w.includes(this.scope[i])) { this.scope.splice(i, 1); diff --git a/packages/node_modules/@node-red/nodes/core/common/25-status.js b/packages/node_modules/@node-red/nodes/core/common/25-status.js index 1fe0f9fe5..14eb3955d 100644 --- a/packages/node_modules/@node-red/nodes/core/common/25-status.js +++ b/packages/node_modules/@node-red/nodes/core/common/25-status.js @@ -23,7 +23,7 @@ module.exports = function(RED) { this.scope = n.scope; // auto-filter out any directly connected nodes to avoid simple loopback - const w = node.wires.flat().toString(); + const w = this.wires.flat().toString(); for (let i=0; i < this.scope.length; i++) { if (w.includes(this.scope[i])) { this.scope.splice(i, 1); diff --git a/test/nodes/core/common/24-complete_spec.js b/test/nodes/core/common/24-complete_spec.js new file mode 100644 index 000000000..8927db3bd --- /dev/null +++ b/test/nodes/core/common/24-complete_spec.js @@ -0,0 +1,54 @@ +/** + * Copyright JS Foundation and other contributors, http://js.foundation + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + **/ + +var should = require("should"); +var catchNode = require("nr-test-utils").require("@node-red/nodes/core/common/24-complete.js"); +var helper = require("node-red-node-test-helper"); + +describe('complete Node', function() { + + afterEach(function() { + helper.unload(); + }); + + it('should output a message when called', function(done) { + var flow = [ { id:"n1", type:"complete", name:"status", wires:[["n2"]], scope:[] }, + {id:"n2", type:"helper"} ]; + helper.load(catchNode, flow, function() { + var n1 = helper.getNode("n1"); + var n2 = helper.getNode("n2"); + n1.should.have.property('name', 'status'); + n2.on("input", function(msg) { + msg.text.should.equal("Oh dear"); + msg.should.have.property('source'); + msg.source.should.have.property('id',"12345"); + msg.source.should.have.property('type',"testnode"); + msg.source.should.have.property('name',"fred"); + done(); + }); + var mst = { + text: "Oh dear", + source: { + id: "12345", + type: "testnode", + name: "fred" + } + } + n1.emit("input", mst); + }); + }); + +}); diff --git a/test/nodes/core/common/25-status_spec.js b/test/nodes/core/common/25-status_spec.js index 41b0a79c8..9457d4372 100644 --- a/test/nodes/core/common/25-status_spec.js +++ b/test/nodes/core/common/25-status_spec.js @@ -25,7 +25,7 @@ describe('status Node', function() { }); it('should output a message when called', function(done) { - var flow = [ { id:"n1", type:"status", name:"status", wires:[["n2"]] }, + var flow = [ { id:"n1", type:"status", name:"status", wires:[["n2"]], scope:[] }, {id:"n2", type:"helper"} ]; helper.load(catchNode, flow, function() { var n1 = helper.getNode("n1"); From aaa4e60d58b5bc4a5100ed298993794e32ffc1fc Mon Sep 17 00:00:00 2001 From: Nick O'Leary Date: Fri, 6 Jun 2025 10:58:30 +0100 Subject: [PATCH 4/5] Apply suggestions from code review --- .../@node-red/nodes/core/common/24-complete.js | 2 +- .../@node-red/nodes/core/common/25-status.js | 2 +- test/nodes/core/common/24-complete_spec.js | 15 --------------- 3 files changed, 2 insertions(+), 17 deletions(-) diff --git a/packages/node_modules/@node-red/nodes/core/common/24-complete.js b/packages/node_modules/@node-red/nodes/core/common/24-complete.js index 0eefa6692..c54e03e7e 100644 --- a/packages/node_modules/@node-red/nodes/core/common/24-complete.js +++ b/packages/node_modules/@node-red/nodes/core/common/24-complete.js @@ -23,7 +23,7 @@ module.exports = function(RED) { this.scope = n.scope; // auto-filter out any directly connected nodes to avoid simple loopback - const w = this.wires.flat().toString(); + const w = this.wires.flat(); for (let i=0; i < this.scope.length; i++) { if (w.includes(this.scope[i])) { this.scope.splice(i, 1); diff --git a/packages/node_modules/@node-red/nodes/core/common/25-status.js b/packages/node_modules/@node-red/nodes/core/common/25-status.js index 14eb3955d..b3d5e8fa3 100644 --- a/packages/node_modules/@node-red/nodes/core/common/25-status.js +++ b/packages/node_modules/@node-red/nodes/core/common/25-status.js @@ -23,7 +23,7 @@ module.exports = function(RED) { this.scope = n.scope; // auto-filter out any directly connected nodes to avoid simple loopback - const w = this.wires.flat().toString(); + const w = this.wires.flat(); for (let i=0; i < this.scope.length; i++) { if (w.includes(this.scope[i])) { this.scope.splice(i, 1); diff --git a/test/nodes/core/common/24-complete_spec.js b/test/nodes/core/common/24-complete_spec.js index 8927db3bd..15f27b43b 100644 --- a/test/nodes/core/common/24-complete_spec.js +++ b/test/nodes/core/common/24-complete_spec.js @@ -1,18 +1,3 @@ -/** - * Copyright JS Foundation and other contributors, http://js.foundation - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - **/ var should = require("should"); var catchNode = require("nr-test-utils").require("@node-red/nodes/core/common/24-complete.js"); From 3f3450ce3e608d4e5e0de1ff8881884614554757 Mon Sep 17 00:00:00 2001 From: Nick O'Leary Date: Fri, 6 Jun 2025 11:00:13 +0100 Subject: [PATCH 5/5] Apply suggestions from code review --- .../node_modules/@node-red/nodes/core/common/24-complete.js | 2 +- packages/node_modules/@node-red/nodes/core/common/25-status.js | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/node_modules/@node-red/nodes/core/common/24-complete.js b/packages/node_modules/@node-red/nodes/core/common/24-complete.js index c54e03e7e..1ba43a423 100644 --- a/packages/node_modules/@node-red/nodes/core/common/24-complete.js +++ b/packages/node_modules/@node-red/nodes/core/common/24-complete.js @@ -20,7 +20,7 @@ module.exports = function(RED) { function CompleteNode(n) { RED.nodes.createNode(this,n); var node = this; - this.scope = n.scope; + this.scope = n.scope || []; // auto-filter out any directly connected nodes to avoid simple loopback const w = this.wires.flat(); diff --git a/packages/node_modules/@node-red/nodes/core/common/25-status.js b/packages/node_modules/@node-red/nodes/core/common/25-status.js index b3d5e8fa3..8c56e2030 100644 --- a/packages/node_modules/@node-red/nodes/core/common/25-status.js +++ b/packages/node_modules/@node-red/nodes/core/common/25-status.js @@ -20,7 +20,7 @@ module.exports = function(RED) { function StatusNode(n) { RED.nodes.createNode(this,n); var node = this; - this.scope = n.scope; + this.scope = n.scope || []; // auto-filter out any directly connected nodes to avoid simple loopback const w = this.wires.flat();