const logger = require('./logger')
const utils = {
+ commitTransaction,
retryTransactionWrapper,
- transactionRetryer,
- startSerializableTransaction
+ rollbackTransaction,
+ startSerializableTransaction,
+ transactionRetryer
+}
+
+function commitTransaction (t, callback) {
+ return t.commit().asCallback(callback)
+}
+
+function rollbackTransaction (err, t, callback) {
+ // Try to rollback transaction
+ if (t) {
+ // Do not catch err, report the original one
+ t.rollback().asCallback(function () {
+ return callback(err)
+ })
+ } else {
+ return callback(err)
+ }
}
// { arguments, errorMessage }
}
function startSerializableTransaction (callback) {
- console.log(db)
db.sequelize.transaction({ isolationLevel: 'SERIALIZABLE' }).asCallback(function (err, t) {
// We force to return only two parameters
return callback(err, t)