i3$dZddlZddlZddlmZddlmZmZmZmZddl m Z ddl m Z ej eZe dz Zded efd Zd ed eeefd efd Zdeeefd eefdZdeeefd efdZdeeefd eeeffdZd eeeeffdZd eeeeffdZd ed eeeeffdZd eeeffdZd eded eefdZd eded eefdZd efdZdS)a6 Channel directory -- cached map of reachable channels/contacts per platform. Built on gateway startup, refreshed periodically (every 5 min), and saved to ~/.hermes/channel_directory.json. The send_message tool reads this file for action="list" and for resolving human-friendly channel names to numeric IDs. N)datetime)AnyDictListOptional)get_hermes_home)atomic_json_writezchannel_directory.jsonvaluereturnct|dS)N#)lstripstriplower)r s >/home/ubuntu/.hermes/hermes-agent/gateway/channel_directory.py_normalize_channel_queryrs, <<   " " $ $ * * , ,, platform_namechannelc|d}|dkr|drd|S|dkr#|dr|d|ddS|S)zHReturn the human-facing target label shown to users for a channel entry.namediscordguildr typez ())get)rrrs r_channel_target_namerso 6?D !!gkk'&:&:!4zz !!gkk&&9&9!,,'&/,,,, Kroriginc|d}|sdS|d}|r|d|St|S)Nchat_id thread_id:rstr)rr r!s r_session_entry_idr%$sYjj##G t ;''I(''I''' w<<rc|dp6|dp!t|d}|d}|s|S|dpd|}|d|S)N chat_name user_namer r! chat_topicztopic z / r#)r base_namer! topic_labels r_session_entry_namer,.s ;''`6::k+B+B`c&**U^J_J_F`F`I ;''I **\**B.By.B.BK ) )K ) ))radapterscNKddlm}i}|D]\}} ||jkrt ||d<n#||jkrt |d{V|d<H#t$r+}t d|j |Yd}~xd}~wwxYwthd}|D]$}|j }||vs||vrt|||<% ddl m} | D]0} | j|vr%| j|vrt| j|| j<1n#t$rYnwxYwt#j|d } t)t*| n2#t$r%}t d |Yd}~nd}~wwxYw| S) z Build a channel directory from connected platform adapters and session data. Returns the directory dict and writes it to DIRECTORY_PATH. r)PlatformrNslackz)Channel directory: failed to build %s: %s>localwebhook api_server)platform_registry updated_at platformsz&Channel directory: failed to write: %s)gateway.configr/itemsDISCORD_build_discordSLACK _build_slack Exceptionloggerwarningr frozenset_build_from_sessionsgateway.platform_registryr4plugin_entriesrrnow isoformatr DIRECTORY_PATH) r-r/r7platformadaptere_SKIP_SESSION_DISCOVERYplat plat_namer4entry directorys rbuild_channel_directoryrP<s\ ('''''13I%^^--[[' [8+++'5g'>'> )$$X^+++7+@+@%@%@%@%@%@%@ '" [ [ [ NNFXY Z Z Z Z Z Z Z Z [ ((J(J(JKK??J / / /9 3I3I 3I>> ) ??????&5577 I IEz!888UZy=X=X()rI team_clientsr\seen_idsteam_idr]rh_pageresponser_cidrrJrNs rr=r=s7OT::@bL -#G,,,%'HEEH'--//$$# $(Fr  !'!;!;:%)! "<""  ||D))NNW Wi88 E",,z266  B&&,,C66&>>D!d!cXoo LL%%%OO! $-/VVL-A-A P y%% #,,':;;ArFF}UUE    NNR    HHHH  &g..** 99T??( * * OOE " " " LL4 ) ) ) OsD;F GF;;Gc tdz dz }|sgSg} t|d5}tj|}dddn #1swxYwYt }|D]\}}|dpi}|d|kr6t|} | r| |vrL| | | | t||dd |d d n3#t$r&} td || Yd} ~ nd} ~ wwxYw|S) zr?debug) r sessions_pathentriesfdataru_keysessionrentry_idrJs rrBrBs#%% 2_DM    ! ! G` -' 2 2 2 a9Q<A  D> A$$D>'A$(CD>> E.E))E.ctsdidS ttd5}tj|cdddS#1swxYwYdS#t $rdidcYSwxYw)z,Load the cached channel directory from disk.Nr5r|r})rGrrrrr>)rs rload_directoryrs  " "5"4445 .7 3 3 3 q9Q<<                  555"444445s4A$A A$AA$AA$$A65A6r ct}|di|gD]2}|d|kr|dcS3dS)ziReturn the channel ``type`` string (e.g. ``"channel"``, ``"forum"``) for *chat_id*, or *None* if unknown.r7rSrN)rr)rr rOr_s rlookup_channel_typerso  ImmK,,00CC"" 66$<<7 " "66&>> ! ! ! # 4rrc$ t}|di|g}|sdS|}|D]%}|d|kr |dcS&t| |D]P}t|d kr |dcStt || kr |dcSQd vr dd\}}|D]e}|dd}||kr#t|d|kr |dcSf fd |D} t| dkr| d dSdS) a Resolve a human-friendly channel name to a numeric ID. Matching strategy (case-insensitive, first match wins): - Discord: "bot-home", "#bot-home", "GuildName/bot-home" - Telegram: display name or group name - Slack: "engineering", "#engineering" r7NrSr/rcdg|],}t|d*|-S)r)r startswith).0r_querys r z(resolve_channel_name..3s:___b(@F(L(L(W(WX](^(^_r___rr)rrrrrrsplitrlen) rrrOr\rawr_ guild_partch_partrmatchesrs @rresolve_channel_namer s  I}}["--11-DDH t **,,C 66$<<3  d8OOO  %T * *E #BvJ / /5 8 8d8OOO #$8$K$K L LPU U Ud8OOO V e||#ll322 G  BFF7B''--//5577E ""'?6 'K'Kw'V'V$x`___H___G 7||qqz$ 4rc t}|di}t|sdSdg}t |D]\}}|s |dkr3i}g}|D]X}|d}|r*||g|C||Yt |D]Y\} } |d| dt | d D](}|d t||)Z|r@|d |D](}|d t||)|d C|| d |D]+}|d|d t||,|d |d|dd |S)zDFormat the channel directory as a human-readable list for the model.r7z?No messaging platforms connected or no channels discovered yet.zAvailable messaging targets: rrz Discord (z):c|dS)Nr)cs rz.format_directory_for_display..Us qyr)keyz discord:zDiscord (DMs):rr"z z1Use these as the "target" parameter when sending.z;Bare platform name (e.g. "telegram") sends to home channel. ) rranyvaluessortedr9 setdefaultrZrtitlejoin) rOr7linesrMr\rXdmsr_r guild_nameguild_channelss rformat_directory_for_displayr:s  I k2..I y!! " "QPP - .E%ioo&7&788 8    ! !&(FC # #w#%%eR0077;;;;JJrNNNN.4V\\^^.D.D U U* N 7777888 5H5HIIIUUBLL!S.B9b.Q.Q!S!STTTTU U -...UUBLL!S.B9b.Q.Q!S!STTTT LL     LLIOO--000 1 1 1 U U S)SS.B9b.Q.QSSTTTT LL     LLDEEE LLNOOO 99U  r)__doc__rloggingrtypingrrrrhermes_cli.configrutilsr getLogger__name__r?rGr$rrr%r,rPr;r=rBrrrrrrrrs ,,,,,,,,,,,,------######  8 $ $ ""%==-C-C----d38nd38n#*S#X*3****1DcN1tCH~1111h"tDcN3""""J;4S#X#7;;;;|T#s(^0DH5S#X5555sSXc],,3,8C=,,,,^+c++++++r