`gj?i UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z m Z ddlmZmZmZddlmZddlmZddlmZdd lmZej4eZd Zd Zd Zd Z dZ!dZ"hdZ#dddddddddd Z$dQdZ%dZ&dRdZ'dSdZ(dTdZ)iZ*d e+d!<e jXZ-dUd"Z. dV dWd#Z/ dX dYd$Z0da1d%e+d&<da2d'e+d(<e jXZ3e4Z5dZd)Z6e fd[d*Z7d+d,d-d.d/d0d.d1d0d2d3d.id4d5d6d7gd8d9Z8d:d;d-dd?d-dd_dEZ?d`dFZ@dadGZAddHdbdIZBdcdJZCddHdddKZDdedLZEdfdMZFGdNdOeZGdTdPZHy)guaHindsight memory plugin — MemoryProvider interface. Long-term memory with knowledge graph, entity resolution, and multi-strategy retrieval. Supports cloud (API key) and local modes. Configurable request timeout via HINDSIGHT_TIMEOUT env var or config.json. Configurable embedded daemon idle timeout via HINDSIGHT_IDLE_TIMEOUT env var or config.json idle_timeout. Original PR #1811 by benfrank241, adapted to MemoryProvider ABC. Config via environment variables: HINDSIGHT_API_KEY — API key for Hindsight Cloud HINDSIGHT_BANK_ID — memory bank identifier (default: hermes) HINDSIGHT_BUDGET — recall budget: low/mid/high (default: mid) HINDSIGHT_API_URL — API endpoint HINDSIGHT_MODE — cloud or local (default: cloud) HINDSIGHT_TIMEOUT — API request timeout in seconds (default: 120) HINDSIGHT_IDLE_TIMEOUT — embedded daemon idle timeout seconds; 0 disables shutdown (default: 300) HINDSIGHT_EMBED_PORT_HEALTH_GRACE_TIMEOUT — seconds to wait for a slow embedded daemon /health before treating it as stale (default: 30; set via config.json port_health_grace_timeout) HINDSIGHT_RETAIN_TAGS — comma-separated tags attached to retained memories HINDSIGHT_RETAIN_OBSERVATION_SCOPES — observation scoping for retained memories: per_tag/combined/all_combinations, or a JSON list of tag-lists for custom scopes HINDSIGHT_RETAIN_SOURCE — metadata source value attached to retained memories HINDSIGHT_RETAIN_USER_PREFIX — label used before user turns in retained transcripts HINDSIGHT_RETAIN_ASSISTANT_PREFIX — label used before assistant turns in retained transcripts Or via $HERMES_HOME/hindsight/config.json (profile-scoped), falling back to ~/.hindsight/config.json (legacy, shared) for backward compatibility. ) annotationsN)datetimetimezone)AnyDictList)MemoryProvider)get_hermes_home) tool_error)cfg_getz"https://api.hindsight.vectorize.iozhttp://localhost:8888z0.6.1xi,z0.5.0>lowmidhigh gpt-4o-minizclaude-haiku-4-5zgemini-2.5-flashzopenai/gpt-oss-120bzqwen/qwen3.5-9bz MiniMax-M2.7z gemma3:12bz local-modelzyour-model-name openai anthropicgeminigroq openrouterminimaxollamalmstudioopenai_compatiblec||dk(r|S t|S#ttf$rtj d|||cYSwxYw)zAParse an integer config/env value, falling back on invalid input.z6Invalid integer Hindsight setting %r; using default %s)int TypeError ValueErrorloggerwarning)valuedefaults T/root/.hermes/venv/lib/python3.12/site-packages/plugins/memory/hindsight/__init__.py_parse_int_settingr&OsM } 5z z "OQVX_`s (AA)HINDSIGHT_EMBED_PORT_HEALTH_GRACE_TIMEOUTc6|jd}||dk(ry t|}|dkrtj d|yt jjtt|y#ttf$rtj d|YywxYw)anExport the embedded-daemon health grace timeout to the process env. Must run BEFORE ``hindsight_embed.daemon_embed_manager`` is imported, because the package reads the env var into a module-level constant at import time. We only set it when the user configured a value AND the env var isn't already set, so an explicit env override always wins. port_health_grace_timeoutNrz9Invalid Hindsight port_health_grace_timeout %r; ignoring.rz:Negative Hindsight port_health_grace_timeout %r; ignoring.) getfloatrr r!r"osenviron setdefault_PORT_HEALTH_GRACE_ENVrepr)configrawsecondss r%!_export_port_health_grace_timeoutr4ds **0 1C {cRi* { H#  JJ0$w-@ z " G   s A00%BBc tjdtjdy#t$r}dt|fcYd}~Sd}~wwxYw)aBReturn whether local embedded Hindsight imports cleanly. On older CPUs, importing the local Hindsight stack can raise a runtime error from NumPy before the daemon starts. Treat that as "unavailable" so Hermes can degrade gracefully instead of repeatedly trying to start a broken local memory backend. hindsightz$hindsight_embed.daemon_embed_manager)TNFN) importlib import_module Exceptionstr)excs r%_check_local_runtimer<sE , FG c#hs*- A  AA A c ddlm}|ddy#t$rYyt$r}tt ||d}~wwxYw)z>Install the Hindsight cloud client lazily before importing it.rensurememory.hindsightFpromptN)tools.lazy_depsr? ImportErrorr9r:) _lazy_ensurer;s r%_ensure_cloud_client_dependencyrFsA-:'6   -#c(#,-s AA;AzDict[str, bool]_append_capability_cachecV|sy ddlm}||||k\S#t$rYywxYw)uJReturn True if *actual* ≥ *required* (semver). False on missing/invalid.FrVersion)packaging.versionrJr9)actualrequiredrJs r%_meets_minimum_versionrNs6 -v'("333 s  ((cXddl}ddl}|sy|jddz}|jj |}|r|j dd| |jj ||5}|jjdd }dddtj}t|tsy|j!d xs|j!d } | r t#| SdS#1swYbxYw#t$r!} tjd || Yd} ~ yd} ~ wwxYw)u)GET ``/version`` and return the version string (or None on failure). Hindsight's `/version` endpoint returns ``{"version": "0.5.6", ...}``. Any failure (timeout, 404, malformed JSON, missing key) → None, which the caller treats as "legacy API, no update_mode support". rN/z/version AuthorizationzBearer timeoututf-8replace)errorsz*Hindsight /version probe failed for %s: %sversion api_version) urllib.errorurllib.requestrstriprequestRequest add_headerurlopenreaddecodejsonloadsr9r!debug isinstancedictr*r:) api_urlapi_keyrSurlliburlreqresppayloaddatar;rWs r%_fetch_hindsight_api_versionros  ..  *C ..  %C ''(;< ^^ # #C # 9 DTiik(((CG Dzz'" dD !hhy!09 $W -I   @ WA /    Pg ' 355 sB:$C:CCz asyncio.AbstractEventLoop | None_loopzthreading.Thread | None _loop_threadct5t#tjrtcdddStjad}t j |ddatjtcdddS#1swYyxYw)z>Return a long-lived event loop running on a background thread.Nc^tjttjyN)asyncioset_event_looprv run_foreverr%_runz_get_loop.._run s  " "5 )    rTzhindsight-looptargetdaemonname) _loop_lockrv is_runningr{new_event_loop threadingThreadrwstart)rs r% _get_looprsu    !1!1!3  &&( !''tDGWX    s BABB crddlm}t}|||}| td|j |S)z8Schedule *coro* on the shared loop and block until done.r)safe_schedule_threadsafezHindsight loop unavailablerR)agent.async_utilsrr RuntimeErrorresult)cororSrloopfutures r% _run_syncrs:: ;D %dD 1F ~788 === ))rhindsight_retainzStore information to long-term memory. Hindsight automatically extracts structured facts, resolves entities, and indexes for retrieval.objectstringzThe information to store.)type descriptionz9Short label (e.g. 'user preference', 'project decision').arrayrzDOptional per-call tags to merge with configured default retain tags.)ritemsr)contentcontexttagsr)r propertiesrM)rr parametershindsight_recallzSearch long-term memory. Returns memories ranked by relevance using semantic search, keyword matching, entity graph traversal, and reranking.queryzWhat to search for.hindsight_reflectzSynthesize a reasoned answer from long-term memories. Unlike recall, this reasons across all stored memories to produce a coherent response.zThe question to reflect on.c`ddlm}tdz dz }|jr& t j |j dS|jdz dz }|jr& t j |j dStjjdd tjjd d ttjjd tttjjd ttjjdd tjjdd tjjdd tjjddtjjdddtjjddtjjddddid S#t$rYwxYw#t$rYwxYw)zLoad config from profile-scoped path, legacy path, or env vars. Resolution order: 1. $HERMES_HOME/hindsight/config.json (profile-scoped) 2. ~/.hindsight/config.json (legacy, shared) 3. Environment variables rPathr6 config.jsonrTencoding .hindsightHINDSIGHT_MODEcloudHINDSIGHT_API_KEYrHINDSIGHT_TIMEOUTHINDSIGHT_IDLE_TIMEOUTHINDSIGHT_RETAIN_TAGS#HINDSIGHT_RETAIN_OBSERVATION_SCOPESHINDSIGHT_RETAIN_SOURCEHINDSIGHT_RETAIN_USER_PREFIXUser!HINDSIGHT_RETAIN_ASSISTANT_PREFIX AssistanthermesHINDSIGHT_BANK_IDHINDSIGHT_BUDGETrT)bankIdbudgetenabled) modeapiKeyrS idle_timeout retain_tagsobservation_scopes retain_sourceretain_user_prefixretain_assistant_prefixbanks)pathlibrr existsrbrc read_textr9homer,r-r*r&_DEFAULT_TIMEOUT_DEFAULT_IDLE_TIMEOUT)r profile_path legacy_paths r% _load_configr]s#${2]BL ::l44g4FG G ))+ ,}>:R+SUjkzz~~&=rB jjnn-RTVW(A2F jjnn-KVT#%::>>2UWb#c **..)per_tagcombinedall_combinationsc0|yt|trP|j}|sy|tvr|S|j dr! t j |}t|Syt|ttfrtd|Dr5|Dcgc]#}|js|j%}}|r|gSdSg}|D]}t|ttfrU|Dcgc]5}t|jst|j7}}|s\|j|nt|ts|js|j|jg|xsdSy#t$rYywxYwcc}wcc}w)u5Normalize an observation_scopes config value to a Hindsight-accepted form. Returns one of: * ``None`` — nothing configured; Hindsight applies its ``combined`` default. * a keyword string — ``"per_tag"`` / ``"combined"`` / ``"all_combinations"``. * ``list[list[str]]`` — custom scopes, one inner list per consolidation pass. Accepts a keyword string, a JSON-encoded list, a flat list of tags (treated as a single scope), or a list of tag-lists. Anything unrecognized yields ``None`` so we never send an invalid payload. Nrc3<K|]}t|tywrz)rer:).0entrys r% z0_normalize_observation_scopes..s9%z%%9s) rer:r_OBSERVATION_SCOPE_KEYWORDSrrbrcr9_normalize_observation_scopesrtupleallr)r#rrrinnerscopesrs r%rrs` }%{{} . .K ??3  D)18 8%$' 959 905GuU[[]GEG#E7 - -"$ /E%$/5:Occ#hnn>NS)OOMM%(E3'EKKM u{{}o.  /~ )  H Ps*E?F'F#FF? F  F ctjtjj dj ddS)zHReturn current UTC timestamp in ISO-8601 with milliseconds and Z suffix. milliseconds)timespecz+00:00Z)rnowrutc isoformatrUr~rr%_utc_timestamprs2 << % / / / H P PQY[^ __rcD|jdd}t|xsdS)zBReturn the Hindsight embedded profile name for this Hermes config.profiler)r*r:)r1rs r%_embedded_profile_namers"jjH-G w"( ##rc|jsiSi}|jdjD]P}|r|jdsd|vr|j dd\}}|j ||j <R|S)zEParse a simple KEY=VALUE env file, ignoring comments and blank lines.rTr#=)rr splitlinesrrr)pathvalueslinekeyr#s r%_load_simple_envrs ;;= F0;;=,ts+s$ ZZQ' U#kkmsyy{ , Mr llm_api_keyc|}|F|jdxs3|jdxs tjjdd}|jdd}|jdd}|jdxs tjjdd}|d vrd n|}t|t|xsdt|d d }|rt||d<|jd |jd ntjjd}|!|dk7rtt |t |d<|S)zKBuild the profile-scoped env file that standalone hindsight-embed consumes. llmApiKeyrHINDSIGHT_LLM_API_KEYr llm_provider llm_model llm_base_urlHINDSIGHT_API_LLM_BASE_URL>rrrinfo)HINDSIGHT_API_LLM_PROVIDERHINDSIGHT_API_LLM_API_KEYHINDSIGHT_API_LLM_MODELHINDSIGHT_API_LOG_LEVELrr#HINDSIGHT_EMBED_DAEMON_IDLE_TIMEOUT)r*r,r-r:r&r) r1r current_keycurrent_provider current_modelcurrent_base_urldaemon_provider env_valuesrs r%_build_embedded_profile_envrsGK JJ{ # ;zz-( ;zz~~5r:  zz."5JJ{B/Mzz.1eRZZ^^D`bd5e#36Y"Yh_oO'*/&:%():%;#&}#5#) J 367G3H /0 ::n % 1  >" ZZ^^4 5 LB$6.-s!HzsE3%qr"HrTr)rparentmkdirr write_textjoinr)r1r profile_envrs r%!_materialize_embedded_profile_envr*'sj,V4KTD9,VMJ HZ5E5E5GHH rc|syg}d}t|D]F}|js |dk(s|dk(r|j|d}1|r4|jdd}Hdj|j dS)zSanitize a bank_id_template placeholder value. Bank IDs should be safe for URL paths and filesystem use. Replaces any character that isn't alphanumeric, dash, or underscore with a dash, and collapses runs of dashes. rF-_T-_)r:isalnumrr(r)r#out prev_dashchs r%_sanitize_bank_segmentr32sz  CI%j! ::<29c JJrNI 3 ! 773<  d ##rc |s|S|jDcic]\}}|t|}}} |jdi|}d|vr|jdd}d|vrd|vr|jdd}d|vr|jd}|xs|Scc}}w#ttf$r$}t j d||||cYd}~Sd}~wwxYw) uResolve a bank_id template string with the given placeholders. Supported placeholders (each is sanitized before substitution): {profile} — active Hermes profile name (from agent_identity) {workspace} — Hermes workspace name (from agent_workspace) {platform} — "cli", "telegram", "discord", etc. {user} — platform user id (gateway sessions) {session} — current session id Missing/empty placeholders are rendered as the empty string and then collapsed — e.g. ``hermes-{user}`` with no user becomes ``hermes``. If the template is empty, resolution falls back to *fallback*. Returns the sanitized bank id. u5Invalid bank_id_template %r: %s — using fallback %rNz--r,__r-r.r~) rr3formatKeyError IndexErrorr!r"rUr)templatefallback placeholderskv sanitizedrenderedr;s r%_resolve_bank_id_templater@Hs :F:L:L:NO$!Q*1--OIO"8??/Y/ ( ##D#. (  ( ##D#. ( ~~d#H  xP j !Nh 0s"BBC &C?C C cFeZdZdZd%dZdZed&dZd'dZdZ d(dZ dZ d Z d Z d)d Zd*d Zd*d Zd*dZd*dZdZd&dZd+dZd,dZd&dZddd-dZddd.dZd/dZd0dZdddddd d1dZddd2dZd3dZd4d Zdd!d" d5d#Z d*d$Z!y)6HindsightMemoryProviderzMHindsight long-term memory with knowledge graph and multi-strategy retrieval.cp ddlm}|jdz }t|gS#t$rgcYSwxYw)zHindsight's legacy shared config and embedded-mode profile env files live under ~/.hindsight (see _load_config / line ~509).rrr)rrrr:r9)selfr legacy_dirs r% backup_pathsz$HindsightMemoryProvider.backup_pathsps;  $|3J O$ $ I s $' 55cd|_d|_t|_d|_d|_d|_d|_d|_d|_ g|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d |_d|_t2|_t6|_d|_t=j>|_ d|_!tEjF|_$d|_%t=jL|_'d |_(d|_)d|_*d|_+d|_,d|_-d|_.d |_/d |_0d |_1d |_2d|_3d |_4g|_5d |_6d |_7d|_8dg|_9d|_:d|_;d|_<d|_=d|_>y)NrrrrhybridrecallrrrFanyTr.conversation between Hermes Agent and the User observation )?_config_api_key_DEFAULT_API_URL_api_url_bank_id_budget_mode _llm_base_url _memory_mode_prefetch_method _retain_tags_retain_source_retain_user_prefix_retain_assistant_prefix _platform_user_id _user_name_chat_id _chat_name _chat_type _thread_id_agent_identity_agent_workspace _turn_index_clientr_timeoutr _idle_timeout_prefetch_resultrLock_prefetch_lock_prefetch_threadqueueQueue _retain_queue_writer_threadEvent_shutting_down_atexit_registered _sync_thread _session_id_parent_session_id _document_id_tags _recall_tags_recall_tags_match _auto_retain_retain_every_n_turns _retain_async_retain_context _turn_counter_session_turns_last_retained_turn_count _auto_recall_recall_max_tokens _recall_types_recall_prompt_preamble_recall_max_input_chars _bank_mission_bank_retain_mission_bank_id_templaterDs r%__init__z HindsightMemoryProvider.__init__zs  (     $ (') #) (3%  ! " ( 2 "'nn. $ +0++-7;'oo/"'!"$(, .2"'!%&"!O)+*+&!"&*7')$'*$ 04!!#rcy)Nr6r~rs r%rzHindsightMemoryProvider.namesrc t}|jdd}|dvrt\}}|S|dk(ryt|jdxs3|jdxs tj jdd }t|jd xs tj jd d }|xs|S#t $rYy wxYw) Nrr>locallocal_embeddedlocal_externalTrrhrrrgHINDSIGHT_API_URLF)rr*r<boolr,r-r9)rDcfgr availabler-has_keyhas_urls r% is_availablez$HindsightMemoryProvider.is_availables .C7767+D2235 1  ''!;779%;::>>"5r:G 3779-X@SUW1XYG%g %  s.CCBC CCc&ddl}ddlm}||dz }|jdd|dz }i}|j r! |j |j }|j|ddl m }|||d y#t$rY.wxYw) z3Write config to $HERMES_HOME/hindsight/config.json.rNrr6Trr)atomic_json_writei)r) rbrrr&rrcrr9updateutilsr) rDr hermes_homerbr config_dir config_pathexistingrs r% save_configz#HindsightMemoryProvider.save_configs +&4 5 =0      %4::k&;&;&=> ++xe<   s B BBc ddl}ddl}ddl}ddlm}ddlm}ddlm}ddl m } m } m } tdt|jt r |jn t#} t| t si} gd} gd }| j%d }|| vr| j'|nd}| d ||| }|| k(r| y| |}t!| }||d <i}d t(}d}|dk(r|g}n |dk(r|g}n|g}d}|dk(rt+t,j/}|Dcgc]}|dt,|f}}|j%d}||vr|j'|nd}| d||| }|| k(r| y||}||d<td|j1d}|s6tdtd|j2ddj5|n@ |j7|ddd|j2ddg|zdd d|j8!td"|d%k(rztd&t<j>j%d'd}!|!rtA|!d(kDrd)|!d*dnd+}"|jBjEd,|"d-|jBjG|jHjKr|dn'|jHjMjO}#n|jBjEd.|jBjG|jHjKr|dn'|jHjMjO}#|#r|#|d'<tQd/tRd0jO}$|$r\|$|d1<nU|dk(rtQd2tTd0jO}$|$xstT|d1<|jBjEd3|jBjG|jHjKr|dn'|jHjMjO}#|#r|#|d'<n|d4k(rE|j%d5d}%d6}&|%r |&d7|%d8z }&|&d9z }&tQ|&jO}$|$r|$|d5<n |d:k(rd;|d5<t,j%|d<}'|j%d=xs|'}(tQd>|(d0jO}$|$xs|(|d=<|jBjEd?|jBjG|jHjKr|dn'|jHjMjO})|)r|)|d@<nm||dAz }*d}+|*jWrK|*jYj[D]*},|,j]dBs|,j_dCdDdD}+n|+|d@<|jadEdF|jadGdH|j%dI}-|-|-ntb}.|.|dI<te|.|dJ<|dk(r.|j%dK}/|/|/ntf}0|0|dK<te|0|dL<dM|dNdO<|||j |||r=||dAz }*|*jhjkddPg}1|*jWr|*jYj[}1tm}2g}3|1D]~},dC|,vr4|,j]dQs#|,j_dCdDdjOnd}4|4r/|4|vr+|3jo|4dC||4|2jq|4n|3jo|,|jsD] \}5}6|5|2vs |3jo|5dC|6"|*judRj5|3dRz|dk(rt!|}7||dMz dSz }8 twjx|8jYdTU}7|j%d@d}9|9s$t{||dAz j%d@d}9|9s$t{t}|7j%dVd}9t|7|9xsdWtdX|dY|r tdZtd[ycc}w#t:$rC} td#| td$|j2ddj5|Yd} ~ d} ~ wwxYw#t:$rYwxYw)\uLCustom setup wizard — installs only the deps needed for the selected mode.rNr)r)masked_secret_prompt) _CANCELLED_curses_select_print_cancelled_setupz! Configuring Hindsight memory: rrr))Cloudz8Hindsight Cloud API (lightweight, just needs an API key))zLocal Embeddedz7Run Hindsight locally (downloads ~200MB, needs LLM key))zLocal Externalz)Connect to an existing Hindsight instancerz Select mode)r$cancel_returnshindsight-client>=z hindsight-allrrrzdefault model: r z Select LLM providerz Checking dependencies...uvuR ⚠ uv not found — install it: curl -LsSf https://astral.sh/uv/install.sh | shz- Then run manually: uv pip install --python  pipinstall--python--quiet --upgradeTr checkrScapture_outputstdinu ✓ Dependencies up to dateu ⚠ Install failed: z( Run manually: uv pip install --python rz9 Get your API key at https://ui.hindsight.vectorize.io rz...rz API key (current: z, blank to keep): z API key: z API URL [z]: rgz Hindsight API URL [z% API key (optional, blank to skip): rr z5 LLM endpoint URL (e.g. http://192.168.1.10:8080/v1)z []: rzhttps://openrouter.ai/api/v1rr z LLM model [z LLM API key: rrzHINDSIGHT_LLM_API_KEY=rrbank_idr recall_budgetrrSrrrr6memoryproviderrrr#rrTrrru$ ✓ Hindsight memory configured (z mode)z API keys saved to .envz$ Start a new session to activate. )@ subprocessshutilsysrrhermes_cli.configrhermes_cli.secret_promptrhermes_cli.memory_setuprrrprintrerOrfrr*index_MIN_CLIENT_VERSIONr_PROVIDER_DEFAULT_MODELSkeyswhich executabler(runDEVNULLr9r,r-lenstdoutwriteflushrisattyreadlinerinputrQ_DEFAULT_LOCAL_URLrrrrrr.rr:rr%r&rrrrr'rbrcrrr*):rDrr1rrrrrrrrrexisting_config mode_values mode_items existing_modemode_default_idxmode_idxrprovider_config env_writes cloud_dep local_depdeps_to_installr providers_listp llm_itemsexisting_llm_providerllm_default_idxllm_idxuv_pathe existing_keymaskedrhvalexisting_base_urlrBprovider_default_modelrllm_keyenv_pathexisting_llm_keyrexisting_timeout timeout_valexisting_idle_timeoutidle_timeout_valexisting_lines updated_keys new_lines key_matchr<r=materialized_configrrs: r% post_setupz"HindsightMemoryProvider.post_setups7  1A^^ 34*4T\\4*H$,,ln/40 OD  (++F3 ?LP[?[;,,];ab!/:GWhrs z ! " $ 8$ $_ 5"& ))<(=> # # #(kO % %(kO(kO # #!":"?"?"ABN(o&>q&A%BCDI%4$7$7$G !MbftMtn223HIz{O$'') G *$&()'2L.:ON + ,-,,t$ f g A#..AQQRSVS[S[\kSlRmn o oeY CNNIWbcfuuD$,, 56 7? O P::>>*=rBL69,6G!6K3|BC012QV   #7x?Q!RS   "69ii6F6F6H.r2ciiN`N`NbNhNhNj   /   "69ii6F6F6H.r2ciiN`N`NbNhNhNj29 ./+&6%7s;<BBDC-0 * % %/0B/C3GHNNPC),)B0BOI & JJ  D E JJ   25))2B2B2D*2.#))J\J\J^JdJdJfG29 ./22$3$7$7$K!P$#4"5Q77F$Fm))+69ON3-2P/%=%A%A,P]%^ "+// <V@VM- c:;AACC+.+?-OK ( JJ  . / JJ   25))2B2B2D*2.#))J\J\J^JdJdJfG6= 23 ,v5#% ??$ ( 2 2 4 ? ? A"??+CD/3zz#q/A!/D,!"7G 23 ""9h7""?E:+..y9*:*F&L\ %0 "*-k*: &' # #$3$7$7$G !8M8Y4_t .>ON +367G3HJ/ 0'2x$F +6 K(61H OO ! !$ ! >N !)!3!3!5!@!@!B5LI& +=@D[QUQ`Q`adQeDJJsA.q1779ko j!8$$ {!Jy4I3J%KL $$Y/$$T*  +#((* 11L($$s!A3Z0 1    ) 4t ; < # #"&"7 {+k9MIK &*jj1F1FPW1F1X&Y#%..)@"EK.tK/@6/IJNNOfhjk ./IJ]/^_cc/ .#'/4  5dV6BC  , - 67E> o.qc23@@PPQRURZRZ[jRkQlmnn o^  s0b+?b0/%c?0 c<98c77c<? d  d c>gdddgddddtddidd d d d d ddidddtddidd dd d ddiddddgdddiddddddddddd d ddidd!d"d#dtd$ddid%d&d'd(d)d*d+dd)d,d-d.d/d0d.d1d2d3gd4dd5d6d7gd8dd9d:d;d;ddd)d?d@dd)dAdBdd)dCdDdEd)dFdGdHd)dIdJdd)dKdLdMgdNddOdPdQd)dRdSd d)dTdUd d)dVdWdXd)dYdZd d)d[d\d]d)d^d_d`d)dadbdcd)ddded.dfdgtd)dhditddiddjdkdddidS)lNrzConnection moderr)rrr$choicesrgzHindsight Cloud API URL)rrr$whenrhzHindsight Cloud API keyTrz!https://ui.hindsight.vectorize.io)rrsecretenv_varrjrzHindsight API URLrzAPI key (optional))rrrrrr z LLM providerrrr)rrr$rrr z/Endpoint URL (e.g. http://192.168.1.10:8080/v1)rr)rr rz,LLM API key (optional for openai_compatible)rr z LLM modelr)fieldmap)rrr$ default_fromrrzAMemory bank name (static fallback when bank_id_template is unset)r)rrr$bank_id_templatezOptional template to derive bank_id dynamically. Placeholders: {profile}, {workspace}, {platform}, {user}, {session}. Example: hermes-{profile} bank_missionz/Mission/purpose description for the memory bank)rrbank_retain_missionz-Custom extraction prompt for memory retentionrzRecall thoroughnessr)rrr memory_modezMemory integration moderH)rHrtoolsrecall_prefetch_methodzAuto-recall methodrIreflectrz;Default tags applied to retained memories (comma-separated)ru(How observations are scoped during consolidation: 'combined' (default — one pass over all tags), 'per_tag' (one isolated observation per tag), 'all_combinations' (every tag subset — expensive), or a JSON list of tag-lists for explicit custom scopes. Empty uses Hindsight's 'combined' default.rz3Metadata source value attached to retained memoriesrz4Label used before user turns in retained transcriptsrrz9Label used before assistant turns in retained transcriptsr recall_tagsz8Tags to filter when searching memories (comma-separated)recall_tags_matchzTag matching mode for recallrJ)rJr any_strict all_strict recall_typesuFact types to surface on recall — applies to both auto-recall and the hindsight_recall tool (comma-separated or list). Defaults to observation-only — observations are Hindsight's consolidated, deduplicated, evidence-grounded knowledge layer; raw world/experience facts are the supporting evidence observations already summarize. Set to e.g. 'observation,world,experience' to also include raw facts.rM auto_recallz.Automatically recall memories before each turn auto_retainz'Automatically retain conversation turnsretain_every_n_turnsz%Retain every N turns (1 = every turn)r retain_asyncz5Process retain asynchronously on the Hindsight serverretain_contextz#Context label for retained memoriesrKrecall_max_tokensz!Maximum tokens for recall resultsrLrecall_max_input_charsz*Maximum input query length for auto-recallrNrecall_prompt_preamblez0Custom preamble for recalled memories in contextrSzAPI request timeout in secondsrzBEmbedded daemon idle timeout in seconds (0 disables auto-shutdown)r)zSeconds to wait for a slow daemon /health before treating it as stale (raise on busy/low-resource hosts; blank uses the 30s default))rQrrrrrs r%get_config_schemaz)HindsightMemoryProvider.get_config_schemas)' +<^K L' .GTdouw~n A' .GSWdwAdouw~n @ ' .AN`kqtDkE F ' .Bd_r~DFV}W X' #>hdQ\bdt[u v' #3dqsGWi|~} ~' "2`lp~U`fhx_y z'  qIahbmsuElF G' .qG H' '8IVX Y' #3d e' *:i j!' "$4IV[h~ #' $"2KX`nL M%' &-=Q^ft|HtI J'' ("2o|~ )' *):dqs t+' ,$4ivx y-' .)9o}C D/' 0.>yGR S1' 2"2ly{ |3' 4(8Vchv` a5' 6#4HUb c7' 8"2bos t9' :"2[hl m;' <+;bop q=' >#2ivz {?' @%5ZhX YA' B(8[hl mC' D-=ivy zE' F-=o pG' H.N[k lI' J#3wEZekm}d~ K' L0AGTVagiy`z {M' ' rc |j|jdk(rt\}}|std|r d|zdz ddlm}|dd dd l m }d |_ |jjd d}|dvrd}tjd|jjdd|t!|jjdd||jjdxs=|jjdxs t"j$jdd|jjdd}|j&r|j&|d<t)|jjd|jjdn)t"j$jd|j*t,}||_||d<|d i||_|jSt/ddlm} |j4xst6} |j8t;| d}|j<r|j<|d<tjd|j8t?|j<|d| d i||_|jS#t $rY^t$r}t t|d}~wwxYw)!z:Return the cached Hindsight client (created once, reused).Nrz&Hindsight local runtime is unavailablerrrr>r@FrA)HindsightEmbeddedcyrzr~rs r%z5HindsightMemoryProvider._get_client..srr >rrrz;Creating HindsightEmbedded client (profile=%s, provider=%s)rrrrrr )rr rr r rr) Hindsight)base_urlrSrhz@Creating Hindsight cloud client (url=%s, has_key=%s, timeout=%s)rSr~) rgrUr<rrCr?rDr9r:r6r__del__rOr*r!rdrfr,r-rVr&rirrFhindsight_clientrrhrrRr+rPr) rDrreasonrE_err kwargsrrrSs r% _get_clientz#HindsightMemoryProvider._get_clients << zz--$8$:! 6 &@,2Rx=<8:</F !3EB 8,=!)#||//C #FF#+L Z!\\--iBLR LL,,YA!- $ 0 0 =!PAQAQR_A`!PdfdndndrdrtKMOeP"ll..{B?  %%-1-?-?F>*1||''7CLL$$^4(@$BTBTU)   &2")5~&0:6: ||016--;+;&*mmgO==(, F9% _!]]D,? ART(262 ||M# /%c"g../s J++ K7K?KKc0t||jS)z@Schedule *coro* on the shared loop using the configured timeout.rR)rrh)rDrs r%rz!HindsightMemoryProvider._run_sync)st}}55rc|jdk7ryt|jd|jt fddDS)z:Return True for stale embedded-daemon connection failures.rFrc3&K|]}|v ywrzr~)rmarkerrs r%rzRHindsightMemoryProvider._is_retriable_embedded_connection_error..2s  dN s)zcannot connect to hostzconnection refusedzconnect call failedclientconnectorerror)rUr__name__lowerrJ)rDr;rs @r%'_is_retriable_embedded_connection_errorz?HindsightMemoryProvider._is_retriable_embedded_connection_error-sS ::) )s)$$%Ru-335    rc|j}||jry|jjt j |j dd}||_||_|jy)zLazy-start the single retain-writer thread. We don't start the writer in initialize() so providers that never retain (e.g. tools-only mode) don't pay for an idle thread. NTzhindsight-writerr) rqis_aliversclearrr _writer_looprur)rDthreads r%_ensure_writerz&HindsightMemoryProvider._ensure_writer<sq $$  &//"3  !!#!!$$#  %# rc |jjd} |t ur |jjy ||jje#tj$r|jj rYyYwxYw#t$r"}tjd|dYd}~vd}~wwxYw#|jjwxYw)zDrain the retain queue serially. Exits on sentinel. Each job() is wrapped so a single failure can't kill the writer. task_done() always fires so queue.join() works in tests. Tg?rRNzHindsight retain failed: %sexc_info) rpr*rnEmptyrsis_set_WRITER_SENTINEL task_doner9r!r")rDjobr;s r%r.z$HindsightMemoryProvider._writer_loopSs  ((,,S,9  /** "",,. VE"",,.;; &&--/ !VNN#@#PTNUUV"",,.s@A'C B'-BB C%C=C CC C&cj|jryd|_tj|jy)a?Register an idempotent atexit hook to drain the writer. Without this, a CLI exit that doesn't go through MemoryManager. shutdown_all() would leave in-flight retain jobs racing interpreter teardown, producing "cannot schedule new futures" warnings and unclosed aiohttp sessions. NT)rtatexitregister_atexit_shutdownrs r%_register_atexitz(HindsightMemoryProvider._register_atexitjs*  " " "&--.rc|jjry |jy#t$r }tj d|Yd}~yd}~wwxYw)Nz$Hindsight atexit shutdown failed: %s)rsr5shutdownr9r!rd)rDr;s r%r<z(HindsightMemoryProvider._atexit_shutdownwsJ    % % '  F MMO F LL? E E Fs. AAAc8|j} |j||S#t$rg}|j|stj d|d|_|j}||_|j||cYd}~Sd}~wwxYw)zKRun an async Hindsight client operation, retrying once after idle shutdown.zVHindsight embedded daemon appears unreachable; recreating client and retrying once: %sN)r"rr9r*r!r rg)rD operationclientr;s r%_run_hindsight_operationz0HindsightMemoryProvider._run_hindsight_operations!!# 5>>)F"34 4 5??D KKh  DL%%'F!DL>>)F"34 4 5s) BABBBc|jdk(r0|j$t|jdd}|r t|S|jxsdS)zReturn the URL to probe /version on. For local_embedded the daemon is on a per-profile dynamic port, so we prefer the running client's URL when available; otherwise fall back to the configured api_url. rNrjr)rUrggetattrr:rR)rDrjs r% _probe_urlz"HindsightMemoryProvider._probe_urlsG ::) )dll.F$,,t4C3x}}""rc|js|dfSt|j|jr|jdfS|dfS)uPick (document_id, update_mode) based on live API capability. On Hindsight ≥ 0.5.0 the API supports ``update_mode='append'``, which lets us reuse a stable session-scoped ``document_id`` across process lifecycles without overwriting prior turns. On older APIs we fall back to *fallback_document_id* (the per-process unique ``f"{session_id}-{start_ts}"`` minted at initialize / switch time) and don't pass ``update_mode`` at all — that's the only way the resume-overwrite fix (#6654) keeps working on legacy servers. Probe is cached at module level per API URL, so this is one HTTP round-trip per (process, api_url) pair regardless of how many retains fire. Nr)rvrurFrP)rDfallback_document_ids r%_resolve_retain_targetz.HindsightMemoryProvider._resolve_retain_targetsI'- - 1$//2CT]] S##X- -#T))rc t|xsdj_t|jddxsdj_t j jd}jd|_ ddl m }ddl m }|d}|||tkrtjd |tddl}ddl}ddl} |j'd } | rU |j)| d d d | j*dddtgddd|j,tj/dtntjdtt3_t|jdxsdj_t|jdxsdj_t|jdxsdj_t|jdxsdj_t|jdxsdj_t|jdxsdj_ t|jdxsdj_!t|jdxsdj_"t|jdxsdj_#d_$g_%d_&j4jd d!_'tQj4jd"j4jd"ntRjTjd#tV_,tQj4jd$j4jd$ntRjTjd%tZ_.jNd&k(rd'_'jNd'k(rBt_j4ta\} } | stjd(| d)_'yj4jd*xs=j4jd+xs tRjTjd,d_1jNd-vrtdntf}j4jd.xs tRjTjd/|_4j4jd0d_5tmj4d1d2i3}j4jd4xs|jd5d2}j4jd6dxsd_7tqjn|jDjFj6j8j7_9j4jd8xs/j4jd9xs|jd9d:}|ttvr|nd:_;j4jd;d<}|d=vr|nd<_<j4jd>xsj4jd?d@}|dAvr|nd@_=j4jdBd_>j4jdCxsd_?tj4jdDxs tRjTjdEd_Ajxsd_Btj4jdFxs tRjTjdGd_Dj4jdHxsd_Ej4jdIdJ_Ftj4jdKxs tRjTjdLdj_Gtj4jdMxs tRjTjdNdOjxsdO_Htj4jdPxs tRjTjdQdRjxsdR_Ij4jdSd_JtdTtj4jdUdT_Mj4jdVdW_Nj4jdXd_Otj4jdYdZ_Pj4jd[}| d\g_Qnit|trD|jd]Dcgc]#}|js|j%c}_Qnt|xsd\g_Qj4jd^d_Utj4jd_d`_Vj4jdad_Wdb} ddl m }|d}tj/dcjNjhjrjvjxjz|jnrWtjddjnjDjFj6j8jrtjdejjjjjjjjj jNd'k(rttRdfrRtSjdk(r;dg}tj| tdh| jdid)_'yfdj}tj|ddkl}|jyy#t0$r&} tjd| tYd} ~ d} ~ wwxYw#t0$rY wxYwcc}w#t0$rY&wxYw#t0$r Yd)_'ywxYw)mNrparent_session_id%Y%m%d_%H%M%S_%fr,r)rWrIzhindsight-clientzBhindsight-client %s is outdated (need >=%s), attempting upgrade...rrrrrrrTr rz!hindsight-client upgraded to >=%szCAuto-upgrade failed: %s. Run: uv pip install 'hindsight-client>=%s'z5uv not found. Run: pip install 'hindsight-client>=%s'platformuser_id user_namechat_id chat_name chat_type thread_idagent_identityagent_workspacerrrSrrrrrzKHindsight local mode disabled because its runtime could not be imported: %sdisabledrrhr>rrrgrr rr)r$rrr)r:r workspacerMusersessionrrrrrH>rrHrrprefetch_methodrI>rIrrrrrrrr r rJrrrrrrrrrrrrrKrrrLr rMrrrrNrunknownzmHindsight initialized: mode=%s, api_url=%s, bank=%s, budget=%s, memory_mode=%s, prefetch_method=%s, client=%sz`Hindsight bank resolved from template %r: profile=%s workspace=%s platform=%s user=%s -> bank=%szHindsight config: auto_retain=%s, auto_recall=%s, retain_every_n=%d, retain_async=%s, retain_context=%s, recall_max_tokens=%d, recall_max_input_chars=%d, tags=%s, recall_tags=%sgeteuidzHindsight local_embedded mode cannot run as root (PostgreSQL initdb refuses root). Skipping the embedded memory daemon. Run Hermes as a non-root user, or switch to cloud / local_external mode via 'hermes memory setup'.u ⚠ )filercddl}tdz }|jdd|dz } ddlm}ddlm}|t|dd d |_ j} jjd d }t j}t j}t|} | |k7} | rst j}|j j#|rCt|dd 5} | j%dddd|j j'||j)t|dd 5} | j%ddddy#1swY]xYw#1swYyxYw#t*$rZ} t|dd 5} | j%d| d|j-| dddn#1swYnxYwYd} ~ yYd} ~ yd} ~ wwxYw)NrlogsTrzhindsight-embed.log)ConsolearTrF)r]force_terminalrrz+ === Config changed, restarting daemon === z% === Daemon started successfully === z === Daemon startup failed: z === )r]) tracebackr r&$hindsight_embed.daemon_embed_managerdaemon_embed_manager rich.consoler`openconsoler"rOr*rrrr*_managerrrstop_ensure_startedr9 print_exc)rclog_dirlog_pathdemr`rBrr) expected_envsavedconfig_changedfrrDs r% _start_daemonz9HindsightMemoryProvider.initialize.._start_daemonzs )+f4 dT :"%:: 4G4")tHcG/Tej"kCK!--/F"ll..y(CG #=T\\"JK#>t||#LL,[9E%*l%:N%&G &U !??55g>!%hg!FY! !(W XY"OO009**,hg>K! IJKK YY KK 4hg>4!"?s& IJ!+++3444444sgC E?9E' AE? E3E?'E0,E?3E<8E?<E?? G"G(G> GG GG"zhindsight-daemon-startr)`r:rrvr*rwrrstrftimerximportlib.metadatarWrKrJrr!r"rrrrrrrr r9rrOr]r^r_r`rarbrcrdrerfrrrUr&r,r-rrhrrir4r<rPrrQrRrVr rr@rS_VALID_BUDGETSrTrWrXrrrrYryr_observation_scopesrzr{rZr[r\r|maxrr}rrrrrerrrrr~rdhasattrr\rstderrrrr)rD session_idr!start_ts pkg_versionrJ installedrrrrrrr default_urlrstatic_bank_idrrrZconfigured_typest_client_versionmsgrts` r% initializez"HindsightMemoryProvider.initializes z/R0668"%fjj1Db&I&OR"P"V"V"X<<>**+=>#//0(<  A 1#$67Iy!G,?$@@c(*=?! ,,t, ?"$eY CNN& 7IJ]I^5_a"&D","4"4 '  $GI\] NN#Z\op$~ VZZ 39r:@@BFJJy17R8>>@ fjj5;<BBDFJJy17R8>>@ fjj5;<BBDfjj5;<BBDfjj5;<BBD"6::.>#?#E2FLLN #FJJ/@$A$GR H N N P )*&\\%%fg6 *+/<<+;+;I+F+RDLL  Y 'XZXbXbXfXfgzX{   004 0@0@0P0\DLL  ^ ,bdblblbpbprJcK !  :: )DJ ::) ) .dll ; 4 6 Iva(  ((2|dll6F6Fy6Q|UWU_U_UcUcdwy{U| ,0JJ:^,^(dt  ((3grzz~~FY[f7g !\\--nbA gxD)))4U (H8U!%!1!12Db!I!OR1  " "#((++^^$$  !!/2ndll6F6Fx6PnTYT]T]^fhmTn!'>!9vu ll&&}h? +6:X+XK^f,,**+CDu HXHXYjltHu3BF[3[ai"\\--nbA$(LL$4$45J$K$St!3 LL  ] + ;zz~~5r: &&.$ #@ LL  1 2 Izz~~CRH$  !LL,,];Ct"&,,"2"23F"N! LL  _ - ^@Y[]1^ %' $' LL  1 2 lbjjnnEcek6l$ %'$  ), LL  6 7 {2::>>Jmoz;{) %')!  % !LL,,]DA%(C 0@0@AWYZ0[,\%]"#||//0@Brs!LL,,]DA"%dll&6&67JD&Q"R <<++N;  #"/D  (# .5E5K5KC5P!^TUT[T[T]!'')!^D !%&6!7!JM?D '+||'7'78PRT'U$'*4<<+;+;' t0t ttt t&%t&. t;:t;> uuc|jdk(rd|jd|jdS|jdk(rd|jd|jdSd|jd|jd S) Nrz0# Hindsight Memory Active (context mode). Bank: z , budget: z<. Relevant memories are automatically injected into context.rz.# Hindsight Memory Active (tools mode). Bank: zc. Use hindsight_recall to search, hindsight_reflect for synthesis, hindsight_retain to store facts.z!# Hindsight Memory Active. Bank: z. Relevant memories are automatically injected into context. Use hindsight_recall to search, hindsight_reflect for synthesis, hindsight_retain to store facts.)rWrSrTrs r%system_prompt_blockz+HindsightMemoryProvider.system_prompt_blocks    )004 jWMN     '..2mm_Jt||nU34 !]]O:dll^D/ 0 rr)r|c|jrK|jjr1tjd|jj d|j 5|j }d|_dddstjdytjdt||jxsd}|d|S#1swYWxYw) Nz3Prefetch: waiting for background thread to complete@rRrzPrefetch: no results availablez'Prefetch: returning %d chars of contextz# Hindsight Memory (persistent cross-session context) Use this to answer questions about the user and prior sessions. Do not call tools to look up information that is already present here.z ) rmr,r!rdr(rlrjrr)rDrr|rheaders r%prefetchz HindsightMemoryProvider.prefetchs  T%:%:%C%C%E LLN O  ! ! & &s & 3   '**F$&D ! ' LL9 : >F L--  U  fX&& ' 's $CCcjdk(rtjdyjstjdyjj rtjdyj r'tj kDrdj fd}tj|dd_ jjy) Nrz#Prefetch: skipped (tools-only mode)z(Prefetch: skipped (auto_recall disabled)z!Prefetch: skipped (shutting down)c jdk(rQtjdjt j fd}|j xsd}njjjdjrjd<jd<jrjd<tjd jt jj fd }|jrt |jnd }tjd ||jr"d jd|jDnd}|rj5|_dddyy#1swYyxYw#t $r"}tjd|dYd}~yd}~wwxYw)Nrz1Prefetch: calling reflect (bank=%s, query_len=%d)cT|jjjSN)rrrareflectrSrTrBrrDs r%rzFHindsightMemoryProvider.queue_prefetch.._run..s5`d`m`muzDHDPDPIQrrrrr max_tokensr tags_matchtypesz;Prefetch: calling recall (bank=%s, query_len=%d, budget=%s)c(|jdiSNr~arecallrB recall_kwargss r%rzFHindsightMemoryProvider.queue_prefetch.._run..sHgYfHgrrz$Prefetch: recall returned %d resultsr#c3TK|] }|jsd|j"yw)z- N)r)rrs r%rzGHindsightMemoryProvider.queue_prefetch.._run..s $SqAFFr!&&]$Ss((zHindsight prefetch failed: %sTr2)rXr!rdrSrrCrrTrrzr{rresultsr(rlrjr9)rlr num_resultsrrrrDs @r%rz4HindsightMemoryProvider.queue_prefetch.._runs P((I5LL!TVZVcVcehineop88:QRD99?D$(==5"&,,d>U>U+M((040A0A f-6:6M6M l3))151C1C g.LL!^!%E DLLJ889ghD7;||#dll"3KLL!GUW[WcWc499$SDLL$SSikD,,504-5555 P  ?   LLC D     % % ' LL< =   ' 'CJ9U9U,U74778E P8!* 0 0TPd e ##%rctjtjj }d|j d||dd|j d||dgS)NrXr)roler timestamp assistant)rrrrrr[r\)rD user_contentassistant_contentrs r%_build_turn_messagesz,HindsightMemoryProvider._build_turn_messagessmll8<<(224"667r,H   $";;QR    rcbtt|t|d}|jr|j|d<|jr|j|d<|jr|j|d<|j r|j |d<|j r|j |d<|jr|j|d<|jr|j|d<|jr|j|d <|jr|j|d <|jr|j|d <|S) N) retained_at message_count turn_indexsourcer|rMrNrOrPrQrRrSrT) rr:rZrvr]r^r_r`rarbrcrd)rDrrmetadatas r%_build_metadataz'HindsightMemoryProvider._build_metadatas)+ /j/$    !%!4!4HX    %)%5%5H\ " >>#'>>HZ =="&--HY  ??$(OOH[ ! =="&--HY  ??$(OOH[ ! ??$(OOH[ ! ??$(OOH[ !   )-)=)=H% &rN)r document_idrrrcH|j||xs|jd|jd}|||d<|r||d<|||d<t|j}t|D]} | |vs|j | |r||d<|j r|j |d<|S) Nrrr)rrrrrrrr)rSrrfrrYrrx) rDrrrrrrr! merged_tagsrs r%_build_retain_kwargsz,HindsightMemoryProvider._build_retain_kwargs$s}} fD$8$8qUYUeUe$8$f"    'F9  $/F= !  #%1F> ",T->->? )$/ (C+%""3' ( (F6N  # #+/+C+CF' ( rc b jstjdyjj rtjdy|rt |j _tjj||d}jj|xjdz c_ j_jjzdk7rStjdjjjjjzz zyj!j"\ d k(r1jj$d}|s+tjd yt'j}tjd t)|t)jt+d |Dd dj-|zdzg jr jdjj.r jdj.j1t)|dzj t)| j2j4 j6d f d }j9j;j<j?|d k(rt)j_yy)ueEnqueue a retain for the current turn. Non-blocking. The actual aretain_batch runs on a single long-lived writer thread that drains an in-memory queue. Once shutdown() has been called, further sync_turn() calls are dropped — this prevents post-exit retains from reaching aiohttp after interpreter shutdown begins. z)sync_turn: skipped (auto_retain disabled)Nz"sync_turn: skipped (shutting down)F) ensure_asciirrz4sync_turn: buffered turn %d (will retain at turn %d)rz@sync_turn: skipped append retain; no new turns since last retainz2sync_turn: retaining %d/%d turns, payload %d charsc32K|]}t|ywrz)r)rrs r%rz4HindsightMemoryProvider.sync_turn..os9AQ9r$rrrsession:parent:rc 0 jxsdjddjdd  d<tjd t  j fdtjdy)Nrrrrr update_modezRHindsight retain: bank=%s, doc=%s, mode=%s, async=%s, content_len=%d, num_turns=%dc0|jgSN)rrrr) aretain_batch)rBrrrretain_async_flags r%rzGHindsightMemoryProvider.sync_turn.._do_retain..s%v33#& +!2 4 rzHindsight retain succeeded)rpopr!rdrrC) rrrr lineage_tagsmetadata_snapshot num_turnsrrrDrs @r% _do_retainz5HindsightMemoryProvider.sync_turn.._do_retains,,&*!)T -D HHY % HH^T *&&1]# LLm +{  ":446D zz$33LBSTchi ""4( a--    : : :a ? LLO++T-?-?4C]C]`d`r`ruyvPvPaPDP.Q R #'#>#>t?P?P#Q [ ( ""11$2P2P2QRO" _`"4#6#67O I)3t/B/B+C999 ;11C7"$      (4+;+;*< = >  " "   '$*A*A)B C D!00o.2''1 ( -- ..-- 7 7.   z* ( "-01D1D-ED * #rcF|jdk(rgStttgS)Nr)rW RETAIN_SCHEMA RECALL_SCHEMAREFLECT_SCHEMArs r%get_tool_schemasz(HindsightMemoryProvider.get_tool_schemass"    )I}n==rc  |dk(r|jdd}|s tdS|jd} j|||jd jdd jd dtj d j t||j fd tj d tjd diS|dk(r|jdd s tdS j jjdjrjd<j d<j"rj"d<tj dj t jjfd}|j$rt|j$nd}tj d||j$stjd diSt'|j$dD cgc]\} } | d| j(} } } tjd d j+| iS|d#k(r|jdd s tdS tj d$j t jj fd%}tj d&t|j(xsdtjd |j(xsdiStd)|S#t$r0}tjd|dtd|cYd}~Sd}~wwxYwcc} } w#t$r0}tjd!|dtd"|cYd}~Sd}~wwxYw#t$r0}tjd'|dtd(|cYd}~Sd}~wwxYw)*Nrrrz#Missing required parameter: contentrr)rrrrz:Tool hindsight_retain: bank=%s, content_len=%d, context=%sc@|jjgS)N)rr)rrS)rBrrDs r%rz:HindsightMemoryProvider.handle_tool_call..s6#7#7 VZU[#7#\rzTool hindsight_retain: successrzMemory stored successfully.zhindsight_retain failed: %sTr2zFailed to store memory: rrz!Missing required parameter: queryrrrz7Tool hindsight_recall: bank=%s, query_len=%d, budget=%sc(|jdiSrrrs r%rz:HindsightMemoryProvider.handle_tool_call..sNFNNDcUbDcrrz!Tool hindsight_recall: %d resultszNo relevant memories found.rz. r#zhindsight_recall failed: %szFailed to search memory: rz8Tool hindsight_reflect: bank=%s, query_len=%d, budget=%scT|jjjSrrrs r%rz:HindsightMemoryProvider.handle_tool_call..s$6?? $ U4<<$3$rz'Tool hindsight_reflect: response_len=%dzhindsight_reflect failed: %szFailed to reflect: zUnknown tool: )r*r rrr!rdrSrrCrbrr9r"rTrrzr{rr enumeraterr()rD tool_nameargsr!rrrrlrirlinesrrrs` @@@r%handle_tool_callz(HindsightMemoryProvider.handle_tool_calls * *hhy"-G!"GHHhhy)G B00#&)1 D). Y!]]CL'C--\ =>zz8-J"KLL , ,HHWb)E!"EFF C#}}u "&"9"9' $$,0,=,=M&)262I2IM,/%%-1-?-?M'* V!]]CJ F445cd37< 1`` would otherwise silently lose whatever's in ``_session_turns`` at the moment of switch — the same data-loss class as the shutdown race, just at a different lifecycle event. Also wait for any in-flight prefetch from the old session and drop its cached result; otherwise the new session's first ``prefetch()`` could read stale recall text from before the switch. ``parent_session_id`` is recorded for lineage tags on future retains. ``reset`` is accepted but not needed for Hindsight's state model — buffer clearing is correct for every session switch, not only /reset. rNrrrrrrrc  jjxsdjddjddd<tj dj t jfdy#t$r"}tjd|d Yd}~yd}~wwxYw) NrrrrzAHindsight flush-on-switch: bank=%s, doc=%s, mode=%s, num_turns=%dcX|jjgjSr)rrSr~)rBrold_document_idrDs r%rzKHindsightMemoryProvider.on_session_switch.._flush..Fs/v';';$(MM#'&(7)-);); (<(rz$Hindsight flush-on-switch failed: %sTr2) rrrr!rdrSrrCr9r") rr old_contentrold_lineage_tags old_metadata old_turnsold_update_moderDs @r%_flushz9HindsightMemoryProvider.on_session_switch.._flush5s]44# $ 4 4!--5 5D HHY-HH^T2&2.=]+LL[ Y11!]NN#I1W[N\\]sBB CB;;CrrRrLr,rzEHindsight on_session_switch: new_session=%s parent=%s reset=%s doc=%s)r:rrrrvrwrfrrrr(rIrxrsr5r0r=rprrmr,rlrjrrrurrr!rd)rDnew_session_idrKrr!new_idold_session_idold_parent_session_idold_turn_indexrr}rrrrrrs` @@@@@@r%on_session_switchz)HindsightMemoryProvider.on_session_switchs=N^)r*002    T001I!--N$($;$; !!--N//!)nq0)0L+-  ''(>2B(CD$ '''2G1H(IJ 33c9K 04/J/J!!0 ,O_ ] ]B&&--/##%%%'""&&v.  T%:%:%C%C%E  ! ! & &s & 3   '$&D ! ' &)*;&<&B&B&DD #!<<>**+=>#//0(< )*& S   d55ud>O>O  ' 's I""I+ctjd|jj|j}||j rp |j jt|jd|j r.tjd|j j|jr6|jj r|jjd|j |jdk(rlt!|jdd}|7t#|dr+t%|j' d|j_ |jj)n)|j%|jj'd|_yy#t$rYXwxYw#t$rYiwxYw#t*$rY3wxYw#t$rYBwxYw) NzDHindsight shutdown: stopping writer + waiting for background threadsg$@rRzIHindsight writer did not stop within 10s; abandoning %d pending retain(s)@rrgaclose)r!rdrsrrqr,rprr6r9r(r"qsizermrgrUrErzrrcloser)rDwriter inner_clients r%r?z HindsightMemoryProvider.shutdownqs [\ !$$  &//"3 ""&&'78 KKK % 6&&,,.  T%:%:%C%C%E  ! ! & &s & 3 << # ::!11$+4<<D#IL#/GL(4S!,"5"5"78!37DLL0 **,NN4<<#6#6#89 DL1 $  2 )! !(  sgF: A G(G -G*G(: GG GG(GG( G%"G($G%%G(( G43G4)r List[str]rr:)rr)rr:r1rfrr)r;r9rrr)rHr:rztuple[str, str | None])r|r:rr)rr:r|r:rr:)rr:r|r:rr)rr:rr:rzList[Dict[str, str]])rrrrrzDict[str, str])rr:r str | NonerrrzDict[str, str] | NonerzList[str] | Nonerz bool | NonerzDict[str, Any])rr:rr:r|r:rr)rzList[Dict[str, Any]])rr:rrfrr:)rr:rKr:rrrr)"r( __module__ __qualname____doc__rFrpropertyrrrrrr"rr*r0r.r=r<rCrFrIrrrrrrrrrrrr?r~rr%rBrBmsPWP$d&="T8l( T3j6  ./. /F5" #**pd ,9;'$?A+&Z  @#"&*.!%$(    ( " >Y[]F~> G8Z"$         B/ rrBc6|jty)z/Register Hindsight as a memory provider plugin.N)register_memory_providerrB)ctxs r%r;r;s  !8!:;r)r#rr$rrr)r1dict[str, Any]rr)rztuple[bool, str | None]r)rLrrMr:rr)Nr)rgr:rhrrSr+rrrz)rgr:rhrrr)rzasyncio.AbstractEventLoop)rSr+)rrf)r#rrr)r#rrrr)r1rrr:)rdict[str, str])r1rrrrr)r1r)r1rrr)r#r:rr:)r9r:r:r:r;r:rr:)Ir __future__rr{r:r7rbloggingr,rnrrrrtypingrrragent.memory_providerr hermes_constantsr tools.registryr rr getLoggerr(r!rQrrrrrrrwrr&r/r4r<rFrG__annotations__rkrqrNrorurvrwrrr6rrrrrrrrrrrrrrr*r3r@rBr;r~rr%r su<#   '""0,%%   8 $7, '.#'# !#* $EA6  -$-//.()..*FJ25-*/-:D-<BF#4>#JN#V+/'.(, %, Y^^  8"&6*(  S (9TU (9tu (+e K   ,  T h7LM I    R h7TU I  (+\"JJ,^` $ VZ#L] \` $, Js ns B*