Method cleanBlockedPM

clean/clean.ts:327–405

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

  // 拉黑用户清理
  private async cleanBlockedPM(client: any, msg: Api.Message, includeAll: boolean = false): Promise<void> {
    this.blockedCleanupStartTime = Date.now();
    
    await this.editMessage(msg, 
      `🧹 开始清理拉黑用户\n\n模式: ${includeAll ? '全量清理' : '智能清理'}`);

    let offset = 0;
    let success = 0, failed = 0, skipped = 0, totalUsers = 0, processedUsers = 0;
    let consecutiveErrors = 0;

    // 获取总数
    try {
      const initialBlocked = await client.invoke(new Api.contacts.GetBlocked({ offset: 0, limit: 1 }));
      totalUsers = initialBlocked.className === 'contacts.BlockedSlice' 
        ? (initialBlocked as any).count || 0 
        : (await client.invoke(new Api.contacts.GetBlocked({ offset: 0, limit: 1000 })))?.users?.length || 0;
    } catch (error) {
      console.error("获取用户总数失败:", error);
    }

    while (true) {
      try {
        const blocked = await client.invoke(new Api.contacts.GetBlocked({ offset, limit: 100 }));
        if (!blocked.users?.length) break;

        for (const user of blocked.users) {
          processedUsers++;
          
          // 智能模式跳过机器人/诈骗账户
          if (!includeAll && (user.bot || user.scam || user.fake)) {
            skipped++;
            continue;
          }

          try {
            await client.invoke(new Api.contacts.Unblock({ id: user }));
            success++;
            
            // 动态延迟
            const delay = this.getDynamicDelay(user, includeAll, consecutiveErrors);
            await sleep(delay);
            consecutiveErrors = 0;
          } catch (error: any) {
            if (error.message?.includes('FLOOD_WAIT_')) {
              await this.handleFloodWait(msg, error);
              continue;
            } else {
              failed++;
              consecutiveErrors++;
              await sleep(this.getDynamicDelay(user, includeAll, consecutiveErrors));
            }
          }

          // 更新进度
          if (processedUsers % 10 === 0) {
            await this.updateBlockedProgress(msg, processedUsers, totalUsers, success, failed, skipped, includeAll);
          }
        }