Method handleBasicCommand

aban/aban.ts:1135–1234

(
    client: TelegramClient,
    message: Api.Message,
    action: 'kick' | 'ban' | 'unban' | 'mute' | 'unmute'
  )

          return client.invoke(
            new Api.messages.DeleteChatUser({
              chatId: bigInt(this.getBasicGroupChatId(group.id)),
              userId: resolvedParticipant,
            })
          );
        }
        const channelInput = await resolveChannelInput(client, group);
        return client.invoke(
          new Api.channels.EditBanned({
            channel: channelInput,
            participant: resolvedParticipant,
            bannedRights: rights,
          })
        );
      };

      // 单组重试：FLOOD_WAIT 等待 ≤ 8s 时重试一次，其余错误直接返回
      const attempt = async (retriesLeft: number): Promise<
        | { success: true; group: ManagedGroup }
        | { success: false; group: ManagedGroup; reason: string }
      > => {
        try {
          await buildRequest();
          return { success: true as const, group };
        } catch (error) {
          const floodSecs = getFloodWaitSeconds(error);
          if (floodSecs !== null && floodSecs <= 8 && retriesLeft > 0) {
            await sleep((floodSecs + 1) * 1000);
            return attempt(retriesLeft - 1);
          }
          return {
            success: false as const,
            group,
            reason: this.getErrorReason(error),
          };
        }
      };

      return attempt(1);
    };

    const settled = await Promise.allSettled(
      groups.map((group) => limit(() => runOne(group)))
    );

    const results: Array<
      | { success: true; group: ManagedGroup }
      | { success: false; group: ManagedGroup; reason: string }
    > = settled.map((result, index) => {
      if (result.status === 'fulfilled') {
        return result.value;
      }
      return {
        success: false as const,
        group: groups[index],
        reason: this.getErrorReason(result.reason),
      };
    });