Function operator

Sub-store-parser/DataQuery.js:18–49

Sub-Store外置流量查询脚本 该脚本基于Sub-Store, 可解决APP使用Sub-Store链接后, 没有流量通知的问题. 使用前需确认您的机场订阅是否支持流量信息. (注:节点名流量信息暂不支持) Sub-Store订阅管理器: https://github.com/Peng-YM/Sub-Store 最后更新: 2022.6.12 测试兼容: QuantumultX, Surge, Loon. 使用方法: 打开Sub-Store => 订阅 => 编辑 => 节点操作+ => 脚本操作 => 填入脚本链接或粘贴脚本 => 保存 您的APP更新Sub-Store订阅链接时,

(proxies, client)

******************************/

async function operator(proxies, client) {
    if (['JSON', 'URI'].includes(client)) return proxies;
    const $ = $substore; //OpenAPI in Sub-Store
    const single = $.read('subs');
    const collection = $.read('collections');
    const subtag = decodeURIComponent($request.url.split(/download\/(collection\/|)(.*)/)[2]);
    const group = [];
    if ($request.url.includes('/collection/')) { //collection subscription.
        const deployed = collection[subtag].process.filter((c) => c.type == 'Script Operator' && c.args.content.includes('/DataQuery.js')).length;
        for (let i = 0; i < collection[subtag].subscriptions.length; i++) {
            if (deployed) group.push({
                name: collection[subtag].subscriptions[i], url: single[collection[subtag].subscriptions[i]].url
            });
        }
    } else { //single subscription.
        group.push({ name: single[subtag].name, url: single[subtag].url })
    }
    await Promise.all(
        group.map((c) => $.http.get(c.url)
            .then((r) => {
                const t = parseInfo(r);
                $.notify(
                    `🔹 订阅昵称:「 ${c.name} 」`,
                    t.expire ? `🔹 过期时间:「 ${t.expire} 」` : ``,
                    `🔸 已用流量:「 ${t.used} GB 」\n🔸 剩余流量:「 ${t.free} GB 」`
                );
            })
            .catch((e) => $.notify(`🔹 订阅昵称:「 ${c.name} 」`, ``, `🔺 查询失败:「 ${e.message || e} 」`))
        )
    )
    return proxies;
}

function parseInfo(resp) { //reference to https://github.com/KOP-XIAO/QuantumultX/blob/master/Scripts/resource-parser.js
    var sinfo = JSON.stringify(resp.headers || '').replace(/ /g, "").toLowerCase();