aboutsummaryrefslogtreecommitdiff
path: root/node_modules/tiny-worker/lib/worker.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/tiny-worker/lib/worker.js')
-rw-r--r--node_modules/tiny-worker/lib/worker.js83
1 files changed, 0 insertions, 83 deletions
diff --git a/node_modules/tiny-worker/lib/worker.js b/node_modules/tiny-worker/lib/worker.js
deleted file mode 100644
index c8e5d6885..000000000
--- a/node_modules/tiny-worker/lib/worker.js
+++ /dev/null
@@ -1,83 +0,0 @@
-"use strict";
-
-var fs = require("fs"),
- path = require("path"),
- vm = require("vm"),
- noop = require(path.join(__dirname, "noop.js")),
- events = /^(error|message)$/;
-
-function trim(arg) {
- return arg.replace(/^(\s+|\t+|\n+)|(\s+|\t+|\n+)$/g, "");
-}
-
-function explode(arg) {
- return trim(arg).split(new RegExp("\\s*,\\s*"));
-}
-
-function toFunction(arg) {
- var args = trim(arg.replace(/^.*\(/, "").replace(/[\t|\r|\n|\"|\']+/g, "").replace(/\).*/, "")),
- body = trim(arg.replace(/^.*\{/, "").replace(/\}$/, ""));
-
- return Function.apply(Function, explode(args).concat([body]));
-}
-
-// Bootstraps the Worker
-process.once("message", function (obj) {
- var exp = obj.isfn ? toFunction(obj.input) : fs.readFileSync(obj.input, "utf8");
-
- global.self = {
- close: function close() {
- process.exit(0);
- },
- postMessage: function postMessage(msg) {
- process.send(JSON.stringify({ data: msg }, null, 0));
- },
- onmessage: void 0,
- onerror: function onerror(err) {
- process.send(JSON.stringify({ error: err.message, stack: err.stack }, null, 0));
- },
- addEventListener: function addEventListener(event, fn) {
- if (events.test(event)) {
- global["on" + event] = global.self["on" + event] = fn;
- }
- }
- };
-
- global.__dirname = obj.cwd;
- global.__filename = __filename;
- global.require = require;
-
- global.importScripts = function () {
- for (var _len = arguments.length, files = Array(_len), _key = 0; _key < _len; _key++) {
- files[_key] = arguments[_key];
- }
-
- if (files.length > 0) {
- vm.createScript(files.map(function (file) {
- return fs.readFileSync(file, "utf8");
- }).join("\n")).runInThisContext();
- }
- };
-
- Object.keys(global.self).forEach(function (key) {
- global[key] = global.self[key];
- });
-
- process.on("message", function (msg) {
- try {
- (global.onmessage || global.self.onmessage || noop)(JSON.parse(msg));
- } catch (err) {
- (global.onerror || global.self.onerror || noop)(err);
- }
- });
-
- process.on("error", function (err) {
- (global.onerror || global.self.onerror || noop)(err);
- });
-
- if (typeof exp === "function") {
- exp();
- } else {
- vm.createScript(exp).runInThisContext();
- }
-});