Expose server parameters

porsager · porsager · commit 45995f4edd4b · 2019-11-26T13:18:27.000+01:00
diff --git a/lib/backend.js b/lib/backend.js
@@ -6,6 +6,7 @@ const char = (acc, [k, v]) => (acc[k.charCodeAt(0)] = v, acc)
 export default Backend
 
 function Backend({
+  onparameter,
   parsers,
   onauth,
   onready,
@@ -46,7 +47,6 @@ function Backend({
 
   const state = backend.state = {
     status    : 'I',
-    settings  : {},
     pid       : null,
     secret    : null
   }
@@ -167,7 +167,7 @@ function Backend({
 
   function ParameterStatus(x) {
     const [k, v] = x.utf8Slice(5, x.length - 1).split(N)
-    state.settings[k] = v
+    onparameter(k, v)
   }
 
   function PortalSuspended(x) {
diff --git a/lib/connection.js b/lib/connection.js
@@ -7,6 +7,7 @@ import { errors } from './types.js'
 
 export default function Connection(options = {}) {
   const {
+    onparameter,
     transform,
     timeout,
     onnotify,
@@ -33,6 +34,7 @@ export default function Connection(options = {}) {
   })
 
   const backend = Backend({
+    onparameter,
     transform,
     parsers,
     resolve,
diff --git a/lib/index.js b/lib/index.js
@@ -41,13 +41,22 @@ export default function Postgres(url, options) {
   }
 
   Object.assign(postgres, {
+    parameters: {},
     listen,
     begin,
     end
   })
 
   addTypes(postgres)
 
+  const onparameter = options.onparameter
+  options.onparameter = (k, v) => {
+    if (postgres.parameters[k] !== v) {
+      postgres.parameters[k] = v
+      onparameter && onparameter(k, v)
+    }
+  }
+
   return postgres
 
   function begin(options, fn) {
@@ -110,10 +119,7 @@ export default function Postgres(url, options) {
       })
 
     function scoped(xs, ...args) {
-      return query(false, connection, xs, args).catch(err => {
-        reject(err)
-        throw err
-      })
+      return query(false, connection, xs, args).catch(reject)
     }
   }
 
