o ÄjÂAã@s”UddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z ddl m Z ddlmZddlmZddlmZe d ¡Zeƒe d d ¡Ze d d ¡Ze dd¡Ze dd¡Ze dd¡Ze dd¡Ze dd¡ d¡Ze ddZda ej!dBe"d<e #d¡d*dd„ƒZ$e %d¡de&e'effd d!„ƒZ(e )e¡d"e de fd#d$„ƒZ*d*d%d&„Z+e )e¡d"e de fd'd(„ƒZ,e-d)krÈe+ƒdSdS)+éN)ÚAny)ÚFastAPIÚRequest)Ú JSONResponseé)Úload_agent_runtime_dotenv)Ú'get_runtime_overrides_from_agents_table)Úget_default_mcube_call_configz mcube.webhookÚ REDIS_URLzredis://127.0.0.1:6379/0ÚMCUBE_WEBHOOK_PATHz/webhooks/mcubeÚMCUBE_OUTBOUND_PATHz/api/mcube/outbound-callÚMCUBE_PUBLIC_BASE_URLÚÚMCUBE_PUBLIC_WS_URL_BASEÚMCUBE_WS_PATH_PREFIXz/bid/websocketÚAGENT_BACKEND_BASE_URLzhttp://127.0.0.1:8000ú/zMCube Webhook Receiver)ÚtitleÚ_redisÚstartupÚreturncÃs.tjtddat ¡IdHt dt¡dS)NF)Údecode_responsesz$mcube webhook: connected to redis %s)Ú redis_asyncÚfrom_urlr rÚpingÚlogÚinfo©rrúY/var/www/html/livekitdocker/backend/agent_runtime/src/mcube_integration/webhook_server.pyÚ_startup's€rz/healthcÃs ddiS)NÚstatusÚokrrrrrÚhealth0s€r"Úrequestc ÃsÔzÅ| ¡IdH}| d¡p| d¡p| d¡}t| dd¡ƒ ¡}| dd¡}| dd ¡}|s:td d d œd dWSt}|dusBJ‚d|›d|›}|j|ddddIdH}|s`tdddœƒWS|jd|›t|tƒrp| d¡n|ddIdH|jd|›t|t t fƒrŒt|ƒ d¡nt|ƒ d¡ddIdH|jd|›t|ƒ d¡ddIdH|dv} | rÀ|jd|›dddIdHtddiƒWSt yé} zt   d ¡td d!t| ƒd"œd#dWYd} ~ Sd} ~ ww)$NÚcall_idÚcallIdÚcallIDr rÚdurationrÚ answered_byÚhumanFzmissing call_id©r!Úerroré©Ú status_codezmcube_webhook_processed:ú:rTé)ÚnxÚex)r!Úskippedzmcube_call_status:úutf-8i€Q©r2zmcube_call_duration:zmcube_call_answered_by:>ú no-answerÚbusyÚfailedÚblockedÚ completedÚ voicemailÚ not_answeredzmcube_call_ended:é`Tr!zmcube webhook failedÚmcube_webhook_failed)r!r+Údetailiô)ÚjsonÚgetÚstrÚlowerrrÚsetÚ isinstanceÚencodeÚintÚfloatÚ ExceptionrÚ exception) r#ÚpayloadÚcall_sidr r'r(ÚredisÚidem_keyÚalreadyÚterminalÚerrrÚ mcube_webhook5sT€    ý( ý  ý þ€þrRcCsFtjtjdddl}t dd¡}tt dd¡ƒ}|jt||ddS)N)ÚlevelrÚMCUBE_WEBHOOK_HOSTz0.0.0.0ÚMCUBE_WEBHOOK_PORTÚ8002)ÚhostÚport) ÚloggingÚ basicConfigÚINFOÚuvicornÚosÚgetenvrGÚrunÚAPP)r\rWrXrrrÚmainjs  rac) Ãs¨ddlm}| ¡IdH}t| d¡p| d¡p| d¡pdƒ ¡}| d¡p1| d ¡p1| d ¡}| d ¡p;| d ¡}d tdtttffdd„}dtdtdtttffdd„}t| d¡pct  dd¡ƒ ¡}|sš|  d¡ss|  d¡rš|  dd¡d d¡  d¡} z|   d¡} | | d ¡}Wn t y™Ynwi} |r¥||ƒIdH} |||ƒIdH} | d¡p¸| d¡p¸d ¡} | sÆtddd œd!d"St| d#¡pÓ| d$¡pÓ|ƒƒ}| }| d%¡}| d&¡}|  d'¡pê|  d'¡}|  d(¡pô|  d(¡}|d)vrýt|ƒn t|pt  d*d¡ƒ ¡}|d)vrt|ƒn t|pt  d+d,¡ƒ ¡}t| d-¡pY| d.¡pY| d/¡pY| d0¡pY| d1¡pY|j d-¡pY|j d1¡pYt  d-d¡pYt  d2d¡ƒ ¡}tdusdJ‚tƒ}d3tdtfd4d5„}t|ƒ}i}d}|d)vrØzt|ƒ}Wn t yd}Ynw|durØtjt|| d6¡p£| d7¡| d8¡p­| d9¡| d:¡p·| d;¡| d¡pÁ| d ¡d<IdH}| ¡D] \}}|rÖ|||<qË| ¡D]}||  |¡|  |¡| |¡ƒ||<qÜ|dur-d=D]4}|| |¡|  |¡|  |¡t|tƒr| |¡ndƒ} | dur+t| tƒr'|  ¡dkr+| ||<qø| d>¡}!t|!tƒr>|! d?d@¡}!||!| d>¡ƒpJ|d>|d><|| dA¡| dB¡| dA¡ƒp^d ¡|dA<dCD]}|| |¡| |¡ƒpv||||<qedDD]}| |¡}"|"duršt|"tƒr–|" ¡dkrš|"||<q}| d:¡dur¾t| d:¡p¬dƒ ¡dkr¾t| d:¡ƒ ¡|d;<| d;¡duràt| d;¡pÎdƒ ¡dkràt| d;¡ƒ ¡|d;<|ræ|stjdE|›t |¡ dF¡dGdHIdHtdI|ddJdKdIdLœƒSddMlm}#|#|dN}$| dO¡p| dP¡pd ¡p+tr*t›t ›nd}%| dQ¡p9| dR¡p9d ¡pJt!rIt!›t"›d|›nd}&|&r_|r]|  d¡s]|  d¡r_|&}z|$j#||||||%pkd|&poddSIdH}'Wn&t yœ}(zt$ %dT|¡tddU|t|(ƒdVœdWd"WYd}(~(Sd}(~(wwtjdE|›t |¡ dF¡dGdHIdHtjdE|'j&›t |¡ dF¡dGdHIdHtdI||'j&|'j'|%|&|dXœƒS)Ya¸ 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) Body examples supported: - { "to": "+1555..." , "exenumber": "8700...", "gid": "1", "call_id": "optional" } - or use env defaults for exenumber/gid/auth. r)Úuuid4NÚ agent_nameÚ agentNameÚagentrÚ business_idÚ businessIdÚbidÚbot_idÚbotIdÚnamerc ÓsB|siSt›d|›d}tt dd¡ƒ}zzt ¡4IdHšd}|j||d4IdHšA}|jdkrOt  d||j¡iWdƒIdHWdƒIdHWS|  ¡IdHWdƒIdHWdƒIdHWS1IdHsqwYWdƒIdHWdS1IdHsˆwYWdSt y t  d|¡iYSw) Nz /api/agents/z/config/ÚAGENT_BACKEND_FETCH_TIMEOUT_Sú5.0©ÚtimeoutéÈz._fetch_agent_mcube_configÚbusiness_id_valÚ bot_id_valc Ós„|dvs |dvr iSz t|ƒ}t|ƒ}Wn ty iYSwt›d|›d|›d}tt dd¡ƒ}z{t ¡4IdHše}|j||d4IdHšB}|j dkrot   d |||j ¡iWdƒIdHWdƒIdHWS|  ¡IdHWdƒIdHWdƒIdHWS1IdHs‘wYWdƒIdHWdS1IdHs¨wYWdStyÁt   d ||¡iYSw) N©Nrz/api/agents/cluster/bots/rz/mcube-config/rlrmrnrpzJmcube outbound: cluster bot config fetch failed bid=%s bot_id=%s status=%szAmcube outbound: cluster bot config fetch errored bid=%s bot_id=%s)rGrIrrHr]r^rqrrrAr rrsr@rJ)ryrzÚbid_intÚbot_intrtrurvrwrrrÚ_fetch_cluster_bot_mcube_config¤sB€  ÿ üøÿ ÷ÿ2ÿ þz6outbound_call.._fetch_cluster_bot_mcube_configÚrefurlÚ MCUBE_REFURLzhttp://zhttps://ú?rrÚ custnumberÚtoFz$missing 'to' (or 'custnumber') valuer*r,r-Úrefidr$Ú exenumberÚgidÚmcube_exenumberÚ mcube_gidr{ÚMCUBE_EXENUMBERÚ MCUBE_GIDÚ1ÚHTTP_AUTHORIZATIONÚhttp_authorizationÚhttpAuthorizationÚ authorizationÚ AuthorizationÚMCUBE_HTTP_AUTHORIZATIONÚvalscWs6|D]}|dur qt|tƒr| ¡dkrq|SdSr{)rErBÚstrip)r’ÚvrrrÚ_pickszoutbound_call.._pickÚagent_idÚagentIdÚuser_idÚuserIdÚemailÚ agent_email)r–r˜ršrk)Úmessage_inboundÚmessage_outboundÚplatform_settingsÚconversation_behaviorÚ system_promptz\nÚ Ú first_messageÚagent_first_message) Ú llm_modelÚ llm_providerÚ stt_providerÚstt_language_codeÚ stt_model_idÚ tts_providerÚ tts_modelÚ tts_voice_idÚ tts_encodingÚ tts_chunk_msÚtts_gainÚplayback_pace_factorÚcheckpoint_every)rfrir–r˜rczmcube_call_config:r4r=r5TÚ not_initiatedz)MCube auth token and/or exenumber not set)r!r$Úmcube_call_sidr rsÚ stored_config)Ú MCubeProvider)rÚ callback_urlÚ callbackUrlÚ websocket_urlÚ websocketUrl)r‚r…r†rr„rµr·z/mcube outbound: initiate_call failed call_id=%sÚmcube_initiate_call_failed)r!r+r$r?iö)r!r$r²r rµr·Ú mcube_refurl)(Úuuidrbr@rBrAr“Údictrr]r^Ú startswithÚsplitÚindexrIrÚheadersrr rGÚasyncioÚ to_threadrÚitemsÚkeysrEÚreplacerDÚdumpsrFÚproviders.mcube_providerr´r r rrÚ initiate_callrrJrLr ))r#rbÚbodyrcrfrirxr~rÚpartsÚidxÚ agent_cfgÚcluster_bot_cfgÚ custnumber_inr„r‚Úexenumber_bodyÚgid_bodyÚ exenumber_dbÚgid_dbr…r†rÚdefaultsr•Ú call_configÚbiar|ÚbkÚbvÚkÚ extra_keyÚevÚbody_system_promptr”r´Úproviderrµr·ÚresultrQrrrÚ outbound_callssˆ€  ÿþüû  ÿþ   ÿý ÿý ÿþýü û ú ù ÷ ö    ÿ  ú€ & ü$€   ýù ( $€..  ýúÿ "þ"ÿû$ù þ€ý  ý  ýùÿrÞÚ__main__)rN).rÁrYr@r]rqÚtypingrÚ redis.asynciorÚfastapirrÚfastapi.responsesrÚenv_loadrÚbusiness_id_agentsrÚmcube_defaultsr Ú getLoggerrr^r r r r rrÚrstriprr`rÚRedisÚ__annotations__Úon_eventrrAr¼rBr"ÚpostrRrarÞÚ__name__rrrrÚsJ                 4 K ÿ