i(UdZddlZddlZddlZddlZddlZddlmZmZddl Z ddl Z ddl m Z ej eZejdZejdZejdZejdZejd ZeZehd Zejd Zhd Zhd ZhdZddhZddhZejdejZ ejdejZ!de"fdZ#de"de$fdZ%de&de'de(dzfdZ)ddde'fdZ*d d!d"d#d$d%gd&d'd#d(d)d#d*d)d+gd,d-Z+d.Z,d/Z-d0Z.d1e"d2e"fd3Z/d4Z0d5Z1d1e"d6e"d7e"dzfd8Z2d9Z3dXd:Z4dYd<Z5de"de"fd=Z6iZ7ee"e8fe9d><d6e"d?e8ddfd@Z:d6e"dee8fdAZ;dXdBZdZdEZ?dFZ@dGZAdHZBdIZCdXdJZDdKZEdLZFdMZGdZdNZHdOZIdXdPZJdQZKdRZLdZdSZMddTlNmOZOmPZPeOjQd dUe+e,eKdVWdS)[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)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*$z ^\s*((?:group|direct):[^:]+)\s*$>smssignalwhatsappz^\s*\+(\d{7,15})\s*$>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4>.wav.flac.m4a.mp3.ogg.opusrrrrzP([?&](?: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 z&_sanitize_error_text..>sQWWQZZ2D2D2Dc2|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*;sF$T**H#''(D(DhOOH(,,-J-JHUUH Or#messagec$dt|iS)z9Build a standardized error payload with redacted content.error)r*)r+s r!_errorr.Cs )'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/r0r2r(s r!_telegram_retry_delayr@Hs#}d33K u[))3// /:&   33  s88>>  Ddi4//t D== $ & & D== D ( ( D==  $ $ D==Q'\""" 4s2AA)attemptsrBc 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)botrBkwargsr0r/delays r!!_send_telegram_message_with_retryrOas??'' '))33F33333333 3 3 3 ' ' ')#w77E}8a< 7 7 NNX! $S))    -&& & & & & & & & & & & & & '''s* B"A$BB"rFaSend 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 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', 'yuanbao:direct:' (DM), 'yuanbao:group:' (group chat))rTrVuThe message text to send. To send an image or file, include MEDIA: (e.g. 'MEDIA:/tmp/hermes/cache/img_xxx.jpg') in the message — the platform will deliver it as a native media attachment.)actiontargetr+)rT propertiesrequired)namerV parametersc t|dd}|dkrtSt|S)z-Handle cross-channel send_message tool calls.rWrRrS)get _handle_list _handle_send)argskwrWs r!send_message_toolrcs8 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_directoryrejsondumpsrGr.)rees 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}~wwxYw ||}n)#t$t&f$rtd|cYSwxYw|j|}|r|js|dkrt-jdd}t-jdd}|re|rcddlm}|d||t-jddt-jddd}n&td|dStd|dSdd lm}||\}}|pt9|}d }|s||}|sC|dkr=t-jd!d}|rdd"lm}|||d#$}|r |j}d}n2tj d d%|d&|d'| d(iStC|||}|rtj |S dd)l"m#}|tI||||||*} |r6tK| tLr!| d+r d,|d-|d.| d/<tK| tLre| d+rP|rN dd0l'm(}!dd1l)m*}"|"d2d3}#|"d4dpd}$|!||||#||$5rd| d6<n#t$rYnwxYwtK| tLrd | vrtW| d | d <tj | S#t$r.}tj t#d7|cYd}~Sd}~wwxYw)8z$Send a message to a platform target.rXr+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: zUnknown platform: weixin 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_idr[zNo 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_PLATFORMcliHERMES_SESSION_USER_ID) source_labelruser_idmirroredz Send failed: ),r^ tool_errorsplitstripr?len_parse_target_refrgrnrhrirGtools.interruptrogateway.configrqrrr.r=KeyError platformsr}osgetenvrwgateway.platforms.baser extract_media_describe_media_for_mirrorget_home_channelrrupper_maybe_skip_cron_duplicate_send model_toolsr_send_to_platform isinstancedictgateway.mirrorrgateway.session_contextrr*)%rarXr+parts platform_name target_refrr is_explicitrnresolved_rorqrrconfigrjrpconfigwx_token wx_accountrwrrcleaned_message mirror_textused_home_channelhomewx_homerduplicate_skiprresultrrrrs% 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!FGGHHHHHHHHI @8M**  !@@@>}>>?????@""8,,G V'/V H $ $y44::<S>S ZY YYwYYYF6N fd # #  9(=(= +  <<<<<<CCCCCC./H%PP )/*BBGGO4$$!!-'# .*.F:&     fd # # D6(9(926'?CCF7Oz&!!! 777z&!4!4!455666666667sAD'EE'E:: F2#F-'F2-F26 G#G('G(4BT=>5;;q>>47 7  !++J77  8;;q>>5;;q>>47 7 !!!++J77  8;;q>>5;;q>>47 7 **:66  .;;q>>4- -  !++J77  .;;q>>4- - !!",,Z88  .;;q>>4- -      % % ' ' =0J,,..00$< <  ((())*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.rlrrz[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!rras 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_PLATFORMrl HERMES_CRON_AUTO_DELIVER_CHAT_IDN"HERMES_CRON_AUTO_DELIVER_THREAD_ID)rrr)rrrr?)rrrrs r!_get_cron_auto_delivery_targetrts777777BBGGMMOOUUWWHo@"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.NrrrrmT#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.)rskippedreasonrXr)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<K ddlm}|}|r\|j|}|r@ddlm}|||d{V}|jr d|jdSdd |j iSn#t$r} dd | icYd} ~ Sd} ~ wwxYwdd |j d iS) zSend a message via a live gateway adapter (for plugin platforms). Falls back to error if no adapter is connected for this platform. r)_gateway_runner_ref) SendResult)rcontentNT)r message_idr-zAdapter send failed: zPlugin platform send failed: zNo live adapter for platform 'z7'. Is the gateway running with this platform connected?) gateway.runradaptersr^rrrRrrr-rGvalue) rrrchunkrrunneradapterrrrjs r!_send_via_adapterrs >333333$$&&  Io))(33G I======&||GU|KKKKKKKK>N'+6;LMMM!G!G!GHH >>><<<=======> }hn}}} ~~s$A!A3& A33 B=B B Bc 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<||vrI dd lm}||j}|r|jdkr |j||<n#t"$rYnwxYw||}|r(||jkr|nd}||||}n|g}||jkrd}t=t?|dio|j d}tC|D]o\}}|tE|dz k}tG|j$|||r|ng||d{V}tK|tLr|dr|cS|}p|S||j'krtQ||||d{VS||jkrd}tC|D]n\}}|tE|dz k}tS|j$|||r|ng|d{V}tK|tLr|dr|cS|}o|S||j*kr|r}d}tC|D]i\}}|tE|dz k}tW||||r|ng|d{V}tK|tLr|dr|cS|}j|S||j,kr|rd}tC|D]m\}}|tE|dz k}t[|j |||r|ngd{V}tK|tLr|dr|cS|}n|S||j.kr}|r{d}tC|D]g\}}|tE|dz k}t_|||r|ndd{V}tK|tLr|dr|cS|}h|S|r!|0s dd|jdiSd}|r d|jd}d}|D]}||jkrtc|j$||d{V}n*||j2krtg|j ||d{V}n||j,krt[|j ||d{V}n||j4krtk|j ||d{V}n||j6krto|j8||d{V}n||j9kr$tu|j$|j ||d{V}nW||j*kr$tw|j$|j ||d{V}n(||j<kr#t{|j$|j ||d{V}n||j>krt|j ||d{V}n||jkrt||||d{V}n||jAkrt|j ||d{V}n||jCkrt|j ||d{V}n]||jEkrt|||d{V}n:||j.krt_||d{V}nt||||d{V}tK|tLr|dr|cS|}|rgtK|tLrR|dr=t|dg}|I|||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)rr)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_%|##  C C C C C C%))(.99E B1A55).)A X&    D  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,?,?   KK8### # !&)) ! !HAuCKK!O+G(+27D66 EEFcK 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)r~Nmessage_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-rr-rrrrrrzGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: rD)*rrDtelegram.constantsrErresearchHTMLrrr r rG MARKDOWN_V2intrrOr>r?rHrIr*rLrrexistsr7ropenr send_photor send_videor send_voice_TELEGRAM_SEND_AUDIO_EXTS send_audio send_documentr-rrr.)r~rr+rrrrDrE _has_html formattedsend_parse_moder_adapterrL int_chat_id thread_kwargslast_msgrmd_errorrLplainrrrIrfrjr-rs r!rrsv4      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_namerv sk&&tQ//288::J""3''--//J   dsd r#!_DISCORD_CHANNEL_TYPE_PROBE_CACHEis_forumcNt|tt|<dSN)rrwr>)rrxs r!_remember_channel_is_forumr{s6:8nn%c'll333r#cPtt|Srz)rwr^r>)rs r!_probe_is_forum_cachedr}!s , 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 drrbasename).0idxrs r! z!_send_discord..~sJ,,, )T$'s889I9I$9O9OPP,,,r#)r attachments)r[r+ payload_json) content_typerNzfiles[])r)rdatarz%Discord forum thread creation error (): z$Discord forum thread upload failed: rrrhrr+)rrrrrrzDiscord API error (zfiles[0]rTz: Discord API error (rUz6No deliverable text or media remained after processingrWrXzDiscord send failed: rD)$aiohttprrrrrgrrGr} ClientSession ClientTimeoutr^statusrhr{rHr rvrrr_rIr7rriFormData add_fieldr`readrpostr(r.r*rr-)/r~rr+rrrrr_proxy_sess_kw_req_kw auth_headers json_headers last_datarurl _channel_typerrxcachedinfo_url info_sess info_respinfo thread_name thread_url valid_mediar _is_voicerIsessionattachments_metastarter_messagerformrfhrespbodyrrjthread_id_createdstarter_msg_idrrrpr-s/ r!rr%s&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-rrz&https://slack.com/api/chat.postMessageBearer rrrr3rrT)channelr(mrkdwnrokrtsrXzSlack API error: unknownzSlack send failed: rD) rrrrrrrrrhr^r.rG)r~rr+rrrrrrrrrpayloadrrrjs r!r!r!skL 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-r bridge_porti zhttp://localhost:z/send)chatIdr+rr)rhr3rTr messageIdrXzWhatsApp bridge error (rzWhatsApp send failed: ) rrr^rrrrrhr(r.rG) rrr+rrrrrrrjs 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 Z  !"#$%K ddl%n#t$rddicYSwxYwddlm}m m}m}m}m}m !m }  | dd d$| d d ""sdd iS|pg} g#| D]U\} } tj| r#| :t"d | V#r, #fd t'dt)# D} ngg} !"$%fd}dt*ddf"$%fd }| }t"d|t)#t)| g}t1| D]\}}t)|}|dkrO||}||kr4|d||d|dzdt)| dd{V|dkr|nd }t'd|dzD]} ||d{Vt7j}|||d{V}t7j|z }d|vr|||d{Vn|d}||s,t=d|dzdt)| d|ccS||}|||||krP||dzt" d|dzt)| ||r|ddndnt"d|dzt)| |||r|ddndl#tB$r}||krY||dzt" d|dzt)| |t+|Yd}~nJt"d|dzt)| ||t+|Yd}~d}~wwxYwg}t)#t)| kr|d |rF|d!t)|d"d#"d$|Dd%|r@t)|t)| kr t=d&t)| d'Sd(d)d*}|r||d+<|S#tB$r}t=d,|cYd}~Sd}~wwxYw)-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. rNr-httpx 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_schedulerhttp_urlzhttp://127.0.0.1:8080/accountrlzSignal account not configuredz)Signal media file not found, skipping: %sc*g|]}||zSrDrD)rrArattachment_pathss r!rz _send_signal..Hs9!1'E#E!EFr#cK|d} dr dd|d<n g|d<|r||d<dd|d ttjd zd }|rt|nd } | 4d{V}| d|d{V}||cdddd{VS#1d{VswxYwYdS)Nrr+rgroupId recipientr2.0rRsend_jsonrpcmethodparamsrrr3 /api/v1/rpcrh)rr^timer AsyncClientrraise_for_statusrh) batch_attachments batch_messagerrr3clientrrrrrhttpxs r!_postz_send_signal.._postOs!(]CCF!!(++ 0$+ABBKy!!'.i{#  :(9}%!  7c$)++"45577 G +*EV+]3/@+A+A+A\]^^G(((99 # # # # # # #V#[[H)A)A)A[PPPPPPPP%%'''yy{{ # # # # # # # # # # # # # # # # # # # # # # # # # # # # # #sAC77 DDr(rc K|d}drdd|d<ng|d< d4d{V}|d d d |d tt jd zdd{Vdddd{VdS#1d{VswxYwYdS#t $r&}t d|Yd}~dSd}~wwxYw)z9Best-effort one-shot RPC for a user-facing pacing notice.rrrNrr>@rrrrRnotice_rrrz Signal: inline notice failed: %s)rrrr^rrGrHrI)r( notice_params_client_errrrs r!_send_inline_noticez)_send_signal.._send_inline_noticeds(/DAAM!!(++ 7+2122; i((.5Y k* G ,,T,::       g!,,#000',&,&3"EC d0B,C,C"E"E '                               G G GA2FFFFFFFFF Gs<B?A B,B?, B66B?9B6:B?? C/ C**C/zIsend_message Signal: scheduler state=%s, %d attachment(s) in %d batch(es)u!(More images coming — pausing ~z for Signal rate limit, batch rz.)zSignal RPC error on batch rUz`Signal: rate-limit retries exhausted on batch %d/%d (%d attachments lost, server retry_after=%s)z.0fsrziSignal: 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, #c34K|]}t|VdSrz)r>)rbs r! z_send_signal..s(??1A??????r#rzSignal: every batch (z*) hit rate limit; no attachments deliveredTrrrrrzSignal send failed: )#rr#gateway.platforms.signal_rate_limitrrrrrrrrr^rstriprrr_r7rHrIrErr>rstater estimate_waitacquirer monotonicreport_rpc_durationr.feedbackr-rGjoin)&rrr+rrrrrrrrrr att_batchesrr schedulerfailed_batchesr att_batchn estimatedrr0_rpc_t0r _rpc_durationerrserver_retry_afterrjrrrrrrrrs& ` @@@@@@r!rrs0 000.////0                    Y299Z)@AAHHMM))Ir** ><= =!'R %0 X X !J w~~j)) X '' 3333JJWWWW  q#&6"7"79WXXKK $K # # # # # # # # #* GC GD G G G G G G G G G*"MOO  W OO  s#344c+6F6F   %'' 44: : NCIA1uu%33A66  DDD--WLLMd**';;M1MMMMMMMMMw-C66s;;h%&f37&f&fSQ\M]M]&f&fad&f&fggggggg)E)Ec)J)J&&&'91==="@@@&--cAg666 K!GS%5%5q':':CCZZ???????CCC     c.11S5E5EEE,K(8(8,,,  "xGLL  *!)F:  2220Q00111111112s!!AT>FTA6M? T:M? TA5M?T7M?=T? P/ AP*"T(r.rG) auth_tokenrr+rr< account_sid from_numberrrrrrcredsencodedrrr form_datarr error_msgmsg_sidrjs r!r'r's= 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-rrMATTERMOST_URLrlrMATTERMOST_TOKENzEMattermost not configured (MATTERMOST_URL, MATTERMOST_TOKEN required)z /api/v4/postsrrrrrr) channel_idr+rrzMattermost API error (rT mattermostrrXzMattermost send failed: )rrr^rrrrrrrr(r.rhrG) r~rrr+rr{rrrrrrrjs r!r*r*,sL 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-r homeserverMATRIX_HOMESERVERrlrMATRIX_ACCESS_TOKENzGMatrix not configured (MATRIX_HOMESERVER, MATRIX_ACCESS_TOKEN required)hermes_rr)quote)safez/_matrix/client/v3/rooms/z/send/m.room.message/rrrzm.text)msgtyper fenced_codetables) extensionsz(.*?)z\1zorg.matrix.custom.htmlformatformatted_bodyrrrrrzMatrix API error (rTrevent_idrXMatrix send failed: )rrr^rrrr^rurandomhex urllib.parserUrJrZr&rrputrr(r.rhrG)r~rrr+rrPtxn_idrU encoded_roomrrr_mdrKrrrrrjs r!r+r+Ds 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: rVTrrX)gateway.platforms.matrixrgrconnectr. disconnectrGrrRrr-rrr_rr?rsend_image_filerrbrrcrrfr)rrr+rrrgr connectedrir@rrrrjs r!rrpsf::::::: 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-rrHASS_URLrlr HASS_TOKENz=Home Assistant not configured (HASS_URL, HASS_TOKEN required)z/api/services/notify/notifyrrrrrr)r+rXrrzHome Assistant API error (rT homeassistantrzHome Assistant send failed: ) rrr^rrrrrrrr(r.rG) r~rrr+rhass_urlrrrrrrjs 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_URLrlzkDingTalk not configured. Set DINGTALK_WEBHOOK_URL env var or webhook_url in dingtalk platform extra config.rrr(r)rWr(rerrcodezDingTalk API error: errmsgrTdingtalkrzDingTalk send failed: ) rrr^rrrrrrhr.rG) rrr+rrvrrrrjs r!r/r/s0 000.////04ii ..W") 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.)rr~rr+rNzWeixin send failed: )gateway.platforms.weixinrrrrr~rGr.)rrr+rrrrjs r!rrs :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.rvr~Nz(BlueBubbles: failed to connect to serverzBlueBubbles send failed: T bluebubblesrX)gateway.platforms.bluebubblesrrrrrwrlr.rRrr-rmrrG) rrr+rrrwrrrorrjs r!r4r4s?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_namerlarkrNrhzFeishu send failed: rjrzFeishu media send failed: rVTrX)r rrrrrr9_build_lark_clientrrrRrr.r-rrr_rr?rrnrrbrrcrrfrrG)rrr+rrrrrrr domain_namedomainrir@rrrrjs r!r0r0-sgLLLLLLLL 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).rrrrllocalT)is_gateway_runningF)rrgateway.statusrrG)rrrs r!_check_send_messagerfs7777778"==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_IDrl 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 rrz#https://api.sgroup.qq.com/channels/ri)rmsg_type)rhrrTqqbotrrXzQQBot send failed:  )rrr.rr^rrr~rrr> status_coderhr(rG)rrr+rrappidsecretr token_resp token_datarrrrrrrjs r!r6r6ssR 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=" - 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.rzYuanbao send failed: )gateway.platforms.yuanbaorrrr.rG)rr+rrrrrjs r!r r s?UUUUUUUUU ???=>>>>>?! ""G E   3(('7P[\\\\\\\\\\ 3331a11222222223s* ))A B'A>8B>B)registryr messagingu📨)r[toolsetschemahandlercheck_fnemoji)NNrrz)R__doc__rJrhloggingrrZtypingrrr-r agent.redactr getLogger__name__rHcompilerrrrrr frozensetrrrrrrrd IGNORECASEr%r'r>r*rr.rGr^r;r@rOSEND_MESSAGE_SCHEMArcr_r`rrrrrrrrvrwr__annotations__r{r}rr!r#rr%r'r*r+rr-r/r2rr4r0rr6r tools.registryrrregisterrDr#r!rs  !!!!!!!! ......  8 $ $&BJ'DEEBJfgg2:<==BJuvvRZ CDD- 9:::;;"*455888 666 @@@ w $V,!rzWM'BJQM #4C4D4444 y354<2EF'''c''''&  5!( a ! o ! k  #@LLLM7M7M7`(S(c((((V:::&   3QTW[Q[>*RRRRj~4~4~4~4Bss68!4T ?777EEtEEEEE?C?HTN????B3B3B3B3J111.4448r2r2r2r2j111D5/5/5/p6660)2)2)2X9999x:::.444>11162222*777662626262r   111111h3333<0///////      r#