Function slackSync

apps/web/services/slack/sync.ts:15–99

({
  accountId,
  channelId,
  domain,
  fullSync,
  logger,
}: {
  accountId: string;
  channelId?: string;
  domain?: string;
  fullSync?: boolean | undefined;
  logger: Logger;
})

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

export async function slackSync({
  accountId,
  channelId,
  domain,
  fullSync,
  logger,
}: {
  accountId: string;
  channelId?: string;
  domain?: string;
  fullSync?: boolean | undefined;
  logger: Logger;
}) {
  logger.log({ startAt: new Date(), fullSync });

  const account = await findAccountById(accountId);

  if (!account) {
    throw new Error('Account not found');
  }
  if (!account.slackTeamId) {
    throw new Error('slackTeamId not found');
  }

  logger.setPrefix(account.slackDomain || account.name || account.id);

  await updateAndNotifySyncStatus({
    accountId,
    status: SyncStatus.IN_PROGRESS,
    accountName: account.name,
    homeUrl: account.homeUrl,
    communityUrl: account.communityUrl,
    pathDomain: account.slackDomain,
  });

  try {
    await syncWrapper({
      account,
      domain,
      accountId,
      channelId,
      fullSync,
      fetchConversationsTyped,
      fetchReplies,
      fetchTeamInfo,
      getSlackChannels,
      joinChannel,
      listUsers,
      getMemberships,
      logger,
    });

    await updateAndNotifySyncStatus({
      accountId,
      status: SyncStatus.DONE,
      accountName: account.name,
      homeUrl: account.homeUrl,
      communityUrl: account.communityUrl,