Method findAndSendVideo

search/search.ts:422–582

(
    msg: Api.Message,
    query: string | null,
    useSpoiler: boolean,
    useRandom: boolean,
    type: "kkp" | "search"
  )

  }

  private async findAndSendVideo(
    msg: Api.Message,
    query: string | null,
    useSpoiler: boolean,
    useRandom: boolean,
    type: "kkp" | "search"
  ) {
    if (this.config.channelList.length === 0)
      throw new Error(`请至少使用 \`${mainPrefix}so add\` 添加一个搜索频道。`);

    const initialMessage = type === "kkp" ? "🎲 正在随机寻找视频..." : "🔍 正在搜索视频...";
    await msg.edit({ text: initialMessage });

    const searchOrder = [...new Set([this.config.defaultChannel, ...this.config.channelList.map((c) => c.handle)].filter(Boolean) as string[])];
    
    let validVideos: Api.Message[] = [];
    const processedGroupIds = new Set<string>();

    for (const [index, channelHandle] of searchOrder.entries()) {
      if (index > 0) {
        await new Promise(resolve => setTimeout(resolve, 750));
      }

      const channelInfo = this.config.channelList.find((c) => c.handle === channelHandle);
      if (!channelInfo) continue;
      
      let videosInCurrentChannel: Api.Message[] = [];

      try {
        await msg.edit({ text: `- 正在搜索... (源: ${index + 1}/${searchOrder.length})` });
        const entity = await this.client.getEntity(channelInfo.handle);

        if (type === "search" && query) {
          if (channelInfo.linkedGroup) {
            const linkedVideos = await this.searchInChannelWithLinkedGroup(channelInfo, query);
            if (linkedVideos.length > 0) videosInCurrentChannel.push(...linkedVideos);
          }

          const allQueryMessages = await safeGetMessages(this.client, entity, { limit: 200, search: query });

          for (const foundMsg of allQueryMessages) {
            if (this.isMessageMatching(foundMsg, query)) {
              if (foundMsg.groupedId) {
                const groupIdStr = foundMsg.groupedId.toString();
                if (processedGroupIds.has(groupIdStr)) continue;

                const surroundingMessages = await safeGetMessages(this.client, entity, {
                    limit: 20,
                    offsetId: foundMsg.id + 10,
                });
                
                const groupedId = foundMsg.groupedId;
                if (!groupedId) continue;
                const albumMessages = surroundingMessages.filter((m: Api.Message) => m.groupedId?.equals(groupedId));
                const videosInAlbum = albumMessages.filter((m: Api.Message) => m.video && !this.isAdContent(m));

                if (videosInAlbum.length > 0) {
                  videosInCurrentChannel.push(...videosInAlbum);