epj3XUdZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZddlmZddlmZdd lmZdd lmZdd lmZmZerdd lmZejeZd Zd]dZ d^dZ!d_dZ"d`dZ#d`dZ$ddiZ%hdZ&dadZ'dbd"Z(dcd$Z)ddd&Z*ded(Z+dfd-Z, dgdhd/Z-did0Z.d1Z/djd4Z0d5Z1dkd7Z2dld;Z3dZ5dad?Z6d@d@d@d@dAd@dBdBd@dAdCZ7dmdGZ8e GdHdIZ9eZ:dJe;dK<dadndQZ?dodTZ@dpdVZAdqdYZBdrdsd[ZCdtd\ZDdS)uaHoncho client initialization and configuration. Resolution order for config file: 1. $HERMES_HOME/honcho.json (instance-local, enables isolated Hermes instances) 2. ~/.honcho/config.json (global, shared across all Honcho-enabled apps) 3. Environment variables (HONCHO_API_KEY, HONCHO_ENVIRONMENT) Resolution order for host-specific settings: 1. Explicit host block fields (always win) 2. Flat/global fields from config root 3. Defaults (host name as workspace/peer) ) annotationsN) dataclassfield)Path)urlparse) get_secret)get_hermes_home)_get_default_hermes_home) SingletonSlot)Any TYPE_CHECKINGHonchohermesprofile str | Nonereturnstrc|r|dvrtSdd|Dd}td|pdS)z5Return the safe Honcho host key for a Hermes profile.>customdefaultc3NK|] }|s|dvr|ndV!dS)z_-_N)isalnum).0cs B/home/thesage/.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+) - --r rawdicthostc|dpi}||i}|s|tds|Std|ttdzd}||iS)z@Return host config, accepting legacy dot-form profile host keys.hostsr.N)get startswithr!len)r&r(r*blocklegacys r _host_blockr2/s GGG   "E IIdB  E DOOtJJJ//  - -tCIIMNN+ - -F 99VR  r c"tjdd}|r|S ddlm}|}t |}n#t$r t}YnwxYw|tkr t}| ratj | d}t|dd}|r|Sn#t$rYnwxYw|S)aWDerive 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. defaultHost from the active config, but only for the default profile 4. Fallback: ``"hermes"`` (default profile) HERMES_HONCHO_HOSTrr)get_active_profile_nameutf-8encoding defaultHost)osenvironr-r#hermes_cli.profilesr5r% Exceptionr!resolve_config_pathexistsjsonloads read_textr)explicitr5r profile_hostpathr& default_hosts rresolve_active_hostrG9s3z~~2B77==??H??????))++'00  t &((D{{}} (j!A!ABB"377="#=#=>>DDFF (''    D  s$AA,+A,;BC?? D  D rc4tjdz dz S)z:Return the shared Honcho config path for the current HOME.z.honchoz config.json)rhomer rresolve_global_config_pathrK_s 9;; "] 22r ctdz }|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)r r?r rK) local_path default_paths rr>r>dsn!""]2J,-- =Lz!!l&9&9&;&;! % ' ''r autohybrid>toolsrPcontextvalcRt||}|tvr|ndS)u?Normalize legacy recall mode values (e.g. 'auto' → 'hybrid').rP)_RECALL_MODE_ALIASESr-_VALID_RECALL_MODESrSs r_normalize_recall_moderX~s,  " "3 , ,C,,,33(:r rboolc6|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. )rY)rvalsrSs r _resolve_boolr\s4 ?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_valrSs r_parse_context_tokensrfs`(# ? 3xx *      4 //r`cj||fD]-}|) t|cS#ttf$rY)wxYw.|S)zz1_parse_dialectic_depth_levels..s75555r r)rtlistr/append)rdrerrSlevelss r_parse_dialectic_depth_levelsrs (#   ?z#t44?vv;F f++%% e$$$f++%%MMM 4r g>@base_urlc|sdS t|}|jpd}n#t$rd}YnwxYw|dvrdS|sdS t j|}n#t$rYdSwxYw|js|j s|j rdS|j dkr6t jd|cxkrt jdkrnndSdS)anReturn True for loopback/LAN/VPN self-hosted Honcho URLs. Local Honcho deployments can run without auth, but the SDK requires a non-empty api_key argument. Treat loopback plus RFC1918/link-local/ULA and carrier-grade-NAT IPs as local so LAN/VPN URLs such as ``http://192.168.2.112:8000`` get the same placeholder-key behavior as localhost. Fr>::1 127.0.0.1 localhostTz 100.64.0.0z100.127.255.255) rhostnamer#lowerr= ipaddress ip_addressra is_loopback is_private is_link_localversion)rparsedr(ips r_is_local_base_urlrs9 u(##%2,,..4466  000t u  !$ ' ' uu ~"*:t zQ9/ ==nnnnyG[\mGnGnnnnnnt 5s#>+v>O7PQQ)~~ovF[?\]]!k6/3JKK%\\/6BU;VWW   r c"eZdZUdZeZded<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<d&Z#d$ed6<d&Z$d$ed7<dZ%ded8<d9Z&d:ed;<dZ(ded?<dZ)ded@<dZ*dedA<dZ+dedB<dZ,dedC<dDZ-dedE<dZ.dedF<eeZ/dedG<eeZ0dHedI<dZ1dedJ<e2 d[d\dLZ3e2 d]d^dOZ4e5d_dQZ6dRZ7dSZ8e2d`dVZ9 dadbdZZ:dS)cHonchoClientConfigz>Configuration for Honcho client, resolved for a specific host.rr(r workspace_idNrapi_key production environmentrrtimeout peer_nameai_peerFrY pin_peer_name)default_factoryrruser_peer_aliasesrruntime_peer_prefixenabledT save_messagesasyncz str | intwrite_frequencyr]context_tokensrdialectic_reasoning_leveldialectic_dynamicXr`dialectic_max_charsr,dialectic_depthrdialectic_depth_levelsreasoning_heuristicrreasoning_level_capamessage_max_chars'dialectic_max_input_charsrP recall_modeinit_on_session_start every-turninjection_frequencycontext_cadencedialectic_cadence query_rewrite@rkfirst_turn_base_wait@first_turn_dialectic_waitrobservation_moderrrr per-directorysession_strategysession_peer_prefixsessionszdict[str, Any]r&explicitly_configuredrc |p t}td}tjddpd}t tjd}||||tjdd|||t|p|S) z4Create config from environment variables (fallback).HONCHO_API_KEYHONCHO_BASE_URLrNHONCHO_TIMEOUTHONCHO_ENVIRONMENTr)r(rrrrrrr)rGrr:r;r-r#rrY)clsrr( resolved_hostrrrs rfrom_envzHonchoClientConfig.from_envs5 3 5 5 -..:>>"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 p#|d ptd } |d p|d d} |dpH|dp3t jddpd} t'|d|d|d|dt jd}|d}|d}||}n||}nt| p| }|dp|dpd} t)|}n&#t*t,f$rt/|}YnwxYw|d}||n|dd}|dp|dd}|d}||n|dd}|dcid|d| d| d | d| d|d |d!p|d!d"| d#t1|d$|d%|d$|d%d&d't3||d(d)t5||d*d|d+|d,|d-t7|d.|d.d/|d0p|d0pd1d2t1|d3|d3d&d4t9|d5|d5d6&d7t;|d8|d8d9t=|d:|d:t;|d8|d8;d|d?p|d?pd@dAt9|dB|dBdC&dDt9|dE|dEdF&dGt?|dHp|dHpdIdJt1|dK|dKd&dL|dMp|dMdNdOt9|dP|dPdQ&dRt9|dS|dSdQ&dTt1|dU|dUd&dVtA|dW|dWdX&dYtA|dZ|dZd[&d\tC|d]p|d]p|rd^nd_tEtC|d]p|d]p|rd^nd_|d`p|d`|||dai||dbS)dzCreate 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(r6r7z*Failed to read %s: %s, falling back to envNrT workspaceaiPeerapiKeyrrrbaseUrlrrrrrequestTimeoutrwriteFrequencyr saveMessagessessionStrategyrsessionPeerPrefixFr(rrrpeerNamerr pinUserPeer pinPeerName)rruserPeerAliasesrruntimePeerPrefixrrr contextTokensrdialecticReasoningLevelrrdialecticDynamicrdialecticMaxCharsrrdialecticDepthrdialecticDepthLevels)rrreasoningHeuristicrreasoningLevelCaprrmessageMaxCharsrrdialecticMaxInputCharsrr recallModerPrinitOnSessionStartrinjectionFrequencyrrcontextCadencer,rdialecticCadencer queryRewriterfirstTurnBaseWaitrrfirstTurnDialecticWaitrrobservationModerr observationr)rrrr&rrJ)#rGr>r?loggerdebugrr@rArBJSONDecodeErrorOSErrorwarningr2rYr-rr:r;r#rr`rbrarr\r|rrfrjrrrXrnrr)rr(rrrEr&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 $ $ ,wwx   ,*++  NN= ) ) 4ww}l33  GGI   wwz"" z~~/44::<<  * NN9 % % NN+ , , GGI   GG$ % % JNN+ , ,   "~~i00 wwy))  #"GG  %"GG7.h//G NN+ , , ww'((    *),VOO:& * * *!&kkOOO *NN>22 %.%: X\@]@]  NN, - - ;ww(/:: !nn%899 &2KK,e44  sR R R R "R GR $ R X R G R !nnZ00GCGGJ4G4GR GR (}--}-- && &&    R ,0!-R 6!7#!!!7R @GAR B(-CR D,OER F1//((GR P89977455UR X,122*++YR b!2233+,,!!!!cR l3/00())mR t$A566.//,Z^^>AR D./00())ER N0122*++OR X(~..''YR b"5233+,,""""cR l':788011''''mR @9011L77,--L!7JII] #+NN#455Pww011P%;N  }--G1G1G KR Z. 3WWZ,,"8cR R R R R s0'(BC"&1CC"C"#L33 MMcwdc ddl} |gddddd|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-toplevelTr6replace)capture_outputtextr8errorsr-rstdin) subprocessrunDEVNULL returncoderstdoutr#namer"TimeoutExpired)r-r6roots r_git_repo_namez!HonchoClientConfig._git_repo_names  >>777#$X[ef ("D !##DK--//0055$23    D tsAA!!A54A5dr$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. r6Nr,-)_HONCHO_SESSION_ID_MAX_LENr/_HONCHO_SESSION_ID_HASH_LENhashlibsha256encode hexdigestrstrip)rr$rAmax_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}|rB|dd|d}|r|||S|jdkr|r|jr|jr |jd|S|S|j |}|r|S|rH|dd|d}|r|jr|jr |jd|S|S|jdkrE| |pt|j }|jr|jr |jd|S|S|jdvr0t|j }|jr|jr |jd|S|S|jS)uaResolve Honcho session name. Resolution order: 1. Gateway session key (stable per-chat identifier from gateway platforms) 2. per-session strategy — Hermes session_id ({timestamp}_{hex}); authoritative, so a generated title never remaps a live conversation 3. Manual directory override from sessions map 4. Hermes session title (from /title command; non-per-session) 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_-]+rC per-sessionzper-repo>rUr)rer:getcwdsubr#rPrrrrr-r>rr;r) selfr-rQrRrSrVr$manualbases rresolve_session_namez'HonchoClientConfig.resolve_session_names&   )++C  V138KLLRRSVWWI V55iATUUU  M 1 1j 1' 8DN 8.77:777 ""3''  M  !13 FFLLSQQI !+;;"n::y:::    J . .&&s++=tCyy~D' 2DN 2.114111K  $D D D99>D' 2DN 2.114111K  r )rN)rrr(rrrNN)r(rrrrr)r-rrr)r$rrArrr)NNNN) r-rrQrrRrrSrrr);__name__ __module__ __qualname____doc__r!r(__annotations__rrrrrrrrrr'rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr&r classmethodrr, staticmethodr>rDrErPr\rJr rrrhsHHD L    G#K####H G     I    G M).d(C(C(CCCCC!!!!!GM")O((((!%N%%%%&+****#"""""""""O043333!%$$$$%%%%%#""""%*****  K#(''''+++++O M#&%%%%'******))))!O    $$$$$M"""""+++++ %%%%%$uT:::H::::%555C5555#(''''%    [ * #'x x x x [x t\*"%"#$$$[$4$(!%*. C!C!C!C!C!C!C!r rr _honcho_client_slot_cached_timeoutr]ztuple[int | None, float | None]_honcho_json_timeout_memoc ddlm}|di}t|tr6t |d|dSdS#t $rYdSwxYw)zJRead honcho.timeout / honcho.request_timeout via the cached config loader.r)load_config_readonlyhonchorrequest_timeoutN)hermes_cli.configrir-rtr'rr=)ri honcho_cfgs r_config_yaml_timeoutrnes ::::::))++//"== j$ ' ' *y))011 t ttsA.A33 BBc8 t} |j}n#t$rd}YnwxYwtd|kr tdSd}|dkrt j|d}t|t}t| d| d| d| d}||fa|S#t$rYdSwxYw) zRRead timeout/requestTimeout from honcho.json (host block wins), memoized on mtime.rr,Nr6r7rr) r>stat st_mtime_nsr"rgr@rArBr2rGrr-r=)rEmtime_nsrr&r%s r_honcho_json_timeoutrtus*"$$  IIKK3HH   HHH  $Q '8 3 3,Q/ / r>>*T^^W^==>>C$S*=*?*?@@J-y))/00 ""()) G &.w$7! tts3D +D :D : D B/D DDconfigHonchoClientConfig | Nonec||j}nr(rr=rr#)rur}tokenrs r_apply_fresh_oauth_tokenrs O//////++,?,A,A6;OOq  #"FNNN # # OOO>NNNNNNOs9?&A)(A)client'Honcho'cX ddlm}||jn t}|t |\}}|r3|r3|||stdSdSdSdS#t$r t ddYdSwxYw)zRotate the cached client's Bearer in place when its OAuth token is stale. If the SDK shape changed and the in-place rotation can't apply, the slot is reset so the next acquisition rebuilds with the fresh token. rr|Nz"Honcho OAuth cached refresh failedTr~) rr}r(rGrr>apply_token_to_clientreresetr=rr#)rrur}r(r refresheds r_refresh_cached_oauthrs L//////$0v{{6I6K6K 334G4I4I4PPy  ( (u'B'B65'Q'Q (  % % ' ' ' ' ' ( ( ( ( ( ( LLL;dKKKKKKLsA5A??&B)(B)rct}|Jt}|tkrtdad}nt ||St tj sj stddfd }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.rrc 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"djjt+|}|rgjpi} | dpi ji} t/| d} | rjnd} nj} |r.ddl} | dd |d}j| jd}|r||d <|||d <|a|di|S)Nr)FeatureUnavailableensurez memory.honchoF)promptrzhoncho-ai is required for Honcho integration. Install it with: pip install honcho-ai (or run `hermes honcho setup` to configure).) load_configrjrrrrkz8Initializing Honcho client (base_url: %s, workspace: %s)z4Initializing Honcho client (host: %s, workspace: %s)r*rlocalz/v\d+/*$/)rrrrJ)tools.lazy_depsrr ImportErrorr=rjrrrrlrr-rtr'r#rrxrinforr(rr&rYrrVrXrJrrf)r _lazy_ensurerresolved_base_urlresolved_timeoutr hermes_cfgrm _is_local_rawr2 _host_has_keyeffective_api_key_rekwargsrus 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''899  / :#D88G,,277 RHHK !:!:;;M2? LW   &   X     # R9J K K R RSV W W #/(!-    3!2F:   ' 0F9 +vs, 1 11<A,BD DD)rr) repeekryrfrrrr,rrrrar-)rucached new_timeoutrs` rget_honcho_clientrs! % % ' 'F 4F;; / ) )  % % ' ' '"OFF !&& 1 1 1M ~#6688V$$$ > &/  @   _ _ _ _ _ _ B  " "6 * **r c@tdadadS)z7Reset the Honcho client singleton (useful for testing).Nr])rerrfrgrJr rreset_honcho_clientrTs'O ,r )rrrr)r&r'r(rrr')rr)rr)rSrrr)rrYrrY)rr])rr`rr`)rrkrrk)ror'rpr'rqrrrr)r) ror'rpr'rqrrrrr)rr`)rr`rr)rrrrY)rr rr)rrrrrr')rr)rurvrrk)rurrrz)rrrurvrrz)N)rurvrr)rrz)Era __future__rr@r:loggingrFr dataclassesrrpathlibr urllib.parseragent.secret_scoperhermes_constantsr r<r plugins.plugin_utilsr typingr r rjr getLoggerr^rr!r%r2rGrKr>rUrVrXr\rfrjrnr|rrrrrxrrrrrrrrrerbrfrgrnrtryrrrrrJr rrsI   #""""" ((((((((!!!!!!)))))),,,,,,888888......%%%%%%%%  8 $ $....!!!!####L3333 ((((,)444;;;;         >@         F2####L$&}5'0mVcddEEEE D  T  > n!n!n!n!n!n!n! n!b&3]__4444 $$$$$>JIIII     8EEEE* O O O O LLLL"J+J+J+J+J+Z------r