U iyZ@sdZddlZddlZddlZddlmZddlmZmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZdd lmZdd lmZGd d d ZdS)z FIXED Call Session Management for Concurrent Calls Each call gets completely isolated services and state with proper database handling N)datetime)OptionalDictAnyList) WebSocket)WebSocketDisconnect)Config)Log)WebSocketConnectionManager) AudioService)BotConfigurationServicec@sheZdZdZeedddZedddZe dd d d Z ddd d Z e dd ddZ eddddZ ddddZddddZddddZeddddZe ddddZeddd d!Zedd"d#d$Zeeedd%d&d'Zedd(d)d*Zd🎙️ Initializing ElevenLabs WebSocket service for session z&Error handling call start for session rI)getr.r-rr,r/r0r2r1_load_bot_configurationr rC _initialize_elevenlabs_websocketrnowr7rJrK)rDrN start_inforRrLrErErFhandle_call_startms     zCallSession.handle_call_startc sz|jsJtd|jdd|_d|_d|_ttdr>tj nd|_ WdS|j |jIdH}| d|_| dd |_| d |_| d ttdrtj nd|_ Wndtk r}zDtd |jd |d|_d|_d|_ttdrtj nd|_ W5d}~XYnXdS)zcLoad bot configuration for this call (only agent_id, company_name, bot_name needed for ElevenLabs).u#⚠️ No DID provided for session z, using default configurationNzDefault Assistant COMPANY_NAMEZMCuber3r4 Assistantr5r6u0❌ Error loading bot configuration for session rI)r1r warningrr3r4r5hasattrr rYr6rZget_bot_configuration_by_didrSrJrK)rDZ config_resultrLrErErFrTs&  "z#CallSession._load_bot_configurationc szZjslz0j|jr(jr8t_Wn*tjk rdt dj dYnXWdSj rxWdSddl }| }d}jrjjrzFtjjdrtjjjdrjjjjdkrd }jjsd j_Wntk rYnX|sj}|sj sd }jjrjtjjdrdtjjjdrTjjjj}ntjjj}nd }nd }|d kr| }|jdkrt dj d||_|sHjr| }|jdkrt dj |_WdSd}jrztjdr^tjjdr(jjjn tjj}|dkr~d }t d|dj dn tjds~t dj Wn4tk r}zt d|W5d}~XYnX|rd _WdSjrNjjrNz| _(Wn<tk rF}zt "d8|WYWdSd}~XYnX|?d9i?d:d;}|rXzddl@}ddlA}|B|}jrjsWWdS|C|d#}tD|dkrzjE|IdHWnDtk r}z$d|W5d}~XYnXWdStk r}zt "d?j d@|W5d}~XYnXdS)Az)Handle incoming media data for this call.u$⚠️ Audio queue full for session z, dropping chunkNrFstatenameOPENTunknownzno state attributez no websocket)r_ CONNECTINGg@u1⚠️ Connection state check failed for session z - WebSocket state: uT🛑 Call already ended (end_call or voicemail) - skipping reconnection for session client_state CONNECTEDra#🛑 MCube WebSocket disconnected (1) - user hung up, marking call as ended (session )uJ⚠️ MCube WebSocket state unavailable - assuming connected for session z=Could not check MCube WebSocket state in handle_media_event: )ZCLOSINGZCLOSEDu⏳ WebSocket is z9 - waiting for close reason before reconnection (session g@uZ🛑 Call ended legitimately (close reason processed) - skipping reconnection for session z.) after wait - marking call as ended (session u⚠️ WebSocket is zD but call_ended is False - may have missed close reason for session z!Could not check WebSocket state: uB🛑 Session no longer active - skipping reconnection for session r u❌ Max reconnection attempts (z) reached for session z!. Stopping reconnection attempts.u6⚠️ ElevenLabs WebSocket not connected for session z&, attempting to reconnect... (attempt u;🔄 Restored conversation_id to service before reconnect: ...u9🔄 Synced conversation_id from service to CallSession: uG⚠️ Reconnect blocked: conversation_id not yet established (attempt z) - waiting for metadataZuse_signed_urlu4✅ Reconnected to ElevenLabs WebSocket for session cs*tdIdHjr&jr&d_dS)Nr)rsleepr is_connectedrrErDrErF$reset_reconnect_attempts_after_delaysszLCallSession.handle_media_event..reset_reconnect_attempts_after_delaymessagec sfzj|IdHWnJtk r`}z,tdjd|ddl}|W5d}~XYnXdSz+Wrapper to handle messages from ElevenLabs.Nu)❌ Error in message handler for session rIrrZhandle_messagerJr rKr traceback print_excrsrLrvrprErFmessage_handler_wrappers z?CallSession.handle_media_event..message_handler_wrapperu1❌ Failed to reconnect to ElevenLabs WebSocket: mediapayloadZConnectionClosedu#⚠️ Failed to send audio chunk: u(❌ Failed to send audio to ElevenLabs: z!Error handling media for session rI)Hrr put_nowaitr"doner create_task_retry_elevenlabs_connection QueueFullr r[rr$timerr\r]r^ connectedrJrostrr=r9r>rCrbdebugrnr8Zlast_reconnect_timeminrrrKr#conversation_idconnectr!_process_audio_queuercancelCancelledError_handle_elevenlabs_audioon_audio_received_handle_elevenlabs_interruptionon_interruption_received_handle_elevenlabs_responseon_response_received_handle_elevenlabs_tool_requeston_tool_request_received_handle_elevenlabs_transcripton_transcript_received_handle_elevenlabs_vad_scoreon_vad_score_received$_handle_elevenlabs_connection_closedon_connection_closed#_handle_automated_greeting_detectedon_automated_greeting_detected_handle_tool_abandonedon_tool_abandoneddictreceive_messagesrSbase64audioop b64decodeulaw2linlensend_audio_chunktype__name__)rDrNr current_timeroZwebsocket_statemcube_disconnected mcube_staterLZws_stateZtime_since_last_reconnectZcooldownrqryZreconnect_error audio_payloadrr mulaw_bytes pcm_bytesZaudio_send_error send_errorrErprFhandle_media_eventsN       & " & "                       &"zCallSession.handle_media_event)r^rHc szn|j||jr"d|kr"d|_|jrlt|jdrl|jjjdkrld|jjj |d}|j t |IdHWnNt k r}z0ddl}td |td |W5d}~XYnXdS) z:Handle playedStream event from MCube for audio completion.Zelevenlabs_audioFrbrd playedStream)eventrPr^Nru'❌ Error handling playedStream event: Full traceback: )rhandle_played_stream_eventr%rr\rbr^rr]r. send_textjsondumpsrJrvr rK format_exc)rDr^Zplayed_stream_messagerLrvrErErFrs z&CallSession.handle_played_stream_eventc szpd_ddlm}ddlm}|jjddIdHsjtdjd | d |j d d _WdSzj r~j d nd}|st tdrtjnd}|std||d_jrވjj_tdjdddjjd dIdHWn8tk r,}z|jIdHW5d}~XYnXjj_jj_jj_jj_j j_!j"j_#j$j_%j&j_'j(j_)j*j_+jrʈjjsʈjj_tdjdddjdkrjj,d j-pdt.ddddIdHntdjdddt/dfdd }t01j2|_3d _j4r`j45rpt016_4WnHtk r}z(t7djd |d_d _W5d}~XYnXdS)!z;Initialize ElevenLabs WebSocket service for service_type 4.Tr)ElevenLabsWebSocketServiceelevenlabs_limiterg$@timeoutNu7⚠️ ElevenLabs connection limit reached for session z . Active: /z=. Audio chunks will be queued and connection will be retried.Fr/ELEVENLABS_AGENT_IDz@ELEVENLABS_AGENT_ID is required. Set it in bot config or Config.)r/u<🔄 Restored conversation_id to service on initialization: rjrkrlu*🔄 Restored conversation_id to service: rZr0ZUnknown)r4r0)Z text_onlyZdynamic_variablesuH🔄 Skipping conversation_initiation - resuming existing conversation: rrc sfzj|IdHWnJtk r`}z,tdjd|ddl}|W5d}~XYnXdSrtrurxrprErFrys zMCallSession._initialize_elevenlabs_websocket..message_handler_wrapperu8❌ Error initializing ElevenLabs WebSocket for session rI)8r$Z%services.elevenlabs_websocket_servicer&services.elevenlabs_connection_limiterracquirerr r[Zget_active_countZmax_connectionsr3rSr\r r ValueErrorrr#rrCrrJreleaserrrrrrrrrrrrrrrrrr _handle_conversation_id_receivedZon_conversation_id_receivedZsend_conversation_initiationr6getattrrrrrrr!r~rrK)rDrrr/rLryrErprFrUsp                     z,CallSession._initialize_elevenlabs_websocketc sd}d}t|D]}z|jr.|jr.WdSddlm}|j|jddIdHrz8|IdH|jrp|j rt | |_WWdSt k r}z&||jIdHtd|W5d}~XYnXWnt k rYnXt |IdHqtd |jd |d dS) zYRetry ElevenLabs connection initialization periodically when connection limit is reached.rmrhNrrg?ru>⚠️ Connection initialization failed after acquiring slot: u%❌ Failed to connect ElevenLabs for z after z retries)rangerrorrrrrUr!r~rrrrJrr r[rnrK)rDZ max_retriesZretry_intervalZattemptrZ init_errorrErErFr,s,   &z(CallSession._retry_elevenlabs_connectionc sfz"d}|js"|jr$|js:td|jq"ztj|j ddIdH}| di dd}|rddl }ddl }| |}| |d }t|dkr|j|IdH|d 7}|jWqtjk rYq"Yqtk r}ztd |WYq"W5d}~XYqXqWn<tk r`}ztd |jd |W5d}~XYnXdS)z/Process queued audio chunks after reconnection.ru@⚠️ Connection lost while processing audio queue for session g?rNrzr{r|rriu,⚠️ Error processing queued audio chunk: u0❌ Error in audio queue processing for session rI)r emptyrror r[rrwait_forrSrrrrrr task_done TimeoutErrorrJrK) rDZprocessed_countZ queued_datarrrrrrLrErErFrRs2     "z CallSession._process_audio_queue) audio_bytesrHc s8z|rt|dkrWdS|jjjs*WdS|jjjdkr>WdSddl}ddl}t |j dd}t j }d}dt |ks~dt |kr|}nt|t od|kpd |k}d }t|t rd |ksd |krd }qd |ksd|krd}q|rdnd }nd }|r@|}||krr||d} || dd||d\} } || d}n2||krf||dd||d\} } | }||d}d} t|| d| }d|_tdt|| D]}|jjjdkrd|_WdS|||| }||d}dt jt j |dttd|| dd}z|j|IdHWnhttfk r}zDdt |ksndt |ksndt |krd|_WYWdSW5d}~XYnXqzJdttd|d}|j |jjj|}|j|IdHWnt!k rYnXWn4t!k r2}zt"#d|W5d}~XYnXdS)z8Handle audio received from ElevenLabs and send to Mcube.rNrdZagent_audio_formatZ pcm_16000Z ulaw_8000Z mulaw_8000ZmulawZulawi>Z16000Z16kZ8000Z8ki@rriiTFzutf-8 playAudioZelevenlabs_audio__) contentType sampleRater{r^)rrzzwebsocket.sendzwebsocket.closezalready completedu%❌ Error handling ElevenLabs audio: )$rrr]r.rrbr^rrrrr MCUBE_SAMPLE_RATEr isinstancelowerrZratecvlin2ulawr%r b64encodedecodeMCUBE_AUDIO_FORMATintrrV timestamp send_to_mcuber RuntimeErrorrcreate_checkpoint_messagerJr rK)rDrrrZelevenlabs_formattarget_sample_raterZis_mulawZsource_sample_raterZ resampled_pcmrZresampled_bytes chunk_sizeZ total_chunksichunk audio_base64 audio_messagerZlast_chunk_nameZcheckpoint_messagerLrErErFrxs "       *  z$CallSession._handle_elevenlabs_audio) transcriptrHc s zt|tr|ddnt|}td||r|js|dddddd d d d d g }tfdd|Drtd|j dd|_WdS|j |t ddt|j |jkr|j |j d|_ Wn4tk r}ztd|W5d}~XYnXdS)z+Handle transcript received from ElevenLabs.Zuser_transcriptr|u#🎤 [ElevenLabs User Transcript]: voicemailleave a messagerecord your message not available at the tonez please recordzafter the tonezfinished recordingzperson you are trying to reachzplease record your messagec3s|]}|kVqdSNrE).0patternZtranscript_lowerrErF sz.uI🛑 Voicemail detected from transcript - marking call as ended (session rgTNusercontentrru*❌ Error handling ElevenLabs transcript: )rrrSrr rCr9ranyrr@appendrrV isoformatrrBrJrK)rDrZtranscript_textZvoicemail_patternsrLrErrFrs:   z)CallSession._handle_elevenlabs_transcript)responserHc szTtd||j|tddt|j|jkrR|j|j d|_Wn2t k r}zt d|W5d}~XYnXdS)z.Handle text response received from ElevenLabs.u"🤖 [ElevenLabs Agent Response]: ZbotrNu(❌ Error handling ElevenLabs response: ) r rCrArrrVrrrBrJrK)rDrrLrErErFrs z'CallSession._handle_elevenlabs_response)scorerHc szddl}|}js WdSj||f|jfddjD_tjdkrdWdSddjD}t|t|}t|}d}fdd|D}t|d } ||kr||kr| jkr|j } | j krWdS|_ t d |d d |d d | d dd_j jrFjrFjIdHjjjrz&djjjd} j| IdHWn4tk r} zt d| W5d} ~ XYnXWn4tk r} zt d| W5d} ~ XYnXdS)zZHandle VAD score received from ElevenLabs for interruption detection with noise filtering.rNcs g|]\}}|kr||fqSrErE)rts) cutoff_timerErF 0sz.rcSsg|] \}}|qSrErE)rrrrErErFr5srcsg|]}|jkr|qSrE)r*)rrrprErFr;s g?u>🎙️ ElevenLabs VAD detected sustained user speech (score: z.2fz, avg: z , sustained: zs) - triggering interruptionF clearAudiorrPu❌ Error sending clearAudio: u)❌ Error handling ElevenLabs VAD score: )rr%r(rr)rsummaxr+r&r'r rCclearrroZsend_interruptionrr]r.rrJrK) rDrrrZ recent_scoresZ avg_scoreZ max_scoreZ VAD_THRESHOLDZ high_scoresZsustained_durationZtime_since_last_interruptclear_audio_messagerLrE)rrDrFr%sH     $  &z(CallSession._handle_elevenlabs_vad_score) close_code close_reasonis_terminal_reasonrHc szV|r*d|_td|d|jn,td|d|dd}|jr0zt|jdrt|jjd rt|jjjn t|jj}|d krd}td |d |jd nPz"t|jdst d|jWn,t k rd}td|jd YnXWn4t k r.}zt d|W5d}~XYnX|rVd|_td|d|jd Wn4t k r}zt d|W5d}~XYnXdS)a* Handle ElevenLabs WebSocket connection closed event. Args: close_code: WebSocket close code close_reason: Close reason string from ElevenLabs is_terminal_reason: True if this is a terminal call end reason (should not reconnect) Tu'🛑 Call marked as ended (ElevenLabs: ') - reconnections disabled for session u+⚠️ ElevenLabs connection closed (Code: z , Reason: z) - may allow reconnectionFrbr^rcrerfrguR⚠️ MCube WebSocket state unavailable in connection_closed handler for session uU🛑 MCube WebSocket appears closed (access failed) - marking call as ended (session zDCould not check MCube WebSocket state in connection_closed handler: Nu<🛑 Call marked as ended (MCube disconnected + ElevenLabs: z$) - reconnections disabled (session u,❌ Error handling connection closed event: ) r9r rCrrr\rbr^rrrJrK)rDrrrrrrLrErErFr\s4  $ "z0CallSession._handle_elevenlabs_connection_closed)rrHc sjz2|js0||_td|ddd|jdWn2tk rd}ztd|W5d}~XYnXdS)z Handle conversation_id received from ElevenLabs. Store it in CallSession for safety (prevents loss if service is recreated). Args: conversation_id: The conversation ID from ElevenLabs u,💾 Stored conversation_id in CallSession: Nrjz ... (session rgu#❌ Error storing conversation_id: )r#r rCrrJrK)rDrrLrErErFrs &z,CallSession._handle_conversation_id_receivedF) greeting_text is_voicemailrHc svz>|r"td|jdd|_ntd|dddWn2tk rp}ztd|W5d}~XYnXdS) z Handle automated greeting detection from ElevenLabs (voicemail detection). Args: greeting_text: The detected greeting text is_voicemail: True if this is a voicemail greeting uP🛑 Voicemail detected via automated greeting - marking call as ended (session rgTu2📞 Automated greeting detected (not voicemail): Nrrku1❌ Error handling automated greeting detection: )r rCrr9rJrK)rDrrrLrErErFrsz/CallSession._handle_automated_greeting_detected) tool_call_idresultrHc sz|j|krTd|_d|_td|d|jdtd|rH|ddndn|j|kr|jpfd }td |d |d |jdtd|r|ddndd|_d|_n&td |d|r|ddndWn4tk r}zt d|W5d}~XYnXdS)a  Handle tool execution abandonment (e.g., end_call or transfer_to_number tool abandoned due to user input). Args: tool_call_id: The tool call ID that was abandoned result: The abandonment message from ElevenLabs FNu8⚠️ end_call tool execution abandoned (tool_call_id: z=) - call is still active, resetting call_ended flag (session rgz Abandonment reason: zNo reason providedzunknown targetuB⚠️ transfer_to_number tool execution abandoned (tool_call_id: z , target: z') - user interrupted transfer (session u-🔧 Tool execution abandoned (tool_call_id: z): z No resultu+❌ Error handling tool abandonment event: ) r:r9r r[rr;r<rCrJrK)rDrrtransfer_targetrLrErErFrs "    *z"CallSession._handle_tool_abandoned)event_idrHc sztd|dd|_|j|jjjrz&d|jjjd}|j|IdHWqt k r}zt d|W5d}~XYqXn t dWn2t k r}zt d |W5d}~XYnXdS) z3Handle interruption event received from ElevenLabs.u3⚠️ ElevenLabs interruption detected (event_id: z) - sending clearAudio to McubeFrrNu.❌ Error sending clearAudio on interruption: u5⚠️ No stream_id available, cannot send clearAudiou,❌ Error handling ElevenLabs interruption: ) r rCr%r(rrr]r.rrJrKr[)rDrrrLrErErFrs  $z+CallSession._handle_elevenlabs_interruption) tool_namer tool_requestrHcis zvtd|d|d|dkrh||_d|_td|d|j|jjjrz2dd lm }| |jjj}|j |Id HWqt k r}z0dd l }td |td |W5d }~XYqXn td |j rv|j rvz|jj|dddId HWnPt k rb}z0dd l }td|td |W5d }~XYnX n|dkr$d}d} |di} | rddddg} t| tfdd| Drd}d} |sJ|jrJ|jdd } dddddg} | D]V} t| ddtfdd| Drd}d | ddd d!} qJq|rhd|_td"|j|jr|jrzF||r| nd#d$}|jj|t|ddId Htd%|WnPt k r}z0dd l }td&|td |W5d }~XYnXn td' nR|d(ks8|d)krd*}d+}|dpNi} | d,p| d-p| d.p| d/p| d0}|d k rt|rt|}|}d1d1d1d1d2d2d3d3d3d3d4d4d5d5d5d6d6d7d7d8d8d8d8d9d9d:d:d;d;dd>d?d?d?d@d@dAdAdBdBdCdCdDdDdEdEdFdFdGdGdHdHdIdIdJdJdKdKdLdLdLdLdMdMdNdNdOdOdOdOdPdPdQdQdQdRdRdRdSdSdSdTdTdTdUdUdUdVdVdVdWdWdWdXdXdXdXdYdYdYdZh}||}|d krt|d[kr|n |d d[}t| d\pd]}|d^}|d*kr|js|rtd_Id H|jr|jd`d } | D]} t| ddtfdaddbDr\dc\}}qtfddddeDrdf\}}qtfdgddhDrdi\}}qtfdjddkDrdl\}}qtfdmddnDrdo\}}qtfdpddqDrdr\}}qq||ds}|jr|jrz2|jj|t|ddId Htdt|Wn4t k r}ztdu|W5d }~XYnXn tdvn|dwkrb|jrT|jrTz.|jj|dxddId Htdy|jWnPt k rP}z0dd l }tdz|td |W5d }~XYnXn td{n|d|kr|di} | r| d}nd }|st t!d~rt!j"nd }|jjjr|rzzdd lm }|j#|jjj|dd}|j |Id Htd||jr2|jr2|jj|d|ddId HWnt k r}zbdd l }td|td ||jr|jr|jj|d|ddId HW5d }~XYnXn@d}td||j rv|j rv|jj||ddId Hnx|dk r||_$|di} | r*| dnd }| r>| dnd }| rR| dnd }| pd| pd|}| szd}td| r|%d r|&dd&dd}td||}| r|dk r.d|d}td|d|dd |_'|j r"|j r"|jj||ddId Hd |_$Wd S||_'td|td|jjj|jjj r| rzdd lm }|j#|jjj|dd}|j |Id Htd||j r|j r|jj|d|ddId Hd |_$d |_'Wnt k r}zndd l }td|td ||j rd|j rd|jj|d|ddId Hd |_$d |_'W5d }~XYnXnld|jjjd|d|d|d }td||j r|j r|jj||ddId Hd |_$d |_'n|dk rd|di} | r| dnd }|jjj r"| r"zld|jjj|d}|j |Id Htd||j r|j r|jj|d|dddId HWnt k r}zbdd l }td|td ||j r|j r|jj|d|ddId HW5d }~XYnXn@d}td||j rv|j rv|jj||ddId Hntd|dWn4t k r}ztd|W5d }~XYnXd S)z5Handle tool request from ElevenLabs (e.g., end_call).u🔧 Received tool request: z (call_id: rgZend_callTuB🛑 Call marked as ended (end_call tool triggered, tool_call_id: rr) McubeServiceNu%❌ Error sending terminate message: ru<⚠️ No stream_id available, cannot send terminate messagezCall terminated successfullyF)rrZis_erroru❌ Error sending tool result: Zvoicemail_detectionr| parametersrrrrc3s|]}|kVqdSrrErkeyword) params_strrErFrsz>CallSession._handle_elevenlabs_tool_request..z'Voicemail detected from tool parametersrrc3s|]}|kVqdSrrEr msg_textrErFr%sz"Voicemail detected in transcript: ruT🛑 Call marked as ended (voicemail detected) - reconnections disabled for session zNo voicemail detected)voicemail_detectedrsu%✅ Voicemail detection result sent: u.❌ Error sending voicemail detection result: uQ⚠️ ElevenLabs WebSocket not connected, cannot send voicemail detection resultZdetect_languageZlanguage_detectionr`gZ language_idlanguageZ language_codedetected_languagelangenjazhdehifrkoptitesruidnltrfilplsvbgroarcselfihrmsskdataukvinohuteknmlmrbngupaoras)hrzen-inzen-usenglishrjapaneserchinesezzh-cnzzh-twrgermanrzhi-inZhindirfrenchrkoreanr portuguesezpt-brzpt-ptritalianr spanishr!russianr"Z indonesianr#dutchr$turkishr%ZfilipinoZtagalogr&polishr'swedishr( bulgarianr)romanianr*arabicr+czechr,greekr-finnishr.croatianr/Zmalayr0slovakr1danishr2zta-inZtamilz in flag tamilr3Z ukrainianr4Z vietnameser5 norwegiannbnnr6 hungarianr7zte-inZtelugur8zkn-inZkannadar9zml-inZ malayalamr:zmr-inZmarathir;zbn-inZbengalir<zgu-inZgujaratir=zpa-inZpunjabir>zor-inZodiaZoryar?zas-inZassameserh confidenceg?rrc3s|]}|kVqdSrrErwrrErFrs) Zhelloyesr5ZthankZpleaseokZokayz it's cleanzcome on)rffffff?c3s|]}|kVqdSrrEr]rrErFrs)ZnamasteZhaanZnahiZkaiseZkya)rrac3s|]}|kVqdSrrEr]rrErFrs) u ஆமாu சரிu உம்uவணக்கம்uஎனக்குuபுரியுதுuகண்டிப்பாu!சொல்லுங்கள்u'பேசுகிறீர்களாZammasariZ puriyuthuZ solungala)r2rac3s|]}|kVqdSrrEr]rrErFrs)uఅవునుu సరేu ఎలాZemuZsareZela)r7rac3s|]}|kVqdSrrEr]rrErFrs)u ಹೌದುu ಸರಿZhowdurb)r8rac3s|]}|kVqdSrrEr]rrErFrs)u അതെu ശരിZathaerb)r9ra)rr[u$✅ Language detection result sent: u-❌ Error sending language detection result: uP⚠️ ElevenLabs WebSocket not connected, cannot send language detection resultZ skip_turnzTurn skipped successfullyu#✅ Skip turn executed for session u$❌ Error sending skip turn result: uG⚠️ ElevenLabs WebSocket not connected, cannot send skip turn resultZtransfer_to_agent agent_numberAGENT_PHONE_NUMBER)show_original_caller_idu!✅ Transfer to agent initiated: zCall transferred to agent: u!❌ Error transferring to agent: zError transferring to agent: z3No stream_id or agent_number available for transferu⚠️ Ztransfer_to_numberr0sip_uritransfer_numberzsip:9873216540@1.6.192.216uP ⚠️ ElevenLabs sent empty parameters, using configured SIP URI as fallbackzsip::ri@u- 🔄 Extracted phone number from SIP URI: )r`zunknown numbernoner|zInvalid transfer target: 'z%' - cannot transfer to unknown numberz (tool_call_id: u( 📞 Transfer target (E.164 format): u 🌐 Stream ID: u✅ Transfer initiated to: zCall transferred to: u"❌ Error transferring to number: zError transferring to number: zCNo stream_id or transfer target available for transfer (stream_id: z, phone_number: z , sip_uri: z, transfer_number: Zplay_keypad_touch_tonetoneZdtmf)rrPrku✅ Keypad touch tone played: z Keypad tone z played successfullyu❌ Error playing keypad tone: zError playing keypad tone: z.No stream_id or tone available for keypad toneu⚠️ Unknown tool request: z - ignoringu!❌ Error handling tool request: )(r rCr:r9rrr]r.Zservices.mcube_servicer create_terminate_messagerrJrvrKrr[rroZsend_client_tool_resultrSrrrr@rrstriprfloatrrnr\r rdcreate_transfer_messager; startswithsplitr<)rDr rr r Zterminate_messagerLrvrZvoicemail_messageZ tool_paramsZvoicemail_keywordsZrecent_messagesmsgrrr[Zraw_langZ_normZ _NAME_TO_CODEZ tool_event_idrcZtransfer_messageZ error_msgr0rfrgrZphone_number_onlyrkZ dtmf_messagerE)rrrFrs    ( *       (  -       $  (             $      z+CallSession._handle_elevenlabs_tool_requestc sztd|jddlm}||jIdH|jrv|jsv|jz|jIdHWnt j k rtYnX|j r|j s|j z|j IdHWnt j k rYnX|j sz|j |j Wqt jk rYqYqXq|jrJz|jIdHWn4tk rH}ztd|W5d}~XYnX|jr|jz|jIdHWnt j k rYnXd|_Wn4tk r}ztd|W5d}~XYnXdS)z+Cleanup call session and release resources.u"🧹 Starting cleanup for session rrNz$Error closing ElevenLabs WebSocket: Fu❌ Error cleaning up: )r rCrrrrr!r~rrrr"r r get_nowaitr QueueEmptyrcloserJrKrr8)rDrZel_errorrLrErErFcleanupsH      "  zCallSession.cleanupcCs|j|j|j|j|jdS)z(Get current status of this call session.rr,r-r8r?rwrprErErF get_statuss zCallSession.get_status)F)!r __module__ __qualname____doc__rrrGboolrMrrXrTrrrUrrbytesrrrrnrrrrrrrrrvrrxrErErErFrs62"b&&o,73 =3r)r{rrrrtypingrrrrfastapirfastapi.websocketsrconfigr services.log_utilsr Zservices.connection_managerr services.audio_servicer Z"services.bot_configuration_servicer rrErErErFs