KiSdZddlZddlZddlZddlZddlZddlZejeZ ej dZ ej dZ hdZ hdZhdZdd hZd d d d ddgddd ddd dddgddZdZdZdZdedefdZdZdZded ed!edzfd"Zd6d#Zd6d$Zd%Zd&Zd'Zd(Zd)Z d*Z!d+Z"d,Z#d-Z$d.Z%d/Z&d6d0Z'd1Z(dd2l)m*Z*e*j+d d3eee(d45dS)7a$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. Nz^\s*(-?\d+)(?::(\d+))?\s*$zD^\s*((?:oc|ou|on|chat|open)_[-A-Za-z0-9]+)(?::([-A-Za-z0-9_]+))?\s*$>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4>.m4a.mp3.wav.ogg.opusrr send_messageaSend 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 Telegram topic 'telegram:chat_id:thread_id'. Examples: 'telegram', 'telegram:-1001234567890:17585', 'discord:#bot-home', 'slack:#engineering', 'signal:+15551234567')rrzThe message text to send)actiontargetmessage)r propertiesrequired)namer parametersc t|dd}|dkrtSt|S)z-Handle cross-channel send_message tool calls.rrr)get _handle_list _handle_send)argskwrs 4/home/ubuntu/hermes-agent/tools/send_message_tool.pysend_message_toolr(9s8 XXh ' 'F ~~   c ddlm}tjd|iS#t$r#}tjdd|icYd}~Sd}~wwxYw)z5Return formatted list of available messaging targets.r)format_directory_for_displaytargetserrorz"Failed to load channel directory: N)gateway.channel_directoryr+jsondumps Exception)r+es r'r#r#CsOJJJJJJz9&B&B&D&DEFFF OOOz7$L$L$LMNNNNNNNNOs#& AAAAc|dd}|dd}|r|stjddiS|dd}|d}t |dkr|dnd }d }d }|rt||\}}}nd }|rw|su dd lm } | ||} | rt|| \}}} ntjdd |d |diSn-#t$r tjdd |d |dicYSwxYwddl m } | rtjddiS ddl m} m}| }n0#t$r#}tjdd|icYd }~Sd }~wwxYw|j|j|j|j|j|j|j|j|j|j|j|j|jd }||}|sCd|}tjdd|d|iS|j|}|r|j stjdd|diSddl!m"}|#|\}}|ptI|}d }|sS|%|}|r |j&}d}n2tjdd|d|d|'diStQ|||}|rtj|S dd l)m*}|tW||||||!}|r6tY|tZr!|d"r d#|d$|d%|d&<tY|tZrY|d"rD|rB dd'l.m/}taj1d(d)}||||||*rd|d+<n#t$rYnwxYwtj|S#t$r#}tjdd,|icYd }~Sd }~wwxYw)-z$Send a message to a platform target.rrr-z;Both 'target' and 'message' are required when action='send':rNF)resolve_channel_namezCould 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: ) telegramdiscordslackwhatsappsignalmatrix mattermost homeassistantdingtalkfeishuwecomemailsmsz, 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_sessionHERMES_SESSION_PLATFORMcli) source_labelrLmirroredz Send failed: )2r"r/r0splitstriplowerlen_parse_target_refr.r7r1tools.interruptr8gateway.configr:r;TELEGRAMDISCORDSLACKWHATSAPPSIGNALMATRIX MATTERMOST HOMEASSISTANTDINGTALKFEISHUWECOMEMAILSMSjoinkeys platformsenabledgateway.platforms.baserJ extract_media_describe_media_for_mirrorget_home_channelchat_idupper_maybe_skip_cron_duplicate_send model_toolsrK_send_to_platform isinstancedictgateway.mirrorrQosgetenv) r%rrparts platform_name target_refrrrL is_explicitr7resolved_r8r:r;configr2 platform_mapplatformavailpconfigrJrMcleaned_message mirror_textused_home_channelhomeduplicate_skiprKresultrQrTs r'r$r$LsT XXh # #Fhhy"%%G ddz7$abccc 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;; ;;;     /.....~4z7M2333L@@@@@@@@$$&& LLLz7$Ia$I$IJKKKKKKKKL%#%//)!/%/|L ..H _ ,++--..z7$\$\$\UZ$\$\]^^^""8,,G ]'/]z7%[%[%[%[\]] ]::::::#6#D#DW#M#M K!''))T-G -T-TK  &&x00  lG $  :rMrr;Hrr@M@S@S@U@Urrr  5]GYWWN*z.))):****** #'         ZFD!9!9 Zfjj>S>S ZY YYwYYYF6N fd # #  9(=(= +  <<<<<<!y)BEJJ $$]G[Wcoxyyy.)-F:&    z&!!! :::z7$7A$7$7899999999:stAD!!'E  E 5F F5F0*F50F5 BP>)0PP> P'$P>&P''P>> Q+Q& Q+&Q+r}r~c|dkrGt|}|r+|d|ddfS|dkrGt|}|r+|d|ddfS|dr|ddfSdS) zFParse a tool target into chat_id/thread_id and whether it is explicit.r<r6TrE-N)NNF)_TELEGRAM_TOPIC_TARGET_RE fullmatchgroup_FEISHU_TARGET_RElstripisdigit)r}r~matchs r'rZrZs "")33J??  8;;q>>5;;q>>47 7  !++J77  8;;q>>5;;q>>47 7%%''&4%%  r)c:|sdSt|dkrr|d\}}tj|d}|r |t vrdS|t vrdS|tvrdS|tvrdSdSd t|d S) zJReturn a human-readable mirror summary when a message only contains media.r4r6rz[Sent voice message]z[Sent image attachment]z[Sent video attachment]z[Sent audio attachment]z[Sent document attachment]z[Sent z media attachments]) rYrzpathsplitextrX _VOICE_EXTS _IMAGE_EXTS _VIDEO_EXTS _AUDIO_EXTS)rM media_pathis_voiceexts r'rprps r ;1*1~ Hgz**1-3355  *{**)) +  ,, +  ,, +  ,,++ 9C $$ 9 9 99r)c,tjdd}tjdd}|r|sdStjddpd}|||dS)zMReturn the cron scheduler's auto-delivery target for the current run, if any.!HERMES_CRON_AUTO_DELIVER_PLATFORMr4 HERMES_CRON_AUTO_DELIVER_CHAT_IDN"HERMES_CRON_AUTO_DELIVER_THREAD_IDrrrrL)rzr{rWrXrs r'_get_cron_auto_delivery_targetrsyCCIIKKStI  r)rrrLct}|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.NrrrrLr5T#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.)rNskippedreasonrrP)rstrr")r}rrrL auto_target same_target target_labels r'rtrts022K t J=0 6  I& ' '3w<< 7 6 OOK ( (I 5 t#//g//LI' 7 h| h h h   r)cKddlm}ddlm}ddlm}ddlm} ddlm }  ddl m } d} n#t$rd } YnwxYw|pg}|j |j|j| j|j| ji} | r| j| |j<| |}|r|||}n|g}||j krd }t)|D]n\}}|t+|d z k}t-|j|||r|ng| d {V}t1|t2r|d r|cS|}o|S|r!|s d d|jdiSd }|r d|jd}d }|D]4}||jkrt9|j||d {V}n||jkrt;|j||d {V}n||jkrt?|j ||d {V}n||j!krtE|j ||d {V}n]||j#krtI|j ||d {V}n4||j%krtM|j'||d {V}n ||j(kr#tS|j|j ||d {V}n||j*kr#tW|j|j ||d {V}n||j,kr#t[|j|j ||d {V}n||j.krt_|j ||d {V}nY||jkrta||||d {V}n4||j1krte|j ||d {V}n d d|ji}t1|t2r|d r|cS|}6|rgt1|t2rR|dr=tg|dg}|4|||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)r;rI)TelegramAdapter)DiscordAdapter) SlackAdapter) FeishuAdapterTFNr6)rMrLr-zMsend_message MEDIA delivery is currently only supported for telegram; target z had only media attachmentsz#MEDIA attachments were omitted for zM; native send_message media delivery is currently only supported for telegram)rLz'Direct sending not yet implemented for rNwarnings)5r\r;rnrJgateway.platforms.telegramrgateway.platforms.discordrgateway.platforms.slackrgateway.platforms.feishur ImportErrorr]MAX_MESSAGE_LENGTHr^r_rfr"truncate_message enumeraterY_send_telegramtokenrwrxrWvalue _send_discord _send_slackr`_send_whatsappextrara _send_signalrh _send_emailri _send_smsapi_keyrc_send_mattermostrb _send_matrixrd_send_homeassistantre_send_dingtalk _send_feishurg _send_wecomrappend)rrrrrrLrMr;rJrrrr_feishu_available _MAX_LENGTHSmax_lenchunks last_resultichunkis_lastrwarningrs r'rvrvs('''''::::::::::::888888444444"::::::  """!"#K ?=.; 7L I(5(H X_%x((G$55gwGG8$$$ !&)) ! !HAuCKK!O+G) +2:KK# F&$'' FJJw,?,?   KK 7==?? F".FFF  G  Z(. Z Z Z  K x' ' '(GGGGGGGGFF  ' '&w}guEEEEEEEEFF * * *)'-%HHHHHHHHFF  ( (' wFFFFFFFFFF  ' '&w}guEEEEEEEEFF  % %$W_guEEEEEEEEFF , , ,+GM7='SXYYYYYYYYFF  ( (' w}guUUUUUUUUFF / / /.w}gmWV[\\\\\\\\FF * * *)'-%HHHHHHHHFF  ( ('%9UUUUUUUUUFF  ' '&w}guEEEEEEEEFFYYYZF fd # #  7(;(; MMM +:k400+[__Y5O5O+  B7788   "* J s + ::cK ddlm}ddlm}t t jd|}|r |}|j} nM ddlm } m } | | } | |}n#t$r|}YnwxYw|j} ||} t|}|pg}i}|t||d<d}g}|r | jd"||| d |d{V}n#t$r}d t%|vsFd t%|vs#d t%|vr]t(d | ||s% ddlm } | |}n#t$r|}YnwxYw|}| jd"||dd |d{V}nYd}~nd}~wwxYw|D]\}}t,j|s5d|}t(|||Zt,j|d} t7|d5}|t8vr| jd"||d|d{V}nx|t<vr| jd"||d|d{V}nX|t@vr|r| j!d"||d|d{V}n6|tDvr| j#d"||d|d{V}n| j$d"||d|d{V}dddn #1swxYwYT#t$rB}d|d|}t(%|||Yd}~d}~wwxYw| d}|r||dSd|iSdd|t%|j&d}|r||d<|S#tN$rdd icYSt$r}dd!|icYd}~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 _strip_mdv2)rNmessage_thread_id)rrtext parse_modeparsemarkdownhtmlzFParse mode %s failed in _send_telegram, falling back to plain text: %s)rz Media file not found, skipping: r6rb)rrphoto)rrvideo)rrvoice)rraudio)rrdocumentzFailed to send media z: ANo deliverable text or media remained after processing MEDIA tags)r-rr-Tr<rNrrr message_idrzGpython-telegram-bot not installed. Run: pip install python-telegram-botzTelegram send failed: )(r<rtelegram.constantsrboolresearchHTMLrrr__new__format_messager1 MARKDOWN_V2intrWrrrXloggerrrzrexistsrropenr send_photor send_videor send_voicer send_audio send_documentr-rr)rrrrrMrLrr _has_html formattedsend_parse_moderr_adapterbot int_chat_id thread_kwargslast_msgrmd_errorplainrrrrfr2r-rs r'rrsn7      000000#6@@AA  4I'nOO $SSSSSSSS*22?CC$33G<<  $ $ $#  $(3Oc'll !'R   14YM- . ??    !1!1"'i.""2?""   c(mm113333zS]]EXEXEZEZ7Z7Z^dhklthuhuh{h{h}h}^}^}NN#km|GHHH$(,NNNNNN$/K $:$:EE(,,,$+EEE,!(%5S%5& +%#'&&+8&&      HH  HHHH &%0! )! ) J7>>*-- IZIIw'''((('"":..q17799C )*d++qk)))7*$/q**!&H===U# #"h122     *!)F:  dddbcccc 7775!5566666667s:N%2A21N%2 B>N%BAN%C10N%1 G ;BGFG F$!G#F$$GN%G  BN%#L%3BL L%L L%L L%#N%% M1/7M,&N%,M11 N%?N%!N%%O5 O>O O OcK ddl}n#t$rddicYSwxYw d|d}d|dd }||d  4d{V}|||d |i4d{V}|jdvrM|d{V}dd|jd|icdddd{Vcdddd{VS|d{V} dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdd|| ddS#t$r} dd| icYd} ~ Sd} ~ wwxYw)zSend a single message via Discord REST API (no websocket client needed). Chunking is handled by _send_to_platform() before this is called. rNr-/aiohttp not installed. Run: pip install aiohttpz%https://discord.com/api/v10/channels/z /messageszBot application/json Authorizationz Content-Typetotaltimeoutcontentheadersr/zDiscord API error (): Tr=idrzDiscord send failed: ) aiohttpr ClientSession ClientTimeoutpoststatusrr/r"r1) rrrrrurlrsessionrespbodydatar2s r'rrse L LLLJKKKKL 6HgHHH$25NNDVWW((1F1FR1F1P1P(QQ ) ) ) ) ) ) )U\||C 7?S|TT ) ) ) ) ) ) )X\;j00!%,,,,,,D#%Q4;%Q%Q4%Q%QR ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) "YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  Y7Z^ZbZbcgZhZhiii 66644455555556s >E!D#=2D/D#ED.D# D D# D D#E# D--E0D-1E E)E$E)$E)cK ddl}n#t$rddicYSwxYw d}d|dd}||d  4d{V}|||||d  4d{V}|d{V}|dr>dd||ddcdddd{Vcdddd{VSdd|ddicdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t$r} dd| icYd} ~ Sd} ~ wwxYw)zSend via Slack Web API.rNr-r z&https://slack.com/api/chat.postMessageBearer r r r rr)channelrrokTr>tsrzSlack API error: unknownzSlack send failed: )rrrrrr/r"r1) rrrrrrrr r!r#r2s r'rrsL LLLJKKKKL 46$5e$5$5GYZZ((1F1FR1F1P1P(QQ U U U U U U UU\||C7\c?d?d|ee U U U U U U Uim!YY[[((((((88D>>t'+Wdhdldlmqdrdrss U U U U U U U U U U U U U U U U U U U U U U U U U U U  !STXXgy5Q5Q!S!ST  U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U U 4442q2233333334s :E"E :A D'E E(D'E E' D1 1E 4D1 5E 9E EEEE E:)E5/E:5E:c K ddl}n#t$rddicYSwxYw |dd}|4d{V}|d|d||d |d  4d{V }|jd krX|d{V}dd||ddcdddd{Vcdddd{VS|d{V}dd|jd|icdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t$r} dd| icYd} ~ Sd} ~ wwxYw)z,Send via the local WhatsApp bridge HTTP API.rNr-r  bridge_porti zhttp://localhost:z/send)chatIdrr r)r/rrTr? messageIdrzWhatsApp bridge error (rzWhatsApp send failed: ) rrr"rrrrr/rr1) rrrrrr+r r!r#r"r2s r'rr's9L LLLJKKKKL7ii t44 ((** S S S S S S Sg||6K666 'G<<--B-77$ S S S S S S S S;#%%!%,,,,,,D#'$.#*&*hh{&;&;  S S S S S S S S S S S S S S S S S S S S S S S S S S S"YY[[((((((!Q4;!Q!Q4!Q!QR S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S 7775!5566666667s 0E2:E ?D:EE2-(D:E'E2: E EE E E2 E))E2,E)-E22 F <FF F cK 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| vrdd| dicdddd{VSdd|dcdddd{VS#1d{VswxYwYdS#t$r} dd| icYd} ~ Sd} ~ wwxYw)z!Send via signal-cli JSON-RPC API.rNr-httpx not installedhttp_urlzhttp://127.0.0.1:8080/accountr4zSignal account not configured)r2rzgroup:groupId recipientz2.0rsend_)jsonrpcmethodparamsr>@rz /api/v1/rpcr/zSignal RPC error: Tr@rNrrrzSignal send failed: ) httpxrr"rstrip startswithrtime AsyncClientrraise_for_statusr/r1) rrrrr>r0r2r:payloadclientr!r#r2s r'rrCs0 000.////0599Z)@AAHHMM))Ir** ><= =$99   h ' ' , ' F9  #*)F; 3#dikkD01133   $$T$22 O O O O O O Of%=%=%=GLLLLLLLLD  ! ! # # #99;;D$!Ed7m!E!EF  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 55533344444445sb AE/#A5E/AE1E/E E/ E&&E/)E&*E// F 9F?F F cKddl}ddlm}|dpt jdd}t jdd}|dpt jd d}t t jd d }t|||gsd d iS ||dd} || d<|| d<d| d<|||} | tj | ||| | | dd|dS#t$r} d d| icYd} ~ Sd} ~ wwxYw)z:Send via SMTP (one-shot, no persistent connection needed).rN)MIMETextaddress EMAIL_ADDRESSr4EMAIL_PASSWORD smtp_hostEMAIL_SMTP_HOSTEMAIL_SMTP_PORT587r-zNEmail not configured (EMAIL_ADDRESS, EMAIL_PASSWORD, EMAIL_SMTP_HOST required)rzutf-8FromToz Hermes AgentSubject)contextTrGr=zEmail send failed: )smtplibemail.mime.textrGr"rzr{rallSMTPstarttlssslcreate_default_contextloginrquitr1) rrrrrSrGrHpasswordrK smtp_portmsgserverr2s r'rrgsNNN((((((ii ""Dbi&D&DGy)2..H +&&J")4Er*J*JIBI/7788I 9- . .kijj 4hw11F D 'Ii33 : < <=== Wh'''C    WIII 4442q2233333334s/BE E(E#E(#E(cK 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|}| } |d|}| | d d}d|d} dd|i} | |d4d{V} |} | d|| d|| d || | | | !4d{V} | d{V}| jd"krV|d#t+|}dd$| jd%|icdddd{Vcdddd{VS|d&d}d'd(||d)cdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t,$r}dd*|icYd}~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-r TWILIO_ACCOUNT_SIDr4TWILIO_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 r5asciiz+https://api.twilio.com/2010-04-01/Accounts/z/Messages.jsonr zBasic r rrrOrPBody)r#rirzTwilio API error (rsidTrHrzSMS send failed: )rrbase64rzr{rsubDOTALL MULTILINErW b64encodeencodedecoderrFormData add_fieldrr/rr"rr1) auth_tokenrrrrrg account_sid from_numbercredsencodedrrr  form_datar!r" error_msgmsg_sidr2s r'rrs L LLLJKKKKLMMM)0"55K)1266K uju usttf%ugRYGGGGf\5'CCCGf\5'CCCGfZryAAAGf_b'22GfZ00Gf]Br|DDDGf.w??GfY00GmmooG2----""5<<#8#899@@IIWKWWW"$6W$6$67((1F1FR1F1P1P(QQ g g g g g g gU\((**I    4 4 4   g . . .    0 0 0||Ci|II g g g g g g gT!YY[[((((((;#%% $CII > >I#%U$+%U%U)%U%UV  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 2220Q0011111112s ,A?M+A5M AL7M ML8M M L' 'M*L' +M/M M  MM M M0M+%M0+M0cK ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iS|d }d |d d}||d4d{V}|||||d4d{V} | j dvrM| d{V} dd| j d| icdddd{Vcdddd{VS| d{V} dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdd|| ddS#t$r} dd| icYd} ~ Sd} ~ wwxYw)zSend via Mattermost REST API.rNr-r rMATTERMOST_URLr4r1MATTERMOST_TOKENzEMattermost not configured (MATTERMOST_URL, MATTERMOST_TOKEN required)z /api/v4/postsr%r r r rr) channel_idrrrzMattermost API error (rTrBrrzMattermost send failed: ) rrr"rzr{r?rrrrrr/r1) rrrrrrbase_urlrrr r!r"r#r2s r'rrsL LLLJKKKKL9IIe$$G 2BB(G(GOOPSTT:#5r:: fu fde e((($5e$5$5GYZZ((1F1FR1F1P1P(QQ ) ) ) ) ) ) )U\||Cgbi?j?j|kk ) ) ) ) ) ) )os;j00!%,,,,,,D#%Tdk%T%Td%T%TU ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) "YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  \g]a]e]efj]k]klll 9997A7788888889s AF*:=F*7"E?2E E?F*0E E? E& &E?)E& *E?-F*? F  F* F  F** G4G:GGcK ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iSd t tjd z}|d |d|}d|dd}|| d4d{V} | ||d|d4d{V} | j dvrM| d{V} dd| j d| icdddd{Vcdddd{VS| d{V} dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdd|| ddS#t$r} dd| icYd} ~ Sd} ~ wwxYw) z"Send via Matrix Client-Server API.rNr-r  homeserverMATRIX_HOMESERVERr4r1MATRIX_ACCESS_TOKENzGMatrix not configured (MATRIX_HOMESERVER, MATRIX_ACCESS_TOKEN required)hermes_r7z/_matrix/client/v3/rooms/z/send/m.room.message/r%r r r rrzm.text)msgtyper"rrzMatrix API error (rTrAevent_idrzMatrix send failed: )rrr"rzr{r?rrArrputrrr/r1)rrrrrrr~txn_idrrr r!r"r#r2s r'rrsL LLLJKKKKL5ii --S;NPR1S1S[[\_`` =#8"== h hfg g43ty{{T12244\\g\\TZ\\$5e$5$5GYZZ((1F1FR1F1P1P(QQ ) ) ) ) ) ) )U\{{3(\c>d>d{ee ) ) ) ) ) ) )im;j00!%,,,,,,D#%P$+%P%P$%P%PQ ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) "YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )  X'Y]YaYablYmYmnnn 55533344444445s AG:A(G""F*2F6F*GF5F* F F*F F*G* F44G7F48G G0G+%G0+G0c6K ddl}n#t$rddicYSwxYw |dptjddd}|ptjd d}|r|sdd iS|d }d |d d}||d4d{V}|||||d4d{V} | j dvrM| d{V} dd| j d| icdddd{Vcdddd{VS dddd{Vn#1d{VswxYwYdddd{Vn#1d{VswxYwYdd|dS#t$r} dd| icYd} ~ Sd} ~ wwxYw)z'Send via Home Assistant notify service.rNr-r rHASS_URLr4r1 HASS_TOKENz=Home Assistant not configured (HASS_URL, HASS_TOKEN required)z/api/services/notify/notifyr%r r r rr)rrrrzHome Assistant API error (rTrCr=zHome Assistant send failed: ) rrr"rzr{r?rrrrrr1) rrrrrrhass_urlrrr r!r"r2s r'rrsL LLLJKKKKL=IIe$$A *b(A(AII#NN4<44 ^u ^\] ]666$5e$5$5GYZZ((1F1FR1F1P1P(QQ Z Z Z Z Z Z ZU\||C7^e?f?f|gg Z Z Z Z Z Z Zko;j00!%,,,,,,D#%X$+%X%XRV%X%XY Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z0 Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z Z  _QQQ ===;;;<<<<<<<=s AE=:=E=7"E&2E E&E=1E& E E&E E&E=& E00E=3E04E== FF FFcK ddl}n#t$rddicYSwxYw |dptjdd}|sddiS|d 4d{V}||d d |id d{V}||}|dddkr-dd|ddicdddd{VS dddd{Vn#1d{VswxYwYdd|dS#t$r}dd|icYd}~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_URLr4zkDingTalk not configured. Set DINGTALK_WEBHOOK_URL env var or webhook_url in dingtalk platform extra config.r;rrr)rrr<errcodezDingTalk API error: errmsgr)TrDr=zDingTalk send failed: ) r>rr"rzr{rBrrCr/r1) rrrrr>rrEr!r#r2s r'rrs0 000.////07ii ..W") G!Ev|!E!EF$$&& & & & & & & & & $W\b\mnn$$&& & & & & & & & &'$$&& & & & & & & & & 4442q2233333334sN,,AD8.C'&D C' D'DD D!DD!D!cbK ddlm}m}|sddiSddlm}m}n#t $rddicYSwxYw|pg} ||} t | dd} | dkr|n|} | | | _|rd |ind } d } | r1| ||| d {V} | j s dd | j iS|D]:\}}tj|s dd |icStj|d}|t$vr| ||| d {V} n|t(vr| ||| d {V} np|t,vr!|r| ||| d {V} nF|t0vr| ||| d {V} n| ||| d {V} | j sdd| j icS<| ddiSdd|| jdS#t6$r}dd |icYd }~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_namerElarkrLN)metadatazFeishu send failed: zMedia file not found: r6zFeishu media send failed: rTr)rrrrrrgetattr_build_lark_client_clientrWrrNr-rzrrrrXrsend_image_filerrrrrrrr1)rrrrrMrLrrrrr domain_namedomainrrrrrr2s r'rr;sgLLLLLLLL kij jGGGGGGGGG gggeffffg#K*5-((g~x@@ "-"7"7[!44V<</8BK++d ==?? M ' Wg Q QQQQQQQK& M!K 8I!K!KLL$/ S S J7>>*-- H!F*!F!FGGGG'"":..q17799Ck!!$+$;$;GZZb$;$c$ccccccc  ##$+$6$6w U]$6$^$^^^^^^^  ###$+$6$6w U]$6$^$^^^^^^^  ##$+$6$6w U]$6$^$^^^^^^^ $+$9$9':X`$9$a$aaaaaaa & S!Qk>O!Q!QRRRR S  `a a %0    55533344444445sG ,,BH/H3D H?H H H.H)#H.)H.ctjdd}|r|dkrdS ddlm}|S#t$rYdSwxYw)zOGate send_message on gateway running (always available on messaging platforms).rRr4localTr)is_gateway_runningF)rzr{gateway.statusrr1)rrs r'_check_send_messagertssy2B77HH''t555555!!### uus 1 ??)registry messagingu📨)rtoolsetschemahandlercheck_fnemoji)NN),__doc__r/loggingrzrrXrA getLogger__name__rcompilerrrrrrSEND_MESSAGE_SCHEMAr(r#r$rrZrprrtrvrrrrrrrrrrrrrrtools.registryrregisterrr)r'rs   8 $ $&BJ'DEEBJfgg888 666 777 w   5!( a ! p !9  #@OOOw:w:w:t S c    :::&   3QTW[Q[>llll^v7v7v7v7r666.444&7778!5!5!5H444:222222j99905552===.777>444665656565r   $#####      r)