+ iHj.jRt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t ^RI H t HtHtHtHt]P$!]4tRRltRR R RR R/R R llt^tRt]!0Rm4tRRlt] !R R7!RR44t]P:!R]P<4tRRlt !RR]4t!R#)aHAbstract base class for pluggable memory providers. Plugins ship in ``plugins/memory//``, activated via ``memory.provider`` (ONE external provider at a time). Lifecycle, driven by MemoryManager: initialize -> system_prompt_block / prefetch / sync_turn per turn -> tool dispatch -> shutdown, plus optional ``on_*`` hooks. ) annotationsN)ABCabstractmethod) dataclass)AnyCallableDictListOptionalc V^8dQhRRRR/#)fnCallable[..., Any]return)formats":/home/ubuntu/.hermes/hermes-agent/agent/memory_provider.py __annotate__rs @@$@);@c>aa\P!4oVV3Rl#)a Bind ``fn`` to the CALLER's contextvars for another thread/executor. Profile isolation is a ContextVar-scoped HERMES_HOME override plus the per-turn secret scope; a worker started with an empty context silently lands on the default profile (or fails closed on secrets).c0<SP!S.VO5/VB#N)run)argskwargsctxr s*,rctx_bound..s3772#?#?#?r) contextvars copy_context)r rsf@r ctx_boundr s  " " $C ??rdaemonTrrc 0V^8dQhRRRRRRRRR R R R /#) r targetrnamestrr!boolrtuplerOptional[dict[str, Any]]rzthreading.Threadr)rs"rrrsBjj!3jcj4j$j3KjWgjrcF\P!\V4W4WR7#)zUnstarted thread running *target* under the spawner's contextvars (see :func:`ctx_bound`). Every memory-provider background job (prefetch, sync, writer loops) must go through this.)r#rrr$r!) threadingThreadr )r#r$r!rrs&$$$$rspawn_context_threadr,s   9V#44UY iiru🧠c V^8dQhRRRR/#)r r$ Optional[str]rr&r)rs"rrr/sMM-MDMrcr\T;'gR4P4P4\9#)zXTrue when ``memory.provider`` selects the built-in store rather than an external plugin.)r%striplowerCORE_MEMORY_PROVIDER_SENTINELS)r$s&ris_core_memory_providerr4/s* tzzr? " ( ( *.L LLr)frozenc>]tRt^4t$RtR]R&R]R&]tR]R&RtR#) RecallStatuszWhat the last prefetch injected, for the deterministic recall indicator (``MemoryManager.describe_recall``). ``count == 0`` means content without a discrete count (e.g. a synthesized reflect answer) and renders generically.r%provider_labelintcountglyphrN) __name__ __module__ __qualname____firstlineno____doc____annotations__INDICATOR_GLYPHr;__static_attributes__rrrr7r74sS J E3 rr7c V^8dQhRRRR/#)r textr.rr&r)rs"rrrKs33M3d3rcT;'gRP4pV'dVPR4'dR#\\P V44#)zTrue for empty input, slash commands and bare greetings/acknowledgements (skipping recall saves a round-trip and keeps stale context from derailing one-word replies).r0/T)r1 startswithr&TRIVIAL_PROMPT_REmatch)rEstrippeds& ris_trivial_promptrLKsE !!#H x**3// !''1 22rc]tRt^TtRt^t]]RRl44t]RRl4t ]RRl4t RR lt R R lt R R /RRllt R R /RRlltRRltR R RRRR/RRllt]RRl4tRRltRRltRR ltR!R"ltR#R$ltR%R R&R'R(R'/R)R*lltR+R,ltR-R /R.R/lltR0R1ltR2R3ltR9R4R5lltR6R7ltR8tR#):MemoryProvidera=Abstract base class for memory providers. Multiplexing contract (#140058). One gateway process can serve several profiles, and each agent's ``MemoryManager`` owns its own provider instance, initialized for one profile. A provider must: - hand every load a NEW instance (``register(ctx)`` / the loader constructs one per agent). The manager refuses an instance another profile's manager already bound, rather than rebinding it; - bind every store, path, client, bank or tenant from ``initialize()``'s ``hermes_home`` (and scoped secrets read during ``initialize``) and keep that binding on the instance; - keep no profile-specific mutable state at module or class level, and never "rebind" a shared binding per call: two profiles' calls interleave on different threads. The manager runs tool calls and lifecycle hooks only from the profile the instance was initialized for (refusing callers that name another profile, or none on a multiplexed process), runs its background hooks under that profile's ``HERMES_HOME``, and passes ``hermes_home`` / ``agent_identity`` / ``caller_gsk`` to ``handle_tool_call`` when it accepts ``**kwargs``. Those keywords name the same profile the instance is bound to; they are not a reason to rebind. Core cannot see inside a provider: one that keeps a process-wide binding still breaks this contract. cV^8dQhRR/#r rr%r)rs"rrMemoryProvider.__annotate__osZZcZrc R#)zKShort identifier for this provider (e.g. 'builtin', 'honcho', 'hindsight').Nrselfs&rr$MemoryProvider.namemrcV^8dQhRR/#)r rr&r)rs"rrrQushhdhrc R#)zYConfigured, credentialed and ready? Gates activation; check config/deps only, no network.NrrSs&r is_availableMemoryProvider.is_availabletrVrc V^8dQhRRRR/#)r session_idr%rNoner)rs"rrrQys  S t rc R#)uInitialize once at agent startup (connections, resources, threads). kwargs always include ``hermes_home`` (profile-scoped storage; never hardcode ``~/.hermes``) and ``platform``; may include ``agent_context`` ("primary" | "subagent" | "cron" | "flush" — skip writes for non-primary contexts), ``agent_identity``, ``agent_workspace``, ``parent_session_id``, ``user_id``, ``user_id_alt``. Nr)rTr\rs&&,r initializeMemoryProvider.initializexrVrcV^8dQhRR/#rPr)rs"rrrQsCrc R#)z[User-facing hint for the "provider unavailable" warning (``initialize()`` never runs then).r0rrSs&runavailable_reason!MemoryProvider.unavailable_reasonrcV^8dQhRR/#rPr)rs"rrrQsSrc R#)zZSTATIC system-prompt text; "" to skip. Recalled context goes through prefetch(), not here.r0rrSs&rsystem_prompt_block"MemoryProvider.system_prompt_blockrerr\r0c$V^8dQhRRRRRR/#)r queryr%r\rr)rs"rrrQs!c#src R#)uFormatted recall context for the upcoming turn ("" if none). Must be fast — recall in the background and return cached results; ``session_id`` scopes concurrent sessions.r0rrTrkr\s&&$rprefetchMemoryProvider.prefetchsrc$V^8dQhRRRRRR/#)r rkr%r\rr]r)rs"rrrQs&[[C[[T[rc R#)zLQueue a background recall after each turn; prefetch() consumes it next turn.Nrrms&&$rqueue_prefetchMemoryProvider.queue_prefetchrVrcV^8dQhRR/#)r rzOptional[RecallStatus]r)rs"rrrQs5rc R#)zWhat the most recent :meth:`prefetch` injected (``None`` = no indicator). Must reflect only the LAST prefetch, never a stale prior count.NrrSs&r recall_statusMemoryProvider.recall_statussrmessagesN turn_authorc 0V^8dQhRRRRRRRRRRR R /#) r user_contentr%assistant_contentr\rxzOptional[list[dict[str, Any]]]ryr(rr]r)rs"rrrQsHNNN47NN(FN.N  Nrc R#)zPersist a completed turn (non-blocking). ``messages`` is the OpenAI-style list so far. ``turn_author`` (``{"id", "name", "is_bot"}``) is who wrote the user side; the manager sends it only to signatures that accept it.Nr)rTr{r|r\rxrys&&&$$$r sync_turnMemoryProvider.sync_turnrVrcV^8dQhRR/#r rlist[dict[str, Any]]r)rs"rrrQscc"6crc R#)zTOpenAI function-calling schemas ({"name", "description", "parameters"}); [] if none.NrrSs&rget_tool_schemasMemoryProvider.get_tool_schemasrVrc$V^8dQhRRRRRR/#)r tool_namer%rdict[str, Any]rr)rs"rrrQs'\\#\^\RU\rc 8\RVP RV 24h)z?Handle one of this provider's tools; must return a JSON string.z Provider z does not handle tool )NotImplementedErrorr$)rTrrrs&&&,rhandle_tool_callMemoryProvider.handle_tool_calls!Idii[8Nyk"Z[[rcV^8dQhRR/#)r rr]r)rs"rrrQsBB$Brc R#)u3Clean shutdown — flush queues, close connections.NrrSs&rshutdownMemoryProvider.shutdownrVrc$V^8dQhRRRRRR/#)r turn_numberr9messager%rr]r)rs"rrrQs&ooosoorc R#)a7Per-turn tick. kwargs may include remaining_tokens, model, platform, tool_count, author_id, author_name, author_is_bot. The author trio names who wrote THIS turn (None, None, False without one): a shared session carries several participants, so a provider keying durable state on identity must read it per turn.Nr)rTrrrs&&&,r on_turn_startMemoryProvider.on_turn_startrVrcV^8dQhRR/#)r rrr)rs"rrrQsNrc /#)a)Identity-mapping values that must bust a cached gateway agent when they change (writer identity, alias tables, session-name prefixing). Provider-namespaced keys, JSON-serializable values. The gateway calls this on an uninitialized instance on every inbound message, so keep it cheap and read-only.rrSs&ridentity_signature!MemoryProvider.identity_signatures  rc V^8dQhRRRR/#)r rxrrr]r)rs"rrrQs``';``rc R#)zQEnd-of-session extraction; fires only at real session boundaries, never per-turn.NrrTrxs&&ron_session_endMemoryProvider.on_session_endrVrparent_session_idresetFrewoundc ,V^8dQhRRRRRRRRRR/#) r new_session_idr%rrr&rrr]r)rs"rrrQs455!59<5JN5ae5 5rc R#)a$session_id reassigned mid-process (/resume, /branch, /reset, /new, compression) without teardown: rebind per-session state so later writes land in the right record. ``reset`` is True only for a genuinely new conversation (flush buffers); ``rewound``: same id but the transcript was truncated.Nr)rTrrrrrs&&$$$,ron_session_switch MemoryProvider.on_session_switchrVrc V^8dQhRRRR/#)r rxrrr%r)rs"rrrQs(<rc R#)zWExtract insights from ``messages`` about to be compressed, fed into the summary prompt.r0rrs&&ron_pre_compressMemoryProvider.on_pre_compressrerchild_session_idc(V^8dQhRRRRRRRR/#)r taskr%resultrrr]r)rs"rrrQs/hh#hshh`dhrc R#)zYPARENT-side observation of a completed delegation (the subagent has no provider session).Nr)rTrrrrs&&&$,r on_delegationMemoryProvider.on_delegationrVrcV^8dQhRR/#rr)rs"rrrQs#7rc .#)a4Setup fields for ``hermes memory setup`` ([] if none): ``key``, ``description``, optional ``secret`` (goes to .env), ``required``, ``default``, ``choices``, ``type`` (text | integer | number | boolean), ``minimum``/``maximum``/``step``, ``url``, ``env_var`` (explicit secret env var; default auto-generated).rrSs&rget_config_schema MemoryProvider.get_config_schemas  rc$V^8dQhRRRRRR/#)r valuesr hermes_homer%rr]r)rs"rrrQs&YY.YsYtYrc R#)zWrite non-secret setup ``values`` to the provider's native config. Plugins MUST either override this or use only env vars (every schema field carrying ``env_var``).Nr)rTrrs&&&r save_configMemoryProvider.save_configrVrc ,V^8dQhRRRRRRRRRR/#) r actionr%r#contentmetadatar(rr]r)rs"rrrQs1  c 3  Ph tx rc R#)aBMirror a built-in memory-tool write (``action``: add | replace | remove; ``target``: memory | user; ``metadata``: provenance such as write_origin, session_id, tool_name). For replace/remove, ``metadata["previous_content"]`` is the full entry selected under the native-store lock. A memory-tool patch arrives as a replace whose ``content`` is the whole entry after the edit. Notifications follow a successful complete write or batch; each batch operation sees the preceding operation's result. Older callers may omit this field: ``old_text`` alone is not authoritative identity. Nr)rTrr#rrs&&&&&ron_memory_writeMemoryProvider.on_memory_writerVrcV^8dQhRR/#)r rz list[str]r)rs"rrrQsirc .#)zAbsolute paths of provider state OUTSIDE HERMES_HOME for ``hermes backup``/``import`` (paths outside the home dir are skipped). MUST work without ``initialize()`` or network.rrSs&r backup_pathsMemoryProvider.backup_pathss  rrr)r<r=r>r?r@#pre_compress_checkpoint_api_versionpropertyrr$rYr_rcrhrnrrrvr~rrrrrrrrrrrrrrCrrrrNrNTs,+,' ZZ hh   [b[ NNIMN15Ncc\B o  `5?A5QV5hm5hrhY rrNr>r0nonebuiltindefaultbuilt-inz^(yes|no|ok|okay|sure|thanks|thank you|y|n|yep|nope|yeah|nah|hi|hey|hello|yo|sup|continue|go ahead|do it|proceed|got it|cool|nice|great|done|next|lgtm|k)[\s!?.:;,"'~\u2018\u2019\u201c\u201d\u2014\u2013\u2026()\[\]{}<>*&^%$#@!+=`\u00a0]*$)"r@ __future__rrloggingrer*abcrr dataclassesrtypingrrrr r getLoggerr<loggerr r,#PRE_COMPRESS_CHECKPOINT_API_VERSIONrB frozensetr3r4r7compile IGNORECASErIrLrNrrrrs# #!66   8 $@jRVj')jNRj'(#"++Y!ZM  $!!!JJgMM 3MSMr