Briq
/
node-red-contrib-postgres-listen
6
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Handle errors parsing JSON payload, close client when ended, don't log every notification

pull/6/merge
Silas Parker 2020-04-21 13:51:32 +01:00 committed by Vincent Schoonenburg
parent dc0b8f5543
commit e6adb4c4d9
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
pglisten.js
View File

@ -25,7 +25,7 @@ module.exports = function(RED) {
this.channel = n.channel;
console.log(this.channel);
var node = this;
var clientdb = null;
node.clientdb = null;
this.status({fill:"red",shape:"ring",text:"disconnected"});
if(this.postgresConfig) {
@ -42,9 +42,9 @@ module.exports = function(RED) {
if (node.postgresConfig.db) { config.database = node.postgresConfig.db; }
config.ssl = node.postgresConfig.ssl;
}
clientdb = new pg.Client(config);
node.clientdb = new pg.Client(config);
clientdb.connect(function(err) {
node.clientdb.connect(function(err) {
try {
if(err) {
@ -53,14 +53,18 @@ module.exports = function(RED) {
} else {
console.log("Connected");
node.status({fill:"green",shape:"dot",text:"connected"});
clientdb.on('notification', function(msg) {
console.log("Notification received");
msg.payload = JSON.parse(msg.payload);
node.log(JSON.stringify(msg));
node.send(msg);
node.clientdb.on('notification', function(msg) {
try {
//console.log("Notification received");
msg.payload = JSON.parse(msg.payload);
//node.log(JSON.stringify(msg));
node.send(msg);
} catch (error) {
node.error(error);
}
});
var query = "LISTEN " + node.channel;
clientdb.query(query);
node.clientdb.query(query);
console.log("Listening to :" + node.channel);
}
} catch (error) {