Function crawlUsers

apps/web/services/discord/users.ts:41–75

({
  accountId,
  serverId,
  token,
  logger,
}: {
  accountId: string;
  serverId: string;
  token: string;
  logger: Logger;
})

}

export async function crawlUsers({
  accountId,
  serverId,
  token,
  logger,
}: {
  accountId: string;
  serverId: string;
  token: string;
  logger: Logger;
}) {
  logger.log({ crawlUsers: 'started' });
  let hasMore = true;
  let after;
  do {
    const [err, response] = await to(
      DiscordApi.getDiscordUsers({ limit: LIMIT, serverId, token, after })
    );
    if (err) {
      logger.error({ crawlUsers: err });
      return;
    }
    const users = response as DiscordGuildMember[];
    await Promise.all(
      users.map((u) => parseUser(u, accountId)).map(UsersService.upsertUser)
    );
    logger.log({ usersFound: users.length });
    if (users.length) {
      after = users.pop()?.user?.id;
    } else {
      hasMore = false;
    }
  } while (hasMore);
  logger.log({ crawlUsers: 'finished' });
}

const parseUser = (guildMember: DiscordGuildMember, accountId: string) => {
  return {