fix: loadModule and fs are now available in a loader context (#88)

webpack-contrib · Jun 29, 2020 · ea5c9ad · ea5c9ad
1 parent 488300f
commit ea5c9ad
Show file tree

Hide file tree

Showing 3 changed files with 35 additions and 0 deletions.
diff --git a/src/WorkerPool.js b/src/WorkerPool.js
@@ -188,6 +188,29 @@ class PoolWorker {
         });
         break;
       }
+      case 'loadModule': {
+        const { request, questionId } = message;
+        const { data } = this.jobs[id];
+        data.loadModule(request, (error, source, sourceMap, module) => {
+          this.writeJson({
+            type: 'result',
+            id: questionId,
+            error: error ? {
+              message: error.message,
+              details: error.details,
+              missing: error.missing,
+            } : null,
+            result: [
+              source,
+              sourceMap,
+              // TODO: Serialize module?
+              // module,
+            ],
+          });
+        });
+        finalCallback();
+        break;
+      }
       case 'resolve': {
         const { context, request, questionId } = message;
         const { data } = this.jobs[id];

diff --git a/src/index.js b/src/index.js
@@ -20,6 +20,7 @@ function pitch() {
     sourceMap: this.sourceMap,
     emitError: this.emitError,
     emitWarning: this.emitWarning,
+    loadModule: this.loadModule,
     resolve: this.resolve,
     target: this.target,
     minimize: this.minimize,

diff --git a/src/worker.js b/src/worker.js
@@ -107,6 +107,17 @@ const queue = asyncQueue(({ id, data }, taskCallback) => {
       readResource: fs.readFile.bind(fs),
       context: {
         version: 2,
+        fs,
+        loadModule: (request, callback) => {
+          callbackMap[nextQuestionId] = (error, result) => callback(error, ...result);
+          writeJson({
+            type: 'loadModule',
+            id,
+            questionId: nextQuestionId,
+            request,
+          });
+          nextQuestionId += 1;
+        },
         resolve: (context, request, callback) => {
           callbackMap[nextQuestionId] = callback;
           writeJson({