const codePath = module.modulePath.slice(0, module.modulePath.lastIndexOf("/") + 1);
const JSEngine = com.example.hikerview.service.parser.JSEngine;
const drpyMap = new Map();
const GMkey = module.importParam;
function oldbuildJsEnv(ticket) {
    let code = String.raw`
    // const my_rule = '
    const MY_RULE = ${my_rule};
    const my_rule = JSON.stringify(MY_RULE);
    const MY_TICKET = "${ticket || ""}";
    eval(getJsPlugin());
    eval(getJsLazyPlugin());
    `;
    return code;
}

function buildJsEnv(ticket) {
    MY_RULE.title = MY_RULE._title || MY_RULE.title;
    let my_rule = JSON.stringify(MY_RULE);

    let code = `
    let my_rule = '';
    my_rule = null;
    const MY_RULE = ${my_rule};
    const MY_TICKET = "${ticket || ""}";
    eval(getJsPlugin());
    eval(getJsLazyPlugin());
    `;
    return code;
}

function sync(func, sp) {
    return new org.mozilla.javascript.Synchronizer(func, sp || {});
}

function createDrpy(sdata) {
    let func = buildJsEnv;
    if (typeof my_rule != "undefined" && my_rule != null) {
        func = oldbuildJsEnv;
    }
    JSEngine.getInstance().evalJS(func(MY_TICKET) + "\n!" + $.toString((sdata, codePath, GMkey, MY_TICKET) => {
        const localKey = "drpy";
        const CryptoUtil = $.require("hiker://assets/crypto-java.js");
        globalThis.local = {
            set(rulekey, k, v) {
                storage0.setItem(localKey + "@" + rulekey + "@" + k, v);
            },
            get(rulekey, k, v) {
                return storage0.getItem(localKey + "@" + rulekey + "@" + k, "") || v;
            },
            delete(rulekey, k) {
                storage0.clearItem(localKey + "@" + rulekey + "@" + k);
            }
        };
        eval(getCryptoJS());
        globalThis.CryptoJS = CryptoJS;

        if (getItem("drpy调试日志")!="1") {
            console.log = function () {
                return;
            };
        }
        
        globalThis.getProxy = function () {
            let proxyUrl = startProxyServer($.toString((sdata, codepath, title) => {
                let {GM} = $.require("http://hiker.nokia.press/hikerule/rulelist.json?id=6916&auth=1d35e8f0-22e8-5270-a9d1-826f53f177ad");
                GM.setSelfKey(title);
                let drpy = GM.defineModule("SrcJyDrpy", codepath + "SrcJyDrpy.js").get(sdata);

                let params = {};
                for (let key in MY_PARAMS) {
                    params[key] = String(MY_PARAMS[key][0]);
                }
                
                let result = drpy.proxy(params);
                let [code, media_type, data, headers, isReturnBytes] = result;
                headers = Object.assign({}, {
                    'Content-Type': media_type,
                }, headers);
                if(typeof data==="string"&&data.startsWith("data:")&&data.includes("base64,")){
                    data = _base64.decode(data.split("base64,")[1], _base64.NO_WRAP);
                }
                return {
                    statusCode: code,
                    body: data,
                    headers: headers,
                };
            }, sdata, codePath, MY_RULE._title||MY_RULE.title));
            return proxyUrl + "?do=js";
        }
        
        let $request = request;
        let $post = post;
        function readFileToString(filePath) {
            const StringBuilder = java.lang.StringBuilder;
            const BufferedReader = java.io.BufferedReader;
            const File = java.io.File;
            const FileReader = java.io.FileReader;

            let file = new File(filePath);
            if (!file.exists()) return "";
            let fileContent = new StringBuilder();
            let br = null;
            try {
                br = new BufferedReader(new FileReader(file));
                let line;
                while ((line = br.readLine()) != null) {
                    fileContent.append(line).append("\n");
                }
            } catch (e) {
                fileContent.append("");
            } finally {
                try {
                    if (br != null) {
                        br.close();
                    }
                } catch (e) { }
            }
            return String(fileContent.toString());
        }
        function hasPropertyIgnoreCase(obj, propertyName) {
            return Object.keys(obj).some(key =>
                key.toLowerCase() === propertyName.toLowerCase()
            );
        }

        function valueStartsWith(obj, propertyName, prefix) {
            const key = Object.keys(obj).find(key =>
                key.toLowerCase() === propertyName.toLowerCase()
            );
            return key !== undefined && obj[key].startsWith(prefix);
        }

        globalThis.req = function (url, cobj) {
            try {
                let res = {};
                let obj = Object.assign({}, cobj);
                if (obj.data) {
                    obj.body = obj.data;
                    if ((obj.postType && obj.postType == "form") || (hasPropertyIgnoreCase(obj.headers, "Content-Type") && valueStartsWith(obj.headers, "Content-Type", "application/x-www-form-urlencoded"))) {
                        let temp_obj = obj.data;
                        obj.body = Object.keys(temp_obj).map(key => {
                            return `${key}=${temp_obj[key]}`;
                        }).join('&');
                    }
                    delete obj.data;
                }

                if (obj.hasOwnProperty("redirect")) obj.redirect = !!obj.redirect;
                if (obj.buffer === 2) {
                    obj.toHex = true;
                }
                obj.headers = Object.assign({
                    Cookie: "#noCookie#"
                }, obj.headers);
                if (url === "https://api.nn.ci/ocr/b64/text" && obj.headers) {
                    obj.headers["Content-Type"] = "text/plain";
                }
                let isFile = url.startsWith("file://");
                if (isFile && (url.includes("?type=") || url.includes("?params="))) {
                    url = url.slice(0, url.lastIndexOf("?"));
                }
                for (let key in obj.headers) {
                    if (typeof obj.headers[key] !== "string") {
                        obj.headers[key] = String(obj.headers[key]);
                    }
                }
                let r = "";
                if (isFile) {
                    r = readFileToString(url.replace("file://", ""));
                } else {
                    r = $request(url, obj);
                }
                if (obj.withHeaders) {
                    r = JSON.parse(r);
                    res.content = r.body;
                    res.headers = {};
                    for (let [k, v] of Object.entries(r.headers || {})) {
                        res.headers[k] = v[0];
                    }
                } else {
                    res.content = r;
                }
                if (obj.buffer === 2) {
                    res.content = CryptoUtil.Data.parseHex(res.content).toBase64(_base64.NO_WRAP);
                }
                return res;
            } catch (e) {
                log("Error" + e.toString());
            }
        }
        globalThis.pdfa = _pdfa;
        globalThis.pd = _pd;
        globalThis.pdfh = _pdfh;
        String.prototype.replaceAll = function (search, replacement) {
            return this.split(search).join(replacement);
        };
        let $toString = Function.prototype.toString;
        Function.prototype.toString = function () {
            return $toString.apply(this).trim();
        };
        //$.require.cache.delete($.require.resolve(codePath +'drpy/drpy2.js'));
        let drpy2 = $.require(codePath +'drpy/drpy2.js');
        GM.has(GMkey, (DrpyManage) => {
            DrpyManage.put(sdata.key, drpy2);
        });
    }, sdata, codePath, GMkey, MY_TICKET) + ";\n", "", false);
}

