110 lines
2.8 KiB
JavaScript
110 lines
2.8 KiB
JavaScript
/**
|
|
* Ajax.org Code Editor (ACE)
|
|
*
|
|
* @copyright 2010, Ajax.org Services B.V.
|
|
* @license LGPLv3 <http://www.gnu.org/licenses/lgpl-3.0.txt>
|
|
* @author Fabian Jakobs <fabian AT ajax DOT org>
|
|
*/
|
|
|
|
define(function(require, exports, module) {
|
|
|
|
var oop = require("pilot/oop");
|
|
var EventEmitter = require("pilot/event_emitter").EventEmitter;
|
|
|
|
var WorkerClient = function(topLevelNamespaces, packagedJs, module, classname) {
|
|
|
|
this.callbacks = [];
|
|
|
|
if (require.packaged) {
|
|
var base = this.$guessBasePath();
|
|
var worker = this.$worker = new Worker(base + packagedJs);
|
|
}
|
|
else {
|
|
var workerUrl = require.nameToUrl("ace/worker/worker", null, "_");
|
|
var worker = this.$worker = new Worker(workerUrl);
|
|
|
|
var tlns = {};
|
|
for (var i=0; i<topLevelNamespaces.length; i++) {
|
|
var ns = topLevelNamespaces[i];
|
|
tlns[ns] = require.nameToUrl(ns, null, "_").replace(/.js$/, "");
|
|
}
|
|
}
|
|
|
|
this.$worker.postMessage({
|
|
init : true,
|
|
tlns: tlns,
|
|
module: module,
|
|
classname: classname
|
|
});
|
|
|
|
this.callbackId = 1;
|
|
this.callbacks = {};
|
|
|
|
var _self = this;
|
|
this.$worker.onerror = function(e) {
|
|
console.log(e);
|
|
throw e;
|
|
};
|
|
this.$worker.onmessage = function(e) {
|
|
var msg = e.data;
|
|
switch(msg.type) {
|
|
case "log":
|
|
window.console && console.log && console.log(msg.data);
|
|
break;
|
|
|
|
case "event":
|
|
_self._dispatchEvent(msg.name, {data: msg.data});
|
|
break;
|
|
|
|
case "call":
|
|
var callback = _self.callbacks[msg.id];
|
|
if (callback) {
|
|
callback(msg.data);
|
|
delete _self.callbacks[msg.id];
|
|
}
|
|
break;
|
|
}
|
|
};
|
|
};
|
|
|
|
(function(){
|
|
|
|
oop.implement(this, EventEmitter);
|
|
|
|
this.$guessBasePath = function() {
|
|
var scripts = document.getElementsByTagName("script");
|
|
for (var i=0; i<scripts.length; i++) {
|
|
var m = scripts[i].src.match(/^(.*\/)ace\.js$/);
|
|
if (m)
|
|
return m[1];
|
|
}
|
|
return "";
|
|
};
|
|
|
|
this.terminate = function() {
|
|
this._dispatchEvent("terminate", {});
|
|
this.$worker.terminate();
|
|
};
|
|
|
|
this.send = function(cmd, args) {
|
|
this.$worker.postMessage({command: cmd, args: args});
|
|
};
|
|
|
|
this.call = function(cmd, args, callback) {
|
|
if (callback) {
|
|
var id = this.callbackId++;
|
|
this.callbacks[id] = callback;
|
|
args.push(id);
|
|
}
|
|
this.send(cmd, args);
|
|
};
|
|
|
|
this.emit = function(event, data) {
|
|
this.$worker.postMessage({event: event, data: data});
|
|
};
|
|
|
|
}).call(WorkerClient.prototype);
|
|
|
|
exports.WorkerClient = WorkerClient;
|
|
|
|
});
|