Function removeChatMember

clean_member/clean_member.ts:208–267

(client: TelegramClient, channelEntity: any, userId: number)

  if (typeof user === "number") {
    return await client.getInputEntity(user);
  }
  try {
    return await client.getInputEntity(user);
  } catch {
    return new Api.InputPeerUser({
      userId: user.id,
      accessHash: user.accessHash ?? (0 as any),
    });
  }
}

async function removeChatMember(client: TelegramClient, channelEntity: any, user: Api.User | number): Promise<void> {
  const userId = typeof user === "number" ? user : Number(user.id);
  try {
    const userEntity = await resolveParticipantEntity(client, user);
    console.log(`正在移出用户: ${userId}`);
    await client.invoke(new Api.channels.EditBanned({
      channel: channelEntity,
      participant: userEntity,
      bannedRights: new Api.ChatBannedRights({
        untilDate: Math.floor(Date.now() / 1000) + 60,
        viewMessages: true,
        sendMessages: true,
        sendMedia: true,
        sendStickers: true,
        sendGifs: true,
        sendGames: true,
        sendInline: true,
        sendPolls: true,
        changeInfo: true,
        inviteUsers: true,
        pinMessages: true,
      }),
    }));
    await sleep(2000 + Math.random() * 1000);
    await client.invoke(new Api.channels.EditBanned({
      channel: channelEntity,
      participant: userEntity,
      bannedRights: new Api.ChatBannedRights({
        untilDate: 0,
        viewMessages: false,
        sendMessages: false,
        sendMedia: false,
        sendStickers: false,
        sendGifs: false,
        sendGames: false,
        sendInline: false,
        sendPolls: false,
        changeInfo: false,
        inviteUsers: false,
        pinMessages: false,
      }),
    }));
    console.log(`用户 ${userId} 已移出并解封，可重新加入`);
  } catch (error: any) {
    console.error(`移出用户 ${userId} 失败:`, error);
    if (error.errorMessage && error.errorMessage.includes("FLOOD_WAIT")) {
      const seconds = parseInt(error.errorMessage.match(/\d+/)?.[0] || "60");