+ kHja0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI t ^RIt^RIt^RIHt^RIHt^RIHtHtHt^RIHtRt^RItRt^R IHtH t ^R I!H"t"^R I#H$t$^R I%H&t&H't'H(t(H)t)^R I*H+t+^RI,H-t-^RI.H/t/H0t0^RI1H2t2H3t3^RI4H5t6^RI7H8t8^RI9H:t:^RI;H4t?Rt@RtARtBRtCRtDRStERtFRtGRRTRRURRURRWRRV/tHRR RR!RR"RR#RR$/tI]P!R%4tKR&R'R(R'R)R'R*R+R,R+R R-/tLR.]MR/&0RXmtN0RYmtO0RZmtPRVtQR1]0PR]0PR]0PR]0PR0]0PR]0PR]0PR2]0PR3]0PR4]0PR5]0P/ tWR[tXR6R7ltYR1R8R2R9R3R:/]NUu/uF qV3R;lbK upCtZR<R=lt[R>R?lt\R@RAlt]RBRClt^RDRElt_]!]rBtsquuV}**//7r6cVVPR4;'g/PR4#)r)r(r:r@s&r4rBrBusx..B33F;r6c6\V4PR4#)title)r=r;r@s&r4rBrBvs/266w?r6cVVPV4;'g/PR4#)captionr:)rAks&&r4rBrBwsqR 4 4Y ?r6c$V^8dQhRRRRRR/#)r.requestr max_bytesintr1bytesr2)r3s"r4r5r5{s!ccer6c"VPPV^,4GRjxL p\ V4V8d \ R4hV#L! \PdpTPpRp?LERp?ii;i5i)z8Read at most ``max_bytes`` from an aiohttp request body.Nzpayload too large)content readexactlyasyncioIncompleteReadErrorpartiallen ValueError)rJrKr?excs&& r4_read_limited_request_bodyrW{sh__00Q?? 4y9,-- K @  & &{{s=A;%A A A A; A A8" A3.A;3A88A;c V^8dQhRRRR/#)r.mimestrr1 Optional[str]r2)r3s"r4r5r5sUUU Ur6c>V'd\V\RRRR7#R#)ugMime → on-disk extension: WhatsApp overrides → mimetypes → None (never the shared default table).FTN) overrides use_defaults use_mimetypesfallback)rr&)rYs&r4 _ext_for_mimeras6GK<(JY^nr~B CUQUUr6cV^8dQhRR/#r.r1boolr2)r3s"r4r5r5srr4rr6c\\RRR7;'gR4P4P4\9#)WHATSAPP_CLOUD_ALLOW_ALL_USERSdefault)rZrstriplower _OPTIN_TRUTHYr2r6r4_cloud_allow_all_opted_inrms5 |R?llt&R@RAlt'RRBRCllt(RDR'RER'RFR'RGR'RHR'/RIRJllt)RFR'RGR'RHR'RKR'/RLRMllt*RRNROllt+RRPRQllt,RRRRSllt-RRTRUllt.RRVRWllt/RXRYlt0RZR[lt1R\R'/R]R^llt2R_R`lt3RaRblt4RcRdlt5ReRflt6RgRhlt7RiRjlt8RkRllt9RmRnlt:RoRplt;] RRqRrll4tRwRxlt?Ry]=Rz]>R{]?/t@R|R}ltA] R~Rl4tBRRltCRtDV;tE#)WhatsAppCloudAdapterzOutbound: Graph ``///messages``; inbound: aiohttp webhook server. The mixin comes first so its ``format_message`` overrides the base one.Trdserves_profile_prefixcV^8dQhRR/#)r.configr r2)r3s"r4r5!WhatsAppCloudAdapter.__annotate__s0000~00r6c <a\SV`V\P4VP;'g/oV3RlR4wVnVnVnVnVn Vn \SPR4;'g\;'gR4;'gRVn\SPR\ 44VnVP%SPR\&44VnVP%SPRR44Vn\SPR\,44VnSPR 4VnVP3SR\44pVP7VP9V44VnVP:'d\=4'gR MR p\SPR 4;'g)\5R 4;'g\5R4;'gT4P?4PA4Vn!\SPR4;'g+\5R4;'g\5RR R7;'gR 4P?4PA4Vn"VPGSRR\44wrEVP7VP9V44Vn$VPK4Vn&\O4Vn(^;Vn);Vn*Vn+RVn,\O4Vn-\O4Vn.\O4Vn/\O4Vn0R;Vn1Vn2R#)c3<"TF7p\SPV4;'gR4P4xK9 R#5irgN)rZr;rj).0keyextras& r4 0WhatsAppCloudAdapter.__init__..s:x m  #$$" % + + - -ms !AA webhook_hostrgN webhook_port webhook_path health_pathz/health api_version reply_prefix allowlistopen dm_policyWHATSAPP_CLOUD_DM_POLICYWHATSAPP_DM_POLICY group_policyWHATSAPP_CLOUD_GROUP_POLICYWHATSAPP_GROUP_POLICYrhF)phone_number_id access_tokenapp_id app_secretwaba_id verify_token)WHATSAPP_CLOUD_ALLOW_FROMWHATSAPP_CLOUD_ALLOWED_USERS)group_allow_fromgroupAllowFrom)WHATSAPP_CLOUD_GROUP_ALLOW_FROM)3super__init__r WHATSAPP_CLOUDr_phone_number_id _access_token_app_id _app_secret_waba_id _verify_tokenrZr;DEFAULT_WEBHOOK_HOST _webhook_hostrLDEFAULT_WEBHOOK_PORT _webhook_port_normalize_pathDEFAULT_WEBHOOK_PATH _webhook_path _health_pathDEFAULT_API_VERSION _api_version _reply_prefix_select_dm_allowlistr_normalize_allow_ids_coerce_allow_list _allow_fromrmrjrk _dm_policy _group_policy_select_allowlist_group_allow_from_compile_mention_patterns_mention_patternsr _seen_wamids_duplicate_count_accepted_count_rejected_signature_count_warned_no_ffmpeg_last_inbound_wamid_by_chat_clarify_state_exec_approval_state_slash_confirm_state_runner _http_client)selfr allow_rawdefault_dm_policy_ raw_groupsr __class__s&& @r4rWhatsAppCloudAdapter.__init__s !8!89 ""x mx tt14<AQSWS`bfbt -0 .0I0g0gMa0g0geg,h,p,plp"%eii@T&U"V"&"6"6uyyQe7f"g!%!5!5eii y6Y!Z!$UYY}>Q%R!S-2IIn,E--e5ruAB %)%>%>t?V?VW`?a%b,0+;+;+;D]D_D_Kek" IIk " G Gl3M&N G G01 G G5F  %'%%' #& IIn % O O6S)T O O3VD O OHN#  %'%%' .. 9;_amo +/+D+DTE\E\]gEh+i!%!?!?!A4?MXYYY 4t7U',CN-(6A];F=!;F=!+// t(r6c V^8dQhRRRR/#)r.pathrr1rZr2)r3s"r4r5rs99c9c9r6c \T;'gR4P4;'gRpVPR4'dV#RV 2#)rg/)rZrj startswith)rraws& r4r$WhatsAppCloudAdapter._normalize_pathsA$**"o##%,,nnS))s83%y8r6c V^8dQhRRRR/#)r.rrZr1r2)r3s"r4r5rshhshshr6c  j\ RVP RVP RVPR4 2#)z'>>+=>XQXXr6cV^8dQhRR/#r.r1rZr2)r3s"r4r5rsaaar6c ZVPeVPPRR4#R#)uRCloud API has no self-chat concept (a Baileys-only setting) — no default prefix.z\n rg)rreplacers&r4_effective_reply_prefix,WhatsAppCloudAdapter._effective_reply_prefixs,:>:L:L:Xt!!))%6`^``r6c V^8dQhRRRR/#)r.idszset[str]r1r2)r3s"r4r5rsUU(UxUr6c  VUu0uF<p\P!RRVPR^4^,4;'gTkK> up#uupi)z_Normalize allowlist entries to bare wa_id (digits): strip ``@...`` JID suffixes and non-digits.\Drg@)resubsplit)rentrys& r4r)WhatsAppCloudAdapter._normalize_allow_idssHQTTPSuub%++c1"5a"89BBUBPSTTTs :A A c V^8dQhRRRR/#)r.targetrZr1rdr2)r3s"r4r5rseeceder6c <\T;'gR4p\P!RR\V4P R^4^,4;'gTpW0P V49;'g\ SV`W4#)zBare-wa_id membership first (Cloud senders are digits), then the shared WhatsApp matcher so ``*`` and phone/LID aliases keep working for DM intake and groups as they always did.rrgrr2)setrrrZrrr_entry_matches)rentriesrbarers&&& r4r#WhatsAppCloudAdapter._entry_matchesslgmm$vveRV!2!23!:1!=>HH&0099ddUW=ST[=ddr6c$V^8dQhRRRRRR/#)r.entry_idrror1rdr2)r3s"r4r5rs!  #   r6c Z\V\4'dTM/p\VPR4;'gR4P 4p\T;'gR4P 4pW0P 8H;'d(VP '*;'gW@P 8H#)zDBind a signed callback to this adapter's configured Meta identities.rrg) isinstancedictrZr;rjrr)rr roincoming_phone_number_idincoming_waba_ids&&& r4_webhook_identity_matches.WhatsAppCloudAdapter._webhook_identity_matchess)(D998r#&x||4E'F'L'L"#M#S#S#U x~~2.446 $(=(= = I I]]"GG&6--&G r6cV^8dQhRR/#)r.r1ztuple[str, ...]r2)r3s"r4r5rsSSoSr6c *<.\SV`4ORN5#)z@Also honor the documented WHATSAPP_CLOUD_ALLOW_ALL_USERS opt-in.rf)r_allow_all_env_names)rrs&r4r)WhatsAppCloudAdapter._allow_all_env_namessR-/R1QRRr6 is_reconnectFc V^8dQhRRRR/#)r.rrdr1r2)r3s"r4r5r s&&T&d&r6c r"\4RR3VP;'d VPRR33F$wr#pV'dKVPW4RR7R# ^RIHp\ P!RV!4R7Vn\P!\R 7pVPPVPVP4VPPVP VP"4VPP%VP VP&4^R IHpV!WVP,VP.VP 4GR jxL VnVP34VP0eM\4P7R VP,VP.VP VP8VP4VP:'g\4P=R 4VP>'g\4P=R4VPAR 4R#L5i)whatsapp_cloud_deps_missinguMaiohttp and httpx are required for whatsapp_cloud — reinstall hermes-agent.whatsapp_cloud_unconfiguredzLWHATSAPP_CLOUD_PHONE_NUMBER_ID and WHATSAPP_CLOUD_ACCESS_TOKEN are required.F) retryable)platform_httpx_limitsg>@)timeoutlimits)client_max_size) bind_listenerNz=[whatsapp_cloud] Listening on %s:%d%s (Graph %s, phone_id=%s)uq[whatsapp_cloud] WHATSAPP_CLOUD_VERIFY_TOKEN is not set — the GET subscription handshake will fail until it is.u[whatsapp_cloud] WHATSAPP_CLOUD_APP_SECRET is not set — incoming webhook POSTs will be refused with 503. Set the app secret to enable inbound message delivery.T)!rrr_set_fatal_error%gateway.platforms._http_client_limitsrhttpx AsyncClientrr ApplicationWEBHOOK_MAX_BODY_BYTESrouteradd_getr_handle_healthr_handle_verifyadd_post_handle_webhook gateway.platforms.shared_ingressrrrr_mark_connectedr{inforrr|r_wire_plugin_handlers)rrokcodemessagerapprs&$ r4connectWhatsAppCloudAdapter.connect s . 02O \ ^  " " 9 9t'9'9;X [ ]" Bg 2%%du%E"  P!--dCXCZ[oo.DE 4,,d.A.AB 4--t/B/BC D..0D0DEB*4d6H6H$J\J\^b^p^pqq   << # KKO""D$6$68J8JDL]L]_c_t_t !!! NNO P NNS  ""4(rs% VP 4R#L& \d\PRT4LGi;i5i)rNz[whatsapp_cloud] %s failed))rcleanupzwebhook server cleanup)raclosezhttp client close)getattr Exceptionr{ exceptionsetattr_mark_disconnected)rattrclosewhatobjs& r4 disconnectWhatsAppCloudAdapter.disconnect4s"E D$%C{ Ec)+++ D %"E ! , E  !=tD Es7BAAA"BA!A=:B<A==Bc V^8dQhRRRR/#)r.resprr1rZr2)r3s"r4r5rBs I Ic Ic Ir6c VP4pT;'g/PR4;'g/pVPR4;'gVPR4;'gRpVPR4pVeRV RVP R V 2#R VP R V 2# \dRTPR,/pLi;i) z;Map a non-200 Graph response to an actionable error string.r:NiNerrorr2z unknown errorr1z graph error z (HTTP z): zHTTP z: )jsonr=r(r; status_code)rHr?errr2r1s& r4_response_error$WhatsAppCloudAdapter._response_errorAs ,99;Dzzrw'--2'')$JJJJ?wwvMQM]dV74+;+;*rZtype__name__rLrNr|rKr;)rrRrSrTrPrHrV error_msgs&&$$$ r4_post_messages#WhatsAppCloudAdapter._post_messagesNs 6**// 0KUYUgUgUipw/xxD   s ",,T2I NN:'7'7 Q+ Qy Qy=  99;??:.44"d: :y 6   X &s3x5549#5#55 5 6 t8O sqD+>B?B=B?A D+%D8D<D+=B?? D >DD D+DD+D(%D+'D((D+c V^8dQhRRRR/#)r.rRr0r1rr2)r3s"r4r5r^sSS.SS]Sr6c "VPf\RRR7#VP!V3/VBGRjxL wr4Ve\RVR7#\RV'dV^,PR4MRR7#LD5i)u```_post_messages`` → SendResult with the first returned message id; guards disconnected state.NF Not connectedsuccessrJTidrc message_id)rrr]r;)rrR log_kwargsrrMs&&, r4_post_message_result)WhatsAppCloudAdapter._post_message_result^s    $e?C C,,WC CC7:z%s3 SJ_cEHpstupvpzpz{qANRMS SDs2A;A9AA;c ,V^8dQhRRRRRRRRRR /#) r.chat_idrZkindblockrreply_tor[r1r0r2)r3s"r4r5rfs03c#[ir6c  :RRRRRVRWV/pV'dRV/VR&V#) zJCommon ``/messages`` envelope; ``context`` quotes ``reply_to`` when given.messaging_productwhatsapprecipient_type individualtorZrfcontextr2)rkrlrmrnrRs&&&& r4_outbound_payload&WhatsAppCloudAdapter._outbound_payloadesA$7 DTVbdhjqsy{HM#N ".!9GI r6Nc ,V^8dQhRRRRRRRRRR /#) r.rkrZrOrnr[rorpr1rr2)r3s"r4r5rms<DD#DD}D_wDDNDr6c v"VPf\RRR7#V'dVP4'g\RRR7#VPV4pRp\ VP WPP 444FywrxTPTRRVR R/V^8XdTMR4p VPV R R R 7GRjxL wrV e\RV R7u#V 'dV ^,PR 4MTpK{ V'd \P!WV4GRjxL \RVR7#LsL5i)zLSend a text message via Graph API. ``chat_id`` is the recipient's ``wa_id``.NFrarbTrer(r? preview_urlz[whatsapp_cloud] send failedz.[whatsapp_cloud] send rejected (status=%d): %srSrTrd) rrrjformat_message enumeratetruncate_message_outgoing_chunk_limitrvr]r;r record_async) rrkrOrnro formattedlast_message_ididxchunkrRrrMs &&&&& r4sendWhatsAppCloudAdapter.sendms%    $e?C Cgmmoodt< <''0 )-#D$9$9)E_E_Ea$bcJC,,&%!ESVZ[S[xaeG"007K1HC !%s;;25c!fjj.?Od !..wS S S$?CC Ts:#D9D9BD9D5 D9#%D9 D9#D7$D97D9c V^8dQhRRRR/#)r.rkrZr1r8r2)r3s"r4r5rsllllr6c "VPPV4pVPe V'gR#RRRRRVRRR //pVPPVP R 4VP 4VR 7GRjxL pTP^8XdR#TP4;'g/PR 4;'g/PR 4pTR8Xd\PRT4R#\PRTPT4R#L \ dR#i;i \ dRpLei;i5i)zMark the latest inbound message read AND show a typing indicator. Meta couples both into one POST; the indicator auto-dismisses on reply or after 25s. Best-effort: every error is swallowed so the main reply path is never blocked.Nrprqstatusreadrftyping_indicatorrZr(rWrXrJr1izS[whatsapp_cloud] typing/read indicator rejected: wamid %s likely older than 30 daysz7[whatsapp_cloud] typing/read indicator returned %d (%s)) rr;rrYrrr=rLrKr{r.debug)rrkrowamidrRrHr1s&&& r4 send_typing WhatsAppCloudAdapter.send_typings00044W=    $E & HflTY[mpvx~oA **// 0KUYUgUgUipw/xxD   s "  YY[&&B++G4::??GD 6> KKmot u LLRTXTdTdfj ky     D sq1EE>D DD ED21D2 D2AED D/+E.D//E2 E?EEEc4V^8dQhRRRRRRRRR RR RR R /#) r.rkrZr*r0rorpstateOrderedDict[str, str]state_id session_keyr1rr2)r3s"r4r5rsF)7C[$03BE r6c "VPVPVRV\V44RRR7GRjxL pVP'd\ WEV\ 4V#L)5i)uPOST an ``interactive`` message (caller supplies ``type``/``body``/``action``) and, on success, remember ``state_id → session_key`` for the tap. Free-form interactives need no Meta approval but are only valid inside the 24h window — fine, all senders here reply to a user.r*z([whatsapp_cloud] interactive send failedz5[whatsapp_cloud] interactive rejected (status=%d): %sr{N)rhrvrsrcrINTERACTIVE_STATE_CACHE_SIZE)rrkr*rorrrresults&&&&&&& r4_send_interactive&WhatsAppCloudAdapter._send_interactivesc00  " "7M;W_H` a?N1   >>> 6R S  s3A!AA! A!c$V^8dQhRRRRRR/#r.r(rZlimitrLr1r2)r3s"r4r5rs&QQSQQcQr6c \T;'gR4P4p\V4V8:dV#VR\^V^, 4R,#)zJButton titles cap at 20 chars, list-row titles at 24; the ellipsis counts.rgNu…)rZrjrTmaxr(rs&&r4_truncate_button_label+WhatsAppCloudAdapter._truncate_button_labelsJ4::2$$&4yE)tPt4Gc!UQY6G/H5/PPr6c$V^8dQhRRRRRR/#rr2)r3s"r4r5rs&IISIIIr6c v\T;'gR4p\V4V8:dV#VRV^, R,#)z-``interactive.body.text`` caps at 1024 chars.rgNz...)rZrTrs&&r4_truncate_body#WhatsAppCloudAdapter._truncate_bodys94::24yE)tHtKeai/@5/HHr6c V^8dQhRRRR/#)r.buttonstuple[str, str]r1zlist[dict[str, Any]]r2)r3s"r4r5rsccc5Icr6c  JVUUu.uFwrRRRRVRV//NK upp#uuppi)rZreplyrdrEr2)rbidrEs* r4_reply_buttons#WhatsAppCloudAdapter._reply_buttonss0ZabZaJC'D#w+FGZabbbsc$V^8dQhRRRRRR/#)r. body_textrZrrr1r0r2)r3s"r4r5rs&ttCt?t~tr6c  6RRRRV/RRVP!V!//#)uZ``interactive.type=button`` body: ≤3 quick-reply buttons (id ≤256 chars, title ≤20).rZr)r?r(actionr)r)clsrrs&&*r4_button_interactive(WhatsAppCloudAdapter._button_interactives.&69*=x)UXUgUgipUqIrssr6c4V^8dQhRRRRRRRRRRRR R R /#) r.rkrZquestionchoiceszOptional[list] clarify_idrrorpr1rr2)r3s"r4r5rsO#z#z#z&)#z4B#zPS#z#z$<#z #zr6c Xaa"T;'gRP4pV'g)SPVRV 2\V4R7GRjxL #VR,Uu.uF=p\V4P4'gK$\V4P4NK? ppSP RV R2RP R\ V444,4p \V4^8:d3SP!V .VV3R l\\V444O5!p M\ V4U U u.uF=wrR R S R V 2R SPV ^, ^R7RSPV ^HR7/NK? p p p V PR R S R2R SP\R4^R7RSP\R4^HR7/4RRRRV /RRSP\R44RR \R4RV /.//p SPWVSPSV4GRjxL #ELuupiuup p iL5i)uClarify as native buttons: 1–3 choices → buttons, 4+ → list (+ "Other" row that flips the entry into text-capture mode), 0 → plain text question. Button ``id`` carries ``cl::``; inbound dispatches on it.rgu❓ )rnN:N N rc3B"TFwrV^, RV 2xK R#5i)z. Nr2)rics& r4r4WhatsAppCloudAdapter.send_clarify..s(I~f}^b^_QQRUGSUVWUX/f}sc3v<"TF.pRS RV 2SP\V^,443xK0 R#5i)cl::N)rrZ)rrrrs& r4rrsIHoGgjJ/r6c "RVRR/#5i)rurZdmr2)rrks&&r4 get_chat_info"WhatsAppCloudAdapter.get_chat_info s..s c(V^8dQhRRRRRRRR/#)r. file_pathrZ media_kind mime_typer[r1#tuple[Optional[str], Optional[str]]r2)r3s"r4r5rs3XXSXcXmXhKXr6c r"VPfR#\PPV4'gRRV 23#\PP V4\ P V\ R,4rTWE8d/RR\PPV4 RV RV RV R2 3#T;'g<\P!V4^,;'g\P VR 4p\VR 4;_uu_4pR \PPV4Wc3R RR RV3/pVPPVPR4VPRR7VR7GRjxL pRRR4XP&^8wdRTP)T43#TP+4P R4p T 'dT R3#R#L^ +'giLd;i \d-p \ P#R4R\%T 43uRp ? #Rp ? ii;i \dRp Lli;i5i)zWUpload a local file to Graph /media. Returns ``(media_id, None)`` or ``(None, error)``.NzFile not found: rzFile z is z bytes; Cloud API z cap is z bytesr"rbfilerprZmediaFr)rfilesz$[whatsapp_cloud] media upload failedrd)Nra)Nrq)NzUpload response missing 'id')rosrexistsgetsize_MEDIA_SIZE_LIMITSr;basename mimetypes guess_type _DEFAULT_MIMErrYrrr=r{r>rZrLrNrK) rrrrsizecapfhrrHrVmedia_ids &&&& r4 _upload_media"WhatsAppCloudAdapter._upload_medias-    $( (ww~~i((+I;77 7GGOOI.0B0F0FzSefpSq0rc :5!1!1)!< =T$GYZdYeemnqmrrxyy yAA!5!5i!@!CAA}GXGXYceHA  "i&&""''"2"29"=r!MObdvx~BFHQARS!..33DOOG4LVZVhVhsxVhVyBG3HH'   s "--d33 3 yy{t,H$,$W1WWH'& "   C DS> ! " H s5H7BH7;$H7 H78G* A*G6G7G;G*$H7(H$H7H7G G' "G*&H7'G** H!5!HH!H7H!!H7$ H41H73H44H7r media_linkrGfilenamernc8V^8dQhRRRRRRRRRRRRR RR R /#) r.rkrZrrr[rrGrrnr1rr2)r3s"r4r5r)sS   (+ :G ! 3@   3@    r6c X"VPf\RRR7#\V4\V48Xd\RRR7#V'dRV/MRV/pV'd VR9dWXR &V'd VR8XdWhR &VPVP WW4R R V3R 7GRjxL #L5i)zPOST a media message referencing exactly one of an uploaded ``media_id`` or a public ``link``. Caption is accepted on image/video/document; filename on document only.NFrarbz1Exactly one of media_id or media_link must be setrdlinkrrGrz"[whatsapp_cloud] media send failedz=[whatsapp_cloud] media send rejected (status=%d, kind=%s): %s)rSrTrP>rrr)rrrdrhrv) rrkrrrrGrrn media_blocks &&&$$$$$ r4 _send_media WhatsAppCloudAdapter._send_media)s    $e?C C >T*- -e3fg g:BtX&6Q[H\ z%CC%, "  j0&. #..  " "7 N9V# /    s$A B* B*B*/4B*#B($B*rc8V^8dQhRRRRRRRRRRRRR RR R /#) r.rkrZsourcerrGr[rrnrr1rr2)r3s"r4r5r@sP$'58FS2?!  r6c "RV/pVP\4'g6VPW#V4GRjxL wrV 'd\RV R7#RV /pVP!W3RVRVRV/VBGRjxL p V P 'dV P 'dRV9dT;'g<\P!V4^,;'g\PVR 4p \P!WP W,3.4GRjxL V'd*\P!WP V4GRjxL V #ELLL<L 5i) uHTTPS URL → ``link`` send (one fewer round trip); local path → upload + ``id`` send. Local sends are indexed in ``rich_sent_store`` so a later quote of the attachment can be resolved (Meta's inbound ``context`` carries only the quoted id).rNFrbrrGrrnr")r_HTTP_PREFIXESrrr rcrfrrrr;rrecord_media_asyncr) rrkr rrGrrnrrefrrMrrYs &&&&$$$$ r4_send_media_from_path_or_link2WhatsAppCloudAdapter._send_media_from_path_or_link@s(*6v(>  00"&"4"4V"SSMH!%s;;x(C''zWzW_zjrzvyzz >>>f///J#4E|| 4 4V O>OSYR`Qab b b%227D ? E; D $D %D ("E; D !#E;E9E; D D E; #E6E#  E6# E3 .E66E;c V^8dQhRRRR/#)r.mp3_pathrZr1r[r2)r3s"r4r5rys y ys y} yr6c "\'g1VP'gRVn\PR4R#\P !\ WPR^4^,R,R7GRjxL #L5i)uMP3 → ``audio/ogg; codecs=opus`` sibling file; None if ffmpeg is missing or fails. The missing-ffmpeg warning fires once per adapter: it is an install hint, not a per-message error.Tu[whatsapp_cloud] ffmpeg not found on PATH — voice messages will be delivered as MP3 audio attachments instead of native voice notes (green waveform bubble). Install ffmpeg to enable: Windows `winget install Gyan.FFmpeg`, macOS `brew install ffmpeg`, Linux package manager.N.r$) output_path) _FFMPEG_PATHrr{r|rQ to_threadrrsplit)rr:s&&r4r1%WhatsAppCloudAdapter._convert_to_opusysl|))))-&p &&'rLr|)rrCrrCrrHs&&&&& r4 _graph_getWhatsAppCloudAdapter._graph_gets **..s.DDD   s " NNVX\hlhxhx y E    Mt ^ s7BA AA 6BA !BBBBext_hintc$V^8dQhRRRRRR/#)r.rrZrGr[r1rr2)r3s"r4r5rs&!+!+s!+!+cF!+r6c "VPfR#\V4P4p\P!RV4'g \ P RVR,4R#VPRR7pVP\ RVP RV 2VRV4GRjxL pVfR#VP4pVPR 4VPR 4;'gR rvV'gR#VPWcR V4GRjxL pVfR#\PR R R7\T T;'g\!V4;'gR 2, p V P#VP$4\T 4T;'gR3#L \d/pLi;iL \&d\ P)RT4Ru#i;i5i)uTwo-step Graph download: ``GET /`` → signed temp URL (~5 min) → bytes. Returns ``(local_path, mime_type)`` or ``(None, None)`` on any failure (logged).Nz[A-Za-z0-9._-]+z/[whatsapp_cloud] refusing malformed media id %r:N@NFrrrorCrrgrMT)parentsexist_okz.binz5[whatsapp_cloud] failed to write cached media (id=%s)NN)rrZrjr fullmatchr{r|rrErrrKr=r;_INBOUND_MEDIA_CACHEmkdirra write_bytesrOr4r>) rrrGr meta_respmetatemp_urlrY blob_respout_paths &&$ r4_download_media_to_cache-WhatsAppCloudAdapter._download_media_to_caches    $ x=&&(||.99 NNLhWZm \ $$u$5//^,O>O=PPQRZQ[*\^egqs{||    >>#D%$((;*?*E*E2$ //(WhOO   ""4$"?'XJx7`7`=QUCV7`7`Z`6a*bb   !2!2 38}dlld**+}  D  P    TV^ _  s~B%G'F( G3F'G+#GF&0GG GF(:G G F# G"F##G(#G G GGc V^8dQhRRRR/#r.rJz web.Requestr1z web.Responser2)r3s"r4r5rs  K L r6c B"\P!RRRVPPRVPRVP R\ VP4R\ VP4R\RJR VPR VPR VP/ 4#5i) rr0platformrrverify_token_configuredapp_secret_configuredffmpeg_presentNaccepted duplicatesrejected_signature) r json_responser\valuerrrdrrr>rrr)rrJs&&r4r(#WhatsAppCloudAdapter._handle_healths  dJ (;(;=NPTPePe D..0I4PTPbPbKc #T$*:*:%;=M|cgOg ,,lD`` HMAC of the raw body keyed by ``app_secret`` (constant-time).zsha256=:NNFzutf-8) rrrjronewrqhashlibsha256 hexdigestrprk)rr|r} expected_hexcomputeds&&& r4rv&WhatsAppCloudAdapter._verify_signatures   V0A0A)0L0LbhikblbrbrbtRtR^Rt88D,,33G>#3#:#:#P>P>R>Y>Y>[\\r6c V^8dQhRRRR/#)r.rrZr1rdr2)r3s"r4r5rs#$r6c WP9dV;P^, unR#V'd\VPVR\4R#)zITrue if this wamid is new; False (and count a duplicate) if already seen.FT)rrrWAMID_DEDUP_CACHE_SIZE)rrs&&r4 _dedup_wamid!WhatsAppCloudAdapter._dedup_wamids= %% %  ! !Q & !  ))5$8N Or6c V^8dQhRRRR/#)r.rRr0r1r8r2)r3s"r4r5rs%r%r~%r$%rr6c "VPR4R8wd(\PRVPR44R#VPR4;'g.EFp\V\4'dVPR4;'g.M.EFp\V\4'dVPR4R8wdK2VPR 4;'g/p\V\4'gKeVPR 4;'g/pVP VPR 4V4'g\P VPR4'd\PM\PR VPR 4\V\4'dVPR 4MRVP;'gRVP4EKMVPR4;'g.Uu/uFp\V\4'gK\VPR4;'gR4P4;p'gKWT\VPR4;'g/PR4;'gR4P4bK ppVPR4;'g.F5p \V \4'gKVPWV4GRjxL K7 VPR4;'g.FPp \V \4'gK\PRV PR4V PR 44KR EK EK R#uupiL5i)uWalk ``entry[].changes[].value.{messages, contacts, statuses}`` and dispatch each message. ``statuses`` (sent/delivered/read/failed) are only logged — the agent doesn't consume receipts.objectwhatsapp_business_accountz6[whatsapp_cloud] ignoring non-WABA payload (object=%r)NrchangesfieldrWrdrordzo[whatsapp_cloud] ignoring signed webhook for waba=%r phone_number_id=%r (configured waba=%s phone_number_id=%r)rzr,wa_idrgprofilerustatusesz![whatsapp_cloud] status %s for %sr)r;r{rr r rlogloggingWARNINGDEBUGrrrZrj_ingest_message) rrRrchangerdrocontactrcontacts_by_waidr/rs && r4rx&WhatsAppCloudAdapter._dispatch_payloads ;;x $? ? LLQSZS^S^_gSh i [[)//R/E:DUD:Q:Q599Y/552WYY!&$//6::g3F*3T 7+11r!%.. 99Z066B55eiioxPPJJ+099Z+@+@gmmB $;EhPT;U;U %67[_ 00--$)99Z#8#>#>B#>$#>!'40Y?B7;;wCWC]C][]?^?d?d?f6fe6fYE3 I 6 < <"AA&IOORPVVXX#>!$ $)99Z#8#>#>B#>K!+t44"22;RZ[[[$?$ii 399r9F!&$// %H&**U]J^`f`j`jko`pq:9Z0*$\sAM=4M= AM=2M=)M=9%M=A*M= ,M=7M=<M6M66M6M63M6 M6%M=?M=M=2M; 3M=M=1A M=c(V^8dQhRRRRRRRR/#)r.r/r0rr%ror1r8r2)r3s"r4r5r)s5[[[Sa[m{[AE[r6c "\VPR4;'gR4P4pVPV4'g\P RV4R#VP WV4GRjxL pTfR#T;P^, un TPT4GRjxL R#L? \d\PRT4R#i;iL0 \d\PRT4R#i;i5i)uDedup → build event → handle_message. Neither build nor dispatch errors may bubble out: the wamid is already dedup-marked, so a 500 would make Meta retry the batch and every message in it would then be dropped as a duplicate.rdrgz-[whatsapp_cloud] duplicate wamid %s, skippingNz3[whatsapp_cloud] failed to build event for wamid %sz3[whatsapp_cloud] handle_message raised for wamid %s) rZr;rjrr{r_build_message_event_from_cloudr=r>rhandle_message)rr/rrorevents&&&& r4r$WhatsAppCloudAdapter._ingest_message)sKOOD)//R0668  '' LLH% P  >>{^fggE =  ! [%%e, , ,h    RTY Z   - [   RTY Z [sxA D D%B<:B:;B<?DC&3C$4C&8D:B<s(UU^U_mUrvUr6c a"\V4p\VPR4;'gR4P4o\VPR4;'gR4P4pS'gR#V'dVP V4'g$\ P RT;'gRS4R#SPR^4p\V3R lVPP44R 4pVe\V4^8wdR#T!T\VPR4;'gR4W54GR jxL #L5i) uRoute an inbound button tap to its resolver (see ``_INTERACTIVE_HANDLERS``). True = claimed. False (unknown prefix, no live state, or no waiter) makes the caller fall back to text dispatch with the button title — covers stale taps.rdrgfromFzM[whatsapp_cloud] Rejected unauthorized interactive tap from %s (button_id=%r)z Trc3^<"TF"wrSPV4'gKVxK$ R#5iN)r)rprefixh button_ids& r4rCWhatsAppCloudAdapter._dispatch_interactive_reply..Ms&n+MifQZQeQeflQm+Ms- -N) r=rZr;rj_is_dm_allowedr{r|rnext_INTERACTIVE_HANDLERSitemsrT)rr/rinner sender_idpartshandlerrs&&& @r4_dispatch_interactive_reply0WhatsAppCloudAdapter._dispatch_interactive_reply>s#;/ $--2.446  /5526<<> d11)<< NNjlumEmEzEGP QQ'n4+E+E+K+K+Mnptu ?c%jAoT3{v'>'D'D"#EuTTTTs7AE E ; E E E 5A?E 5E E E c(V^8dQhRRRRRRRR/#)r.rtrZr(rSr1r8r2)r3s"r4r5rSs(''3'c'S'T'r6c "VPW4GRjxL R#L \d\PT4R#i;i5ir)rr=r{r>)rrtr(rSs&&&&r4_reply_best_effort'WhatsAppCloudAdapter._reply_best_effortSs8 '))B% % % '   X & 's1A!!A! AAAAc 0V^8dQhRRRRRRRRRRR R /#) r.rrrrZ stale_logchoicevalidrUr1r[r2)r3s"r4r5rZs<  $ +. ;> HK Y^   r6c VPVR4pV'g\PW!4V#V'd W49dWPV&R#V#)uPop the session_key for a tapped prompt. None (info-logged) when nothing is live — likely a stale tap; an unrecognised ``choice`` keeps the prompt live and also yields None.N)popr{r.)rrrrrrs&&&&& r4_pop_tap_state#WhatsAppCloudAdapter._pop_tap_stateYsE iiT*  KK 'v*$#Jr6c(V^8dQhRRRRRRRR/# r.rtrZrr0rrr1rdr2)r3s"r4r5rgs)((C((t(X\(r6c "VwrEpVPVPVR4pV'gR#\RR4pVfR#VR8XdgVPV4p V 'g\ PRV4R#WpPV&VPV\R4R 4GRjxL R #\V4p TPT\TPR 4;'g\T ^,444'g\ PR T4R#R # \d\ P RT4Rp Li;iL \d)\ PR T4YpPT&R#i;i5i)uj[whatsapp_cloud] clarify tap with no matching state (clarify_id=%s) — likely stale; falling back to textFztools.clarify_gatewayzL[whatsapp_cloud] clarify resolver unavailable; falling back to text dispatchNotherz1[whatsapp_cloud] mark_awaiting_text failed for %sz\[whatsapp_cloud] clarify 'Other' tap but entry missing (clarify_id=%s); falling back to textz%platform.whatsapp.clarify_type_answerz,[whatsapp_cloud] clarify other-prompt failedTz3[whatsapp_cloud] clarify tap had non-int choice: %rrEu][whatsapp_cloud] clarify resolver reported no waiter (clarify_id=%s) — falling back to text)rrr}mark_awaiting_textr=r{r>r.rr rLrUr|resolve_gateway_clarifyrZr;) rrtrrrrrrclarify_gatewayflippedrs &&&& r4_handle_clarify_tap(WhatsAppCloudAdapter._handle_clarify_tapgs %v))    x * #%s   " W  )<r) rrtrrrrrr slash_confirm result_texts &&&& r4_handle_slash_confirm_tap.WhatsAppCloudAdapter._handle_slash_confirm_taps %:))  % %z h 0 ()>@uv    - 5 5kv VVK ))";hi i i W    L M  jsNAB-BBBB-&B-;B+<B-B B($B-'B((B-rrzsc:c(V^8dQhRRRRRRRR/#)r. msg_type_strrZr/r0r?r1z tuple[list[str], list[str], str]r2)r3s"r4r5rs4[[[>[ad[jJ[r6c "VPV4;'g/p\VPR4;'gR4P4\VPR4;'gR4P4reV'g..V3#VPV\ V4R7GRjxL wrxV'd\ P RW4M\ PRW4VR8Xd3\VPR 4;'gR4P4MRp T;'gV 'dR V R 2MTpV'g..V3#V.T;'g T;'gR .V3#L5i) zTDownload inbound media by ``media_id``; returns ``(media_urls, media_types, body)``.rdrgr)rGNz,[whatsapp_cloud] cached inbound %s media: %sum[whatsapp_cloud] failed to download inbound %s (id=%s) — agent will see message metadata but not the binaryrrz [Document: ]r")r;rZrjrWrar{r.r|) rrr/r?rr inbound_mime local_pathdl_mimefnames &&&& r4_collect_inbound_media+WhatsAppCloudAdapter._collect_inbound_medias: -33!$UYYt_%:%:!;!A!A!CSS^I_IeIeceEfElElEn,r4< $($A$A(UbcoUp$A$qq  KKF a NN =IJ %d)z [Content of z]: z utf-8-sigr)encodingerrorsrTz1[whatsapp_cloud] failed to read document text: %s)rTr}maprsuffixrk_TEXT_INJECT_EXTSstatst_size_MAX_TEXT_INJECT_BYTESr{r.ru read_textr4r>)rr?inlinedrdoc file_size injections&& r4_inject_document_text*WhatsAppCloudAdapter._inject_document_texts'C O+D* 56FAzz!):: [HHJ.. 55KK acftJK*388*DP[dm9n8op 37)D/Y! 7} [  !TVYZ [sAC*C C!C>=C>c(V^8dQhRRRRRRRR/#)r.r/r0rr%ror1zOptional[MessageEvent]r2)r3s"r4r5rs2B B )B =KB WeB B r6c "\VPR4;'gR4P4pV\9d(\P RWAPR44R#VR8Xd"VP W4GRjxL 'dR#\PV4pV'd\V!V4;'gR4MRp\VPR4;'gR4P4;rxVPVR4p VPR 4'd8\PR VPR 4VPR44R#VPR VR VR RRV/4'gR#...rp V\9d@VPWAV4GRjxL wrpVR8XdV 'dVPW4wrlVPR4;'g/p \V PR4;'gR4P4;'gRpV'd\P!W~4MRp\V PR4;'gR4P4p\VPR4;'gR4P4p\!T;'d T;'dT4;'dVV8Hp\VPR4;'gR4;'gRpV'dV'd\#VP$VV\&4V'd!\P(!VVV4GRjxL V\9d;V 'd3\P*!VV\-\/W444GRjxL V'dL\P0!W~4F1wppVV 9gKV P3V4V P3V4K3 \5T\6PV\8P:4TP=Yy;'gTRY;'gRR7VVVVVWV R7 #ELELELL5i)zMConvert a Cloud-API message object into a MessageEvent, or None if gated out.rZr(z<[whatsapp_cloud] skipping contentless %s envelope (wamid=%s)rdNr*rgrchatu[whatsapp_cloud] received group-shaped message (chat=%s, wamid=%s) — group support is not yet implemented; dropping. Use the Baileys whatsapp adapter for group chats.chatIdsenderIdisGroupFr?rrudisplay_phone_numberr)rk chat_name chat_typeuser_id user_name) r( message_typer r/rfrr reply_to_textreply_to_is_own_messager media_typesmedia_text_inlined)rZr;rk_CONTENTLESS_KINDSr{rr _BODY_BY_KINDrjr|_should_process_message_INBOUND_MEDIA_KINDSrrrlookuprdrrrrrrzip lookup_mediarr_MESSAGE_TYPE_BY_KINDrTEXT build_source)rr/rrorextractr?rkr sender_namerr r ru reply_to_idr  quoted_from our_numberreply_to_is_ownrrrYs&&&& r4r4WhatsAppCloudAdapter._build_message_event_from_clouds;??62<  ++Xw IW`bgioqu,vww68"b!3 / /262M2Mlim2n,n )JTz)j+/+E+Ej+W(//),22'++d+11r288:BBd HS..wDY] '++f-334::< &<=CCDJJL {II{IIzJhh{^hOhKOOD)//R088D W 88'5Jf g%227E4HHH33 %88%cR\NjIklll -::7P dz)%%d+&&t,Q$9$=$=lKL\L\$]$$+A+A'T!-@-@D%$;'!Oa  [.s&-o$IlsBQQ  Q Q,Q%Q&BQ;'Q"Q #Q9*Q$QQ Q+4Q 1Q"Q5 Q? Q "Q0 Q> Q Q?QQQ(-QQ Q" QA"Q* Q6Q QQQ)rrrrrrrrrrrrrrrrrrrrrrrrrrrrr2rMr))i)NNN)rgr2)Fr[ __module__ __qualname____firstlineno____doc__r__annotations__splits_long_messagesr staticmethodrrrrrrrrr4rErNr]rhrvrrrrrr classmethodrrpropertyr_EA_CODE_CLOSE_EA_CMD_BUDGETrrrrr rrr r&r+r7r1rErWr(r)r+rvrrxrrrrrrrrrrr__static_attributes__ __classcell__)rs@r4rrsW#'4&0000f99hYYaUUee SS &E&P " I Itv SD8l4 QQ II cctt#zJ22!NN v @/ X2 JN $( CG #' CG .VZ"&BF$(.yzz O$ y !+Y]!+H P (>]%rN[*U*'   (T.*#$7BVX]_xy[(&B B r6rcV^8dQhRR/#rcr2)r3s"r4r5r50s^^T^r6caVe\VRR4;'g/M/pVPR4'dVPR4'dR#^RIHo\;QJdV3RlR4F 'dK R# R#!V3RlR44#) zPhone-number id + access token, from ``PlatformConfig.extra`` (YAML / env seeding) or the scope-aware env reader (``hermes_cli.gateway.get_env_value`` so setup-status patches see it).NrrrTc3v<"TF.pSPV4;'gRP4xK0 R#5ir) get_env_valuerj)rru gateway_mods& r4r _is_connected..7s8^\4))$/552<<>>\s99F)WHATSAPP_CLOUD_PHONE_NUMBER_IDWHATSAPP_CLOUD_ACCESS_TOKEN)r<r;hermes_cli.gatewaygatewayall)rrr0s& @r4 _is_connectedr70s7=6HWVWd + 1 1rbE yy"## .(A(A, 3^\^33^3^3^\^ ^^r6cV^8dQhRR/#r7r2)r3s"r4r5r5;sDr6c ^RIHpV!4R#)zO``hermes gateway setup`` entry: the same wizard ``hermes whatsapp-cloud`` runs.run_whatsapp_cloud_setupN) setup_wizardr;r:s r4_interactive_setupr=;s 6r6uYou are on WhatsApp (Meta Business Cloud API). Standard markdown auto-converts to WhatsApp syntax — write markdown freely. No tables — use bullets or labeled lines. You can send files natively: write MEDIA:/absolute/path/to/file in your response. Images (.jpg, .png) send as photos, videos (.mp4) inline, audio as voice/audio, other files as documents; ![alt](url) works. NOTE: Meta refuses free-form replies when the user hasn't messaged in 24h (error 131047) — relevant only for delayed/scheduled sends.cV^8dQhRR/#r7r2)r3s"r4r5r5LsTr6c $^RIHpVP!R$/RRbRRbR\bRRbR R bR R bR \bR\ bR\ RR4bRRR.bRRbR\bRRbRRbRRbR\bRR bR!VPbR"VPbVPBR##)%uPlugin entry point — called by the Hermes plugin system. No ``validate_config``: an unconfigured adapter still reaches ``connect()``, which records the ``whatsapp_cloud_unconfigured`` fatal error (same outcome as the former core wiring). No ``standalone_sender_fn`` / ``max_message_length``: out-of-process ``send_message`` had no WhatsApp Cloud sender in core either, and ``send()`` chunks itself.) gateway_envruwhatsapp_cloudlabelzWhatsApp Business (Cloud)adapter_factorydashboard_labelzWhatsApp Cloud APIdashboard_descriptionzBUse Hermes via Meta's hosted WhatsApp Cloud API (no local bridge).docs_urlzNhttps://hermes-agent.nousresearch.com/docs/user-guide/messaging/whatsapp-cloudcheck_fn is_connectedconfig_connected_fnrr required_envr2r3 install_hintu0aiohttp/httpx missing — reinstall hermes-agentsetup_fncron_deliver_env_varWHATSAPP_CLOUD_HOME_CHANNELemojiu📱allow_update_commandF platform_hint display_tierlow env_overridesenv_enable_credentialsNr2) rgr@register_platformrrr7r r=_PLATFORM_HINT ENV_OVERRIDESENV_ENABLE_CREDENTIALSAUTHZ)ctxr@s& r4registerr\Ls %@Rf,cb  3  BO  33DnU 78UVHSe;CI`e%"// +AA[EVEVr6i0iPiii@>rrrr'r r>systemunknownreaction unsupported> .js.md.py.ts.css.csv.log.txt.xml.yml.html.json.yaml)zhttp://zhttps://)g__conditional_annotations__r" __future__rrQr2rrorxrKrrrrshutilr collectionsrpathlibrtypingrrraiohttprrrzr"rgateway.configr r gateway.platforms._sharedr agent.i18nr gateway.platforms.baser rrr$gateway.platforms.base_exec_approvalrgateway.platforms.helpersrgateway.platforms.eventrr!gateway.platforms.whatsapp_commonrr%gateway.platforms.access_policy_mixinrrlgateway.platforms.media_cacherr5rhermes_constantsr getLoggerr[r{rrrrrr%rrrrwhichr>r&r#rr rrrPHOTOVIDEOVOICEDOCUMENTrrr=rrWrarmrsr}rOrrr7r=rWr\)rlrns0@r4rsR#   #&&O 4<mm?1=QO6#+   8 $*-(#  _g'7BR!9j  \7K,*I| ||H% +V\6 f6"N SF{# K  g{'8'8';CTCT [  ):):J H\H\ {  (K,<,.>  )F 7 ;?NbbMaT$??Mab  U r7N+KMcde1 D 02ED V^KY! C O Ebcs*H(H:I ( H76H7: I I