Method cleanDeletedPM

clean/clean.ts:172–256

(client: any, msg: Api.Message, deleteDialogs: boolean = false)

      ? "🔍 正在扫描并从对话列表中移除已注销账号..." 
      : "🔍 正在扫描私聊已注销账号...");

    const deletedUsers: Array<{id: string, username?: string}> = [];
    
    try {
      const dialogsMain = await client.getDialogs({});
      let dialogsArchived: any[] = [];
      try {
        dialogsArchived = await client.getDialogs({ folder: 1 });
      } catch (error: any) {
        console.error(`[Clean] 获取归档对话失败:`, error?.message || error);
      }

      const dialogByUserId = new Map<string, any>();
      const dialogs = [...(dialogsMain || []), ...(dialogsArchived || [])];

      for (const dialog of dialogs) {
        if (dialog.isUser && dialog.entity instanceof Api.User && dialog.entity.deleted) {
          const user = dialog.entity;
          const userId = user.id.toString();

          if (!dialogByUserId.has(userId)) {
            dialogByUserId.set(userId, dialog);
            deletedUsers.push({
              id: userId,
              username: user.username || "已注销账号"
            });
          }
        }
      }

      if (deleteDialogs) {
        for (const [userId, dialog] of dialogByUserId.entries()) {
          try {
            /**
             * 本 fork 的 teleproto 没有 client.deleteDialog，TL 层也没有
             * messages.deleteDialog / just_remove；改用 messages.deleteHistory
             * 清空本地历史，会话随之从列表移除。
             * 不传 revoke：已注销账号无对端可撤销，开启反而可能失败。
             */
            await client.invoke(
              new Api.messages.DeleteHistory({
                peer: dialog.inputEntity,
                maxId: 2147483647,
              })
            );

            await sleep(150);
          } catch (error: any) {
            console.error(`[Clean] 无法移除对话 ${userId}:`, error.message);
            if (error.message?.includes("FLOOD_WAIT")) {
              await this.handleFloodWait(msg, error);
              return;
            }
          }
        }
      }

      // 构建结果反馈