diff --git a/prisma/schema.prisma b/prisma/schema.prisma index 4fbf0f8..f58e2f6 100644 --- a/prisma/schema.prisma +++ b/prisma/schema.prisma @@ -39,7 +39,7 @@ model Message { createdAt DateTime @default(now()) role Role - content String + content String @default("") session Session @relation(fields: [sessionId], references: [id]) sessionId String @db.ObjectId diff --git a/src/api/call.js b/src/api/call.js index a531553..44db02c 100644 --- a/src/api/call.js +++ b/src/api/call.js @@ -69,10 +69,6 @@ app.post("/respond", async (req, res) => { transferSession(req.body.CallSid, operatorPhone); twiml.say("We're connecting you to a counselor now."); - await addMessage(callId, Role.BOT, ""); - let summary = await summarize(callId); - console.log(summary); - const dial = twiml.dial({}); dial.number(operatorPhone); res.type("text/xml"); diff --git a/src/lib/chat.js b/src/lib/chat.js index c9a5b40..b832cda 100644 --- a/src/lib/chat.js +++ b/src/lib/chat.js @@ -36,7 +36,10 @@ export const chat = async (callId) => { for (let msg of msgs) { messages.push({ role: convertRole(msg.role), - content: msg.content, + content: + msg.content.length > 0 + ? msg.content + : "This message was not recorded correctly.", }); } diff --git a/src/lib/session.js b/src/lib/session.js index 832bc4f..3b2b4e7 100644 --- a/src/lib/session.js +++ b/src/lib/session.js @@ -2,6 +2,9 @@ import { Role } from "@prisma/client"; import { db } from "./db.js"; export const createSession = async (callId, callerPhone) => { + let session = await findSessionByCallId(callId); + if (session) return session; + return await db.session.create({ data: { callId: callId,