Function syncWrapper

apps/web/services/slack/syncWrapper.ts:11–91

({
  account,
  domain,
  accountId,
  channelId,
  fullSync,
  fetchTeamInfo,
  joinChannel,
  getSlackChannels,
  listUsers,
  fetchConversationsTyped,
  fetchReplies,
  getMemberships,
  logger,
}: SyncWrapperTypes & { logger: Logger })

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

export async function syncWrapper({
  account,
  domain,
  accountId,
  channelId,
  fullSync,
  fetchTeamInfo,
  joinChannel,
  getSlackChannels,
  listUsers,
  fetchConversationsTyped,
  fetchReplies,
  getMemberships,
  logger,
}: SyncWrapperTypes & { logger: Logger }) {
  const { token, syncFrom, shouldJoinChannel } = await fetchToken({
    account,
    domain,
    accountId,
    fetchTeamInfo,
  });
  logger.log({ token, syncFrom, shouldJoinChannel });
  const oldest = syncFrom
    ? Math.floor(syncFrom.getTime() / 1000).toString()
    : '0';

  // create and join channels
  const channels = await syncChannels({
    account,
    token,
    accountId,
    channelId,
    joinChannel,
    getSlackChannels,
    shouldJoinChannel,
    fullSync,
    logger,
  });

  //paginate and find all the users
  const usersInDb = await syncUsers({
    accountId,
    token,
    account,
    fullSync,
    listUsers,
    logger,
  });

  for (const channel of channels) {
    if (!channel.externalChannelId) {
      continue;
    }

    await syncMemberships({
      accountId,
      channelId: channel.id,
      externalChannelId: channel.externalChannelId,