feat: deserialize error after it comes in

BREAKING CHANGE: error format would change to an Error object and not
serialized js object with properties

Author: AVVS

package.json

@@ -34,28 +34,28 @@
     "ioredis": "~4.x.x"
   },
   "dependencies": {
-    "bluebird": "^3.5.5",
+    "bluebird": "^3.7.1",
     "bunyan": "^1.8.12",
     "callback-queue": "^3.0.0",
     "denque": "^1.4.1",
     "ioredis-lock": "^4.0.0",
     "lodash": "^4.17.15",
-    "serialize-error": "^4.1.0"
+    "serialize-error": "^5.0.0"
   },
   "devDependencies": {
-    "@babel/cli": "^7.6.0",
-    "@babel/core": "^7.6.0",
+    "@babel/cli": "^7.6.4",
+    "@babel/core": "^7.6.4",
     "@babel/plugin-transform-strict-mode": "^7.0.0",
-    "@makeomatic/deploy": "^8.4.7",
-    "codecov": "^3.5.0",
-    "cross-env": "^5.2.1",
-    "eslint": "^6.3.0",
-    "eslint-config-makeomatic": "^3.1.0",
+    "@makeomatic/deploy": "^9.3.2",
+    "codecov": "^3.6.1",
+    "cross-env": "^6.0.3",
+    "eslint": "^6.5.1",
+    "eslint-config-makeomatic": "^4.0.0",
     "eslint-plugin-import": "^2.18.2",
     "eslint-plugin-promise": "^4.2.1",
-    "ioredis": "^4.14.0",
+    "ioredis": "^4.14.1",
     "jest": "^24.9.0",
-    "sinon": "^7.4.2"
+    "sinon": "^7.5.0"
   },
   "engine": {
     "node": ">= 10.15.0"

src/callback-queue.js

@@ -1,6 +1,6 @@
 const Promise = require('bluebird');
 const callbackQueue = require('callback-queue');
-const serializeError = require('serialize-error');
+const { serializeError, deserializeError } = require('serialize-error');
 
 // callback buckets
 const queue = new Map();
@@ -115,6 +115,7 @@ exports.createConsumer = function createConsumer(redis, pubsubChannel, logger) {
     // no listeners here
     // eat the error
     try {
+      if (args[0]) args[0] = deserializeError(args[0]);
       await call(key, args, logger);
     } catch (err) {
       logger.warn({ err }, 'call failed');