+ iEFRt^RIt^RIt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t ]P!] 4t^RIHtHt^RIHt^RIHt^RIHtHtHtHtHtHtHt^RIHt^RIt^RIHt ]PBPE^]#!] !]$4PK4PL^,44^R I'H(t(H)t)^R I*H+t+H,t,^R I-H.t.^R I/H0t0R t1R@RRllt2]0!RR4t3RRlt4RARRllt5RBRRllt6RCRRllt7]0!RR4t8RRlt9RDRRllt:RER R!llt;]0!R"R#4tR4R5lt?RCR6R7llt@!R8R9]4tA]!R:R;44tB]!R<R=44tCRFtD]]B.]]]#,,3,tE!R>R?]4tFR#)Gz Base platform adapter interface. All platform adapters (Telegram, Discord, WhatsApp) inherit from this and implement the required methods. N)ABCabstractmethod)urlsplit) dataclassfield)datetimePath)DictListOptionalAnyCallable AwaitableTuple)Enum)PlatformPlatformConfig) SessionSourcebuild_session_key)get_hermes_home)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.c<V^8dQhR\R\R\/#)urlmax_lenreturnstrint)formats"3/home/ubuntu/hermes-agent/gateway/platforms/base.py __annotate__r"(s!"&"&3"&"&c"&cPV^8:dR#VfR#\V4pV'gR#\V4pTP'dTP'dTPP R^4R ,pTP RT 2pTP ;'gRpT'd6TR8wd/TP R^4R ,pT'dT RT 2MT R2pMTpMTp\T4T8:dT#T^8:d RT,#TRT^,  R 2# \d TRTu#i;i) z?Return a URL string safe for logs (no query/fragment/userinfo).N@z:///z/.../z/....z...)rr Exceptionschemenetlocrsplitpathlen) rrrawparsedr,baser.basenamesafes && r!_safe_url_for_logr5(s!| { c(C #}}}%%c1-b1--F8,{{  b DCK{{3*2.H/7dV5 +vT]DD 4yG !|W}@Ttimeoutfollow_redirects User-Agent)Mozilla/5.0 (compatible; HermesAgent/1.0)Acceptzimage/*,*/*;q=0.8headers?z*Media cache retry %d/%d for %s (%.1fs): %s)asynciohttpxlogging getLogger__name__ AsyncClientrangegetraise_for_statusrVcontentTimeoutExceptionHTTPStatusError isinstanceresponse status_codedebugr5sleep rrFrYrgrh_logging_loglast_excclientattemptrtexcwaits &&& r!cache_image_from_urlrr   h 'DH   EEEWq[)G !'$&Q "5","))+-h.>.>DDFEE)FE: N;FF**E,A,AB c#8#899cll>V>VY\>\$'A+.DJJD! )#. "-----! FEEE: NAF/C F/ F C:C ;)C$F& F/3C4F/9F; F/FF/CF/F 0B F :E= ;F FF F FF/F, F F, $F, & F/c0V^8dQhR\R\/#r max_age_hoursrr)r s"r!r"r"ssCr#cZ^RIp\4pVP4VR,, p^pVP4FVpVP4'gKVP 4P V8gK<VP 4V^, pKX V# \dKji;i)zX Delete cached images older than *max_age_hours*. Returns the number of files removed. N)timerAiterdiris_filestatst_mtimeunlinkOSErrorrrrScutoffremovedfs& r!cleanup_image_cachers #%I YY[MD0 1FG     99;;1668,,v5  1  ! N  <B B*)B*z cache/audio audio_cachec$V^8dQhR\/#r8r)r s"r!r"r"r9r#c<\PRRR7\#)zBReturn the audio cache directory, creating it if it doesn't exist.Tr;)AUDIO_CACHE_DIRr?r@r#r!get_audio_cache_dirrrBr#c<V^8dQhR\R\R\/#rDrG)r s"r!r"r"rIr#c\4pR\P!4PR, V 2pW#, pVP V4\ V4#)z 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_rL)rrNrOrPrQrrRs&& r!cache_audio_from_bytesrsN$%I ((-.se4H#H  x=r#cHV^8dQhR\R\R\R\/#rXr)r s"r!r"r"rZr#c b"^RIp^RIp^RIpVP\4pRpVP RRR7;_uu_4GRjxL p\ V^,4F[p VPVRRRR/R 7GRjxL p V P4\V PV4uuuRRR4GRjxL # RRR4GRjxL VhLLTL TPTP3dp T p\YP4'dT PPR 8dhY8dYR T ^,,p TP!R T ^,T\#T4T T 4TP$!T 4GRjxL Rp ? EK+hRp ? ii;iL +GRjxL 'giTh;i5i) a 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. Nr\Tr]r`rarbzaudio/*,*/*;q=0.8rcrerfz*Audio cache retry %d/%d for %s (%.1fs): %s)rgrhrirjrkrlrmrnrorrprqrrrsrtrurvr5rwrxs &&& r!cache_audio_from_urlrrrzcache/documentsdocument_cachez.pdfzapplication/pdfz.mdz text/markdownz.txtz text/plainz.zipzapplication/zipz.docxzGapplication/vnd.openxmlformats-officedocument.wordprocessingml.documentz.xlsxzAapplication/vnd.openxmlformats-officedocument.spreadsheetml.sheetz.pptxzIapplication/vnd.openxmlformats-officedocument.presentationml.presentationc$V^8dQhR\/#r8r)r s"r!r"r"'sr#c<\PRRR7\#)zEReturn the document cache directory, creating it if it doesn't exist.Tr;)DOCUMENT_CACHE_DIRr?r@r#r!get_document_cache_dirr'sTD9 r#c<V^8dQhR\R\R\/#)rrErTrrG)r s"r!r"r"-s!ESSr#c\4pV'd\V4PMRpVPRR4P 4pV'dVR9dRpR\ P !4PR, RV 2pW$, pVP4PVP44'g\RV: 24hVPV4\V4#) 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. documentr%doc_rL_zPath traversal rejected: )r(z..) rr namereplacestriprNrOrPresolveis_relative_to ValueErrorrQr)rErTrS safe_name cached_namerUs&& r!cache_document_from_bytesr-s"'(I'/X##ZI!!&"-335I  [0 ))#./q ->-@ A A4XLABB  x=r#c0V^8dQhR\R\/#rr)r s"r!r"r"Ms#sr#cZ^RIp\4pVP4VR,, p^pVP4FVpVP4'gKVP 4P V8gK<VP 4V^, pKX V# \dKji;i)z[ Delete cached documents older than *max_age_hours*. Returns the number of files removed. Nr)rrrrrrrrrs& r!cleanup_document_cacherMs &(I YY[MD0 1FG     99;;1668,,v5  1  ! N  rc>]tRtRtRtRtRtRtRtRt Rt R t R t R t R tR #) MessageTypeibzTypes of incoming messages.textlocationphotovideoaudiovoicerstickercommandr@N)rk __module__ __qualname____firstlineno____doc__TEXTLOCATIONPHOTOVIDEOAUDIOVOICEDOCUMENTSTICKERCOMMAND__static_attributes__r@r#r!rrbs2% DH E E E EHGGr#rca]tRtRtoRt]P tRtRt Rt ] !] R7t ] !] R7tRtRtRt] !]P&R7tV3RlRltV3RlRltV3R lR ltV3R ltR tVtR#) MessageEventiozY Incoming message from a platform. Normalized representation that all adapters produce. N)default_factoryc <V^8dQhRS[/#r8bool)r __classdict__s"r!r"MessageEvent.__annotate__s))D)r#c 8VPPR4#)z8Check if this is a command message (e.g., /new, /reset).r')r startswithselfs&r! is_commandMessageEvent.is_commandsyy##C((r#c0<V^8dQhRS[S[,/#r8r r)r rs"r!r"rs  Xc] r#c VP4'gR#VPP^R7pV'dV^,R,P4MRpV'd!RV9dVPR^4^,pV#)z2Extract command name if this is a command message.Nmaxsplit:NNr&)rrsplitlower)rpartsr0s& r! get_commandMessageEvent.get_commandsc   +&+eAhrl  " 3#:))C#A&C r#c <V^8dQhRS[/#r8r)r rs"r!r"rs22#2r#c VP4'g VP#VPP^R7p\V4^8d V^,#R#)z"Get the arguments after a command.rr%)rrrr/)rrs& r!get_command_argsMessageEvent.get_command_argssF  99  +u:>uQx1r1r#c<V^8dQh/S[;R&S[;R&S[;R&S[;R&S[S[,;R&S[S[,;R&S[S[,;R&S[S[,;R&S[S[,;R &S[S[,;R &S[;R &#) rr message_typesource raw_message message_id media_urls media_typesreply_to_message_id reply_to_text auto_skill timestamp)rrrr r r r)r rs"r!r"ros I0    $!(S 7)*c8+0"#-12C='38 $9>=?r#r@)rkrrrrrrrrrrrlistrrrrrrnowrrrr__annotate_func__r__classdictcell__rs@r!rros!, 0 0L!FK $J"$7J"48K*.#'M!%J  =I))  22ar#rc@a]tRtRtoRtRtRtRtRtV3Rlt Rt Vt R#) SendResultizResult of sending a message.NFcv<V^8dQh/S[;R&S[S[,;R&S[S[,;R&S[;R&S[;R&#)rsuccessrerror raw_response retryable)rr rr )r rs"r!r"SendResult.__annotate__sMM $  C=   r#r@) rkrrrrrrrrrrrrs@r!rrs#& $JELIr#rcha]tRtRtoRtV3RlRlt]V3RlRl4t]V3RlRl4t]V3R lR l4t ]V3R lR l4t V3R lRlt V3RlRlt V3RlRlt V3RlRltV3RlRlt]V3RlRl4t]V3RlRl4tV3RlRltV3RlRlt]V3RlR l4t]V3R!lR"l4t]ReV3R$lR%ll4tV3R&lR'ltRfV3R(lR)lltV3R*lR+ltRgV3R,lR-lltRgV3R.lR/llt]V3R0lR1l4t]V3R2lR3l4tReV3R4lR5llt V3R6lR7lt!ReV3R8lR9llt"RgV3R:lR;llt#ReV3R<lR=llt$]V3R>lR?l4t%]V3R@lRAl4t&RhV3RBlRCllt'V3RDlRElt(V3RFlRGlt)V3RHlRIlt*]V3RJlRKl4t+]V3RLlRMl4t,RiV3RNlROllt-V3RPlRQlt.]V3RRlRSl4t/V3RTlRUlt0V3RVlRWlt1V3RXlRYlt2V3RZlR[lt3RjV3R\lR]llt4]V3R^lR_l4t5V3R`lRalt6]RkV3RblRcll4t7Rdt8Vt9R##)lBasePlatformAdapteriz Base class for platform adapters. Subclasses implement platform-specific logic for: - Connecting and authenticating - Receiving messages - Sending messages/responses - Handling media c&<V^8dQhRS[RS[/#)rconfigplatform)rr)r rs"r!r" BasePlatformAdapter.__annotate__s33~33r#cWnW nRVnRVnRVnRVnRVnRVn/Vn/Vn \4Vn \4Vn R#)NFT) r r _message_handler_running_fatal_error_code_fatal_error_message_fatal_error_retryable_fatal_error_handler_active_sessions_pending_messagesset_background_tasks_auto_tts_disabled_chats)rr r s&&&r!__init__BasePlatformAdapter.__init__sc  :> 0437!&*#im!;=:<58E-0U%r#c <V^8dQhRS[/#r8r)r rs"r!r"r s555r#cVPRJ#Nrrs&r!has_fatal_error#BasePlatformAdapter.has_fatal_errors((44r#c0<V^8dQhRS[S[,/#r8r)r rs"r!r"r s))Xc])r#cVP#rrrs&r!fatal_error_message'BasePlatformAdapter.fatal_error_messages(((r#c0<V^8dQhRS[S[,/#r8r)r rs"r!r"r s&&(3-&r#cVP#r)rrs&r!fatal_error_code$BasePlatformAdapter.fatal_error_codes%%%r#c <V^8dQhRS[/#r8r)r rs"r!r"r s++t+r#cVP#r)rrs&r!fatal_error_retryable)BasePlatformAdapter.fatal_error_retryables***r#cV<V^8dQhRS[R.S[R,R,3,RR/#)rhandlerrNr)rr)r rs"r!r"r s7,,x9N8OQZ[_Q`cgQg8g/h,mq,r#cWnR#r)rrr.s&&r!set_fatal_error_handler+BasePlatformAdapter.set_fatal_error_handlers$+!r#c<V^8dQhRR/#rrNr@)r rs"r!r"r s   r#cRVnRVnRVnRVn^RIHpV!VP PRRRR7R# \dR#i;i)TNwrite_runtime_status connectedr platform_state error_code error_message rrrrgateway.statusr7r valuer*rr7s& r!_mark_connected#BasePlatformAdapter._mark_connectedsU !%$(!&*#  ; $--*=*=kfjz~    s&A AAc<V^8dQhRR/#r4r@)r rs"r!r"r sDr#cRVnVP'dR#^RIHpV!VPP RRRR7R# \ dR#i;i)FNr6 disconnectedr9)rrr>r7r r?r*r@s& r!_mark_disconnected&BasePlatformAdapter._mark_disconnectedsS       ; $--*=*=nim~B C   s&A AAc0<V^8dQhRS[RS[RS[RR/#)rcodemessagerrNrr)r rs"r!r"r s)S3dtr#cRVnWnW nW0n^RIHpV!VP PRVVR7R# \dR#i;i)Fr6fatalr9Nr=)rrIrJrr7s&&&$ r!_set_fatal_error$BasePlatformAdapter._set_fatal_errorsU !%$+!&/#  ; ,,&%      s&A AAc<V^8dQhRR/#r4r@)r rs"r!r"r !s4r#c"VPpV'gR#V!V4p\P!V4'd VGRjxL R#R#L5ir)rrg iscoroutine)rr.results& r!_notify_fatal_error'BasePlatformAdapter._notify_fatal_error!s?++    v & &LL ' s:A A A  A c <V^8dQhRS[/#r8r)r rs"r!r"r *s++c+r#c JVPPP4#)z%Human-readable name for this adapter.)r r?titlers&r!rBasePlatformAdapter.name)s}}""((**r#c <V^8dQhRS[/#r8r)r rs"r!r"r /sdr#c VP#)z(Check if adapter is currently connected.)rrs&r! is_connected BasePlatformAdapter.is_connected.s}}r#c$<V^8dQhRS[RR/#)rr.rN)MessageHandler)r rs"r!r"r 3s((>(d(r#c WnR#)z| Set the handler for incoming messages. The handler receives a MessageEvent and should return an optional response string. N)rr0s&&r!set_message_handler'BasePlatformAdapter.set_message_handler3s !(r#c$<V^8dQhRS[RR/#)r session_storerN)r )r rs"r!r"r <s,,s,t,r#c WnR#)z 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)rrds&&r!set_session_store%BasePlatformAdapter.set_session_store<s ,r#c <V^8dQhRS[/#r8r)r rs"r!r"r Gs  t r#c "R#5i)zc Connect to the platform and start receiving messages. Returns True if connection was successful. Nr@rs&r!connectBasePlatformAdapter.connectF  c<V^8dQhRR/#r4r@)r rs"r!r"r Ps  $ r#c "R#5i)zDisconnect from the platform.Nr@rs&r! disconnectBasePlatformAdapter.disconnectOs  rnNc n<V^8dQhRS[RS[RS[S[,RS[S[S[S[3,,RS[/#)rchat_idrpreply_tometadatarrr r r r)r rs"r!r"r UsN    3-  4S>*    r#c "R#5i)a 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@)rrtrprurvs&&&&&r!sendBasePlatformAdapter.sendTs ( rnc2<V^8dQhRS[RS[RS[RS[/#)rrtrrprrr)r rs"r!r"r js9 @ @ @ @ @  @r#c $"\RRR7#5i)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)rr)r)rrtrrps&&&&r! edit_message BasePlatformAdapter.edit_messagejs%??sc$<V^8dQhRS[RR/#rrtrNr)r rs"r!r"r ws    r#c "R#5i)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@)rrtrvs&&&r! send_typingBasePlatformAdapter.send_typingwrmrnc$<V^8dQhRS[RR/#rr)r rs"r!r"r s    r#c "R#5i)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. Nr@rrts&&r! stop_typingBasePlatformAdapter.stop_typings rnc <V^8dQhRS[RS[RS[S[,RS[S[,RS[S[S[S[3,,RS[/#)rrt image_urlcaptionrurvrrw)r rs"r!r"r sdQQQQ# Q 3- Q 4S>* Q Qr#c f"V'dV RV 2MTpVPWVR7GRjxL #L5i)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.  rtrpruNry)rrtrrrurvrs&&&&&& r! send_imageBasePlatformAdapter.send_images4 -4'"YK(YYwxYPPPPs (1/1c <V^8dQhRS[RS[RS[S[,RS[S[,RS[S[S[S[3,,RS[/#)rrt animation_urlrrurvrrw)r rs"r!r"r sdFFFF# F 3- F 4S>* F Fr#c F"VPWW4VR7GRjxL #L5i)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. )rtrrrurvN)r)rrtrrrurvs&&&&&&r!send_animation"BasePlatformAdapter.send_animations4__WW^}E_FF FFs !!c&<V^8dQhRS[RS[/#)rrrrK)r rs"r!r"r s&&s&t&r#c pVP4PR4^,pVPR4#)z=Check if a URL points to an animated GIF (vs a static image).?.gif)rrendswith)rrs& r!_is_animation_url%BasePlatformAdapter._is_animation_urls. !!#&q)~~f%%r#cb<V^8dQhRS[RS[S[S[S[S[3,,S[3,/#rrprrrr )r rs"r!r"r s2---d5c?.CS.H(I-r#c aa .pTpRp\P!W04FzpVP^4pVP^4o\;QJdV3RlR 4F 'gK RM RM!V3RlR 44'gKgVP SV34K| Rp\P!W`4F'pVP^4oVP SR34K) V'dqVUUu0uFwrxVkK uppo V 3Rlp \P !W9V4p\P !WiV4p\P !RR V4P 4pW3#uuppi) av 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\)]+)\)c3<"TF?pSP4PV4;'gVSP49xKA R#5ir)rr).0rFrs& r! 5BasePlatformAdapter.extract_images..sBmkHK399;'',BBsyy{0BBks *A A TFzA]+)["\']?\s*/?>\s*(?:)?r%c<VP^8dVP^4MVP^4pVS9dR#VP^4#)rr%) lastindexgroup)matchrextracted_urlss& r!_remove_if_extracted@BasePlatformAdapter.extract_images.._remove_if_extracteds?(-1(>@G8s- Ec X<V^8dQhRS[RS[RS[S[,RS[S[,RS[/#)rrt audio_pathrrurrr r)r rs"r!r"r LQQQQ# Q 3- Q Qr#c l"RV 2pV'dV RV 2pVPWVR7GRjxL #L5i)z 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: rrNr)rrtrrrukwargsrs&&&&&, r! send_voiceBasePlatformAdapter.send_voices?j\* Yb'DYYwxYPPPP +424c,<V^8dQhRS[RS[RS[/#)rrtrrr|)r rs"r!r"r s. W W W W  Wr#c J"VP!RRVRV/VBGRjxL #L5i)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). rtrNr@)r)rrtrrs&&&,r!play_ttsBasePlatformAdapter.play_ttss)__VWVVvVVVVs #!#c X<V^8dQhRS[RS[RS[S[,RS[S[,RS[/#)rrt video_pathrrurr)r rs"r!r"r sLQQQQ# Q 3- Q Qr#c l"RV 2pV'dV RV 2pVPWVR7GRjxL #L5i)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: rrNr)rrtrrrurrs&&&&&, r! send_videoBasePlatformAdapter.send_videos?j\* Yb'DYYwxYPPPPrc n<V^8dQhRS[RS[RS[S[,RS[S[,RS[S[,RS[/#)rrt file_pathr file_namerurr)r rs"r!r"r s[QQQQ# Q C= Q 3- Q Qr#c l"RV 2pV'dV RV 2pVPWVR7GRjxL #L5i)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: rrNr)rrtrrrrurrs&&&&&&, r! send_document!BasePlatformAdapter.send_documents?YK( Yb'DYYwxYPPPPrc X<V^8dQhRS[RS[RS[S[,RS[S[,RS[/#)rrt image_pathrrurr)r rs"r!r"r +rr#c l"RV 2pV'dV RV 2pVPWVR7GRjxL #L5i)z 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: rrNr)rrtrrrurrs&&&&&, r!send_image_file#BasePlatformAdapter.send_image_file+s?! - Yb'DYYwxYPPPPrcb<V^8dQhRS[RS[S[S[S[S[3,,S[3,/#r)rrr r)r rs"r!r"r @s3''s'uT%T 2B-CS-H'I'r#c \.pTpRV9pVPRR4p\P!R4pVPV4FpVP R4P 4p\ V4^8d7V^,VR ,8Xd"V^,R9dV^R P 4pVPR4PR4pV'gKVPWc34K V'd9VPRV4p\P!RRV4P 4pW3#) a6 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]]r%z[`"']?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+)[`"']?r.z`"'z `"',.;:)}]rrr)) rrcompilerrrr/lstriprstriprr)rpmediar has_voice_tag media_patternrr.s& r! extract_media!BasePlatformAdapter.extract_media?s-7 //"6;  G #++G4E;;v&,,.D4yA~$q'T"X"5$q'V:KAbz'');;v&--m>@G~r#cL<V^8dQhRS[RS[S[S[,S[3,/#rr)r rs"r!r"r js,AASAU49c>-BAr#c aR pRPRV44p\P!RV,R,\P4p.o\P!RV\P 4F2pSP VP4VP434K4 \P!RV4F2pSP VP4VP434K4 RV3Rllp.pVP V4FpV!VP44'dK!VP^4p\PPV4p \PPV 4'gKxVP W34K \4p .p VF0wrW9gK V PV 4V P W34K2 V U U u.uFwrV NK p p p TpV 'dDV FwrVP!VR 4pK \P"!R R V4P%4pW3#uup p i) a 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). |c3B"TFqPR4xK R#5i)r(N)r)res& r!r:BasePlatformAdapter.extract_local_files..~sE3DaHHSMM3Dsz/(?.__annotate__s < <# <$ ._in_code..s; qC||!|| s%(TF)r)r code_spanssfr!_in_code9BasePlatformAdapter.extract_local_files.._in_codes,3; ;33 ;3 ;3; ;; ;r#r%rr) rrrrr.mp4.mov.avi.mkv.webm)joinrr IGNORECASErDOTALLrstartendrosr. expanduserisfileraddrrr)rp_LOCAL_MEDIA_EXTSext_partpath_remrfoundrr0expandedseenuniquerpathsr_exprs& @r!extract_local_files'BasePlatformAdapter.extract_local_filesis" 88E3DEE ** > IF R MM   17BIIFA   qwwy!%%'2 3G\73A   qwwy!%%'2 34 < <%%g.E &&++a.Cww))#.Hww~~h'' c_- /E"MC#" so.# .44VkaV4 # !//#r2$ffY8>>@G~5s+ I c*<V^8dQhRS[RS[RR/#)rrtintervalrN)rfloat)r rs"r!r"r s##X\r#c "VPWR7GRjxL \P!V4GRjxL K;L$L \PdMi;i\ TR4'd0TP T4GRjxL R# \ dR#i;iR# \ TR4'd.TP T4GRjxL i \ dii;ii;i5i)z 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. rvNr)rrgrwCancelledErrorhasattrrr*)rrtrrvs&&&&r! _keep_typing BasePlatformAdapter._keep_typings &&w&BBBmmH---C-%%   t]++**7333 ,wt]++**7333 ,sC%A?AAAAAB!AB!C%1B BB C% BC%BC%!C"5C C  CC" CC"CC""C%c$<V^8dQhRS[RR/#reventrNr)r rs"r!r"r s==|==r#c "R#5i)z.Hook called when background processing begins.Nr@)rrs&&r!on_processing_start'BasePlatformAdapter.on_processing_startrnc*<V^8dQhRS[RS[RR/#)rrrrN)rr)r rs"r!r"r s(@@,@@RV@r#c "R#5i)z1Hook called when background processing completes.Nr@)rrrs&&&r!on_processing_complete*BasePlatformAdapter.on_processing_completer"rnc0<V^8dQhRS[RS[RS[RR/#)r hook_nameargsrrN)rr )r rs"r!r"r s0OOCOOsOW[Or#c "\WR4p\V4'gR#V!V/VBGRjxL R#L \d-p\P RTP Y4Rp?R#Rp?ii;i5i)zARun a lifecycle hook without letting failures break message flow.Nz[%s] %s hook failed: %s)getattrcallabler*loggerwarningr)rr(r)rhookrs&&*, r!_run_processing_hook(BasePlatformAdapter._run_processing_hooks_t-~~  O'' ' ' O NN4dii N N Os7 A1 757A17 A.!A)#A1)A..A1c6<V^8dQhRS[S[,RS[/#rrrr rr)r rs"r!r"r s#HH8C=HTHr#c aV'gR#VP4o\;QJd#V3Rl\4F 'gK R# R#!V3Rl\44#)zGReturn True if the error string looks like a transient network failure.Fc3,<"TF qS9xK R#5irr@)rpatlowereds& r!r:BasePlatformAdapter._is_retryable_error..sG-Fc'>-FsT)rr_RETRYABLE_ERROR_PATTERNSrr8s&@r!_is_retryable_error'BasePlatformAdapter._is_retryable_errorsA++-sG-FGssGsGsG-FGGGr#c6<V^8dQhRS[S[,RS[/#r3r4)r rs"r!r"r s# _ _# _4 _r#c tV'gR#VP4pRV9;'gRV9;'gRV9#)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)rr;s& r!_is_timeout_error%BasePlatformAdapter._is_timeout_errors;++-g%^^')A^^^W^E^^r#cR<V^8dQhRS[RS[RS[S[,RS[RS[RS[RR/#) rrtrprurv max_retries base_delayrr)rr r rr)r rs"r!r"r s^PPPP3- P  P  PP Pr#c "VPVVVVR7GRjxL pVP'dV#VP;'gRpVP;'gVP V4p V 'gVP V4'dV#V 'Edh\ ^V^,4EFp V^V ^, ,,\P!^^4,p \PRVPWW4\P!V 4GRjxL VPVVVVR7GRjxL pVP'd&\PRVPV 4Vu#VP;'gRpVP'dKVP V4'dEKMC \PRVPWX4Rp VPWW4R7GRjxL V#\PR VPV4VPVR VR , 2VVR7GRjxL pVP'g,\PR VPVP4V#ELlELlELRL \d-p \P!RTPT 4Rp ? T#Rp ? ii;iL5i) aH 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. rtrprurvNr%z7[%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:) :Ni Nz"[%s] Fallback send also failed: %s)ryrrrr<rBrmrandomuniformr-r.rrgrwinfor*rv)rrtrprurvrErFrS error_str is_networkr}delaynotice notify_errfallback_results&&&&&&& r!_send_with_retry$BasePlatformAdapter._send_with_retrysv$yy !   >>>MLL&&B %%LL)A)A))L d44Y??M : K!O4"aGaK&89FNN1a>>KK A499gV!M"LL..B (((D,D,DY,O,O%5* SUYU^U^`kwmk))Gh)jjj  LdiiYbc $ CGENCST !*!   &&& LL=tyy/J_J_ `} 4+(k kLL!RTXT]T]_ijj k  sKJKKKK7K KBKJ K;J <K7K K!K;'K#J9J:J>AKK K.K K KJ K !K>KK  Kc$<V^8dQhRS[RR/#rr)r rs"r!r"r ?s#lClC,lC4lCr#c "VP'gR#\VPVPPP RR4VPPP RR4R7pW P 9Ed<VP4pVR9d\PRVPW24VPP'dRVPP/MRpVPV4GRjxL pV'd<VPVPPVVPVR 7GRjxL R#VR 8Xd\PR VPV4VPP'dRVPP/MRpVPV4GRjxL pV'd<VPVPPVVPVR 7GRjxL R#VP"\$P&8XEd@\PRVPV4VP(P V4pV'dVP"\$P&8XdVP*P-VP*4VP.P-VP.4VP0'doVP0'gVP0VnR#VP0VP09d/VP0 RVP0 2P34VnR#WP(V&R#\PRVPV4WP(V&VP V,P54R#\6P8!4VP V&\6P:!VP=W44pVP>PAV4\ETR4'd(TPGTP>PH4R#R#ELVEL \d/p\P!R TPTRR 7Rp?R#Rp?ii;iELEL \d/p\P!RTPTRR 7Rp?R#Rp?ii;i \BdR#i;i5i)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)rVrWzA[%s] Approval command '/%s' bypassing active-session guard for %s thread_idrHz![%s] Approval dispatch failed: %sexc_infostatusz9[%s] Status command bypassing active-session guard for %sz[%s] Status dispatch failed: %sz=[%s] Queuing photo follow-up for session %s without interruptruD[%s] New message while session %s is active — triggering interruptadd_done_callback)approvedeny)%rrrr extrarnrrr-rvrrXrRrtrr*rrrrrrextendrrrrrgEvent create_task_process_message_backgroundrr TypeErrorrr\discard) rr session_keycmd _thread_metartrexistingtasks && r!handle_message"BasePlatformAdapter.handle_message?s$$$ ' LL$(KK$5$5$9$9:SUY$Z%)[[%6%6%:%:;UW\%]  // /##%C)) WIIs cLQLLLbLbLbK1G1G#HhlL%)%:%:5%AAH"33$)LL$8$8$,%*%5%5%1 4 h OII{ aLQLLLbLbLbK1G1G#HhlL%)%:%:5%AAH"33$)LL$8$8$,%*%5%5%1 4 !![%6%66 \^b^g^gitu1155kB 5 59J9J J''..u/?/?@((//0A0ABzzz'}}},1JJHM  #ZZx}}S7A Q' Q! Q'6Q'Q$Q'*S7>R).R)R# R)6R) R& R)A%S76A:S71S7DS7 S%&;S7!Q'$Q'' R 2#RS7R  S7#R)&R)) S"4#SS7S""S7% S40S73S44S7c <V^8dQhRS[/#r8)r)r rs"r!r"r s@@e@r#c <^RIp\P!RR4P4pVR8XdR#\ \P!RR44p\ \P!RR44pVR 8XdR R r2VP !VR , VR , 4#) a3 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) NHERMES_HUMAN_DELAY_MODEoffgHERMES_HUMAN_DELAY_MIN_MS800HERMES_HUMAN_DELAY_MAX_MS2500naturali i g@@)rIrgetenvrrrJ)rImodemin_msmax_mss r!_get_human_delay$BasePlatformAdapter._get_human_delays yy2E:@@B 5=RYY:EBCRYY:FCD 9  $F~~fvov??r#c*<V^8dQhRS[RS[RR/#)rrrfrN)rr)r rs"r!r"r s)F7F7|F7RUF7Z^F7r#c xa)a*"Ro)Ro*V)V*3RlpVPPV4;'g\P!4pW@PV&VPP 'dRVPP /MRp\P !VPVPPVR74pVPRV4GRjxL VPV4GRjxL pV'g6\PRVPVPP4V'EdVPV4wrVPV4wrV P!RR 4P#4p \$P&!R R V 4P#4p V 'd5\P)R VP\+V 4\+V44VP-V 4wrV 'd+\P)R VP\+V 44Rp VP.\0P28XdV 'dV'gVPPVP49d^R IHp HpV!4'd^RIp\$P&!RR V 4R,P#4pV'g \?R4h\P@!V VR7GRjxL pVPCV4pVPR4p V 'dh\IV 4PK4'dIVPMVPPV VR7GRjxL \NPP!V 4V 'd\P)RVP\+V 4VPP4VPUVPPV VPVVR7GRjxL pV!V4VPY4pV 'd+\P)RVP\+V 44V EF7wppV^8d\PZ!V4GRjxL \P)RVP\]V4V'd VR,MR 4VP_V4'd=TPaVPPTV'dTMRVR7GRjxL pM;TPcVPPTV'dTMRVR7GRjxL pVPd'g/\PgRVPVPf4EK7EK: 0R0mp0R1mp0R2mpVEFiwppV^8d\PZ!V4GRjxL \IV4PhPk4pVV9d2VPmVPPVVR7GRjxL p MVV9d2VPoVPPVVR 7GRjxL p MhVV9d2VPqVPPVVR!7GRjxL p M0VPsVPPVVR"7GRjxL p V Pd'g0\PGR#VPVV Pf4EKiEKl V Fp"V^8d\PZ!V4GRjxL \IV"4PhPk4pVV9d3VPqVPPV"VR!7GRjxL KVV9d3VPoVPPV"VR 7GRjxL KVPsVPPV"VR"7GRjxL K S)'dS*M\uV4'*p$VPR&VV$4GRjxL W Pv9Ed VPvPyV4p%\PR'VP4W P9dVPVVP{4VGRjxL VPV%V4GRjxL VP{4VGRjxL \VR(4'd.VPVPP4GRjxL Y P9dTPTR#R#TP{4TGRjxL \TR(4'd.TPTPP4GRjxL Y P9dTPTR#R#ELELEL \Dd-p\PGRTPT4Rp?ELRp?ii;iEL \RdELi;i \NPP!T 4i \Rdii;i;iELOELELNEL \Dd0p\PgRTPTRR7Rp?EK?Rp?ii;iELEL~ELIELEL \Dd.p!\PGR$TPT!4Rp!?!EK?Rp!?!ii;iELEL\EL&EL \Dd/p#\PgR%TPT"T#4Rp#?#EKRp#?#ii;iELEL| \P|dELi;iELELh \P|dEL~i;iELG \DdELSi;i \P|dTPR&TR4GRjxL h\DEd p&TPR&TR4GRjxL \PgR)TPT&RR7\T&4Pp'\T&4'd\T&4R*,MR+p(TPP 'dRTPP /MRpTPTPPR,T' R-T( R.2TR/7GRjxL Rp&?&EL` \Dd Rp&?&ELri;iRp&?&ii;iELh \P|dEL~i;iELG \DdELSi;i TP{4TGRjxL M \P|dMi;i\TR(4'd/TPTPP4GRjxL M \DdMi;iY P9dTPTii;i5i)3z4Background task that actually processes the message.FcF<VfR#Ro\VRR4'dRoR#R#)NTrF)r+)rSdelivery_attempteddelivery_succeededs&r!_record_deliveryIBasePlatformAdapter._process_message_background.._record_deliverys+~!% vy%00%)"1r#rXNrr z0[%s] Handler returned empty/None response for %srr%z 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 response)text_to_speech_toolcheck_tts_requirementsz [*_`#\[\]()]:NiNz!Empty text after markdown cleanup)rrz[%s] Auto-TTS failed: %s)rtrrvz&[%s] Sending response (%d chars) to %srHz1[%s] Extracted %d image(s) to send as attachmentsz[%s] Sending image: %s (alt=%s):NN)rtrrrv)rtrrrvz[%s] Failed to send image: %sz[%s] Error sending image: %sTrY)rtrrv)rtrrv)rtrrvz"[%s] Failed to send media (%s): %sz[%s] Error sending media: %sz$[%s] Error sending local file %s: %sr%z-[%s] Processing queued message from interruptrz[%s] Error handling message: %s:Ni,Nzno details availablezSorry, I encountered an error (z). z2 Try again or use /reset to start a fresh session.)rtrprv>.m4a.mp3.ogg.wav.opus>.3gprrrrr>rrrrr)FrrnrgrarrXrbrrtr0rr-rvrrrrrrrrKr/rrrrrtools.tts_toolrrjsonr to_threadloadsr*r.r existsrrremoverrRrrzrwr5rrrrrsuffixrrrrrrrpopcancelrrcrrtyperkrry)+rrrfrinterrupt_event_thread_metadata typing_taskrt media_filesr text_content local_files _tts_pathrr_json speech_texttts_result_strtts_datatts_errrS human_delayrr img_resultimg_err _AUDIO_EXTS _VIDEO_EXTS _IMAGE_EXTS media_pathis_voicerF media_result media_errrfile_err processing_ok pending_eventr error_type error_detailrrs+&&& @@r!rc/BasePlatformAdapter._process_message_backgrounds #" *//33K@SSGMMO-<k*EJLLDZDZDZK)?)?@`d))$*;*;ELL'BH(0 [(AI i!7!7!9!9 !"mm$)LL$8$8'0%5, !IIi0  KK H$))UXYeUfhmhthth|h|}#'#8#8 % 4 4 ,!&!1!1!1 $9$F %V,#335 KK SUYU^U^`cdj`kl+1'Ix"Q%mmK888h = II-i8-5HSM2  11)<H O H ,7(J"Q%mmK888]":.55;;=+-15(- (<(<+5)92A2,L !K/15(- (<(<+5)92A2,L !K/151E1E(- (<(<+5)92F2,L 261C1C(- (<(<*4)92D2,L ,333"NN+OQUQZQZ\_amasast 4=-8H"-I"Q%mmK888m"9o44::<+-"&"6"6(- (<(<+4)9#7# !K/"&//(- (<(<+4)9#2# #'"4"4(- (<(<*3)9#5#%"-63E.dS[nJ\M++,De][ [ [444 $ 6 6 : :; G  LdiiX"7"77--k:""$%%%66}kRRR4     !!!  4//**5<<+?+?@@@333))+64i5N     !!!  4//**5<<+?+?@@@333))+64Y J:P. %W'A499gVVW  '! !!IIi0&! !  9**%h %CTYYPWbf ggh9, , , ,%]'EtyyR[\\] 9   %m %KTYYXackllm \&--S:"))   A  E%% ++,DeUS S S  ++,DeUS S S LL:DIIqSWL X !!W-- /21vvs1vd|;Q LQLLLbLbLbK1G1G#Hhl ii!LL009*T'.)LL.   # ."))   A       !!!))   4//**5<<+?+?@@@  333))+64sCv:ngn6g7 n=nDnn%ng8g&g9g:&g n(n+h.3h4h.9hnA5n i #n1Anin Ai'(i' i'i!-i' i'i$i'&+i'=nj$nAj3)j'*7j3!j*"7j3j-0j3 j0 j3!,j3 -n:k.;nAk:k1k:n2k:k4k:n+k:k7k: n(n9l6:A=n8l<=l9>l<nmnv:.m3m4m9:m=3m:4m=8!v:t v:+s0s1s6:s:0s71s:5!v:nng h*!h nhnh. h+'n*h++n.i0ii iiiinn!i'$i'' j!2#jnj!!n'j3*j3-j30j33 k+>!k&n&k++n1k:4k:7k:: l3"l.'n.l33n9l<<mnmnmm73v:6m77v::m== n v: n  v:+s:n=;s s s"o%#(s Ar:"A r:.r1/r:4t : s st s  sst ss40v:3s44v:7s:: t v:t  v: v7t*#t&$t*)v7*u?v7uv7:vvvv7 vv7v"v77v:c<V^8dQhRR/#r4r@)r rs"r!r"r s & &t &r#c "VPUu.uFqP4'dKVNK ppVFpVP4K V'd\P!VRR/GRjxL VPP 4VP P 4VPP 4R#uupiLY5i)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. return_exceptionsTN)rdonerrggatherclearrr)rrjtaskss& r!cancel_background_tasks+BasePlatformAdapter.cancel_background_taskss #'"8"8L"8$ "8LD KKM ..%@4@ @ @ $$& $$& ##%M As'C CC"C C /C 0AC c&<V^8dQhRS[RS[/#rrfrrK)r rs"r!r"r sddddr#c pWP9;'d"VPV,P4#)z3Check if there's a pending interrupt for a session.)ris_setrrfs&&r!has_pending_interrupt)BasePlatformAdapter.has_pending_interrupts-333cc8M8Mk8Z8a8a8ccr#c6<V^8dQhRS[RS[S[,/#r)rr r)r rs"r!r"r s ==s=x 7M=r#c :VPPVR4#)z0Get and clear any pending message for a session.N)rrrs&&r!get_pending_message'BasePlatformAdapter.get_pending_messages%%))+t< r#c "R#5i)zw Get information about a chat/channel. Returns dict with at least: - name: Chat name - type: "dm", "group", "channel" Nr@rs&&r! get_chat_info!BasePlatformAdapter.get_chat_infos  rnc&<V^8dQhRS[RS[/#rr)r rs"r!r"r  s  c c r#c V#)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@)rrps&&r!format_message"BasePlatformAdapter.format_message s r#c<<V^8dQhRS[RS[RS[S[,/#)rrp max_lengthr)rrr )r rs"r!r"r s+mm#m3m$s)mr#c  \V4V8:dV.#^ pRp.pTpRpV'EdfVeRV R2MRpW, \V4, \V4, pV^8d V^,p\V4\V4,W, 8:dVPWu,4EMVRVp V PR4p W^,8dV PR4p V ^8dTp VRV p V PR4V PR4, p V ^,^8XdV PR4p V ^8d*W^, ,R 8XdV PR^V 4p K0V ^8dAV PR^V 4pV PR^V 4p\ W4pW^,8dTp VRV pWZRP 4pVV,pVRJpT;'gRpVP R4FtpVP4pVPR4'gK,V'dR pRpK:R pVR ,P4pV'dVP 4^,MRpKv V'd VV, pTpMRpVPV4EKn\V4^8d;\V4p\V4UUu.uFwppV R V^, RV R2NK pppV#uuppi)a 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) Returns: List of message chunks z ```Nz```rr% `z\`\FT:NNz (r')) r/rrfindcountmaxrrrr enumerate)rprINDICATOR_RESERVE FENCE_CLOSEchunks remaining carry_langprefixheadroomregionsplit_at candidatebacktick_countlast_bt safe_splitnl_split chunk_body full_chunkin_codelanglinestrippedtagtotalichunks&& r!truncate_message$BasePlatformAdapter.truncate_messages" w<: %9   %) i.8-Cs:,b)F"5F Cc+FVVH!|%?6{S^+z/MM f01y)F||D)Ha-'!<<,!|#")8,I&__S1IOOE4JJN!Q&#//#.ki! &<&D'ooc1g>GQ;!*a!AJ(tQ@H!$Z!:J!M1#-"9H-J!),335I*,J!,G##D"((.::<&&u--"'!"&&rl00214syy{1~"/k) ! ! MM* % v;?KE=Fv=N=NE5'AE7!E7!,=N  s5K) rrrrrrrrrrrfr r )NNr)NNN)@N)NNrr)NdmNNNNNN)i):rkrrrrrpropertyrr#r'r+r1rArFrNrTrr\rargrrkrqryr~rrrr staticmethodrrrrrrrrrrr r%r0r<rBrRrkrzrcrrrrrrrrrrs@r!rrs33*55))&&++,,   ++((,,       * @ @    QQ&FF"&& --^QQ( W WQQ&QQ(QQ(''RAAF8==@@OOHH _ _PPdlClC\@@(F7F7P & &dd==  :    mmmr#r)P)r)rr))r)rr) connecterrorconnectionerrorconnectionresetconnectionrefusedconnecttimeoutnetworkz broken piperemotedisconnectedeoferror)GrrgrirrIrrNabcrr urllib.parserrjrkr- dataclassesrrrpathlibr typingr r r r rrrenumrsys_Pathr.insertr__file__rr<gateway.configrrgateway.sessionrrhermes_cli.configrhermes_constantsr*GATEWAY_SECRET_CAPTURE_UNSUPPORTED_MESSAGEr5r>rArVrrrrrrrSUPPORTED_DOCUMENT_TYPESrrrrrrr:r_rr@r#r!rs #!   8 $(HHH !3uX..088;<=3<-+b+ "&^!? $2j8! > $2x$$57GH  ? L  V P X @* $  4242 42n   <.)HSM*BBCy#yr#