O2OA/o2web/source/o2_core/scriptWorker.js

window = self;
window.addEvent = function(){};
self.window = window;
window.execScript = function(text){
    return eval(text)
}

if (!this.document) document = {
    "window": self,
    "head": "head",
    "location": "url",
    "documentElement": {
        style:{
            "color": ""
        }
    },
    "html": {
        style:{
            "color": ""
        }
    },
    "readyState": "loaded",
    "addEventListener": function(){},
    "removeEventListener": function(){},
    "createElement": function(){
        return {
            contains: null,
            getAttribute:function(){return null},
            cloneNode: function(){return {
                firstChild: {
                    childNodes: {length: 1},
                    value: "s"
                }
            }},
            firstChild: {
                childNodes: {length: 1},
                value: "s"
            },
            getAttributeNode: function(){return null},
            childNodes: [""],
            style: {},
            appendChild: function(){}
        }
    }
};

self.importScripts("../o2_core/o2.min.js");

layout = window.layout || {};
layout.desktop = layout;
layout.desktop.type = "app";
var locate = window.location;
layout.protocol = locate.protocol;
layout.inBrowser = true;
layout.session = layout.session || {};
layout.debugger = (locate.href.toString().indexOf("debugger") !== -1);
layout.anonymous = (locate.href.toString().indexOf("anonymous") !== -1);
o2.xApplication = o2.xApplication || {};

o2.xDesktop = o2.xDesktop || {};
o2.xDesktop.requireApp = function (module, clazz, callback, async) {
    o2.requireApp(module, clazz, callback, async);
};

layout.openApplication = function(){};
layout.refreshApp = function(){};
layout.load = function(){};

layout.readys = [];
layout.addReady = function () {
    for (var i = 0; i < arguments.length; i++) {
        if (o2.typeOf(arguments[i]) === "function") layout.readys.push(arguments[i]);
    }
};

o2.addReady(function () {
    var _setLayoutService = function(service, center){
        layout.serviceAddressList = service;
        layout.centerServer = center;
        layout.desktop.serviceAddressList = service;
        layout.desktop.centerServer = center;
    };
    var _getDistribute = function (callback) {
        if (layout.config.app_protocol === "auto") {
            layout.config.app_protocol = window.location.protocol;
        }
        if (layout.config.configMapping && (layout.config.configMapping[window.location.host] || layout.config.configMapping[window.location.hostname])){
            var mapping = layout.config.configMapping[window.location.host] || layout.config.configMapping[window.location.hostname];
            if (mapping.servers){
                layout.serviceAddressList = mapping.servers;
                layout.desktop.serviceAddressList = mapping.servers;
                if (mapping.center) center = (o2.typeOf(mapping.center)==="array") ? mapping.center[0] : mapping.center;
                layout.centerServer = center;
                layout.desktop.centerServer = center;
                if (callback) callback();
            }else{
                if (mapping.center) layout.config.center = (o2.typeOf(mapping.center)==="array") ? mapping.center : [mapping.center];
                o2.xDesktop.getServiceAddress(layout.config, function (service, center) {
                    _setLayoutService(service, center);
                    if (callback) callback();
                }.bind(this));
            }
        }else{
            o2.xDesktop.getServiceAddress(layout.config, function (service, center) {
                _setLayoutService(service, center);
                if (callback) callback();
            }.bind(this));
        }
    };

    var _load = function () {
        var _loadApp = function (data) {
            //用户已经登录
            if (data){
                layout.user = data;
                layout.session = layout.session || {};
                layout.session.user = data;
                layout.session.token = data.token;
                layout.desktop.session = layout.session;
            }
            while (layout.readys && layout.readys.length) {
                layout.readys.shift().apply(window);
            }
        };

        var data = { name: "anonymous", roleList: [] };
        o2.Actions.get("x_organization_assemble_authentication").getAuthentication(function (json) {
            data = json.data;
        }.bind(this), null, false);
        _loadApp(data);
    };

    //异步载入必要模块
    layout.config = null;
    var configLoaded = false;
    var lpLoaded = false;
    var commonLoaded = false;
    var lp = o2.session.path + "/lp/" + o2.language + ".js";

    var loadModuls = function () {
        lpLoaded = true;

        var modules = ["o2.xDesktop.$all"];
        o2.require(modules, {
            "onSuccess": function () {
                commonLoaded = true;
                if (configLoaded && commonLoaded && lpLoaded) _getDistribute(function () { _load(); });
            }
        });
    }

    if (!o2.LP){
        o2.load(lp, loadModuls);
    }else{
        loadModuls();
    }

    o2.getJSON("../x_desktop/res/config/config.json", function (config) {
        layout.config = config;
        configLoaded = true;
        if (configLoaded && commonLoaded && lpLoaded) _getDistribute(function () { _load(); });
    });

});

