Jj3dZddlZddlZddlZddlZddlZddlZddlZejdkZ ddl m Z ddl m Z mZmZddlmZmZmZejeZdZded efd Zded dfd Zd ed e d efdZd e d dfdZd e d ed dfdZddded dfdZ ddl!Z!e!j"#de$e e%&j'dddl(m)Z)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6ddl7m8Z8de$d efdZ9de d e$fdZ:d efdZ;Gd d!e,e0Zhd$Z?d%e$d&ed'ed e$fd(Z@dddd)d*ZAd2d+ZBd,eCd-eCd eCdzfd.ZDd efd/ZEd0ZFd2d1ZGdS)3aG 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)find_node_executableget_hermes_dirwith_hermes_node_pathz[owner reply] portreturnc:g} tjddd|dgddd}|jD]5} |t |&#t$rY2wxYw|r|Sn#t$rYnwxYw tjdd d |gddd}tj d |jD]7}|t | d 8n#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:LISTENTcapture_outputtexttimeoutssz-ltnHpz sport = :z pid=(\d+)) subprocessrunstdoutstrip splitlinesappendint ValueErrorFileNotFoundErrorrefinditergroup)r pidsresultlinems H/home/rurouni/.hermes/hermes-agent/plugins/platforms/whatsapp/adapter.py_listener_pids_on_portr'+s}D   UM4MM> :dA   M''))4466  D  CII&&&&      K         8/// 0dA   \6=99 ) )A KKAGGAJJ ( ( ( ( )      KsIA B "A43B 4 B>B BB BBA0D DDc trddlm}tjgdddd|}|jD]}|}t|dkrm|ddkra|d }| d |rA tjd d |d dgdd|#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`BD5!*C  D5 CD5CD5$D56DD5D0-D5/D00D55 EErD 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.statusrIrKrLstr)rDrFexpected_startrIrKrLcmdlines r&_bridge_pid_is_oursrRws+***** ;s  u!999999%%c**n<<544444##C((G u g  AC $5$5$@Ac|dz }|sdSd}d} |d}t|d}t |dkrA|dr't|d}nJ#t tttf$r* | n#t$rYnwxYwYdSwxYwt|||rY tj |tjt d|nI#t$t&tf$rYn0wxYwddlm}||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.pidN rrz2[whatsapp] Killed stale bridge PID %d from pidfilerHz[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_textr6rrr7rr@ TypeError IndexErrorunlinkrRr:r;r<r=loggerinfor>r?rNrIwarning)rFpid_filerDrecorded_startlinesrIs r&_kill_stale_bridge_by_pidfilerbsl*H ??   CN ""$$**400%(..""## u::>>eAhnn..> q!1!122N J 7  OO        D   3 n==   GC ( ( ( KKLc R R R R"OW=    D  /..... ;s    NN&'*           sZB"CD "C76D 7 DD DD  D  :EE54E5%F;; G G c ddlm}||}|t|nd||}|dz |dS#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. rrJNz{} {}rU)rNrKrOformat write_textr@)rFrDrKstartrs r&_write_bridge_pidfilergs 999999&&s++ =s3xxxhooc5.I.I  $0066666      sAA A"!A"Fforceric:trddt|jdg}|r|d t j|ddd}n<#t $r/|r|n|YdSwxYw|j d kr;|j p|j pd }t|p d |jdSd dl} ||j}|d }|r@|D]'} |#|j$rY$wxYw|dS|D]'} |#|j$rY$wxYw|dS#|j$rYdSwxYw) zITerminate the bridge process using process-tree semantics where possible.r0r1z/Tr3T rNrztaskkill failed for PID ) recursive)r4rOrDrrrrr; terminate returncodestderrrrr@psutilProcesschildren NoSuchProcess) procricmdr#detailsrqparentrschilds r&_terminate_bridge_processrzs63tx==$7   JJt    ^# FF !    !    FF     ! !}; ;BBDDG'J%J%J%JKK KMMM))??T?22  !  JJLLLL+D KKMMMMM!  OO%%%%+D          sqA5B  B 6F D&%F & D30F 2D33F F E&%F & E30F 2E33F 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) rresolver@rgateway.platforms.baserrrris_relative_to)rresolvedrrrrroots r&_is_allowed_bridge_pathrs)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. rNrl)hashlibsha256 read_bytes hexdigestr@)rrs r&_file_content_hashr@seNNN~~doo//00::<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|tjtjddlm}|t_d|_|j dd|_ |j dt|jdz |_ t|j dtdd |_|j d |_t|j d pt%jd d |_||j dp|j d|_t|j dpt%jdd |_||j dp|j d|_||_t;j|_d|_ d|_!d|_"d|_#d|_$|%dd|_&|%dd|_'i|_(i|_)dS)Nr)resolve_whatsapp_bridge_dir bridge_port bridge_scriptz bridge.jsrFzplatforms/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_portrO_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__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..{;;iryI]_h?i?ijjpprrxxzz226<3C3CL3Q3Q3rU[UaUeUefqUrUrss !1!1.!A!A!rRYOfhqErErssyy{{BBDD!%!8!89I9IJ\9]9]:DagamaqaqsCbDbD"E"E!%!?!?!A!A-4]__"+/26@D%**.)A)A &* * &04/G/G ,d0 0 ,?A"BD&&&rSkeydefaultr c`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) mathgetattrrrrfloatrYrisfinite)rrrrvalueparseds r&rz#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 rM || kot#| } n#t$$rd} YnwxYw| swt'd|jdt)dpd} t+dd} t-j| ddgt|dd| t1} | jdkrUt'd|jd | j |js,|r||dSdSt'd|jd!| r' || n#t$$rYnwxYwne#t$rX}t'd|jd"|Yd}~|js,|r||dSdSd}~wwxYw|jdd#ddl } |!4d{V}|"d$|j#d%|$d&'(4d{V }|j%d)krt|&d{V}|"d*d+}|d,kr"|"d-d.}t|}|r|r||krt'd|jd/|d0|'d|_(|!|_)tUj+|,|_- dddd{Vdddd{V|js,|r||dSdSt'd|jd1|pd2d3|d4nt'd|jd5|d4dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYn#t$rYnwxYwt]|jt_|j#tUj0d6d{Vtcj2d7d8}|jj d9z |_3ti|j3d:d;<}||_5t1}|j6 |j6|d=<dd>l7m8}m9}m:}t||d?<t||d@<t||dA<t-j;t)dBpdBt|dCt|j#dDt|jdE|g||d|F|_(ty|j|j(j=ddl }d}i}t}dGD]}tUj0d6d{V|j(?t'd|jdH|j(jd0t'd|jdI|j3||js,|r||dSdS |!4d{V}|"d$|j#d%|$d&'(4d{V }|j%d)krrd}|&d{V}|"d*d,kr=t'd|jdJ dddd{Vdddd{VnYdddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwY#t$rYwxYw|st'd|jdKt'd|jdI|j3| |js,|r||dSdS|"d*d,krYt'd|jdLt}dGD]}tUj0d6d{V|j(?t'd|jdMt'd|jdI|j3||js,|r||dSdS |!4d{V}|"d$|j#d%|$d&'(4d{V }|j%d)krp|&d{V}|"d*d,kr=t'd|jdJ dddd{Vdddd{Vndddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwY#t$rYwxYwt'd|jdNt'd|jdO|j3t'd|jdP|!|_)tUj+|,|_-|'t'd|jdQ|j# |js,|r||dSdS#t$ra}t@dR|j|dSYd}~|js,|r||dSdSd}~wwxYw#|js+|r||wwxYw)Tz 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). Run `hermes whatsapp` to pair, or remove WHATSAPP_ENABLED from your .env to disable.whatsapp_not_paireduBWhatsApp enabled but not paired — run `hermes whatsapp` to pair.z[%s] Bridge found at %szwhatsapp-sessionzWhatsApp sessionTz3[%s] Could not acquire session lock (non-fatal): %sNz package.json node_modulesz.hermes-pkg-hash[z,] Installing WhatsApp bridge dependencies...npmWHATSAPP_NPM_INSTALL_TIMEOUTi,installz--silent)cwdrrrenvrz] npm install failed: z] Dependencies installedz"] Failed to install dependencies: )parentsexist_okhttp://127.0.0.1:z/healthtotalrstatusunknown connected scriptHashrlz!] Using existing bridge (status: )z#] Running bridge is stale (running= unversionedz, disk=z ), restartingz*] Bridge found but not connected (status: r WHATSAPP_MODEz self-chatz bridge.logautf-8)encodingWHATSAPP_REPLY_PREFIX)rrrHERMES_IMAGE_CACHE_DIRHERMES_AUDIO_CACHE_DIRHERMES_DOCUMENT_CACHE_DIRrMz--portz --sessionz--mode)rrpstart_new_sessionrz!] 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)Arr\r^name_set_fatal_errorrrrWrr]_acquire_platform_lockrOrArxrrXrboolr@printrrrrr rorp_running_release_platform_lock_close_bridge_logremkdiraiohttp ClientSessionrr ClientTimeoutrjson_mark_connectedrrr create_task_poll_messagesrrbrEsleepr:rropenrrrrrrPopenrgrDrangepollerror)rr bridge_path creds_path lock_acquirede bridge_dir _pkg_json _dep_stamp _pkg_hash _deps_fresh_npm_binnpm_install_timeoutinstall_resultrsessionrespdata bridge_status running_hash disk_hash whatsapp_mode bridge_log_fh bridge_env_get_audio_dir _get_doc_dir _get_img_dir http_readyattempts r&connectzWhatsAppAdapter.connects1 +,,  NNOQUQZ [ [ [  ! !'[ "    54.// !!##  NN=ty+ V V V  ! !)C[CCC "    5',6   ""  NN( :      ! !%T "    5 -ty+FFF  `../A3tGYCZCZ\noo u MM ` ` ` NNPRVR[]^ _ _ _ _ _ _ _ _ `Y ) %+J"^3I#n47IIJ*955IK^+3355 ((#-#7#7#9#9#?#?#A#AY#N"cTXYbTcTcKK((("'KKK( !Q$)QQQRRR066?%!+22PRU*V*V'%/^!9j9 OO'+! 3133 &&&N&0A55Z$)ZZ>CXZZ[[[$h= ) 2//111&&((((( ) )gAdiAAABBB !!&11)<<<<&!!! D! !!!NdiNN1NNOOO 555V= ) 2//111&&((((( ) )[!   $ $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 #/!0I!0,R[B[B[$)*jdi*j*jZg*j*j*j$k$k$k$($8$8$:$:$:;?D$89@9N9N9P9PD$66=6I$J]J]J_J_6`6`DO+/3}}}}}}}}}}}} } } } } } } } } } } } }F= ) 2//111&&((((( ) )Q!&%o %o%o0<0M %o%oV_%o%o%o!"!"!"!" !&&{$)&{&{_l&{&{&{ | | |?}}}}}}}}}}}}}}}}}}}}}}}}}}} } } } } } } } } } } } } } } } } } } } } } } } } } } }B     *$*< = = = t0 1 1 1-"" " " " " " " " Io{CCM#18<GD  !13IIIM"/D  /00J!-6:6H 23            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+<+<+<+<+<+NtN#t:W;WC.V#>WWrz-[%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)rromessages r&_check_managed_bridge_exitz*WhatsAppAdapter._check_managed_bridge_exits   '4)..00  4 4)5 1 1 jL6P6P KK?     4UzUUU# - LLDIw 7 7 7  ! !":Gt ! T T T  " " $ $ $**,, , , , , , , ,'272rScKd|_|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.TFrhrNrz] Error stopping bridge: z.] Disconnecting (external bridge left running)rU) missing_okz] Disconnected)rrrzr>r?rnrrrr;rAr rrr[r@rdonecancelCancelledErrorrclosedr9r _mark_disconnectedr)rr s r& disconnectzWhatsAppAdapter.disconnect s #   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 connectedsuccessrNTrR message_idrchatIdrAreplyTor/sendrrrr messageIdrg333333? message_ids)rRrTcontinuation_message_ids raw_response)r rrrBrr~rformat_messagetruncate_message_outgoing_chunk_limit enumeratepostrrrrrrrOrr7rrtuplerA)rrKrLrMrN bridge_exitr formattedchunkssent_message_idslast_message_ididxchunkpayloadr*r+rr s r&sendzWhatsAppAdapter.send@s} 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)finalizerTrocK|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.FrPrQNrrz/edit)rVr[rArrrZrTrS) r rrrBrrdrr~rrrrArO) rrKrTrLrorfrr*rr s r& edit_messagezWhatsAppAdapter.edit_messages} DD$6 De?CCC C ;;========  @e;??? ? ; NNN)..>),, 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=GGrselectable_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. FrPrQNr)rVrrselectableCountrz /send-pollrYrrZrTr[r})r rrrBrr~listrdrrrrrrrArO) rrKrrrrfrrmr*r+rr s r& send_pollzWhatsAppAdapter.send_polls} 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)rOr).0choices r& z0WhatsAppAdapter.send_clarify..sBbbbcRXkkN_N_NaNabV**,,bbbrSr rlrrNzB[%s] Native WhatsApp clarify poll failed; falling back to text: %s)rKrrrrrN) r7rrOrrRr\r^rrr send_clarify) rrKrrrrrN clean_choicesr#rs r&rzWhatsAppAdapter.send_clarifys,"cbGMrbbb M"" ( ( ( (b ( ( ( ( (>>HN##))++!" *F ~  NNT      WW))!# *         rS)raddressrMrNlatitude longituderrcdK|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.FrPrQNr)rVrrrrrz/send-locationrYrrZrTr[r})r rrrBrr~rrdrrrrrrrArO)rrKrrrrrMrNrfrrmr*r+rr s r& send_locationzWhatsAppAdapter.send_location-s} 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)rr~rAr send_image)rrKrrtrMrN local_pathrs r&rzWhatsAppAdapter.send_image[s ]3I>>>>>>>>J33GZRYZZZZZZZZ Z ] ] ]++GYS[\\\\\\\\ \ \ \ ]s285A0/A0 image_pathcBK|||d|d{VS)z,Send a local image file natively via bridge.rNr~)rrKrrtrMkwargss r&send_image_filezWhatsAppAdapter.send_image_filep4//WgVVVVVVVVVrS video_pathcBK|||d|d{VS)u>Send a video natively via bridge — plays inline in WhatsApp.videoNr)rrKrrtrMrs r& send_videozWhatsAppAdapter.send_video{rrS audio_pathcBK|||d|d{VS)z:Send an audio file as a WhatsApp voice message via bridge.audioNr)rrKrrtrMrs r& send_voicezWhatsAppAdapter.send_voicerrSc K|||d||ptj|d{VS)z=Send a document/file as a downloadable attachment via bridge.documentN)r~r:rbasename)rrKrrrtrurMrs r& send_documentzWhatsAppAdapter.send_documents_// Y G  4)))44         rScxK|jr|jsdS|d{VrdS ddl}|jd|jddt |i|d4d{V dddd{VdS#1d{VswxYwYdS#t$rYdSwxYw) z!Send typing indicator via bridge.Nrrz/typingrVrrrZ) r rrBrrdrr~rrA)rrKrNrs 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)rtypeNrrz/chat/rkrrrrisGroupr! participants)rrrz+Could not get WhatsApp chat info for %s: %s) r rrBrrrr~rrrrAr\debug)rrKrr*r+r s r& get_chat_infozWhatsAppAdapter.get_chat_infos} 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++ E5EEcKddl}|jr|jsdS|d{V}|rt d|jd|dS |jd|jd|d 4d{V }|j d kr| d{V}|D]e}| |d{V}|rF|j tjkr||J||d{Vfdddd{Vn#1d{VswxYwYn#t"j$rYdSt&$rz}|d{V}|r t d|jd|Yd}~dSt d|jd |t#jd d{VYd}~nd}~wwxYwt#jd d{V|jdSdS)z&Poll the bridge for incoming messages.rNrz] rz /messagesrYrrrz] Poll error: rr)rr rrBr rrrrrr_build_message_event message_typerTEXT_enqueue_text_eventhandle_messagerrGrAr)rrrfr*messagesmsg_dataeventr s r&rzWhatsAppAdapter._poll_messagessm #%  $ ? ? A AAAAAAAK 4$)44{44555 '-11D(9DDD#111;;2 E E E E E E E E{c)))-#4#4#4#4#4#4(0EEH*.*C*CH*M*M$M$M$M$M$M$ME$E#(#59I#I#I$($<$D;?EG G6G4GGiprcddlm}||j|jjdd|jjddS)z-Session-scoped key for text message batching.r)build_session_keygroup_sessions_per_userTthread_sessions_per_userF)rr)gateway.sessionrsourcerrr)rrrs r&_text_batch_keyzWhatsAppAdapter._text_batch_keysg555555  L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]    rSc||}|j|}t|jpd}|||_||j|<nw|jr$|jr|jd|jn|j|_||_|jr>|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. rlNrV)rrrr7r_last_chunk_len media_urlsextend media_typesrrErFrr_flush_text_batch)rrrexisting chunk_len prior_tasks r&rz#WhatsAppAdapter._enqueue_text_eventsL""5))-11#66 (b))  $-E !.3D &s + +z bDLM a8= @ @EJ @ @ @W\Wa '0H $ ?#**5+;<<<$++E,=>>>377<<  joo//      .5.A  " "3 ' '/ / &s+++rScKtj} |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_THRESHOLDrrrpoprr)rrrpendinglast_lendelayrs r&rz!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#r+czK ||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|||}t|d0pd }|pd}d}d}d }|d1rg|d2}|t|}||d3}|r|}||}d4}|tj kr[|rX|D]T}t3|j}|d5vr& t3| j!}||kr$t#d|jd6|d7|d8|d9 dt3|"d:d;<}t3|j}|}d=|vr1|#d=d>}tI|d?kr|d>}d@|dA|}|r|dB|}n|}t#d|jdC|d #t&$r'} t#d|jdD| dYd} ~ Ld} ~ wwxYwVi} t|dEpd }!|dF}"|!r|!| dG<tK|"tLr|"r|"| dH<|dIr*d| dJ<|tNs tN|}tQ|||||dK|| | ||||L S#t&$r%} t#d|jdM| Yd} ~ dSd} ~ wwxYw)NzKBuild a MessageEvent from bridge message data, downloading images to cache.Nryrl>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_messagerrrOrLOCATIONSTICKERPHOTOVIDEOVOICEAUDIODOCUMENT build_sourcer startswithrrr rrAr:risabsrrrsuffixrr_clean_bot_mention_text_normalize_whatsapp_id_message_is_reply_to_botstatst_sizerXr6r7 isinstancedict_OWNER_REPLY_PREFIXr)#rr+msg_typersis_grouprrraw_urls cached_urlsrr bridge_mime cached_pathr rrr quoted_textr rr r  raw_reply_idquoted_participantMAX_TEXT_INJECT_BYTESdoc_path file_sizerLfname display_namerB injectionrN native_typenative_metadatas# r&rz$WhatsAppAdapter._build_message_event1s } //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$?? 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########N \ c      $    8>3>4>>>>&tCH~(.gif.png.jpeg.webpr>.3gp.avi.mkv.mov.mp4.webm>.m4a.mp3.wav.flac.opusrrris_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. rrrrr)r:rsplitextr_WA_AUDIO_EXTS_WA_IMAGE_EXTS_WA_VIDEO_EXTS)rrrHrIrs r&_bridge_media_typerOssz '  9 % %a ( . . 0 0C3.((w nw nw :rS) thread_id media_filesrIc LKt|dipi} ddl}n#t$rddicYSwxYw |dd}t |} |pg} |pd} d} |4d{V} | r| d |d | | d |d 4d{V }|j dkrM| d{V}dd|j d|icdddd{Vcdddd{VS| d{V}|d} dddd{Vn#1d{VswxYwY| D]e\}}tj |sdd|iccdddd{VSt|||}| ||d}|dkr"tj ||d<| d |d||d 4d{V }|j dkrO| d{V}dd|j d|icdddd{Vccdddd{VS| d{V}|dp| } dddd{Vn#1d{VswxYwYg dddd{Vn#1d{VswxYwYdd| | dS#t"$r}dd|icYd}~Sd}~wwxYw)zOut-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. rrNrz/aiohttp not installed. Run: pip install aiohttprrrlzhttp://localhost:rXrUrYrrZrzWhatsApp bridge error (z): r[zWhatsApp media file not found: rwrrzr{r|zWhatsApp media error (Twhatsapp)rRplatformrKrTzWhatsApp send failed: )rr ImportErrorrr~rrrdrrrrr:rrWrOrrA)pconfigrKrArPrQrIrrrnormalized_chat_idmediarrjr)r*rr+ media_pathrHrsrmr s r&_standalone_sendrZs, GWb ) ) /REL LLLJKKKKL57ii t44 ,W55!r}"((**& O& O& O& O& O& O& Ogzz|| <"<<: :::$64HH#111;;( < < < < < < < <{c))%)YY[[000000 ')Y4;)Y)YSW)Y)YZ < < < < < < < < < < < < <& O& O& O& O& O& O& O& O& O& O& O& O& O& O"&,,,,,,D&*hh{&;&;O < < < < < < < < < < < < < < < < < < < < < < < < < < <). O O$ Hw~~j11U#%Sz%S%STTT)& O& O& O& O& O& O& O& O& O& O& O& O& O& O*0 HnUU 0 *!+++ ++*,'*:*::*F*FGJ'"<<@ @@@ #111<<( O O O O O O O O{c))%)YY[[000000 ')X$+)X)XRV)X)XY O O O O O O O O O O O O O O O;& O& O& O& O& O& O& O& O& O& O& O& O& O& OJ"&,,,,,,D&*hh{&;&;&NO O O O O O O O O O O O O O O O O O O O O O O O O O O O O%& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& O& OR"))    7775!5566666667s--A L:AK0 4E#=K0L"/E#K0# E- -K00E- 12K0#L6A5K0,4K  K04L1K 8K0 K K0K K0L0 K::L=K:> L L#LL#L#c0ddlm}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 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_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?TrgzWhatsApp enabledfalsezWhatsApp left disabledz@Allowed user IDs (comma-separated, leave empty for no allowlist)WHATSAPP_ALLOWED_USERS rlzWhatsApp allowlist configuredz4Home chat ID for cron delivery (leave empty to skip)WHATSAPP_HOME_CHANNEL) hermes_cli.configr\r]hermes_cli.cli_outputr^r_r`rarbrrr) r\r]r^r_r`rarbr allowed_users home_channels r&interactive_setuprpgs@???????LJLMMMJSTTT}/00HHNN$$(<<< .///}4e<<  F}'..)6222 ()))))7333 +,,,FJM7/1F1FsB1O1OPPP 56666PQQLF. 0B0B0D0DEEEEEFFrSyaml_cfg whatsapp_cfgc8ddl}d|vrHtjds4t|dtjd<d|vrz%_apply_yaml_config..(//a3q66//////rSrrrric34K|]}t|VdSr2r|r}s r&rz%_apply_yaml_config..s(--Q#a&&------rSrrrWHATSAPP_GROUP_ALLOWED_USERSc34K|]}t|VdSr2r|r}s r&rz%_apply_yaml_config..rrS) rr:rrOrenvirondumpsrrrjoin)rqrr_jsonfrcafgafs r&_apply_yaml_configrsYL((;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 4rSct|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. rNenabledFTrrdrl>rerfrg)rhermes_cli.gatewaygatewayr\rr)rr gateway_modvals r& _is_connectedrs FGR ( ( .BE gfi??Et-,,,,,  $ $%7 8 8 >B E E G G M M O OC & &&rSc t|S)zFFactory wrapper that constructs WhatsAppAdapter from a PlatformConfig.)r)rs r&_build_adapterrs 6 " ""rSc|ddtttdgdtt dddt dd d d S) u:Plugin entry point — called by the Hermes plugin system.rSrcrduFWhatsApp requires a Node.js bridge — see the WhatsApp messaging docsriWHATSAPP_ALLOW_ALL_USERSrkiu💬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_platformrrrrprrZ)ctxs r&registerrs\ &,"()]"/204-!!rSr1)Hr6rloggingr:rTrr<rsystemr4pathlibrtypingrrrhermes_constantsrr r getLoggerr3r\rrrr'rEr rRrbrgrzsysrinsertrO__file__rrgateway.configr{r|rr}gateway.whatsapp_identityr~rrrrrrrrutilsrrrrrrMrNrLrOrZrprrrrrrrSr&rsn"  ho9, &&&&&&&&&&  8 $ $'######L# S# T# # # # LBSBBBBBB>. . . . . . b    3  4     6;,,,d,t,,,,\ 33ttH~~--//7:;;<<<33333333CCCCCC555555&&&&&&R T c     T.IIIII+-@IIIv$<;;BBBCCC#tPS2I7I7I7I7I7X*F*F*F*FZTdTkD'T''''0### rS