,jB dZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ej e ZejdZejdZejdZejdZejd Zejd ZeZehd Zejd Zejd ZddiZhdZhdZhdZddhZddhZ ejdej!Z"ejdej!Z#de$fdZ%de$de&fdZ'de(de)de*dzfdZ+d d!d"e)fd#Z,d$d%d&d'gd(d)d*d'd+d,d'd-d,d'd.d,d'd/d,d0gd1d2Z-d3Z.d4Z/dYd6Z0d7Z1d8e$d9e$fd:Z2d;Z3d<Z4d8e$d=e$d>e$dzfd?Z5ddd5d@dAZ6dZdBZ7dCe(de8fdDZ9d[dEZ:d\dFZ;dGZdJZ?dKZ@d]dLZAdMZBdNZCd\dOZDdPZEd]dQZFdRZGdSZHd\dTZIddUlJmKZKmLZLeKjMd$dVe-e.eGdWXdS)^a$Send Message Tool -- cross-channel messaging via platform APIs. Sends a message to a user or channel on any connected messaging platform (Telegram, Discord, Slack). Supports listing available targets and resolving human-friendly channel names to IDs. Works in both CLI and gateway contexts. N) formatdate)redact_sensitive_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*$>smsphotonsignalwhatsappz^\s*\+(\d{7,15})\s*$z6^\s*[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Za-z]{2,}\s*$emailEMAIL_HOME_ADDRESS>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4>.wav.flac.m4a.mp3.ogg.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..IsQWWQZZ2D2D2Dc2|ddS)Nrz=***rr!s r#r$z&_sanitize_error_text..Js!''!**7J7J7Jr%)r_URL_SECRET_QUERY_REsub_GENERIC_SECRET_ASSIGN_RE)textredacteds r#_sanitize_error_textr,FsF$T**H#''(D(DhOOH(,,-J-JHUUH Or%messagec$dt|iS)z9Build a standardized error payload with redacted content.error)r,)r-s r#_errorr0Ns )'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)r1r2r4r*s r#_telegram_retry_delayrBSs#}d33K u[))3// /:&   33  s88>>  Ddi4//t D== $ & & D== D ( ( D==  $ $ D==Q'\""" 4s2AA)attemptsrDc 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 ExceptionrBloggerwarningr,asynciosleep)botrDkwargsr2r1delays r#!_send_telegram_message_with_retryrQls??'' '))33F33333333 3 3 3 ' ' ')#w77E}8a< 7 7 NNX! $S))    -&& & & & & & & & & & & & & '''s* B"A$BB"rHaSend a message to a connected messaging platform, or list available targets. IMPORTANT: When the user asks to send to a specific channel or person (not just a bare platform name), call send_message(action='list') FIRST to see available targets, then send to the correct one. If the user just says a platform name like 'send to telegram', send directly to the home channel without listing first.objectstring)sendlistreactunreactaAction to perform. 'send' (default) sends a message. 'list' returns all available channels/contacts across connected platforms. 'react' attaches an emoji reaction to a message (platforms that support it, e.g. photon/iMessage tapbacks). 'unreact' retracts a previously-added reaction.)typeenum descriptionaDelivery target. Format: 'platform' (uses home channel), 'platform:#channel-name', 'platform:chat_id', or 'platform:chat_id:thread_id' for Telegram topics and Discord threads. Examples: 'telegram', 'telegram:-1001234567890:17585', 'discord:999888777:555444333', 'discord:#bot-home', 'slack:#engineering', 'signal:+155****4567', 'matrix:!roomid:server.org', 'matrix:@user:server.org', 'ntfy:alerts-channel' (explicit ntfy topic), 'yuanbao:direct:' (DM), 'yuanbao:group:' (group chat))rXrZuThe message text to send. To send an image or file, include MEDIA: (e.g. 'MEDIA:/tmp/report.pdf') in the message — the platform will deliver it as a native media attachment.uFor action='react': the emoji to react with (e.g. '❤️'). On iMessage, ❤️👍👎😂‼️❓ render as native tapbacks; other emoji use custom-emoji reactions.zFor action='react'/'unreact': id of the message to react to. Omit to target the most recent message received in that chat (usually the one being replied to).)actiontargetr-emoji message_id)rX propertiesrequired)namerZ parametersc |dd}|dkrtS|dkrt|S|dkrt|dSt|S)z-Handle cross-channel send_message tool calls.r[rTrUrVrWT)remove)get _handle_list _handle_react _handle_send)argskwr[s r#send_message_toolrkso XXh ' 'F ~~ T""" T$////   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_directoryrmjsondumpsrIr0)rmes r#rfrfsLJJJJJJz9&B&B&D&DEFFF LLLz&!Ia!I!IJJKKKKKKKKLs#& A#AAAFc8|dd}|dpd}|dpdpd}|r|s|st|sdndS|dd }|d }t |d kr|d nd}d}|r@t ||\}} } |s* d d lm} | ||} n#t$rd} YnwxYw| p|} d d l m } m }| |}n)#ttf$rtd |cYSwxYw|sR |}||}n#t$rd}YnwxYw|std|d|dS|j}d} d dlm}|}n#t$rd}YnwxYw||j|nd}|td|dS|rdnd}t)||d}t+|std|dS d dlm}|r||||}n|||||}n;#t$r.}t1jt5d|cYd}~Sd}~wwxYwt7|t8rt1j|St1jdt;|iS)uAttach (or with ``remove=True`` retract) an emoji reaction on a message via a live gateway adapter. Only adapters that expose ``add_reaction(chat_id, emoji, message_id)`` / ``remove_reaction(chat_id, message_id)`` coroutines support this (e.g. photon/iMessage tapbacks). Requires the gateway to be running in this process — there is no standalone fallback, since reacting needs the adapter's live message-id state. r\r]r^Nz:Both 'target' and 'emoji' are required when action='react'z*'target' is required when action='unreact':rrresolve_channel_name)Platformload_gateway_configUnknown platform: z.No chat specified and no home channel set for z. Use 'z :chat_id'._gateway_runner_refzReactions require a live zN adapter in the running gateway (not available from cron/standalone contexts).remove_reaction add_reaction Platform 'z%' does not support message reactions. _run_async)chat_idr^)rr]r^zReaction failed: success)restrip tool_errorsplitrAlen_parse_target_refrorwrIgateway.configrxryr?KeyErrorget_home_channelr gateway.runr|adaptersr;callable model_toolsrrprqr0 isinstancedictbool)rirdr\r]r^parts platform_name target_refr _thread_id_rwresolvedrxryplatformconfighomerunnerr|adapterfn_namereact_fnrresultrrs r#rgrgsrXXh # #F XXg   $" + + - -E((<((.B5577?4J  &   > H H=   LLa E!HNN$$**,,M%(ZZ!^^q!!!JG -!2=*!M!MQ - JJJJJJ// zJJ    ,*G@@@@@@@@@8M**  !@@@>}>>?????@   ((**F**844DD   DDD  222%222 , F333333$$&& /5/Afo!!(+++tG E  E E E   $*=~Gw..H H    M M M M    ;******  ZZ@@@FF Z*MMMF ;;;z&!8Q!8!899::::::::;&$"z&!!! :y$v,,/ 0 00sfD## D21D2:E#E43E4:F F)(F)G G.-G.6J K #KK K c 4 )|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}nPtB||"d&}tj d d'|d(|d)|d*iStG|||} | rtj | S|d+kr|r|$d,rz ddl%))fd-}!dd.l&m'}"|"|!|j(|}#|#r|#}ntj d d/|d0iSn0#t$r#}tj d d1|icYd}~Sd}~wwxYw dd.l&m'}"|"tS|||||||2}$|r6tU|$tVr!|$d3r d4|d5|d6|$d7<tU|$tVre|$d3rP|rN dd8l,m-}%dd9l.m/}&|&d:d;}'|&d<n#t$rYnwxYwtU|$tVrd |$vrta|$d |$d <tj |$S#t$r.}tj t#d?|cYd}~Sd}~wwxYw)@z$Send a message to a platform target.r\rtr-z;Both 'target' and 'message' are required when action='send'rurrNFrvr/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)ryrxzFailed to load gateway config: rzweixin WEIXIN_TOKENWEIXIN_ACCOUNT_IDPlatformConfigTWEIXIN_BASE_URLWEIXIN_CDN_BASE_URL) account_idbase_url cdn_base_url)enabledtokenextrarzZ' is not configured. Set up credentials in ~/.hermes/config.yaml or environment variables.)BasePlatformAdapterz[[as_document]]WEIXIN_HOME_CHANNEL) HomeChannelz Weixin Home)rrra _HOME_CHANNELzNo home channel set for zQ to determine where to send the message. Either specify a channel directly with 'z=:CHANNEL_NAME', or set a home channel via: hermes config set z 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 totalr5usersheadersrpokchannelid) ClientSession ClientTimeoutpostrpre)ruser_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  DDrz"Could not open DM with Slack user z#. Check bot permissions (im:write).zFailed to open Slack DM:  thread_id media_filesforce_documentrzSent to z home channel (chat_id: )note)mirror_to_sessionget_session_envHERMES_SESSION_PLATFORMcliHERMES_SESSION_USER_ID) source_labelrrmirroredz Send failed: )1rerrrrArrrorwrprqrItools.interruptrrryrxr0r?r platformsrosgetenvrgateway.platforms.baser extract_mediafilter_media_delivery_paths_describe_media_for_mirrorrrr_HOME_CHANNEL_ENV_OVERRIDESupper_maybe_skip_cron_duplicate_send startswithrrrr_send_to_platformrrgateway.mirrorrgateway.session_contextrr,)*rir\r-rrrrr is_explicitrwrrrryrxrrrrpconfigwx_token wx_accountrrforce_document_attachmentsrcleaned_message mirror_textused_home_channelrwx_homerhome_envduplicate_skiprr dm_channelrrrrrrs* @r#rhrhs 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) AR R?R:4R?:R?B W rWNmatrixz:$ryuanbaogroup:NNFntfyr -!@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_EMAIL_TARGET_RE_PHONE_PLATFORMS_E164_TARGET_RElstripr)rrmatchrrtrimmed split_idxtopics r#rrs "")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$< <    ""  %$$ $ **:66  2##%%tT1 1((())*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.rtrrz[Sent voice message]z[Sent image attachment]z[Sent video attachment]z[Sent audio attachment]z[Sent document attachment]z[Sent z media attachments]) rrpathsplitextrA _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_PLATFORMrt HERMES_CRON_AUTO_DELIVER_CHAT_IDN"HERMES_CRON_AUTO_DELIVER_THREAD_ID)rrr)rrrrA)rrrrs r#_get_cron_auto_delivery_targetr'$s777777BBGGMMOOUUWWHo@"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.NrrrruT#cron_auto_delivery_duplicate_targetzSkipped send_message to z. This cron job will already auto-deliver its final response to that same target. Put the intended user-facing content in your final response instead, or use a different target if you want an additional message.)rskippedreasonr\r)r'r@re)rrr auto_target same_target target_labels r#rr3s022K t J=0 6  I& ' '3w<< 7 6 OOK ( (I 5 t#//g//LI' 7 h| h h h   r%rc"Kt|dr|jnt|}d} ddlm} | }n#t $rd}YnwxYw| |j|} n#t $rd} YnwxYw| i} |r|| d<|dkr|r|| d<| sd} | ||| d{V} n-#tj $rt $r} d d | icYd} ~ Sd} ~ wwxYw| j r d | j d Sd d | j iSd} ddlm}||}n#t $rd}YnwxYw||j |||||||d{V} nJ#tj $rt $r.} t"d|d d d| icYd} ~ Sd} ~ wwxYwt'| t(r,| ds| d r| Sd d|dt+| jiSd d|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. valueNrr{rr publish_topic)rcontentmetadatar/zPlugin platform send failed: T)rr^zAdapter send failed: platform_registryrz$Plugin standalone send for %s raisedexc_infozPlugin standalone send failed: rzPlugin standalone send for 'zR' returned an invalid result: expected a dict with 'success' or 'error' keys, got zNo live adapter for platform 'z'. Is the gateway running with this platform connected? For out-of-process delivery (e.g. cron in a separate process), the platform plugin must register a standalone_sender_fn on its PlatformEntry.)hasattrr0r@rr|rIrrerTrLCancelledErrorrr^r/gateway.platform_registryr5standalone_sender_fnrJdebugrrrX__name__)rrrchunkrrrrrr|rr3rrrentryr5s r#_send_via_adapterr@Rs*'.h&@&@SHNNc(mmM F333333$$&&  o))(33GG   GGG    F6,5H[) F**w*07H_-$#H&||GUU]|^^^^^^^^)    F F F!D!D!DEEEEEEE F~ J#'v7HIIICV\CCD D 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 so= A  A A-- A<;A<8B;;C%C C% C%D$$ D32D3!E""F);#F$F)$F)c $Kddlm}|pg}||jkrt||||d{VSddlm}m} ddlm}  ddl m } d} n#t$rd } YnwxYw dd l m } d}n#t$rd }YnwxYw||jkrZ|rX | | }||}n,#t"$rt$d d YnwxYw|j| r| jnd |j| ji}|r| j||j<||vrI ddlm}||j}|r|jdkr |j||<n#t"$rYnwxYw||}|r(||jkr| nd}||||}n|g}||jkrd}t;t=|dio|jd}tA|D]p\}}|tC|dz k}tE|j#|||r|ng|||d{V}tI|tJr|dr|cS|}q|S||j&krddlm}|d}||j'ddiSd}tA|D]o\}}|tC|dz k}|'|||||r|ngd{V}tI|tJr|dr|cS|}p|S||j(kr|r}d}tA|D]i\}}|tC|dz k}tS||||r|ng|d{V}tI|tJr|dr|cS|}j|S||j*kr|rd}tA|D]m\}}|tC|dz k}tW|j|||r|ngd{V}tI|tJr|dr|cS|}n|S||j,kr}|r{d}tA|D]g\}}|tC|dz k}t[|||r|ndd{V}tI|tJr|dr|cS|}h|S||jkr|r}d}tA|D]i\}}|tC|dz k}t]||||r|nd|d{V}tI|tJr|dr|cS|}j|S|r!|/s dd|jdiSd}|r d|jd}d}|D].}||jkr ta|j#|||d{V}n||j1krte|j||d{V}n||j*krtW|j||d{V}n~||j3krti|j||d{V}nU||j5krtm|j7||d{V}n,||j(kr#tq|j#|j||d{V}n||j9krtu|j||d{V}n||jkrt]||||d{V}n||j;krty|j||d{V}n||j=krt}|j||d{V}na||j?krt|||d{V}n>||j,krt[||d{V}nt|||||||d{V}tI|tJr|dr|cS|}0|rgtI|tJrR|d r=t|d!g}|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)rxrN)r utf16_len) SlackAdapterTelegramAdapterTF) FeishuAdapterzis_lastrrKrKs r#rrs ('''''#K 8?""!'7GUUUUUUUUUUEEEEEEEE444444$>>>>>>" $$$#$"::::::  """!"8>!!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###??????!%%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]*>rE)resolve_proxy_urlTELEGRAM_PROXYzapi.telegram.org) target_hostsN) HTTPXRequestz>send_message: standalone Telegram send routed through proxy %s)proxy)rrequestget_updates_requestzUsend_message: failed to attach Telegram proxy (%s), falling back to direct connection)r1message_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/rKr/rrrrr^rKzGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: rF)5rrtelegram.constantsrrresearchHTMLrOrFrSrTrI MARKDOWN_V2rrtelegram.requestrrJinforKint_message_thread_id_for_sendr@rrrQrrepoprAr,rrrexistsruropenr send_photor send_videor send_voice_TELEGRAM_SEND_AUDIO_EXTS send_audio send_documentseekr/r^rPr0)&rrr-rrrIrrr _has_html formattedsend_parse_moderF_adapterr _tg_proxyrrN _proxy_err int_chat_id thread_kwargseffective_thread_id text_kwargslast_msgrKmd_errorrplainr r!rKr"f media_kwargs media_errrrr/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 aiohttprproxy_kwargs_for_aiohttpz&https://slack.com/api/chat.postMessagerrrr5rT)rr*mrkdwnrJrrrtsrzSlack API error: unknownzSlack send failed: rF) rrPrrrrrrrprer0rI)rrr-rJrrr_proxy_sess_kw_req_kwrrrpayloadrrrrs r#rdrds}L LLLJKKKKL1VVVVVVVV""$$44V<<'6$5e$5$5GYZZ(7(]]1F1FR1F1P1P]T\]] R R R R R R Rah")7dKKG 1'0 $#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 RP$((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 AF1%E3A EE31F%E)E3;F E E3E E3 F3 E==FE=F 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)rpr5Tr messageIdrzWhatsApp bridge error (): zWhatsApp send failed: ) rrPrerrrstatusrpr*r0rI) rrr-rrrrrbodyrrs r#rfrfs?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/accountrtzSignal account not configuredz)Signal media file not found, skipping: %sc*g|]}||zSrFrF).0r~rattachment_pathss r# z _send_signal..s9!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.0rTsend_jsonrpcmethodparamsrrr /api/v1/rpcrp)rrtimer AsyncClientrraise_for_statusrp) batch_attachments batch_messagerrr5clientrrrrrhttpxs r#_postz_send_signal.._posts!(]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>@rrrrTnotice_rrrz Signal: inline notice failed: %s)rrrrrrIrJrK)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..ks(??1A??????r%rzSignal: every batch (z*) hit rate limit; no attachments deliveredTrrrrrKzSignal send failed: )#rrP#gateway.platforms.signal_rate_limitrrrrrrrrrerstriprrrrurJrKrGrr@rstaterZ estimate_waitacquirer monotonicreport_rpc_durationr0feedbackr/rIjoin)&rrr-rrrrrrr valid_mediar  _is_voice att_batchesrr schedulerfailed_batchesidx att_batchn estimatedrr2_rpc_t0r _rpc_durationerrserver_retry_afterrrrKrrrrrrrs& ` @@@@@@r#r`r`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(allrSMTPstarttlssslcreate_default_contextloginrHquitrIr0) rrr-r.r r!passwordr$ smtp_portmsgserverrrs r#rhrh|sNNN((((((ii ""Dbi&D&DGy)2..H +&&J")4Er*J*JI "3U;;<<  "  9- . .kijj1hw11F D 'I 4000F i33 : < <=== Wh'''C    WIII 111/A//000000001s17"BB0/B0 B0E;; F!FF!F!c6K 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/rTWILIO_ACCOUNT_SIDrtTWILIO_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 rruasciiz+https://api.twilio.com/2010-04-01/Accounts/z/Messages.jsonrzBasic r5rrr(r)Body)rrir-zTwilio API error (rsidTrrzSMS send failed: rF)rrPbase64rrrr(DOTALL MULTILINErrrr b64encodeencodedecoderrFormData add_fieldrrprrer@r0rI) auth_tokenrr-rrB account_sid from_numberrrrrrcredsencodedrrr form_datarr error_msgmsg_sidrrs r#rjrjs= 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 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_HOMESERVERrtrMATRIX_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: )rrPrerrr rrurandomhex urllib.parserXrrr(rrputrr*r0rprI)rrrr-rrStxn_idrX encoded_roomrrr_mdrrrrrrrs r#rlrls 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 failedrr3rcMedia file not found: rzMatrix media send failed: rTrr)gateway.platforms.matrixrlrPconnectr0 disconnectrIrrTrr/rrrrrArsend_image_filerrrrrrr^)rrr-rrrlr connectedr3r}r r!r"rrs r#r^r^sf::::::: 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 NNNNcK 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_URLrtzkDingTalk not configured. Set DINGTALK_WEBHOOK_URL env var or webhook_url in dingtalk platform extra config.rrr*r2)rZr*rerrcodezDingTalk API error: errmsgrTdingtalkrzDingTalk send failed: ) rrPrerrrrrrpr0rI) rrr-rrurrrrrs r#rnrn=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.)rrrr-rNzWeixin send failed: )gateway.platforms.weixinrrrPrrrIr0)rrr-rrrrrs r#rMrMws :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: T bluebubblesr)gateway.platforms.bluebubblesrrrPrrrpr0rTrr/rqr^rI) rrr-rrrrrrsrrrs r#rrrrs?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)rGFEISHU_AVAILABLEr/zJFeishu dependencies not installed. Run: pip install 'hermes-agent[feishu]') FEISHU_DOMAIN LARK_DOMAIN _domain_namerlarkrNrmzFeishu send failed: rnrzFeishu media send failed: rTr)rQrGrrrrPr;_build_lark_clientrrrTrr0r/rrrrrArrrrrrrrrr^rI)rrr-rrrGrrrr domain_namedomainr3r}r r!r"rrs r#rcrcsgLLLLLLLL 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_TASKTrrrrtlocal)is_gateway_runningF)renvironrerrgateway.statusrrI)rrrs r#_check_send_messagers 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_IDrt 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)r2msg_typez#https://api.sgroup.qq.com/channels/z /messages)rprr`Tqqbotrrz#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: )rrPr0rrerrrrrr@ status_coderprI)rrr-rrappidsecretr token_resp token_datarrrrrrurl_c2cresp_c2c url_group resp_grouprrs r#rtrtsKR 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.rBzYuanbao send failed: )gateway.platforms.yuanbaorrrPr0rI)rr-rrrrrrs r#rbrbBs?UUUUUUUUU ???=>>>>>?! ""G E   3(('7P[\\\\\\\\\\ 3331a11222222223s* ))A B'A>8B>B)registryr messagingu📨)ratoolsetschemahandlercheck_fnr])Fr)NNFFr)NN)N__doc__rLrploggingrrr3r email.utilsr agent.redactr getLoggerr=rJcompilerr r r rrr  frozensetrrrrrrrrr IGNORECASEr'r)r@r,rr0rIrr=rBrQSEND_MESSAGE_SCHEMArkrfrgrhrrr'rr@rrrr[rdrfr`rhrjrlr^rnrprMrrrcrrtrbtools.registryrrregisterrFr%r#rs  """"""......  8 $ $&BJ'DEEBJfgg2:=>>$"*%MNNBJuvvRZ CDD- 9DDDEE"*4552:WXX '(<=888 666 @@@ w $V,!rzWM'BJQM #4C4D4444 y354<2EF'''c''''&  5!<<< } ! \ ! ] ! J ! %  .3%%P    LLLY1Y1Y1Y1xn7n7n7bBSBcBBBBJ:::&   3QTW[Q[J\\\\\~uuuup44t4444]4]4]4]4@111124448r2r2r2r2j111B5/5/5/p)2)2)2X9999x444>11162222*777662626262r4E1E1E1P3333<0///////      r%