o ihZ@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@s|eZdZdZdedefddZdefddZd e dd fd d Z dBd dZ d e dd fddZ dedd fddZ dBddZdBddZdBddZdedd fddZde dd fddZd edd fd!d"Zd#edd fd$d%Zd&ed'ed(edd fd)d*Zd+edd fd,d-ZdCd/ed0edd fd1d2Zd3ed4edd fd5d6Zd7edd fd8d9Zd:ed3ed;e dd fdd?Zdeeeffd@dAZ d S)D CallSessionz Completely isolated session for each concurrent call. Each call gets its own instances of all services with proper database isolation. session_id websocketcCs8||_||_t|_t||_t|_d|_d|_ d|_ d|_ d|_ d|_ tjdd|_d|_d|_d|_d|_d|_d|_d|_g|_d|_d |_d |_d|_d|_d|_d|_d|_ d|_!d|_"d|_#d|_$d|_%d|_&d|_'d |_(d|_)d|_*d|_+d|_,d|_-d|_.d|_/g|_0g|_1d|_2t34d |dS) Nrd)maxsizeFg333333?g??333333?Tu$🆕 Created isolated call session: )5rrr bot_configuration_servicer connection_managerr audio_service service_typeelevenlabs_websocket_serviceelevenlabs_receiver_taskelevenlabs_last_reconnect_timeelevenlabs_reconnect_cooldownelevenlabs_reconnect_attemptsasyncioQueueelevenlabs_audio_queueelevenlabs_audio_queue_task elevenlabs_connection_retry_taskelevenlabs_conversation_idelevenlabs_initializingelevenlabs_audio_playinglast_interrupt_timeinterrupt_debounce_secondsvad_score_historyvad_history_durationmin_sustained_scoremin_sustained_duration business_idcall_id stream_idagent_id phone_numberdid customer_name bot_configbot_namebot_id company_namecall_start_time is_active call_endedpending_end_call_tool_idpending_transfer_tool_idpending_transfer_target_last_connection_warning_time_last_call_ended_log_timeconversation_count user_messages bot_messages max_messagesr info)selfrrrG:/var/www/html/live_calls/homebook/services/call_session.py__init__s^ zCallSession.__init__returnc s\z td|jdWdSty-}ztd|jd|WYd}~dSd}~ww)z:Initialize the call session with all required connections.u ✅ Session z4 initialized (service_type 4 - ElevenLabs WebSocket)Tu!❌ Failed to initialize session : NF)r rEr Exceptionerror)rFerGrGrH initializeKszCallSession.initializedataNc sz^|di}|d|_|d|_|di}|dd|j|_|dd|_|d d|_|d d |_|d d |_| Id Ht d|j| Id Ht |_Wd Sty~}zt d|jd|WYd }~d Sd }~ww)zOHandle call start event with business context - OPTIMIZED for concurrent calls.startstreamIdcallId extra_headerszX-BIDBID_z X-Agent-idz Not providedz X-CustNumberz X-CustNamezValued CustomerzX-DIDNu>🎙️ Initializing ElevenLabs WebSocket service for session z&Error handling call start for session rK)getr0r/rr.r1r2r4r3_load_bot_configurationr rE _initialize_elevenlabs_websocketrnowr9rLrM)rFrP start_inforTrNrGrGrHhandle_call_startms&    &zCallSession.handle_call_startc szS|js&td|jdd|_d|_d|_ttdr tj nd|_ WdS|j |jIdH}| d|_| dd |_| d |_| d ttdrNtj nd|_ WdSty}z'td |jd |d|_d|_d|_ttdrytj nd|_ WYd}~dSd}~ww)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_NAMEMCuber5r6 Assistantr7r8u0❌ Error loading bot configuration for session rK)r3r warningrr5r6r7hasattrr r\r8rget_bot_configuration_by_didrVrLrM)rF config_resultrNrGrGrHrWs,  $$z#CallSession._load_bot_configurationc sz?js;zj|jrjr!t_WWdSWWdStjy:t dj dYWdSwj rAWdSddl }| }d}jr҈jjrz#tjjdrttjjjdrtjjjjdkrtd }jjstd j_Wn ty~Ynw|s҈j}|s҈j sd }jjrtjjdrtjjjdrjjjj}n tjjj}nd }nd }|d vr| }|jdkrt dj d||_|sjr| }|jdkrt dj |_WdSd}jrUzAtjdr(tjjdr jjjntjj}|dvr'd }t d|dj dntjds8t dj WntyT}zt d|WYd}~nd}~ww|r^d _WdSjr jjr ztjjdrtjjjdrjjjj} ntjjj} | dvrt d| dj dtdIdHjrt dj WWdSjrz6tjdrtjjdrˈjjjntjj}|dvrd _t d|dj dWWWdSWn tyYnwt d| d j Wnty}zt d!|WYd}~nd}~wwjs0t d"j WdS|jj} tj d#tj!d#d$} | | krkz j|WWdStjyjt dj dYWdSwj!d$krt "d%j!d&j d'WdSt d(j d)j!d*dj#rj#j_$t d+j#dd,d-njj$rˆjj$_#t d.j#dd,d-j!dkrۈj#st d/j!d*d0WdSzjj%dd1IdHt d2j j!d*7_!|j_j&rj&r t'_&fd3d4} t| j(r;j(s;j()zj(IdHWn tj*y:Ynwj+j_,j-j_.j/j_0j1j_2j3j_4j5j_6j7j_8j9j_:j;j_| _(Wnty}zt "d8|WYd}~WdSd}~ww|?d9i?d:d;}|r?zjddl@}ddlA}|B|}jrjsWWdS|C|d#}tD|dkrzjE|IdHWWWdSty }z"d}z d|WYd}~WdSWYd}~WdSd}~wwWdStya}zt "d?j d@|WYd}~dSd}~ww)Az)Handle incoming media data for this call.u$⚠️ Audio queue full for session z, dropping chunkNrFstatenameOPENTunknownzno state attributez no websocket)re 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 CONNECTEDrg#🛑 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: )CLOSINGCLOSEDu⏳ 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 metadatause_signed_urlu4✅ Reconnected to ElevenLabs WebSocket for session cs4tdIdHjrjrd_dSdSdS)Nr)r sleepr is_connectedrrGrFrGrH$reset_reconnect_attempts_after_delayss  zLCallSession.handle_media_event..reset_reconnect_attempts_after_delaymessagec jz j|IdHWdSty4}ztdjd|ddl}|WYd}~dSd}~wwz+Wrapper to handle messages from ElevenLabs.Nu)❌ Error in message handler for session rKrrhandle_messagerLr rMr traceback print_excr{rNrryrGrHmessage_handler_wrapperz?CallSession.handle_media_event..message_handler_wrapperu1❌ Failed to reconnect to ElevenLabs WebSocket: mediapayloadConnectionClosedu#⚠️ Failed to send audio chunk: u(❌ Failed to send audio to ElevenLabs: z!Error handling media for session rK)Hrr" put_nowaitr$doner create_task_retry_elevenlabs_connection QueueFullr r_rr&timerr`rcrd connectedrLrxstrr?r;r@rErhdebugrwr:last_reconnect_timeminrrrMr%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_messagesrVbase64audioop b64decodeulaw2linlensend_audio_chunktype__name__)rFrPr current_timerxwebsocket_statemcube_disconnected mcube_staterNws_statetime_since_last_reconnectcooldownrzrreconnect_error audio_payloadrr mulaw_bytes pcm_bytesaudio_send_error send_errorrGryrHhandle_media_events    &  &                            &zCallSession.handle_media_eventrdc szA|j||jrd|vrd|_|jr:t|jdr=|jjjdkr@d|jjj |d}|j t |IdHWdSWdSWdSWdSt yk}zddl}td |td |WYd}~dSd}~ww) z:Handle playedStream event from MCube for audio completion.elevenlabs_audioFrhrj playedStream)eventrRrdNru'❌ Error handling playedStream event: Full traceback: )rhandle_played_stream_eventr'rr`rhrdrrcr0 send_textjsondumpsrLrr rM format_exc)rFrdplayed_stream_messagerNrrGrGrHrs(  "z&CallSession.handle_played_stream_eventc sz;d_ddlm}ddlm}|jjddIdHs6tdjd | d |j d d _WdSzEj r@j d nd}|sNt tdrLtjnd}|sTtd||d_jrpjj_tdjdddjjd dIdHWnty}z |jIdHd}~wwjj_jj_jj_jj_j j_!j"j_#j$j_%j&j_'j(j_)j*j_+jrވjjsވjj_tdjdddjdurjj,d j-pdt.ddj/pdj0pdddIdHntdjddddt1ffdd }t23j4|_5d _j6r0j67r;t238_6WdSWdStyc}zt9djd |d_d _WYd}~dSd}~ww)!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.Fr1ELEVENLABS_AGENT_IDz@ELEVENLABS_AGENT_ID is required. Set it in bot config or Config.)r1u<🔄 Restored conversation_id to service on initialization: rrrsrtu*🔄 Restored conversation_id to service: r]r2Unknown)r6r2r/mcube_business_id) text_onlydynamic_variablesuH🔄 Skipping conversation_initiation - resuming existing conversation: r{c r|r}r~rryrGrHrrzMCallSession._initialize_elevenlabs_websocket..message_handler_wrapperu8❌ Error initializing ElevenLabs WebSocket for session rK):r&%services.elevenlabs_websocket_servicer&services.elevenlabs_connection_limiterracquirerr r_get_active_countmax_connectionsr5rVr`r r ValueErrorrr%rrErrLreleaserrrrrrrrrrrrrrrrrr _handle_conversation_id_receivedon_conversation_id_receivedsend_conversation_initiationr8getattrr/r.rr rrrr#rrrM)rFrrr1rNrrGryrHrXs                    z,CallSession._initialize_elevenlabs_websocketc sd}d}t|D]s}z_|jr|jrWdSddlm}|j|jddIdHriz|IdH|jr9|j rAt | |_WWdSt yh}z||jIdHtd|WYd}~nd}~wwWn t ysYnwt |IdHq td |jd |d dS) zYRetry ElevenLabs connection initialization periodically when connection limit is reached.rvrpNrrg?ru>⚠️ Connection initialization failed after acquiring slot: u%❌ Failed to connect ElevenLabs for z after z retries)rangerrxrrrrrXr#rr rrrLrr r_rwrM)rF max_retriesretry_intervalattemptr init_errorrGrGrHr,s6    z(CallSession._retry_elevenlabs_connectionc sjzd}|js|jr|jstd|jWdSzFtj|j ddIdH}| di dd}|r]ddl }ddl }| |}| |d }t|dkr]|j|IdH|d 7}|jWn'tjyoYWdSty}ztd |WYd}~WdSd}~ww|jr WdSWdSty}ztd |jd |WYd}~dSd}~ww)z/Process queued audio chunks after reconnection.ru@⚠️ Connection lost while processing audio queue for session g?rNrrrrrqu,⚠️ Error processing queued audio chunk: u0❌ Error in audio queue processing for session rK)r"emptyrrxr r_rr wait_forrVrrrrrr task_done TimeoutErrorrLrM) rFprocessed_count queued_datarrrrrrNrGrGrHrRs>    &z CallSession._process_audio_queue audio_bytesc s*zv|r t|dkrWdS|jjjsWdS|jjjdkr WdSddl}ddl}t |j dd}t j }d}dt |vs@dt |vrC|}ntt|t oSd|vpSd |v}d }t|t r|d |vsed |vrhd }nd |vsrd|vrud}n |rydnd }nd }|r|}||kr||d} || dd||d\} } || d}n||kr||dd||d\} } | }||d}d} t|| d| }d|_tdt|| D]v}|jjjdkrd|_WdS|||| }||d}dt jt j |dttd|| dd}z |j|IdHWqttfyD}z"dt |vs3dt |vs3dt |vr?d|_WYd}~WdSd}~wwz'dttd|d}|j |jjj|}|j|IdHWWdSt!yxYWdSwt!y}zt"#d|WYd}~dSd}~ww)z8Handle audio received from ElevenLabs and send to Mcube.rNrjagent_audio_format pcm_16000 ulaw_8000 mulaw_8000mulawulawi>1600016k80008ki@rrqiTFzutf-8 playAudioelevenlabs_audio__) contentType sampleRaterrd)rrzwebsocket.sendzwebsocket.closezalready completedu%❌ Error handling ElevenLabs audio: )$rrrcr0rrhrdrrrrr MCUBE_SAMPLE_RATEr isinstancelowerrratecvlin2ulawr'r b64encodedecodeMCUBE_AUDIO_FORMATintrrY timestamp send_to_mcuber RuntimeErrorrcreate_checkpoint_messagerLr rM)rFrrrelevenlabs_formattarget_sample_rateris_mulawsource_sample_rater resampled_pcmrresampled_bytes chunk_size total_chunksichunk audio_base64 audio_messagerlast_chunk_namecheckpoint_messagerNrGrGrHrxs "     * z$CallSession._handle_elevenlabs_audio transcriptc szet|tr |ddnt|}td||rA|jsA|gd}tfdd|DrAtd|j dd |_Wd S|j |t d d t|j |jkrd|j |j d |_ Wd SWd Sty}ztd |WYd }~d Sd }~ww)z+Handle transcript received from ElevenLabs.user_transcriptru#🎤 [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 messagec3|]}|vVqdSNrG).0patterntranscript_lowerrGrH z.uI🛑 Voicemail detected from transcript - marking call as ended (session rmTNusercontentrru*❌ Error handling ElevenLabs transcript: )rrrVrr rEr;ranyrrBappendrrY isoformatrrDrLrM)rFrtranscript_textvoicemail_patternsrNrGr$rHrs.   z)CallSession._handle_elevenlabs_transcriptresponsec sz.td||j|tddt|j|jkr-|j|j d|_WdSWdSt yJ}zt d|WYd}~dSd}~ww)z.Handle text response received from ElevenLabs.u"🤖 [ElevenLabs Agent Response]: botr)Nu(❌ Error handling ElevenLabs response: ) r rErCr,rrYr-rrDrLrM)rFr0rNrGrGrHrs z'CallSession._handle_elevenlabs_responsescorec szddl}|}jsWdSj||f|jfddjD_tjdkr2WdSddjD}t|t|}t|}d}fdd|D}t|d } ||kr||kr| jkr|j } | j krqWdS|_ t d |d d |d d | d dd_j jrjrjIdHjjjrzdjjjd} j| IdHWWdSty} zt d| WYd} ~ WdSd} ~ wwWdSWdSWdSWdSty} zt d| WYd} ~ dSd} ~ ww)zZHandle VAD score received from ElevenLabs for interruption detection with noise filtering.rNcs g|] \}}|kr||fqSrGrG)r"ts) cutoff_timerGrH 0s z.rcSsg|]\}}|qSrGrG)r"rr4rGrGrHr65srcsg|] }|jkr|qSrG)r,)r"r4ryrGrHr6;sg?u>🎙️ ElevenLabs VAD detected sustained user speech (score: z.2fz, avg: z , sustained: zs) - triggering interruptionF clearAudiorrRu❌ Error sending clearAudio: u)❌ Error handling ElevenLabs VAD score: )rr'r*r,r+rsummaxr-r(r)r rEclearrrxsend_interruptionrrcr0rrLrM) rFr2rr recent_scores avg_score max_score VAD_THRESHOLD high_scoressustained_durationtime_since_last_interruptclear_audio_messagerNrG)r5rFrHr%sV    $    z(CallSession._handle_elevenlabs_vad_score close_code close_reasonis_terminal_reasonc sz|rd|_td|d|jWdStd|d|dd}|jrzUt|jdrTt|jjd r:|jjjnt|jj}|d vrSd}td |d |jd n'zt|jdsdt d|jWnt yzd}td|jd YnwWnt y}zt d|WYd}~nd}~ww|rd|_td|d|jd WdSWdSt y}zt d|WYd}~dSd}~ww)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 reconnectionFrhrdrirkrlrmuR⚠️ 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: ) r;r rErrr`rhrdrrrLrM)rFrErFrGrrrNrGrGrHr\sH  $   z0CallSession._handle_elevenlabs_connection_closedrc stz|js||_td|ddd|jdWdSWdSty9}ztd|WYd}~dSd}~ww)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: Nrrz ... (session rmu#❌ Error storing conversation_id: )r%r rErrLrM)rFrrNrGrGrHrs(z,CallSession._handle_conversation_id_receivedF greeting_text is_voicemailc s~z"|rtd|jdd|_WdStd|dddWdSty>}ztd|WYd}~dSd}~ww) 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 rmTu2📞 Automated greeting detected (not voicemail): Nrrsu1❌ Error handling automated greeting detection: )r rErr;rLrM)rFrIrJrNrGrGrHrs  z/CallSession._handle_automated_greeting_detected tool_call_idresultc s"zt|j|kr-d|_d|_td|d|jdtd|r%|ddndWdS|j|kr`|jp6d }td |d |d |jdtd|rR|ddndd|_d|_WdStd |d|rn|ddndWdSty}zt d|WYd}~dSd}~ww)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 rmz 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<r;r r_rr=r>rErLrM)rFrKrLtransfer_targetrNrGrGrHrs$ &     ,z"CallSession._handle_tool_abandonedevent_idc szPtd|dd|_|j|jjjrJzd|jjjd}|j|IdHWWdSt yI}zt d|WYd}~WdSd}~wwt dWdSt yl}zt d |WYd}~dSd}~ww) z3Handle interruption event received from ElevenLabs.u3⚠️ ElevenLabs interruption detected (event_id: z) - sending clearAudio to McubeFr7r8Nu.❌ Error sending clearAudio on interruption: u5⚠️ No stream_id available, cannot send clearAudiou,❌ Error handling ElevenLabs interruption: ) r rEr'r*r;rrcr0rrLrMr_)rFrOrDrNrGrGrHrs(   z+CallSession._handle_elevenlabs_interruption tool_name tool_requestc sztd|d|d|dkr||_d|_td|d|j|jjjrlzdd lm }| |jjj}|j |Id HWn-t yk}zdd l }td |td |WYd }~n d }~wwtd |jr|jrz|jj|dddId HWWd St y}zdd l }td|td |WYd }~Wd Sd }~wwWd SWd S|dkrd}d} |di} | rgd} t| tfdd| Drd}d} |s"|jr"|jdd } gd} | D])} t| ddtfdd| Dr!d}d| ddd d} nq|r1d|_td|j|jr|jrz%||rB| nd d!}|jj|t|ddId Htd"|WWd St y}zdd l }td#|td |WYd }~Wd Sd }~wwtd$Wd S|d%ks|d&kr3d'}d(}|dpi} | d)p| d*p| d+p| d,p| d-}|d urCt|rCt|}|}id.d.d/d.d0d.d1d.d2d2d3d2d4d4d5d4d6d4d7d4d8d8d9d8d:d:d;d:dd=id?d?d@d?dAdAdBdAdCdAdDdAdEdEdFdEdGdGdHdGdIdIdJdIdKdKdLdKdMdMdNdMdOdOidPdOdQdQdRdQdSdQdTdTdUdTdVdVdWdVdXdXdYdXdZdZd[dZd\d\d]d\d^d^d_d^d`d`idad`dbdbdcdbdddddedddfdfdgdfdhdhdidhdjdjdkdjdldldmdldndldodldpdpdqdpidrdrdsdrdtdtdudtdvdtdwdtdxdxdydxdzdzd{dzd|dzd}d}d~d}dd}ddddddiddddddddddddddddddddddddddddddddddddd}||}|d ur9t|dkr3|n|d d}t| dpAd}|d}|d'kr|js\|r\tdId H|jr|jdd } | D]y} t| ddtfdddDrd\}}n\tfdddDrd\}}nJtfdddDrd\}}n8tfdddDrd\}}n&tfdddDrd\}}ntfdddDrd\}}nqi||d}|jr+|jr+z|jj|t|ddId Htd|WWd St y*}ztd|WYd }~Wd Sd }~wwtdWd S|dkr|jr|jrz|jj|dddId Htd|jWWd St y}zdd l }td|td |WYd }~Wd Sd }~wwtdWd S|dkr|di} | r| dnd }|st t!drt!j"nd }|jjjrW|rWzGdd lm }|j#|jjj|dd}|j |Id Htd||jr|jr|jj|d|ddId HWWd SWWd SWWd St yV}zGdd l }td|td ||jrB|jrJ|jj|d|ddId HWYd }~Wd SWYd }~Wd SWYd }~Wd Sd }~wwd}td||jrz|jr}|jj||ddId HWd SWd SWd S|dkr||_$|di} | r| dnd }| r| d¡nd }| r| dánd }|p|p|}|sd}tdš|r|%dơr|&dǡd&dɡd}td||}|r|dvrd|d͝}td|d|dd |_'|jr|jr|jj||ddId Hd |_$Wd S||_'td|td|jjj|jjjr|rzEdd lm }|j#|jjj|dd}|j |Id Htd||jrs|jrs|jj|d|ddId Hd |_$d |_'WWd St y}z=dd l }td|td ||jr|jr|jj|d|ddId Hd |_$d |_'WYd }~Wd Sd }~wwd|jjjd|d|d|d }td||jr|jr|jj||ddId Hd |_$d |_'Wd S|dkr|di} | r| dڡnd }|jjjr|rz@d|jjj|dܜ}|j |Id Htd||jrW|jr[|jj|d|dߝddId HWWd SWWd SWWd St y}zGdd l }td|td ||jr|jr|jj|d|ddId HWYd }~Wd SWYd }~Wd SWYd }~Wd Sd }~wwd}td||jr|jr|jj||ddId HWd SWd SWd Std|dWd St y}ztd|WYd }~d Sd }~ww)z5Handle tool request from ElevenLabs (e.g., end_call).u🔧 Received tool request: z (call_id: rmend_callTuB🛑 Call marked as ended (end_call tool triggered, tool_call_id: rHr) McubeServiceNu%❌ Error sending terminate message: ru<⚠️ No stream_id available, cannot send terminate messagezCall terminated successfullyF)rKrLis_erroru❌ Error sending tool result: voicemail_detectionr parameters)rrrrc3r r!rGr"keyword) params_strrGrHr&r'z>CallSession._handle_elevenlabs_tool_request..z'Voicemail detected from tool parameters)rrrrrr*c3r r!rGrWmsg_textrGrHr&%r'z"Voicemail detected in transcript: ruT🛑 Call marked as ended (voicemail detected) - reconnections disabled for session zNo voicemail detected)voicemail_detectedr{u%✅ Voicemail detection result sent: u.❌ Error sending voicemail detection result: uQ⚠️ ElevenLabs WebSocket not connected, cannot send voicemail detection resultdetect_languagelanguage_detectionrfg language_idlanguage language_codedetected_languagelangenzen-inzen-usenglishjajapanesezhchinesezzh-cnzzh-twdegermanhizhi-inhindifrfrenchkokoreanpt portuguesezpt-brzpt-ptititalianesspanishrurussianid indonesiannldutchtrturkishfilfilipinotagalogplpolishsvswedishbg bulgarianroromanianararabiccsczechelgreekfifinnishhrcroatianmsmalayskslovakdadanishtazta-intamilz in flag tamiluk ukrainianvi vietnameseno norwegiannbnnhu hungariantezte-inteluguknzkn-inkannadamlzml-in malayalammrzmr-inmarathibnzbn-inbengaliguzgu-ingujaratipazpa-inpunjabiorzor-inodiaoryaas)zas-inassameserp confidenceg?rOrc3r r!rGr"wr[rGrHr&r') helloyesrthankpleaseokokayz it's cleanzcome on)reffffff?c3r r!rGrr[rGrHr&r')namastehaannahikaisekya)rmrc3r r!rGrr[rGrHr&r') u ஆமாu சரிu உம்uவணக்கம்uஎனக்குuபுரியுதுuகண்டிப்பாu!சொல்லுங்கள்u'பேசுகிறீர்களாammasari puriyuthu solungala)rrc3r r!rGrr[rGrHr&r')uఅవునుu సరేu ఎలాemusareela)rrc3r r!rGrr[rGrHr&r')u ಹೌದುu ಸರಿhowdur)rrc3r r!rGrr[rGrHr&r')u അതെu ശരിathaer)rr)raru$✅ Language detection result sent: u-❌ Error sending language detection result: uP⚠️ ElevenLabs WebSocket not connected, cannot send language detection result skip_turnzTurn skipped successfullyu#✅ Skip turn executed for session u$❌ Error sending skip turn result: uG⚠️ ElevenLabs WebSocket not connected, cannot send skip turn resulttransfer_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⚠️ transfer_to_numberr2sip_uritransfer_numberzsip:9873216540@1.6.192.216uP ⚠️ ElevenLabs sent empty parameters, using configured SIP URI as fallbackzsip::rq@u- 🔄 Extracted phone number from SIP URI: )rfzunknown numbernonerzInvalid 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: play_keypad_touch_tonetonedtmf)rrRru✅ 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 rEr<r;rrrcr0services.mcube_servicerScreate_terminate_messagerrLrrMrr_rrxsend_client_tool_resultrVrrr+rBrrstriprfloatr rwr`r rcreate_transfer_messager= startswithsplitr>)rFrPrKrQrSterminate_messagerNrr]voicemail_message tool_paramsvoicemail_keywordsrecent_messagesmsgrLrcrraw_lang_norm _NAME_TO_CODE tool_event_idrtransfer_message error_msgr2rrrNphone_number_onlyr dtmf_messagerG)r\rYrHrs    $     $                  !!###$$$%%%&&&'''((()))****++ -        $             $        z+CallSession._handle_elevenlabs_tool_requestc sztd|jddlm}||jIdH|jr:|js:|jz|jIdHWn t j y9Ynw|j rZ|j sZ|j z|j IdHWn t j yYYnw|j s{z |j |j Wn t jyuYnw|j r_|jrz |jIdHWnty}ztd|WYd}~nd}~ww|jr|jz|jIdHWn t j yYnwd|_WdSty}ztd|WYd}~dSd}~ww)z+Cleanup call session and release resources.u"🧹 Starting cleanup for session rrNz$Error closing ElevenLabs WebSocket: Fu❌ Error cleaning up: )r rErrrrr#rrr rr$r"r get_nowaitr QueueEmptyrcloserLrMrr:)rFrel_errorrNrGrGrHcleanups\        zCallSession.cleanupcCs|j|j|j|j|jdS)z(Get current status of this call session.rr.r/r:rArryrGrGrH get_statuss zCallSession.get_status)rJN)F)!r __module__ __qualname____doc__rrrIboolrOrr[rWrrrXrrbytesrrrrrrrrrrrrrrrrGrGrGrHrs82"   b &&o,73  =3r)rr rrrtypingrrrrfastapirfastapi.websocketsrconfigr services.log_utilsr services.connection_managerr services.audio_servicer "services.bot_configuration_servicer rrGrGrGrHs