Function syncJob

apps/web/services/discord/sync.ts:12–89

({
  account,
  decodeBotToken,
  fullSync,
  logger,
}: {
  account: accounts & {
    discordAuthorizations: discordAuthorizations[];
  };
  decodeBotToken: (accessToken: string) => string;
  logger: Logger;
  fullSync?: boolean;
})

import { Logger } from '@linen/types';

async function syncJob({
  account,
  decodeBotToken,
  fullSync,
  logger,
}: {
  account: accounts & {
    discordAuthorizations: discordAuthorizations[];
  };
  decodeBotToken: (accessToken: string) => string;
  logger: Logger;
  fullSync?: boolean;
}) {
  logger.log({ sync: 'stared' });

  if (!account.discordServerId) {
    throw new Error('discord server id not found');
  }
  if (!account.discordAuthorizations || !account.discordAuthorizations.length) {
    throw new Error('discord authorization not found');
  }

  const discordAuthorizations = account.discordAuthorizations.find(Boolean);
  const onboardingTimestamp = discordAuthorizations?.syncFrom || new Date(0);

  logger.log({ onboardingTimestamp });

  const token = discordAuthorizations?.customBot
    ? decodeBotToken(discordAuthorizations.accessToken)
    : botV1().PRIVATE_TOKEN;

  await crawlUsers({
    accountId: account.id,
    serverId: account.discordServerId,
    token,
    logger,
  });

  const hideChannels = account.newChannelsConfig === 'HIDDEN';

  const channels = await listChannelsAndPersist({
    serverId: account.discordServerId,
    accountId: account.id,
    token,
    logger,
    hideChannels,
  });

  if (fullSync) {
    await ChannelsService.setCursorNull({ accountId: account.id });
  }

  // active threads are global (not channel specific)
  await getActiveThreads({
    serverId: account.discordServerId,
    token,
    onboardingTimestamp,
    logger,