Function upsertThreadByExternalId

apps/web/services/threads/index.ts:372–392

(upsertData: {
  sentAt: number;
  channelId: string;
  externalThreadId: string;
  messageCount: number;
  slug: string;
  title: null;
  lastReplyAt: number;
})

}

export async function upsertThreadByExternalId(upsertData: {
  sentAt: number;
  channelId: string;
  externalThreadId: string;
  messageCount: number;
  slug: string;
  title: null;
  lastReplyAt: number;
}) {
  return await prisma.threads.upsert({
    select: { id: true },
    where: {
      channelId_externalThreadId: {
        channelId: upsertData.channelId,
        externalThreadId: upsertData.externalThreadId,
      },
    },
    update: upsertData,
    create: upsertData,
  });
}

export const findOrCreateThread = async (thread: {
  channelId: string;