Function searchMyMessagesOptimized

da/da.ts:108–167

* 使用messages.search直接搜索自己的消息 - 高效版本 * 从dme.ts移植的优化搜索函数

(
  client: TelegramClient,
  chatEntity: any,
  myId: bigInt.BigInteger,
  batchSize: number = 100
)

  chatEntity: any,
  myId: bigInt.BigInteger,
  batchSize: number = 100
): Promise<Api.Message[]> {
  const allMyMessages: Api.Message[] = [];
  let offsetId = 0;

  console.log(`[DA] 使用优化搜索模式，直接定位自己的消息`);

  try {
    while (true) {
      // 使用messages.search直接搜索自己的消息
      const searchResult = await client.invoke(
        new Api.messages.Search({
          peer: chatEntity,
          q: "", // 空查询搜索所有消息
          fromId: await client.getInputEntity(myId.toString()), // 关键：指定from_id为自己
          filter: new Api.InputMessagesFilterEmpty(), // 不过滤消息类型
          minDate: 0,
          maxDate: 0,
          offsetId: offsetId,
          addOffset: 0,
          limit: batchSize,
          maxId: 0,
          minId: 0,
          hash: 0 as any
        })
      );

      // 正确处理搜索结果类型
      const resultMessages = (searchResult as any).messages;
      if (!resultMessages || resultMessages.length === 0) {
        console.log(`[DA] 搜索完成，共找到 ${allMyMessages.length} 条自己的消息`);
        break;
      }

      const messages = resultMessages.filter((m: any) => 
        m.className === "Message" && m.senderId?.toString() === myId.toString()
      );

      if (messages.length > 0) {
        allMyMessages.push(...messages);
        offsetId = messages[messages.length - 1].id;
        console.log(`[DA] 批次搜索到 ${messages.length} 条消息，总计 ${allMyMessages.length} 条`);
      } else {
        break;
      }

      // 避免API限制
      await sleep(200);
    }
  } catch (error: any) {
    console.error("[DA] 优化搜索失败:", error);
    return [];
  }

  return allMyMessages;
}

// 发送或更新进度到收藏夹