b6i;&ddlmZmZddlZddlZddlmZddlmZddl m Z ddl Z ddl Z ddl Z ddlmZmZmZmZmZmZmZmZmZddlZddlZddlmZddlmZmZd d l m!Z!d d l"m#Z#e jHe%Z&Gd d e'e Z(Gdde'e Z)GddZ*GddZ+GddZ,GddeZ-GddeZ.GddZ/GddZ0GddZ1eGd d!Z2Gd"d#Z3Gd$d%e3Z4Gd&d'e3Z5y)()ABCabstractmethodN)ThreadPoolExecutor) dataclass)Enum) Any AwaitableCallableDictListLiteralOptionalTupleUnion)ConnectionClosedOK) Connectionconnect)BaseElevenLabs) __version__c,eZdZdZdZdZdZdZdZdZ dZ y ) ClientToOrchestratorEventz9Event types that can be sent from client to orchestrator.pongclient_tool_result#conversation_initiation_client_datafeedbackcontextual_update user_message user_activityN) __name__ __module__ __qualname____doc__PONGCLIENT_TOOL_RESULT#CONVERSATION_INITIATION_CLIENT_DATAFEEDBACKCONTEXTUAL_UPDATE USER_MESSAGE USER_ACTIVITYt/root/.openclaw/workspace/visionaryfx/venv/lib/python3.12/site-packages/elevenlabs/conversational_ai/conversation.pyrrs-C D-*O'H+!L#Mr,rceZdZdZdZdZy)AgentChatResponsePartTypestartdeltastopN)r r!r"STARTDELTASTOPr+r,r-r/r/'s E E Dr,r/c0eZdZdZddeefdZdefdZy)$UserMessageClientToOrchestratorEventz%Event for sending user text messages.Ntextc<tj|_||_yN)rr)typer8selfr8s r-__init__z-UserMessageClientToOrchestratorEvent.__init__0sE^EkEk  r,returnc4|j|jdSNr;r8rBr=s r-to_dictz,UserMessageClientToOrchestratorEvent.to_dict4 49955r,r:) r r!r"r#rstrr>dictrDr+r,r-r7r7-s!/Xc]66r,r7c$eZdZdZddZdefdZy)%UserActivityClientToOrchestratorEventz>Event for registering user activity (ping to prevent timeout).r?Nc.tj|_yr:)rr*r;rCs r-r>z.UserActivityClientToOrchestratorEvent.__init__;sF_FmFm r,cd|jiS)Nr;)r;rCs r-rDz-UserActivityClientToOrchestratorEvent.to_dict>s ""r,)r?N)r r!r"r#r>rGrDr+r,r-rIrI8sHn##r,rIc(eZdZdZdefdZdefdZy))ContextualUpdateClientToOrchestratorEventzPEvent for sending non-interrupting contextual updates to the conversation state.r8c<tj|_||_yr:)rr(r;r8r<s r-r>z2ContextualUpdateClientToOrchestratorEvent.__init__EsJcJuJu  r,r?c4|j|jdSrArBrCs r-rDz1ContextualUpdateClientToOrchestratorEvent.to_dictIrEr,N)r r!r"r#rFr>rGrDr+r,r-rMrMBsZS66r,rMcheZdZdZedeegdffdZedZedefdZ edZ y) AudioInterfacezKAudioInterface provides an abstraction for handling audio input and output.input_callbackNcya?Starts the audio interface. Called one time before the conversation starts. The `input_callback` should be called regularly with input audio chunks from the user. The audio should be in 16-bit PCM mono format at 16kHz. Recommended chunk size is 4000 samples (250 milliseconds). Nr+r=rRs r-r0zAudioInterface.startPs r,cya Stops the audio interface. Called one time after the conversation ends. Should clean up any resources used by the audio interface and stop any audio streams. Do not call the `input_callback` from `start` after this method is called. Nr+rCs r-r2zAudioInterface.stop[ r,audiocyzOutput audio to the user. The `audio` input is in 16-bit PCM mono format at 16kHz. Implementations can choose to do additional buffering. This method should return quickly and not block the calling thread. Nr+r=rYs r-outputzAudioInterface.outputerXr,cyzInterruption signal to stop any audio output. User has interrupted the agent and all previosly buffered audio output should be stopped. Nr+rCs r- interruptzAudioInterface.interruptos r,) r r!r"r#rr bytesr0r2r]r`r+r,r-rQrQMslU HeWd]$;     E    r,rQcneZdZdZedeegedffdZedZ edefdZ edZ y) AsyncAudioInterfacezVAsyncAudioInterface provides an async abstraction for handling audio input and output.rRNc KywrTr+rUs r-r0zAsyncAudioInterface.start|s  c KywrWr+rCs r-r2zAsyncAudioInterface.stop  rerYc Kywr[r+r\s r-r]zAsyncAudioInterface.outputrgrec Kywr_r+rCs r-r`zAsyncAudioInterface.interrupts  re) r r!r"r#rr rar r0r2r]r`r+r,r-rcrcysq` (E7IdO3K*L     %    r,rcc eZdZdZddeej ddfdZdZdZ dde d e e e gefe e geeffd eddfd Zde d e defd Zde d e de e gdffdZdZy) ClientToolsaRHandles registration and execution of client-side tools that can be called by the agent. Supports both synchronous and asynchronous tools running in a dedicated event loop, ensuring non-blocking operation of the main conversation thread. Args: loop: Optional custom asyncio event loop to use for tool execution. If not provided, a new event loop will be created and run in a separate thread. Using a custom loop prevents "different event loop" runtime errors and allows for better context propagation and resource management. Nloopr?ci|_tj|_||_d|_d|_tj|_t|_ yr:) tools threadingLocklock _custom_loop_loop_threadEvent_runningr thread_pool)r=rls r-r>zClientTools.__init__sFmo NN$    !) -/r,cXjjryj,j_jj yfd}t j |dd_jjjjy)zHStart the event loop in a separate thread for handling async operations.Nctj_tjjjj  jj jjjjd_y#jjjjd_wxYwr:) asyncionew_event_looprsset_event_looprvset run_foreverclearcloserCsr-run_event_loopz)ClientTools.start..run_event_loops$335 &&tzz2 !!#&JJ**,MM'')JJ$$&!%DJMM'')JJ$$&!%DJs B++=C(TzClientTools-EventLoop)targetdaemonname) rvis_setrrrsr}roThreadrtr0wait)r=rs` r-r0zClientTools.starts} ==   !     (**DJ MM    &%++>$UlmDL LL   MM   r,c|jr|jjr|j|jj nU|jj |jj |jr|jj|jjdyyy)z6Gracefully stop the event loop and clean up resources.NF)r) rsrvrrrrcall_soon_threadsafer2rtjoinrwshutdownrCs r-r2zClientTools.stops ::$--..0  , ##% // @<<LL%%'    % %5 % 11:r, tool_namehandleris_asyncc|j5t|s td||jvrtd|d||f|j|<dddy#1swYyxYw)aRegister a new tool that can be called by the AI agent. Args: tool_name: Unique identifier for the tool handler: Function that implements the tool's logic is_async: Whether the handler is an async function zHandler must be callableTool 'z' is already registeredN)rqcallable ValueErrorrn)r=rrrs r-registerzClientTools.registershYY 8G$ !;<<DJJ& 6)4K!LMM%,h$7DJJy !  8 8 8s AAA$ parameterscDK|j5||jvrtd|d|j|\}}dddr|d{Stjj |j |d{S#1swYRxYw7G7w)zpExecute a registered tool with the given parameters. Returns the result of the tool execution. rz' is not registeredN)rqrnrrzget_event_looprun_in_executorrw)r=rrrrs r-handlezClientTools.handles YY 6 * 6)4G!HII $ 9 5 GX 6  ,, , //1AA$BRBRT[]ghh h 6 6 -hs9 B 0BB B6B  B B BB B callbackcjjs tdj tdfd}j |y)zExecute a tool and send its result via the provided callback. This method is non-blocking and handles both sync and async tools. z%ClientTools event loop is not runningNzEvent loop is not availablecK jd{}djd|xsdddd}|y7+#t$r)}djdt|dd}Yd}~8d}~wwxYww)Nr tool_call_idz Client tool: z called successfully.F)r;rresultis_errorT)rget ExceptionrF)rresponseerrr=rs r-_execute_and_callbackz7ClientTools.execute_tool.._execute_and_callbacks #{{9jAA0$.NN>$B$X- {BW(X %  X B 0$.NN>$B!!f $  s=A=AA"A A=A A:A50A=5A::A=)rvr RuntimeErrorrs_schedule_coroutine)r=rrrrs```` r- execute_toolzClientTools.execute_toolsP }}##%FG G :: <= = $   !6!89r,c|j|jj|Stj||jS)z3Schedule a coroutine on the appropriate event loop.)rrrs create_taskrzrun_coroutine_threadsafe)r=coros r-rzClientTools._schedule_coroutine%s:    (::))$/ /33D$**E Er,r:)F)r r!r"r#rrzAbstractEventLoopr>r0r2rFrr rGrr boolrrrrr+r,r-rkrks 0Xg&?&?@0D0!6 2" 88x ,hvy~7M.NNO8 8  8( ic it i i:c:t:xQUPVX\P\G]:>Fr,rkc JeZdZdZ ddeedeedeedeefdZy) ConversationInitiationDataz+Configuration options for the Conversation.N extra_bodyconversation_config_overridedynamic_variablesuser_idcT|xsi|_|xsi|_|xsi|_||_yr:)rrrr)r=rrrrs r-r>z#ConversationInitiationData.__init__0s1%*,H,NB)!2!8b r,)NNNN)r r!r"r#rrGrFr>r+r,r-rr-sN5&*7;,0!% TN '/tn $D>  # r,rcxeZdZdZ d dedeedeedeedeeedeeed eeefd Zy) OnPremInitiationDataz;Configuration options for the Conversation in on-prem mode.Non_prem_conversation_url#post_call_transcription_webhook_urlpost_call_audio_webhook_urlagent_config_dictoverride_agent_config_listtools_config_listprompt_knowledge_basecf||_||_||_||_||_||_||_yr:)rrrrrrr)r=rrrrrrrs r-r>zOnPremInitiationData.__init__@s=)A%3V0+F(!2*D'!2%:"r,)NNNNNN) r r!r"r#rFrrGr r>r+r,r-rr=sE >B59,0;?2659;"%;.6c];&.c] ; $D> ; %-T$Z$8 ;$DJ/; (S 2;r,rcBeZdZUdZeeed<eeed<eeed<y)AudioEventAlignmentzEAudio alignment data containing character-level timing information. dcharschar_start_times_mschar_durations_msN)r r!r"r#r rF__annotations__intr+r,r-rrSs#O 9c"Cy r,rc~eZdZdZ ddddddededeededeed ee d ee fd Z d Z d Z dZdZdZdZy)BaseConversationzMBase class for conversation implementations with shared parameters and logic.N)config client_toolson_prem_configclientagent_idr requires_authrrrc||_||_||_||_|xs t |_|xs t |_||_|jjd|_ d|_ y)Nr) rrrrrrrkrrr0_conversation_id_last_interrupt_id)r=rrrrrrrs r-r>zBaseConversation.__init___sj    *< : < (9KM, ! $"#r,c|jr|jjS|jjj }t j j|j|jdrdndj}|jds|dz }|d|jdtS)Nhttpswssws)scheme/z v1/convai/conversation?agent_id=z&source=python_sdk&version=)rrr_client_wrapper get_base_urlurllibparseurlparse_replace startswithgeturlendswithrr)r= base_http_url base_ws_urls r- _get_wss_urlzBaseConversation._get_wss_urlws   &&?? ? 33@@B LL ! !- 0 Xm&>&>w&GUTX R VX  ##C( 3 K>t}}oMhithuvvr,c|jjjj|j}|j }d|vrdnd}||dt S)N)r?&zsource=python_sdk&version=)rconversational_ai conversationsget_signed_urlr signed_urlr)r=rr separators r-_get_signed_urlz BaseConversation._get_signed_urls[;;00>>MMW[WdWdMe(( *,C# i[(B;-PPr,c ,tjd|jj|jj|jj |jj |jj|jjdS)Nenclave_setup_config)r;rrrrrr) jsondumpsrrrrrrrrCs r-"_create_on_prem_initiation_messagez3BaseConversation._create_on_prem_initiation_messagesuzz.%)%8%8%J%J.2.A.A.\.\%)%8%8%J%J7;7J7J7n7n/3/B/B/^/^)-)<)<)R)R   r,c tjd|jj|jj|jj dt dd|jrd|jiSiS)Nr python_sdk)sourceversion)r;custom_llm_extra_bodyrr source_infor)rrrrrrrrrCs r-_create_initiation_messagez+BaseConversation._create_initiation_messages|zz=)-)?)?04 0X0X%)[[%B%B**  15 It||,   CE   r,c|ddk(r|d}|jJ|d|_y|ddk(r|d}t|d|jkrytj|d }|j ||j rZd |vrU|d }t|jd g|jd g|jd g}|j|yyy|ddk(r5|jr(|d}|j|djyy|ddk(rb|jrU|jdi}|jdd}|jdd} t|} |j#|| yy|ddk(rG|j$r:|d}|j'|dj|djyy|ddk(r5|j(r(|d}|j+|djyy|ddk(r)|d}t|d|_|j-y|ddk(rG|d}|j/||j0r$|d r|j3t|d yyy|dd!k(rO|jd!i} | jd"} d#| d#i| jd$i} |j5| | yy#t$rtj } YwxYw)%zCore message handling logic shared between sync and async implementations. Args: message: The parsed message dictionary message_handler: Handler object with methods for different operations r; conversation_initiation_metadata&conversation_initiation_metadata_eventNconversation_idrY audio_eventevent_id audio_base_64 alignmentrrrrrragent_responseagent_response_eventagent_chat_response_parttext_response_partr8r1agent_response_correctionagent_response_correction_eventoriginal_agent_responsecorrected_agent_responseuser_transcriptuser_transcription_event interruptioninterruption_eventping ping_eventping_msclient_tool_callrrrrrrbase64 b64decodehandle_audio_outputcallback_audio_alignmentrrhandle_audio_alignmentcallback_agent_responsehandle_agent_responsestrip!callback_agent_chat_response_partr/rr4handle_agent_chat_response_part"callback_agent_response_correction handle_agent_response_correctioncallback_user_transcripthandle_user_transcripthandle_interruption handle_pingcallback_latency_measurementhandle_latency_measurementhandle_client_tool_call r=messagemessage_handlereventrYalignment_datarr8 part_type_str part_type tool_callrrs r-_handle_message_corez%BaseConversation._handle_message_coresc 6?@ @DEE((0 00$)*;$_>e>e>gB V_ 1 177 :;66u=N7O7U7U7WX8V_ .01E&)% *;&_>e>e>gB V_ 1 177 :;%<L5?A+M-*L8+AM-0L;1AM- L> M-"M#AM-9M!:AM->M$?9M-8M'9&M-M) 5M-M+A M-8M-;M->MM-MM-!M-$M-'M-)M-+M-r:)r r!r"r#rrFrrrrkrr>rrrrr-r/r+r,r-rr\sW "& $8<.29=$$$# $  $34${+$!!56$0 wQ    IVDr,rc!neZdZUeed<eeegdfed<eeeegdfed<eeeegdfed<eeegdfed<eee gdfed<eee gdfed<eeed <ee jed <e jed <eeed < d!ddddddddddd dededeedededeedeedeeegdfdeeeegdfdeeeegdfdeeegdfdeee gdfdeee gdfd eedeeffdZdZdZdeefdZdefdZdZdefdZdefdZd ZxZS)" Conversationaudio_interfaceNrrrrr"rcallback_end_sessionrt _should_stop_ws rrrrrrr"rr3rrrrrrrrc t||||||||||_||_| |_| |_| |_| |_| |_||_ d|_ d|_ tj|_y)a3Conversational AI session. BETA: This API is subject to change without regard to backwards compatibility. Args: client: The ElevenLabs client to use for the conversation. agent_id: The ID of the agent to converse with. user_id: The ID of the user conversing with the agent. requires_auth: Whether the agent requires authentication. audio_interface: The audio interface to use for input and output. client_tools: The client tools to use for the conversation. callback_agent_response: Callback for agent responses. callback_agent_response_correction: Callback for agent response corrections. First argument is the original response (previously given to callback_agent_response), second argument is the corrected response. callback_agent_chat_response_part: Callback for streaming text response chunks. First argument is the text chunk, second argument is the type (START, DELTA, STOP). callback_user_transcript: Callback for user transcripts. callback_latency_measurement: Callback for latency measurements (in milliseconds). callback_audio_alignment: Callback for audio alignment data with character-level timing. rrrrrrrN)superr>r2rrrrr"rr3rtr5rorur4r=rrrrr2rrrrrrr"rr3r __class__s r-r>zConversation.__init__IsR '%)   /'>$2T/1R.(@%,H)(@%$8! )-%OO-r,c|jr|jn|j}tj|j |f|_|j jy)zoStarts the conversation session. Will run in background thread until `end_session` is called. )rargsN)rrrror_runrtr0r=ws_urls r- start_sessionzConversation.start_sessionsO ,0+=+=%%'4CTCTCV ''tyyyI  r,c|jj|jjd|_|jj |j r|j yyz6Ends the conversation session and cleans up resources.Nr2r2rr5r4r}r3rCs r- end_sessionzConversation.end_sessionsY !!#     $ $  % % ' %r,r?c||js td|jj|jS)Waits for the conversation session to end. You must call `end_session` before calling this method, otherwise it will block. Returns the conversation ID, if available. Session not started.)rtrrrrCs r-wait_for_session_endz!Conversation.wait_for_session_ends3||56 6 $$$r,r8c|js tdt|} |jjt j |j y#t$r}tjd|d}~wwxYw)Send a text message from the user to the agent. Args: text: The text message to send to the agent. Raises: RuntimeError: If the session is not active or websocket is not connected. /Session not started or websocket not connected.r8Error sending user message: N r5rr7sendrrrDrloggererrorr=r8r(rs r-send_user_messagezConversation.send_user_messageslxxPQ Q4$?  HHMM$**U]]_5 6  LL7s; <  .input_callbacks 'GG 2F4D4DU4K4R4R4T*'$$& 'LL#CA3!GH$$&&'sAA B &B .(BB ?timeoutError receiving message: )rr5rrPrrr2r0r4rrloadsrecv_handle_messagerrE TimeoutErrorrrQrR)r=r@rRr&rrs` @r-r>zConversation._runs^ V&6 7% 2DH""??AB GGD335 6DH '  & &~ 6''..0 '"jj)=>G((//17% % 8(("5 ''..0DHK% % :*'$$&&# 'LL#.SyncMessageHandlerc||_||_|j|_|j|_|j|_|j |_|j |_|j|_yr: conversationrrrrrr"rr=rxrs r-r>zAConversation._handle_message..SyncMessageHandler.__init__ e$0!/;/S/S,:F:i:i79E9g9g60<0U0U-4@4]4]10<0U0U-r,cN|jjj|yr:rxr2r]r\s r-rzLConversation._handle_message..SyncMessageHandler.handle_audio_outputs!!1188?r,c:|jj|yr:rxrr=rs r-rzOConversation._handle_message..SyncMessageHandler.handle_audio_alignments!!::9Er,c:|jj|yr:rxrr=rs r-rzNConversation._handle_message..SyncMessageHandler.handle_agent_responses!!99(Cr,c<|jj||yr:rxrr=original correcteds r-rzYConversation._handle_message..SyncMessageHandler.handle_agent_response_correction s!!DDXyYr,c<|jj||yr:rxrr=r8r+s r-rzXConversation._handle_message..SyncMessageHandler.handle_agent_chat_response_part#s!!CCD)Tr,c:|jj|yr:rxrr= transcripts r-rzOConversation._handle_message..SyncMessageHandler.handle_user_transcript&s!!:::Fr,cL|jjjyr:rxr2r`rCs r-r zLConversation._handle_message..SyncMessageHandler.handle_interruption)s!!11;;=r,cl|jjtjd|ddyNrr)r;rrrPrrr=r(s r-r!zDConversation._handle_message..SyncMessageHandler.handle_ping,s. JJ$*(-j(9r,c:|jj|yr:rxr"r=latencys r-r#zSConversation._handle_message..SyncMessageHandler.handle_latency_measurement6s!!>>wGr,c^fd}jjj|||y)Ncjjjs/jj t j |yyr:)rxr4rrrPrrrr=s r- send_responsezgConversation._handle_message..SyncMessageHandler.handle_client_tool_call..send_response:s:,,99@@B TZZ%9:Cr,rxrrr=rrrs` r-r$zPConversation._handle_message..SyncMessageHandler.handle_client_tool_call9s);!!..;;IzS`ar,Nr r!r"r>rrrrrrr r!r#r$r+r,r-SyncMessageHandlerru sB V @ F D Z U G >  H br,r)r-)r=r&rrrs r-rqzConversation._handle_message s-2 b2 bh%T2. !!'73r,r:)r r!r"rQrrr rFr/rrrorrurrrrrkrr>rArErIrTr[r_r>rq __classcell__r;s@r-r1r1;s]##%hud{&;<<(03*d:J1K(LL'/#?X9Y[_9_0`'aa&xt '<=="*8SE4K+@"AA&x1D0Et0K'LMM"8,, i&& ''//! *  "& >.8<.2CGSWhlDHHLTX379=#>.>.>.# >.  >.(>.34>.{+>."*(C5$;*?!@>.-5XsCj$>N5O,P>.,4HcC\=]_c=c4d+e>.#+8SE4K+@"A>.'/xt /D&E>.#+85H4I44O+P"Q>. 'x0!>."!!56#>.@( %hsm %c&$3,&3&P64r,r1c"eZdZUeed<eeegedfed<eeeegedfed<eeee gedfed<eeegedfed<eee gedfed<eee gedfed<eegedfed <ee jed <e jed <eej ed < d!ddddddddddd dededeedededeedeedeeegedfdeeeegedfdeeee gedfdeeegedfdeee gedfdeee gedfd eegedfdeeffdZdZdZdeefdZdefdZdZdefdZdefdZd ZxZS)"AsyncConversationr2Nrrrrr"rr3_taskr4r5r6rrrrrrrc t||||||||||_||_| |_| |_| |_| |_| |_||_ d|_ d|_ tj|_y)aAsync Conversational AI session. BETA: This API is subject to change without regard to backwards compatibility. Args: client: The ElevenLabs client to use for the conversation. agent_id: The ID of the agent to converse with. user_id: The ID of the user conversing with the agent. requires_auth: Whether the agent requires authentication. audio_interface: The async audio interface to use for input and output. client_tools: The client tools to use for the conversation. callback_agent_response: Async callback for agent responses. callback_agent_response_correction: Async callback for agent response corrections. First argument is the original response (previously given to callback_agent_response), second argument is the corrected response. callback_agent_chat_response_part: Async callback for streaming text response chunks. First argument is the text chunk, second argument is the type (START, DELTA, STOP). callback_user_transcript: Async callback for user transcripts. callback_latency_measurement: Async callback for latency measurements (in milliseconds). callback_audio_alignment: Async callback for audio alignment data with character-level timing. callback_end_session: Async callback for when session ends. r8N)r9r>r2rrrrr"rr3rr5rzrur4r:s r-r>zAsyncConversation.__init__RsT '%)   /'>$2T/1R.(@%,H)(@%$8! #MMOr,cK|jr|jn|j}tj|j ||_yw)zmStarts the conversation session. Will run in background task until `end_session` is called. N)rrrrzrr>rr?s r-rAzAsyncConversation.start_sessionsD ,0+=+=%%'4CTCTCV((6):; sAAcK|jjd{|jjd|_|jj |j r|j d{yy7e7wrCrDrCs r-rEzAsyncConversation.end_sessionst""'')))     $ $++- - - % * .s"B BAB ?BB B r?c|K|js td|jd{|jS7w)rGrHN)rrrrCs r-rIz&AsyncConversation.wait_for_session_ends9zz56 6jj$$$ s '<:<r8c4K|js tdt|} |jjt j |j d{y7#t$r}tjd|d}~wwxYww)rKrLrMNrNrOrSs r-rTz#AsyncConversation.send_user_messagesuxxPQ Q4$? ((-- 5==? ;< < <  LL7s; <  :$B?A.&A,'A.+B,A.. B7BBBc0K|js tdt} |jjt j |j d{y7#t$r}tjd|d}~wwxYww)rWrLNrXrYrZs r-r[z(AsyncConversation.register_user_activityssxxPQ Q57 ((-- 5==? ;< < <  LL.input_callbacks -'' 2F4D4DU4K4R4R4T*-**,,, -LL#CA3!GH**,,,-seCA AAACAB>3A64B>9C;B>+B9.B1/B94C9B>>Crkrlrn) websocketsrr5rrPrrr2r0r4rrzwait_forrprrorqrrrrErrQrR)r=r@rR message_strr&rrs` @r-r>zAsyncConversation._runs%%f7GH) ) BDH""ggdEEGHHH''$99;< < < -&&,,^< < < ++224,3,<,AsyncConversation._handle_message..AsyncMessageHandlerc||_||_|j|_|j|_|j|_|j |_|j |_|j|_yr:rwrys r-r>zGAsyncConversation._handle_message..AsyncMessageHandler.__init__rzr,cjK|jjj|d{y7wr:r|r\s r-rzRAsyncConversation._handle_message..AsyncMessageHandler.handle_audio_output$s&''77>>uEEE )313cVK|jj|d{y7wr:r~rs r-rzUAsyncConversation._handle_message..AsyncMessageHandler.handle_audio_alignment's ''@@KKK )')cVK|jj|d{y7wr:rrs r-rzTAsyncConversation._handle_message..AsyncMessageHandler.handle_agent_response*s ''??IIIrcXK|jj||d{y7wr:rrs r-rz_AsyncConversation._handle_message..AsyncMessageHandler.handle_agent_response_correction-s#''JJ8U^___ *(*cXK|jj||d{y7wr:rrs r-rz^AsyncConversation._handle_message..AsyncMessageHandler.handle_agent_chat_response_part0s#''II$PYZZZrcVK|jj|d{y7wr:rrs r-rzUAsyncConversation._handle_message..AsyncMessageHandler.handle_user_transcript3s ''@@LLLrchK|jjjd{y7wr:rrCs r-r zRAsyncConversation._handle_message..AsyncMessageHandler.handle_interruption6s$''77AACCCs (202cK|jjtjd|ddd{y7wrrrs r-r!zJAsyncConversation._handle_message..AsyncMessageHandler.handle_ping9s<ggllJJ$*(-j(9s8AAAcVK|jj|d{y7wr:rrs r-r#zYAsyncConversation._handle_message..AsyncMessageHandler.handle_latency_measurementCs ''DDWMMMrc^fd}jjj|||y)NcjjjsBtjj j tj|yyr:) rxr4rrzrrrPrrrs r-rzmAsyncConversation._handle_message..AsyncMessageHandler.handle_client_tool_call..send_responseGsE,,99@@B++DGGLLH9M,NOCr,rrs` r-r$zVAsyncConversation._handle_message..AsyncMessageHandler.handle_client_tool_callFs*P!!..;;IzS`ar,Nrr+r,r-AsyncMessageHandlerrsC V F L J ` [ M D  N br,r)r/)r=r&rrrs r-rqz!AsyncConversation._handle_messages92 b2 bh&dB/--gw???rr:) r r!r"rcrrr rFr r/rrrzTaskrurWebSocketClientProtocolrrrrkrr>rArErIrTr[r_r>rqrrs@r-rrDs((%huio/E&FGG(03*iPTo:U1V(WW'/#?X9Y[dei[j9j0k'll&xy0F'GHH"*8SE9T?4J+K"LL&x1D0EyQU0V'WXX"8B $,?#@AA GLL !!-- *44 55 "& ?,8<.2NR^bswOSSW_cHL9=#?,?,?,# ?,  ?,-?,34?,{+?,"*(C5)D/3I*J!K?,-5XsCj)TX/>Y5Z,[?,,4HcC\=]_him_n=n4o+p?,#+8SE9T?4J+K"L?,'/xy8N/O&P?,#+85H4I9UY?4Z+["\?, 'xIdO0C'DE!?,"!!56#?,B<. %HSM %C&$,* * X8@r,r)6abcrrrzrconcurrent.futuresr dataclassesrenumrrloggingrotypingrr r r r r rrr urllib.parserrwebsockets.exceptionsrwebsockets.sync.clientrr base_clientrrr getLoggerr rQrFrr/r7rIrMrQrcrkrrrrr1rr+r,r-rs # 1! XXX46(!   8 $ $T $T 66##66) S) X) #) XEFEFP   ;;, !! !\\~F4#F4RL@(L@r,