Adding support for ES6 import/export

README.md

@@ -27,6 +27,37 @@ worker.onmessage = function (ev) {
 worker.postMessage("Hello World!");
 ```
 
+#### Enable ES6 import/export within Worker file
+The worker helper script (helper.js):
+```javascript
+export const dataFormatter = (data) => {
+  return `${data} World!`;
+};
+```
+
+The worker script (repeat.js):
+```javascript
+import { dataFormatter } from "./helper";
+
+onmessage = function (ev) {
+  const data = dataFormatter(ev.data);
+	postMessage(data);
+};
+```
+
+The core script:
+```javascript
+var Worker = require("tiny-worker");
+var worker = new Worker("repeat.js", [], {esm: true});
+
+worker.onmessage = function (ev) {
+	console.log(ev.data);
+	worker.terminate();
+};
+
+worker.postMessage("Hello");
+```
+
 #### Creating a Worker from a Function
 ```javascript
 var Worker = require("tiny-worker");

package.json

@@ -31,5 +31,7 @@
     "grunt-contrib-watch": "~1.0.0",
     "grunt-eslint": "~19.0.0"
   },
-  "dependencies": {}
+  "dependencies": {
+    "esm": "^3.2.22"
+  }
 }

src/index.js

@@ -79,7 +79,7 @@ class Worker {
 			}
 		});
 
-		this.child.send({input: input, isfn: isfn, cwd: options.cwd});
+		this.child.send({ input: input, isfn: isfn, cwd: options.cwd, esm: options.esm });
 	}
 
 	static setRange (min, max) {

src/worker.js

@@ -13,18 +13,19 @@ function toFunction (arg) {
 
 // Bootstraps the Worker
 process.once("message", obj => {
-	const exp = obj.isfn ? toFunction(obj.input) : fs.readFileSync(obj.input, "utf8");
+	const { isfn, input, esm, cwd } = obj;
+	const exp = isfn ? toFunction(input) : esm ? `require("${input}");` : fs.readFileSync(input, "utf8");
 
 	global.self = {
 		close: () => {
 			process.exit(0);
 		},
 		postMessage: msg => {
-			process.send(JSON.stringify({data: msg}, null, 0));
+			process.send(JSON.stringify({ data: msg }, null, 0));
 		},
 		onmessage: void 0,
 		onerror: err => {
-			process.send(JSON.stringify({error: err.message, stack: err.stack}, null, 0));
+			process.send(JSON.stringify({ error: err.message, stack: err.stack }, null, 0));
 		},
 		addEventListener: (event, fn) => {
 			if (events.test(event)) {
@@ -33,9 +34,9 @@ process.once("message", obj => {
 		}
 	};
 
-	global.__dirname = obj.cwd;
+	global.__dirname = cwd;
 	global.__filename = __filename;
-	global.require = require;
+	global.require = esm ? require("esm")(module) : require;
 
 	global.importScripts = (...files) => {
 		if (files.length > 0) {