var _worker = self;
layout.addReady(function(){
    window.isCompletionEnvironment = true;

    _worker.runtimeEnvironment = {};

    _worker.createEnvironment = function(runtime, url){
        return new Promise(function(s, f){
            o2.xhr_get(url, function (xhr) {
                if (xhr.responseText){
                    _worker.createRuntime(runtime, xhr.responseText);
                    if (s) s();
                }
            }, function (err) {
                f(err);
            });
        });
    };
    _worker.createRuntime = function(runtime, script){
        var code = "o2.Macro.swapSpace.tmpMacroCompletionFunction = function (){\n" + script + "\nreturn bind;" + "\n};";
        Browser.exec(code);
        var ev = o2.Macro.swapSpace.tmpMacroCompletionFunction() ;
        _worker.runtimeEnvironment[runtime] = {
            "environment": ev,
            exec: function(code){
                try{
                    return o2.Macro.exec(code, this.environment);
                }catch(e){
                    return null;
                }
            }
        }
    };

    _worker.getCompletionEnvironment = function(runtime) {
        if (!_worker.runtimeEnvironment[runtime]) {
            return new Promise(function(s){
                o2.require("o2.xScript.Macro", function() {
                    switch (runtime) {
                        case "service":
                            s(_worker.getServiceCompletionEnvironment());
                            break;
                        case "server":
                            s(_worker.getServerCompletionEnvironment());
                            break;
                        case "all":
                            s(_worker.getAllCompletionEnvironment());
                            break;
                        default:
                            s(_worker.getDefaultCompletionEnvironment());
                    }
                });
            });
        } else {
            return Promise.resolve();
        }
    };
    _worker.getServiceCompletionEnvironment = function() {
        var runtime = "service";
        return _worker.createEnvironment(runtime, "../x_desktop/js/initalServiceScriptSubstitute.js");
    };
    _worker.getServerCompletionEnvironment = function() {
        var runtime = "server";
        return _worker.createEnvironment(runtime, "../x_desktop/js/initalScriptSubstitute.js");
    };
    _worker.getDefaultCompletionEnvironment = function(){
        var runtime = "web";
        return new Promise(function(s){
            o2.getJSON("../o2_core/o2/widget/$JavascriptEditor/environment.json", function (data) {
                json = data;
                _worker.runtimeEnvironment[runtime] = new o2.Macro.FormContext(json);
                if (s) s();
            });
        });
    }
    _worker.getAllCompletionEnvironment = function(){
        var runtime = "all";
        var arr = [
            _worker.getServiceCompletionEnvironment(),
            _worker.getServerCompletionEnvironment(),
            _worker.getDefaultCompletionEnvironment()
        ];

        return Promise.all(arr).then(function(){
            if (_worker.runtimeEnvironment["service"] && _worker.runtimeEnvironment["server"] && _worker.runtimeEnvironment["web"] ){
                var ev = Object.merge(_worker.runtimeEnvironment["service"].environment,
                    _worker.runtimeEnvironment["server"].environment,
                    _worker.runtimeEnvironment["web"].environment)


                _worker.runtimeEnvironment[runtime] = {
                    "environment": ev,
                    exec: function(code){
                        try{
                            return o2.Macro.exec(code, this.environment);
                        }catch(e){
                            return null;
                        }
                    }
                }
            }
        });
    };

    _worker.getMonacoCompletions = function(o){
        var arr = [];
        Object.keys(o).each(function (key) {
            var keyType = typeOf(o[key]);
            if (keyType === "function") {
                var count = o[key].length;
                var v = key + "(";
                for (var i = 1; i <= count; i++) v += (i == count) ? "par" + i : "par" + i + ", ";
                v += ")";
                arr.push({ label: key, kind: 1, insertText: v, detail: keyType });
            } else {
                arr.push({ label: key, kind: 7, insertText: key, detail: keyType });
            }
        });
        return arr;
    };
    _worker.getAceCompletions = function(o){
        var arr = [];
        Object.keys(o).each(function(key){
            var keyType = typeOf(o[key]);
            if (keyType==="function") {
                var count = o[key].length;
                var v = x+"."+key+"(";
                for (var i=1; i<=count; i++) v+= (i==count) ? "par"+i :  "par"+i+", ";
                v+=")";
                arr.push({ caption: x+"."+key, value: v, score: 3, meta: keyType, type: keyType, docText: o[key] });
            }else{
                arr.push({ caption: x+"."+key, value: x+"."+key, score: 3, meta: keyType, type: keyType, docText: o[key] });
            }
        });
        return arr;
    };

    _worker.overwriteRequest = function(){
        if (!_worker.isOverwriteRequest){
            if (_worker.XMLHttpRequest){
                var send = XMLHttpRequest.prototype.send;
                var open = XMLHttpRequest.prototype.open;
                XMLHttpRequest.prototype.open = function(method, url){
                    this.continueRequest = false;
                    if (url){
                        var tmpUrl = url;
                        if (tmpUrl.indexOf(":")==-1) tmpUrl = "http://"+tmpUrl;
                        var u = new URI(tmpUrl);
                        var f = u.get("file");
                        var ext = f.substr(f.indexOf(".")+1).toLowerCase();
                        if (ext=="json" || ext=="js" || ext=="html" ){
                            this.continueRequest = true;
                            return open.apply(this, arguments);
                        }
                    }
                };
                XMLHttpRequest.prototype.send = function(){
                    if (this.continueRequest){
                        return send.apply(this, arguments);
                    }
                };
            }
            if (_worker.fetch){
                var nativeFetch = _worker.fetch;
                _worker.fetch = function(o){
                    var url = o;
                    if (o2.typeOf(o)=="string"){
                        url = o;
                    }else if (Object.getPrototypeOf(o)==NativeRequest.prototype){
                        url = o.url;
                    }
                    if (url.indexOf(":")==-1) url = "http://"+url;
                    var u = new URI(url);
                    var f = u.get("file");
                    var ext = f.substr(f.indexOf(".")+1).toLowerCase();
                    if (ext=="json" || ext=="js" || ext=="html" ){
                        return nativeFetch.apply(_worker, arguments);
                    }
                }
            }

            _worker.isOverwriteRequest = true;
        }
    };

    _worker.exec = function(id, uuid, code, preCode, runtime, type){
        var promise = _worker.getCompletionEnvironment(runtime);
        promise.then(function(){
            _worker.overwriteRequest();
            if (_worker.runtimeEnvironment[runtime]){

                code = "return "+code+";";
                if (preCode){
                    code = preCode+"\n"+code;
                }
                code = "try {\n"+code+"\n}catch(e){return null;}";
                var o = _worker.runtimeEnvironment[runtime].exec(code);
                if (o) {
                    var completions = (type=="ace") ? _worker.getAceCompletions(o) : _worker.getMonacoCompletions(o);
                    _worker.postMessage({"o": completions, "id": id, "uuid": uuid});
                }
            }
        }, function(){});
    };
    _worker.postMessage({"type": "ready"});
});
onmessage = function(e) {
    if (e.data){
        var id = e.data.id;
        var uuid = e.data.uuid;
        var code = e.data.code;
        var runtime = e.data.runtime;
        var type = e.data.type;
        var preCode = e.data.preCode;
        if (id && code && runtime && uuid && type){
            _worker.exec(id, uuid, code, preCode, runtime, type)
        }
    }
}