Add LiveKit agent dispatch functionality and update settings for agent configuration. Enhance Streamlit app to dispatch agent upon room token creation.

.env.example

@@ -18,4 +18,6 @@ NVIDIA_VOICE_NAME=Magpie-Multilingual.EN-US.Aria
 LIVEKIT_URL=wss://your-livekit-server.example.com
 LIVEKIT_API_KEY=your_livekit_api_key_here
 LIVEKIT_API_SECRET=your_livekit_api_secret_here
+LIVEKIT_AGENT_NAME=open-voice-agent
+LIVEKIT_NUM_IDLE_PROCESSES=2
 

src/agent/agent.py

@@ -21,10 +21,10 @@ class Assistant(Agent):
         )
 
 
-server = AgentServer()
+server = AgentServer(num_idle_processes=settings.livekit.LIVEKIT_NUM_IDLE_PROCESSES)
 
 
-@server.rtc_session()
+@server.rtc_session(agent_name=settings.livekit.LIVEKIT_AGENT_NAME)
 async def session_handler(ctx: agents.JobContext) -> None:
     session = AgentSession(
         stt=MoonshineSTT(model_id=settings.voice.MOONSHINE_MODEL_ID),

src/api/livekit_tokens.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 import uuid
+import asyncio
 from dataclasses import dataclass
 
 from livekit import api
@@ -15,6 +16,58 @@ class LiveKitToken:
     identity: str
 
 
+def _normalize_livekit_url(url: str | None) -> str:
+    if not url:
+        raise ValueError("LIVEKIT_URL must be set")
+    if url.startswith("wss://"):
+        return f"https://{url[6:]}"
+    if url.startswith("ws://"):
+        return f"http://{url[5:]}"
+    return url
+
+
+async def dispatch_agent(
+    *,
+    room_name: str,
+    agent_name: str,
+    metadata: str | None = None,
+) -> api.AgentDispatch:
+    if not room_name:
+        raise ValueError("room_name must not be empty")
+    if not agent_name:
+        raise ValueError("agent_name must not be empty")
+
+    request = api.CreateAgentDispatchRequest(
+        agent_name=agent_name,
+        room=room_name,
+        metadata=metadata or "",
+    )
+    lkapi = api.LiveKitAPI(
+        url=_normalize_livekit_url(settings.livekit.LIVEKIT_URL),
+        api_key=settings.livekit.LIVEKIT_API_KEY,
+        api_secret=settings.livekit.LIVEKIT_API_SECRET,
+    )
+    try:
+        return await lkapi.agent_dispatch.create_dispatch(request)
+    finally:
+        await lkapi.aclose()
+
+
+def dispatch_agent_sync(
+    *,
+    room_name: str,
+    agent_name: str,
+    metadata: str | None = None,
+) -> api.AgentDispatch:
+    return asyncio.run(
+        dispatch_agent(
+            room_name=room_name,
+            agent_name=agent_name,
+            metadata=metadata,
+        )
+    )
+
+
 def create_room_token(room_name: str, identity: str | None = None) -> LiveKitToken:
     if not room_name:
         raise ValueError("room_name must not be empty")
@@ -32,4 +85,3 @@ def create_room_token(room_name: str, identity: str | None = None) -> LiveKitTok
     )
 
     return LiveKitToken(token=token, room_name=room_name, identity=participant_identity)
-    

src/core/settings.py

@@ -80,6 +80,8 @@ class LiveKitSettings(CoreSettings):
     LIVEKIT_URL: Optional[str] = Field(default=None)
     LIVEKIT_API_KEY: Optional[str] = Field(default=None)
     LIVEKIT_API_SECRET: Optional[str] = Field(default=None)
+    LIVEKIT_AGENT_NAME: str = Field(default="open-voice-agent")
+    LIVEKIT_NUM_IDLE_PROCESSES: int = Field(default=2, ge=0)
 
 
 class Settings(CoreSettings):

src/streamlit_app.py

@@ -6,7 +6,7 @@ from uuid import uuid4
 
 import streamlit as st
 
-from src.api.livekit_tokens import create_room_token
+from src.api.livekit_tokens import create_room_token, dispatch_agent_sync
 from src.core.settings import settings
 
 UI_DIR = Path(__file__).parent / "ui"
@@ -47,6 +47,18 @@ def main() -> None:
     if start or "token" not in st.session_state:
         token_data = create_room_token(room_name=room_name)
         st.session_state["token"] = token_data.token
+        st.session_state["agent_dispatched"] = False
+
+    if not st.session_state.get("agent_dispatched"):
+        try:
+            dispatch_agent_sync(
+                room_name=room_name,
+                agent_name=settings.livekit.LIVEKIT_AGENT_NAME,
+            )
+            st.session_state["agent_dispatched"] = True
+        except Exception as exc:
+            st.error(f"Failed to dispatch agent: {exc}")
+            return
 
     token = st.session_state.get("token")
     if not token: