Fix .end() hanging as pending forever

Author: porsager

lib/connection.js

@@ -322,7 +322,7 @@ function postgresSocket(options, {
       return Promise.resolve()
     },
     end: () => {
-      return new Promise(r => socket ? socket.end(r) : r())
+      return new Promise(r => socket && !closed ? socket.once('close', r) : r())
     },
     connect
   }

tests/index.js

@@ -1087,6 +1087,16 @@ t('Catches connection config errors', async() => {
   ]
 })
 
+t('Catches connection config errors with end', async() => {
+  const sql = postgres({ ...options, user: { toString: () => { throw new Error('wat') } }, database: 'prut' })
+
+  return [
+    'wat',
+    await sql`select 1`.catch((e) => e.message),
+    await sql.end()
+  ]
+})
+
 t('Catches query format errors', async() => [
   'wat',
   await sql.unsafe({ toString: () => { throw new Error('wat') } }).catch((e) => e.message)