From e8e3b3890c104f746af159465af3ea4129d2f9df Mon Sep 17 00:00:00 2001
From: Alexandre Alapetite <alexandre.alapetite@alexandra.dk>
Date: Wed, 2 Aug 2023 15:21:30 +0200
Subject: [PATCH 1/4] Add support for LISTEN / NOTIFY / RAISE events New option
 *Keep listening for notifications*
 https://www.postgresql.org/docs/current/sql-listen.html

---
 README.md                     |  18 ++
 locales/en-US/postgresql.html |  17 ++
 locales/en-US/postgresql.json |   1 +
 package-lock.json             | 400 +++++++++++++++++++++++-----------
 package.json                  |   8 +-
 postgresql.html               |  10 +
 postgresql.js                 |  23 +-
 7 files changed, 343 insertions(+), 134 deletions(-)

diff --git a/README.md b/README.md
index c97a7b3..8818bcd 100644
--- a/README.md
+++ b/README.md
@@ -7,6 +7,8 @@ It supports *splitting* the resultset and *backpressure* (flow control), to allo
 
 It supports *parameterized queries* and *multiple queries*.
 
+It supports [`LISTEN`](https://www.postgresql.org/docs/current/sql-listen.html) / [`NOTIFY`](https://www.postgresql.org/docs/current/sql-notify.html) / [`RAISE`](https://www.postgresql.org/docs/current/plpgsql-errors-and-messages.html) events.
+
 ## Outputs
 
 The response (rows) is provided in `msg.payload` as an array.
@@ -19,6 +21,22 @@ See the [underlying documentation](https://node-postgres.com/apis/result) for de
 
 In the case of multiple queries, then `msg.pgsql` is an array.
 
+## Events
+
+If you tick the *Keep listening for notifications* option along with a [`LISTEN`](https://www.postgresql.org/docs/current/sql-listen.html) request (see below),
+you will receive a message for each [`NOTIFY`](https://www.postgresql.org/docs/current/sql-notify.html) event,
+where `msg.channel` is the name of the channel, `msg.payload` is content of the notification, and `msg.processId` indicates the process ID.
+
+```sql
+LISTEN my_topic;
+```
+
+This can be especially useful when combined with a [`TRIGGER`](https://www.postgresql.org/docs/15/sql-createtrigger.html) to be informed of database changes such as new insertions.
+
+See the [underlying documentation](https://node-postgres.com/apis/client#notification) for details.
+
+Likewise, you may get notice messages producted by [`RAISE`](https://www.postgresql.org/docs/current/plpgsql-errors-and-messages.html) as a `msg.notice` message.
+
 ## Inputs
 
 ### SQL query template
diff --git a/locales/en-US/postgresql.html b/locales/en-US/postgresql.html
index e5534d3..6c6f4c9 100644
--- a/locales/en-US/postgresql.html
+++ b/locales/en-US/postgresql.html
@@ -16,6 +16,23 @@ <h3>Outputs</h3>
 	</p>
 	<p>In the case of multiple queries, then <code>msg.pgsql</code> is an array.</p>
 
+	<h3>Events</h3>
+	<p>
+		If you tick the <em>Keep listening for notifications</em> option along with a <a href="https://www.postgresql.org/docs/current/sql-listen.html"><code>LISTEN</code></a> request (see below),
+		you will receive a message for each <a href="https://www.postgresql.org/docs/current/sql-notify.html"><code>NOTIFY</code> event,
+		where <code>msg.channel</code> is the name of the channel, <code>msg.payload</code> is content of the notification, and <code>msg.processId</code> indicates the process ID.
+	</p>
+
+<pre>
+LISTEN my_topic;
+</pre>
+
+This can be especially useful when combined with a <a href="https://www.postgresql.org/docs/15/sql-createtrigger.html"><code>TRIGGER</code></a> to be informed of database changes such as new insertions.
+
+See the <a href="https://node-postgres.com/apis/client#notification">underlying documentation</a> for details.
+
+Likewise, you may get notice messages producted by <a href="https://www.postgresql.org/docs/current/plpgsql-errors-and-messages.html"><code>RAISE</code></a> as a <code>msg.notice</code> message.
+
 	<h3>Inputs</h3>
 	<h4>SQL query template</h4>
 	<p>This node uses the <a href="https://github.com/janl/mustache.js">Mustache template system</a> to generate queries based on the message:</p>
diff --git a/locales/en-US/postgresql.json b/locales/en-US/postgresql.json
index 5b197d2..44d6096 100644
--- a/locales/en-US/postgresql.json
+++ b/locales/en-US/postgresql.json
@@ -15,6 +15,7 @@
 			"server": "Server",
 			"query": "Query",
 			"split": "Split results in multiple messages",
+			"listen": "Keep listening for notifications",
 			"rowsPerMsg": "Number of rows per message"
 		},
 		"placeholder": {
diff --git a/package-lock.json b/package-lock.json
index e14b4dc..38289ef 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,12 +1,12 @@
 {
 	"name": "node-red-contrib-postgresql",
-	"version": "0.13.0",
+	"version": "0.14.0",
 	"lockfileVersion": 3,
 	"requires": true,
 	"packages": {
 		"": {
 			"name": "node-red-contrib-postgresql",
-			"version": "0.13.0",
+			"version": "0.14.0",
 			"license": "Apache-2.0",
 			"dependencies": {
 				"mustache": "^4.2.0",
@@ -14,11 +14,11 @@
 				"pg-cursor": "^2.10.0"
 			},
 			"devDependencies": {
-				"eslint": "^8.41.0",
+				"eslint": "^8.46.0",
 				"eslint-config-standard": "^17.1.0",
 				"eslint-plugin-html": "^7.1.0",
-				"eslint-plugin-import": "^2.27.5",
-				"eslint-plugin-n": "^16.0.0",
+				"eslint-plugin-import": "^2.28.0",
+				"eslint-plugin-n": "^16.0.1",
 				"eslint-plugin-promise": "^6.1.1",
 				"mocha": "^10.2.0"
 			},
@@ -26,6 +26,15 @@
 				"node": ">=8"
 			}
 		},
+		"node_modules/@aashutoshrathi/word-wrap": {
+			"version": "1.2.6",
+			"resolved": "https://registry.npmjs.org/@aashutoshrathi/word-wrap/-/word-wrap-1.2.6.tgz",
+			"integrity": "sha512-1Yjs2SvM8TflER/OD3cOjhWWOZb58A2t7wpE2S9XfBYTiIl+XFhQG2bjy4Pu1I+EAlCNUzRDYDdFwFYUKvXcIA==",
+			"dev": true,
+			"engines": {
+				"node": ">=0.10.0"
+			}
+		},
 		"node_modules/@eslint-community/eslint-utils": {
 			"version": "4.4.0",
 			"resolved": "https://registry.npmjs.org/@eslint-community/eslint-utils/-/eslint-utils-4.4.0.tgz",
@@ -42,23 +51,23 @@
 			}
 		},
 		"node_modules/@eslint-community/regexpp": {
-			"version": "4.5.1",
-			"resolved": "https://registry.npmjs.org/@eslint-community/regexpp/-/regexpp-4.5.1.tgz",
-			"integrity": "sha512-Z5ba73P98O1KUYCCJTUeVpja9RcGoMdncZ6T49FCUl2lN38JtCJ+3WgIDBv0AuY4WChU5PmtJmOCTlN6FZTFKQ==",
+			"version": "4.6.2",
+			"resolved": "https://registry.npmjs.org/@eslint-community/regexpp/-/regexpp-4.6.2.tgz",
+			"integrity": "sha512-pPTNuaAG3QMH+buKyBIGJs3g/S5y0caxw0ygM3YyE6yJFySwiGGSzA+mM3KJ8QQvzeLh3blwgSonkFjgQdxzMw==",
 			"dev": true,
 			"engines": {
 				"node": "^12.0.0 || ^14.0.0 || >=16.0.0"
 			}
 		},
 		"node_modules/@eslint/eslintrc": {
-			"version": "2.0.3",
-			"resolved": "https://registry.npmjs.org/@eslint/eslintrc/-/eslintrc-2.0.3.tgz",
-			"integrity": "sha512-+5gy6OQfk+xx3q0d6jGZZC3f3KzAkXc/IanVxd1is/VIIziRqqt3ongQz0FiTUXqTk0c7aDB3OaFuKnuSoJicQ==",
+			"version": "2.1.1",
+			"resolved": "https://registry.npmjs.org/@eslint/eslintrc/-/eslintrc-2.1.1.tgz",
+			"integrity": "sha512-9t7ZA7NGGK8ckelF0PQCfcxIUzs1Md5rrO6U/c+FIQNanea5UZC0wqKXH4vHBccmu4ZJgZ2idtPeW7+Q2npOEA==",
 			"dev": true,
 			"dependencies": {
 				"ajv": "^6.12.4",
 				"debug": "^4.3.2",
-				"espree": "^9.5.2",
+				"espree": "^9.6.0",
 				"globals": "^13.19.0",
 				"ignore": "^5.2.0",
 				"import-fresh": "^3.2.1",
@@ -74,18 +83,18 @@
 			}
 		},
 		"node_modules/@eslint/js": {
-			"version": "8.41.0",
-			"resolved": "https://registry.npmjs.org/@eslint/js/-/js-8.41.0.tgz",
-			"integrity": "sha512-LxcyMGxwmTh2lY9FwHPGWOHmYFCZvbrFCBZL4FzSSsxsRPuhrYUg/49/0KDfW8tnIEaEHtfmn6+NPN+1DqaNmA==",
+			"version": "8.46.0",
+			"resolved": "https://registry.npmjs.org/@eslint/js/-/js-8.46.0.tgz",
+			"integrity": "sha512-a8TLtmPi8xzPkCbp/OGFUo5yhRkHM2Ko9kOWP4znJr0WAhWyThaw3PnwX4vOTWOAMsV2uRt32PPDcEz63esSaA==",
 			"dev": true,
 			"engines": {
 				"node": "^12.22.0 || ^14.17.0 || >=16.0.0"
 			}
 		},
 		"node_modules/@humanwhocodes/config-array": {
-			"version": "0.11.8",
-			"resolved": "https://registry.npmjs.org/@humanwhocodes/config-array/-/config-array-0.11.8.tgz",
-			"integrity": "sha512-UybHIJzJnR5Qc/MsD9Kr+RpO2h+/P1GhOwdiLPXK5TWk5sgTdu88bTD9UP+CKbPPh5Rni1u0GjAdYQLemG8g+g==",
+			"version": "0.11.10",
+			"resolved": "https://registry.npmjs.org/@humanwhocodes/config-array/-/config-array-0.11.10.tgz",
+			"integrity": "sha512-KVVjQmNUepDVGXNuoRRdmmEjruj0KfiGSbS8LVc12LMsWDQzRXJ0qdhN8L8uUigKpfEHRhlaQFY0ib1tnUbNeQ==",
 			"dev": true,
 			"dependencies": {
 				"@humanwhocodes/object-schema": "^1.2.1",
@@ -157,9 +166,9 @@
 			"dev": true
 		},
 		"node_modules/acorn": {
-			"version": "8.8.2",
-			"resolved": "https://registry.npmjs.org/acorn/-/acorn-8.8.2.tgz",
-			"integrity": "sha512-xjIYgE8HBrkpd/sJqOGNspf8uHG+NOHGOw6a/Urj8taM2EXfdNAH2oFcPeIFfsv3+kz/mJrS5VuMqbNLjCa2vw==",
+			"version": "8.10.0",
+			"resolved": "https://registry.npmjs.org/acorn/-/acorn-8.10.0.tgz",
+			"integrity": "sha512-F0SAmZ8iUtS//m8DmCTA0jlh6TDKkHQyK6xc6V4KDTyZKA9dnvX9/3sRTVQrWm79glUAZbnmmNcdYwUIHWVybw==",
 			"dev": true,
 			"bin": {
 				"acorn": "bin/acorn"
@@ -277,6 +286,25 @@
 				"url": "https://github.com/sponsors/ljharb"
 			}
 		},
+		"node_modules/array.prototype.findlastindex": {
+			"version": "1.2.2",
+			"resolved": "https://registry.npmjs.org/array.prototype.findlastindex/-/array.prototype.findlastindex-1.2.2.tgz",
+			"integrity": "sha512-tb5thFFlUcp7NdNF6/MpDk/1r/4awWG1FIz3YqDf+/zJSTezBb+/5WViH41obXULHVpDzoiCLpJ/ZO9YbJMsdw==",
+			"dev": true,
+			"dependencies": {
+				"call-bind": "^1.0.2",
+				"define-properties": "^1.1.4",
+				"es-abstract": "^1.20.4",
+				"es-shim-unscopables": "^1.0.0",
+				"get-intrinsic": "^1.1.3"
+			},
+			"engines": {
+				"node": ">= 0.4"
+			},
+			"funding": {
+				"url": "https://github.com/sponsors/ljharb"
+			}
+		},
 		"node_modules/array.prototype.flat": {
 			"version": "1.3.1",
 			"resolved": "https://registry.npmjs.org/array.prototype.flat/-/array.prototype.flat-1.3.1.tgz",
@@ -313,6 +341,26 @@
 				"url": "https://github.com/sponsors/ljharb"
 			}
 		},
+		"node_modules/arraybuffer.prototype.slice": {
+			"version": "1.0.1",
+			"resolved": "https://registry.npmjs.org/arraybuffer.prototype.slice/-/arraybuffer.prototype.slice-1.0.1.tgz",
+			"integrity": "sha512-09x0ZWFEjj4WD8PDbykUwo3t9arLn8NIzmmYEJFpYekOAQjpkGSyrQhNoRTcwwcFRu+ycWF78QZ63oWTqSjBcw==",
+			"dev": true,
+			"dependencies": {
+				"array-buffer-byte-length": "^1.0.0",
+				"call-bind": "^1.0.2",
+				"define-properties": "^1.2.0",
+				"get-intrinsic": "^1.2.1",
+				"is-array-buffer": "^3.0.2",
+				"is-shared-array-buffer": "^1.0.2"
+			},
+			"engines": {
+				"node": ">= 0.4"
+			},
+			"funding": {
+				"url": "https://github.com/sponsors/ljharb"
+			}
+		},
 		"node_modules/available-typed-arrays": {
 			"version": "1.0.5",
 			"resolved": "https://registry.npmjs.org/available-typed-arrays/-/available-typed-arrays-1.0.5.tgz",
@@ -386,9 +434,9 @@
 			}
 		},
 		"node_modules/builtins/node_modules/semver": {
-			"version": "7.5.1",
-			"resolved": "https://registry.npmjs.org/semver/-/semver-7.5.1.tgz",
-			"integrity": "sha512-Wvss5ivl8TMRZXXESstBA4uR5iXgEN/VC5/sOcuXdVLzcdkz4HWetIoRfG5gb5X+ij/G9rw9YoGn3QoQ8OCSpw==",
+			"version": "7.5.4",
+			"resolved": "https://registry.npmjs.org/semver/-/semver-7.5.4.tgz",
+			"integrity": "sha512-1bCSESV6Pv+i21Hvpxp3Dx+pSD8lIPt8uVjRrxAUt/nbswYc+tK6Y2btiULjd4+fnq15PX+nqQDC7Oft7WkwcA==",
 			"dev": true,
 			"dependencies": {
 				"lru-cache": "^6.0.0"
@@ -684,18 +732,19 @@
 			}
 		},
 		"node_modules/es-abstract": {
-			"version": "1.21.2",
-			"resolved": "https://registry.npmjs.org/es-abstract/-/es-abstract-1.21.2.tgz",
-			"integrity": "sha512-y/B5POM2iBnIxCiernH1G7rC9qQoM77lLIMQLuob0zhp8C56Po81+2Nj0WFKnd0pNReDTnkYryc+zhOzpEIROg==",
+			"version": "1.22.1",
+			"resolved": "https://registry.npmjs.org/es-abstract/-/es-abstract-1.22.1.tgz",
+			"integrity": "sha512-ioRRcXMO6OFyRpyzV3kE1IIBd4WG5/kltnzdxSCqoP8CMGs/Li+M1uF5o7lOkZVFjDs+NLesthnF66Pg/0q0Lw==",
 			"dev": true,
 			"dependencies": {
 				"array-buffer-byte-length": "^1.0.0",
+				"arraybuffer.prototype.slice": "^1.0.1",
 				"available-typed-arrays": "^1.0.5",
 				"call-bind": "^1.0.2",
 				"es-set-tostringtag": "^2.0.1",
 				"es-to-primitive": "^1.2.1",
 				"function.prototype.name": "^1.1.5",
-				"get-intrinsic": "^1.2.0",
+				"get-intrinsic": "^1.2.1",
 				"get-symbol-description": "^1.0.0",
 				"globalthis": "^1.0.3",
 				"gopd": "^1.0.1",
@@ -715,14 +764,18 @@
 				"object-inspect": "^1.12.3",
 				"object-keys": "^1.1.1",
 				"object.assign": "^4.1.4",
-				"regexp.prototype.flags": "^1.4.3",
+				"regexp.prototype.flags": "^1.5.0",
+				"safe-array-concat": "^1.0.0",
 				"safe-regex-test": "^1.0.0",
 				"string.prototype.trim": "^1.2.7",
 				"string.prototype.trimend": "^1.0.6",
 				"string.prototype.trimstart": "^1.0.6",
+				"typed-array-buffer": "^1.0.0",
+				"typed-array-byte-length": "^1.0.0",
+				"typed-array-byte-offset": "^1.0.0",
 				"typed-array-length": "^1.0.4",
 				"unbox-primitive": "^1.0.2",
-				"which-typed-array": "^1.1.9"
+				"which-typed-array": "^1.1.10"
 			},
 			"engines": {
 				"node": ">= 0.4"
@@ -793,27 +846,27 @@
 			}
 		},
 		"node_modules/eslint": {
-			"version": "8.41.0",
-			"resolved": "https://registry.npmjs.org/eslint/-/eslint-8.41.0.tgz",
-			"integrity": "sha512-WQDQpzGBOP5IrXPo4Hc0814r4/v2rrIsB0rhT7jtunIalgg6gYXWhRMOejVO8yH21T/FGaxjmFjBMNqcIlmH1Q==",
+			"version": "8.46.0",
+			"resolved": "https://registry.npmjs.org/eslint/-/eslint-8.46.0.tgz",
+			"integrity": "sha512-cIO74PvbW0qU8e0mIvk5IV3ToWdCq5FYG6gWPHHkx6gNdjlbAYvtfHmlCMXxjcoVaIdwy/IAt3+mDkZkfvb2Dg==",
 			"dev": true,
 			"dependencies": {
 				"@eslint-community/eslint-utils": "^4.2.0",
-				"@eslint-community/regexpp": "^4.4.0",
-				"@eslint/eslintrc": "^2.0.3",
-				"@eslint/js": "8.41.0",
-				"@humanwhocodes/config-array": "^0.11.8",
+				"@eslint-community/regexpp": "^4.6.1",
+				"@eslint/eslintrc": "^2.1.1",
+				"@eslint/js": "^8.46.0",
+				"@humanwhocodes/config-array": "^0.11.10",
 				"@humanwhocodes/module-importer": "^1.0.1",
 				"@nodelib/fs.walk": "^1.2.8",
-				"ajv": "^6.10.0",
+				"ajv": "^6.12.4",
 				"chalk": "^4.0.0",
 				"cross-spawn": "^7.0.2",
 				"debug": "^4.3.2",
 				"doctrine": "^3.0.0",
 				"escape-string-regexp": "^4.0.0",
-				"eslint-scope": "^7.2.0",
-				"eslint-visitor-keys": "^3.4.1",
-				"espree": "^9.5.2",
+				"eslint-scope": "^7.2.2",
+				"eslint-visitor-keys": "^3.4.2",
+				"espree": "^9.6.1",
 				"esquery": "^1.4.2",
 				"esutils": "^2.0.2",
 				"fast-deep-equal": "^3.1.3",
@@ -823,7 +876,6 @@
 				"globals": "^13.19.0",
 				"graphemer": "^1.4.0",
 				"ignore": "^5.2.0",
-				"import-fresh": "^3.0.0",
 				"imurmurhash": "^0.1.4",
 				"is-glob": "^4.0.0",
 				"is-path-inside": "^3.0.3",
@@ -833,9 +885,8 @@
 				"lodash.merge": "^4.6.2",
 				"minimatch": "^3.1.2",
 				"natural-compare": "^1.4.0",
-				"optionator": "^0.9.1",
+				"optionator": "^0.9.3",
 				"strip-ansi": "^6.0.1",
-				"strip-json-comments": "^3.1.0",
 				"text-table": "^0.2.0"
 			},
 			"bin": {
@@ -924,13 +975,13 @@
 			}
 		},
 		"node_modules/eslint-plugin-es-x": {
-			"version": "6.2.1",
-			"resolved": "https://registry.npmjs.org/eslint-plugin-es-x/-/eslint-plugin-es-x-6.2.1.tgz",
-			"integrity": "sha512-uR34zUhZ9EBoiSD2DdV5kHLpydVEvwWqjteUr9sXRgJknwbKZJZhdJ7uFnaTtd+Nr/2G3ceJHnHXrFhJ67n3Tw==",
+			"version": "7.2.0",
+			"resolved": "https://registry.npmjs.org/eslint-plugin-es-x/-/eslint-plugin-es-x-7.2.0.tgz",
+			"integrity": "sha512-9dvv5CcvNjSJPqnS5uZkqb3xmbeqRLnvXKK7iI5+oK/yTusyc46zbBZKENGsOfojm/mKfszyZb+wNqNPAPeGXA==",
 			"dev": true,
 			"dependencies": {
 				"@eslint-community/eslint-utils": "^4.1.2",
-				"@eslint-community/regexpp": "^4.5.0"
+				"@eslint-community/regexpp": "^4.6.0"
 			},
 			"engines": {
 				"node": "^14.18.0 || >=16.0.0"
@@ -952,26 +1003,29 @@
 			}
 		},
 		"node_modules/eslint-plugin-import": {
-			"version": "2.27.5",
-			"resolved": "https://registry.npmjs.org/eslint-plugin-import/-/eslint-plugin-import-2.27.5.tgz",
-			"integrity": "sha512-LmEt3GVofgiGuiE+ORpnvP+kAm3h6MLZJ4Q5HCyHADofsb4VzXFsRiWj3c0OFiV+3DWFh0qg3v9gcPlfc3zRow==",
+			"version": "2.28.0",
+			"resolved": "https://registry.npmjs.org/eslint-plugin-import/-/eslint-plugin-import-2.28.0.tgz",
+			"integrity": "sha512-B8s/n+ZluN7sxj9eUf7/pRFERX0r5bnFA2dCaLHy2ZeaQEAz0k+ZZkFWRFHJAqxfxQDx6KLv9LeIki7cFdwW+Q==",
 			"dev": true,
 			"dependencies": {
 				"array-includes": "^3.1.6",
+				"array.prototype.findlastindex": "^1.2.2",
 				"array.prototype.flat": "^1.3.1",
 				"array.prototype.flatmap": "^1.3.1",
 				"debug": "^3.2.7",
 				"doctrine": "^2.1.0",
 				"eslint-import-resolver-node": "^0.3.7",
-				"eslint-module-utils": "^2.7.4",
+				"eslint-module-utils": "^2.8.0",
 				"has": "^1.0.3",
-				"is-core-module": "^2.11.0",
+				"is-core-module": "^2.12.1",
 				"is-glob": "^4.0.3",
 				"minimatch": "^3.1.2",
+				"object.fromentries": "^2.0.6",
+				"object.groupby": "^1.0.0",
 				"object.values": "^1.1.6",
-				"resolve": "^1.22.1",
-				"semver": "^6.3.0",
-				"tsconfig-paths": "^3.14.1"
+				"resolve": "^1.22.3",
+				"semver": "^6.3.1",
+				"tsconfig-paths": "^3.14.2"
 			},
 			"engines": {
 				"node": ">=4"
@@ -1002,19 +1056,19 @@
 			}
 		},
 		"node_modules/eslint-plugin-n": {
-			"version": "16.0.0",
-			"resolved": "https://registry.npmjs.org/eslint-plugin-n/-/eslint-plugin-n-16.0.0.tgz",
-			"integrity": "sha512-akkZTE3hsHBrq6CwmGuYCzQREbVUrA855kzcHqe6i0FLBkeY7Y/6tThCVkjUnjhvRBAlc+8lILcSe5QvvDpeZQ==",
+			"version": "16.0.1",
+			"resolved": "https://registry.npmjs.org/eslint-plugin-n/-/eslint-plugin-n-16.0.1.tgz",
+			"integrity": "sha512-CDmHegJN0OF3L5cz5tATH84RPQm9kG+Yx39wIqIwPR2C0uhBGMWfbbOtetR83PQjjidA5aXMu+LEFw1jaSwvTA==",
 			"dev": true,
 			"dependencies": {
 				"@eslint-community/eslint-utils": "^4.4.0",
 				"builtins": "^5.0.1",
-				"eslint-plugin-es-x": "^6.1.0",
-				"ignore": "^5.1.1",
-				"is-core-module": "^2.12.0",
+				"eslint-plugin-es-x": "^7.1.0",
+				"ignore": "^5.2.4",
+				"is-core-module": "^2.12.1",
 				"minimatch": "^3.1.2",
 				"resolve": "^1.22.2",
-				"semver": "^7.5.0"
+				"semver": "^7.5.3"
 			},
 			"engines": {
 				"node": ">=16.0.0"
@@ -1027,9 +1081,9 @@
 			}
 		},
 		"node_modules/eslint-plugin-n/node_modules/semver": {
-			"version": "7.5.1",
-			"resolved": "https://registry.npmjs.org/semver/-/semver-7.5.1.tgz",
-			"integrity": "sha512-Wvss5ivl8TMRZXXESstBA4uR5iXgEN/VC5/sOcuXdVLzcdkz4HWetIoRfG5gb5X+ij/G9rw9YoGn3QoQ8OCSpw==",
+			"version": "7.5.4",
+			"resolved": "https://registry.npmjs.org/semver/-/semver-7.5.4.tgz",
+			"integrity": "sha512-1bCSESV6Pv+i21Hvpxp3Dx+pSD8lIPt8uVjRrxAUt/nbswYc+tK6Y2btiULjd4+fnq15PX+nqQDC7Oft7WkwcA==",
 			"dev": true,
 			"dependencies": {
 				"lru-cache": "^6.0.0"
@@ -1054,9 +1108,9 @@
 			}
 		},
 		"node_modules/eslint-scope": {
-			"version": "7.2.0",
-			"resolved": "https://registry.npmjs.org/eslint-scope/-/eslint-scope-7.2.0.tgz",
-			"integrity": "sha512-DYj5deGlHBfMt15J7rdtyKNq/Nqlv5KfU4iodrQ019XESsRnwXH9KAE0y3cwtUHDo2ob7CypAnCqefh6vioWRw==",
+			"version": "7.2.2",
+			"resolved": "https://registry.npmjs.org/eslint-scope/-/eslint-scope-7.2.2.tgz",
+			"integrity": "sha512-dOt21O7lTMhDM+X9mB4GX+DZrZtCUJPL/wlcTqxyrx5IvO0IYtILdtrQGQp+8n5S0gwSVmOf9NQrjMOgfQZlIg==",
 			"dev": true,
 			"dependencies": {
 				"esrecurse": "^4.3.0",
@@ -1070,9 +1124,9 @@
 			}
 		},
 		"node_modules/eslint-visitor-keys": {
-			"version": "3.4.1",
-			"resolved": "https://registry.npmjs.org/eslint-visitor-keys/-/eslint-visitor-keys-3.4.1.tgz",
-			"integrity": "sha512-pZnmmLwYzf+kWaM/Qgrvpen51upAktaaiI01nsJD/Yr3lMOdNtq0cxkrrg16w64VtisN6okbs7Q8AfGqj4c9fA==",
+			"version": "3.4.2",
+			"resolved": "https://registry.npmjs.org/eslint-visitor-keys/-/eslint-visitor-keys-3.4.2.tgz",
+			"integrity": "sha512-8drBzUEyZ2llkpCA67iYrgEssKDUu68V8ChqqOfFupIaG/LCVPUT+CoGJpT77zJprs4T/W7p07LP7zAIMuweVw==",
 			"dev": true,
 			"engines": {
 				"node": "^12.22.0 || ^14.17.0 || >=16.0.0"
@@ -1082,12 +1136,12 @@
 			}
 		},
 		"node_modules/espree": {
-			"version": "9.5.2",
-			"resolved": "https://registry.npmjs.org/espree/-/espree-9.5.2.tgz",
-			"integrity": "sha512-7OASN1Wma5fum5SrNhFMAMJxOUAbhyfQ8dQ//PJaJbNw0URTPWqIghHWt1MmAANKhHZIYOHruW4Kw4ruUWOdGw==",
+			"version": "9.6.1",
+			"resolved": "https://registry.npmjs.org/espree/-/espree-9.6.1.tgz",
+			"integrity": "sha512-oruZaFkjorTpF32kDSI5/75ViwGeZginGGy2NoOSg3Q9bnwlnmDm4HLnkl0RE3n+njDXR037aY1+x58Z/zFdwQ==",
 			"dev": true,
 			"dependencies": {
-				"acorn": "^8.8.0",
+				"acorn": "^8.9.0",
 				"acorn-jsx": "^5.3.2",
 				"eslint-visitor-keys": "^3.4.1"
 			},
@@ -1826,16 +1880,12 @@
 			}
 		},
 		"node_modules/is-typed-array": {
-			"version": "1.1.10",
-			"resolved": "https://registry.npmjs.org/is-typed-array/-/is-typed-array-1.1.10.tgz",
-			"integrity": "sha512-PJqgEHiWZvMpaFZ3uTc8kHPM4+4ADTlDniuQL7cU/UDA0Ql7F70yGfHph3cLNe+c9toaigv+DFzTJKhc2CtO6A==",
+			"version": "1.1.12",
+			"resolved": "https://registry.npmjs.org/is-typed-array/-/is-typed-array-1.1.12.tgz",
+			"integrity": "sha512-Z14TF2JNG8Lss5/HMqt0//T9JeHXttXy5pH/DBU4vi98ozO2btxzq9MwYDZYnKwU8nRsz/+GVFVRDq3DkVuSPg==",
 			"dev": true,
 			"dependencies": {
-				"available-typed-arrays": "^1.0.5",
-				"call-bind": "^1.0.2",
-				"for-each": "^0.3.3",
-				"gopd": "^1.0.1",
-				"has-tostringtag": "^1.0.0"
+				"which-typed-array": "^1.1.11"
 			},
 			"engines": {
 				"node": ">= 0.4"
@@ -1868,6 +1918,12 @@
 				"url": "https://github.com/sponsors/ljharb"
 			}
 		},
+		"node_modules/isarray": {
+			"version": "2.0.5",
+			"resolved": "https://registry.npmjs.org/isarray/-/isarray-2.0.5.tgz",
+			"integrity": "sha512-xHjhDr3cNBK0BzdUJSPXZntQUx/mwMS5Rw4A7lPJ90XGAO6ISP/ePDNuo0vhqOZU+UD5JoodwCAAoZQd3FeAKw==",
+			"dev": true
+		},
 		"node_modules/isexe": {
 			"version": "2.0.0",
 			"resolved": "https://registry.npmjs.org/isexe/-/isexe-2.0.0.tgz",
@@ -2152,6 +2208,35 @@
 				"url": "https://github.com/sponsors/ljharb"
 			}
 		},
+		"node_modules/object.fromentries": {
+			"version": "2.0.6",
+			"resolved": "https://registry.npmjs.org/object.fromentries/-/object.fromentries-2.0.6.tgz",
+			"integrity": "sha512-VciD13dswC4j1Xt5394WR4MzmAQmlgN72phd/riNp9vtD7tp4QQWJ0R4wvclXcafgcYK8veHRed2W6XeGBvcfg==",
+			"dev": true,
+			"dependencies": {
+				"call-bind": "^1.0.2",
+				"define-properties": "^1.1.4",
+				"es-abstract": "^1.20.4"
+			},
+			"engines": {
+				"node": ">= 0.4"
+			},
+			"funding": {
+				"url": "https://github.com/sponsors/ljharb"
+			}
+		},
+		"node_modules/object.groupby": {
+			"version": "1.0.0",
+			"resolved": "https://registry.npmjs.org/object.groupby/-/object.groupby-1.0.0.tgz",
+			"integrity": "sha512-70MWG6NfRH9GnbZOikuhPPYzpUpof9iW2J9E4dW7FXTqPNb6rllE6u39SKwwiNh8lCwX3DDb5OgcKGiEBrTTyw==",
+			"dev": true,
+			"dependencies": {
+				"call-bind": "^1.0.2",
+				"define-properties": "^1.2.0",
+				"es-abstract": "^1.21.2",
+				"get-intrinsic": "^1.2.1"
+			}
+		},
 		"node_modules/object.values": {
 			"version": "1.1.6",
 			"resolved": "https://registry.npmjs.org/object.values/-/object.values-1.1.6.tgz",
@@ -2179,17 +2264,17 @@
 			}
 		},
 		"node_modules/optionator": {
-			"version": "0.9.1",
-			"resolved": "https://registry.npmjs.org/optionator/-/optionator-0.9.1.tgz",
-			"integrity": "sha512-74RlY5FCnhq4jRxVUPKDaRwrVNXMqsGsiW6AJw4XK8hmtm10wC0ypZBLw5IIp85NZMr91+qd1RvvENwg7jjRFw==",
+			"version": "0.9.3",
+			"resolved": "https://registry.npmjs.org/optionator/-/optionator-0.9.3.tgz",
+			"integrity": "sha512-JjCoypp+jKn1ttEFExxhetCKeJt9zhAgAve5FXHixTvFDW/5aEktX9bufBKLRRMdU7bNtpLfcGu94B3cdEJgjg==",
 			"dev": true,
 			"dependencies": {
+				"@aashutoshrathi/word-wrap": "^1.2.3",
 				"deep-is": "^0.1.3",
 				"fast-levenshtein": "^2.0.6",
 				"levn": "^0.4.1",
 				"prelude-ls": "^1.2.1",
-				"type-check": "^0.4.0",
-				"word-wrap": "^1.2.3"
+				"type-check": "^0.4.0"
 			},
 			"engines": {
 				"node": ">= 0.8.0"
@@ -2276,14 +2361,14 @@
 			"dev": true
 		},
 		"node_modules/pg": {
-			"version": "8.11.0",
-			"resolved": "https://registry.npmjs.org/pg/-/pg-8.11.0.tgz",
-			"integrity": "sha512-meLUVPn2TWgJyLmy7el3fQQVwft4gU5NGyvV0XbD41iU9Jbg8lCH4zexhIkihDzVHJStlt6r088G6/fWeNjhXA==",
+			"version": "8.11.2",
+			"resolved": "https://registry.npmjs.org/pg/-/pg-8.11.2.tgz",
+			"integrity": "sha512-l4rmVeV8qTIrrPrIR3kZQqBgSN93331s9i6wiUiLOSk0Q7PmUxZD/m1rQI622l3NfqBby9Ar5PABfS/SulfieQ==",
 			"dependencies": {
 				"buffer-writer": "2.0.0",
 				"packet-reader": "1.0.0",
-				"pg-connection-string": "^2.6.0",
-				"pg-pool": "^3.6.0",
+				"pg-connection-string": "^2.6.2",
+				"pg-pool": "^3.6.1",
 				"pg-protocol": "^1.6.0",
 				"pg-types": "^2.1.0",
 				"pgpass": "1.x"
@@ -2292,7 +2377,7 @@
 				"node": ">= 8.0.0"
 			},
 			"optionalDependencies": {
-				"pg-cloudflare": "^1.1.0"
+				"pg-cloudflare": "^1.1.1"
 			},
 			"peerDependencies": {
 				"pg-native": ">=3.0.1"
@@ -2304,20 +2389,20 @@
 			}
 		},
 		"node_modules/pg-cloudflare": {
-			"version": "1.1.0",
-			"resolved": "https://registry.npmjs.org/pg-cloudflare/-/pg-cloudflare-1.1.0.tgz",
-			"integrity": "sha512-tGM8/s6frwuAIyRcJ6nWcIvd3+3NmUKIs6OjviIm1HPPFEt5MzQDOTBQyhPWg/m0kCl95M6gA1JaIXtS8KovOA==",
+			"version": "1.1.1",
+			"resolved": "https://registry.npmjs.org/pg-cloudflare/-/pg-cloudflare-1.1.1.tgz",
+			"integrity": "sha512-xWPagP/4B6BgFO+EKz3JONXv3YDgvkbVrGw2mTo3D6tVDQRh1e7cqVGvyR3BE+eQgAvx1XhW/iEASj4/jCWl3Q==",
 			"optional": true
 		},
 		"node_modules/pg-connection-string": {
-			"version": "2.6.0",
-			"resolved": "https://registry.npmjs.org/pg-connection-string/-/pg-connection-string-2.6.0.tgz",
-			"integrity": "sha512-x14ibktcwlHKoHxx9X3uTVW9zIGR41ZB6QNhHb21OPNdCCO3NaRnpJuwKIQSR4u+Yqjx4HCvy7Hh7VSy1U4dGg=="
+			"version": "2.6.2",
+			"resolved": "https://registry.npmjs.org/pg-connection-string/-/pg-connection-string-2.6.2.tgz",
+			"integrity": "sha512-ch6OwaeaPYcova4kKZ15sbJ2hKb/VP48ZD2gE7i1J+L4MspCtBMAx8nMgz7bksc7IojCIIWuEhHibSMFH8m8oA=="
 		},
 		"node_modules/pg-cursor": {
-			"version": "2.10.0",
-			"resolved": "https://registry.npmjs.org/pg-cursor/-/pg-cursor-2.10.0.tgz",
-			"integrity": "sha512-azXIjeIGBwlv/icYyuki5xJYfVSXeirGn4+mvAmYTB8SY0gS1xhluc2CENnq1JrcVSA81lWZgtqc1GAAhH/UuQ==",
+			"version": "2.10.2",
+			"resolved": "https://registry.npmjs.org/pg-cursor/-/pg-cursor-2.10.2.tgz",
+			"integrity": "sha512-fqn5FBDMu2TmecI205rD1Oi/85RtE/iBOP5amN1gaLdnkGGvA8+OsolzkUqnof1zsAgnvwO3LymKgvFlVZAlbw==",
 			"peerDependencies": {
 				"pg": "^8"
 			}
@@ -2331,9 +2416,9 @@
 			}
 		},
 		"node_modules/pg-pool": {
-			"version": "3.6.0",
-			"resolved": "https://registry.npmjs.org/pg-pool/-/pg-pool-3.6.0.tgz",
-			"integrity": "sha512-clFRf2ksqd+F497kWFyM21tMjeikn60oGDmqMT8UBrynEwVEX/5R5xd2sdvdo1cZCFlguORNpVuqxIj+aK4cfQ==",
+			"version": "3.6.1",
+			"resolved": "https://registry.npmjs.org/pg-pool/-/pg-pool-3.6.1.tgz",
+			"integrity": "sha512-jizsIzhkIitxCGfPRzJn1ZdcosIt3pz9Sh3V01fm1vZnbnCMgmGl5wvGGdNN2EL9Rmb0EcFoCkixH4Pu+sP9Og==",
 			"peerDependencies": {
 				"pg": ">=8.0"
 			}
@@ -2499,12 +2584,12 @@
 			}
 		},
 		"node_modules/resolve": {
-			"version": "1.22.2",
-			"resolved": "https://registry.npmjs.org/resolve/-/resolve-1.22.2.tgz",
-			"integrity": "sha512-Sb+mjNHOULsBv818T40qSPeRiuWLyaGMa5ewydRLFimneixmVy2zdivRl+AF6jaYPC8ERxGDmFSiqui6SfPd+g==",
+			"version": "1.22.3",
+			"resolved": "https://registry.npmjs.org/resolve/-/resolve-1.22.3.tgz",
+			"integrity": "sha512-P8ur/gp/AmbEzjr729bZnLjXK5Z+4P0zhIJgBgzqRih7hL7BOukHGtSTA3ACMY467GRFz3duQsi0bDZdR7DKdw==",
 			"dev": true,
 			"dependencies": {
-				"is-core-module": "^2.11.0",
+				"is-core-module": "^2.12.0",
 				"path-parse": "^1.0.7",
 				"supports-preserve-symlinks-flag": "^1.0.0"
 			},
@@ -2572,6 +2657,24 @@
 				"queue-microtask": "^1.2.2"
 			}
 		},
+		"node_modules/safe-array-concat": {
+			"version": "1.0.0",
+			"resolved": "https://registry.npmjs.org/safe-array-concat/-/safe-array-concat-1.0.0.tgz",
+			"integrity": "sha512-9dVEFruWIsnie89yym+xWTAYASdpw3CJV7Li/6zBewGf9z2i1j31rP6jnY0pHEO4QZh6N0K11bFjWmdR8UGdPQ==",
+			"dev": true,
+			"dependencies": {
+				"call-bind": "^1.0.2",
+				"get-intrinsic": "^1.2.0",
+				"has-symbols": "^1.0.3",
+				"isarray": "^2.0.5"
+			},
+			"engines": {
+				"node": ">=0.4"
+			},
+			"funding": {
+				"url": "https://github.com/sponsors/ljharb"
+			}
+		},
 		"node_modules/safe-buffer": {
 			"version": "5.2.1",
 			"resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
@@ -2607,9 +2710,9 @@
 			}
 		},
 		"node_modules/semver": {
-			"version": "6.3.0",
-			"resolved": "https://registry.npmjs.org/semver/-/semver-6.3.0.tgz",
-			"integrity": "sha512-b39TBaTSfV6yBrapU89p5fKekE2m/NwnDocOVruQFS1/veMgdzuPcnOM34M6CwxW8jH/lxEa5rBoDeUwu5HHTw==",
+			"version": "6.3.1",
+			"resolved": "https://registry.npmjs.org/semver/-/semver-6.3.1.tgz",
+			"integrity": "sha512-BR7VvDCVHO+q2xBEWskxS6DJE1qRnb7DxzUrogb71CWoSficBxYsiAGd+Kl0mmq/MprG9yArRkyrQxTO6XjMzA==",
 			"dev": true,
 			"bin": {
 				"semver": "bin/semver.js"
@@ -2837,6 +2940,57 @@
 				"url": "https://github.com/sponsors/sindresorhus"
 			}
 		},
