`gj:dZddlZddlZddlZddlZddlZddlZddlZejdk(Z ddl m Z ddl m Z mZmZddlmZddlmZmZmZej,eZdZd ed efd Zd ed dfd Zd ede d efdZde d dfdZ de d ed dfdZ!ddded dfdZ"ddl#Z#e#jHjKde&e e'jQjRdddl*m+Z+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8ddl9m:Z:de&d efdZ;de d e&fdZhd#Z?hd$Z@hd%ZAd&e&d'ed(ed e&fd)ZBddddd*d+ZCd3d,ZDd-eEd.eEd eEdzfd/ZFd efd0ZGd1ZHd3d2ZIy)4aG WhatsApp platform adapter. WhatsApp integration is more complex than Telegram/Discord because: - No official bot API for personal accounts - Business API requires Meta Business verification - Most solutions use web-based automation This adapter supports multiple backends: 1. WhatsApp Business API (requires Meta verification) 2. whatsapp-web.js (via Node.js subprocess) - for personal accounts 3. Baileys (via Node.js subprocess) - alternative for personal accounts For simplicity, we'll implement a generic interface that can work with different backends via a bridge pattern. NWindows)Path)DictOptionalAny)windows_detach_popen_kwargs)find_node_executableget_hermes_dirwith_hermes_node_pathz[owner reply] portreturnc g} tjddd|dgddd}|jjj D]} |j t ||r|S tjdd d |gddd}tjd |jD]+}|j t |jd - |S#t$rYwxYw#t$rYwxYw#t$rY|SwxYw) uPIDs of processes *listening* on ``port`` (POSIX) — never clients. This must match only LISTEN sockets. A bare ``lsof -i :PORT`` (or ``fuser PORT/tcp``) also returns *clients* whose connection merely involves that port number — e.g. a browser with a tab open on a local dev server sharing the port. SIGTERMing those closed the user's browser at irregular intervals. Restricting to LISTEN state frees the port for a new bridge without ever touching an unrelated client. lsofz-tiztcp:z -sTCP:LISTENTcapture_outputtexttimeoutssz-ltnHpz sport = :z pid=(\d+)) subprocessrunstdoutstrip splitlinesappendint ValueErrorFileNotFoundErrorrefinditergroup)r pidsresultlinems U/root/.hermes/venv/lib/python3.12/site-packages/plugins/platforms/whatsapp/adapter.py_listener_pids_on_portr(,s)D   Ud4&M> :dA MM'')446 D  CI&  K    8y/ 0dA \6==9 )A KKAGGAJ ( ) K!         K sIA C1C"*C12A-D" C.+C1-C..C11 C=<C= D  D c^ trddlm}tjgdddd|}|j j D]j}|j}t|dk\s"|ddk(s+|d }|jd |sE tjd d |d dgdd|lyt|D]'} tj|tj)y#tj$rYwxYw#t t"t$f$rYZwxYw#t&$rYywxYw)zDKill any process *listening* on the given TCP port (a stale bridge).r)windows_hide_flags)netstatz-anoz-pTCPTr)rrr creationflags LISTENINGr:taskkill/PID/F)rrr-N) _IS_WINDOWShermes_cli._subprocess_compatr*rrrrsplitlenendswithSubprocessErrorr(oskillsignalSIGTERMProcessLookupErrorPermissionErrorOSError Exception)r r*r$r%parts local_addrpids r'_kill_port_processrFRs'!  H ^^0#$02F  002 ! u:?uQx;'>!&qJ!**Qtf:6!&NN!+VU1Xt D/3Q.@.B !".d3 GGC0  *99! !+OWE    slA(D +D 4D %C-4D 7D $D*D -DD DD DD DD D,+D,rE session_pathcddlm}||sy|ddlm}|||k(Sddlm}||}|syd|vxr t ||vS)uTrue only if ``pid`` is alive AND still our node bridge for this session. The PID is read from a file written by a previous run. Once that process exits and is reaped the kernel can recycle the number onto an unrelated process — observed in the wild landing on a desktop browser's main process, which a bare-liveness ``os.kill`` then SIGTERMed, closing the whole browser at irregular intervals (every time the flapping bridge restarted). Identity is confirmed two ways: the kernel start time captured when we wrote the pidfile (definitive), and — for legacy pidfiles with no baseline — the command line, which must contain ``node`` and this session's unique path. A recycled PID (different start time / different cmdline) is never ours. r _pid_existsFget_process_start_time)_read_process_cmdlinenode)gateway.statusrJrLrMstr)rErGexpected_startrJrLrMcmdlines r'_bridge_pid_is_oursrSxsZ+ s !9%c*n<<5#C(G  g  AC $5$@Ac|dz }|jsyd}d} |jjd}t|dj }t |dkDr/|dj rt|dj }t|||r< tj|tjt j#d|n$ddlm}||rt j-d| |jy#t tttf$r$ |jYy#t$rYYywxYwwxYw#t$t&tf$rYhwxYw#t$rYywxYw) uKill a bridge process recorded in a PID file from a previous run. The bridge writes ``bridge.pid`` into the session directory when it starts. If the gateway crashed without a clean shutdown the old bridge process becomes orphaned — this helper finds and kills it. Critically, the recorded PID is re-validated against the live process (:func:`_bridge_pid_is_ours`) before any signal, so a recycled PID that now names an unrelated process (e.g. the user's browser) is never killed. bridge.pidN rrz2[whatsapp] Killed stale bridge PID %d from pidfilerIz[whatsapp] Not killing pidfile PID %d: it is no longer the bridge (recycled onto an unrelated process); skipping to avoid killing a stranger.)exists read_textr7rrr8rrA TypeError IndexErrorunlinkrSr;r<r=r>loggerinfor?r@rOrJwarning)rGpid_filerErecorded_startlinesrJs r'_kill_stale_bridge_by_pidfilercs]l*H ??  CN ""$**40%(.."# u:>eAhnn. q!12N3 n=  GGC ( KKLc R / s  NN&'*   + J 7  OO     #OW=       sNA8D":EE-E-D?? E E E  EE*)E*- E98E9c ddlm}||}| t|ndj||}|dz j |y#t $rYywxYw)a'Write the bridge PID (and its kernel start time) for later cleanup. The start time on line 2 lets a future run prove the PID still names this exact process before signalling it, so a recycled PID can never be killed as a "stale bridge". Older single-line files remain readable. rrKNz{} {}rV)rOrLrPformat write_textrA)rGrErLstartrs r'_write_bridge_pidfilerhsS 9&s+ =s3xhooc5.I  $006    sAA AAFforcerjc:trddt|jdg}|r|jd t j |ddd}|jd k7rH|jxs|jxsd j}t|xsd |jyd dl} |j|j}|j!d }|r)|D]} |j|jy|D]} |j|jy#t $r'|r|jYy|jYywxYw#|j"$rYwxYw#|j"$rYwxYw#|j"$rYywxYw) zITerminate the bridge process using process-tree semantics where possible.r1r2z/Tr4T rNrztaskkill failed for PID ) recursive)r5rPrErrrrr< terminate returncodestderrrrrApsutilProcesschildren NoSuchProcess) procrjcmdr$detailsrrparentrtchilds r'_terminate_bridge_processr{s63txx=$7  JJt  ^^# F    !}}; ;BBDG'J'?z%JK K)??T?2 ! JJL  KKM! OO%     ;!      (++++   swD+*4FE/FFE3F+EEEE0-F/E00F3FFFFFFr.)PlatformPlatformConfig)WhatsAppBehaviorMixin)to_whatsapp_jid)BasePlatformAdapter MessageEvent MessageType SendResultSUPPORTED_DOCUMENT_TYPEScache_image_from_urlcache_audio_from_url)env_inturlc8 t|j}ddlm}m}m}m}||||fD]-} |jt|jry/y#ttf$rYywxYw#ttf$rYWwxYw)u~Return True only when an absolute path from the bridge resolves inside a known Hermes media cache directory. The Baileys bridge is a local subprocess that downloads inbound media and hands back absolute file paths. A compromised or buggy bridge could hand back an arbitrary path (e.g. ``/etc/passwd``) which would otherwise be attached verbatim and sent to the model. Resolve the path (following any symlinks) and require it to live under one of the real cache roots — this covers both the canonical ``cache/`` layout and the legacy ``_cache`` layout that ``get_hermes_dir`` may return. Fr)get_audio_cache_dirget_document_cache_dirget_image_cache_dirget_video_cache_dirT) rresolverArgateway.platforms.baserrrris_relative_to)rresolvedrrrrroots r'_is_allowed_bridge_pathrs9$$&     &&tDz'9'9';<=  1 Z ,$   s#A2(B2BBBBpathcddl} |j|jjddS#t$rYywxYw)aReturn the first 16 hex chars of the SHA-256 of *path*'s contents. Used for the bridge staleness handshake: bridge.js reports its own source hash in ``/health`` (``scriptHash``), and the adapter compares it against the hash of bridge.js currently on disk. A mismatch means a long-lived bridge process is serving code from before an update. Returns ``""`` when the file can't be read. rNrm)hashlibsha256 read_bytes hexdigestrA)rrs r'_file_content_hashrAsD~~doo/0::Z'deddfd?Z(d@eeefdee%fdAZ)xZ*S)FWhatsAppAdapteru WhatsApp adapter. This implementation uses a simple HTTP bridge pattern where: 1. A Node.js process runs the WhatsApp Web client 2. Messages are forwarded via HTTP/IPC to this Python adapter 3. Responses are sent back through the bridge The actual Node.js bridge implementation can vary: - whatsapp-web.js based - Baileys based - Business API based Configuration: - bridge_script: Path to the Node.js bridge script - bridge_port: Port for HTTP communication (default: 3000) - session_path: Path to store WhatsApp session data - dm_policy: "open" | "allowlist" | "disabled" | "pairing" — how DMs are handled (default: "pairing") - allow_from: List of sender IDs allowed in DMs (when dm_policy="allowlist") - group_policy: "open" | "allowlist" | "disabled" | "pairing" — which groups are processed (default: "pairing") - group_allow_from: List of group JIDs allowed (when group_policy="allowlist") Behavior (gating, mention parsing, markdown conversion, chunking) is provided by ``WhatsAppBehaviorMixin`` so the Cloud API adapter can share it. Only transport-specific code lives here. NTconfigc t||tjtj ddlm}|t_d|_|jjdd|_ |jjdt|j dz |_ t|jjdtdd |_|jjd |_t|jjd xst%j&d d j)j+|_|j/|jjdxs|jjd|_t|jjdxst%j&dd j)j+|_|j/|jjdxs|jjd|_|j7|_t;j<|_d|_ d|_!d|_"d|_#d|_$|jKdd|_&|jKdd|_'i|_(i|_)y)Nr)resolve_whatsapp_bridge_dir bridge_port bridge_scriptz bridge.jsrGzplatforms/whatsapp/sessionzwhatsapp/session reply_prefix dm_policyWHATSAPP_DM_POLICYpairing allow_from allowFrom group_policyWHATSAPP_GROUP_POLICYgroup_allow_fromgroupAllowFromFtext_batch_delay_secondsg@text_batch_split_delay_secondsg$@)*super__init__r|WHATSAPPr_DEFAULT_BRIDGE_DIR!gateway.platforms.whatsapp_commonr_bridge_processextraget _bridge_portrP_bridge_scriptrr _session_path _reply_prefixr;getenvrlower _dm_policy_coerce_allow_list _allow_from _group_policy_group_allow_from_compile_mention_patterns_mention_patternsasyncioQueue_message_queue_bridge_log_fh _bridge_log _poll_task _http_session_shutting_down_coerce_float_extra_text_batch_delay_seconds_text_batch_split_delay_seconds_pending_text_batches_pending_text_batch_tasks)selfrr __class__s r'rzWhatsAppAdapter.__init__sb !2!23  . . 6 U2M2OO /;?!'!1!1-!F-3\\-=-=  ((;6 7. $( (8(8  79K L) $ -3LL,<,<^,Lfll..{;iryyI]_h?ijpprxxz226<<3C3CL3Q3rU[UaUaUeUefqUrs !1!1.!A!rRYYOfhqErsyy{BBD!%!8!89I9IJ\9]:DagamamaqaqsCbD"E!%!?!?!A-4]]_"+/26@D%**.)A)A &* &04/G/G ,d0 ,?A"BD&rTkeydefaultr c>ddl}t|jddr%|jjj |nd}| t |S t |}|j|r|dkr t |S|S#t tf$rt |cYSwxYw)zRead a float from ``config.extra``, guarding against bad/non-finite values. The result is fed directly to ``asyncio.sleep()``, so NaN/Inf and unparseable values fall back to ``default``. rNr) mathgetattrrrrfloatrZrisfinite)rrrrvalueparseds r'rz#WhatsAppAdapter._coerce_float_extras .5dkk7D.Q !!%%c*W[ => ! "5\F}}V$ > ! :& "> ! "s A??BBF) is_reconnectrc vKts5tjd|j|j dddyt |j }|js:tjd|j||j dd|d dy|jd z }|js6tjd |j||j d d dytjd|j|d} |jdt|jdsyd} |j}|dz }|dz dz }t|} d} |dz jr/ |jj!| k(xr t#| } | st'd|jdt)dxsd} t+dd} t-j.| ddgt|dd| t1} | j2dk7rVt'd|jd | j4 |j6s#|r|j9|j;yyt'd|jd!| r |j=| |jj?dd#ddl } |jC4d{}|jEd$|jFd%|jId&'(4d{}|jJd)k(rW|jMd{}|jEd*d+}|d,k(r |jEd-d.}t|}|r|r||k(rt'd|jd/|d0|jOd|_(|jC|_)tUjV|jY|_- dddd{dddd{|j6s#|r|j9|j;yyt'd|jd1|xsd2d3|d4nt'd|jd5|d4dddd{dddd{t]|jt_|jFtUj`d6d{tcjdd7d8}|jjd9z |_3ti|jfd:d;<}||_5t1}|jl|jl|d=<dd>l7m8}m9}m:}t||d?<t||d@<t||dA<t-jvt)dBxsdBt|dCt|jFdDt|jdE|gf|||dFty|_(t{|j|jPj|ddl }d}i}tdGD]}tUj`d6d{|jPjt'd|jdH|jPj2d0t'd|jdI|jf|j;|j6s#|r|j9|j;yy |jC4d{}|jEd$|jFd%|jId&'(4d{}|jJd)k(rjd}|jMd{}|jEd*d,k(r :    ! !%g "   -tyy+F  `../A3tGYGYCZ\no MY ) %++J"^3I#n47IIJ*95IK^+335(#-#7#7#9#?#?#AY#N"cTXYbTcK$))$PQR06?%!+22PRU*V'%/^^!9j9 O'+! 313 &N&00A5$)),B>CXCXBYZ[$h== //1&&(!gAdii[(@AB !&11)<    $ $TD $ A # "002 } }g&{{+D,=,=+>gF ' 5 5A 5 > + }};;#-)-#4D,0HHXy,IM, ;04xx b/I ,>{,K #/I,R[B[$)Adii[8YZgYhhi*j$k$($8$8$:;?D$89@9N9N9PD$66=6I6I$J]J]J_6`DO+/3}} } }F== //1&&(!Q!&&' {300<0M /NgV_U``m%o!" !&$))4^_l^mmz&{ |?}} } }J *$*<*< = t00 1--" " " IIo{CM#1188<GD  !1!13IM"/D  /0J!!-6:6H6H 23    47|~3FJ/ 036~7G3HJ/ 069,.6IJ2 3#-#3#3(0:F $c$"3"34T%7%7!8m  $%$ $./ $D  "$"4"4d6J6J6N6N O JD 9 mmA&&&'',,.:Adii[(I$J^J^JiJiIjjklmAdii[ d6F6F5GHI**, F== //1&&(!E &446 * *'#*;;/0A0A/B'J$+$9$9$9$B$/$ * *"#{{c1-1 -1YY['8#'88H#5#D$)Adii[8Z*[$\$) * * * * * * * * * ,$))$MNO$))M$2B2B1CDE&&(^== //1&&(!Wxx![0$))$[\]$Ry[G!--***++002>$)),STU$))M$:J:J9KLM..0$F== //1&&(!E !#*#8#8#: . .g'.{{"3D4E4E3Fg N(/(=(=A(=(F(3(.."&#';;##515+.n,*tA/o0v97on1$!tq"p!q"6q p$q $p3<p'=B3p30 q ;p*<q  q" p- q"0v9Ap3 q  p0 q  q"q q" At"q2#Ft&q5'Bt+0v9r90q81r946r#*q; +r#.%r q> 2r  r#rr# r9!r"r9&t( r#3r4r#8 r9r r9At0v9 At!s "A-t0v9t s t 6s7s s7#s5s 62s( s73s4s78 t st t s7ss7 t %s4&t *C t70v9' n0!nv9nv9 n.*t-n..t1 n>:o=n>>o p p%t)0v9pt!q"$q 'p3*q -q"0q 3q 9p<:q q  q" qq qq"" q/+t.q//t5t8r9;r#>r r#r9r# r rr r# r9#r6 )r,*r6 1r99 stst t s7ss7t s7s1 $s'%s1 ,s74t 7t =t>t t  tttt v&#u= v 0v9=vv1v66v9c|jr# |jjd|_yy#t$rYwxYw)z)Close the bridge log file handle if open.N)rcloserB)rs r'rz!WhatsAppAdapter._close_bridge_logsE    ##))+#'D    s 1 ==cK|jy|jj}|yt|ddr&|dvr"tj d|j |yd|d}|j s]tjd|j ||jd |d |j|jd{|jxs|S7w) z@Return a fatal error message if the managed bridge child exited.NrF>rz-[%s] Bridge exited during shutdown (code %d).z2WhatsApp bridge process exited unexpectedly (code z).z[%s] %swhatsapp_bridge_exitedTr) rrrr]r^rhas_fatal_errorrrr_notify_fatal_errorfatal_error_message)rrpmessages r'_check_managed_bridge_exitz*WhatsAppAdapter._check_managed_bridge_exits    '))..0   4)5 1jL6P KK?   FzlRTU## LLDIIw 7  ! !":Gt ! T  " " $**, , ,''272 -sCC! C C!cKd|_|jri t|jdt jdd{|jj t|jdntd|jd |jd z jd |j rI|j j#s/|j j% |j d{d|_|j(r8|j(j*s"|j(j-d{d|_|j/|j1d|_|j3td|jd y#ttf$r|jj YwxYw7#ttf$r|jjYwxYw#t$r&}td|jd|Yd}~d}~wwxYw#t$rYwxYw7M#t j&tf$rYgwxYw7%w) z=Stop the WhatsApp bridge and clean up any orphaned processes.TFrirNrz] Error stopping bridge: z.] Disconnecting (external bridge left running)rV) missing_okz] Disconnected)rrr{r?r@rorrrr<rBr rrr\rArdonecancelCancelledErrorrclosedr9r _mark_disconnectedr)rr s r' disconnectzWhatsAppAdapter.disconnects% #    C5-d.B.B%PmmA&&&'',,.641$2F2FdS Adii[ NO P    , . 6 6$ 6 G ??4??#7#7#9 OO " " $ oo%%   d&8&8&?&?$$**, , ,! ##% !#   $))N+,O+O<5((2245&/@4,,1134 C$))$=aSABB C   &**I6   -sI;F0HG H'G#>I;I8AI;9II I AI;I8AI;0)GHGH#)H HHH IH=7I;=II; II;II;II51I;4I55I;chat_idcontentreply_tometadatac K|jr |js tddS|jd{}|r td|S|r|j s tddSt |} ddl}|j|}|j||j}g} d} t|D]&\} } || d} |r | dk(r|| d <|jjd |jd | |jd 4d{}|jdk(rF|jd{}|j!d} | rS| j#t%| n8|j'd{}td|cdddd{cSdddd{t)|dkDs t+j,dd{)td| t/| ddd| iS77777m7\#1d{7swYlxYw7F#t0$r }tdt%|cYd}~Sd}~wwxYww)zSend a message via the WhatsApp bridge. Formats markdown for WhatsApp, splits long messages into chunks that preserve code block boundaries, and sends each chunk sequentially. F Not connectedsuccessrNTrR message_idrchatIdrAreplyTor/sendrrrr messageIdrg333333? message_ids)rRrTcontinuation_message_ids raw_response)r rrrBrrrformat_messagetruncate_message_outgoing_chunk_limit enumeratepostrrrrrrrPrr8rrtuplerB)rrKrLrMrN bridge_exitr formattedchunkssent_message_idslast_message_ididxchunkpayloadr*r+rr s r'sendzWhatsAppAdapter.sendAsW}}D$6$6e?C C ;;== e;? ?gmmodt< <!'*, ; ++G4I**9d6P6P6RSF*, "O'/ - U%$+q*2GI&--22'(9(9':%@ #111;3 F F{{c)%)YY[0*.((;*?*,33C4HI&*iik 1)%uE F F F F Fv;?!--,,,5 -8*)./?/D)E+-=>  ]>8 F 1 !2 F F F F F - ;e3q6: : ;s9IH=I:BH)HH)#H=H >AHH H H) H!H)'I( H)3H4H)H) H'!#H)IH) H HH)H)H$ HH$ H)) I2I II II)finalizerTrocK|jr |js tddS|jd{}|r td|S ddl}|jj d|j dt|||d|jd  4d{}|jd k(rtd |cdddd{S|jd{}td|cdddd{S77i7?7(7 #1d{7swYyxYw#t$r } tdt| cYd} ~ Sd} ~ wwxYww)z7Edit a previously sent message via the WhatsApp bridge.FrPrQNrrz/edit)rVr[rArrrZrTrS) r rrrBrrdrrrrrrBrP) rrKrTrLrorfrr*rr s r' edit_messagezWhatsAppAdapter.edit_messagesY}}D$6$6e?C C ;;== e;? ? ; ))..#D$5$5#6e<-g6!+&  --B-7/ B B;;#%%dzJ B B B#'))+-E%e5A B B B > B B. B B B B ;e3q6: : ;s9ED EAD(!D "D(%D D( D D(ED&D'D7 D(DD(E D( D(DD(D%D D%!D($E%D(( E1E EE EE file_path media_typecaption file_namecK|jr |js tddS|jd{}|r td|S ddl}t j j|stdd|St|||d}|r||d<|r||d <|jjd |jd ||jd 4d{} | jdk(rF| jd{} td| jd| cdddd{S| jd{} td| cdddd{S7577m7B7+7#1d{7swYyxYw#t $r } tdt#| cYd} ~ Sd} ~ wwxYww)z4Send any media file via bridge /send-media endpoint.FrPrQNrzFile not found: rVfilePath mediaTypertfileNamer /send-mediaxrrZrTr[rRrTr_)r rrrBrr;rrXrrdrrrrrrrBrP) rrKrrrsrtrurfrrmr*r+rr s r'_send_media_to_bridgez%WhatsAppAdapter._send_media_to_bridges}}D$6$6e?C C ;;== e;? ?! ; 77>>),!%9I)7UVV*'2%''G %, "&/ #))..#D$5$5#6kB--C-8/ B B;;#%!%,D% $#'88K#8%) B B B#'))+-E%e5A B B B'>& B -  B. B B B B  ;e3q6: : ;s9F>E0F>2FF>AF E3!F$#E=E5 E=( F4E75F9F>:E= E9E= F*E;+F/F>3F5E=7F9E=;F=FF F FF>F F;F60F;1F>6F;;F>rselectable_countquestionoptionsrc"K|jr |js tddS|jd{}|r td|S ddl}t ||t |xsg|d}|jjd|jd||jd  4d{}|jd k(rF|jd{} td | jd| cdddd{S|jd{} td| cdddd{S777m7B7+7#1d{7swYyxYw#t$r } tdt| cYd} ~ Sd} ~ wwxYww)a Send a native WhatsApp poll via the Baileys bridge. This is a low-level transport primitive only. Gateway approval UX must remain gateway-owned and add text fallback plus explicit confirmation semantics before approval prompts are ever mapped onto polls. FrPrQNr)rVrrselectableCountrz /send-pollrYrrZrTr[r})r rrrBrrlistrdrrrrrrrBrP) rrKrrrrfrrmr*r+rr s r' send_pollzWhatsAppAdapter.send_polls}}D$6$6e?C C ;;== e;? ? ; *'2$ 2.#3 'G ))..#D$5$5#6jA--B-7/ > >;;#%!%,D% $#'88K#8%) > > >#iik)!%u= > > >> > - >* > > > > ;e3q6: : ;s9FEFA!E#1E2E#5#EE E9 E#EE# F EE E/ E#;E <E#FE#EE# E E#E E E E#F E## F ,FF FF  Fchoices clarify_id session_keycK|xsgDcgc]5}t|jst|j7}}dt|cxkrdkrtnnq|j|t|xsdj|dd{} | jr| St j d|j| jt |)||||||d{Scc}w7_7 w) aRender multiple-choice clarify as a native WhatsApp poll. The gateway registers the pending clarify before calling this method. When Baileys later emits a poll_update with the selected option as message text, the normal clarify text-intercept resolves the pending question and the blocked agent continues. Open-ended clarifies use the text fallback so the user's next typed message is captured. r rmrrNzB[%s] Native WhatsApp clarify poll failed; falling back to text: %s)rKrrrrrN) rPrr8rrRr]r_rrr send_clarify) rrKrrrrrNchoice clean_choicesr$rs r'rzWhatsAppAdapter.send_clarifys"=DMrbcRXkN_N_NaV**,b b M" (b (>>HN#))+!" *F ~~ NNT    W)!# *   c s5 C6C-C-A C6C2AC6(C4) C64C6)raddressrMrNlatitude longituderrcFK|jr |js tddS|jd{}|r td|S ddl} t |t |t |d} |r|| d<|r|| d<|jjd |jd | | jd  4d{} | jdk(rF| jd{} td| jd| cdddd{S| jd{} td| cdddd{S777m7B7+7#1d{7swYyxYw#t$r }tdt|cYd}~Sd}~wwxYww)z;Send a native WhatsApp location pin via the Baileys bridge.FrPrQNr)rVrrrrrz/send-locationrYrrZrTr[r})r rrrBrrrrdrrrrrrrBrP)rrKrrrrrMrNrfrrmr*r+rr s r' send_locationzWhatsAppAdapter.send_location.s}}D$6$6e?C C ;;== e;? ? ; *'2!(O"9-'G "&%, "))..#D$5$5#6nE--B-7/ > >;;#%!%,D% $#'88K#8%) > > >#iik)!%u= > > >> > - >* > > > > ;e3q6: : ;s9F!EF!A3E5EE5#E *E+ E  E5EE5F!E 0E1E  E5 EE5F!E5E E5E E5 E2&E) 'E2.E51F!2E55 F>FFF!FF! image_urlcK t|d{}|j||d|d{S7 7#t$rt||||||d{7cYSwxYww)u^Download image URL to cache, send natively via bridge. ``metadata`` is accepted to honor the base-class contract — the batch sender ``send_multiple_images`` passes it through to every send path. The bridge media call doesn't use it, matching the sibling overrides (send_video / send_voice / send_document). Nimage)rr~rBr send_image)rrKrrtrMrN local_pathrs r'rzWhatsAppAdapter.send_image\sm ]3I>>J33GZRYZZ Z?Z ]+GYS[\\\ \ ]sIA#84868A#88A AA A#A  A# image_pathcFK|j||d|d{S7w)z,Send a local image file natively via bridge.rNr~)rrKrrtrMkwargss r'send_image_filezWhatsAppAdapter.send_image_fileq%//WgVVVV !! video_pathcFK|j||d|d{S7w)u>Send a video natively via bridge — plays inline in WhatsApp.videoNr)rrKrrtrMrs r' send_videozWhatsAppAdapter.send_video|rr audio_pathcFK|j||d|d{S7w)z:Send an audio file as a WhatsApp voice message via bridge.audioNr)rrKrrtrMrs r' send_voicezWhatsAppAdapter.send_voicerrc K|j||d||xstjj|d{S7w)z=Send a document/file as a downloadable attachment via bridge.documentN)r~r;rbasename)rrKrrrtrurMrs r' send_documentzWhatsAppAdapter.send_documentsE// Y G  4)))4    s:AAAcK|jr |jsy|jd{ry ddl}|jj d|j ddt |i|jd4d{ dddd{y7l77 #1d{7swYyxYw#t$rYywxYww) z!Send typing indicator via bridge.Nrrz/typingrVrrrZ) r rrBrrdrrrrB)rrKrNrs r' send_typingzWhatsAppAdapter.send_typings}}D$6$6 002 2 2    ))..#D$5$5#6g> 89--A-6/        3         s-CBCAB7BB7 B" B7B B7CB7 B7"B4(B+ )B40B73C4B77 CCCCcK|jr |jsdddS|jd{r|ddS ddl}|jj d|j dt ||jd  4d{}|jd k(rb|jd{}|j d ||j d rdnd|j dgdcdddd{Sdddd{|ddS777g7 7#1d{7swY!xYw#t$r!}tjd||Yd}~Id}~wwxYww)z&Get information about a WhatsApp chat.Unknowndm)rtypeNrrz/chat/rlrrrrisGroupr" participants)rrrz+Could not get WhatsApp chat info for %s: %s) r rrBrrrrrrrrBr]debug)rrKrr*r+r s r' get_chat_infozWhatsAppAdapter.get_chat_infosb}}D$6$6%t4 4002 2 2#T2 2 T ))--#D$5$5#6f_W=UD(,(D      ..) 3  -      T LLFQR S S Ts1E#D E#AD6 D D6#D!3D4E0?E8E2E8$AE8'E4(E8. F 9E6:F >H-H+H-)H-.F 0E82E84E86F 8F >F ?F F H( H-"H(*H#=G>"H# H-%3H#HH#H-#H((H-iprcddlm}||j|jjj dd|jjj dd|jj S)z-Session-scoped key for text message batching.r)build_session_keygroup_sessions_per_userTthread_sessions_per_userF)rrprofile)gateway.sessionrsourcerrrr)rrrs r'_text_batch_keyzWhatsAppAdapter._text_batch_keys^5 LL$(KK$5$5$9$9:SUY$Z%)[[%6%6%:%:;UW\%]LL((   rTc|j|}|jj|}t|jxsd}|||_||j|<n|jr8|jr|jd|jn |j|_||_|j rJ|j j|j |jj|j|jj|}|r |js|jtj|j||j|<y)zBuffer a text event and reset the flush timer. When WhatsApp delivers rapid-fire messages (e.g. forwarded batches), this concatenates them and waits for a short quiet period before dispatching the combined message. rmNrW)rrrr8r_last_chunk_len media_urlsextend media_typesrrErFrr_flush_text_batch)rrrexisting chunk_len prior_tasks r'rz#WhatsAppAdapter._enqueue_text_events'""5)--11#6 (b)  $-E !.3D & &s +zzDLMM8==/EJJ< @W\WaWa '0H $##**5+;+;<$$++E,=,=>3377< joo/    .5.A.A  " "3 '/ &&s+rTcKtj} |jj|}|r t |ddnd}||j k\r |j }n |j}tj|d{|jj|d}|s< |jj||ur|jj|dyy|j|d{|jj||ur|jj|dyy77A#|jj||ur|jj|dwwxYww)z4Wait for quiet period then dispatch aggregated text.rrN) r current_taskrrr_SPLIT_THRESHOLDrrrpoprr)rrrpendinglast_lendelayrs r'rz!WhatsAppAdapter._flush_text_batch sY++-  >0044S9GAHww(91=aH4000<<66--& & &..223=E--11#6,F..223=G%%e, , ,--11#6,F..223=G ' ---11#6,F..223=GsME:A,D;D7"D;(;E:#D;7D98D;<;E:7D;9D;;}tI|d?k\r|d>}d@|dA|}|r|dB|}n|}t#d|j$dC|d i} t|j dExsdj}!|j dF}"|!r|!| dG<tK|"tLr|"r|"| dH<|j dIr$d| dJ<|jtNs tN|}tQ|||||j dK|| | ||||L S7#t&$rN} t#d|j$d| d|j!| | j!| xsdYd} ~ Zd} ~ wwxYw7#t&$rc} t#d|j$d%| d|j!| | j!| xs|tjk(rd"nd#Yd} ~ d} ~ wwxYw#t&$r(} t#d|j$dD| dYd} ~ d} ~ wwxYw#t&$r%} t#d|j$dM| Yd} ~ yd} ~ wwxYww)NzKBuild a MessageEvent from bridge message data, downloading images to cache.Nryrm>location live_locationstickerhasMediarrpttrrFr"rrVchatNamesenderId senderName)rK chat_name chat_typeuser_id user_name mediaUrlsmime)zhttp://zhttps://.jpg)extz image/jpegrz] Cached user image: T)flushz] Failed to cache image: z] Using bridge-cached image: z0] Rejected bridge image path outside cache dir: .oggz audio/oggz audio/mpegz] Cached user audio: z] Failed to cache audio: z] Using bridge-cached audio: z0] Rejected bridge audio path outside cache dir: zapplication/octet-streamz ] Using bridge-cached document: z3] Rejected bridge document path outside cache dir: z video/mp4z] Using bridge-cached video: z0] Rejected bridge video path outside cache dir: rbody quotedTexthasQuotedMessagequotedMessageIdquotedParticipanti> .js.md.py.ts.css.csv.log.txt.xml.yml.html.json.yamlz] Skipping text injection for z (z bytes > rrreplace)rerrors_rr.z [Content of z]: z z] Injected text content from: z ] Failed to read document text: nativeTypenativeMetadatawhatsapp_native_typewhatsapp_native fromOwnerwhatsapp_from_ownerr[) rrr raw_messagerTrrrNreply_to_message_id reply_to_textreply_to_author_idreply_to_is_own_messagez] Error building event: ))_should_process_messagerrrPrLOCATIONSTICKERPHOTOVIDEOVOICEAUDIODOCUMENT build_sourcer startswithrrr rrBr;risabsrrrsuffixrr_clean_bot_mention_text_normalize_whatsapp_id_message_is_reply_to_botstatst_sizerYr7r8 isinstancedict_OWNER_REPLY_PREFIXr)#rr+msg_typersis_grouprrraw_urls cached_urlsrr bridge_mime cached_pathr rrr quoted_textrrrr  raw_reply_idquoted_participantMAX_TEXT_INJECT_BYTESdoc_path file_sizerLfname display_namerC injectionrN native_typenative_metadatas# r'rz$WhatsAppAdapter._build_message_event3s } //5#''HTXXk26<"=J::&//y(&..*%j(*00H **00Hj(*00H **00H*33Hxx 51H#+I&&2.((:.#,((<0 'Fxx R0HKK9 2!$((6"2"8b9??A {000S^^D[5\H,@&,Q&Q #**;7#**;+F,G$)),A+OW[\ !2!22rww}}S7I.s3#**3/#**;+F,G$)),I#OW[\$)),\]`\abjno+"3"3[5F5F!GGCNN[rLs|,@&,Q&Q #**;7#**;+z(VaVgVgJg;my{$)),A+OW[\ +"3"3[5F5F!GGBGGMMZ]L^.s3#**3/#**;+z(VaVgVgJg;my{$)),I#OW[\$)),\]`\abjno!5!55"''--:L.s3#**3/"3i..446*k.F.J.J3Pj.k#**40$)),LSERZ^_$)),_`c_demqr!2!22rww}}S7I.s3#**3/#**;+E+F$)),I#OW[\$)),\]`\abjno&&s+&&y1s9 2|88FB'Dxx "33D$? dhh|4:;AACK'/4M"& !% &+ #xx*+#xx(9: +*-l*;'%)%@%@J]A^%_"%);&*.*G*G*M'$. !;///K +bHx.//557CFFb(,X(;(;(=(E(EI(+@@ %$))4RS[R\\^_h^iirtIsJJK'LTX!Y (&*8n&>&>Xa&>&bG$(N$7$7E+0L"e|(- C(;#&u:?388L*6|nD (RI#*3D'?'0!Adii[0Nxj"Yaef+b2(*Hdhh|4:;AACK"hh'78O3>/0/40_.=*+xx $26./':;124&9D% 88K0&'!$7+#5(?  A'R%H$)),EaSIQUV#**3/#**;+F,GGH'R%|$)),EaSIQUV#**3/#**;+z(VaVgVgJg;my{{|b )b!Adii[0PQRPS"T\`aabN  Adii[ 8< = sf!e0f!F&e0=a0 a-Aa0Ce0+c ;c e0A d<$e0%B d<2B:e0,f!-a00 c9Ac<e0ce0 c  d9Ad4.e04d99e0< e-e("e0(e--e00 f9ff!ff!r N)NNN)NNN)+__name__ __module__ __qualname____doc__rsplits_long_messagesr}rrPrrr r7rrrBrJrrrrnrqr~rrrrrrrrrrrrrrrrrrr __classcell__)rs@r'rrhs83E~3EjsUu&5:S)TS)dS)j'3(3-3@1-n#'-1 C;C;C;3- C; 4S>* C;  C;V ;;; ;  ; ;L"&#' /;/;/; /; # /; C= /; /;n!" +;+;+;c +;  +; +;h.2' ' ' $ '  '  ' 4S>*'  ' ^#!%"&-1,;,;,; ,; sm ,;#,;3-,;4S>*,; ,;d"&"&-1 ]]]# ] 3- ] 4S>* ] ]2"&"& W W W# W 3- W  W"&"& W W W# W 3- W  W"&"& W W W# W 3- W  W"&#'"&      #  C=  3-     ,/3/4S>/4##N \ c   $ 8>3>4>&tCH~(.gif.png.jpeg.webpr>.3gp.avi.mkv.mov.mp4.webm>.m4a.mp3.wav.flac.opusrrris_voiceforce_documentc|rytjj|dj}|s|tvry|t vry|t vryy)ayMap a local media file to the bridge /send-media ``mediaType``. Returns one of ``image`` | ``video`` | ``audio`` | ``document`` so the Baileys bridge renders the right native WhatsApp message kind. Voice notes and audio files route to ``audio``; ``force_document`` (the [[as_document]] directive) forces every file to ``document`` regardless of extension. rrrrr)r;rsplitextr_WA_AUDIO_EXTS_WA_IMAGE_EXTS_WA_VIDEO_EXTS)rrrFrGrs r'_bridge_media_typerM sR ''  9 %a ( . . 0C3.( n n rT) thread_id media_filesrGrtc (Kt|dixsi} ddl} |jdd} t |} |xsg} |xsd} |rt | d k(r|nd} d}|j 4d{}| jr| s|jd | d | | d |jd 4d{}|jdk7rN|jd{}dd|jd|icdddd{cdddd{S|jd{}|jd}dddd{| D]\}}tjj|s| r{ |jd | d | | d |jd 4d{}|jdk(r'|jd{jd}dddd{dd|iccdddd{St'|||}| ||d}|dk(r"tjj)||d<| r| |d<|jd | d||jd4d{}|jdk7rP|jd{}dd|jd|icdddd{ccdddd{S|jd{}|jdxs|}dddd{dddd{dd| |dS#t$rddicYSwxYw777t7S7E7/7#1d{7swY"xYw777#1d{7swYxYw#t $rt"j%dYwxYw77@77777#1d{7swYxYw7#1d{7swYxYw#t $r}dd |icYd}~Sd}~wwxYww)!aOut-of-process WhatsApp delivery via the local bridge HTTP API. Implements the standalone_sender_fn contract so deliver=whatsapp cron jobs succeed when cron runs separately from the gateway. Replaces the legacy _send_whatsapp helper. When ``caption`` is provided (single-file ``MEDIA: caption`` send), the text rides on the media bubble's native caption via the bridge ``/send-media`` ``caption`` field instead of being posted as a separate ``/send`` message beforehand. rrNrz/aiohttp not installed. Run: pip install aiohttprrrmrzhttp://localhost:rXrUrYrrZrzWhatsApp bridge error (z): r[z7WhatsApp caption-fallback send failed for missing mediazWhatsApp media file not found: rwrrzrtr{r|zWhatsApp media error (Twhatsapp)rRplatformrKrTzWhatsApp send failed: )rr ImportErrorrrr8rrrdrrrrr;rrXrBr]r_rMr)pconfigrKrArNrOrGrtrrrnormalized_chat_idmediar media_captionrjr)r*rr+ media_pathrFrsrmr s r'_standalone_sendrYs* GWb ) /RELJ7ii t4 ,W5!r}"%,E ad ((*8 O8 Ogzz|M"<<' }E:$64H#111;( < <{{c)%)YY[0 '+B4;;-sSWRX)YZ < < < 8 O8 O8 O"&,D&*hh{&;O < <).% O$ Hww~~j1 % f'.||"3K= F0B}%](/(=(=B(=(G(4([["&#';;##5=AYY[7H6M6Mk6ZO [[$'Fzl%STTI8 O8 O8 OJ0 HnU 0 *!++ +*,''*:*::*FGJ' )6GI&"<<' }K@ #111<( O O{{c)%)YY[0 '+A$++cRVQW)XY O O O_8 O8 O8 On"&,D&*hh{&;&NO O O O9% O'8 O8 Ov"))   K LJKKL8 O < 1 < 8 O- < < < <.[ 8I [[[[ )f"NN+defE8 O^ O 1 O_8 On- O O O O_8 O8 O8 O8 O@ 71!5667sPL5AO5-M.O51AO 3M 4O 7#MMM2 O >M?O  O5MO5PM(M)M> O  M .O 9/N(M3 )N,#M<M6 M<# N.M9/N3O ; O5N7O5 P A-O :N: ;O >#O!N= "O9 O O O  O5OO5PO1O 2O O OO  O5)O* O54P5 MPMPO5 O MO O5MO M0 #M&$M0 +O 3N6M<9N<N NN NN40O 3N44O 7O5:O =OO O5OO O OO O O5 O2&O) 'O2.O55 P>P PP PPcddlm}m}ddlm}m}m}m}m}|d|d|d|d}|r$|jdvr|d |d d sy |d dr|dd|dn|dd|dy |d}|r!|d|jdd|d|d} | r|d| jy y )zGuide the user through WhatsApp setup. Replaces the central _setup_whatsapp in hermes_cli/gateway.py and the static _PLATFORMS["whatsapp"] dict. CLI helpers are lazy-imported so the plugin's module-load surface stays minimal. r) get_env_valuesave_env_value)prompt prompt_yes_no print_header print_info print_successWhatsAppz;WhatsApp uses a local Node.js bridge (WhatsApp Web client).zBStart the bridge separately; the gateway connects to it over HTTP.WHATSAPP_ENABLED>1yestruezWhatsApp: already enabledzReconfigure WhatsApp?FNzEnable WhatsApp?TrfzWhatsApp enabledfalsezWhatsApp left disabledz@Allowed user IDs (comma-separated, leave empty for no allowlist)WHATSAPP_ALLOWED_USERS rmzWhatsApp allowlist configuredz4Home chat ID for cron delivery (leave empty to skip)WHATSAPP_HOME_CHANNEL) hermes_cli.configr[r\hermes_cli.cli_outputr]r^r_r`rarrr) r[r\r]r^r_r`rar allowed_users home_channels r'interactive_setupros@LMST/0HHNN$(<<./4e< '.)62())73+,JM/1F1FsB1OP56PQL. 0B0B0DErTyaml_cfg whatsapp_cfgcddl}d|vrBtjds-t|dj tj d<d|vr:tjds%|j |dtj d<|jd}|YtjdsDt|trd jd |D}t|tj d<d |vrBtjd s-t|d j tj d <|jd }|YtjdsDt|trd jd|D}t|tj d<d|vrBtjds-t|dj tj d<|jd}|YtjdsDt|trd jd|D}t|tj d<y)u/Translate config.yaml whatsapp: keys into WHATSAPP_* env vars. Implements the apply_yaml_config_fn contract (#24849). Mirrors the legacy whatsapp_cfg block from gateway/config.py::load_gateway_config(). Env vars take precedence over YAML. Returns None — everything flows through env. rNrequire_mentionWHATSAPP_REQUIRE_MENTIONmention_patternsWHATSAPP_MENTION_PATTERNSfree_response_chatsWHATSAPP_FREE_RESPONSE_CHATS,c32K|]}t|ywr0rP.0vs r' z%_apply_yaml_config../a3q6/rrrrhc32K|]}t|ywr0r{r|s r'rz%_apply_yaml_config..s-Q#a&-rrrrWHATSAPP_GROUP_ALLOWED_USERSc32K|]}t|ywr0r{r|s r'rz%_apply_yaml_config..rr) rr;rrPrenvirondumpsrrrjoin)rprq_jsonfrcafgafs r'_apply_yaml_configrsL(;U1V14\BS5T1U1[1[1] -.\)"))^2_ ./   0 1C ryy)GH c4 ((/3//C58X 12l"2995I+J+.|K/H+I+O+O+Q '(   , 'B ~bii(@A b$ -"--B/22w +,%bii8O.P.1,~2N.O.U.U.W *+   - .C ryy)GH c4 ((/3//C58X 12 rTct|dixsi}|t|ddr|ryddlm}|jdxsdj j }|d vS) uVWhatsApp is considered connected when the user has explicitly enabled it via ``WHATSAPP_ENABLED`` (or the YAML-bridged equivalent on the config). Auth itself is handled by the external Node.js bridge — we can't verify the bridge token here — so the opt-in flag is the connection signal. The legacy built-in path keyed off ``WHATSAPP_ENABLED`` in both the connected-platforms check and the setup-status display; returning an unconditional True here would make WhatsApp always show as "configured" in ``hermes setup`` even when the user never enabled it. #41112. rNenabledFTrrcrm>rdrerf)rhermes_cli.gatewaygatewayr[rr)rr gateway_modvals r' _is_connectedrsh FGR ( .BE gfi?E-  $ $%7 8 >B E E G M M OC & &&rTct|S)zFFactory wrapper that constructs WhatsAppAdapter from a PlatformConfig.)r)rs r'_build_adapterrs 6 ""rTcx|jddtttdgdtt dddt dd d y ) u:Plugin entry point — called by the Hermes plugin system.rQrbrcuFWhatsApp requires a Node.js bridge — see the WhatsApp messaging docsrhWHATSAPP_ALLOW_ALL_USERSrjiu💬T)rlabeladapter_factorycheck_fn is_connected required_env install_hintsetup_fnapply_yaml_config_fnallowed_users_env allow_all_envcron_deliver_env_varstandalone_sender_fnmax_message_lengthemojiallow_update_commandN)register_platformrrrrorrY)ctxs r'registerrsH &,"()]"/204-!!rTr/)Jr4rloggingr;rRr r=rsystemr5pathlibrtypingrrrr6rhermes_constantsr r r getLoggerr1r]rrrr(rFr rSrcrhr{sysrinsertrP__file__rrgateway.configr|r}rr~gateway.whatsapp_identityrrrrrrrrrutilsrrrrrrKrLrJrMrYrorrrrrrTr'rs"  hoo9, &&E   8 $'###L# S# T# LBSBBB>. . . b    3  4  6;,d,t,\ 3tH~--/77:;<3C5&&&R T c  T.J+-@Jx$<BC#tPS2 d7N*FZTdTkD'T'0# rT