.travis.yml

@@ -14,10 +14,10 @@ matrix:
     - node_js: "lts/argon"
       addons:
         postgresql: "9.6"
-    - node_js: "9"
+    - node_js: "10"
       addons:
         postgresql: "9.6"
-    - node_js: "10"
+    - node_js: "11"
       addons:
         postgresql: "9.6"
     - node_js: "lts/carbon"

CHANGELOG.md

@@ -4,6 +4,9 @@ For richer information consult the commit log on github with referenced pull req
 
 We do not include break-fix version release in this file.
 
+### 7.6.0
+- Add support for ["bring your own promise"](https://github.com/brianc/node-postgres/pull/1518)
+
 ### 7.5.0
 
 - Better [error message](https://github.com/brianc/node-postgres/commit/11a4793452d618c53e019416cc886ad38deb1aa7) when passing `null` or `undefined` to `client.query`.

SPONSORS.md

@@ -11,4 +11,9 @@ node-postgres is made possible by the helpful contributors from the community we
 - Arnaud Benhamdine [@abenhamdine](https://twitter.com/abenhamdine)
 - Matthew Welke
 - Matthew Weber
+- Andrea De Simon
+- Todd Kennedy
+- Alexander Robson
 - Benjie Gillam
+- David Hanson
+- Franklin Davenport

lib/client.js

@@ -31,6 +31,7 @@ var Client = function (config) {
 
   var c = config || {}
 
+  this._Promise = c.Promise || global.Promise
   this._types = new TypeOverrides(c.types)
   this._ending = false
   this._connecting = false
@@ -232,7 +233,7 @@ Client.prototype.connect = function (callback) {
     return
   }
 
-  return new Promise((resolve, reject) => {
+  return new this._Promise((resolve, reject) => {
     this._connect((error) => {
       if (error) {
         reject(error)
@@ -409,12 +410,9 @@ Client.prototype.query = function (config, values, callback) {
   } else {
     query = new Query(config, values, callback)
     if (!query.callback) {
-      let resolveOut, rejectOut
-      result = new Promise((resolve, reject) => {
-        resolveOut = resolve
-        rejectOut = reject
+      result = new this._Promise((resolve, reject) => {
+        query.callback = (err, res) => err ? reject(err) : resolve(res)
       })
-      query.callback = (err, res) => err ? rejectOut(err) : resolveOut(res)
     }
   }
 
@@ -458,7 +456,7 @@ Client.prototype.end = function (cb) {
   if (cb) {
     this.connection.once('end', cb)
   } else {
-    return new Promise((resolve) => {
+    return new this._Promise((resolve) => {
       this.connection.once('end', resolve)
     })
   }

lib/connection-parameters.js

@@ -87,7 +87,7 @@ ConnectionParameters.prototype.getLibpqConnectionString = function (cb) {
   add(params, this, 'application_name')
   add(params, this, 'fallback_application_name')
 
-  var ssl = typeof this.ssl === 'object' ? this.ssl : {sslmode: this.ssl}
+  var ssl = typeof this.ssl === 'object' ? this.ssl : { sslmode: this.ssl }
   add(params, ssl, 'sslmode')
   add(params, ssl, 'sslca')
   add(params, ssl, 'sslkey')

lib/native/client.js

@@ -25,6 +25,7 @@ var Client = module.exports = function (config) {
   EventEmitter.call(this)
   config = config || {}
 
+  this._Promise = config.Promise || global.Promise
   this._types = new TypeOverrides(config.types)
 
   this.native = new Native({
@@ -121,7 +122,7 @@ Client.prototype.connect = function (callback) {
     return
   }
 
-  return new Promise((resolve, reject) => {
+  return new this._Promise((resolve, reject) => {
     this._connect((error) => {
       if (error) {
         reject(error)
@@ -156,7 +157,7 @@ Client.prototype.query = function (config, values, callback) {
     query = new NativeQuery(config, values, callback)
     if (!query.callback) {
       let resolveOut, rejectOut
-      result = new Promise((resolve, reject) => {
+      result = new this._Promise((resolve, reject) => {
         resolveOut = resolve
         rejectOut = reject
       })
@@ -196,11 +197,8 @@ Client.prototype.end = function (cb) {
   }
   var result
   if (!cb) {
-    var resolve, reject
-    cb = (err) => err ? reject(err) : resolve()
-    result = new global.Promise(function (res, rej) {
-      resolve = res
-      reject = rej
+    result = new this._Promise(function (resolve, reject) {
+      cb = (err) => err ? reject(err) : resolve()
     })
   }
   this.native.end(function () {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pg",
-  "version": "7.5.0",
+  "version": "7.6.0",
   "description": "PostgreSQL client - pure javascript & libpq with the same API",
   "keywords": [
     "database",
@@ -29,13 +29,14 @@
   },
   "devDependencies": {
     "async": "0.9.0",
+    "bluebird": "3.5.2",
     "co": "4.6.0",
-    "eslint": "4.2.0",
-    "eslint-config-standard": "10.2.1",
-    "eslint-plugin-import": "2.7.0",
-    "eslint-plugin-node": "5.1.0",
-    "eslint-plugin-promise": "3.5.0",
-    "eslint-plugin-standard": "3.0.1",
+    "eslint": "^4.19.1",
+    "eslint-config-standard": "^11.0.0",
+    "eslint-plugin-import": "^2.14.0",
+    "eslint-plugin-node": "^6.0.1",
+    "eslint-plugin-promise": "^4.0.1",
+    "eslint-plugin-standard": "^3.1.0",
     "pg-copy-streams": "0.3.0"
   },
   "minNativeVersion": "2.0.0",

test/integration/client/query-as-promise-tests.js

@@ -1,4 +1,5 @@
 'use strict'
+var bluebird = require('bluebird')
 var helper = require(__dirname + '/../test-helper')
 var pg = helper.pg
 
@@ -7,10 +8,10 @@ process.on('unhandledRejection', function (e) {
   process.exit(1)
 })
 
-const pool = new pg.Pool()
 const suite = new helper.Suite()
 
 suite.test('promise API', (cb) => {
+  const pool = new pg.Pool()
   pool.connect().then((client) => {
     client.query('SELECT $1::text as name', ['foo'])
       .then(function (result) {
@@ -31,3 +32,24 @@ suite.test('promise API', (cb) => {
       })
   })
 })
+
+suite.test('promise API with configurable promise type', (cb) => {
+  const client = new pg.Client({ Promise: bluebird })
+  const connectPromise = client.connect()
+  assert(connectPromise instanceof bluebird, 'Client connect() returns configured promise')
+
+  connectPromise
+    .then(() => {
+      const queryPromise = client.query('SELECT 1')
+      assert(queryPromise instanceof bluebird, 'Client query() returns configured promise')
+
+      return queryPromise.then(() => {
+        client.end(cb)
+      })
+    })
+    .catch((error) => {
+      process.nextTick(() => {
+        throw error
+      })
+    })
+});