eidZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z ddl mZddlmZejeZddd d d d d dd idddgddZddd d dd ddd d d d ddgddZddd d dd d dgdd d d d d!dgddZd"d#d d d$d d d d d%gddZd&d'd d d(d d d)d d d d d*gddZeeeeegZGd+d,eZd0d/ZdS)1uLHoncho 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 or update a peer card from Honcho — a curated list of key facts about that peer (name, role, preferences, communication style, patterns). Pass `card` to update; omit `card` to read.objectstringzaPeer to query. Built-in aliases: 'user' (default), 'ai'. Or pass any peer ID from this workspace.)type descriptionarrayr zGNew peer card as a list of fact strings. Omit to read the current card.)r itemsr)peercard)r propertiesrequired)namer parameters honcho_searchuSemantic search over Honcho's stored context about a peer. Returns raw excerpts ranked by relevance — no LLM synthesis. Cheaper and faster than honcho_reasoning. Good when you want to find specific past facts and reason over them yourself.z&What to search for in Honcho's memory.integerz:Token budget for returned context (default 800, max 2000).)query max_tokensrrhoncho_reasoningugAsk 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 via alias or explicit peer ID. Pass reasoning_level to control depth: minimal (fast/cheap), low (default), medium, high, max (deep/expensive). Omit for configured default.zA natural language question.aOverride the default reasoning depth. Omit to use the configured default (typically low). Guide: - minimal: quick factual lookups (name, role, simple preference) - low: straightforward questions with clear answers - medium: multi-aspect questions requiring synthesis across observations - high: complex behavioral patterns, contradictions, deep analysis - max: thorough audit-level analysis, leave no stone unturnedminimallowmediumhighmax)r renum)rreasoning_levelrhoncho_contextuRetrieve full session context from Honcho — summary, peer representation, peer card, and recent messages. No LLM synthesis. Cheaper than honcho_reasoning. Use this to see what Honcho knows about the current conversation and the specified peer.zOOptional focus query to filter context. Omit for full session context snapshot.)rrhoncho_concludeuCWrite or delete a conclusion about a peer in Honcho's memory. Conclusions are persistent facts that build a peer's profile. You MUST pass exactly one of: `conclusion` (to create) or `delete_id` (to delete). Passing neither is an error. Deletion is only for PII removal — Honcho self-heals incorrect conclusions over time.zpA factual statement to persist. Provide this when creating a conclusion. Do not send it together with delete_id.zzConclusion ID to delete for PII removal. Provide this when deleting a conclusion. Do not send it together with conclusion.) conclusion delete_idrceZdZUdZdZedNdZdOdZdZd Z dPdZ dQdZ dQdZ dOdZ dRdZdNdZdddSdZdTdZdddUdZddddddd Zd!ed"<d#Zd$Zd%Zd&Zd'Zd(ZdOd)ZdVd+ZdWd,ZdXd-ZdYdZd/Zd[d3Z e!d\d5Z"d]d6Z#e$j%d7e$j&Z'e(d^d8Z)d_d;Z*e!d`d>Z+dddadAZ,dbdDZ-dcdGZ.dddHZ/dedKZ0dfdLZ1dMS)gHonchoMemoryProviderzHHoncho AI-native memory with dialectic Q&A and persistent user modeling.cd|_d|_d|_d|_t j|_d|_d|_d|_ d|_ t j|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d |_d|_d|_d |_d|_d|_d |_dS) Nhybridr every-turnTr gF)_manager_config _session_key_prefetch_result threadingLock_prefetch_lock_prefetch_thread _sync_thread _recall_mode_base_context_cache_base_context_lock _turn_count_injection_frequency_context_cadence_dialectic_cadence_dialectic_depth_dialectic_depth_levels_reasoning_heuristic_reasoning_level_cap_last_context_turn_last_dialectic_turn_prefetch_thread_started_at_prefetch_result_fired_at_dialectic_empty_streak_session_initialized_lazy_init_kwargs_lazy_init_session_id _cron_skippedselfs @/home/div/.hermes/hermes-agent/plugins/memory/honcho/__init__.py__init__zHonchoMemoryProvider.__init__s   "'n..<@8<%37 "+."2"2$0! !"# !9=$*.!)/!"&$(!36(.2&,-$%*!1548"#returnstrcdS)NhonchorMs rOrzHonchoMemoryProvider.namesxrQboolc ddlm}|}|jot |jp|jS#t$rYdSwxYw)z0Check if Honcho is configured. No network calls.r)HonchoClientConfigF)plugins.memory.honcho.clientrYfrom_global_configenabledrWapi_keybase_url Exception)rNrYcfgs rO is_availablez!HonchoMemoryProvider.is_availablesj  G G G G G G$7799C;D4 (Cs|#D#D D   55 s;> 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) jsonpathlibrcexistsloads read_textr_update write_textdumps)rNvalues hermes_homerfrc config_pathexistings rO save_configz HonchoMemoryProvider.save_configs       d;''-7        %4:k&;&;&=&=>>    ztz(1===>>>>>s"A A A cddddddddd gS) Nr]zHoncho API keyTHONCHO_API_KEYzhttps://app.honcho.dev)keyrsecretenv_varurlbaseUrlz!Honcho base URL (for self-hosted))rurrVrMs rOget_config_schemaz&HonchoMemoryProvider.get_config_schemas6.>$[kuM N N.Q R R  rQroconfigdictNonecTddl}ddlm}||dS)z:Run the full Honcho setup wizard after provider selection.rN) cmd_setup)typesplugins.memory.honcho.clirSimpleNamespace)rNror{rrs rO post_setupzHonchoMemoryProvider.post_setup s? 777777 %''))*****rQ session_idc T |dd}|dd}|dvs|dkr%td||d|_d Sd d lm}m}d d lm}| }|j r|j s#|j std d S||_ |j|_td|j |jpi} | dd|_t%| dd|_t%| dd|_t+dt-|jd|_|j|_|j|_|j|jvr |j|_n2#t@$r%} td| Yd } ~ nd } ~ wwxYw|jdkrI|j!r|j"||fi|d S||_#||_$||_ tdd S|j"||fi|d S#tJ$rtdYd St@$r-} t&d| 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_contextr+platformcli)cronflushrzBHoncho skipped: cron/flush context (agent_context=%s, platform=%s)TNr)rYget_honcho_clientHonchoSessionManageru)Honcho not configured — plugin inactivezHoncho recall_mode: %sinjectionFrequencyr-contextCadencer.dialecticCadencez,Honcho cost-awareness config parse error: %stoolsuGHoncho tools-only mode — deferring session init until first tool callu3honcho-ai package not installed — plugin inactivezHoncho init failed: %s)(getloggerdebugrLrZrYrplugins.memory.honcho.sessionrr[r\r]r^r1 recall_moder9rawr=intr>r?r!mindialectic_depthr@dialectic_depth_levelsrAreasoning_heuristicrBreasoning_level_cap _LEVEL_ORDERrCr_init_on_session_start_do_session_initrJrK ImportErrorwarningr0) rNrkwargsrrrYrrr`res rO initializezHonchoMemoryProvider.initializesD !"JJ;;Mzz*e44H 111X5G5G a*H666%)" Z Z Z Z Z Z Z Z J J J J J J$7799C; s{ cl  HIIIDL!$D  LL143D E E E Pgm,/GG4H,,W,W)(+CGG4Da,H,H(I(I% +.cgg6H!.L.L*M*M'(+As33F/J/J(K(K%/2/I,,/,C)*d.???030GD- P P P KQOOOOOOOO P G++,)D)#zDDVDDDF)/&-7*"  fggg "D !#z < ._prewarm_dialectics+11.AAAA LL!FLLL00A500FFFFF66,;;01-9:6;;;;;;;;;;;;;;;12D-34D00000A50000& A+AA9BBBzhoncho-prewarm-dialectictargetdaemonrz'Honcho pre-warm started for session: %srRr})rZrrrrrr0resolve_session_namer2rr get_or_createrImessagessession_strategyhermes_constantsrrSmigrate_memory_filesr_r9prefetch_contexttime monotonicrFr4Threadr7start)rNr`rrrrclientrrsessionrmem_dirrrrs` @rOrz%HonchoMemoryProvider._do_session_init\s"BBBBBBFFFFFF""3'',,-#)::i#8#8#@D      ?33 $jj)>??  $ $+%$7 %         68IJJJ---d.?@@$(! H# (< (M(M<<<<<<oo//*<== 2243DgNNN Y[_[lmmmm%66 u% H H H LLCQ G G G G G G G G H   5 5 5 E ..t/@AAAA E E E @!DDDDDDDD EM   6 6 6 6 6 6 6"04~/?/?D ,$-$4)$=W%%%D !  ! ' ' ) ) ) LLBDDU V V V V VC 6 5s1BE99 F(F##F(5G HG??Hc*|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) r0rIrLr1rJrrKr_rr)rNrs rO_ensure_sessionz$HonchoMemoryProvider._ensure_sessions = 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 ||d d}|r|d ||sdSd |S) zEFormat the prefetch context dict into a readable system prompt block.summaryr+z## Session Summary representationz## User Representation rz## User Peer Card ai_representationz## AI Self-Representation ai_cardz## AI Identity Card  )rappendjoin)rNrpartsrreprai_reprs rO_format_first_turn_contextz/HonchoMemoryProvider._format_first_turn_contexts9'')R((  ; LL999 : : :gg&++  ; LL9C99 : : :wwvr""  7 LL5t55 6 6 6,b11  A LL?v?? @ @ @'')R((  < LL::: ; ; ; 2{{5!!!rQc|jrdS|jr|js|jdkr |jr dSdS|jdkrd}n|jdkrd}nd}|S)uReturn system prompt text, adapted by recall_mode. Returns only the mode header and tool instructions — static text that doesn't change between turns (prompt-cache friendly). Live context (representation, card) is injected via prefetch(). r+rz# Honcho Memory Active (tools-only mode). Use honcho_profile, honcho_search, honcho_reasoning, honcho_context, and honcho_conclude tools to access user memory.ru# 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 raw peer context, honcho_reasoning for synthesized answers (pass reasoning_level minimal/low/medium/high/max — you pick the depth per call), honcho_conclude to save facts about the user. No automatic context injection — you must use tools to access memory.u# 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 raw peer context, honcho_reasoning for synthesized answers (pass reasoning_level minimal/low/medium/high/max — you pick the depth per call), honcho_conclude to save facts about the user.)rLr0r2r9r1)rNheaders rOsystem_prompt_blockz(HonchoMemoryProvider.system_prompt_blocks   2} D$5  G++ +i 2   ) )) F  ' ) )Z F@  rQr+)rrcrjrdSjdkrdSjdkr jdkrdSrdSg}j5j jj }|r |nd_j_ n9#t$r,}td|d_Yd}~nd}~wwxYwj}dddn #1swxYwYjr`jj }|r? |}|r(j5|_dddn #1swxYwY|}|r||j5t%j} dddn #1swxYwY| rjdkr j_jdkrΉr̉jrjjr jjnd} jdfd } t/j_t5j| d d _jj| jrtd| jr4jrjdj5j} j } d_d_ dddn #1swxYwYj!j"z}| r8| dkr2j| z |kr$td| j|d} | r)| #r|| |sdSd|}$|}|S)uReturn base context (representation + card) plus dialectic supplement. Assembles two layers: 1. Base context from peer.context() — cached, refreshed on context_cadence 2. Dialectic supplement — cached, refreshed on dialectic_cadence 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. r+rz first-turnr.Nz$Honcho base context fetch failed: %sr/ @rRr}c }nC#t$r6}td|xjdz c_Yd}~dSd}~wwxYw|rQ|r=j5|__dddn #1swxYwY_ d_dSxjdz c_dS)Nz&Honcho first-turn dialectic failed: %sr.rr)rr _fired_atrrNs rO_run_first_turnz6HonchoMemoryProvider.prefetch.._run_first_turnls<11%88AA LL!I3OOO00A500FFFFF 6 6,CC01-9B6CCCCCCCCCCCCCCC 1:D-34D00000A50000rTzhoncho-prefetch-firstrtimeoutuSHoncho first-turn dialectic still running after %.1fs — will surface on next turng@rzKHoncho pending dialectic discarded as stale: fired_at=%d, turn=%d, limit=%drr)%rLr9r=r<_is_trivial_promptr;r:r0get_prefetch_contextr2rrDr_rrpop_context_resultrr6rWr3rEr1rrrrFr4rr7rris_aliverGr?_STALE_RESULT_MULTIPLIERr_truncate_to_budget)rNrrrrr base_context fresh_ctx formatted_prewarm_landed_first_turn_timeoutrdialectic_resultfired_at stale_limitresultrs`` @rOprefetchzHonchoMemoryProvider.prefetchs_   2   ' '2  $ 4 49IA9M9M2  " "5 ) ) 2  $ 4 4'/2-<D++ 222LL!GKKK/1D,,,,,,2 3L 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 = - 889JKKI - ;;IFF -0==3<0===============#,L  ' LL & & &  : :"4#899O : : : : : : : : : : : : : : :  9t8D@@(,(8D %  $ , , ,(, V9MV $$SV (I 6 6 6 6 6 6 6 6$04~/?/?D ,$-$4&t:Q%%%D !  ! ' ' ) ) )  ! & &/B & C C C$--//  0'   4T%:%C%C%E%E 4  ! & &s & 3 3 3   2 2#4 5H$&D !-1D *  2 2 2 2 2 2 2 2 2 2 2 2 2 2 2-0MM  "A 43Ch3NR]2]2] LL$%-t/?    "   + 0 6 6 8 8 + LL) * * * 2U##))&11 ssC1A B%$C1% C/"CC1C C11C58C5EEEF""F&)F&!L  LLtextc|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 …)r1rlenrfind)rNr budget_chars truncated last_spaces rOrz(HonchoMemoryProvider._truncate_to_budgets| 4<#> K|2Q6 t99 $ $K,' __S))  s* * *!+:+.I6!!rQcbjrdSjr jrsdSjdkrdSrdSjdksjjz jkr`j_ jjn2#t$r%}t d|Yd}~nd}~wwxYw rt ddS }jjz |kr7t d|jjjjz dSjfd}t#j_t)j|dd _jdS) a Fire background prefetch threads for the upcoming turn. B5: Checks cadence independently for dialectic and context refresh. Context refresh updates the base layer (representation + card). Dialectic fires the LLM reasoning supplement. Nrr.z"Honcho context prefetch failed: %sz=Honcho dialectic prefetch skipped: prior thread still runningzhHoncho dialectic prefetch skipped: effective cadence %d (base %d, empty streak %d), turns since last: %dc }nC#t$r6}td|xjdz c_Yd}~dSd}~wwxYw|rQ|r=j5|__dddn #1swxYwY_ d_dSxjdz c_dS)NzHoncho prefetch failed: %sr.rr)rrrrrNs rO_runz1HonchoMemoryProvider.queue_prefetch.._runs+ 22599    91===,,1,,  2&,,.. 2(??,2D)5>D2???????????????-6)/0,,,,,1,,,,rTzhoncho-prefetchr)rLr0r2r9rr>r<rDrr_rr_thread_is_live_effective_cadencerEr?rHrrrFr4rr7r)rNrrr effectiverrs`` @rOqueue_prefetchz#HonchoMemoryProvider.queue_prefetchs    F} D$5 U  F   ' ' F  " "5 ) )  F  A % %$*:T=T*TY]Yn)n)n&*&6D # F ..t/@%HHHH F F F A1EEEEEEEE F    ! !  LLX Y Y Y F++--  t8 8I E E LLC42D4P 4#<<     F$  2 2 2 2 2 2 2 ,0>+;+;( ) 0+<! ! !  ##%%%%%s3 B CB>>Cbaserr))r.r)rdr)rdr.)rr)rr.)rrdzdict[tuple[int, int], str]_PROPORTIONAL_LEVELSrxig@rdc*|jr|jsdS|jr|jjr |jjnd}t j|jz }|||jzkr&t d|||jzdSdS)zThread-alive guard that treats threads older than the stale threshold as dead, so a hung Honcho request can't block new fires.FruSHoncho prefetch thread age %.1fs exceeds stale threshold %.1fs — treating as deadT) r7rr1rrrrF_STALE_THREAD_MULTIPLIERrr)rNrages rOrz$HonchoMemoryProvider._thread_is_live&s$ D,A,J,J,L,L 5+/<YDL=120 chars, +2 at >=400. rr.rd)rBrr_HEURISTIC_LENGTH_MEDIUM_HEURISTIC_LENGTH_HIGHindexrCr)rNrrnbumpbase_idxcap_idxs rO_apply_reasoning_heuristicz/HonchoMemoryProvider._apply_reasoning_heuristicPs (  K t( ( (K JJ t, , ,DD , , ,DDD$**400#))$*CDD X_g!>!>??rQpass_idxc|jr%|t|jkr |j|S|jr |jjnd}|j|j|f}||dkr|||S|S)utResolve reasoning level for a given pass index. Precedence: 1. dialecticDepthLevels (explicit per-pass) — wins absolutely 2. _PROPORTIONAL_LEVELS table (depth>1 lighter-early passes) 3. Base level = dialecticReasoningLevel, optionally scaled by the reasoning heuristic when the mapping falls through to 'base' rNr)rArr1dialectic_reasoning_levelrrr@r")rNr#rrmappings rO_resolve_pass_levelz(HonchoMemoryProvider._resolve_pass_levelds  ' :Hs4;W7X7X,X,X/9 9:>,Q 66E+//1F0QRR ?g//224?? ?rQ prior_results list[str]is_coldc|dkr|r dS dS|dkr|r|dnd}d|dSd t|dkr|dnd d t|dkr|dnd d S) aBuild the prompt for a given dialectic pass. Pass 0: cold start (general user query) or warm (session-scoped). Pass 1: self-audit / targeted synthesis against gaps from pass 0. Pass 2: reconciliation / contradiction check across prior passes. rzWho is this person? What are their preferences, goals, and working style? Focus on facts that would help an AI assistant be immediately useful.zGiven what's been discussed in this session so far, what context about this user is most relevant to the current conversation? Prioritize active context over biographical facts.r.r+z Given this initial assessment: z What gaps remain in your understanding that would help going forward? Synthesize what you actually know about the user's current state and immediate needs, grounded in evidence from recent sessions.z Prior passes produced: Pass 1: z(empty)z Pass 2: z Do these assessments cohere? Reconcile any contradictions and produce a final, concise synthesis of what matters most for the current conversation.)r)rNr#r(r*priors rO_build_dialectic_promptz,HonchoMemoryProvider._build_dialectic_promptvs q== 7 S   ]])6>M"%%BE4U444 003M0B0BQ0F0FM!,,I0003M0B0BQ0F0FM!,,I000 rQrc:|r%t|dkrdSd|vrJd|vsDd|vs@tjd|tjs tjd|tjrdSt|d kS) zCheck if a dialectic pass returned enough signal to skip further passes. Heuristic: a response longer than 100 chars with some structure (section headers, bullets, or an ordered list) is considered sufficient. dF z##u•z^[*-] z ^\s*\d+\. Ti,)rrresearch MULTILINE)rs rO_signal_sufficientz'HonchoMemoryProvider._signal_sufficients V\\^^,,s225 6>> FNNyFBL99y ==46<<>>""S((rQc|jr|jsdS|j }g}t|jD]}|dkr|d||}nW|r>||dr#td|j|n||||}| ||}td|j||||j |j||d}| |pdt|D]}|r| r|cSdS) u[Execute up to dialecticDepth .chat() calls with conditional bail-out. Cold start (no base context): general user-oriented query. Warm session (base context exists): session-scoped query. Each pass is conditional — bails early if prior pass returned strong signal. Returns the best (usually last) result. r+rr,zCHoncho dialectic depth %d: pass %d skipped, prior signal sufficient)rz5Honcho dialectic depth %d: pass %d, level=%s, cold=%suserr#r)r0r2r:ranger@r.r5rrr'dialectic_queryrreversedr) rNrr*resultsipromptlevelrrs rOrz)HonchoMemoryProvider._run_dialectic_depths} D$5 2..t,-- ) )AAvv55a'JJt66wr{CCLL!f!%!6;;;E55a'JJ,,Qe,<EJ,>I9~~** 5Hiify6HIII  +G--''CY_$$mmD))!881HCY_$$mmC((Y_$$dsdO**,,E!#$$..00I ' MM% E1 4 rQ 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)Nr7 assistantzHoncho sync_turn failed: %s) r0rr2rX add_message_flush_sessionr_rr)rrWrrZ msg_limitrNrYs rO_syncz-HonchoMemoryProvider.sync_turn.._sync0s ?-55d6GHH!00yII77E''6666!001BINN<>>>>>>>> ?sBB C &CC @rTz honcho-syncr) rLr0r2r1message_max_charsr8rrr4rr)rNrYrZrrar`s``` @rO sync_turnzHonchoMemoryProvider.sync_turn#s    F} D$5  F6:lMDL22  ? ? ? ? ? ? ? ?   0!2!;!;!=!= 0   " "3 " / / /%,M    !!!!!rQactionrc|dks|dkssdSjrdSjrjsdSfd}tj|dd}|dS)z:Mirror built-in user profile writes as Honcho conclusions.addr7Nc jjdS#t$r&}td|Yd}~dSd}~wwxYw)NzHoncho memory mirror failed: %s)r0create_conclusionr2r_rr)rrKrNs rO_writez4HonchoMemoryProvider.on_memory_write.._writeKst C //0A7KKKKK C C C >BBBBBBBBB Cs % AAATzhoncho-memwriter)rLr0r2r4rr)rNrerrKrjts` ` rOon_memory_writez$HonchoMemoryProvider.on_memory_writeBs U??f..g. F    F} D$5  F C C C C C C  F4>O P P P  rQrList[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) rLr0r8rr flush_allr_rr)rNrrs rOon_session_endz#HonchoMemoryProvider.on_session_endTs    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)rLr9listALL_TOOL_SCHEMASrMs rOget_tool_schemasz%HonchoMemoryProvider.get_tool_schemasbs6   I   ) )I$%%%rQ tool_nameargsc j |jrtdS|js#|stdS|jr|jstdS |dkr|dd}|d}|r[|j|j||}|td Stj d t|d |d S|j |j|}|stj ddiStj d|iS|dkr|dd}|stdStt|ddd} |dd}|j|j|| |}|stj ddiStj d|iS|dkr|dd}|stdS|dd}|d} |j|j|| |}|j|_tj d|pdiS|dkrq|dd}|j|j|} | stj ddiSg} | dr| d | d| d!r| d"| d!| dr| d#| d| d$rG| d$} d%d&| d'd D}| d(|tj dd)| pd*iS|d+kr<|d,pd}|d-d}|dd}t-|}t-|}||krtd.S|rQ|j|j||}|rtj dd/|d0iStd1|d2S|j|j||}|rtj dd3|d4|iStd5Std6|S#t2$r;}t4d7||td8|d9|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 rr7r)rNzFailed to update peer card.zPeer card updated (z facts).)rrrzNo profile facts available yet.rrr+z!Missing required parameter: queryri i)rrzNo relevant context found.rr#r8zNo result from Honcho.r$zNo context available yet.rz ## Summary rz## Representation z## Card recent_messagesr1c3NK|] }d|dd|dddV!dS)z [rolez] rKNrV).0ms rO z8HonchoMemoryProvider.handle_tool_call..sX((@ai??1Y<+=??((((((rQz## Recent messages rzNo context available.r%r'r&z8Exactly one of conclusion or delete_id must be provided.z Conclusion z deleted.zFailed to delete conclusion .zConclusion saved for z: zFailed to save conclusion.zUnknown tool: zHoncho tool %s failed: %szHoncho z failed: )rLr rIrr0r2r set_peer_cardrfrmr get_peer_cardrrsearch_contextr:r<rEget_session_contextrrrrWdelete_conclusionrir_rerror)rNrurvrr card_updaterrrrr#rrmsgsmsg_strr'r& has_delete_idhas_conclusionokrs rOhandle_tool_callz%HonchoMemoryProvider.handle_tool_callmsT   FDEE E( N'')) N!"LMMM} HD$5 HFGG GW A,,,xx//"hhv.. o!]889JK^b8ccF~)*GHHH:1\s6{{1\1\1\fl&m&mnnn}2243D42PPU:x1R&STTTz8T"2333o--"--K%&IJJJ TXXlC%@%@!A!A4HH xx//55%u$6P:x1M&NOOOz8V"4555000"--K%&IJJJxx//"&((+<"="=66%u$37 -1,<)z8V-O7O"PQQQ...xx//m778IPT7UUO:x1L&MNNN779%%BLL!@I!@!@AAA77+,,PLL!Ns;K7L!N!NOOO776??<LL!:S[!:!:;;;77,--C01D"ii((!%bcc(((GLL!A!A!ABBBz8V[[-?-?-ZCZ"[\\\///!XXk228b??AA !XXlB77==?? xx// $Y !%j!1!1 N22%&`aaa S889JI\`8aaBZ#z85W95W5W5W*XYYY%&QY&Q&Q&QRRR]44T5F Y]4^^`:x1]1]1]Q[1]1]&^___!">???:y::;; ; A A A LL4i C C C? ??A??@@ @ @ @ @ @ @ AsA%U-'U--8U-&U-<,U-)BU-+U-,U-.A1U- AU-6D!U-B U-9?U-9U- ?U- U-U-- V270V-'V2-V2c|j|jfD].}|r*|r|d/|jr- |jdS#t $rYdSwxYwdS)Nrbr)r7r8rrr0ror_)rNrks rOshutdownzHonchoMemoryProvider.shutdowns'):; $ $A $QZZ\\ $s### =   '')))))      sA!! A/.A/N)rRrS)rRrW)rorSr{r|rRr})rrSrRr})rr|rRrS)rrSrrSrRrS)rrSrRrS)rrSrrSrRr})rRr)rRr|)rrSrrSrRrS)r+)r#rrrSrRrS)r#rr(r)r*rWrRrS)rrSrRrW)rrSrRrS)rrSrRrW)rGrrHrSrRr})rKrSrLrrRr))rYrSrZrSrrSrRr})rerSrrSrKrSrRr})rrmrRr})rRrm)rurSrvr|rRrSr)2__name__ __module__ __qualname____doc__rPpropertyrrarrrzrrrrrrrrrr__annotations__rrrr rr rrrr"r'r. staticmethodr5rr2compile IGNORECASErC classmethodrrJrXrdrlrprtrrrVrQrOr)r)sRR'#'#'#RX ? ? ?   ++++ K!K!K!K!ZXWXWXWXWt4"""":0000d9;KKKKKKZ " " " "?AH&H&H&H&H&H&b 8 8    ?L #  # !L    %%%%    &@@@@($%%%%N)))\)&((((Z$ U     [ ''''***\*XY["""""">$ C C C C & & & &dAdAdAdAL      rQr)rRr}cH|tdS)z,Register Honcho as a memory provider plugin.N)register_memory_providerr))rs rOregisterrs#  !5!7!788888rQr)r __future__rrfloggingr2r4rtypingrrrragent.memory_providerrtools.registryr getLoggerrrPROFILE_SCHEMA SEARCH_SCHEMAREASONING_SCHEMACONTEXT_SCHEMACONCLUDE_SCHEMArsr)rrVrQrOrs6  #"""""   ,,,,,,,,,,,,000000%%%%%%  8 $ $  6 ! C   (+h   2  X !G "[ ! C   I! :  K!= !TDCC  ! C'  0I5%%P  ; !p ! C     2  b! R ! \ ! C   !<#M3C^Udeaaaaa>aaaP!999999rQ