iXs2dZddlmZddlZddlZddlZddlmZmZm Z m Z ddl m Z ddl mZejeZddd igd d Zd d d ddddddddgd d Zddd ddddddddgd d Zddd ddddidgd d ZeeeegZGdde Zd#d"ZdS)$uLHoncho memory plugin — MemoryProvider for Honcho AI-native memory. Provides cross-session user modeling with dialectic Q&A, semantic search, peer cards, and persistent conclusions via the Honcho SDK. Honcho provides AI-native cross-session user modeling with dialectic Q&A, semantic search, peer cards, and conclusions. The 4 tools (profile, search, context, conclude) are exposed through the MemoryProvider interface. Config: Uses the existing Honcho config chain: 1. $HERMES_HOME/honcho.json (profile-scoped) 2. ~/.honcho/config.json (legacy global) 3. Environment variables ) annotationsN)AnyDictListOptional)MemoryProvider) tool_errorhoncho_profileuRetrieve the user's peer card from Honcho — a curated list of key facts about them (name, role, preferences, communication style, patterns). Fast, no LLM reasoning, minimal cost. Use this at conversation start or when you need a quick factual snapshot.object)type propertiesrequired)name description parameters honcho_searchuSemantic search over Honcho's stored context about the user. Returns raw excerpts ranked by relevance — no LLM synthesis. Cheaper and faster than honcho_context. Good when you want to find specific past facts and reason over them yourself.stringz&What to search for in Honcho's memory.)r rintegerz:Token budget for returned context (default 800, max 2000).)query max_tokensrhoncho_contextuAsk Honcho a natural language question and get a synthesized answer. Uses Honcho's LLM (dialectic reasoning) — higher cost than honcho_profile or honcho_search. Can query about any peer: the user (default) or the AI assistant.zA natural language question.z4Which peer to query about: 'user' (default) or 'ai'.)rpeerhoncho_concludezWrite a conclusion about the user back to Honcho's memory. Conclusions are persistent facts that build the user's profile. Use when the user states a preference, corrects you, or shares something to remember across sessions. conclusionz.A factual statement about the user to persist.ceZdZdZdZed4dZd5dZdZd Z d6dZ d7dZ d7dZ d5dZ d8dZd4dZddd9dZd:dZddd;dZdd'Zd?d*Zd@d-ZdAd.ZdBd1ZdCd2Zd3S)DHonchoMemoryProviderzHHoncho AI-native memory with dialectic Q&A and persistent user modeling.cpd|_d|_d|_d|_t j|_d|_d|_d|_ d|_ t j|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_dS)Nhybridr every-turniF)_manager_config _session_key_prefetch_result threadingLock_prefetch_lock_prefetch_thread _sync_thread _recall_mode_first_turn_context_first_turn_lock _turn_count_injection_frequency_context_cadence_dialectic_cadence_reasoning_level_cap_last_context_turn_last_dialectic_turn_session_initialized_lazy_init_kwargs_lazy_init_session_id _cron_skippedselfs A  A c>ddl}ddlm}||dz }i}|r4 |j|}n#t $rYnwxYw||||j |ddS)zDWrite config to $HERMES_HOME/honcho.json (Honcho SDK native format).rN)Pathz honcho.json)indent) jsonpathlibrOexistsloads read_textrKupdate write_textdumps)r:values hermes_homerRrO config_pathexistings r; save_configz HonchoMemoryProvider.save_configs       d;''-7        %4:k&;&;&=&=>>    ztz(1===>>>>>s"A A A cddddddddd gS) NrIzHoncho API keyTHONCHO_API_KEYzhttps://app.honcho.dev)keyrsecretenv_varurlbaseUrlz!Honcho base URL (for self-hosted))rarrBr9s r;get_config_schemaz&HonchoMemoryProvider.get_config_schemas6.>$[kuM N N.Q R R  r=r[configdictNonecTddl}ddlm}||dS)z:Run the full Honcho setup wizard after provider selection.rN) cmd_setup)typesplugins.memory.honcho.clirkSimpleNamespace)r:r[rgrlrks r; post_setupzHonchoMemoryProvider.post_setups? 777777 %''))*****r= session_idc b |dd}|dd}|dvs|dkr%td||d|_d Sd d lm}m}d d lm}| }|j r|j s#|j std d S|d} | r|j s| |_ ||_|j|_td|j |jpi} | dd|_t'| dd|_t'| dd|_| d} | r | dvr| |_n2#t.$r%} td| Yd } ~ nd } ~ wwxYw|jdkrc|jr+td|j||fi|d S||_||_||_tdd S|j||fi|d S#t8$rtdYd St.$r-} td| d |_Yd } ~ d Sd } ~ wwxYw)zInitialize Honcho session manager. Handles: cron guard, recall_mode, session name resolution, peer memory mode, SOUL.md ai_peer sync, memory file migration, and pre-warming context at init. agent_contextrplatformcli)cronflushruzBHoncho skipped: cron/flush context (agent_context=%s, platform=%s)TNr)rEget_honcho_clientHonchoSessionManageru)Honcho not configured — plugin inactiveuser_idzHoncho recall_mode: %sinjectionFrequencyr contextCadencer!dialecticCadencereasoningLevelCap)minimallowmidhighz,Honcho cost-awareness config parse error: %stoolsuGHoncho tools-only mode — eager session init (initOnSessionStart=true)uGHoncho tools-only mode — deferring session init until first tool callu3honcho-ai package not installed — plugin inactivezHoncho init failed: %s)getloggerdebugr8rFrErwplugins.memory.honcho.sessionryrGrHrIrJ peer_namer# recall_moder+rawr/intr0r1r2rKinit_on_session_start_do_session_initr6r7 ImportErrorwarningr") r:rpkwargsrrrsrErwryrL _gw_user_idrcapes r; initializezHonchoMemoryProvider.initializes-H !"JJ;;Mzz*e44H 111X5G5G a*H666%)" Z Z Z Z Z Z Z Z J J J J J J$7799C; s{ cl  HIII !**Y//K ,3= , + DL!$D  LL143D E E E Pgm,/GG4H,,W,W)(+CGG4Da,H,H(I(I%*-cgg6H!.L.L*M*M'gg12243"CCC03D- P P P KQOOOOOOOO P G++,LL!jkkk)D)#zDDVDDDF)/&-7*"  fggg "D !#z < I/II$J.8 J."J))J.c ddlm}ddlm}||}||||j|_|d}|||p|pd|_t d|j|j |j}d |_ |j s`dd lm} t!| d z } |j|j| t d |jn2#t$$r%} t d | Yd} ~ nd} ~ wwxYw|jdvr |j|j|j|jdt d|jdS#t$$r&} t d| Yd} ~ dSd} ~ wwxYwdS)zBShared session initialization logic for both eager and lazy paths.r)rwrx)rArgcontext_tokens session_title)rrphermes-defaultzHoncho session key resolved: %sT)get_hermes_homememoriesz:Honcho memory file migration attempted for new session: %sz(Honcho memory file migration skipped: %sNcontextrz#What should I know about this user?z/Honcho pre-warm threads started for session: %szHoncho pre-warm failed: %s)rFrwrryrr"rresolve_session_namer$rr get_or_creater5messageshermes_constantsrr?migrate_memory_filesrKr+prefetch_contextprefetch_dialectic) r:rLrprrwryclientrsessionrmem_dirrs r;rz%HonchoMemoryProvider._do_session_initsJBBBBBBFFFFFF""3'',,-     ?33  $ $=Z $ X X     68IJJJ---d.?@@$(! H# n<<<<<<oo//*<== 2243DgNNN Y[_[lmmm H H H LLCQ G G G G G G G G H   5 5 5 > ..t/@AAA 001BDijjj NPTPabbbbb > > > 91========= > 6 5s2,A'D ED>>EAF11 G!;GG!c*|jr |jrdS|jrdS|jr|jsdS |j|j|jpdfi|jd|_d|_|jduS#t$r&}t d|Yd}~dSd}~wwxYw)zLazily initialize the Honcho session (for tools-only mode). Returns True if the manager is ready, False otherwise. TFrNz#Honcho lazy session init failed: %s) r"r5r8r#r6rr7rKrr)r:rs r;_ensure_sessionz$HonchoMemoryProvider._ensure_session@s = T6 4   5| 4#9 5  !D ! *>.>  (    &*D ")-D &=, ,    NN@! D D D55555 s6A"" B,B  Bctxcg}|dd}|r|d||dd}|r|d||dd}|r|d||dd}|r|d ||sdSd |S) zEFormat the prefetch context dict into a readable system prompt block.representationrz## User Representation cardz## User Peer Card ai_representationz## AI Self-Representation ai_cardz## AI Identity Card  )rappendjoin)r:rpartsreprai_reprs r;_format_first_turn_contextz/HonchoMemoryProvider._format_first_turn_contextZsgg&++  ; LL9C99 : : :wwvr""  7 LL5t55 6 6 6,b11  A LL?v?? @ @ @'')R((  < LL::: ; ; ; 2{{5!!!r=c|jrdS|jr|js|jdkr |jr dSdSd}|jdvr|j5|jx |j|j}|r||nd|_n9#t$r,}t d|d|_Yd}~nd}~wwxYw|j}dddn #1swxYwY|jdkrd}n|jdkrd }nd }|r|d |S|S) a$Return system prompt text, adapted by recall_mode. B4: On the FIRST call, fetch and bake the full Honcho context (user representation, peer card, AI representation, continuity synthesis). Subsequent calls return the cached block for prompt caching stability. rrz# Honcho Memory Active (tools-only mode). Use honcho_profile, honcho_search, honcho_context, and honcho_conclude tools to access user memory.rNz*Honcho first-turn context fetch failed: %sru# Honcho Memory Active (context-injection mode). Relevant user context is automatically injected before each turn. No memory tools are available — context is managed automatically.u# Honcho Memory Active (tools-only mode). Use honcho_profile for a quick factual snapshot, honcho_search for raw excerpts, honcho_context for synthesized answers, honcho_conclude to save facts about the user. No automatic context injection — you must use tools to access memory.a# Honcho Memory Active (hybrid mode). Relevant context is auto-injected AND memory tools are available. Use honcho_profile for a quick factual snapshot, honcho_search for raw excerpts, honcho_context for synthesized answers, honcho_conclude to save facts about the user.r) r8r"r$r+r#r-r,get_prefetch_contextrrKrr)r:first_turn_blockrrheaders r;system_prompt_blockz(HonchoMemoryProvider.system_prompt_blockrs   2} D$5  G++ +W 2   5 5 5& < <+36"m@@ARSS[^3f43R3RSV3W3W3Wdf00$666 %QSTUUU350000006$(#;  < < < < < < < < < < < < < < <   ) )) F  ' ) )Z F@   544"244 4 s<C =BC B>"B94C9B>> CCCr)rprcj|jrdS|jdkrdS|jdkr |jdkrdS|jr4|jr|jd|j5|j}d|_dddn #1swxYwY|sdS| |}d|S) u Return prefetched dialectic context from background thread. B1: Returns empty when recall_mode is "tools" (no injection). B5: Respects injection_frequency — "first-turn" returns cached/empty after turn 0. Port #3265: Truncates to context_tokens budget. rrz first-turnrg@timeoutNz## Honcho Context ) r8r+r/r.r)is_aliverr(r%_truncate_to_budget)r:rrpresults r;prefetchzHonchoMemoryProvider.prefetchs&   2   ' '2  $ 4 49IA9M9M2   4T%:%C%C%E%E 4  ! & &s & 3 3 3   ' '*F$&D ! ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 2))&11-V---s1B  BBtextc|jr |jjs|S|jjdz}t||kr|S|d|}|d}||dzkr |d|}|dzS)z9Truncate text to fit within context_tokens budget if set.N g?u …)r#rlenrfind)r:r budget_chars truncated last_spaces r;rz(HonchoMemoryProvider._truncate_to_budgets| 4<#> K|2Q6 t99 $ $K,' __S))  s* * *!+:+.I6!!r=cjrdSjr jrsdSjdkrdSjdkrHjjz jkr0tdjjjz dSj_fd}tj |dd_ j j dksjjz j krbj_ jjdS#t $r&}td |Yd}~dSd}~wwxYwdS) zFire a background dialectic query for the upcoming turn. B5: Checks cadence before firing background threads. Nrr!zCHoncho dialectic prefetch skipped: cadence %d, turns since last: %dc6 jjd}|r=|r+j5|_ddddS#1swxYwYdSdSdS#t $r&}td|Yd}~dSd}~wwxYw)NuserrzHoncho prefetch failed: %s) r"dialectic_queryr$stripr(r%rKrr)rrrr:s r;_runz1HonchoMemoryProvider.queue_prefetch.._runs >66%u677fllnn7,7706-7777777777777777777777 > > > 91========= >s;?A(A A(AA(AA(( B2BBTzhoncho-prefetchtargetdaemonrz"Honcho context prefetch failed: %s)r8r"r$r+r1r.r4rrr&Threadr)startr0r3rrK)r:rrprrs`` r;queue_prefetchz#HonchoMemoryProvider.queue_prefetchs    F} D$5 U  F   ' ' F  "Q & & 4#<<@WWW b!4d6FIb6bddd$($4! > > > > > >!* 0+<! ! !  ##%%%  A % %$*:T=T*TY]Yn)n)n&*&6D # F ..t/@%HHHHH F F F A1EEEEEEEEE F *o)ns5 D E!EE turn_numberrmessagec ||_dS)z;Track turn count for cadence and injection_frequency logic.N)r.)r:rrrs r; on_turn_startz"HonchoMemoryProvider.on_turn_start s&r=contentlimit list[str]clt||kr|gSd}t|}g}|}d}|r|r|n||z }t||kr||r|n||zn|d|}|d} | |dzkr |d} | dkr| dz } | |dzkr|d } | |dzkr|} |d| } || d}|s|| z} || d }||S) aRSplit content into chunks that fit within the Honcho message limit. Splits at paragraph boundaries when possible, falling back to sentence boundaries, then word boundaries. Each continuation chunk is prefixed with "[continued] " so Honcho's representation engine can reconstruct the full message. z [continued] TNrg333333?z. rrPrF)rrrrstriplstrip) rrprefix prefix_lenchunks remainingfirst effectivesegmentcutchunks r;_chunk_messagez#HonchoMemoryProvider._chunk_messages} w<<5 9 [[   !&>EJ,>I9~~** 5Hiify6HIII  +G--''CY_$$mmD))!881HCY_$$mmC((Y_$$dsdO**,,E!#$$..00I ' MM% E1 4 r= user_contentassistant_contentcZjrdSjrjsdSjr jjndfd}jr4jrjdtj |dd_j dS) zRecord the conversation turn in Honcho (non-blocking). Messages exceeding the Honcho API limit (default 25k chars) are split into multiple messages with continuation markers. Niac jj}D]}|d|D]}|d|j|dS#t $r&}td|Yd}~dSd}~wwxYw)Nr assistantzHoncho sync_turn failed: %s) r"rr$r add_message_flush_sessionrKrr)rrrr msg_limitr:rs r;_syncz-HonchoMemoryProvider.sync_turn.._syncJs ?-55d6GHH!00yII77E''6666!001BINN<>>>>>>>> ?sBB C &CC @rTz honcho-syncr) r8r"r$r#message_max_charsr*rrr&rr)r:rrrprrs``` @r; sync_turnzHonchoMemoryProvider.sync_turn=s    F} D$5  F6:lMDL22  ? ? ? ? ? ? ? ?   0!2!;!;!=!= 0   " "3 " / / /%,M    !!!!!r=actionrc|dks|dkssdSjrdSjrjsdSfd}tj|dd}|dS)z:Mirror built-in user profile writes as Honcho conclusions.addrNc jjdS#t$r&}td|Yd}~dSd}~wwxYw)NzHoncho memory mirror failed: %s)r"create_conclusionr$rKrr)rrr:s r;_writez4HonchoMemoryProvider.on_memory_write.._writeest C //0A7KKKKK C C C >BBBBBBBBB Cs % AAATzhoncho-memwriter)r8r"r$r&rr)r:rrrrts` ` r;on_memory_writez$HonchoMemoryProvider.on_memory_write\s U??f..g. F    F} D$5  F C C C C C C  F4>O P P P  r=rList[Dict[str, Any]]c:|jrdS|jsdS|jr4|jr|jd |jdS#t $r&}td|Yd}~dSd}~wwxYw)z4Flush all pending messages to Honcho on session end.Ng$@rz#Honcho session-end flush failed: %s) r8r"r*rr flush_allrKrr)r:rrs r;on_session_endz#HonchoMemoryProvider.on_session_endns    F}  F   1!2!;!;!=!= 1   " "4 " 0 0 0 C M # # % % % % % C C C LL> B B B B B B B B B CsA** B4BBcV|jrgS|jdkrgSttS)zeReturn tool schemas, respecting recall_mode. B1: context-only mode hides all tools. r)r8r+listALL_TOOL_SCHEMASr9s r;get_tool_schemasz%HonchoMemoryProvider.get_tool_schemas|s6   I   ) )I$%%%r= tool_nameargsc \|jrtdS|js#|stdS|jr|jstdS |dkrM|j|j}|stjddiStjd|iS|dkr| dd }|std Stt| d d d }|j |j||}|stjddiStjd|iS|dkrw| dd }|std S| dd}|j |j||}tjd|pdiS|dkrq| dd } | stdS|j|j| } | rtjdd| iStdStd|S#t$r;} t d|| td|d| cYd} ~ Sd} ~ wwxYw)zFHandle a Honcho tool call, with lazy session init for tools-only mode.z$Honcho is not active (cron context).z(Honcho session could not be initialized.z&Honcho is not active for this session.r rzNo profile facts available yet.rrrz!Missing required parameter: queryri i)rzNo relevant context found.rrrrzNo result from Honcho.rrz&Missing required parameter: conclusionzConclusion saved: zFailed to save conclusion.zUnknown tool: zHoncho tool %s failed: %szHoncho z failed: N)r8r r5rr"r$ get_peer_cardrRrYrminrsearch_contextrrrKrerror) r:rr rrrrrrrokrs r;handle_tool_callz%HonchoMemoryProvider.handle_tool_calls   FDEE E( N'')) N!"LMMM} HD$5 HFGG G* A,,,}2243DEEU:x1R&STTTz8T"2333o--"--K%&IJJJ TXXlC%@%@!A!A4HH 55%u6P:x1M&NOOOz8V"4555..."--K%&IJJJxx//66%u47z8V-O7O"PQQQ///!XXlB77 !P%&NOOO]44T5F SSU:x1Rj1R1R&STTT!">???:y::;; ; A A A LL4i C C C? ??A??@@ @ @ @ @ @ @ As\r?)r>rC)r[r?rgrhr>ri)rpr?r>ri)rrhr>r?)rr?rpr?r>r?)rr?r>r?)rr?rpr?r>ri)rrrr?r>ri)rr?rrr>r)rr?rr?rpr?r>ri)rr?rr?rr?r>ri)rrr>ri)r>r)rr?r rhr>r?r>ri)__name__ __module__ __qualname____doc__r<propertyrrMr^rfrorrrrrrrrr staticmethodrrrrrrrrBr=r;rrws$RR###BX ? ? ?   ++++ O!O!O!O!b*>*>*>*>X4""""0<<<<|9;......> " " " "?A-F-F-F-F-F-F^''''***\*XY["""""">$ C C C C & & & &7A7A7A7Ar      r=rr>ricH|tdS)z,Register Honcho as a memory provider plugin.N)register_memory_providerr)rs r;registerrs#  !5!7!788888r=r)r __future__rrRloggingr&typingrrrragent.memory_providerrtools.registryr getLoggerrrPROFILE_SCHEMA SEARCH_SCHEMACONTEXT_SCHEMACONCLUDE_SCHEMArrrrBr=r;r's  #""""" ,,,,,,,,,,,,000000%%%%%%  8 $ $  T $22FF    X !G "[   I   2  L != !U   I  0  1   O "N  *#M>?SR R R R R >R R R r999999r=