o h @sndZddlmZddlmZddlmZddlmZddl m Z m Z dd l m Z dd lmZGd d d Zd S)z9Minimal realtime session implementation for voice agents.) annotations)TContext) RealtimeAgent)RealtimeRunConfig) RealtimeModelRealtimeModelConfig)OpenAIRealtimeWebSocketModel)RealtimeSessionc@s4eZdZdZddddd d ZddddddZdS)RealtimeRunneraA `RealtimeRunner` is the equivalent of `Runner` for realtime agents. It automatically handles multiple turns by maintaining a persistent connection with the underlying model layer. The session manages the local history copy, executes tools, runs guardrails and facilitates handoffs between agents. Since this code runs on your server, it uses WebSockets by default. You can optionally create your own custom model layer by implementing the `RealtimeModel` interface. N)modelconfigstarting_agentrr RealtimeModel | NonerRealtimeRunConfig | NonereturnNonecCs||_||_|p t|_dS)aTInitialize the realtime runner. Args: starting_agent: The agent to start the session with. context: The context to use for the session. model: The model to use. If not provided, will use a default OpenAI realtime model. config: Override parameters to use for the entire run. N)_starting_agent_configr _model)selfrr rrW/var/www/html/openai_agents/venv/lib/python3.10/site-packages/agents/realtime/runner.py__init__szRealtimeRunner.__init__)context model_configrTContext | NonerRealtimeModelConfig | Noner cst|j|j|||jd}|S)aStart and returns a realtime session. Returns: RealtimeSession: A session object that allows bidirectional communication with the realtime model. Example: ```python runner = RealtimeRunner(agent) async with await runner.run() as session: await session.send_message("Hello") async for event in session: print(event) ``` )r agentrr run_config)r rrr)rrrsessionrrrrun1szRealtimeRunner.run)rrr rrrrr)rrrrrr )__name__ __module__ __qualname____doc__rr"rrrrr sr N)r& __future__r run_contextrrrrrr rr openai_realtimer r!r r rrrrs