o bfjm @sUddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl mZ ddl m Z mZddlmZddlmZddlmZdd lmZdd lmZed Zeed d ZeddZeddZedZ de!e"e"ffddZ#de"de"fddZ$eddZ%edd&Z'edddZ(e dd Z)da*e j+dBe,d!<e)-d"dOd#d$Z.e)/d%de0e"effd&d'Z1d(ede2fd)d*Z3dPd,ed-e4de"fd.d/Z5d0e"d1e0e"efde0e"effd2d3Z6e)/d4d(edefd5d6Z7e)/d7d(edefd8d9Z8e)9ed(edefd:d;Z:dOdd(ed?e4dBd@e4dBdefdAdBZe)9ed(edefdLdMZ?e@dNkroe;dSdS)QN)Any)urlparse)FastAPIRequest) JSONResponse)load_agent_runtime_dotenv)'get_runtime_overrides_from_agents_table)get_default_mcube_call_config)configure_mcube_file_loggingz mcube.webhook REDIS_URLzredis://localhost:6379/0MCUBE_WEBHOOK_PATHz/webhooks/mcubeMCUBE_OUTBOUND_PATHz/api/mcube/outbound-call/returncCs.ttdd}tdd}||fS)z Re-read backend/.env on each outbound call so ngrok URL updates apply without restarting the webhook (stale MCUBE_PUBLIC_* was causing Mcube to open WSS to an old tunnel). MCUBE_PUBLIC_BASE_URLMCUBE_PUBLIC_WS_URL_BASE)rosgetenvstrip)basewssrY/var/www/html/livekitdocker/backend/agent_runtime/src/mcube_integration/webhook_server.py_mcube_public_urlssrurlcCs>|pd}|s dSz t|jpdWStyYdSwNr)rrnetloclower Exception)rurrr _url_netloc(s  r"MCUBE_WS_PATH_PREFIXz/bid/websocketMCUBE_WS_BUSINESS_IDrAGENT_BACKEND_BASE_URLzhttp://localhost:8000zMCube Webhook Receiver)title_redisstartupcs.tjtddatIdHtdtdS)NF)decode_responsesz$mcube webhook: connected to redis %s) redis_asyncfrom_urlr r'pingloginforrrr_startup<sr/z/healthcs ddiS)NstatusokrrrrrhealthEsr2requestcCs2tdd}|s dS|jdd}||kS)ue Protect /api/mcube/inspect/* — set MCUBE_INSPECT_KEY and send header X-Mcube-Inspect-Key. MCUBE_INSPECT_KEYrFzX-Mcube-Inspect-Key)rrrheadersget)r3expectedgotrrr_inspect_authorizedJs r9val max_charscCsX|durdSt|dddd}|dd}t||kr"|S|d|ddS)Nr\n z  ru…)strreplacerlen)r;r<srrr_preview_cfg_fieldUs rDcall_idcfgcCs|d}t|tr|dd}|dpd}||d|d|d|d |d |d |d |d |d|dt|dt|dd S)N system_promptr=r> first_messager business_idbot_idagent_id agent_nameuser_id agent_email llm_model llm_provider stt_provider tts_providerr:) rErIrJrKrLrMrNrOrPrQrRsystem_prompt_previewfirst_message_preview)r6 isinstancer@rArrD)rErFspfmrrr_summarize_stored_config_s$   rXz/api/mcube/inspect/activec st|stddddddSt}|dusJttdd }td td |}g}d }z~|jd d2zt3dHW}||kr>nj|d 7}t |t t frP|j dddnt |}z6||IdH}|si||ddWq2t |t t frw|j dddnt |}t|} || d<|| Wq2ty} z||t | dWYd} ~ q2d} ~ ww6Wn"ty} ztdtdt | dddWYd} ~ Sd} ~ wwtdt||dS)z Live PSTN legs where MCube sent `start` and we loaded Redis config (mcube_ws_active:*). Requires X-Mcube-Inspect-Key matching MCUBE_INSPECT_KEY. F unauthorized2Set MCUBE_INSPECT_KEY and send X-Mcube-Inspect-Keyr1errorhint status_codeNMCUBE_INSPECT_MAX_KEYS200rrzmcube_ws_active:*matchutf-8rAerrorsempty) redis_keyr\rjzinspect active failedr1r\T)r1countactive)r9rr'intrrmaxmin scan_iterrUbytes bytearraydecoder@r6appendjsonloadsr r- exceptionrB) r3redismax_krowsnkeyksrawraw_strpayloaderrrinspect_active_mcube_sessionsusN  $$   "rz /api/mcube/inspect/redis-configsc st|stddddddSt}|dusJttdd }td td |}g}d }z|jd d2z3dHW}||kr>n|d 7}t |t t frP|j dddnt |}|dd d}zL||IdH}|sr|||ddWq2t |t t fr|j dddnt |} t| } t | ts|||ddWq2t|| } || d<|| Wq2ty} z|||t | dWYd} ~ q2d} ~ ww6Wn"ty} ztdtdt | dddWYd} ~ Sd} ~ wwtdt||dS)u Recent `mcube_call_config:*` blobs written at outbound-call time (TTL ~6h). Useful to see which bot/prompt was stored before MCube connects — compare with /inspect/active when a call is up. FrYrZr[r^r_Nrarbrrcrzmcube_call_config:*rdrfrArgmcube_call_config:ri)rjrEr\ not_a_dictrjzinspect redis-configs failedrkrlT)r1rmstored_configs)r9rr'rorrrprqrrrUrsrtrur@splitr6rvrwrxdictrXr r-ryrB) r3rzr{r|r}r~rsuffixrrrFrowrrrrinspect_redis_call_configssX  $$   " "rc sz|IdH}|dp|dp|d}t|dd}|dd}|dd }|s:td d d d dWSt}|dusBJd|d|}|j|ddddIdH}|s`tdddWS|jd|t|trp|dn|ddIdH|jd|t|t t frt|dnt|dddIdH|jd|t|dddIdH|dv} | r|jd|dddIdHtddiWSt y} zt d td d!t| d"d#dWYd} ~ Sd} ~ ww)$NrEcallIdcallIDr0rdurationr answered_byhumanFzmissing call_idrkr_zmcube_webhook_processed::rT)nxex)r1skippedzmcube_call_status:rfiQrzmcube_call_duration:zmcube_call_answered_by:> no-answerbusyfailedblocked completed voicemail not_answeredzmcube_call_ended:`Tr1zmcube webhook failedmcube_webhook_failed)r1r\detailrl)rwr6r@rrr'setrUencoderofloatr r-ry) r3rcall_sidr0rrrzidem_keyalreadyterminalrrrr mcube_webhooksT    (    rcCsNtjtjdtdddl}tdd}ttdd}|jt ||ddS) N)levelwebhookrMCUBE_WEBHOOK_HOSTz0.0.0.0MCUBE_WEBHOOK_PORT8002)hostport) logging basicConfigINFOr uvicornrrrorunAPP)rrrrrrmains  rpath_business_id path_bot_idrrc: s> ddlm}|IdH}t|dp|dp|dpd|dp1|d p1|d }|d p;|d }|durB|}|durH|}ttd ddtdt tt fffdd dt dt dt tt fffdd }t|dp{tdd}s| ds| dr| dddd d} z| d} | | dWn tyYnw|dp|dpd} | std d!d"d#d$Sdt tt fffd%d& } t} t| |||IdH\}}td't| d(t|pit|pit|d)p|d*p|}| }|d+}|d,}|d-p)|d-}|d.p4|d.}|d/vr>t|n t|pGtd0d}|d/vrTt|n t|p]td1d2}t|d3p|d4p|d5p|d6p|d7p|jd3p|jd7ptd3dptd8d}tdusJt}d9t dt fd:d;}t |}|D]}|||||||||<q|d/vrezt|}Wn tyd}Ynw|duretjt||d<p|d=|d>p|d?|d@p |dA|dp|ddBIdH}|D] \}} | r,| ||<q!dCD]4}!|||!||!||!t|t rJ||!nd}"|"durct|"tr_|"dkrc|"||!<q0|dD}#t|#trv|# dEdF}#||#|dDp|dD|dD<||dG|dH|dGpd|dG<dID]}|||||p||||<qdJt dt!fdKdL}$|$|r||d<|$|r||d <dMD]}||}%|%durt|%tr|%dkr|%||<q|d@durt|d@pddkrt|d@|dA<|dAdur3t|dAp!ddkr3t|dA|dA<|r9|sXtj"dN|t#|$dOdPdQIdHtdR|ddSdTdRdUSddVl%m&}&|&|dW}'t'\}(})t(|(}*t(|)}+|dXp}|dYp}d},|,r|*rt(|,|*krt)dZt(|,|*d},|,p|(r|(*dt+nd}-|)r|)*dnd}.t,pt|d[p|d\pd}/|d]p|d^pd}0|0r|+rt(|0|+krt)d_t(|0|+d}0|0}1|1s|.r|/rt|/-r|.d|/d`|}1n |.t.d|}1|1rF|pd}2|2r+|2 dar.|1}nt(|2}3|+rF|3rF|3|+krFt)db|3|+|1}t#|$dO}4tj"dN||4dPdQIdHtdc|t| d(z|'j/||||||-pud|1pydddIdH}5Wn&ty}6zt0de|td df|t|6dgdhd$WYd}6~6Sd}6~6wwtj"dN||4dPdQIdH|5j1rtj"dN|5j1|4dPdQIdHt|5j2pd3}7|5j1pd}8dR||8|5j2|-|1|di}9|8dur|7rdj|7vrdk|9dl<t|9S|8durdm|9dl<t|9S|7rdj|7vrdn|7vrdo|5j2dp|9dl<t|9S)qa Minimal endpoint to kick off an outbound MCube click-to-call. This integrates with MCube's Restmcube-api/outbound-calls endpoint which expects: - HTTP header: Authorization - JSON body keys: custnumber, exenumber, gid, refurl, refid (as per your doc) URL forms (path overrides business_id / bot_id in JSON when set): - POST /api/mcube/outbound-call/{business_id}/{bot_id} - POST /api/mcube/outbound-call/{bot_id} (legacy: bot in path, business_id in body) - POST /api/mcube/outbound-call (all identifiers in body) Body examples supported: - { "to": "+1555..." , "exenumber": "8700...", "gid": "1", "call_id": "optional" } - or use env defaults for exenumber/gid/auth. r)uuid4NrL agentNameagentrrI businessIdbidrJbotIdAGENT_BACKEND_FETCH_TIMEOUT_Sz15.0namerc s>|siStd|d}tjd}zztj|d4IdHb}||4IdHA}|jdkrMtd||jiWdIdHWdIdHWS|IdHWdIdHWdIdHWS1IdHsowYWdIdHWdS1IdHswYWdSt yt d|iYSw)Nz /api/agents/z/config/totaltimeoutz._fetch_agent_mcube_configbusiness_id_val bot_id_valc s|dvs |dvr iSz t|}t|}Wn ty iYSwtd|d|d}tjd}z{tj|d4IdHc}||4IdHB}|jdkrmt d|||jiWdIdHWdIdHWS| IdHWdIdHWdIdHWS1IdHswYWdIdHWdS1IdHswYWdStyt d ||iYSw) Nrz/api/agents/cluster/bots/rz/mcube-config/rrrzJmcube outbound: cluster bot config fetch failed bid=%s bot_id=%s status=%szAmcube outbound: cluster bot config fetch errored bid=%s bot_id=%s) ror r%rrrr6r0r-rrwry)rrbid_intbot_intrrrrrrr_fetch_cluster_bot_mcube_configIsB     2 z?_outbound_call_handler.._fetch_cluster_bot_mcube_configrefurl MCUBE_REFURLhttp://https://?rr custnumbertoFz$missing 'to' (or 'custnumber') valuerkrr_cs,r tdvriSIdHS)N)defaultr)r@rrr)rrLrr_agent_cfg_wrappedxsz2_outbound_call_handler.._agent_cfg_wrappedzNmcube outbound: django config fetch done ms=%.0f agent_keys=%s cluster_keys=%sg@@refidrE exenumbergidmcube_exenumber mcube_gidrMCUBE_EXENUMBER MCUBE_GID1HTTP_AUTHORIZATIONhttp_authorizationhttpAuthorization authorization AuthorizationMCUBE_HTTP_AUTHORIZATIONvalscWs6|D]}|dur qt|tr|dkrq|SdSrrUr@r)rvrrr_picksz%_outbound_call_handler.._pickrKagentIdrMuserIdemailrN)rKrMrr)message_inboundmessage_outboundplatform_settingsconversation_behaviorrGr=r>rHagent_first_message) rOrPrQstt_language_code stt_model_idrR tts_model tts_voice_id tts_encoding tts_chunk_mstts_gainplayback_pace_factorcheckpoint_everyr;cSs*|durdSt|tr|dkrdSdS)NFrTr)r;rrr _cfg_nonemptys z-_outbound_call_handler.._cfg_nonempty)rKrMrLrrfrrT not_initiatedz)MCube auth token and/or exenumber not set)r1rEmcube_call_sidr0r stored_config) MCubeProvider)r callback_url callbackUrlzZmcube outbound: ignoring stale client callback_url host=%r (MCUBE_PUBLIC_BASE_URL host=%r)mcube_ws_business_idmcubeWsBusinessId websocket_url websocketUrlz^mcube outbound: ignoring stale client websocket_url host=%r (MCUBE_PUBLIC_WS_URL_BASE host=%r)z /websocket/)rrzPmcube outbound: ignoring stale refurl host=%r (MCUBE_PUBLIC_WS_URL_BASE host=%r)zHmcube outbound: calling MCube initiate refid=%s prep_since_fetch_ms=%.0f)rrrrrr r z/mcube outbound: initiate_call failed call_id=%smcube_initiate_call_failed)r1r\rEri)r1rErr0r r  mcube_refurlsucczMCube did not return a call id and status does not look successful; check mcube outbound logs (full response body) and the destination number.rz{MCube did not return a callid in the response; outbound may not have been queued. See mcube.provider logs for the raw body.successzMCube status was z9; confirm in MCube dashboard whether the call was placed.)4uuidrrwr@r6rrrrrr startswithrindexr rtime perf_counterasynciogatherr-r.rBr5r'r keysro to_threadr itemsrUrAboolrdumpsrproviders.mcube_providerrrr"rrstripr r$isdigitr# initiate_callryrr0r):r3rrrbodyrIrJrrpartsidx custnumber_inroutbound_prep_t0 agent_cfgcluster_bot_cfgrrexenumber_bodygid_body exenumber_dbgid_dbrrrdefaultsr call_configkrbiabkbv extra_keyevbody_system_promptrrrproviderpub_basepub_wssexpected_http_hostexpected_wss_hostbody_cbr ws_basebid_wsbody_wsr ruru_hostcfg_blobresultrst mcube_sidrr)rrLrr_outbound_call_handler s  "    "             &    $    (   $..     ""          rFz/{business_id}/{bot_id}rIrJcst|||dIdHS)NrrF)rIrJr3rrroutbound_call_scopedsrHz/{legacy_path_bot_id}legacy_path_bot_idcst||dIdHS)N)rrG)rIr3rrroutbound_call_legacy_path_botsrJcst|IdHS)NrG)r3rrr outbound_callsrK__main__)rN)r:)Arrrwrrrtypingr urllib.parser redis.asyncior*fastapirrfastapi.responsesrenv_loadrbusiness_id_agentsr mcube_defaultsr service_logr getLoggerr-rr r rr MCUBE_OUTBOUND_PATH_BASEtupler@rr"r#rr$r%rr'Redis__annotations__on_eventr/r6rr2rr9rorDrXrrpostrrrFrHrJrK__name__rrrrs                  & ', 4  +