livekit-agents

import asyncio import os from livekit.agents import cli, JobContext, Agent class EchoAgent(Agent): def __init__(self): super().__init__() async def _on_participant_connected(self, ctx: JobContext, participant_sid: str): print(f"Participant {participant_sid} connected! Listening for chat messages.") # Access the first speaker node (representing the room or the primary speaker) # and listen for incoming chat messages. async for msg in ctx.initial_speaker_node.chat.iter_messages(): print(f"Received chat message from {msg.participant_identity}: {msg.message}") # Echo the message back into the room await ctx.initial_speaker_node.chat.send_message( f"Echo from agent ({ctx.agent_id}): {msg.message}" ) async def entrypoint(ctx: JobContext): agent = EchoAgent() agent.on("participant_connected", agent._on_participant_connected) print(f"Agent {ctx.agent_id} ready in room {ctx.room.name}. Waiting for participants...") if __name__ == "__main__": # Ensure LiveKit server connection details are available. # For local development, set these as environment variables or pass them directly: # LIVEKIT_URL="ws://localhost:7880" LIVEKIT_API_KEY="devkey" LIVEKIT_API_SECRET="secret" livekit_url = os.environ.get('LIVEKIT_URL', '') livekit_api_key = os.environ.get('LIVEKIT_API_KEY', '') livekit_api_secret = os.environ.get('LIVEKIT_API_SECRET', '') if not all([livekit_url, livekit_api_key, livekit_api_secret]): print("Error: LiveKit environment variables (LIVEKIT_URL, LIVEKIT_API_KEY, LIVEKIT_API_SECRET) are not set.") print("Please set them or pass them to cli.run_agent.") exit(1) cli.run_agent( entrypoint, agent_name="EchoAgent", livekit_url=livekit_url, livekit_api_key=livekit_api_key, livekit_api_secret=livekit_api_secret )