From fa8da9ae25f8dbf20625aabe9c9bf0722211c022 Mon Sep 17 00:00:00 2001
From: jiangrui <jiangrui@01ly.com.cn>
Date: Tue, 4 Mar 2025 14:34:30 +0800
Subject: [PATCH] =?UTF-8?q?refactor:=E4=BC=98=E5=8C=96=E6=90=9C=E7=B4=A2?=
 =?UTF-8?q?=E8=B5=84=E6=BA=90=E7=9A=84=E8=AF=B7=E6=B1=82=E9=80=9F=E5=BA=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/src/services/Searcher.ts | 54 +++++++++++++++++---------------
 1 file changed, 29 insertions(+), 25 deletions(-)

diff --git a/backend/src/services/Searcher.ts b/backend/src/services/Searcher.ts
index 3286cd4..fd8bced 100644
--- a/backend/src/services/Searcher.ts
+++ b/backend/src/services/Searcher.ts
@@ -77,42 +77,46 @@ export class Searcher {
   }
 
   async searchAll(keyword: string, channelId?: string, messageId?: string) {
-    const allResults = [];
+    const allResults: any[] = [];
 
-    const channelList = channelId
-      ? config.rss.channels.filter((channel) => channel.id === channelId)
+    const channelList: any[] = channelId
+      ? config.rss.channels.filter((channel: any) => channel.id === channelId)
       : config.rss.channels;
 
-    for (let i = 0; i < channelList.length; i++) {
-      const channel = channelList[i];
+    // 使用Promise.all进行并行请求
+    const searchPromises = channelList.map(async (channel) => {
       try {
         const messageIdparams = messageId ? `before=${messageId}` : "";
         const url = `/${channel.id}${keyword ? `?q=${encodeURIComponent(keyword)}&${messageIdparams}` : `?${messageIdparams}`}`;
         console.log(`Searching in channel ${channel.name} with URL: ${url}`);
-        const results = await this.searchInWeb(url);
-        console.log(`Found ${results.items.length} items in channel ${channel.name}`);
-        if (results.items.length > 0) {
-          const channelResults = results.items
-            .filter((item: sourceItem) => item.cloudLinks && item.cloudLinks.length > 0)
-            .map((item: sourceItem) => ({
-              ...item,
-              channel: channel.name,
-              channelId: channel.id,
-            }));
+        return this.searchInWeb(url).then((results) => {
+          console.log(`Found ${results.items.length} items in channel ${channel.name}`);
+          if (results.items.length > 0) {
+            const channelResults = results.items
+              .filter((item: sourceItem) => item.cloudLinks && item.cloudLinks.length > 0)
+              .map((item: sourceItem) => ({
+                ...item,
+                channel: channel.name,
+                channelId: channel.id,
+              }));
 
-          allResults.push({
-            list: channelResults,
-            channelInfo: {
-              ...channel,
-              channelLogo: results.channelLogo,
-            },
-            id: channel.id,
-          });
-        }
+            allResults.push({
+              list: channelResults,
+              channelInfo: {
+                ...channel,
+                channelLogo: results.channelLogo,
+              },
+              id: channel.id,
+            });
+          }
+        });
       } catch (error) {
         Logger.error(`搜索频道 ${channel.name} 失败:`, error);
       }
-    }
+    });
+
+    // 等待所有请求完成
+    await Promise.all(searchPromises);
 
     return {
       data: allResults,