reply.type("text/xml").send(
   `<?xml version="1.0" encoding="UTF-8"?>
   <Response>
     <Connect>
       <ConversationRelay url="${WS_URL}" welcomeGreeting="${WELCOME_GREETING}" />
     </Connect>
   </Response>`
 );

const message = JSON.parse(data);
switch (message.type) {
  case "prompt":
    console.log("Processing prompt:", message.voicePrompt);
    const response = await aiResponse(message.voicePrompt);
    console.log("AI response:", response);

    ws.send(
      JSON.stringify({
        type: "text",
        token: response,
        last: true,
      })
    );
    break;
  default:
    console.warn("Unknown message type received:", message.type);
    break;
}

import OpenAI from "openai";
const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY });

async function aiResponse(prompt) {
  let completion = await openai.chat.completions.create({
    model: "gpt-4o-mini",
    messages: [
      { role: "system", content: SYSTEM_PROMPT },
      { role: "user", content: prompt },
    ],
  });
  return completion.choices[0].message.content;
}

const sessions = new Map();

async function aiResponse(messages) {
 let completion = await openai.chat.completions.create({
   model: "gpt-4o-mini",
   messages: messages,
 });
 return completion.choices[0].message.content;
}

case "setup":
  const callSid = message.callSid;
  console.log("Setup for call:", callSid);
  ws.callSid = callSid;
  sessions.set(callSid, [{ role: "system", content: SYSTEM_PROMPT }]);
  break;

const messages = sessions.get(ws.callSid);
messages.push({ role: "user", content: message.voicePrompt });

const response = await aiResponse(messages);
messages.push({ role: "assistant", content: response });

async function aiResponseStream(messages, ws) {
 const stream = await openai.chat.completions.create({
   model: "gpt-4o-mini",
   messages: messages,
   stream: true,
 });

 const assistantSegments = [];
 console.log("Received response chunks:");
 for await (const chunk of stream) {
   const content = chunk.choices[0]?.delta?.content || "";

   // Send each token
   console.log(content);
   ws.send(
     JSON.stringify({
       type: "text",
       token: content,
       last: false,
     })
   );
   assistantSegments.push(content);
 }

 const finalResponse = assistantSegments.join("");
 console.log("Assistant response complete:", finalResponse);
 messages.push({
   role: "assistant",
   content: finalResponse,
 });
}

case "prompt":
 console.log("Processing prompt:", message.voicePrompt);

 const messages = sessions.get(ws.callSid);
 messages.push({ role: "user", content: message.voicePrompt });

 await aiResponseStream(messages, ws);

 // Send the final "last" token when streaming completes
 ws.send(
   JSON.stringify({
     type: "text",
     token: "",
     last: true,
   })
 );
 break;

const WELCOME_GREETING =
  "Hi! Thank you for calling Wiggles Veterinary. How can I help you today?";
const SYSTEM_PROMPT = `You are a helpful assistant for a veterinary clinic, so you will be asked about animal care, appointments, and other related topics.
  This conversation is being translated to voice, so answer carefully.
  When you respond, please spell out all numbers, for example twenty not 20. Do not include emojis in your responses. 
  Do not include bullet points, asterisks, or special symbols.
    
  Make sure you get the pet's name, the owner's name, and the type of animal (dog, cat, etc.) if relevant.
  If someone asks for an appointment call the "get_appointments" function to fetch appointment options.
  Do not call the function if someone confirms an appointment, just say "Great! We have you scheduled for that time."`;

import axios from "axios";

const tools = [
  {
    type: "function",
    function: {
      name: "find_appointments",
      description:
        "Find available appointments based on user preferences, such as mornings or a specific week.",
      parameters: {
        type: "object",
        properties: {
          preferences: {
            type: "string",
            description:
              "Preferences for appointment search, e.g., 'mornings, week of june ninth'.",
          },
        },
        required: ["preferences"],
      },
    },
  },
];

async function getAppointments(preferences) {
  const response = await axios.get(
    `https://appointment-finder-4175.twil.io/appointments?preferences=${encodeURIComponent(
      preferences
    )}`
  );
  const data = response.data;
  return data.availableAppointments
    .map((appointment) => appointment.displayTime)
    .join(", ");
}

<?xml version="1.0" encoding="UTF-8"?>
<Response>
  <Connect>
    <ConversationRelay 
      url="${WS_URL}"
      welcomeGreeting="${WELCOME_GREETING}"
      intelligenceService="GAxxxxxx"
    />
  </Connect>
</Response>