ip< UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddl mZmZmZddlmZddlmZddlmZdd lmZejeZd Zd Zd Zd ZdZ dZ!hdZ"dddddddddd Z#dgd Z$dhd"Z%iZ&d#e'd$<e j(Z)did*Z* djdkd0Z+ dldmd1Z,da-d2e'd3<da.d4e'd5<e j(Z/e0Z1dnd7Z2efdod8Z3d9d:d;ddd@dAdidJgdFdGZ5dLdMd;dJdidJgdFdGZ6dpdPZ7dqdRZ8drdSZ9dsdVZ:dtdXZ;ddYdud[Zdxd^Z?dydbZ@GdcddeZAdzdfZBdS){uHindsight 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_RETAIN_TAGS — comma-separated tags attached to retained memories 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:88880.4.22xi,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_compatiblevaluerdefaultintreturnc||dkr|S t|S#ttf$r!td|||cYSwxYw)zAParse an integer config/env value, falling back on invalid input.Nz6Invalid integer Hindsight setting %r; using default %s)r TypeError ValueErrorloggerwarning)rrs F/home/piyush/.hermes/hermes-agent/plugins/memory/hindsight/__init__.py_parse_int_settingr(Ksg } 5zz z "OQVX_```s/A  A tuple[bool, str | None]c tjdtjddS#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_runtimer1Vsm ,,, FGGGz c#hhs(, AA A AzDict[str, bool]_append_capability_cacheactual str | Nonerequiredr/boolcj|sdS ddlm}||||kS#t$rYdSwxYw)uJReturn True if *actual* ≥ *required* (semver). False on missing/invalid.FrVersion)packaging.versionr9r.)r3r5r9s r'_meets_minimum_versionr;qse u------wv''("3"333 uus $ 22@api_urlapi_keytimeoutfloatcddl}ddl}|sdS|ddz}|j|}|r|dd| |j||5}|dd }dddn #1swxYwYtj |}n4#t$r'} t d || Yd} ~ dSd} ~ wwxYwt|tsdS|d p|d } | rt#| ndS)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 r?utf-8replace)errorsz*Hindsight /version probe failed for %s: %sversion api_version) urllib.errorurllib.requestrstriprequestRequest add_headerurlopenreaddecodejsonloadsr.r%debug isinstancedictgetr/) r=r>r?urlliburlreqresppayloaddatar0rHs r'_fetch_hindsight_api_versionr_|s t ..   *C .  % %C= (;'(;(;<<< ^ # #C # 9 9 DTiikk(((CCG D D D D D D D D D D D D D D Dz'""  A3LLLttttt dD ! !thhy!!C99C>c|sdSt5|tvrt|cdddS dddn #1swxYwYt||}t|t}t5t|}| |t|<n|}dddn #1swxYwY|s)t d||ttnt d|||S)u Cached capability check for ``update_mode='append'`` on *api_url*. Probes once per URL per process. Returns False on any probe failure — that's the safe default: a per-process unique ``document_id`` and no ``update_mode`` keeps the resume-overwrite fix (#6654) intact. FNuHindsight API at %s reports version %r, older than %s. Falling back to per-process document_id — retains across processes/sessions create separate documents instead of appending to a session-scoped one. Upgrade Hindsight to %s+ to enable update_mode='append' deduplication.z9Hindsight API %s version %s supports update_mode='append') _append_capability_lockr2r_r;#_MIN_VERSION_FOR_UPDATE_MODE_APPENDrXr%r&rU)r=r>rH supportedcacheds r'&_check_api_supports_update_mode_appendres u 55 . . .+G455555555 .555555555555555+7G<09 $W - -I   ' @ WA /      Pg ' ' ' s!<AA3*B))B-0B-z asyncio.AbstractEventLoop | None_loopzthreading.Thread | None _loop_threadasyncio.AbstractEventLoopcDt5t,trtcdddStjad}t j|ddattcdddS#1swxYwYdS)z>Return a long-lived event loop running on a background thread.NcjtjttdSN)asyncioset_event_looprf run_foreverr'_runz_get_loop.._runs+  "5 ) ) )        rpTzhindsight-looptargetdaemonname) _loop_lockrf is_runningrlnew_event_loop threadingThreadrgstart)rqs r' _get_loopr|s     !1!1!3!3         &((   !'tDGWXXX                   s'BA BBBctt}tj||}||S)z8Schedule *coro* on the shared loop and block until done.rD)r|rlrun_coroutine_threadsaferesult)coror?loopfutures r' _run_syncrs1 ;;D  -dD 9 9F === ) ))rphindsight_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 propertiesr5)rur 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.rWcbddlm}tdz dz }|r9 t j|dS#t$rYnwxYw|dz dz }|r9 t j|dS#t$rYnwxYwtj dd tj d d ttj d tttj d ttj dd tj dd tj ddtj dddtj ddtj ddddid S)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 rPathr+ config.jsonrEencoding .hindsightHINDSIGHT_MODEcloudHINDSIGHT_API_KEYr"HINDSIGHT_TIMEOUTHINDSIGHT_IDLE_TIMEOUTHINDSIGHT_RETAIN_TAGSHINDSIGHT_RETAIN_SOURCEHINDSIGHT_RETAIN_USER_PREFIXUser!HINDSIGHT_RETAIN_ASSISTANT_PREFIX AssistanthermesHINDSIGHT_BANK_IDHINDSIGHT_BUDGETrT)bankIdbudgetenabled) modeapiKeyr? idle_timeout retain_tags retain_sourceretain_user_prefixretain_assistant_prefixbanks)pathlibrr existsrSrT read_textr.homeosenvironrXr(_DEFAULT_TIMEOUT_DEFAULT_IDLE_TIMEOUT)r profile_path legacy_paths r' _load_configr&s#$${2]BL :l44g4FFGG G    D ))++ ,}>:R+S+SUjkkz~~&=rBB(A2FF jnn-KVTT#%:>>2UWb#c#c *..)""" Z^^4 5 5 LB$6$6z4_materialize_embedded_profile_env..s7HHzsE3"""""HHHHHHrprEr)rparentmkdirr write_textjoinr)rr profile_envrs r'!_materialize_embedded_profile_envrs,V44KTD999,VMMMJ HHZ5E5E5G5GHHHHH rpc(|sdSg}d}t|D]S}|s |dks|dkr||d}:|s|dd}Td|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. r"F-_T-_)r/isalnumrrr)rout prev_dashchs r'_sanitize_bank_segmentrs r CI%jj!! ::<< !299c JJrNNNII ! 3 773<<  d # ##rptemplatefallback placeholdersc |s|Sd|D} |jd i|}n=#ttf$r)}td||||cYd}~Sd}~wwxYwd|vr|dd}d|vd|vr|dd}d|v|d}|p|S) 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. c4i|]\}}|t|Sro)r)r kvs r' z-_resolve_bank_id_template..s'OOO$!Q*1--OOOrpu5Invalid bank_id_template %r: %s — using fallback %rNz--r__rrro)rformatKeyError IndexErrorr%r&rFr)rrr sanitizedrenderedr0s r'_resolve_bank_id_templater)s OO,:L:L:N:NOOOI"8?//Y// j !Nh 0 0 0 (  ##D#.. (   (  ##D#.. (  ~~d##H  xs 2A,A'!A,'A,ceZdZdZdZedIdZdJdZdZdKd Z dZ dZ dZ dLdZ dMdZdMdZdMdZdMdZdZdIdZdNdZdOdZdIdZd d!dPd#Zd d!dQd$ZdRd(ZdSd-Zd.d.d.d.d.d/dTd;Zd d!dUd<ZdVd>ZdWdAZd dBdCdXdGZdMdHZ d.S)YHindsightMemoryProviderzMHindsight long-term memory with knowledge graph and multi-strategy retrieval.c~d|_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|_!tEj#|_$d|_%t=j&|_'d |_(d|_)d|_*d|_+d|_,d|_-d|_.d |_/d |_0d |_1d |_2d|_3d |_4g|_5d |_6d|_7d|_8d|_9d|_:d|_;d|_<d|_=dS)Nrrrr"hybridrecallrrrFanyTr.conversation between Hermes Agent and the User )>_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_resultryLock_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 _auto_recall_recall_max_tokens _recall_types_recall_prompt_preamble_recall_max_input_chars _bank_mission_bank_retain_mission_bank_id_templateselfs r'__init__z HindsightMemoryProvider.__init__s  (     $ (') #) (3%  ! " ( 2 "'n.. $ +0+--7;'o//"'!"$(, .2"'!%&"!O)+!"&/3')$'*$ 04!!#rpr r/cdS)Nr+rorns r'ruzHindsightMemoryProvider.nameLs{rpr6c t}|dd}|dvrt\}}|S|dkrdSt|dp4|dptjdd }t|d ptjd d }|p|S#t $rYd SwxYw) Nrr)locallocal_embeddedlocal_externalTrr>rr"r=HINDSIGHT_API_URLF)rrXr1r6rrr.)rocfgr availablerhas_keyhas_urls r' is_availablez$HindsightMemoryProvider.is_availablePs ..C7767++D222355 1  '''t!!;779%%;:>>"5r::G 3779--X@SUW1X1XYYG%g %   55 s:C"C"BC"" C0/C0cvddl}ddlm}||dz }|dd|dz }i}|r4 |j|}n#t$rYnwxYw||| |j |d dS) z3Write config to $HERMES_HOME/hindsight/config.json.rNrr+Trr)indent) rSrrr rrTrr.updaterdumps)ror hermes_homerSr config_dir config_pathexistings r' save_configz#HindsightMemoryProvider.save_configcs       T+&&4 555 =0        %4:k&;&;&=&=>>    ztz(1===>>>>>s "A// A<;A<rrrWNonec dddl}ddl}ddl}ddl}ddlm}ddlm}ddlm } tdt|j tr|j n t} t| tsi} gd} gd} | d } | | vr| | nd}| d | | }| |}t| }||d <i}d }d |}d}|dkr|g}n |dkr|g}n|g}td|d}|s=tdtd|jdd|n ||ddd|jddg|zdddtdnV#t*$rI}td|td |jdd|Yd}~nd}~wwxYw|d!krtd"t,jd#d$}|rt1|d%kr d&|d'dnd(}|jd)|d*|j|jr|d$+n*|j}n|jd,|j|jr|d$+n*|j}|r||d#<tAd-tBd.}|r||d/<n)|dkrtAd0tDd.}|ptD|d/<|jd1|j|jr|d$+n*|j}|r||d#<nWtGtH%}d2|D}|d3}||vr||nd} | d4|| }!||!}"|"|d3<|"d5krQ|d6d$}#d7}$|#r |$d8|#d9z }$|$d:z }$tA|$}|r||d6<n |"d;krd<|d6<tH|"d=}%|d>p|%}&tAd?|&d.}|p|&|d><|jd@|j|jr|d$+n*|j}'|'r|'|dA<n||dBz }(d$})|(&r\|('(D]5}*|*)dCr|**dDdEdE})n6|)|dA<|+dFdG|+dHdI|dJ}+|+|+ntX},|,|dJ<t[|,|dK<|dkr7|dL}-|-|-nt\}.|.|dL<t[|.|dM<dN|dOdP<||||||rx||dBz }(|(j/0ddQg}/|(&r&|('(}/tc}0g}1|/D]}*dD|*vrC|*)dRs.|**dDdEdnd}2|2r:|2|vr6|12|2dD||2|03|2|12|*|4D]#\}3}4|3|0vr|12|3dD|4$|(5dS|1dSz|dkrt|}5||dNz dTz }6 tmj7|6'dUV}5n#t*$rYnwxYw|dAd$}7|7s/tq||dBz dAd$}7|7s0tqts|5dWd$}7tu|5|7pdXtdY|dZ|rtd[td\dS)]uLCustom setup wizard — installs only the deps needed for the selected mode.rNr)r)_curses_selectz! Configuring Hindsight memory: rrtru))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 moderr hindsight-client>=z hindsight-allrtruz 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 --upgradeTrcheckr?capture_outputu ✓ Dependencies up to dateu ⚠ Install failed: z( Run manually: uv pip install --python rz9 Get your API key at https://ui.hindsight.vectorize.io rr"z...rz API key (current: z, blank to keep): )promptz API key: z API URL [z]: r=z Hindsight API URL [z% API key (optional, blank to skip): c2g|]}|dt|fS)zdefault model: )_PROVIDER_DEFAULT_MODELS)r ps r' z6HindsightMemoryProvider.post_setup..s<C&>q&ACCDrprz Select LLM providerrrz5 LLM endpoint URL (e.g. http://192.168.1.10:8080/v1)z []: rzhttps://openrouter.ai/api/v1rrz LLM model [z LLM API key: rrzHINDSIGHT_LLM_API_KEY=rrbank_idr recall_budgetrr?rrrr+memoryproviderrrr rrErrru$ ✓ Hindsight memory configured (z mode)z API keys saved to .envz$ Start a new session to activate. );getpass subprocessshutilsysrrhermes_cli.configrhermes_cli.memory_setuprprintrVr3rWrrXindexwhich executablerrunr.rrlenstdoutwriteflushstdinisattyreadlinerinputr5_DEFAULT_LOCAL_URLrrkeysrrrrr setdefaultrr/rr r rrrrrrSrTrrr)8rorrrrrrrrrexisting_config mode_values mode_items existing_modemode_default_idxmode_idxrprovider_config env_writes_MIN_CLIENT_VERSION cloud_dep local_depdeps_to_installuv_pathe existing_keymaskedr>valproviders_list llm_itemsexisting_llm_providerllm_default_idxllm_idxrexisting_base_urlrprovider_default_modelrllm_keyenv_pathexisting_llm_keyrexisting_timeout timeout_valexisting_idle_timeoutidle_timeout_valexisting_lines updated_keys new_lines key_matchr r!materialized_configrrs8 r' post_setupz"HindsightMemoryProvider.post_setupss         111111:::::: 3444*4T\4*H*H\$,,lnn/400 ! ODCC    (++F33 ?LP[?[?[;,,];;;ab!>/:GWXXX8$ $_ 5 5"& '>)<>> # # # #(kOO % % %(kOO(kO ,---,,t$$ o f g g g n#.nnSVS[S[\kSlSlnn o o o o oeY CNIWbcfuuD56666 o o o2q22333mmmRURZRZ[jRkRkmmnnnnnnnn o 7?? O P P P:>>*=rBBL m69,6G6G!6K6K2|BCC0222QV   !R!R!R!RSSS   """8; 8H8H8J8Jl'///444PSPYPbPbPdPdPjPjPlPl   ///   """8; 8H8H8J8Jl'///444PSPYPbPbPdPdPjPjPlPl :29 ./;&6;;;<<BBDDC 1-0 * % % %G0BGGGHHNNPPC),)B0BOI & J  D E E E J     47I4D4D4F4FhgooRo000CIL^L^L`L`LfLfLhLhG :29 ./"":"?"?"A"ABBN'I%4$7$7$G$G !MbftMtMtn223HIIIz{O$n%ON +367G3H3HJ/ 0'2x$ F +666  =tK((61H O ! !$ ! > > >N   C!)!3!3!5!5!@!@!B!B55LI& + +=@D[[QUQ`Q`adQeQe[DJJsA..q177999ko +j!8!8$$ %K%KJy4I%K%KLLL $$Y////$$T****"((** 1 11L(($$ZZAZZ000    ) 4 4t ; < < < # # #"&"7"7 ${++k9MIK &*j1F1FPW1F1X1X&Y&Y##    %..)@"EEK l.ttK/@/@6/IJJNNOfhjkk  ./IJ]/^/^__cc/ .#'/4     BdBBBCCC  . , - - - 677777s* 7F G+"?G&&G+8(e!! e.-e.cgdddgddddtddidd 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)dAdBdCd)dDdEdFd)dGdHdd)dIdJdKgdLddMdNd d)dOdPd d)dQdRdSd)dTdUd d)dVdWdXd)dYdZd[d)d\d]d^d)d_d`d.dadbtd)dcddtddidS)eNrzConnection moderr)rrrchoicesr=zHindsight Cloud API URL)rrrwhenr>zHindsight Cloud API keyTrz!https://ui.hindsight.vectorize.io)rrsecretenv_varrZrzHindsight API URLruzAPI key (optional))rrrrrrz LLM providerrrrt)rrrrrrz/Endpoint URL (e.g. http://192.168.1.10:8080/v1)r"r)rrrz,LLM API key (optional for openai_compatible)rrz LLM modelr)fieldmap)rrr default_fromrrzAMemory bank name (static fallback when bank_id_template is unset)r)rrrbank_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 moder-)r-rtoolsrecall_prefetch_methodzAuto-recall methodr.reflectrz;Default tags applied to retained memories (comma-separated)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 recallr/)r/all any_strict all_strict 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 memoriesr0recall_max_tokensz!Maximum tokens for recall resultsr1recall_max_input_charsz*Maximum input query length for auto-recallr2recall_prompt_preamblez0Custom preamble for recalled memories in contextr?zAPI request timeout in secondsrzBEmbedded daemon idle timeout in seconds (0 disables auto-shutdown))r5rrrrrns r'get_config_schemaz)HindsightMemoryProvider.get_config_schema=s$ +<^K^K^K L L$ .GTdouw~n A A$ .GSWdwAdouw~n @ @ $ .AN`kqtDkE F F $ .Bd_r~DFV}W X X$ #>hdQdQdQ\bdt[u v v$ #3dqsGWi|~}~} ~ ~$ "2`lp~U`fhx_y z z$  qIahbhbmsuElF G G$ .qG H H$ '8IVX Y Y$ #3d e e$ *:i j j!$ "$4IV[h~h~h~  #$ $"2KX`nLnLnL M M%$ &-=Q^ft|HtI J J'$ ("2o|~  )$ *$4ivx y y+$ ,)9o}C D D-$ ..>yGR S S/$ 0"2ly{ | |1$ 2(8Vchv`v`v` a a3$ 4"2bos t t5$ 6"2[hl m m7$ 8+;bop q q9$ :#2ivz { {;$ <%5ZhX Y Y=$ >(8[hl m m?$ @-=ivy z zA$ B-=o p pC$ D.N[k l lE$ F#3wEZekm}d~  G$ $ rpc |jM|jdkrt\}}|std|rd|ndzddlm}d|_|jd d}|d vrd }t d |jd d|t|jd d||jdp9|jdptj dd|jdd}|jr |j|d<t|jd|jdn$tj d|jt"}||_||d<|di||_nddlm}|jpt*}|jt/|d}|jr |j|d<t d|jt3|j|d|di||_|jS)z:Return the cached Hindsight client (created once, reused).Nrtz&Hindsight local runtime is unavailablerr"r)HindsightEmbeddedcdSrkrorns r'z5HindsightMemoryProvider._get_client..osrprrrz;Creating HindsightEmbedded client (profile=%s, provider=%s)rrrrrr)rrrrrrr) Hindsight)base_urlr?r>z@Creating Hindsight cloud client (url=%s, has_key=%s, timeout=%s)r?ro)rKr9r1 RuntimeErrorr+r__del__r3rXr%rUrWrrr:r(rMrhindsight_clientrrLrr6r@r4r6) rorxreasonrrkwargsrrr?s r' _get_clientz#HindsightMemoryProvider._get_clientds < z---$8$:$:! 6 &@,2:====<877777,=,=!)#|//CC #FFF#+L Z!\--iBBLRRR L,,YAA!- $ 0 0 = =!PAQAQR_A`A`!PdfdndrdrtKMOePeP"l..{B??  %@-1-?F>*1|''77CL$$^444(@$BTUU)    &2")5~&00::6:: 666666-;+;&*mgOO=6(, F9% _!]D,?,? ARTTT(y22622 |rpc.t||jS)z@Schedule *coro* on the shared loop using the configured timeout.rD)rrL)rors r'rz!HindsightMemoryProvider._run_syncst}5555rpr0r.c|jdkrdSt|jd|t fddDS)z:Return True for stale embedded-daemon connection failures.rtFrc3 K|]}|vV dSrkro)r markerrs r'r zRHindsightMemoryProvider._is_retriable_embedded_connection_error..s;   dN      rp)zcannot connect to hostzconnection refusedzconnect call failedclientconnectorerror)r9r__name__lowerr/)ror0rs @r''_is_retriable_embedded_connection_errorz?HindsightMemoryProvider._is_retriable_embedded_connection_errorsx :) ) )5s))$----3355          rpc|j}||rdS|jt j|jdd}||_||_|dS)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-writerrr) rUis_aliverWclearryrz _writer_looprYr{)rothreads r'_ensure_writerz&HindsightMemoryProvider._ensure_writers $  &//"3"3  F !!###!$#    %# rpc |jd}n1#tj$r|jrYdSYKwxYw |t ur |jdS |n4#t$r'}t d|dYd}~nd}~wwxYw|jn#|jwxYw)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?rDNzHindsight retain failed: %sexc_info) rTrXrREmptyrWis_set_WRITER_SENTINEL task_doner.r%r&)rojobr0s r'rz$HindsightMemoryProvider._writer_loops1  / (,,S,99;   &--//FF  /*** ",,..... VCEEEE VVVNN#@#PTNUUUUUUUUV",,....",,.... /sE(A  A  C7 BC B3 B.)C.B33CC+cX|jrdSd|_tj|jdS)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)rXatexitregister_atexit_shutdownrns r'_register_atexitz(HindsightMemoryProvider._register_atexits5  "  F"&-.....rpc|jrdS |dS#t$r&}td|Yd}~dSd}~wwxYw)Nz$Hindsight atexit shutdown failed: %s)rWrshutdownr.r%rU)ror0s r'r!z(HindsightMemoryProvider._atexit_shutdowns   % % ' '  F F MMOOOOO F F F LL? E E E E E E E E E Fs3 A#AA#cx|} |||S#t$r{}||std|d|_|}||_|||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)rrr.rr%rrK)ro operationclientr0s r'_run_hindsight_operationz0HindsightMemoryProvider._run_hindsight_operations!!## 5>>))F"3"344 4 5 5 5??DD  KKh    DL%%''F!DL>>))F"3"344 4 4 4 4 4 4 5s4 B9A0B4.B94B9c|jdkr.|j't|jdd}|rt|S|jpdS)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. rtNrZr")r9rKgetattrr/r6)rorZs r' _probe_urlz"HindsightMemoryProvider._probe_urlsL :) ) )dl.F$,t44C 3xx}""rpfallback_document_idtuple[str, str | None]c|js|dfSt||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)rZrer+r4)ror,s r'_resolve_retain_targetz.HindsightMemoryProvider._resolve_retain_targetsQ .'- - 1$//2C2CT] S S .#X- -#T))rp session_idc t|pd_t|ddpd_t jd}jd|_ ddl m }ddl m }|d}|||tkrtd |tddl}ddl}ddl} |d } | r || d d d | jdddtgdddtdtnX#t.$r+} td| tYd} ~ n(d} ~ wwxYwtdtn#t.$rYnwxYwt1_t|dpd_t|dpd_t|dpd_t|dpd_t|dpd_t|dpd_t|dpd_ t|dpd_!t|dpd_"d_#g_$jd d!_%tMjd"jd"ntNj(d#tR_*tMjd$jd$ntNj(d%tV_,j%d&krd'_%j%d'kr7t[\} } | s$td(| d)_%dSjd*p9jd+ptNj(d,d_.j%d-vrt^nt`}jd.ptNj(d/|_1jd0d_2tgjd1d2i3}jd4p|d5d2}jd6dpd_4tkj4|j!j"jjj7_6jd8p/jd9p|d9d:}|tnvr|nd:_8jd;d<}|d=vr|nd<_9jd>pjd?d@}|dAvr|nd@_:jdBd_;jdCpd_<t{jdDptNj(dEd_>j>pd_?jdFpd_@jdGdH_AtjdIptNj(dJd_BtjdKptNj(dLdMpdM_CtjdNptNj(dOdPpdP_DjdQd_EtdRtjdSdR_HjdTdU_IjdVd_JtjdWdX_KjdYpd_LjdZd_Mtjd[d\_Njd]d_Od^} ddl m }|d}n#t.$rYnwxYwtd_j%j1j6j8j9j:|j4r>tPd`j4j!j"jjj6tPdajEjJjHjOjIjKjNj?j@ j%d'kr2fdb}tjR|ddcd}|SdSdS)eNr"parent_session_id%Y%m%d_%H%M%S_%frr)rHr8zhindsight-clientzBhindsight-client %s is outdated (need >=%s), attempting upgrade...rrrrrrrTrrz!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_workspacerrr?rrrrsrtzKHindsight local mode disabled because its runtime could not be imported: %sdisabledrr>r)rtrur=rvrrrrrrr)rr workspacer4usersessionrrrrr-)rrr-rprefetch_methodr.)r.rrrrrrrr/rrrrrrrrrrrrr0rrr1 recall_typesrrr2runknownzmHindsight 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=%sc8ddl}tdz }|dd|dz } ddlm}ddlm}|t|dd |_ } j d d }t j }t j }t|} | |k} | rt j }|j|rWt|d5} | d dddn #1swxYwY|j||t|d5} | d ddddS#1swxYwYdS#t*$rh} t|d5} | d| d|| dddn#1swxYwYYd} ~ dSYd} ~ dSd} ~ wwxYw)NrlogsTrzhindsight-embed.log)ConsoleaF)fileforce_terminalrrz+ === Config changed, restarting daemon === z% === Daemon started successfully === z === Daemon startup failed: z === )rH) tracebackr r $hindsight_embed.daemon_embed_managerdaemon_embed_manager rich.consolerFopenconsolerr3rXrrrr_managerrwrstop_ensure_startedr. print_exc)rJlog_dirlog_pathdemrFr'rr expected_envsavedconfig_changedfrros r' _start_daemonz9HindsightMemoryProvider.initialize.._start_daemonsQ    )++f4 dT :::"%:: 4GFFFFF444444")'tHc/B/BSX"Y"Y"YCK!--//F"l..y(CCG #=T\"J"JK#>t|#L#LL,[99E%*l%:N%:&G &U&U !?55g>>:!%h!4!4Y !(W X X XYYYYYYYYYYYYYYY"O00999**,,,h,,K IJJJKKKKKKKKKKKKKKKKKK 444h,,4 I I I IJJJ!+++3334444444444444444444444444444sCF' D." F'.D22F'5D26AF'7F F'FF'!F"F'' H1H0G=1 H=H HH HHzhindsight-daemon-startrr)Tr/rrZrXr[rrstrftimer\importlib.metadatarHr:r9rr%r&rrrrrrrr.rr3rArBrCrDrErFrGrHrIrJrer9r(rrrrLrrMr1r4rr5r6r:r rmr)r7_VALID_BUDGETSr8r;r<rkrlrr=r]r^r_r>r?r@r`maxrrarcrfrgrhrirjrbrUryrzr{)ror0rstart_ts pkg_versionr9 installedrrrrrrxr default_urlrstatic_bank_idrrrA_client_versionr[ts` r' initializez"HindsightMemoryProvider.initializesr z/R006688"%fjj1Db&I&I&OR"P"P"V"V"X"X<>>**+=>>#/<<(<<  A A A A A A 1 1 1 1 1 1# $677Iwy!!GG,?$@$@@@c(*=??? !!!!  ,,t,, q ?"$eY CN& 5_J]5_5_a"&D'  $GI\]]]]$???'l'(*=?????????NN#Z\oppp    D $~~ VZZ 339r::@@BBFJJy117R88>>@@ fjj55;<<BBDDFJJy117R88>>@@ fjj55;<<BBDDfjj55;<<BBDDfjj55;<<BBDD"6::.>#?#?#E2FFLLNN #FJJ/@$A$A$GR H H N N P P \%%fg66 *+/<+;+;I+F+F+RDL  Y ' ' 'XZXbXfXfgzX{X{    004 0@0@0P0P0\DL  ^ , , ,bdblbpbprJcKcK !   : )DJ :) ) ) 4 6 6 Iv a(  ((22|dl6F6Fy6Q6Q|UWU_UcUcdwy{U|U| ,0J:^,^,^((dt  ((33grz~~FY[f7g7g !\--nbAA gxDDD)))44U (H8U8U!%!1!12Db!I!I!OR1  "#(+^$    !!/22ndl6F6Fx6P6PnTYT]T]^fhmTnTn!'>!9!9vvu l&&}h?? +6:X+X+XKK^f,**+CDDu HXHXYjltHuHu3BF[3[3[ai"\--nbAA$(L$4$45J$K$K$St!3 L  ] + + ;z~~5r::  &.$  L,,];;Ct"&,"2"23F"N"N! L  _ - - ^@Y[]1^1^  %'' $' L  1 2 2 lbjnnEcek6l6l$ $ %''$  ), L  6 7 7 {2:>>Jmoz;{;{) ) %'')!  % !L,,]DAA%(C 0@0@AWYZ0[0[,\,\%]%]"#|//0@Brss!L,,]DAA"%dl&6&67JD&Q&Q"R"R!\--n==E'+|'7'78PRT'U'U$'*4<+;+;F LLL-  U  &&f&&&sA88A<?A<cjdkrtddSjstddSjrtddSjr'tjkrdjfd}tj |dd_ j dS) Nrz#Prefetch: skipped (tools-only mode)z(Prefetch: skipped (auto_recall disabled)z!Prefetch: skipped (shutting down)cj jdkrQtdjt fd}|jpd}njjjdj rj d<j d<j r j d<td jt jfd }|j rt |j nd }td ||j r$d d|j Dnd}|r)j5|_ddddS#1swxYwYdSdS#t $r(}td|dYd}~dSd}~wwxYw)Nrz1Prefetch: calling reflect (bank=%s, query_len=%d)cH|jjSN)rrrareflectr7r8r'rros r'rzFHindsightMemoryProvider.queue_prefetch.._run..s2`d`muzDHDPIQIQrpr"rrr max_tokensr tags_matchtypesz;Prefetch: calling recall (bank=%s, query_len=%d, budget=%s)c|jdiSNroarecallr' recall_kwargss r'rzFHindsightMemoryProvider.queue_prefetch.._run..)sHgHgYfHgHgrprz$Prefetch: recall returned %d resultsr c38K|]}|j d|jVdS)z- Nr)r rs r'r zGHindsightMemoryProvider.queue_prefetch.._run..,s1$S$SqAF$S]!&]]$S$S$S$S$S$SrpzHindsight prefetch failed: %sTr)r<r%rUr7rr(rr8rgr^r_rhresultsrrPrNr.)r\r num_resultsrr~rros @r'rqz4HindsightMemoryProvider.queue_prefetch.._runs` P(I55LL!TVZVcehineoeoppp88:Q:Q:Q:Q:QRRD9?DD$(=5"&,d>U++M(N040A f-6:6M l3)D151C g.LL!^!%E DLJJJ889g9g9g9ghhD7;|"J#dl"3"3"3KLL!GUUUW[Wck499$S$SDL$S$S$SSSSikD5,5504-55555555555555555555 P P P  ? ? ? F   LLC D D D F   % % ' '  LL< = = = F  ' 9CJJ9U,U,U74778E P P P P P P8!* 0TPd e e e ##%%%%%rp user_contentassistant_contentList[Dict[str, str]]ctjtj}d|jd||dd|jd||dgS)Nr?r)roler timestamp assistant)rrrrrr?r@)rorrrs r'_build_turn_messagesz,HindsightMemoryProvider._build_turn_messages6svl8<((2244"6HH,HH    $";RR?PRR     rp message_countr turn_indexDict[str, str]ctt|t|d}|jr |j|d<|jr |j|d<|jr |j|d<|jr |j|d<|jr |j|d<|jr |j|d<|jr |j|d<|j r |j |d <|j r |j |d <|j r |j |d <|S) N) retained_atrrsourcer0r4r5r6r7r8r9r:r;) rr/r>rZrArBrCrDrErFrGrH)rorrmetadatas r'_build_metadataz'HindsightMemoryProvider._build_metadataEs)++ //j//$ $    5!%!4HX    6%)%5H\ " > 2#'>HZ = 0"&-HY  ? 4$(OH[ ! = 0"&-HY  ? 4$(OH[ ! ? 4$(OH[ ! ? 4$(OH[ !   >)-)=H% &rpN)r document_idrrrrrr4rrDict[str, str] | NonerList[str] | Noner bool | NoneDict[str, Any]c |j||p|d|jd}|||d<|r||d<|||d<t|j}t|D]} | |vr|| |r||d<|S)Nrrr)rrrrrrr)r7rrJrr=r) rorrrrrrr merged_tagsrs r'_build_retain_kwargsz,HindsightMemoryProvider._build_retain_kwargsas} fD$8$8qUYUe$8$f$f" "    'F9   0$/F= !  #%1F> ",T->?? )$// ( (C+%%""3'''  )(F6N rpc x jstddSjrtddS|r&t |_tj ||d}j |xj dz c_ j _j jzdkr@tdj j jj jzz zdStd t!j t#d j Dd d j zd zg jr djjr djt!j dzj t!j  j\jj j d f d }j|dS)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)z=sync_turn: retaining %d turns, total session content %d charsc34K|]}t|VdSrk)r)r rfs r'r z4HindsightMemoryProvider.sync_turn..s(2W2Wa3q662W2W2W2W2W2Wrprrrsession:parent:r}rr rc j pddddd  d<td t  fdtddS)Nrrrrr update_modezRHindsight retain: bank=%s, doc=%s, mode=%s, async=%s, content_len=%d, num_turns=%dc8|gSN)rrrr) aretain_batch)r'rrrretain_async_flags r'rzGHindsightMemoryProvider.sync_turn.._do_retain..s*v33#& +!2 4  rpzHindsight retain succeeded)rpopr%rUrr() rrrr lineage_tagsmetadata_snapshot num_turnsrrrors @r' _do_retainz5HindsightMemoryProvider.sync_turn.._do_retains,,&*!)T -D HHY % % % HH^T * * *&&1]# LLm +{ > > F  7":4466D z$33LBSTTchiii ""4((( a-   : :a ? ? LLO+T-?4C]`d`ruyvPaPDP.Q R R R F T,--s2W2W4CV2W2W2W/W/W Y Y Y!4555;"$   ?    =4+; = = > > >  " E    C$*A C C D D D!00d122Q6'1  +,, #'#>#>t?P#Q#Q [- .- 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7.   z*****rpList[Dict[str, Any]]cD|jdkrgStttgS)Nr)r; RETAIN_SCHEMA RECALL_SCHEMAREFLECT_SCHEMArns r'get_tool_schemasz(HindsightMemoryProvider.get_tool_schemass"   ) )I}n==rp tool_nameargsc  |dkr%|dd}|stdS|d} |||d tdjt || fd td tj d d iS#t$r9}t d |dtd|cYd}~Sd}~wwxYw|dkr|dd stdS j j j d jrj d<j d<jr j d<tdjt j  fd}|jrt |jnd}td||jstj d diSdt%|jdD} tj d d| iS#t$r9}t d|dtd |cYd}~Sd}~wwxYw|d!kr|dd stdS td"jt j  fd#}td$t |jpdtj d |jpdiS#t$r9}t d%|dtd&|cYd}~Sd}~wwxYwtd'|S)(Nrrr"z#Missing required parameter: contentrr)rrz:Tool hindsight_retain: bank=%s, content_len=%d, context=%sc|jdiSrz)aretain)r' retain_kwargss r'rz:HindsightMemoryProvider.handle_tool_call..s^V^=\=\m=\=\rpzTool hindsight_retain: successrzMemory stored successfully.zhindsight_retain failed: %sTrzFailed to store memory: rrz!Missing required parameter: queryrurwrxz7Tool hindsight_recall: bank=%s, query_len=%d, budget=%sc|jdiSrzr{r}s r'rz:HindsightMemoryProvider.handle_tool_call..sNFNDcDcUbDcDcrprz!Tool hindsight_recall: %d resultszNo relevant memories found.c,g|]\}}|d|jS)z. r)r irs r'rz.s,QQQdaA))))QQQrprr zhindsight_recall failed: %szFailed to search memory: rz8Tool hindsight_reflect: bank=%s, query_len=%d, budget=%scH|jjSrqrrrts r'rz:HindsightMemoryProvider.handle_tool_call..s%6?? $ U4<$3$$rpz'Tool hindsight_reflect: response_len=%dzhindsight_reflect failed: %szFailed to reflect: zUnknown tool: )rXr rr%rUr7rr(rSrr.r&r8rgr^r_rhr enumeraterr) rorrrrrrr\rlinesrr~rs ` @@@r'handle_tool_callz(HindsightMemoryProvider.handle_tool_calls * * *hhy"--G I!"GHHHhhy))G B $ 9 9#&))!:!!  Y!]CLL'CCC--.\.\.\.\]]] =>>>z8-J"KLLL B B B??? C C C 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. r"Nr}rrrrrrc  jpdddddd<tdjt fddS#t$r(}t d|d Yd}~dSd}~wwxYw) NrrrrzAHindsight flush-on-switch: bank=%s, doc=%s, mode=%s, num_turns=%dcL|jgjSr)rr7rb)r'rold_document_idros r'rzKHindsightMemoryProvider.on_session_switch.._flush..js/v';';$(M#'&(7)-); (<((rpz$Hindsight flush-on-switch failed: %sTr) rrcrr%rUr7rr(r.r&) rr old_contentrold_lineage_tags old_metadata old_turnsold_update_moderos @r'_flushz9HindsightMemoryProvider.on_session_switch.._flushYs/]44# $ 4!--5 5D HHY---HH^T222&2.=]+LL[ Y11!]]]NN#I1W[N\\\\\\\\\]sBB## C-CCrkrDr3rrzEHindsight on_session_switch: new_session=%s parent=%s reset=%s doc=%s)r/rrerrZr[rJrrrrr/r\rWrrr"rTrrQrrPrNrrr\rdr%rU)rorr2rrnew_idold_session_idold_parent_session_idold_turn_indexrr`rrrrrrs` @@@@@@r'on_session_switchz)HindsightMemoryProvider.on_session_switchsN^)r**0022  F  ; /T011I!-N$($; !!-N//!)nnq0)0L+-  E ''(C>(C(CDDD$ K ''(I2G(I(IJJJ 3 33c9K 04/J/J!00 ,O_ ] ] ] ] ] ] ] ] ] ] ]B&--// /##%%%%%'''"&&v...   4T%:%C%C%E%E 4  ! & &s & 3 3 3   ' '$&D ! ' ' ' ' ' ' ' ' ' ' ' ' ' ' '  E&)*;&<&<&B&B&D&DD #!<>>**+=>>#/<<(<<  S  d5ud>O     sF11F58F5c td|j|j}||r |jtn#t$rYnwxYw| d|r2t d|j |j r4|j r|j d|j |jdkrt!|jdd}|Ot#|dr?t%| d|j_n#t$rYnwxYw |jn<#t*$rYn0wxYw||jn#t$rYnwxYwd|_dSdS) NzDHindsight shutdown: stopping writer + waiting for background threadsg$@rDzIHindsight writer did not stop within 10s; abandoning %d pending retain(s)r<rtrKaclose)r%rUrWrrUrrTrrr.rr&qsizerQrKr9r*hasattrrrcloser)rowriter inner_clients r'r$z HindsightMemoryProvider.shutdowns> [\\\ !!!$  &//"3"3  "&&'78888     KKK % % %   6&,,..   4T%:%C%C%E%E 4  ! & &s & 3 3 3 < # :!111$+4<D#I#IL#/GL(4S4S/!,"5"5"7"7888!37DL00(!!! D! **,,,,'NN4<#6#6#8#8999    DLLL1 $ #smA22 A?>A?!AG+6 FG+ F G+FG+F.-G+. F;8G+:F;;/G++ G87G8r r/)r r6)rr/rrWr r)r0r.r r6r)r,r/r r-)r0r/r r)rr/r0r/r r/)rr/r0r/r r)rr/rr/r r)rrrrr r)rr/rr4rr4rrrrrrr r)rr/rr/r0r/r r)r r)rr/rrWr r/)rr/r2r/rr6r r)!r  __module__ __qualname____doc__rppropertyrur{rrrrrrrrr"r!r(r+r/rgrirmrrrrrrrrr$rorpr'r+r+sWWD$D$D$LX&??? H8H8H8H8T% % % N+++Z666     .////. / / / /FFFF555" # # # #*****EEEEN    ,9;''''''$?A+&+&+&+&+&+&Z     @#"&*.!%$(:Y[K+K+K+K+K+K+Z>>>> B8B8B8B8P"$ ~ ~ ~ ~ ~ ~ @/ / / / / / rpr+rcH|tdS)z/Register Hindsight as a memory provider plugin.N)register_memory_providerr+)ctxs r'r r s#  !8!:!:;;;;;rp)rrrrr r)r r))r3r4r5r/r r6)Nr<)r=r/r>r4r?r@r r4rk)r=r/r>r4r r6)r rh)r?r@)r rW)rrr rr)rrr r/)r r)rrrr4r r)rr)rrrr4)rr/r r/)rr/rr/rr/r r/r)Cr __future__rrlrr,rSloggingrrRryrrtypingrrragent.memory_providerr hermes_constantsr tools.registryr rr getLoggerr r%r5rrrrrbr^rr(r1r2__annotations__rOrar;r_rerfrgrvrrr|rrrrrrrrrrrrrr)r+r rorpr'rs8#"""""   ''''''''""""""""""000000,,,,,,%%%%%%%%%%%%  8 $ $7, '.#'''# !#*      .-/....().**FJ25-----<BF#####V+/....(, ,,,, Y^   688"&6*****"  S (9TUU (9tuu (+e  K    ,  T h7LMM I     R h7TUU I   (****Z""""J```` $$$$    VZ######L]]]] \`      $$$$,    J@ @ @ @ @ n@ @ @ \&<<<<<