function createNewDrpy(sdata) {
    createDrpy(sdata);
    let drpy = drpyMap.get(sdata.key);
    drpy.init(sdata.ext);
    //log(sdata.key + ">init");
    return drpy;
}

function getext(jkdata) {
    let extp = "";
    if(jkdata.ext && jkdata.ext.includes('?')){
        extp = '?' + jkdata.ext.split('?')[1];
    }
    let gmParams = globalMap0.getVar('Jy_gmParams');

    if (/^hiker/.test(jkdata.url)) {
        if (!fileExist(jkdata.url)) {
            if(!fileExist(gmParams.jkfile)){
                jkdata.url = jkdata.url.replace('/data/','/_cache/');
            }
            jkdata.url = jkdata.url.replace('/聚影✓/','/聚影/');
            if (jkdata.ext) {
                let content = gmParams.getContnet(jkdata.ext.split('?')[0]);
                if (content) {
                    writeFile(jkdata.url, content);
                }
            }
        }
        if (fileExist(jkdata.url)) {
            return getPath(jkdata.url) + extp;
        }
    }else if(/^file/.test(jkdata.url) && fileExist(jkdata.url)){
        return jkdata.url + extp;
    }
    return '';
}

function get(jkdata) {
    let key = jkdata.key || jkdata.name;
    let ext = jkdata.key?jkdata.ext:getext(jkdata);
    let sdata = {key:key, ext:ext};
    return sync(() => {
        //log(drpyMap.size)
        if (drpyMap.has(key)) {
            //log("取缓存>" + key)
            let drpy = drpyMap.get(key);
            if(Object.keys(drpy.getRule()).length > 0){
                return drpy;
            }else{
                drpyMap.delete(key);
            }
        }
        if (drpyMap.size >= 16) {
            //log("删缓存>"+Array.from(drpyMap.keys()).at(0))
            del(Array.from(drpyMap.keys()).at(0));
        }
        //log(sdata);
        let drpy = createNewDrpy(sdata);
        return drpy;
    }, this).call();
}

function put(key, drpy) {
    sync(() => drpyMap.set(key, drpy), this).call();
}

function del(key) {
    sync(() => {
        //log("删除" + key);
        drpyMap.delete(key);
    }, this).call();
}

function clear() {
    sync(() => {
        drpyMap.clear();
    }, this).call();
}
$.exports = {
    get,
    clear,
    put
}