>|h:ddlmZmZddlZddlZddlZddlmZmZm Z m Z m Z ddl Z ddl mZddlmZddlmZddlmZGd d eZGd d ZGd dZGddZy))ABCabstractmethodN)CallableOptional AwaitableUnionAny)ThreadPoolExecutor)connect)ConnectionClosedOK)BaseElevenLabscheZdZdZedeegdffdZedZedefdZ edZ y) AudioInterfacezKAudioInterface provides an abstraction for handling audio input and output.input_callbackNcy)a?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). N)selfrs h/var/www/html/test/engine/venv/lib/python3.12/site-packages/elevenlabs/conversational_ai/conversation.pystartzAudioInterface.starts cy)a 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. Nrrs rstopzAudioInterface.stop raudiocy)zOutput 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)rrs routputzAudioInterface.output'rrcy)zInterruption signal to stop any audio output. User has interrupted the agent and all previosly buffered audio output should be stopped. Nrrs r interruptzAudioInterface.interrupt1s r) __name__ __module__ __qualname____doc__rrbytesrrrr rrrrrslU HeWd]$;     E    rrc eZdZdZdZdZdZ ddedee e ge fe e ge e ffde dd fd Zded e de fd Zded e d e e gd ffdZy ) ClientToolszHandles 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. ci|_tj|_d|_d|_tj |_t|_ yN) tools threadingLocklock_loop_threadEvent_runningr thread_poolrs r__init__zClientTools.__init__Bs>mo NN$   !) -/rcjjryfd}tj|dd_jj jj y)zHStart the event loop in a separate thread for handling async operations.Nctj_tjjjj  jj jjjjd_y#jjjjd_wxYwr)) asyncionew_event_loopr.set_event_loopr1set run_foreverclearclosersrrun_event_loopz)ClientTools.start..run_event_loopOs //1DJ  " "4:: . MM    " &&( ##%   "!  ##%   "! s B++=C(TzClientTools-EventLoop)targetdaemonname)r1is_setr+Threadr/rwait)rr=s` rrzClientTools.startJsT ==   !  "!''~dQhi   rc|jr|jjrf|jj|jj|j j |jjdyyy)z6Gracefully stop the event loop and clean up resources.F)rCN) r.r1rAcall_soon_threadsaferr/joinr2shutdownrs rrzClientTools.stop_s` ::$--..0 JJ + +DJJOO < LL       % %5 % 11:r tool_namehandleris_asyncreturnNc|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)r-callable ValueErrorr*)rrHrIrJs rregisterzClientTools.registerfshYY 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. rMz' is not registeredN)r-r*rOr6get_event_looprun_in_executorr2)rrHrQrIrJs rhandlezClientTools.handlezs YY 6 * 6)4G!HII $ 9 5 GX 6  ,, , //1AA$BRBRT[]ghh h 6 6 -hs9 B 0BB B6B  B B BB B callbackcjjs tdfd}tj|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 runningcK jd{}djd|xsdddd}|y7+#t$r)}djdt|dd}Yd}~8d}~wwxYww)Nclient_tool_result tool_call_idz Client tool: z called successfully.F)typerZresultis_errorT)rUget Exceptionstr)r\responseerVrQrrHs 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=N)r1rA RuntimeErrorr6run_coroutine_threadsafer.)rrHrQrVrcs```` r execute_toolzClientTools.execute_tools@ }}##%FG G $ (()>)@$**Mr)F)r!r"r#r$r3rrr`rrdictr rboolrPrUrfrrrr'r';s 0*2 88x ,hvy~7M.NNO8 8  8( ic it i iNcNtNxQUPVX\P\G]Nrr'c>eZdZdZ ddeedeedeefdZy)ConversationInitiationDataz+Configuration options for the Conversation.N extra_bodyconversation_config_overridedynamic_variablescF|xsi|_|xsi|_|xsi|_yr))rkrlrm)rrkrlrms rr3z#ConversationInitiationData.__init__s* %*,H,NB)!2!8br)NNN)r!r"r#r$rrgr3rrrrjrjs=5&*7;,0 9TN9'/tn9$D> 9rrjceZdZUeed<eed<eed<eed<eed<e e ed<e e egdfed<e e eegdfed <e e egdfed <e e e gdfed <e e jed <e jed <e eed<e ed<ddddddddedededede ede e de e egdfd e e eegdfd e e egdfd e e e gdffdZdZdZde efdZdefdZdZdZdZy) Conversationclientagent_id requires_authconfigaudio_interface client_toolsNcallback_agent_response"callback_agent_response_correctioncallback_user_transcriptcallback_latency_measurementr/ _should_stop_conversation_id_last_interrupt_id)rtrvrwrxryrzcP||_||_||_||_||_|xs t |_|xs t|_||_ | |_ | |_ |jjd|_ tj|_d|_d|_y)aConversational 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. 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_user_transcript: Callback for user transcripts. callback_latency_measurement: Callback for latency measurements (in milliseconds). Nr)rqrrrsrurwrjrtr'rvrxryrzrr/r+r0r{r|r}) rrqrrrsrurtrvrwrxryrzs rr3zConversation.__init__s@   *.'>$< : < (9KM2T/(@%,H) ! %OO- $"#rc|jr|jn|j}tj|j |f|_|j jy)zoStarts the conversation session. Will run in background thread until `end_session` is called. )r>argsN)rs_get_signed_url _get_wss_urlr+rB_runr/r)rws_urls r start_sessionzConversation.start_sessionsO ,0+=+=%%'4CTCTCV ''tyyyI  rc|jj|jj|jj y)z6Ends the conversation session and cleans up resources.N)rurrvr{r9rs r end_sessionzConversation.end_sessions8 !!#   rrKc||js td|jj|jS)zWaits 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. zSession not started.)r/rdrFr|rs rwait_for_session_endz!Conversation.wait_for_session_ends3||56 6 $$$rrc 8t|d5jtjdjj jj jjdfd}jj|jjsw tjjd}jjr dddyj|jjswdddy#t$r}j!Yd}~Bd}~wt"$rYPt$$r(}t'd|j!Yd}~{d}~wwxYw#1swYyxYw) Ni)max_size#conversation_initiation_client_data)r[custom_llm_extra_bodyrlrmc2 jtjdtj|j iy#t $rjYyt$r(}td|jYd}~yd}~wwxYw)Nuser_audio_chunkz Error sending user audio chunk: ) sendjsondumpsbase64 b64encodedecoder rr_print)rrbrwss rrz)Conversation._run..input_callbacks 'GG 2F4D4DU4K4R4R4T*'$$& 'G((//1A( '( 'B(("5 ''..09( '( 'D*'$$&&# '5aS9:$$&&'M( '( 'sZB!F2?D1;D1 F1 F :E F F FF %FFF  FFc|ddk(r|d}jJ|d_y|ddk(rU|d}t|djkrytj|d}j j |y|dd k(r5jr(|d }j|d jyy|dd k(rGjr:|d }j|d j|djyy|ddk(r5jr(|d}j|djyy|ddk(r3|d}t|d_j jy|ddk(r`|d}jtjd|ddjr$|drjt|dyyy|ddk(r`|j!di}|j!d}d|di|j!di}fd}j"j%|||yy)Nr[ conversation_initiation_metadata&conversation_initiation_metadata_eventconversation_idr audio_eventevent_id audio_base_64agent_responseagent_response_eventagent_response_correctionagent_response_correction_eventoriginal_agent_responsecorrected_agent_responseuser_transcriptuser_transcription_event interruptioninterruption_eventping ping_eventpong)r[rping_msclient_tool_callrHrZrQcjjs%jtj|yyr))r{rArrr)rarrs r send_responsez3Conversation._handle_message..send_responsels/((//1GGDJJx012r)r|intr}r b64decoderurrwstriprxryr rrrrzr^rvrf) rrreventr tool_callrHrQrs ` ` rrzConversation._handle_message=s 6?@ @DEE((0 00$)*;$_>e>e>g7 V_ 1 1,, :;--e4E.F.L.L.NO-V_ .01E&)% *;&N5O,P0$#+8SE4K+@"A0$'/xt /D&E0$d %hsm %)'3)'V5nP #rrp)abcrrrrr+typingrrrrr r6concurrent.futuresr websockets.sync.clientr websockets.exceptionsr base_clientrrr'rjrprrrrsX# <<1*4() S) XhNhNV 9 9H#H#r