Function traditionalStreamProcessing

dme/dme.ts:679–870

* 传统遍历消息流式处理 - 适用于禁止转发和复制的群组

(
  client: TelegramClient,
  chatEntity: any,
  myId: bigint,
  userRequestedCount: number,
  isAntiRecallMode: boolean = false,
  topicRootId?: number
)

  isAntiRecallMode: boolean = false,
  topicRootId?: number
): Promise<{
  processedCount: number;
  actualCount: number;
  editedCount: number;
}> {
  console.log(`[DME] 使用传统遍历消息流式处理模式`);
  
  const targetCount = userRequestedCount === 999999 ? Infinity : userRequestedCount;
  const trollImagePath = isAntiRecallMode ? await getTrollImage() : null;
  const sendAsIdentity =
    chatEntity.className === "Channel"
      ? await getSendAsIdentitySet(client, chatEntity)
      : { typedKeys: new Set<string>(), rawIds: new Set<string>() };
  
  let totalProcessed = 0;
  let totalEdited = 0;
  let totalDeleted = 0;
  let offsetId = 0;
  let consecutiveEmptyBatches = 0;
  const maxEmptyBatches =
    chatEntity.className === "Channel" ? CONFIG.CHANNEL_EMPTY_BATCH_LIMIT : 3;
  const HISTORY_BATCH = 100; // 每批获取历史消息数量

  // 传统模式：逐批获取历史消息，筛选自己的消息进行处理
  while (totalProcessed < targetCount && consecutiveEmptyBatches < maxEmptyBatches) {
    try {
      // 获取历史消息
      const history = await client.invoke(
        new Api.messages.GetHistory({
          peer: chatEntity,
          offsetId,
          offsetDate: 0,
          addOffset: 0,
          limit: HISTORY_BATCH,
          maxId: 0,
          minId: 0,
          hash: 0 as any,
        })
      );

      const allMessages: any[] = (history as any).messages || [];
      const validMessages = allMessages.filter((m: any) => m.className === "Message");
      
      if (validMessages.length === 0) {
        consecutiveEmptyBatches++;
        console.log(`[DME] 空批次 ${consecutiveEmptyBatches}/${maxEmptyBatches}`);
        await sleep(CONFIG.DELAYS.SEARCH);
        continue;
      }

      // 筛选出自己的消息
      const myMessages = validMessages.filter(
        (m: any) =>
          isMessageInTopic(m, topicRootId) &&
          isMyMessageByIdentity(
            m,
            myId,
            sendAsIdentity.typedKeys,