Method cleanDeletedMember

clean/clean.ts:259–324

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

  }

  // 群组已注销账号清理
  // 根因修复：必须传完整 User（含 accessHash），不能只传裸 userId；
  // banUser 失败返回 false 时不能算「已清理」。
  private async cleanDeletedMember(client: any, msg: Api.Message, cleanMembers: boolean = false): Promise<void> {
    const chat = await msg.getChat();
    if (!chat || !(chat instanceof Api.Chat || chat instanceof Api.Channel)) {
      await this.sendError(msg, "此命令仅在群组中可用");
      return;
    }

    await this.editMessage(msg, cleanMembers 
      ? "🔍 正在扫描并清理群组已注销账号..." 
      : "🔍 正在扫描群组已注销账号...");

    // 用完整 chat 实体，避免 EditBanned 拿不到 channel access_hash
    const chatEntity = await client.getInputEntity(chat);
    if (cleanMembers && !await this.checkBanPermission(client, chat)) {
      await this.sendError(msg, "没有封禁用户权限，无法执行清理");
      return;
    }

    let foundCount = 0;
    let removedCount = 0;
    let failedCount = 0;
    const deletedUsers: Array<{id: string, username?: string, ok?: boolean, err?: string}> = [];

    // 优先用完整 chat 实体迭代，保证 participant 上带 accessHash
    const participants = client.iterParticipants(chat);
    for await (const participant of participants) {
      if (participant instanceof Api.User && participant.deleted) {
        foundCount++;
        const entry: {id: string, username?: string, ok?: boolean, err?: string} = {
          id: participant.id.toString(),
          username: participant.username || "已注销账号",
        };

        if (cleanMembers) {
          try {
            // 传完整 User，不要 participant.id（已注销账号 getInputEntity(id) 会失败）
            const ok = await banUser(client, chatEntity, participant);
            if (ok) {
              removedCount++;
              entry.ok = true;
              // 踢出：封禁后再解封，避免永久 ban 列表堆积（与 kickUser 一致）
              try {
                await unbanUser(client, chatEntity, participant);
              } catch {
                /* 解封失败不影响已移出 */
              }
            } else {
              failedCount++;
              entry.ok = false;
              entry.err = "封禁接口返回失败";
            }
            await sleep(150);
          } catch (error: any) {
            if (error.message?.includes("FLOOD_WAIT")) {
              await this.handleFloodWait(msg, error);