Function processThread

apps/web/services/discord/threads.ts:124–153

({
  thread,
  onboardingTimestamp,
  channel,
  token,
  logger,
}: {
  thread: DiscordThread;
  onboardingTimestamp: Date;
  channel: channels;
  token: string;
  logger: Logger;
})

}

async function processThread({
  thread,
  onboardingTimestamp,
  channel,
  token,
  logger,
}: {
  thread: DiscordThread;
  onboardingTimestamp: Date;
  channel: channels;
  token: string;
  logger: Logger;
}) {
  let linenThread = await findOrCreateThread(parseThread(thread, channel));

  const messages = await crawlExistingThread({
    thread: linenThread,
    onboardingTimestamp,
    token,
    logger,
  });

  // persist thread with messages
  await upsertThreadWithNewMessages({
    channel,
    thread: linenThread,
    messages,
    logger,
  });
}

function parseThread(thread: DiscordThread, channel: channels) {
  const date = thread.thread_metadata?.create_timestamp || Date.now();