Function searchEditAndDeleteMyMessages

dme/dme.ts:1004–1222

* 搜索并处理用户消息的主函数 - 防撤回模式（-f参数）流式处理版本

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

  topicRootId?: number
): Promise<{
  processedCount: number;
  actualCount: number;
  editedCount: number;
}> {
  // 收藏夹（保存的消息）专用快速删除
  if (isSavedMessagesPeer(chatEntity, myId)) {
    console.log("[DME] 检测到收藏夹会话，直接按数量删除");
    return await deleteInSavedMessages(client, chatEntity, userRequestedCount);
  }

  // 检查是否为频道且有管理权限
  const isChannel = chatEntity.className === "Channel";
  if (isChannel) {
    console.log(`[DME] 检测到频道，检查管理员权限...`);
    try {
      const me = await safeGetMe(client);
      if (!me) return { processedCount: 0, actualCount: 0, editedCount: 0 };
      const participant = await client.invoke(
        new Api.channels.GetParticipant({
          channel: chatEntity,
          participant: me.id,
        })
      );

      const isCreator =
        participant.participant.className === "ChannelParticipantCreator";
      const isBroadcast = (chatEntity as any).broadcast === true;
      if (isCreator && isBroadcast) {
        console.log(`[DME] 检测到私人频道且为频道主，直接按数量删除`);
        return await deleteInSavedMessages(client, chatEntity, userRequestedCount);
      }

      const isAdmin =
        participant.participant.className === "ChannelParticipantAdmin" ||
        participant.participant.className === "ChannelParticipantCreator";

      if (isAdmin) {
        console.log(`[DME] 拥有频道管理权限，但仍使用普通模式避免误删别人消息`);
      } else {
        console.log(`[DME] 无频道管理权限，使用普通模式`);
      }
    } catch (error) {
      console.log(`[DME] 权限检查失败，使用普通模式:`, error);
    }
  }

  // 频道/超级群里“以频道身份发言”的消息通常不带个人 senderId，
  // 直接改用 out 消息遍历模式，避免流式搜索漏删。
  if (isChannel) {
    console.log(`[DME] 频道会话启用出站消息遍历模式（支持频道身份发言）`);
    return await traditionalStreamProcessing(client, chatEntity, myId, userRequestedCount, true, topicRootId);
  }
  
  // 检测是否为受限群组（禁止转发和复制）
  const isRestricted = await isRestrictedGroup(client, chatEntity);
  if (isRestricted) {
    console.log(`[DME] 检测到受限群组，切换到传统遍历模式`);
    return await traditionalStreamProcessing(client, chatEntity, myId, userRequestedCount, true, topicRootId);