o;i)2ddlmZ ddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z mZmZmZmZmZejeZhdZhdZ ddlZddlmZmZddlmZd Zn#e$r d ZdZeZeZdZYnwxYwddl Z dd l!m"Z#e j$%de&e#e'(j)d dd l*m+Z+m,Z,ddl-Z-ddl.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>d(dZ?d)dZ@dZAGddZBGdde2ZCd*dZDerbGd d!ejEjFZGGd"d#ejEjFZHGd$d%ejEjFZIGd&d'ejEjFZJdSdS)+) annotationsN) defaultdict)CallableDictListOptionalAnyTuple>`'<>offbulksafe)MessageIntents)commandsTF)Path)PlatformPlatformConfig)MessageDeduplicatorThreadParticipationTracker) BasePlatformAdapter MessageEvent MessageTypeProcessingOutcome SendResultcache_image_from_urlcache_image_from_bytescache_audio_from_urlcache_audio_from_bytescache_document_from_bytesSUPPORTED_DOCUMENT_TYPES) is_safe_urlentrystrreturncX|}|dr=|dr(|dd}|dr |dd}|S)aStrip common prefixes from a Discord user ID or username entry. Users sometimes paste IDs with prefixes like ``user:123``, ``<@123>``, or ``<@!123>`` from Discord's UI or other tools. This normalises the entry to just the bare ID or username. <@><@!zuser:N)strip startswithendswithlstriprstriplower)r's >/home/ubuntu/.hermes/hermes-agent/gateway/platforms/discord.py_clean_discord_idr6@s KKMME 0%.."5"50 U##**3// {{}}((abb  ;;==boolctS)z,Check if Discord dependencies are available.)DISCORD_AVAILABLEr7r5check_discord_requirementsr<Qs r7c tsdSdd}tj|dd |d d |d d |d d S)u|Build Discord ``AllowedMentions`` with safe defaults, overridable via env. Discord bots default to parsing ``@everyone``, ``@here``, role pings, and user pings when ``allowed_mentions`` is unset on the client — any LLM output or echoed user content that contains ``@everyone`` would therefore ping the whole server. We explicitly deny ``@everyone`` and role pings by default and keep user / replied-user pings enabled so normal conversation still works. Override via environment variables (or ``discord.allow_mentions.*`` in config.yaml): DISCORD_ALLOW_MENTION_EVERYONE default false — @everyone + @here DISCORD_ALLOW_MENTION_ROLES default false — @role pings DISCORD_ALLOW_MENTION_USERS default true — @user pings DISCORD_ALLOW_MENTION_REPLIED_USER default true — reply-ping author Nnamer(defaultr8r)ctj|d}|s|S|dvS)Ntrue1yeson)osgetenvr/r4)r>r?raws r5_bz#_build_allowed_mentions.._bksDib!!''))//11 N000r7DISCORD_ALLOW_MENTION_EVERYONEFDISCORD_ALLOW_MENTION_ROLESDISCORD_ALLOW_MENTION_USERST"DISCORD_ALLOW_MENTION_REPLIED_USER)everyonerolesusers replied_user)r>r(r?r8r)r8)r:discordAllowedMentions)rJs r5_build_allowed_mentionsrUVs$ t1111  "4e<<b.66b.55RJJJJJr7cd|_ |jj|jn#t $rYnwxYw|j5|j|j |j |j dddn #1swxYwYt ddS)zStop listening and clean up.FNzVoiceReceiver stopped)r^r\rpremove_socket_listenerrw Exceptionrergclearrhrirbrxryrls r5stopzVoiceReceiver.stops   H 7 7 H H H H    D  Z ' ' M   ! ! !  " ( ( * * * N " " "   $ $ & & &  ' ' ' ' ' ' ' ' ' ' ' ' ' ' '  +,,,,,s$. ;;A%B66B:=B:cd|_dSNTrjrs r5pausezVoiceReceiver.pauses  r7cd|_dS)NFrrs r5resumezVoiceReceiver.resumes  r7rtintuser_idcZ|j5||j|<ddddS#1swxYwYdSN)rerb)rlrtrs r5map_ssrczVoiceReceiver.map_ssrcs{ Z / /'.D t $ / / / / / / / / / / / / / / / / / /s $$c0|j|fd}||_ ddlm}t|dr1|j|ur*||j_t ddSdSdS#t$r&}t d|Yd}~dSd}~wwxYw)aKWrap the voice websocket hook to capture SPEAKING events (op 5). VoiceConnectionState stores the hook as ``conn.hook`` (public attr). It is passed to DiscordVoiceWebSocket on each (re)connect, so we must wrap it on the VoiceConnectionState level AND on the current live websocket instance. cKt|tr|ddkr|di}|d}|d}|rN|rLtd||t |t |r||d{VdSdS)Nopr.drtrz"SPEAKING event: ssrc=%d -> user=%s) isinstancedictgetrxryrr)wsmsgdatartr original_hook receiver_selfs r5 wrapped_hookz:VoiceReceiver._install_speaking_hook..wrapped_hooks#t$$ D!););wwsB''xx''((9--DGDKK DdGTTT!**3t99c'llCCC -#mB,,,,,,,,,,, - -r7r)MISSINGrz)Speaking hook installed on live websocketz%Could not install hook on live ws: %sN) hook discord.utilsrhasattrr_hookrxryr~warning)rlrzrrerrs @@r5ruz$VoiceReceiver._install_speaking_hooks   - - - - - -!  G - - - - - -tT"" Itwg'='= ,  GHHHHH I I'='= G G G NNBA F F F F F F F F F GsAA%% B/BBrrqc  |jr|jrdS|xjdz c_|jdkrXtdt |t |dkr|ddndt |dkrdS|ddz d ks|dd zd kr5|jdkr(td |d|ddS|d}tjd |d\}}}}}||j krdS|dz}t|dz}t|dz} dd|zz|rdndz} t || dzkrdSd} |r,dd|zz} tjd|| d zd} | dz} |jdkrY|j 5|j |d}dddn #1swxYwYtd|||| | t|d| }|| d}t |dkrdStd}|dd|dd<t|dd} ddl}|j|j}|||t|}nM#t*$r@}|jdkr*td|| t |Yd}~dSd}~wwxYw| rt || kr || d}| r|s(|jdkrtd|dS|d}|dks|t |kr7|jdkr*td|t ||dS|d| }|sdS|jr|j 5|j |d}dddn #1swxYwY|r ddl}|j||jj|}nU#t*$rH}dt7|vr-|jdkrtd||Yd}~dSYd}~nd}~wwxYw ||jvr&t:j|j|<|j| |}|j 5|j!|"|tGj$|j%|<ddddS#1swxYwYdS#t*$r'}td||Yd}~dSd}~wwxYw)Nr.z&Raw UDP packet: len=%d, first_bytes=%sshortrrxz*Skipped non-RTP: byte0=0x%02x byte1=0x%02xz>BBHII z>H unknownz9RTP packet: ssrc=%d, seq=%d, user=%s, hdr=%d, ext_data=%dz(NaCl decrypt failed: %s (hdr=%d, enc=%d)z,RTP padding bit set but no payload (ssrc=%d)z;Invalid RTP padding length %d for payload size %d (ssrc=%d) Unencryptedz#DAVE decrypt failed for ssrc=%d: %sz!Opus decode error for SSRC %s: %s)&r^rjrkrxdebuglenhexstruct unpack_fromrar8rerbrrqrf nacl.secretsecretAeadr_decryptr~rr`davey MediaTypeaudior(rirSopusDecoderdecodergextendtime monotonicrh)rlr first_byte_seq timestamprtcc has_extension has_padding header_size ext_data_lenext_preamble_offset ext_words known_userheaderpayload_with_noncenonce encryptednaclbox decryptedrpad_lenrrpcms r5rwzVoiceReceiver._on_packets}    F   A%   #q ( ( LL8D SYY!^^48<<>>>    t99r>> F GqLQ  47T>d":":'1,, I4PQ7TXYZT[\\\ F!W %+%7$%J%J"1c9d 4> ! ! F$ Z$.// :,-- AFmM'@qqqA t99{Q & & F  )"$B- *47JQ7NOOPQRI$q=L  #r ) ) E E!/33D)DD  E E E E E E E E E E E E E E E LLKc:{L    tL[L)**!+,,/ ! " "Q & & F" &rss+bqb ,SbS122      +""4#344C IvuU||DDII   '2--I1k[^_h[i[ijjj FFFFF   1C NN\99!,--0I   +r11NNFmG!||wY77+r11NNUY!)G8),I     : :,00q99 : : : : : : : : : : : : : : :   LLL $ 2 : :!6 !!II!$CFF223r99"NN+PRVXYZZZ32222 4>))'.|';';'='=t$.&--i88C @ @ d#**3////3~/?/?&t, @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @    LLz6VoiceReceiver._infer_user_for_ssrc..sF46>>7>c!$ii76J6J6J6J6Jr7rz4Auto-mapped ssrc=%d -> user=%d (sole allowed member)) r\channeluserrr]membersrrbrxryr~)rlrtr candidatesuidrrs @@r5_infer_user_for_ssrcz"VoiceReceiver._infer_user_for_ssrc}s h&G q)-=TX]%%AF,G%oJ:!## m+."4( RTXZ]^^^ $     D qsBA???*3++DM$'*..tT::::%)?!)CCCM%%dD111*..tT:::) ;  ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;4sE0FF!Fpcm_data output_pathr(src_rate src_channelsctjdd5}|||j}dddn #1swxYwY t jddddd d d t |d t |d |d dd d|gdd tj|dS#t$rYdSwxYw# tj|w#t$rYwwxYwxYw)z-Convert raw PCM to 16kHz mono WAV via ffmpeg.z.pcmF)suffixdeleteNffmpegz-yz -loglevelerrorz-fs16lez-arz-acz-i16000rDTr)checktimeout) tempfileNamedTemporaryFilewriter> subprocessrunr(rGunlinkOSError)rrrrfpcm_paths r5 pcm_to_wavzVoiceReceiver.pcm_to_wavsa (u E E E  GGH   vH                 NdK'3x==3|,,(73       (#####      (####    sTAAA AB6B%% B32B36C8C  C CCCCr)rYrZ)rtrrr)rrq)rtrr)r)r)r)rXr)rrqrr(rrrr)__name__ __module__ __qualname____doc__rrrrrnr{rrrrrurwrr staticmethodrr;r7r5rWrWysKH%%%%%> K K K - - -////GGGJDDDDT4J>?\r7rWceZdZdZdZdZdZdfd Zdd Zdd Z dd Z ddZ ddZ e ddZddZddZddZddZddZdd Zdd!Zdd$Zdd'Z ddd/Zdd1Zd(d2d(d(d3dd8Zd9d:dd=Z dddAZ dd̈fdG ZddIZ ddψfdJ ZddKZ ddNZ!dOZ"ddPZ#ddRZ$ddSZ%ddTZ&ddUZ'ddVZ(ddWZ)dXZ*ddYZ+dd\Z,ddd]Z-ddaZ.ddcZ/ddeZ0ddgZ1 ddވfdi Z2 dd߈fdk Z3 ddfdm Z4 ddfdo Z5 ddfdp Z6dddqZ7ddrZ8ddsZ9ddtZ:dduZ; dddyZdd|Z?dd}Z@ddZAddZB dddZCddZDdddZEdddZFddZGddZHddZIddZJd2ddddZKddZL dddZM dddZN dddZO dddZPddZQddZRdddZSddZTddZUddZVddZWddZXddZYddZZddZ[ddZ\xZ]S(DiscordAdapteraD Discord bot adapter. Handles: - Receiving messages from servers and DMs - Sending responses with Discord markdown - Thread support - Native slash commands (/ask, /reset, /status, /stop) - Button-based exec approvals - Auto-threading for long conversations - Reaction-based feedback iil,configrc t|tjd|_t j|_t|_ t|_ d|_ i|_ i|_ ttjdd|_ttjdd|_i|_i|_i|_i|_i|_i|_i|_d|_d|_t9d|_i|_d|_d|_ tC|_"tG|ddpd|_$|j%j&'dd |_(dS) N'HERMES_DISCORD_TEXT_BATCH_DELAY_SECONDSz0.6-HERMES_DISCORD_TEXT_BATCH_SPLIT_DELAY_SECONDSz2.0rS reply_to_modefirstslash_commandsT))superrnrDISCORD_clientasyncioEvent _ready_eventrZr]_allowed_role_idsgateway_runner_voice_clients _voice_locksfloatrGrH_text_batch_delay_seconds_text_batch_split_delay_seconds_pending_text_batches_pending_text_batch_tasks_voice_text_channels_voice_sources_voice_timeout_tasks_voice_receivers_voice_listen_tasks_voice_input_callback_on_voice_disconnectr_threads _typing_tasks _bot_task_post_connect_taskr_dedupgetattr_reply_to_moderextrar_slash_commands)rlr __class__s r5rnzDiscordAdapter.__init__sb !1222/3 #MOO&)ee&)ee".057).ry9bdi/j/j)k)k&/4RY?npu5v5v/w/w,>@"BD&46!9;=?!:<<> 9="8<!39== 7915:>*++ $+6?G#L#L#WPW%)[%6%:%:;KT%R%Rr7r)r8c Kts"tdjdStjsddl}|j d}|s:d}tj dkr(|D]%}tj |r|}n&|rL tj|n+#t $rtd|YnwxYwtjstd jjs"td jdS d jjd sdStjd d}|r$d|dD_tjdd}|r$d|dD_t3j}d|_d|_d|_t=djDpt?j|_ d|_!ddl"m#}m$} |d} | r!t%dj| j& j&'sj&(d{Vn0#t $r#t)djYnwxYwd_&j*+n%#d_&j*+wxYwtYj-d&d|t]d| | _&j&j/fd} j&j/d'fd } j&j/fd } j0r1tej3j&4jj_5tej6j*7d!"d{Vd_8dS#tdj9$r:td#jd$:YdSt $rB}td%j|d$:Yd}~dSd}~wwxYw)(z.Connect to Discord and start receiving events.z:[%s] discord.py not installed. Run: pip install discord.pyFrNr)z/opt/homebrew/lib/libopus.dylibz/usr/local/lib/libopus.dylibdarwinz)Opus codec found at %s but failed to loadu8Opus codec not found — voice channel playback disabledz[%s] No bot token configuredzdiscord-bot-tokenzDiscord bot tokenDISCORD_ALLOWED_USERSrAcTh|]%}|t|&Sr;)r/r6)rrs r5 z)DiscordAdapter.connect..?s>***/2yy{{*%c*****r7,DISCORD_ALLOWED_ROLESch|]I}|(t|JSr;)r/isdigitr)rrids r5rCz)DiscordAdapter.connect..HsR***),yy{{**,,* $$***r7Tc3@K|]}| VdSr)rG)rr's r5 z)DiscordAdapter.connect..Ys-LLE 'LLLLLLr7)resolve_proxy_urlproxy_kwargs_for_bot DISCORD_PROXYplatform_env_varz [%s] Using proxy for Discord: %sz,[%s] Failed to close previous Discord client!)command_prefixintentsallowed_mentionscKtdjjjd{Vjjr2j sj tj _dS)Nz[%s] Connected as %s)rxryr>r!r_resolve_allowed_usernamesr$rZr8donecancelr" create_task _run_post_connect_initialization) adapter_selfsr5on_readyz(DiscordAdapter.connect..on_readys 2L4E|G[G`aaa#==?????????)--///2=<;Z;_;_;a;a= 3::<<<292E AACC33 ///r7messageDiscordMessagecKjsJ tjjdd{Vn#tj$rYnwxYwjt|j rdS|j j j krdS|j tjjtjjfvrdSt%|j ddrit'jdd}|dkrdS|dkr!j j rj j |jvrdSn4t|j j |j sdSt3|jtjs|jrxj j duoj j |jv}t9fd|jD}|r|sdSt'jd d d v}|r|s|sdS|d{VdS) Ng>@rbotFDISCORD_ALLOW_BOTSnonementionsc3FK|]}|jo|jjkVdSr)r`r!r)rrrls r5rJz=DiscordAdapter.connect..on_message..sH008!t|'8"8000000r7DISCORD_IGNORE_NO_MENTIONrCrCrDrE)r$is_setr"wait_forwait TimeoutErrorr9 is_duplicater(rauthorr!rtyperSrr?replyr:rGrHr4r/rc_is_allowed_userrr DMChannelany_handle_message)r\ allow_bots_self_mentioned_other_bots_mentioned_ignore_no_mentionrZrls r5 on_messagez*DiscordAdapter.connect..on_messages $07799%.|/H/M/M/O/OY]^^^^^^^^^^^"/ &33C OODDF>T\%666F<(;(CWEXE^'___F7>5%88 !#+?!H!H!N!N!P!P!V!V!X!XJ!V++#z11#|0#DL4EWM]4]4]"F  00W^5F1G1GXX"'/73DEE'JZ )5B L-1AA$-00000!(!1000--) -_*,3V**egg!5*6&*/J_**733333333333s3AA$#A$c  Ktj}|sdS|jj}||vrdS|jjkrdS|jduo|jdu}|jduo|jdu}|jduo|jduo|j|jk}|s|s|rft d|j |j|rd|jj zn,|rd|jj znd|jj d|jj |dSdS)z&Track voice channel join/leave events.Nz"Voice state: %s (%d) %s (guild %d)zjoined zleft zmoved z -> ) rZr'rguildrr!rrrxry display_namer>) memberbeforeafter bot_guild_idsguild_idjoinedleftswitchedrZs r5on_voice_state_updatez5DiscordAdapter.connect..on_voice_state_updates`!$L$?$D$D$F$F G G $F!BTWv~':::Sfn&9SSu}?QSS   r7r_z.[%s] Timeout waiting for connection to Discordexc_infoz%[%s] Failed to connect to Discord: %sr;)r\r]);r:rxrr>rSr is_loaded ctypes.utilutil find_librarysysplatformrGpathisfile load_opusr~rrtoken_acquire_platform_lockrHsplitr]r%rr?message_content dm_messagesguild_messagesrqr8r voice_statesgateway.platforms.baserKrLryr! is_closedcloserr$rrBotrUeventr=_register_slash_commandsr"rXr{r7rhrir^rj_release_platform_lock)rlctypes opus_path_homebrew_paths_hp allowed_env roles_envrRrKrL proxy_urlr[rwrrrZs` @r5connectzDiscordAdapter.connects   LLUW[W` a a a5|%%'' [     0088I "#<8++.""7>>#.."(+I!E" [[L**95555 [[[NN#NPYZZZZZ[<))++ [YZZZ{   LL7 C C C5X ../BDKDUWjkk u)$;R@@K **6A6G6G6L6L***& "92>>I **090D0D***&o''G&*G #"&G %)G "LLT5KLLLLL0.// O$(G  W V V V V V V V))?KKKI V > 9UUU|'.<11333"l00222222222 \\\LL!OQUQZ[[[[[\$(DL%++----$(DL%++----#<"!8!:!:'&y11 DL  L\       \ I 4I 4I 4I 4I 4I 4 I 4V\       B# 0--///%01C1CDKDU1V1VWWDN"4#4#9#9#;#;RHHH H H H H H H H DM4#    LLI49_cL d d d  ' ' ) ) )55    LL@$)QY]L ^ ^ ^  ' ' ) ) )55555 so)C %C10C1!Q>DQ8KL#*K?<L#>K??L#!Q#"MD QAS% S%#7S  S%NonecHKt|jD]W} ||d{V#t$r,}t d|j||Yd}~Pd}~wwxYw|jr[ |j d{Vn:#t$r-}t d|j|dYd}~nd}~wwxYw|j rV|j s=|j  |j d{Vn#tj$rYnwxYwd|_d|_|jd|_ |t d|jdS)zDisconnect from Discord.Nz'[%s] Error leaving voice channel %s: %sz [%s] Error during disconnect: %sTrFz[%s] Disconnected)rr'rleave_voice_channelr~rxrr>r!rrr8rVrWr"CancelledErrorr^r$rrry)rlrrs r5 disconnectzDiscordAdapter.disconnectsT0557788 ` `H `..x8888888888 ` ` ` F S[]^________ ` < ` `l((********** ` ` `A49aZ^________ `  " 4+B+G+G+I+I   # * * , , , ---------)       !!!"& ##%%% '33333sAA A>"A99A> B)) C 3#CC  D++D=<D=c XK|jsdS |}|dkr"td|jdS|dkrht j|jjdd{V}td|jt|dSt j| dd{V}td |j|d |d |d |d |d|ddS#t j $r$t d|jYdSt j $rt$r.}t d|j|dYd}~dSd}~wwxYw)zr"rhtreesyncr_safe_sync_slash_commandsrjrrr~)rl sync_policysyncedsummaryrs r5rYz/DiscordAdapter._run_post_connect_initialization1s|  F& ^??AAKe## SUYU^___f$$&/ 0A0F0F0H0HRTUUUUUUUUU PRVR[]`ag]h]hiii$,T-K-K-M-MWZ[[[[[[[[[G KKx   $ " $ " "     #    NNA        %     ^ ^ ^ NN?AX\N ] ] ] ] ] ] ] ] ] ^s+:D1 A,D17A8D11/F)#F);#F$$F)r(cttjddpd}|t vr|S|r!t d|j|dS)NDISCORD_COMMAND_SYNC_POLICYrrAzC[%s] Invalid DISCORD_COMMAND_SYNC_POLICY=%r; falling back to 'safe') r(rGrHr/r4_DISCORD_COMMAND_SYNC_POLICIESrxrr>)rlrIs r5rz/DiscordAdapter._get_discord_command_sync_policy]sz")96BBHbIIOOQQWWYY 0 0 0J   NNU     vr7payloadDict[str, Any]c |d}|d}t|ddpdt|ddpdt|ddpd|dt |d d t |d d |rt d |Dnd|rt d|Dndfd|dgpgDd S)z>Reduce command payloads to the semantic fields Hermes manages.contextsintegration_typesrmrr>rA descriptiondefault_member_permissions dm_permissionTnsfwFc34K|]}t|VdSrrrcs r5rJzCDiscordAdapter._canonicalize_app_command_payload..vs(88!s1vv888888r7Nc34K|]}t|VdSrr)ris r5rJzCDiscordAdapter._canonicalize_app_command_payload..xs(99!s1vv999999r7cdg|],}t|t|-Sr;rr _canonicalize_app_command_optionritemrls r5rzDDiscordAdapter._canonicalize_app_command_payload..zGdD))55d;;r7options) rmr>rrrrrrr)rrr(_normalize_permissionsr8sorted)rlrrrs` r5!_canonicalize_app_command_payloadz0DiscordAdapter._canonicalize_app_command_payloadisj;;z**#KK(;<< FA..3!44 FB//5266w{{="==CDD*.*E*E 899++"'++ot"D"DEEVU3344rArrequiredF autocompletecg|]R}t|tt|ddpd|ddSS)r>rArr>r)rrr(r)rchoices r5rzCDiscordAdapter._canonicalize_app_command_option..sn fd++  62 6 6 <"==#ZZ00r7choices channel_types min_value max_value min_length max_lengthcdg|],}t|t|-Sr;rrs r5rzCDiscordAdapter._canonicalize_app_command_option..rr7r) rmr>rrrrrrrrrr)rrr(r8r)rlrs` r5rz/DiscordAdapter._canonicalize_app_command_optionsd FA..3!44 FB//5266w{{="==CDDW[[U;;<< ^U!C!CDD &kk)R88>B "'++or"B"B"HbII [11 [11!++l33!++l33#KK 266<"'   r7c\||}|d|d|ddS)z;Fields supported by discord.py's edit_global_command route.r>rr)r>rr)r)rlr canonicals r5_patchable_app_command_payloadz-DiscordAdapter._patchable_app_command_payloads<::7CC f%$]3 +   r7Dict[str, int]cK|js dddddddS|jjt|jddp$tt|jdddd}|stdfdD}d |D}d{V}d |D}d}d}d}d} d} |jj} |D]!\} } || d}|"| || d{V| d z } @| |}| |}| | }||kr|d z }| || | krC| ||jd{V| || d{V|d z }| ||j| d{V|d z }#|D](}| ||jd{V| d z } )t#||||| | dS) zHDiff existing global commands and only mutate the commands that changed.r)rrrrrrapplication_idNrrz.s%UUUgGOOD11UUUr7c i|]_}t|ddpdt|ddpdf|`S)rmrr>rA)rrr(r4)rrs r5 z.sr   VQ'',1 - -s7;;vr3J3J3Pb/Q/Q/W/W/Y/Y Z\c   r7c i|]i}ttt|dddt|ddpdt|jpdf|jS)rmNrrrA)rr:r(r>r4)rrs r5rz.s   GGGVT::GWWV\^_E`E`aafefggGL&B''--//     r7r)r!rr: RuntimeError get_commandsfetch_commandshttpitemsrupsert_global_commandrrrdelete_global_commandredit_global_commandvaluesr)rlapp_iddesired_payloadsdesired_by_keyexisting_commandsexisting_by_keyrrrrrrkeydesiredcurrentcurrent_existing_payloadcurrent_payloaddesired_payloadrs @r5rz(DiscordAdapter._safe_sync_slash_commandss8|   | '7>>z''RVR^`fhlJmJmosuyBzBz _]^^ ^UUUUARARATATUUU  +   #'"5"5"7"7777777  -      | *0022  LC%))#t44G00AAAAAAAAA1 '+'H'H'Q'Q $"DDE]^^O"DDWMMO/11Q 223KLLPTPsPst{P|P|||00DDDDDDDDD00AAAAAAAAAQ **67:wGG G G G G G G G qLGG&--//  G,,VWZ@@ @ @ @ @ @ @ @ qLGG)**""    r7r\emojicK|rt|dsdS ||d{VdS#t$r-}td|j||Yd}~dSd}~wwxYw)z+Add an emoji reaction to a Discord message. add_reactionFNTz![%s] add_reaction failed (%s): %s)rr r~rxrr>rlr\r rs r5 _add_reactionzDiscordAdapter._add_reactions gg~>> 5 &&u-- - - - - - - -4    LLr s r5_remove_reactionzDiscordAdapter._remove_reactions gg/@AA  ]a]i]n 5 ))%1BCC C C C C C C C4    LL?EST U U U55555 s&A B "BB cTtjdddvS)z6Check if message reactions are enabled via config/env.DISCORD_REACTIONSrC)false0no)rGrHr4rs r5_reactions_enabledz!DiscordAdapter._reactions_enabled$s'y,f55;;==EYYYr7rrcK|sdS|j}t|dr||dd{VdSdS)z>Add an in-progress reaction for normal Discord message events.Nr 👀)r raw_messagerr)rlrr\s r5on_processing_startz"DiscordAdapter.on_processing_start(sq&&((  F# 7N + + 6$$Wf55 5 5 5 5 5 5 5 5 5 6 6r7outcomercXK|sdS|j}t|drx||dd{V|tjkr||dd{VdS|tjkr ||dd{VdSdSdS)zCSwap the in-progress reaction for a final success/failure reaction.Nr ru✅u❌)rrrrrSUCCESSrFAILURE)rlrrr\s r5on_processing_completez%DiscordAdapter.on_processing_complete0s&&((  F# 7N + + 9''88 8 8 8 8 8 8 8+333((%88888888888-555((%88888888888  9 965r7Nchat_idcontentreply_tometadataOptional[Dict[str, Any]]rcK|jstddS d}|r|dr|d}|rn|jt |}|s-|jt |d{V}|stdd|dSnm|jt |}|s-|jt |d{V}|stdd|dS||r|||d{VS||}| ||j }g} d} |r|j d kr | t |d{V} t| d r| d } n| } n2#t$r%} t d | Yd} ~ nd} ~ wwxYwt%|D]\} }|j d kr| }n | dkr| nd} |||d{V}nv#t$ri} t)| }|Md|vrd|vsd|vrAt d|j|d} ||dd{V}nYd} ~ nd} ~ wwxYw| t)|jtd| r| dndd| iS#t$rK} t d|j| dtdt)| cYd} ~ Sd} ~ wwxYw)u1Send a message to a Discord channel or thread. When metadata contains a thread_id, the message is sent to that thread instead of the parent channel identified by chat_id. Forum channels (type 15) reject direct messages — a thread post is created automatically. F Not connectedsuccessrN thread_idzThread not foundChannel r to_reference)fail_if_not_existsz$Could not fetch reply-to message: %sallr)r" referencezerror code: 50035z Cannot reply to a system messagezerror code: 10008zX[%s] Reply target %s rejected the reply reference; retrying send without reply referenceT message_idsr) message_id raw_responsez'[%s] Failed to send Discord message: %sr)r!rr get_channelr fetch_channel_is_forum_parent_send_to_forumformat_messagetruncate_messageMAX_MESSAGE_LENGTHr; fetch_messagerr-r~rxr enumeratesendr(rr>rrr)rlr!r"r#r$r*r formattedchunksr1r0ref_msgrrchunkchunk_referencererr_texts r5r>zDiscordAdapter.send<s| De?CCC CV ;I 2HLL55 2$[1  [,223y>>BBO$(L$>$>s9~~$N$NNNNNNNG\%e;ZY;Z;Z;Z[[[[\,223w<<@@M$(L$>$>s7||$L$LLLLLLLG[%e;Yg;Y;Y;YZZZZ$$W-- C!00'BBBBBBBBB++G44I**9d6MNNFKI LD/588L$+$9$9#h--$H$HHHHHHHGw77,$+$8$8E$8$R$R $+  LLLLL!GKKKKKKKKL&f--" 0" 05&%//&/OO3466iitO ' %"1!-!!CC!"1vvH'3!4x ? ?$F($R$R2h>>v I$ %) $+LL$)&*%1%%  %0""3sv;;////-8B;q>>d+[9   ; ; ; LLBDIq[_L ` ` `e3q66::: : : : : : : ;sBL,A-L0L AL AGL H)H L H/L>IL K&AK L KAL M-"AM("M-(M- forum_channelc &Kddlm}||}|||j}||}|r|dn|} |||d{V}nR#t $rE} td|j |j | tdd| cYd} ~ Sd} ~ wwxYwt|d r|nt|d d} tt| d t|d d } t|d d} | rtt| d | n| } | g}g}|ddD]} | |d{V}|t|j G#t $rH} d| d| }td|j |||Yd} ~ d} ~ wwxYw|| d}|r||d<td|d|S)aCreate a thread post in a forum channel with the message as starter content. Forum channels (type 15) don't support direct messages. Instead we POST to /channels/{forum_id}/threads with a thread name derived from the first line of the message. Any follow-up chunk failures are reported in ``raw_response['warnings']`` so the caller can surface partial-send issues. r_derive_forum_thread_name)r>r"Nz,[%s] Failed to create forum thread in %s: %sFForum thread creation failed: r(r>threadrrAr\rr"z/Failed to send follow-up chunk to forum thread z: z[%s] %s)r1r*warningsTr2)tools.send_message_toolrHr9r:r; create_threadr~rxrr>rrrr:r(r>rr)rlrEr"rHr?r@ thread_namestarter_contentrJrthread_channelr* starter_msgr3r1rLrBrrr4s r5r8zDiscordAdapter._send_to_forums FEEEEE''00 &&y$2IJJ//88 '->&)); Y(66 '7FF Y Y Y LLGTaTdfg h h he3WTU3W3WXXX X X X X X X Y$+66#:#:_PXZ^@_@_gfdB6O6OPPQQ fi66 CN]SdI>>???T] "l  ABBZ ) )E )*///>>>>>>>>""3sv;;//// ) ) )\I\\YZ\\y$)W===(((((((( ) 8CQZ'['[  0'/L $"1~%    s7A// B>9:B93B>9B>AF G,$>G''G,rA)rOr"filefilesrOrSrTOptional[list]c ,Kddlm}|sj|pd}|s1|t|ddpd}n|rt|dddpd}|r ||nd}d|i}|r||d<|||d <|r||d < |jdi|d{V} n\#t $rO} t d |jt|d d | tdd| cYd} ~ Sd} ~ wwxYwt| dr| nt| dd} tt| d t| d d} t| dd} | rtt| d | n| }td|d| iS)auCreate a forum thread whose starter message carries file attachments. Used by the send_voice / send_image_file / send_document paths when the target channel is a forum (type 15). ``create_thread`` on a ForumChannel accepts the same file/files/content kwargs as ``channel.send``, creating the thread and starter message atomically. rrGrANfilenamezNew Postr>r"rSrTz6[%s] Failed to create forum thread with file in %s: %sr?FrIr(r>rJr\Tr*r2r;) rMrHr/r:rNr~rxrr>rrr()rlrErOr"rSrTrHhintkwargsrJrrQr*rRr3s r5_forum_post_filezDiscordAdapter._forum_post_files: FEEEEE Z=bD::<< C#"4R88>BDDC"58Z<<BD=AZZ\\Y33D999zK"(+!6  ( 'F9   !F6N  $#F7O Y6=6@@@@@@@@@@FF Y Y Y LLH  tS11     e3WTU3W3WXXX X X X X X X Y$+66#:#:_PXZ^@_@_gfdB6O6OPPQQ fi66 CN]SdI>>???T] !%y1    sB## C<-AC71C<7C<F)finalizer3r\cK|jstddS |jt|}|s-|jt|d{V}|t|d{V}||}t||jkr|d|jdz dz}| |d{Vtd| S#t$rL}t d |j ||d tdt|cYd}~Sd}~wwxYw) z'Edit a previously sent Discord message.Fr'r(N...rKTr)r3z*[%s] Failed to edit Discord message %s: %sr)r!rr5rr6r<r9rr;editr~rxrr>r() rlr!r3r"r\rrr?rs r5 edit_messagezDiscordAdapter.edit_messages| De?CCC C ;l..s7||<>>>>>>>C++G44I9~~ 777%&Bt'>'B&BCeK ((9(-- - - - - - - -dzBBB B ; ; ; LLEtyR\^_jnL o o oe3q66::: : : : : : : ;sC,D EAEEE file_pathcaption file_namecK|jstddS|jt|}|s-|jt|d{V}|stdd|dS|pt j|}t|d5}tj ||}| |r>| ||pd | d{VcdddS||r|nd| d{V} dddn #1swxYwYtd t| j S) uSend a local file as a Discord attachment. Forum channels (type 15) get a new thread whose starter message carries the file — they reject direct POST /messages. Fr'r(Nr,r+rbrWrAr"rSTr`)r!rr5rr6rGrbasenameopenrSFiler7r[r/r>r(r) rlr!rcrdrerrWfhrSrs r5_send_file_attachmentz$DiscordAdapter._send_file_attachment1s$| De?CCC C,**3w<<88 E L66s7||DDDDDDDDG Se3Qg3Q3Q3QRRR R; 0 0 ; ; )T " " Vb<X666D$$W-- !22$]11333 V V V V V V V V -IWWTPT UUUUUUUUC V V V V V V V V V V V V V V V$3sv;;????s9AE#!EEEimagesList[Tuple[str, str]] human_delayr)c P K|jsdSsdS ddl}ddl}ddlm}n;#t $r.t |||d{VYdSwxYw |jt|}|s-|j t|d{V}|s#t d|j |dSnc#t $rV} t d|j | t |||d{VYd} ~ dSd} ~ wwxYwdfdtdtD} t!| D]\} } |dkr | dkrt#j|d{Vg} g}d} | D]\}}|r|||dr||d d}t*j|s"t d |j || ||t*j| t5|s!t d |j  ddl}dd lm}m}|d}||\}}| |jd(i|}|j |fd|!di|4d{V }|j"dkrCt d|j |j"|dd dddd{V|#d{V}|j$ dd}d}d|vsd|vrd}n d|vrd}nd|vrd}| ||%|dt| d| dddd{Vn#1d{VswxYwYr#t $r5}t d|j |dd|Yd}~d}~wwxYw| s3 |. |&d{V #t $rYwxYw|r|dnd}t'd |j t| | d!zt| |(|r3|)||pd"*| #d{Vn|+|| #d{Vnw#t $rj} t d$|j | d!zt| | d%&t || ||'d{VYd} ~ nd} ~ wwxYw|. |&d{Vf#t $rYswxYwy#|, |&d{Vw#t $rYwwxYwwxYwdS))aSend a batch of images as a single Discord message with multiple attachments. Discord permits up to 10 file attachments per message. Batches are chunked accordingly. URL images are downloaded into memory and uploaded as inline attachments (same pattern as ``send_image`` so they render inline, not as bare links). Local files are opened directly. On per-chunk failure the remaining images in that chunk fall back to the base per-image loop. Nr)unquotez.[%s] Channel %s not found for multi-image sendz7[%s] Failed to resolve channel for multi-image send: %src*g|]}||zSr;r;)rrCHUNKrps r5rz7DiscordAdapter.send_multiple_images..|s&LLL!&1u9%LLLr7zfile://z[%s] Skipping missing image: %srhz&[%s] Blocked unsafe image URL in batchrKproxy_kwargs_for_aiohttprMrNrrrz4[%s] Failed to download image (HTTP %d) in batch: %sP content-type image/pngpngjpegjpggifwebpimage_.z[%s] Download failed for %s: %sz@[%s] Sending %d image(s) as single Discord message (chunk %d/%d)rrA)r"rTzQ[%s] Multi-image Discord send failed (chunk %d/%d), falling back to per-image: %sTr)rrr;),r!rSio urllib.parsertr~rsend_multiple_imagesr5rr6rxrr>rangerr=r"sleeprr0rGrexistsrlrjr&aiohttprrKry ClientSessionr ClientTimeoutstatusreadheadersBytesIOrryr7r[r/r>)!rlr!rpr$rr _discord_mod_io_unquoterrr@ chunk_idxrBrTcaptionsaiohttp_session image_urlalt_text local_path_aiohttprKry_proxy_sess_kw_req_kwresprctextdl_errr"rvr>s! ` @r5rz#DiscordAdapter.send_multiple_imagesRs |  F  F  * * * *     8 8 8 8 8 8 8   ''..w+VV V V V V V V V FF  l..s7||<->s{{4?P?P[vdghmdndn[v[vqt[v[v->-w-w x x x%yyyyyyyyyyyyyyyyyyyyyyyyyyy& )%%%"NN+LdiYbcfdfcfYgioppp$HHHH%2#.-335555555555$/-*2;(1++t VIs5zz9q=#f++ ((11E//!(B 5 5 7 7#0 ",,we,DDDDDDDDD f f fgIy1}c&kk1! gg227E8Yd2eeeeeeeeeeeeee  f#.-335555555555$/?.-335555555555$/]R R s #4AAA9C D;%A D66D;-DU .AP!A V94W39V>>W3W  W.-W.3X#7XX# X X#X X# audio_pathcxK|jD]\}}t|t|krd||rOtd|j||||d{V}t|cS|j d||d|d{VS)zPlay auto-TTS audio. When the bot is in a voice channel for this chat's guild, play directly in the VC instead of sending as a file attachment. z,[%s] Playing TTS in voice channel (guild=%d)N)r))r!rr;) r.rr(is_in_voice_channelrxryr>play_in_voice_channelr send_voice)rlr!rrZgid text_ch_idr)s r5play_ttszDiscordAdapter.play_ttss $8>>@@ 3 3OC:#g,,..43K3KC3P3P. JDIWZ[[[ $ : :3 K KKKKKKK!'222222$T_VWVVvVVVVVVVVVr7c `K ddl}|jt|}|s-|jt|d{V}|st dd|dSt j|st dd|St j |} t|d5} | } dddn #1swxYwY| |r[tj|| | } |||pd | d{VS ddl} d } dd lm}||}|jj}n0#t.$r#t1dt3| dz }YnwxYwt5dgdz}| |}ddl}|dddt?|d|dgd}d|dd| dddg}|jj !tj "dd|j#| d{V}t d!tI|d"#S#t.$r}tJ&d$|tj|| | }|'|%d{V}t d!tI|j##cYd}~Sd}~wwxYw#t.$rY}tJ(d&|j)|d!'tU+|||||(d{VcYd}~Sd}~wwxYw))z(Send audio as a Discord file attachment.rNFr,r+r(zAudio file not found: rgrhrArig@)OggOpus?g@@i rzvoice-message.oggr)rrW duration_secswaveform)flags attachments payload_jsonrzfiles[0]z audio/ogg)r>rrW content_typePOSTz/channels/{channel_id}/messages channel_id)formTrr`z3Voice message flag failed, falling back to file: %s)rSz;[%s] Failed to send audio, falling back to base adapter: %srr$),rr!r5rr6rrGrrrjrkrr7rSrlrr[r/base64mutagen.oggopusrrylengthr~maxrrq b64encoderjsondumpsroundrrequestRouterr(rxrr>rr>rr)rlr!rrdr#r$rZrrrWr  file_data forum_filerrrrywaveform_bytes waveform_b64_jsonrrmsg_data voice_errrSrrr>s r5rzDiscordAdapter.send_voicesK g IIIl..s7||<>*-- ^!%7\PZ7\7\]]]]w'' 33Hj$'' %1FFHH  % % % % % % % % % % % % % % %$$W-- $\"**Y*?*?(SSS !22$]1133#3* H # F777777"7:..D$(I$4MM FFF$'S^^f-D$E$EMMMF"'us{!3!3%//??FFHH $$$$++!!$7).}a)@)@$0 %%$'',g>> *!*$7(3 "&!2!:!:L&&v/P]d]g&hh";"""$3x~;N;NOOOO H H H RT]^^^|BJJy$9$9HMMM#LLdL33333333!$3sv;;GGGGGGGGG  H  g g g LLVX\XacdosL t t t++GZ(]e+ffffffff f f f f f f gsA0M 62M )/M C9- M 9C==M C=A2M 5J0<FJ0*GJ0GC(J00 M:BM<M=M MM N-AN("N-(N-cK|jrtsdS|jj}|j|t j4d{V|j |}|r| r|j j|jkr)| | dddd{VdS| |d{V| | dddd{VdS|d{V}||j|<| | t||j}|||j|<t j|||j|<n2#t,$r%}t.d|Yd}~nd}~wwxYw dddd{VdS#1d{VswxYwYdS)z6Join a Discord voice channel. Returns True on success.FNT)rYz"Voice receiver failed to start: %s)r!r:ryrr( setdefaultr"rdr'r is_connectedr_reset_voice_timeoutmove_torrWr]r{r1 ensure_future_voice_listen_loopr2r~rxr)rlrrexistingvcreceiverrs r5join_voice_channelz!DiscordAdapter.join_voice_channel?s"| #4 5=#$//',..II        *..x88H H1133 #&'*44--h777               &&w/////////))(333              ((((((((B,.D  )  % %h / / / H(d>TUUU   2:%h/5<5J++H5566(22 H H HCQGGGGGGGG H5                              sJAG(1G(9G(>A#F"!G(" G,G G( GG(( G25G2rrcK|j|tj4d{V|j|d}|r||j|d}|r||j |d}|r.| r| d{V|j |d}|r||j |d|j|ddddd{VdS#1d{VswxYwYdS)z-Disconnect from the voice channel in a guild.N)r(rr"rdr1rrr2rWr'rrr0r.r/)rlrr listen_taskrtasks r5rz"DiscordAdapter.leave_voice_channelas$//',..II 4 4 4 4 4 4 4 4,004@@H  266xFFK %""$$$$((488B &boo'' &mmoo%%%%%%%,004@@D   % ) )(D 9 9 9   # #Hd 3 3 3! 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4sDE E'*E'rc K|j|}|r|sdS|j|}|r| t j}|r|t j|z |jkr/t d| n.tj dd{V||tjtj  fd}t!j|}t!j|d}||| tj|j d{VnI#tj$r7t d |j| YnwxYw|| |r|d Sd S#|r|wwxYw) z2Play an audio file in the connected voice channel.Fz1Timed out waiting for previous playback to finishg?Ncv|rtd|jdS)NzVoice playback error: %s)rxrcall_soon_threadsaferZ)rrVloops r5_afterz4DiscordAdapter.play_in_voice_channel.._afters=DLL!;UCCC))$(33333r7r)volume)r}r_z"Voice playback timed out after %dsT)r'rrr1rrr is_playingPLAYBACK_TIMEOUTrxrrr"rr#get_running_looprSFFmpegPCMAudioPCMVolumeTransformerplayrhrirjrr) rlrrrr wait_startrsourcerVrs @@r5rz$DiscordAdapter.play_in_voice_channelxs\  $ $X . . ** 5(,,X66   NN    "))J--// )>##j043HHHNN#VWWWGGIIImC((((((((( --// )=??D+--D 4 4 4 4 4 4 +J77F1&EEEF GGF&G ) ) ) &tyy{{D)rlrrchs r5rz%DiscordAdapter._voice_timeout_handlers - 233 3 3 3 3 3 3 3 3%    FF .228<< &&x000000000  $   ))#j//::::      $, ))*55B ''"LMMMMMMMMMMM DD       s0$779"B B)(B)C// C=<C=cf|j|}|duo|S)z?Check if the bot is connected to a voice channel in this guild.N)r'rr)rlrrs r5rz"DiscordAdapter.is_in_voice_channels1  $ $X . .~3"//"3"33r7c|j|}|r|sdS|j}|sdSg}|jr |jjnd}|jD]=}|r|j|jkr||j|j |j d>t}|j |}|rtj} |j5|jD]?\} } | | z dkr1|j| } | r|| @ dddn #1swxYwY|D]} | d|v| d<|jt+||t+|dS)aReturn voice channel awareness info for the given guild. Returns None if the bot is not in a voice channel. Otherwise returns a dict with channel name, member list, count, and currently-speaking user IDs (from SSRC mapping). N)rrzis_botg@r is_speaking) channel_name member_countrspeaking_count)r'rrrr!rrrrrzr`rZr1rrrerhrrbaddr>r)rlrrr members_infobot_userrspeaking_user_idsrrrtlast_trrys r5get_voice_channel_infoz%DiscordAdapter.get_voice_channel_infos  $ $X . . ** 4* 4 (, >4<$$$  A ADHK//   4 !%!!    "%(,,X66  7.""C 7 7$,$>$D$D$F$F77LD&V|c))&488>>7-11#666 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7! G GD"&y/5F"FD  $L --#!"344    sAEE  E c||}|sdSd|dd|ddg}|dD].}|drd nd}|d |d |/d |S) zReturn a human-readable voice channel context string. Suitable for injection into the system/ephemeral prompt so the agent is always aware of voice channel state. rAz[Voice channel: #r — rz participant(s)]rrz (speaking)z - rz )rrjoin)rlrrypartsrrs r5get_voice_channel_contextz(DiscordAdapter.get_voice_channel_contexts **844 2fT.%9ff^@Tfffgi = =A&' &6>]]BF LL;. 1;6;; < < < <yyr7rcK|j|}|sdStj} |jrt jdd{Vtj}||z |jkr^|} |j|}|r.| r|j dn#t$rYnwxYw| }|D]E\}}|t|s(||||d{VF|jdSdS#t j$rYdSt$r(} t$d| dYd} ~ dSd} ~ wwxYw)z=Periodically check for completed utterances and process them.Ng?szVoice listen loop error: %sTr)r1rrrr^r"r_KEEPALIVE_INTERVALr'rrp send_packetr~rror(_process_voice_inputrrxr) rlrrlast_keepaliverrrrrrs r5rz!DiscordAdapter._voice_listen_loops(,,X66  F)) J# QmC(((((((((n&&'4+CCC%(N!044X>>H"//"3"3HN66GGG$%2244 )2QQ%GX00W>>! 33HgxPPPPPPPPPP'# Q Q Q Q Q(%    DD J J J LL6DL I I I I I I I I I JsDAD<:A CD< CD<CA&D<<E? E?E::E?rrqcKddlm}tjddd}|j}| t jtj ||d{Vddl m }t j||d{V}| d s) tj|dS#t$rYdSwxYw| d d } | r || r) tj|dS#t$rYdSwxYwt"d || dd |jr|||| d{Vn4#t($r'} t"d| dYd} ~ nd} ~ wwxYw tj|dS#t$rYdSwxYw# tj|w#t$rYwwxYwxYw)z&Convert PCM -> WAV -> STT -> callback.r)is_whisper_hallucination.wav vc_listen_F)rprefixrN)transcribe_audior) transcriptrAzVoice input from user %d: %sd)rrrz!Voice input processing failed: %sTr)tools.voice_moder rrr>rr" to_threadrWrtools.transcription_toolsrrrGr r r/rxryr3r~r) rlrrrr tmp_fwav_pathrresultrrs r5r z#DiscordAdapter._process_voice_input?s======+6,W\]]]:  #M$DN Q Q Q Q Q Q Q Q R  (#####      (####    sAE)B00 B>=B>5E)8D DDA E)(G) F3FGFGF44 GGG,GG, G)&G,(G))G,cV t|dt}t|dt t|}t }|s|sdS|r||vrdS|r|t|ddnd}|rt fd|DrdS|j t |}n#t tf$rd}YnwxYw|X|jjD]K}| |} | t| ddpg} t fd| DrdSLdS) aCheck if user is allowed via DISCORD_ALLOWED_USERS or DISCORD_ALLOWED_ROLES. Uses OR semantics: if the user matches EITHER allowlist, they're allowed. If both allowlists are empty, everyone is allowed (backwards compatible). When author is a Member, checks .roles directly; otherwise falls back to scanning the bot's mutual guilds for a Member record. r]r%TNrPc3>K|]}t|ddvVdSrNr:rr allowed_roless r5rJz2DiscordAdapter._is_allowed_user..{s4UU1wq$-->UUUUUUr7c3>K|]}t|ddvVdSrrrs r5rJz2DiscordAdapter._is_allowed_user..s4XX1wq$55FXXXXXXr7F) r:rZr8rqr!r TypeError ValueErrorguildsr) rlrrl allowed_users has_users has_roles direct_rolesuid_intryrm_rolesrs @r5rozDiscordAdapter._is_allowed_userbs &9355AA &9355AA '' ''   4  M114  (=C=O767D999UYL UUUU UUUUU 4|'#!'llGG!:.###"GGG#&!%!4((!,,W559$")!Wd";";"ArXXXXPWXXXXX(#'44(us&B66C  C  interaction'discord.Interaction'Tuple[bool, Optional[str]]c&t|dd}|t|tjnd}|s/t|ddpt|dd}t }|u|t |t|tjr9||}|r"|t |tj dd}|r.d| d D}d |vr |sd S||zsd Stj d d} | r,|r*d| d D} d | vs|| zrdSt|dd} t|dt p t } t|dt p t } | t| dd| s| rdSdSt | j }| || sdSdS)afEvaluate slash authorization without producing any response. Returns ``(allowed, reason)``. ``reason`` is populated only when ``allowed`` is False. This is the shared core used by both the responding wrapper (``_check_slash_authorization``) and side-effect- free callers like the ``/skill`` autocomplete callback, which must return an empty list for unauthorized users instead of leaking an ephemeral rejection per-keystroke. Fail-closed semantics for malformed payloads: when an allowlist is configured but the interaction is missing the data needed to evaluate it (no channel id with channel policy active, no user with user/role policy active), the gate REJECTS rather than falling through. Without these guards a guild interaction that happens to deserialize without a channel id would silently bypass ``DISCORD_ALLOWED_CHANNELS`` and a payload missing ``user`` would raise ``AttributeError`` in the user check below, surfacing as an opaque interaction failure rather than a clean rejection. rNFrrDISCORD_ALLOWED_CHANNELSrAc^h|]*}||+Sr;r/rs r5rCz?DiscordAdapter._evaluate_slash_authorization..-RRR R17799RRRr7rD*)Fz;channel id missing with DISCORD_ALLOWED_CHANNELS configured)Fz'channel not in DISCORD_ALLOWED_CHANNELSDISCORD_IGNORED_CHANNELSc^h|]*}||+Sr;r0rs r5rCz?DiscordAdapter._evaluate_slash_authorization..r1r7)Fz#channel in DISCORD_IGNORED_CHANNELSrr]r%)Fz2missing interaction.user with allowlist configured)TN)rl)Fz9user not in DISCORD_ALLOWED_USERS / DISCORD_ALLOWED_ROLES)r:rrSrprZrr(Thread_get_parent_channel_idrGrHrrro)rlr*chan_objin_dm chan_id_raw channel_ids parent_id allowed_rawr ignored_rawignoredrr$rrs r5_evaluate_slash_authorizationz,DiscordAdapter._evaluate_slash_authorizationsg,; 488;C;O 8W%6777UZ # J!+|TBBg$GGK #uuK&K 0 0111h778 $ ; ;H E EI 8#I777)$>CCK RRRk.?.?.D.DRRRg%%&  ('1RQQ )$>CCK J{ JRRk.?.?.D.DRRR'>>kG&;>II{FD11&9355AAJSUU &9355AAJSUU <74t44<  U  UTT<dg,,$$WT$::  |r7 command_textc~K||\}}|rdS||||pdd{VS)uOMirror on_message's user/role/channel gates onto a slash invocation. Returns True to proceed. Returns False *after* sending an ephemeral rejection, logging a warning, and scheduling a cross-platform admin alert — the caller must stop on False (the interaction has already been responded to). T unauthorized)reasonN)r? _reject_slash)rlr*r@rrCs r5_check_slash_authorizationz)DiscordAdapter._check_slash_authorizationss<<[II  4'' f.F(         r7rCc Kt|dd}|0tt|dd}t|dd}nd}d}t|ddptt|dddd}t|dd}td |||||| |jd d d{Vn2#t $r%} td | Yd} ~ nd} ~ wwxYw tj | ||||||n2#t $r%} td| Yd} ~ nd} ~ wwxYwdS)aSend ephemeral reject + log warning + schedule admin alert. Returns False. Tolerates a missing ``interaction.user`` -- the fail-closed branch in ``_evaluate_slash_authorization`` deliberately routes here for malformed payloads (no user) when an allowlist is configured, and ``str(interaction.user.id)`` would raise AttributeError before the ephemeral rejection could be sent. rNrrXr>rrrzX[Discord] Unauthorized slash attempt: user=%s id=%s channel=%s guild=%s cmd=%r reason=%rz*You're not authorized to use this command.T ephemeralz3[Discord] Could not send unauthorized ephemeral: %sz2[Discord] Could not schedule admin notify task: %sF) r:r(rxrresponse send_messager~rr"rX_notify_unauthorized_slash) rlr*r@rCrr user_namechan_idrrs r5rDzDiscordAdapter._reject_slashs{FD11  '$c2233Gfc22IIGI+|T:: g KD 1 14? ? ; D99 ( w<    S&33<4         S S S LLNPQ R R R R R R R R S  R   ? ?7GX|V!!     R R R LLMq Q Q Q Q Q Q Q Q Rus0-"C C?C::C?,D00 E:EErLc pKt|dd}|sdStjtjfD]} |j|} | s!|j|} | rt| ddsOd|d|d|d|d|d | } | t| j | d{V} t| d dd ur,t d |t| d ddS#t$r&} t d|| Yd} ~ d} ~ wwxYwdS)aBest-effort cross-platform alert to the gateway operator. Tries TELEGRAM first (most operators set TELEGRAM_HOME_CHANNEL), then SLACK. Silently no-ops if no other platform is configured with a home channel. A soft send failure -- adapter.send() returning a result with ``success=False`` rather than raising -- continues the fallback chain. Treating a SendResult(success=False) as delivered would mean a Telegram outage that the adapter politely surfaces (e.g. rate-limit, auth failure) silently swallows the alert without attempting Slack. Hard exceptions still take the same path via the except branch below. r&Nr!u0⚠️ Unauthorized Discord slash attempt User:  (z ) Channel: z (guild z ) Command: z Reason: r)FzP[Discord] Admin notify via %s returned success=False (error=%r); falling throughrz([Discord] Admin notify via %s failed: %s)r:rTELEGRAMSLACKadaptersrrget_home_channelr>r(r!rxrr~)rlrLrrMrr@rCrunnertargetadapterhomerrrs r5rKz)DiscordAdapter._notify_unauthorized_slash6s$/66  F((.9 T TF T /--f55}55f==74D#A#A(&((*1(( '((19((!-(( & (( '||C ,=,=sCCCCCCCC69d33u<<LL7 > >  T T T GQRSSSSSSSS T5 T Ts$D-D?BD D3 D..D3 image_pathcNK ||||d{VS#t$rtdd|cYSt$rY}td|j|dt|||||d{VcYd}~Sd}~wwxYw) z>Send a local image file natively as a Discord file attachment.NFzImage file not found: r(zA[%s] Failed to send local image, falling back to base adapter: %sTrr) rnFileNotFoundErrorrr~rxrr>rsend_image_file)rlr!rXrdr#r$rr>s r5r[zDiscordAdapter.send_image_filehs l33GZQQQQQQQQ Q  Z Z Ze3XJ3X3XYYY Y Y Y l l l LL\^b^gijuyL z z z00*gxbj0kkkkkkkk k k k k k k l""B$ B$ ABB$B$rcbK|jstddSt|sLtd|jt |||||d{VS ddl}|j t|}|s-|j t|d{V}|stdd|d Sdd l m }m} |d } | | \} } |jd"i| 4d{V} | j|fd |di| 4d{V}|jdkrt'd|j|d{V}|jdd}d}d|vsd|vrd}n d|vrd}nd|vrd}ddl}t/j||d|}||rV|||pd|d{Vcdddd{Vcdddd{VS||r|nd|d{V}tdt=|jcdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t@$rOtd|jd t ||||d{VcYSt&$rW}t!d!|j|d t ||||d{VcYd}~Sd}~wwxYw)#z4Send an image natively as a Discord file attachment.Fr'r(z7[%s] Blocked unsafe image URL during Discord send_imagerNrr,r+rxrMrNrrrzr{zFailed to download image: HTTP r}r~rrrrrzimage.rhrAriTr`I[%s] aiohttp not installed, falling back to URL. Run: pip install aiohttprz=[%s] Failed to send image attachment, falling back to URL: %sr;)"r!rr&rxrr>r send_imagerr5rr6rrKryrrrrr~rrrrSrlrr7r[r/r>r(r ImportErrorr)rlr!rrdr#r$rrrKryrrrsessionr image_datarrrrSrrr>s r5r_zDiscordAdapter.send_imageys| De?CCC C9%% f NNTVZV_ ` ` `++GY\d+eeeeeeee e= S NNNl..s7||<(>RUXXXD,,W55%)%:%:#%,]$9$9$;$;!%&;&&      )LLLLLLLLLLLLL L L L L L L L L L L L L L L6!( +2 <!!-!!C&ds36{{KKK=LLLLLLLLLLLLL L L L L L L L L L L L L L LLLLLLLLLLLLLLLL L L L L L L L L L L L L L L L L L L L L L L L L L L L L L LB S S S NN[      ++GYRRRRRRRR R R R S S S LLO      ++GYRRRRRRRR R R R R R R Ss8A0K6)5K6+K# C(J>1K#K6AJ>K#+K6> K K# K K#K6# K--K60K-1K66AN. N.A N)#N.)N. animation_urlcK|jstddSt|sLtd|jt |||||d{VS ddl}|j t|}|s-|j t|d{V}|stdd|d Sdd l m }m} |d } | | \} } |jdi| 4d{V} | j|fd |di| 4d{V}|jdkrt'd|j|d{V}ddl}t-j||d}||rV|||pd|d{Vcdddd{Vcdddd{VS||r|nd|d{V}tdt;|jcdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS#t>$rQtd|jdt |||||d{VcYSt&$rY}t d|j|dt |||||d{VcYd}~Sd}~wwxYw)z;Send an animated GIF natively as a Discord file attachment.Fr'r(z?[%s] Blocked unsafe animation URL during Discord send_animationrNrr,r+rxrMrNrrrzr{z#Failed to download animation: HTTP z animation.gifrhrAriTr`r^rzA[%s] Failed to send animation attachment, falling back to URL: %sr;)!r!rr&rxrr>rsend_animationrr5rr6rrKryrrrrr~rrrSrlrr7r[r/r>r(rr`r)rlr!rcrdr#r$rrrKryrrrraranimation_datarrSrrr>s r5rezDiscordAdapter.send_animations| De?CCC C=)) n NN\^b^g h h h//QYdl/mmmmmmmm m3 n NNNl..s7||<S>SZ\>S>]>]iahiiLLLLLLLmq{c))'([dk([([\\\+/99;;%6%6%6%6%6%6NIII"< >(B(B_]]]D,,W55%)%:%:#%,]$9$9$;$;!%&;&&      LLLLLLLLLLLLL L L L L L L L L L L L L L L"!( +2 <!!-!!C&ds36{{KKK)LLLLLLLLLLLLL L L L L L L L L L L L L L LLLLLLLLLLLLLLLL L L L L L L L L L L L L L L L L L L L L L L L L L L L L L L. n n n NN[      //QYdl/mmmmmmmm m m m n n n LLS      //QYdl/mmmmmmmm m m m m m m ns8A0J>)5J>+J+ B0J9J+ J>AJ!J+3J> J J+J J+J>+ J55J>8J59J>>AM: M:!AM5/M:5M: video_pathcNK ||||d{VS#t$rtdd|cYSt$rY}td|j|dt|||||d{VcYd}~Sd}~wwxYw) z9Send a local video file natively as a Discord attachment.NFzVideo file not found: r(zA[%s] Failed to send local video, falling back to base adapter: %sTrr) rnrZrr~rxrr>r send_video)rlr!rgrdr#r$rr>s r5rizDiscordAdapter.send_video s g33GZQQQQQQQQ Q  Z Z Ze3XJ3X3XYYY Y Y Y g g g LL\^b^gijuyL z z z++GZ(]e+ffffffff f f f f f f gr\c TK |||||d{VS#t$rtdd|cYSt$rZ}td|j|dt|||||| d{VcYd}~Sd}~wwxYw) z8Send an arbitrary file natively as a Discord attachment.)reNFzFile not found: r(z>[%s] Failed to send document, falling back to base adapter: %sTrr) rnrZrr~rxrr>r send_document) rlr!rcrdrer#r$rr>s r5rkzDiscordAdapter.send_document s t33GY[d3eeeeeeee e  S S Se3Qi3Q3QRRR R R R t t t LLY[_[dfgrvL w w w..w 7IW_jr.ssssssss s s s s s s ts"$B' B' AB"B'"B'cKjsdSjvrdSdfd }tj|j<dS)a`Start a persistent typing indicator for a channel. Discord's TYPING_START gateway event is unreliable in DMs for bots. Instead, start a background loop that hits the typing endpoint every 8 seconds (typing indicator lasts ~10s). The loop is cancelled when stop_typing() is called (after the response is sent). Nr)rcK tjdd}jj|d{VnE#t j$rYdSt$r'}t d|Yd}~dSd}~wwxYwt j dd{V#t j$rYdSwxYw)NTrz/channels/{channel_id}/typingrz*Discord typing indicator failed for %s: %s) rSrrr!rr"rr~rxrr)routerr!rls r5 _typing_loopz0DiscordAdapter.send_typing.._typing_loop> s  +  ' 2 2"$C'.!3!!#l/77>>>>>>>>>>"1$ %QSZ\]^^^"-********* +)    sGB/AAB/BB/! B*B B/ BB//CCr)r)r!r6r"rX)rlr!r$rps`` r5 send_typingzDiscordAdapter.send_typing0 su|  F d( ( ( F       $'.&9,,..&I&I7###r7cK|j|d}|r<| |d{VdS#tjt f$rYdSwxYwdS)z3Stop the persistent typing indicator for a channel.N)r6rrWr"rr~)rlr!rs r5 stop_typingzDiscordAdapter.stop_typingR s!%%gt44   KKMMM  *I6       s?AAcK|jsdddS |jt|}|s-|jt|d{V}|st |ddSt |t jr%d}|jr |jj nt |}nt |t j r d}|j }n_t |t j r%d}d|j }|j r|j j d|}n d}t|d t |}||t|d r |j rt |j jndt|d r|j r |j j ndd S#t $rN}t"d |j ||d t |dt |dcYd}~Sd}~wwxYw)z(Get information about a Discord channel.Unknowndm)r>rmNrJr# / r>ry)r>rmr guild_namez'[%s] Failed to get chat info for %s: %sTr)r>rmr)r!r5rr6r(rrSrp recipientr>r5 TextChannelryr:rrr~rxr)rlr!r chat_typer>rs r5 get_chat_infozDiscordAdapter.get_chat_info\ s3| 5%t44 4 Il..s7||< 181BTw(--G GW^44 >$ |GW%899 >% )7<))=<%m0;;T;;D% wG ==!5. s.PPPPPPPP1qPPPPs)limitz(Failed to fetch members for guild %s: %srArz ] Resolved 'z' -> rOrx)z] Could not resolve usernames: rDrAz%] Updated DISCORD_ALLOWED_USERS with z resolved ID(s))r]r!rZrGrr4printr>rrr#rr fetch_membersr~rxrrz global_namer(rdiscard discriminatorrrGenviron)rl numeric_ids to_resolver'resolved_countryrrr{ name_lower display_lower global_lowermatchedr matched_names r5rUz)DiscordAdapter._resolve_allowed_usernames s[% T\  Fee UU + . .E}} .&&&&u{{}}----  F _$)__Z__ R\H]H]__```\(  E -w<<%"444PP0C0C$0C0O0OPPPPPPPPPG   I5:WXYYY " v v#[..00 & 3 9 9 ; ; & 2 8b??AA $ 2omz6QoUaeoUovfi..COOC((("a'N1;z1I1I::)6*)D)D ,!&&|444tditt\ttttv{tt]c]qtttuuu    Y WdiWW *@U@UWW X X X"-.1hhvk7J7J.K.K *+  g edieeneee f f f f f g gsAD## E-!EEc|S)z] Format message for Discord. Discord uses its own markdown variant. r;)rlr"s r5r9zDiscordAdapter.format_message s r7discord.Interaction followup_msg str | Nonec K |j}t|jddpt|dd}td|t|ddt|dd|t|ddn#t $rYnwxYw|||d{VsdS|jd d{V| ||}| |d{V |r| | d{VdS| d{VdS#t $r&}t d |Yd}~dSd}~wwxYw) amCommon handler for simple slash commands that dispatch a command string. Defers the interaction (shows "thinking..."), dispatches the command, then cleans up the deferred response. If *followup_msg* is provided the "thinking..." indicator is replaced with that text; otherwise it is deleted so the channel isn't cluttered. rNrzA[Discord] slash '%s' invoked by user=%s id=%s channel=%s guild=%sr>rXrTrGrKz&Discord interaction cleanup failed: %s)rr:rrxryr~rErIdefer_build_slash_eventhandle_messageedit_original_responsedelete_original_responser)rlr*r@r_user_chan_idrrs r5_run_simple_slashz DiscordAdapter._run_simple_slash s" $E{2D$??k7;XdfjCkCkH KKSvs++tS)) Z66         D  44[,OOOOOOOO  F"((4(888888888'' \BB!!%((((((((( F =!888NNNNNNNNNNN!::<<<<<<<<<<< F F F LLA1 E E E E E E E E E Fs0A:A?? B  B D< D<< E,E''E,c jsdSjj}|dddfd }|dd dfd }|d d tjd ddfd }|ddtjdddfd }|ddtjdddfd }|dddfd }|d d!dfd" }|d#d$dfd% } |d&d'dfd( } |d)d*dfd+ } |d,d-tjd./dfd1 } |d2d3dfd4 } |d5d6tjd7ddfd8 }|d9d:tjd;ddfd< }|d=d>dfd? }|d@dAdfdB }|dCdDtjdEFddfdJ }|dKdLdfdM }|dNdOdfdP }|dQdRtjdSTtjtjdUdVWtjdXdYWtjdZd[Wtjd\d]Wtjd^d_Wtjd`d#WgTddfdb }|dcdddfde }|dfdgdfdh }|didjtjdklddfdn }|dodptjdqlddfdr }|dsdttjdudvdwx ddfd| }|d}d~tjd/dfd }|ddtjd/dfd }ddfd }t} ddl m }m } m }! d| D}n#t$rYnwxYw|!}"|D]}#| |#|"s|#jdd}$|$|vr5||#j|#j|#j}% ||%||$}#t$rYwxYwt*dt/|n2#t$r%}&t*d|&Yd}&~&nd}&~&wwxYw ddl m}'|'D]o\}(})}*|(dd}$|$|vr'||(|)|*}% ||%||$`#t$rYlwxYwn2#t$r%}&t*d|&Yd}&~&nd}&~&wwxYw|t7jdddvr|dSdS)z4Register Discord slash commands on the command tree.NnewzStart a new conversation)r>rr*rcFK|ddd{VdS)N/resetzNew conversation started~rr*rls r5 slash_newz:DiscordAdapter._register_slash_commands..slash_new s8((h@[\\ \ \ \ \ \ \ \ \ \r7resetzReset your Hermes sessioncFK|ddd{VdS)NrzSession reset~rrs r5 slash_resetz.slash_reset s8((h@PQQ Q Q Q Q Q Q Q Q Qr7modelzShow or change the modelzHModel name (e.g. anthropic/claude-sonnet-4). Leave empty to see current.r>rAr>r(cnK|d|d{VdS)Nz/model rr/r*r>rls r5 slash_modelz.slash_model L((6F6F6F6L6L6N6NOO O O O O O O O O Or7 reasoningzShow or change reasoning effortz=Reasoning effort: none, minimal, low, medium, high, or xhigh.)effortrcnK|d|d{VdS)Nz /reasoning r)r*rrls r5slash_reasoningz@DiscordAdapter._register_slash_commands..slash_reasoning sL((6LF6L6L6R6R6T6TUU U U U U U U U U Ur7 personalityzSet a personalityz0Personality name. Leave empty to list available.cnK|d|d{VdS)Nz /personality rrs r5slash_personalityzBDiscordAdapter._register_slash_commands..slash_personality sL((6Ld6L6L6R6R6T6TUU U U U U U U U U Ur7retryzRetry your last messagecFK|ddd{VdS)Nz/retryz Retrying~rrs r5 slash_retryz.slash_retry s7((h LL L L L L L L L L Lr7undozRemove the last exchangecDK|dd{VdS)Nz/undorrs r5 slash_undoz;DiscordAdapter._register_slash_commands..slash_undo 5((g>> > > > > > > > > >r7rzShow Hermes session statuscFK|ddd{VdS)Nz/statusz Status sent~rrs r5 slash_statusz=DiscordAdapter._register_slash_commands..slash_status! s7((iPP P P P P P P P P Pr7sethomez!Set this chat as the home channelcDK|dd{VdS)Nz/sethomerrs r5 slash_sethomez>DiscordAdapter._register_slash_commands..slash_sethome% s5((jAA A A A A A A A A Ar7rzStop the running Hermes agentcFK|ddd{VdS)Nz/stopzStop requested~rrs r5 slash_stopz;DiscordAdapter._register_slash_commands..slash_stop) s8((g?PQQ Q Q Q Q Q Q Q Q Qr7steerz8Inject a message after the next tool call (no interrupt)z0Text to inject into the agent's next tool result)promptrcnK|d|d{VdS)Nz/steer rr*rrls r5 slash_steerz.slash_steer- sL((6H6H6H6N6N6P6PQQ Q Q Q Q Q Q Q Q Qr7compresszCompress conversation contextcDK|dd{VdS)Nz /compressrrs r5slash_compressz?DiscordAdapter._register_slash_commands..slash_compress2 s5((kBB B B B B B B B B Br7titlezSet or show the session titlez+Session title. Leave empty to show current.cnK|d|d{VdS)Nz/title rrs r5 slash_titlez.slash_title6 rr7rz!Resume a previously-named sessionz5Session name to resume. Leave empty to list sessions.cnK|d|d{VdS)Nz/resume rrs r5 slash_resumez=DiscordAdapter._register_slash_commands..slash_resume; sL((6G6G6G6M6M6O6OPP P P P P P P P P Pr7usagez!Show token usage for this sessioncDK|dd{VdS)Nz/usagerrs r5 slash_usagez.slash_usage@ s5((h?? ? ? ? ? ? ? ? ? ?r7helpzShow available commandscDK|dd{VdS)Nz/helprrs r5 slash_helpz;DiscordAdapter._register_slash_commands..slash_helpD rr7insightsz!Show usage insights and analyticsz&Number of days to analyze (default: 7))daysrwrrcJK|d|d{VdS)Nz /insights r)r*rrls r5slash_insightsz?DiscordAdapter._register_slash_commands..slash_insightsH s@((6I46I6IJJ J J J J J J J J Jr7z reload-mcpzReload MCP servers from configcDK|dd{VdS)Nz /reload-mcprrs r5slash_reload_mcpzADiscordAdapter._register_slash_commands..slash_reload_mcpM s5((mDD D D D D D D D D Dr7z reload-skillsz3Re-scan ~/.hermes/skills/ for new or removed skillscDK|dd{VdS)Nz/reload-skillsrrs r5slash_reload_skillszDDiscordAdapter._register_slash_commands..slash_reload_skillsQ s6((6FGG G G G G G G G G Gr7rzToggle voice reply modez3Voice mode: on, off, tts, channel, leave, or status)modeu#channel — join your voice channelrruleave — leave voice channelleaveu$on — voice reply to voice messagesrFu#tts — voice reply to all messagesttsuoff — text onlyrustatus — show current modercnK|d|d{VdS)Nz/voice r)r*rrls r5 slash_voicez.slash_voiceU sL((6F6F6F6L6L6N6NOO O O O O O O O O Or7updatez)Update Hermes Agent to the latest versioncFK|ddd{VdS)Nz/updatezUpdate initiated~rrs r5 slash_updatez=DiscordAdapter._register_slash_commands..slash_updateb s8((iATUU U U U U U U U U Ur7restartz%Gracefully restart the Hermes gatewaycFK|ddd{VdS)Nz/restartzRestart requested~rrs r5 slash_restartz>DiscordAdapter._register_slash_commands..slash_restartf s8((jBVWW W W W W W W W W Wr7approvez#Approve a pending dangerous commandzAOptional: 'all', 'session', 'always', 'all session', 'all always')scopercnK|d|d{VdS)Nz /approve rr*rrls r5 slash_approvez>DiscordAdapter._register_slash_commands..slash_approvej sL((6I%6I6I6O6O6Q6QRR R R R R R R R R Rr7denyz Deny a pending dangerous commandz,Optional: 'all' to deny all pending commandscnK|d|d{VdS)Nz/deny rrs r5 slash_denyz;DiscordAdapter._register_slash_commands..slash_denyo sL((6Fu6F6F6L6L6N6NOO O O O O O O O O Or7rJz4Create a new thread and start a Hermes session in itz Thread namez6Optional first message to send to Hermes in the threadz/Auto-archive in minutes (60, 1440, 4320, 10080)r>r\auto_archive_durationrr\rcHK||||d{VdSr)_handle_thread_create_slash)r*r>r\rrls r5 slash_threadz=DiscordAdapter._register_slash_commands..slash_threadt s<22;gOdee e e e e e e e e er7queuez4Queue a prompt for the next turn (doesn't interrupt)zThe prompt to queuecLK|d|dd{VdS)Nz/queue zQueued for the next turn.rrs r5 slash_queuez.slash_queue sC((6H6H6HJeff f f f f f f f f fr7 backgroundzRun a prompt in the backgroundz#The prompt to run in the backgroundcLK|d|dd{VdS)Nz /background zBackground task started~rrs r5slash_backgroundzADiscordAdapter._register_slash_commands..slash_background sC((6MV6M6MOijj j j j j j j j j jr7_name _description _args_hintc|dd}|pd|dd}t|}|rd fd }|||}nd fd }||}tj||| S) zGBuild a discord.app_commands.Command that proxies to _run_simple_slash.NrzRun /r_DiscordAdapter__namer(_DiscordAdapter__hintctjd|ddd dfd }d d d |_|S)Nz Arguments: r)argsrAr*rrr(ctK|dd|d{VdS)N/ r)r*rrrls r5_handlerzxDiscordAdapter._register_slash_commands.._build_auto_slash_command.._make_args_handler.._handler si"44')._build_auto_slash_command.._make_args_handler s)228Nf8N8NtPSt8T2UUVU)QfnnS#6N6N(P(PH%#Or7cTdfd }ddd|_|S)Nr*rcJK|dd{VdS)Nrr)r*rrls r5r zzDiscordAdapter._register_slash_commands.._build_auto_slash_command.._make_simple_handler.._handler s;"44[,f,,OOOOOOOOOOOr7r r rr*r)rr)rr rls` r5_make_simple_handlerzhDiscordAdapter._register_slash_commands.._build_auto_slash_command.._make_simple_handler sQPPPPPPP(PfnnS#6N6N(P(PH%#Or7r>rcallback)rr(rr()rr()r4r8rSrCommand) rrr discord_namedeschas_argsrhandlerrrls r5_build_auto_slash_commandzJDiscordAdapter._register_slash_commands.._build_auto_slash_command s ;;=="-L 3OEOOTcT:DJ''H 6$$$$$$-,UJ??$$$$$$ /.u55'//!  0 r7r)COMMAND_REGISTRY_is_gateway_available_resolve_config_gatesch|] }|j Sr;rrcmds r5rCz:DiscordAdapter._register_slash_commands.. s%N%N%N3ch%N%N%Nr7rz9Discord auto-registered %d commands from COMMAND_REGISTRYz6Discord auto-register from COMMAND_REGISTRY failed: %s)_iter_plugin_command_entriesz5Discord auto-register from plugin commands failed: %sDISCORD_HIDE_SLASH_COMMANDSrrBrr )r*rr>r()r*rrr()r*rrr()rw)r*rrr)r*rrr()r*rrr(rAr)r*rr>r(r\r(rr)rr(rr(rr()r!rrrSrrrChoicerZhermes_cli.commandsrrr rr~r>r4r args_hint add_commandrrxrrrr$_register_skill_grouprGrHr/_apply_owner_only_visibility)+rlrrrrrrrrrrrrrrrrrrrrrrrrrrrrralready_registeredrrr config_overridescmd_defrauto_cmdrr$ plugin_name plugin_descplugin_args_hints+` r5rz'DiscordAdapter._register_slash_commands sn |  F|  5.H I I ] ] ] ] ] J I ] 70K L L R R R R R M L R 70J K K   & &,v & w w P P P P P P x w L K P ;4U V V   & &.m & n n V V V V V V o n W V V =6I J J   & &,^ & _ _ V V V V V V ` _ K J V 70I J J M M M M M K J M 6/I J J ? ? ? ? ? K J ? 81M N N Q Q Q Q Q O N Q 92U V V B B B B B W V B 6/N O O R R R R R P O R 70j k k   & &.` & a a R R R R R b a l k R :3R S S C C C C C T S C 70O P P   & &,Y & Z Z P P P P P P [ Z Q P P 81T U U   & &,c & d d Q Q Q Q Q Q e d V U Q 70S T T @ @ @ @ @ U T @ 6/H I I ? ? ? ? ? J I ? :3V W W   & &,T & U U K K K K K K V U X W K <5U V V E E E E E W V E ?8m n n H H H H H o n H 70I J J   & &,a & b b   % %  ' '-RZc ' d d  ' '-LT[ ' \ \  ' '-S[_ ' ` `  ' '-RZ_ ' ` `  ' '-@ ' N N  ' '-KS[ ' \ \ , %   P P P P P P   c b K J P 81\ ] ] V V V V V ^ ] V 92Y Z Z X X X X X [ Z X 92W X X   & &-p & q q S S S S S S r q Y X S 6/Q R R   & &-[ & \ \ P P P P P P ] \ S R P 81g h h   & &L"S '  )-  f f f f f f    i h  f 70f g g   & &.C & D D g g g g g E D h g g <5U V V   & &.S & T T k k k k k U T W V k       @(+uu# X j j j j j j j j j j %N%N$:K:K:M:M%N%N%N""     5466 +  ,,W6FGG&|1133CRC8 #55544L'% $$X...&**<8888 D LLK&''     X X X NNSUV W W W W W W W W X  H H H H H H>Z>Z>\>\  : [*:*00223B37 #55544$ $$X...&**<8888 D      NNG          ""4((( 92G < < B B D D J J L LQ     - -d 3 3 3 3 3  s ^< [*)^<* [74^<6[77A ^<*^^< ^ ^<^+^<< _+_&&_+/Aa04*aa0 a,)a0+a,,a00 b:bbc  tjd}n3#t$r&}td|Yd}~dSd}~wwxYwd}|D]Q} ||_|dz }#t$r5}tdt|dd|Yd}~Jd}~wwxYwt d|dS) uiSet default_member_permissions=0 on every registered slash command. Discord interprets ``Permissions(0)`` as "requires no permissions", which paradoxically means the command is hidden from every guild member except those with the Administrator permission. Server admins can re-grant per user/role via Server Settings → Integrations → → Permissions. Authoritative gate is ``_check_slash_authorization`` on every invocation, which catches stale clients, role grants made by mistake, and direct API calls bypassing Discord's UI hide. rzG[Discord] _apply_owner_only_visibility: cannot build Permissions(0): %sNrz5[Discord] Could not set default_permissions on %r: %sr>rXzy[Discord] Hid %d slash command(s) from non-admin guild members (opt-in defense in depth via DISCORD_HIDE_SLASH_COMMANDS).) rS Permissionsr~rxrrrrr:ry)rlrno_permsrappliedr#s r5r,z+DiscordAdapter._apply_owner_only_visibility s* *1--HH    NNY    FFFFF   $$&&  C *2'1     KC--q    I      s, AAA# A00 B/:+B**B/c^ t} d|D}n#t$rYnwxYwg_i_t|_jsdSdfd }tj d d tj |  ddfd }tj dd|}| |tdjt!jjr(tdjjdSdS#t$r,}tdj|Yd}~dSd}~wwxYw)uQRegister a single ``/skill`` command with autocomplete on the name. Discord enforces an ~8000-byte per-command payload limit. The older nested layout (``/skill ``) registered one giant command whose serialized payload grew linearly with the skill catalog — with the default ~75 skills the payload was ~14 KB and ``tree.sync()`` rejected the entire slash-command batch (issues #11321, #10259, #11385, #10261, #10214). Autocomplete options are fetched dynamically by Discord when the user types — they do NOT count against the per-command registration budget. So we register ONE flat ``/skill`` command with ``name: str`` (autocompleted) and ``args: str = ""``. This scales to thousands of skills with no size math, no splitting, and no hidden skills. The slash picker also becomes more discoverable — Discord live-filters by the user's typed prefix against both the skill name and its description. The entries list and lookup dict are stored on ``self`` rather than captured in closure variables so :meth:`refresh_skill_group` can repopulate them when the user runs ``/reload-skills`` without needing to touch the Discord slash-command tree or trigger a ``tree.sync()`` call. ch|] }|j Sr;rr"s r5rCz7DiscordAdapter._register_skill_group..F s!J!J!Js#(!J!J!Jr7Nr*r+rr(r)rc&K |\}}n#t$rgcYSwxYw|sgS|pd}g} jD]\}}}|r.||vs|r||vru|r|d|} n|} t | dkr | dddz} |tj | |t |dkrn|S) uFilter skills by the user's typed prefix. Matches both the skill name and its description so "/skill pdf" surfaces skills whose description mentions PDFs even if the name doesn't. Discord caps this list at 25 entries per query. Authorization: a quiet pre-check evaluates the slash allowlists and returns ``[]`` for unauthorized users so the installed skill catalog is not leaked to anyone who can see the command in the picker. Returning a generic empty list here is intentional — sending a per-keystroke ephemeral rejection would produce a barrage of error popups during typing. Reads ``self._skill_entries`` so a ``/reload-skills`` run since process start shows up on the very next keystroke. rArrNar_r) r?r~r/r4_skill_entriesrrrSrr') r*rr_reasonqrr>r_keylabelrls r5_autocomplete_namez@DiscordAdapter._register_skill_group.._autocomplete_nameV s]*'+'I'I+'V'V$GWW IIII]))++1133 "(,(; " "$D$ "TZZ\\ 1 1d 1qDJJLL?P?P)'+$8$8$$8$8EE$(Eu::++$)#2#J$6E#077U$7OOw<<2--!Es  --zWhich skill to runz Optional arguments for the skill)r>rrrAr>rc@K|dd{VsdSj|}|s(|jd|ddd{VdS|\}}||d|d{VdS)Nz/skillzUnknown skill: `z-`. Start typing for autocomplete suggestions.TrGr )rE _skill_lookuprrIrJrr/)r*r>rr'_desccmd_keyrls r5_skill_handlerz._skill_handler s"<<[(SSSSSSSSF*..t44%.;;54555"&< F!&w,,G!4!4d!4!4!:!:!r(rr()rZrr~r=rD_skill_group_reserved_names_refresh_skill_catalog_staterSrrrrr*rxryr>r_skill_group_hidden_countr)rlrexisting_namesrBrGr#excs` r5r+z$DiscordAdapter._register_skill_group* s12n Y UUN !J!Jd6G6G6I6I!J!J!J    ?AD =?D 9<^9L9LD ,  - - / / /& - - - - - - ^ ! * *)7+ ! . .4F . G GKM      H G   ,&..0'/C   S ! ! ! KKR 3t233   -  UIt=    Y Y Y NNGTW X X X X X X X X X Ys:E61E6 >E6>AE6C2E66 F,!F''F,chddlm}t|dt}|t|\}}}t |}|D]}|||d||_d|D|_ ||_ dS) uRe-scan disk for skills and repopulate ``self._skill_entries``. Called once from :meth:`_register_skill_group` at startup and again from :meth:`refresh_skill_group` whenever the user runs ``/reload-skills``. No Discord API calls are made — autocomplete and the handler both read from these instance attributes directly, so an in-place mutation is sufficient. r)"discord_skill_commands_by_categoryrI)reserved_namesc|dS)Nrr;)ts r5z=DiscordAdapter._refresh_skill_catalog_state.. s 1Q4r7)rc i|] \}}}|||f Sr;r;)rnrks r5rz?DiscordAdapter._refresh_skill_catalog_state.. s$???GAq!a!Q???r7N) r(rOr:rZrrrsortr=rDrK)rlrOreserved categories uncategorizedhiddenentries cat_skillss r5rJz+DiscordAdapter._refresh_skill_catalog_state s KJJJJJ4!>FF,N,Nx==- - - ) M6/3=.A.A$++-- ' 'J NN: & & & &   (((%??w???)/&&&r7tuple[int, int]c |nX#t$rK}td|j|t t |dgdfcYd}~Sd}~wwxYwtd|jt |j|j t |j|j fS)uRescan skills and update the live ``/skill`` autocomplete state. Invoked by :meth:`gateway.run.GatewayOrchestrator._handle_reload_skills_command` after :func:`agent.skill_commands.reload_skills` has refreshed the in-process skill-command registry. Without this call, the ``/skill`` autocomplete dropdown keeps showing the list captured at process start — new skills stay invisible and deleted skills return an "Unknown skill" error when clicked. Because autocomplete options are fetched dynamically by Discord, we only need to mutate the entries/lookup attributes read by the callbacks — no ``tree.sync()`` is required. Returns ``(new_count, hidden_count)``. z;[%s] Failed to refresh /skill autocomplete after reload: %sr=rNzG[%s] Refreshed /skill autocomplete: %d skill(s) available (%d filtered)) rJr~rxrr>rr:ryr=rK)rlrMs r5refresh_skill_groupz"DiscordAdapter.refresh_skill_group s  A  - - / / / / A A A NNM 3   &6;;<Build a MessageEvent from a Discord slash command interaction.NrwrJgrouprAr>ry / # is_threadr! chat_namer}rrLr* chat_topicrrr;)ra message_typerrchannel_prompt)rrrSrpr5r(rrr>ry_get_effective_topic build_sourcerrrzr0rCOMMANDTEXTr:r_resolve_channel_prompt) rlr*rais_dmrfr*r}rhrirmsg_typerr;s r5rz!DiscordAdapter._build_slash_event s;.0ABB{2GNCC   II   IK233III  O!4f== O#+0I{*G44 O9L9R O*28=NN9NN ..{/Bi.XX "" .// (+,,!&3!#  +///#*>*>T;&&KDT/00  Y E E{TVWW][]^^ !#77 IDUQUVV     r7rr>rcK||dd{VsdS|jdd{V|||||d{V}|ds=|dd}|jd |dd{VdS|d }|d p|}|rd |d nd|d} |jd| dd{V|r|j||pd } | r"|r"| |||| d{VdSdSdS)zGCreate a Discord thread from a slash command and start a session in it.z/threadNTrGrr)rz unknown errorzFailed to create thread: r*rOz<#r,**zCreated thread rA) rErIr_create_threadrfollowupr>r5markr/_dispatch_thread_session) rlr*r>r\rrrr*rOlinkstarters r5rz*DiscordAdapter._handle_thread_create_slash s'44[)LLLLLLLL  F"((4(888888888** "7 +        zz)$$ JJw88E&++,O,O,O[_+`` ` ` ` ` ` ` ` FJJ{++ jj//74 %.G I    3G 3G3G3G"''(@$(@(@D'QQQQQQQQQ  * M  y ) ) )=b''))  ^y ^// Y U\]] ] ] ] ] ] ] ] ] ] ^ ^ ^ ^r7r*c Kd}t|dr|jr |jj}|r|d|n|}t|dd}|r||dnd}|||dt |jj|jj || } | t|dd} t t| d dpd} | || pd} | || pd} t|tj| || | }||d{VdS) zMBuild a MessageEvent pointing at a thread and send it through handle_message.rAryryrNTrerJrgr)rarjrr auto_skillrk)rryr>r:rlrmr(rrrz_thread_parent_channel_resolve_channel_skillsrprrror)rlr*r*rOrarzrh_chanrir_parent_channel _parent_id_skills_channel_promptrs r5rxz'DiscordAdapter._dispatch_thread_sessionE s ; ( ( 0[-> 0$*/J7ARz33k333{  Y55INXT..u.EEETX "" (+,,!&3!#  55gk9VZ6[6[\\$;;ArBB ..y*:LMM66y*BTPTUU$)#*    !!%(((((((((((r7rr;list[str] | Nonec<ddlm}||jj||S)a1Look up auto-skill bindings for a Discord channel/forum thread. Config format (in platform extra): channel_skill_bindings: - id: "123456" skills: ["skill-a", "skill-b"] Also checks parent_id so forum threads inherit the forum's bindings. r)resolve_channel_skills)rrrr<)rlrr;rs r5r~z&DiscordAdapter._resolve_channel_skillso s1 BAAAAA%%dk&7YOOOr7c<ddlm}||jj||S)zSResolve a Discord per-channel prompt, preferring the exact channel over its parent.r)resolve_channel_prompt)rrrr<)rlrr;rs r5rpz&DiscordAdapter._resolve_channel_prompt{ s.AAAAAA%%dk&7YOOOr7c |jjd}|:t|tr|dvSt |StjdddvS)z>Return whether Discord channel messages require a bot mention.require_mentionN)rrrrDISCORD_REQUIRE_MENTIONrC) rr<rrr(r4r8rGrH)rl configureds r5_discord_require_mentionz'DiscordAdapter._discord_require_mention s[&**+<==  !*c** M!''))1LLL ## #y2F;;AACCKfffr7rZcX|jjd}|tjdd}t |t r d|DS|!t|nd}|rd| dDStS)a"Return Discord channel IDs where no bot mention is required. A single ``"*"`` entry (either from a list or a comma-separated string) is preserved in the returned set so callers can short-circuit on wildcard membership, consistent with ``allowed_channels``. free_response_channelsNDISCORD_FREE_RESPONSE_CHANNELSrAch|]D}t|#t|ESr;)r(r/rparts r5rCzADiscordAdapter._discord_free_response_channels.. s=KKK$T9J9JKCIIOO%%KKKr7c^h|]*}||+Sr;r0rs r5rCzADiscordAdapter._discord_free_response_channels.. s-JJJTTZZ\\JDJJLLJJJr7rD) rr<rrGrHrrr(r/rrZ)rlrIss r5_discord_free_response_channelsz.DiscordAdapter._discord_free_response_channels sk##$<== ;). s(ZZ1AZZZZZZr7z&auto_archive_duration must be one of: rNz.Could not resolve the current Discord channel.zIDiscord threads can only be created inside server text channels, not DMs.z=Could not determine a parent text channel for the new thread.rrz unknown userz Requested by z via /threadr>rrCTr>)r)r*rO!🧵 Thread created by Hermes: **rtzTDiscord rejected direct thread creation and the fallback also failed. Direct error: z. Fallback error: )r/!VALID_THREAD_AUTO_ARCHIVE_MINUTESrrrrrSrpr}r:rNr>r(rr~)rlr*r>r\rrrparent_channelrzrCstarter_messagerJ direct_error seed_contentseed_msgfallback_errors r5ruzDiscordAdapter._create_thread s[ !!## 978 8 (I I IiiZZ7X0Y0YZZZZZGPgPPPQ Q99+FFFFFFFF ?MN N gw0 1 1 jhi i44W==  !\] ]w{FDAA>SWXXj\j ;;;;"=b//11! )77&;8F  3kk/222222222 ^^&vvt<<D      .d2d\`2d2d2d !/!4!4\!B!BBBBBBB'55*?! 6   $!$VY#*664#@#@#HD    Z)5ZZIWZZ  sJ:A#E H)A)GH G;" G6+G;,G>0H6G;;G>>H'DiscordMessage'cK|jpd}tjdd|}tjdd|}tjdd|}|r |ddnd}t |dkr |dd d z} ||d d{V}|S#t $r}tt|d dddpd}d|} |j d|dd{V}||d |d{V}|cYd}~S#t $r1} t d|j || Yd} ~ Yd}~dSd} ~ wwxYwd}~wwxYw)zCreate a thread from a user message for auto-threading. Returns the created thread object, or ``None`` on failure. rAz <@[!&]?\d+>z<#\d+>z\s+r Nr|HermesMr_r)r>rrlrzrzAuto-threaded from mention by rrtrzF[%s] Auto-thread creation failed. Direct error: %s. Fallback error: %s) r"r/resubrrNr~r:rr>rxrr>) rlr\r"rOrJrrzrCrrs r5_auto_create_threadz"DiscordAdapter._auto_create_thread s ?(b//11&W55&B00&g..4466&-;gcrcll8 w<<"  %crc*U2K "00kY]0^^^^^^^^FM   "77Hd#C#C^UYZZl^lLDlDDF !(!5!56o`k6o6o6o!p!ppppppp'55$*.! 6       \I "  ttttttttt  sC!C E> 'E92AD;5E>; E6"E1'E91E66E99E>dangerous command session_keyrOptional[dict]cBK|jrtstddS |}|r|dr|d}|jt |}|s-|jt |d{V}d}t||kr|n|d|dz dz} tj d d | d tj } | d |dt||j|j} || | d{V} tdt#| jS#t&$r(} tdt#| cYd} ~ Sd} ~ wwxYw)u Send a button-based exec approval prompt for a dangerous command. The buttons call ``resolve_gateway_approval()`` to unblock the waiting agent thread — this replaces the text-based ``/approve`` flow on Discord. Fr'r(r*Nr^r_u ⚠️ Command Approval Requiredz``` z ```rrcolorReason)r>rinlinerrYallowed_role_idsembedviewTr`)r!r:rrr5rr6rrSEmbedColororange add_fieldExecApprovalViewr]r%r>r(rr~)rlr!rrrr$ target_idrmax_desc cmd_displayrrrrs r5send_exec_approvalz!DiscordAdapter.send_exec_approval* s| D#4 De?CCC C ;I 2HLL55 2$[1 l..s9~~>>G K $ : :3y>> J JJJJJJJH%(\\X%=%=''7>XXY\>CZ]bCbKM86K666m**,,E OOUO K K K#'!%!7!%!7D  5t <<<<<<<r(rr~)rlr!rr\rrr$rrrbodyrrrrs r5send_slash_confirmz!DiscordAdapter.send_slash_confirmX s | D#4 De?CCC C ;I 2HLL55 2$[1 l..s9~~>>G K $ : :3y>> J JJJJJJJH!'llh6677GNhQRlNr(rr~) rlr!rr?rr$rr default_hintrrrrs r5send_update_promptz!DiscordAdapter.send_update_prompt~ s| D#4 De?CCC C ;5=h(,,{B[B[h [111ahIl..s9~~>>G K $ : :3y>> J JJJJJJJ7>F33333BLM3%5|55m((**E $'!%!7!%!7D  5t <<<<<<<r(rrxrr>)rlr!rrrrrr$rrrprovider_labelrrrrs r5send_model_pickerz DiscordAdapter.send_model_picker s'| D#4 De?CCC C) ;I 2HLL55 2$[1 l..s9~~>>G K $ : :3y>> J JJJJJJJ 2::::::!*+;! 1 M M Me3q66::: : : : : : : ;sCA7EB-,E- B<9E;B<F)#F.)F.ct|dd}|%t|ddt|jSt|dd}|t|SdS)zKReturn the parent channel ID for a Discord thread-like channel, if present.rNrr;)r:r(r)rlrrr;s r5r6z%DiscordAdapter._get_parent_channel_id s`(D11  '&$"="="Ivy>> !G[$77  y>> !tr7c|dSttdd}|rt||rdSt|dd}|t|d|}|dkrdSdS)zCBest-effort check for whether a Discord channel is a forum channel.NF ForumChannelTrmrr)r:rSr)rlr forum_cls channel_type type_values r5r7zDiscordAdapter._is_forum_parent sx ?5G^T::  GY77 4w55  # w EEJRtur7rfct|dd}|s;|r9t|dd}|r&||rt|dd}|S)zUReturn the channel topic, falling back to the parent forum's topic for forum threads.topicNr)r:r7)rlrrfrrs r5rlz#DiscordAdapter._get_effective_topic sf$// 7 7Wh55F 7$//77 766 r7rJct|ddptt|dd}t|dd}t|ddpt|dd}t|dd}t|dd}||r|r |r |d|d|S|r |r |d|d|S|r|d|S|S) zdBuild a readable chat name for thread-like Discord channels, including forum context when available.r>NrrJrryryrd)r:r(r7)rlrJrOrryrz parent_names r5_format_thread_chat_namez'DiscordAdapter._format_thread_chat_name sffd33[s764QY;Z;Z7[7[ 400..P'&'42P2PUFD11 ffd33   ( ( CZ CK C BB[BB[BB B  D: D CCkCCkCC C  4!33k33 3r7Optional[bytes]c Kt|dd}|t|sdS |d{VS#t$rG}tdt|ddpt|dd|Yd}~dSd}~wwxYw)a5Read an attachment via discord.py's authenticated bot session. Returns the raw bytes on success, or ``None`` if ``att`` doesn't expose a callable ``read()`` or the read itself fails. Callers should treat ``None`` as a signal to fall back to the URL-based downloaders. rNz9[Discord] Authenticated attachment read failed for %s: %srWurlz )r:callabler~rxr)rlattreaderrs r5_read_attachment_bytesz%DiscordAdapter._read_attachment_bytes'sfd++ >&!1!1>4 >>>>>> !    NNKZ..R'#uk2R2R    44444  s8 B r3|j>|-kr(t$=d5|j>|j) |?||)d{V}.t|.|j)pd6|)}*tX|)}/|%6|*|&6|/t$Ad7|*d8}0|)d9vrpt|.|0kr] |.Cd:}1|j)pd6|)}2tjEd;d<|2}2d=|2d>|1}3|'r|'d?|3}'n|3}'n#t$rYnwxYw#tp$r.}+t$=d@|j)|+dAYd}+~+3d}+~+wwxYw|}4|'r |4r|'d?|4n|'}4|4r|4sdB}4|j}5t t9|5dCdpd}6t t9|5dDd}7|G|7|6pd}8|H|7|6pd}9d}:d};|jIrBt |jIjJ}:|jIjKrt9|jIjKdEdpd};t|4||$|t |j|%|&|:|;|jM|8|9F }<|r|j ||t:j!kr"|jNd(kr|O|<dS|P|<d{VdS)Gz!Handle incoming Discord messages.NFTr+r,rAr-r.c^h|]*}||+Sr;r0rrs r5rCz1DiscordAdapter._handle_message..s2#g#g#g2\^\d\d\f\f#gBHHJJ#g#g#gr7rDr2z0[%s] Ignoring message in non-allowed channel: %sr3c^h|]*}||+Sr;r0rs r5rCz1DiscordAdapter._handle_message..s2cccrXZX`X`XbXbc cccr7z,[%s] Ignoring message in ignored channel: %sc,h|]}t|Sr;r)rch_ids r5rCz1DiscordAdapter._handle_message..s[[[uE [[[r7DISCORD_NO_THREAD_CHANNELSc^h|]*}||+Sr;r0rs r5rCz1DiscordAdapter._handle_message..s2!g!g!g\^\d\d\f\f!g"((**!g!g!gr7DISCORD_AUTO_THREADrCrfrmrzimage/zvideo/zaudio/rwrJrcr>ryrdrer`) r!rhr}rrLr*rirrparent_chat_idr3rrr;r).jpgz.jpegz.pngz.gifz.webpr z[Discord] Cached user image: )flushz,[Discord] Failed to cache image attachment: ).oggz.mp3r z.webmz.m4ar z[Discord] Cached user audio: z,[Discord] Failed to cache audio attachment: ci|]\}}|| Sr;r;)rrVrs r5rz2DiscordAdapter._handle_message..Js"U"U"UDAq1a"U"U"Ur7z7[Discord] Unsupported document type '%s' (%s), skippingiz5[Discord] Document too large (%s bytes), skipping: %sdocumentz"[Discord] Cached user document: %si)z.mdz.txtz.logzutf-8z [^\w.\- ]rz [Content of z]: z z)[Discord] Failed to cache document %s: %srz.(The user sent a message with no text content)r;rr") rarjrrr3 media_urls media_typesreply_to_message_id reply_to_textrr|rk)QrrrSr5r(rr6r"r/r!rrcrrprrGrHrrxrr>rrr.rr8r5r4r:rrnrrwror0rnrrPHOTOVIDEOAUDIOrWrsplitextr%DOCUMENTrlrrryrlrmrzrrrr~rrrrrsizerr$ryrrrrUnicodeDecodeErrorr~rpr0r3resolvedr created_atr*_enqueue_text_eventr)=rlr\r*parent_channel_idrfis_voice_linked_channel raw_contentnormalized_contentmention_prefixr:allowed_channels_rawallowed_channelsignored_channels_rawignored_channels free_channelsrvoice_linked_idscurrent_channel_idis_free_channel in_bot_threadauto_threaded_channelno_thread_channels_rawno_thread_channels skip_thread auto_threadis_reply_messagerJrrrdoc_extreffective_channelr}rhriryrrrpending_text_injectionrr cached_pathr mime_to_ext MAX_DOC_BYTESrdoc_mimeMAX_TEXT_INJECT_BYTES text_contentrz injection event_textrrrrr reply_to_idrrs= r5rrzDiscordAdapter._handle_messages9  w??  MGO.//I $ ; ;GO L L "'o++-- ( <  1!2g6F!F!F!N!3!;!;(?(?% $I #FII,2)M&&y111#  ( ( - - "*HH   *  #'228<< <#.#4)44X>> <#.#4)44X>><#.#4"$<6)+)9)9#,)G)GJAw&-mmooG"&>>>'2';HE"2DW_ gow'8 9 9 KI+II  K I556GHHIIIW_=O9P9PQQIw00 KW_5J K&49JJyJJ ..w).TT $//""),--)**n1!7>5%88&+5S]]],7:#      04&O O C+8yL&&x00M  5 2 23 7 7 ; A A# F Fq IIC"LLL$(,(A(A#s(K(K"K"K"K"K"K"KK%%k222&&|444G+GGtTTTTT 555LLLTXYYYY%%cg...&&|44444444 5 ((22>  5 2 23 7 7 ; A A# F Fq IIC"KKK$(,(A(A#s(K(K"K"K"K"K"K"KK%%k222&&|444G+GGtTTTTT 555LLLTXYYYY%%cg...&&|444444445 <&W--cl;;FAs))++C<|<"U"U4L4R4T4T"U"U"UK%//,;;C666NNQ(y, %5Mx!CH}$<$<SHcl .2.J.J3PS.T.T(T(T(T(T(T(TI*C )3<+K;Kc;K;K++K(@'DH&--k:::'..x888"KK(LkZZZ4>1"&===#i..TiBiBi !)3<3C3CG3L3LL36<3SCScCSCSL356,\3Z3ZL0_|0_0_Q]0_0_I'=%KDZAkAk`iAkAk(>(>AJ(>'9!)!)!)$(D!)("NN K # a$+( ! oHRn2DD DDDXnJ J!1!1!3!3 JIJ R88>B?? wudB//00..x9KtLL66xAStTT    ]g/:;;K ) ] '(9(BIt T T \X\ !7:!# +'(*    "  * M  y ) ) ) {' ' 'D,JQ,N,N  $ $U + + + + +%%e,, , , , , , , , , ,sr B]$$ ^<.A^77^<Ba.. c8Acc*B!j* A jj* j%"j*$j%%j** k"4#kk"cddlm}||j|jjdd|jjddS)z-Session-scoped key for text message batching.r)build_session_keygroup_sessions_per_userTthread_sessions_per_userF)r>r?)gateway.sessionr=rrr<r)rlrr=s r5_text_batch_keyzDiscordAdapter._text_batch_keysg555555  L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]    r7c||}|j|}t|jpd}|||_||j|<nw|jr$|jr|jd|jn|j|_||_|jr>|j|j|j|j|j |}|r(| s| tj |||j |<dS)zBuffer a text event and reset the flush timer. When Discord splits a long user message at 2000 chars, the chunks arrive within a few hundred milliseconds. This merges them into a single event before dispatching. rANr)rAr,rrra_last_chunk_lenrrrr-rVrWr"rX_flush_text_batch)rlrrr chunk_len prior_tasks r5rz"DiscordAdapter._enqueue_text_eventsL""5))-11#66 (b))  $-E !.3D &s + +z bDLM a8= @ @EJ @ @ @W\Wa '0H $ ?#**5+;<<<$++E,=>>>377<<  joo//      .5.A  " "3 ' '/ / &s+++r7rc|Ktj} |j|}|rt |ddnd}||jkr|j}n|j}tj|d{V|j |d}|s< |j ||ur|j |ddSdSt d|t|jpdtj||d{Vn#tj$rYnwxYw|j ||ur|j |ddSdS#|j ||ur|j |dwwxYw)zWait for the quiet period then dispatch the aggregated text. Uses a longer delay when the latest chunk is near Discord's 2000-char split point, since a continuation chunk is almost certain. rCrNz+[Discord] Flushing text batch %s (%d chars)rA)r" current_taskr,rr:_SPLIT_THRESHOLDr+r*rrr-rxryrrashieldrr)rlrrHpendinglast_lendelayrs r5rDz DiscordAdapter._flush_text_batchs +--  >044S99GAHOww(91===aH4000<6-&& & & & & & & &.223==E (-11#66,FF.223=====GF' KK=S)r**   .!4!4U!;!;<< < < < < < < < <%    D   -11#66,FF.223=====GFt-11#66,FF.223====Gs1BD1AD10F1EFEF:F;)rrr)r8rq)r)r()rrr)r)rr r)r)rr r)r)r)r)r\r r r(r)r8)rrr)r)rrrrr)r)NN) r!r(r"r(r#rr$r%r)r)rEr r"r(r)r) rEr rOrr"r(rSr rTrUr)r) r!r(r3r(r"r(r\r8r)r) r!r(rcr(rdrrerr)r)Nro) r!r(rprqr$r%rrr)r)r)r!r(rr(r)r)NNN) r!r(rr(rdrr#rr$r%r)r)rrr)r)rrrr(r)r8)rrrr()rrr)r8)rrr)r%)rrr)r()rr)rrrrrrqr)rr(r)r8)r*r+r)r,)r*r+r@r(r)r8)r*r+r@r(rCr(r)r8) rLr(rr(r@r(rCr(r)r) r!r(rXr(rdrr#rr$r%r)r) r!r(rr(rdrr#rr$r%r)r) r!r(rcr(rdrr#rr$r%r)r) r!r(rgr(rdrr#rr$r%r)r)NNNN)r!r(rcr(rdrrerr#rr$r%r)r)r!r(r)r)r!r(r)r)r"r(r)r()r*rr@r(rrr)r)r)r^)r*rrar(r)rr&) r*rr>r(r\r(rrr)r) r*rr*r(rOr(rar(r)r)rr(r;rr)r)rr(r;rr)r)r)rZ)rr r)r )r*rr)r) r*rr>r(r\r(rrr)r)r\rr)r)rN) r!r(rr(rr(rr(r$rr)r)r!r(rr(r\r(rr(rr(r$rr)r)rArAN) r!r(rr(r?r(rr(r$r%r)r)r!r(rrrr(rr(rr(r$r%r)r)rr r)r)rr r)r8)F)rr rfr8r)r)rJr r)r()r)r)rr(r)r()rr(r)rq)r\r]r)r)rrr)r()rr(r)r)^rrrrr;rIrrnrrrYrrrrrrrrrrrrr r>r8r[rbrnrrrrrrrrrrrrrrrr ror?rErDrKr[r_rerirkrrrtr~rUr9rrr,r+rJr`rrrxr~rprrr}rrurrrrrr6r7rlrrrrrrrrArrD __classcell__r>s@r5rrs(   M&S&S&S&S&S&SPzzzzx4444>*^*^*^*^X        0\.    6    H H H H T        ZZZZ6666 9 9 9 9 #'-1 h;h;h;h;h;T5 5 5 5 v&* $9 9 9 9 9 9 B ;;;;;;:"&#' @@@@@J.2 ~~~~~~~@WWWW,"&"&-1 UgUgUgUgUgUgUgv    D4444*)")")")"V $ $ $ $    ,4444 1 1 1 1 f    .JJJJ@!!!!F)))))vUUUUn    "////b0T0T0T0Tl"&"&-1 lllllll*"&"&-1 MSMSMSMSMSMSMSf"&"&-1 CnCnCnCnCnCnCnR"&"&-1 ggggggg*"&#'"&-1ttttttt$ J J J J JD%I%I%I%IN>g>g>g>g@$( -F-F-F-F-F^H4H4H4H4T# # # # JGYGYGYGYR00004JJJJ@+ + + + j%) %^%^%^%^%^N()()()()T P P P P PPPPPP gggg.;;;;.%) EEEEEEV''''V/#',;,;,;,;,;`59$;$;$;$;$;N9;-1 ; ; ; ; ;T.2;;;;;;;;;;z    R*<<<<&<<<<& ) ) ) )Dc-c-c-c-R         8&>&>&>&>&>&>&>&>r7rrY Optional[set]rc|p t}|p t}t|}t|}|s|sdSt|dd}|dS|r0 t|j}n#t $rd}YnwxYw|r||vrdS|r;t|dd} | dS d| D} n#t $rYdSwxYw| |zrdSdS)a?Shared user-or-role OR semantics for component view button clicks. Mirrors ``DiscordAdapter._is_allowed_user`` / the slash and on_message gates so every Discord interaction surface honors the same trust boundary. Component views (ExecApprovalView, SlashConfirmView, UpdatePromptView, ModelPickerView) used to receive only ``allowed_user_ids``: in role-only deployments (DISCORD_ALLOWED_ROLES set, DISCORD_ALLOWED_USERS empty) the user set was empty and the legacy "no allowlist = allow everyone" branch let any guild member click the buttons -- approving exec commands, cancelling slash confirmations, switching the model. Behavior: - both allowlists empty -> allow (preserves existing no-allowlist deployments, no regression) - user is in user allowlist -> allow - role allowlist set + user has a role in it -> allow - role allowlist set + interaction.user has no resolvable ``roles`` attribute (e.g. DM context with a role policy active) -> reject (fail closed) - otherwise -> reject TrNFrArPc0h|]}t|ddSrr)rrs r5rCz(_component_check_auth..8s$HHHWQd33HHHr7)rZr8r:r(rAttributeErrorr!) r*rYruser_setrole_setr%r&rr roles_attr user_role_idss r5_component_check_authrYs38 (355H(355HXIXI Yt ; - -D |u dg,,CC   CCC   3(??4 T7D11   5 HHZHHHMM   55  8 # 4 5s$A22 BB$ B11 B?>B?ceZdZdZ d d!fd Zd"dZd#dZej dej j d$dZ ej dej j d$dZej dej jd$dZej dej jd$dZdZxZS)%ru Interactive button view for exec approval of dangerous commands. Shows four buttons: Allow Once, Allow Session, Always Allow, Deny. Clicking a button calls ``resolve_gateway_approval()`` to unblock the waiting agent thread — the same mechanism as the text ``/approve`` flow. Only users in the allowed list can click. Times out after 5 minutes. Nrr(rYrZrrQctd||_||_|p t |_d|_dSNrr_FrrnrrYrZrrrlrrYrr>s r5rnzExecApprovalView.__init__ML GG  S  ) ) )*D $4D !$4$=D !!DMMMr7r*rr)r8c8t||j|jS)z'Verify the user clicking is authorized.rYrYrrlr*s r5 _check_authzExecApprovalView._check_authYs!(T2D4I r7rr discord.ColorrAcK|jr$|jddd{VdS||s$|jddd{VdSd|_|jjr|jjdnd}|r,||_||d|jj |j D] }d|_ |j || d{V dd l m}||j|}t d ||j||jj dS#t$$r&} t d | Yd} ~ dSd} ~ wwxYw) zIResolve the approval via the gateway approval queue and update the embed.z(This approval has already been resolved~TrGNz*You're not authorized to approve commands~r by rar)resolve_gateway_approvalzJDiscord button resolved %d approval(s) for session %s (choice=%s, user=%s)z2Failed to resolve gateway approval from button: %s)rrIrJrcr\embedsr set_footerrrzchildrendisabledrbtools.approvalrhrrxryr~r) rlr*rrrArchildrhcountrMs r5_resolvezExecApprovalView._resolve_s } !*77>$8##K00 !*77@D8 DM6A5H5OYK'.q11UYE U#   &S&SK4D4Q&S&S TTT & &!%&33%d3KK K K K K K K K XCCCCCC001A6JJ `4+V[5E5R X X X QSVWWWWWWWWW Xs0AD66 E&E!!E&z Allow OncerAstylebuttondiscord.ui.Buttonc~K||dtjdd{VdSNoncez Approved oncerprSrgreenrlr*rss r5 allow_oncezExecApprovalView.allow_onceF-- VW]5H5H5J5JO\\ \ \ \ \ \ \ \ \ \r7z Allow Sessionc~K||dtjdd{VdS)NrazApproved for session)rprSrrrzs r5 allow_sessionzExecApprovalView.allow_sessionsG-- Y 8J8J8L8LNdee e e e e e e e e er7z Always Allowc~K||dtjdd{VdS)NalwayszApproved permanentlyrprSrpurplerzs r5 allow_alwayszExecApprovalView.allow_alwayssG-- Xw}7K7K7M7MOeff f f f f f f f f fr7Denyc~K||dtjdd{VdS)NrDenied)rprSrredrzs r5rzExecApprovalView.denysF-- VW]5F5F5H5H(SS S S S S S S S S Sr7c:Kd|_|jD] }d|_ dS)z;Handle view timeout -- disable buttons and mark as expired.TNrrkrlrlrns r5 on_timeoutzExecApprovalView.on_timeouts1 DM & &!% & &r7rrr(rYrZrrQr*rr)r8r*rrr(rrdrAr(r*rrsrt)rrrrrnrcrprSuirs ButtonStyleryr{greyr~blurplerrrrrOrPs@r5rrCs  /3 " " " " " " "     ( X( X( X( XT   W5H5N  O O ] ] ] P O ]   8K8P  Q Q f f f R Q f   w7J7R  S S g g g T S g   w/B/F  G G T T T H G T  & & & & & & &r7rc^eZdZdZ dd fd Zd!dZd"dZej dej j d#dZ ej dej j d#dZej dej jd#dZdZxZS)$ruThree-button view for generic slash-command confirmations. Used by ``/reload-mcp`` and any future slash command routed through ``GatewayRunner._request_slash_confirm``. Buttons map to the gateway's three choices: * "Approve Once" → ``choice="once"`` * "Always Approve" → ``choice="always"`` * "Cancel" → ``choice="cancel"`` Clicking calls the module-level ``tools.slash_confirm.resolve(session_key, confirm_id, choice)`` which runs the handler the runner stored for this ``session_key``. Only users in the adapter's allowlist can click. Times out after 5 minutes (matches the gateway primitive's timeout). Nrr(rrYrZrrQctd||_||_||_|p t |_d|_dSr\)rrnrrrYrZrr)rlrrrYrr>s r5rnzSlashConfirmView.__init__sS GG  S  ) ) )*D (DO$4D !$4$=D !!DMMMr7r*rr)r8c8t||j|jSrrarbs r5rczSlashConfirmView._check_auth!(T2D4I r7rrrdrAcDK|jr$|jddd{VdS||s$|jddd{VdSd|_|jjr|jjdnd}|r,||_||d|jj |j D] }d|_ |j ||d{V dd l m}||j|j|d{V}|r |j|d{Vt(d |j||jj dS#t,$r(} t(d | d Yd} ~ dSd} ~ wwxYw) Nz&This prompt has already been resolved~TrGz,You're not authorized to answer this prompt~rrfrgr) slash_confirmzIDiscord button resolved slash-confirm for session %s (choice=%s, user=%s)z(Discord slash-confirm resolve failed: %sr)rrIrJrcr\rirrjrrzrkrlrbtoolsrresolverrrvr>rxryr~r) rlr*rrrArrn_slash_confirm_mod result_textrMs r5rpzSlashConfirmView._resolvesx} !*77<8##K00 !*77Bd8 DM5@5H5OYK'.q11UYE U#   &S&SK4D4Q&S&S TTT & &!%&33%d3KK K K K K K K K ]EEEEEE$6$>$>$dov%% A%.33K@@@@@@@@@ +$fk.>.K  ] ] ] GW[ \\\\\\\\\ ]s0A;E-- F7FFz Approve Oncerqrsrtc~K||dtjdd{VdSrvrxrzs r5 approve_oncezSlashConfirmView.approve_oncer|r7zAlways Approvec~K||dtjdd{VdS)NrzAlways approvedrrzs r5approve_alwayszSlashConfirmView.approve_alwayssG-- Xw}7K7K7M7MO`aa a a a a a a a a ar7Cancelc~K||dtjdd{VdS)NrW Cancelled)rprSrgreyplerzs r5rWzSlashConfirmView.cancelsG-- Xw}7L7L7N7NP[\\ \ \ \ \ \ \ \ \ \r7c:Kd|_|jD] }d|_ dSrrrs r5rzSlashConfirmView.on_timeout 1 DM & &!% & &r7r)rr(rr(rYrZrrQrrr)rrrrrnrcrprSrrsrryrrrrrWrrOrPs@r5rrsQ  ,/3 " " " " " " "     * ]* ]* ]* ]X   w7J7P  Q Q ] ] ] R Q ]   !19L9T  U U b b b V U b   1D1H  I I ] ] ] J I ]  & & & & & & &r7rceZdZdZ ddfd Zd dZd!dZej dej j dd"dZ ej dej j dd"dZdZxZS)#raIInteractive Yes/No buttons for ``hermes update`` prompts. Clicking a button writes the answer to ``.update_response`` so the detached update process can pick it up. Only authorized users can click. Times out after 5 minutes (the update process also has a 5-minute timeout on its side). Nrr(rYrZrrQctd||_||_|p t |_d|_dSr\r]r^s r5rnzUpdatePromptView.__init__r_r7r*rr)r8c8t||j|jSrrarbs r5rczUpdatePromptView._check_auth$rr7answerrrdrAc>K|jr$|jddd{VdS||s$|jddd{VdSd|_|jjr|jjdnd}|r,||_||d|jj |j D] }d|_ |j ||d{V dd l m}|}|d z } | d } | || | t$d ||jj dS#t($r&} t$d | Yd} ~ dSd} ~ wwxYw)NzAlready answered~TrGYou're not authorized~rrfrgr)get_hermes_homez.update_responsez.tmpz)Discord update prompt answered '%s' by %sz#Failed to write update response: %s)rrIrJrcr\rirrjrrzrkrlrbhermes_constantsr with_suffix write_textrrxryr~r) rlr*rrrArrnrrW response_pathtmprMs r5_respondzUpdatePromptView._respond)sK} !*77'48##K00 !*77,8 DM6A5H5OYK'.q11UYE U#   &S&SK4D4Q&S&S TTT & &!%&33%d3KK K K K K K K K I<<<<<<&(( $'9 9 #//77v&&& M*** ?K,9 I I I BCHHHHHHHHH Is0A:E,, F6FFYesu✓)rArrr rsrtc~K||dtjdd{VdS)Nyr)rrSrryrzs r5yes_btnzUpdatePromptView.yes_btnSsF-- S'-2E2E2G2GOO O O O O O O O O Or7Nou✗c~K||dtjdd{VdS)NrUr)rrSrrrzs r5no_btnzUpdatePromptView.no_btnYsF-- S'-2C2C2E2EtLL L L L L L L L L Lr7c:Kd|_|jD] }d|_ dSrrrs r5rzUpdatePromptView.on_timeout_rr7rrr)r*rrr(rrdrAr(r)rrrrrnrcrrSrrsrryrrrrrOrPs@r5rrs  /3 " " " " " " "     ( I( I( I( IT   g.A.Gu  U U P P P V U P   W-@-DE  R R M M M S R M  & & & & & & &r7rcdeZdZdZ ddfd ZddZdZddZddZddZ ddZ ddZ dZ xZ S) ruInteractive select-menu view for model switching. Two-step drill-down: provider dropdown → model dropdown. Edits the original message in-place as the user navigates. Times out after 2 minutes. Nrrrr(rrrYrZrrQctd||_||_||_||_||_||_|p t|_ d|_ d|_ | dS)Nrr_FrA) rrnrrrrrrYrZrr_selected_provider_build_provider_select) rlrrrrrrYrr>s r5rnzModelPickerView.__init__ls GG  S  ) ) )&DN!.D $4D !*D %6D "$4D !$4$=D !!DM+-D #  ' ' ) ) ) ) )r7r*rr)r8c8t||j|jSrrarbs r5rczModelPickerView._check_authrr7c |g}|jD]}|dt|dg}|dd|d}|drdnd}|t j|dd |d | |sdSt jd |dd d}|j |_ | |t j dt j jd}|j|_ | |dS)z!Build the provider dropdown menu. total_modelsmodelsr>rOz models) is_currentrNrslug)rArrzChoose a provider...r<model_provider_select placeholderr custom_idr model_cancelrArrr) clear_itemsrrrrrS SelectOptionrSelect_on_provider_selectedradd_itemButtonrr _on_cancel)rlrprorArselect cancel_btns r5rz&ModelPickerView._build_provider_selectss      G^  nc!%%"2E2E.F.FGGV977777$%EE,$7$7AyyT(#DSDki$( Z&&2 1'F #8FO MM& ! ! ! **g&9&=+J#'/J  MM* % % % % %r7 provider_slugc ~|tfd|jDd}|sdS|dg}g}|ddD]\}d|vr|ddn|}|t j|dd|dd]|sdSt j d |d d |d }|j |_ | |t j dt jjd}|j|_ | |t j dt jjd} |j| _ | | dS)z1Build the model dropdown for a specific provider.c34K|]}|dk|VdSrNr;rrrs r5rJz6ModelPickerView._build_model_select..1IIqai=.H.H.H.H.H.HIIr7Nrr<rrr)rArzChoose a model from r>r_model_model_selectru◀ Back model_backrr model_cancel2)rnextrrrrrSrrr_on_model_selectedrrrrr_on_backrr) rlrproviderrrmodel_idrrback_btnrs ` r5_build_model_selectz#ModelPickerView._build_model_selects      IIIIDNIII4H \\(B//FG"3B3K  36(??s++B//(#DSDk&ttn  Z&&[8<< 3V3V[[[.'F #5FO MM& ! ! !z(( (;(@L)H!% H  MM( # # # **g&9&=+J#'/J  MM* % % % % %r7c K||s$|jddd{VdS|jdd|_t fd|jDd}|r|dn}||r|ddnd}|r1tt|d gd nd}||kr d ||z d nd }|j tj dd|d|tj|d{VdS)NrTrGrrc34K|]}|dk|VdSrr;rs r5rJz8ModelPickerView._on_provider_selected..rr7r>rrr<z *u2 more available — type `/model ` directly*rArz Provider: **z** Select a model:rr)rcrIrJrrrrrrminrrbrSrrr)rlr*rpnamershownr<rs @r5rz%ModelPickerView._on_provider_selecteds##K00 !*77,8',X6q9M&3D #IIIIDNIII4H$($:$: .//+%%  > > >===  >44m. +!---//  5         s-4D"" D;,D66D;c K||s$|jddd{VdS| ddlm}||j}n#t$r |j}YnwxYw|jtj dd|j pdd |d tj | d{VdS) NrTrGrrrrrrrrr)rcrIrJrrrrr~rbrSrrrr)rlr*rrs r5rzModelPickerView._on_backsn##K00 !*77,8  ' ' ) ) ) 7::::::!*4+@!A!A 7 7 7!%!6 7&33m3.4+=+J..%3..."-,,..4           sA((A<;A<cKd|_||jt jddtj|d{VdS)NTrzModel selection cancelled.rr)rrrIrbrSrrrrbs r5rzModelPickerView._on_cancel5s DM      &33m3 <!-//11  4         r7c@Kd|_|dSr)rrrs r5rzModelPickerView.on_timeoutAs% DM        r7r) rrrr(rr(rr(rYrZrrQr)rr(r)rrrrrnrcrrrrrrrrOrPs@r5rrds  /3 * * * * * * *.      & & &@( &( &( &( &T    :( ( ( ( T    8           r7r)r'r(r)r(rN)rYrQrrQr)r8)K __future__rr"loggingrGrr rrcr collectionsrtypingrrrrr r getLoggerrrxrrrSrr]r discord.extrr:r`rpathlibr_Pathrinsertr(__file__rparentsgateway.configrrrgateway.platforms.helpersrrrrrrrrr r!r"r#r$r%tools.url_safetyr&r6r<rUrWrrYrViewrrrrr;r7r5rs,""""""  ######================  8 $ $$;$;$;!!8!8!8 NNN::::::::$$$$$$GNGHHH  !!!!!!33uuX..008;<<===33333333 UUUUUUUU                          )((((("   F]]]]]]]]@ _8>_8>_8>_8>_8>(_8>_8>_8>Nq>>>>BBb&b&b&b&b&7:?b&b&b&Hf&f&f&f&f&7:?f&f&f&PS&S&S&S&S&7:?S&S&S&j_____'*/_____G BBsA,,A>=A>