fixed update destroy and save query

lib/model.js

@@ -32,16 +32,18 @@ module.exports = (function() {
   })
 
   Model.prototype.save = function() {
-    var attr = this.__options.underscored ? 'updated_at' : 'updatedAt'
+    var updatedAtAttr = this.__options.underscored ? 'updated_at' : 'updatedAt'
 
-    if(this.hasOwnProperty(attr))
-      this[attr] = new Date()
+    if(this.hasOwnProperty(updatedAtAttr))
+      this[updatedAtAttr] = new Date()
 
     if(this.isNewRecord) {
       return this.QueryInterface.insert(this, this.__definition.tableName, this.values)
     } else {
       var identifier = this.__options.hasPrimaryKeys ? this.primaryKeyValues : this.id
-      return this.QueryInterface.update(this, this.__definition.tableName, this.values, identifier)
+        , query = this.QueryInterface.update(this, this.__definition.tableName, this.values, identifier)
+
+      return query
     }
   }
 
@@ -133,7 +135,8 @@ module.exports = (function() {
 
   Model.prototype.destroy = function() {
     if(this.__options.timestamps && this.__options.paranoid) {
-      this[this.__options.underscored ? 'deleted_at' : 'deletedAt'] = new Date()
+      var attr = this.__options.underscored ? 'deleted_at' : 'deletedAt'
+      this[attr] = new Date()
       return this.save()
     } else {
       var identifier = this.__options.hasPrimaryKeys ? this.primaryKeyValues : this.id

lib/query-interface.js

@@ -167,35 +167,25 @@ module.exports = (function() {
 
   QueryInterface.prototype.insert = function(model, tableName, values) {
     var self = this
+      , sql  = self.QueryGenerator.insertQuery(tableName, values)
 
-    return new Utils.CustomEventEmitter(function(emitter) {
-      query
-        .call(self, self.QueryGenerator.insertQuery(tableName, values), model)
-        .success(function(obj) {
-          self.emit('insert', null)
-
-          obj.isNewRecord = false
-          emitter.emit('success', obj)
-        })
-        .error(function(err) {
-          self.emit('insert', err)
-          emitter.emit('failure', err)
-        })
-    }).run()
+    return queryAndEmit.call(this, [sql, model], 'insert', {
+      success: function(obj) { obj.isNewRecord = false }
+    })
   }
 
   QueryInterface.prototype.update = function(model, tableName, values, identifier) {
     var sql  = this.QueryGenerator.updateQuery(tableName, values, identifier)
       , self = this
 
-    return queryAndEmit.call(this, sql, 'update')
+    return queryAndEmit.call(this, [sql, model], 'update')
   }
 
   QueryInterface.prototype.delete = function(model, tableName, identifier) {
     var sql  = this.QueryGenerator.deleteQuery(tableName, identifier)
       , self = this
 
-    return queryAndEmit.call(this, sql, 'delete')
+    return queryAndEmit.call(this, [sql, model], 'delete')
   }
 
   QueryInterface.prototype.select = function(factory, tableName, options, queryOptions) {
@@ -232,14 +222,28 @@ module.exports = (function() {
 
   // private
 
-  var queryAndEmit = function(sql, methodName) {
+  var queryAndEmit = function(sqlOrQueryParams, methodName, options) {
     var self = this
 
+    options = Utils._.extend({
+      success: function(obj){},
+      error: function(err){}
+    }, options || {})
+
     return new Utils.CustomEventEmitter(function(emitter) {
-      self.sequelize.query(sql).success(function() {
+      var query = null
+
+      if(Array.isArray(sqlOrQueryParams))
+        query = self.sequelize.query.apply(self.sequelize, sqlOrQueryParams)
+      else
+        query = self.sequelize.query(sqlOrQueryParams)
+
+      query.success(function(obj) {
+        options.success && options.success(obj)
         self.emit(methodName, null)
-        emitter.emit('success', null)
+        emitter.emit('success', obj)
       }).error(function(err) {
+        options.error && options.error(err)
         self.emit(methodName, err)
         emitter.emit('failure', err)
       })

test/Model/destroy.js

@@ -23,9 +23,9 @@ module.exports = {
   'destroy should mark the record as deleted if paranoid is activated': function(exit) {
     var User = sequelize.define('User' + config.rand(), { name: Sequelize.STRING, bio: Sequelize.TEXT }, {paranoid:true})
     User.sync({force: true}).on('success', function() {
-      User.create({name: 'asd', bio: 'asd'}).on('success', function(u) {
+      User.create({name: 'asd', bio: 'asd'}).success(function(u) {
         assert.isNull(u.deletedAt)
-        u.destroy().on('success', function(u) {
+        u.destroy().success(function(u) {
           assert.isNotNull(u.deletedAt)
           exit(function(){})
         })