frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

expose send, status, log, warn, error, debug, trace, name, id in setup code of function node

Browse Source
This commit is contained in:
cinhcet 2020-07-08 01:30:29 +02:00
parent f72903ccc2
commit 5d7a625883
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/node_modules/@node-red/nodes/core/function/10-function.js vendored
View File

@ -25,6 +25,7 @@ module.exports = function(RED) {
} else if (!util.isArray(msgs)) { } else if (!util.isArray(msgs)) {
msgs = [msgs]; msgs = [msgs];
} }
if(_msgid === "") _msgid = RED.util.generateId();
var msgCount = 0; var msgCount = 0;
for (var m=0; m<msgs.length; m++) { for (var m=0; m<msgs.length; m++) {
if (msgs[m]) { if (msgs[m]) {
@ -268,7 +269,23 @@ module.exports = function(RED) {
var iniScript = null; var iniScript = null;
var iniOpt = null; var iniOpt = null;
if (node.ini && (node.ini !== "")) { if (node.ini && (node.ini !== "")) {
var iniText = "(async function () {\n"+node.ini +"\n})();"; var iniText = `
(async function(__send__) {
var node = {
id:__node__.id,
name:__node__.name,
log:__node__.log,
error:__node__.error,
warn:__node__.warn,
debug:__node__.debug,
trace:__node__.trace,
status:__node__.status,
send: function(msgs, cloneMsg) {
__node__.send(__send__, "", msgs, cloneMsg);
}
};
`+ node.ini +`
})(send);`;
iniOpt = createVMOpt(node, " setup"); iniOpt = createVMOpt(node, " setup");
iniScript = new vm.Script(iniText, iniOpt); iniScript = new vm.Script(iniText, iniOpt);
} }
@ -280,7 +297,9 @@ module.exports = function(RED) {
} }
var promise = Promise.resolve(); var promise = Promise.resolve();
if (iniScript) { if (iniScript) {
context.send = function(m) { node.send(m); };
promise = iniScript.runInContext(context, iniOpt); promise = iniScript.runInContext(context, iniOpt);
delete context.send;
} }
function processMessage(msg, send, done) { function processMessage(msg, send, done) {