eiX DdZddlZddlZddlZddlZddlZddlZddlZddlZ ddl Z ddl Z ddl Z ddl mZmZddlmZddlmZejeZdedefdZded edefd Zded edefd Zd edefdZdedzfdZdedeeedzffdZ de!efdZ"dpded ededzdefdZ#dee!ezeedfze$ezdzdefdZ% dpdddedzdee!ezeedfze$ezdzdedzfdZ&dedzde'fdZ(dedzdee'e'ffdZ)ddl*m+Z+m,Z,dd l-m-Z-dd!l.m/Z/dd"l0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7dd#l8m9Z9dd!l.m/Z:e j;<dee:e=>j?d$dd%l@mAZAmBZBdd&lCmDZDmEZEdd'lFmGZGd(ZHdqd*ed+edefd,ZId-ZJeGd.d/ZKde/fd0ZLd1eMdefd2ZNdrd1eMd4edefd5ZOdsd*ed4ed6edefd7ZPdtd9edefd:ZQeGd;d<ZRde/fd=ZSdud1eMd4edefd?ZTdvd*ed4ed6edefd@ZUeGdAdBZVdCdDdEdFdGdHZWde/fdIZXdwd1eMd4edefdKZYeGdLdMZZdNdOdPdPdQdRdSdTdUZ[de/fdVZ\d1eMdWedefdXZ]dtd9edefdYZ^GdZd[e9Z_Gd\d]e9Z`e+Gd^d_Zae+Gd`daZbdbdcdde1eeafdeedfeadgeddf dhZcdiZde5eage6e3efZe dpdje'dkedledzdedzfdmZfGdndoeZgdS)xz Base platform adapter interface. All platform adapters (Telegram, Discord, WhatsApp) inherit from this and implement the required methods. N)ABCabstractmethod)urlsplit)normalize_proxy_urlsreturncLt|ddzS)uCount UTF-16 code units in *s*. Telegram's message-length limit (4 096) is measured in UTF-16 code units, **not** Unicode code-points. Characters outside the Basic Multilingual Plane (emoji like 😀, CJK Extension B, musical symbols, …) are encoded as surrogate pairs and therefore consume **two** UTF-16 code units each, even though Python's ``len()`` counts them as one. Ported from nearai/ironclaw#2304 which discovered the same discrepancy in Rust's ``chars().count()``. z utf-16-le)lenencode)rs 8/home/div/.hermes/hermes-agent/gateway/platforms/base.py utf16_lenrs# qxx $$ % % **limitct||kr|Sdt|}}||kr4||zdzdz}t|d||kr|}n|dz }||k4|d|S)uReturn the longest prefix of *s* whose UTF-16 length ≤ *limit*. Unlike a plain ``s[:limit]``, this respects surrogate-pair boundaries so we never slice a multi-code-unit character in half. rr N)rr )rrlohimids r _prefix_within_utf16_limitr*s ||u AB r''Bw{q  QttW   & &BBqB r'' SbS6Mrbudgetc|||krt|Sdt|}}||kr0||zdzdz}||d||kr|}n|dz }||k0|S)a8Return the largest codepoint offset *n* such that ``len_fn(s[:n]) <= budget``. Used by :meth:`BasePlatformAdapter.truncate_message` when *len_fn* measures length in units different from Python codepoints (e.g. UTF-16 code units). Falls back to binary search which is O(log n) calls to *len_fn*. rrr Nr )rrlen_fnrrrs r _custom_unit_to_cpr=svayyF1vv AB r''Bw{q  6!DSD'??f $ $BBqB r'' Irhostc tj|}|jrdSt|ddr|jjrdSdS#t $rYnwxYw t j|dt jt j }|D],\}}}}}tj|d}|jsdS-dS#t j tf$rYdSwxYw)aReturn True if *host* would expose the server beyond loopback. Loopback addresses (127.0.0.1, ::1, IPv4-mapped ::ffff:127.0.0.1) are local-only. Unspecified addresses (0.0.0.0, ::) bind all interfaces. Hostnames are resolved; DNS failure fails closed. F ipv4_mappedNTr) ipaddress ip_address is_loopbackgetattrr ValueError_socket getaddrinfo AF_UNSPEC SOCK_STREAMgaierrorOSError)raddrresolved_family_type_proto _canonnamesockaddrs r is_network_accessibler1Ps  #D))   5 4 - - $2B2N 5t       & $)7+>   =E   8GUFJ' 44D# tt u  g &tts/AA A  A AB-*B--CCc2tjdkrdS tjddgddtj}n#t $rYdSwxYwi}|D]\}|}d|vrB|d\}}}|||<]d D]W\}}}| |d kr8| |} | |} | r | r d | d | cSXdS) zRead the macOS system HTTP(S) proxy via ``scutil --proxy``. Returns an ``http://host:port`` URL string if an HTTP or HTTPS proxy is enabled, otherwise *None*. Falls back silently on non-macOS or on any subprocess error. darwinNscutilz--proxyT)timeouttextstderrz : )) HTTPSEnable HTTPSProxy HTTPSPort) HTTPEnable HTTPProxyHTTPPort1zhttp://:) sysplatform subprocess check_outputDEVNULL Exception splitlinesstrip partitionget) outpropslinekey_val enable_keyhost_keyport_keyrports r _detect_macos_system_proxyrUssU |xt% y !14 @R    ttE  --zz|| D==..//KCC!$E#))++ +//& Hh 99Z C ' '99X&&D99X&&D / /........ 4s$9 AAvaluect|pd}|sdSd|vrDt|}|jpdd|jfS|drd|vr|ddd\}}}d}|dr3|dd rt|dd}|d|fS| ddkrc| d\}}}| r6|dt|fS|d ddfS) N)rXN://.[]rr@z[]) strrHrhostnamelowerrstriprT startswithrIisdigitintcount rpartition)rVrawparsedrrOrestrT maybe_ports r _split_host_portrjs ekr   " "C x ||#%2,,..55c::FKGG ~~c.sczzABB))#.. a ??3   !DH$4$4$6$6 !tABBx==Dzz||""3''-- yy~~!nnS11a      =::<<&&s++S__< < 99;;  T " " ) )# . . 44rcg}dD]T}tj|d}|d|dDU|S)N)NO_PROXYno_proxyrXc3fK|],}||V-dSNrH).0parts r z$_no_proxy_entries..s7OO$**,,Otzz||OOOOOOr,)osenvironrJextendsplit)entriesrNrfs r _no_proxy_entriesrzs`G'PPjnnS"%%OO #OOOOOOO NrentryrTc$t|pd}|sdS|dkrdSt|\}}| |||krdS||dS|sdS t j|d} t j||vS#t$rYdSwxYw#t$rYnwxYw t j|} t j||kS#t$rYdSwxYw#t$rYnwxYw|dr|dd}| |S|dr#||ddkp| |S||kp| d|S) NrXF*T)strictz*.rrZ) r]rHr_rjr ip_networkr r#raendswith) r{rrTtoken token_host token_portnetworktoken_ipsuffixs r _no_proxy_entry_matchesrs     " " $ $ * * , ,E u ||t-e44J $"2zT7I7Iu$,u u &z%@@@ '--8 8   55        ' 33 '--9 9   55       T""%ABB}}V$$$S!!Cz!""~%Bz)B)BB :  @/?:/?/?!@!@@s`+B)B B&"B)%B&&B)) B65B6:C8C'' C51C84C55C88 DD target_hosts.ct}|r|sdSt|tr|g}nt|}|D]C}t t|\s$t fd|DrdSDdS)zReturn True when NO_PROXY/no_proxy matches at least one target host. Supports exact hosts, domain suffixes, wildcard suffixes, IP literals, CIDR ranges, optional host:port entries, and ``*``. Fc3:K|]}t|VdSro)r)rqr{rrTs r rsz&should_bypass_proxy..s0OOe&udD99OOOOOOrT)rz isinstancer]listrjany)rry candidates candidaterrTs @@r should_bypass_proxyrs  !!G ,u,$$("^ ,''  %c)nn55 d   OOOOOwOOO O O 44  5r)rplatform_env_varc|rUtj|pd}|r t |rdSt |SdD]Z}tj|pd}|r#t |rdSt |cS[t t }|rt |rdS|S)uReturn a proxy URL from env vars, or macOS system proxy. Check order: 0. *platform_env_var* (e.g. ``DISCORD_PROXY``) — highest priority 1. HTTPS_PROXY / HTTP_PROXY / ALL_PROXY (and lowercase variants) 2. macOS system proxy via ``scutil --proxy`` (auto-detect) Returns *None* if no proxy is found, or if NO_PROXY/no_proxy matches one of ``target_hosts``. rXN) HTTPS_PROXY HTTP_PROXY ALL_PROXY https_proxy http_proxy all_proxy)rurvrJrHrrrU)rrrVrNdetecteds r resolve_proxy_urlrs. 0117R>>@@  ."<00 t&u-- -:..$$*1133  ."<00 tt&u-- - - - .##=#?#?@@H' 55t Or proxy_urlc|siS|drO ddlm}||d}d|iS#t $r t d|icYSwxYwd|iS) uBuild kwargs for ``commands.Bot()`` / ``discord.Client()`` with proxy. Returns: - SOCKS URL → ``{"connector": ProxyConnector(..., rdns=True)}`` - HTTP URL → ``{"proxy": url}`` - *None* → ``{}`` ``rdns=True`` forces remote DNS resolution through the proxy — required by many SOCKS implementations (Shadowrocket, Clash) and essential for bypassing DNS pollution behind the GFW. socksrProxyConnectorTrdns connectorVaiohttp_socks not installed — SOCKS proxy %s ignored. Run: pip install aiohttp-socksproxyr_ra aiohttp_socksrfrom_url ImportErrorloggerwarningrrrs r proxy_kwargs_for_botrs  ##G,,   4 4 4 4 4 4&// /EEI+ +    NN1    III   Y s A'A87A8c|siifS|drS ddlm}||d}d|iifS#t $r"t d|iifcYSwxYwid|ifS) uBuild kwargs for standalone ``aiohttp.ClientSession`` with proxy. Returns ``(session_kwargs, request_kwargs)`` where: - SOCKS → ``({"connector": ProxyConnector(...)}, {})`` - HTTP → ``({}, {"proxy": url})`` - None → ``({}, {})`` Usage:: sess_kw, req_kw = proxy_kwargs_for_aiohttp(proxy_url) async with aiohttp.ClientSession(**sess_kw) as session: async with session.get(url, **req_kw) as resp: ... rrrTrrrrrrs r proxy_kwargs_for_aiohttpr2s 2v ##G,,   4 4 4 4 4 4&// /EEI+R/ /    NN1    r6MMM   # ##s"A)A>=A>) dataclassfield)datetime)Path)DictListOptionalAnyCallable AwaitableTuple)Enumr )PlatformPlatformConfig) SessionSourcebuild_session_key)get_hermes_dirzSecure secret entry is not supported over messaging. Load this skill in the local CLI to be prompted, or add the key to ~/.hermes/.env manually.Purlmax_lenc|dkrdS|dSt|}|sdS t|}n#t$r |d|cYSwxYw|jrs|jrl|jddd}|jd|}|jpd}|r1|dkr+|ddd}|r|d |n|d }n|}n|}t||kr|S|d krd |zS|d|d z d S)z?Return a URL string safe for logs (no query/fragment/userinfo).rrXN@rrY/z/.../z/...r5rZz...)r]rrFschemenetlocrsplitpathr ) rrrfrgrbaserbasenamesafes r safe_url_for_logrgsc!||r {r c((C r# 8G8}}  %%c1--b1-,,F,,{ b  DCKK{{3**2.H/7Jd+++++]]]DDDD 4yyG !||W}@Trr6follow_redirects event_hooksr)Mozilla/5.0 (compatible; HermesAgent/1.0)zimage/*,*/*;q=0.8z User-AgentAcceptheaders?z*Media cache retry %d/%d for %s (%.1fs): %s)rrr#rhttpxlogging getLogger__name__ AsyncClientrrangerJraise_for_statusrcontentTimeoutExceptionHTTPStatusErrorrr status_codedebugasynciosleep rrrrr_logclientattemptrexcwaits r cache_image_from_urlr$-,,,,, ;s  [YBRSVBWBWYYZZZLLL  X & &D  "6!78! Wq[))  G !'&Q"5",""))+++-h.>DDDD *E,AB   c5#899cl>VY\>\>\W$$'A+.DJJD! (-- "----------HHHH   D7F AC*F*E>;A8E93F8E99E>>F F"F max_age_hourscHddl}t}||dzz }d}|D]^}|rH|j|kr+ ||dz }N#t$rYZwxYw_|S)zd Delete cached images older than *max_age_hours*. Returns the number of files removed. rNr)timeriterdiris_filestatst_mtimeunlinkr)r r#rcutoffremovedfs r cleanup_image_cacher-s KKK#%%I YY[[MD0 1FG     99;; 16688,v55  1      N7B BBz cache/audio audio_cachecHtddtS)zBReturn the audio cache directory, creating it if it doesn't exist.Tr)AUDIO_CACHE_DIRrrrr get_audio_cache_dirr27rr.oggct}dtjjdd|}||z }||t |S)a Save raw audio bytes to the cache and return the absolute file path. Args: data: Raw audio bytes. ext: File extension including the dot (e.g. ".ogg", ".mp3"). Returns: Absolute path to the cached audio file as a string. audio_Nr)r2rrrrr]rrrrrs r cache_audio_from_bytesr7=s]$%%I4 ("-4s44H8#H  x==rc PKddlm}||stdt|ddl}t jt}|dddtgi4d{V }t|d zD]} | |d d d  d{V}| t|j|ccdddd{VS#|j|jf$r} t#| |jr| jjdkr||krQd|d zz} |d|d z|t|| | t+j| d{VYd} ~ d} ~ wwxYw dddd{VdS#1d{VswxYwYdS)aE Download an audio file from a URL and save it to the local cache. Retries on transient failures (timeouts, 429, 5xx) with exponential backoff so a single slow CDN response doesn't lose the media. Args: url: The HTTP/HTTPS URL to download from. ext: File extension including the dot (e.g. ".ogg", ".mp3"). retries: Number of retry attempts on transient failures. Returns: Absolute path to the cached audio file as a string. Raises: ValueError: If the URL targets a private/internal network (SSRF protection). rrrNrTrrrrzaudio/*,*/*;q=0.8rrrrz*Audio cache retry %d/%d for %s (%.1fs): %s)rrr#rrr r r r rr rJrr7rrrrrrrrrrs r cache_audio_from_urlr9Orrz cache/videos video_cachez video/mp4zvideo/quicktimez video/webmzvideo/x-matroskazvideo/x-msvideo).mp4.mov.webm.mkv.avicHtddtS)zBReturn the video cache directory, creating it if it doesn't exist.Tr)VIDEO_CACHE_DIRrrrr get_video_cache_dirrBrrr;ct}dtjjdd|}||z }||t |S)zDSave raw video bytes to the cache and return the absolute file path.video_Nr)rBrrrrr]r6s r cache_video_from_bytesrEs[#%%I4 ("-4s44H8#H  x==rzcache/documentsdocument_cachezapplication/pdfz text/markdownz text/plainzapplication/zipzGapplication/vnd.openxmlformats-officedocument.wordprocessingml.documentzAapplication/vnd.openxmlformats-officedocument.spreadsheetml.sheetzIapplication/vnd.openxmlformats-officedocument.presentationml.presentation)z.pdfz.mdz.txtz.logz.zipz.docxz.xlsxz.pptxcHtddtS)zEReturn the document cache directory, creating it if it doesn't exist.Tr)DOCUMENT_CACHE_DIRrrrr get_document_cache_dirrIs!TD999 rrct}|rt|jnd}|dd}|r|dvrd}dt jjddd|}||z }| |std || |t|S) a Save raw document bytes to the cache and return the absolute file path. The cached filename preserves the original human-readable name with a unique prefix: ``doc_{uuid12}_{original_filename}``. Args: data: Raw document bytes. filename: Original filename (e.g. "report.pdf"). Returns: Absolute path to the cached document file as a string. Raises: ValueError: If the sanitized path escapes the cache directory. documentrX)rZz..doc_NrrOzPath traversal rejected: ) rIrnamerrHrrrresolveis_relative_tor#rr])rrr safe_name cached_namers r cache_document_from_bytesrSs"'((I'/?X##ZI!!&"--3355I  [00 <)#2#.<<<->-@-@ A ACAXAABBB  x==rcHddl}t}||dzz }d}|D]^}|rH|j|kr+ ||dz }N#t$rYZwxYw_|S)zg Delete cached documents older than *max_age_hours*. Returns the number of files removed. rNr"r)r#rIr$r%r&r'r(r)r)s r cleanup_document_cacherUs KKK&((I YY[[MD0 1FG     99;; 16688,v55  1      Nr.c6eZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) MessageTypezTypes of incoming messages.r7locationphotovideoaudiovoicerKstickercommandN) r  __module__ __qualname____doc__TEXTLOCATIONPHOTOVIDEOAUDIOVOICEDOCUMENTSTICKERCOMMANDrrr rWrWsA%% DH E E E EHGGGGrrWceZdZdZdZdZdZdS)ProcessingOutcomez=Result classification for message-processing lifecycle hooks.successfailure cancelledN)r r_r`raSUCCESSFAILURE CANCELLEDrrr rlrls#GGGGIIIrrlceZdZUdZeed<ejZeed<dZ e ed<dZ e ed<dZ eeed<dZeeed<ee Zeeed <ee Zeeed <dZeeed <dZeeed <dZeeeezed<dZeeed<dZeed<eej Zeed<defdZdeefdZ defdZ!dS) MessageEventzi Incoming message from a platform. Normalized representation that all adapters produce. r7 message_typeNsource raw_message message_idplatform_update_id)default_factory media_urls media_typesreply_to_message_id reply_to_text auto_skillchannel_promptFinternal timestamprc6|jdS)z8Check if this is a command message (e.g., /new, /reset).r)r7raselfs r is_commandzMessageEvent.is_commandCsy##C(((rc|sdS|jd}|r"|dddnd}|r d|vr|ddd}|rd|vrdS|S)z2Extract command name if this is a command message.Nrmaxsplitrrr)rr7rxr_)rpartsrfs r get_commandzMessageEvent.get_commandGs   4 ++&+5eAhqrrl  """  '3#::))C##A&C  3#::4 rc(|s|jS|jd}t|dkr|dnd}|dddddd}|S) z"Get the arguments after a command.rrrXu——z--u—u–-)rr7rxr r)rrargss r get_command_argszMessageEvent.get_command_argsUs   9  ++u::>>uQxxr||ND1199(DIIQQRZ\_`` r)"r r_r`rar]__annotations__rWrbrurvrrwrrxrryrcrrr{rr|r}r~rrrboolrnowrrrrrrr rtrts III + 0L+000!FM   K $J $$$)- ,,,"E$777JS 777"U4888Kc888*.#---#'M8C='''-1JtCy)000%)NHSM(((Hd % ===Ix===)D)))) Xc]    #rrtcneZdZUdZeed<dZeeed<dZ eeed<dZ e ed<dZ eed<dS) SendResultzResult of sending a message.rmNrxerror raw_responseF retryable) r r_r`rarrrxrr]rrrrrrr rr`si&& MMM $J $$$E8C=L#ItrrF) merge_textpending_messages session_keyeventrc||}|rt|ddtjk}|jtjk}t |j}t |j}|rs|rq|j|j|j|j|j r*t |j |j |_ dS|s|r|r>|j|j|j|j|j r>|j r+t |j |j |_ n |j |_ |s|rtj|_dS|rat|ddtj krB|jtj kr-|j r$|j r|j d|j n|j |_ dS|||<dS)aStore or merge a pending event for a session. Photo bursts/albums often arrive as multiple near-simultaneous PHOTO events. Merge those into the existing queued event so the next turn sees the whole burst. When ``merge_text`` is enabled, rapid follow-up TEXT events are appended instead of replacing the pending turn. This is used for Telegram bursty follow-ups so a multi-part user thought is not silently truncated to only the last queued fragment. ruN ) rJr"rWrdrurr{rwr|r7BasePlatformAdapter_merge_captionrb) rrrrexistingexisting_is_photoincoming_is_photoexisting_has_mediaincoming_has_medias r merge_pending_message_eventrjs$ ##K00H!#HndCC{GXX!.+2CC!("566!%"233  !2    & &u'7 8 8 8  ' '(9 : : :z ^ 3 B B8=RWR\ ] ] F  !3 ! ?#**5+;<<<$++E,=>>>z /=/$7$F$Fx}V[V`$a$aHMM$)JHM  :$5 :(3(9% F  .$77;;KKK"k&666z bDLM a8= @ @EJ @ @ @W\Wa F$)[!!!r) connecterrorconnectionerrorconnectionresetconnectionrefusedconnecttimeoutrz broken piperemotedisconnectedeoferror config_extra channel_id parent_idc|dpi}t|tsdS||fD]D}|s||}|t|}|r|cSEdS)aResolve a per-channel ephemeral prompt from platform config. Looks up ``channel_prompts`` in the adapter's ``config.extra`` dict. Prefers an exact match on *channel_id*; falls back to *parent_id* (useful for forum threads / child channels inheriting a parent prompt). Returns the prompt string, or None if no match is found. Blank/whitespace- only prompts are treated as absent. channel_promptsN)rJrdictr]rH)rrrpromptsrNprompts r resolve_channel_promptrs0117RG gt $ $tI&  S!! > V""$$  MMM  4rc eZdZUdZdedefdZedefdZ ede e fdZ ede e fdZ edefd Zd e defd Zd edged d zfdd fdZddZddZde de dedd fdZddZde de de defdZddZede fdZedefdZd edd fdZd e eee geefdd fdZdedd fd Z e!defd!Z"e!dd"Z#e! dd e d#e d$e e d%e e$e efde%f d&Z&d'Z'ee(d(<d'd)d e d*e d#e d+ede%f d,Z)dd e dd fd-Z*d e dd fd.Z+ dd e d/e d0e e d$e e d%e e$e efde%f d1Z, dd e d2e d0e e d$e e d%e e$e efde%f d3Z-e.d4e defd5Z/e.d#e de0e1e0e e fe ffd6Z2 dd e d7e d0e e d$e e de%f d8Z3d e d7e de%fd9Z4 dd e d:e d0e e d$e e de%f d;Z5 dd e dZ6 dd e d?e d0e e d$e e de%f d@Z7e.d#e de0e1e0e efe ffdAZ8e.d#e de0e1e e ffdBZ9 dd e dDe:dEe;j<d zdd fdFZ=d e dd fdGZ>d e dd fdHZ?dIe d e dd fdJZ@d dKdIe dLedMeAd zdd fdNZBd dKdIe dMeAd zded zfdOZCdPedd fdQZDdPedReEdd fdSZFdTe dUedVedd fdWZGe.dXe e defdYZHe.dXe e defdZZI dd e d#e d$e e d%ed\eAd]e:dd^fd_ZJe.d`e e dae de fdbZKd dcdIe dde e;j<dd fdeZLdIe defdfZMdIe defdgZNd dhdPedIe die e;j<defdjZOdkdkdldIe dmednedd fdoZPdIe dpe;j<dd fdqZQdPedIe dre dd fdsZRdPedd fdtZSe.de:fduZTdPedIe dd fdvZUddwZVdIe defdxZWdIe de efdyZX dd e d{e e d|e d}e e d~e e de e de e de e de e dede e de e d*e e deYfdZZe!d e de$e effdZ[d#e de fdZ\e. dd#e deAde dde1e fdZ]d S)rz Base class for platform adapters. Subclasses implement platform-specific logic for: - Connecting and authenticating - Receiving messages - Sending messages/responses - Handling media configrBc||_||_d|_d|_d|_d|_d|_d|_i|_i|_ i|_ t|_ i|_ t|_d|_d|_t|_t|_t|_dS)NFT)rrB_message_handler_running_fatal_error_code_fatal_error_message_fatal_error_retryable_fatal_error_handler_active_sessions_pending_messages_session_tasksset_background_tasks_post_delivery_callbacks_expected_cancelled_tasks_busy_session_handler_auto_tts_default_auto_tts_enabled_chats_auto_tts_disabled_chats_typing_paused)rrrBs r __init__zBasePlatformAdapter.__init__s   :> 0437!&*#im!;=:<7958EE 9;%|jjS)z%Human-readable name for this adapter.)rBrVtitlers r rNzBasePlatformAdapter.names}"((***rc|jS)z(Check if adapter is currently connected.)rrs r is_connectedz BasePlatformAdapter.is_connecteds }rc||_dS)z Set the handler for incoming messages. The handler receives a MessageEvent and should return an optional response string. N)rrs r set_message_handlerz'BasePlatformAdapter.set_message_handlers!(rc||_dS)zESet an optional handler for messages arriving during active sessions.N)rrs r set_busy_session_handlerz,BasePlatformAdapter.set_busy_session_handlers%,"""r session_storec||_dS)a  Set the session store for checking active sessions. Used by adapters that need to check if a thread/conversation has an active session before processing messages (e.g., Slack thread replies without explicit mentions). N)_session_store)rrs r set_session_storez%BasePlatformAdapter.set_session_stores,rc KdS)z Connect to the platform and start receiving messages. Returns True if connection was successful. Nrrs r connectzBasePlatformAdapter.connect  rc KdS)zDisconnect from the platform.Nrrs r disconnectzBasePlatformAdapter.disconnects  rrreply_torc KdS)ar Send a message to a chat. Args: chat_id: The chat/channel ID to send to content: Message content (may be markdown) reply_to: Optional message ID to reply to metadata: Additional platform-specific options Returns: SendResult with success status and message ID Nr)rrrrrs r sendzBasePlatformAdapter.sends ( rFREQUIRES_EDIT_FINALIZE)finalizerxrc(KtddS)uL Edit a previously sent message. Optional — platforms that don't support editing return success=False and callers fall back to sending a new message. ``finalize`` signals that this is the last edit in a streaming sequence. Most platforms (Telegram, Slack, Discord, Matrix, etc.) treat it as a no-op because their edit APIs have no notion of message lifecycle state — an edit is an edit. Platforms that render streaming updates with a distinct "in progress" state and require explicit closure (e.g. rich card / AI assistant surfaces such as DingTalk AI Cards) use it to finalize the message and transition the UI out of the streaming indicator — those should also set ``REQUIRES_EDIT_FINALIZE = True`` so callers route a final edit through even when content is unchanged. Callers should set ``finalize=True`` on the final edit of a streamed response (typically when ``got_done`` fires in the stream consumer) and leave it ``False`` on intermediate edits. Fz Not supported)rmr)r)rrrxrrs r edit_messagez BasePlatformAdapter.edit_messages6%????rc KdS)z Send a typing indicator. Override in subclasses if the platform supports it. metadata: optional dict with platform-specific context (e.g. thread_id for Slack). Nr)rrrs r send_typingzBasePlatformAdapter.send_typingrrc KdS)zStop a persistent typing indicator (if the platform uses one). Override in subclasses that start background typing loops. Default is a no-op for platforms with one-shot typing indicators. Nrrs r stop_typingzBasePlatformAdapter.stop_typings r image_urlcaptioncXK|r|d|n|}||||d{VS)z Send an image natively via the platform API. Override in subclasses to send images as proper attachments instead of plain-text URLs. Default falls back to sending the URL as a text message. rrrrNr)rrr#r$rrr7s r send_imagezBasePlatformAdapter.send_imagesO -4B'((Y(((YYwxYPPPPPPPPPr animation_urlcFK||||||d{VS)z Send an animated GIF natively via the platform API. Override in subclasses to send GIFs as proper animations (e.g., Telegram send_animation) so they auto-play inline. Default falls back to send_image. )rr#r$rrN)r()rrr)r$rrs r send_animationz"BasePlatformAdapter.send_animationsX__W W^iq}E_FFFFFFFF Frrc|dd}|dS)z=Check if a URL points to an animated GIF (vs a static image).?r.gif)r_rxr)rr_s r _is_animation_urlz%BasePlatformAdapter._is_animation_url"s6 !!#&&q)~~f%%%rc\ g}|}d}tj||D]^}|d}|d t fddDr| |f_d}tj||D].}|d | df/|red|Dfd }tj|||}tj|||}tjd d |}||fS) a Extract image URLs from markdown and HTML image tags in a response. Finds patterns like: - ![alt text](https://example.com/image.png) - - Args: content: The response text to scan. Returns: Tuple of (list of (url, alt_text) pairs, cleaned content with image tags removed). z$!\[([^\]]*)\]\((https?://[^\s\)]+)\)rr c3K|]A}|p|vVBdSro)r_r)rqrrs r rsz5BasePlatformAdapter.extract_images..Ascmms399;;'',,Bsyy{{0Bmmmmmmr).pngr.jpegr..webpz fal.mediazfal-cdnzreplicate.deliveryzA]+)["\']?\s*/?>\s*(?:)?rXch|]\}}|Srr)rqrrOs r z5BasePlatformAdapter.extract_images..Ms777fc1c777rc|jdkr|dn|d}|vrdn|dS)Nr rrXr) lastindexgroup)matchrextracted_urlss r _remove_if_extractedz@BasePlatformAdapter.extract_images.._remove_if_extractedNsJ(-1(<(>@@Gwr audio_pathc^Kd|}|r|d|}||||d{VS)a  Send an audio file as a native voice message via the platform API. Override in subclasses to send audio as voice bubbles (Telegram) or file attachments (Discord). Default falls back to sending the file path as text. u 🔊 Audio: rr&Nr')rrrIr$rkwargsr7s r send_voicezBasePlatformAdapter.send_voiceXsZ+j**  (''''DYYwxYPPPPPPPPPrc2K|jd||d|d{VS)z Play auto-TTS audio for voice replies. Override in subclasses for invisible playback (e.g. Web UI). Default falls back to send_voice (shows audio player). )rrINr)rL)rrrIrKs r play_ttszBasePlatformAdapter.play_ttsls9%T_VWVVvVVVVVVVVVr video_pathc^Kd|}|r|d|}||||d{VS)z Send a video natively via the platform API. Override in subclasses to send videos as inline playable media. Default falls back to sending the file path as text. u 🎬 Video: rr&Nr')rrrOr$rrKr7s r send_videozBasePlatformAdapter.send_videozsZ+j**  (''''DYYwxYPPPPPPPPPr file_path file_namec^Kd|}|r|d|}||||d{VS)z Send a document/file natively via the platform API. Override in subclasses to send files as downloadable attachments. Default falls back to sending the file path as text. u 📎 File: rr&Nr')rrrRr$rSrrKr7s r send_documentz!BasePlatformAdapter.send_documentsZ)Y((  (''''DYYwxYPPPPPPPPPr image_pathc^Kd|}|r|d|}||||d{VS)a Send a local image file natively via the platform API. Unlike send_image() which takes a URL, this takes a local file path. Override in subclasses for native photo attachments. Default falls back to sending the file path as text. u🖼️ Image: rr&Nr')rrrVr$rrKr7s r send_image_filez#BasePlatformAdapter.send_image_filesZ.--  (''''DYYwxYPPPPPPPPPrcg}|}d|v}|dd}tjd}||D]}|d}t |dkr8|d|dkr&|ddvr|d d}|dd }|r4| tj ||f|r>| d|}tj d d |}||fS) a Extract MEDIA: tags and [[audio_as_voice]] directives from response text. The TTS tool returns responses like: [[audio_as_voice]] MEDIA:/path/to/audio.ogg Args: content: The response text to scan. Returns: Tuple of (list of (path, is_voice) pairs, cleaned content with tags removed). [[audio_as_voice]]rXz[`"']?MEDIA:\s*(?P`[^`\n]+`|"[^"\n]+"|'[^'\n]+'|(?:~/|/)\S+(?:[^\S\n]+\S+)*?\.(?:png|jpe?g|gif|webp|mp4|mov|avi|mkv|webm|ogg|opus|mp3|wav|m4a|epub|pdf|zip|rar|7z|docx?|xlsx?|pptx?|txt|csv|apk|ipa)(?=[\s`"',;:)\]}]|$)|\S+)[`"']?rr rrz`"'rz `"',.;:)}]r=r>)rr?compiler@r9rHr lstripr`rArur expanduserrB)rmediarD has_voice_tag media_patternr:rs r extract_mediaz!BasePlatformAdapter.extract_mediasf-7 //"6;;  }  #++G44 H HE;;v&&,,..D4yyA~~$q'T"X"5"5$q'V:K:KAbDz''));;v&&--m<>@@Gg~rcd}dd|D}tjd|zdztj}gtjd|tjD]=}||f>tjd|D]=}||f>dtd tffd }g}||D]}||r | d }tj |} tj | r||| ft!} g} |D]5\}} | | vr,| | | || f6d | D} |} | rF| D]\}}| |d } tjdd| } | | fS)aW Detect bare local file paths in response text for native media delivery. Matches absolute paths (/...) and tilde paths (~/) ending in common image or video extensions. Validates each candidate with ``os.path.isfile()`` to avoid false positives from URLs or non-existent paths. Paths inside fenced code blocks (``` ... ```) and inline code (`...`) are ignored so that code samples are never mutilated. Returns: Tuple of (list of expanded file paths, cleaned text with the raw path strings removed). ) r2rr3r.r4r;r<r?r>r=|c3@K|]}|dVdS)rZN)r\)rqes r rsz:BasePlatformAdapter.extract_local_files..s,EEaAHHSMMEEEEEErz/(?K|]\}}|cxko|kncVdSror)rqrrerfs r rszLBasePlatformAdapter.extract_local_files.._in_code..s;;;1qC||||!||||;;;;;;r)r)rf code_spanss`r _in_codez9BasePlatformAdapter.extract_local_files.._in_codes';;;; ;;;;; ;rrcg|]\}}|Srr)rqrOexpandeds r z;BasePlatformAdapter.extract_local_files..s444ka444rrXr=r>)joinr?r[ IGNORECASEr@DOTALLrAstartendrcrr9rurr]isfileraddrrBrH)r_LOCAL_MEDIA_EXTSext_partpath_remrjfoundr:rfrlseenuniquepathsrD_expris @r extract_local_filesz'BasePlatformAdapter.extract_local_filesst" 88EE3DEEEEE * > IF R M    17BIFF 4 4A   qwwyy!%%''2 3 3 3 3\733 4 4A   qwwyy!%%''2 3 3 3 3 <# <$ < < < < < <%%g.. . .Ex && ++a..Cw))#..Hw~~h'' . c8_---EE" / /MCt##""" sHo...44V444  A# 3 3 T!//#r22fY88>>@@Gg~r@interval stop_eventcDK |n|rZ t|dr- ||d{Vn#t$rYnwxYw|j|dS||jvr|||d{V|tj|d{V tj | |d{Vn#tj $rYwxYw t|dr- ||d{Vn#t$rYnwxYw|j|dS#tj $rYnwxYw t|dr- ||d{Vn#t$rYnwxYw|j|dS#t|dr- ||d{Vn#t$rYnwxYw|j|wxYw)u/ Continuously send typing indicator until cancelled. Telegram/Discord typing status expires after ~5 seconds, so we refresh every 2 to recover quickly after progress messages interrupt it. Skips send_typing when the chat is in ``_typing_paused`` (e.g. while the agent is waiting for dangerous-command approval). This is critical for Slack's Assistant API where ``assistant_threads_setStatus`` disables the compose box — pausing lets the user type ``/approve`` or ``/deny``. TNr"r)r6) is_sethasattrr"rFrdiscardr rrwait_forr TimeoutErrorCancelledError)rrrrrs r _keep_typingz BasePlatformAdapter._keep_typing#s$ 1 )j.?.?.A.A)$t]++ **73333333333 D   ' ' 0 0 0 0 0-$"555**7X*FFFFFFFFF%!-111111111!*:??+<+F F'&F'HG43H4 H>HHHc:|j|dS)uPause typing indicator for a chat (e.g. during approval waits). Thread-safe (CPython GIL) — can be called from the sync agent thread while ``_keep_typing`` runs on the async event loop. N)rrtrs r pause_typing_for_chatz)BasePlatformAdapter.pause_typing_for_chatQs! (((((rc:|j|dS)z;Resume typing indicator for a chat after approval resolves.N)rrrs r resume_typing_for_chatz*BasePlatformAdapter.resume_typing_for_chatYs ##G,,,,,rrcK|r0|j|}|| ||d{VdS#t$rYdSwxYw)zDSignal the active session loop to stop and clear typing immediately.N)rrJrr"rF)rrrinterrupt_events r interrupt_session_activityz.BasePlatformAdapter.interrupt_session_activity]s  &"377 DDO*##%%% ""7++ + + + + + + + + +    DD sA A! A! generationcallbackrcz|rt|sdS| ||j|<dSt||f|j|<dS)zRegister a deferred callback to fire after the main response. ``generation`` lets callers tie the callback to a specific gateway run generation so stale runs cannot clear callbacks owned by a fresher run. N)callablerrc)rrrrs r register_post_delivery_callbackz3BasePlatformAdapter.register_post_delivery_callbackhsW (8"4"4  F  9AD )+ 6 6 6:=j//89TD )+ 6 6 6rc|sdS|j|}|dSt|trjt |dkrW|\}}|"t |t |krdS|j|dt|r|ndS|dS|j|dt|r|ndS)zCPop a deferred callback, optionally requiring generation ownership.Nr )rrJrtupler rcpopr)rrrr{entry_generationrs r pop_post_delivery_callbackz.BasePlatformAdapter.pop_post_delivery_callback{s 4-11+>> =4 eU # # <E a). & h%#.>*?*?3z??*R*Rt  ) - -k4 @ @ @'11;88t ;  !4 %))+t<<< 1uuT1rrc KdS)z.Hook called when background processing begins.Nr)rrs r on_processing_startz'BasePlatformAdapter.on_processing_start routcomec KdS)z1Hook called when background processing completes.Nr)rrrs r on_processing_completez*BasePlatformAdapter.on_processing_completerr hook_namerrKcKt||d}t|sdS ||i|d{VdS#t$r-}td|j||Yd}~dSd}~wwxYw)zARun a lifecycle hook without letting failures break message flow.Nz[%s] %s hook failed: %s)r"rrFrrrN)rrrrKhookres r _run_processing_hookz(BasePlatformAdapter._run_processing_hookstY--~~  F O$''' ' ' ' ' ' ' ' ' ' O O O NN4diA N N N N N N N N N Os6 A-"A((A-rct|sdS|tfdtDS)zGReturn True if the error string looks like a transient network failure.Fc3 K|]}|vV dSror)rqpatlowereds r rsz:BasePlatformAdapter._is_retryable_error..s'GGc3'>GGGGGGr)r_r_RETRYABLE_ERROR_PATTERNSrrs @r _is_retryable_errorz'BasePlatformAdapter._is_retryable_errorsC 5++--GGGG-FGGGGGGrcJ|sdS|}d|vpd|vpd|vS)uReturn True if the error string indicates a read/write timeout. Timeout errors are NOT retryable and should NOT trigger plain-text fallback — the request may have already been delivered. Fz timed out readtimeout writetimeout)r_rs r _is_timeout_errorz%BasePlatformAdapter._is_timeout_errors> 5++--g%^')A^^W^E^^rr max_retries base_delayrc K|||||d{V}|jr|S|jpd}|jp||} | s||r|S| rft d|dzD]} |d| dz zztjddz} t d|j | || |tj | d{V|||||d{V}|jr%td|j | |cS|jpd}|js||sntd |j ||d } ||| ||d{Vn8#t$r+} td |j | Yd} ~ nd} ~ wwxYw|St d |j |||d |dd||d{V}|js&td|j |j|S)ax Send a message with automatic retry for transient network errors. On permanent failures (e.g. formatting / permission errors) falls back to a plain-text version before giving up. If all attempts fail due to network errors, sends the user a brief delivery-failure notice so they know to retry rather than waiting indefinitely. rrrrNrXrr rz7[%s] Send failed (attempt %d/%d, retrying in %.1fs): %sz[%s] Send succeeded on retry %dz4[%s] Failed to deliver response after %d retries: %su⚠️ Message delivery failed after multiple attempts. Please try again — your request was processed but the response could not be sent.z/[%s] Could not send delivery-failure notice: %su3[%s] Send failed: %s — trying plain-text fallbackz+(Response formatting failed, plain text:) i z"[%s] Fallback send also failed: %s)rrmrrrrr randomuniformrrrNrrinforFr)rrrrrrrr error_str is_networkrdelaynotice notify_errfallback_results r _send_with_retryz$BasePlatformAdapter._send_with_retrys.$yy !         > ML&B %L)A)A))L)L  d44Y?? M   K!O44  "aGaK&89FN1a"KK A49gVVV!MMM"L.B (D,D,DY,O,OE SUYU^`kmvwwwmk))GVhai)jjjjjjjjjj kkkLL!RTXT]_ijjjjjjjjk  LdiYbccc $ TGETENTT !*! !        & a LL=ty/J_ ` ` `s8F G "!GG  existing_textnew_textc|s|Sd|dD}||vr|d|S|S)a`Merge a new caption into existing text, avoiding duplicates. Uses line-by-line exact match (not substring) to prevent false positives where a shorter caption is silently dropped because it appears as a substring of a longer one (e.g. "Meeting" inside "Meeting agenda"). Whitespace is normalised for comparison. c6g|]}|Srrp)rqcs r rmz6BasePlatformAdapter._merge_caption..s LLL1QWWYYLLLrr>)rxrH)rrexisting_captionss r rz"BasePlatformAdapter._merge_caption so OLL 0C0CF0K0KLLL >>  #4 4 4#333399;; ;rguardrcb|j|}|dS|||urdS|j|=dS)acRelease the adapter-level guard for a session. When ``guard`` is provided, only release the entry if it still points at that exact Event. This lets reset-like commands swap in a temporary guard while the old processing task unwinds, without having the old task's cleanup accidentally clear the replacement guard. N)rrJ)rrr current_guards r _release_session_guardz*BasePlatformAdapter._release_session_guard$sK-11+>>  F  e!;!; F  !+ . . .rc|j|}|dSt|dd}t|o |S)ukReturn True if the owner task for ``session_key`` is done/cancelled. A lock is "stale" when the adapter still has ``_active_sessions[key]`` AND a known owner task in ``_session_tasks`` that has already exited. When there is no owner task at all, that usually means the guard was installed by some path other than handle_message() (tests sometimes install guards directly) — don't treat that as stale. The on-entry self-heal only needs to handle the production split-brain case where an owner task was recorded, then exited without clearing its guard. NFdone)rrJr"r)rrtaskrs r _session_task_is_stalez*BasePlatformAdapter._session_task_is_stale8sM"&&{33 <5tVT**DOTTVV$$$rc.||jvrdS||sdStd|j||j|d|j|d|j|ddS)uClear a stale session lock if the owner task is already gone. Returns True if a stale lock was healed. Returns False if there is no lock, or the owner task is still alive (the normal busy case). This is the on-entry safety net sidbin's issue #11016 analysis calls for: without it, a split-brain — adapter still thinks the session is active, but nothing is actually processing — traps the chat in infinite "Interrupting current task..." until the gateway is restarted. FzB[%s] Healing stale session lock for %s (owner task is done/absent)NT)rrrrrNrrrrrs r _heal_stale_session_lockz,BasePlatformAdapter._heal_stale_session_lockIs d3 3 35**;77 5 P I    !!+t444 "";555  T222tr)rrc|ptj}||j|<tj|||}||j|< |j|nC#t$r6|j |d| ||YdSwxYwt|dr>| |jj | |jj dS)aHSpawn a background processing task under the given session guard. Returns True on success. If the runtime stubs ``create_task`` with a non-Task sentinel (some tests do this), the guard is rolled back and False is returned so the caller isn't left holding a half-installed session lock. NrFadd_done_callbackT)rEventr create_task_process_message_backgroundrrrt TypeErrorrrrrrr)rrrrrrs r _start_session_processingz-BasePlatformAdapter._start_session_processingcs 27=??-2k*"4#C#CE;#W#WXX+/K(   " & &t , , , ,      # #K 6 6 6  ' ' 5 ' A A A55   4, - - K  " "4#9#A B B B  " "4#A#I J J JtsA..>   -:k*?D|?U_{EL$:;;[_  !22599999999H00# %1         ++!L0$"-( ,    $((55FF$"555-:S9FD)+66// =/QQQ  77 ]SSSSSSSSSSSs9A)C##AD8cK|jsdSt|j|jjdd|jjdd}||jvr||||jvrI|}ddl m }||r(|d vr\ | |||d{Vn;#t$r.}td |j||d Yd}~nd}~wwxYwdStd |j|| |jjrd |jjind}||d{V}|r.||jj||j|d{Vn;#t$r.}td |j||d Yd}~nd}~wwxYwdS|jZ |||d{VrdSn:#t$r-}td|j|d Yd}~nd}~wwxYw|jt.jkr9td|j|t3|j||dStd|j|||j|<|j|dS|||dS)z Process an incoming message. This method returns quickly by spawning background tasks. This allows new messages to be processed even while an agent is running, enabling interruption support. Ngroup_sessions_per_userTthread_sessions_per_userF)rrr)should_bypass_active_session)stopnewresetz&[%s] Command '/%s' dispatch failed: %srrrrz$[%s] Busy-session handler failed: %sz=[%s] Queuing photo follow-up for session %s without interruptuD[%s] New message while session %s is active — triggering interrupt)rrrvrextrarJrrrhermes_cli.commandsrrrFrrrNrrrrrxrrurWrdrrrr)rrrrrre _thread_metars r handle_messagez"BasePlatformAdapter.handle_messages$  F' L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]    $/ / /  ) )+ 6 6 6 $/ / /##%%C H H H H H H++C00"  222"CCE;X[\\\\\\\\\\$ D IsA% F  NIsK mLQLLb#lK1G#H#HhlL%)%:%:5%A%AAAAAAAH"33$)L$8$,%*%5%1 4 !mmmLL!I49VY[\gkLllllllllm)5f!77{KKKKKKKK fffLL!GTU`dLeeeeeeeef ![%666 \^b^gituuu+D,BKQVWWW LL_aeajlw x x x27D "; /  !+ . 2 2 4 4 4 F &&uk:::::sI2C D$DD0A'F G"$G  GG<< H3#H..H3c4tjdd}|dkrdSttjdd}ttjdd}|dkrd \}}t j|d z |d z S) ac Return a random delay in seconds for human-like response pacing. Reads from env vars: HERMES_HUMAN_DELAY_MODE: "off" (default) | "natural" | "custom" HERMES_HUMAN_DELAY_MIN_MS: minimum delay in ms (default 800, custom mode) HERMES_HUMAN_DELAY_MAX_MS: maximum delay in ms (default 2500, custom mode) HERMES_HUMAN_DELAY_MODEoffgHERMES_HUMAN_DELAY_MIN_MS800HERMES_HUMAN_DELAY_MAX_MS2500natural)i i g@@)rugetenvr_rcrr)modemin_msmax_mss r _get_human_delayz$BasePlatformAdapter._get_human_delay_sy2E::@@BB 5==3RY:EBBCCRY:FCCDD 9  &NFF~fvov???rc j#34Kd3d434fd}|j|ptj}||j|<t |dd}|jjrd|jjind}d|i} tj|j }n#ttf$rd}YnwxYw| d|j vr||d<tj |j |jjfi|} |d|d{V||d{V} | r@|r,||jvr#t&d |j|d} | s+t&d |j|jj| r$|| \} } || \} } | d d } t7jd d | } | r|jj| |'d{V}#nU|"|vr)|?|jj| |(d{V}#n(|@|jj| |)d{V}#|#j9s't&*d*|j|"|#j:,#tR$r,}$t&*d+|j|$Yd}$~$]d}$~$wwxYw|D]}%|dkrtj4|d{V tW|%j;<}"|"|vr)|?|jj|%|(d{VnU|"|vr)|>|jj|%|'d{Vn(|@|jj|%|)d{V#tR$r,}&t&:d,|j|%|&Yd}&~&d}&~&wwxYw3r4nt|  }'|d-||'r tjCn tjDd{V||jvr|jE|}(t&d.|j|j|})|)|)F| G | d{Vn#tjH$rYnwxYw|I|(|d{V |}*t|d/r|K||*0}+n%t |d1iE|d}+t|+r |+n#tR$rYnwxYw| G | d{Vn#tjH$rYnwxYw t|d2r%|M|jjd{Vn#tR$rYnwxYw|jE|d},|,t&d3|j|j|})|)|)Ftj |I|,|}-|-|jN|< |jOP|-|-Q|jOjRdS#t$rYdSwxYwtjS}.|.$|jN||.ur|jN|=|T||4dSn\#tjH$rUtjS}.tjU}/|. |.|jVvr tjD}/|d-||/d{VtR$r}0|d-|tjDd{Vt&:d5|j|0d"# t|0jX}1t|0rt|0dd6nd7}2|jjrd|jjind}|Z|jjd8|1d9|2d:|;d{Vn#tR$rYnwxYwYd}0~0nd}0~0wwxYw|}*t|d/r|K||*0}+n%t |d1iE|d}+t|+r |+n#tR$rYnwxYw| G | d{Vn#tjH$rYnwxYw t|d2r%|M|jjd{Vn#tR$rYnwxYw|jE|d},|,t&d3|j|j|})|)|)Ftj |I|,|}-|-|jN|< |jOP|-|-Q|jOjRdS#t$rYdSwxYwtjS}.|.$|jN||.ur|jN|=|T||4dS#|}*t|d/r|K||*0}+n%t |d1iE|d}+t|+r |+n#tR$rYnwxYw| G | d{Vn#tjH$rYnwxYw t|d2r%|M|jjd{Vn#tR$rYnwxYw|jE|d},|,t&d3|j|j|})|)|)Ftj |I|,|}-|-|jN|< |jOP|-|-Q|jOjRw#t$rYwwxYwtjS}.|.$|jN||.ur|jN|=|T||4wxYw)|dSdt|ddrddSdS)NTrmF)r")rdelivery_attempteddelivery_succeededs r _record_deliveryzIBasePlatformAdapter._process_message_background.._record_deliveryxs=~!% vy%00 *%)""" * *r_hermes_run_generationNrrrrz:[%s] Suppressing stale response for interrupted session %sz0[%s] Handler returned empty/None response for %srZrXz MEDIA:\s*\S+z<[%s] extract_images found %d image(s) in response (%d chars)z5[%s] extract_local_files found %d file(s) in responser)text_to_speech_toolcheck_tts_requirementsz [*_`#\[\]()]iz!Empty text after markdown cleanup)r7rRz[%s] Auto-TTS failed: %s)rrIrz&[%s] Sending response (%d chars) to %srz1[%s] Extracted %d image(s) to send as attachmentsz[%s] Sending image: %s (alt=%s))rr)r$r)rr#r$rz[%s] Failed to send image: %sz[%s] Error sending image: %sTr>.m4a.mp3.wav.opusr3>.3gpr?r>r<r;r=>r.rr2r3r4)rrOr)rrVr)rrRrz"[%s] Failed to send media (%s): %sz[%s] Error sending media: %sz$[%s] Error sending local file %s: %srz-[%s] Processing queued message from interruptrrrr"uH[%s] Late-arrival pending message during cleanup — spawning drain taskrz[%s] Error handling message: %si,zno details availablezSorry, I encountered an error (z). z2 Try again or use /reset to start a fresh session.)rrr)[rrJrrr"rvrinspect signaturerrr# parametersrrrrrrrrrNrrarHrrHr?rBr r~rrurWrgtools.tts_toolrr json to_threadloadsrFrrexistsrNruremover)rrxrrrr/r+r(rmrrr_rLrQrXrUrrlrprqrclearrrrrrrr"rrrtrr current_taskrrrrtyper r]r)5rrrrrcallback_generation_thread_metadata_keep_typing_kwargs_keep_typing_sig typing_taskr media_filesrC text_content local_files _tts_pathrr _json speech_texttts_result_strtts_datatts_errr human_delayr#rF img_resultimg_err _AUDIO_EXTS _VIDEO_EXTS _IMAGE_EXTS media_pathis_voicer media_result media_errrRfile_err processing_okr_active_callback_generation_post_cb late_pending drain_taskrrre error_type error_detailrrs5 @@r rz/BasePlatformAdapter._process_message_backgroundrsg#" * * * * * */33K@@SGMOO-<k*%o7OQUVVEJLDZdK)?@@`d)+;< $&01BCC  :& $ $ $#    $  #|7G7R'R'R0?  -) D  $  %    C P++,A5II I I I I I I I"22599999999H #**,,  4#999 PI   r OQUQZ\a\h\pqqqh m(,(:(:8(D(D% X(,':':8'D'D$ +334H"MMSSUU !vor<HHNNPP GKK ^`d`iknoukvkvx{}EyFyFGGG-1,D,D\,R,R) \vKK WY]Ybdghsdtdtuuu ! 225<3GHHW!.+2CCC(D +D W^^^^^^^^1133 B0000*,&"l*S*STYUYTY*Z*`*`*b*bK#.V&01T&U&U U3:3D 3+444......N(-{{>'B'BH(0 [(A(AI$WWW'A49gVVVVVVVVW !i!7!7!9!9 ! !"mm$)L$8'0%5, !Ii0000&!!! D!!Ii0000&!!! D! -KK H$)UXYeUfUfhmhth|}}}#'#8#8 % 4 ,!&!1!1 $9$$F %$V,,,#3355 mKK SUYU^`cdj`k`klll+1hh'Ix"Q%mK888888888h = I,Y77-5=HSbSMM2  11)<< /3/B/B(- (<.74<(F$)9 0C00******JJ04(- (<*34<(F$)9 0?00******J *1g"LL)H$)U_Uefff$hhh %CTYPWbf gggggggghHGG OOO HHH ,7!]!](J"Q%mK888888888]":..5;;==+--15(- (<+5)92A22,,,,,,LL !K//15(- (<+5)92A22,,,,,,LL !K//151E1E(- (<+5)92F22,,,,,,LL 261C1C(- (<*4)92D22,,,,,,L ,3u"NN+OQUQZ\_amasttt$]]]'EtyR[\\\\\\\\]"-mmI"Q%mK888888888m"9oo4::<<+--"&"6"6(- (<+4)9#7## !K//"&//(- (<+4)9#2## #'"4"4(- (<*3)9#5## %mmm %KTYXackllllllllm3E\..dS[nnJ\M++(-:Y!))@Q@Y       d444 $ 6 : :; G G  LdiXXX/33K@@&MMOOO""$$$%%%%%%%%%-D66}kRRRRRRRRR>$7 t9:: `::3; #4)CRHHLL[Z^__!! HJJJJ D     !!!!!!!!!)     4//A**5<+?@@@@@@@@@     155k4HHL' ^I/33K@@&MMOOO$044\;OO 4>#K0*..z:::001G1OPPPPP DD '355 +0C0G0G 0T0TXd0d0d+K8++K+OOOOOk50%   "/11L'1G#|4;Y'Y'Y+3++,DeWUU U U U U U U U    ++,DeM^Mfgg g g g g g g g LL:DIqSWL X X X !!WW- /21vvQs1vvdsd||;Q LQLLb#lK1G#H#Hhl ii!L0L*LL'LLL.     # ,$7 t9:: `::3; #4)CRHHLL[Z^__!! HJJJJ D     !!!!!!!!!)     4//A**5<+?@@@@@@@@@     155k4HHL' ^I/33K@@&MMOOO$044\;OO 4>#K0*..z:::001G1OPPPPP DD '355 +0C0G0G 0T0TXd0d0d+K8++K+OOOOOA$7 t9:: `::3; #4)CRHHLL[Z^__!! HJJJJ D     !!!!!!!!!)     4//A**5<+?@@@@@@@@@     155k4HHL' ^I/33K@@&MMOOO$044\;OO 4>#K0*..z:::001G1OPPPP D '355 +0C0G0G 0T0TXd0d0d+K8++K+OOOOs8BB('B(&G)o4BM.-o4. N#8!No4N##&o4 (P3Po4 Po4Po4P?P/.P?/ P<9P?;P<<P??C#o4#CW=;o4= X5#X0*o40X557o4-D]20o42 ^(5x44 yy$9| |-,|-AAF2" -,AF2- :7AF29::AF2@A@@AF2@A@-@*AF2@,A@-@-AF2@15AA'A&AF2A' AA4A1AF2A3AA4A4B"AF2D9AEEAF2E AEEAF2EAEEAAF2cKd}t|D]a}d|jD}|snK|D]0}|j||1t j|ddid{Vb|j|j|j|j |j dS)zCancel any in-flight background message-processing tasks. Used during gateway shutdown/replacement so active sessions from the old process do not keep running after adapters are being torn down. c:g|]}||Sr)r)rqrs r rmz?BasePlatformAdapter.cancel_background_tasks.. s%PPPdDIIKKPTPPPrreturn_exceptionsTN) r rrrtrrgatherrrrr)rMAX_DRAIN_ROUNDSrOtasksrs r cancel_background_tasksz+BasePlatformAdapter.cancel_background_tasks s'(( A AAPPd&<PPPE   .224888 .%@4@@ @ @ @ @ @ @ @ @ $$&&& &,,... !!### $$&&& ##%%%%%rcR||jvo|j|S)z3Check if there's a pending interrupt for a session.)rrrs r has_pending_interruptz)BasePlatformAdapter.has_pending_interrupt s)d33c8Mk8Z8a8a8c8ccrc8|j|dS)z0Get and clear any pending message for a session.N)rrrs r get_pending_messagez'BasePlatformAdapter.get_pending_message s%))+t<<s:$    rc KdS)z Get information about a chat/channel. Returns dict with at least: - name: Chat name - type: "dm", "group", "channel" Nrrs r get_chat_infoz!BasePlatformAdapter.get_chat_info) s  rc|S)z Format a message for this platform. Override in subclasses to handle platform-specific formatting (e.g., Telegram MarkdownV2, Discord markdown). Default implementation returns content as-is. r)rrs r format_messagez"BasePlatformAdapter.format_message4 s r max_lengthrzCallable[[str], int]c|pt}|||kr|gSd}d}g}|}d}|r|d|dnd} ||z || z ||z } | dkr|dz} || ||z||z kr|| |zn |turt|| |} n| } |d| } | d} | | dzkr| d } | dkr| } |d| }|d |d z }|dzdkr|d }|d kr;||dz d kr,|d d |}|d kr||dz d k,|d krI|d d |}|dd |}t ||}|| dzkr|} |d| }|| d}| |z}|du}|pd}|dD]n}|}| drC|rd}d}2d}|dd}|r|d nd}o|r||z }|}nd}|||t|dkr*t|fdt|D}|S)a9 Split a long message into chunks, preserving code block boundaries. When a split falls inside a triple-backtick code block, the fence is closed at the end of the current chunk and reopened (with the original language tag) at the start of the next chunk. Multi-chunk responses receive indicators like ``(1/3)``. Args: content: The full message content max_length: Maximum length per chunk (platform-specific) len_fn: Optional length function for measuring string length. Defaults to ``len`` (Unicode code-points). Pass ``utf16_len`` for platforms that measure message length in UTF-16 code units (e.g. Telegram). Returns: List of message chunks z ```Nz```rrXrr  `z\`r\rFTr5c2g|]\}}|d|dzddS)z (rrrr)rqichunktotals r rmz8BasePlatformAdapter.truncate_message.. sG19E5,,AE,,E,,,r) r rArrfindrdmaxr\rxrHra enumerate)rr[r_lenINDICATOR_RESERVE FENCE_CLOSEchunks remaining carry_langprefixheadroom _cp_limitregionsplit_atrbacktick_countlast_bt safe_splitnl_split chunk_body full_chunkin_codelangrMstrippedtagrds @r truncate_messagez$BasePlatformAdapter.truncate_message? s2} 4==J & &9   %) S &.8-C):))))F"$55V DttKGXGXXH!||%?tF||dd9oo->O1OOO fy01113.y(DII $ z z*F||D))H)q.((!<<,,!||$")8),I&__S11IOOE4J4JJN!Q&&#//#..kki! &<&D&D'ooc1g>>Gkki! &<&D&DQ;;!*a!A!AJ(tQ@@H!$Z!:!:J!IN22#-"9H9-J!()),3355I*,J!,G#D"((.. = =::<<&&u--=="'!"&&qrrl002214(d((((-*      ^ 6$)D((( @@@@@ @  @ @@@@:             "&"&-1 QQQQ# Q 3- Q 4S>* Q QQQQ."&"&-1 FFFF# F 3- F 4S>* F FFFF"&s&t&&&\& --d5c?.CS.H(I---\-f"&"& QQQQ# Q 3- Q QQQQ( W W W  W W W W$"&"& QQQQ# Q 3- Q QQQQ."&#'"& QQQQ# Q C= Q 3- Q QQQQ0"&"& QQQQ# Q 3- Q QQQQ('s'uT%T 2B-CS-H'I'''\'RASAU49c>-BAAA\AL+/ ,1,1,1,1 MD( ,1  ,1,1,1,1\)S)T))))-c-d---- C # RV     "& UUUUU $J U  UUUU."& 2222$J 2 D 22226=|=====@,@IZ@_c@@@@OCOOsOW[OOOOH8C=HTHHH\H _# _4 _ _ _\ _#'PPPP3- P  P  PP PPPPd hsm s s   \ 6*. //// & /  ////(%#%$%%%%"CD>48  "'-0   H# $ $5$5$5$5 $5  $5  $5$5$5$5LCC}C  CCCC"8T8T8T 8T  8T8T8T8Tti;,i;4i;i;i;i;V@e@@@\@$hP|hPRUhPZ^hPhPhPhPT &&&&@dddddd=s=x 7M====$(!%#'#'$(%)%)"&(,$(# # # C=#  # # # C= # C=# SM# c]# c]# # 3-# ! # SM#  # # # # J 3 4S>   ^  c c    37AAAA/0A c AAA\AAArrro)r)r)rr )r)r3)r3r )r;)hrarrrr rurr?socketr$rCrArabcrr urllib.parserutilsrr r rr]rcrrrrr1rUrrjrrzrrrrrrr dataclassesrrrpathlibrtypingrrrrrrrenumr_Pathrinsert__file__rOrgateway.configrrgateway.sessionrrhermes_constantsr*GATEWAY_SECRET_CAPTURE_UNSUPPORTED_MESSAGErrrrbytesrrrr-r1r2r7r9rASUPPORTED_VIDEO_TYPESrBrErHSUPPORTED_DOCUMENT_TYPESrIrSrUrWrlrtrrrrrrrrr rs  ########!!!!!!%%%%%%  8 $ $ + + + + + +#cc&#ss&      F!C$J!!!!H5C5E#sTz/$:5555(49&A&A3&Ac&At&At&A&A&A&ARcDIoc3h&G#c(&RUY&Y^b.$(IMDjS /E#s(O3c#h>E 4Z D C$J 4    <$d $uT4Z7H$$$$B)(((((((HHHHHHHHHHHHHHHHHH!!!!!!33uuX..008;<<===33333333<<<<<<<<++++++b+ "&"&#"&"&S"&"&"&"&J6!.??T Ed"Sc888C8c8S8QT8888vsC8!. >>T Sc$88C8c8S8QT8888D!.??      T Sc $^$57GHH      V P X   ESS@#s*     $    LLLLLLL L^   6*6*6*3 ,-6*6* 6*  6*  6*6*6*6*@ <.)HSM*BBC !Tz 4Z