Function slackSyncWithFiles

apps/web/services/slack/syncWithFiles.ts:12–114

({
  accountId,
  channelId,
  domain,
  fullSync,
  fileLocation,
  logger,
  getFileFromS3 = thisGetFileFromS3,
  extractIntoTemp = thisExtractIntoTemp,
}: {
  accountId: string;
  channelId?: string;
  domain?: string;
  fullSync?: boolean | undefined;
  fileLocation?: string;
  logger: Logger;
  getFileFromS3?(fileLocation: string): Promise<unknown>;
  extractIntoTemp?(file: any): Promise<string>;
})

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

export async function slackSyncWithFiles({
  accountId,
  channelId,
  domain,
  fullSync,
  fileLocation,
  logger,
  getFileFromS3 = thisGetFileFromS3,
  extractIntoTemp = thisExtractIntoTemp,
}: {
  accountId: string;
  channelId?: string;
  domain?: string;
  fullSync?: boolean | undefined;
  fileLocation?: string;
  logger: Logger;
  getFileFromS3?(fileLocation: string): Promise<unknown>;
  extractIntoTemp?(file: any): Promise<string>;
}) {
  logger.log({ startAt: new Date(), fullSync });

  if (!fileLocation) throw 'missing files location';

  const account = await findAccountById(accountId);

  if (!account) {
    throw { status: 404, error: 'Account not found' };
  }

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

  const file = await getFileFromS3(fileLocation);
  const tempFolder = await extractIntoTemp(file);

  const {
    fetchConversationsTyped,
    fetchReplies,
    fetchTeamInfo,
    getSlackChannels,
    joinChannel,
    listUsers,
    getMemberships,
  } = new SlackFileAdapter(tempFolder);

  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,