Better error messages & child process now exposed

Author: mallocator

forked.js

@@ -9,6 +9,9 @@ try {
     process.on('message', async message => {
         try {
             if (message.prop) {
+                if (!forkedModule[message.prop]) {
+                    return process.send({error: 'TypeError: ' + message.prop + ' is not a function', stack: ''})
+                }
                 let response = await forkedModule[message.prop](...message.args);
                 process.send({response});
             } else {
@@ -21,4 +24,4 @@ try {
     });
 } catch (err) {
     process.send({error: err.message, stack: err.stack, failed: true});
-}
+}

index.js

@@ -1,5 +1,5 @@
-const path = require('path');
 const cp = require('child_process');
+const path = require('path');
 const util = require('util');
 
 function getProcessArgs() {
@@ -26,6 +26,12 @@ function handleResponse(process, resolve, reject, source)  {
 }
 
 function fixStack(stack, source) {
+    if (!stack) {
+        return;
+    }
+    if (!source) {
+        return stack;
+    }
     let myStack = source.stack;
     let tail = myStack.substr(myStack.indexOf('\n', myStack.indexOf('\n') + 1));
     let head = stack.substr(0, stack.substr(0, stack.indexOf('forked.js')).lastIndexOf('\n'));
@@ -48,7 +54,7 @@ module.exports = (file, options = {
     let filePath = path.isAbsolute(file) ? file : path.join(calleePath, file);
     options.args.unshift(filePath, options.title || 'fork-require.js file ' + filePath);
 
-    let child = cp.fork('./forked.js', options.args , {
+    let child = cp.fork(path.join(__dirname, 'forked.js'), options.args , {
         env: options.env,
         cwd: options.cwd,
         execArgv: options.execArgv,
@@ -63,15 +69,18 @@ module.exports = (file, options = {
         }
     });
 
-    return new Proxy(() => {}, {
+    let proxy = new Proxy(() => { this.process = process }, {
         apply: (_, __, args) => {
             let source = new Error();
             return new Promise((resolve, reject) => {
                 handleResponse(child, resolve, reject, options.fixStack && source);
                 child.send({args});
             });
         },
-        get: (_, prop) => {
+        get: (obj, prop) => {
+            if (obj[prop]) {
+                return obj[prop];
+            }
             let source = new Error();
             return function (...args) {
                 return new Promise((resolve, reject) => {
@@ -81,4 +90,6 @@ module.exports = (file, options = {
             }
         }
     });
-};
+    proxy._childProcess = child;
+    return proxy;
+};

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fork-require",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "Allows to \"require\" a file, while forking it into a child process.",
   "author": "Ravi Gairola <mallox@pyxzl.net>",
   "homepage": "https://github.com/mallocator/fork-require",