`gj?I\dZddlZddlZddlZddlmZddlmZmZmZm Z ddl m Z ddl m Z ejeZe dz Ze dz Zd eeeeefffd Zd eeefd dfd Zd ed efdZdedeeefd efdZdeeefd e efdZdeeefd efdZdeeefd eeeffdZd eeeeffdZd eeeeffdZded eeeeffdZded eeeeffdZded eeeeffdZd eeeffdZ deded e efdZ!deded e efd Z"d efd!Z#y)"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.jsonzchannel_aliases.jsonreturnctjsiS ttd5}tj|}dddt t r|SiS#1swYxYw#t$ricYSwxYw)Nutf-8encoding)CHANNEL_ALIASES_PATHexistsopenjsonload isinstancedict Exception)fdatas L/root/.hermes/venv/lib/python3.12/site-packages/gateway/channel_directory.py_load_channel_aliasesrsp  & & (  & 9 Q99Qlocalwebhook api_serverr6)platform_registry updated_atrz&Channel directory: failed to write: %s)gateway.configrQr$DISCORDasyncio to_thread_build_discordSLACK _build_slackrloggerwarningr6 frozensetgetattrr'_build_from_sessionsgateway.platform_registryrVplugin_entriesrr4rnow isoformatr DIRECTORY_PATH)rOrQrplatformadapterr3_SKIP_SESSION_DISCOVERYpadapter_platform_namesplatr-rVentry directorys rbuild_channel_directoryrrps- (13I%^^-[' [8+++-4->->~w-W'W )$X^^++7+@%@ '" [((JKCKLaga#a&9LLXJJ 0 0I% 66 %,%6%67KY%WW )X  ?&557 bE "99JJi/JJ"88.5.?.?@TV[V`V`.a(a %**%  b9%lln..0I D.)4 i(X%@ [ NNFXY Z Z [M X)b     D?CC DsH=,F?F9%F?4F<5F?<H=G7,=H=)G<* H=4'HH+H:'H!G?"H51H='H7H=9F?<F?? G4!G/)H=/G44 H=?H H  H= H  H= H:H5/H=5H::H=c g}t|dd}|s|S ddl}|jD]}|jD]?}|j t |j|j|jddAt|ddxsg}|D]?}|j t |j|j|jddA|jtd|S#t$r|cYSwxYw) zGEnumerate all text channels and forum channels the Discord bot can see._clientNrr=)rrr@r"forum_channelsforumr?) rcr? ImportErrorguilds text_channelsr*r'rrextendrd)rkchannelsclient_discordr@chforumss rr]r]sH Wi .F "%% B OO"%%j!    0$7=2 B OO"%%j   * OO(34 O3 sC)) C76C7c "Kt|ddxsi}|s"tjtdd{Sg}t }|j D]\}} d}t dD]}|jddd|d{}|jd s)tjd ||jd d n|jd gD]f} | jd} | jd} | r| r| |vr.|j| |j| | | jdrdnddh|jdxsijd}|rntjtdd{D]G} | jd|vs|j| |j| jdI|S77X#t$r"} tjd|| Yd} ~ d} ~ wwxYw7w)a.List Slack channels the bot has joined across all workspaces. Uses ``users.conversations`` against each workspace's web client. Pulls public + private channels the bot is a member of, then merges in DMs discovered from session history (IMs aren't useful to enumerate proactively). _team_clientsNrRzpublic_channel,private_channelT)typesexclude_archivedlimitcursorokz=Channel directory: users.conversations not ok for team %s: %serrorunknownr{rr is_privateprivater=)rrr"response_metadata next_cursorz@Channel directory: failed to list Slack channels for team %s: %s)rcr[r\rdsetr$rangeusers_conversationsr)r`raaddr*r)rk team_clientsr{seen_idsteam_idr|r_pageresponser~cidrr3rps rr_r_s7OT:@bL &&';WEEE%'HEH'--/$# $(Fr !'!;!;:%)! "<"  ||D)NNW Wi8 ",,z26 B&&,C66&>DdcXo LL%OO! $-/VVL-A y% #,,':;ArFF}U7 $N(()=wGG* 99T?( * OOE " LL4 )* OcF6  NNR    Hsd1HG'H(GGCG%G( HH  H$6HG H (H?HH  Hc6t|}|r|St|S)zPull known channels/contacts from gateway session origin data. state.db is the primary source (#9006): gateway session rows persist origin_json. Falls back to sessions.json for pre-migration databases. )_build_from_sessions_db_build_from_sessions_json)r<r/s rrdrds! &m4G $] 33r5c 2g} ddlm}|} t|dd}t|sg|j S||d}|j t }|D]}i}|j dr+ tj|d} t| tr| }|s3|j d|j d |j d d }t|} | r| |vr|j| |j| t!||j d xsd |j d d |S#|j wxYw#ttf$rYwxYw#t"$r"} t$j'd|| Yd} ~ |Sd} ~ wwxYw)z:Pull channels/contacts from state.db gateway session rows.r) SessionDBlist_gateway_sessionsNF)rj active_only origin_jsonr0r# display_name)r0r#rI chat_typer r!z:Channel directory: state.db session read failed for %s: %s) hermes_staterrccallablecloserr)rloadsrr TypeError ValueErrorrGrr*rNrr`debug) r<r/rdblisterrowsrrowrCparsedentry_idr3s rrr#s$&G) * [ R!8$?FF# HHJ=eDD HHJ5 C%'Fww}%!ZZM(:;F!&$/!'"wwy1!$!5!$!8 )0Hx83 LL " NN+F3 ,4#ZZ 4  ' < NC HHJ":.$   H 1   N  s] E+EE+ E2E+9*E#BE+EE+E(%E+'E((E++ F4FFc tdz dz }|jsgSg} t|d5}tj|}dddt }j D]\}}t|jdst|ts1|jdxsi}|jd|k7r[t|} | r| |vrm|j| |j| t||jd d |jd d  |S#1swYxYw#t $r"} t"j%d || Yd} ~ |Sd} ~ wwxYw)zGLegacy fallback: pull channels/contacts from sessions.json origin data.sessionsz sessions.jsonr r N_rCrjrr r#r!z5Channel directory: failed to read sessions for %s: %s)rrrrrrr$r' startswithrrr)rGrr*rNrr`r) r< sessions_pathr/rrr_keysessionrCrr3s rrrSsT#% 2_DM    ! G` -' 2 a99Q !" r5rct}|jdij|g}|sy|j}|D]}|jd|k(s|dcSt|}|D]9}t|d|k(r|dcStt |||k(s4|dcSd|vrh|j dd\}}|D]N}|jddjj } | |k(s7t|d|k(sI|dcS|Dcgc]"}t|dj|s!|$} }t| dk(r| d dSycc}w) 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" rNrr/r@r) rr)r(r;rBrsplitr:rlen) r<rrqr{rawr~query guild_partch_partr@matchess rresolve_channel_namers| I}}["-11-DH  **,C 66$<3 d8O %T *E #BvJ /5 8d8O #$8$K LPU Ud8O  e|#ll32 G BFF7B'--/557E "'?6 'Kw'V$x %_b(@F(L(W(WX](^r_G_ 7|qqz$  `s "E>Ec t}|jdi}t|jsydg}t |j D]m\}}|s |dk(ri}g}|D]H}|jd}|r"|j |gj|8|j|Jt |j D]K\} } |jd| dt | d D] }|jd t||"M|r6|jd |D] }|jd t||"|jd |j|jd |D]#}|jd|d t||%|jd p|jd|jddj|S)zDFormat the channel directory as a human-readable list for the model.rz?No messaging platforms connected or no channels discovered yet.zAvailable messaging targets: r?r@z Discord (z):c |dS)Nr)cs rz.format_directory_for_display..s qyr5)keyz discord:zDiscord (DMs):rrEz z1Use these as the "target" parameter when sending.z;Bare platform name (e.g. "telegram") sends to home channel. ) rr)anyvaluessortedr$r%r*rBtitlejoin) rqrlinesr-r{rxdmsr~r@ guild_nameguild_channelss rformat_directory_for_displayrs I k2.I y! "P - .E%ioo&78 8   !&(FC #w%%eR077;JJrN  #/5V\\^.D U* N y B78 5HIUBLL:.B9b.Q-R!STU U -.UBLL:.B9b.Q-R!STU LL  LLIOO-.a0 1 U r)A.B9b.Q-RST U LL 9< LLDE LLNO 99U r5)$__doc__r[rloggingrtypingrrrrhermes_cli.configrutilsr getLogger__name__r`rirr'rr4r;rBrGrNrrr]r_rdrrrrrrrr5rrs ,,-#   8 $ "%=='(+AAtCc3h$78d38nB-C-C-d38nd38n#*S#X*3*ADcNAtCH~AH"tDcN3"J;4S#X#7;| 4 4T#s(^0D 4-3-4S#X3G-`!S!T$sCx.5I!PS#X&sSXc],,3,8C=,^+c+r5