`gj] ,dZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ejeZej"dZej"dZej"dZej"d Zej"d Zej"d ZeZehd Zej"d Zej"dej8Zej"dZddiZhdZ hdZ!hdZ"ddhZ#ddhZ$e e!zhdzZ%dZ&dZ'dZ(ej"dej8Z)ej"dej8Z*de+fd Z,d!e+de-fd"Z.d#e+d$e+de+fd%Z/d&e0d'e1de2dzfd(Z3d)d*d+e1fd,Z4d-d.d/d0gd1d2d3d0d4d5d0d6d5d0d7d5d0d8d5d9gd:d;Z5d<Z6d=Z7dWd?Z8d@Z9d#e+dAe+fdBZ:dCZ;dDZdGdHZ>dXdIZ?dJe0de@fdKZAdYdLZBdZdMZCdZdNZDd[dOZEdPZFdZdQZGdRZHdSZIdTZJdZdUZKddVlLmMZMy)\a$Send Message Tool -- cross-channel messaging via platform APIs. Sends a message to a user or channel on any connected messaging platform (Telegram, Discord, Slack). Supports listing available targets and resolving human-friendly channel names to IDs. Works in both CLI and gateway contexts. N) formatdate)redact_sensitive_text) get_secretz^\s*(-?\d+)(?::(\d+))?\s*$zD^\s*((?:oc|ou|on|chat|open)_[-A-Za-z0-9]+)(?::([-A-Za-z0-9_]+))?\s*$z^\s*([CGDU][A-Z0-9]{8,})\s*$z%^\s*([CGD][A-Z0-9]{8,}):([^\s:]+)\s*$zS^\s*((?:wxid|gh|v\d+|wm|wb)_[A-Za-z0-9_-]+|[A-Za-z0-9._-]+@chatroom|filehelper)\s*$z ^\s*((?:group|direct):[^:]+)\s*$>smsphotonsignalwhatsappz^\s*\+(\d{7,15})\s*$zB^\s*[\w-]+@(?:g\.us|s\.whatsapp\.net|lid|broadcast|newsletter)\s*$z6^\s*[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Za-z]{2,}\s*$emailEMAIL_HOME_ADDRESS>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4>.wav.flac.m4a.mp3.ogg.opusrrrr>.md.csv.doc.pdf.txt.zip.docx.xlsxic|xsdj}|xsg}|rt|dk7rd|fS|d\}}|rd|fStjj |dj }|t vrd|fSt||kDrd|fS|dfS)uxDecide whether the accompanying text should ride on the media bubble. Single enforced chokepoint for the ``MEDIA: caption`` behavior across every standalone sender. ``hermes send`` (and the send_message tool / cron) strips the ``MEDIA:`` tag and leaves the remaining prose as ``text``; historically each platform sent that ``text`` as a *separate* message before an uncaptioned media bubble, splitting the reported case ``hermes send --to whatsapp "MEDIA:/x.png This Caption"`` into two parts. Returns ``(caption, body_text)``: * ``(caption, "")`` — attach ``text`` to the media as its native caption and send *no* separate body message. Only when there is exactly one media file, it is a captionable kind (image/video/document, not a voice/audio note), and ``text`` fits ``max_caption_len``. * ``(None, text)`` — keep the historical behavior: ``text`` is a separate body message and the media carries no caption. Applies to multi-file sends (caption→file association is ambiguous), voice/audio notes, empty text, or text longer than the caption limit. Nr)striplenospathsplitextlower_CAPTIONABLE_EXTS)text media_filesmax_caption_lenstrippedmedia media_pathis_voiceexts J/root/.hermes/venv/lib/python3.12/site-packages/tools/send_message_tool.py_media_caption_splitr8Vs* !!#H  2E s5zQTz 8JTz ''  : &q ) / / 1C ##Tz  8}&Tz R<zP([?&](?:access_token|api[_-]?key|auth[_-]?token|token|signature|sig)=)([^&#\s]+)zJ\b(access_token|api[_-]?key|auth[_-]?token|signature|sig)\s*=\s*([^\s,;]+)returncxt|}tjd|}tjd|}|S)zCRedact secrets from error text before surfacing it to users/models.c*|jddS)Nr'z***groupms r7z&_sanitize_error_text..sQWWQZL2Dr9c*|jddS)Nr'z=***r=r?s r7rAz&_sanitize_error_text..s!''!*T7Jr9)r_URL_SECRET_QUERY_REsub_GENERIC_SECRET_ASSIGN_RE)r/redacteds r7_sanitize_error_textrGs7$T*H#''(DhOH(,,-JHUH Or9messagecdt|iS)z9Build a standardized error payload with redacted content.error)rG)rHs r7_errorrKs )'2 33r9 platform_namechat_idcF|dk(rt|jdry|S)zHReturn a result-safe chat identifier for tool transcripts/log consumers.rgroup:z group:***)str startswith)rLrMs r7_display_chat_idrRs# S\%<%> Ddi4/ D= $ & D= D ( D=  $ D=Q'\"" #:&  sA77B B )attemptsrdc HKt|D]} |jdi|d{cSy7#t$rd}t||}|||dz k\rtj d|dz||t |tj|d{7Yd}~d}~wwxYww)Nr'zFTransient Telegram send failure (attempt %d/%d), retrying in %.1fs: %s) range send_message ExceptionrbloggerwarningrGasynciosleep)botrdkwargsrTrSdelays r7!_send_telegram_message_with_retryrqs?' ')))3F33 3'3 ')#w7E}8a< 7 NNX! $S)  --& & & 'sCB"202B"2 BABBBB"BB"rhaSend a message to a connected messaging platform, or list available targets. IMPORTANT: When the user asks to send to a specific channel or person (not just a bare platform name), call send_message(action='list') FIRST to see available targets, then send to the correct one. If the user just says a platform name like 'send to telegram', send directly to the home channel without listing first.objectstring)sendlistreactunreactaAction to perform. 'send' (default) sends a message. 'list' returns all available channels/contacts across connected platforms. 'react' attaches an emoji reaction to a message (platforms that support it, e.g. photon/iMessage tapbacks). 'unreact' retracts a previously-added reaction.)typeenum descriptionaDelivery target. Format: 'platform' (uses home channel), 'platform:#channel-name', 'platform:chat_id', or 'platform:chat_id:thread_id' for Telegram topics and Discord threads. Examples: 'telegram', 'telegram:-1001234567890:17585', 'discord:999888777:555444333', 'discord:#bot-home', 'slack:#engineering', 'signal:+155****4567', 'matrix:!roomid:server.org', 'matrix:@user:server.org', 'ntfy:alerts-channel' (explicit ntfy topic), 'yuanbao:direct:' (DM), 'yuanbao:group:' (group chat))rxrzuThe message text to send. To send an image or file, include MEDIA: (e.g. 'MEDIA:/tmp/report.pdf') in the message — the platform will deliver it as a native media attachment.uFor action='react': the emoji to react with (e.g. '❤️'). On iMessage, ❤️👍👎😂‼️❓ render as native tapbacks; other emoji use custom-emoji reactions.zFor action='react'/'unreact': id of the message to react to. Omit to target the most recent message received in that chat (usually the one being replied to).)actiontargetrHemoji message_id)rx propertiesrequired)namerz parametersc |jdd}|dk(r tS|dk(r t|S|dk(r t|dSt|S)z-Handle cross-channel send_message tool calls.r{rtrurvrwT)remove)get _handle_list _handle_react _handle_send)argskwr{s r7send_message_toolrsU XXh 'F ~ T"" T$//  r9c ddlm}tjd|iS#t$r+}tjt d|cYd}~Sd}~wwxYw)z5Return formatted list of available messaging targets.r)format_directory_for_displaytargetsz"Failed to load channel directory: N)gateway.channel_directoryrjsondumpsrirK)res r7rrsQLJzz9&B&DEFF Lzz&#EaS!IJKKLs!$ A A AAFcb|jdd}|jdxsdj}|jdxsdjxsd}|r|s|st|sdSdS|jdd }|d jj }t |d kDr|d jnd}d}|r(t ||\}} } |s d d lm} | ||} | xs|} d d l m } m }| |}|s9 |}|j|}|std|d|dS|j }d} d dlm}|}||j&j|nd}|td|dS|rdnd}t)||d}t+|std|dS d dlm}|r||||}n|||||}t7|t8rt1j2|St1j2dt;|iS#t$rd} Y=wxYw#ttf$rtd |cYSwxYw#t$rd}Y@wxYw#t$rd}Y"wxYw#t$r+}t1j2t5d|cYd}~Sd}~wwxYw)uAttach (or with ``remove=True`` retract) an emoji reaction on a message via a live gateway adapter. Only adapters that expose ``add_reaction(chat_id, emoji, message_id)`` / ``remove_reaction(chat_id, message_id)`` coroutines support this (e.g. photon/iMessage tapbacks). Requires the gateway to be running in this process — there is no standalone fallback, since reacting needs the adapter's live message-id state. r|r&r}r~Nz:Both 'target' and 'emoji' are required when action='react'z*'target' is required when action='unreact':r'rresolve_channel_name)Platformload_gateway_configUnknown platform: z.No chat specified and no home channel set for z. Use 'z :chat_id'._gateway_runner_refzReactions require a live zN adapter in the running gateway (not available from cron/standalone contexts).remove_reaction add_reaction Platform 'z%' does not support message reactions. _run_async)rMr~)rMr}r~zReaction failed: success)rr( tool_errorsplitr-r)_parse_target_refrrrigateway.configrrraKeyErrorget_home_channelrM gateway.runradaptersr]callable model_toolsrrrrK isinstancedictbool)rrr|r}r~partsrL target_refrM _thread_id_rresolvedrrplatformconfighomerunnerradapterfn_namereact_fnrresultrs r7rrsXXh #F XXg  $" + + -E((<(.B557?4J & I  >  LLa E!HNN$**,M%(Z!^q!JG!2=*!MQ J/ zJ ,*G@@M*  (*F**84D@P%j2 ,, F3$&06/Afoo!!(+tG' 7E E  $*~Gw.H H 'L M   ;* Z@F *MF &$zz&!! ::y$v,/ 00w    !@.}o>??@ D  2 ;zzQC!89::;sf#H!9H3 I I(2*I:! H0/H03II I%$I%( I76I7: J. J)#J.)J.c  )|jdd}|jdd}|r|s tdS|jdd}|djj }t |dkDr|djnd}d}d}|rt ||\}}}nd }|rD|sB dd lm} | ||} | rt || \}}} ntjd d |d |diS ddl m } | r tdS ddlm} m}| } ||}|j(j|}|r |j*s|dk(rt-ddj}t-ddj}|rH|rFddlm}|d||t-ddjt-ddjd}ntd|dStd|dSdd lm}d!|v}|j5|\}}|j7|}|jxs t9|}d }|s|j;|}|s<|dk(r7t=j>d"dj}|rdd#lm }|||d$%}|r|jB}d}nHtDj||jGd&}tjd d'|d(|d)|d*iStI|||} | rtj| S|d+k(r]|r[|jKd,rJ ddl&))fd-}!dd.l'm(}"|"|!|jR|}#|#r|#}ntjd d/|d0iS dd.l'm(}"|"tU|||||||2}$|r-tW|$tXr|$jd3r d4|d5|d6|$d7<tW|$tXrI|$jd3r8|r6 dd8l-m.}%dd9l/m0}&|&d:d;}'|&d<tW|$tXrd |$vrtc|$d |$d <tj|$S#t$r!tjd d |d |dicYSwxYw#t$r+}tjt#d|cYd}~Sd}~wwxYw#t$t&f$rtd|cYSwxYw#t$r$}tjd d1|icYd}~Sd}~wwxYw#t$rYwxYw#t$r+}tjt#d?|cYd}~Sd}~wwxYw)@z$Send a message to a platform target.r|r&rHz;Both 'target' and 'message' are required when action='send'rr'rNFrrJzCould not resolve 'z' on z;. Use send_message(action='list') to see available targets.z). Try using a numeric channel ID instead.)is_interrupted Interrupted)rrzFailed to load gateway config: rweixin WEIXIN_TOKENWEIXIN_ACCOUNT_IDPlatformConfigTWEIXIN_BASE_URLWEIXIN_CDN_BASE_URL) account_idbase_url cdn_base_url)enabledtokenextrarzZ' is not configured. Set up credentials in ~/.hermes/config.yaml or environment variables.)BasePlatformAdapterz[[as_document]]WEIXIN_HOME_CHANNEL) HomeChannelz Weixin Home)rrMr _HOME_CHANNELzNo home channel set for zQ to determine where to send the message. Either specify a channel directly with 'z=:CHANNEL_NAME', or set a home channel via: hermes config set z slackUc4Kd}d|dd}jjd4d{}|j||d|gi 4d{}|jd{}|j d r*|d d cdddd{cdddd{S dddd{dddd{y77{7e7>7/77#1d{7swYnxYwdddd{7y#1d{7swYyxYww) Nz(https://slack.com/api/conversations.openzBearer application/json Authorizationz Content-Type )totalrWusers)headersrokchannelid) ClientSession ClientTimeoutpostrr)ruser_idurlrsessionrespdataaiohttps r7_open_slack_dmz$_handle_send.._open_slack_dms @.5eW,=Oab"009N9NUW9N9X0Y$$]d&||CRYQZG[|\$$`d%)YY[088D>#' ?4#8$$$$$$ $ $$$$$$0$$$$$$$$$$$$s1DCDDCDC,C-C DCD D&C'D,C- D8C9D= DC DDCDDDDC. "C%#C. *D1 D<C?=DD D DDrz"Could not open DM with Slack user z#. Check bot permissions (im:write).zFailed to open Slack DM:  thread_idr0force_documentrzSent to z home channel (chat_id: )note)mirror_to_sessionget_session_envHERMES_SESSION_PLATFORMcliHERMES_SESSION_USER_ID) source_labelrrmirroredz Send failed: )2rrrr(r-r)rrrrrritools.interruptrrrrrKrar platformsrrrgateway.platforms.baser extract_mediafilter_media_delivery_paths_describe_media_for_mirrorrr*getenvrrM_HOME_CHANNEL_ENV_OVERRIDESupper_maybe_skip_cron_duplicate_sendrQrrrr_send_to_platformrrgateway.mirrorrgateway.session_contextrrG)*rr|rHrrLrrMr is_explicitrrrrrrrrrpconfigwx_token wx_accountrrforce_document_attachmentsr0cleaned_message mirror_textused_home_channelrwx_homerhome_envduplicate_skiprr dm_channelrrrrrrs* @r7rrcs XXh #Fhhy"%G WXX LLa E!HNN$**,M%(Z!^q!JGI*;M:*V'K +  F+M:FH(9-(R%Azz2:,eM?SPQ#%&/-((I@$& @M*""8,G '// H $!."5;;=H#$7<BBDJJ9( "&0$./@"$E$K$K$M(23H"(M(S(S(U"J}o>X#YZZ =/:TUV V: "3g!=#6#D#DW#M K%AA+NK!'')T-G -TK &&x0 1ii 5r:@@BG6"HgMZ llG $ 266-"5"5"7!8 FH::3M?C;;H/J@@HzX  5]GYWNzz.))G0B0B30G J  $ /#N7=='$JKJ$zz7.PQXPYY|,}"~ '7* #'9    FD!9fjj>S' 6NwiWXYF6N fd # 9(=+ <C./H%P )*BBGO4$!!-'# *.F:& fd #6(926'?CF7Ozz&!!] ::.zl% O:;   Izz&#B1#!FGHHI  !@.}o>??@d J::w*CA3(GHI I JF   7zz&=!45667s)?QQ1R(AS $A0T 5S; 9T 'Q.-Q.1 R%: R R% R%(SS S8S3-S83S8; TT TT T> T93T>9T>rc|dk(rOtj|}|r#|jd|jddfSddlm}||}|r|ddfS|dk(r:t j|}|r#|jd|jddfS|d k(r:t j|}|r#|jd|jddfS|d k(rntj|}|r#|jd|jddfStj|}|r|jd}|dd v}|d|fS|d k(r4|j}|jd }|dkDr|d|||dzddfS|dk(r+tj|}|r|jdddfS|dk(r`tj|}|r|jdddfS|jjrd|jddfSy|dk(r|j} | r| ddfS|dk(r*tj|}|r|jddfS|dk(r(tj|r|jddfS|j} |dk(r8| j!dr'| t#ddj} | rd| ddfSy|t$vr*t&j|}|r|jddfS|j)djr|ddfS|d k(r'|j!ds|j!dr|ddfS|dk(r d|vr|ddfSy)zFParse a tool target into chat_id/thread_id and whether it is explicit.telegramr'r\Tr)parse_telegram_username_targetNfeishudiscordr>rWmatrixz:$ryuanbaorONNFntfyr r r-!@xmpp)_TELEGRAM_TOPIC_TARGET_RE fullmatchr>'plugins.platforms.telegram.telegram_idsr_FEISHU_TARGET_RE_NUMERIC_TOPIC_RE_SLACK_THREAD_TARGET_RE_SLACK_TARGET_REr(rfind_WEIXIN_TARGET_RE_YUANBAO_TARGET_REisdigit_EMAIL_TARGET_RE_WHATSAPP_JID_RErQr)_PHONE_PLATFORMS_E164_TARGET_RElstrip) rLrmatchrusernamerMrtrimmed split_idxtopicstripped_targetgroup_ids r7rrs ")33J? ;;q>5;;q>47 7 2*= T4' ' !++J7 ;;q>5;;q>47 7 !!++J7 ;;q>5;;q>47 7'11*= ;;q>5;;q>47 7 **:6 kk!nG "!*J6KD+- - ""$MM$' q=:I& A (@$F F !++J7 ;;q>4- - !",,Z8 ;;q>4- -     % % 'J,,./0$< <   " $$ $ **:6 ##%tT1 1 "  % %j 1##%tT1 1 &&(O _%?%?%I"3x=>288: H:&d2 2 (())*5 ##%tT1 1%%'4%% j&;&;C&@JDYDYZ]D^4%%3*#44%% r9c|syt|dk(r_|d\}}tjj|dj }|r |t vry|t vry|tvry|tvryyd t|d S) zJReturn a human-readable mirror summary when a message only contains media.r&r'rz[Sent voice message]z[Sent image attachment]z[Sent video attachment]z[Sent audio attachment]z[Sent document attachment]z[Sent z media attachments]) r)r*r+r,r- _VOICE_EXTS _IMAGE_EXTS _VIDEO_EXTS _AUDIO_EXTS)r0r4r5r6s r7rrls  ;1*1~ Hggz*1-335 {*) + , + , + ,+ C $%%8 99r9cddlm}|ddjj}|ddj}|r|sy|ddjxsd}|||dS) zMReturn the cron scheduler's auto-delivery target for the current run, if any.rr!HERMES_CRON_AUTO_DELIVER_PLATFORMr& HERMES_CRON_AUTO_DELIVER_CHAT_IDN"HERMES_CRON_AUTO_DELIVER_THREAD_ID)rrMr)rrr(r-)rrrMrs r7_get_cron_auto_delivery_targetr<sq7BBGMMOUUWH@"EKKMG 7 DbIOOQYUYI r9rct}|sy|d|k(xr0t|dt|k(xr|jd|k(}|sy|d|}||d|z }ddd|d|d d S) zRSkip redundant cron send_message calls when the scheduler will auto-deliver there.NrrMrrT#cron_auto_delivery_duplicate_targetzSkipped send_message to z. This cron job will already auto-deliver its final response to that same target. Put the intended user-facing content in your final response instead, or use a different target if you want an additional message.)rskippedreasonr|r)r<rPr)rLrMr auto_target same_target target_labels r7rrs02K  J=0 6  I& '3w< 7 6 OOK (I 5 #_AgY/L!I;' 7&|n5h h  r9rcKt|dr |jn t|}d} ddlm} | }| |j j|} | b i} |r|| d<|dk(r|r|| d<| sd} | j||| d{} | jrd | jd Sd d | jiSd} ddlm}|j|}|}|j q |j!||||||d{} t'| t(r$| jds| jd r| Sd d|dt+| j,iSd d|diS#t $rd}Y1wxYw#t $rd} Y%wxYw7#tj$rt $r} d d | icYd} ~ Sd} ~ wwxYw#t $rd}YwxYw7#tj$rt $r)} t"j%d|d d d| icYd} ~ Sd} ~ wwxYww)aSend a message via a live gateway adapter, with a standalone fallback for out-of-process callers (e.g. cron running separately from the gateway). Order of attempts: 1. Live in-process adapter via ``_gateway_runner_ref()`` (the path that existed before this change). 2. The plugin's ``standalone_sender_fn`` registered on its ``PlatformEntry`` (used when the gateway is not in this process, so the runner weakref is ``None``). 3. A descriptive error explaining both options. valueNrrrr publish_topic)rMcontentmetadatarJzPlugin platform send failed: T)rr~zAdapter send failed: platform_registryrz$Plugin standalone send for %s raisedexc_infozPlugin standalone send failed: rzPlugin standalone send for 'zR' returned an invalid result: expected a dict with 'success' or 'error' keys, got zNo live adapter for platform 'z'. Is the gateway running with this platform connected? For out-of-process delivery (e.g. cron in a separate process), the platform plugin must register a standalone_sender_fn on its PlatformEntry.)hasattrrErPrrrirrrtrlCancelledErrorrr~rJgateway.platform_registryrJstandalone_sender_fnrjdebugrrrx__name__)rrrMchunkrr0rrLrrrrHrrentryrJs r7_send_via_adapterrUs*'.h&@HNNc(mM F3$& oo))(3G   F,5H[) F*w07H_-#H&||GUU]|^^ ~~#'v7H7HII4V\\NCD D E?!%%m4 U77C D 55#'- 6F fd #I)>&**WBUM .}o>!&\2235   ,]OqcBC C Ds&H  EH E+H 0E?E=E? .H ;F/H !G;G<GAH  E($H 'E((H + E:6H 9E::H =E??F,F'!F,"H 'F,,H / F=:H <F==H GHH<H=H HH c Kddlm}|xsg}||jk(rt||||d{Sddlm}m}  ddlm} d} |xsg}|j| r  jnd i} || vrB dd l m } | j|j}|r|j dkDr|j | |<| j|}|r(||jk(r| nd}|j%||| }n|g}||jk(rWt't)|d ixr|j*jd }t-|j.||||||d{S||j0k(rdd l m } | jd}| |j2ddiSt5|||xst6\}}|D|j3||d|||d{}t9|t:r|jdr|S|Sd}t=|D]_\}}|t?|dz k(}|j3|||||r|ngd{}t9|t:r|jdr|cS|}a|S||j@k(rkd}t=|D]Y\}}|t?|dz k(}tC||||r|ng|d{}t9|t:r|jdr|cS|}[|S||jDk(rv|rtd}t=|D]b\}}|t?|dz k(}tG|j*|||r|ngd{}t9|t:r|jdr|cS|}d|S||jHk(rk|rid}t=|D]W\}}|t?|dz k(}tK|||r|ndd{}t9|t:r|jdr|cS|}Y|S||jLk(r|rdd l m }ddl'm(}||jd}| |j2ddiSd}t=|D]_\}}|t?|dz k(}|j3||||r|nd|d{}t9|t:r|jdr|cS|}a|S||jRk(r |rdd l m }ddl'm(}||jd}| |j2ddiSt5|||xst6\} }d}| E|j3||d|||| d{}t9|t:r|jdr|S|St=|D]`\}}|t?|dz k(}|j3||||r|nd||d{}t9|t:r|jdr|cS|}b|S|r"|jUsdd|jd iSd}!|rd!|jd"}!d}|D]2}||jVk(rJdd l m } | jd#}"|" |"j2dd$i}n|"j3||||%d{}n||jRk(rtYd||||d{}n||jDk(r!tG|j*||d{}nW||jZk(rtYd&||||d{}n/||j\k(rtYd'||||d{}n||j^k(rtYd(||||d{}n||jLk(rtYd||||d{}n||j`k(rtYd)||||d{}n||jbk(r te|j*||d{}nc||jfk(rti|||d{}n>||jHk(rtK||d{}ntk|||||||*d{}t9|t:r|jdr|cS|}5|!rRt9|t:rB|jd+r1tm|jd,g}#|#jo|!|#|d,<|S7>#t$rd} Y9wxYw#t"$rYwxYw7F77o77v77J7757v7Q7$77777m7A777w)-aRoute a message to the appropriate platform sender. Long messages are automatically chunked to fit within platform limits using the same smart-splitting algorithm as the gateway adapters (preserves code-block boundaries, adds part indicators). rrr0Nr utf16_lenTelegramAdapterTFr$rIlen_fnrdisable_link_previews)r0rr_rrrJz=Discord plugin not registered or missing standalone_sender_fnr1r&)rr0captionr')rr0)r0rdiscover_pluginsrzWhatsApp plugin not registered or missing standalone_sender_fn)r0rrra)r0rrzsend_message MEDIA delivery is currently only supported for telegram, discord, matrix, weixin, signal, yuanbao, feishu and whatsapp; target z had only media attachmentsz#MEDIA attachments were omitted for z; native send_message media delivery is currently only supported for telegram, discord, matrix, weixin, signal, yuanbao, feishu and whatsapprz;Slack plugin not registered or missing standalone_sender_fnrr rdingtalkwecomrrwarnings)8rrWEIXIN _send_weixinrrrZ"plugins.platforms.telegram.adapterr\ ImportErrorTELEGRAMMAX_MESSAGE_LENGTHrOrJrrEmax_message_lengthritruncate_messagerr]r_send_telegramrDISCORDrPr8_DEFAULT_CAPTION_LIMITrr enumerater)MATRIX_send_matrix_via_adapterSIGNAL _send_signalYUANBAO _send_yuanbaoFEISHUhermes_cli.pluginsrcWHATSAPPr(SLACK_registry_standalone_sendEMAILSMSDINGTALKWECOM BLUEBUBBLES_send_bluebubblesQQBOT _send_qqbotrUruappend)$rrrMrHrr0rrrrZr\_telegram_available _MAX_LENGTHSrJrTmax_len_len_fnchunksr_ _dc_captionrr last_resultirSis_last _pr_feishu _dp_feishu _feishu_entry_pr_wa_dp_wa _wa_entry _wa_captionrk _slack_entryrgs$ r7rr s (#K 8??"!'7GUUUE$F"#K AT?==Z^L |#  C%))(..9E11A5).)A)A X&x(G'8+<+<<)$$55gww5W8$$$ $WWgr%B%qw}}GXGXYpGq r# MM  #"7)   "8###?!%%i0 =E66>\] ] . [$>(>  Q  " 55#'# 6F&$'FJJw,? M !&) !HAuCK!O+G 55#+2K 6F&$'FJJw,?  K !8??" !&) !HAuCK!O+G3+2K# F&$'FJJw,?  K !8??"{ !&) !HAuCK!O+G' +2K F &$'FJJw,?  K !8###  !&) !HAuCK!O+G(+2KF &$'FJJw,?  K !8??"{ME "x0  M$F$F$N[\ \ !&) !HAuCK!O+G(==+2K# >F&$'FJJw,?  K ! 8$$$IAJJz*   > > F]^ ^ . [$>(>  Q  "%99'#-#:F&$'FJJw,? M!&) !HAuCK!O+G$99+2K#- :F&$'FJJw,?  K !7==? "..))DF  G1(..1ABY Y  K0 x~~ % D,009L#|'H'H'P!#`a+@@Wey A ** *4Z'SXZcddF  (' wFFF  '4WgwPUW`aaF  %4UGWeU^__F ** *4Z'SXZcddF  (4XwQVXabbF  '4WgwPUW`aaF -- -,W]]GUKKF  '&w??F )) )(%88F-#'-F fd # 7(;M a0d:k40[__Y5O  B78 "* J k V $#$6   * >*" ,FNeFa_dbaK?8s.ca. ca1&c-Ab.Bc bA1c?bA*c*b+A9c$b%Bc)b*A9c#b"$B7cb%B0c b( A)c6b+7Cc8b.9'c b1!/cb4'c8b79'c b:!'cb= &c/c0&cc.cc$c*c +#cc c)c*Bc1 b<c?bc b cbccccc"c%c(c+c.c1c4c7c:c=cccc c ccrJc8dt|jvS)zCheck if a Telegram error is a thread-not-found failure. Matches the gateway adapter's ``_is_thread_not_found_error`` for the standalone ``_send_telegram`` path (issue #27012). zthread not found)rPr-)rJs r7_is_telegram_thread_not_foundrTs U!1!1!3 33r9c hK ddlm}ddlm}t t j d|} | r|} |j} n5 ddlm } | j| } | j|} |j} ddlm}|ddg }|r7 dd lm}t$j'd ||||| || }n ||}ddlm}||}|xsg}i}|( ddlm } | j/t1|}|||d<t5|}|rd|d<d }g}d }ddlm}t9||t:\}}||| t:kr| }d} | j=r]*>r[)resolve_proxy_urlTELEGRAM_PROXYzapi.telegram.org) target_hostsN) HTTPXRequestz>send_message: standalone Telegram send routed through proxy %s)proxy)rrequestget_updates_requestzUsend_message: failed to attach Telegram proxy (%s), falling back to direct connection)r)normalize_telegram_chat_id1message_thread_idTdisable_web_page_preview)rZr`r&rYr$r])rMr/ parse_modezIThread %s not found in _send_telegram, retrying without message_thread_idparsemarkdownhtmlzFParse mode %s failed in _send_telegram, falling back to plain text: %s) _strip_mdv2z Media file not found, skipping: z;Telegram caption-fallback send failed for missing media: %sr'rbrar)_probe_voice_duration_secondsduration)rMphoto)rMvideo)rMvoice)rMaudio)rMdocumentzFThread %s not found for media send, retrying without message_thread_idz7Caption parse failed for media send, retrying plain: %szFailed to send media : ANo deliverable text or media remained after processing MEDIA tags)rJrgrJrrrrMr~rgzGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: rf)?rrtelegram.constantsrrresearchHTMLrjr\__new__format_messageri MARKDOWN_V2rrtelegram.requestrrjinforkrr_message_thread_id_for_sendrPintrrZr8_TELEGRAM_CAPTION_LIMITr(rrorqrrpopr-rGrr*r+existsrr,openr4_TELEGRAM_SEND_AUDIO_EXTSrrl to_threadr5 send_photor6 send_video send_voice send_audio send_documentseekrJr~rkrK)2rrMrHr0rr_rrr _has_html formattedsend_parse_moder\_adapterr _tg_proxyrrn _proxy_errr int_chat_id thread_kwargseffective_thread_id text_kwargslast_msgrg _tg_caption _utf16_len_caprrrZ text_chunksrSmd_errorrplainr4r5rk_cap_errr6f media_kwargsrr media_errrrJrs2 r7rprp]s0 u4 0#6@A I'nnO $N*22?C$33G< (33O  @)*:J\I]^I  '9 \^gh(y9(49(EE"C 19 !'R    N&5&Q&Q N'##.5H 12=) 6:K2 3 B& [2I a   9 59P P#KI ??  N->>4 ?K%* )%F& +%#2&7B& H* X%0A ) J77>>*-->?\^h-i'iH'3;C Z 8T"+-n-;S^^.(31.@L.(H!K/-;S^^.(31.@L.(H!K/H-;S^^.(31.@L.(H!$==-;S^^.(31.@L.(H.?S->->.(3a.CO.(HGe"1A )F  WE!&H==U# #"h112   !)F:  A  $#  $ I  'vyCD& '8  Nc1Ds9~$ b  !#5X>;??SfCgCsg'OO,?@$(;TB)J*$/e'6*;F*$$ !CM$7$7$99Z3x=K^K^K`=`djnqrzn{oBoBoDeDd+0: ). Z(3E(:#,.(-.%*E)J*$/e'+*0;*$$ G#^$ %Y0:*(j )! !(((((%?"8C HXHXYlHm#NN h ,-@ A FF1I(,,-@$G"k1.1?2",7q2"DP2",",""% !31?2",7q2"DP2",",""% !31?2",7q2"DP2",",""%(A!A1?2",7q2"DP2",","2C1B1B2",7!2"GS2",","*--l;#s9~';';'==(C N,@,@,BB #NN Y 4Y ?FF1I(,,\4@#,1A1A)1L!)$^>I,W`Ja>bL$;'0!)$(!)"k1.1?2",7q2"DP2",",""% !31?2",7q2"DP2",","2C1B1B2",7!2"GS2",",""?"Me"e"L ).1FzlRTUVTW/XY W%(( )( dbcc 4.qc2334sb2BbP,P)P,Ab5U%U" U%1b `2 4`%V!V" V."V=V.%V=6V17'V=V4%V=V7V="V:#V='`2/ b<b2=bb2"b#b2$ N3/b2N33b6 ObOb O;O60b6O;;b>$P&"b%P&&b)P,, U6A&URA9UT&%U& T41U3T44U U UbUb"U%% V.V bVbV V+'`%*V++`%.V=1V=4V=7V=:V== `"A<`Y '`+Y. ,)`Z '`=[ >`[ B$`^` ^$ !`#^$ $%` _ &`0_3 1`` ``%`""`%%`/ *`22 a=;7a82b8a==b b/ b2b/ b*$b/%b2*b//b2cKddlm}ddlm}||j |}| |j d|diS|j ||||d{S7w)akDispatch a one-shot send through a migrated platform plugin's standalone_sender_fn (registry hook). Used for platforms whose adapter moved out of gateway/platforms/ into plugins/platforms// (#41112): the legacy inline ``_send_`` helper now lives in the plugin as ``_standalone_send`` and is reached via the platform registry. rrIrbNrJz6 plugin not registered or missing standalone_sender_fnrd)rOrJr{rcrrP)rLrrMrHrrJrcrTs r7r~r~sh<3  ! !- 0E }22:M?*`abb++GWgQZ+[ [[ [sAAAAc 4 %&'()K ddl(ddlm}m}m}m}m}m} m %m } ddl m }  |jddjd '|jd d &&sdd iS|xsg} g} | D]L\}}tj j#|r| j%|7t&j)d |N| r*t+dt-| |Dcgc] }| |||z }}ngg}| |\})%&'()fd}dt.ddf&'(fd }| }t&j1d|j3t-| t-|g}t5|D]\}}t-|}|dkDrB|j7|}||k\r,|d||d|dzd t-|dd{|dk(r|nd }t+d|dzD];} |j9|d{t;j<}|||d{}t;j<|z }d|vr|j?||d{|d} | | s$tAd|dzd t-|d| ccS|| }!|jC|!|||k\rD|j%|dzt&jEd|dzt-|||!r|!ddndt&j)d|dzt-||||!r|!ddnd>g}#t-| t-| kr|#j%d |r7|#j%d!t-|d"d#jId$|Dd%|r/t-|t-|k(rtAd&t-|d'Sd(d)tKd)d*}$|#r|#|$d+<|$S#t$rddicYSwxYwcc}w7$777#tF$r}"||k\rI|j%|dzt&jEd|dzt-||t/|"Yd}"~"t&j)d|dzt-|||t/|"Yd}"~"d}"~"wwxYw#tF$r}"tAd,|"cYd}"~"Sd}"~"wwxYww)-uSend via signal-cli JSON-RPC API. Supports both text-only and text-with-attachments (images/audio/documents). Multi-attachment sends are chunked into batches of SIGNAL_MAX_ATTACHMENTS_PER_MSG and metered by the process-wide SignalAttachmentScheduler — same bucket the gateway adapter uses, so sends from this tool and inbound-driven replies share rate-limit state. rNrJzhttpx not installed)$SIGNAL_BATCH_PACING_NOTICE_THRESHOLDSIGNAL_MAX_ATTACHMENTS_PER_MSGSIGNAL_RATE_LIMIT_MAX_ATTEMPTS_extract_retry_after_seconds _format_wait_is_signal_rate_limit_error_signal_send_timeout get_scheduler)markdown_to_signalhttp_urlzhttp://127.0.0.1:8080/accountr&zSignal account not configuredz)Signal media file not found, skipping: %sc(K|d}|r rt dk(r d|d<n |d< jdr dd|d<n g|d <|r||d <d d |d ttjdzd}|r t|nd} j |4d{}|j d|d{}|j |jcdddd{S7S777 #1d{7swYyxYww)NrrHr'r textStyle textStylesrOgroupId recipient attachments2.0rtsend_jsonrpcmethodparamsrr /api/v1/rpcr)r)rQrtime AsyncClientrraise_for_statusr) batch_attachments batch_messagerpayloadrWclientrrrrMrhttpx text_styless r7_postz_send_signal.._posts.!(]CF{#q(*5a.F;'+6F<(!!(+$+ABKy!'.i{# (9}%!  c$))+"4567 G +EV3/@+A\]^G(((9 # #V#[[H:[)A[PP%%'yy{ # # #P # # # #sZB D#C7$D'C=C9#C=% D1C;2D9C=;D=DD D Dr/r:c K|d}jdr dd|d<ng|d< jd4d{}|jd d d |d tt jd zdd{dddd{y7Y77 #1d{7swYyxYw#t $r }t jd|Yd}~yd}~wwxYww)z9Best-effort one-shot RPC for a user-facing pacing notice.rrOrNrrg>@rrrrtnotice_rrrz Signal: inline notice failed: %s)rQrrrrrirjrk)r/ notice_params_client_errMrr s r7_send_inline_noticez)_send_signal.._send_inline_notices(/DAM!!(++212; i(.5Y k* G ,,T,:  g!,,#*K0',&,&3$+C d0B,C+D"E '        GA2FF Gs&C!B5BB5AB BB  B5BB5C!B5B B5 B2&B) 'B2.B51C!2B55 C>CC!CC!zIsend_message Signal: scheduler state=%s, %d attachment(s) in %d batch(es)u!(More images coming — pausing ~z for Signal rate limit, batch r'z.)zSignal RPC error on batch rz`Signal: rate-limit retries exhausted on batch %d/%d (%d attachments lost, server retry_after=%s)z.0fsunknownziSignal: rate-limited on batch %d/%d (attempt %d/%d, server retry_after=%s); scheduler will pace the retryz7Signal: send error on batch %d/%d after %d attempts: %szFSignal: transient error on batch %d/%d (attempt %d/%d): %s; will retryz1Some media files were skipped (not found on disk)zSignal rate-limited z batch(es) (#z, #c32K|]}t|ywN)rP).0bs r7 z_send_signal..as?1A?srzSignal: every batch (z*) hit rate limit; no attachments deliveredTr)rrrMrgzSignal send failed: )&r rk#gateway.platforms.signal_rate_limitrrrrrrrrgateway.platforms.signal_formatrrrstripr*r+rrrjrkrgr)rPrstaters estimate_waitacquirer monotonicreport_rpc_durationrKfeedbackrJrijoinrR)*rrMrHr0rrrrrrrr valid_mediaattachment_pathsr4 _is_voicer att_batches plain_textr r schedulerfailed_batchesidx att_batchn estimatedrrT_rpc_t0r _rpc_durationerrserver_retry_afterrrgrrrrr r s* ` @@@@@r7rwrws0   C`299Z)@AHHM))Ir*<= =!'R %0 X !J ww~~j) '' 3JJW  X q#&6"79WX!1'E#EFK $K"4W"= K # #4 GC GD G G*"O  W OO s#34c+6F %'' 4: NCIA1u%33A6  DD-;LMd*';;M1MMMw-C6s;%(B37)1SQ\M]L^^`ad`e&fgg)Ec)J&&&'91="@@&--cAg6 K!GS%5q':&;<ZZ???@C  c.1S5EE'K(8'9:+,  "xDTU]_fDgh !)F:  [ 0.//0BF/@N8! "@@&--cAg6 U!GS%5wANN`a[!17G?GG GGGGGc|Kd}|jr@|j|||d{}|jstd|jS|D]=\}}t j j|std|cSt j j|dj}|tvr|j|||d{}n|tvr|j|||d{}nh|tvr|r|j|||d{}nA|t vr|j|||d{}n|j#|||d{}|jr&td|jcS|ddiSd d ||j$d S77777j7Ow) z=Core send logic shared by live and ephemeral Matrix adapters.N)rHr6zMedia file not found: r'zMatrix media send failed: rJrTrr)r(rtrrKrJr*r+rr,r-r5send_image_filer6rr4rr7rr~) rrMrHr0rHrr4r5r6s r7r7r7sK}}#LL'HLMM ""01B1B0CDE E +L Hww~~j)2:,?@ @ggz*1-335 +  ' 7 7V^ 7 __K K  ' 2 27JQY 2 ZZK K H ' 2 27JQY 2 ZZK K  ' 2 27JQY 2 ZZK ' 5 5gzT\ 5 ]]K""6{7H7H6IJK K#L&\]]!,,  5N`ZZZ]sp*F<F/B/F<F2$F<F4&F<(F6)$F< F8F<*F:+F<=3F<2F<4F<6F<8F<:F<cK ddlm}m}|sddiS ||j|j |||d{S#t$rddicYSwxYw7#t $r}td|cYd}~Sd}~wwxYww) z6Send via Weixin iLink using the native adapter helper.r)check_weixin_requirementssend_weixin_directrJz9Weixin requirements not met. Need aiohttp + cryptography.zWeixin adapter not available.)rrrMrHr0NzWeixin send failed: )gateway.platforms.weixinr@rArkrrrirK)rrMrHr0r@rArs r7riris:Z(*XY Y+ 2'----#    :899:  2,QC0112sfA;AA;$AAAA; AA;AA;A A8 A3-A8.A;3A88A;chK ddlm}m}|sddiS ddlm}||}||}|j d{}|s td S |j||d{} | js0td | j|jd{Sd d || jd |jd{S#t$rddicYSwxYw77~7E7#|jd{7wxYw#t$r} td | cYd} ~ Sd} ~ wwxYww)zBSend via BlueBubbles iMessage server using the adapter's REST API.r)BlueBubblesAdaptercheck_bluebubbles_requirementsrJz8BlueBubbles requirements not met (need aiohttp + httpx).z"BlueBubbles adapter not available.r)rNz(BlueBubbles: failed to connect to serverzBlueBubbles send failed: T bluebubblesr)gateway.platforms.bluebubblesrDrErkrrr9rKrtrrJr:r~ri) rrMrHrDrErrrr<rrs r7rr s3?d-/WX X0 71 u-$W-!//++ DE E '"<<99F>> 9&,,HI$$& & & $7bhbsbst$$& & &! ?=>>?,: ' &'$$& & & 71!5667sD2CD2*DC(DD2C0+C*,'C0D&C,'D+D2,C0<DC.DD2 C%"D2$C%%D2(D*C0,D.D0D DD  D D/ D*$D/%D2*D//D2ctjjdryddlm}|dd}|r|dk7ry ddlm}|S#t$rYy wxYw) uGate send_message on gateway running (always available on messaging platforms). Also passes for kanban workers — the dispatcher sets ``HERMES_KANBAN_TASK`` on every spawned worker, but those workers run with the assignee profile's ``HERMES_HOME`` which has no ``gateway.pid``, so the gateway-running check would fail even though the parent gateway is alive. Honoring the env var lets workers call ``send_message`` to deliver rich content directly to the originating chat (paired with ``kanban_complete`` for the short notifier summary), which is the canonical pattern for any worker that needs to reply with more than the ~200-char first-line truncation the kanban notifier applies. HERMES_KANBAN_TASKTrrrr&local)is_gateway_runningF)r*environrrrgateway.statusrKri)rrrKs r7_check_send_messagerN*sX zz~~*+78"=HH'5!## s A AAc K ddl}|jxsi}|j dxst j dd}|jxs)|j dxst j dd}|r|s td S |jd 4d{}|jd t|t|d d{}|jdk7r)td|jcdddd{S|j} | j d} | stdcdddd{Sd| dd} |dddd} d|d} |j| | | d{}|jdvr7|j}dd||j ddcdddd{Sd |d}|j|| | d{}|jdvr7|j}dd||j ddcdddd{Sd!|d}|j|| | d{}|jdvr7|j}dd||j ddcdddd{Std"|jd#|jd$|jcdddd{S#t$rtdcYSwxYw7N7!7777@7 777{7:#1d{7swYyxYw#t$r}td%|cYd}~Sd}~wwxYww)&aSend via QQBot using the REST API directly (no WebSocket needed). Uses the QQ Bot Open Platform REST endpoints to get an access token and post a message. Supports guild channels, C2C (private) chats, and group chats by trying the appropriate endpoints. rNz8QQBot direct send requires httpx. Run: pip install httpxapp_id QQ_APP_IDr& client_secretQQ_CLIENT_SECRETz3QQBot: QQ_APP_ID / QQ_CLIENT_SECRET not configured.rz)https://bots.qq.com/app/getAppAccessToken)appId clientSecretrzQQBot token request failed: access_tokenz"QQBot: no access_token in responsezQQBot rri)rGmsg_typez#https://api.sgroup.qq.com/channels/z /messages)rr>rWTqqbotrrz#https://api.sgroup.qq.com/v2/users/z$https://api.sgroup.qq.com/v2/groups/zQQBot send failed: channel=z c2c=z group=zQQBot send failed: )r rkrKrrr*rrrrrP status_coderri)rrMrHr rappidsecretr  token_resp token_datarXrr rrrurl_c2cresp_c2c url_group resp_grouprs r7rrDsR MM RE IIh  =299["#=Emm3uyy93-r2 KLL21$$R$0/ F/ FF%{{;"5z3v;G + J%%, >.9LBC/ F/ F/ F"$*,!8 2G#*%4.a@G8y JCSwHHD:-yy{#'W&*hhtn67/ F/ F/ F>7L  L"L#L'M(L L7L = L L LM1L  L L LMK)&M(K))M,L/L 2L5L8L ;L>L LL LL LL LLML L?' L:4L?5M:L??McK ddlm}m}|}| t dS |||||d{S#t$rt dcYSwxYw7#t $r}t d|cYd}~Sd}~wwxYww)uSend via Yuanbao using the running gateway adapter's WebSocket connection. Yuanbao uses a persistent WebSocket — unlike HTTP-based platforms, we cannot create a throwaway client. We obtain the running singleton from the adapter module itself (``get_active_adapter``). chat_id format: - Group: "group:" - DM: "direct:" or just "" r)get_active_adaptersend_yuanbao_directz%Yuanbao adapter module not available.NzVYuanbao adapter is not running. Start the gateway with yuanbao platform enabled first.rXzYuanbao send failed: )gateway.platforms.yuanbaorfrgrkrKri)rMrHr0rfrgrrs r7ryrys?U!"G E  3('7P[\\\ ?=>>?] 3-aS1223scA55A5AAAA5A  A5 A  A5A A2 A-'A2(A5-A22A5)r)Fr)NNFFr)NN)N__doc__rlrloggingr*rsslr email.utilsr agent.redactragent.secret_scoper getLoggerrRrjcompilerrr"r!r$r%r  frozensetr)r* IGNORECASEr(r'rr5r6r7r4rr.rrrr8rCrErPrGrrKrRrirr_rbrqSEND_MESSAGE_SCHEMArrrrrrr<rrUrrrrpr~rwrur7rirrNrrytools.registryrrfr9r7rusG  ".)   8 $&BJJ'DEBJJfg2::=>$"**%MNBJJuvRZZ CD- DE"**45 2::IMM2::WX '(<=8 6 @ w $V,  +-1&N"rzzWMM'BJJQMM #4C4D4 C##y354<2EF'c'&  5!< } ! \ ! ] ! J ! % .3%P  LY1xn7bUSUcUp:& 3QTW[Q[J\~EP 44t4}4H \(z2NGT$^2*7@4E1P3<&r9