@fraight/transaction-tools - npm Package Compare versions

Comparing version 1.2.6 to 1.2.7

context/worker.js

@@ -5,3 +5,2 @@ const Context = require('./context');
 class WorkerContext extends Context {
-
   constructor(config) {
@@ -13,14 +12,21 @@ super(config);
   static factory({ db, queue }) {
-    queue.processWithTransaction = function(config) {
-      const { name, concurrency, handler, transactionSettings} = config
-      const shimmedHandler = function(job) {
+    queue.processWithTransaction = function processWithTransaction(config) {
+      const { name, concurrency, handler, transactionSettings } = config;
+      const shimmedHandler = function shimmedHandler(job) {
         const context = new WorkerContext({ job });
-        return db.transaction(transactionSettings, async t => {
-          Sequelize.cls.set('context', context);
-          await handler.call(this, job);
-        })
-      }
+        return new Promise(async (resolve, reject) => {
+          try {
+            await db.transaction(transactionSettings, async (t) => {
+              Sequelize.cls.set('context', context);
+              const jobResult = await handler.call(this, job);
+              resolve(jobResult);
+            });
+          } catch (e) {
+            reject(e);
+          }
+        });
+      };
       const processArgs = [name, concurrency, shimmedHandler].filter(v => !!v);
-      queue.process(...processArgs)
-    }
+      queue.process(...processArgs);
+    };
   }
@@ -27,0 +33,0 @@ }

package.json

 {
   "name": "@fraight/transaction-tools",
-  "version": "1.2.6",
+  "version": "1.2.7",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

24115

1.07%

Lines of code

197

3.68%

No dependency changes