[jLUdZddlmZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZddlmZddlmZdd lmZdd lmZmZerdd lmZejeZd Zd\dZd]dZd^dZ d_dZ!d_dZ"ddiZ#hdZ$d`dZ%dad!Z&dbd#Z'dcd%Z(ddd'Z)ded,Z* dfdgd.Z+dhd/Z,d0Z-did3Z.d4Z/djd6Z0dkd:Z1d;dZ4d?d?d?d?d@d?dAdAd?d@dBZ5dldFZ6e GdGdHZ7eZ8dIe9dJ<da:d9e9dK<dLa;dMe9dN<dmdOZdodUZ?dpdXZ@dqdrdZZAdsd[ZBdS)taHoncho 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_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 >/home/ice/.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 startswithr len)r%r'r)blocklegacys r _host_blockr1.s GGG   "E IIdB  E DOOtJJJ//  - -tCIIMNN+ - -F 99VR  rc"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.profilesr4r$ Exceptionr resolve_config_pathexistsjsonloads read_textr)explicitr4r profile_hostpathr% default_hosts rresolve_active_hostrF8s3z~~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)rhomerrresolve_global_config_pathrJ^s 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)rr>r rJ) local_path default_paths rr=r=csn!""]2J,-- =Lz!!l&9&9&;&;! % ' ''rautohybrid>toolsrOcontextvalcRt||}|tvr|ndS)u?Normalize legacy recall mode values (e.g. 'auto' → 'hybrid').rO)_RECALL_MODE_ALIASESr,_VALID_RECALL_MODESrRs r_normalize_recall_moderW}s,  " "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. )rX)rvalsrRs 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_valrRs r_parse_context_tokensres`(# ? 3xx *      4 //r_cj||fD]-}|) t|cS#ttf$rY)wxYw.|S)zz1_parse_dialectic_depth_levels..s75555rr)rslistr.append)rcrdrrRlevelss r_parse_dialectic_depth_levelsrs (#   ?z#t44?vv;F f++%% e$$$f++%%MMM 4rg>@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_addressr` 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   rc"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_peerFrX pin_peer_name)default_factoryrquser_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_charsrO recall_modeinit_on_session_start every-turninjection_frequencycontext_cadencedialectic_cadence query_rewrite@rjfirst_turn_base_wait@first_turn_dialectic_waitrobservation_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)rFr9r:r,r"rrX)clsrr' resolved_hostrrrs rfrom_envzHonchoClientConfig.from_envs5 3 5 5 *..!122:>>"3R88>>@@HD)"*..9I*J*JKKs% ';\JJ!,H--    r config_path Path | NonecB|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|d|d|dtjd}|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#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&dL|dMp|dMdNdOt7|dP|dPdQ&dRt7|dS|dSdQ&dTt/|dU|dUd&dVt?|dW|dWdX&dYt?|dZ|dZd[&d\tA|d]p|d]p|rd^nd_tCtA|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'r5r6z*Failed to read %s: %s, falling back to envNrT workspaceaiPeerapiKeyrrrbaseUrlrrrrrequestTimeoutrwriteFrequencyr saveMessagessessionStrategyrsessionPeerPrefixFr'rrrpeerNamerr pinUserPeer pinPeerName)rruserPeerAliasesrruntimePeerPrefixrrr contextTokensrdialecticReasoningLevelrrdialecticDynamicrdialecticMaxCharsrrdialecticDepthrdialecticDepthLevels)rrreasoningHeuristicrreasoningLevelCaprrmessageMaxCharsrrdialecticMaxInputCharsrr recallModerOrinitOnSessionStartrinjectionFrequencyrrcontextCadencer+rdialecticCadencer queryRewriterfirstTurnBaseWaitrrfirstTurnDialecticWaitrrobservationModerr observationr)rrrr%rrI)"rFr=r>loggerdebugrr?r@rAJSONDecodeErrorOSErrorwarningr1rXr,r9r:r"rr_rar`rr[r{r~rerirrrWrmrr)rr'rrrDr%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::<<  * 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"3M M&%M&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_outputtextr,rstdin) subprocessrunDEVNULL returncoderstdoutr"namer!TimeoutExpired)r,r3roots r_git_repo_namez!HonchoClientConfig._git_repo_names  >>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. r5Nr+-)_HONCHO_SESSION_ID_MAX_LENr._HONCHO_SESSION_ID_HASH_LENhashlibsha256encode hexdigestrstrip)rr#r>max_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_-]+r@ per-sessionzper-repo>rRr)rer9getcwdsubr"rMrrrrr,r;rr8r) selfr,rNrOrPrSr#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#rr>rrr)NNNN) r,rrNrrOrrPrrr);__name__ __module__ __qualname____doc__r r'__annotations__rrrrrrrrrr&rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr%r classmethodrr+ staticmethodr;rArBrMrYrIrrrrgsHHD 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!rrr _honcho_client_slot_cached_timeoutrZztuple[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.configrfr,rsr&rr<)rf honcho_cfgs r_config_yaml_timeoutrkds ::::::))++//"== 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+Nr5r6rr) r=stat st_mtime_nsr!rdr?r@rAr1rFrr,r<)rDmtime_nsrr%r$s r_honcho_json_timeoutrqts*"$$  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}nNNNNNNOs9?&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. rryNz"Honcho OAuth cached refresh failedTr{) r}rzr'rFr~r=apply_token_to_clientrbresetr<rr")rrrrzr'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)promptr zhoncho-ai is required for Honcho integration. Install it with: pip install honcho-ai (or run `hermes honcho setup` to configure).) load_configrgrrrrhz8Initializing Honcho client (base_url: %s, workspace: %s)z4Initializing Honcho client (host: %s, workspace: %s)r)rlocalz/v\d+/*$/)rrrrI)tools.lazy_depsrr ImportErrorr<rgrrrrirr,rsr&r"rrurinforr'rr%rXrrSrUrGrrc)r _lazy_ensurerresolved_base_urlresolved_timeoutr hermes_cfgrj _is_local_rawr1 _host_has_keyeffective_api_key_rekwargsrrs 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) rbpeekrvrcrrrr+rrrr`r,)rrcached new_timeoutrs` rget_honcho_clientrs! % % ' 'F 4F;; / ) )  % % ' ' '"OFF !&& 1 1 1M ~#6688V$$$ > &/  @   _ _ _ _ _ _ B  " "6 * **rc@tdadadS)z7Reset the Honcho client singleton (useful for testing).NrZ)rbrrcrdrIrrreset_honcho_clientrSs'O ,r)rrrr)r%r&r'rrr&)rr)rr)rRrrr)rrXrrX)rr\)rr_rr_)rrjrrj)rnr&ror&rprrrq)r) rnr&ror&rprrrrr)rr_)rr_rr)rrrrX)rr rr)rrrrrr&)rr)rrrsrrj)rrrrrw)rrrrrsrrw)N)rrrsrr)rrw)Cr^ __future__rr?r9loggingrCr dataclassesrrpathlibr urllib.parserhermes_constantsrr;r plugins.plugin_utilsr typingr r rgr getLoggerr[rr r$r1rFrJr=rTrUrWr[rerirmr{r~rrrrurrrrrrrrrbr_rcrdrkrqrvrrrrrIrrrs7   #""""" ((((((((!!!!!!,,,,,,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