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

add msg.stop handler and docs, msg.start restarts process as per existing doc

Browse Source
This commit is contained in:
G S Marzot 2023-07-20 07:15:42 -04:00 committed by gmarzot
parent 74aeb2ddae
commit 95ace249b3
2 changed files with 25 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
utility/daemon/README.md
View File

@ -36,6 +36,8 @@ Setting `msg.kill` to a signal name (e.g. SIGINT, SIGHUP) will stop the process
Sending `msg.start` will also re-start the process. Additional arguments can be specified in `msg.args`.
Sending `msg.stop` will stop the process and prevent automatic re-start until reset with `msg.start`.
**Note:** Some applications will automatically buffer lines of output. It is advisable to turn off this behaviour.
For example, if running a Python app, the `-u` parameter will stop the output being buffered.

31
utility/daemon/daemon.js
View File

@ -12,6 +12,7 @@ module.exports = function(RED) {
this.op = n.op;
this.redo = n.redo;
this.running = false;
this.stopped = false;
this.closer = n.closer || "SIGKILL";
this.autorun = true;
if (n.autorun === false) { this.autorun = false; }
@ -32,16 +33,29 @@ module.exports = function(RED) {
function inputlistener(msg) {
if (msg != null) {
if (msg.hasOwnProperty("kill") && node.running) {
if (msg.hasOwnProperty("stop")) {
this.stopped = true;
if (node.running) {
node.child.kill("SIGINT");
}
node.debug(node.cmd+" stopped by msg");
node.status({fill:"grey",shape:"ring",text:RED._("daemon.status.stopped")});
}
else if (msg.hasOwnProperty("kill") && node.running) {
if (typeof msg.kill !== "string" || msg.kill.length === 0 || !msg.kill.toUpperCase().startsWith("SIG") ) { msg.kill = "SIGINT"; }
node.child.kill(msg.kill.toUpperCase());
}
else if (msg.hasOwnProperty("start") && !node.running) {
let args = "";
if (msg.hasOwnProperty("args") && msg.args.length > 0) {
args = parseArgs(msg.args.trim());
else if (msg.hasOwnProperty("start")) {
this.stopped = false;
if (!node.running) {
let args = "";
if (msg.hasOwnProperty("args") && msg.args.length > 0) {
args = parseArgs(msg.args.trim());
}
runit(args);
} else {
node.child.kill("SIGINT");
}
runit(args);
}
else {
if (!Buffer.isBuffer(msg.payload)) {
@ -111,7 +125,8 @@ module.exports = function(RED) {
var rc = code;
if (code === null) { rc = signal; }
node.send([null,null,{payload:rc}]);
node.status({fill:"red",shape:"ring",text:RED._("daemon.status.stopped")});
const color = node.stopped ? "grey" : "red";
node.status({fill:color,shape:"ring",text:RED._("daemon.status.stopped")});
});
node.child.on('error', function (err) {
@ -138,7 +153,7 @@ module.exports = function(RED) {
if (node.redo === true) {
var loop = setInterval( function() {
if (!node.running) {
if (!node.running && !node.stopped) {
node.warn(RED._("daemon.errors.restarting") + " : " + node.cmd);
runit();
}