+		"node_modules/typed-array-buffer": {
+			"version": "1.0.0",
+			"resolved": "https://registry.npmjs.org/typed-array-buffer/-/typed-array-buffer-1.0.0.tgz",
+			"integrity": "sha512-Y8KTSIglk9OZEr8zywiIHG/kmQ7KWyjseXs1CbSo8vC42w7hg2HgYTxSWwP0+is7bWDc1H+Fo026CpHFwm8tkw==",
+			"dev": true,
+			"dependencies": {
+				"call-bind": "^1.0.2",
+				"get-intrinsic": "^1.2.1",
+				"is-typed-array": "^1.1.10"
+			},
+			"engines": {
+				"node": ">= 0.4"
+			}
+		},
+		"node_modules/typed-array-byte-length": {
+			"version": "1.0.0",
+			"resolved": "https://registry.npmjs.org/typed-array-byte-length/-/typed-array-byte-length-1.0.0.tgz",
+			"integrity": "sha512-Or/+kvLxNpeQ9DtSydonMxCx+9ZXOswtwJn17SNLvhptaXYDJvkFFP5zbfU/uLmvnBJlI4yrnXRxpdWH/M5tNA==",
+			"dev": true,
+			"dependencies": {
+				"call-bind": "^1.0.2",
+				"for-each": "^0.3.3",
+				"has-proto": "^1.0.1",
+				"is-typed-array": "^1.1.10"
+			},
+			"engines": {
+				"node": ">= 0.4"
+			},
+			"funding": {
+				"url": "https://github.com/sponsors/ljharb"
+			}
+		},
+		"node_modules/typed-array-byte-offset": {
+			"version": "1.0.0",
+			"resolved": "https://registry.npmjs.org/typed-array-byte-offset/-/typed-array-byte-offset-1.0.0.tgz",
+			"integrity": "sha512-RD97prjEt9EL8YgAgpOkf3O4IF9lhJFr9g0htQkm0rchFp/Vx7LW5Q8fSXXub7BXAODyUQohRMyOc3faCPd0hg==",
+			"dev": true,
+			"dependencies": {
+				"available-typed-arrays": "^1.0.5",
+				"call-bind": "^1.0.2",
+				"for-each": "^0.3.3",
+				"has-proto": "^1.0.1",
+				"is-typed-array": "^1.1.10"
+			},
+			"engines": {
+				"node": ">= 0.4"
+			},
+			"funding": {
+				"url": "https://github.com/sponsors/ljharb"
+			}
+		},
 		"node_modules/typed-array-length": {
 			"version": "1.0.4",
 			"resolved": "https://registry.npmjs.org/typed-array-length/-/typed-array-length-1.0.4.tgz",
@@ -2907,17 +3061,16 @@
 			}
 		},
 		"node_modules/which-typed-array": {
-			"version": "1.1.9",
-			"resolved": "https://registry.npmjs.org/which-typed-array/-/which-typed-array-1.1.9.tgz",
-			"integrity": "sha512-w9c4xkx6mPidwp7180ckYWfMmvxpjlZuIudNtDf4N/tTAUB8VJbX25qZoAsrtGuYNnGw3pa0AXgbGKRB8/EceA==",
+			"version": "1.1.11",
+			"resolved": "https://registry.npmjs.org/which-typed-array/-/which-typed-array-1.1.11.tgz",
+			"integrity": "sha512-qe9UWWpkeG5yzZ0tNYxDmd7vo58HDBc39mZ0xWWpolAGADdFOzkfamWLDxkOWcvHQKVmdTyQdLD4NOfjLWTKew==",
 			"dev": true,
 			"dependencies": {
 				"available-typed-arrays": "^1.0.5",
 				"call-bind": "^1.0.2",
 				"for-each": "^0.3.3",
 				"gopd": "^1.0.1",
-				"has-tostringtag": "^1.0.0",
-				"is-typed-array": "^1.1.10"
+				"has-tostringtag": "^1.0.0"
 			},
 			"engines": {
 				"node": ">= 0.4"
@@ -2926,15 +3079,6 @@
 				"url": "https://github.com/sponsors/ljharb"
 			}
 		},
