epjS dZddlZddlZddlZddlZddlZddlZddlZejdkZ ddl m Z ddl m Z mZmZddlmZddlmZmZmZd7d ed ed efd ZejeZd Zded efdZded dfdZdede d e fdZ!de d dfdZ"de ded dfdZ#ddde d dfdZ$ddl%Z%e%j&'dee e()j*dddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9ddl:m;Z;d ed e fd!ZGd%d&e/e3Z?hd'Z@hd(ZAhd)ZBd*ed+e d,e d efd-ZCddddd.d/ZDd8d0ZEd1eFd2eFd eFdzfd3ZGd e fd4ZHd5ZId8d6ZJdS)9aG 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_pathnamedefaultreturncvddlm}m} ||}n#|$rtj|}YnwxYw||n|S)aRead a WHATSAPP_* env var through the profile secret scope. Under multiplexing, ``os.getenv`` bypasses the per-profile ``.env`` and returns the process-global value (often unset), causing the bridge to silently fall back to ``"self-chat"`` and reject all messages. ``get_secret`` honors the active ``_profile_runtime_scope`` so secondary profiles see their own credentials. r)UnscopedSecretError get_secret)agent.secret_scoperrosgetenv)r rrrvals H/home/thesage/.hermes/hermes-agent/plugins/platforms/whatsapp/adapter.py_wenvr%sqCBBBBBBBj  ioo /33w.s 22z[owner reply] portcBg} tjddd|dgddddd }|jD]5} |t |&#t$rY2wxYw|r|Sn#t$rYnwxYw tjd d d |gddddd }tj d |jD]7}|t | d8n#t$rYnwxYw|S)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:LISTENTutf-8replacecapture_outputtextencodingerrorstimeoutssz-ltnHpz sport = :z pid=(\d+)) subprocessrunstdoutstrip splitlinesappendint ValueErrorFileNotFoundErrorrefinditergroup)rpidsresultlinems r_listener_pids_on_portr7AsD   UM4MM> :dWYXY   M''))4466  D  CII&&&&      K         8/// 0dWYXY   \6=99 ) )A KKAGGAJJ ( ( ( ( )      KsIAB "A65B 6 BB BB BBA2D DDc  trddlm}tjgdddddd|}|jD]}|}t|dkrm|d d kra|d }| d |rA tjd d|ddgdd|#tj $rYwxYwdSt|D]?} tj |tj##t t"t$f$rY'>!&qJ!**:t::66!!&N!+VU1Xt D/3Q.@.@.B.B *9!!! D! ! !".d33  GC0000*OWED        s`B D7#*C D7C D7C  D7&D78DD7D2/D71D22D77 EErS session_pathcddlm}||sdS|ddlm}|||kSddlm}||}|sdSd|vot ||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_existsFNget_process_start_time)_read_process_cmdlinenode)gateway.statusrXrZr[str)rSrUexpected_startrXrZr[cmdlines r_bridge_pid_is_oursras+***** ;s  u!999999%%c**n<<544444##C((G u g  AC $5$5$@Ac|dz }|sdSd}d} |dd}t|d}t |dkrA|dr't|d}nJ#t tttf$r* | n#t$rYnwxYwYdSwxYwt|||rY tj |tjt d|nI#t$t&tf$rYn0wxYwdd lm}||rt d | | dS#t$rYdSwxYw) 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.pidNrr" rr&z2[whatsapp] Killed stale bridge PID %d from pidfilerWz[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_textrFr-r*rGr.rO TypeError IndexErrorunlinkrarrJrKrLloggerinforMrNr]rXwarning)rUpid_filerSrecorded_startlinesrXs r_kill_stale_bridge_by_pidfilerrsl*H ??   CN ""G"44::4@@%(..""## u::>>eAhnn..> q!1!122N J 7  OO        D   3 n==   GC ( ( ( KKLc R R R R"OW=    D  /..... ;s    NN&'*           sZB$CD $C98D 9 DD DD  D ":EE76E7'F== G  G c ddlm}||}|t|nd||}|dz |ddS#t $rYdSwxYw)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. rrYNz{} {}rdrre)r]rZr^format write_textrO)rUrSrZstartr!s r_write_bridge_pidfilerws 999999&&s++ =s3xxxhooc5.I.I  $000HHHHH      sAA A$#A$Fforceryc>trddt|jdg}|r|d t j|ddddd }n<#t $r/|r|n|Yd SwxYw|j d kr;|j p|j pd }t|p d |jd Sd d l} ||j}|d}|r@|D]'} |#|j$rY$wxYw|d S|D]'} |#|j$rY$wxYw|d S#|j$rYd SwxYw)zITerminate the bridge process using process-tree semantics where possible.r@rAz/TrCTrr rNrr ztaskkill failed for PID ) recursive)rDr^rSr,r'r(r/rJ terminate returncodestderrr)r*rOpsutilProcesschildren NoSuchProcess) procrycmdr4detailsrparentrchilds r_terminate_bridge_processrs63tx==$7   JJt    ^#GI FF !    !    FF     ! !}; ;BBDDG'J%J%J%JKK KMMM))??T?22  !  JJLLLL+D KKMMMMM!  OO%%%%+D          sqA5B  B 6FD('F( D52F4D55FFE('F( E52F4E55F FFr=)PlatformPlatformConfig)WhatsAppBehaviorMixin)to_whatsapp_jid)BasePlatformAdapter MessageEvent MessageType SendResultSUPPORTED_DOCUMENT_TYPEScache_image_from_urlcache_audio_from_url)env_inturlc t|}n#ttf$rYdSwxYwddlm}m}m}m}||||fD]Q} | t|rdS;#ttf$rYNwxYwdS)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) rresolverOr.gateway.platforms.baserrrris_relative_to)rresolvedrrrrroots r_is_allowed_bridge_pathr-s)99$$&& Z uu        &&tDzz'9'9';';<< tt $    H  5s!$9914B))B=<B=pathcddl} ||ddS#t$rYdSwxYw)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. rNr )hashlibsha256 read_bytes hexdigestrO)rrs r_file_content_hashrVseNNN~~doo//00::<e&defd?Z'd>e&ddfd@Z(deddfdAZ)d;eeefdee&fdBZ*xZ+S)GWhatsAppAdapteru 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") - send_read_receipts: Mark accepted inbound WhatsApp messages as read 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 zt|tjtjddlm}|t_d|_|j dd|_ |j dt|jdz |_ t|j dtdd |_|j d |_t|j d pt%d d |_d|j vr"d|_|j d}nZd|j vr"d|_|j d}n/t%drd|_t%d}n d|_d}|||_t|j dpt%dd |_||j dp|j d|_|j dd}t7|t8r|n6t|pddv|_||_tAj!|_"d|_#d|_$d|_%d|_&d|_'|(dd|_)|(dd|_*i|_+i|_,dS)Nr)resolve_whatsapp_bridge_dir bridge_port bridge_scriptz bridge.jsrUzplatforms/whatsapp/sessionzwhatsapp/session reply_prefix dm_policyWHATSAPP_DM_POLICYpairing allow_fromr allowFromWHATSAPP_ALLOWED_USERS group_policyWHATSAPP_GROUP_POLICYgroup_allow_fromgroupAllowFromsend_read_receiptsFr >1onyestruetext_batch_delay_secondsg@text_batch_split_delay_secondsg$@)-super__init__rWHATSAPPr_DEFAULT_BRIDGE_DIR!gateway.platforms.whatsapp_commonr_bridge_processextraget _bridge_portr^_bridge_scriptrr _session_path _reply_prefixrr*lower _dm_policy_dm_allowlist_source_coerce_allow_list _allow_from _group_policy_group_allow_from isinstancebool_send_read_receipts_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 allow_raw read_receipts __class__s rrzWhatsAppAdapter.__init__s !2333  . 6 U U U U U U2M2M2O2OO /;?!'!1!1-!F!F-3\-=-=  (;6 7 7. . $( (8(8  79K L L) ) $ $ -3L,<,<^,L,Lfl..{;;euEY[d?e?effllnnttvv 6< ' '(0D % ((66II FL ( ((0D % ((55II + , , (@D %677II(,D %I229== !1!1.!A!A!nUKbdmEnEnoouuww}}!%!8!89I9IJ\9]9]:DagamaqaqsCbDbD"E"E (()=uEE ' t<< XMM](b))//117799=WW  "&!?!?!A!A-4]__"+/26@D%**.)A)A &* * &04/G/G ,d0 0 ,?A"BD&&&rbkeyrrc`ddl}t|jddr|jj|nd}|t |S t |}n&#t tf$rt |cYSwxYw||r|dkrt |S|S)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) mathgetattrrrrfloatrir.isfinite)rrrrvalueparseds rrz#WhatsAppAdapter._coerce_float_extras  .5dk7D.Q.Q[ !%%c***W[ =>> ! "5\\FF:& " " ">> ! ! ! "}}V$$ " >> ! sA BBF) is_reconnectrc Kts:td|j|ddddSt |j}|s?td|j||dd|d ddS|jd z }|s;td |j||d d ddSt d|j|d} | dt|jdsdSd}n8#t$r+}td|j|Yd}~nd}~wwxYw |j }|dz }|dz dz }t|} d} |dz rO |d| kot#| } n#t$$rd} YnwxYw| s{t'd|jdt)dpd} t+dd} t-j| ddgt|dddd | t1!} | jd"krUt'd|jd#| j |js,|r||dSdSt'd|jd$| r) || dn#t$$rYnwxYwne#t$rX}t'd|jd%|Yd}~|js,|r||dSdSd}~wwxYw|jdd&d"dl } |!4d{V}|"d'|j#d(|$d)*+4d{V }|j%d,kr|&d{V}|"d-d.}|d/kr_|"d0d1}t|}t#|"d2d}||j'k}|r|r||kr|rt'd|jd3|d4|(d|_)|!|_*tWj,|-|_. dddd{Vdddd{V|js,|r||dSdS||kr d5|pd6d7|nd8}t'd|jd9|d:nt'd|jd;|d:dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYn#t$rYnwxYwt_|jta|j#tWj1d<d{Vted=d>}|jj d?z |_3ti|j3d@d}||_5t1}|j6 |j6|dA<|j'rdBndC|dD<ted=d>}|r||d=<dED]}te|}|r|||<d"dFl7m8}m9}m:} t| |dG<t||dH<t||dI<t-j;t)dJpdJt|dKt|j#dLt|jdM|gf|||dNty|_)t{|j|j)j>d"dl }d}!i}tdOD]}"tWj1d<d{V|j)@t'd|jdP|j)jd4t'd|jdQ|j3||js,|r||dSdS |!4d{V}|"d'|j#d(|$d)*+4d{V }|j%d,krrd}!|&d{V}|"d-d/kr=t'd|jdR dddd{Vdddd{VnYdddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwY#t$rYwxYw|!st'd|jdSt'd|jdQ|j3| |js,|r||dSdS|"d-d/krYt'd|jdTtdOD]}"tWj1d<d{V|j)@t'd|jdUt'd|jdQ|j3||js,|r||dSdS |!4d{V}|"d'|j#d(|$d)*+4d{V }|j%d,krp|&d{V}|"d-d/kr=t'd|jdR dddd{Vdddd{Vndddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwY#t$rYwxYwt'd|jdVt'd|jdW|j3t'd|jdX|!|_*tWj,|-|_.|(t'd|jdY|j# |js,|r||dSdS#t$ra}tAdZ|j|d[Yd}~|js,|r||dSdSd}~wwxYw#|js+|r||wwxYw)\z Start the WhatsApp bridge. This launches the Node.js bridge process and waits for it to be ready. z2[%s] Node.js not found. WhatsApp requires Node.js.whatsapp_node_missinguINode.js is not installed — install Node.js and re-run `hermes gateway`.F retryablez [%s] Bridge script not found: %swhatsapp_bridge_missingz"WhatsApp bridge script missing at .z creds.jsonz[%s] WhatsApp is enabled but not paired (no creds.json at %s). Pair from the dashboard or run `hermes whatsapp`; remove WHATSAPP_ENABLED from your .env to disable.whatsapp_not_paireduUWhatsApp enabled but not paired — pair from the dashboard or run `hermes whatsapp`.z[%s] Bridge found at %szwhatsapp-sessionzWhatsApp sessionTz3[%s] Could not acquire session lock (non-fatal): %sNz package.json node_modulesz.hermes-pkg-hashrre[z,] Installing WhatsApp bridge dependencies...npmWHATSAPP_NPM_INSTALL_TIMEOUTi,installz--silentr)cwdr r!r"r#r$envrz] npm install failed: z] Dependencies installedz"] Failed to install dependencies: )parentsexist_okhttp://127.0.0.1:z/healthtotalr$statusunknown connected scriptHashr sendReadReceiptsz!] Using existing bridge (status: )zrunning= unversionedz, disk=z!send_read_receipts config changedz] Running bridge is stale (z ), restartingz*] Bridge found but not connected (status: r& WHATSAPP_MODEz self-chatz bridge.logaWHATSAPP_REPLY_PREFIXrfalseWHATSAPP_SEND_READ_RECEIPTS)rWHATSAPP_ALLOW_FROMrrWHATSAPP_GROUP_ALLOWED_USERSWHATSAPP_GROUP_ALLOW_FROMWHATSAPP_REQUIRE_MENTIONWHATSAPP_MENTION_PATTERNSWHATSAPP_FREE_RESPONSE_CHATSWHATSAPP_DEBUGWHATSAPP_FORWARD_OWNER_MESSAGESrWHATSAPP_MAX_MESSAGE_LENGTHWHATSAPP_CHUNK_DELAY_MSWHATSAPP_SEND_TIMEOUT_MS)rrrHERMES_IMAGE_CACHE_DIRHERMES_AUDIO_CACHE_DIRHERMES_DOCUMENT_CACHE_DIRr\z--portz --sessionz--mode)r)rrz!] Bridge process died (exit code z ] Check log: z"] Bridge ready (status: connected)z)] Bridge HTTP server did not start in 15sz7] Bridge HTTP ready, waiting for WhatsApp connection...z'] Bridge process died during connectionu&] ⚠ WhatsApp not connected after 30sz] Bridge log: z0] If session expired, re-pair: hermes whatsappz] Bridge started on port z[%s] Failed to start bridge: %s)exc_info)Brrlrnr _set_fatal_errorrrrgrrm_acquire_platform_lockr^rPrrrhr*rrOprintr rr'r(r r~r_running_release_platform_lock_close_bridge_logrumkdiraiohttp ClientSessionrr ClientTimeoutrjsonr_mark_connectedrrr create_task_poll_messagesrrrrTsleeprropenrrrrrrPopenrrwrSrangepollerror)#rr bridge_path creds_path lock_acquirede bridge_dir _pkg_json _dep_stamp _pkg_hash _deps_fresh_npm_binnpm_install_timeoutinstall_resultr2sessionrespdata bridge_status running_hash disk_hashrunning_read_receiptsconfig_matches stale_reason whatsapp_mode bridge_log_fh bridge_env_profile_wa_mode_key_v_get_audio_dir _get_doc_dir _get_img_dir http_readyattempts# rconnectzWhatsAppAdapter.connects +,,  NNOQUQZ [ [ [  ! !'[ "    54.// !!##  NN=ty+ V V V  ! !)C[CCC "    5',6   ""  NN> :      ! !%g "    5 -ty+FFF  `../A3tGYCZCZ\noo u MM ` ` ` NNPRVR[]^ _ _ _ _ _ _ _ _ ` ) %+J"^3I#n47IIJ*955IK^+3355 ((",,g,>>DDFF)S#*y// K((("'KKK( !Q$)QQQRRR066?%!+22PRU*V*V'%/^!9j9 OO'+!GI 3133 &&&N&0A55Z$)ZZ>CXZZ[[[$p= ) 2//111&&((((( ) )oAdiAAABBB !!&11)g1NNNN&!!! D! !!!NdiNN1NNOOO 555^= ) 2//111&&((((( ) )c!   $ $TD $ A A A NNN, "0022)})})})})})})}g&{{FD,=FFF ' 5 5A 5 > > +  (}(}(}(}(}(}(}(};#--)-#4#4#4#4#4#4D,0HHXy,I,IM, ;;04xx b/I/I ,>{,K,K 8 ?+  * *4[[*')Jt$            47||~~3F3FJ/ 036~~7G7G3H3HJ/ 069,,..6I6IJ2 3#-#3(00:F $$c$"344T%7!8!8m  $%$ $ $.// $ $D  "$"4d6J6N O O O NNNJD 99  mA&&&&&&&&&',,..:ldill$J^JilllmmmHdiHHd6FHHIII**,,, F= ) 2//111&&((((( ) )E &4466 * * * * * * *'#*;;J0AJJJ$+$9$9$9$B$B$/$$ * * * * * * * *"#{c11-1 -1YY[['8'8'8'8'8'8#'88H#5#5#D#D$)*[di*[*[*[$\$\$\$) * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *!H N$)NNNOOOD$)DD$2BDDEEE&&(((^= ) 2//111&&((((( ) )Wxx!![00\$)\\\]]]$Ryy[[G!-*********+0022>T$)TTTUUUL$)LL$:JLLMMM..000$F= ) 2//111&&((((( ) )E !#*#8#8#:#: . . . . . . .g'.{{ ND4E N N N(/(=(=A(=(F(F(3((........"&#';##5#515+<+<+<+<+<+rz-[%s] Bridge exited during shutdown (code %d).z2WhatsApp bridge process exited unexpectedly (code z).z[%s] %swhatsapp_bridge_exitedTr) rr=rrlrmr has_fatal_errorr>r+r0_notify_fatal_errorfatal_error_message)rr~messages r_check_managed_bridge_exitz*WhatsAppAdapter._check_managed_bridge_exitAs   '4)..00  4 4)5 1 1 jL6P6P KK?     4UzUUU# - LLDIw 7 7 7  ! !":Gt ! T T T  " " $ $ $**,, , , , , , , ,'272rbcKd|_|jr t|jdn0#ttf$r|jYnwxYwt jdd{V|jH t|jdn0#ttf$r|j YnwxYwnI#t$r$}td|j d|Yd}~n d}~wwxYwtd|j d |j d z d n#t$rYnwxYw|jr]|jsD|j |jd{Vn#t jtf$rYnwxYwd|_|jr+|jjs|jd{Vd|_||d|_|td|j d dS) z=Stop the WhatsApp bridge and clean up any orphaned processes.TFrxr&Nrz] Error stopping bridge: z.] Disconnecting (external bridge left running)rd) missing_okz] Disconnected)rrrrMrNr}rr9r=rJrPr-r rrkrOrdonecancelCancelledErrorrclosedrar/_mark_disconnectedr0)rrBs r disconnectzWhatsAppAdapter.disconnectas #   Q C5-d.B%PPPPP*O<555(22444445mA&&&&&&&&&',,..641$2FdSSSSS.@444,11333334 C C CA$)AAaAABBBBBBBB C OdiOOO P P P   , . 6 6$ 6 G G G G    D  ? 4?#7#7#9#9  O " " $ $ $ o%%%%%%%%*I6       -d&8&? -$**,, , , , , , , ,! ##%%% !!!#     +$)+++,,,,,sz*C*ACA6CB%$C%*CCCC D C??D D?? E  E  FF0/F0chat_idcontentreply_tometadatac K|jr|jstddS|d{V}|rtd|S|r|stddSt |} ddl}||}||| }g} d} t|D]H\} } || d} |r | dkr|| d <|j d |j d | | d 4d{V }|jdkrT|d{V}|d} | r"| t%| n?|d{V}td|cdddd{VcSdddd{Vn#1d{VswxYwYt)|dkrt+jdd{VJtd| t/| ddd| iS#t0$r(}tdt%|cYd}~Sd}~wwxYw)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 connectedsuccessr>NTrz message_idrchatIdrireplyTor /sendr r5r$r messageIdr&g333333? message_ids)rzr|continuation_message_ids raw_response)r.rrrjr*rr2format_messagetruncate_message_outgoing_chunk_limit enumeratepostrr4rr5rr,r^r!rGrr9tuplerP)rrsrtrurv bridge_exitr2 formattedchunkssent_message_idslast_message_ididxchunkpayloadrLrMr>rBs rsendzWhatsAppAdapter.sends} DD$6 De?CCC C ;;========  @e;??? ? =gmmoo =dt<<< <!'**, ; NNN++G44I**9d6P6P6R6RSSF*, "O'// - - U%$++2q*2GI&-22@(9@@@ #111;;3 F F F F F F F F{c))%)YY[[000000*.((;*?*?*J,33C4H4HIII&*iikk 1 1 1 1 1 1)%uEEE F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F Fv;;??!-,,,,,,,,,*)./?/D)E)E+-=>    ; ; ;e3q66::: : : : : : : ;sKB,I3B G$=II$ G. .I1G. 2AI JI;5J;J)finalizer|rcK|jr|jstddS|d{V}|rtd|S ddl}|jd|jdt|||d|d  4d{V }|j d kr#td |cdddd{VS| d{V}td|cdddd{VS#1d{VswxYwYdS#t$r(} tdt| cYd} ~ Sd} ~ wwxYw)z7Edit a previously sent message via the WhatsApp bridge.FrxryNrr z/edit)r~rrir)r rrTr{) r.rrrjr2rrrr4rr!rPr^) rrsr|rtrrr2rLr>rBs r edit_messagezWhatsAppAdapter.edit_messages} DD$6 De?CCC C ;;========  @e;??? ? ; NNN)..rBs r_send_media_to_bridgez%WhatsAppAdapter._send_media_to_bridgesF} DD$6 De?CCC C ;;========  @e;??? ?! ; NNN7>>),, W!%7U)7U7UVVVV*'22%'''G  -%, " 0&/ #)..BD$5BBB--C-88/ B B B B B B B B;#%%!%,,,,,,D% $#'88K#8#8%) B B B B B B B B B B B B B B#'))++------E%e5AAA B B B B B B B B B B B B B B B B B B B B B B B B B B B B B B  ; ; ;e3q66::: : : : : : : ;sV6FA!F)A F3F*F0F F  FF F G G=GGr&selectable_countquestionoptionsrc4K|jr|jstddS|d{V}|rtd|S ddl}t ||t |pg|d}|jd|jd|| d  4d{V }|j d krQ| d{V} td | d| cdddd{VS| d{V} td| cdddd{VS#1d{VswxYwYdS#t$r(} tdt| cYd} ~ Sd} ~ wwxYw)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. FrxryNr)r~rrselectableCountr z /send-pollrr rrTrr)r.rrrjr2rlistrrr4rr5rr!rPr^) rrsrrrrr2rrLrMr>rBs r send_pollzWhatsAppAdapter.send_poll+s} DD$6 De?CCC C ;;========  @e;??? ? ; NNN*'22$ 2..#3 ''G )..AD$5AAA--B-77/ > > > > > > > >;#%%!%,,,,,,D% $#'88K#8#8%) > > > > > > > > > > > > > >#iikk))))))!%u=== > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > ; ; ;e3q66::: : : : : : : ;sPA'E%8A EE%*E?E% EE%E E%% F/F FFchoices clarify_id session_keycKd|pgD}dt|cxkrdkrrnno||t|pd|dd{V}|jr|St d|j|jt |||||| d{VS) 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. cg|]D}t|#t|ES)r^r*).0choices r z0WhatsAppAdapter.send_clarify..isBbbbcRXkkN_N_NaNabV**,,bbbrbr  r r&rNzB[%s] Native WhatsApp clarify poll failed; falling back to text: %s)rsrrrrrv) rGrr^r*rzrlrnr r>r send_clarify) rrsrrrrrv clean_choicesr4rs rrzWhatsAppAdapter.send_clarifyXs,"cbGMrbbb M"" ( ( ( (b ( ( ( ( (>>HN##))++!" *F ~  NNT      WW))!# *         rb)r addressrurvlatitude longituder rcdK|jr|jstddS|d{V}|rtd|S ddl} t |t |t |d} |r|| d<|r|| d<|jd |jd | | d  4d{V } | j dkrQ| d{V} td| d| cdddd{VS| d{V} td| cdddd{VS#1d{VswxYwYdS#t$r(}tdt|cYd}~Sd}~wwxYw)z;Send a native WhatsApp location pin via the Baileys bridge.FrxryNr)r~rrr rr z/send-locationrr rrTrr)r.rrrjr2rrrrr4rr5rr!rPr^)rrsrrr rrurvrr2rrLrMr>rBs r send_locationzWhatsAppAdapter.send_locations} DD$6 De?CCC C ;;========  @e;??? ? ; NNN*'22!(OO"9--''G  '"& -%, ")..ED$5EEE--B-77/ > > > > > > > >;#%%!%,,,,,,D% $#'88K#8#8%) > > > > > > > > > > > > > >#iikk))))))!%u=== > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > ; ; ;e3q66::: : : : : : : ;sPA?E=A E*E=-*E*E=* E44E=7E48E== F/F*$F/*F/ image_urlcK t|d{V}|||d|d{VS#t$r.t|||||d{VcYSwxYw)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)rrrPr send_image)rrsrrrurv local_pathrs rrzWhatsAppAdapter.send_images ]3I>>>>>>>>J33GZRYZZZZZZZZ Z ] ] ]++GYS[\\\\\\\\ \ \ \ ]s285A0/A0 image_pathcBK|||d|d{VS)z,Send a local image file natively via bridge.rNr)rrsrrrukwargss rsend_image_filezWhatsAppAdapter.send_image_file4//WgVVVVVVVVVrb video_pathcBK|||d|d{VS)u>Send a video natively via bridge — plays inline in WhatsApp.videoNr)rrsrrrurs r send_videozWhatsAppAdapter.send_videorrb audio_pathcBK|||d|d{VS)z:Send an audio file as a WhatsApp voice message via bridge.audioNr)rrsrrrurs r send_voicezWhatsAppAdapter.send_voicerrbc K|||d||ptj|d{VS)z=Send a document/file as a downloadable attachment via bridge.documentN)rrrbasename)rrsrrrrurs r send_documentzWhatsAppAdapter.send_documents_// Y G  4)))44         rbcxK|jr|jsdS|d{VrdS ddl}|jd|jddt |i|d4d{V dddd{VdS#1d{VswxYwYdS#t$rYdSwxYw) z!Send typing indicator via bridge.Nrr z/typingr~rr r) r.rrjr2rrrr4rP)rrsrvr2s r send_typingzWhatsAppAdapter.send_typings} D$6  F0022 2 2 2 2 2 2  F  NNN )..>D$5>>> 8 89--A-66/                                             DD s6AB+BB+ B""B+%B"&B++ B98B9cK|jr|jsdddS|d{Vr|ddS ddl}|jd|jdt ||d  4d{V }|jd krq| d{V}|d ||d rdnd|dgdcdddd{VS dddd{Vn#1d{VswxYwYn3#t$r&}t d||Yd}~nd}~wwxYw|ddS)z&Get information about a WhatsApp chat.Unknowndm)r typeNrr z/chat/r{r r rr isGroupr2 participants)r rrz+Could not get WhatsApp chat info for %s: %s) r.rrjr2rrrr4rr5rPrldebug)rrsr2rLrMrBs r get_chat_infozWhatsAppAdapter.get_chat_info s} 5D$6 5%t44 40022 2 2 2 2 2 2 3#T22 2 T NNN)--WD$5WW_W=U=UWW--B-77.        ;#%%!%,,,,,,D $ 9 9+/88I+>+> HD(,(D(D              &                            T T T LLFQR S S S S S S S S T ...sCAD+ A*D3D+D+ D##D+&D#'D++ E5EEcPKddl}|jr|jsdS|d{V}|rt d|jd|dS |jd|jd|d 4d{V }|j d kr| d{V}|D]}| |d{V}|rmtj |||jt jkr||q||d{Vdddd{Vn#1d{VswxYwYn#tj$rYdSt*$rz}|d{V}|r t d|jd|Yd}~dSt d|jd |tjd d{VYd}~nd}~wwxYwtjd d{V|jdSdS)z&Poll the bridge for incoming messages.rNrz] r z /messagesrr r rz] Poll error: rr&)r2r.rrjr-r rrr4rr5_build_message_eventrr7_send_read_receipt message_typerTEXT_enqueue_text_eventhandle_messagerorPr9)rr2rrLmessagesmsg_dataeventrBs rr8zWhatsAppAdapter._poll_messages$sm# #%  $ ? ? A AAAAAAAK 4$)44{44555 '-11D(9DDD#111;;2EEEEEEEE{c)))-#4#4#4#4#4#4(0 E EH*.*C*CH*M*M$M$M$M$M$M$ME$E!( 3D4K4KH4U4U V V V#(#59I#I#I$($<$Mark a policy-accepted inbound message as read via the bridge.NreadReceiptKeyrr z/readrrr rrz.[%s] WhatsApp read receipt failed with HTTP %sz%[%s] WhatsApp read receipt failed: %s)rrrrdictr2rrr4rrlrnr rP)rrMrr2rLexcs rrz"WhatsAppAdapter._send_read_receiptMs' t/A  Fhh'((#t$$  F T NNN)..|j|j|j|j|j |}|r(| s| tj |||j |<dS)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. r Nrf)rrrrGr!_last_chunk_len media_urlsextend media_typesrrmrnrr7_flush_text_batch)rrrexisting chunk_len prior_tasks rrz#WhatsAppAdapter._enqueue_text_eventssL""5))-11#66 (b))  $-E !.3D &s + +z bDLM a8= @ @EJ @ @ @W\Wa '0H $ ?#**5+;<<<$++E,=>>>377<<  joo//      .5.A  " "3 ' '/ / &s+++rbcKtj} |j|}|rt |ddnd}||jkr|j}n|j}tj|d{V|j |d}|s< |j ||ur|j |ddSdS| |d{V|j ||ur|j |ddSdS#|j ||ur|j |dwwxYw)z4Wait for quiet period then dispatch aggregated text.rrN) r current_taskrrr_SPLIT_THRESHOLDrrr9poprr)rrrpendinglast_lendelayrs rrz!WhatsAppAdapter._flush_text_batchs+--  >044S99GAHOww(91===aH4000<6-&& & & & & & & &.223==E -11#66,FF.223=====GF%%e,, , , , , , , ,-11#66,FF.223=====GFt-11#66,FF.223====GsBD)D)):E#cK ||sdStj}t|ddpd}|dvr tj}nx|dkr tj}ne|drPd|vr tj}n?d|vr tj}n.d |vr tj }nd |vr tj }n tj }|d d }|rd nd}| |dd|d||d|d}|dg}g}g} |D]M} t|dpd } |tjkr| dr t| dd{V} || | | pdt#d|jd| d#t&$rS} t#d|jd| d|| | | pdYd} ~ d} ~ wwxYw|tjkrt(j| rwt/| rJ|| | | pdt#d|jd| dt#d|jd | d|tj tj hvr| dr t1| d!d{V} || | | p|tj krd"nd#t#d|jd$| dh#t&$re} t#d|jd%| d|| | | p|tj krd"nd#Yd} ~ d} ~ wwxYw|tj tj hvrt(j| rt/| r\|| | | p|tj krd"nd#t#d|jd&| d~t#d|jd'| d|tj krt(j| rt/| r|| t3| j}| pt9j|d(}| |t#d|jd)| d_t#d|jd*| d}|tjkrt(j| rwt/| rJ|| | | pd+t#d|jd,| dt#d|jd-| d#|| | d.O|d/d}|d r|||}|tj kr;|r9t| d0krd}t|d1pd }|pd}d}d}d }|d2rg|d3}|t|}||d4}|r|}||}d5}|tj kr[|rX|D]T}t3|j}|d6vr& t3| j!}||kr$t#d|jd7|d8|d9|d: dt3|"d;d<=}t3|j}|}d>|vr1|#d>d?}tI|d@kr|d?}dA|dB|}|r|dC|}n|}t#d|jdD|d #t&$r'} t#d|jdE| dYd} ~ Ld} ~ wwxYwVi} t|dFpd }!|dG}"|!r|!| dH<tK|"tLr|"r|"| dI<|dJr*d| dK<|tNs tN|}tQ|||||dL|| | ||||M S#t&$r%} t#d|jdN| Yd} ~ dSd} ~ wwxYw)OzKBuild a MessageEvent from bridge message data, downloading images to cache.Nrr >location live_locationstickerhasMediarrpttrrFr2rr~chatNamesenderId senderName)rs 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: rbodyz[ptt received] quotedTexthasQuotedMessagequotedMessageIdquotedParticipanti> .js.md.py.ts.css.csv.log.txt.xml.yml.html.json.yamlz] Skipping text injection for z (z bytes > rrr)r"r#_r r=z [Content of z]: z z] Injected text content from: z ] Failed to read document text: nativeTypenativeMetadatawhatsapp_native_typewhatsapp_native fromOwnerwhatsapp_from_ownerr) r!rr raw_messager|rrrvreply_to_message_id reply_to_textreply_to_author_idreply_to_is_own_messagez] Error building event: ))_should_process_messagerrr^rLOCATIONSTICKERPHOTOVIDEOVOICEAUDIODOCUMENT build_sourcer* startswithrr,r-r rPrrisabsrrrsuffixrr_clean_bot_mention_text_normalize_whatsapp_id_message_is_reply_to_botstatst_sizerhrFrGrr_OWNER_REPLY_PREFIXr)#rrMmsg_typeris_grouprrraw_urls cached_urlsrr bridge_mime cached_pathrBrrr quoted_textr5r4r6r7 raw_reply_idquoted_participantMAX_TEXT_INJECT_BYTESdoc_path file_sizertfname display_namerQ injectionrv native_typenative_metadatas# rrz$WhatsAppAdapter._build_message_eventsH F //55 t#'HTXXk266<"==J:::&/y((&.*%% 4j((*0HH ***0HHj((*0HH ***0HH*3Hxx 511H#+5I&&2..((:..#,,((<00 'Fxx R00HKK9 29 2!$((6"2"2"8b99??AA {000S^^D[5\5\0H,@&,Q,Q,Q&Q&Q&Q&Q&Q&Q #**;777#**;+F,GGGO$)OO+OOW[\\\\\$HHHI$)IIaIIQUVVVV#**3///#**;+F,GGGGGGGGH!222rw}}S7I7I2.s33p#**3///#**;+F,GGGO$)OO#OOW[\\\\\b$)bb]`bbjnooooo+"3[5F!GGGCNN[rLsLsG|,@&,Q,Q,Q&Q&Q&Q&Q&Q&Q #**;777#**;+z(VaVgJgJg;;my{{{O$)OO+OOW[\\\\\$|||I$)IIaIIQUVVVV#**3///#**;+z(VaVgJgJg;;my{{{{{{{{|+"3[5F!GGGBGMMZ]L^L^G.s33p#**3///#**;+z(VaVgJgJg;;my{{{O$)OO#OOW[\\\\\b$)bb]`bbjnooooo!555"'--:L:L5.s33s#**3///"3ii.4466*k.F.J3Pj.k.k#**4000R$)RRSRRZ^_____e$)ee`ceemqrrrrr!222rw}}S7I7I2.s33p#**3///#**;+E+FFFO$)OO#OOW[\\\\\b$)bb]`bbjnooooo&&s+++&&y1111 88FB''Dxx "" @33D$??K---.IIOO%%++--1AAA  dhh|44:;;AACCK'/4M"& !% &+ #xx*++ N#xx(9:: +*-l*;*;'%)%@%@J]A^A^%_%_"%<);&*.*G*G*M*M'$. !;///K/ +bbHx../5577CFFFb(,X(;(;(=(=(EI(+@@@ %'L$)'L'LS['L'L_h'L'LtI'L'L'LTX!Y!Y!Y!Y (&*8nn&>&>Xa&>&b&bG$(NN$7E+0L"e||(- C(;(;#&u::??388L(R|(R(R(R(RI#1*3'?'?'?'?'0!"Ydi"Y"Yx"Y"Yaefffff(bbb!"Tdi"T"TQR"T"T\`aaaaaaaaab)F.(*Hdhh|44:;;AACCK"hh'788O ?3>/0/400 >_ >.=*+xx $$ :26./':;;:19499D% 88K00&'!$7+#5(?        * C;  C;C;C;C;V ;;;;; ;  ; ;;;;L"&#' /;/;/;/; /; # /; C= /; /;/;/;/;n!" +;+;+;+;+;c +;  +; +;+;+;+;h.2' ' ' ' $ '  '  ' 4S>*'  ' ' ' ' ' ' ^#!%"&-1,;,;,;,;,; ,; sm ,;#,;3-,;4S>*,; ,;,;,;,;d"&"&-1 ]]]]# ] 3- ] 4S>* ] ]]]]]]2"&"& W W W W# W 3- W  W W W W"&"& W W W W# W 3- W  W W W W"&"& W W W W# W 3- W  W W W W"&#'"&       #  C=  3-        ,/3/4S>////4'#'#'#'#RTT#s(^TTTTT4 \ c      $    8>3>4>>>>&HtCH~H(.gif.png.jpeg.webpr>.3gp.avi.mkv.mov.mp4.webm>.m4a.mp3.wav.flac.opusrris_voiceforce_documentc|rdStj|d}|s |tvrdS|t vrdS|t vrdSdS)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. rr&rrr)rrsplitextr_WA_AUDIO_EXTS_WA_IMAGE_EXTS_WA_VIDEO_EXTS)rrrrsrs r_bridge_media_typeryssz '  9 % %a ( . . 0 0C3.((w nw nw :rb) thread_id media_filesrsrc Kt|dipi} ddl}n#t$rddicYSwxYw |dd} t |} |pg} |pd} |rt | d kr|nd} d}|4d{V}| r| s|d | d | | d | d 4d{V }|j dkrM| d{V}dd|j d|icdddd{Vcdddd{VS| d{V}|d}dddd{Vn#1d{VswxYwY| D]1\}}tj|s| r |d | d | | d | d 4d{V }|j dkr-| d{Vd} dddd{Vn#1d{VswxYwYn*#t $rt"dYnwxYwdd|iccdddd{VSt'|||}| ||d}|dkr"tj||d<| r| |d<|d | d|| d4d{V }|j dkrO| d{V}dd|j d|icdddd{Vccdddd{VS| d{V}|dp|}dddd{Vn#1d{VswxYwY3 dddd{Vn#1d{VswxYwYdd| |dS#t $r}dd |icYd}~Sd}~wwxYw)!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. rrNr>z/aiohttp not installed. Run: pip install aiohttprrr r&zhttp://localhost:rr}rr rrzWhatsApp bridge error (z): rz7WhatsApp caption-fallback send failed for missing mediazWhatsApp media file not found: rrrrrrzWhatsApp media error (Twhatsapp)rzplatformrsr|zWhatsApp send failed: )rr2 ImportErrorrrrGr3r*rr4rr!r5rrrgrPrlrnryr)pconfigrsrirzr{rsrrr2rnormalized_chat_idmediar! media_captionrrKrLrrM media_pathrrrrrBs r_standalone_sendrs * GWb ) ) /REL LLLJKKKKLJ7ii t44 ,W55!r}"%,JE ad ((**8 O8 O8 O8 O8 O8 O8 Ogzz|| O*O/=/E>,O> F O F ,O99I39H?-I? I I I IO$I85O7I88 OO/AN; ?OO/ O!!O/$O!% O// P 9P?P P cdddlm}m}m}ddlm}m}m}m}m }|d|d|d|d}|r/| dvr|d |d d sd S|d dr|dd|dn|dd|dd S|d} | r+|d| dd|d|d } | r|d| d S|dr |dd Sd S)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_valueremove_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>rrrzWhatsApp: already enabledzReconfigure WhatsApp?FNzEnable WhatsApp?TrzWhatsApp enabledrzWhatsApp left disabledz@Allowed user IDs (comma-separated, leave empty for no allowlist)r r zWhatsApp allowlist configuredz4Home chat ID for cron delivery (leave empty to skip)WHATSAPP_HOME_CHANNELzHome channel cleared.) hermes_cli.configrrrhermes_cli.cli_outputrrrrrrrr*) rrrrrrrrr allowed_users home_channels rinteractive_setuprsRQQQQQQQQQLJLMMMJSTTT}/00HHNN$$(<<< .///}4e<<  F}'..)6222 ()))))7333 +,,,FJM7/1F1FsB1O1OPPP 56666PQQWWYYL0. =====  3 4 4 0 J. / / / / / 0 0rbyaml_cfg whatsapp_cfgc8ddl}d|vrHtjds4t|dtjd<d|vrz%_apply_yaml_config..;(//a3q66//////rbrrrrc34K|]}t|VdSr\rrs rrz%_apply_yaml_config..Bs(--Q#a&&------rbrrrrc34K|]}t|VdSr\rrs rrz%_apply_yaml_config..Irrb) r5rrr^renvirondumpsrrrjoin)rr_jsonfrcafgafs r_apply_yaml_configr,sYL((;U1V1V(14\BS5T1U1U1[1[1]1] -.\))")^2_2_ ./   0 1 1C ry)GHH c4  0((//3/////C58XX 12l""295I+J+J"+.|K/H+I+I+O+O+Q+Q '(   , ' 'B ~bi(@AA~ b$   .--"-----B/22ww +,%%bi8O.P.P%.1,~2N.O.O.U.U.W.W *+   - . .C ry)GHH c4  0((//3/////C58XX 12 4rbct|dipi}|t|ddr|rdSddlm}|dpd}|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. rNenabledFTrrr >rrr)rhermes_cli.gatewaygatewayrr*r)rr gateway_modrs r _is_connectedrNs FGR ( ( .BE gfi??Et-,,,,,  $ $%7 8 8 >B E E G G M M O OC & &&rbc t|S)zFFactory wrapper that constructs WhatsAppAdapter from a PlatformConfig.)r)rs r_build_adapterrfs 6 " ""rbc|ddtttdgdtt dddt dd d d S) u:Plugin entry point — called by the Hermes plugin system.r}rruFWhatsApp requires a Node.js bridge — see the WhatsApp messaging docsrWHATSAPP_ALLOW_ALL_USERSriu💬T)r labeladapter_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_platformrrrrrr)ctxs rregisterrks\ &,"()]"/204-!!rb)r r[)Kr`rloggingrr~r0rKr'systemrDpathlibrtypingrrrrErhermes_constantsr r r r^r getLoggerr]rlrIr-rr7rTrrarrrwrsysrinsert__file__rrgateway.configrrrrgateway.whatsapp_identityrrrrrrrrrutilsrrrrrrwrxrvryrrrrrrrrrbrrs"  ho9, &&&&&&&&&&EEEEEE ///c/3////*  8 $ $'######L# S# T# # # # LBSBBBBBB>. . . . . . b    3  4     6;,,,d,t,,,,\ 33ttH~~--//7:;;<<<33333333CCCCCC555555&&&&&&R T c     T.mmmmm+-@mmm~'<;;BBBCCC#tPS2 d7d7d7d7d7N-0-0-0-0`TdTkD'T''''0### rb