Function upsertThreadWithNewMessages

apps/web/services/discord/threads.ts:249–278

({
  channel,
  thread,
  messages,
  logger,
}: {
  channel: channels;
  thread: threads;
  messages: DiscordMessage[];
  logger: Logger;
})

}

async function upsertThreadWithNewMessages({
  channel,
  thread,
  messages,
  logger,
}: {
  channel: channels;
  thread: threads;
  messages: DiscordMessage[];
  logger: Logger;
}) {
  await createMessages({
    channel,
    thread,
    messages,
    logger,
  });

  try {
    if (messages.length) {
      const lastMessage = messages[messages.length - 1];
      const lastReplyAt = parseDiscordSentAt(lastMessage.timestamp);
      if (lastReplyAt && thread.id) {
        await updateLastReplyAt({ lastReplyAt, threadId: thread.id });
      }
    }
  } catch (error) {
    logger.error({ error });
  }
}