mirror of
https://github.com/node-red/node-red.git
synced 2023-10-10 13:36:53 +02:00
201 lines
8.4 KiB
JavaScript
201 lines
8.4 KiB
JavaScript
module.exports = function(RED) {
|
|
"use strict";
|
|
var util = require("util");
|
|
var events = require("events");
|
|
//var path = require("path");
|
|
var debuglength = RED.settings.debugMaxLength || 1000;
|
|
var useColors = RED.settings.debugUseColors || false;
|
|
util.inspect.styles.boolean = "red";
|
|
|
|
function DebugNode(n) {
|
|
var hasEditExpression = (n.targetType === "jsonata");
|
|
var editExpression = hasEditExpression ? n.complete : null;
|
|
RED.nodes.createNode(this,n);
|
|
this.name = n.name;
|
|
this.complete = hasEditExpression ? null : (n.complete||"payload").toString();
|
|
if (this.complete === "false") { this.complete = "payload"; }
|
|
this.console = ""+(n.console || false);
|
|
this.tostatus = n.tostatus || false;
|
|
this.statusType = n.statusType || "msg";
|
|
this.statusVal = n.statusVal || this.complete;
|
|
this.tosidebar = n.tosidebar;
|
|
if (this.tosidebar === undefined) { this.tosidebar = true; }
|
|
this.active = (n.active === null || typeof n.active === "undefined") || n.active;
|
|
if (this.tostatus) { this.status({fill:"grey", shape:"ring"}); }
|
|
else { this.status({}); }
|
|
var hasStatExpression = (n.statusType === "jsonata");
|
|
var statExpression = hasStatExpression ? n.statusVal : null;
|
|
|
|
var node = this;
|
|
var preparedEditExpression = null;
|
|
var preparedStatExpression = null;
|
|
if (editExpression) {
|
|
try {
|
|
preparedEditExpression = RED.util.prepareJSONataExpression(editExpression, this);
|
|
}
|
|
catch (e) {
|
|
node.error(RED._("debug.invalid-exp", {error: editExpression}));
|
|
return;
|
|
}
|
|
}
|
|
if (statExpression) {
|
|
try {
|
|
preparedStatExpression = RED.util.prepareJSONataExpression(statExpression, this);
|
|
}
|
|
catch (e) {
|
|
node.error(RED._("debug.invalid-exp", {error: editExpression}));
|
|
return;
|
|
}
|
|
}
|
|
|
|
function prepareValue(msg, done) {
|
|
// Either apply the jsonata expression or...
|
|
if (preparedEditExpression) {
|
|
RED.util.evaluateJSONataExpression(preparedEditExpression, msg, (err, value) => {
|
|
if (err) { done(RED._("debug.invalid-exp", {error: editExpression})); }
|
|
else { done(null,{id:node.id, z:node.z, _alias: node._alias, path:node._flow.path, name:node.name, topic:msg.topic, msg:value}); }
|
|
});
|
|
} else {
|
|
// Extract the required message property
|
|
var property = "payload";
|
|
var output = msg[property];
|
|
if (node.complete !== "false" && typeof node.complete !== "undefined") {
|
|
property = node.complete;
|
|
try { output = RED.util.getMessageProperty(msg,node.complete); }
|
|
catch(err) { output = undefined; }
|
|
}
|
|
done(null,{id:node.id, z:node.z, _alias: node._alias, path:node._flow.path, name:node.name, topic:msg.topic, property:property, msg:output});
|
|
}
|
|
}
|
|
|
|
function prepareStatus(msg, done) {
|
|
// Either apply the jsonata expression or...
|
|
if (preparedStatExpression) {
|
|
RED.util.evaluateJSONataExpression(preparedStatExpression, msg, (err, value) => {
|
|
if (err) { done(RED._("debug.invalid-exp", {error:editExpression})); }
|
|
else { done(null,{msg:value}); }
|
|
});
|
|
} else {
|
|
// Extract the required message property
|
|
var output;
|
|
try { output = RED.util.getMessageProperty(msg,node.statusVal); }
|
|
catch(err) { output = undefined; }
|
|
done(null,{msg:output});
|
|
}
|
|
}
|
|
|
|
this.on("input", function(msg, send, done) {
|
|
if (node.tostatus === true) {
|
|
prepareStatus(msg, function(err,debugMsg) {
|
|
if (err) { node.error(err); return; }
|
|
var output = debugMsg.msg;
|
|
var st = (typeof output === 'string') ? output : util.inspect(output);
|
|
if (st.length > 32) { st = st.substr(0,32) + "..."; }
|
|
var fill = "grey";
|
|
var shape = "dot";
|
|
if (node.statusVal === "error.message" && msg.hasOwnProperty("error")) { fill = "red"; }
|
|
if (node.statusVal === "status.text" && msg.hasOwnProperty("status")) {
|
|
if (msg.status.hasOwnProperty("fill")) { fill = msg.status.fill; }
|
|
if (msg.status.hasOwnProperty("shape")) { shape = msg.status.shape; }
|
|
}
|
|
node.status({fill:fill, shape:shape, text:st});
|
|
});
|
|
}
|
|
|
|
if (this.complete === "true") {
|
|
// debug complete msg object
|
|
if (this.console === "true") {
|
|
node.log("\n"+util.inspect(msg, {colors:useColors, depth:10}));
|
|
}
|
|
if (this.active && this.tosidebar) {
|
|
sendDebug({id:node.id, z:node.z, _alias: node._alias, path:node._flow.path, name:node.name, topic:msg.topic, msg:msg});
|
|
}
|
|
done();
|
|
}
|
|
else {
|
|
prepareValue(msg,function(err,debugMsg) {
|
|
if (err) {
|
|
node.error(err);
|
|
return;
|
|
}
|
|
var output = debugMsg.msg;
|
|
if (node.console === "true") {
|
|
if (typeof output === "string") {
|
|
node.log((output.indexOf("\n") !== -1 ? "\n" : "") + output);
|
|
} else if (typeof output === "object") {
|
|
node.log("\n"+util.inspect(output, {colors:useColors, depth:10}));
|
|
} else {
|
|
node.log(util.inspect(output, {colors:useColors}));
|
|
}
|
|
}
|
|
if (node.active) {
|
|
if (node.tosidebar == true) {
|
|
sendDebug(debugMsg);
|
|
}
|
|
}
|
|
done();
|
|
});
|
|
}
|
|
})
|
|
}
|
|
|
|
RED.nodes.registerType("debug",DebugNode, {
|
|
settings: {
|
|
debugUseColors: {
|
|
value: false,
|
|
},
|
|
debugMaxLength: {
|
|
value: 1000,
|
|
}
|
|
}
|
|
});
|
|
|
|
function sendDebug(msg) {
|
|
// don't put blank errors in sidebar (but do add to logs)
|
|
//if ((msg.msg === "") && (msg.hasOwnProperty("level")) && (msg.level === 20)) { return; }
|
|
msg = RED.util.encodeObject(msg,{maxLength:debuglength});
|
|
RED.comms.publish("debug",msg);
|
|
}
|
|
|
|
DebugNode.logHandler = new events.EventEmitter();
|
|
DebugNode.logHandler.on("log",function(msg) {
|
|
if (msg.level === RED.log.WARN || msg.level === RED.log.ERROR) {
|
|
sendDebug(msg);
|
|
}
|
|
});
|
|
RED.log.addHandler(DebugNode.logHandler);
|
|
|
|
RED.httpAdmin.post("/debug/:id/:state", RED.auth.needsPermission("debug.write"), function(req,res) {
|
|
var node = RED.nodes.getNode(req.params.id);
|
|
var state = req.params.state;
|
|
if (node !== null && typeof node !== "undefined" ) {
|
|
if (state === "enable") {
|
|
node.active = true;
|
|
res.sendStatus(200);
|
|
if (node.tostatus) { node.status({fill:"grey", shape:"dot"}); }
|
|
} else if (state === "disable") {
|
|
node.active = false;
|
|
res.sendStatus(201);
|
|
if (node.tostatus && node.hasOwnProperty("oldStatus")) {
|
|
node.oldStatus.shape = "dot";
|
|
node.status(node.oldStatus);
|
|
}
|
|
} else {
|
|
res.sendStatus(404);
|
|
}
|
|
} else {
|
|
res.sendStatus(404);
|
|
}
|
|
});
|
|
|
|
// As debug/view/debug-utils.js is loaded via <script> tag, it won't get
|
|
// the auth header attached. So do not use RED.auth.needsPermission here.
|
|
RED.httpAdmin.get("/debug/view/*",function(req,res) {
|
|
var options = {
|
|
root: __dirname + '/lib/debug/',
|
|
dotfiles: 'deny'
|
|
};
|
|
res.sendFile(req.params[0], options);
|
|
});
|
|
};
|