iP dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZddlmZejeZdedefdZdededefd Zded edefd Zd edefd ZdedzfdZdZdedzdedzfdZdedzdefdZdedzdeeeffdZ ddl!m"Z"m#Z#ddl$m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.ddl/m0Z0ddl%m&Z1e j23dee1e45j6dddl7m8Z8m9Z9ddl:m;Z;mZ>dZ?d[ded edefd!Z@d"ZAe>d#d$ZBde&fd%ZCd&eDdefd'ZEd\d&eDd)edefd*ZFd]ded)ed+edefd,ZGd^d.edefd/ZHe>d0d1ZIde&fd2ZJd_d&eDd)edefd4ZKd`ded)ed+edefd5ZLe>d6d7ZMd8d9d:d:d;dd?ZNde&fd@ZOd&eDdAedefdBZPd^d.edefdCZQGdDdEe0ZRGdFdGe0ZSe"GdHdIZTe"GdJdKZUdLdMdNe(eeTfdOedPeTdQeddf dRZVdSZWe,eTge-e*efZX dZdTedUedVedzdedzfdWZYGdXdYe ZZdS)az Base platform adapter interface. All platform adapters (Telegram, Discord, WhatsApp) inherit from this and implement the required methods. N)ABCabstractmethod)urlsplitsreturncLt|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 >/home/agentuser/.hermes/hermes-agent/gateway/platforms/base.py utf16_lenr s# 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)r r )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_accessibler0Ms  #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_proxyrTpsU |xt% y !14 @R    ttE  --zz|| D==..//KCC!$E#))++ +//& Hh 99Z C ' '99X&&D99X&&D / /........ 4s$9 AAplatform_env_varc |r7tj|pd}|r|SdD];}tj|pd}|r|cS>@@  L:$$*1133  LLL  % ' ''r 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-socksproxylower startswith aiohttp_socksrffrom_url ImportErrorloggerwarningrbrfris r proxy_kwargs_for_botrus  ##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: ... rdrreTrgrirjrkrlrts r proxy_kwargs_for_aiohttprws 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).rrWN@rz:///z/.../z/...r4.z...)strrrEschemenetlocrsplitpathr ) rrrawparsedrbaserbasenamesafes r safe_url_for_logrsc!||r {r c((C r# 8G8}}  %%c1--b1-,,F,,{ b  DCKK{{3**2.H/7Jd+++++]]]DDDD 4yyG !||W}@Trr5follow_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"rasynciohttpxlogging getLogger__name__ AsyncClientrrangerIraise_for_statusrcontentTimeoutExceptionHTTPStatusError isinstancer status_codedebugsleeprrrrrr_logging_loglast_excclientattemptrexcwaits r cache_image_from_urlrs%$-,,,,, ;s  [YBRSVBWBWYYZZZNNNLLL   h ' 'DH  "6!78!         Wq[))  G !'&Q"5",""))+++-h.>DDDD               *E,AB   c5#899cl>VY\>\>\W$$'A+.DJJD! (-- ('----------HHHH!                             B NDFAC5 F5FA6F<FFFF 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(rrrcutoffremovedfs r cleanup_image_cachers 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_dirrrr.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)rrrrrr)rrrrrs r cache_audio_from_bytesrs]$%%I4 ("-4s44H8#H  x==rc `Kddlm}||stdt|ddl}ddl}ddl}|t}d}| dddtgi4d{V } t|d zD]} | |d d d  d{V} | t| j|ccdddd{VS#|j|jf$r} | }t%| |jr| jjdkr| |krMd| d zz} |d| d z|t|| | |j| d{VYd} ~ d} ~ wwxYw dddd{Vn#1d{VswxYwY|)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"rrrrrrrrrrIrrrrrrrrrrrs r cache_audio_from_urlrrrzcache/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_dirr ?s!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. documentrW)rz..doc_NrrNzPath traversal rejected: ) r r{namerrGrrrresolveis_relative_tor"rr)rrr safe_name cached_namers r cache_document_from_bytesrEs"'((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. rNrr)rr rrrrrr(rs r cleanup_document_cacheres KKK&((I YY[[MD0 1FG     99;; 16688,v55  1      Nrc6eZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) MessageTypezTypes of incoming messages.r6locationphotovideoaudiovoicerstickercommandN) r __module__ __qualname____doc__TEXTLOCATIONPHOTOVIDEOAUDIOVOICEDOCUMENTSTICKERCOMMANDrrr rrzsA%% DH E E E EHGGGGrrceZdZdZdZdZdZdS)ProcessingOutcomez=Result classification for message-processing lifecycle hooks.successfailure cancelledN)rr"r#r$SUCCESSFAILURE CANCELLEDrrr r/r/s#GGGGIIIrr/ceZdZUdZeed<ejZeed<dZ e ed<dZ e ed<dZ eeed<eeZeeed <eeZeeed <dZeeed <dZeeed <dZeeeezed <dZeeed<dZeed<eejZeed<defdZdeefdZdefdZdS) MessageEventzi Incoming message from a platform. Normalized representation that all adapters produce. r6 message_typeNsource raw_message message_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)r6rnselfs r is_commandzMessageEvent.is_commandsy##C(((rc|sdS|jd}|r"|dddnd}|r d|vr|ddd}|rd|vrdS|S)z2Extract command name if this is a command message.Nrmaxsplitrrr)rHr6splitrm)rGpartsrs r get_commandzMessageEvent.get_commands   4 ++&+5eAhqrrl  """  '3#::))C##A&C  3#::4 rc|s|jS|jd}t|dkr|dndS)z"Get the arguments after a command.rrJrW)rHr6rLr )rGrMs r get_command_argszMessageEvent.get_command_argssM   9  ++u::>>uQxxr1r) rr"r#r$r__annotations__rr%r8r9rr:rr;r~rylistr=r}r>r?r@rArBrCboolrznowrDrHrNrPrrr r7r7s III + 0L+000!FM   K $J $$$"E$777JS 777"U4888Kc888*.#---#'M8C='''-1JtCy)000%)NHSM(((Hd % ===Ix===)D)))) Xc]    2#222222rr7cneZdZUdZeed<dZeeed<dZ eeed<dZ e ed<dZ eed<dS) SendResultzResult of sending a message.r0Nr;error raw_responseF retryable) rr"r#r$rSrQr;r~rrWrXrrYrrr rVrVsi&& MMM $J $$$E8C=L#ItrrVF) merge_textpending_messages session_keyeventrZc||}|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. r8N ) rIr!rr'r8rSr=extendr>r6BasePlatformAdapter_merge_captionr%) r[r\r]rZexistingexisting_is_photoincoming_is_photoexisting_has_mediaincoming_has_medias r merge_pending_message_eventrhs$ ##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) connecterrorconnectionerrorconnectionresetconnectionrefusedconnecttimeoutnetworkz 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)rIrdictrrG)rqrrrspromptsrMprompts r resolve_channel_promptry.s0117RG gt $ $tI&  S!! > V""$$  MMM  4rceZdZdZdedefdZedefdZ ede e fdZ ede e fdZ edefd Zd edged d zfdd fd Zdnd ZdndZde de dedd fdZdndZde de de defdZdndZede fdZedefdZd edd fdZd e eee geefdd fdZdedd fdZe defdZ!e dnd Z"e dod!e d"e d#e e d$e e#e efde$f d%Z%d!e d&e d"e de$fd'Z&dpd!e dd fd(Z'd!e dd fd)Z( dqd!e d*e d+e e d#e e d$e e#e efde$f d,Z) dqd!e d-e d+e e d#e e d$e e#e efde$f d.Z*e+d/e defd0Z,e+d"e de-e.e-e e fe ffd1Z/ dod!e d2e d+e e d#e e de$f d3Z0d!e d2e de$fd4Z1 dod!e d5e d+e e d#e e de$f d6Z2 dqd!e d7e d+e e d8e e d#e e de$f d9Z3 dod!e d:e d+e e d#e e de$f d;Z4e+d"e de-e.e-e efe ffd<Z5e+d"e de-e.e e ffd=Z6drd!e d?e7dd fd@Z8d!e dd fdAZ9d!e dd fdBZ:dCedd fdDZ;dCedEee+dKe e defdLZ?e+dKe e defdMZ@ dsd!e d"e d#e e d$edOeAdPe7ddQfdRZBe+dSe e dTe de fdUZCdCedd fdVZDe+de7fdWZEdCedXe dd fdYZFdndZZGdXe defd[ZHdXe de efd\ZI dtd!e d^e e d_e d`e e dae e dbe e dce e dde e dee e deJfdfZKe d!e de#e effdgZLd"e de fdhZMe+ dud"e djeAdke dlde.e fdmZNd S)vraz Base class for platform adapters. Subclasses implement platform-specific logic for: - Connecting and authenticating - Receiving messages - Sending messages/responses - Handling media configrAcF||_||_d|_d|_d|_d|_d|_d|_i|_i|_ t|_ i|_ t|_ d|_t|_t|_dS)NFT)r{rA_message_handler_running_fatal_error_code_fatal_error_message_fatal_error_retryable_fatal_error_handler_active_sessions_pending_messagesset_background_tasks_post_delivery_callbacks_expected_cancelled_tasks_busy_session_handler_auto_tts_disabled_chats_typing_paused)rGr{rAs r __init__zBasePlatformAdapter.__init__Ws   :> 0437!&*#im!;=:<58EE >@%|jjS)z%Human-readable name for this adapter.)rAr`titlerFs r rzBasePlatformAdapter.names}"((***rc|jS)z(Check if adapter is currently connected.)r~rFs 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)r}rs 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)rGrs 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. NrrFs r connectzBasePlatformAdapter.connect  rc KdS)zDisconnect from the platform.NrrFs r disconnectzBasePlatformAdapter.disconnects  rchat_idrreply_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)rGrrrrs r sendzBasePlatformAdapter.sends ( rr;c(KtddS)u Edit a previously sent message. Optional — platforms that don't support editing return success=False and callers fall back to sending a new message. Fz Not supported)r0rW)rV)rGrr;rs r edit_messagez BasePlatformAdapter.edit_messages%????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)rGrrs r send_typingzBasePlatformAdapter.send_typing%rrc 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. NrrGrs r stop_typingzBasePlatformAdapter.stop_typing.s 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. r_rrrNr)rGrrrrrr6s r send_imagezBasePlatformAdapter.send_image6sO -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. )rrrrrN)r)rGrrrrrs r send_animationz"BasePlatformAdapter.send_animationIsX__W W^iq}E_FFFFFFFF Frrc|dd}|dS)z=Check if a URL points to an animated GIF (vs a static image).?r.gif)rmrLendswith)rrms r _is_animation_urlz%BasePlatformAdapter._is_animation_urlZs6 !!#&&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|vVBdSr)rmr).0rrs r z5BasePlatformAdapter.extract_images..yscmms399;;'',,Bsyy{{0Bmmmmmmr).pngr.jpegr.webpz fal.mediazfal-cdnzreplicate.deliveryzA]+)["\']?\s*/?>\s*(?:)?rWch|]\}}|Srr)rrrNs r z5BasePlatformAdapter.extract_images..s777fc1c777rc|jdkr|dn|d}|vrdn|dS)Nr rrWr) lastindexgroup)matchrextracted_urlss r _remove_if_extractedz@BasePlatformAdapter.extract_images.._remove_if_extractedsJ(-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: r_rNr)rGrr rrkwargsr6s r send_voicezBasePlatformAdapter.send_voicesZ+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). )rr Nr)r)rGrr r s r play_ttszBasePlatformAdapter.play_ttss9%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: r_rNr)rGrrrrr r6s r send_videozBasePlatformAdapter.send_videosZ+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: r_rNr)rGrrrrrr r6s 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: r_rNr)rGrrrrr r6s 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]]rWz[`"']?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)(?=[\s`"',;:)\]}]|$)|\S+)[`"']?rr rrz`"'rz `"',.;:)}]rr)rrcompilerrrGr lstriprstriprr^r expanduserr)rmediar has_voice_tag media_patternrrs r extract_mediaz!BasePlatformAdapter.extract_mediasf-7 //"6;;  G  #++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). ) rrrrr.mp4.mov.avi.mkv.webm|c3@K|]}|dVdS)rN)r)res r rz:BasePlatformAdapter.extract_local_files..,s,EEaAHHSMMEEEEEErz/(?K|]\}}|cxko|kncVdSrr)rrr-r.s r rzLBasePlatformAdapter.extract_local_files.._in_code..>s;;;1qC||||!||||;;;;;;r)r)r. code_spanss`r _in_codez9BasePlatformAdapter.extract_local_files.._in_code=s';;;; ;;;;; ;rrcg|]\}}|Srr)rrNexpandeds r z;BasePlatformAdapter.extract_local_files..Qs444ka444rrWrr)joinrr IGNORECASErDOTALLrstartendintrSrr^rr isfileraddrrrG)r_LOCAL_MEDIA_EXTSext_partpath_remr2foundrrr4seenuniquepathsr_expr1s @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@intervalc"K ||jvr|||d{Vtj|d{VA#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``. TrNr) rrrrCancelledErrorhasattrrrEdiscard)rGrrIrs r _keep_typingz BasePlatformAdapter._keep_typing[s 1 .$"555**7X*FFFFFFFFFmH--------- .%    D   t]++ **73333333333 D   ' ' 0 0 0 0 0 t]++ **73333333333 D   ' ' 0 0 0 0sZAAAB5AB5-B BB5DC#"D# C0-D/C00Dc:|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)rr=rs r pause_typing_for_chatz)BasePlatformAdapter.pause_typing_for_chatzs! (((((rc:|j|dS)z;Resume typing indicator for a chat after approval resolves.N)rrMrs r resume_typing_for_chatz*BasePlatformAdapter.resume_typing_for_chats ##G,,,,,rr]c KdS)z.Hook called when background processing begins.Nr)rGr]s r on_processing_startz'BasePlatformAdapter.on_processing_start routcomec KdS)z1Hook called when background processing completes.Nr)rGr]rVs r on_processing_completez*BasePlatformAdapter.on_processing_completerUr hook_nameargsr cKt||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!callablerErrrsr)rGrYrZr hookr-s 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-rWct|sdS|tfdtDS)zGReturn True if the error string looks like a transient network failure.Fc3 K|]}|vV dSrr)rpatlowereds r rz:BasePlatformAdapter._is_retryable_error..s'GGc3'>GGGGGGr)rmr_RETRYABLE_ERROR_PATTERNSrWrbs @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)rmrds r _is_timeout_errorz%BasePlatformAdapter._is_timeout_errors> 5++--g%^')A^^W^E^^rr max_retries base_delayrVc 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. rrrrNrWrr 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)rr0rWrYrerirrandomuniformrrrsrrrinforEr)rGrrrrrjrkr 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|]}|Sr)rG)rcs r r5z6BasePlatformAdapter._merge_caption.. s LLL1QWWYYLLLrr)rLrG)rxryexisting_captionss r rbz"BasePlatformAdapter._merge_captionso OLL 0C0CF0K0KLLL >>  #4 4 4#333399;; ;rc K|jsdSt|j|jjdd|jjdd}||jvr|}|dvrt d|j || |jj rd |jj ind}||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&jkr9t d|j |t+|j||dSt d|j |||j|<|j|dSt1j|j|<t1j|||} |j|n#t<$rYdSwxYwt?|dr@| |jj!| |j"j!dSdS)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)rr) approvedenystatusstopnewreset backgroundrestartqueueqz8[%s] Command '/%s' bypassing active-session guard for %s thread_idrmz&[%s] Command '/%s' dispatch failed: %sexc_infoz$[%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 interruptadd_done_callback)#r}rr9r{extrarIrrNrrrrrrwrr;rErWrr8rr'rhrrrEvent create_task_process_message_backgroundrr= TypeErrorrLrrMr)rGr]r\cmd _thread_metarr-tasks r handle_messagez"BasePlatformAdapter.handle_messages$  F' L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]    $/ / /##%%Crrr 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.5]__k*"4#C#CE;#W#WXX   " & &t , , , ,    FF  4, - - K  " "4#9#A B B B  " "4#A#I J J J J J K KsC$A'D E$D??EE00 F':#F""F'J## J10J1c4ddl}tjdd}|dkrdSt tjdd}t tjdd }|d krd \}}|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) rNHERMES_HUMAN_DELAY_MODEoffgHERMES_HUMAN_DELAY_MIN_MS800HERMES_HUMAN_DELAY_MAX_MS2500natural)i i g@@)rnr^getenvrmr;ro)rnmodemin_msmax_mss r _get_human_delayz$BasePlatformAdapter._get_human_delayjs  y2E::@@BB 5==3RY:EBBCCRY:FCCDD 9  &NFFv~fvov???rr\c ,-Kd,d-,-fd}|j|ptj}||j|<|jjrd|jjind}tj||jj|} | d|d{V| |d{V}|r@| r,||j vr#td|j|d}|s+td|j|jj|r||\}}||\} } | d d } t+jd d | } | rn tzj?d{V||j vrz|j @|}%td,|j||jvr|j|=|A |d{Vn#tjB$rYnwxYw|C|%|d{V t|d-i@|d}&t|&r |&n#tH$rYnwxYw|A |d{Vn#tjB$rYnwxYw t|d.r%|G|jjd{Vn#tH$rYnwxYw||jvr |j|=dSdSn\#tjB$rUtjH}'tzjI}(|' |'|jJvr tzj?}(| d+||(d{VtH$r})| d+|tzj?d{Vt5d/|j|)d ! t|)jL}*t|)rt|)dd0nd1}+|jjrd|jjind}|N|jjd2|*d3|+d4|5d{Vn#tH$rYnwxYwYd})~)nd})~)wwxYwt|d-i@|d}&t|&r |&n#tH$rYnwxYw|A |d{Vn#tjB$rYnwxYw t|d.r%|G|jjd{Vn#tH$rYnwxYw||jvr |j|=dSdS#t|d-i@|d}&t|&r |&n#tH$rYnwxYw|A |d{Vn#tjB$rYnwxYw t|d.r%|G|jjd{Vn#tH$rYnwxYw||jvr|j|=wxYw)6z4Background task that actually processes the message.Fc>|dSdt|ddrddSdS)NTr0F)r!)rdelivery_attempteddelivery_succeededs r _record_deliveryzIBasePlatformAdapter._process_message_background.._record_deliverys=~!% vy%00 *%)""" * *rrNrrTz:[%s] Suppressing stale response for interrupted session %sz0[%s] Handler returned empty/None response for %srrWz 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)r6rz[%s] Auto-TTS failed: %s)rr rz&[%s] Sending response (%d chars) to %srmz1[%s] Extracted %d image(s) to send as attachmentsz[%s] Sending image: %s (alt=%s))rrrr)rrrrz[%s] Failed to send image: %sz[%s] Error sending image: %sTr>.m4a.mp3.wav.opusr>.3gpr(r)r'r&r*>rrrrr)rrr)rrr)rrrz"[%s] Failed to send media (%s): %sz[%s] Error sending media: %sz$[%s] Error sending local file %s: %srXz-[%s] Processing queued message from interruptrrz[%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)OrrIrrr9rrrNrr^r}is_setrrrrprrr$r rrGrrr rGr8rr*rtools.tts_toolrrjsonr" to_threadloadsrErsr{existsrr^remover(rwr;rrrrrrr0rWsuffixrmrrrrrSr/r3r4popcancelrKrr!r\rLr current_taskr5rtyperrr).rGr]r\rinterrupt_event_thread_metadata typing_taskr media_filesr text_content local_files _tts_pathrr_json speech_texttts_result_strtts_datatts_errr human_delayrr img_resultimg_err _AUDIO_EXTS _VIDEO_EXTS _IMAGE_EXTS media_pathis_voicer media_result media_errrfile_err processing_ok pending_event_post_cbrrVr- error_type error_detailrrs. @@r rz/BasePlatformAdapter._process_message_backgroundsr#" * * * * * */33K@@SGMOO-<k*EJLDZdK)?@@`d)$*;*;EL'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$"777-k:""$$$%%%%%%%%%-D66}kRRRRRRRRR>t%?DDHHVZ[[H!! HJJJJ D     !!!!!!!!!)     4//A**5<+?@@@@@@@@@    d333)+66643A5%   "/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.     # ,t%?DDHHVZ[[H!! HJJJJ D     !!!!!!!!!)     4//A**5<+?@@@@@@@@@    d333)+66643)t%?DDHHVZ[[H!! HJJJJ D     !!!!!!!!!)     4//A**5<+?@@@@@@@@@    d333)+66666s\Gh&4BLh& M!M=h&M&h&.(N<N,+h&, N96h&8N99h&<O#>OO# O O#O  O##C#h&CV!h&! W+#Wh&W7h&D\h& ]  !]h&]  (h&5B(`h& a("a h&aB5h& dh&d%"h&$d%%h&: f ff*f33gg 5g?? h  h $q!&A,m?A m:Bm%$m:% m2/m:1m22m:5q!:m??q!7 o oo'o00pp5p<< q q !5t> r"!t>" r/,t>.r//t>st>s"t>!s""t>&5tt> t)&t>(t))t>cKd|jD}|D]0}|j||1|rt j|ddid{V|j|j|j|jdS)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)done)rrs r r5z?BasePlatformAdapter.cancel_background_tasks..s%LLL$ LLLLrreturn_exceptionsTN) rrr=rrgatherclearrr)rGtasksrs r cancel_background_tasksz+BasePlatformAdapter.cancel_background_taskss ML$"8LLL  D  * . .t 4 4 4 KKMMMM  A.%@4@@ @ @ @ @ @ @ @ $$&&& &,,... $$&&& ##%%%%%rcR||jvo|j|S)z3Check if there's a pending interrupt for a session.)rrrGr\s r has_pending_interruptz)BasePlatformAdapter.has_pending_interrupts)d33c8Mk8Z8a8a8c8ccrc8|j|dS)z0Get and clear any pending message for a session.N)rrrs r get_pending_messagez'BasePlatformAdapter.get_pending_messages%))+t<<.psG19E5,,AE,,E,,,r) r rrrfindcountmaxrrLrGrn enumerate)rrr_lenINDICATOR_RESERVE FENCE_CLOSEchunks remaining carry_langprefixheadroom _cp_limitregionsplit_at candidatebacktick_countlast_bt safe_splitnl_split chunk_body full_chunkin_codelangrLstrippedtagrs @r truncate_messagez$BasePlatformAdapter.truncate_messages2} 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--=="'!"&&qrrl0022145555X5)Xc])))X)&(3-&&&X&+t+++X+,x9N8OQZ[_Q`cgQg8g/h,mq,,,,    S3dt C3sW[(,,,,+c+++X+dX(>(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\AF11#11X\1111>)S)T))))-c-d----=|=====@,@IZ@_c@@@@OCOOsOW[OOOOH8C=HTHHH\H _# _4 _ _ _\ _#'PPPP3- P  P  PP PPPPd hsm s s   \ XK,XK4XKXKXKXKt@e@@@\@(e7|e7RUe7Z^e7e7e7e7N &&&&"dddddd=s=x 7M====$(!%#'#'$(%)%)   C=   #  C=  C= SM c] c]      : 3 4S>   ^  c c    37AAAA/0A c AAA\AAArrar)r)r)rr )r)r)rr )[r$rrrr^rnrsocketr#rBr@rabcrr urllib.parserrrrrrr;r rrrSr0rTrarvrutuplerw dataclassesrxryrzpathlibr{typingr|r}r~rrrrenumr_Pathrinsert__file__rrgateway.configrrgateway.sessionrrhermes_constantsr*GATEWAY_SECRET_CAPTURE_UNSUPPORTED_MESSAGErrrrbytesrrrrrrrrr SUPPORTED_DOCUMENT_TYPESr rrrr/r7rVrhrcrryrarrr r0s0  ########!!!!!!  8 $ $ + + + + + +#cc&#ss&      F!C$J!!!!H((d (cDj((((, C$J 4    <$d $uT4Z7H$$$$B)(((((((HHHHHHHHHHHHHHHHHH!!!!!!33uuX..008;<<===33333333<<<<<<<<++++++b+ "&"&#"&"&S"&"&"&"&J6!.??T Ed"Sc8==C=c=S=QT====@sC8!. >>T Sc$==C=c=S=QT====N$^$57GHH      V P X   ESS@#s*     $    @2@2@2@2@2@2@2 @2F   6*6*6*3 ,-6*6* 6*  6*  6*6*6*6*@ <.)HSM*BBC !Tz 4Z