iddlZddlZddlZddlZddlmZddlmZddlZddl m Z m Z ddl m Z ddlmZddlmZddlmZdd lmZdd lmZmZdd lmZmZmZmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%dd l&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-m.Z.dZ/dZ0dZ1dZ2dZ3dZ4ejjdZ6dZ7de8e9e9ffdZ:eGddZ;dpde9dzdeddd d!d"ed#ee8e9eIfdzde)dzfd?ZJd"ed2e9d6e9dzde?fd@ZKdeIde]+?\|>Zreturnclt}ddi}|jxsdj}|r||d<|S)N Content-Typeapplication/jsonzX-Internal-API-Token)r llm_proxy_internal_tokenstrip)settingsheaderstokens 8PRENOTAZIONI_IA/backend/app/services/whatsapp_service.pybuild_internal_llm_headersr0+s@~H12G  . . 4" ; ; =E */&' NcBeZdZUeed<eed<edzed<edzed<y)WhatsAppGraphConfigurationvenuer,N access_tokenphone_number_id)__name__ __module__ __qualname__r __annotations__r strr1r/r3r34s! L""*4Zr1r3valuevisible_digitsc|syt||krdt|zSdtt||z dz|| dS)N*)lenmax)r=r>s r/ mask_valuerD<sS  5z^#SZCE ^3Q77 8?O9P8Q RRr1c|j}|sttjd|j d}dj d|D}t |dkrttjd|rd|S|S)NzNumero di telefono non valido status_codedetail+r)c3BK|]}|js|ywN)isdigit).0 characters r/ z)normalize_phone_number..JsO99;L;L;NYOs)r+rrHTTP_422_UNPROCESSABLE_ENTITY startswithjoinrB)r=trimmedhas_plusdigitss r/normalize_phone_numberrWDszkkmG (L(LUtuu!!#&H WWOO OF 6{Q(L(LUtuu#Qvh<//r1F)venue_idr6strict_phone_number_matchdbrXr6rYc |r|j}|rtttj ttj tj k(jtj|k(jd}|j|j}|(|\}}t||t||t||St||} | -| d| d}}t||t||t||S|r t!dt#||\}} t|| t| |t| |S)N)r4r,r5r6)expected_phone_number_idrz3Nessun locale associato al phone_number_id ricevutorX)r+rr r rSidrXwherewhatsapp_phone_number_idlimitexecutefirstr3rrr ValueErrorr) rZrXr6rYnormalized_phone_number_idstmtrowr,r4adopted_configurationbooking_settingss r/get_whatsapp_configurationrkPsZ%4%:%:%<" %+U3eUXX)=)F)FFG+DDHbbcq  **T"((*C"%%1%!DXu!U$J8UZ$[  %H)C% !%0"7":?OQVW  r1r^c .t}t||}t|jxr|jxr |j }|j jdt}t|j|j}|r|sdn|rt|jrdnd}tdid|jjd|jjd|d t!|jd |jxsd d |jj"xsd d |jj$xsd d|jj&xsdd|jj(xsddt|jdtt+|jdtt-|jd|dt|j dt|j.d|j0dtd|d|S)NrZrX/z8Configurazione WhatsApp pronta per invio test e webhook.zLinea operativa, ma sta ancora usando un fallback legacy globale. Salva i dati direttamente nel locale per completare la migrazione.zPCompleta token, phone number id o verify token per attivare la linea del locale.rX venue_name configuredphone_number_id_maskedr6r)business_account_id business_iddisplay_phone_number verified_nameaccess_token_configuredphone_number_id_savedaccess_token_saveduses_global_fallbackverify_token_configuredapp_secret_configuredgraph_api_version webhook_path webhook_urlmessager<)r rkboolr5r6whatsapp_verify_tokenpublic_base_urlrstrip WEBHOOK_PATHrr,r4rrr_namerDwhatsapp_business_account_idwhatsapp_business_idwhatsapp_display_phone_numberwhatsapp_verified_namerrwhatsapp_app_secretwhatsapp_graph_api_version)rZrXr,graph_configurationrpr~using_global_fallbackrs r/get_whatsapp_statusrsJ~H4XN)66B;N;^;^BckdBdBCJ--44S9:<.IK9:M:V:VXkXqXqr 3 CEFYF_F_` Sc   " $**-- &,,11   **=*M*MN   ,;;Ar   088UU[Y[  (00EEK 199WW_[_ *22IIQT !%%8%E%E F ##EFYFbFb#cd  ?@S@\@\ ]^ 3 !%X%C%C D #8#?#?@  #==! ""# $ % &' r1cg}t||}|js|jd|js|jd|r-t t j ddj||S)Nrmwhatsapp_access_tokenraz2Configurazione WhatsApp incompleta per il locale: z, rF)rkr5appendr6rrHTTP_400_BAD_REQUESTrS)rZrXmissing configurations r/require_graph_api_configurationrsuG."xHM  % %./  ( (1233G RYHZG[\   r1cht}|jsttjd|S)Nz9Configurazione WhatsApp incompleta: WHATSAPP_VERIFY_TOKENrF)r rrrr)r,s r/require_webhook_configurationrs2~H  ) )33N   Or1pathct}|jjdd|jd|j dS)Nrn)r whatsapp_api_base_urlrrlstrip)rr,s r/build_graph_urlrsH~H,,33C8 98;^;^:__`aealalmpaq`r ssr1responsec |j}t |t r|j dnd}t |t re|j dxsd}|j d}|j d}djd|||fD}|xsd|jS|jxsd|jS#t$r |jxsd|jcYSwxYw) NzErrore Graph API errorrzErrore Graph APIcodetypez - c3<K|]}|dvst|yw))Nr)N)r;)rMparts r/rOz&extract_graph_error..si4RV^hRhSYis )jsonretextrG isinstancedictgetrS)rpayloadrrr error_typedetailss r/extract_graph_errorrsK--/%/w$=GKK 4E%))I&<*<yy YYv& **iJg3NiiD-h.B.B-CDD == F/0D0D/EFF K}}J"3H4H4H3I JJKsC&C0/C0fallback_prefixc |j}d}t|tr|jd}t|tr?t |jdxs|jdxsdj }|s?t |jdxs|jdxsdj }|stj |d} dj|jdd}|r|d |S|d |jd S#t$r|jj }YbwxYw) Nr)rrrHT) ensure_ascii : z ()) rrrrr;r+dumpsrerrSsplitrG)rrrrH error_payloads r/extract_http_errorrs# <--/ gt $#KK0M-.]..y9^]=N=Nx=X^\^_eegW[[2Rgkk)6LRPRSYY[ZZd;F XXflln %ds +F !""VH-- b!5!5 6a 88! '$$&'sD#EE)rX contact_phone wa_message_id event_typesummaryrrrcjt||||||}|j||j|S)N)rXrrrrr)raddflush)rZrrrrXrr log_entrys r/create_log_entryrs=!## IFF9HHJ r1)assistant_routeassistant_modelsource_wa_message_idtracerolecontentrrrrc |dk(r t|ndj|j} | j} | syt |||| ||||xsi} |j | |j | S)N assistantr)rXrrrrrrr)!normalize_assistant_reply_contentrSrr+rrr) rZrXrrrrrrrnormalized_contentturns r/create_assistant_turnrsHL{GZ:7C`c`h`hipivivix`y+113  # "''1kr DFF4LHHJ Kr1c|syttjjtj|k(tj |k(j d}|j|duS)NFr\)rrr_r`rrrbscalar)rZrrrgs r/ has_event_logr!s_ ""# **j8:J:X:X\i:i j q 99T?$ &&r1ct|tr|St|tr*|jr t|jSy#t$rYywxYwrK)rintr;r+re)r=s r/parse_unix_timestampr,sR% %%++- u{{}% %   sA AAcT|jttjtjt k(tj |k(tj|k(jtjjtjjjd}d}|D]c}t|jtr |jni}t!t|tr|j#dnd}|Z|||kDsb|}e|S)N timestamp)scalarsrrr`rINBOUND_MESSAGE_EVENTrXrorder_by created_atdescr_rbrrrrr)rZrXr recent_logslatest_timestamprr candidates r/latest_inbound_timestampr7s**   ' '+@ @  % % 1  * *m ; "--2246F6I6I6N6N6P Q r K$( ) '1)2C2CT'J)##PR(ZPWY]E^[)Adhi     #y3C'C(  ) r1rct|jd}|yt|||}|d|dfS||tz k}|||fS)Nr)FNN)rZrXrF)rrrSTALE_INBOUND_GRACE_SECONDS)rZrXrrincoming_timestampris_stales r/is_stale_inbound_messagerMsc-gkk+.FG! /2Xef($..!%58S%STH ')9 99r1c|jddk7ry|jdijd}t|tsy|j}|xsdS)Nrrbody)rrr;r+)r text_bodycleaneds r/extract_message_textrXsT{{6f$ FB'++F3I i %ooG ?dr1c\|jd}t|tsyt|S)Nassistant_reply)rrr;r)rreplys r/extract_logged_replyrbs) KK) *E eS ! ,U 33r1c@t}ttjtj|k(tj |k(j tjjtjjjt|jdzd}t|j|}|rYt|Dcgc]5}|j dvr%|j"r|j |j"d7}}||j dStt$jt$j|k(t$j |k(t$j&j)t*t,gj t$jjt$jjjt|jdzd}t|j|} g}t| D][} | j&t*k(rt/| j0} d} nt3| j0} d} | sH|j5| | d]||j dScc}w)N>userrrrrr)r rrr`rXrrrrr_rbrCassistant_history_limitlistrreversedrrrrin_rOUTBOUND_AGENT_EVENTrrrr) rZrrXr, turn_stmtturnsrhistoryrglogsrrrs r/build_conversation_historyris2~H$%  ! * *h 6 ! / /= @  '22779;P;S;S;X;X;Z [ s833a7; < I& 'E ! yy11dllYY4<< 8  888:;;    % % 1  * *m ;  ' ' + +-BDX,Y Z "--2246F6I6I6N6N6P Q s833a7; <   4 !D$&Gd^ ;   #8 8*9+<+<=GD*9+<+<=GD 9: ; H4446 77C s#:J)rbrbc @t|jttj tj |k(j tjjtjjjt|dzd}g}i}|D]}|j|j}|at||k\r/|jd|j|j|j ddd}|||j<|j#|t%|ddz|d<|jdk(r|ds|j |d<|jd k(s|d r|j |d <|r|St|jtt&j t&j |k(t&jj)dt&j*j-t.t0gj t&jjt&jjjt|d zd }g} t3} |D]} t5| jxsd j7} | r| | vr2t9| j:t<r | j:ni} | j*t.k(r t?| n tA| }| j#| d| j| j*t.k(rdnd || j*t.k(r|nd| j*t0k(r|ndd| jC| t| |k\s| S| S)Nxr)r turn_count last_turn_at last_role last_messagelast_user_messagelast_assistant_messagerr\rrrrrPr))"rrrrr`rXrrrr_rbrCrrrBrrrrris_notrrrrsetr;r+rrrrrr)rZrXrbrgrouped by_contactrentryrfallback_grouped fallback_seenrrrrs r/list_whatsapp_conversationsrs9  ( ) U(11X= > X+66;;=?T?W?W?\?\?^ _ U3urz3' (   E(*G/1J;t112 =7|u$!%!3!3 $!YY $ %)*.E.3Jt)) * NN5 !!% "56:l 99 u-@'A)-E% & 99 #E2J,K.2llE* ++;. # $ U ))X5 ..55d; ++//1FH\0]^ X&11668:J:M:M:R:R:T U U3urz2& '  K13!eM  I339r:@@B   > '1)2C2CT'J)##PR8A8L8LPe8e+G4kAHlI !. ) 4 4'0';';?T'TVZe ,5>5I5IMb5b\hl:C:N:NRf:f,lp   -(  E )  )( r1<c xt|}t|jttj tj |k(tj|k(jtjjtjjj|SrK) rWrrrrr`rXrrrrr_rb)rZrXrrbnormalized_phones r/list_whatsapp_assistant_turnsrs.m<  ( ) U%..(:%337GGX+66;;=?T?W?W?\?\?^ _ U5\   r1 conversationcg}|ddD]}t|tst|jdxsdj }dj t|jdxsdj }|r|s|j|t|dkr|n|dddd t||d S) Nirr)rrz...r)countrecent) rrr;rr+rSrrrB)rrecent_messagesr rrs r/summarize_conversation_historyrsObc"  %& 599V$*+113((3uyy39r:@@BC7 &)'lc&97'$3-PS?T    \"! r1rc&t}|jddj}t|jd}t ||kr|S|d|dz j }d|vr#|jdddj }|dS)N  r\rru…)r replacer+rCassistant_reply_max_charsrBrrsplit)rr,r max_chars truncateds r/trim_reply_for_whatsappr$s~HmmFD)//1GH66 FF:r95 !#OC Y%7%7%<y) NN3 E //# C {sbyS5[US1W- ? *  " "8 ,)' ZZ/F fd #jj+G'3'GMMO}}&' ##   sE  EEc|jddj}|syt|}|r|}d|vr2|jdddj}t|}|r|}tj d|j}|syt|}|r|}tj d|j}|r|j dry|S)Nrrz <|message|>r\r)z{"role")rr+r7rCONTROL_TOKEN_PATTERNr+rR)rr json_contentnested_json_contents r/rr<smmFD)//1G 4W=L-- q1!4::<?H )G#''G4::r?s r/build_whatsapp_unclear_replyrDhsN%2,,.L!'')!, zl#O O  Kr1 recipientrct}t|}t|}|jr |jst t jdt|jd}dd|dd|dd }tj|j 5}|j|d |jd d |} ddd jdk\r)t| } t t jd| | j!} d} t#| t$r| j'dnd} t#| t(r(| r&| d}t#|t$r|j'd} ||| | fS#1swYxYw)Nz0Configurazione WhatsApp incompleta per il localerFz /messageswhatsapp individualrF) preview_urlr)messaging_productrecipient_typetorrtimeoutBearer r() Authorizationr'r-rrzInvio WhatsApp fallito: messagesrr_)r rWr$r6r5rrrrhttpxClientwhatsapp_timeout_secondspostrGrHTTP_502_BAD_GATEWAYrrrrr)rErrr,normalized_recipient clean_messageendpoint request_bodyclientr error_detailr message_idrR first_messages r/deliver_whatsapp_text_messager`vsx ~H1)<+G4M  ( ( 0J0J(C(CL~-"?"?!@ JKH'&" ! L h?? @ F;; #*=+E+E*F!G 2   s"*84 (C(CNfgsftLuvvmmoGJ*4Wd*Cw{{:&H(D!h  mT *&**40J w BB-  s %E//E8ct} t||\}}|jjdd}t|j|jxsd} t} dd| dd| dg|d |di} tj|j 5} | j!|t#| } ddd j$d k\r't'| d }ttj || j)}d}t+|t,r|j/dnd}t+|t,r}|j/d}t+|t0r\|rZ|d}t+|t,rE|j/d}t+|t,r|j/d}|s|j/d}t+|t r|j3sttj dt5|}|sttj dt7|t |xsdfS#t$r*}ttj t ||d}~wwxYw#1swYxYw)Nr^rFrn/llm/openai/chat/completionsr)rRsystemrrrMrQrzAssistente non disponibilemodelchoicesrrrrz)Assistente privo di risposta utilizzabilez0Assistente privo di risposta pulita utilizzabile)r rrerrrWr;assistant_api_base_urlrrrwhatsapp_assistant_promptrrSrTassistant_timeout_secondsrVr0rGrrrrrrr+rr$)rrrZrXr,r4rjexcrZ system_prompttime_context_promptr[r\rrHrrrdre first_choicemessage_payloadnormalized_replys r/request_assistant_replyrosL~H_"6rH"M1188=>>Z[H3EJJ@P@j@j@pnpqM;=- 8*= >   0  L h@@ A V;; .0  s"#H.JK(C(CFSSmmoG E$.w$=GKK 4E'4 ++i( gt $"1:L,-"."2"29"=ot4+// :E(,,V4E eS !(C(CLwxx8? (C(CL~ "#3 4c%+26F FF[ _(C(CCPSHU[^^_  s#H5I+5 I(>%I##I(+I5ct|} t||\}}|jxsdj }|s|dfSt }|j jdd}t|j|} t} d} dd| dd| dd| dd d |dgd } tj|j 5} | j|t| }dddj"dk\r|dfS|j%}d}t'|t(r|j+dnd}t'|t(r}|j+d}t'|t,r\|rZ|d}t'|t(rE|j+d}t'|t(r|j+d}|s|j+d}t'|t.r|j s|dfSt1|}|s|dfSt|t/|xsdfS#t$r|dfcYSwxYw#1swYAxYw#tj $r|dfcYSwxYw)Nr^r)rnrbaRiceverai un messaggio prenotazioni gia verificato dal sistema. Riscrivilo applicando le istruzioni del locale, ma senza alterare alcun fatto operativo. Mantieni invariati disponibilita, stato della prenotazione, data, ora, durata, numero di persone, area, nome cliente, alternative proposte e call to action. Puoi pero riformulare la durata con un'unita di misura equivalente, per esempio da 120 minuti a 2 ore, se le istruzioni del locale lo richiedono. Se un'istruzione locale puo essere applicata solo cambiando la formulazione, fallo. Se richiederebbe di inventare o cambiare i fatti, ignorala. Restituisci solo il testo finale del messaggio da inviare al cliente.rrcrrz3Riscrivi questo messaggio senza cambiare i fatti: ) temperaturerRrMrQrrdrerrr)r$rrergr+r rfrrrrrSrTrhrVr0 HTTPErrorrGrrrrrr;r)rrZrX base_replyr4rj custom_promptr,rZrjrkrewrite_guardrailsr[r\rrrewritten_replyrdrerlrmrns r/maybe_personalize_booking_replyrwsj )/J "6rH"M&??E2LLNM 4~H1188=>>Z[H3EJJ NM;= P- 8*= >*< =*_`j_k(l m  L \\("D"D E {{24!#H s"4mmoGO$.w$=GKK 4E'4 ++i( gt $"1:L,-"."2"29"=ot4&5&9&9)&DO&&2&6&6v&>O os +?3H3H3J48I 4 "#3 4c%+26F FFE  4 B   ?? 4 s;H $ H-H !H- HH H*%H--IIsenderc4t|}|syd}t}d} d|t||jdd} t |} t ||} t || |||| jj} | | j}t| j||\}}| j}| j} | j| jxsi| | d<t|| d <|rN|d |}|| d <nAt!|rt#|}t}d } d}| | d<nt%||||\}}d } d}| | d<t1||| \}}}}t-|t2d||jd||r||k7r|nd|| | ||d|||t5|||d|| |||  y#t&$r}t)|}t}d} |}| | d<|j*| d<t-|t.d|d|j*|jd|||j*|| d|||jdYd}~d}~wwxYw#t&$r^}t-|t.d|d|j*|jd|||j*| d|||jdYd}~yd}~wwxYw)Nr#rGr_)surface incoming_textrsource_message_idrm)rZ sender_phoner<r{rXturn_duration_minutesr^route personalizedz+prompt:personalization_modelz greeting-onlyz llm-freeformzfallback-unclearr]zAssistente in fallback verso r)r|incoming_messagerrHfallback_replyassistant_tracerZrrrrXrrrzRisposta agente non inviata a )r|rrrHrzRisposta agente inviata a )r|rassistant_base_replyrrrrequestrr) rZrXrrrrrrr)rDETERMINISTIC_WHATSAPP_MODELrrrWrr r,r~rrwrrupdaterrr rBrorrDrHrASSISTANT_ERROR_EVENTr`rr)rZrXrxr<rrr{rrrrnormalized_senderrbooking_resultrrrirEr[response_payloadreply_message_ids r/reply_to_inbound_text_messager.s?)1M '+2O.O&6|D$[[. *O R26:=hW9 9.'+!&9&B&B&X&X N)'5';';$9X"((%:6!6 #1"@"@"0"6"6&&~';';'ArB+:(267L2M/()8(9BWAX&YO?TO$;<)-8"? "L">"1'+$+:(3J=Zfhju}3~0"0'+$+:(0Gd  -G C H(#H0(H--H00 J9AJJc t||}t|jd}tjt j 5}|j|dd|ji}dddjdk\r)t|}ttjd| |j}d }t|jd xsd j!|j"_t|jd xsd j!|j"_t)|d|||j*j,|jd |j/t1d|jxsd |jd |jd |S#1swYJxYw)Nrmz*?fields=display_phone_number,verified_namerMrPrO)r-rz!Verifica token WhatsApp fallita: rFzConnessione a Meta riuscita.rtr)ruconfig_validationrZrrrrXrT)successr6rtrurH)rrr6rSrTr rUrr5rGrrrrWrr;r+r,rrrr4r_commitr)rZrXrrZr\rrHrs r/validate_whatsapp_configrs3rHMM-"?"?!@@jklH lnEE F &:: $ 0J0J/K&LM  s"$X.(C(CNopvowLxyymmoG +F;>w{{Ka?b?hfh;i;o;o;qM847 O8T8ZXZ4[4a4a4cM1 &$$''kk"89 IIK +%55;$[[)?@kk/2  /  s #F99GrLc |j}t||} t|||\}}}} t |dd|||d |jj|| |jtd || d S#t$rg} t |t d|d| j ||| j d|jjt||j| d} ~ wwxYw)NrmrzInvio test fallito verso r)rLrrHr outbound_testzMessaggio test inviato a )rrrTz%Messaggio test inviato correttamente.)rrEr^rH) r+rr`rrOUTBOUND_ERROR_EVENTrHr4r_rWrr) rLrrZrXrYrrEr[rr^ris r/send_test_whatsapp_messagersMMOM3rHMM7T  '8 4 <*" "+I;7(g>$$'' IIK #6  -  +/t2cjj\B-3::N"((++04     sA== C-A"C((C-mode verify_token challengec|t}|dk7s||jk7s|ttjd|S)N subscribez!Verifica webhook WhatsApp fallitarF)rrrrHTTP_403_FORBIDDEN)rrrr,s r/verify_webhook_handshakers?,.H {lh.L.LLPYPa(A(AJmnn r1r signaturect}|js(|jrttj dy|sttj ddtj|jjd|tjjz}tj||sttj dy)Nz#WHATSAPP_APP_SECRET non configuratorFzFirma webhook WhatsApp mancantezsha256=utf-8z!Firma webhook WhatsApp non valida)r r is_productionrrHTTP_503_SERVICE_UNAVAILABLEHTTP_401_UNAUTHORIZEDhmacnewencodehashlibsha256 hexdigestcompare_digest)rrr,expecteds r/validate_webhook_signaturer s~H  ' '  ! !"??<   444  488H$@$@$G$G$PRVX_XfXfgqqssH   x 3446   4r1contacts_by_wa_idc(|jd}|j|xsd|xsd}|jdxsd}|dk(rB|jdijdxsd}d|d |dd j}||fSd |d |}||fS) Nfromr) sconosciutorunknownrrzMessaggio in arrivo da rz Messaggio z in arrivo da )rr+)rrrxr< message_typerrs r/summarize_incoming_messager s [[ F#'' "f6M NK;;v&3)LvKK+//7=2 +K=9Tc?:KLRRT F?|nN;-H F?r1 status_itemcn|jd}|jdxsd}d|xsdd|}||fS)N recipient_idrrzAggiornamento messaggio verso rr)r)rrEdelivery_statusrs r/summarize_status_updater-sG/I!ooh/<9O.y/IM.J"_L]^G I r1c d}|jd}t|ts t|dd||j y|D]}t|t s|jdgD]}t|t s|jdi}t|t s8|jd i}t|t r|jd nd}d} t|t r|jr t||d } |jd g} | D cic]d} t| t rR| jdrA| jd| jdijd| jdf} } |jdg} | D]$}t|t st|t|jdr7t|}t|| \}}| j|xsd|xsd}|r t||nd}|r&t||r||k7r|n||}||j }n|r|}|rp|rn| lt#|| j$j&||\}}}|rCt|dd||||d| j$j&||jd|dz }t|t||| | j$j&nd||jd|r<|r:| 8t)|| j$j&|d||jdddd |dz }|rR|rP| Nt+||| j$j&!}t-|| j$j&||||"|dz }|s|s| t|t.d#||d$||jd%|dz }'|jd&g}|D]_}t|t st1|\}}t|d'||| | j$j&nd||jd|dz }a|dk(rt|dd(|d}|j |S#t$rd} YowxYwcc} w))Nrr webhook_unknownzWebhook WhatsApp senza entry)rZrrrr\changesr=metadatar6T)rZr6rYcontactswa_idprofilerrRr_)rrr)r)phoner@rZ)rZrXrrinbound_ignoredzHMessaggio WhatsApp ignorato perche piu vecchio del contesto attuale per )rrlatest_processed_timestamprrrGzinbound-webhook)rzsource)rZrXrrrrr)rrX)rZrXrxr<rrzFMessaggio WhatsApp ricevuto su una linea non associata a nessun locale)rr6)rZrrrrrstatusesrz0Webhook WhatsApp ricevuto senza messaggi o stati)rrrrrrr;r+rkrerrrrrrr@rr4r_rrrrr)rrZprocessed_eventsentriesr changer=rr6venue_configurationrcontactrrRr message_textrrxr<stored_contact_nameremembered_contact stale_messagerrrrrrEs r/process_webhook_payloadr4skk'"G gt $B+N% &9%>%>%A%A*0*1++d*; )A-(  4##=P=\06699bf"(")++d"3l/B/N)!4!:!:!=!=&,# ,-4[[->*4@QR!A% l/B/N#=&,!4!:!:!=!=$L 2!4!:!:!=!=%$/ '%1 %)$ 1D1L$#8 h,3 X&,&-kk$&7 %)$uZ *xyyR0H' & !+t4%<[%I" 0#'=P=\06699bf"+"-//$"7!A%  &qE &H&T1(F  IIK C"/*.'/!s=Q,!A)Q>, Q;:Q;c(|siS tj|jd}t|tst t jd|S#ttjf$r!}t t jd|d}~wwxYw)Nrz#Payload webhook WhatsApp non validorF) rr/decodeUnicodeDecodeErrorr0rrrrr)rrris r/parse_webhook_bodyrs  |**T[[12 gt $(C(CLqrr N  4 4 5|(C(CLqrx{{|s$AB0B  BcNttjtjj tj j }|"|j tj|k(}|j|}t|j|SrK) rrrrrr_r`rXrbrr)rZrbrXrgs r/list_whatsapp_logsrs| " # , ,-=-H-H-M-M-OQaQdQdQiQiQk lDzz*33x?@ ::e D  4 !!r1)rA)2)jrrrr* dataclassesrtypingrrSfastapirr sqlalchemyrsqlalchemy.ormrapp.core.configr app.models.bookingr app.models.venuer &app.services.booking_assistant_servicer r %app.services.booking_settings_servicerrrrrrrrr%app.services.whatsapp_contact_servicerr!app.services.time_context_servicerapp.models.whatsapprrapp.schemas.whatsapprrrrrrrrrcompiler9rrr;r0r3rrDrWrrkrrrrResponserrrobjectrrrrtuplerrrrrrrrr$r7rrBrDr`rorwrrrrbytesrrrrrrr<r1r/rs ! )"(3"i   mOGss# )'')7" ?3 DcN     ScDjS#ScDjS 0# 0# 0 "&&+ ..Dj.4Z . $ .  .b@D#w##*#H^#LLP 7 cDj Tn st#t#t G%.. GS G99#9#98 $ $    Dj ::<#'"&'+&*     4Z4Z* V t #T!@'g'c'#*'QU'3:Gs3SVY]S],:G:s:3:Y]:bghlnqtxnxz}AE{EiEcF:$3:4$43:4.87.8c.8S.8UYZ^_bdg_gZhUi.8bMOGwG#GcGSWX\]`bh]hXiSjG^       *d38n1E$sTZ{J[* 3 3 d BSS4Z< sTz c  cDj S -C-C -C. -C  3dC$J &' -C`7G 7GtCH~&7G 7G  7G  38_ 7GtKG KGKG KG  3d ? KG\FFF  F t F  FtCH~&F FREI!!sTz!Mm!H^b$3$$'$PSVZPZ$f~$N3:S4ZTWZ^T^cf U sTz d .  c3h TYZ]_bei_iZiTj %S4Z2H\T\w\3\~ U t "t"7"3"#*"X\]mXn"r1