🐛 新增批次检查脚本的 timeout, 避免一个脚本更新时间太长导致所有脚本检查失败 (#1265)

* 新增批次检查脚本的 timeout, 避免一个脚本更新时间太长导致所有脚本检查失败

* 🐛 修复批量更新超时机制的 4 个问题

- fetchScriptBody 添加 AbortSignal 支持
- 繁体转简体：確保次序 → 确保顺序
- 用 setTimeout+clearTimeout 替代 sleep，超时后正确清理
- 超时时通过 AbortController 中止进行中的请求
- Map 预初始化确保返回顺序一致

---------

Co-authored-by: 王一之 <[email protected]>

Author: cyfung1031

src/app/service/service_worker/script.ts

@@ -772,17 +772,51 @@ export class ScriptService {
         setTimeout(resolve, Math.round(MIN_DELAY + ((++i / n + Math.random()) / 2) * (MAX_DELAY - MIN_DELAY)))
       );
 
-    return Promise.all(
-      (uuids as string[]).map(async (uuid, _idx) => {
-        const script = scripts[_idx];
-        const res =
-          !script || script.uuid !== uuid || !checkScripts.includes(script)
-            ? false
-            : await this._checkUpdateAvailable(script, delayFn);
-        if (!res) return false;
-        return res;
-      })
-    );
+    const CHECK_UPDATE_TIMEOUT_MS = 300_000; // 5 分钟超时
+
+    const results = new Map<
+      string,
+      | false
+      | {
+          updateAvailable: true;
+          code: string;
+          metadata: Partial<Record<string, string[]>>;
+        }
+    >();
+
+    // 预初始化 Map 确保顺序
+    for (const uuid of uuids as string[]) {
+      results.set(uuid, false);
+    }
+
+    const abortController = new AbortController();
+    let timeoutId: ReturnType<typeof setTimeout>;
+
+    const timeoutPromise = new Promise<void>((resolve) => {
+      timeoutId = setTimeout(() => {
+        abortController.abort();
+        resolve();
+      }, CHECK_UPDATE_TIMEOUT_MS);
+    });
+
+    await Promise.race([
+      timeoutPromise,
+      Promise.allSettled(
+        (uuids as string[]).map(async (uuid, _idx) => {
+          const script = scripts[_idx];
+          const res =
+            !script || script.uuid !== uuid || !checkScripts.includes(script)
+              ? false
+              : await this._checkUpdateAvailable(script, delayFn, abortController.signal);
+          if (!res) return false;
+          results.set(uuid, res);
+          return res;
+        })
+      ).finally(() => {
+        clearTimeout(timeoutId);
+      }),
+    ]);
+    return [...results.values()];
   }
 
   async _checkUpdateAvailable(
@@ -792,7 +826,8 @@ export class ScriptService {
       checkUpdateUrl?: string;
       metadata: Partial<Record<string, any>>;
     },
-    delayFn?: () => Promise<any>
+    delayFn?: () => Promise<any>,
+    signal?: AbortSignal
   ): Promise<false | { updateAvailable: true; code: string; metadata: SCMetadata }> {
     const { uuid, name, checkUpdateUrl } = script;
 
@@ -804,8 +839,12 @@ export class ScriptService {
       name,
     });
     try {
-      if (delayFn) await delayFn();
-      const code = await fetchScriptBody(checkUpdateUrl);
+      if (delayFn) {
+        if (signal?.aborted) return false;
+        await delayFn();
+      }
+      if (signal?.aborted) return false;
+      const code = await fetchScriptBody(checkUpdateUrl, signal);
       const metadata = parseMetadata(code);
       if (!metadata) {
         logger.error("parse metadata failed");

src/pkg/utils/script.ts

@@ -46,8 +46,9 @@ export function parseMetadata(code: string): SCMetadata | null {
 }
 
 // 从网址取得脚本代码
-export async function fetchScriptBody(url: string): Promise<string> {
+export async function fetchScriptBody(url: string, signal?: AbortSignal): Promise<string> {
   const resp = await fetch(url, {
+    signal,
     headers: {
       "Cache-Control": "no-cache",
     },