handle connection timeouts from node-pg, fixes #1207

lib/associations/has-one.js

@@ -151,7 +151,6 @@ module.exports = (function() {
           .create(values, fieldsOrOptions)
           .create(values, fieldsOrOptions)
           .proxy(emitter, { events: ['error', 'sql'] })
           .proxy(emitter, { events: ['error', 'sql'] })
           .success(function(newAssociatedObject) {
           .success(function(newAssociatedObject) {
-            console.log(self.accessors.set, !!newAssociatedObject, !!options.transaction);
             instance[self.accessors.set](newAssociatedObject, options)
             instance[self.accessors.set](newAssociatedObject, options)
               .proxy(emitter)
               .proxy(emitter)
           })
           })

lib/dao-factory.js

@@ -287,16 +287,15 @@ module.exports = (function() {
         self
         self
           .QueryInterface
           .QueryInterface
           .createTable(self.getTableName(), self.attributes, options)
           .createTable(self.getTableName(), self.attributes, options)
+          .proxy(emitter, {events: ['error', 'sql']})
           .success(function() { emitter.emit('success', self) })
           .success(function() { emitter.emit('success', self) })
-          .error(function(err) { emitter.emit('error', err) })
-          .on('sql', function(sql) { emitter.emit('sql', sql) })
       }
       }
 
 
       if (options.force) {
       if (options.force) {
         self
         self
           .drop(options)
           .drop(options)
+          .proxy(emitter, {events: ['error', 'sql']})
           .success(doQuery)
           .success(doQuery)
-          .error(function(err) { emitter.emit('error', err) })
       } else {
       } else {
         doQuery()
         doQuery()
       }
       }

lib/dialects/postgres/connector-manager.js

@@ -148,11 +148,22 @@ module.exports = (function() {
         connectCallback(null, this.client)
         connectCallback(null, this.client)
       } else {
       } else {
         //create one-off client
         //create one-off client
+
+        var responded = false
+
         this.client = new this.pg.Client(uri)
         this.client = new this.pg.Client(uri)
         this.client.connect(function(err, client, done) {
         this.client.connect(function(err, client, done) {
+          responded = true
           connectCallback(err, client || self.client, done)
           connectCallback(err, client || self.client, done)
         })
         })
 
 
+        // If we didn't ever hear from the client.connect() callback the connection timedout, node-postgres does not treat this as an error since no active query was ever emitted
+        this.client.on('end', function () {
+          if (!responded) {
+            connectCallback(new Error('Connection timed out'))
+          }
+        })
+
         // Closes a client correctly even if we have backed up queries
         // Closes a client correctly even if we have backed up queries
         // https://github.com/brianc/node-postgres/pull/346
         // https://github.com/brianc/node-postgres/pull/346
         this.client.on('drain', function() {
         this.client.on('drain', function() {

lib/query-interface.js

@@ -902,7 +902,6 @@ module.exports = (function() {
     }, options || {})
     }, options || {})
 
 
     var execQuery = function(emitter) {
     var execQuery = function(emitter) {
-      var query = null
 
 
       if (Array.isArray(sqlOrQueryParams)) {
       if (Array.isArray(sqlOrQueryParams)) {
         if (sqlOrQueryParams.length === 1) {
         if (sqlOrQueryParams.length === 1) {
@@ -920,19 +919,19 @@ module.exports = (function() {
 
 
       emitter
       emitter
         .query
         .query
+        .proxy(emitter)
         .success(function(obj) {
         .success(function(obj) {
-          options.success && options.success(obj)
+          if (options.success) {
+            options.success(obj)
+          }
           this.emit(methodName, null)
           this.emit(methodName, null)
-          emitter.emit('success', obj)
         }.bind(this))
         }.bind(this))
         .error(function(err) {
         .error(function(err) {
-          options.error && options.error(err)
+          if (options.error) {
+            options.error(err)
+          }
           this.emit(methodName, err)
           this.emit(methodName, err)
-          emitter.emit('error', err)
         }.bind(this))
         }.bind(this))
-        .on('sql', function(sql) {
-          emitter.emit('sql', sql)
-        })
     }.bind(this)
     }.bind(this)
 
 
     if (!!emitter) {
     if (!!emitter) {

test/sequelize.test.js

@@ -397,14 +397,15 @@ describe(Support.getTestDialectTeaser("Sequelize"), function () {
     })
     })
 
 
     if (dialect !== "sqlite") {
     if (dialect !== "sqlite") {
-      it("fails with incorrect database credentials", function(done) {
-        this.sequelizeWithInvalidCredentials = new Sequelize("omg", "bar", null, this.sequelize.options)
+      it("fails with incorrect database credentials (1)", function(done) {
+        this.sequelizeWithInvalidCredentials = new Sequelize("omg", "bar", null, _.omit(this.sequelize.options, ['host']))
 
 
         var User2 = this.sequelizeWithInvalidCredentials.define('User', { name: DataTypes.STRING, bio: DataTypes.TEXT })
         var User2 = this.sequelizeWithInvalidCredentials.define('User', { name: DataTypes.STRING, bio: DataTypes.TEXT })
 
 
         User2.sync().error(function(err) {
         User2.sync().error(function(err) {
           if (dialect === "postgres" || dialect === "postgres-native") {
           if (dialect === "postgres" || dialect === "postgres-native") {
             assert([
             assert([
+              'fe_sendauth: no password supplied',
               'role "bar" does not exist',
               'role "bar" does not exist',
               'FATAL:  role "bar" does not exist',
               'FATAL:  role "bar" does not exist',
               'password authentication failed for user "bar"'
               'password authentication failed for user "bar"'
@@ -415,6 +416,20 @@ describe(Support.getTestDialectTeaser("Sequelize"), function () {
           done()
           done()
         })
         })
       })
       })
+
+      it('fails with incorrect database credentials (2)', function (done) {
+        var sequelize = new Sequelize('db', 'user', 'pass', {
+          dialect: this.sequelize.options.dialect
+        });
+
+        var Project = sequelize.define('Project', {title: Sequelize.STRING})
+        var Task = sequelize.define('Task', {title: Sequelize.STRING})
+
+        sequelize.sync({force: true}).done(function (err) {
+          expect(err).to.be.ok
+          done()
+        })
+      })
     }
     }
 
 
     describe("doesn't emit logging when explicitly saying not to", function() {
     describe("doesn't emit logging when explicitly saying not to", function() {