i%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 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 A/home/agentuser/.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 ) ))radapterscddlm}i}|D]y\}} ||jkrt ||d<n||jkrt ||d<B#t$r+}t d|j |Yd}~rd}~wwxYwthd}|D]$}|j }||vs||vrt|||<%tj|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)Platformrslackz)Channel directory: failed to build %s: %sN>localwebhook api_server updated_at platformsz&Channel directory: failed to write: %s)gateway.configr/itemsDISCORD_build_discordSLACK _build_slack Exceptionloggerwarningr frozenset_build_from_sessionsrnow isoformatr DIRECTORY_PATH) r-r/r6platformadaptere_SKIP_SESSION_DISCOVERYplat plat_name directorys rbuild_channel_directoryrL<s ('''''13I%^^--[[' [8+++'5g'>'> )$$X^++%1'%:%: '" [ [ [ NNFXY Z Z Z Z Z Z Z Z [ ((J(J(JKK??J / / /9 3I3I 3I>> )lnn..00I D.)4444 DDD?CCCCCCCCD s/;A B)!BB8D D=D88D=c <g}t|dd}|s|S ddl}n#t$r|cYSwxYw|jD]B}|jD]8}|t |j|j|jdd9C| td|S)z4Enumerate all text channels the Discord bot can see._clientNrr)idrrrr) getattrr ImportErrorguilds text_channelsappendr$rOrextendrA)rFchannelsclient_discordrchs rr:r:fsH Wi . .F """"" %  B OO"%jj!       OO(33444 Os  --ct|ddpt|dd}|stdS ddlm}n#t$rYnwxYwtdS)z'List Slack channels the bot has joined._appNrNr0r) _send_slack)rPrAtools.send_message_toolr\r=)rFrWr\s rr<r<sWfd + + Pww 4/P/PF -#G,,, 7777777        ( ((s< A A c 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) zdebug) r sessions_pathentriesfdataseen_ids_keysessionrentry_idrGs rrArAs#%% 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.Nr4r`ra)rDrerfrgrhr=)rns rload_directoryrus  " "5"4445 .7 3 3 3 q9Q<<                  555"444445s4A$A A$AA$AA$$A65A6rc t}|di|g}|sdSt| |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" r6NrrO/rcdg|],}t|d*|-S)r)r startswith).0rYquerys r z(resolve_channel_name..s:___b(@F(L(L(W(WX](^(^_r___rr)rurrrrsplitrrlen) rrrKrVrY guild_partch_partrmatchesr}s @rresolve_channel_namers  I}}["--11-DDH t $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.r6z?No messaging platforms connected or no channels discovered yet.zAvailable messaging targets: rrz Discord (z):c|dS)Nr)cs rz.format_directory_for_display..s qyr)keyz discord:zDiscord (DMs):ryr"z z1Use these as the "target" parameter when sending.z;Bare platform name (e.g. "telegram") sends to home channel. ) ruranyvaluessortedr8 setdefaultrTrtitlejoin) rKr6linesrJrVrRdmsrYr guild_nameguild_channelss rformat_directory_for_displayrs  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__rgloggingrtypingrrrrhermes_cli.configrutilsr getLogger__name__r>rDr$rrr%r,rLr:r<rArurrrrrrsv ,,,,,,,,,,,,------######  8 $ $ ""%==-C-C----d38nd38n#*S#X*3****'d38n'c3h''''TtDcN38)T$sCx.1))))"T#s(^0DH5S#X5555$$3$8C=$$$$N+c++++++r