.cjYVUdZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddl m Z ddl mZejeZe dz ZdZiZeeeefefed <e d z Zd eeeeefffd Zd eeefd dfdZded efdZdedeeefd efdZdeeefd e efdZdeeefd efdZdeded dfdZ deeefd eeeffdZ!d e eeeffdZ"de#d e efdZ$d e eeeffdZ%ded e eeeffd Z&ded e eeeffd!Z'ded e eeeffd"Z(d eeeffd#Z)ded$ed e efd%Z*ded&ed e efd'Z+d efd(Z,dS))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.jsoni_slack_directory_warning_lastzchannel_aliases.jsonreturnctsiS ttd5}tj|}dddn #1swxYwYt |t r|niS#t$ricYSwxYw)Nutf-8encoding)CHANNEL_ALIASES_PATHexistsopenjsonload isinstancedict Exception)fdatas ;/home/ice/.hermes/hermes-agent/gateway/channel_directory.py_load_channel_aliasesr's  & & ( (  & 9 9 9 Q9Q<| ||t | drdnddd ϐ-dS) aOverlay friendly names onto directory entries by chat_id. Renames matching entries in place; injects a placeholder entry for an aliased id that hasn't been discovered yet (so a freshly-created group is addressable by name before its first message). Mutates *platforms*. FidnameTz@g.usgroupdmNrrtype thread_id) ritemsrr setdefaultliststrstripgetappendendswith) raliases plat_nameid_mapentrieschat_idfriendlymatchedes r_apply_channel_aliasesr52sp$%%G$]]__ 6&$''  &&y"55'4((  !'   GXh,, HNN4D4D 'llG~~''HG # #a&&#155;;'+A+A (AfI"G !$'*7||'<'r?rs r_channel_target_namerDWso 6?D !!gkk'&:&:!4zz !!gkk&&9&9!,,'&/,,,, Kr6originc|d}|sdS|d}|r|d|St|S)Nr1r$:r*r()rEr1r$s r_session_entry_idrIasYjj##G t ;''I(''I''' w<<r6c|dp6|dp!t|d}|d}|s|S|dpd|}|d|S)N chat_name user_namer1r$ chat_topicztopic z / rH)rE base_namer$ topic_labels r_session_entry_namerPks ;''`6::k+B+B`c&**U^J_J_F`F`I ;''I **\**B.By.B.BK ) )K ) ))r6team_iddetailcDt|t|f}tj}t|}|||z t kr(|t|<t d||dSt d||dS)zKWarn once per team/error per interval for recurring Slack refresh failures.Nz@Channel directory: failed to list Slack channels for team %s: %szQChannel directory: suppressed repeated Slack channel list failure for team %s: %s) r(time monotonicr r*)_SLACK_DIRECTORY_WARNING_INTERVAL_SECONDSloggerwarningdebug)rQrRkeynowlasts r_warn_slack_directoryr]us w<<V %C .  C ( , ,S 1 1D |sTz%NNN-0%c* N                 r6adapterscKddlm}i}|D]\}} ||jkr$t jt |d{V|d<n#||jkrt|d{V|d<Y#t$r+}t d|j |Yd}~d}~wwxYwthd}d|D}|D]9}|j } | |vs| |vs| |vrt jt| d{V|| <: dd lm} | D]J} | j|vr?| j|vr6| j|vr-t jt| jd{V|| j<Kn#t$rYnwxYwt'|t)j|d } t/t0| 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)PlatformNrAslackz)Channel directory: failed to build %s: %s>localwebhook api_serverc Jh|] }t|dt|!Sr<)getattrr().0ps r z*build_channel_directory..s*LLLaga#a&&99LLLr6)platform_registry updated_atrz&Channel directory: failed to write: %s)gateway.configr`r%DISCORDasyncio to_thread_build_discordSLACK _build_slackrrWrXr7 frozenset_build_from_sessionsgateway.platform_registryrjplugin_entriesrr5rr[ isoformatr DIRECTORY_PATH) r^r`rplatformadapterr4_SKIP_SESSION_DISCOVERYadapter_platform_namesplatr.rjentry directorys rbuild_channel_directoryrs ('''''13I%^^--[[' [8+++-4->~w-W-W'W'W'W'W'W'W )$$X^+++7+@+@%@%@%@%@%@%@ '" [ [ [ NNFXY Z Z Z Z Z Z Z Z [((J(J(JKKLL8LLLXXJ 0 0 0I%% 666 %,%67KY%W%WWWWWWW )  ??????&5577 b bE "999Ji//J"888.5.?@TV[V`.a.a(a(a(a(a(a(a %*%  b      9%%%lnn..00I D.)4444 DDD?CCCCCCCCD sCAA88 B-!B((B- A%E00 E=<E=8G G=G88G=c g}t|dd}|s|S ddl}n#t$r|cYSwxYw|jD]}|jD]8}|t |j|j|jdd9t|ddpg}|D]8}|t |j|j|jdd9| td|S) zGEnumerate all text channels and forum channels the Discord bot can see._clientNrr?)rrrBr#forum_channelsforumrA) rfrA ImportErrorguilds text_channelsr+r(rrextendru)r{channelsclient_discordrBchforumss rrqrqsKH Wi . .F """"" %  B OO"%jj!      0$77=2  B OO"%jj       OO(33444 Os  --errorct|dd}t|tr(|d}|rt |ndS|9 |d}|rt |ndS#t $rYnwxYwdS)zCReturn Slack Web API error code from SlackApiError-like exceptions.responseNr)rfrrr*r(r)rrr7s r_slack_api_error_codersuj$//H(D!!- W%%",s5zzz, LL))E!&03u:::D 0    D  4s'A:: BBc 8 Kt|ddpi}|s tjtdd{VSg}t }|D]\}} d}t dD]E}|ddd|d{V}|d sO|d d } | d krt d |nd| } t|| n|dgD]z} | d} | d} | r| r| |vr5| | | | | | drdndd{|dpid}|snGa#t$rW}t|d krt d |nt|t!|Yd}~d}~wwxYwd|D}tjtdd{VD]}}|d}||vrb|dddr||vr |||d<| || |~d|D}|r|rt%t'|}|D]} ||dd{V}|d s<|di}|dr|dd}|r||d{V}|d rk|d}|d id!p1|d"p|dp|d|d<d#|d$<n5|dp|d%p|d|d<S#t$r-}t d&|d|Yd}~d}~wwxYw|S)'aList 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). If the Slack app lacks channels:read, fall back to session history quietly instead of logging a recurring warning every refresh. _team_clientsNrazpublic_channel,private_channelT)typesexclude_archivedlimitcursorokrunknown missing_scopezPChannel directory: Slack team %s lacks channels:read; using session history onlyzusers.conversations not ok: rrr is_privateprivater?)rrr#response_metadata next_cursorc,i|]}|d|dS)rrrgrs r z _build_slack..Es"???r$xF???r6C0D0G0cdg|]-}|ddd+|.S)rrr)r* startswithrs r z _build_slack..Ts:]]]266&"+=+=+H+HI[+\+\]"]]]r6)r?is_imuser)rprofile display_name real_namer!r#name_normalizedz+Channel directory: failed to resolve %s: %s)rfrorprusetr%rangeusers_conversationsr*rWrYr]addr+rrr(rnextitervaluesconversations_info users_info)r{ team_clientsrseen_idsrQrr_pager error_coderRrcidrr4api_name_lookupreid unresolvedrespch_info peer_user user_respus rrsrss7OT::@bL F&';WEEEEEEEEE%'HEEH'--//++* $(Fr  !'!;!;:%)! "<""  ||D)) !)gy!A!AJ!_44 n# "M !L!L-gv>>>E",,z266  B&&,,C66&>>D!d!cXoo LL%%%OO! $-/VVL-A-A P y%% #,,':;;ArFF}UUE   $Q''?:: f &gs1vv666 HHHH @?h???O()=wGGGGGGGG  iioo h  yy$$//0BCC 9/))$3C$8E&M OOE " " " LL   ^]x]]]Jld<..001122  E #66uT{6KKKKKKKKxx~~((9b11;;w''i ' FB 7 7I 1*0*;*;*;*K*K$K$K$K$K$K$K $==..1 )& 1A !i 4 4 8 8 H H!/#$55#5#5!/#$55==!/$); "&M -1E&M$+KK$7$7$h7;;GX;Y;Y$h]bcg]hE&M    JERVKYZ[[[  Os9#EF== HA HH7Q  DQ  R*"RRcFt|}|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>r0s rruruss, &m44G $] 3 33r6c g} ddlm}|} t|dd}t|sg|S||d}|n#|wxYwt }|D]}i}|drJ tj|d} t| tr| }n#ttf$rYnwxYw|s?|d|d |d d }t|} | r| |vr|| || t!||d pd |d d!n3#t"$r&} t$d|| Yd} ~ nd} ~ wwxYw|S)z:Pull channels/contacts from state.db gateway session rows.r) SessionDBlist_gateway_sessionsNF)rz active_only origin_jsonr1r$r)r1r$rK chat_typer!r"z:Channel directory: state.db session read failed for %s: %s) hermes_staterrfcallablecloserr*rloadsrr TypeError ValueErrorrIrr+rPrrWrY) r>r0rdblisterrowsrrowrEparsedentry_idr4s rrrsS$&G) ****** Y[[ R!8$??FF##  HHJJJJ6=eDDDD HHJJJJBHHJJJJ55  C%'Fww}%% !ZM(:;;F!&$//(!'!:.D "wwy11!$!5!5!$!8!8 )00H x833 LL " " " NN+F33 ,,4#ZZ 44     ' 2     H 1         Ns^F8!A-F8 A-F8-B-F811C#"F8#C74F86C77CF88 G(G##G(c Vtdz dz }|sgSg} t|d5}tj|}dddn #1swxYwYt }|D]\}}t|dst|ts=| dpi}| d|krnt|} | r| |vr| | || t|| d d | d d n3#t $r&} t"d || Yd} ~ nd} ~ wwxYw|S)zGLegacy fallback: pull channels/contacts from sessions.json origin data.sessionsz sessions.jsonr rN_rErzrr!r$r"z5Channel directory: failed to read sessions for %s: %s)rrrrrrr%r(rrrr*rIrr+rPrrWrY) r> sessions_pathr0rrr_keysessionrErr4s rrrs#%% 2_DM    ! ! G` -' 2 2 2 a9Q<r1rrs rlookup_channel_typerso  ImmK,,00CC"" 66$<<7 " "66&>> ! ! ! # 4r6rc$ 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" rNrr/rBrcdg|],}t|d*|-S)r)r=r)rgrquerys rrz(resolve_channel_name..s:___b(@F(L(L(W(WX](^(^_r___r6r)rr*r)r=rDrsplitr;len) r>rrrrawr guild_partch_partrBmatchesrs @rresolve_channel_namers  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$ 4r6c 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.rz?No messaging platforms connected or no channels discovered yet.zAvailable messaging targets: rArBz Discord (z):c|dS)Nrr)cs rz.format_directory_for_display..=s qyr6)rZz discord:zDiscord (DMs):rrGz z1Use these as the "target" parameter when sending.z;Bare platform name (e.g. "telegram") sends to home channel. ) rr*anyrsortedr%r&r+rDtitlejoin) rrlinesr.rrdmsrrB 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  r6)-__doc__rorloggingrTrtypingrrrrhermes_cli.configrutilsr getLogger__name__rWryrVr tupler(float__annotations__rrr5r=rDrIrPr]rrqrrrsrurrrrrrrr6rrs  ,,,,,,,,,,,,------######  8 $ $ ""%== -1)>@tE#s(OU$:;@@@'((+AAtCc3h$78d38nB-C-C----d38nd38n#*S#X*3**** 3      2ADcNAtCH~AAAAH"tDcN3""""J  x}    j4S#X#7jjjjZ 4 4T#s(^0D 4 4 4 4-3-4S#X3G----`!S!T$sCx.5I!!!!PS#X&sSXc],,3,8C=,,,,^+c++++++r6