Briq
/
red-briq-nodes
6
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

non vogliamo effettuare un retry; inoltre il modo in cui effettuava il retry porta a riempire lo heap di oggetti promise

master
Pietro Brenna 2025-08-25 18:14:28 +02:00
parent ac239ea27a
commit e1cdaca4d1
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
red/s7/s7-briq.js
View File

@ -76,11 +76,7 @@ function s7node_from_plc(plc) {
} else if (hop(s7promises, plc.ip)) { } else if (hop(s7promises, plc.ip)) {
// sta già provando a connettersi ma bisogna aspettare la promise // sta già provando a connettersi ma bisogna aspettare la promise
let prom = s7promises[plc.ip]; let prom = s7promises[plc.ip];
return prom.then(() => { return prom;
return s7nodes[plc.ip];
}, () => {
return s7node_from_plc(plc)
});
} else { } else {
let conn_opt = { let conn_opt = {
host: plc.ip, host: plc.ip,
@ -195,6 +191,7 @@ module.exports = function (RED) {
RED.nodes.createNode(this, config); RED.nodes.createNode(this, config);
var node = this; var node = this;
node.on('input', function (msg) { node.on('input', function (msg) {
msg.payload = msg.payload || {};
/*try { /*try {
write_msg.assert(msg); write_msg.assert(msg);
} catch (e) { } catch (e) {
@ -225,6 +222,7 @@ module.exports = function (RED) {
RED.nodes.createNode(this, config); RED.nodes.createNode(this, config);
var node = this; var node = this;
node.on('input', function (msg) { node.on('input', function (msg) {
msg.payload = msg.payload || {};
// console.log("input", msg); // console.log("input", msg);
/*try { /*try {
read_msg.assert(msg); read_msg.assert(msg);