i,dZddlZddlZddlZddlZddlZddlZddlZddlm Z ej e Z ej dZej dZej dZeZhdZhdZhd Zd d hZej d ejZej d ejZdefdZdedefdZdedededzfdZ dddefdZ!ddddddgdd dd!d"dd#d"d$gd%d&Z"d'Z#d(Z$d)Z%d*ed+efd,Z&d-Z'd.Z(d*ed/ed0edzfd1Z)dJd2Z*dKd4Z+dJd5Z,d6Z-d7Z.d8Z/d9Z0d:Z1d;Z2d<Z3dJd=Z4d>Z5d?Z6d@Z7dLdAZ8dBZ9dJdCZ:dDZ;dEZZ>m?Z?e>j@ddGe"e#e;dHIdS)Ma$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)redact_sensitive_textz^\s*(-?\d+)(?::(\d+))?\s*$zD^\s*((?:oc|ou|on|chat|open)_[-A-Za-z0-9]+)(?::([-A-Za-z0-9_]+))?\s*$zS^\s*((?:wxid|gh|v\d+|wm|wb)_[A-Za-z0-9_-]+|[A-Za-z0-9._-]+@chatroom|filehelper)\s*$>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4>.m4a.mp3.wav.ogg.opusrrzP([?&](?:access_token|api[_-]?key|auth[_-]?token|token|signature|sig)=)([^&#\s]+)zJ\b(access_token|api[_-]?key|auth[_-]?token|signature|sig)\s*=\s*([^\s,;]+)returnct|}td|}td|}|S)zCRedact secrets from error text before surfacing it to users/models.c2|ddS)Nz***groupms ?/home/agentuser/.hermes/hermes-agent/tools/send_message_tool.pyz&_sanitize_error_text..*sQWWQZZ2D2D2Dc2|ddS)Nrz=***rrs rrz&_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 Ormessagec$dt|iS)z9Build a standardized error payload with redacted content.error)r$)r%s r_errorr(/s )'22 33rexcattemptcRt|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*r,r"s r_telegram_retry_delayr:4s#}d33K u[))3// /:&   33  s88>>  Ddi4//t D== $ & & D== D ( ( D==  $ $ D==Q'\""" 4s2AA)attemptsr<c 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)botr<kwargsr*r)delays r!_send_telegram_message_with_retryrIMs??'' '))33F33333333 3 3 3 ' ' ')#w77E}8a< 7 7 NNX! $S))    -&& & & & & & & & & & & & & '''s* B"A$BB"r@aSend a message to a connected messaging platform, or list available targets. IMPORTANT: When the user asks to send to a specific channel or person (not just a bare platform name), call send_message(action='list') FIRST to see available targets, then send to the correct one. If the user just says a platform name like 'send to telegram', send directly to the home channel without listing first.objectstringsendlistzAction to perform. 'send' (default) sends a message. 'list' returns all available channels/contacts across connected platforms.)typeenum descriptiona~Delivery target. Format: 'platform' (uses home channel), 'platform:#channel-name', 'platform:chat_id', or 'platform:chat_id:thread_id' for Telegram topics and Discord threads. Examples: 'telegram', 'telegram:-1001234567890:17585', 'discord:999888777:555444333', 'discord:#bot-home', 'slack:#engineering', 'signal:+155****4567', 'matrix:!roomid:server.org', 'matrix:@user:server.org')rNrPzThe message text to send)actiontargetr%)rN propertiesrequired)namerP parametersc t|dd}|dkrtSt|S)z-Handle cross-channel send_message tool calls.rQrLrM)get _handle_list _handle_send)argskwrQs rsend_message_toolr]s8 XXh ' 'F ~~   rc 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_directoryr_jsondumpsrAr()r_es rrYrYsLJJJJJJz9&B&B&D&DEFFF LLLz&!Ia!I!IJJKKKKKKKKLs#& A#AAAc  |dd}|dd}|r|stdS|dd}|d}t |dkr|dnd}d}d}|rt ||\}}}nd }|rw|su dd lm} | ||} | rt || \}}} ntj d d |d |diSn-#t$r tj d d |d |dicYSwxYwddl m } | rtdS ddlm} m}| }n;#t$r.}tj t#d|cYd}~Sd}~wwxYwid|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd |jd!|jd"|j d#|j!d$|j"}||}|sz$Send a message to a platform target.rRr%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: telegramdiscordslackwhatsappsignal bluebubblesqqbotmatrix mattermost homeassistantdingtalkfeishuwecomwecom_callbackweixinemailsmsz, zUnknown platform: z . Available: z Platform 'zZ' is not configured. Set up credentials in ~/.hermes/config.yaml or environment variables.)BasePlatformAdapterTzNo home channel set for zQ to determine where to send the message. Either specify a channel directly with 'z=:CHANNEL_NAME', or set a home channel via: hermes config set z_HOME_CHANNEL ) _run_async) thread_id media_filessuccesszSent to z home channel (chat_id: )note)mirror_to_sessionget_session_envHERMES_SESSION_PLATFORMcli) source_labelrmirroredz Send failed: )9rX tool_errorsplitstripr9len_parse_target_refrarhrbrcrAtools.interruptrigateway.configrkrlr(TELEGRAMDISCORDSLACKWHATSAPPSIGNAL BLUEBUBBLESQQBOTMATRIX MATTERMOST HOMEASSISTANTDINGTALKFEISHUWECOMWECOM_CALLBACKWEIXINEMAILSMSjoinkeys platformsenabledgateway.platforms.baser~ extract_media_describe_media_for_mirrorget_home_channelchat_idupper_maybe_skip_cron_duplicate_send model_toolsr_send_to_platform isinstancedictgateway.mirrorrgateway.session_contextrr$)!r[rRr%parts platform_name target_refrr is_explicitrhresolved_rirkrlconfigrd platform_mapplatformavailpconfigr~rcleaned_message mirror_textused_home_channelhomeduplicate_skiprresultrrrs! rrZrZs" XXh # #Fhhy"%%G YYWXXX LLa E!HNN$$**,,M%(ZZ!^^q!!!JGI*;M:*V*V'KK +  F F F F F F++M:FFH (9-(R(R%AAzQ:QQMQQQ#%&    :;z;; ;;;     /.....~)-(((I@@@@@@@@$$&& IIIz&!F1!F!FGGHHHHHHHHIH%8#  H%  (/  x+   (/ h) / H% (/  (1 (/ !" x|#L& ..H T ,++--..R}RR5RRSSS""8,,G R'/RQ}QQQRR R::::::#6#D#DW#M#M K!''))T-G -T-TK  &&x00  lG $  :rMrr;Hrr@M@S@S@U@Urrr  5]GYWWN*z.)))7****** #'         ZFD!9!9 Zfjj>S>S ZY YYwYYYF6N fd # #  9(=(= +  <<<<<<CCCCCC./H%PP $$]G[Wcoxyyy.)-F:&     fd # # D6(9(926'?CCF7Oz&!!! 777z&!4!4!455666666667suAD'EE'E:: F2#F-'F2-F2BR-P?>R? Q  R Q  AR S #SS S rrc |dkrGt|}|r+|d|ddfS|dkrGt|}|r+|d|ddfS|dkrGt|}|r+|d|ddfS|dkr4t |}|r|dddfS|d r|ddfS|d kr/|d s|d r|ddfSd S)zFParse a tool target into chat_id/thread_id and whether it is explicit.rmrr2Trxrnr{N-rt!@NNF) _TELEGRAM_TOPIC_TARGET_RE fullmatchr_FEISHU_TARGET_RE_NUMERIC_TOPIC_RE_WEIXIN_TARGET_RElstripisdigit startswith)rrmatchs rrrs "")33J??  8;;q>>5;;q>>47 7  !++J77  8;;q>>5;;q>>47 7 !!!++J77  8;;q>>5;;q>>47 7  !++J77  .;;q>>4- -%%''&4%%  j&;&;C&@&@ JDYDYZ]D^D^ 4%%  rc:|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.rfrrz[Sent voice message]z[Sent image attachment]z[Sent video attachment]z[Sent audio attachment]z[Sent document attachment]z[Sent z media attachments]) rospathsplitextr9 _VOICE_EXTS _IMAGE_EXTS _VIDEO_EXTS _AUDIO_EXTS)r media_pathis_voiceexts rrr-s r ;1*1~ Hgz**1-3355  *{**)) +  ,, +  ,, +  ,,++ 9C $$ 9 9 99rc,tjdd}tjdd}|r|sdStjddpd}|||dS)zMReturn the cron scheduler's auto-delivery target for the current run, if any.!HERMES_CRON_AUTO_DELIVER_PLATFORMrf HERMES_CRON_AUTO_DELIVER_CHAT_IDN"HERMES_CRON_AUTO_DELIVER_THREAD_IDrrr)rgetenvrr9rs r_get_cron_auto_delivery_targetr@syCCIIKKStI  rrrct}|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.NrrrrgT#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.)rskippedreasonrRr)rr8rX)rrr auto_target same_target target_labels rrrNs022K t J=0 6  I& ' '3w<< 7 6 OOK ( (I 5 t#//g//LI' 7 h| h h h   rc l Kddlm}ddlm}m}ddlm} ddlm}  ddl m } d} n#t$rd} YnwxYw dd l m } d}n#t$rd}YnwxYw|pg}||jkrZ|rX | | }||}n,#t"$rt$d d YnwxYw|j| r| jnd |j| j|j| ji}|r| j||j<||}|r(||jkr|nd }||||}n|g}||jkrd }t5t7|dio|jd}t;|D]o\}}|t=|dz k}t?|j |||r|ng||d {V}tC|tDr|dr|cS|}p|S||j#krtI||||d {VS||jkrd }t;|D]n\}}|t=|dz k}tK|j |||r|ng|d {V}tC|tDr|dr|cS|}o|S||j&kr|r}d }t;|D]i\}}|t=|dz k}tO||||r|ng|d {V}tC|tDr|dr|cS|}j|S|r!|(s dd|j)diSd }|r d|j)d}d }|D]W}||jkrtU|j ||d {V}n||j+krtY|j||d {V}n||j-krt]|j||d {V}n||j/krta|j||d {V}n||j1krte|j3||d {V}nW||j4kr$tk|j |j||d {V}n(||j&kr#tm|j |j||d {V}n||j7kr#tq|j |j||d {V}n||j9krtu|j||d {V}n||jkrtw||||d {V}n||j<krt{|j||d {V}nW||j>krt|j||d {V}n/||j@krt|||d {V}n dd|j)i}tC|tDr|dr|cS|}Y|rgtC|tDrR|dr=t|dg}|C|||d<|S)aRoute a message to the appropriate platform sender. Long messages are automatically chunked to fit within platform limits using the same smart-splitting algorithm as the gateway adapters (preserves code-block boundaries, adds part indicators). r)rl)r~ utf16_len)DiscordAdapter) SlackAdapterTelegramAdapterTF) FeishuAdapterz>>>>>" $$$#$"::::::  """!"#K8>!!g! h(00>>M#227;;GG h h h LLWbfL g g g g g h AT^?==Z^.; 7L I(5(H X_% x((G'8+<<<))$$55gww5WW8$$$ $WWgr%B%B%qw}GXGXYpGqGq r r!&)) ! !HAuCKK!O+G) +2:KK#&; F&$'' FJJw,?,?   KK8?""!'7GUUUUUUUUUU8### !&)) ! !HAuCKK!O+G( +2:KK# F&$'' FJJw,?,?   KK8?""{" !&)) ! !HAuCKK!O+G3+2:KK# F&$'' FJJw,?,?   KK 7==?? F".FFF  G  w(. w w w  K   x~ % %&w}guEEEEEEEEFF * * *)'-%HHHHHHHHFF  ( (' wFFFFFFFFFF  ' '&w}guEEEEEEEEFF  % %$W_guEEEEEEEEFF , , ,+GM7='SXYYYYYYYYFF  ( (' w}guUUUUUUUUFF / / /.w}gmWV[\\\\\\\\FF * * *)'-%HHHHHHHHFF  ( ('%9UUUUUUUUUFF  ' '&w}guEEEEEEEEFF - - -,W]GUKKKKKKKKFF  ' '&w????????FFYYYZF fd # #  7(;(; MMM +:k400+[__Y5O5O+  B7788   "* J s/' 66A AA'*B&B;:B;FcK ddlm}ddlm}t t jd|}|r |} |j} nK ddlm } | | } | |} n#t$r|} YnwxYw|j } ||} t|}|pg}i}|t||d<|rd |d <d}g}| r t!| f|| | d |d{V}n#t$r}d t#|vsFd t#|vs#dt#|vrjt&d| t+||s% ddlm}|| }n#t$r|}YnwxYw|}t!| f||dd |d{V}nYd}~nd}~wwxYw|D]\}}t.j|s5d|}t&|||Zt.j|d} t9|d5}|t:vr| jd#||d|d{V}nx|t>vr| j d#||d|d{V}nX|tBvr|r| j"d#||d|d{V}n6|tFvr| j$d#||d|d{V}n| j%d#||d|d{V}dddn #1swxYwYT#t$rO}t+d|d|}t&&|||Yd}~d}~wwxYw| d}|r||dSd|iSd d|t#|j'd}|r||d <|S#tP$rdd!icYSt$r}tSd"|cYd}~Sd}~wwxYw)$uDSend via Telegram Bot API (one-shot, no polling needed). Applies markdown→MarkdownV2 formatting (same as the gateway adapter) so that bold, links, and headers render correctly. If the message already contains HTML tags, it is sent with ``parse_mode='HTML'`` instead, bypassing MarkdownV2 conversion. r)Bot) ParseModez<[a-zA-Z/][^>]*>r)rNmessage_thread_idTdisable_web_page_preview)rr" parse_modeparsemarkdownhtmlzFParse mode %s failed in _send_telegram, falling back to plain text: %s) _strip_mdv2 Media file not found, skipping: rrb)rphoto)rvideo)rvoice)raudio)rdocumentFailed to send media : ANo deliverable text or media remained after processing MEDIA tagsr'rr'rmrrr message_idrzGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: r>)*rmr&telegram.constantsr'rresearchHTMLrrrrrA MARKDOWN_V2intrrIr8r9rBrCr$r.rrexistsrropenr send_photor send_videor send_voicer send_audio send_documentr'r;rr()rrr%rrrr&r' _has_html formattedsend_parse_moder_adapterrF int_chat_id thread_kwargslast_msgrmd_errorr.plainrrrCrfrdr'rs rrrsv4      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 K ddl}n#t$rddicYSwxYw ddlm}m}|d}||\} } |rd|d } nd|d } d d |i} |pg}d} g}|jd&d |d i| 4d{V}|s|si| ddi}|j| f|d|id| 4d{V}|j dvrX| d{V}td|j d|cdddd{Vcdddd{VS| d{V} dddd{Vn#1d{VswxYwY|D] \}}tj|s5d|}t |||Z |}tj|}t+|d5}|d|||j| f| |d| 4d{V}|j dvr| d{V}t/d|d|j d|}t ||| dddd{Vddd]| d{V} dddd{Vn#1d{VswxYwYdddn #1swxYwY#t2$rO}t/d|d|}t |||Yd}~d}~wwxYw dddd{Vn#1d{VswxYwY| d}|r||dSd|iSd d!|| d"d#}|r||d$<|S#t2$r}td%|cYd}~Sd}~wwxYw)'aSend a single message via Discord REST API (no websocket client needed). Chunking is handled by _send_to_platform() before this is called. When thread_id is provided, the message is sent directly to that thread via the /channels/{thread_id}/messages endpoint. Media files are uploaded one-by-one via multipart/form-data after the text message is sent (same pattern as Telegram). rNr'/aiohttp not installed. Run: pip install aiohttpresolve_proxy_urlproxy_kwargs_for_aiohttp DISCORD_PROXY)platform_env_varz%https://discord.com/api/v10/channels/ /messages AuthorizationzBot r-total Content-Typeapplication/jsoncontentheadersrbzDiscord API error (): r/r0zfiles[0])filename)rcdatar6z: Discord API error (r7z6No deliverable text or media remained after processingr9Trnidr:rzDiscord send failed: r>)aiohttprrrVrW ClientSession ClientTimeoutrpoststatusr"r(rbrrrBrBrCrFormDatabasenamerC add_fieldr$r'rArX)rrr%rrrkrVrW_proxy_sess_kw_req_kwurl auth_headers last_datarsessionrcrespbodyr _is_voicerCformrhrRrdr'rs rrrsL LLLJKKKKL<3VVVVVVVV""ODDD44V<<'  MN)NNNCCL'LLLC'8 !'R  (7(]]1F1FR1F1P1P]T\]]! -! -! -! -! -! -! -ah}} 2k 2N\N>;MNN'7<cWIwCWcc[bcc2222222gk{*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,,,,,,,,-' -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -! -F  LE >!&H===U# #!yW\e\i\ijn\o\opp  *!)F:  3331a11222222223s A)O8N?=E <NO!E ;N E NE AN;AL>0L.A1K) L0 L;N=K) L) K3 3L6K3 7L: LL L L LN M,AM'!N'M,,N0O N  ON  OO""O O+O& O+&O+c PK ddl}n#t$rddicYSwxYw ddlm}m}|}||\}}d} d|dd } |jdd |d i|4d{V} ||d d} | j| f| | d|4d{V} | d{V}| dr>d d|| ddcdddd{Vcdddd{VStd| ddcdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t$r}td|cYd}~Sd}~wwxYw)zSend via Slack Web API.rNr'rTrUz&https://slack.com/api/chat.postMessageBearer r`r[r_r-r\r]T)channelr"mrkdwnrbokrotsr:zSlack API error: unknownzSlack send failed: r>) rkrrrVrWrlrmrnrbrXr(rA)rrr%rkrVrWrsrtrurvrcrypayloadrzrirds rr 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'rT bridge_porti zhttp://localhost:z/send)chatIdr%r\r])rbr-reTrp messageIdr:zWhatsApp bridge error (rgzWhatsApp send failed: ) rkrrXrlrnrmrorbr"r(rA) rrr%rkrryrzrir{rds rr 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#cFK ddl}n#t$rddicYSwxYw |ddd}|dd }|sdd iS||d }|d r|d d|d<n|g|d<dd|dt t jdzd}|d4d{V}||d|d{V} | | } d| vr*td| dcdddd{VSdd|dcdddd{VS#1d{VswxYwYdS#t$r} td| cYd} ~ Sd} ~ wwxYw)z!Send via signal-cli JSON-RPC API.rNr'httpx not installedhttp_urlzhttp://127.0.0.1:8080/accountrfzSignal account not configured)rr%zgroup:groupId recipientz2.0rLsend_)jsonrpcmethodparamsrj>@r-z /api/v1/rpcrbzSignal RPC error: TrqrrrzSignal send failed: ) httpxrrXrstriprrAtime AsyncClientrnraise_for_statusrbr(rA) rrr%rrrrrclientrzrirds rr r s0 000.////0299Z)@AAHHMM))Ir** ><= =$99   h ' ' , ' F9  #*)F; 3#dikkD01133   $$T$22 O O O O O O Of%=%=%=GLLLLLLLLD  ! ! # # #99;;D$B4=BBCC  O O O O O O O O O O O O O O $gNN  O O O O O O O O O O O O O O O O O O O O O O O O O O O O O O 2220Q00111111112sb AE:#A5E:A$E'<E:E'E:' E11E:4E15E:: F FF F c"Kddl}ddlm}|dpt jdd}t jdd}|dpt jd d} t t jd d }n#ttf$rd }YnwxYwt|||gsd diS ||dd} || d<|| d<d| d<| ||} | tj | ||| | | dd|dS#t"$r} t%d| cYd} ~ Sd} ~ wwxYw)z:Send via SMTP (one-shot, no persistent connection needed).rN)MIMETextaddress EMAIL_ADDRESSrfEMAIL_PASSWORD smtp_hostEMAIL_SMTP_HOSTEMAIL_SMTP_PORT587iKr'zNEmail not configured (EMAIL_ADDRESS, EMAIL_PASSWORD, EMAIL_SMTP_HOST required)rQzutf-8FromToz Hermes AgentSubject)contextTr|rzEmail send failed: )smtplibemail.mime.textrrXrrrAr7r6allSMTPstarttlssslcreate_default_contextloginr@quitrAr() rrr%rrrpasswordr smtp_portmsgserverrds rrr;sNNN((((((ii ""Dbi&D&DGy)2..H +&&J")4Er*J*JI "3U;;<<  "  9- . .kijj 1hw11F D 'Ii33 : < <=== Wh'''C    WIII 111/A//000000001s17"BB0/B0 BE(( F2F F Fc6K ddl}n#t$rddicYSwxYwddl}tjdd}tjdd}|r|r|sddiSt jd d |t j }t jd d |t j }t jd d |t j }t jdd |t j }t jdd|}t jdd |}t jdd|t j }t jdd |}t jdd|}| } ddl m }m }|} || \} } |d|} | | dd} d|d}dd| i}|jd,d|di| 4d{V}|}|d||d ||d!||j|f||d"| 4d{V}|d{V}|jd#kra|d$t1|}t3d%|jd&|cdddd{Vcdddd{VS|d'd}d(d)||d*cdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t4$r}t3d+|cYd}~Sd}~wwxYw)-zSend a single SMS via Twilio REST API. Uses HTTP Basic auth (Account SID : Auth Token) and form-encoded POST. Chunking is handled by _send_to_platform() before this is called. rNr'rTTWILIO_ACCOUNT_SIDrfTWILIO_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 rUrgasciiz+https://api.twilio.com/2010-04-01/Accounts/z/Messages.jsonr[zBasic r-r\r]rrBody)rircir%zTwilio API error (rgsidTr}r:zSMS send failed: r>)rkrbase64rrr=r DOTALL MULTILINErrrVrW b64encodeencodedecoderlrmrprrrnrbrorXr8r(rA) auth_tokenrr%rkr account_sid from_numberrVrWrsrtrucredsencodedrvrcry form_datarzr{ error_msgmsg_sidrds rrr[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'rTrvMATTERMOST_URLrfrMATTERMOST_TOKENzEMattermost not configured (MATTERMOST_URL, MATTERMOST_TOKEN required)z /api/v4/postsrr`rr\r]r) channel_idr%rbrdzMattermost API error (rgTrurjr:zMattermost send failed: )rkrrXrrrrlrmrnror"r(rbrA) rrrr%rkbase_urlrvrcryrzr{rirds rrrsL LLLJKKKKL6IIe$$G 2BB(G(GOOPSTT:#5r:: fu fde e((($5e$5$5GYZZ((1F1FR1F1P1P(QQ ) ) ) ) ) ) )U\||Cgbi?j?j|kk ) ) ) ) ) ) )os;j00!%,,,,,,D!"Q4;"Q"Q4"Q"QRR ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) "YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  \g]a]e]efj]k]klll 666444555555556s AF5:=F57"F =E'F (F5;E'F ' E1 1F 4E1 5F 8F5 FF5FF55 G?GGGc(K ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iSd t tjd zd tjd }ddl m }||d}|d|d|} d|dd} d|d} ddl } | |ddg} tjdd| } d| d<| | d<n#t$rYnwxYw||d !"4d{V}|| | | #4d{V}|jd$vrX|d{V}t)d%|jd&|cdddd{Vcdddd{VS|d{V}dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYd'd(||d)d*S#t,$r}t)d+|cYd}~Sd}~wwxYw),zSend via Matrix Client-Server API. Converts markdown to HTML for rich rendering in Matrix clients. Falls back to plain text if the ``markdown`` library is not installed. rNr'rT homeserverMATRIX_HOMESERVERrfrMATRIX_ACCESS_TOKENzGMatrix not configured (MATRIX_HOMESERVER, MATRIX_ACCESS_TOKEN required)hermes_rr)quote)safez/_matrix/client/v3/rooms/z/send/m.room.message/rr`rzm.text)msgtyper{ fenced_codetables) extensionsz(.*?)z\1zorg.matrix.custom.htmlformatformatted_bodyr\r]rrbrdzMatrix API error (rgTrtevent_idr:Matrix send failed: )rkrrXrrrrArurandomhex urllib.parserr,r=r rlrmputror"r(rbrA)rrrr%rkrtxn_idr encoded_roomrvrcr_mdr-ryrzr{rirds rrrs 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 failedrmetadatarMedia file not found: rzMatrix media send failed: r8Trtr:)gateway.platforms.matrixrrconnectr( disconnectrArrLrr'rrrBrr9rsend_image_filerrErrFrrHr;)rrr%rrradapter connectedrr!rrrrds rr 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 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'rTrvHASS_URLrfr HASS_TOKENz=Home Assistant not configured (HASS_URL, HASS_TOKEN required)z/api/services/notify/notifyrr`rr\r]r)r%rRrbrdzHome Assistant API error (rgTrvrzHome Assistant send failed: ) rkrrXrrrrlrmrnror"r(rA) rrrr%rkhass_urlrvrcryrzr{rds rrrsL 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_URLrfzkDingTalk not configured. Set DINGTALK_WEBHOOK_URL env var or webhook_url in dingtalk platform extra config.rrr"ra)rr"rerrcodezDingTalk API error: errmsgrTrwrzDingTalk send failed: ) rrrXrrrrnrrbr(rA) rrr%rrrrzrirds rrr*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.weixinr r rrrrAr()rrr%rr r rds rrrds :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.rrNz(BlueBubbles: failed to connect to serverzBlueBubbles send failed: Trrr:)gateway.platforms.bluebubblesrrrrrrr(rLrr'rr;rA) rrr%rrrrrrrrds rrrys?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_namerxlarkrNrzFeishu send failed: rrzFeishu media send failed: r8Tr:)rrrrrrr3_build_lark_client_clientrrLrr(r'rrrBrr9rrrrErrFrrHr;rA)rrr%rrrrrrr domain_namedomainrr!rrrrds rrrsgLLLLLLLL 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).rrrrflocalT)is_gateway_runningF)rrgateway.statusrrA)rrrs r_check_send_messagers7777778"==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_IDrf client_secretQQ_CLIENT_SECRETz3QQBot: QQ_APP_ID / QQ_CLIENT_SECRET not configured.rz)https://bots.qq.com/app/getAppAccessToken)appId clientSecretrrezQQBot token request failed: access_tokenz"QQBot: no access_token in responsezQQBotAccessToken r`rz#https://api.sgroup.qq.com/channels/rZi)ramsg_type)rbrcrdTrsrjr:zQQBot send failed:  )rrr(rrXrrrrrnr8 status_coderbr"rA)rrr%rrappidsecretr token_resp token_datar(rcrvrrzrirds rrrsR 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"D\!C!C 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=rrrAso  ......  8 $ $&BJ'DEEBJfggBJuvv-888 666 777 w !rzWM'BJQM #4C4D4444 y354<2EF'''c''''&  5!( a ! ` !9  #@LLL~7~7~7BSc4:::&   3QTW[Q[>eeeeP~4~4~4~4BK3K3K3K3\111.4448!2!2!2H111@5/5/5/p6660)2)2)2X9999x:::.444>11162222*777662626262r   111111j0///////      r