Update v3

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pg-async",
-  "version": "2.4.3",
+  "version": "3.0.0",
   "description": "PostgreSQL client for node.js designed for usage with ES7 async/await based on node-postgres (pg) module",
   "main": "lib/index.js",
   "scripts": {
@@ -36,22 +36,22 @@
   "homepage": "https://github.com/langpavel/node-pg-async#readme",
   "dependencies": {
     "bluebird": "^3.4.6",
-    "debug": "^2.5.0",
-    "pg": "^6.1.0"
+    "debug": "^2.6.3",
+    "pg": "^6.1.4"
   },
   "devDependencies": {
     "babel": "^6.5.2",
-    "babel-core": "^6.7.7",
+    "babel-core": "^6.24.0",
     "babel-eslint": "^7.1.1",
     "babel-plugin-add-module-exports": "^0.2.1",
     "babel-preset-es2015-node5": "^1.2.0",
     "babel-preset-stage-1": "^6.5.0",
-    "babel-register": "^6.7.2",
+    "babel-register": "^6.24.0",
     "chai": "^3.5.0",
     "del": "^2.2.0",
     "eslint": "^3.1.1",
-    "eslint-config-strict": "^12.0.0",
-    "eslint-plugin-import": "^1.4.0",
+    "eslint-config-strict": "^13.0.0",
+    "eslint-plugin-import": "^2.2.0",
     "estraverse-fb": "^1.3.1",
     "gulp": "^3.9.1",
     "gulp-babel": "^6.1.2",

src/index.js

@@ -74,7 +74,10 @@ export default class PgAsync {
 
   async getClient() {
     return new Promise((resolve, reject) => {
-      this.getDriver().connect(this.getConnectionOptions(), (err, client, done) => {
+      const driver = this.getDriver();
+      const Pool = driver.Pool;
+      const pool = new Pool(this.getConnectionOptions());
+      pool.connect((err, client, done) => {
         if (err) {
           debug('%s getClient(%j)', err, this.getConnectionOptions());
           if (done) done(err);

test/mock/pgMock.js

@@ -17,15 +17,23 @@ export class Client {
   }
 }
 
+function poolFactory(driver) {
+  return function Pool() {
+    return driver;
+  };
+};
+
 export default class PgMock {
-  constructor() {
+  constructor(conString) {
+    this.conString = conString;
     this.connections = 0;
     this.defaults = {};
     this.done = this.done.bind(this);
+    this.Pool = poolFactory(this);
   }
 
-  connect(conString, cb) {
-    if (conString === 'INVALID') {
+  connect(cb) {
+    if (this.conString === 'INVALID') {
       setImmediate(() => cb(new Error));
     } else {
       this.connections++;