$jupdZddlZddlZddlmZddlmZddlmZddlm Z m Z ddl Z ej dZ n#ej$rdZ YnwxYwd e Zdd lmZmZmZmZmZmZmZmZmZmZdd lmZmZmZmZdd l m!Z!dd l"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/dZ0GddZ1dS)z Clean, pythonic wrapper for the Hindsight API client. This file is MAINTAINED and NOT auto-generated. It provides a high-level, easy-to-use interface on top of the auto-generated OpenAPI client. N)datetime)metadata)Path)AnyLiteralzhindsight-clientz0.0.0zhindsight-client-python/) banks_apidirectives_api documents_api entities_api files_api memory_apimental_models_apimonitoring_apioperations_api webhooks_api) memory_itemrecall_requestreflect_requestretain_request)ReflectIncludeOptions)BankProfileResponse)FileRetainResponse)ListMemoryUnitsResponse)RecallResponse) RecallResult)ReflectResponse)RetainResponsec tj}n7#t$r*tj}tj|YnwxYw||S)z%Run an async coroutine synchronously.)asyncioget_event_loop RuntimeErrornew_event_loopset_event_looprun_until_complete)coroloops i/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/hindsight_client/hindsight_client.py _run_asyncr(3sm%%'' %%%%''t$$$$$%  " "4 ( ((s1A  A c/eZdZdZ ddededzdededzfdZed ej fd Z ed e j fd Z ed ejfd Zed ejfd Zed ejfdZed ejfdZed ejfdZed ejfdZed e j!fdZ"ed e#j$fdZ%dZ&dZ'dZ(dZ) ddedede*dzdedzdedzde+eefdzde,e+eefdzd e,edzd!edzd"e-d e.fd#Z/ dded$e,e+ee0fdedzd%e,edzd"e-d e.f d&Z1 dded'e,ee2zdedzd(e,e+ee0fdzd e3f d)Z4 dded/ed0e,edzd1e5d2ed3e-d4edzd5e-d6e5d7e-d8e5d9e-d:e5d e,edzd;e6d<d=e,e+ee0fdzd e7f"d>Z8 dded/ed2ededzd1e5dzd@e+ee0fdzd e,edzd;e6d<dAe-d=e,e+ee0fdzdBe,edzdCe-dDe,edzd e9fdEZ: ddedHedzdIedzdJe5dKe5d e;f dLZ< ddedMedzdNedzdOe5dzdPe5dzdQe5dzdRe+eefdzdSedzdTedzdUedzdVe5dzdWe-dzdXedzdYedzdZedzd e=f d[Z> ddedMedzdNedzdYedzdOe5dzdPe5dzdQe5dzdRe+eefdzdSedzdTedzdUedzdVe5dzdWe-dzdXedzdZedzd e=f d\Z?dedNed e+ee0ffd]Z@dedYed e+ee0ffd^ZA ddedMedzdNedzdOe5dzdPe5dzdQe5dzdRe+eefdzdSedzdTedzdUedzdVe5dzdWe-dzdXedzdYedzdZedzd e=f d_ZBdedNed e+ee0ffd`ZCdedYed e+ee0ffdaZD dded$e,e+ee0fdedzd%e,edzd"e-d e.f dbZE ddedede*dzdedzdedzde+eefdzde,e+eefdzd e,edzd!edzd"e-d e.fdcZF dded/ed0e,edzd1e5d2ed3e-d4edzd5e-d6e5d7e-d8e5d9e-d:e5d e,edzd;e6d<d=e,e+ee0fdzd e7f"ddZG dded/ed2ededzd1e5dzd@e+ee0fdzd e,edzd;e6d<dAe-d=e,e+ee0fdzdBe,edzdCe-dDe,edzd e9fdeZH ddedMedfed e,edzd1e5dzdge+ee0fdzdhedzfdiZIdded e,edzfdjZJdedkefdlZKdedkefdmZL ddedkedMedzdfedzd e,edzd1e5dzdge+ee0fdzfdnZMdedkefdoZNdedkefdpZO ddedMededre5dse-d e,edzf dtZPdded e,edzfduZQdedvefdwZR ddedvedMedzdedzdre5dzdse-dzd e,edzfdxZSdedvefdyZTded e+ee0ffdzZUded e+ee0ffd{ZVddddddddddddddddddddd|dedYedzd}e5dzdSedzdTedzdUedzdVe5dzd~edzde+ee0fdzde,edzde-dzdWe-dzdXedzde5dzde5dzde5dzdOe5dzdPe5dzdQe5dzde,edzde+eefdzd e+ee0ff,dZWdede+ee0fd e+ee0ffdZXded e+ee0ffdZYded e+ee0ffdZZdefdZ[defdZ\dS) Hindsightu] High-level, easy-to-use Hindsight API client. This class provides simplified methods for the most common operations: retain, recall, reflect, bank management, mental models, and directives. **Async vs sync:** Every convenience method has an async counterpart prefixed with ``a`` (e.g. ``aretain``, ``arecall``, ``areflect``). **Prefer the async variants** (``aretain``, ``arecall``, ``areflect``, etc.) whenever you are inside an async context (``async def``, event loops, frameworks like FastAPI/LangGraph/CrewAI). The sync versions (``retain``, ``recall``, ``reflect``) are convenience wrappers that call ``asyncio.run_until_complete`` under the hood — they exist for scripts and REPLs but will raise errors if an event loop is already running. For operations not covered here (documents, entities, operations/async jobs, webhooks, file uploads, monitoring), use the low-level API clients exposed as properties on this class. These are auto-generated from the OpenAPI spec and cover the full API surface. **All low-level methods are async-only.** Example — async (preferred):: from hindsight_client import Hindsight client = Hindsight(base_url="http://localhost:8888", api_key="your-api-key") # Inside an async function — use the a* methods await client.aretain(bank_id="alice", content="Alice loves AI") response = await client.arecall(bank_id="alice", query="What does Alice like?") answer = await client.areflect(bank_id="alice", query="What are my interests?") Example — sync (scripts / REPLs only):: # Outside an async context — sync wrappers are available client.retain(bank_id="alice", content="Alice loves AI") response = client.recall(bank_id="alice", query="What does Alice like?") Example — low-level API for advanced operations:: # Access documents, entities, operations, webhooks, etc. # All low-level methods are async-only — use 'await' or asyncio.run(). # List documents in a bank docs = await client.documents.list_documents("alice") # Delete a specific document await client.documents.delete_document("alice", "doc-123") # Check async operation status status = await client.operations.get_operation_status("alice", "op-456") # List entities entities = await client.entities.list_entities("alice") Available low-level API properties: - ``client.memory``: Core memory operations (MemoryApi) - ``client.banks``: Bank management (BanksApi) - ``client.documents``: Document CRUD (DocumentsApi) - ``client.entities``: Entity browsing (EntitiesApi) - ``client.mental_models``: Mental model management (MentalModelsApi) - ``client.directives``: Directive management (DirectivesApi) - ``client.operations``: Async operation tracking (OperationsApi) - ``client.webhooks``: Webhook management (WebhooksApi) - ``client.files``: File upload (FilesApi) - ``client.monitoring``: Health/version checks (MonitoringApi) Nr@base_urlapi_keytimeout user_agentcrtj||}tj||_|pt|j_||_|d|_||_ |r|j dd|tj |j|_ tj|j|_t#j|j|_t)j|j|_t/j|j|_t5j|j|_t;j|j|_tAj!|j|_"tGj$|j|_%tMj'|j|_(dS)a Initialize the Hindsight client. Args: base_url: The base URL of the Hindsight API server api_key: Optional API key for authentication (sent as Bearer token) timeout: Request timeout in seconds (default: 300.0) user_agent: Override the default ``User-Agent`` header. Integrations should set this to identify themselves (e.g. ``"hindsight-crewai/1.2.0"``). Defaults to ``hindsight-client-python/``. )host access_token/ AuthorizationBearer N))hindsight_client_api Configuration ApiClient _api_clientDEFAULT_USER_AGENTr/_timeoutrstrip _base_url_api_keyset_default_headerr MemoryApi _memory_apirBanksApi _banks_apirMentalModelsApi_mental_models_apir DirectivesApi_directives_apir FilesApi _files_apir DocumentsApi_documents_apir EntitiesApi _entities_apir OperationsApi_operations_apir WebhooksApi _webhooks_apir MonitoringApi_monitoring_api)selfr,r-r.r/configs r'__init__zHindsight.__init__sj&&3PWXXX/9&AA&0&F4F# !--  V   / /AT7ATAT U U U%/0@AA#,T-=>>"3"CDDT"U"U-;D>+89IJJ)5d6FGG-;D=A>cZK|jr!|jd{VdSdS)z%Close the API client (async version).N)r9rurZs r'aclosezHindsight.aclosesH   +"((** * * * * * * * * * + +rWFbank_idcontent timestampcontext document_idrrbtags update_mode retain_asyncc V||||||d} | | | d<||| g|| S)u Store a single memory (sync wrapper — prefer :meth:`aretain` in async code). Args: bank_id: The memory bank ID content: Memory content timestamp: Optional event timestamp context: Optional context description document_id: Optional document ID for grouping metadata: Optional user-defined metadata entities: Optional list of entities [{"text": "...", "type": "..."}] tags: Optional list of tags for filtering memories during recall/reflect update_mode: How to handle existing documents ('replace' or 'append') retain_async: If True, process asynchronously in background (default: False) Returns: RetainResponse with success status rrrrrbrNrritemsrr) retain_batch rTrrrrrrrbrrritems r'retainzHindsight.retains`@"       ""-D   &#% !   rWr document_tagsc Pt||||||S)u6 Store multiple memories in batch (sync wrapper — prefer :meth:`aretain_batch` in async code). Args: bank_id: The memory bank ID items: List of memory items, each a dict with 'content' (required) and optional keys: 'timestamp', 'context', 'metadata', 'document_id', 'entities', 'tags', 'observation_scopes' (str or list[list[str]]), 'strategy'. document_id: Optional document ID for grouping memories (applied to items that don't have their own) document_tags: Optional list of tags applied to all items in this batch (merged with per-item tags) retain_async: If True, process asynchronously in background (default: False) Returns: RetainResponse with success status and item count )rrrrr)r( aretain_batch)rTrrrrrs r'rzHindsight.retain_batch*s=.   '+)      rWrnfiles_metadatac8g}|D]?}t|}||j|f@|p fd|D}t jd|i} t |j||| |j S)u Upload files and retain their contents as memories (sync wrapper). Files are automatically converted to text (PDF, DOCX, images via OCR, audio via transcription, and more) and ingested as memories. Processing is always asynchronous — use the returned operation IDs to track progress. Args: bank_id: The memory bank ID files: List of file paths to upload context: Optional context description applied to all files files_metadata: Optional per-file metadata list. If provided, must match the length of `files`. Each entry can have: context, document_id, tags, metadata. Returns: FileRetainResponse with operation_ids for tracking progress c g|] }rdini S)rrr).0_rs r' z*Hindsight.retain_files..hs(!Y!Y!Ya'"I9g"6"6r!Y!Y!YrWr)rrnrequest_request_timeout) rappendname read_bytesjsondumpsr(rI file_retainr;) rTrrnrr file_data file_pathpathmeta request_bodys ` r' retain_fileszHindsight.retain_filesKs0  = =I ??D   di):):; < < < <Y!Y!Y!Y!YSX!Y!Y!Yz#3T":;; $/55gY`l@D@M5NNOO OrWmid anyquerytypes max_tokensbudgettracequery_timestampinclude_entitiesmax_entity_tokensinclude_chunksmax_chunk_tokensinclude_source_factsmax_source_facts_tokens tags_match)rall any_strict all_strict tag_groupscft|||||||||| | | | | |||S)uS Recall memories using semantic similarity (sync wrapper — prefer :meth:`arecall` in async code). Args: bank_id: The memory bank ID query: Search query types: Optional list of fact types to filter (world, experience, opinion, observation) max_tokens: Maximum tokens in results (default: 4096) budget: Budget level for recall - "low", "mid", or "high" (default: "mid") trace: Enable trace output (default: False) query_timestamp: Optional ISO format date string (e.g., '2023-05-30T23:40:00') include_entities: Include entity observations in results (default: False) max_entity_tokens: Maximum tokens for entity observations (default: 500) include_chunks: Include raw text chunks in results (default: False) max_chunk_tokens: Maximum tokens for chunks (default: 8192) include_source_facts: Include source facts for observation-type results (default: False) max_source_facts_tokens: Maximum tokens for source facts (default: 4096) tags: Optional list of tags to filter memories by tags_match: How to match tags - "any" (OR, includes untagged), "all" (AND, includes untagged), "any_strict" (OR, excludes untagged), "all_strict" (AND, excludes untagged). Default: "any" tag_groups: Optional list of tag group filters for advanced boolean tag matching. Returns: RecallResponse with results, optional entities, optional chunks, optional source_facts, and optional trace )rrrrrrrrrrrrrrrr)r(arecall)rTrrrrrrrrrrrrrrrrs r'recallzHindsight.recallns]X LL% /!1"3-!1%9(?%%!      rWlowresponse_schema include_facts fact_typesexclude_mental_modelsexclude_mental_model_idsc`t|||||||||| | | | |  S)u Generate a contextual answer based on bank identity and memories (sync wrapper — prefer :meth:`areflect` in async code). Args: bank_id: The memory bank ID query: The question or prompt budget: Budget level for reflection - "low", "mid", or "high" (default: "low") context: Optional additional context max_tokens: Maximum tokens for the response (server default: 4096) response_schema: Optional JSON Schema for structured output. When provided, the response will include a 'structured_output' field with the LLM response parsed according to this schema. tags: Optional list of tags to filter memories by tags_match: How to match tags - "any" (OR, includes untagged), "all" (AND, includes untagged), "any_strict" (OR, excludes untagged), "all_strict" (AND, excludes untagged). Default: "any" include_facts: If True, the response will include a 'based_on' field listing the memories, mental models, and directives used to construct the answer. tag_groups: Optional list of tag group filters for advanced boolean tag matching. fact_types: Optional list of fact types to include (world, experience, observation). exclude_mental_models: If True, exclude all mental models from reflection (default: False). exclude_mental_model_ids: Optional list of specific mental model IDs to exclude. Returns: ReflectResponse with answer text, optionally facts used, and optionally structured_output if response_schema was provided ) rrrrrrrrrrrrr)r(areflect)rTrrrrrrrrrrrrrs r'reflectzHindsight.reflectsTT MM% /%+%%&;)A      rWdrtype search_querylimitoffsetc ft|j||||||jS)urList memory units with pagination (sync wrapper — use ``await client.memory.list_memories(...)`` in async code).)rrqrrr)r(rA list_memoriesr;)rTrrrrrs r'rzHindsight.list_memoriessE   * *!% +     rWrmissiondisposition_skepticismdisposition_literalismdisposition_empathy dispositionretain_missionretain_extraction_moderetain_custom_instructionsretain_chunk_sizeenable_observationsobservations_missionreflect_mission backgroundcdt||||||||||| | | | | |S)uCreate or update a memory bank (sync wrapper — prefer :meth:`acreate_bank` in async code). Args: bank_id: Unique identifier for the bank name: Deprecated. Display label only. mission: Deprecated. Use reflect_mission instead. disposition_skepticism: Deprecated. Use update_bank_config(disposition_skepticism=...) instead. disposition_literalism: Deprecated. Use update_bank_config(disposition_literalism=...) instead. disposition_empathy: Deprecated. Use update_bank_config(disposition_empathy=...) instead. disposition: Deprecated. Use update_bank_config(disposition_skepticism=...) instead. retain_mission: Steers what gets extracted during retain(). Injected alongside built-in rules. retain_extraction_mode: Fact extraction mode: 'concise' (default), 'verbose', or 'custom'. retain_custom_instructions: Custom extraction prompt (only active when mode is 'custom'). retain_chunk_size: Maximum token size for each content chunk during retain. enable_observations: Toggle automatic observation consolidation after retain(). observations_mission: Controls what gets synthesised into observations. Replaces built-in rules. reflect_mission: Mission/context for Reflect operations. background: Optional background context for the bank. rrrrrrrrrrrrrr)r( _acreate_bankrTrrrrrrrrrrrrrrrs r' create_bankzHindsight.create_banks\J    /'='=$7'-'=+E"3$7%9%      rWc Kddl}i}|||d<|||d<|||d<|||d<|||d<n||d|d<|||d<n||d |d<|||d <n||d |d <| | |d <| | |d <| | |d<| | |d<| | |d<|||d<|jd|}|jr dd|jini}|4d{V}||||||j4d{V }|| d{V}tj |cdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS)Nrrrrrr skepticismr literalismrempathyrrrrrr/v1/default/banks/r4r5totalrheadersr.) aiohttpgetr=r> ClientSessionput ClientTimeoutr;raise_for_statusrrmodel_validate)rTrrrrrrrrrrrrrrrrbodyurlrsessionrespdatas r'rzHindsight._acreate_bank8s$ !  DL  %DO  &&5D" #  !!+D  ! --CD) * *  $-8__\-J-JD) * ! --CD) * *  $-8__\-J-JD) *  **=D& ' '  $*5//)*D*DD& '  %%3D! " ! --CD) * % 11KD- .  ((9D$ %  **=D& '  ++?D' (<<7<<BF-W?$=dm$=$=>>UW((** @ @ @ @ @ @ @g{{$9N9NUYUb9N9c9c# @ @ @ @ @ @ @ @%%'''!YY[[((((((*9$??  @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @s709F6*AF,F6 F F6F F66 GGc0|||S)@Deprecated. Use update_bank_config(reflect_mission=...) instead.r)rrTrrs r' set_missionzHindsight.set_missionys999rWc.|||S)z#Deprecated alias for set_mission().)rrTrrs r'set_reflect_missionzHindsight.set_reflect_mission}s999rWcZK||||||||||| | | | | |d{VS)uCreate or update a memory bank (async — preferred over :meth:`create_bank`). Args: bank_id: Unique identifier for the bank name: Deprecated. Display label only. mission: Deprecated. Use reflect_mission instead. disposition_skepticism: Deprecated. Use update_bank_config(disposition_skepticism=...) instead. disposition_literalism: Deprecated. Use update_bank_config(disposition_literalism=...) instead. disposition_empathy: Deprecated. Use update_bank_config(disposition_empathy=...) instead. disposition: Deprecated. Use update_bank_config(disposition_skepticism=...) instead. retain_mission: Steers what gets extracted during retain(). Injected alongside built-in rules. retain_extraction_mode: Fact extraction mode: 'concise' (default), 'verbose', or 'custom'. retain_custom_instructions: Custom extraction prompt (only active when mode is 'custom'). retain_chunk_size: Maximum token size for each content chunk during retain. enable_observations: Toggle automatic observation consolidation after retain(). observations_mission: Controls what gets synthesised into observations. Replaces built-in rules. reflect_mission: Mission/context for Reflect operations. background: Optional background context for the bank. rN)rrs r' acreate_bankzHindsight.acreate_banksqJ'' +#9#9 3#)#9'A/ 3!5!(         rWc@K|||d{VS)rrN)rrs r' aset_missionzHindsight.aset_missions1&&w&@@@@@@@@@rWc>K|||d{VS)z$Deprecated alias for aset_mission().N)rrs r'aset_reflect_missionzHindsight.aset_reflect_missions.&&w@@@@@@@@@rWcKddlmddlm}ddlm}g}|D]'} d} | drfd| dD} | d} | || nd} d} | d || d  } |tj | d | | d | d | dp|| | d| | d| d )tj |||}|j |||jd{VS)u( Store multiple memories in batch (async — preferred over :meth:`retain_batch`). Args: bank_id: The memory bank ID items: List of memory items, each a dict with 'content' (required) and optional keys: 'timestamp', 'context', 'metadata', 'document_id', 'entities', 'tags', 'observation_scopes' (str or list[list[str]]), 'strategy'. document_id: Optional document ID for grouping memories (applied to items that don't have their own) document_tags: Optional list of tags applied to all items in this batch (merged with per-item tags) retain_async: If True, process asynchronously in background (default: False) Returns: RetainResponse with success status and item count r) EntityInput)ObservationScopes) TimestampNrbc\g|](}|d|d)S)textr)r r)r)rers r'rz+Hindsight.aretain_batch..s7fffPQKKQvYQUU6]]KKKfffrWr)actual_instanceobservation_scopesrrrrrstrategyr) rrrrrrbrr rr)r var_asyncrr)(hindsight_client_api.models.entity_inputr.hindsight_client_api.models.observation_scopesr%hindsight_client_api.models.timestamprrrr MemoryItemr RetainRequestrAretain_memoriesr;)rTrrrrrrr memory_itemsrrbraw_ts timestamp_val obs_scopes request_objrs @r'rzHindsight.aretain_batchs. IHHHHHTTTTTTCCCCCC   DHxx ## gffffUYZdUefffXXk**FAGASIIf====Y]MJxx,--9..tDX?YZZZ   & O+ HHY//!XXj11 $ 7 7 F;%&))'1!XXj11 $ 7 7        %2"'   %55g{]a]j5kkkkkkkkkrWc fK||||||d} | | | d<||| g|| d{VS)u Store a single memory (async — preferred over :meth:`retain`). Args: bank_id: The memory bank ID content: Memory content timestamp: Optional event timestamp context: Optional context description document_id: Optional document ID for grouping metadata: Optional user-defined metadata entities: Optional list of entities [{"text": "...", "type": "..."}] tags: Optional list of tags for filtering memories during recall/reflect update_mode: How to handle existing documents ('replace' or 'append') retain_async: If True, process asynchronously in background (default: False) Returns: RetainResponse with success status rNrr)rrs r'aretainzHindsight.aretains@"       ""-D ''&#% (         rWc Kddlm}m}m}m}||r|| nd| r|| nd| r|| nd}d}|ddl m fd|D}tj |||||||||| }|j |||j d{VS) u< Recall memories using semantic similarity (async — preferred over :meth:`recall`). Args: bank_id: The memory bank ID query: Search query types: Optional list of fact types to filter (world, experience, opinion, observation) max_tokens: Maximum tokens in results (default: 4096) budget: Budget level for recall - "low", "mid", or "high" (default: "mid") trace: Enable trace output (default: False) query_timestamp: Optional ISO format date string (e.g., '2023-05-30T23:40:00') include_entities: Include entity observations in results (default: False) max_entity_tokens: Maximum tokens for entity observations (default: 500) include_chunks: Include raw text chunks in results (default: False) max_chunk_tokens: Maximum tokens for chunks (default: 8192) include_source_facts: Include source facts for observation-type results (default: False) max_source_facts_tokens: Maximum tokens for source facts (default: 4096) tags: Optional list of tags to filter memories by tags_match: How to match tags - "any" (OR, includes untagged), "all" (AND, includes untagged), "any_strict" (OR, excludes untagged), "all_strict" (AND, excludes untagged). Default: "any" tag_groups: Optional list of tag group filters for advanced boolean tag matching. Each element is a dict representing a tag group node (TagGroupLeaf, TagGroupAnd, TagGroupOr, or TagGroupNot). Example:: [{"tags": ["customer"], "match": "all"}, {"not": {"tags": ["internal"]}}] Returns: RecallResponse with results, optional entities, optional chunks, optional source_facts, and optional trace r)chunk_include_optionsentity_include_optionsinclude_optionssource_facts_include_options)rN)rbchunks source_factsRecallRequestTagGroupsInnerc:g|]}|Srr from_dictrtgr&s r'rz%Hindsight.arecall..t(^^^R:DDRHH^^^rW) rrrrrrincluderrrr)hindsight_client_api.modelsrr r!r"IncludeOptionsEntityIncludeOptionsChunkIncludeOptionsSourceFactsIncludeOptions;hindsight_client_api.models.recall_request_tag_groups_innerr&r RecallRequestrArecall_memoriesr;)rTrrrrrrrrrrrrrrrrrr r!r" include_optstag_groups_objsrr&s @r'rzHindsight.arecall/sk`            '55+@@L]@^^^]ku(<.r,rW) rrrrrrrr-rrrrr)rr3r&rReflectRequestrArr;)rTrrrrrrrrrrrrrr-r7rr&s @r'rzHindsight.areflectsT6CL'b1111  ! o o o o o o^^^^S]^^^O%4!+!&!"7"?4%=    %--g{UYUb-cccccccccrW source_querytriggeridcddlm}m} d} |r | jdi|} ||||||| } t |j|| |jS)u Create a mental model (sync wrapper — use ``await client.mental_models.create_mental_model(...)`` in async code). Args: bank_id: The memory bank ID name: Human-readable name for the mental model source_query: The query to run to generate content tags: Optional tags for filtering during retrieval max_tokens: Optional maximum tokens for the mental model content trigger: Optional trigger settings (e.g., {"refresh_after_consolidation": True}) id: Optional custom ID for the mental model (alphanumeric lowercase with hyphens) Returns: CreateMentalModelResponse with operation_id r)create_mental_model_requestmental_model_trigger_inputN)r>rr<rrr=rrr) r.r@rAMentalModelTriggerInputCreateMentalModelRequestr(rEcreate_mental_modelr;) rTrrr<rrr=r>r@rA trigger_objrs r'rDzHindsight.create_mental_models2 hggggggg  XL4LWWwWWK1JJ%! K  $1EEg{mqmzE{{|||rWc`t|j|||jS)u5 List all mental models in a bank (sync wrapper — use ``await client.mental_models.list_mental_models(...)`` in async code). Args: bank_id: The memory bank ID tags: Optional tags to filter by Returns: ListMentalModelsResponse with items rr)r(rElist_mental_modelsr;rTrrs r'rHzHindsight.list_mental_modelss/$1DDWSWjnjwDxxyyyrWmental_model_idc`t|j|||jS)u" Get a specific mental model (sync wrapper — use ``await client.mental_models.get_mental_model(...)`` in async code). Args: bank_id: The memory bank ID mental_model_id: The mental model ID Returns: MentalModelResponse r)r(rEget_mental_modelr;rTrrJs r'rLzHindsight.get_mental_models.$1BB7Onrn{B||}}}rWc`t|j|||jS)u: Refresh a mental model (sync wrapper — use ``await client.mental_models.refresh_mental_model(...)`` in async code). Args: bank_id: The memory bank ID mental_model_id: The mental model ID Returns: RefreshMentalModelResponse with operation_id r)r(rErefresh_mental_modelr;rMs r'rOzHindsight.refresh_mental_models>$1FFwP_rvrFAABB BrWcddlm}m} d} |r |jdi|} | ||||| } t |j||| |jS)u3 Update a mental model's metadata (sync wrapper — use ``await client.mental_models.update_mental_model(...)`` in async code). Args: bank_id: The memory bank ID mental_model_id: The mental model ID name: Optional new name source_query: Optional new source query tags: Optional new tags max_tokens: Optional new max tokens trigger: Optional trigger settings (e.g., {"refresh_after_consolidation": True}) Returns: MentalModelResponse r)rAupdate_mental_model_requestN)rr<rrr=rrr) r.rArQrBUpdateMentalModelRequestr(rEupdate_mental_modelr;) rTrrJrr<rrr=rArQrErs r'rSzHindsight.update_mental_models2 hggggggg  XL4LWWwWWK1JJ%! K  $1EEg`kCLEMMNN NrWc`t|j|||jS)u Delete a mental model (sync wrapper — use ``await client.mental_models.delete_mental_model(...)`` in async code). Args: bank_id: The memory bank ID mental_model_id: The mental model ID r)r(rEdelete_mental_modelr;rMs r'rUzHindsight.delete_mental_modelDs7$1EEgquq~EAA ArWc`t|j|||jS)u Get the content change history of a mental model (sync wrapper — use ``await client.mental_models.get_mental_model_history(...)`` in async code). Returns a list of history entries (most recent first), each with ``previous_content`` and ``changed_at`` fields. Args: bank_id: The memory bank ID mental_model_id: The mental model ID r)r(rEget_mental_model_historyr;rMs r'rWz"Hindsight.get_mental_model_historyNsB$1JJ7TcvzwDJEEFF FrWTpriority is_activecddlm}||||||}t|j|||jS)u Create a directive (sync wrapper — use ``await client.directives.create_directive(...)`` in async code). Args: bank_id: The memory bank ID name: Human-readable name for the directive content: The directive content/rules priority: Priority level (higher = injected first) is_active: Whether the directive is active tags: Optional tags for filtering Returns: DirectiveResponse r)create_directive_requestrrrXrYrr)r.r[CreateDirectiveRequestr(rGcreate_directiver;) rTrrrrXrYrr[rs r'r^zHindsight.create_directive]sm. IHHHHH.EE F  $.??gkgt?uuvvvrWc`t|j|||jS)u* List all directives in a bank (sync wrapper — use ``await client.directives.list_directives(...)`` in async code). Args: bank_id: The memory bank ID tags: Optional tags to filter by Returns: ListDirectivesResponse with items rG)r(rGlist_directivesr;rIs r'r`zHindsight.list_directivess.$.>>wTdhdq>rrsssrW directive_idc`t|j|||jS)u Get a specific directive (sync wrapper — use ``await client.directives.get_directive(...)`` in async code). Args: bank_id: The memory bank ID directive_id: The directive ID Returns: DirectiveResponse r)r(rG get_directiver;rTrras r'rczHindsight.get_directives.$.<rrrr;rrrTrrrrrrs r'rlzHindsight._aget_bank_configsjCC7CCCBF-W?$=dm$=$=>>UW((** ) ) ) ) ) ) )g{{3AVAV]a]jAVAkAk{ll ) ) ) ) ) ) )pt%%'''!YY[[(((((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )68C3;.C)C3 C C3C C33 C=C=)rreflect_source_facts_max_tokensrrrrretain_default_strategyretain_strategies entity_labelsentities_allow_free_formrrconsolidation_llm_batch_size%consolidation_source_facts_max_tokens5consolidation_source_facts_max_tokens_per_observationrrrmcp_enabled_toolsllm_gemini_safety_settingsrtrurvrwrxryrzr{r|r}cdid|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|d||||dD}t|||S)u Update configuration overrides for a bank (sync wrapper — use ``await client.banks.update_bank_config(...)`` in async code). Can be disabled on the server by setting ``HINDSIGHT_API_ENABLE_BANK_CONFIG_API=false``. Args: bank_id: The memory bank ID reflect_mission: Identity and reasoning framing for reflect(). reflect_source_facts_max_tokens: Token budget for source facts in observation search during reflect. -1 to disable (default: -1). retain_mission: Steers what gets extracted during retain(). retain_extraction_mode: Fact extraction mode: 'concise', 'verbose', or 'custom'. retain_custom_instructions: Custom extraction prompt (only active when mode is 'custom'). retain_chunk_size: Maximum token size for each content chunk during retain. retain_default_strategy: Default retain strategy name. retain_strategies: Named strategy definitions (dict of strategy name to config). entity_labels: Controlled vocabulary for entity type classification. When set, extracted entities are classified into these labels. entities_allow_free_form: Whether to allow entity types outside entity_labels (default: True). enable_observations: Toggle automatic observation consolidation after retain(). observations_mission: Controls what gets synthesised into observations. consolidation_llm_batch_size: Number of LLM calls to batch during consolidation. consolidation_source_facts_max_tokens: Max tokens for source facts across all observations in a consolidation pass. consolidation_source_facts_max_tokens_per_observation: Max tokens of source facts per individual observation in the consolidation prompt. disposition_skepticism: How skeptical vs trusting (1=trusting, 5=skeptical). disposition_literalism: How literally to interpret information (1=flexible, 5=literal). disposition_empathy: How much to consider emotional context (1=detached, 5=empathetic). mcp_enabled_tools: List of MCP tool names to enable for this bank. llm_gemini_safety_settings: Gemini/VertexAI safety setting overrides (category → threshold). Returns: dict with ``bank_id``, ``config`` (fully resolved), and ``overrides`` (bank-level only) ci|] \}}||| SNrr)rkvs r' z0Hindsight.update_bank_config..$s/   1,}/ q.}}rWrrtrrrrrurvrwrxrrryrzr{rr)rr|r})rr(_aupdate_bank_config)rTrrrtrrrrrurvrwrxrrryrzr{rrrr|r}updatess r'update_bank_configzHindsight.update_bank_configs?F  !?13R!.)*@  -.H  $%6 *+B$%6 +,D&':'(</0L89^HI~ )*@!")*@#$(;%6.H)*egg/   4$33GWEEFFFrWrc Kddl}|jd|d}|jr dd|jini}|4d{V}||d|i|||j4d{V }||d{Vcdddd{Vcdddd{VS#1d{VswxYwY dddd{VdS#1d{VswxYwYdS) Nrrrqr4r5rrr) rr=r>rpatchrr;rr)rTrrrrrrrs r'rzHindsight._aupdate_bank_config@s~CC7CCCBF-W?$=dm$=$=>>UW((** ) ) ) ) ) ) )g}}9g.I^I^eierI^IsIs% ) ) ) ) ) ) ) )%%'''!YY[[((((((  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s6;C7?.C-C7 C C7C C77 DDcFt||S)u Reset all bank-level config overrides (sync wrapper — use ``await client.banks.reset_bank_config(...)`` in async code). Can be disabled on the server by setting ``HINDSIGHT_API_ENABLE_BANK_CONFIG_API=false``. Args: bank_id: The memory bank ID Returns: dict with ``bank_id``, ``config`` (fully resolved), and ``overrides`` (now empty) )r(_areset_bank_configrms r'reset_bank_configzHindsight.reset_bank_configLs $227;;<<rdeleterr;rrrrs r'rzHindsight._areset_bank_configZsjCC7CCCBF-W?$=dm$=$=>>UW((** ) ) ) ) ) ) )g~~c7GDYDY`d`mDYDnDn~oo ) ) ) ) ) ) )sw%%'''!YY[[(((((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )rsc^t|j||jS)u Delete a memory bank (sync wrapper — prefer :meth:`adelete_bank` in async code). Args: bank_id: The memory bank ID r)r(rC delete_bankr;rms r'rzHindsight.delete_bankds+$/55gPTP]5^^___rWcTK|j||jd{VS)u Delete a memory bank (async — preferred over :meth:`delete_bank`). Args: bank_id: The memory bank ID rN)rCrr;rms r' adelete_bankzHindsight.adelete_bankms7_004=0YYYYYYYYYrW)Nr+N)NNNNNNNF)NNF)NN)NrrFNFrFrFrNrN) rNNNNrFNNFN)NNrr)NNNNNNNNNNNNNN)NNNNr)NNNNN)rTN)]__name__ __module__ __qualname____doc__strfloatrVpropertyr r@r[rrBr]r rJr`r rLrbrrDrer rFrgrrNrjrrPrlr rHrnrrRrprsryrur~rdictlistboolrrrrrrrintrrrrrrrrrrrrrrrrrrrrDrHrLrOrSrUrWr^r`rcrhrjrnrlrrrrrrrrrWr'r*r*>sAAL#!% $N$N$Nt$N $N $J $N$N$N$NV ,   X y)X#=5###X#",2"""X"'0@'''X'$N8$$$X$$N8$$$X$",2"""X"y)X$N8$$$X$ 5 5 5+++&*""&*.04!%"&". . . . d? . t . 4Z . sCx.4'. tCH~&-. 3i$. 4Z. .  . . . . h#'*."    DcN# 4Z  Cy4'         J#6: !O!O!OC$J!Ot !O T#s(^,t3 !O  !O!O!O!ON#'&*!&!$$ $%*'+!%HM26#? ? ? ? Cy4 ?  ?  ? ? t? ? ? ? ? #? "%? 3i$? DE!? "c3h(4/#? $ %? ? ? ? J"!%15!%HM#26'+&+59: : : :  : t : $J : c3h$.: 3i$: DE: : c3h(4/: I$:  $: #'s)d"2:  : : : : ~ #'    Dj Dj       !    . "-1-1*./3%)-115(,+/+/&*!%!7 7 7 Dj7 t 7 !$d 7 !$d 7 !4Z7 #u*%,7 d 7 !$d 7 %($J7 :7 "D[7 "Dj7 t7 $J!7 " #7 7 7 7 x "&*-1-1*./3%)-115(,+/+/!%!?@?@?@Dj?@t ?@ t ?@ !$d ?@!$d ?@!4Z?@#u*%,?@d ?@!$d ?@%($J?@:?@"D[?@"Dj?@ $J!?@" #?@?@?@?@B:3::c3h:::::3::cSVh:::: "-1-1*./3%)-115(,+/+/&*!%!5 5 5 Dj5 t 5 !$d 5 !$d 5 !4Z5 #u*%,5 d 5 !$d 5 %($J5 :5 "D[5 "Dj5 t5 $J!5 " #5 5 5 5 nA#AAS#XAAAAA#AAPTUXZ]U]P^AAAA#'*." ;l;l;lDcN#;l4Z ;l Cy4' ;l  ;l ;l;l;l;lB&*""&*.04!%"&". . . . d? . t . 4Z . sCx.4'. tCH~&-. 3i$. 4Z. .  . . . . h#'&*!&!$$ $%*'+!%HM26#TlTlTlTlCy4 Tl  Tl  TlTltTlTlTlTlTl#Tl"%Tl3i$Tl DE!Tl"c3h(4/#Tl$ %TlTlTlTlt"!%15!%HM#26'+&+59AdAdAdAd Ad t Ad $J Adc3h$.Ad3i$AdDEAdAdc3h(4/AdI$Ad $Ad#'s)d"2Ad AdAdAdAdT"&!%)-(}(}(}(} (} 3i$ (} $J (}c3h$&(} $J(}(}(}(}T z z# zT#Y5E z z z z ~ ~c ~ ~ ~ ~ BC B# B B B B" #'!%!%)-'N'N'N'NDj 'N Dj 'N 3i$ 'N$J'Nc3h$&'N'N'N'NRA3AAAAA F Fc F F F F(!%!w!w!w!w !w  !w  !w3i$!w!w!w!wF t ts t$s)d2B t t t t uS u u u u u" "#!%!%#E#E#E#EDj #E t #E * #E$;#E3i$#E#E#E#EJxx3xxxx ;s ;tCH~ ; ; ; ;)s)tCH~))))'+6:%)-115(,.237*.04+/+/37<@LP-1-1*..2<@=]G]G]G]G t ]G *-t ]Gd ]G!$d ]G%($J]G:]G"%t]G S>D0]GCy4']G #'+!]G$"D[%]G&"Dj']G('*Dj)]G*03Tz+]G,@CTz-]G0!$d 1]G2!$d 3]G4!4Z5]G8 9t+9]G<%)cNT$9=]G> c3h?]G]G]G]G~ )# )S#X )SWX[]`X`Sa ) ) ) ) = =c3h = = = =))c3h))))`3````Z#ZZZZZZrWr*)2rrrr importlibrpathlibrtypingrrr6version_CLIENT_VERSIONPackageNotFoundErrorr:hindsight_client_api.apirr r r r r rrrrr.rrrr3hindsight_client_api.models.reflect_include_optionsr1hindsight_client_api.models.bank_profile_responser0hindsight_client_api.models.file_retain_responser6hindsight_client_api.models.list_memory_units_responser+hindsight_client_api.models.recall_responser)hindsight_client_api.models.recall_resultr,hindsight_client_api.models.reflect_responser+hindsight_client_api.models.retain_responserr(r*rrrWr'rsk &h&'9::OO$OOOBAA                         VUUUUUQQQQQQOOOOOOZZZZZZFFFFFFBBBBBBHHHHHHFFFFFF)))vZvZvZvZvZvZvZvZvZvZs; A  A