diff --git a/postgresql.js b/postgresql.js index e45040f..092e7fd 100644 --- a/postgresql.js +++ b/postgresql.js @@ -167,7 +167,11 @@ module.exports = function (RED) { } } else { const partsId = Math.random(); - let query = msg.query ? msg.query : Mustache.render(node.query, { msg }); + + const flowContext = this.flow.keys().reduce((prev, k) => ({ ...prev, [k]: this.flow.get(k) }), { }); + const globalContext = this.global.keys().reduce((prev, k) => ({ ...prev, [k]: this.global.get(k) }), { }); + + let query = msg.query ? msg.query : Mustache.render(node.query, { flow: flowContext, global: globalContext, msg }); let client = null;