Function fetchAndPersist

apps/web/services/slack/sync/saveAllThreads.ts:197–222

(
  fetchReplies: Function,
  thread: threads,
  channel: channels,
  token: string,
  usersInDb: UserMap[],
  logger: Logger
)

}

async function fetchAndPersist(
  fetchReplies: Function,
  thread: threads,
  channel: channels,
  token: string,
  usersInDb: UserMap[],
  logger: Logger
) {
  const replies = await fetchReplies(
    thread.externalThreadId,
    channel!.externalChannelId,
    token
  );
  const replyMessages: ConversationHistoryMessage[] =
    replies?.body?.messages?.filter(filterMessages).map(parseMessage) || [];

  if (replyMessages && replyMessages.length) {
    await saveMessagesSynchronous(
      replyMessages,
      thread.channelId,
      usersInDb,
      token,
      logger
    );
  }
}