-		"node_modules/word-wrap": {
-			"version": "1.2.4",
-			"resolved": "https://registry.npmjs.org/word-wrap/-/word-wrap-1.2.4.tgz",
-			"integrity": "sha512-2V81OA4ugVo5pRo46hAoD2ivUJx8jXmWXfUkY4KFNw0hEptvN0QfH3K4nHiwzGeKl5rFKedV48QVoqYavy4YpA==",
-			"dev": true,
-			"engines": {
-				"node": ">=0.10.0"
-			}
-		},
 		"node_modules/workerpool": {
 			"version": "6.2.1",
 			"resolved": "https://registry.npmjs.org/workerpool/-/workerpool-6.2.1.tgz",
diff --git a/package.json b/package.json
index 1cb69ee..1e9625d 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "node-red-contrib-postgresql",
-	"version": "0.13.0",
+	"version": "0.14.0",
 	"description": "Node-RED node for PostgreSQL, supporting parameters, split, back-pressure",
 	"author": {
 		"name": "Alexandre Alapetite",
@@ -49,11 +49,11 @@
 		"pg-cursor": "^2.10.0"
 	},
 	"devDependencies": {
-		"eslint": "^8.41.0",
+		"eslint": "^8.46.0",
 		"eslint-config-standard": "^17.1.0",
 		"eslint-plugin-html": "^7.1.0",
-		"eslint-plugin-import": "^2.27.5",
-		"eslint-plugin-n": "^16.0.0",
+		"eslint-plugin-import": "^2.28.0",
+		"eslint-plugin-n": "^16.0.1",
 		"eslint-plugin-promise": "^6.1.1",
 		"mocha": "^10.2.0"
 	},
diff --git a/postgresql.html b/postgresql.html
index 39ce99e..b7831a6 100644
--- a/postgresql.html
+++ b/postgresql.html
@@ -279,6 +279,12 @@
 		</label>
 		<input type="number" id="node-input-rowsPerMsg" placeholder="1" value="1" min="1" />
 	</div>
+	<div class="form-row">
+		<input type="checkbox" id="node-input-listen" style="display: inline-block; width: auto; vertical-align: top;" />
+		<label for="node-input-listen" style="width: auto;">
+			<span data-i18n="postgresql.label.listen"></span>
+		</label>
+	</div>
 	<div class="form-row" style="position: relative; margin-bottom: 0px;">
 		<label for="node-input-query">
 			<i class="fa fa-file-code-o"></i>
@@ -313,6 +319,9 @@
 			rowsPerMsg: {
 				value: 1,
 			},
+			listen: {
+				value: false,
+			},
 			outputs: {
 				value: 1,
 			},
@@ -329,6 +338,7 @@
 		oneditprepare: function () {
 			$('#node-input-split').prop('checked', this.split);
 			$('#node-input-rowsPerMsg').value = this.split ? this.rowsPerMsg : 1;
+			$('#node-input-listen').prop('checked', this.listen);
 			this.editor = RED.editor.createEditor({
 				id: 'node-input-editor',
 				mode: 'ace/mode/sql',
diff --git a/postgresql.js b/postgresql.js
index ed1415e..0db5142 100644
--- a/postgresql.js
+++ b/postgresql.js
@@ -95,6 +95,7 @@ module.exports = function (RED) {
 	function PostgreSQLNode(config) {
 		const node = this;
 		RED.nodes.createNode(node, config);
+		node.listen = config.listen;
 		node.topic = config.topic;
 		node.query = config.query;
 		node.split = config.split;
@@ -223,6 +224,22 @@ module.exports = function (RED) {
 						client = await node.config.pgPool.connect();
 					}
 
+					client.on('notice', (msg) => {
+						send({
+							notice: msg,
+						});
+					});
+
+					if (node.listen) {
+						client.on('notification', (msg) => {
+							send({
+								channel: msg.channel,
+								payload: msg.payload,
+								processId: msg.processId,
+							});
+						});
+					}
+
 					let params = [];
 					if (msg.params && msg.params.length > 0) {
 						params = msg.params;
@@ -241,7 +258,7 @@ module.exports = function (RED) {
 								handleError(err);
 							} else {
 								const complete = rows.length < node.rowsPerMsg;
-								if (complete) {
+								if (complete && !node.listen) {
 									handleDone(false);
 								}
 								const msg2 = Object.assign({}, msg, {
@@ -308,7 +325,9 @@ module.exports = function (RED) {
 									};
 								}
 
-								handleDone();
+								if (!node.listen) {
+									handleDone();
+								}
 								downstreamReady = false;
 								send(msg);
 								if (tickUpstreamNode) {

From af8bc38f1994159a4d8d01ba2b02ec6e5f613fb4 Mon Sep 17 00:00:00 2001
From: Alexandre Alapetite <alexandre.alapetite@alexandra.dk>
Date: Wed, 2 Aug 2023 15:41:24 +0200
Subject: [PATCH 2/4] Avoid multiple listening instances

---
 postgresql.js | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/postgresql.js b/postgresql.js
index 0db5142..b3f11d3 100644
--- a/postgresql.js
+++ b/postgresql.js
@@ -152,6 +152,8 @@ module.exports = function (RED) {
 		};
 		updateStatus(0, false);
 
+		let client = null;
+
 		node.on('input', async (msg, send, done) => {
 			// 'send' and 'done' require Node-RED 1.0+
 			send = send || function () { node.send.apply(node, arguments); };
@@ -171,8 +173,6 @@ module.exports = function (RED) {
 				const partsId = Math.random();
 				let query = msg.query ? msg.query : Mustache.render(node.query, { msg });
 
-				let client = null;
-
 				const handleDone = async (isError = false) => {
 					if (cursor) {
 						cursor.close();
@@ -212,7 +212,10 @@ module.exports = function (RED) {
 					}
 				};
 
-				handleDone();
+				if (node.listen) {
+					// Avoid multiple listening instances
+					handleDone();
+				}
 				updateStatus(+1);
 				downstreamReady = true;
 

From e69c1f80de1ab1e06be987f20a8229c474aeabf3 Mon Sep 17 00:00:00 2001
From: Alexandre Alapetite <alexandre.alapetite@alexandra.dk>
Date: Wed, 2 Aug 2023 16:55:57 +0200
Subject: [PATCH 3/4] Do not use pool for clients with custom config nor for
 listeners

---
 postgresql.js | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/postgresql.js b/postgresql.js
index b3f11d3..d99bc91 100644
--- a/postgresql.js
+++ b/postgresql.js
@@ -220,8 +220,13 @@ module.exports = function (RED) {
 				downstreamReady = true;
 
 				try {
-					if (msg.pgConfig) {
-						client = new Client(msg.pgConfig);
+					if (msg.pgConfig || node.listen) {
+						// Do not use pool for clients with custom config nor for listeners
+						const pgConfig = Object.assign({},
+							node.config.pgPool.options, {
+								password: node.config.password,
+							}, msg.pgConfig);
+						client = new Client(pgConfig);
 						await client.connect();
 					} else {
 						client = await node.config.pgPool.connect();

From 6866f024eed0127ae920ee25a34ee15b2571c7b8 Mon Sep 17 00:00:00 2001
From: Alexandre Alapetite <alexandre.alapetite@alexandra.dk>
Date: Mon, 6 Nov 2023 11:17:01 +0100
Subject: [PATCH 4/4] Draft

---
 .github/workflows/nodejs.yml      | 2 +-
 .github/workflows/npm-publish.yml | 6 +++---
 postgresql.html                   | 8 ++++----
 postgresql.js                     | 6 +++---
 4 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/.github/workflows/nodejs.yml b/.github/workflows/nodejs.yml
index e3c63d8..b08142e 100644
--- a/.github/workflows/nodejs.yml
+++ b/.github/workflows/nodejs.yml
@@ -16,7 +16,7 @@ jobs:
         node-version: [16.x, 20.x]
 
     steps:
-    - uses: actions/checkout@v3
+    - uses: actions/checkout@v4
     - name: Use Node.js ${{ matrix.node-version }}
       uses: actions/setup-node@v3
       with:
diff --git a/.github/workflows/npm-publish.yml b/.github/workflows/npm-publish.yml
index 73040d1..b899edb 100644
--- a/.github/workflows/npm-publish.yml
+++ b/.github/workflows/npm-publish.yml
@@ -11,7 +11,7 @@ jobs:
   build:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
       - uses: actions/setup-node@v3
         with:
           node-version: 18
@@ -22,7 +22,7 @@ jobs:
     needs: build
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
       - uses: actions/setup-node@v3
         with:
           node-version: 18
@@ -39,7 +39,7 @@ jobs:
 #      contents: read
 #      packages: write
 #    steps:
-#      - uses: actions/checkout@v3
+#      - uses: actions/checkout@v4
 #      - uses: actions/setup-node@v3
 #        with:
 #          node-version: 18
diff --git a/postgresql.html b/postgresql.html
index b7831a6..660b156 100644
--- a/postgresql.html
+++ b/postgresql.html
@@ -24,7 +24,7 @@
 						<span data-i18n="postgresql.label.port"></span>
 					</label>
 					<input type="text" id="node-config-input-port" data-i18n="[placeholder]postgresql.placeholder.port" style="width: 80%;" />
-					<input type="hidden" id="node-config-input-portFieldType" />
+					<input type="hidden" id="node-config-input-portFieldType" value="num" />
 				</div>
 			<div class="form-row">
 				<label for="node-config-input-database">
@@ -75,7 +75,7 @@
 					<span data-i18n="postgresql.label.max"></span>
 				</label>
 				<input type="text" id="node-config-input-max" data-i18n="[placeholder]postgresql.placeholder.max" style="width: 60%;" />
-				<input type="hidden" id="node-config-input-maxFieldType" />
+				<input type="hidden" id="node-config-input-maxFieldType" value="num" />
 			</div>
 			<div class="form-row">
 				<label for="node-config-input-idle" style="width: 150px;">
@@ -83,7 +83,7 @@
 					<span data-i18n="postgresql.label.idle"></span>
 				</label>
 				<input type="text" id="node-config-input-idle" data-i18n="[placeholder]postgresql.placeholder.idle" style="width: 60%;" />
-				<input type="hidden" id="node-config-input-idleFieldType" />
+				<input type="hidden" id="node-config-input-idleFieldType" value="num" />
 			</div>
 			<div class="form-row">
 				<label for="node-config-input-connectionTimeout" style="width: 150px;">
@@ -91,7 +91,7 @@
 					<span data-i18n="postgresql.label.connectionTimeout" ></span>
 				</label>
 				<input type="text" id="node-config-input-connectionTimeout" data-i18n="[placeholder]postgresql.placeholder.connectionTimeout" style="width: 60%;" />
-				<input type="hidden" id="node-config-input-connectionTimeoutFieldType" />
+				<input type="hidden" id="node-config-input-connectionTimeoutFieldType" value="num" />
 			</div>
 		</div>
 	</div>
diff --git a/postgresql.js b/postgresql.js
index c507c92..b037c94 100644
--- a/postgresql.js
+++ b/postgresql.js
@@ -82,11 +82,11 @@ module.exports = function (RED) {
 			host: getField(node, n.hostFieldType, n.host),
 			port: getField(node, n.portFieldType, n.port),
 			database: getField(node, n.databaseFieldType, n.database),
-			ssl: getField(node, n.sslFieldType, n.ssl),
+			ssl: getField(node, n.sslFieldType, n.ssl) != 'false',
 			application_name: getField(node, n.applicationNameType, n.applicationName),
 			max: getField(node, n.maxFieldType, n.max),
-			idleTimeoutMillis: getField(node, n.idleFieldType, n.idle),
-			connectionTimeoutMillis: getField(node, n.connectionTimeoutFieldType, n.connectionTimeout),
+			idleTimeoutMillis: +getField(node, n.idleFieldType, n.idle),
+			connectionTimeoutMillis: +getField(node, n.connectionTimeoutFieldType, n.connectionTimeout),
 		});
 		this.pgPool.on('error', (err, _) => {
 			node.error(err.message);