Function streamProcessMembers

clean_member/clean_member.ts:306–496

(options: StreamProcessOptions)

  onlySearch: boolean;
  maxRemove?: number;
  statusCallback?: (message: string, forceUpdate?: boolean) => Promise<void>;
  modeNames: { [key: string]: string };
}

interface StreamProcessResult {
  totalScanned: number;
  totalFound: number;
  totalRemoved: number;
  users: UserInfo[];
  failedUsers: FailedUserInfo[];
}

async function streamProcessMembers(options: StreamProcessOptions): Promise<StreamProcessResult> {
  const { client, chatEntity, mode, day, adminIds, onlySearch, maxRemove, statusCallback, modeNames } = options;
  const result: StreamProcessResult = {
    totalScanned: 0,
    totalFound: 0,
    totalRemoved: 0,
    users: [],
    failedUsers: []
  };
  let offset = 0;
  const limit = 200;
  let hasMore = true;
  let batchNumber = 0;
  try {
    while (hasMore) {
      batchNumber++;
      if (statusCallback) {
        await statusCallback(
          `🔍 扫描第 ${batchNumber} 批 (${modeNames[mode]}) | 已扫描: ${result.totalScanned} | 已找到: ${result.totalFound}${!onlySearch ? ` | 已移出: ${result.totalRemoved}` : ''}`,
          true
        );
      }
      const participantsResult = await client.invoke(new Api.channels.GetParticipants({
        channel: chatEntity,
        filter: new Api.ChannelParticipantsRecent(),
        offset: offset,
        limit: limit,
        hash: 0 as any,
      }));
      if ("users" in participantsResult && participantsResult.users.length > 0) {
        const users = participantsResult.users as Api.User[];
        result.totalScanned += users.length;
        for (const user of users) {
          const uid = Number(user.id);
          if (adminIds.has(uid)) continue;
          let shouldProcess = false;
          if (mode === "1") {
            const lastOnlineDays = getLastOnlineDays(user);
            if (lastOnlineDays !== null && lastOnlineDays > day) {
              shouldProcess = true;
            }
          } else if (mode === "2") {
            try {
              const userEntity = await client.getInputEntity(uid);
              const minDate = Math.floor(Date.now() / 1000) - day * 24 * 60 * 60;
              const res = await client.invoke(new Api.messages.Search({