frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2025-03-01 10:37:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

serial control draft

Browse Source
This commit is contained in:
Yoonseok Hur 2023-11-19 18:19:50 +09:00
parent efbc8786bd
commit 10176b5b90
1 changed files with 21 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
io/serialport/25-serial.js
View File

@ -28,9 +28,9 @@ module.exports = function(RED) {
this.waitfor = n.waitfor || ""; this.waitfor = n.waitfor || "";
this.responsetimeout = n.responsetimeout || 10000; this.responsetimeout = n.responsetimeout || 10000;
this.newPort = (serialPort) => { this.changePort = (serialPort) => {
serialPool.close(this.serialport,() => {}); serialPool.close(this.serialport,() => {});
this.serialport = serialPort.port; this.serialport = serialPort.newport;
this.serialbaud = parseInt(serialPort.serialbaud) || this.serialbaud; this.serialbaud = parseInt(serialPort.serialbaud) || this.serialbaud;
this.databits = parseInt(serialPort.databits) || this.databits; this.databits = parseInt(serialPort.databits) || this.databits;
this.parity = serialPort.parity || this.parity; this.parity = serialPort.parity || this.parity;
@ -64,7 +64,7 @@ module.exports = function(RED) {
node.port = serialPool.get(this.serialConfig); node.port = serialPool.get(this.serialConfig);
var serialConfig = this.serialConfig; var serialConfig = this.serialConfig;
this.serialConfig.on('newport', function(newPort) { this.serialConfig.on('start', function() {
node.port = serialPool.get(serialConfig); node.port = serialPool.get(serialConfig);
}); });
@ -113,7 +113,7 @@ module.exports = function(RED) {
this.serial = n.serial; this.serial = n.serial;
var node = this; var node = this;
this.serialConfig.on('newport', function(newPort) { this.serialConfig.on('start', function() {
setCallback(node, node.serialConfig); setCallback(node, node.serialConfig);
}); });
@ -179,7 +179,7 @@ module.exports = function(RED) {
}); });
let serialConfig = this.serialConfig; let serialConfig = this.serialConfig;
serialConfig.on('newport', function(newPort) { serialConfig.on('start', function() {
node.port = serialPool.get(serialConfig); node.port = serialPool.get(serialConfig);
setCallback(node); setCallback(node);
}); });
@ -239,12 +239,22 @@ module.exports = function(RED) {
var node = this; var node = this;
node.port = serialPool.get(this.serialConfig); node.port = serialPool.get(this.serialConfig);
node.on("input",function(msg) { node.on("input",function(msg) {
if (msg.payload.hasOwnProperty("port")) { if (msg.payload.hasOwnProperty("config")) {
node.serialConfig.newPort(msg.payload); if (msg.payload.config === "query") {
node.serialConfig.emit('newport',msg.payload); node.send({payload: node.serialConfig});
node.send(msg); } else {
} else { node.serialConfig.changePort(msg.payload.config);
node.send({payload: {port: node.serialConfig.serialport}}); node.serialConfig.emit('start',msg.payload.config);
node.send({payload: msg.payload.config});
}
} else if (msg.payload.hasOwnProperty("start")) {
node.serialConfig.emit('start',msg.payload);
node.send({payload: node.serialConfig});
} else if (msg.payload.hasOwnProperty("stop")) {
serialPool.close(node.serialConfig.serialport,() => {
RED.log.info("[serialconfig:"+node.serialConfig.id+"] stopped");
});
node.send({payload: node.serialConfig});
} }
}); });
} }