i_UdZddlZddlZddlZddlZddlZddlmZmZddl Z ddl Z ddl m Z ej eZejdZejdZejdZejdZeZehd Zejd Zhd Zhd Zhd ZddhZejdejZejdejZde fdZ!de de"fdZ#de$de%de&dzfdZ'ddde%fdZ(dddd d!d"gd#d$d d%d&d d'd&d(gd)d*Z)d+Z*d,Z+d-Z,d.e d/e fd0Z-d1Z.d2Z/d.e d3e d4e dzfd5Z0dSd6Z1dTd8Z2de de fd9Z3iZ4ee e5fe6d:<d3e d;e5ddfd<Z7d3e dee5fd=Z8dSd>Z9d?Z:d@Z;dUdAZdDZ?dEZ@dSdFZAdGZBdHZCdIZDdUdJZEdKZFdSdLZGdMZHdNZIddOlJmKZKmLZLeKjMddPe)e*eHdQRdS)Va$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)DictOptional)redact_sensitive_textz^\s*(-?\d+)(?::(\d+))?\s*$zD^\s*((?:oc|ou|on|chat|open)_[-A-Za-z0-9]+)(?::([-A-Za-z0-9_]+))?\s*$z^\s*([CGD][A-Z0-9]{8,})\s*$zS^\s*((?:wxid|gh|v\d+|wm|wb)_[A-Za-z0-9_-]+|[A-Za-z0-9._-]+@chatroom|filehelper)\s*$>smssignalwhatsappz^\s*\+(\d{7,15})\s*$>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4>.m4a.mp3.wav.ogg.opusrrzP([?&](?:access_token|api[_-]?key|auth[_-]?token|token|signature|sig)=)([^&#\s]+)zJ\b(access_token|api[_-]?key|auth[_-]?token|signature|sig)\s*=\s*([^\s,;]+)returnct|}td|}td|}|S)zCRedact secrets from error text before surfacing it to users/models.c2|ddS)Nz***groupms 9/home/div/.hermes/hermes-agent/tools/send_message_tool.pyz&_sanitize_error_text..9sQWWQZZ2D2D2Dc2|ddS)Nrz=***rrs r r!z&_sanitize_error_text..:s!''!**7J7J7Jr")r_URL_SECRET_QUERY_REsub_GENERIC_SECRET_ASSIGN_RE)textredacteds r _sanitize_error_textr)6sF$T**H#''(D(DhOOH(,,-J-JHUUH Or"messagec$dt|iS)z9Build a standardized error payload with redacted content.error)r))r*s r _errorr->s )'22 33r"excattemptcRt|dd}|6 tt|dS#ttf$rYdSwxYwt |}d|vsd|vrdSd|vsd|vsd|vsd |vsd |vs d |vsd |vsd |vrtd|zSdS)N retry_aftergg?z timed outtimeoutz bad gateway502ztoo many requests429zservice unavailable503zgateway timeout504)getattrmaxfloat TypeError ValueErrorstrlower)r.r/r1r's r _telegram_retry_delayr?Cs#}d33K u[))3// /:&   33  s88>>  Ddi4//t D== $ & & D== D ( ( D==  $ $ D==Q'\""" 4s2AA)attemptsrAc NKt|D]} |jdi|d{VcS#t$rn}t||}| ||dz krtd|dz||t |tj|d{VYd}~d}~wwxYwdS)NrzFTransient Telegram send failure (attempt %d/%d), retrying in %.1fs: %s) range send_message Exceptionr?loggerwarningr)asynciosleep)botrAkwargsr/r.delays r !_send_telegram_message_with_retryrN\s??'' '))33F33333333 3 3 3 ' ' ')#w77E}8a< 7 7 NNX! $S))    -&& & & & & & & & & & & & & '''s* B"A$BB"rEaSend 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.objectstringsendlistzAction to perform. 'send' (default) sends a message. 'list' returns all available channels/contacts across connected platforms.)typeenum descriptiona~Delivery 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')rSrUzThe message text to send)actiontargetr*)rS propertiesrequired)namerU parametersc t|dd}|dkrtSt|S)z-Handle cross-channel send_message tool calls.rVrQrR)get _handle_list _handle_send)argskwrVs r send_message_toolrbs8 XXh ' 'F ~~   r"c 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_directoryrdjsondumpsrFr-)rdes r r^r^sLJJJJJJz9&B&B&D&DEFFF LLLz&!Ia!I!IJJKKKKKKKKLs#& A#AAAc  |dd}|dd}|r|stdS|dd}|d}t |dkr|dnd}d}d}|rt ||\}}}nd }|rw|su dd lm} | ||} | rt || \}}} ntj d d |d |diSn-#t$r tj d d |d |dicYSwxYwddl m } | rtdS ddlm} m}| }n;#t$r.}tj t#d|cYd}~Sd}~wwxYwid|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd |jd!|jd"|j d#|j!d$|j"}||}|s|d?|d@|"dA<tm|"tnrV|"d=rA|r? ddBl8m9}#ddCl:m;}$|$dDdE}%|#||||%|Frd+|"dG<n#t$rYnwxYwtm|"tnrd |"vrty|"d |"d <tj |"S#t$r.}tj t#dH|cYd}~Sd}~wwxYw)Iz$Send a message to a platform target.rWr*z;Both 'target' and 'message' are required when action='send':rrNF)resolve_channel_namer,zCould 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)load_gateway_configPlatformzFailed to load gateway config: telegramdiscordslackrr bluebubblesqqbotmatrix mattermost homeassistantdingtalkfeishuwecomwecom_callbackweixinemailrz, zUnknown platform: z . Available: WEIXIN_TOKENWEIXIN_ACCOUNT_IDPlatformConfigTWEIXIN_BASE_URLWEIXIN_CDN_BASE_URL) account_idbase_url cdn_base_url)enabledtokenextraz Platform 'zZ' is not configured. Set up credentials in ~/.hermes/config.yaml or environment variables.)BasePlatformAdapterWEIXIN_HOME_CHANNEL) HomeChannelz Weixin Home)platformchat_idrZzNo 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_HOME_CHANNEL ) _run_async) thread_id media_filessuccesszSent to z home channel (chat_id: )note)mirror_to_sessionget_session_envHERMES_SESSION_PLATFORMcli) source_labelrmirroredz Send failed: )=r] tool_errorsplitstripr>len_parse_target_refrfrmrgrhrFtools.interruptrngateway.configrprqr-TELEGRAMDISCORDSLACKWHATSAPPSIGNAL BLUEBUBBLESQQBOTMATRIX MATTERMOST HOMEASSISTANTDINGTALKFEISHUWECOMWECOM_CALLBACKWEIXINEMAILSMSjoinkeys platformsrosgetenvrgateway.platforms.baser extract_media_describe_media_for_mirrorget_home_channelrrupper_maybe_skip_cron_duplicate_send model_toolsr_send_to_platform isinstancedictgateway.mirrorrgateway.session_contextrr))&r`rWr*parts platform_name target_refrr is_explicitrmresolved_rnrprqconfigri platform_mapravailpconfigwx_token wx_accountrrrcleaned_message mirror_textused_home_channelhomewx_homerduplicate_skiprresultrrrs& r r_r_s XXh # #Fhhy"%%G YYWXXX LLa E!HNN$$**,,M%(ZZ!^^q!!!JGI*;M:*V*V'KK +  F F F F F F++M:FFH (9-(R(R%AAzQ:QQMQQQ#%&    :;z;; ;;;     /.....~)-(((I@@@@@@@@$$&& IIIz&!F1!F!FGGHHHHHHHHIH%8#  H%  (/  x+   (/ h) / H% (/  (1 (/ !" x|#L& ..H T ,++--..R}RR5RRSSS""8,,G V'/V H $ $y44::<S>S ZY YYwYYYF6N fd # #  9(=(= +  <<<<<<CCCCCC./H%PP $$]G[Wcoxyyy.)-F:&     fd # # D6(9(926'?CCF7Oz&!!! 777z&!4!4!455666666667suAD'EE'E:: F2#F-'F2-F2BV'$-UV' UV'UAV'' W1#WWWrrc|dkrGt|}|r+|d|ddfS|dkrGt|}|r+|d|ddfS|dkrGt|}|r+|d|ddfS|dkr4t |}|r|dddfS|d kr4t |}|r|dddfS|tvr3t|}|r| ddfS| d  r|ddfS|d kr/| d s| d r|ddfSdS)zFParse a tool target into chat_id/thread_id and whether it is explicit.rrrr7Tr{rsrtNr~-rw!@NNF) _TELEGRAM_TOPIC_TARGET_RE fullmatchr_FEISHU_TARGET_RE_NUMERIC_TOPIC_RE_SLACK_TARGET_RE_WEIXIN_TARGET_RE_PHONE_PLATFORMS_E164_TARGET_RErlstripisdigit startswith)rrmatchs r rr:s "")33J??  8;;q>>5;;q>>47 7  !++J77  8;;q>>5;;q>>47 7 !!!++J77  8;;q>>5;;q>>47 7 **:66  .;;q>>4- -  !++J77  .;;q>>4- -((())*55  2##%%tT1 1%%''&4%%  j&;&;C&@&@ JDYDYZ]D^D^ 4%%  r"c:|sdSt|dkrr|d\}}tj|d}|r |t vrdS|t vrdS|tvrdS|tvrdSdSd t|d S) zJReturn a human-readable mirror summary when a message only contains media.rkrrz[Sent voice message]z[Sent image attachment]z[Sent video attachment]z[Sent audio attachment]z[Sent document attachment]z[Sent z media attachments]) rrpathsplitextr> _VOICE_EXTS _IMAGE_EXTS _VIDEO_EXTS _AUDIO_EXTS)r media_pathis_voiceexts r rr^s r ;1*1~ Hgz**1-3355  *{**)) +  ,, +  ,, +  ,,++ 9C $$ 9 9 99r"cddlm}|dd}|dd}|r|sdS|ddpd}|||dS) zMReturn the cron scheduler's auto-delivery target for the current run, if any.rr!HERMES_CRON_AUTO_DELIVER_PLATFORMrk HERMES_CRON_AUTO_DELIVER_CHAT_IDN"HERMES_CRON_AUTO_DELIVER_THREAD_ID)rrr)rrrr>)rrrrs r _get_cron_auto_delivery_targetrqs777777BBGGMMOOUUWWHo@"EEKKMMG 7t DbIIOOQQYUYI  r"rrct}|sdS|d|ko>t|dt|ko|d|k}|sdS|d|}||d|z }ddd|d|d d S) zRSkip redundant cron send_message calls when the scheduler will auto-deliver there.NrrrrlT#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.)rskippedreasonrWr)rr=r])rrr auto_target same_target target_labels r rrs022K t J=0 6  I& ' '3w<< 7 6 OOK ( (I 5 t#//g//LI' 7 h| h h h   r"c Kddlm}ddlm}m}ddlm} ddlm}  ddl m } d} n#t$rd} YnwxYw dd l m } d}n#t$rd}YnwxYw|pg}||jkrZ|rX | | }||}n,#t"$rt$d d YnwxYw|j| r| jnd |j| j|j| ji}|r| j||j<||}|r(||jkr|nd }||||}n|g}||jkrd }t5t7|dio|jd}t;|D]o\}}|t=|dz k}t?|j |||r|ng||d {V}tC|tDr|dr|cS|}p|S||j#krtI||||d {VS||jkrd }t;|D]n\}}|t=|dz k}tK|j |||r|ng|d {V}tC|tDr|dr|cS|}o|S||j&kr|r}d }t;|D]i\}}|t=|dz k}tO||||r|ng|d {V}tC|tDr|dr|cS|}j|S||j(kr|rd }t;|D]m\}}|t=|dz k}tS|j|||r|ngd {V}tC|tDr|dr|cS|}n|S|r!|*s dd|j+diSd }|r d|j+d}d }|D]W}||jkrtY|j ||d {V}n||j-krt]|j||d {V}n||j(krtS|j||d {V}n||j/krta|j||d {V}n||j1krte|j3||d {V}nW||j4kr$tk|j |j||d {V}n(||j&kr#tm|j |j||d {V}n||j7kr#tq|j |j||d {V}n||j9krtu|j||d {V}n||jkrtw||||d {V}n||j<krt{|j||d {V}nW||j>krt|j||d {V}n/||j@krt|||d {V}n dd|j+i}tC|tDr|dr|cS|}Y|rgtC|tDrR|dr=t|dg}|C|||d<|S)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). r)rq)r utf16_len)DiscordAdapter) SlackAdapterTelegramAdapterTF) FeishuAdapterz>>>>>" $$$#$"::::::  """!"#K8>!!g! h(00>>M#227;;GG h h h LLWbfL g g g g g h AT^?==Z^.; 7L I(5(H X_% x((G'8+<<<))$$55gww5WW8$$$ $WWgr%B%B%qw}GXGXYpGqGq r r!&)) ! !HAuCKK!O+G) +2:KK#&; F&$'' FJJw,?,?   KK8?""!'7GUUUUUUUUUU8### !&)) ! !HAuCKK!O+G( +2:KK# F&$'' FJJw,?,?   KK8?""{" !&)) ! !HAuCKK!O+G3+2:KK# F&$'' FJJw,?,?   KK8?""{" !&)) ! !HAuCKK!O+G' +2:KK F &$'' FJJw,?,?   KK 7==?? F".FFF  G  (.     K   x~ % %&w}guEEEEEEEEFF * * *)'-%HHHHHHHHFF  ( (' wFFFFFFFFFF  ' '&w}guEEEEEEEEFF  % %$W_guEEEEEEEEFF , , ,+GM7='SXYYYYYYYYFF  ( (' w}guUUUUUUUUFF / / /.w}gmWV[\\\\\\\\FF * * *)'-%HHHHHHHHFF  ( ('%9UUUUUUUUUFF  ' '&w}guEEEEEEEEFF - - -,W]GUKKKKKKKKFF  ' '&w????????FFYYYZF fd # #  7(;(; MMM +:k400+[__Y5O5O+  B7788   "* J s/' 66A AA'*B&B;:B;FcK ddlm}ddlm}t t jd|}|r |} |j} nK ddlm } | | } | |} n#t$r|} YnwxYw|j } ||} t|}|pg}i}|t||d<|rd |d <d}g}| r t!| f|| | d |d{V}n#t$r}d t#|vsFd t#|vs#dt#|vrjt&d| t+||s% ddlm}|| }n#t$r|}YnwxYw|}t!| f||dd |d{V}nYd}~nd}~wwxYw|D]\}}t.j|s5d|}t&|||Zt.j|d} t9|d5}|t:vr| jd#||d|d{V}nx|t>vr| j d#||d|d{V}nX|tBvr|r| j"d#||d|d{V}n6|tFvr| j$d#||d|d{V}n| j%d#||d|d{V}dddn #1swxYwYT#t$rO}t+d|d|}t&&|||Yd}~d}~wwxYw| d}|r||dSd|iSd d|t#|j'd}|r||d <|S#tP$rdd!icYSt$r}tSd"|cYd}~Sd}~wwxYw)$uDSend via Telegram Bot API (one-shot, no polling needed). Applies markdown→MarkdownV2 formatting (same as the gateway adapter) so that bold, links, and headers render correctly. If the message already contains HTML tags, it is sent with ``parse_mode='HTML'`` instead, bypassing MarkdownV2 conversion. r)Bot) ParseModez<[a-zA-Z/][^>]*>r)rNmessage_thread_idTdisable_web_page_preview)rr' parse_modeparsemarkdownhtmlzFParse mode %s failed in _send_telegram, falling back to plain text: %s) _strip_mdv2 Media file not found, skipping: rrb)rphoto)rvideo)rvoice)raudio)rdocumentFailed to send media : ANo deliverable text or media remained after processing MEDIA tagsr,r r,rrrrr message_idr zGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: rC)*rrr9telegram.constantsr:rresearchHTMLrrrrrF MARKDOWN_V2intrrNr=r>rGrHr)rArrexistsr,ropenr send_photor send_videor send_voicer send_audio send_documentr,rNrr-)rrr*rrr r9r: _has_html formattedsend_parse_moder_adapterrK int_chat_id thread_kwargslast_msgr md_errorrAplainrrrHrfrir,rs r rrWsv4      000000#6@@AA  4I'nOO $FFFFFF*22?CC$33G<<  $ $ $#  $(3Oc'll !'R   14YM- .  =8>*-- IZIIw'''((('"":..q17799C )*d++qk)))7*$/q**!&H===U# #"h122     *!)F:  dddbcccc 4442q22333333334s:O0A0/O0 A?<O>A??AOC76O7 GBGF('G( F74G6F77GOGBO6L8BL+ L8+L/ /L82L/ 3L86O8 NAN O N OO#!OO: O:O5/O:5O:c|ddd}|d}|sd}|ddS)zMDerive a thread name from the first line of the message, capped at 100 chars. rr#zNew PostNd)rrr)r* first_lines r _derive_forum_thread_namerksk&&tQ//288::J""3''--//J   dsd r"!_DISCORD_CHANNEL_TYPE_PROBE_CACHEis_forumcNt|tt|<dSN)rrlr=)rrms r _remember_channel_is_forumrps6:8nn%c'll333r"cPtt|Sro)rlr]r=)rs r _probe_is_forum_cachedrrs , 0 0W > >>r"c .K ddl}n#t$rddicYSwxYw ddlm}m}|d}||\} } dd |i} i| d d i} |pg}d} g}|rd |d }n.d} ddlm}|d|}n#t$rYnwxYw|dkrd}n&|d}n t|}||}n d} d |}|j dz!_send_discord..IsJ,,, )T$'s889I9I$9O9OPP,,,r")content attachments)rZr* payload_json) content_typerCzfiles[])r)rdatarz%Discord forum thread creation error (): z$Discord forum thread upload failed: rrrgrr*)rrrrrNr zDiscord API error (zfiles[0]rIz: Discord API error (rJz6No deliverable text or media remained after processingrLrMzDiscord send failed: rC)$aiohttprrrvrwrfr~rFrr ClientSession ClientTimeoutr]statusrgrprGrrkrrrUrHr,rrhFormData add_fieldrVreadrpostr'r-r)rr,)/rrr*rrrrvrw_proxy_sess_kw_req_kw auth_headers json_headers last_datar url _channel_typer~rmcachedinfo_url info_sess info_respinfo thread_name thread_url valid_mediar _is_voicerHsessionattachments_metastarter_messagerformrfhrespbodyrrithread_id_createdstarter_msg_idrrrer,s/ r rrs&L LLLJKKKKLk3VVVVVVVV""ODDD44V<<''8 K,K8JKK !'R   q MN)NNNCC !M IIIIII 3 3Iw G G     ''* /88%%HH$H d#T7#T#T#87#8#m#mAVAV]_AVA`A`#mdl#m#mRRRRRRRqz'4y}X'_'_|'_W^'_'_RRRRRRRcl#,#3s#:#:1:1A1A+A+A+A+A+A+AD/3xx/?/?2/EH$>w$Q$Q$Q RRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRR %ddd %JG^b cccccdL 7@@ VWVVV ! -833)J 7>>*55!"QZ"Q"Qw/// 000 &&z2222070ee9N9NUW9N9X9Xe\dee05050505050505ip"/5,,-6{-C-C,,,(7>N^*_*_'+z;Sb2c2c'd'd &//11~|Rdeee l3<[3I3I&&Z%)*d%;%;!&r$(NN(7(* 131A1A*1M1M%3%&%&%&!&!&!&!&!&!&!&!&!&!&!&!&!&!&!& (4w|J'k [_'k'kcj'k'k9999999os#';j#@#@15+<+<+<+<+<+?ifg?i?i*j*j#k#kkkkkkA0505050505050505050505050505>l $07<&$$0(3,5w+?""$$&$$ 5 5 5 5 5 5 5 5"#{*<<-1YY[['8'8'8'8'8'8'-.lVZVa.l.lfj.l.l'm'm 5 5 5 5 5 5 5 5 5 5 5 5 5I0505050505050505050505050505`*.#4#4#4#4#4#4D 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5I050505050505050505050505050505050505050505050505050505d%)HHTNN!"&((9"5"5";!@!@GX!Y!Y# )&!2"0 2)1F:& L'LLLC(7(]]1F1FR1F1P1P]T\]] - - - - - - -ah}} 2k 2'7<h\T[H\hh`ghh2222222lp{*44%)YY[[000000%&RDK&R&RD&R&RSS2222222222222 - - - - - - - - - - - - - -'+iikk 1 1 1 1 1 1I 222222222222222222222222222*5 - -% Iw~~j11MMMGNN7+++OOG,,,-"++--D!w// ;;Hj$// :1z1xHHH#/7<#`\PT#`#`X_#`#`:::::::dh#{*<<-1YY[['8'8'8'8'8'8*>@OWa@O@Ox|yD@O@OIM@O@O+P+P & W 5 5 5 ( 8 8 8 ( :::::::::::: : : : : : : :/3iikk(9(9(9(9(9(9I::::::::::::::::::::::::::: : : : : : : : : : : : : : : :!---23\:3\3\YZ3\3\]]GLL)))OOG,,,,,,,,-' - - - - - - - - - - - - - - - - - - - - - - - - - - - -D  LE >!&H===U# #!yW\e\i\ijn\o\opp  *!)F:  3331a11222222223s Ac.$A76c.7 Bc.B*c./.F E84AEE8 E E8"E #E8&F 8 FF FF c. 'F41c.3F44B7c.+A%T'$P5A M  P M PM P0=O>-P?c.O>,P> P P P PT' QQ9Q:T'>c.QT'6=T3T'c.T2T' T T'T T'c.' T11c.4T15Ac. /c.80b+(=Y6%b+7c. Y6$b+6 Z b+Z Ab+$A`<'0`/A1` `/ `<$b+&` `/ ` `/` `/# `</`3 3`<6`3 7`<:b+< bAb b+bb+c.+ b55c.8b59 c.c. "c.. d8d ddc PK ddl}n#t$rddicYSwxYw ddlm}m}|}||\}}d} d|dd } |jdd |d i|4d{V} ||d d} | j| f| | d|4d{V} | d{V}| dr>d d|| ddcdddd{Vcdddd{VStd| ddcdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t$r}td|cYd}~Sd}~wwxYw)zSend via Slack Web API.rNr,rtruz&https://slack.com/api/chat.postMessageBearer r|rzr{r2rrT)channelr'mrkdwnrokrttsrMzSlack API error: unknownzSlack send failed: rC) rrrrvrwrrrrgr]r-rF)rrr*rrvrwrrrrrrpayloadrrris r rrskL LLLJKKKKL1VVVVVVVV""$$44V<<'6$5e$5$5GYZZ(7(]]1F1FR1F1P1P]T\]] R R R R R R Rah")7dKKG#w|CRwRR'RR R R R R R R RVZ!YY[[((((((88D>>t'+Wdhdldlmqdrdrss R R R R R R R R R R R R R R R R R R R R R R R R R R R P$((7I2N2NPPQQ  R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R 111/A//000000001s AE?1E,A EE,*E?=%E"E,4E? E E,E E,E?, E66E?9E6:E?? F% F F% F%cLK ddl}n#t$rddicYSwxYw |dd}|4d{V}|d|d||d |d  4d{V }|jd krX|d{V}dd||ddcdddd{Vcdddd{VS|d{V}td|jd|cdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t$r} td| cYd} ~ Sd} ~ wwxYw)z,Send via the local WhatsApp bridge HTTP API.rNr,rt bridge_porti zhttp://localhost:z/send)chatIdr*rr)rgr2rTr messageIdrMzWhatsApp bridge error (rzWhatsApp send failed: ) rrr]rrrrrgr'r-rF) rrr*rrrrrrris r r r s?L LLLJKKKKL4ii t44 ((** P P P P P P Pg||6K666 'G<<--B-77$ P P P P P P P P;#%%!%,,,,,,D#'$.#*&*hh{&;&;  P P P P P P P P P P P P P P P P P P P P P P P P P P P"YY[[((((((N NNNNOO P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P P 4442q22333333334s 0E=:E* ?EE*E=-3E E*2E= E E*E E*E=* E44E=7E48E== F#FF#F#c`K ddl}n#t$rddicYSwxYw |ddd}|dd }|sdd iS||d }|d r|d d|d<n|g|d<|pg}g} |D]U\} } t j| r| | :t d| V| r| |d<dd|dttj dzd} | d4d{V} | |d| d{V}||}d|vr*t#d|dcdddd{VSdd|d}t%| t%|krdg|d <|cdddd{VS#1d{VswxYwYdS#t&$r}t#d!|cYd}~Sd}~wwxYw)"zSend via signal-cli JSON-RPC API. Supports both text-only and text-with-attachments (images/audio/documents). Attachments are sent as an 'attachments' array in the JSON-RPC params. rNr,httpx not installedhttp_urlzhttp://127.0.0.1:8080/accountrkzSignal account not configured)rr*zgroup:groupId recipientz)Signal media file not found, skipping: %srz2.0rQsend_)jsonrpcmethodparamsr>@r2z /api/v1/rpcrgzSignal RPC error: Trrrrz1Some media files were skipped (not found on disk)r zSignal send failed: )httpxrr]rstriprrrrUr,rGrHrTtime AsyncClientrraise_for_statusrgr-rrF)rrr*rrrrrrattachment_pathsrrrclientrrrris r rrs 0 000.////0,299Z)@AAHHMM))Ir** ><= =$99   h ' ' , ' F9  #*)F; "'R %0 X X !J w~~j)) X '' 3333JJWWWW  5$4F= !3#dikkD01133   $$T$22       f%=%=%=GLLLLLLLLD  ! ! # # #99;;D$B4=BBCC              "&8PPF#$$s;'7'777&Z%[z"                               2220Q00111111112sb AH#CH=A$G4!H4-G4!H4 G>>HG>H H-H("H-(H-c"Kddl}ddlm}|dpt jdd}t jdd}|dpt jd d} t t jd d }n#ttf$rd }YnwxYwt|||gsd diS ||dd} || d<|| d<d| d<| ||} | tj | ||| | | dd|dS#t"$r} t%d| cYd} ~ Sd} ~ wwxYw)z:Send via SMTP (one-shot, no persistent connection needed).rN)MIMETextaddress EMAIL_ADDRESSrkEMAIL_PASSWORD smtp_hostEMAIL_SMTP_HOSTEMAIL_SMTP_PORT587iKr,zNEmail not configured (EMAIL_ADDRESS, EMAIL_PASSWORD, EMAIL_SMTP_HOST required)rdzutf-8FromToz Hermes AgentSubject)contextTrrzEmail send failed: )smtplibemail.mime.textrr]rrrTr<r;allSMTPstarttlssslcreate_default_contextloginrEquitrFr-) rrr*rrrpasswordr smtp_portmsgserverris r r!r!!sNNN((((((ii ""Dbi&D&DGy)2..H +&&J")4Er*J*JI "3U;;<<  "  9- . .kijj 1hw11F D 'Ii33 : < <=== Wh'''C    WIII 111/A//000000001s17"BB0/B0 BE(( F2F F Fc6K ddl}n#t$rddicYSwxYwddl}tjdd}tjdd}|r|r|sddiSt jd d |t j }t jd d |t j }t jd d |t j }t jdd |t j }t jdd|}t jdd |}t jdd|t j }t jdd |}t jdd|}| } ddl m }m }|} || \} } |d|} | | dd} d|d}dd| i}|jd,d|di| 4d{V}|}|d||d ||d!||j|f||d"| 4d{V}|d{V}|jd#kra|d$t1|}t3d%|jd&|cdddd{Vcdddd{VS|d'd}d(d)||d*cdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t4$r}t3d+|cYd}~Sd}~wwxYw)-zSend a single SMS via Twilio REST API. Uses HTTP Basic auth (Account SID : Auth Token) and form-encoded POST. Chunking is handled by _send_to_platform() before this is called. rNr,rtTWILIO_ACCOUNT_SIDrkTWILIO_PHONE_NUMBERzXSMS not configured (TWILIO_ACCOUNT_SID, TWILIO_AUTH_TOKEN, TWILIO_PHONE_NUMBER required)z \*\*(.+?)\*\*z\1)flagsz \*(.+?)\*z __(.+?)__z_(.+?)_z ```[a-z]*\n?z`(.+?)`z ^#{1,6}\s+z\[([^\]]+)\]\([^\)]+\)z\n{3,}z rurlasciiz+https://api.twilio.com/2010-04-01/Accounts/z/Messages.jsonrzzBasic r2rrrrBody)rrir*zTwilio API error (rsidTrrMzSMS send failed: rC)rrbase64rrrPr%DOTALL MULTILINErrrvrw b64encodeencodedecoderrrrrrgrr]r=r-rF) auth_tokenrr*rr account_sid from_numberrvrwrrrcredsencodedrrr form_datarr error_msgmsg_sidris r r"r"As= L LLLJKKKKLMMM)0"55K)1266K uju usttf%ugRYGGGGf\5'CCCGf\5'CCCGfZryAAAGf_b'22GfZ00Gf]Br|DDDGf.w??GfY00GmmooG/VVVVVVVV""$$44V<<'----""5<<#8#899@@IIWKWWW"$6W$6$67(7(]]1F1FR1F1P1P]T\]] g g g g g g gah((**I    4 4 4   g . . .    0 0 0#w|CTiTTGTT g g g g g g gX\!YY[[((((((;#%% $CII > >I!"Rt{"R"Ry"R"RSS  g g g g g g g g g g g g g g g g g g g g g g g g g g g((5"--#'Uw^eff  g g g g g g g g g g g g g g g g g g g g g g g g g g g  g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g g ///-!--......../s ,BM2A.M2A"L:M&M29L:M'M2: M MM M M2 M))M2,M)-M22 N<N NNcK ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iS|d }d |d d}||d4d{V}|||||d4d{V} | j dvrX| d{V} td| j d| cdddd{Vcdddd{VS| d{V} dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdd|| ddS#t$r} td| cYd} ~ Sd} ~ wwxYw)zSend via Mattermost REST API.rNr,rtrMATTERMOST_URLrkrMATTERMOST_TOKENzEMattermost not configured (MATTERMOST_URL, MATTERMOST_TOKEN required)z /api/v4/postsrr|rrrr) channel_idr*rrzMattermost API error (rTrxrrMzMattermost send failed: )rrr]rrrrrrrr'r-rgrF) rrrr*rrrrrrrrris r r$r$ysL LLLJKKKKL6IIe$$G 2BB(G(GOOPSTT:#5r:: fu fde e((($5e$5$5GYZZ((1F1FR1F1P1P(QQ ) ) ) ) ) ) )U\||Cgbi?j?j|kk ) ) ) ) ) ) )os;j00!%,,,,,,D!"Q4;"Q"Q4"Q"QRR ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) "YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  \g]a]e]efj]k]klll 666444555555556s AF5:=F57"F =E'F (F5;E'F ' E1 1F 4E1 5F 8F5 FF5FF55 G?GGGc(K ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iSd t tjd zd tjd }ddl m }||d}|d|d|} d|dd} d|d} ddl } | |ddg} tjdd| } d| d<| | d<n#t$rYnwxYw||d !"4d{V}|| | | #4d{V}|jd$vrX|d{V}t)d%|jd&|cdddd{Vcdddd{VS|d{V}dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYd'd(||d)d*S#t,$r}t)d+|cYd}~Sd}~wwxYw),zSend via Matrix Client-Server API. Converts markdown to HTML for rich rendering in Matrix clients. Falls back to plain text if the ``markdown`` library is not installed. rNr,rt homeserverMATRIX_HOMESERVERrkrMATRIX_ACCESS_TOKENzGMatrix not configured (MATRIX_HOMESERVER, MATRIX_ACCESS_TOKEN required)hermes_rr)quote)safez/_matrix/client/v3/rooms/z/send/m.room.message/rr|rzm.text)msgtyper fenced_codetables) extensionsz(.*?)z\1zorg.matrix.custom.htmlformatformatted_bodyrrrrrzMatrix API error (rTrwevent_idrMMatrix send failed: )rrr]rrrrTrurandomhex urllib.parserr?rPr%rrputrr'r-rgrF)rrrr*rrtxn_idr encoded_roomrrr_mdr@rrrrris r r%r%s L LLLJKKKKL2ii --S;NPR1S1S[[\_`` =#8"== h hfg gJ3ty{{T122JJRZ]]5F5F5H5HJJ&&&&&&uW2... aalaaY_aa$5e$5$5GYZZ'88  " " " "<<]H4M<NND635KTRRD 8GH (,G$ % %    D ((1F1FR1F1P1P(QQ ) ) ) ) ) ) )U\{{3g{FF ) ) ) ) ) ) )$;j00!%,,,,,,D!"Mt{"M"Mt"M"MNN ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) "YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  X'Y]YaYablYmYmnnn 2220Q00111111112s AI+:A7I+2=D0/I+0 D=:I+<D==3I+0I=H II+1H I H' 'I*H' +I.I+ I  I+ I I++ J5J J Jc@K ddlm}n#t$rddicYSwxYw|pg} ||}|d{V}|s:t d |d{VS#t $rYSwxYw|rd|ind}d} |rg||||d{V} | j sBt d | j  |d{VS#t $rYSwxYw|D]\} } tj | s?t d | c |d{VS#t $rYSwxYwtj | d } | t vr||| |d{V} n| t$vr||| |d{V} np| t(vr!| r||| |d{V} nF| t,vr||| |d{V} n||| |d{V} | j sDt d | j c |d{VS#t $rYSwxYw| /dd i |d{VS#t $rYSwxYwdd|| jd |d{VS#t $rYSwxYw#t $rG} t d | cYd} ~ |d{VS#t $rYSwxYwd} ~ wwxYw# |d{Vw#t $rYwwxYwxYw)zISend via the Matrix adapter so native Matrix media uploads are preserved.r) MatrixAdapterr,zIMatrix dependencies not installed. Run: pip install 'mautrix[encryption]'NzMatrix connect failedrmetadatar!Media file not found: rzMatrix media send failed: rKTrwrM)gateway.platforms.matrixr*rconnectr- disconnectrFrrQrr,rrrUrr>rsend_image_filerrXrrYrr[rN)rrr*rrr*adapter connectedr,r4rrrris r rrsf::::::: fffdeeeef#K0-((!//++++++++  3122R $$&& & & & & & & & &    D S09BK++d ==?? J ' Wg Q QQQQQQQK& JH[5FHHIIB $$&& & & & & & & & &    D C%0 P P J7>>*-- ECzCCDDDD: $$&& & & & & & & & &    D ;'"":..q17799Ck!!$+$;$;GZZb$;$c$ccccccc  ##$+$6$6w U]$6$^$^^^^^^^  ###$+$6$6w U]$6$^$^^^^^^^  ##$+$6$6w U]$6$^$^^^^^^^ $+$9$9':X`$9$a$aaaaaaa & PN;;LNNOOOO $$&& & & & & & & & &    D # P  `a $$&& & & & & & & & &    D  %0    $$&& & & & & & & & &    D  2220Q001111111 $$&& & & & & & & & &    D  2 $$&& & & & & & & & &    D s 5LA55 BBALC:: DD :LE  E-,E-0DLJ"" J/.J/2L:K K"!K"% L1L  LL M-&M(7M-8M0=M M%$M%(M--M00N2N  N NNNNcbK ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iS|d }d |d d}||d4d{V}|||||d4d{V} | j dvrX| d{V} td| j d| cdddd{Vcdddd{VS dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdd|dS#t$r} td| cYd} ~ Sd} ~ wwxYw)z'Send via Home Assistant notify service.rNr,rtrHASS_URLrkr HASS_TOKENz=Home Assistant not configured (HASS_URL, HASS_TOKEN required)z/api/services/notify/notifyrr|rrrr)r*rWrrzHome Assistant API error (rTryrzHome Assistant send failed: ) rrr]rrrrrrrr'r-rF) rrrr*rhass_urlrrrrrris r r&r&sL LLLJKKKKL:IIe$$A *b(A(AII#NN4<44 ^u ^\] ]666$5e$5$5GYZZ((1F1FR1F1P1P(QQ W W W W W W WU\||C7^e?f?f|gg W W W W W W Wko;j00!%,,,,,,D!"Ut{"U"Ut"U"UVV W W W W W W W W W W W W W W W W W W W W W W W W W W W0 W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W W  _QQQ :::8Q8899999999:s AF:=F7"E1=EE1(F<E1 E E1E E1F1 E;;F>E;?F F.F)#F.)F.cK ddl}n#t$rddicYSwxYw |dptjdd}|sddiS|d 4d{V}||d d |id d{V}||}|dddkr8td|ddcdddd{VS dddd{Vn#1d{VswxYwYdd|dS#t$r}td|cYd}~Sd}~wwxYw)aqSend via DingTalk robot webhook. Note: The gateway's DingTalk adapter uses per-session webhook URLs from incoming messages (dingtalk-stream SDK). For cross-platform send_message delivery we use a static robot webhook URL instead, which must be configured via ``DINGTALK_WEBHOOK_URL`` env var or ``webhook_url`` in the platform's extra config. rNr,r webhook_urlDINGTALK_WEBHOOK_URLrkzkDingTalk not configured. Set DINGTALK_WEBHOOK_URL env var or webhook_url in dingtalk platform extra config.rrr'r)rr'rerrcodezDingTalk API error: errmsgrTrzrzDingTalk send failed: ) rrr]rrrrrrgr-rF) rrr*rr9rrrris r r'r's0 000.////04ii ..W")r?rrrr/r-fatal_error_messagerQrr,r0rNrF) rrr*r>r?rrr2r3rris r r)r)/s9RRRRRRRR'')) `^_ _ ` 9997888891111111 .u---,w''!//++++++++  jh8S8fWfhhii i '"<<99999999F> DBFLBBCC$$&& & & & & & & & & $W\b\mnn$$&& & & & & & & & &'$$&& & & & & & & & & 111/A//000000001sN,,AD9C=<D C="D=DD E&D=7E=EcK ddlm}m}|sddiSn#t$rddicYSwxYw ||j|j|||d{VS#t $r}td|cYd}~Sd}~wwxYw) z6Send via Weixin iLink using the native adapter helper.r)check_weixin_requirementssend_weixin_directr,z9Weixin requirements not met. Need aiohttp + cryptography.zWeixin adapter not available.)rrrr*rNzWeixin send failed: )gateway.platforms.weixinrDrErrrrFr-)rrr*rrDrEris r rrJs :ZZZZZZZZ((** ZXY Y Z :::89999: 2''--#            2220Q00111111112s),,A A6A1+A61A6cvK ddlm}m}|sddiSn#t$rddicYSwxYw ddlm}||}||}|d{V}|std S |||d{V} | j s1td | j | d{VSd d || j d | d{VS#| d{VwxYw#t$r} td | cYd} ~ Sd} ~ wwxYw)zBSend via BlueBubbles iMessage server using the adapter's REST API.r)BlueBubblesAdaptercheck_bluebubbles_requirementsr,z8BlueBubbles requirements not met (need aiohttp + httpx).z"BlueBubbles adapter not available.rr@Nz(BlueBubbles: failed to connect to serverzBlueBubbles send failed: TrurM)gateway.platforms.bluebubblesrHrIrrrr/r-rQrr,r0rNrF) rrr*rHrIrrr2r3rris r r*r*_s?dddddddd--// YWX X Y ???=>>>>?7111111 .u---$$W--!//++++++++  FDEE E '"<<99999999F> JH&,HHII$$&& & & & & & & & & $7bhbstt$$&& & & & & & & & &'$$&& & & & & & & & & 7775!55666666667sN,,AD99C32D C3D3DD D8D3-D83D8cK ddlm}m}|sddiSddlm}m}n#t $rddicYSwxYw|pg} ||} t | dd} | dkr|n|} | | | _|rd |ind } d } | r<| ||| d {V} | j std | j S|D]P\}}tj|std |cStj|d}|t&vr| ||| d {V} n|t*vr| ||| d {V} np|t.vr!|r| ||| d {V} nF|t2vr| ||| d {V} n| ||| d {V} | j std| j cSR| ddiSdd|| jdS#t8$r}td |cYd }~Sd }~wwxYw)z7Send via Feishu/Lark using the adapter's send pipeline.r)rFEISHU_AVAILABLEr,zJFeishu dependencies not installed. Run: pip install 'hermes-agent[feishu]') FEISHU_DOMAIN LARK_DOMAIN _domain_namer{larkrNr+zFeishu send failed: r-rzFeishu media send failed: rKTrM)rrrLrMrNrr8_build_lark_client_clientrrQrr-r,rrrUrr>rr1rrXrrYrr[rNrF)rrr*rrrrLrMrNr2 domain_namedomainr,r4rrrris r r(r(zsgLLLLLLLL kij jGGGGGGGGG gggeffffg#K*2-((g~x@@ "-"7"7[!44V<</8BK++d ==?? J ' Wg Q QQQQQQQK& JH[5FHHIII$/ P P J7>>*-- ECzCCDDDDD'"":..q17799Ck!!$+$;$;GZZb$;$c$ccccccc  ##$+$6$6w U]$6$^$^^^^^^^  ###$+$6$6w U]$6$^$^^^^^^^  ##$+$6$6w U]$6$^$^^^^^^^ $+$9$9':X`$9$a$aaaaaaa & PN;;LNNOOOOO P  `a a %0    2220Q00111111112sG ,,BH4:H4 DH4 H4( H44 I>IIIc~ddlm}|dd}|r|dkrdS ddlm}|S#t$rYdSwxYw) zOGate send_message on gateway running (always available on messaging platforms).rrrrklocalT)is_gateway_runningF)rrgateway.statusrWrF)rrrWs r _check_send_messagerYs7777778"==HH''t555555!!### uus . <<cK ddl}n#t$rtdcYSwxYw|jpi}|dpt jdd}|jp)|dpt jdd}|r|std S |d 4d{V}| d t|t|d d{V}|j dkr)td|j cdddd{VS| } | d} | s!tdcdddd{VSd| dd} d|d} |dddd} | | | | d{V}|j dvr@| }dd||ddcdddd{VStd |j d!|j cdddd{VS#1d{VswxYwYdS#t$r}td |cYd}~Sd}~wwxYw)"zSend 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. Works for guild channels without requiring a running gateway adapter. rNz8QQBot direct send requires httpx. Run: pip install httpxapp_id QQ_APP_IDrk client_secretQQ_CLIENT_SECRETz3QQBot: QQ_APP_ID / QQ_CLIENT_SECRET not configured.rrz)https://bots.qq.com/app/getAppAccessToken)appId clientSecretrrzQQBot token request failed: access_tokenz"QQBot: no access_token in responsezQQBot r|rz#https://api.sgroup.qq.com/channels/r}i)rmsg_type)rgrrTrvrrMzQQBot send failed:  )rrr-rr]rrrrrr= status_codergr'rF)rrr*rrappidsecretr token_resp token_datararrrrrris r r+r+sR RRRPQQQQQR M RE IIh   =29["#=#=Em3uyy993-r22 MMKLLL1$$R$00 T T T T T T TF%{{;"5zz3v;;GG +  J%,,UZ=SUUVV T T T T T T T T T T T T T T$**J%>>.99L ECDD T T T T T T T T T T T T T T"9,!8!8 2GKJJJC")%4%.a@@GSwHHHHHHHHD:--yy{{#'W&*hhtnn661 T T T T T T T T T T T T T T6RD4DRRtyRRSS7 T T T T T T T T T T T T T T T T T T T T T T T T T T T T T T8 111/A//000000001st %% H=r}se  !!!!!!!! ......  8 $ $&BJ'DEEBJfgg2:<==BJuvv- 9:::;;"*455888 666 777 w !rzWM'BJQM #4C4D4444 y354<2EF'''c''''&  5!( a ! ` !9  #@LLLV7V7V7r!S!c!!!!H:::&   3QTW[Q[>uuuup~4~4~4~4Bss68!4T ?777EEtEEEEE?C?HTN????B3B3B3B3J111.444862626262r111@5/5/5/p6660)2)2)2X9999x:::.444>11162222*777662626262r   111111j0///////      r"