@fraight/transaction-tools
Advanced tools
Comparing version 1.2.2 to 1.2.3
@@ -13,4 +13,8 @@ const Context = require('./context'); | ||
if (req.transactionPromise) { | ||
const resolve = RequestContext.requestResolvers.get(context); | ||
resolve(); | ||
const { resolve, reject } = RequestContext.requestResolvers.get(context); | ||
if (res.statusCode < 400) { | ||
resolve(); | ||
} else { | ||
reject(); | ||
} | ||
RequestContext.requestResolvers.delete(context); | ||
@@ -24,4 +28,4 @@ await req.transactionPromise; | ||
Sequelize.cls.set('context', context); | ||
const beforeFinish = new Promise((resolve) => { | ||
RequestContext.requestResolvers.set(context, resolve); | ||
const beforeFinish = new Promise((resolve, reject) => { | ||
RequestContext.requestResolvers.set(context, { resolve, reject }); | ||
next(); | ||
@@ -28,0 +32,0 @@ }); |
{ | ||
"name": "@fraight/transaction-tools", | ||
"version": "1.2.2", | ||
"version": "1.2.3", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
18562
146