commit and rollback transactions

lib/transaction.js

 var Utils = require('./utils')
   , util  = require('util')
 
-var Transaction = module.exports = function(options) {
+var Transaction = module.exports = function(sequelize, options) {
+  this.sequelize = sequelize
   this.options   = options || {}
   this.id        = Utils.generateUUID()
 }
@@ -9,10 +10,18 @@ var Transaction = module.exports = function(options) {
 util.inherits(Transaction, Utils.CustomEventEmitter)
 
 Transaction.prototype.commit = function() {
-  this.emit('success')
+  this
+    .sequelize
+    .getQueryInterface()
+    .commitTransaction({ transaction: this })
+    .proxy(this)
 }
 
 
 Transaction.prototype.rollback = function() {
-  this.emit('success')
+  this
+    .sequelize
+    .getQueryInterface()
+    .rollbackTransaction({ transaction: this })
+    .proxy(this)
 }