FjJ0dZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ej e ZejdZejdZejdZejdZejd Zejd ZeZehd Zejd Zhd ZhdZhdZddhZddhZejdejZ ejdejZ!de"fdZ#de"de$fdZ%de&de'de(dzfdZ)ddde'fd Z*d!d"d#d$d%d&gd'd(d$d)d*d$d+d*d,gd-d.Z+d/Z,d0Z-d1Z.d2e"d3e"fd4Z/d5Z0d6Z1d2e"d7e"d8e"dzfd9Z2ddd:d;d<Z3dUd=Z4d>e&de5fd?Z6dVd@Z7dAZ8dBZ9dWdCZ:dDZ;dEZdHZ?dIZ@dJZAdWdKZBdLZCdXdMZDdNZEdOZFdWdPZGddQlHmIZImJZJeIjKd!dRe+e,eEdSTdS)Ya$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_textz^\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*$>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 6/usr/local/lib/hermes-agent/tools/send_message_tool.pyz&_sanitize_error_text..@sQWWQZZ2D2D2Dc2|ddS)Nrz=***rrs r r!z&_sanitize_error_text..As!''!**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-Es )'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?Js#}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_retryrNcs??'' '))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 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))rSrUuThe 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.)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}~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}d!|v}||\}}||}|pt;|}d }|s||}|sC|dkr=t-jd"d}|rdd#lm}|||d$%}|r |j }d}n2tj d d&|d'|d(|!d)iStE|||}|rtj |S|d*kr|r|#d+rz ddl$((fd,} dd-l%m&}!|!| |j'|}"|"r|"}ntj d d.|d/iSn0#t$r#}tj d d0|icYd}~Sd}~wwxYw dd-l%m&}!|!tQ|||||||1}#|r6tS|#tTr!|#d2r d3|d4|d5|#d6<tS|#tTre|#d2rP|rN dd7l+m,}$dd8l-m.}%|%d9d:}&|%d;dpd}'|$||||&||'<rd|#d=<n#t$rYnwxYwtS|#tTrd |#vrt_|#d |#d <tj |#S#t$r.}tj t#d>|cYd}~Sd}~wwxYw)?z$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: 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.)BasePlatformAdapterz[[as_document]]WEIXIN_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 slackUc>Kd}d|dd}d4d{V}|||d|gi 4d{V}|d{V}|d r2|d d cdddd{Vcdddd{VS dddd{Vdddd{VdS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS) Nz(https://slack.com/api/conversations.openBearer application/json Authorizationz Content-Type totalr2usersheadersrgokchannelid) ClientSession ClientTimeoutpostrgr])r}user_idurlrsessionrespdataaiohttps r _open_slack_dmz$_handle_send.._open_slack_dms@,=e,=,=Oabb"009N9NUW9N9X9X0YY$$$$$$$]d&||CRYQZG[|\\$$$$$$$`d%)YY[[00000088D>>9#' ?4#8$$$$$$$$$$$$$$$$$$$$$$$$$$$ $ $$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$sA"D  =C'D C'D ' C1 1D 4C1 5D  DD) _run_asyncz"Could not open DM with Slack user z#. Check bot permissions (im:write).zFailed to open Slack DM:  thread_id media_filesforce_documentsuccesszSent to z home channel (chat_id: )note)mirror_to_sessionget_session_envHERMES_SESSION_PLATFORMcliHERMES_SESSION_USER_ID) source_labelrrmirroredz Send failed: )0r] tool_errorsplitstripr>len_parse_target_refrfrmrgrhrFtools.interruptrngateway.configrprqr-r<KeyError platformsr|osgetenvrvgateway.platforms.baser extract_mediafilter_media_delivery_paths_describe_media_for_mirrorget_home_channelrrupper_maybe_skip_cron_duplicate_send startswithr model_toolsrr}_send_to_platform isinstancedictgateway.mirrorrgateway.session_contextrr)))r`rWr*parts platform_name target_refrr is_explicitrmresolved_rnrprqconfigrirpconfigwx_token wx_accountrvrforce_document_attachmentsrcleaned_message mirror_textused_home_channelhomewx_homerduplicate_skiprr dm_channelresultrrrrrs) @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;; F3#F.(F3.F37 G#G)(G)+AQ44 R!>RR!R!%B W/rWNmatrixz:$rryuanbaogroup:NNF-!@xmpp)_TELEGRAM_TOPIC_TARGET_RE fullmatchr_FEISHU_TARGET_RE_NUMERIC_TOPIC_RE_SLACK_THREAD_TARGET_RE_SLACK_TARGET_RErrfind_WEIXIN_TARGET_RE_YUANBAO_TARGET_REisdigit_PHONE_PLATFORMS_E164_TARGET_RElstripr)rrmatchrrtrimmed split_idxs r rrVsW "")33J??  8;;q>>5;;q>>47 7  !++J77  8;;q>>5;;q>>47 7 !!!++J77  8;;q>>5;;q>>47 7'11*==  8;;q>>5;;q>>47 7 **:66  .kk!nnG "!*J6KD+- -  ""$$MM$'' q==:I:& A (@$F F  !++J77  .;;q>>4- - !!",,Z88  .;;q>>4- -      % % ' ' =0J,,..00$< <  ((())*55  2##%%tT1 1%%''&4%%  j&;&;C&@&@ JDYDYZ]D^D^ 4%%3*#4#44%%  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 rrs 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_targetrs777777BBGGMMOOUUWWHo@"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"FrcKd} ddlm}|}n#t$rd}YnwxYw| |j|} n#t$rd} YnwxYw| r |rd|ind} | ||| d{V} n-#t j$rt$r} dd| icYd} ~ Sd} ~ wwxYw| jr d| j d Sdd | j iSt|d r|j nt|} d} dd lm}|| }n#t$rd}YnwxYw||j ||||||| d{V} nJ#t j$rt$r.} t"d| ddd| icYd} ~ Sd} ~ wwxYwt'| t(r,| ds| dr| Sdd| dt+| jiSdd| diS)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. Nr)_gateway_runner_refr)rcontentmetadatar,zPlugin platform send failed: T)r message_idzAdapter send failed: valueplatform_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.) gateway.runrrFadaptersr]rQrICancelledErrorrrr,hasattrrr=gateway.platform_registryrstandalone_sender_fnrGdebugrrrS__name__)rrrchunkrrrrunnerradapterrrrirentryrs r _send_via_adapterr$si*F333333$$&&  o))(33GG   GGG    F7@JK33d&||GUU]|^^^^^^^^)    F F F!D!D!DEEEEEEE F~ J#'v7HIIICV\CCD D&-h&@&@SHNNc(mmM E??????!%%m44  U7C D 55#'- 6FF%     D D D LL?Y]L ^ ^ ^BqBBC C C C C C C D fd # # I)>)> &**WBUBU M 5}55!&\\255    E] E E E sk &&A AA&BB-B("B-(B-6D D! D!.!EF)#F FFc ~Kddlm}ddlm}m} ddlm}  ddlm} d} n#t$rd} YnwxYw ddl m } d}n#t$rd}YnwxYw|pg}||j krZ|rX | | }||}n,#t$rt d d YnwxYw|j| r| jnd |j | ji}|r| j||j<||vrI dd lm}||j}|r|jdkr |j||<n#t$rYnwxYw||}|r(||jkr| nd }||||}n|g}||jkrd }t7t9|dio|jd}t=|D]p\}}|t?|dz k}tA|j!|||r|ng|||d {V}tE|tFr|dr|cS|}q|S||j$krtK||||d {VS||j&krdd lm}|d}||j'ddiSd }t=|D]o\}}|t?|dz k}|'|||||r|ngd {V}tE|tFr|dr|cS|}p|S||j(kr|r}d }t=|D]i\}}|t?|dz k}tS||||r|ng|d {V}tE|tFr|dr|cS|}j|S||j*kr|rd }t=|D]m\}}|t?|dz k}tW|j|||r|ngd {V}tE|tFr|dr|cS|}n|S||j,kr}|r{d }t=|D]g\}}|t?|dz k}t[|||r|nd d {V}tE|tFr|dr|cS|}h|S||jkr|r}d }t=|D]i\}}|t?|dz k}t]||||r|nd |d {V}tE|tFr|dr|cS|}j|S|r!|/s dd|jdiSd }|r d|jd}d }|D][}||j krta|j!||d {V}n||j1krte|j||d {V}n||j*krtW|j||d {V}n||j3krti|j||d {V}n||j5krtm|j7||d {V}n[||j(kr$tq|j!|j||d {V}n,||j9kr#tu|j!|j||d {V}n||j;krty|j||d {V}n||jkrt]||||d {V}n||j=krt}|j||d {V}n||j?krt|j||d {V}na||jAkrt|||d {V}n>||j,krt[||d {V}nt|||||||d {V}tE|tFr|dr|cS|}]|rgtE|tFrR|dr=t|d g}|E|||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) SlackAdapterTelegramAdapterTF) FeishuAdapterz>>>>>" $$$#$"::::::  """!"#K8>!!g! h(00>>M#227;;GG h h h LLWbfL g g g g g h AT^?==Z^ 7LI(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###??????!%%i00 =E6>\] ] !&)) ! !HAuCKK!O+G 55#+2:KK 6F&$'' FJJw,?,?   KK8?""{" !&)) ! !HAuCKK!O+G3+2:KK# F&$'' FJJw,?,?   KK8?""{" !&)) ! !HAuCKK!O+G' +2:KK F &$'' FJJw,?,?   KK8### # !&)) ! !HAuCKK!O+G(+2)r,s r _is_telegram_thread_not_foundrg#s! U!1!1!3!3 33r"c f K ddlm}ddlm}t t jd|} | r |} |j} nK ddlm } | | } | |} n#t$r|} YnwxYw|j } ddlm}|ddg }n#t$rd }YnwxYw|r dd lm}t$d ||||| || }nJ#t$r1}t$d|||}Yd }~nd }~wwxYw||}t+|}|pg}i}|e ddlm } | t/|}n4#t$r't/|dkrd nt+|}YnwxYw|||d<t1|}|rd|d<d }g}| rs t5|f|| | d|d {V}nY#t$rK}t7|r^|r\t$d|d|dd t5|f|| | d|d {V}ndt/|vsFdt/|vs#dt/|vrjt$d| t?|| s% ddlm }|| }n#t$r|}YnwxYw|}t5|f||d d|d {V}nYd }~nd }~wwxYw|D]\}}tBj"#|s5d|}t$||$|ZtBj"%|d} tM|d5} t1|}! |tNvr|s|j(d/|| d|!d {V}nx|tRvr|j*d/|| d |!d {V}nX|tVvr|r|j,d/|| d!|!d {V}n6|tZvr|j.d/|| d"|!d {V}n|j/d/|| d#|!d {V}n$#t$r}"t7|"r|!drt$d$|!d| 0d|!dd |tNvr|s|j(d/|| d|!d {V}nz|tRvr|j*d/|| d |!d {V}nZ|tVvr|r|j,d/|| d!|!d {V}n8|tZvr|j.d/|| d"|!d {V}n|j/d/|| d#|!d {V}nYd }"~"nd }"~"wwxYwd d d n #1swxYwY#t$rO}#t?d%|d&|#}t$1||$|Yd }#~#d }#~#wwxYw| d'}$|r|$|d(Sd)|$iSdd*|t/|j2d+}%|r||%d,<|%S#tf$rd)d-icYSt$r}#tid.|#cYd }#~#Sd }#~#wwxYw)0uDSend 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()resolve_proxy_urlTELEGRAM_PROXYzapi.telegram.org) target_hostsN) HTTPXRequestz>send_message: standalone Telegram send routed through proxy %s)proxy)r}requestget_updates_requestzUsend_message: failed to attach Telegram proxy (%s), falling back to direct connection)r}1message_thread_idTdisable_web_page_preview)rr' 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: rrb)rphoto)rvideo)rvoice)raudio)rdocumentzFThread %s not found for media send, retrying without message_thread_idzFailed to send media : ANo deliverable text or media remained after processing MEDIA tags)r,r.r,rrrrrr.zGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: rC)5rritelegram.constantsrjr;researchHTMLr0r)r4r5rF MARKDOWN_V2rrktelegram.requestrnrGinforHint_message_thread_id_for_sendr=rrrNrgr]popr>r)ryrrexistsr[ropenr send_photor send_videor send_voice_TELEGRAM_SEND_AUDIO_EXTS send_audio send_documentseekr,rr1r-)&r}rr*rrr,rrirj _has_html formattedsend_parse_moder)_adapterrk _tg_proxyrnrK _proxy_err int_chat_id thread_kwargseffective_thread_id text_kwargslast_msgr.md_errorryplainrrrHrf media_kwargs media_errrir,rs& r r=r=,s U4      000000#6@@AA  4I'nOO $FFFFFF*22?CC$33G<<  $ $ $#  $(3O  @ @ @ @ @ @))*:J\I]^^^II   III   # '999999 \^ghhhc(Ly999(4 9(E(E(E  ' ' 'vyCDDDc&&& '#E"""C'll !'R    FFFFFF&5&Q&Q NN''##    NNc11DDs9~~$##  #.5H 12=))  ;6:K2 3 ??  * ) !B"'i.""3>"" # # # 1::}NNc%))*=>> OO$7>>>%F& +)#2&&7B&&      HH H 3 3 5 555s8}}GZGZG\G\9\9\`fjmnvjwjwj}j}jj``NN`',X66 %(,NNNNNN$/K $:$:EE(,,,$+EEE,!(%F& +%#'&&,7&&      HH G# J%0D )D ) J7>>*-- IZIIw'''((('"":..q17799C< )*d++7"q#' #6#6L5"+--n--;S^.(31..@L..((((((HH!K//-;S^.(31..@L..((((((HH!K//H/-;S^.(31..@L..((((((HH!$===-;S^.(31..@L..((((((HH.?S->.(3a..CO..((((((H% " " "8CC" HXHXYlHmHm"#NN h ,-@ A FF1III(,,-@$GGG"k11.11?2",7q2"2"DP2"2",",",",",",""% !3!31?2",7q2"2"DP2"2",",",",",",""% !3!3!31?2",7q2"2"DP2"2",",",",",",""%(A!A!A1?2",7q2"2"DP2"2",",",",",","2C1B2",7!2"2"GS2"2",",",",",",""A "/7"7"7"7"7"7"7"7"7"7"7"7"7"7"7"p ) ) )./Xz/X/XUV/X/XYY W%%%(((((((( )  WE >!&H===U# #"h122     *!)F:  dddbcccc 4442q22333333334s:Y;0A0/Y;0 A?<Y;>A?? Y; BY; B.+Y;-B..Y;4AC87Y;8 D3'D.)Y;.D33&Y;(FY;.F41Y;3F449Y;.HY; MDML&%M& L52M4L55MY;MBY;4W.W!BR1/W!1 Wd 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,/aiohttp not installed. Run: pip install aiohttprkproxy_kwargs_for_aiohttpz&https://slack.com/api/chat.postMessagerrrr2rT)rr'mrkdwnrrrtsrzSlack API error: unknownzSlack send failed: rC) rr1rrkrrrrrgr]r-rF)r}rr*rrkr_proxy_sess_kw_req_kwrrrpayloadrrris r rHrH 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)rgr2Tr messageIdrzWhatsApp bridge error (): zWhatsApp send failed: ) rr1r]rrrstatusrgr'r-rF) r~rr*rrrrrbodyris r rJrJ#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/accountrkzSignal account not configuredz)Signal media file not found, skipping: %sc*g|]}||zSrCrC).0rdrattachment_pathss r z _send_signal..js9!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 recipient attachments2.0rQsend_jsonrpcmethodparamsrrr /api/v1/rpcrg)rrtimer AsyncClientrraise_for_statusrg) batch_attachments batch_messagerrr2clientrrrrrhttpxs r _postz_send_signal.._postqs!(]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>@rrrrQnotice_rrrz Signal: inline notice failed: %s)rrrrrrFrGrH)r' notice_params_client_errrrs r _send_inline_noticez)_send_signal.._send_inline_notices(/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 rz`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|VdSN)r=)rbs r z_send_signal..s(??1A??????r"rzSignal: every batch (z*) hit rate limit; no attachments deliveredTrrrrr.zSignal send failed: )#rr1#gateway.platforms.signal_rate_limitrrrrrrrrr]rstriprrrr[rGrHrDrr=rstater< estimate_waitacquirer monotonicreport_rpc_durationr-feedbackr,rFjoin)&r~rr*rrrrrrr valid_mediar _is_voice att_batchesrr schedulerfailed_batchesidx att_batchn estimatedrr/_rpc_t0r _rpc_durationerrserver_retry_afterrir.rrrrrrrs& ` @@@@@@r rDrD?s0 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( >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 NNc(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_HOMESERVERrkrMATRIX_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_idrMatrix send failed: )rr1r]rrrrrurandomhex urllib.parser?rwrr%rrputrr'r-rgrF)r}r~rr*rr:txn_idr? encoded_roomrrr_mdrxrrrrris r rPrPMs 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 failedrrrJMedia file not found: rzMatrix media send failed: rTrr)gateway.platforms.matrixrSr1connectr- disconnectrFrrQrr,rrrrr>rsend_image_filerrrrrrr)rrr*rrrSr" connectedrrcrrrris r rBrBysf::::::: 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_URLrkr HASS_TOKENz=Home Assistant not configured (HASS_URL, HASS_TOKEN required)z/api/services/notify/notifyrrrrrr)r*rWrrGzHome Assistant API error (rT homeassistantrzHome Assistant send failed: ) rr1r]rrrrrrrr'r-rF) r}r~rr*rhass_urlrrrrrris r rRrRsL 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)rAr'rerrcodezDingTalk API error: errmsgrTdingtalkrzDingTalk send failed: ) rr1r]rrrrrrgr-rF) r~rr*rrarrrris r rTrTs0 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.)r~r}rr*rNzWeixin send failed: )gateway.platforms.weixinrnror1r~r}rFr-)rrr*rrnroris r r?r?s :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.ruriNz(BlueBubbles: failed to connect to serverzBlueBubbles send failed: T bluebubblesr)gateway.platforms.bluebubblesrrrsr1rrvrWr-rQrr,rXrrF) r~rr*rrrsrvrr"rZrris r rXrXs?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)r*FEISHU_AVAILABLEr,zJFeishu dependencies not installed. Run: pip install 'hermes-agent[feishu]') FEISHU_DOMAIN LARK_DOMAIN _domain_namerlarkrNrTzFeishu send failed: rUrzFeishu media send failed: rTr)r2r*rwrxryr1r8_build_lark_clientrrrQrr-r,rrrrr>rrYrrrrrrrrF)rrr*rrr*rwrxryr" domain_namedomainrrcrrrris r rGrG6sgLLLLLLLL 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>IIIctjdrdSddlm}|dd}|r|dkrdS ddlm}|S#t$rYd SwxYw) 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_TASKTrrrrklocal)is_gateway_runningF)renvironr]rrgateway.statusrrF)rrrs r _check_send_messageros z~~*++t7777778"==HH''t555555!!### uusA AAc K 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} |dddd} d|d} | | | | d{V}|j dvr@| }dd||ddcdddd{VSd |d}| || | d{V}|j dvr@| }dd||ddcdddd{VSd!|d}| || | d{V}|j dvr@| }dd||ddcdddd{VStd"|j d#|j d$|j cdddd{VS#1d{VswxYwYdS#t$r}td%|cYd}~Sd}~wwxYw)&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_IDrk client_secretQQ_CLIENT_SECRETz3QQBot: QQ_APP_ID / QQ_CLIENT_SECRET not configured.rz)https://bots.qq.com/app/getAppAccessToken)appId clientSecretrrzQQBot token request failed: access_tokenz"QQBot: no access_token in responsezQQBot rri)rmsg_typez#https://api.sgroup.qq.com/channels/z /messages)rgrrGTqqbotrrz#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: )rr1r-r~r]rrr}rrr= status_codergrF)rrr*rr~appidsecretr token_resp token_datarrrrrrurl_c2cresp_c2c url_group resp_groupris r rZrZsKR RRRPQQQQQR M RE IIh   =29["#=#=Em3uyy993-r22 MMKLLL21$$R$00/ F/ F/ F/ F/ F/ F/ FF%{{;"5zz3v;;GG +  J%,,UZ=SUUVV/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F$**J%>>.99L ECDD/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F""9,!8!8 2G#*%4%.a@@GKJJJCSwHHHHHHHHD:--yy{{#'W&*hhtnn667/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F>OGNNNG#[[w[PPPPPPPPH#z11}}#'W&*hhtnn66G/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ FNRwQQQI%{{97G{TTTTTTTTJ%33!((#'W&*hhtnn66W/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F^E8HEExOcEElvmCEEFF_/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F/ F` 111/A//000000001s %% L" - 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.r-zYuanbao send failed: )gateway.platforms.yuanbaorrr1r-rF)rr*rrrr"ris r rFrFs?UUUUUUUUU ???=>>>>>?! ""G E   3(('7P[\\\\\\\\\\ 3331a11222222223s* ))A B'A>8B>B)registryr messagingu📨)rZtoolsetschemahandlercheck_fnemojir)NNFFr)NN)L__doc__rIrgloggingrrrr email.utilsr agent.redactr getLoggerrrGcompilerrrrrrr frozensetrrrrrrr IGNORECASEr$r&r=r)rr-rFrr:r?rNSEND_MESSAGE_SCHEMArbr^r_rrrrr$rr;rgr=rHrJrDrLrNrPrBrRrTrVr?rXrGrrZrFtools.registryrrregisterrCr"r rs=  """"""......  8 $ $&BJ'DEEBJfgg2:=>>$"*%MNNBJuvvRZ CDD- 9:::;;"*455888 666 @@@ w $V,!rzWM'BJQM #4C4D4444 y354<2EF'''c''''&  5!( a ! o ! ]  #@LLLk7k7k7\:S:c::::z:::&   3QTW[Q[JVVVVVrssssl44t4444]4]4]4]4@111.4448r2r2r2r2j111B5/5/5/p)2)2)2X9999x:::.444>11162222*777662626262r4E1E1E1P3333<0///////      r"