1 files changed, 62 insertions, 0 deletions

diff --git a/node_modules/montage/require/worker.js b/node_modules/montage/require/worker.js
new file mode 100644
index 00000000..3b06aad2
--- /dev/null
+++ b/node_modules/montage/require/worker.js
@@ -0,0 +1,62 @@
+
+var URL = require("core/mini-url");
+
+exports.Worker = function (package, id) {
+    var worker = new Worker(
+        URL.resolve(module.location, 'worker-script.js')
+    );
+    worker.postMessage({
+        "type": "init",
+        "package": package,
+        "module": id
+    })
+    worker.onmessage = function (event) {
+        // request module text
+        // handle URL resolution
+        // console log
+        // read a url
+        if (event.data.type === "console") {
+            console[event.data.method].apply(console, event.data.args);
+        } else if (event.data.type === "read") {
+            require.read(event.data.url)
+            .then(function (content) {
+                worker.postMessage({
+                    type: "read",
+                    url: event.data.url,
+                    content: content
+                })
+            }, function (error) {
+                worker.postMessage({
+                    type: "read",
+                    url: event.data.url,
+                    error: error
+                });
+            })
+            .end();
+        } else if (event.data.type === "forward") {
+            if (proxy.onmessage) {
+                proxy.onmessage({
+                    data: event.data.data
+                });
+            } else {
+                // XXX
+            }
+        } else {
+            // XXX
+        }
+    };
+    var proxy = {
+        postMessage: function (data) {
+            worker.postMessage({
+                type: "forward",
+                data: data
+            });
+        },
+        onmessage: null,
+        terminate: function () {
+            return worker.terminate();
+        }
+    };
+    return proxy;
+};
+