Fix connection config errors being swallowed

Author: porsager

lib/connection.js

@@ -38,7 +38,7 @@ function Connection(options = {}) {
       , connection = { send, end, destroy }
 
   const socket = postgresSocket(options, {
-    ready: () => socket.write(frontend.connect(options)),
+    ready,
     data,
     error,
     close
@@ -114,26 +114,26 @@ function Connection(options = {}) {
   }
 
   function send(query, { sig, str, args = [] }) {
-    query.str = str
-    query.args = args
-    query.result = []
-    query.result.count = null
-    idle_timeout && clearTimeout(timer)
-
-    typeof options.debug === 'function' && options.debug(id, str, args)
-    const buffer = query.simple
-      ? simple(str, query)
-      : sig in statements
-        ? prepared(statements[sig], args, query)
-        : prepare(sig, str, args, query)
-
-    ready
-      ? (backend.query = query, ready = false)
-      : queries.push(query)
-
-    open
-      ? socket.write(buffer)
-      : (messages.push(buffer), connect())
+      query.str = str
+      query.args = args
+      query.result = []
+      query.result.count = null
+      idle_timeout && clearTimeout(timer)
+
+      typeof options.debug === 'function' && options.debug(id, str, args)
+      const buffer = query.simple
+        ? simple(str, query)
+        : sig in statements
+          ? prepared(statements[sig], args, query)
+          : prepare(sig, str, args, query)
+
+      ready
+        ? (backend.query = query, ready = false)
+        : queries.push(query)
+
+      open
+        ? socket.write(buffer)
+        : (messages.push(buffer), connect())
   }
 
   function connect() {
@@ -244,7 +244,6 @@ function Connection(options = {}) {
 function postgresSocket(options, {
   error,
   close,
-  ready,
   data
 }) {
   let socket
@@ -295,6 +294,14 @@ function postgresSocket(options, {
     socket.once('close', onclose)
   }
 
+  function ready() {
+    try {
+      socket.write(frontend.connect(options))
+    } catch (e) {
+      error(e)
+    }
+  }
+
   const x = {
     write: x => {
       buffer = buffer ? Buffer.concat([buffer, x]) : Buffer.from(x)

tests/index.js

@@ -1075,3 +1075,12 @@ t('no_prepare: true disables prepared transactions', async() => {
   const result = await sql`select * from pg_prepared_statements`
   return [0, result.count]
 })
+
+o('Catches connection config errors', async() => {
+  const sql = postgres({ user: { toString: () => { throw new Error('wat') } }, database: 'prut' })
+
+  return [
+    'wat',
+    await sql`select 1`.catch((e) => e.message)
+  ]
+})