feat: 支持 flowUrl

backend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "sub-store",
-  "version": "2.14.329",
+  "version": "2.14.330",
   "description": "Advanced Subscription Manager for QX, Loon, Surge, Stash and ShadowRocket.",
   "main": "src/main.js",
   "scripts": {

backend/src/restful/download.js

@@ -156,6 +156,7 @@ async function downloadSubscription(req, res) {
                             $arguments.flowUserAgent,
                             undefined,
                             sub.proxy,
+                            $arguments.flowUrl,
                         );
                         if (flowInfo) {
                             res.set('subscription-userinfo', flowInfo);
@@ -314,6 +315,7 @@ async function downloadCollection(req, res) {
                                 $arguments.flowUserAgent,
                                 undefined,
                                 sub.proxy,
+                                $arguments.flowUrl,
                             );
                             if (flowInfo) {
                                 res.set('subscription-userinfo', flowInfo);

backend/src/restful/subscriptions.js

@@ -118,6 +118,7 @@ async function getFlowInfo(req, res) {
                 $arguments.flowUserAgent,
                 undefined,
                 sub.proxy,
+                $arguments.flowUrl,
             );
             if (!flowHeaders) {
                 failed(

backend/src/utils/download.js

@@ -217,6 +217,7 @@ export default async function download(
                     $arguments.flowUserAgent,
                     undefined,
                     proxy,
+                    $arguments.flowUrl,
                 ),
             ),
         );

backend/src/utils/flow.js

@@ -10,8 +10,8 @@ export function getFlowField(headers) {
     )[0];
     return headers[subkey];
 }
-export async function getFlowHeaders(rawUrl, ua, timeout, proxy) {
+export async function getFlowHeaders(rawUrl, ua, timeout, proxy, flowUrl) {
-    let url = rawUrl;
+    let url = flowUrl || rawUrl;
     let $arguments = {};
     const rawArgs = url.split('#');
     url = url.split('#')[0];
@@ -48,9 +48,24 @@ export async function getFlowHeaders(rawUrl, ua, timeout, proxy) {
             'Quantumult%20X/1.0.30 (iPhone14,2; iOS 15.6)';
         const requestTimeout = timeout || defaultTimeout;
         const http = HTTP();
+        if (flowUrl) {
+            $.info(
+                `使用 GET 方法从响应体获取流量信息: ${flowUrl}, User-Agent: ${
+                    userAgent || ''
+                }`,
+            );
+            const { body } = await http.get({
+                url: flowUrl,
+                headers: {
+                    'User-Agent': userAgent,
+                },
+                timeout: requestTimeout,
+            });
+            flowInfo = body;
+        } else {
             try {
                 $.info(
-                `使用 HEAD 方法获取流量信息: ${url}, User-Agent: ${
+                    `使用 HEAD 方法从响应头获取流量信息: ${url}, User-Agent: ${
                         userAgent || ''
                     }`,
                 );
@@ -80,7 +95,7 @@ export async function getFlowHeaders(rawUrl, ua, timeout, proxy) {
                 flowInfo = getFlowField(headers);
             } catch (e) {
                 $.error(
-                `使用 HEAD 方法获取流量信息失败: ${url}, User-Agent: ${
+                    `使用 HEAD 方法从响应头获取流量信息失败: ${url}, User-Agent: ${
                         userAgent || ''
                     }: ${e.message ?? e}`,
                 );
@@ -103,6 +118,7 @@ export async function getFlowHeaders(rawUrl, ua, timeout, proxy) {
                 });
                 flowInfo = getFlowField(headers);
             }
+        }
         if (flowInfo) {
             headersResourceCache.set(url, flowInfo);
         }