fix(resolve): fix passing error to worker

Author: sokra

src/WorkerPool.js

@@ -134,10 +134,15 @@ class PoolWorker {
           this.writeJson({
             type: 'result',
             id: questionId,
-            error,
+            error: error ? {
+              message: error.message,
+              details: error.details,
+              missing: error.missing,
+            } : null,
             result,
           });
         });
+        finalCallback();
         break;
       }
       case 'emitWarning': {

src/worker.js

@@ -26,6 +26,14 @@ function toErrorObj(err) {
   };
 }
 
+function toNativeError(obj) {
+  if (!obj) return null;
+  const err = new Error(obj.message);
+  err.details = obj.details;
+  err.missing = obj.missing;
+  return err;
+}
+
 function writeJson(data) {
   const lengthBuffer = new Buffer(4);
   const messageBuffer = new Buffer(JSON.stringify(data), 'utf-8');
@@ -43,14 +51,14 @@ const queue = asyncQueue(({ id, data }, taskCallback) => {
       context: {
         version: 2,
         resolve: (context, request, callback) => {
+          callbackMap[nextQuestionId] = callback;
           writeJson({
             type: 'resolve',
             id,
             questionId: nextQuestionId,
             context,
             request,
           });
-          callbackMap[nextQuestionId] = callback;
           nextQuestionId += 1;
         },
         emitWarning: (warning) => {
@@ -148,8 +156,12 @@ function onMessage(message) {
         const { error, result } = message;
         const callback = callbackMap[id];
         if (callback) {
-          callback(error, result);
+          const nativeError = toNativeError(error);
+          callback(nativeError, result);
+        } else {
+          console.error(`Worker got unexpected result id ${id}`);
         }
+        delete callbackMap[id];
         break;
       }
       default: {