what triggers src\app\api\token\route.ts to genera...
# ask-ais
stocky-tailor-95498
08/11/2025, 4:20 PMwhat triggers src\app\api\token\route.ts to generate a room?
t
tall-airline-16756
08/11/2025, 4:20 PMThanks for reaching out, Nakshatra. I'm an AI assistant and I'm here to help. Give me a moment while I research this topic.
tall-airline-16756
08/11/2025, 4:21 PMHey there! Just wanted to walk you through what happens in the file
src\app\api\token\route.ts/api/tokenLIVEKIT_API_KEYLIVEKIT_API_SECRETAccessTokenVideoGrants
stocky-tailor-95498
08/11/2025, 4:23 PMhow do i configure it to create a room everytime I click the 'start' button in my frontend
t
tall-airline-16756
08/11/2025, 4:25 PMHey there! If you want your frontend to create a room when the 'start' button is clicked, here’s a simple way to do it:
1. Set Up the Backend: First, create an API endpoint (like
/api/tokenroomJoincanPublishconnect Copy code
document.getElementById('startButton').addEventListener('click', async () => {
const response = await fetch('/api/token?room=myRoom&username=myUser');
const data = await response.json();
if (data.token) {
const room = new LiveKit.Room();
await room.connect(process.env.LIVEKIT_SERVER_URL, data.token);
console.log('Connected to room:', room.name);
}
});s
stocky-tailor-95498
08/11/2025, 5:32 PMhow would this /api/token/route.js be changed to macth the requirement:
// accepts both styles and returns token
import { NextRequest, NextResponse } from 'next/server';
import { AccessToken } from 'livekit-server-sdk';
import type { AccessTokenOptions, VideoGrant } from 'livekit-server-sdk';
const apiKey = process.env.LK_API_KEY!;
const apiSecret = process.env.LK_API_SECRET!;
const createToken = async (userInfo: AccessTokenOptions, grant: VideoGrant) => {
const at = new AccessToken(apiKey, apiSecret, userInfo);
at.addGrant(grant);
return await at.toJwt();
};
export async function GET(req: NextRequest) {
try {
const { searchParams } = new URL(req.url);
// Support both patterns:
// - room/username (common from tutorials)
// - roomName/identity/name/metadata (your current frontend)
const room = searchParams.get('room') ?? searchParams.get('roomName') ?? undefined;
const username = searchParams.get('username') ?? searchParams.get('identity') ?? undefined;
const name = searchParams.get('name') ?? undefined;
const metadata = searchParams.get('metadata') ?? undefined;
if (!room) throw Error('Missing room/roomName');
if (!username) throw Error('Missing username/identity');
const grant: VideoGrant = {
room,
roomJoin: true,
canPublish: true,
canPublishData: true,
canSubscribe: true,
canUpdateOwnMetadata: true,
};
const token = await createToken({ identity: username, name: name ?? undefined, metadata: metadata ?? undefined }, grant);
// Return a standard token payload
return NextResponse.json({ token });
} catch (e: any) {
return new NextResponse(e.message ?? 'Error generating token', { status: 500 });
}
}
t
tall-airline-16756
08/11/2025, 5:33 PMHey there! If you want to tweak your
/api/token/route.jsroom/usernameroomName/identity/name/metadata Copy code
import { NextRequest, NextResponse } from 'next/server';
import { AccessToken } from 'livekit-server-sdk';
import type { AccessTokenOptions, VideoGrant } from 'livekit-server-sdk';
const apiKey = process.env.LK_API_KEY!;
const apiSecret = process.env.LK_API_SECRET!;
const createToken = async (userInfo: AccessTokenOptions, grant: VideoGrant) => {
const at = new AccessToken(apiKey, apiSecret, userInfo);
at.addGrant(grant);
return await at.toJwt();
};
export async function GET(req: NextRequest) {
try {
const { searchParams } = new URL(req.url);
// We’re supporting both patterns here:
// - room/username (common from tutorials)
// - roomName/identity/name/metadata (your current frontend)
const room = searchParams.get('room') ?? searchParams.get('roomName') ?? undefined;
const username = searchParams.get('username') ?? searchParams.get('identity') ?? undefined;
const name = searchParams.get('name') ?? undefined;
const metadata = searchParams.get('metadata') ?? undefined;
if (!room) throw Error('Missing room/roomName');
if (!username) throw Error('Missing username/identity');
const grant: VideoGrant = {
room,
roomJoin: true,
canPublish: true,
canPublishData: true,
canSubscribe: true,
canUpdateOwnMetadata: true,
};
const token = await createToken({ identity: username, name: name ?? undefined, metadata: metadata ?? undefined }, grant);
// Here’s your token, ready to go!
return NextResponse.json({ token });
} catch (e: any) {
return new NextResponse(e.message ?? 'Error generating token', { status: 500 });
}
}room/usernameroomName/identity/name/metadataroomusernameroomJoincanPublishcanSubscribes
stocky-tailor-95498
08/11/2025, 5:35 PMthe button click handler example you gave, to be added to the frontend. it will go into src\app\page.tsx, right?
t
tall-airline-16756
08/11/2025, 5:36 PMAbsolutely! You can add the button click handler for LiveKit room creation right in
src\app\page.tsx Copy code
// In src/app/page.tsx
const startMeeting = async () => {
const response = await fetch('/api/token?room=myRoom&username=myUser');
const data = await response.json();
if (data.token) {
const room = new LiveKit.Room();
await room.connect(process.env.LIVEKIT_SERVER_URL, data.token);
console.log('Connected to room:', room.name);
}
};
// In the JSX:myRoommyUsers
stocky-tailor-95498
08/11/2025, 5:38 PMmy current page.tsx obviously has a lot more elements to it but help me find the appropriate changes to be done to it:
'use client';
import { LiveKitRoom, AudioConference, useRoomContext, StartAudio, RoomName } from '@livekit/components-react';
import { RoomEvent, Track } from 'livekit-client';
import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
// Generates a random user ID for the session
function generateRandomUserId() {
return `user-${Math.floor(Math.random() * 100000)}`;
}
export default function AudioExamplePage() {
const [mounted, setMounted] = useState(false);
const [roomName, setRoomName] = useState<string>('test-room');
const [userIdentity, setUserIdentity] = useState<string>('');
useEffect(() => {
setMounted(true);
const params = new URLSearchParams(window.location.search);
const rn = params.get('room') ?? 'test-room';
setRoomName(rn);
const stored = localStorage.getItem('lk-user-id');
if (stored) {
setUserIdentity(stored);
} else {
const uid = params.get('user') ?? generateRandomUserId();
localStorage.setItem('lk-user-id', uid);
setUserIdentity(uid);
}
}, []);
const endpoint = process.env.NEXT_PUBLIC_LK_TOKEN_ENDPOINT!;
const serverUrl = process.env.NEXT_PUBLIC_LK_SERVER_URL!;
const [isStarting, setIsStarting] = useState(false);
const [isInRoom, setIsInRoom] = useState(false);
const [token, setToken] = useState<string | null>(null);
const [error, setError] = useState<string | null>(null);
const tokenUrl = useMemo(() => {
if (!endpoint || !roomName || !userIdentity) return null;
const url = new URL(endpoint);
url.searchParams.set('roomName', roomName);
url.searchParams.set('identity', userIdentity);
url.searchParams.set('name', userIdentity);
return url.toString();
}, [endpoint, roomName, userIdentity]);
const handleStart = useCallback(async () => {
if (!tokenUrl) return;
setError(null);
setIsStarting(true);
try {
const res = await fetch(tokenUrl, { method: 'GET' });
if (!res.ok) throw new Error(
Token fetch failed: ${res._status_} ${res._statusText_}<http://localhost:8000/api/end-room>t
tall-airline-16756
08/11/2025, 5:39 PMHey there! To get the button click handler working for LiveKit room creation in your existing
page.tsxhandleStarthandleStart Copy code
<button
type="button"
onClick={handleStart}
disabled={isStarting || !tokenUrl}
style={{
padding: '10px 16px',
borderRadius: 8,
border: 'none',
background: '#007AFF',
color: 'white',
fontWeight: 500,
cursor: isStarting ? 'not-allowed' : 'pointer',
transition: 'background-color 0.2s',
}}
aria-label="Start"
>
{isStarting ? 'Starting…' : 'Start Session'}
</button>handleStarttokenUrlLiveKitRoompage.tsxs
stocky-tailor-95498
08/11/2025, 5:41 PMisn't it already doing that:
<button
type="button"
onClick={handleStart}
disabled={isStarting || !tokenUrl}
style={{
padding: '10px 16px',
borderRadius: 8,
border: 'none',
background: '#007AFF', // A more vibrant start button
color: 'white',
fontWeight: 500,
cursor: isStarting ? 'not-allowed' : 'pointer',
transition: 'background-color 0.2s',
}}
aria-label="Start"
>
{isStarting ? 'Starting…' : 'Start Session'}
</button>
t
tall-airline-16756
08/11/2025, 5:42 PMYou're absolutely right—the button in your code is already set up to trigger the
handleStarts
stocky-tailor-95498
08/11/2025, 5:50 PMalright now help me out with the python and fastapi backend. using the stop button in the frontend, the room should be deleted/disconnected gracefully with clean up. tell me if i am wrong but that should be handled by the backend
t
tall-airline-16756
08/11/2025, 5:51 PMHere’s a friendly guide to help you handle room deletion or disconnection in LiveKit using a FastAPI backend. Let’s walk through it step-by-step:
1. Create a FastAPI Endpoint: You’ll want to set up an API route that deletes a room and disconnects all participants. Check out this example:
Copy code
from fastapi import FastAPI, HTTPException
import os
from livekit import api
from livekit.protocol import room as room_proto
app = FastAPI()
LIVEKIT_BASE_URL = os.getenv("LIVEKIT_URL")
LIVEKIT_API_KEY = os.getenv("LIVEKIT_API_KEY")
LIVEKIT_API_SECRET = os.getenv("LIVEKIT_API_SECRET")
@app.post("/api/delete-room")
async def delete_room(room_name: str):
try:
# Initialize LiveKit API client
livekit_client = api.LiveKitAPI(
base_url=LIVEKIT_BASE_URL,
api_key=LIVEKIT_API_KEY,
api_secret=LIVEKIT_API_SECRET,
)
# Create a DeleteRoomRequest
delete_request = room_proto.DeleteRoomRequest(room=room_name)
# Delete the room
await livekit_client.room.delete_room(delete_request)
return {"message": f"Room {room_name} deleted successfully"}
except Exception as e:
raise HTTPException(status_code=500, detail=str(e))/api/delete-room Copy code
async function handleStopButton() {
const roomName = "your_room_name"; // Replace with the actual room name
try {
const response = await fetch(`/api/delete-room`, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({ room_name: roomName }),
});
if (!response.ok) {
throw new Error('Failed to delete room');
}
const data = await response.json();
console.log(data.message);
} catch (error) {
console.error('Error:', error);
}
}HTTPBearerLIVEKIT_API_KEYLIVEKIT_API_SECRETLIVEKIT_URLs
stocky-tailor-95498
08/11/2025, 5:52 PMbut room-name isn't fixed though
t
tall-airline-16756
08/11/2025, 5:52 PMIf your room name changes dynamically, no worries—you can easily send it from the frontend to the backend as part of the request body. Here’s a friendly walkthrough on how to tweak your implementation:
1. Frontend: Make sure the stop button sends the current room name to the backend. Here's a simple example:
Copy code
async function handleStopButton(roomName) {
try {
const response = await fetch(`/api/delete-room`, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({ room_name: roomName }),
});
if (!response.ok) {
throw new Error('Failed to delete room');
}
const data = await response.json();
console.log(data.message);
} catch (error) {
console.error('Error:', error);
}
} Copy code
from fastapi import FastAPI, HTTPException, Request
import os
from livekit import api
from livekit.protocol import room as room_proto
app = FastAPI()
LIVEKIT_BASE_URL = os.getenv("LIVEKIT_URL")
LIVEKIT_API_KEY = os.getenv("LIVEKIT_API_KEY")
LIVEKIT_API_SECRET = os.getenv("LIVEKIT_API_SECRET")
@app.post("/api/delete-room")
async def delete_room(request: Request):
try:
body = await request.json()
room_name = body.get("room_name")
if not room_name:
raise HTTPException(status_code=400, detail="Room name is required")
# Initialize LiveKit API client
livekit_client = api.LiveKitAPI(
base_url=LIVEKIT_BASE_URL,
api_key=LIVEKIT_API_KEY,
api_secret=LIVEKIT_API_SECRET,
)
# Create a DeleteRoomRequest
delete_request = room_proto.DeleteRoomRequest(room=room_name)
# Delete the room
await livekit_client.room.delete_room(delete_request)
return {"message": f"Room {room_name} deleted successfully"}
except Exception as e:
raise HTTPException(status_code=500, detail=str(e))s
stocky-tailor-95498
08/11/2025, 5:56 PMthe workflow i am aiming for is that of a translation app, user clicks start, the room is created with the user and agent in it. the user clicks stop, the room ends. if the user clicks start again, it should work again and for that i was hoping that creating a new room would be right as there would be no conflict with the previous rooms
t
tall-airline-16756
08/11/2025, 5:57 PMAlright, to set up the workflow for your translation app—where a new room pops up every time someone hits "Start" and wraps up when they click "Stop"—here’s a simple way to do it:
1. Start Button: When the user clicks "Start":
◦ Create a unique room name on the fly (think timestamp or a random string).
◦ Send a request to your backend to get a token for this new room.
◦ Connect the user and agent to the room using that token.
1. Stop Button: When the user clicks "Stop":
◦ Send a request to your backend to delete the room by its name.
◦ Make sure your backend disconnects everyone and tidies up the room.
1. Backend: You’ll want to set up endpoints for:
◦ `/api/create-token`: This one makes a token for the new room.
◦ `/api/delete-room`: This one deletes the room and kicks everyone out.
Here’s a quick example of how your backend might handle this:
Copy code
# Endpoint to create a token for a new room
@app.post("/api/create-token")
async def create_token(room_name: str, user_identity: str):
try:
# Initialize LiveKit API client
livekit_client = api.LiveKitAPI(
base_url=LIVEKIT_BASE_URL,
api_key=LIVEKIT_API_KEY,
api_secret=LIVEKIT_API_SECRET,
)
# Generate a token for the user
token = livekit_client.create_token(
room=room_name,
identity=user_identity,
permissions=["roomJoin", "canPublish", "canSubscribe"]
)
return {"token": token}
except Exception as e:
raise HTTPException(status_code=500, detail=str(e))
# Endpoint to delete a room
@app.post("/api/delete-room")
async def delete_room(room_name: str):
try:
# Initialize LiveKit API client
livekit_client = api.LiveKitAPI(
base_url=LIVEKIT_BASE_URL,
api_key=LIVEKIT_API_KEY,
api_secret=LIVEKIT_API_SECRET,
)
# Delete the room
livekit_client.delete_room(room_name)
return {"message": f"Room {room_name} deleted successfully"}
except Exception as e:
raise HTTPException(status_code=500, detail=str(e))s
stocky-tailor-95498
08/12/2025, 4:01 AMregarding the python backend necessary to keep this functioning, could you check the following code and find any discrepancies:
import asyncio
import logging
from fastapi import FastAPI, HTTPException, Request
from fastapi.middleware.cors import CORSMiddleware
from livekit import rtc
from livekit.agents import JobContext, WorkerOptions, cli
from livekit.agents.voice import Agent, AgentSession
from livekit.plugins import openai, silero, deepgram, cartesia
# Load environment variables as needed here
from dotenv import load_dotenv
load_dotenv(dotenv_path=".env.local")
# Logger config
logger = logging.getLogger("listen-and-respond")
logging.basicConfig(level=logging.INFO)
class SimpleAgent(Agent):
def __init__(self):
logger.info("starting SimpleAgent\n")
super().__init__(
instructions="Translate English speech to Hindi only, say nothing else",
stt=deepgram.STT(),
llm=openai.LLM(model="gpt-4o-mini"),
tts=cartesia.TTS(
model="sonic-2",
voice="28ca2041-5dda-42df-8123-f58ea9c3da00",
language="hi"
),
vad=silero.VAD.load()
)
async def on_enter(self):
logger.info(f"Agent entered room: {self.session.rtc.room}\n")
self.session.generate_reply()
# async def entrypoint(ctx: JobContext):
# session = AgentSession()
# logger.info(f"Agent joined room: {ctx.room.name}")
# await session.start(agent=SimpleAgent(), room=ctx.room)
# if hasattr(session, "wait"):
# await session.wait()
async def entrypoint(ctx: JobContext):
session = AgentSession()
logger.info(f"Agent job started for room: {ctx.room.name}")
async def _on_shutdown():
logger.info(f"Shutdown hook called for room: {ctx.room.name}")
ctx.add_shutdown_callback(_on_shutdown)
try:
await session.start(agent=SimpleAgent(), room=ctx.room)
logger.info(f"Agent fully connected to room: {ctx.room.name}")
if hasattr(session, "wait"):
await session.wait()
except Exception as e:
logger.exception(f"Agent session error in room {ctx.room.name}: {e}")
ctx.shutdown(reason=f"Agent error: {e}")
finally:
logger.info(f"Stopping agent session for room: {ctx.room.name}")
try:
await session.stop()
logger.info(f"Agent session stopped for room: {ctx.room.name}")
except Exception as stop_err:
logger.error(f"Error stopping session for room {ctx.room.name}: {stop_err}")
if name == "__main__":
cli.run_app(WorkerOptions(entrypoint_fnc=entrypoint))
t
tall-airline-16756
08/12/2025, 4:02 AMYour Python FastAPI backend code for LiveKit integration looks solid and follows LiveKit's recommended patterns nicely. That said, I’ve got a few friendly suggestions to help make it even more reliable and smooth:
1. Error Handling:
◦ It’d be great to add thorough error handling around API operations like
session.start()session.stop()try-exceptsession.start()session.stop() Copy code
async def delete_livekit_room(room_name: str) -> bool:
try:
async def _delete_room(lkapi):
delete_request = room_proto.DeleteRoomRequest(room=room_name)
await lkapi.room.delete_room(delete_request)
return True
success = await with_livekit_api(_delete_room)
return success
except Exception as e:
logger.error(f"Failed to delete room {room_name}: {str(e)}")
return Falses
stocky-tailor-95498
08/12/2025, 4:03 AMbut 'AgentSession' object has no attribute 'stop'
t
tall-airline-16756
08/12/2025, 4:04 AMYou're absolutely right—the
AgentSessionstopsession.aclose() Copy code
async def entrypoint(ctx: JobContext):
session = AgentSession()
<http://logger.info|logger.info>(f"Agent job started for room: {ctx.room.name}")
async def _on_shutdown():
<http://logger.info|logger.info>(f"Shutdown hook called for room: {ctx.room.name}")
ctx.add_shutdown_callback(_on_shutdown)
try:
await session.start(agent=SimpleAgent(), room=ctx.room)
<http://logger.info|logger.info>(f"Agent fully connected to room: {ctx.room.name}")
if hasattr(session, "wait"):
await session.wait()
except Exception as e:
logger.exception(f"Agent session error in room {ctx.room.name}: {e}")
ctx.shutdown(reason=f"Agent error: {e}")
finally:
<http://logger.info|logger.info>(f"Stopping agent session for room: {ctx.room.name}")
try:
await session.aclose()
<http://logger.info|logger.info>(f"Agent session closed for room: {ctx.room.name}")
except Exception as close_err:
logger.error(f"Error closing session for room {ctx.room.name}: {close_err}")session.stop()session.aclose()s
stocky-tailor-95498
08/12/2025, 4:09 AMi run all 3 files, frontend npm run dev, fastapi uvicorn and python main.py dev
but when i click on start in the UI, the backend terminal does not show connection being established so I can't talk to the agent. there are no errors thrown either
t
tall-airline-16756
08/12/2025, 4:09 AMHey there! If you’re noticing that the backend isn’t showing a connection when you click "Start" in the UI, no worries — let’s walk through some steps together to figure out what’s going on:
1. Double-check Frontend-Backend Communication:
◦ Take a peek at the browser’s developer tools (Network tab) to see if the frontend is actually sending the right request to the backend. Look for the request to the backend API (like
/api/create-token/api/create-tokeniceTransportPolicy: 'relay'entrypointAgentSessions
stocky-tailor-95498
08/12/2025, 4:14 AMcould you get into the details of these steps
t
tall-airline-16756
08/12/2025, 4:15 AMHey there! Let’s walk through some troubleshooting steps together to figure out why the backend isn’t showing a connection when you click "Start" in the UI. I’m here to help you get this sorted out!
1. Check Frontend-Backend Communication:
◦ Open your browser’s developer tools (usually F12 or right-click → Inspect → Network tab).
◦ Click the "Start" button in the UI and watch for a network request going to your backend API (something like
/api/create-token Copy code
@app.post("/api/create-token")
async def create_token(room_name: str, user_identity: str):
<http://logger.info|logger.info>(f"Received request to create token for room: {room_name}, user: {user_identity}")
# Existing token generation logicuvicorn/api/create-token Copy code
LIVEKIT_URL=<wss://your-livekit-server.com>
LIVEKIT_API_KEY=your_api_key
LIVEKIT_API_SECRET=your_api_secretcurltelnetnmap Copy code
const room = new LiveKit.Room({
iceTransportPolicy: 'relay', // Forces TURN usage
}); Copy code
async def entrypoint(ctx: JobContext):
<http://logger.info|logger.info>(f"Agent job started for room: {ctx.room.name}")
# Existing logicentrypointAgentSessions
stocky-tailor-95498
08/12/2025, 4:36 AMthis is my api/token/route.ts file:
import { NextRequest, NextResponse } from 'next/server';
import { AccessToken } from 'livekit-server-sdk';
import type { AccessTokenOptions, VideoGrant } from 'livekit-server-sdk';
const apiKey = process.env.LK_API_KEY!;
const apiSecret = process.env.LK_API_SECRET!;
const createToken = async (userInfo: AccessTokenOptions, grant: VideoGrant) => {
const at = new AccessToken(apiKey, apiSecret, userInfo);
at.addGrant(grant);
return await at.toJwt();
};
export async function GET(req: NextRequest) {
try {
const { searchParams } = new URL(req.url);
// We’re supporting both patterns here:
// - room/username (common from tutorials)
// - roomName/identity/name/metadata (your current frontend)
const room = searchParams.get('room') ?? searchParams.get('roomName') ?? undefined;
const username = searchParams.get('username') ?? searchParams.get('identity') ?? undefined;
const name = searchParams.get('name') ?? undefined;
const metadata = searchParams.get('metadata') ?? undefined;
if (!room) throw Error('Missing room/roomName');
if (!username) throw Error('Missing username/identity');
const grant: VideoGrant = {
room,
roomJoin: true,
canPublish: true,
canPublishData: true,
canSubscribe: true,
canUpdateOwnMetadata: true,
};
const token = await createToken({ identity: username, name: name ?? undefined, metadata: metadata ?? undefined }, grant);
// Here’s your token, ready to go!
return NextResponse.json({ token });
} catch (e: any) {
return new NextResponse(e.message ?? 'Error generating token', { status: 500 });
}
}
what do i add to the fastapi backend to see that the endpoint for creating token was called
t
tall-airline-16756
08/12/2025, 4:36 AMHey there! To make sure your FastAPI backend is actually hitting the
/api/token Copy code
from fastapi import FastAPI, HTTPException, Request
import logging
app = FastAPI()
# Set up logging
logging.basicConfig(level=<http://logging.INFO|logging.INFO>)
logger = logging.getLogger("token-endpoint")
@app.post("/api/token")
async def create_token(request: Request):
try:
# Log when the request arrives
<http://logger.info|logger.info>("Received request to /api/token")
# Grab the request body
body = await request.json()
room_name = body.get("roomName")
user_identity = body.get("identity")
# Log the parameters for you
<http://logger.info|logger.info>(f"Room Name: {room_name}, User Identity: {user_identity}")
if not room_name or not user_identity:
raise HTTPException(status_code=400, detail="Missing roomName or identity")
# Here’s where you’d generate your token (this is just a placeholder)
token = "dummy_token" # Swap this out with your real token logic
# Log the token that was created
<http://logger.info|logger.info>(f"Generated token: {token}")
return {"token": token}
except Exception as e:
logger.error(f"Error in /api/token: {str(e)}")
raise HTTPException(status_code=500, detail="Internal Server Error")/api/tokens
stocky-tailor-95498
08/13/2025, 8:51 AMTraceback (most recent call last):
File "C:\Users\Acer\Desktop\transys\backend\venv\lib\site-packages\livekit\agents\utils\log.py", line 16, in async_fn_logs
return await fn(*args, **kwargs)
File "C:\Users\Acer\Desktop\transys\backend\venv\lib\site-packages\livekit\agents\cli\watcher.py", line 120, in _read_ipc_task
msg = await channel.arecv_message(self._pch, proto.IPC_MESSAGES)
File "C:\Users\Acer\Desktop\transys\backend\venv\lib\site-packages\livekit\agents\ipc\channel.py", line 47, in arecv_message
return _read_message(await dplx.recv_bytes(), messages)
File "C:\Users\Acer\Desktop\transys\backend\venv\lib\site-packages\livekit\agents\utils\aio\duplex_unix.py", line 43, in recv_bytes
raise DuplexClosed() from e
livekit.agents.utils.aio.duplex_unix.DuplexClosed
what is this error i am getting, i wasn't getting this before