feat: 通过代理/节点/策略获取订阅现已支持 Surge, Loon, Stash, Shadowrocket, QX, Node.js

2026-03-21 13:12:36 +08:00 · 2024-03-14 01:28:05 +08:00
23 changed files with 71 additions and 193 deletions
--- a/backend/package.json
+++ b/backend/package.json
@@ -1,6 +1,6 @@
 {
  "name": "sub-store",
-  "version": "2.14.269",
+  "version": "2.14.253",
  "description": "Advanced Subscription Manager for QX, Loon, Surge, Stash and ShadowRocket.",
  "main": "src/main.js",
  "scripts": {
--- a/backend/src/core/proxy-utils/index.js
+++ b/backend/src/core/proxy-utils/index.js
@@ -159,7 +159,7 @@ async function processFn(proxies, operators = [], targetPlatform, source) {
            continue;
        }

-        $.log(
+        $.info(
            `Applying "${item.type}" with arguments:\n >>> ${
                JSON.stringify(item.args, null, 2) || 'None'
            }`,
@@ -186,10 +186,6 @@ function produce(proxies, targetPlatform, type, opts = {}) {
        throw new Error(`Target platform: ${targetPlatform} is not supported!`);
    }

-    const sni_off_supported = /Surge|SurgeMac|Shadowrocket/i.test(
-        targetPlatform,
-    );
-
    // filter unsupported proxies
    proxies = proxies.filter(
        (proxy) =>
@@ -200,22 +196,10 @@ function produce(proxies, targetPlatform, type, opts = {}) {
        if (!isNotBlank(proxy.name)) {
            proxy.name = `${proxy.type} ${proxy.server}:${proxy.port}`;
        }
-        if (proxy['disable-sni']) {
-            if (sni_off_supported) {
-                proxy.sni = 'off';
-            } else if (!['tuic'].includes(proxy.type)) {
-                $.error(
-                    `Target platform ${targetPlatform} does not support sni off. Proxy's fields (tls-fingerprint and skip-cert-verify) will be modified.`,
-                );
-                delete proxy.sni;
-                proxy['skip-cert-verify'] = true;
-                delete proxy['tls-fingerprint'];
-            }
-        }
        return proxy;
    });

-    $.log(`Producing proxies for target: ${targetPlatform}`);
+    $.info(`Producing proxies for target: ${targetPlatform}`);
    if (typeof producer.type === 'undefined' || producer.type === 'SINGLE') {
        let localPort = 10000;
        const list = proxies
--- a/backend/src/core/proxy-utils/parsers/index.js
+++ b/backend/src/core/proxy-utils/parsers/index.js
@@ -547,7 +547,6 @@ function URI_Hysteria2() {
            proxy.obfs = params.obfs;
        }

-        proxy.ports = params.mport;
        proxy['obfs-password'] = params['obfs-password'];
        proxy['skip-cert-verify'] = /(TRUE)|1/i.test(params.insecure);
        proxy.tfo = /(TRUE)|1/i.test(params.fastopen);
--- a/backend/src/core/proxy-utils/parsers/peggy/surge.js
+++ b/backend/src/core/proxy-utils/parsers/peggy/surge.js
@@ -177,13 +177,7 @@ username = & {
 password = comma match:[^,]+ { proxy.password = match.join(""); }

 tls = comma "tls" equals flag:bool { proxy.tls = flag; }
-sni = comma "sni" equals sni:("off"/domain) { 
-    if (sni === "off") {
-        proxy["disable-sni"] = true;
-    } else {
-        proxy.sni = sni;
-    }
-}
+sni = comma "sni" equals sni:domain { proxy.sni = sni; }
 tls_verification = comma "skip-cert-verify" equals flag:bool { proxy["skip-cert-verify"] = flag; }
 tls_fingerprint = comma "server-cert-fingerprint-sha256" equals tls_fingerprint:$[^,]+ { proxy["tls-fingerprint"] = tls_fingerprint.trim(); }

--- a/backend/src/core/proxy-utils/parsers/peggy/surge.peg
+++ b/backend/src/core/proxy-utils/parsers/peggy/surge.peg
@@ -175,13 +175,7 @@ username = & {
 password = comma match:[^,]+ { proxy.password = match.join(""); }

 tls = comma "tls" equals flag:bool { proxy.tls = flag; }
-sni = comma "sni" equals sni:("off"/domain) { 
-    if (sni === "off") {
-        proxy["disable-sni"] = true;
-    } else {
-        proxy.sni = sni;
-    }
-}
+sni = comma "sni" equals sni:domain { proxy.sni = sni; }
 tls_verification = comma "skip-cert-verify" equals flag:bool { proxy["skip-cert-verify"] = flag; }
 tls_fingerprint = comma "server-cert-fingerprint-sha256" equals tls_fingerprint:$[^,]+ { proxy["tls-fingerprint"] = tls_fingerprint.trim(); }

--- a/backend/src/core/proxy-utils/producers/uri.js
+++ b/backend/src/core/proxy-utils/producers/uri.js
@@ -274,9 +274,6 @@ export default function URI_Producer() {
                        `sni=${encodeURIComponent(proxy.sni)}`,
                    );
                }
-                if (proxy.ports) {
-                    hysteria2params.push(`mport=${proxy.ports}`);
-                }
                if (proxy['tls-fingerprint']) {
                    hysteria2params.push(
                        `pinSHA256=${encodeURIComponent(
--- a/backend/src/core/rule-utils/parsers.js
+++ b/backend/src/core/rule-utils/parsers.js
@@ -10,8 +10,6 @@ const RULE_TYPES_MAPPING = [
    [/^PROTOCOL$/, 'PROTOCOL'],
    [/^IP-CIDR$/i, 'IP-CIDR'],
    [/^(IP-CIDR6|ip6-cidr|IP6-CIDR)$/, 'IP-CIDR6'],
-    [/^GEOIP$/i, 'GEOIP'],
-    [/^GEOSITE$/i, 'GEOSITE'],
 ];

 function AllRuleParser() {
@@ -39,7 +37,8 @@ function AllRuleParser() {
                            content: params[1],
                        };
                        if (
-                            ['IP-CIDR', 'IP-CIDR6', 'GEOIP'].includes(rule.type)
+                            rule.type === 'IP-CIDR' ||
+                            rule.type === 'IP-CIDR6'
                        ) {
                            rule.options = params.slice(2);
                        }
--- a/backend/src/core/rule-utils/producers.js
+++ b/backend/src/core/rule-utils/producers.js
@@ -10,8 +10,6 @@ function QXFilter() {
            'SRC-IP',
            'IN-PORT',
            'PROTOCOL',
-            'GEOSITE',
-            'GEOIP',
        ];
        if (UNSUPPORTED.indexOf(rule.type) !== -1) return null;

@@ -31,8 +29,6 @@ function QXFilter() {
 function SurgeRuleSet() {
    const type = 'SINGLE';
    const func = (rule) => {
-        const UNSUPPORTED = ['GEOSITE', 'GEOIP'];
-        if (UNSUPPORTED.indexOf(rule.type) !== -1) return null;
        let output = `${rule.type},${rule.content}`;
        if (['IP-CIDR', 'IP-CIDR6'].includes(rule.type)) {
            output +=
@@ -47,7 +43,7 @@ function LoonRules() {
    const type = 'SINGLE';
    const func = (rule) => {
        // skip unsupported rules
-        const UNSUPPORTED = ['SRC-IP', 'GEOSITE', 'GEOIP'];
+        const UNSUPPORTED = ['DEST-PORT', 'SRC-IP', 'IN-PORT', 'PROTOCOL'];
        if (UNSUPPORTED.indexOf(rule.type) !== -1) return null;
        if (['IP-CIDR', 'IP-CIDR6'].includes(rule.type) && rule.options) {
            // Loon only supports the no-resolve option
@@ -73,7 +69,7 @@ function ClashRuleProvider() {
                let output = `${TRANSFORM[rule.type] || rule.type},${
                    rule.content
                }`;
-                if (['IP-CIDR', 'IP-CIDR6', 'GEOIP'].includes(rule.type)) {
+                if (['IP-CIDR', 'IP-CIDR6'].includes(rule.type)) {
                    if (rule.options) {
                        // Clash only supports the no-resolve option
                        rule.options = rule.options.filter((option) =>
--- a/backend/src/products/cron-sync-artifacts.js
+++ b/backend/src/products/cron-sync-artifacts.js
@@ -128,19 +128,10 @@ async function doSync() {
                        files.map((item) => [item.path, item]),
                    );
                }
-                const raw_url =
-                    files[encodeURIComponent(artifact.name)]?.raw_url;
-                const new_url = isGitLab
-                    ? raw_url
-                    : raw_url?.replace(/\/raw\/[^/]*\/(.*)/, '/raw/$1');
-                $.info(
-                    `上传配置完成\n文件列表: ${Object.keys(files).join(
-                        ', ',
-                    )}\n当前文件: ${encodeURIComponent(
-                        artifact.name,
-                    )}\n响应返回的原始链接: ${raw_url}\n处理完的新链接: ${new_url}`,
-                );
-                artifact.url = new_url;
+                const url = files[encodeURIComponent(artifact.name)]?.raw_url;
+                artifact.url = isGitLab
+                    ? url
+                    : url?.replace(/\/raw\/[^/]*\/(.*)/, '/raw/$1');
            }
        }

--- a/backend/src/restful/download.js
+++ b/backend/src/restful/download.js
@@ -79,7 +79,8 @@ async function downloadSubscription(req, res) {

            if (
                sub.source !== 'local' ||
-                ['localFirst', 'remoteFirst'].includes(sub.mergeSources)
+                ['localFirst', 'remoteFirst'].includes(sub.mergeSources) ||
+                url
            ) {
                try {
                    url = `${url || sub.url}`
@@ -112,7 +113,7 @@ async function downloadSubscription(req, res) {
                        // forward flow headers
                        const flowInfo = await getFlowHeaders(
                            url,
-                            $arguments.flowUserAgent,
+                            undefined,
                            undefined,
                            sub.proxy,
                        );
@@ -249,7 +250,7 @@ async function downloadCollection(req, res) {
                        if (!$arguments.noFlow) {
                            const flowInfo = await getFlowHeaders(
                                url,
-                                $arguments.flowUserAgent,
+                                undefined,
                                undefined,
                                sub.proxy,
                            );
--- a/backend/src/restful/miscs.js
+++ b/backend/src/restful/miscs.js
@@ -3,8 +3,6 @@ import { ENV } from '@/vendor/open-api';
 import { failed, success } from '@/restful/response';
 import { updateArtifactStore, updateAvatar } from '@/restful/settings';
 import resourceCache from '@/utils/resource-cache';
-import scriptResourceCache from '@/utils/script-resource-cache';
-import headersResourceCache from '@/utils/headers-resource-cache';
 import {
    GIST_BACKUP_FILE_NAME,
    GIST_BACKUP_KEY,
@@ -75,8 +73,6 @@ async function refresh(_, res) {

    // 2. clear resource cache
    resourceCache.revokeAll();
-    scriptResourceCache.revokeAll();
-    headersResourceCache.revokeAll();
    success(res);
 }

@@ -157,14 +153,11 @@ async function gistBackup(req, res) {
            }
            success(res);
        } catch (err) {
-            $.error(
-                `Failed to ${action} gist data.\nReason: ${err.message ?? err}`,
-            );
            failed(
                res,
                new InternalServerError(
                    'BACKUP_FAILED',
-                    `Failed to ${action} gist data!`,
+                    `Failed to ${action} data to gist!`,
                    `Reason: ${err.message ?? err}`,
                ),
            );
--- a/backend/src/restful/preview.js
+++ b/backend/src/restful/preview.js
@@ -253,7 +253,11 @@ async function compareCollection(req, res) {
                    errors[name] = err;

                    $.error(
-                        `❌ 处理组合订阅 ${collection.name} 中的子订阅: ${sub.name}时出现错误：${err}！`,
+                        `❌ 处理组合订阅中的子订阅: ${
+                            sub.name
+                        }时出现错误：${err}！进度--${
+                            100 * (processed / subnames.length).toFixed(1)
+                        }%`,
                    );
                }
            }),
--- a/backend/src/restful/subscriptions.js
+++ b/backend/src/restful/subscriptions.js
@@ -115,7 +115,7 @@ async function getFlowInfo(req, res) {
        } else {
            const flowHeaders = await getFlowHeaders(
                url,
-                $arguments.flowUserAgent,
+                undefined,
                undefined,
                sub.proxy,
            );
--- a/backend/src/restful/sync.js
+++ b/backend/src/restful/sync.js
@@ -563,19 +563,10 @@ async function syncArtifacts() {
                        files.map((item) => [item.path, item]),
                    );
                }
-                const raw_url =
-                    files[encodeURIComponent(artifact.name)]?.raw_url;
-                const new_url = isGitLab
-                    ? raw_url
-                    : raw_url?.replace(/\/raw\/[^/]*\/(.*)/, '/raw/$1');
-                $.info(
-                    `上传配置完成\n文件列表: ${Object.keys(files).join(
-                        ', ',
-                    )}\n当前文件: ${encodeURIComponent(
-                        artifact.name,
-                    )}\n响应返回的原始链接: ${raw_url}\n处理完的新链接: ${new_url}`,
-                );
-                artifact.url = new_url;
+                const url = files[encodeURIComponent(artifact.name)]?.raw_url;
+                artifact.url = isGitLab
+                    ? url
+                    : url?.replace(/\/raw\/[^/]*\/(.*)/, '/raw/$1');
            }
        }

@@ -669,18 +660,10 @@ async function syncArtifact(req, res) {
            isGitLab = true;
            files = Object.fromEntries(files.map((item) => [item.path, item]));
        }
-        const raw_url = files[encodeURIComponent(artifact.name)]?.raw_url;
-        const new_url = isGitLab
-            ? raw_url
-            : raw_url?.replace(/\/raw\/[^/]*\/(.*)/, '/raw/$1');
-        $.info(
-            `上传配置完成\n文件列表: ${Object.keys(files).join(
-                ', ',
-            )}\n当前文件: ${encodeURIComponent(
-                artifact.name,
-            )}\n响应返回的原始链接: ${raw_url}\n处理完的新链接: ${new_url}`,
-        );
-        artifact.url = new_url;
+        const url = files[encodeURIComponent(artifact.name)]?.raw_url;
+        artifact.url = isGitLab
+            ? url
+            : url?.replace(/\/raw\/[^/]*\/(.*)/, '/raw/$1');
        $.write(allArtifacts, ARTIFACTS_KEY);
        success(res, artifact);
    } catch (err) {
--- a/backend/src/utils/download.js
+++ b/backend/src/utils/download.js
@@ -129,12 +129,7 @@ export default async function download(rawUrl, ua, timeout, proxy) {
    if ($arguments?.validCheck) {
        await validCheck(
            parseFlowHeaders(
-                await getFlowHeaders(
-                    url,
-                    $arguments.flowUserAgent,
-                    undefined,
-                    proxy,
-                ),
+                await getFlowHeaders(url, undefined, undefined, proxy),
            ),
        );
    }
--- a/backend/src/utils/flow.js
+++ b/backend/src/utils/flow.js
@@ -49,11 +49,7 @@ export async function getFlowHeaders(rawUrl, ua, timeout, proxy) {
        const requestTimeout = timeout || defaultTimeout;
        const http = HTTP();
        try {
-            $.info(
-                `使用 HEAD 方法获取流量信息: ${url}, User-Agent: ${
-                    userAgent || ''
-                }`,
-            );
+            // $.info(`使用 HEAD 方法获取流量信息: ${url}`);
            const { headers } = await http.head({
                url: url
                    .split(/[\r\n]+/)
@@ -80,17 +76,11 @@ export async function getFlowHeaders(rawUrl, ua, timeout, proxy) {
            flowInfo = getFlowField(headers);
        } catch (e) {
            $.error(
-                `使用 HEAD 方法获取流量信息失败: ${url}, User-Agent: ${
-                    userAgent || ''
-                }: ${e.message ?? e}`,
+                `使用 HEAD 方法获取流量信息失败: ${url}: ${e.message ?? e}`,
            );
        }
        if (!flowInfo) {
-            $.info(
-                `使用 GET 方法获取流量信息: ${url}, User-Agent: ${
-                    userAgent || ''
-                }`,
-            );
+            $.info(`使用 GET 方法获取流量信息: ${url}`);
            const { headers } = await http.get({
                url: url
                    .split(/[\r\n]+/)
@@ -138,10 +128,10 @@ export function parseFlowHeaders(flowHeaders) {
    return { expires, total, usage: { upload, download } };
 }
 export function flowTransfer(flow, unit = 'B') {
-    const unitList = ['B', 'KB', 'MB', 'GB', 'TB', 'PB', 'EB', 'ZB', 'YB'];
+    const unitList = ['B', 'KB', 'MB', 'GB', 'TB', 'PB', 'EB'];
    let unitIndex = unitList.indexOf(unit);

-    return flow < 1024 || unitIndex === unitList.length - 1
+    return flow < 1024
        ? { value: flow.toFixed(1), unit: unit }
        : flowTransfer(flow / 1024, unitList[++unitIndex]);
 }
--- a/backend/src/vendor/open-api.js
+++ b/backend/src/vendor/open-api.js
@@ -316,53 +316,42 @@ export function HTTP(defaultOptions = { baseURL: '' }) {
                url: options.url,
                headers: options.headers,
                body: options.body,
-                opts: options.opts,
            });
        } else if (isLoon || isSurge || isNode) {
            worker = new Promise((resolve, reject) => {
                const request = isNode
                    ? eval("require('request')")
                    : $httpClient;
-                const opts = JSON.parse(JSON.stringify(options));
-                if (!isNode && opts.timeout) {
-                    opts.timeout++;
-                    let unit = 'ms';
-                    // 这些客户端单位为 s
-                    if (isSurge || isStash || isShadowRocket) {
-                        opts.timeout = Math.ceil(opts.timeout / 1000);
-                        unit = 's';
-                    }
-                    // Loon 为 ms
-                    // console.log(`[httpClient timeout] ${opts.timeout}${unit}`);
-                }
-                request[method.toLowerCase()](opts, (err, response, body) => {
-                    // if (err) {
-                    //     console.log(err);
-                    // } else {
-                    //     console.log({
-                    //         statusCode:
-                    //             response.status || response.statusCode,
-                    //         headers: response.headers,
-                    //         body,
-                    //     });
-                    // }
+                request[method.toLowerCase()](
+                    JSON.parse(JSON.stringify(options)),
+                    (err, response, body) => {
+                        // if (err) {
+                        //     console.log(err);
+                        // } else {
+                        //     console.log({
+                        //         statusCode:
+                        //             response.status || response.statusCode,
+                        //         headers: response.headers,
+                        //         body,
+                        //     });
+                        // }

-                    if (err) reject(err);
-                    else
-                        resolve({
-                            statusCode: response.status || response.statusCode,
-                            headers: response.headers,
-                            body,
-                        });
-                });
+                        if (err) reject(err);
+                        else
+                            resolve({
+                                statusCode:
+                                    response.status || response.statusCode,
+                                headers: response.headers,
+                                body,
+                            });
+                    },
+                );
            });
        }

        let timeoutid;
-
        const timer = timeout
            ? new Promise((_, reject) => {
-                  //   console.log(`[request timeout] ${timeout}ms`);
                  timeoutid = setTimeout(() => {
                      events.onTimeout();
                      return reject(
--- a/config/Loon.plugin
+++ b/config/Loon.plugin
@@ -17,4 +17,4 @@ hostname=sub.store
 http-request ^https?:\/\/sub\.store\/((download)|api\/(preview|sync|(utils\/node-info))) script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-1.min.js, requires-body=true, timeout=120, tag=Sub-Store Core
 http-request ^https?:\/\/sub\.store script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js, requires-body=true, timeout=120, tag=Sub-Store Simple

-cron "55 23 * * *" script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/cron-sync-artifacts.min.js, timeout=120, tag=Sub-Store Sync
+cron "55 23 * * *" script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/cron-sync-artifacts.min.js, tag=Sub-Store Sync
--- a/config/Surge-Beta.sgmodule
+++ b/config/Surge-Beta.sgmodule
@@ -10,6 +10,6 @@ hostname = %APPEND% sub.store
 [Script]
 Sub-Store Core=type=http-request,pattern=^https?:\/\/sub\.store\/((download)|api\/(preview|sync|(utils\/node-info))),script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-1.min.js,requires-body=true,timeout=120,ability="{{{ability}}}"

-Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true,timeout=120
+Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true

 {{{sync}}}=type=cron,cronexp="{{{cronexp}}}",wake-system=1,timeout=120,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/cron-sync-artifacts.min.js
--- a/config/Surge-Noability.sgmodule
+++ b/config/Surge-Noability.sgmodule
@@ -8,6 +8,6 @@ hostname = %APPEND% sub.store
 [Script]
 # 主程序 已经去掉 Sub-Store Core 的参数 [,ability=http-client-policy] 不会爆内存，这个参数在 Surge 非常占用内存； 如果不需要使用指定节点功能 例如[加旗帜脚本或者cname脚本] 则可以使用此脚本
 Sub-Store Core=type=http-request,pattern=^https?:\/\/sub\.store\/((download)|api\/(preview|sync|(utils\/node-info))),script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-1.min.js,requires-body=true,timeout=120
-Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true,timeout=120
+Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true

 Sub-Store Sync=type=cron,cronexp=55 23 * * *,wake-system=1,timeout=120,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/cron-sync-artifacts.min.js
--- a/config/Surge-ability.sgmodule
+++ b/config/Surge-ability.sgmodule
@@ -7,6 +7,6 @@ hostname = %APPEND% sub.store

 [Script]
 Sub-Store Core=type=http-request,pattern=^https?:\/\/sub\.store\/((download)|api\/(preview|sync|(utils\/node-info))),script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-1.min.js,requires-body=true,timeout=120,ability=http-client-policy
-Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true,timeout=120
+Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true

 Sub-Store Sync=type=cron,cronexp=55 23 * * *,wake-system=1,timeout=120,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/cron-sync-artifacts.min.js
--- a/config/Surge.sgmodule
+++ b/config/Surge.sgmodule
@@ -7,6 +7,6 @@ hostname = %APPEND% sub.store

 [Script]
 Sub-Store Core=type=http-request,pattern=^https?:\/\/sub\.store\/((download)|api\/(preview|sync|(utils\/node-info))),script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-1.min.js,requires-body=true,timeout=120
-Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true,timeout=120
+Sub-Store Simple=type=http-request,pattern=^https?:\/\/sub\.store,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/sub-store-0.min.js,requires-body=true

 Sub-Store Sync=type=cron,cronexp=55 23 * * *,wake-system=1,timeout=120,script-path=https://github.com/sub-store-org/Sub-Store/releases/latest/download/cron-sync-artifacts.min.js
--- a/scripts/demo.js
+++ b/scripts/demo.js
@@ -22,9 +22,6 @@ function operator(proxies = [], targetPlatform, context) {
  
  // scriptResourceCache 缓存
  // 可参考 https://t.me/zhetengsha/1003
-  // const cache = scriptResourceCache
-  // cache.set(id, data)
-  // cache.get(id)

  // ProxyUtils 为节点处理工具
  // 可参考 https://t.me/zhetengsha/1066
@@ -38,13 +35,6 @@ function operator(proxies = [], targetPlatform, context) {
  //     yaml, // yaml 解析和生成
  // }

-  // 示例: 从 sni 文件中读取内容并进行节点操作
-  // const sni = await produceArtifact({
-  //     type: 'file',
-  //     name: 'sni' // 文件名
-  // });
-  // $server.sni = sni
-
  // 1. Surge 输出 WireGuard 完整配置

  // let proxies = await produceArtifact({
@@ -59,10 +49,7 @@ function operator(proxies = [], targetPlatform, context) {
  
  // 2. sing-box

-  // 但是一般不需要这样用, 可参考
-  // 1. https://t.me/zhetengsha/1111
-  // 2. https://t.me/zhetengsha/1070
-  // 3. https://t.me/zhetengsha/1241
+  // 但是一般不需要这样用, 可参考 1. https://t.me/zhetengsha/1111 和 2. https://t.me/zhetengsha/1070

  // let singboxProxies = await produceArtifact({
  //     type: 'subscription', // type: 'subscription' 或 'collection'
@@ -76,42 +63,24 @@ function operator(proxies = [], targetPlatform, context) {

  // 3. clash.meta

-  // 但是一般不需要这样用, 可参考
-  // 1. https://t.me/zhetengsha/1111
-  // 2. https://t.me/zhetengsha/1070
-  // 3. https://t.me/zhetengsha/1234
+  // 但是一般不需要这样用, 可参考 1. https://t.me/zhetengsha/1111 和 2. https://t.me/zhetengsha/1070

  // let clashMetaProxies = await produceArtifact({
  //     type: 'subscription',
  //     name: 'sub',
  //     platform: 'ClashMeta',
  //     produceType: 'internal' // 'internal' produces an Array, otherwise produces a String( ProxyUtils.yaml.safeLoad('YAML String').proxies )
-  // })
+  // }))

  // // YAML
-  // ProxyUtils.yaml.load('YAML String')
-  // ProxyUtils.yaml.safeLoad('YAML String')
  // $content = ProxyUtils.yaml.safeDump({})
-  // $content = ProxyUtils.yaml.dump({})
-
-  // 一个往文件里插入本地节点的例子:
-  // const yaml = ProxyUtils.yaml.safeLoad($content ?? $files[0])
-  // let clashMetaProxies = await produceArtifact({
-  //     type: 'collection',
-  //     name: '机场',
-  //     platform: 'ClashMeta',
-  //     produceType: 'internal'
-  // })
-  // yaml.proxies.unshift(...clashMetaProxies)
-  // $content = ProxyUtils.yaml.dump(yaml)


  // { $content, $files } will be passed to the next operator 
  // $content is the final content of the file
-
  // flowUtils 为机场订阅流量信息处理工具
-  // 可参考: 
-  // 1. https://t.me/zhetengsha/948
+  // 可参考 https://t.me/zhetengsha/948
+  // https://github.com/sub-store-org/Sub-Store/blob/31b6dd0507a9286d6ab834ec94ad3050f6bdc86b/backend/src/utils/download.js#L104

  // context 为传入的上下文
  // 有三种情况, 按需判断