Function createTavusRouter

server/src/routes/tavus.ts:328–628

()

});

export function createTavusRouter() {
  // Page router: serves GET /video
  const pageRouter = Router();
  pageRouter.get("/", (_req, res) => {
    // Daily.co iframe needs camera, microphone, and autoplay permissions
    res.setHeader("Permissions-Policy", "camera=*, microphone=*, autoplay=*");
    res.sendFile(path.join(__dirname, "../../public/video.html"));
  });

  // API router: POST /api/addie/video/session
  const apiRouter = Router();

  apiRouter.post("/session", optionalAuth, sessionRateLimiter, async (req, res) => {
    if (!req.user) {
      return res.status(401).json({ error: "Please log in to start a video call." });
    }

    const tavusApiKey = process.env.TAVUS_API_KEY;
    const personaId = process.env.TAVUS_PERSONA_ID;

    if (!tavusApiKey || !personaId) {
      return res.status(503).json({ error: "Video chat not configured" });
    }

    try {
      const conversationName = `addie-${uuidv4()}`;
      const rawDisplayName = [req.user.firstName, req.user.lastName].filter(Boolean).join(" ") || req.user.email;
      const displayName = rawDisplayName.replace(/[\[\]<>{}]/g, "").slice(0, 100);

      // Create a thread to track this video conversation
      const threadService = getThreadService();
      const thread = await threadService.getOrCreateThread({
        channel: "video",
        external_id: conversationName,
        user_type: "workos",
        user_id: req.user.id,
        user_display_name: displayName,
        context: { persona_id: personaId },
      });

      const response = await fetch("https://tavusapi.com/v2/conversations", {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          "x-api-key": tavusApiKey,
        },
        body: JSON.stringify({
          persona_id: personaId,
          conversation_name: conversationName,
          custom_greeting: `Hi ${displayName.split(" ")[0]}, I'm Addie! How can I help you today?`,
          // Tavus appends this to the system message sent to our LLM endpoint,
          // letting us correlate LLM calls back to the thread.
          conversational_context: `[conductor:thread_id=${thread.thread_id}] The user's name is ${displayName}.`,
        }),
      });

      if (!response.ok) {
        const errorText = await response.text();