From 2e2d3b460d92fbfac8fa0789a18b6756f953d051 Mon Sep 17 00:00:00 2001
From: Guido Longoni <guido.longoni@briq.it>
Date: Tue, 18 Aug 2020 11:24:32 +0200
Subject: [PATCH] Changed msg structure

---
 pglisten.js | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/pglisten.js b/pglisten.js
index 96e095f..f60c4d0 100644
--- a/pglisten.js
+++ b/pglisten.js
@@ -55,10 +55,13 @@ module.exports = function(RED) {
                             node.status({fill:"green",shape:"dot",text:"connected"});
                             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);
+                                    var outmsg = {};
+                                    outmsg.payload = JSON.parse(msg.payload);
+                                    delete msg.payload;
+                                    outmsg.topic = msg.channel;
+                                    delete msg.channel;
+                                    outmsg.pg_data = msg;
+                                    node.send(outmsg);
                                 } catch (error) {
                                     node.error(error);
                                 }