abc

// server.js
import express from "express";
import fetch from "node-fetch"; // or native fetch in newer Node
import { AccessToken, VideoGrant } from "livekit-server-sdk";

const app = express();
app.use(express.json());

// Replace these with your project values
const LIVEKIT_API_KEY = process.env.LIVEKIT_API_KEY;
const LIVEKIT_API_SECRET = process.env.LIVEKIT_API_SECRET;
const LIVEKIT_API_URL = process.env.LIVEKIT_API_URL || "<https://your-project.livekit.cloud>";

// Example endpoint: creates room (optional) and returns a token for given identity & room
<http://app.post|app.post>("/join", async (req, res) => {
  const { identity, room = "abc", purpose = "billing-assistance" } = req.body;
  if (!identity) return res.status(400).json({ error: "identity required" });

  // Optional: pre-create the room and attach metadata/agent dispatch via LiveKit REST API
  // If your LiveKit deployment supports Room Service REST, call createRoom here.
  // Example minimal create-room call:
  try {
    await fetch(`${LIVEKIT_API_URL}/v1/rooms`, {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        Authorization: `Bearer ${createRoomServiceJwt()}`,
      },
      body: JSON.stringify({
        name: room,
        metadata: JSON.stringify({ purpose }),
        // add additional room configuration if supported by your deployment
      }),
    });
  } catch (e) {
    // room may already exist; ignore or handle specific errors as needed
  }

  // Create access token for the participant
  const at = new AccessToken(LIVEKIT_API_KEY, LIVEKIT_API_SECRET, {
    identity,
    ttl: "2h",
  });

  const grant = new VideoGrant({
    roomJoin: true,
    room,
    // set publish/subscribe as needed
    // canPublish: true, // Note: grant fields depend on SDK version
  });
  at.addGrant(grant);

  const token = at.toJwt();

  return res.json({ token, room });
});

// Helper: if your LiveKit setup requires a service JWT for room creation calls,
// implement createRoomServiceJwt() to return a signed JWT using your api key/secret.
// If your deployment exposes a server SDK room service, prefer that instead.
function createRoomServiceJwt() {
  // Minimal placeholder: for many hosted LiveKit setups you can use API key/secret directly in the RoomServiceClient.
  // If your deployment needs a REST JWT, generate it here similarly to AccessToken but with appropriate grants.
  return ""; // implement as needed for your environment
}

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => console.log(`Listening on ${PORT}`));

// App.jsx
import React, { useEffect, useState } from "react";
import { Room, connect } from "livekit-client"; // or use @livekit/components-react for prebuilt UI
import { LiveKitRoom } from "@livekit/components-react"; // optional prebuilt components

export default function App() {
  const [token, setToken] = useState(null);
  const [roomName, setRoomName] = useState("abc");

  useEffect(() => {
    async function getToken() {
      const resp = await fetch("/join", {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({ identity: "user-123", room: roomName }),
      });
      const data = await resp.json();
      setToken(data.token);
    }
    getToken();
  }, [roomName]);

  if (!token) return <div>Connecting...</div>;

  // Minimal: use LiveKitRoom component (prebuilt UI) — pass server URL and token
  return (
    <LiveKitRoom
      serverUrl="wss://your-project.livekit.cloud"
      token={token}
      connect={true}
      audio={true}
      video={true}
    >
      {/* Your room UI / participants list / controls */}
      <div>Joined room: {roomName}</div>
    </LiveKitRoom>
  );

  // Alternatively, use the low-level client API:
  // useEffect(() => {
  //   let lkRoom = new Room();
  //   connect("<wss://your-project.livekit.cloud>", token, { autoSubscribe: true })
  //     .then((remoteRoom) => {
  //       lkRoom = remoteRoom;
  //       // attach tracks to DOM, subscribe handlers, etc.
  //     });
  //   return () => lkRoom.disconnect();
  // }, [token]);
}