Juying/SrcJyDrpy.js

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 buildJsEnv(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 sync(func, sp) {
    return new org.mozilla.javascript.Synchronizer(func, sp || {});
}

function createDrpy(sdata) {
    JSEngine.getInstance().evalJS(buildJsEnv(MY_TICKET) + "\n!" + $.toString((sdata, codePath, GMkey, MY_TICKET) => {
        const localKey = "drpy";
        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;
        
        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("SrcJuDrpy", 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;
        globalThis.req = function (url, cobj) {
            try {
                let res = {};
                let obj = Object.assign({}, cobj);
                if (obj.data) {
                    obj.body = obj.data;
                    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";
                }

                if (url.startsWith("file://") && (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 = "";
                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) {
                    const CryptoUtil = $.require("hiker://assets/crypto-java.js");
                    res.content = CryptoUtil.Data.parseHex(res.content).toBase64(_base64.NO_WRAP);
                }
                return res;
            } catch (e) {
                log("Error" + e.toString());
            }
        }
        pdfa = _pdfa;
        pd = _pd;
        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();
        };
        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);
    return drpy;
}

//获取在线文件内容
function getJkContnet(url) {
    if(!url.startsWith('http')){
        return '';
    }
    if(url.startsWith('https://raw.github')){
        let proxys = $.require('ghproxy').getproxy();
        for(let i=0;i<proxys.length;i++){
            let content = fetch(proxys[i]+url, {timeout:5000});
            if (content && !content.trim().startsWith('<!DOCTYPE html>') && !content.startsWith('<html>')) {
                return content;
            }
        }
    }
    return fetch(url, {timeout:20000});
}

function getext(jkdata) {
    let extp = "";
    if(jkdata.ext && jkdata.ext.includes('?')){
        extp = '?' + jkdata.ext.split('?')[1];
    }
    if (/^hiker/.test(jkdata.url)) {
        if (!fileExist(jkdata.url)) {
            jkdata.url = jkdata.url.replace('/data/','/_cache/');
            if (jkdata.ext && /^http/.test(jkdata.ext)) {
                let content = getJkContnet(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)){
        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)
            return drpyMap.get(key);
        }
        if (drpyMap.size >= 5) {
            //log("删除缓存")
            del(Array.from(drpyMap.keys()).at(0));
        }
        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
}