mirror of
https://github.com/node-red/node-red.git
synced 2023-10-10 13:36:53 +02:00
Add async context support to Inject node
This commit is contained in:
parent
4bcf13cb58
commit
afb566b6b4
@ -63,8 +63,9 @@ module.exports = function(RED) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
this.on("input",function(msg) {
|
this.on("input",function(msg) {
|
||||||
try {
|
|
||||||
msg.topic = this.topic;
|
msg.topic = this.topic;
|
||||||
|
if (this.payloadType !== 'flow' && this.payloadType !== 'global') {
|
||||||
|
try {
|
||||||
if ( (this.payloadType == null && this.payload === "") || this.payloadType === "date") {
|
if ( (this.payloadType == null && this.payload === "") || this.payloadType === "date") {
|
||||||
msg.payload = Date.now();
|
msg.payload = Date.now();
|
||||||
} else if (this.payloadType == null) {
|
} else if (this.payloadType == null) {
|
||||||
@ -79,6 +80,17 @@ module.exports = function(RED) {
|
|||||||
} catch(err) {
|
} catch(err) {
|
||||||
this.error(err,msg);
|
this.error(err,msg);
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
RED.util.evaluateNodeProperty(this.payload,this.payloadType,this,msg, function(err,res) {
|
||||||
|
if (err) {
|
||||||
|
node.error(err,msg);
|
||||||
|
} else {
|
||||||
|
msg.payload = res;
|
||||||
|
node.send(msg);
|
||||||
|
}
|
||||||
|
|
||||||
|
});
|
||||||
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -368,7 +368,7 @@ function evaluateNodeProperty(value, type, node, msg, callback) {
|
|||||||
if (callback) {
|
if (callback) {
|
||||||
callback(result);
|
callback(result);
|
||||||
} else {
|
} else {
|
||||||
return value;
|
return result;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user