JjFdZddlZddlZddlmZddlmZmZmZmZddl m Z ddl m Z ej eZe dz Ze dz Zd eeeeefffd Zd eeefd dfd Zd ed efdZdedeeefd efdZdeeefd eefdZdeeefd efdZdeeefd eeeffdZd eeeeffdZd eeeeffdZded eeeeffdZded eeeeffdZded eeeeffdZd eeeffdZdeded eefdZ deded eefd 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.jsonzchannel_aliases.jsonreturnctsiS ttd5}tj|}dddn #1swxYwYt |t r|niS#t$ricYSwxYw)Nutf-8encoding)CHANNEL_ALIASES_PATHexistsopenjsonload isinstancedict Exception)fdatas ?/home/rurouni/.hermes/hermes-agent/gateway/channel_directory.py_load_channel_aliasesrs  & & ( (  & 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_aliasesr4(sp$%%G$]]__ 6&$''  &&y"55'4((  !'   GXh,, HNN4D4D 'llG~~''HG # #a&&#155;;'+A+A (AfI"G !$'*7||'<'localwebhook api_server)platform_registry updated_atrz&Channel directory: failed to write: %s)gateway.configrQr$DISCORD_build_discordSLACK _build_slackrloggerwarningr6 frozenset_build_from_sessionsgateway.platform_registryrVplugin_entriesrr4rnow isoformatr DIRECTORY_PATH) rOrQrplatformadapterr3_SKIP_SESSION_DISCOVERYplatr-rVentry directorys rbuild_channel_directoryrmosl ('''''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(>D!d!cXoo LL%%%OO! $-/VVL-A-A P y%% #,,':;;ArFF}UUE    NNR    HHHH  &g..** 99T??( * * OOE " " " LL4 ) ) ) OsD;F GF;;GcFt|}|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 rrara s, &m44G $] 3 33r5c 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)rg active_only origin_jsonr0r# display_name)r0r#rI chat_typer r!z:Channel directory: state.db session read failed for %s: %s) hermes_staterrrcallablecloserr)rloadsrr TypeError ValueErrorrGrr*rNrr^debug) r<r/rdblisterrowsrrowrCparsedentry_idr3s 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 r N_rCrgrr r#r!z5Channel directory: failed to read sessions for %s: %s)rrrrrrr$r' startswithrrr)rGrr*rNrr^r) r< sessions_pathr/rrr_keysessionrCrr3s rrrEs#%% 2_DM    ! ! G` -' 2 2 2 a9Q<> ! ! ! # 4r5rc$ 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/r@cdg|],}t|d*|-S)r)r;r).0rzquerys r z(resolve_channel_name..s:___b(@F(L(L(W(WX](^(^_r___r5r)rr)r(r;rBrsplitr:len) r<rrlrwrawrz guild_partch_partr@matchesrs @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$ 4r5c 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: 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) rlrlinesr-rwrtdmsrzr@ 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  r5)#__doc__rloggingrtypingrrrrhermes_cli.configrutilsr getLogger__name__r^rfrr'rr4r;rBrGrNrmr[r]rarrrrrrrr5rrsr ,,,,,,,,,,,,------######  8 $ $ ""%=='((+AAtCc3h$78d38nB-C-C----d38nd38n#*S#X*3****4DcN4tCH~4444n"tDcN3""""J;4S#X#7;;;;| 4 4T#s(^0D 4 4 4 4-3-4S#X3G----`!S!T$sCx.5I!!!!PS#X&sSXc],,3,8C=,,,,^+c++++++r5