@fraight/transaction-tools
Advanced tools
Comparing version 1.1.1 to 1.1.2
@@ -49,5 +49,5 @@ const cls = require('cls-hooked'); | ||
if (req.transactionPromise) { | ||
const resolve = requestResolvers[req.id]; | ||
const resolve = requestResolvers[req.req_id]; | ||
resolve(); | ||
delete requestResolvers[req.id]; | ||
delete requestResolvers[req.req_id]; | ||
await req.transactionPromise; | ||
@@ -58,6 +58,6 @@ } | ||
req.transactionPromise = db.transaction(async function(t) { | ||
req.transactionPromise = db.transaction({ isolationLevel: db.Transaction.ISOLATION_LEVELS.READ_COMMITTED }, async function(t) { | ||
Sequelize.cls.set('req', req); | ||
const beforeFinish = new Promise((resolve) => { | ||
requestResolvers[req.id] = resolve; | ||
requestResolvers[req.req_id] = resolve; | ||
next(); | ||
@@ -76,2 +76,3 @@ }); | ||
db.transaction(transactionSettings, async t => { | ||
Sequelize.cls.set('job', job); | ||
await handler.call(this, job, done); | ||
@@ -78,0 +79,0 @@ }) |
{ | ||
"name": "@fraight/transaction-tools", | ||
"version": "1.1.1", | ||
"version": "1.1.2", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
4573
78