Function findOrCreateThread

apps/web/services/threads/index.ts:394–423

(thread: {
  channelId: string;
  externalThreadId: string;
  sentAt: number;
  lastReplyAt: number;
  slug?: string;
  messageCount?: number;
  title?: string;
})

}

export const findOrCreateThread = async (thread: {
  channelId: string;
  externalThreadId: string;
  sentAt: number;
  lastReplyAt: number;
  slug?: string;
  messageCount?: number;
  title?: string;
}) => {
  const exist = await prisma.threads.findUnique({
    where: {
      channelId_externalThreadId: {
        channelId: thread.channelId,
        externalThreadId: thread.externalThreadId,
      },
    },
    include: {
      messages: true,
    },
  });
  if (exist) {
    return exist;
  }
  return await prisma.threads.create({
    data: thread,
    include: {
      messages: true,
    },
  });
};

export async function updateLastReplyAt({
  lastReplyAt,