Function quickDeleteMyMessages

dme/dme.ts:875–999

* 快速删除模式 - 直接调用官方API删除消息

(
  client: TelegramClient,
  chatEntity: any,
  myId: bigint,
  userRequestedCount: number,
  topicRootId?: number
)

  topicRootId?: number
): Promise<{
  processedCount: number;
  actualCount: number;
  editedCount: number;
}> {
  // 频道/超级群里“以频道身份发言”的消息通常不带个人 senderId，
  // 直接改用 out 消息遍历模式，避免快速搜索漏删。
  if (chatEntity.className === "Channel") {
    console.log(`[DME] 频道会话启用出站消息遍历模式（支持频道身份发言）`);
    return await traditionalStreamProcessing(client, chatEntity, myId, userRequestedCount, false, topicRootId);
  }

  // 检测是否为受限群组（禁止转发和复制）
  const isRestricted = await isRestrictedGroup(client, chatEntity);
  if (isRestricted) {
    console.log(`[DME] 检测到受限群组，切换到传统遍历模式`);
    return await traditionalStreamProcessing(client, chatEntity, myId, userRequestedCount, false, topicRootId);
  }
  
  console.log(`[DME] 使用快速删除模式`);
  
  const targetCount =
    userRequestedCount === CONFIG.UNLIMITED_REQUEST_COUNT
      ? Infinity
      : userRequestedCount;
  let offsetId = 0;
  let searchFailCount = 0;
  const maxSearchFails = 2;
  let totalMatched = 0;
  let totalDeleted = 0;
  let hasSearchResult = false;

  // 流式搜索并删除：避免 allMyMessages 大数组导致堆内存膨胀
  while (targetCount === Infinity || totalMatched < targetCount) {
    const searchLimit =
      targetCount === Infinity
        ? CONFIG.SEARCH_LIMIT
        : Math.min(CONFIG.SEARCH_LIMIT, targetCount - totalMatched);

    try {
      const searchResult = await client.invoke(
        new Api.messages.Search({
          peer: chatEntity,
          q: "",
          fromId: await client.getInputEntity(myId.toString()),
          ...(typeof topicRootId === "number" ? { topMsgId: topicRootId } : {}),
          filter: new Api.InputMessagesFilterEmpty(),
          minDate: 0,
          maxDate: 0,
          offsetId: offsetId,
          addOffset: 0,
          limit: searchLimit,
          maxId: 0,
          minId: 0,
          hash: 0 as any
        })
      );

      const resultMessages = (searchResult as any).messages;