)j;UdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZmZerdd lmZejeZd ZdLdZdMdZdNdZdOdZdOdZddiZ hdZ!dPdZ"dQd Z#dRd"Z$dSd$Z%dTd)Z& dUdVd+Z'dWd,Z(d-Z)dXd0Z*d1Z+dYd5Z,d6d7hZ-d6d7d7d8Z.dPd9Z/d:d:d:d:d;d:dcustomdefaultc3NK|] }|s|dvr|ndV!dS)z_-_N)isalnum).0cs A/home/ubuntu/.hermes/hermes-agent/plugins/memory/honcho/client.py z#profile_host_key..(s;PP1QYY[[>AII3PPPPPPrr)HOSTjoinstrip)r sanitizeds rprofile_host_keyr#$sb g!666 PPPPPPPVVWZ[[I - -Y+) - --rrawdicthostc|dpi}||i}|s|tds|Std|ttdzd}||iS)z@Return host config, accepting legacy dot-form profile host keys.hostsr.N)get startswithrlen)r$r&r(blocklegacys r _host_blockr0,s GGG   "E IIdB  E DOOtJJJ//  - -tCIIMNN+ - -F 99VR  rctjdd}|r|S ddlm}|}t |S#t$rYnwxYwtS)a Derive the Honcho host key from the active Hermes profile. Resolution order: 1. HERMES_HONCHO_HOST env var (explicit override) 2. Active profile name via profiles system -> ``hermes.`` 3. Fallback: ``"hermes"`` (default profile) HERMES_HONCHO_HOSTrr)get_active_profile_name) osenvironr+r!hermes_cli.profilesr3r# Exceptionr)explicitr3rs rresolve_active_hostr96sz~~2B77==??H ??????))++(((      KsA A$#A$rc4tjdz dz S)z:Return the shared Honcho config path for the current HOME.z.honchoz config.json)rhomerrresolve_global_config_pathr=Ks 9;; "] 22rctdz }|r|Stdz }||kr|r|StS)uoReturn the active Honcho config path. Resolution order: 1. $HERMES_HOME/honcho.json (profile-local, if it exists) 2. ~/.hermes/honcho.json (default profile — shared host blocks live here) 3. ~/.honcho/config.json (global, cross-app interop) Returns the global path if none exist (for first-time setup writes). z honcho.json)rexistsrr=) local_path default_paths rresolve_config_pathrBPsn!""]2J,-- =Lz!!l&9&9&;&;! % ' ''rautohybrid>toolsrDcontextvalcRt||}|tvr|ndS)u?Normalize legacy recall mode values (e.g. 'auto' → 'hybrid').rD)_RECALL_MODE_ALIASESr+_VALID_RECALL_MODESrGs r_normalize_recall_moderLjs,  " "3 , ,C,,,33(:rrboolc6|D]}|t|cS|S)aEResolve a bool config field: first non-None wins, else default. Variadic to support aliased keys (e.g. ``pinUserPeer`` shadowing ``pinPeerName`` for backwards compatibility). Pass values in precedence order: caller's preferred alias first, then fallback aliases, in (host, root) interleaving as needed. )rM)rvalsrGs r _resolve_boolrPps4 ?99     Nr int | Nonecj||fD]-}|) t|cS#ttf$rY)wxYw.dS)z@Parse contextTokens: host wins, then root, then None (uncapped).Nint ValueError TypeErrorhost_valroot_valrGs r_parse_context_tokensrZ~s`(# ? 3xx *      4 //rTcj||fD]-}|) t|cS#ttf$rY)wxYw.|S)zz1_parse_dialectic_depth_levels..s75555rru)rclistr-append)rXrYrxrGlevelss r_parse_dialectic_depth_levelsrs (#   ?z#t44?vv;F f++%% e$$$f++%%MMM 4rg>@valuesr float | Nonec|D]c}|t|tr|}|s1 t|}n#tt f$rYUwxYw|dkr|cSddS)z=Return the first non-empty value coerced to a positive float.Nr)rcrr!floatrVrU)rrmparseds r_resolve_optional_floatrs   =  eS ! ! KKMME  5\\FF:&    H  A::MMM  4sAAAunified directional)sharedseparatecrosscRt||}|tvr|ndS)z"Normalize observation mode values.r)_OBSERVATION_MODE_ALIASESr+_VALID_OBSERVATION_MODESrKs r_normalize_observation_moders, # ' 'S 1 1C11133}DrTuser_observe_meuser_observe_others ai_observe_meai_observe_othersF)rrmodeobservation_obj dict | Nonect|td}|rt|tst|S|dpi}|dpi}|d|d|d|d|d|d|d|d d S) ajResolve per-peer observation booleans. Config forms: String shorthand: ``"observationMode": "directional"`` Granular object: ``"observation": {"user": {"observeMe": true, "observeOthers": true}, "ai": {"observeMe": true, "observeOthers": false}}`` Granular fields override preset defaults. ruserai observeMer observeOthersrrrr)_OBSERVATION_PRESETSr+rcr%)rrpreset user_blockai_blocks r_resolve_observationrs" % %d,@,O P PF *_d"C"CF|| $$V,,2J""4((.BH&>>+v>O7PQQ)~~ovF[?\]]!k6/3JKK%\\/6BU;VWW   rceZdZUdZeZded<dZded<dZded<d Z ded <dZ ded <dZ d ed <dZ ded<dZ ded<dZded<eeZded<dZded<dZded<dZded<dZded<dZded<d Zded!<dZded"<d#Zd$ed%<d&Zd$ed'<dZd(ed)<dZded*<d+Zded,<d-Zd$ed.<d/Zd$ed0<d1Z ded2<dZ!ded3<d4Z"ded5<dZ#ded6<dZ$ded7<dZ%ded8<dZ&ded9<d:Z'ded;<dZ(ded<<eeZ)ded=<eeZ*d>ed?<dZ+ded@<e, dQdRdBZ-e, dSdTdEZ.e/dUdGZ0dHZ1dIZ2e,dVdLZ3 dWdXdPZ4dS)YHonchoClientConfigz>Configuration for Honcho client, resolved for a specific host.rr&r workspace_idNrapi_key production environmentbase_urlrtimeout peer_nameai_peerFrM pin_peer_name)default_factoryrauser_peer_aliasesrruntime_peer_prefixenabledT save_messagesasyncz str | intwrite_frequencyrQcontext_tokensrudialectic_reasoning_leveldialectic_dynamicXrTdialectic_max_charsr*dialectic_depthrydialectic_depth_levelsreasoning_heuristicrwreasoning_level_capamessage_max_chars'dialectic_max_input_charsrD recall_modeinit_on_session_startrobservation_moderrrr per-directorysession_strategysession_peer_prefixsessionszdict[str, Any]r$explicitly_configuredrc |p t}tjd}tjddpd}t tjd}||||tjdd|||t |p|S) z4Create config from environment variables (fallback).HONCHO_API_KEYHONCHO_BASE_URLrNHONCHO_TIMEOUTHONCHO_ENVIRONMENTr)r&rrrrrrr)r9r4r5r+r!rrM)clsrr& resolved_hostrrrs rfrom_envzHonchoClientConfig.from_env~s5 3 5 5 *..!122:>>"3R88>>@@HD)"*..9I*J*JKKs% ';\JJ!,H--    r config_path Path | Nonec`|p t}|p t}|s1td|||S t j|d}nU#t j tf$r<}t d||||cYd}~Sd}~wwxYwt||}t|p|ddu}|d p|d p|} |d p|d p|} |d p3|d ptjd } |d p|d d} |dpH|dp3tjddpd} t%|d|dtjd}|d}|d}||}n||}nt| p| }|dp|dpd} t'|}n&#t(t*f$rt-|}YnwxYw|d}||n|dd}|dp|dd}|d}||n|dd}|dSid|d| d| d | d| d|d |d!p|d!d"| d#t/|d$|d%|d$|d%d&d't1||d(d)t3||d*d|d+|d,|d-t5|d.|d.d/|d0p|d0pd1d2t/|d3|d3d&d4t7|d5|d5d6&d7t9|d8|d8d9t;|d:|d:t9|d8|d8;d|d?p|d?pd@dAt7|dB|dBdC&dDt7|dE|dEdF&dGt=|dHp|dHpdIdJt/|dK|dKd&dLt?|dMp|dMp|rdNndOtAt?|dMp|dMp|rdNndO|dPp|dP|||dQi||dRS)TzCreate config from the resolved Honcho config path. Resolution: $HERMES_HOME/honcho.json -> ~/.honcho/config.json -> env vars. When host is None, derives it from the active Hermes profile. z2No global Honcho config at %s, falling back to env)r&utf-8)encodingz*Failed to read %s: %s, falling back to envNrT workspaceaiPeerapiKeyrrrbaseUrlrrrrrequestTimeoutrwriteFrequencyr saveMessagessessionStrategyrsessionPeerPrefixFr&rrrpeerNamerr pinUserPeer pinPeerName)rruserPeerAliasesrruntimePeerPrefixrrr contextTokensrdialecticReasoningLevelrurdialecticDynamicrdialecticMaxCharsrrdialecticDepthrdialecticDepthLevels)rxrreasoningHeuristicrreasoningLevelCaprwrmessageMaxCharsrrdialecticMaxInputCharsrr recallModerDrinitOnSessionStartrobservationModerr observationr)rrrr$rr<)!r9rBr?loggerdebugrjsonloads read_textJSONDecodeErrorOSErrorwarningr0rMr+r4r5r!rrTrVrUrrPrkrnrZr]rsrrLrr)rr&rrpathr$e host_block_explicitly_configuredrrrrrr host_enabled root_enabledrraw_wfr host_saverr host_prefixrs rfrom_global_configz%HonchoClientConfig.from_global_configs 5 3 5 5 3133{{}} 4 LLMt T T T<<]<33 3 4*T^^W^==>>CC$g. 4 4 4 NNGq Q Q Q<<]<33 3 3 3 3 3 3 4!m44 "&j!1!1!OSWWY5G5G45O NN; ' ' ww{##   NN8 $ $ wwx     NN8 $ $ 0wwx   0z~~.//  NN= ) ) 4ww}l33  GGI   wwz"" z~~/44::<<   * GGI   GG$ % % JNN+ , ,  "~~i00 wwy))  #"GG  %"GG7.h//G NN+ , , ww'((    *),VOO:& * * *!&kkOOO *NN>22 %.%: X\@]@]  NN, - - ;ww(/:: !nn%899 &2KK,e44  st t t t "t Gt $ t X t G t !nnZ00GCGGJ4G4Gt Gt (}--}-- && &&    t ,0!-t 6!7#!!!7t @GAt B(-Ct D,OEt F1//((Gt P89977455Ut X,122*++Yt b!2233+,,!!!!ct l3/00())mt t$A566.//,Z^^=L>cwdcddl} |gddd|d|j}|jdkr+t |jjSn#t|j f$rYnwxYwdS)zBReturn the git repo root directory name, or None if not in a repo.rN)gitz rev-parsez--show-toplevelT)capture_outputtextrrstdin) subprocessrunDEVNULL returncoderstdoutr!namerTimeoutExpired)rr roots r_git_repo_namez!HonchoClientConfig._git_repo_namens  >>777#$C ("D !##DK--//0055$23    D tsAAA32A3dr"originalc"|j}t||kr|S|j}tj|dd|}||z dz }|d|d}|d|S)a]Truncate a sanitized session ID to Honcho's 100-char limit. The common case (short keys) short-circuits with no modification. For over-limit keys, keep a prefix of the sanitized ID and append a deterministic ``-`` suffix so two distinct long keys that share a leading segment don't collide onto the same truncated ID. The hash is taken over the *original* pre-sanitization key, so two inputs that sanitize to the same string still collide intentionally (same logical session), but two inputs that only share a prefix do not. rNr*-)_HONCHO_SESSION_ID_MAX_LENr-_HONCHO_SESSION_ID_HASH_LENhashlibsha256encode hexdigestrstrip)rr"rmax_lenhash_lendigest prefix_lenprefixs r_enforce_session_id_limitz,HonchoClientConfig._enforce_session_id_limits0 y>>W $ $ 2 8 899CCEEixiPx'!+ ;J;'..s33##6###r session_title session_idgateway_session_keycddl}|stj}|j|}|r|S|rH|dd|d}|r|jr|jr |jd|S|S|rB|dd|d}|r| ||S|j dkr|r|jr|jr |jd|S|S|j dkrE| |pt|j }|jr|jr |jd|S|S|j dvr0t|j }|jr|jr |jd|S|S|jS)uResolve Honcho session name. Resolution order: 1. Manual directory override from sessions map 2. Hermes session title (from /title command) 3. Gateway session key (stable per-chat identifier from gateway platforms) 4. per-session strategy — Hermes session_id ({timestamp}_{hex}) 5. per-repo strategy — git repo root directory name 6. per-directory strategy — directory basename 7. global strategy — workspace name rNz[^a-zA-Z0-9_-]+r per-sessionzper-repo>r,r)rer4getcwdrr+subr!rrr'rrrrr) selfrr(r)r*r-manualr"bases rresolve_session_namez'HonchoClientConfig.resolve_session_names$   )++C""3''  M  !13 FFLLSQQI !+;;"n::y:::    V138KLLRRSVWWI V55iATUUU  M 1 1j 1' 8DN 8.77:777   J . .&&s++=tCyy~D' 2DN 2.114111K  $D D D99>D' 2DN 2.114111K  r)rN)rrr&rrr)NN)r&rrrrr)rrrr)r"rrrrr)NNNN) rrr(rr)rr*rrr)5__name__ __module__ __qualname____doc__rr&__annotations__rrrrrrrrrr%rrrrrrrrrrrrrrrrrrrrrrrrrr$r classmethodrr staticmethodrrrr'r3r<rrrr#sHHD L    G#K####H G     I    G M).d(C(C(CCCCC!!!!!GM")O((((!%N%%%%&+****#"""""""""O043333!%$$$$%%%%%#""""%*****  K#(''''*))))!O    $$$$$M"""""+++++ %%%%%$uT:::H::::%555C5555#(''''%    [ * #'W W W W [W r\*"%"#$$$[$4$(!%*. C!C!C!C!C!C!C!rrr _honcho_client_slotconfigHonchoClientConfig | Noner ct}||Stjsjst ddfd }t|S)aGet or create the Honcho client singleton. When no config is provided, attempts to load ~/.honcho/config.json first, falling back to environment variables. Thread-safe: the client is built exactly once even under concurrent first calls (double-checked locking via ``SingletonSlot``), so racing threads can't each construct a client and leak the loser's connection. NzHoncho API key not found. Get your API key at https://app.honcho.dev, then run 'hermes honcho setup' or set HONCHO_API_KEY. For local instances, set HONCHO_BASE_URL instead.r'Honcho'c ddlm}m}|ddn#t$rYnt$rYnwxYw ddlm}n#t$rtdwxYwj}j}|r| ddl m }|}| d i}t|trd|s*| d d pd}|6t| d | d }n#t$rYnwxYw|t }|r"t"d|jn&t"djj|o d|vpd|vpd|v}|rgjpi} | dpi ji} t-| d} | rjnd} nj} |r.ddl} | dd |d}j| jd}|r||d <|||d <|di|S)Nr)FeatureUnavailableensurez memory.honchoF)promptr zhoncho-ai is required for Honcho integration. Install it with: pip install honcho-ai (or run `hermes honcho setup` to configure).) load_confighonchorrrrequest_timeoutz8Initializing Honcho client (base_url: %s, workspace: %s)z4Initializing Honcho client (host: %s, workspace: %s) localhostz 127.0.0.1z::1r(rlocalz/v\d+/*$/)rrrr<)tools.lazy_depsrArB ImportErrorr7rEr rrhermes_cli.configrDr+rcr%r!r_DEFAULT_HTTP_TIMEOUTrinforr&r$rMrr-r/r!r)rA _lazy_ensurer resolved_base_urlresolved_timeoutrD hermes_cfg honcho_cfg _is_local_rawr0 _host_has_keyeffective_api_key_rekwargsr<s r_buildz!get_honcho_client.._builds=  R R R R R R R R L 7 7 7 7 7    D    D    % % % % % % %   ?  #O!>  $4$< 999999([]] '^^Hb99 j$//,[,6NN:r,J,J,P,P,R,R,ZVZ)'/+B&NN955&NN+<==,,(      #4   r KKRTegmgz { { { { KKNPVP[]c]p q q q& , , *// *))   / :#D88G,,277 RHHK !:!:;;M2? LW   &   X     # R9J K K R RSV W W #/(!-    3!2F:   ' 0F9 vs, 1 11<A,BD DD)rr?)r;peekrrrrrUr+)r<cachedrZs` rget_honcho_clientr]s! % % ' 'F   ~#6688 > &/  @   d d d d d d L  " "6 * **rNonec8tdS)z7Reset the Honcho client singleton (useful for testing).N)r;resetr<rrreset_honcho_clientrapsr)rrrr)r$r%r&rrr%)rr)rr)rGrrr)rrMrrM)rrQ)rrTrrT)r^r%r_r%r`rrra)r) r^r%r_r%r`rrrrr)rrT)rxrTrry)rr rr)rrrrrr%)N)r<r=rr )rr^)7r7 __future__rrr4loggingr dataclassesrrpathlibrhermes_constantsrr6rplugins.plugin_utilsr typingr r rEr getLoggerr4rrr#r0r9r=rBrIrJrLrPrZr]rkrnrsr|rrMrrrrrrrr;r8r]rar<rrrjsY   #""""" ((((((((,,,,,,888888......%%%%%%%%  8 $ $....!!!!*3333 ((((,)444;;;;         >@         F2$&}5'0mVcddEEEE D  T  > !!!!!!! !D&3]__4444D+D+D+D+D+N      r