$jH dZddlZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z m Z ddl mZmZmZmZmZmZmZmZmZddlmZmZddlmZd e d eee ffd Zdd l mZdd l m!Z!m"Z"m#Z#m$Z$m%Z%ddl&m'Z'ded e fdZ(ddl)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/ddl0m1Z1ddl2m3Z3m4Z4m5Z5ddl6m7Z7m8Z8ddlm9Z9m:Z:m;Z;ddlZ>m?Z?ddl@mAZAejBeCZDGdde!ZEGdde!ZFGdde!ZGGdd e!ZHGd!d"e!ZIGd#d$e!ZJGd%d&e!ZKGd'd(e!ZLGd)d*e!ZMGd+d,e!ZNGd-d.e!ZOGd/d0e!ZPGd1d2e!ZQGd3d4e!ZRGd5d6e!ZSGd7d8e!ZTGd9d:e!ZUGd;de!ZWGd?d@e!ZXGdAdBe!ZYGdCdDe!ZZGdEdFe!Z[GdGdHe!Z\GdIdJe!Z]GdKdLe!Z^GdMdNe!Z_GdOdPe!Z`GdQdRe!ZaGdSdTe!ZbGdUdVe!ZcGdWdXe!ZdGdYdZe!ZeGd[d\e!ZfGd]d^e!ZgGd_d`e!ZhGdadbe!ZiGdcdde!ZjGdedfe!ZkGdgdhe!ZlGdidje!ZmGdkdle!ZnGdmdne!ZoGdodpe!ZpGdqdre!ZqGdsdte!ZrGdudve!ZsGdwdxe!ZtGdydze!ZuGd{d|e!ZvGd}d~e!ZwGdde!ZxGdde!ZyGdde!ZzGdde!Z{Gdde!Z|Gdde!Z}Gdde!Z~Gdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZGdde!ZdZGdde!ZGdde!ZGdde!ZGdde!ZGdde!Zddd eefdZdeddddd dfdZGdde!ZGdde!ZGdde!ZGd„de!ZGdĄde!ZGdƄde!ZGdȄde!ZGdʄde!ZGd̄de!ZGd΄de!ZddlmZGdфde!ZGdӄde!ZGdՄde!ZGdׄde!ZGdلde!ZGdۄde!ZdegedzffdބZ dde'dede9dzd efdZdefdZdS)z FastAPI application factory and API routes for memory system. This module provides the create_app function to create and configure the FastAPI application with all API endpoints. N)asynccontextmanager)datetimetimezone)AnyLiteral) DependsFastAPIFileFormHeader HTTPExceptionQueryRequest UploadFile) AuditEntry AuditLogger)AuthenticationErrormetadatareturnc|iSt|tr|St|tr, tj|S#tj$ricYSwxYwiS)z8Parse metadata that may be a dict, JSON string, or None.) isinstancedictstrjsonloadsJSONDecodeError)rs ^/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/hindsight_api/api/http.py_parse_metadatarsw (D!!(C   :h'' '#   III  IsAAACallable) BaseModel ConfigDictFieldfield_validatormodel_validator) MemoryEnginedefault_factoryc |turg}n|turi}ni}|di}t|tr||d<nd|i}t d||d|S)aj Field wrapper that ensures default_factory values appear in OpenAPI schema. Pydantic doesn't include default_factory in OpenAPI schemas, causing OpenAPI Generator to make fields Optional with default=None instead of non-optional with the correct default value. This wrapper adds json_schema_extra to include the default in the schema. json_schema_extradefault)r'r))listrpoprr#)r'kwargsschema_default json_extras rFieldWithDefaultr1,s$ D /44J*d##1 . 9 0  YJ Y YRX Y YY get_config)Budget_current_schema_get_tiktoken_encodingfq_table)LLMNotAvailableError)VALID_RECALL_FACT_TYPES MemoryFact TokenUsage)TagGroup TagsMatch) HttpExtensionOperationValidationErrorload_extension)create_metrics_collectorget_metrics_collectorinitialize_metrics)RequestContextc8eZdZUdZeddZeed<dS)EntityIncludeOptionszrur=r$ classmethodr}r%rr+r2rrara~s_,,: E!<0"#8&s(;<! #    L JJJ#eME49t ZFFJE4"'%"X###OS4Z/.^G^#U[D$s)d "EWJ  ).`)))JX% _W[_'"""#"r2racleZdZUdZdddddddgd d d d d d d idddgd idZeed<eed<dZedzed<dZe edzed<dZ edzed<dZ edzed<dZ edzed<dZ edzed<dZedzed<dZeeefdzed<dZedzed<dZe edzed<dZe edzed <dS)! RecallResultzSingle recall result item.Trb$123e4567-e89b-12d3-a456-426614174000$Alice works at Google on the AI teamrdAliceGoogle work info2024-01-15T10:30:00Zsession_abc123sourceslack$456e7890-e12b-34d5-a678-901234567890rguser_b) idtexttyper]contextoccurred_start occurred_end mentioned_at document_idrchunk_idropopulate_by_namer)rrNrr]rrrrrrrrosource_fact_ids)rMrNrOrPrrrRrr]r,rrrrrrrrrorr+r2rrrs$$! <>$h/&"8 6 6/%w/B!8,   L( GGG IIID#*!%Hd3i$%%%GS4Z!%NC$J%%%#L#*####L#*###"Kt"""&*Hd38nt#***HcDj!D$s)d !!! T#Y%r2rc2eZdZUdZeed<dZedzed<dS)EntityObservationResponsezAn observation about an entity.rNr)rMrNrOrPrrRrr+r2rrrs5)) III#L#*#####r2rc>eZdZUdZeed<eed<eeed<dS)EntityStateResponsez"Current mental model of an entity. entity_idcanonical_name observationsN)rMrNrOrPrrRr,rr+r2rrrs?,,NNN0111111r2rc eZdZUdZedddddddi Zeed <eed <eed <d Z ed zed<d Z ed zed<d Z e ee fd zed<d S)EntityListItemzEntity list item with summary.rbrJohnr2024-02-01T14:00:00Zrr mention_count first_seen last_seenrqrrrNrrr)rMrNrOrPr"rrrRrQrrrrrr+r2rrrs((: <"(!#43     L GGG!Jd !!! IsTz   &*Hd38nt#*****r2rc |eZdZUdZedddddddgd d d d i Zeeed<e ed<e ed<e ed<dS)EntityListResponsez(Response model for entity list endpoint.rbrrrrrrdritemstotallimitoffsetrqrrrrN) rMrNrOrPr"rr,rrRrQr+r2rrr s22: E*0)+&<%;    L&   JJJ JJJ KKKKKr2rceZdZUdZedddddddidd d d ddigdd dd d dddddigddddiZeeee fe d<eeee fe d<e e d<e e d<e e d<dS)EntityGraphResponsez7Response model for entity co-occurrence graph endpoint.rbdatazuuid-1r z#42a5f5)rlabel mentionCountcolorzuuid-2rz uuid-1-uuid-2 cooccurrencez#ffd700solidr)rrtargetlinkTypeweightr lineStylelastCooccurredrx)nodesedgestotal_entities total_edgesrrqrrrrrN rMrNrOrPr"rr,rrrrRrQr+r2rrr)sAA: HwPR]fgghHxQR]fggh "1&.&.(6&'%.)0.D ! !  #$ + L8 S#X  S#X  JJJJJr2rc eZdZUdZeddddddddd gd i Zeed <eed <eed<dZ edzed<dZ edzed<dZ e ee fdzed<eeed<dS)EntityDetailResponsez*Response model for entity detail endpoint.rbrrrrrzJohn works at Googlerr)rrrrrrrqrrrNrrrr)rMrNrOrPr"rrrRrQrrrrrr,rr+r2rrrOs44: <"(!#43*@Rh!i!i j      L GGG!Jd !!! IsTz   &*Hd38nt#***0111111r2rcVeZdZUdZeed<eed<eed<eddZe ed<d S) ChunkDatazChunk data for a single chunk.rr chunk_indexFz8Whether the chunk text was truncated due to token limitsrI truncatedN) rMrNrOrPrrRrQr#rrr+r2rrrhsV(( GGG IIIeE7qrrrItrrrrrr2rc beZdZUdZeddddddgdd d d d gd d ddddddd dgdid d dddidiZeeed<dZ e e e fdzed<e ddZe e efdzed<e ddZe e efdzed<e dd Ze e efdzed!<dS)"RecallResponsez$Response model for recall endpoints.rbrrrdrrrrr)rrrr]rrrrrcrgrh|?)ri num_results time_secondsz$123e4567-e89b-12d3-a456-426614174001rrrrzEAlice works at Google on the AI team. She's been there for 3 years...r)rrr)resultsrlr]r^rqrNrlz/Entity states for entities mentioned in resultsrIr]z#Chunks for facts, keyed by chunk_idr^z;Source facts for observation-type results, keyed by fact IDr_)rMrNrOrPr"rr,rrRrlrrrr#r]rr^rr_r+r2rrrqs..: E F '%,h$7#.*@(>$J   J#$$) %K*1%K]stt);D g'(==7""$ &&&LP, #'E4S>D '''6;e"S777Hd3++,t3+0%Jo*p*p*pFDi 4 'ppp385"_444L$sL()D0r2rc`eZdZUdZedZeed<eddZedzed<dS) EntityInputz*Entity to associate with retained content.zThe entity name/textrrrNz7Optional entity type (e.g., 'PERSON', 'ORG', 'CONCEPT')rIr) rMrNrOrPr#rrrRrr+r2rrrsZ44"8999D#999uT7pqqqD#*qqqqqr2rc eZdZUdZedddddddd d d id d dgddgdiZeed<eddZ e ezdzed<dZ edzed<dZ e eefdzed<eddZedzed<eddZeedzed<eddZeedzed<edd !ed"Zedd#d$%Zed&eeezdzed'<edd(Zedzed)<edd*Zed+dzed,<edd !ed-ZdS). MemoryItemzSingle memory item for retain.rbz/Alice mentioned she's working on a new ML modelrz team meetingr engineeringrchannelmeeting_notes_2024_01_15rrzML modelCONCEPTrrrgr)content timestamprrrr]rorqrNaWhen the content occurred. Accepts an ISO 8601 datetime string (e.g. '2024-01-15T10:30:00Z'), null/omitted (defaults to now), or the special string 'unset' to explicitly store without any timestamp (use this for timeless content such as fictional documents or static reference material).rIrrrz*Optional document ID for this memory item.rz:Optional entities to combine with auto-extracted entities.r]zWOptional tags for visibility scoping. Memories with tags can be filtered during recall.robeforerct|trL tj|}t|tr|Sn#tjt f$rYnwxYw|gS|S)aNCoerce JSON-string tags to list. MCP tool bridges sometimes serialize JSON arrays as strings during transport, e.g. '["a", "b"]' instead of ["a", "b"]. This validator parses such strings back into lists so the retain call succeeds. A plain non-JSON string is wrapped in a single-element list. )rrrrr,r TypeError)r|rvparseds r coerce_tagszMemoryItem.coerce_tagssx a    Afd++"!M"()4    3Js*AAAObservationScopesa<How to scope observations during consolidation. 'per_tag' runs one consolidation pass per individual tag, creating separate observations for each tag. 'combined' (default) runs a single pass with all tags together. A list of tag lists runs one pass per inner list, giving full control over which combinations to use.)r*titlerJ)per_tagcombinedall_combinationsobservation_scopeszNamed retain strategy for this item. Overrides the bank's default strategy for this item only. Strategies are defined in the bank config under 'retain_strategies'.strategyzHow to handle an existing document with the same document_id. 'replace' (default) deletes old data and reprocesses from scratch. 'append' concatenates new content to the existing document text and reprocesses.)replaceappend update_modec||dkrdSt|tr|St|tri|dkrdS tj|ddS#t $r}t d|d|d}~wwxYwt dt|j)NunsetZ+00:00z&Invalid timestamp/event_date format: 'z'. Expected ISO format like '2024-01-15T10:30:00' or '2024-01-15T10:30:00Z', or the special value 'unset' to store without a timestamp.z,timestamp must be a string or datetime, got ) rrrlower fromisoformatrr{rrM)r|rves rvalidate_timestampzMemoryItem.validate_timestamps 9R4 a " " H a   wwyyG##w -aiiX.F.FGGG    HQHHH ZQHXZZ[[[s'A:: BBB)rMrNrOrPr"rrrRr#rrrrrrr]r,rror$rrrrrrrr+r2rrrs((: L3)'.=II9$g.Y0W0WX!8,     LLLL',u h(((Ix#~$GS4Z&*Hd38nt#***#eD>jkkkKtkkk).P***Hd;$&#UmD$s)d  _V(+++[,+$glfk! t g g g IJTRVWZR[_\_cc   !5OHcDj 8=u[888K,-4_[x000\\[10\\\r2rceZdZUdZeddddddddd gd d i Zeeed <e d ddZ e ed<e dddZ ee dzed<dS) RetainRequestz"Request model for retain endpoint.rbAlice works at Googleworkconversation_123)rrrzBob went hiking yesterdayz2024-01-15T10:00:00Z)rrrF)rasyncrqrr z]If true, process asynchronously in background. If false, wait for completion (default: false))r*aliasrJasync_Nz(Deprecated. Use item-level tags instead.Tr*rJ deprecated document_tags)rMrNrOrPr"rr,rrRr#r rrrr+r2rrrs,,:  7F[mnn#>%;'9    L  5sFD ',e>'''M49t#r2rcheZdZUdZeddZedzed<eddZedzed<eddZ e ee fdzed <edd Z e edzed <edd Zedzed <eddZee ezdzed<eddZedzed<dS)FileRetainMetadataz2Metadata for a single file in file retain request.Nz,Document ID (auto-generated if not provided)rIrzContext for the filerzAdditional metadatarzTags for this fileroz ISO timestamprzwParser or ordered fallback chain for this file (overrides request-level parser). E.g. 'iris' or ['iris', 'markitdown'].parserzNamed retain strategy for this file. Overrides the bank's default strategy. Strategies are defined in the bank config under 'retain_strategies'.r)rMrNrOrPr#rrrRrrrrror,rrrr+r2rrr3sO<<#eD>lmmmKtmmm%:PQQQGS4ZQQQ&+eDF[&\&\&\Hd38nt#\\\"U4=QRRRD$s)d RRR!E$OLLLIsTzLLL%*U1&&&FC$s)Od " !5OHcDjr2rceZdZUdZeddddgddddgd gd i Zed d Zee ezd ze d<ed dZ e e d ze d<d S)FileRetainRequestz'Request model for file retain endpoint.rbiris report_2024 quarterly)rroz meeting notes markitdown)rr)rfiles_metadatarqNzDefault parser or ordered fallback chain for all files in this request. E.g. 'markitdown' or ['iris', 'markitdown']. Falls back to server default if not set. Per-file 'parser' in files_metadata takes precedence over this value.rIrzIMetadata for each file (optional, must match number of files if provided)r) rMrNrOrPr"rr#rrr,rRrrr+r2rrrGs11:  $1K=II /FL;QRR#    L&+UP&&&FC$s)Od " 7>5oFDr2r1cheZdZUdZeddZedzed<eddZe dzed<dS)ReflectIncludeOptionsz9Options for including additional data in reflect results.NzdInclude facts that the answer is based on. Set to {} to enable, null to disable (default: disabled).rIfactszcInclude tool calls trace. Set to {} for full trace (input+output), {output: false} for inputs only. tool_calls) rMrNrOrPr#r5r/rRr6r1r+r2rr4r4sCC(-z)))E  %27y222J'$.r2r4c eZdZUdZedddddiiddd id dd id d d dgddgddiZeed<ej Z eed<e dddZ edzed<e ddZ eed<e edZeed <e dd!Zedzed"<e dd#Zeedzed$<e dd%Zeed&<e dd'Zeedzed(<e dd)Zeed*dzed+<e d,d-Zeed.<e dd/Zeedzed0<ed+ed1eedzd2eedzfd3Z e!d45d7d6Z"dS)8ReflectRequestz#Request model for reflect endpoint.rbz0What do you think about artificial intelligence?lowrXr5objectrstringarray)rrsummary key_pointsr>r?)r propertiesrequiredrgrh)rirkrKrnresponse_schemarorprqrirkNzDEPRECATED: Additional context is now concatenated with the query. Pass context directly in the query field instead. If provided, it will be appended to the query for backward compatibility.TrrzMaximum tokens for the responserIrKz;Options for including additional data (disabled by default)r'rJrnzOptional JSON Schema for structured output. When provided, the response will include a 'structured_output' field with the LLM response parsed according to this schema.rBzYFilter memories by tags during reflection. If not specified, all memories are considered.rorsrprtrulFilter which fact types are retrieved during reflect. None means all types (world, experience, observation).rdre observation fact_typesFZIf true, exclude all mental models from the reflect loop (skip search_mental_models tool).exclude_mental_models;Exclude specific mental models by ID from the reflect loop.exclude_mental_model_idsrvrcN|"t|dkrtd|SNrzAfact_types must not be empty. Use null to include all fact types.lenr{r|rvs rvalidate_reflect_fact_typesz*ReflectRequest.validate_reflect_fact_types+ =SVVq[[`aa ar2r~rc@|j|jtd|Srrrs rrz&ReflectRequest.validate_tags_exclusiverr2)rr8)#rMrNrOrPr"rrrRr5LOWrkr#rrKrQr4rnrBrror,rpr>rur=rGrrIrrKr$rrQr%rr+r2rr8r8sK--: K"#R=$$*H#5/6&(AS&T&T##"+L 9 $$" # L* JJJZFF%T GS4ZeD6WXXXJXXX%*U-;x&&&G "$)5~$$$OTD[#UoD$s)d "EWJ  ).`)))JX% NSUCNNNJWABCdJ#(%p###427Q222d3i$. _\""DI,<cTAQ[#" _'"""#"r2r8c eZdZUdZeddddddddi Zd Zed zed <e d Z eed<d Z ed zed<d Z ed zed<d Z ed zed<d Zed zed<d S) ReflectFactzA fact used in think response.rbrAI is used in healthcarerdzhealthcare discussionrrrrrrrrqNrz[Fact text. When type='observation', this contains markdown-formatted consolidated knowledgerrrrrrr)rMrNrOrPr"rrrrRr#rrrrrr+r2rrVrVs((: <22"8 6      LBd qD#D#*GS4Z!%NC$J%%%#L#*#####r2rVczeZdZUdZedZeed<edZeed<edZ eed<d S) ReflectDirectivez#A directive applied during reflect.z Directive IDrrrzDirective namenamezDirective contentrN) rMrNrOrPr#rrrRr[rr+r2rrZrZ"sq--e///B///"2333D#3335%8999GS99999r2rZceZdZUdZedZeed<edZeed<edd Z edzed <dS) ReflectMentalModelz#A mental model used during reflect.zMental model IDrrrzMental model contentrNzAdditional contextrIr) rMrNrOrPr#rrrRrrr+r2rr]r]*sx--e 1222B222"8999D#999%:NOOOGS4ZOOOOOr2r]ceZdZUdZedZeed<edZe ed<edd Z e dzed <ed Z e ed <ed d Z e ed<dS)ReflectToolCallz0A tool call made during reflect agent execution.z(Tool name: lookup, recall, learn, expandrrtoolzTool input parametersinputNzBTool output (only included when include.tool_calls.output is true)rIr2Execution time in milliseconds duration_msrz4Iteration number (1-based) when this tool was called iteration)rMrNrOrPr#r`rrRrarr2rcrQrdr+r2rr_r_2s::"LMMMD#MMM%$;<<sT::#NOOOE3OOOu)IJJJKJJJJJr2rfceZdZUdZeedZeeed<eedZ ee ed<eedZ ee ed<d S) ReflectBasedOnzKEvidence the response is based on: memories, mental models, and directives.z*Memory facts used to generate the responserrmemoriesz$Mental models used during reflection mental_modelsz$Directives applied during reflection directivesN) rMrNrOrPr1r,rjrVrRrkr]rlrZr+r2rririEsUU"2"24Eq"r"r"rHd;rrr.>.>tQw.x.x.xM4*+xxx)9)9$Lr)s)s)sJ%&sssssr2ricteZdZUdZeedZeeed<eedZ ee ed<dS) ReflectTracez8Execution trace of LLM and tool calls during reflection.z!Tool calls made during reflectionrrr6z LLM calls made during reflection llm_callsN) rMrNrOrPr1r,r6r_rRrorfr+r2rrnrnMsdBB(8(8Kn(o(o(oJ_%ooo&6&6tIk&l&l&lItN#lllllr2rncZeZdZUdZedddddddd d d dgid d dgddddddddiddgdddgddddd gd!d"i#Zed$%Zee d&<ed'd()Z e d'ze d*<ed'd+)Z e d'ze d,<ed'd-)Zed'ze d.<ed'd/)Zed'ze d0<d'S)1ReflectResponsez"Response model for think endpoint.rbz## AI Overview Based on my understanding, AI is a **transformative technology**: - Used extensively in healthcare - Discussed in recent conversations - Continues to evolve rapidlyrj123rWrd)rrr456z%I discussed AI applications last weekrezAI is transformativezUsed in healthcarezDiscussed recentlyr=irHirrecallriAIr)r`rarcagent_1irgrczobs-1z AI Technologyconcept structural)rr[rsubtype)r6rorrbased_onstructured_outputr&rlrqz`The reflect response as well-formatted markdown (headers, lists, bold/italic, code blocks, etc.)rrrNzOEvidence used to generate the response. Only present when include.facts is set.rIr|zStructured output parsed according to the request's response_schema. Only present when response_schema was provided in the request.r}z4Token usage metrics for LLM calls during reflection.r&zSExecution trace of tool and LLM calls. Only present when include.tool_calls is set.rl)rMrNrOrPr"rr#rrrRr|rir}rr&r<rlrnr+r2rrqrqTs,,: V$.HRYZZ$.U_kll! 6#79M"N&&+/VZ[[,4_b#c#c"d,5d"K"K!L#*$3$-'3 %   L>vD#',ee'''Hnt#&+UZ&&&td{ %uJ   E: "'i"""E<$ r2rqceZdZUdZedddddiZeddd Zee d <eddd Z ee d <eddd Z ee d<dS)DispositionTraitszJDisposition traits that influence how memories are formed and interpreted.rb skepticism literalismempathyrqrrz3How skeptical vs trusting (1=trusting, 5=skeptical)gelerJrz>How literally to interpret information (1=flexible, 5=literal)rzAHow much to consider emotional context (1=detached, 5=empathetic)rN) rMrNrOrPr"rr#rrQrRrrr+r2rrrsTT:1\]jkeZdZUdZedddiiZeed<dS)MissionResponsez"Response model for mission update.rbrzKI am a PM helping my engineering team stay organized and ship quality code.rqNrMrNrOrPr"rrrRr+r2rrrsJ,,: h LLLLLLr2rc|eZdZUdZeddddiZedZee d <edd Z e e d <d S)AddBackgroundRequestzcRequest model for adding/merging background information. Deprecated: use SetMissionRequest instead.rbzI was born in TexasT)rupdate_dispositionrqz*New background information to add or mergerrrz@Deprecated - disposition is no longer auto-inferred from missionrIrN) rMrNrOrPr"rr#rrrRrrr+r2rrrsmm:$2G_c&d&deL5%QRRRGSRRR$u"d   r2rc|eZdZUdZedddiiZeed<eddZ edzed <dZ e dzed <dS) BackgroundResponsezNResponse model for background update. Deprecated: use MissionResponse instead.rbrzJI was born in Texas. I am a software engineer with 10 years of experience.rqNzDeprecated: same as missionrIrr) rMrNrOrPr"rrrRr#rrrr+r2rrrsXX: g LLLL"U4=Z[[[Jd [[[,0K"T)00000r2rceZdZUdZeed<dZedzed<eed<dZedzed<dZ edzed<dZ edzed<d Z e ed <dZ edzed <dS) BankListItemz.Bank list item with profile summary and stats.r$Nr[rr created_at updated_atr fact_countlast_document_at)rMrNrOrPrrRr[rrrrrrQrr+r2rrrs88 LLLD#*""""GS4Z!Jd !!!!Jd !!!J#'cDj'''''r2rc feZdZUdZedddddddddd d d d d gii Zeeed<dS)BankListResponsez%Response model for listing all banks.rbbanksrrrrz:I am a software engineer helping my team ship quality coderz2024-01-16T14:20:00Z)r$r[rrrrrrrqN) rMrNrOrPr"rr,rrRr+r2rrrs//: #, '67qUV'W'W#_&<&<&),B     L&  r2rceZdZUdZeddddiZedd Zedze d <edd Z e dze d <edd dd Z e dze d<edd dd Ze dze d<edd dd Ze dze d<edd Zedze d<edd Zedze d<edd Zedze d<edd Zedze d<edd Zedze d<edd Zedze d<edd Ze dze d<edd Zedze d!<edd" Zedze d#<d$eeeffd%ZdS)&CreateBankRequestz+Request model for creating/updating a bank.rbzZAlways include technical decisions and architectural trade-offs. Ignore meeting logistics.z_Observations are stable facts about people and projects. Always include preferences and skills.)retain_missionobservations_missionrqNz.Deprecated: display label only, not advertisedrIr[z*Deprecated: use update_bank_config insteadrrrr*rrrJdisposition_skepticismdisposition_literalismdisposition_empathyz?Deprecated: use update_bank_config with reflect_mission insteadrrzXMission/context for Reflect operations. Guides how Reflect interprets and uses memories.reflect_missionzYSteers what gets extracted during retain(). Injected alongside built-in extraction rules.rzBFact extraction mode: 'concise' (default), 'verbose', or 'custom'.retain_extraction_modezNCustom extraction prompt. Only active when retain_extraction_mode is 'custom'.retain_custom_instructionsz8Maximum token size for each content chunk during retain.retain_chunk_sizez:Toggle automatic observation consolidation after retain().enable_observationszaControls what gets synthesised into observations. Replaces built-in consolidation rules entirely.rrcji}|jp |jp|j}|||d<|j |j|d<n|j|jj|d<|j |j|d<n|j|jj|d<|j |j|d<n|j|jj |d<dD]}t||}||||<|S)zReturn only the config fields that were explicitly set. reflect_mission takes precedence over deprecated mission/background aliases. Individual disposition_* fields take priority over the deprecated disposition dict. Nrrrr)rrrrrr) rrrrrrrrrrgetattr)rupdatesresolved_reflect_mission field_namevalues rget_config_updatesz$CreateBankRequest.get_config_updatesPs #%#'#7#Z4<#Z4? # /)AG% &  & 2040KG, - -   )040@0KG, -  & 2040KG, - -   )040@0KG, -  # /-1-EG) * *   )-1-=-EG) * , ,JD*--E &+ #r2)rMrNrOrPr"rr#r[rrRrrrrQrrrrrrrrrrrrrrrr+r2rrr sA55: "~)J LuT7ghhhD#*hhh,1E"N---K"T)*/q.Z***C$J*/q.Z***C$J',eq.Z'''t %"cGS4Z#U"cJd  #(%n###OS4Z "'o"""NC$J*/X***C$J.3Ud...d %*EN%%%sTz(-uP((((-uw(((#* #DcN######r2rcneZdZUdZeddddddiiZed Zee e fe d<d S) BankConfigUpdatez.Request model for updating bank configuration.rbrzclaude-sonnet-4-5verbosez#Extract technical details carefully) llm_modelrrrqzConfiguration overrides. Keys can be in Python field format (llm_provider) or environment variable format (HINDSIGHT_API_LLM_PROVIDER). Only hierarchical fields can be overridden per-bank.rrN) rMrNrOrPr"rr#rrrrrRr+r2rrrvs88: !4.72W    L$e?GT#s(^r2rceZdZUdZedddddddddd i Zed Zee d <ed Z e ee fe d<ed Z e ee fe d<dS)BankConfigResponsez&Response model for bank configuration.rbzmy-bankopenaizgpt-4r) llm_providerrr)rrr$config overridesrqzBank identifierrrr$zYFully resolved configuration with all hierarchical overrides applied (Python field names)rz?Bank-specific configuration overrides only (Python field names)rN)rMrNrOrPr"rr#r$rrRrrrrr+r2rrrs00: $$,!(.7 ").7    L"5%6777GS777"UoFDcN!&2s t t tItCH~tttttr2rc eZdZUdZedddddddddgddd d d gd dd dddgdddiZeeee fe d<eeee fe d<eeee fe d<e e d<e e d<dS)GraphDataResponsez'Response model for graph data endpoint.rb1rrd)rrr2zBob went hikingsemanticg?)fromtorrz abc12345...z Work infoz2024-01-15 10:30%Alice (PERSON), Google (ORGANIZATION))rrrdater]rxr)rr table_rows total_unitsrrqrrrrrNrr+r2rrrs11: )@'RR):GLL$'c:QTUUV, 7#. 2$K  !! L. S#X  S#X T#s(^$$$$ JJJJJr2rc eZdZUdZedddddddd gd d d d iZeeee fe d<e e d<e e d<e e d<dS)ListMemoryUnitsResponsez.Response model for list memory units endpoint.rbr-rzWork conversationrrdr)rrrrrr]rrrrrqrrrrNrr+r2rrrs88: E F#6 6 '$K   L( S#X  JJJ JJJ KKKKKr2rc eZdZUdZeddddddddd d gd gd d ddiZeeee fe d<e e d<e e d<e e d<dS)ListDocumentsResponsez+Response model for list documents endpoint.rb session_1rabc123ri,rrg session_123)rr$ content_hashrr text_lengthmemory_unit_countro2rrrrqrrrrNrr+r2rrrs55: *#,(0&<&<'+-/!)= 9    L, S#X  JJJ JJJ KKKKKr2rcXeZdZUdZedZeed<edZe ed<dS)TagItemzSingle tag with usage count.z The tag valuerrtagz Number of memories with this tagcountN) rMrNrOrPr#rrrRrrQr+r2rrrsS&&u111C111#EFFFE3FFFFFr2rceZdZUdZeddddddddd dgd d d d iZeeed<e ed<e ed<e ed<dS)ListTagsResponsez&Response model for list tags endpoint.rbz user:alice*)rrzuser:bobrzsession:abc123rrrrrqrrrrN) rMrNrOrPr"rr,rrRrQr+r2rrr s00: (266&44,q99        L = JJJ JJJ KKKKKr2rceZdZUdZeddddddddd d gd d d dddd iZeed<eed<eed<edzed<eed<eed<eed<e ddZ e eefdzed<e e dZe eed <e dd!Ze eefdzed"<e dd#Ze eefdzed$<dS)%DocumentResponsez)Response model for get document endpoint.rbrrzFull document text here...rrrrgrrz#generalrzTeam meeting notesz 2024-01-15)r event_date) rr$ original_textrrrrrodocument_metadata retain_paramsrqrr$rNrrrrz;Memory count per fact type (world, experience, observation)rInodes_by_fact_typez"Tags associated with this documentrrrozDocument metadatarzParameters used during retainr)rMrNrOrPr"rrrRrQr#rrr1r,rorrrr+r2rrr#s33: !$!= (44%'!=107J%O%O-AQ]!^!^    L" GGG LLL*OOOOOO05"_111S#X-'&t9]^^^D$s)^^^/4uTOb/c/c/ctCH~,ccc+05Kj+k+k+kM4S>D(kkkkkr2rcneZdZUdZeddddgiiZedd Zee dze d<dS) UpdateDocumentRequestz7Request model for updating a document's mutable fields.rbrozteam-azteam-brqNzgNew tags for the document and its memory units. Triggers observation invalidation and re-consolidation.rI) rMrNrOrPr"rr#ror,rrRr+r2rrrFsAA: 8, L#UBD$s)d r2rc"eZdZUdZdZeed<dS)UpdateDocumentResponsez,Response model for update document endpoint.Tr#N)rMrNrOrPr#rrRr+r2rrrXs(66GTr2rcbeZdZUdZeddddddiZeed <eed <eed <e ed <d S)DeleteDocumentResponsez,Response model for delete document endpoint.rbTzGDocument 'session_1' and 5 associated memory units deleted successfullyrrr#messagermemory_units_deletedrqr#rrrN) rMrNrOrPr"rrrRrrQr+r2rrr^sx66: d*()     LMMM LLLr2rc zeZdZUdZedddddddd i Zeed <eed <eed <eed<eed<eed<dS) ChunkResponsez&Response model for get chunk endpoint.rbuser123_session_1_0rrrz*This is the first chunk of the document...r)rrr$r chunk_textrrqrrr$rrrN) rMrNrOrPr"rrrRrQr+r2rrrrs00: 1*$ J4      LMMM LLLOOOOOOOOr2rcHeZdZUdZeeed<eed<eed<eed<dS)ListChunksResponsez0Response model for listing chunks of a document.rrrrN)rMrNrOrPr,rrRrQr+r2rrrsB::   JJJ JJJ KKKKKr2rc2eZdZUdZeed<eed<eed<dS)ReprocessDocumentResponsez/Response model for reprocess document endpoint.r#r)r%N)rMrNrOrPrrRrrQr+r2rrrs999 MMMr2rcjeZdZUdZedddddiZeed<d Ze d zed <d Z e d zed <d S) DeleteResponsez%Response model for delete operations.rbTzDeleted successfully r#r deleted_countrqr#Nrr) rMrNrOrPr"rrrRrrrrQr+r2rrrsu//:$$CYln&o&opLMMMGS4Z $M3:$$$$$r2rc>eZdZUdZedddiiZeed<dS)ClearMemoryObservationsResponsez?Response model for clearing observations for a specific memory.rbrrrqNrMrNrOrPr"rrQrRr+r2rrrs@II:_aeZdZUdZedddiiZeed<dS)RecoverConsolidationResponsez3Response model for recovering failed consolidation.rb retried_countrrqNrr+r2rrrs@==:_b)*()&( L*LLLS#X&&&S#X&&&S#X&&&#tCH~-....+05m,,,$sCx. (-uTGq'r'r'r#*rrr!&q>v!w!w!w3www %f!!!#$eA;YZZZZZZZZr2rceZdZUdZedZeed<eddZe ed<edd Z e ed <edd Z e ed <d S)MemoryTimeseriesBucketz/One bucket in the memory ingestion time-series.z)Bucket start timestamp in ISO-8601 (UTC).rrtimerz,World-fact memories ingested in this bucket.rIrdz,Experience memories ingested in this bucket.rez%Observations recorded in this bucket.rFN) rMrNrOrPr#rrrRrdrQrerFr+r2rrrs99"MNNND#NNNq.\]]]E3]]]eA3abbbJbbbuQ4[\\\K\\\\\r2rceZdZUdZeed<edZeed<edZeed<edd Z eed <ee d Z e e ed<dS)MemoriesTimeseriesResponsez?Time-series of memory ingestion bucketed by time and fact type.r$z"One of: 1h, 12h, 1d, 7d, 30d, 90d.rrperiodz&Bucket granularity: minute, hour, day.truncrzTimestamp column used to assign each row to a bucket. `created_at` shows ingest time; `mentioned_at` / `occurred_start` show event time (falls back to `created_at` per row when null).rI time_fieldzIPer-bucket counts, always returned fully padded for the requested period.rCbucketsN) rMrNrOrPrrRr#r!r"r#r,r$rr+r2rr r sII LLL%$HIIIFCIII#KLLLE3LLLe NJ-2E_---GT( )r2r ceZdZUdZeed<eed<eed<eed<dZeed<dZe ed <e e Z e eed <d Z ed zed <d Zed zed <d S)DirectiveResponsezResponse model for a directive.rr$r[rrpriorityT is_activeroNrr)rMrNrOrPrrRr'rQr(rr1r,rorrr+r2rr&r& s)) GGG LLL III LLLHcIt&&t,,D$s),,,!Jd !!!!Jd !!!!!r2r&c*eZdZUdZeeed<dS)DirectiveListResponsez&Response model for listing directives.rN)rMrNrOrPr,r&rRr+r2rr*r*s*00 ! """"""r2r*ceZdZUdZedZeed<edZeed<edd Z e ed <ed d Z e ed <e edZeeed<dS)CreateDirectiveRequestz'Request model for creating a directive.z%Human-readable name for the directiverrr[)The directive text to inject into promptsrr-Higher priority directives are injected firstrIr'T Whether this directive is activer(Tags for filteringroNrMrNrOrPr#r[rrRrr'rQr(rr1r,ror+r2rr,r, s11"IJJJD#JJJ5%PQQQGSQQQE!1`aaaHcaaaeD6XYYYItYYY&&t9MNNND$s)NNNNNr2r,ceZdZUdZeddZedzed<eddZedzed<eddZ e dzed <edd Z e dzed <edd Z eedzed <dS)UpdateDirectiveRequestz'Request model for updating a directive.NzNew namerIr[z New contentrz New priorityr'zNew active statusr(zNew tagsro)rMrNrOrPr#r[rrRrr'rQr(rror,r+r2rr3r3*s11uTzBBBD#*BBB%-HHHGS4ZHHH 5>JJJHcDjJJJ"U4=PQQQItd{QQQ"U4ZHHHD$s)d HHHHHr2r3cHeZdZUdZeddZeded<eddZe ed <ed d Z e ed d zed <eddZ e ed<ed dZ e ed zed<ed dZed zed<ed dZe ed zed<ed dZe d zed<ed dZed zed<ed dZed zed<ed ede ed zde ed zfdZd S)MentalModelTriggerz$Trigger settings for a mental model.fullaRefresh mode. 'full' (default) regenerates the mental model content from scratch on each refresh. 'delta' performs surgical edits against the existing content: unchanged sections are preserved byte-for-byte, stale content is removed, new content is added. If the mental model has no existing content, or if the source_query has changed since the last refresh, delta mode falls back to a full regeneration automatically.rI)r6deltarFzTIf true, refresh this mental model after observations consolidation (real-time mode)refresh_after_consolidationNrDrErGrHrIrJrKaOverride how the model's tags filter memories during refresh. If not set, defaults to 'all_strict' when the model has tags (security isolation) or 'any' when the model has no tags. Set to 'any' to include untagged memories alongside tagged ones during refresh.rpaCompound boolean tag expressions to use during refresh instead of the model's own tags. When set, these tag groups are passed to reflect and the model's flat tags are NOT used for filtering. Supports nested and/or/not expressions for complex tag-based scoping.ruzOverride whether the internal recall used during refresh returns raw chunk text. None means use the bank/global config default (recall_include_chunks).include_chunkszOverride the token budget for facts returned by the internal recall during refresh. None means use the bank/global config default (recall_max_tokens).recall_max_tokenszOverride the token budget for raw chunks returned by the internal recall during refresh. None means use the bank/global config default (recall_chunks_max_tokens).recall_chunks_max_tokensrvrcN|"t|dkrtd|SrMrNrPs rvalidate_fact_typesz&MentalModelTrigger.validate_fact_types}rRr2)rMrNrOrPr#rrrRr8rrGr,rIrKrrpr>rur=r9r:rQr;r$rr=r+r2rr5r59s..%*U * & & &D'/ "   ).j)))NSUCNNNJWABCdJ#(%p###427Q222d3i$.$)5 ^$$$J D ). T)))JX%#(% U###ND4K%*E Q%%%sTz,15 X,,,cDj_\""DI$4cT9I[#"r2r5cheZdZUdZeed<eed<eed<dZedzed<eddZedzed <e e Z e eed <ed Z e dzed <ed Zedzed <dZedzed<dZedzed<eddZedzed<eddZedzed<dS)MentalModelResponsez<edd?Z)e'dzed@<eddAZ*e dzedB<eddCZ+e dzedD<dEeeeffdFZ,dS)GBankTemplateConfigzBank configuration fields within a template manifest. Only includes configurable (per-bank) fields. Credential fields (API keys, base URLs) are intentionally excluded for security. Nz&Mission/context for Reflect operationsrIrz(Steers what gets extracted during retainrzAFact extraction mode: 'concise' (default), 'verbose', or 'custom'rz-Custom extraction prompt (when mode='custom')rz%Max token size for each content chunkrz Toggle observation consolidationrzControls what gets synthesisedrrrzSkepticism trait (1-5)rrzLiteralism trait (1-5)rzEmpathy trait (1-5)rz'Controlled vocabulary for entity labels entity_labelsz+Allow entities outside the label vocabularyentities_allow_free_formzDName of the default retain strategy (key into retain_strategies map)retain_default_strategyz7Map of retain strategy name to per-strategy config dictretain_strategiesz4Max chunks per streaming batch (0 disables batching)retain_chunk_batch_sizez3MCP tool allowlist for this bank (None = all tools)mcp_enabled_toolsz,LLM batch size for observation consolidationconsolidation_llm_batch_sizez2Max tokens of source facts per consolidation batch%consolidation_source_facts_max_tokensz*Max tokens of source facts per observation5consolidation_source_facts_max_tokens_per_observationz2Max observations to retain per consolidation scopemax_observations_per_scopez+Max tokens of source facts per reflect callreflect_source_facts_max_tokensz/Per-bank Gemini/VertexAI safety filter settingsllm_gemini_safety_settingsz5Recall budget mapping function: 'fixed' or 'adaptive'recall_budget_functionz7Fixed thinking_budget for budget=low (function='fixed')recall_budget_fixed_lowz7Fixed thinking_budget for budget=mid (function='fixed')recall_budget_fixed_midz8Fixed thinking_budget for budget=high (function='fixed')recall_budget_fixed_highz8Ratio of max_tokens for budget=low (function='adaptive')recall_budget_adaptive_lowz8Ratio of max_tokens for budget=mid (function='adaptive')recall_budget_adaptive_midz9Ratio of max_tokens for budget=high (function='adaptive')recall_budget_adaptive_highz0Floor for the adaptive function (after clamping)recall_budget_minz2Ceiling for the adaptive function (after clamping)recall_budget_maxrcbd|DS)z;Return only the fields that were explicitly set (non-None).ci|] \}}||| SNr+.0krvs r z9BankTemplateConfig.get_config_updates..QsLLLAam1mmmr2) model_dumprrs rrz%BankTemplateConfig.get_config_updatesOs,LL!2!2!8!8!:!:LLLLr2)-rMrNrOrPr#rrrRrrrrrQrrrrrrrbr,rrrcrdrerfrgrhrirjrkrlrmrnrorprqrrfloatrsrtrurvrr+r2rraras0 #(%Bj"k"k"kOS4Zkkk!&tAk!l!l!lNC$Jlll)."e***C$J.3U"Q...d %*E$Dk$l$l$lsTzlll',uTGi'j'j'jjjj',uTGg'h'h'h#*hhh).taUm)n)n)nC$Jnnn).taUm)n)n)nC$Jnnn&+eDQ1Rg&h&h&hthhh16"K222M4S#X'$.-2E"O---dTk+0%"h+++S4Z&+U"[&&&td{+0%"X+++S4Z+0%"W+++tCy4'05u"P000 #*9>"V999)3:IN"NIII93:.3U"V...d 38%"O333#S4Z/4e"S///t */"Y***C$J+0%"[+++S4Z+0%"[+++S4Z,15"\,,,cDj05u"\000 05u"\000 16"]111%*E$Dv$w$w$wsTzwww$)E"V%%%sTzMDcNMMMMMMr2raceZdZUdZedZeed<edZeed<edd Z e ed <ed d Z e ed <e edZeeed<dS)BankTemplateDirectivezA directive definition within a bank template manifest. Directives are matched by name on re-import: existing directives with the same name are updated, new ones are created. zFHuman-readable name for the directive (used as match key on re-import)rrr[r-rrr.rIr'Tr/r(r0roNr1r+r2rrrTs "jkkkD#kkk5%PQQQGSQQQE!1`aaaHcaaaeD6XYYYItYYY&&t9MNNND$s)NNNNNr2rc $eZdZUdZedddddddd d d d did gddddgdiZedZee d<eddZ e dze d<eddZ e edze d<eddZe edze d<ededed efd!Zedede edzd e edzfd"Zedede edzd e edzfd#ZdS)$BankTemplateManifestzA bank template manifest for import/export. Version field enables forward-compatible schema evolution: the API auto-upgrades older manifest versions to the current schema on import. rbrz?You are helping a support agent remember customer interactions.z4Extract customer issues, resolutions, and sentiment.rT)rrrrzsentiment-overviewzCustomer Sentiment Overviewz$What is the overall sentiment trend?r8)rr[r@rBzAlways be empatheticz.Always respond with empathy and understanding.r)r[rr'versionbankrkrlrqz'Manifest schema version (currently '1')rrrNz= 1z version 'z2' is not supported by this server (max supported: z). Please upgrade Hindsight.)rQr{BANK_TEMPLATE_CURRENT_VERSION)r|rvvers rvalidate_versionz%BankTemplateManifest.validate_versions Ma&&CC M M MKqKKKLL L M 77344 4 233 3 3_A__#@___ s0c||Sd|DfdD}|r,tdtt||S)Ncg|] }|j Sr+rr{ms r zIBankTemplateManifest.validate_unique_mental_model_ids..sqtr2cFg|]}|dk|Srr)r{rfidss rrzIBankTemplateManifest.validate_unique_mental_model_ids..s-???cCIIcNNQ,>,>c,>,>,>r2zDuplicate mental model ids: r{sortedset)r|rv duplicatesrs @r validate_unique_mental_model_idsz5BankTemplateManifest.validate_unique_mental_model_idssn 9HQ????S???  WUF3z??.s###A###r2cFg|]}|dk|Srr)r{nnamess rrzHBankTemplateManifest.validate_unique_directive_names..s-===A%++a..1*<*> J HAHHHIII9??$$ M KAKKKLLL Mr2r$request_contextrEc zKd}|jr?|j}|r$|j|||d{Vd}g}g}g}|jr|||d{V} d| D} |jD]} | j| vr||| j| j| j | j | j r| j nd| j r| j nd|d{V||| j|d{V} || d|| j||| j| j d | j| j r| j nd| j | j r| j nd| d{V} ||| d |d{V} || d|| jg}g}|jr||d| d{V}d |D}|jD]}|j|vrk||||jd |j|j|j|j r|j nd|d{V||jv|||j|j|j|j|j r|j nd|d{V||jt1|||||||dS)a*Apply a validated BankTemplateManifest to an existing bank. Shared by the /import endpoint and the default-template-on-create hook driven by HINDSIGHT_API_DEFAULT_BANK_TEMPLATE. The bank MUST already exist; caller is responsible for validation (Pydantic + validate_bank_template). FNTr$rc i|] }|d| Srr+rs rr}z0apply_bank_template_manifest..s777!D'1777r2r$rVr[r@rKrorBrr$rVrr)Generating content... r$r[r@rrVrorKrBrrr$ active_onlyrc i|] }|d| Srr+rs rr}z0apply_bank_template_manifest..7sFFFQAfIqFFFr2)r$ directive_idrr'r(rorr$r[rr'r(ror)r$rrrrrr*r)rr_config_resolverupdate_bank_configrklist_mental_modelsrupdate_mental_modelr[r@rKrorBr~!submit_async_refresh_mental_modelrcreate_mental_modelrllist_directivesupdate_directiverr'r(create_directiver)memoryr$rrrconfig_updates created_ids updated_idsr*existingexisting_by_idrresult mental_modelrrexisting_directivesexisting_by_name directives rapply_bank_template_manifestrsN}"!99;;  ")<Ct$3.#))).9999--#"%-&/'1+4>Ct$3.#))).9999 %%))--#    r2c eZdZUdZeddddddddd dd i Zeed <eed <eed<dZ edzed<eed<eed<edzed<e ddZ edzed<e ddZ edzed<dS)OperationResponsez,Response model for a single async operation.rbr-retainrNrpendingr) r task_typer%rrstatus error_message retry_count next_retry_atrqrrr%rrrr>Number of times this operation has been retried after failure.rIru>When the worker will next attempt this operation. For a pending operation, a value in the future indicates the task is waiting rather than available for immediate pickup — for example, an extension may have raised DeferOperation to park the task until some backpressure window opens. Always null for completed tasks.r) rMrNrOrPr"rrrRrQrr#rrr+r2rrr]s66: <% #4#!% !%    L GGGNNN"Kt"""OOO KKK:#eTKt!& O ! ! !M3:     r2rcZeZdZUdZedZeed<eddZe ed<d S) ConsolidationResponsez2Response model for consolidation trigger endpoint.z'ID of the async consolidation operationrrr)Fz+True if an existing pending task was reusedrI deduplicatedN) rMrNrOrPr#r)rrRrrr+r2rrrsV<<*STTTL#TTTu:ghhhL$hhhhhr2rc eZdZUdZedddddddd d d d gd iZeed<eed<eed<eed<e e ed<d S)OperationsListResponsez,Response model for list operations endpoint.rbrrrrr-rrrN)rrrrrr$rrr operationsrqr$rrrr) rMrNrOrPr"rrrRrQr,rr+r2rrrs66: $E%-&<"+)-   L(LLL JJJ JJJ KKK&''''''r2rcVeZdZUdZedddddiZeed<eed <eed <d S) CancelOperationResponsez-Response model for cancel operation endpoint.rbTz8Operation 550e8400-e29b-41d4-a716-446655440000 cancelledr-r#rr)rqr#rr)N rMrNrOrPr"rrrRrr+r2rrrsi77: U F LMMM LLLr2rcVeZdZUdZedddddiZeed<eed <eed <d S) RetryOperationResponsez,Response model for retry operation endpoint.rbTz?Operation 550e8400-e29b-41d4-a716-446655440000 queued for retryr-rrqr#rr)Nrr+r2rrrsi66: \ F LMMM LLLr2rcdeZdZUdZeed<eed<dZedzed<dZedzed<dZ edzed<dS)ChildOperationStatusz3Status of a child operation (for batch operations).r)rNsub_batch_indexr%r) rMrNrOrPrrRrrQr%rr+r2rrrsi== KKK"&OS4Z&&&"Kt""" $M3:$$$$$r2rc eZdZUdZeddddddddd i Zeed <ed ed <dZ edzed<dZ edzed<dZ edzed<dZ edzed<dZ edzed<eddZedzed<eddZedzed<eddZeeefdzed<eddZeedzed<eddZeeefdzed<dS)OperationStatusResponsez5Response model for getting a single operation status.rbr- completedrefresh_mental_modelsrz2024-01-15T10:31:30ZN)r)roperation_typerr completed_atrrqr))r processingrfailed cancelled not_foundrrrrrrrrIrzWhen the worker will next attempt this operation. For a pending operation, a value in the future indicates the task is parked (e.g. by an extension raising DeferOperation) rather than awaiting immediate pickup.rz]Internal metadata for debugging. Structure may change without notice. Not for production use.result_metadataz5Child operations for batch operations (if applicable)child_operationszeRaw task payload (params the operation was submitted with). Only populated when include_payload=true. task_payload)rMrNrOrPr"rrrRrrrrrrr#rrQrrrrrr,rrr+r2rrrs??:  F%"944 6!%     L \ ]]]]!%NC$J%%%!Jd !!!!Jd !!!#L#*### $M3:$$$#eTKt!& !!!M3:.3Us...OT#s(^d*;@%"Y;;;d/047+0%{+++L$sCx.4'r2rcJeZdZUdZeddddiZeed<eed<d S) AsyncOperationSubmitResponsez1Response model for submitting an async operation.rbr-queuedr)rrqr)rNrr+r2rrr s[;;:  F" L KKKKKr2rceZdZUdZedZeed<edZeed<edZ eed<ed Z eed <ed Z eed <d S) FeaturesInfoz8Feature flags indicating which capabilities are enabled.z5Whether observations (auto-consolidation) are enabledrrrz6Whether MCP (Model Context Protocol) server is enabledmcpz(Whether the background worker is enabledworkerz-Whether per-bank configuration API is enabledbank_config_apiz-Whether file upload/conversion API is enabledfile_upload_apiN) rMrNrOrPr#rrrRrrrr r+r2rrr sBB+bcccL$ccc"Z[[[C[[[5%OPPPFDPPP!E.]^^^OT^^^!E.]^^^OT^^^^^r2rc eZdZUdZedddddddddiZed Zee d <ed Z e e d <dS)VersionResponsez-Response model for the version/info endpoint.rbz0.4.0FTrrrrr  api_versionfeaturesrqzAPI version stringrrrzEnabled feature flagsrN) rMrNrOrPr"rr#rrrRrrr+r2rr r & s77: &$)"','+        Lu)=>>>K>>>"U/FGGGHlGGGGGr2r )WebhookHttpConfigceZdZUdZedZeed<eddZedzed<ed gd Z e eed <ed d Z e ed<ee dZe ed<dS)CreateWebhookRequestz(Request model for registering a webhook.z)HTTP(S) endpoint URL to deliver events torrurlNz%HMAC-SHA256 signing secret (optional)rIsecretzconsolidation.completedzNList of event types to deliver. Currently supported: 'consolidation.completed' event_typesTWhether this webhook is activeenabledz>HTTP delivery configuration (method, timeout, headers, params)rC http_config)rMrNrOrPr#rrrRrrr,rrrrr+r2rrrD s22u!LMMMCMMMt9`aaaFC$Jaaa"U*+dKcE$4TUUUGTUUU%*U)T&&&K"r2rceZdZUdZeed<edzed<eed<eddZedzed<eeed <e ed <ee Z e ed <dZ edzed <dZ edzed<dS)WebhookResponsezResponse model for a webhook.rNr$rz&Signing secret (redacted in responses)rIrrr)r'rrr)rMrNrOrPrrRr#rr,rrrrrr+r2rrrT s'' GGG 4Z HHHt9abbbFC$Jbbbc MMM%*U;L%M%M%MK"MMM!Jd !!!!Jd !!!!!r2rceZdZUdZeddZedzed<eddZedzed<eddZ e edzed <edd Z e dzed <edd Z edzed <dS)UpdateWebhookRequestzGRequest model for updating a webhook. Only provided fields are updated.NzHTTP(S) endpoint URLrIrzFHMAC-SHA256 signing secret. Omit to keep existing; send null to clear.rzList of event typesrrrzHTTP delivery configurationr)rMrNrOrPr#rrrRrrr,rrrrr+r2rrrb sQQeD6LMMMCtMMM"jFC$J%*E$DY$Z$Z$ZKcT!ZZZ 5;[\\\GTD[\\\,1E$Li,j,j,jK"T)jjjjjr2rc*eZdZUdZeeed<dS)WebhookListResponsez$Response model for listing webhooks.rN)rMrNrOrPr,rrRr+r2rrrn s)..       r2rceZdZUdZeed<edzed<eed<eed<eed<eed<dZedzed <dZedzed <dZ edzed <dZ edzed <dZ edzed <dZ edzed<dZ edzed<ededdfdZdS)WebhookDeliveryResponsez-Response model for a webhook delivery record.rN webhook_idr event_typerattemptsr last_errorlast_response_statuslast_response_bodylast_attempt_atrrrowrcddl}|d}t|tr||}nt|tr|}ni}|d}t|tr|r||ni}nt|tr|}ni}|t|d|d|dd|dd|d |d d z|d |d |d|d|d|d|d S)Nrrrr)r!rrr"rrrrrlast_status_coder&r'rr) rr!rr"rr#rr$r%r&r'rr)rrrrrget)r|r(_jsonrawrraw_metars rfrom_async_operation_rowz0WebhookDeliveryResponse.from_async_operation_row s.! c3    ;;s++LL T " " LLL77,-- h $ $ !7?Gekk(333ROO $ ' ' !&OO Os3~&''#'' 55  ++#'' b99x='!+o.?+!0!4!45G!H!H.223GHH+//0ABB<(<(    r2)rMrNrOrPrrRrQrr$r%r&r'rrrrr/r+r2rr r t s77 GGGd  HHHOOO KKKMMM $M3:$$$!Jd !!!'+#*+++%)d )))"&OS4Z&&&!Jd !!!!Jd !!!! 4! 4M! ! ! [! ! ! r2r c>eZdZUdZeeed<dZedzed<dS)WebhookDeliveryListResponsez.Response model for listing webhook deliveries.rN next_cursor) rMrNrOrPr,r rRr2rr+r2rr1r1 s>88 ' (((("Kt"""""r2r1audit_logger_gettercxddlmddlmddlmddlm}dddt d t d zffd }|S) zCreate an audit decorator bound to an audit logger getter. Returns a decorator factory that can be used as @audited("action_name"). r)r)r)wrapsrrequest request_paramactionr8Nc fd}|S)a=Decorator that wraps an HTTP handler with audit logging. Args: action: The audit action name (e.g. "retain", "recall"). request_param: Name of the kwarg holding the Pydantic request model (None if handler has no request body). Also supports "body". c|fd}ddl}||_|S)Nc.K }|| s |i|d{VS|d}  j}d}rW|}|'t |dr|d}n|t |tr|}t d|||}  |i|d{V}t |dr|d|_ nt |tr||_ |  j|_ | |S#  j|_ | |wxYw)Nr$r~rrhttp)r9 transportr$ started_atr6) is_enabledr+nowutchasattrr~rrrresponseended_atlog_fire_and_forget)argsr.alr$r?req_datareq_objentryr_dt_tzr9r3funcr8s rwrapperzG_make_audited_http..audited..decorator..wrapper s((**:R]]6%:%::!%t!6v!6!66666666 **Y// WWSW--  +$jj77G*ww /M/M*#*#5#56#5#B#B ,GT1J1J,#*"!$#)$  2#'4#8#8#8888888Fv|440)/):):):)G)G#FD110)/!%(WWSW%5%5EN**51111&)WWSW%5%5EN**51111s AE6Fr)inspect signature __signature__) rNrOrPrLrMr9r3r8r5s ` r decoratorz6_make_audited_http..audited..decorator so U4[[! 2! 2! 2! 2! 2! 2! 2! 2! 2[! 2H NNN$+$5$5d$;$;G !Nr2r+)r9r8rSrLrMr3r5s`` rauditedz#_make_audited_http..audited s@) ) ) ) ) ) ) ) ) ) Vr2)rr functoolsr5typingr r)r3 _CallablerTrLrMr5s` @@@r_make_audited_httprX s )(((((((((((,,,,,,t5| dr.| jtj d|jrjjrddlm } |j!p|"}|j#| krdn|j#}|j|j$|j%|j&|j'|j(}|j)|*}tj d|dn'|jr jjstj dj+}|r.|,d{Vtj dr.,d{Vtj ddWV|`|-dd{V|.|. |d{Vn#|j/$rYnwxYwtj d|r.|0d{Vtj dr.0d{Vtj d 1d{Vtj d!dS)"z Lifespan context manager for startup and shutdown events. Note: This only fires when running the app standalone, not when mounted. rNr3) WorkerPollerz hindsight-apiz1.0.0) service_nameservice_versionz4Metrics initialized - available at /metrics endpointzFailed to initialize metrics: z3. Metrics will be disabled (using no-op collector).zBOTEL tracing enabled but no endpoint configured. Tracing disabled.)create_span_recorderinitialize_tracing)r`endpointheadersdeployment_environmentz,OpenTelemetry tracing enabled and configuredzFailed to initialize tracing: zContinuing without tracingzMemory system initialized set_db_poolzDB pool metrics configuredrx)DEFAULT_DATABASE_SCHEMA)backend worker_idexecutorpoll_interval_msschematenant_extension max_slotsslot_reservationsz!Worker poller started (worker_id=)uWorker poller disabled — backend does not support async operations. Tasks (mental model refresh, consolidation) will run synchronously.zTenant extension startedzHTTP extension startedg>@)timeoutzWorker poller stoppedzTenant extension stoppedzHTTP extension stoppedzMemory system closed)2asynciosockethindsight_api.configr4hindsight_api.workerr_rDrBstateprometheus_readerlogginginfo Exceptionwarningotel_traces_enabledotel_exporter_otlp_endpointhindsight_api.tracingrbrcotel_service_nameotel_exporter_otlp_headersotel_deployment_environmenterror initializerC_poolrCrgworker_enabled_backendsupports_worker_pollerrrhrj gethostnamedatabase_schema execute_taskworker_poll_interval_ms_tenant_extensionworker_max_slotsworker_slot_reservations create_taskrunrn on_startupshutdown_gracefulcancelCancelledError on_shutdownclose)r]rsrtr4r_rpoller poller_taskrxrrbrcmetrics_collectorrhrjrmrnrZrYrs rlifespanzcreate_app..lifespan sf  333333555555  / 2ah i i i  $ & & &*;CI ' LO P P P P / / / OsQsss t t t*.CI ' ' ' ' ' ' /  % B5 B deeeeZZZZZZZZ B&&%+%=!'!C & A/5/Q  )(***L!OPPPP BBBM"F1"F"FGGGO$@AAAAAAAAB  ;##%% % % % % % % % L4 5 5 5!6 7 7 |'G4E},U,U'!--fl;;; 9:::   V_%K  8 8 8 8 8 8(@F,>,>,@,@I#37NNNTTTZTjF!\#,!'!?!'!9 1"("A   F.'-fjjll;;K LIYIII J J J J  " 6?+Q  OV    "2  5"--// / / / / / / / L3 4 4 4  3 ++-- - - - - - - - L1 2 2 2   **4*88 8 8 8 8 8 8 8&""$$$%%%%%%%%%-D L0 1 1 1  5"..00 0 0 0 0 0 0 0 L3 4 4 4  3 ,,.. . . . . . . . L1 2 2 2llnn +,,,,,sB?A'' B1$BBAD E+E  EM M'&M'r __version__r3zHindsight HTTP APIzHTTP API for Hindsightr[z Memory Systemz Apache 2.0z0https://www.apache.org/licenses/LICENSE-2.0.html)r[r)rrrJcontact license_infor root_pathrc}|didid}|rAd|divr)ddi|dd<dd d |dd <d d d |dd<|S)N componentsschemasValidationErrorrar@rInputContextr:)rrctxURLr;r)r+)rmve_original_openapis r_patched_openapiz$create_app.._patched_openapi s""$$ ZZ b ) ) - -i < < @ @AR S S  I' b!9!999)0'(:B| W %098&L&LB| U #05x&H&HB| U # r2r=cKddl}ddlm}g}|jrjD]}||j\}}||jkrt|dd}|r| |} t| j } tt|di t|j z} | | z } |jD]} | | vr| | vr||  ng}|jdd}|jdvrd |vr |d{V}|rlt'j|}t+|t,rBjD]9}||j\}}||jkr t|dd}|r| |} | j D]}|j}t+|t2rt5|t6rt|j }|jD]6}t+|jt<r||j7|D]}||vr||nn;n#t&j tBf$rYnwxYw||z}||d{V}|rKd "|}tF$d ||j|j%j&||jd <|S) zQDetect unknown query params and body fields, log warning and set response header.rN)Matchrdparam_convertorsz content-typer)POSTPUTPATCHzapplication/jsonz, z*Unknown parameters ignored: [%s] for %s %szX-Ignored-Params)'rPstarlette.routingr query_paramsroutesmatchesrgFULLrrQr parameterskeys path_paramsrrer+methodbodyrrrrvalues annotationr issubclassr! model_fieldsr raddrUnicodeDecodeErrorjoinloggerr|rpath)r6 call_nextrPrignored_paramsrouter^_rdsigdeclaredr known_queryr[ body_ignored content_type body_bytes body_jsonparamann known_fieldsfieldkey all_ignoredrD ignored_strr]s runknown_params_middlewarez-create_app..unknown_params_middleware s ++++++$&      ==77qEJ&&&uj$??H <%//99#&s~':':'<'<#=#=&)'%9KR*P*P*U*U*W*W&X&X[^#/4466\\' '/&< $+$8<2>> >5 5 5:LP\:\:\ #*<<>>111111 & $ : 6 6I!)T22&%(Z&&E',}}W]'C'CHE1$ 22+25*d+K+K#+!2*1*;*;H*E*EC141F1F1H1H%2%2.3.>+5c4+@+@ )2ZPSU^E_E_ )2;>s?O?T?T?V?V;W;WL9<9I9P9P9R9R-R-R 4>ek33O3O1R4@4D4DU[4Q4Q4Q7@-M-M36l3J3J4@4G4G4L4L4L,1E %' 3((*<=    %|3 "7++++++++  ?))K00K NN<      4?H / 0s F KK-,K-cJKddl}ddlm}|jj}|jdd|}|jdd|}dgt }||j|fd5||d{V}|j d<|cdddS#1swxYwYdS) zRecord HTTP request metrics.rN)rz=/[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}z/{id}z /\d+(?=/|$)rHcdS)Nrr+) status_codesrz=create_app..http_metrics_middleware.. sQ\]^Q_r2) r]starlette.requestsrrrsubrCrecord_http_requestrr)r6rr]rrrrDrs @rhttp_metrics_middlewarez+create_app..http_metrics_middleware s&  ......{rvVX_aeffrvngt44e 133  2 27>4I_I_I_I_ ` `  &Yw////////H%1KN                  s.BBBz/ext Extension)prefixroz&HTTP extension router mounted at /ext/z"HTTP extension root router mounted)rAr?ryrz __class__rMrr hindsight_apirrur4 base_pathrwr audit_loggeropenapirrr middleware_register_routes get_routerinclude_routerget_root_router)rrYrZrrr4rrrrextension_router root_routerrr]s``` @@r create_appr s\0' >>  X LV>3K3TVV W W Ww-Gw-w-w-w-w-w-w-w-r*)))))////// Z\\F ", O !E  "   C"CI#0CI d38n#CK ^^FJJJJJZ ^^F.S ?)44V<< +F+OOO =>>>%44V<<  ?   { + + + L= > > > Jr2r]c8HItfd}tdfdtdzdtfd}t dt fd}d d d d g fd}dtddd gddtfd}dddd g d}dtddddgdddtdd ddt|fd!td"tdzd#td$tdzd%ttdzd&td'tdzd(tdzd)tffd* }d+td,d-d.dgdddd/d0t|fd!td"tdzd$tdzd1tdzd#td2td)tffd3 }d4d5d6d7dg8t|fd!td9td)tffd: } d;ddg8t|fd!td9td)tffd? } d@tdAdBdCdg|dDt|fd!tdEt d)tffdF } dGt"dHdIdJdg|dJt|fd!tdEt$d)tffdK } dLt&dMdNdOdPgt|fd)tffdQ } dRt(dSdTdUdPgt|fd!td)tffdV }dWt*dXdYdZdPgd[td\d]^t|fd!td_td`td)tffda }dbt,dcdddedfgtd/dg^td0dh^t|fd!td#td2td)tffdi }djt.dkdldmdfgtddn^tdodp^t|fd!td#tdqtd)tffdr }dst0dtdudvdfgt|fd!tdwtd)tffdx }dyt0dzd{d|dfgd}~t|fd!tdwtd)tfd}dt2ddddgtdd%dtddtddtd/dodtd0d0t|fd!tdttdzd&t4ddt4dd#td2td)tffd }dt6ddddgtddt|fd!tdtdt4dd)tffd }dddddg8t|fd!tdtd)tffd }dt8ddddg|ddt|fd!tdt:d)tffd }dt<ddddg|ddt|fd!tdtd)tffd }dt6ddddg|ddt|fd!tdtdt@d)tffd }!dddddg8|ddt|fd!tdtd)tffd }dtDddddgtdd%dtddtd}dtd/dodtd0d0t|fd!tdttdzd&t4ddtFd#td2td)tffd }dtHddddgt|fd!tdtd)tffd }dtHddddg|ddt|fd!tdtJd)tffd„ }dtHddddg|ddt|fd!tdtdtLd)tffdƄ }!dddddg8|ddt|fd!tdtd)tffdʄ }dtNddddgtddЬtddѬtddӬd/d0t|fd!td$tdzd%ttdzd&td#td2td)tffdԄ } dtPddddgtd/dodd٬ڦtd0d0dhۦt|fd!td'td#td2td)tf fd܄ }!dtRddddg|dt|fd!td'td)tffd }"dtTddddgt|fd!td'td)tffd }#dtVddddgtdd^tdd^td/d^td0dh^t|fd!td$tdzdt4dd#td2td)tf fd }$dtXddddgt|fd(td)tffd }%dtZddddg|ddt|fd!td'tdt\d)tffd }&!dt^ddddg|ddt|fd!td'td)tffd }'dt`ddddgtdd^tdd^tddod/dڦtd0d0dۦtd d ^t|fd!td tdzd"tdzd#td2td tFd)tffd }(dtbddddgtd d^t|fd!tdtdtFd)tffd })!dtdddddg|ddt|fd!tdtd)tffd }*dtfddddg|ddt|fd!tdtd)tffd }+dthd d!d"dPgd}~t|fd!td)tffd# },5dthd$d%d&dPgd}~t|fd!tdEtld)tffd' }-d(tnd)d*d+dPgd}~t|fd!tdEtpd)tffd, }.5d-thd.d/d0dPg|d1t|fd!tdEtrd)tffd2 }/d-thd3d4d5dPg|d5t|fd!tdEtrd)tffd6 }0!d-ttd7d8d9dPg|d9dt|fd!td)tffd: }1d;tvd<d=d>d?g|d>dtd d@^t|fd!tdEtxdAtFd)tffdB }2dCtzdDdEdFd?gt|fd!td)tffdG }3dHdIdJdKd?g8dL}4!dMttdNdOdPdPg|dPdt|fd!td)tffdQ }5dRt|dSdTdUdPg|dUdt|fd!td)tffdV }6!dWt~dXdYdZdg|dZdt|fd!td9td)tffd[ }7d\td]d^d_dPgt|fd!td)tffd` }8d\tdadbdcdPg|dct|fd!tdEtd)tffdd }9!d\tdedfdgdPg|dgdt|fd!td)tffdh }:ditdjdkdldPg|dmdt|fd!td)tffdn };dotdpdqdrdsgdtu|drt|fd!tdEtd)tffdv }<dotdwdxdydsgt|fd!td)tffdz }=!d{ttd|d}d~dsg|d~dt|fd!tdtd)tffd }>d{tddddsg|dt|fd!tdtdEtd)tffd }?dtddddsgtdddtdd^t|fd!tdtd#tdtdzd)tf fd }@dtddddg|dt|fd!tdEtd)tffd }Adtddddg|ddtddtddt|fd!tdttdEtd)tffd }B!dttddddg|ddtddt|fd!td"tdzd)tffd }CGddtHGHfddt}DGddtIGIfddt}Edddddg|Dtddtddtddtddtddoddtd0d0dht|fd!tdtdzdtdzdtdzdtdzd#td2td)tffd }FdddÐdĐdg|Etddtd[dŬt|fd!tdtdzd_td)tffdƄ }GdS(z2Register all API routes on the given app instance.c0tjddS)Nr)rrw)r]srrz"_register_routes..4 sND)Q)Qr2NrA authorizationrcd}|rX|dr|dd}n|}t|S)a Extract request context from Authorization header. Supports: - Bearer token: "Bearer " - Direct API key: "" Returns RequestContext with extracted API key (may be None if no auth header). Nzbearer )api_key)r startswithrrE)rrs rget_request_contextz-_register_routes..get_request_context6 sq  0""$$// :: 0'+1133'--//g....r2exccJKddlm}|ddt|iS)Nr JSONResponseidetail)rr)fastapi.responsesrr)r6rrs rauthentication_error_handlerz6_register_routes..authentication_error_handlerI sB222222|s3xx(    r2z/healthzHealth check endpointz4Checks the health of the API and database connection Monitoring)r>rJrocKddlm}jjd{V}|ddkrdnd}|||S) z Health check endpoint that verifies database connectivity. Returns 200 if healthy, 503 if unhealthy. rrNrhealthyr i)rr)rrrwr health_checkr+)rhealthrr]s rhealth_endpointz)_register_routes..health_endpointR sw 322222y'4466666666#ZZ11Y>>ccC |F DDDDr2z/versionz!Get API version and feature flagszReturns API version information and enabled feature flags. Use this to check which capabilities are available in this deployment. get_version)response_modelr>rJror)c Kddlm}ddlm}|}t |t |j|j|j|j |j S)aI Get API version and enabled features. Returns version info and feature flags that can be used by clients to determine which capabilities are available. Note: observations flag shows the global default. Individual banks may override this setting via bank-specific configuration. rr)_get_raw_configr r ) rrrurr rr mcp_enabledrenable_bank_config_apienable_file_upload_api)rrrs rversion_endpointz*_register_routes..version_endpointd s& .-----888888 ""#!#7&, & = & =     r2z/metricszPrometheus metrics endpointz1Exports metrics in Prometheus format for scrapingcPKddlm}ddlm}m}|}|||S)zReturn Prometheus metrics.r)Response)CONTENT_TYPE_LATESTgenerate_latest)r media_type)rr prometheus_clientrr)r rr metrics_datas rmetrics_endpointz*_register_routes..metrics_endpoint sU /.....JJJJJJJJ&(( x 9LMMMMr2z!/v1/default/banks/{bank_id}/graphzGet memory graph dataz^Retrieve graph data for visualization, optionally filtered by type (world/experience/opinion). get_graphMemory)rr>rJr)ror all_strictr$rrqrorprrrc K jj||||||||| d{V} | S#t$r } t | j| jd} ~ wttf$rt$rm} ddl } t| d| } t d|d| t dt| d} ~ wwxYw) zIGet graph data from database, filtered by bank_id and optionally by type.)rrrorprrrNrrr Traceback: Error in /v1/default/banks/z/graph: rH)rwrget_graph_datar@r rreasonrr{ tracebackr format_excrr)r$rrrrorprrrrrr error_detailr]s r api_graphz#_register_routes..api_graph sF( @)88%'! /9        DK' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLVwVV VV W W WCA??? ?  @s!/5 C%AC%8A(C  C%z)/v1/default/banks/{bank_id}/memories/listzList memory unitszList memory units with pagination and optional full-text search. Supports filtering by type. Results are sorted by most recent first (mentioned_at DESC, then created_at DESC). list_memoriesrrconsolidation_staterc "K jj|||||||d{V}|S#t$r#}t dt |d}~wt $r }t |j|jd}~wttf$rt$rm}ddl } t |d| } td|d| t d t |d}~wwxYw) a List memory units for table view with optional full-text search. Results are ordered by most recent first, using mentioned_at timestamp (when the memory was mentioned/learned), falling back to created_at. Args: bank_id: Memory Bank ID (from path) type: Filter by fact type (world, experience, opinion) q: Search query for full-text search (searches text and context) consolidation_state: Filter by consolidation state for source memories (world/experience). One of 'failed', 'pending', or 'done'. limit: Maximum number of results (default: 100) offset: Offset for pagination (default: 0) )r$ fact_type search_queryr#rrrNrrrrz/memories/list: rH)rwrlist_memory_unitsr{r rr@rrrr{rrrr) r$rrr#rrrrrrr r]s rapi_listz"_register_routes..api_list st@ @);;$7 /<DK @ @ @CA??? ?' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL^w^^P\^^ _ _ _CA??? ?  @s--3 DA D(BD!A(D  Dz0/v1/default/banks/{bank_id}/memories/{memory_id}zGet memory unitzGet a single memory unit by ID with all its metadata including entities and tags. Note: the 'history' field is deprecated and always returns an empty list - use GET /memories/{memory_id}/history instead. get_memory)r>rJr)ro memory_idc NK jj|||d{V}|tdd|d|S#t$r }t|j|jd}~wt$r#}tdt|d}~wttf$rt$rp}ddl }t|d | }td |d |d |td t|d}~wwxYw)zGet a single memory unit by ID.r$r+rN Memory unit ' ' not foundrr'rrr /memories/: rH)rwrget_memory_unitr r@rrr{rrr{rrrrr$r+rrrrr r]s rapi_get_memoryz(_register_routes..api_get_memory s @)99# /:D |#.api_get_observation_history sb @)AA# /BD |#.api_recall.._fact_to_result s_#w!] L#'#6!%!2!%!2 $ 0!]!]$($8r2c&g|] }|Sr+r+)r{rrFs rrz8_register_routes..api_recall.. s#TTTood33TTTr2)rrrrcDg|]}t|j|jSrrrrr{obss rrz8_register_routes..api_recall.. s;&&& #638RURbccc&&&r2rc.i|]\}}||Sr+r+)r{fact_idrrFs rr}z8_register_routes..api_recall.. s6)))7DwG__T22)))r2)rrlr]r^r_g?z[RECALL HTTP] bank=z handler_total=z.3fzs pre=z s recall=zs post=z s results=z entities=z[RECALL TIMEOUT] bank=z handler_duration=zs - database query timed outzQRequest timed out while searching memories. Try a shorter or more specific query.rz[RECALL ERROR] bank=zs error= );rrCr4recall_max_query_tokensr7rOencoderir rjr,r:rmrrrr{rrnr]rKr^r_rZrecord_operationrkrrwr recall_asyncrlrorprurrrrrrrrrrrrryrzr@rrrrs TimeoutErrorrrr{rr)&r$r6rr handler_startmetricsmax_query_tokensencoding query_tokensrGr>rr?r@r9rArBrCrD pre_recall recall_start core_resultrecall_resultschunks_responser chunk_infoentities_responser[rwsource_facts_responserDhandler_durationrecall_duration post_recallrr rFr]s& @r api_recallz$_register_routes..api_recall< s^   '))&<<?)++8??7=99:: * * *B,BBScBBB  X @*1-ZTBY=Z=ZJ!M& $,$:7;R;Z;Z[^`h;i;i$j$jMM!'$'}uxyzu{u{}} '7tC GW ` 8 C C]` %_34?NDR\w5@@X\ $+?#?t#K Qe&ogo&B&M&Mko #K_g,GGeg 4}4J))'%@Tahas*   $yy{{ $'I$4$A$A#!-">&1!(("/%5&7#1%5)=,C,D,D,F,F(Hj09#'2$.$:","6 111OH--!% # $&!#.#7#=#=#?#?KD%.A"'/',';&&','9&&&///%d++%) !' ))))HSH`HfHfHhHh)))%&&!'*&2 H $yy{{]: "iikkL8O*Z7/IK#%% s'ssBRZss%css4CcssP[css">22ssXi>pcBS>T>T>Topss O    ' L L LAM!(KKK K#]3    $l3   #yy{{]:  LLvvvDTvvvv    j  @ @ @    #yy{{]: !!ffNNi6J6J6L6LNNL LLxwxxBRxxx`cde`f`fxxjvxx    CA??? ? @sq+O:>-C,+O:, D6!DDCO:A/I O:IO:I FO::T>P))A=T>&BT99T>z#/v1/default/banks/{bank_id}/reflectzReflect and generate answeraSReflect and formulate an answer using bank identity, world facts, and opinions. This endpoint: 1. Retrieves experience (conversations and events) 2. Retrieves world facts relevant to the query 3. Retrieves existing opinions (bank's perspectives) 4. Uses LLM to formulate a contextual answer 5. Returns plain text answer and the facts usedreflectcKt} |j}|jr|jd|j}|d|d|jj5jj|||jd|j |j ||j |j |j |j|j|j d{V}dddn #1swxYwYd}|jjg}g}g} |jD]\} } | dkr=| D]9} | t-| d| d| d  :H| d kr:| D]6} |t/| j| j| j 7| D]H} |t5| j| j| j| j| j| j It=||| }d}|jjF|jjj fd|j!D}d|j"D}tG||}tI|j||j%|j&|S#tN$r }tQ|j)|j*d}~wtVtPf$rtX$r#}tQdt[|d}~wt\$rA}t^0d||tQdt[|pdd}~wtb$rm}ddl2}t[|d|3}t^0d|d|tQdt[|d}~wwxYw)Nz Additional context: rgr<)r$rrk) r$rirkrrKrBrrorprurGrIrKrlrr[r)rr[rz mental-models)rrrrX)rjrkrlc rg|]3}t|j|jr|jnd|j|j4S)N)r`rar2rcrd)r_r`rar2rcrd)r{tcinclude_outputs rrz9_register_routes..api_reflect..N s\   $W h,:Dryy$&N"$,    r2cDg|]}t|j|jS)rw)rfrgrc)r{lcs rrz9_register_routes..api_reflect..X s*xxx\^^"(WWWxxxr2)r6ror{rr'z+Timeout in /v1/default/banks/%s/reflect: %srOzSReflect operation timed out. Consider reducing the budget or simplifying the query.rrrz /reflect: rH)4rCrirrSrkrrwr reflect_asyncrKrBrorprurGrIrKrnr5r|rrrZr]rrrVr%rrrir6r2 tool_trace llm_tracernrqr}r&r@r rrrr9rrUrrr{rr)r$r6rrWrir]based_on_resultrjrkrlr%r5rr trace_resultr6rorrr rkr]s @r api_reflectz%_register_routes..api_reflect s$())n @ME T"=SS'/SS)))WU[b[i[o)pp  $'I$4$B$B#"> &1$+$;$3 &1&1&1*1*G-4-M%C%%                $6:O$0 "  (3(<(B(B(D(D  $Iu L00).I&-- 0'0)26):,5i,@!"!"!"#o55$)D)00 2'+w)-,0L!"!"!"%*  D$OO +'+w)-)-,0L373F151B !"!"!"     #1(R_lv"w"w"w15L)5!(!;!B    *4    yxbmbwxxx +)'    # %("-"?!'"  ( L L LAM!(KKK K#]3    # @ @ @CA??? ?    LLFQR S S S1vvv!v  @ @ @    !!ffNNi6J6J6L6LNNL LLXwXX,XX Y Y YCA??? ?  @scAIA C6 ICI C F I M<"I==M<J99 M<.api_list_banksy s @)*55o5VVVVVVVVE#%000 0#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLF FF G G GCA??? ?  @s5;CA%B;;Cz!/v1/default/banks/{bank_id}/statszGet statistics for memory bankz9Get statistics about nodes and links for a specific agentget_agent_statscK jj||d{V}|d}|d}|d}i}|dD]*}|d}||vri||<|d|||d <+|d } t|t |t ||d ||||| d d | dd | |d|d|dd |dS#t$r } t| j | j d} ~ wttf$rt$rm} d dl } t| d| } t d|d| tdt| d} ~ wwxYw)z>Get statistics about memory nodes and links for a memory bank.rwN node_counts link_countslink_counts_by_fact_typelink_breakdownr%r link_typerrrrrrrrr)r$rrrrrrrrrrrrrrrrrz/stats: rH)rwrget_bank_statsrsumrr+r@r rrrr{rrrrr)r$rstats nodes_by_type links_by_typerrr(ftopsrrr r]s r api_statsz#_register_routes..api_stats sH& @)*99'Sb9ccccccccE!-0M!-0M!&'A!B 9;O-. E E%_,,*,OB'8;G #C $455 %C$ 4 4 6 677 4 4 6 677 %&7 8#0#0#5 /#&779a#8#8"%''(A"6"6%(%*+A%B&+,C&D%*YY/Eq%I%I#()=#> "( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLVwVV VV W W WCA??? ?  @s%D+D11 G!;EG!4A(GG!z5/v1/default/banks/{bank_id}/stats/memories-timeserieszMemory ingestion time-serieszOMemories ingested over a period, bucketed by time and broken down by fact type.get_memories_timeseries7draTimestamp column to bucket on. `created_at` (default) = ingest time; `mentioned_at` / `occurred_start` = event time, useful for migrated corpora where ingest time is a single point and doesn't reflect the underlying knowledge timeline. Unknown values fall back to `created_at`.rIr!r#cK jj||||d{V}tdi|S#t$r }t |j|jd}~wtt f$rt$rm}ddl }t|d| }td|d|t dt|d}~wwxYw) N)r!r#rrrrrz/stats/memories-timeseries: rHr+)rwrrr r@r rrrr{rrrrr) r$r!r#rrrrr r]s rapi_memories_timeseriesz1_register_routes..api_memories_timeseries sE, @)AA:BD.5555 5' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLjwjj\hjj k k kCA??? ?  @s"4: C*AC*=A(C%%C*z$/v1/default/banks/{bank_id}/entitiesz List entitieszqList all entities (people, organizations, etc.) known by the bank, ordered by mention count. Supports pagination. list_entitiesEntitiesz$Maximum number of entities to returnzOffset for paginationc,K jj||||d{V}td|dD|d|d|dS#t$r }t |j|j d}~wtt f$rt$rm}d dl }t|d | }td |d |t dt| d}~wwxYw)z0List entities for a memory bank with pagination.)rrrNc&g|]}tdi|Sr+)rr{rs rrz?_register_routes..api_list_entities.. s&BBBq~****BBBr2rrrrrrrrrz /entities: rH)rwrrrr@r rrrr{rrrrr) r$rrrrrrr r]s rapi_list_entitiesz+_register_routes..api_list_entities sr @)77uV_8D&BBDMBBB7m7mH~   ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLYwYY<YY Z Z ZCA??? ?  @s%AA## D-BD&A(DDz*/v1/default/banks/{bank_id}/entities/graphzGet entity co-occurrence graphzVReturn a graph of entities (nodes) and their co-occurrences (edges) for visualization.get_entity_graphz/Maximum number of co-occurrence edges to returnrz-Minimum cooccurrence_count to include an edge min_countcK jj||||d{VS#t$r }t |j|jd}~wttf$rt$rm}ddl }t|d| }t d|d|t dt|d}~wwxYw) z-Return entity co-occurrence graph for a bank.)rrrNrrrrz/entities/graph: rH)rwrrr@r rrrr{rrrrr)r$rrrrrr r]s rapi_entity_graphz*_register_routes..api_entity_graphs3 @)::u ?; ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL_w__Q]__ ` ` `CA??? ?  @s!(. CAC1A(CCz0/v1/default/banks/{bank_id}/entities/{entity_id}zGet entity detailszOGet detailed information about an entity including observations (mental model). get_entityrc K jj|||d{V}|tdd|dt |d|d|d |d |d t |d d |dDS#t $r }t|j|jd}~wttf$rt$rp}ddl }t|d| }td|d|d|tdt|d}~wwxYw)z%Get entity details with observations.rwNr.zEntity z not foundrrrrrrrcDg|]}t|j|jSrIrJrKs rrz<_register_routes..api_get_entity..Es:.38#JZ[[[r2r)rrrrrrrrrrz /entities/r2rH)rwrrr rrr@rrrr{rrrrr)r$rrr rrr r]s rapi_get_entityz(_register_routes..api_get_entity,s @9+66w [j6kkkkkkkkF~#<[i<[<[<[\\\\'$<%&67$_5!,/ -( );<<%n5    ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLewee)eeWcee f f fCA??? ?  @s%BB E%CEA+E  Ez;/v1/default/banks/{bank_id}/entities/{entity_id}/regeneratez+Regenerate entity observations (deprecated)zUThis endpoint is deprecated. Entity observations have been replaced by mental models.regenerate_entity_observationsT)rr>rJr)rorc(Ktdd)z2Regenerate observations for an entity. DEPRECATED.izIThis endpoint is deprecated. Entity observations are no longer supported.rr )r$rrs r"api_regenerate_entity_observationsz<_register_routes..api_regenerate_entity_observationsUs%^    r2z)/v1/default/banks/{bank_id}/mental-modelszList mental modelsz5List user-curated living documents that stay current.rz Mental ModelszFilter by tags)r rJrhzHow to match tagsrrr6zoDetail level: 'metadata' (names/tags only), 'content' (adds content/config), 'full' (includes reflect_response))rr)r tags_filter)rhallexactr)rrr6c K jj|||||||d{V}td|DS#t$r }t |j|jd}~wtt f$rt$rm}ddl } t|d| } td|d | t d t|d}~wwxYw) zList mental models for a bank.)r$rorprrrrNc&g|]}tdi|Sr)r?rs rrzD_register_routes..api_list_mental_models..s'1b1b1bq2E2J2J2J2J1b1b1br2rrrrError in GET /v1/default/banks//mental-models: rH)rwrrrGr@r rrrr{rrrrr) r$rrprrrrrkrrr r]s rapi_list_mental_modelsz0_register_routes..api_list_mental_modelsns^* @"%)"2"E"E % /#F##M+1b1bTa1b1b1bccc c' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLb7bbT`bb c c cCA??? ?  @%AA C;A00C;A(C66C;z;/v1/default/banks/{bank_id}/mental-models/{mental_model_id}zGet mental modelz"Get a specific mental model by ID.get_mental_modelrVc dK jj||||d{V}|tdd|dt di|S#t tf$rt $r }t|j|jd}~wt$r#}tdt|d}~wt$rp}ddl }t|d | }td |d |d |td t|d}~wwxYw)zGet a mental model by ID.)r$rVrrNr.Mental model 'r0rr'rrr/mental-models/r2rHr+)rwrrr r?rr@rrr{rr{rrrr) r$rVrrrrrr r]s rapi_get_mental_modelz._register_routes..api_get_mental_models$ @!$!1!B!B / / "C""L ##.api_get_mental_model_historys @)BB / /CD |#.api_create_mental_models" @!$!1!E!EY!./+/7 <"&)5TYY?59\K //111t /"F " "      L9+MM ,T 2 /NF -\$=O^des^tuuu u @ @ @CA??? ?#]3    ' L L LAM!(KKK K @ @ @    !!ffNNi6J6J6L6LNNL LLcGccUacc d d dCA??? ?  @s1CC F$C11F$D** F$7A(FF$zC/v1/default/banks/{bank_id}/mental-models/{mental_model_id}/refreshzRefresh mental modelzWSubmit an async task to re-run the source query through reflect and update the content.refresh_mental_modelc K jj|||d{V}t|ddS#t$r#}t dt |d}~wt$r#}t dt |d}~wtt f$rt$r }t |j |j d}~wt$rp}d dl }t |d |}td |d |d |t dt |d}~wwxYw)z>Refresh a mental model by re-running its source query (async).rNr)rrr'rr.rrrrz /refresh: rH)rwrrrr9r rr{rr@rrr{rrrr)r$rVrrrrr r]s rapi_refresh_mental_modelz2_register_routes..api_refresh_mental_models @9+MM / /NF 0VN=S\deee e# @ @ @CA??? ? @ @ @CA??? ?#]3    ' L L LAM!(KKK K @ @ @    !!ffNNi6J6J6L6LNNL LLt7tt?ttfrtt    CA??? ? @s<>A E A,, E 9BE 5C E A+EE zUpdate mental modelz1Update a mental model's name and/or source query.rc ~K jj|||j|j|j|j|jr|jnd|d{V}|tdd|dtd i|S#t$r }t|j |j d}~wttf$rt$rp}ddl}t#|d|}t&d |d |d |td t#|d}~wwxYw)zUpdate a mental model.Nrr.rr0rrr!Error in PATCH /v1/default/banks/rr2rHr+)rwrrr[r@rKrorBr~r r?r@rrrr{rrrrr) r$rVrrrrrr r]s rapi_update_mental_modelz1_register_routes..api_update_mental_modelAs  @!$!1!E!E /Y!.?Y59\K //111t /"F " "      L##.api_delete_mental_modeljs @I,@@ / /AG  k#.api_list_directives..s'/[/[/[10A0F0FA0F0F/[/[/[r2rrrrr /directives: rH)rwrrr*r@r rrrr{rrrrr) r$rrprrrrrlrrr r]s rapi_list_directivesz-_register_routes..api_list_directivess^$ @"y/?? %' / @  J)/[/[PZ/[/[/[\\\ \' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL_7__Q]__ ` ` `CA??? ?  @rz5/v1/default/banks/{bank_id}/directives/{directive_id}z Get directivezGet a specific directive by ID. get_directiverc K jj|||d{V}|tdd|dt d i|S#t $r }t|j|jd}~wttf$rt$rp}ddl }t|d| }td |d |d |td t|d}~wwxYw)zGet a directive by ID.r$rrNr. Directive 'r0rrrr /directives/r2rHr+)rwrrr r&r@rrrr{rrrrr)r$rrrrrr r]s rapi_get_directivez+_register_routes..api_get_directivesr @!i.<<) /=I  #>DzCreate directivez6Create a hard rule that will be injected into prompts.rc hK jj||j|j|j|j|j|d{V}td i|S#t$r#}tdt|d}~wt$r }t|j |jd}~wttf$rt $rm}ddl}t|d|}t&d|d|td t|d}~wwxYw) zCreate a directive.rNr'rrrrrrHr+)rwrrr[rr'r(ror&r{r rr@rrrr{rrrr)r$rrrrrr r]s rapi_create_directivez._register_routes..api_create_directives @!i.??Y .Y /@I%11y11 1 @ @ @CA??? ?' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL`G``R^`` a a aCA??? ?  @s1AA D1 A>> D1 B&&D1A(D,,D1zUpdate directivez Update a directive's properties.rc HK jj|||j|j|j|j|j|d{V}|tdd|dtd i|S#t$r }t|j |j d}~wttf$rt$rp}ddl}t!|d|}t$d |d |d |td t!|d}~wwxYw)zUpdate a directive.)r$rr[rr'r(rorNr.rr0rrrrrr2rHr+)rwrrr[rr'r(ror r&r@rrrr{rrrrr) r$rrrrrrr r]s rapi_update_directivez._register_routes..api_update_directives  @!i.??)Y .Y /@        I #.api_delete_directive,sl @I,==) />G  e#.api_list_documentsNsA@ @)88% /9DK' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLZwZZLZZ [ [ [CA??? ?  @s!-3 C#AC#6A(CC#z?/v1/default/banks/{bank_id}/documents/{document_id:path}/chunkszList document chunksz=List all chunks for a given document, ordered by chunk index.list_document_chunksz"Maximum number of chunks to returnr)r*rrJc K jj|||||d{V}|tdd|S#t$r }t|j|jd}~wttf$rt$rp}ddl }t|d| }t d|d |d |td t|d}~wwxYw) a5 List all chunks for a document, ordered by chunk_index. Args: bank_id: Memory Bank ID (from path) document_id: Document ID (from path) limit: Maximum number of chunks to return (default: 100) offset: Offset for pagination (default: 0) )r$rrrrNr.Document not foundrrrr /documents/z /chunks: rH)rwrrr r@rrrr{rrrrr) r$rrrrrrrr r]s rapi_list_document_chunksz2_register_routes..api_list_document_chunkss]0 @9+@@' / AF~#A C7A))C7A+C22C7zB/v1/default/banks/{bank_id}/documents/{document_id:path}/reprocesszReprocess documentaRe-run the retain pipeline on an existing document without changing its content. This deletes the existing memory units and re-extracts facts using the current engine configuration. Useful when the LLM model, chunking strategy, or extraction settings have changed.reprocess_documentc (K jj|||d{V}|tddt d|d|d S#t $r }t|j|jd}~wttf$rt$rp}d dl }t|d | }td |d |d|tdt|d}~wwxYw)z Reprocess a document by re-running retain with its existing content and parameters. Args: bank_id: Memory Bank ID (from path) document_id: Document ID (from path) )r$rrNr.rrTr)r%)r#r)r%rrrrz /reprocess: rH)rwrrr rr@rrrr{rrrrrr$rrrrrr r]s rapi_reprocess_documentz0_register_routes..api_reprocess_documents}. @9+>>' /?F ~#.api_get_documentsD$ @ Y-::;ap:qqqqqqqqH R#.api_list_tagssR @(( Y-DD#!$3 E!Y-77#!$3 8K' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLUwUU|UU V V VCA??? ?  @s%AA"" D,BD%A(D  Dz"/v1/default/chunks/{chunk_id:path}zGet chunk detailszGet a specific chunk by its ID get_chunkcK jj||d{V}|stdd|S#t$r }t|j|jd}~wttf$rt$rm}ddl }t|d| }t d|d |td t|d}~wwxYw) z Get a specific chunk with its text. Args: chunk_id: Chunk ID (from path, format: bank_id_document_id_chunk_index) rwNr.zChunk not foundrrrzError in /v1/default/chunks/r2rH)rwrrr r@rrrr{rrrrr)rrchunkrrr r]s r api_get_chunkz'_register_routes..api_get_chunkIs8 @)*44X4________E O#.api_update_documenths6 9 C8deee e @9+;;Y / <F  R#.api_delete_documents0 @9+;;Kbq;rrrrrrrrF()Q..#.api_list_operations..s'SSS-3333SSSr2rrrrrrz /operations: rH)rwrrrr@r rrrr{rrrrr) r$rrrrrrrrrr r]s rapi_list_operationsz-_register_routes..api_list_operationssz. @9+;; / /<F*WoSSf\>RSSS  ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL[w[[\[[ \ \ \CA??? ?  @s%AA D %BD A(DD z5/v1/default/banks/{bank_id}/operations/{operation_id}zGet operation statuszGet the status of a specific async operation. Returns 'pending', 'completed', or 'failed'. Completed operations are removed from storage, so 'completed' means the operation finished successfully.get_operation_statuszOInclude the raw task payload (submission params) in the response. May be large.r)include_payloadc PK tj|n"#t$rtdd|wxYwjj||||d{V}td i|S#t$r }t|j |j d}~wttf$rt$rp}ddl }t|d|}t d|d |d |td t|d}~wwxYw) z%Get the status of an async operation.r'Invalid operation_id format: r)rrNrrr /operations/r2rHr+)uuidUUIDr{r rwrrrr@rrrr{rrrrr) r$r)rrrrrr r]s rapi_get_operation_statusz2_register_routes..api_get_operation_statuss& @ l ,'''' l l l#Cancel a pending async operation by removing it from the queuecancel_operationc K tj|n"#t$rtdd|wxYwjj|||d{V}td i|S#t$r#}tdt|d}~wt$r }t|j |j d}~wttf$rt$rp}ddl}t|d|}t d |d |d |td t|d}~wwxYw)z!Cancel a pending async operation.r'rrrwNr.rrrrr2rHr+)rrr{r rwrrrrr@rrrr{rrrrr$r)rrrrr r]s rapi_cancel_operationz._register_routes..api_cancel_operation%s @ l ,'''' l l l#.api_retry_operationHs @ l ,'''' l l l#.api_get_bank_profilejs! @  I,==E>G#C E4C))E4A(E//E4zUpdate memory bank dispositionzBUpdate bank's disposition traits (skepticism, literalism, empathy)update_bank_dispositionc <K jj||j|d{V jj||d{V}t |ddr|dnt|d}|dpd}t||dtdi|||S#t$r }t|j |j d}~wttf$rt $rm}d dl}t%|d |}t(d |d |tdt%| d}~wwxYw)zUpdate bank disposition traits.rwNrr~rrr[rrrrrrrHr+)rwrrrr~rrCrr+rrr@r rrrr{rrrrr) r$r6rrrrrrr r]s rapi_update_bank_dispositionz5_register_routes..api_update_bank_dispositions @)"::,7799?;         I,==gWf=ggggggggG7=1<@@2 &11333'-011  kk),,2G&V_-AA0@AA"  ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLXwXX,XX Y Y YCA??? ?  @s%C%C++ F5DF.A(FFz&/v1/default/banks/{bank_id}/backgroundz-Add/merge memory bank background (deprecated)zRDeprecated: Use PUT /mission instead. This endpoint now updates the mission field.add_bank_backgroundcK jj||j|d{V}|dpd}t ||S#t $r }t|j|j d}~wttf$rt$rm}ddl }t|d|}td |d |td t|d}~wwxYw) zDDeprecated: Add or merge bank background. Now updates mission field.rwNrr)rrrrrrz /background: rH)rwrmerge_bank_missionrr+rr@r rrrr{rrrrr) r$r6rrrrrr r]s rapi_add_bank_backgroundz1_register_routes..api_add_bank_backgroundsX @9+>>/?Fjj++1rG%g'JJJ J' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL[w[[\[[ \ \ \CA??? ?  @s%AA D $A??D A(DD z/v1/default/banks/{bank_id}zCreate or update memory bankzrCreate a new agent or update existing agent with disposition and mission. Auto-fills missing fields with defaults.create_or_update_bank create_bankc K jj||d{V|j- jj||j|d{V|}|r, jjj|||d{V jj||d{V}t|ddr|d nt|d}| dpd}t||dtdi||| S#t$r }t|j|j d}~wt$tf$rt&$rm}d dl}t+|d |} t.d |d| tdt+| d}~wwxYw)z7Create or update an agent with disposition and mission.rwNr[rrr~rrr[rrrrrr2rHr+rwrrr[ update_bankrrrrCr~rr+rrr@r rrrr{rrrrr r$r6rr final_profilerrrrr r]s rapi_create_or_update_bankz3_register_routes..api_create_or_update_banks) @)"33G_3]] ] ] ] ] ] ] ]|'i&22 $33%7799N ui&7JJ7Tbdsttttttttt#&)"2"C"CG]l"C"m"mmmmmmmM=7FF8 m,77999- 677  $'' 228bG&"6*-AA0@AA"  ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLPwPP,PP Q Q QCA??? ?  @%EE G9E..G9 A(G44G9zPartial update memory bankzJPartially update an agent's profile. Only provided fields will be updated.r$c K jj||d{V|j- jj||j|d{V|}|r, jjj|||d{V jj||d{V}t|ddr|d nt|d}| dpd}t||dtdi||| S#t$r }t|j|j d}~wt$tf$rt&$rm}d dl}t+|d |} t.d |d| tdt+| d}~wwxYw)zAPartially update an agent's profile (name, mission, disposition).rwNr"rr~rrr[rrrrrr2rHr+r#r%s rapi_update_bankz)_register_routes..api_update_banks) @)"33G_3]] ] ] ] ] ] ] ]|'i&22 $33%7799N ui&7JJ7Tbdsttttttttt#&)"2"C"CG]l"C"m"mmmmmmmM=7FF8 m,77999- 677  $'' 228bG&"6*-AA0@AA"  ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLVWVV VV W W WCA??? ?  @r(zDelete memory bankzDelete an entire memory bank including all memories, entities, documents, and the bank profile itself. This is a destructive operation that cannot be undone. delete_bankc nK jj||d{V}tdd|d|dd|ddz|d dz S#t $r }t |j|j d}~wtt f$rt$rm}ddl }t|d | }td |d|t dt| d}~wwxYw)z.Delete an entire memory bank and all its data.rwNTrz.' and all associated data deleted successfullyrrentities_deleteddocuments_deletedrrrrr2rH)rwrr+rr+r@r rrrr{rrrrrr$rrrrr r]s rapi_delete_bankz)_register_routes..api_delete_bankSs @9+77Q`7aaaaaaaaF!XXXX$jj)?CC**/334**0!445 ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLWgWWWW X X XCA??? ?  @s%A>B D4B))D4A(D//D4z"/v1/default/banks/{bank_id}/importzImport bank templateurImport a bank template manifest to create or update a bank's configuration, mental models, and directives. If the bank does not exist it is created. Config fields are applied as per-bank overrides. Mental models are matched by id, directives by name — existing ones are updated, new ones are created. Use dry_run=true to validate the manifest without applying changes.import_bank_templatezBank Templatesz#Validate only, do not apply changesrcdK |d{V}ddlm} t|}nR#|$rJ}d|D}t ddd|d}~wwxYwt|} | r't dd d| |r=t||j dud |j pgDd |j pgDd S j j||d{Vt! j j|||d{VS#t"$r#}t dt%|d}~wt&$r }t |j|jd}~wt,t f$rt.$rm}ddl} t%|d| } t4d|d| t dt%|d}~wwxYw)z Import a bank template manifest.Nr)rcng|]2}dd|dDd|d3S).c34K|]}t|VdSry)r)r{locs r zP_register_routes..api_import_bank_template...s(%E%E3c#hh%E%E%E%E%E%Er2r6r2msg)r)r{errs rrzF_register_routes..api_import_bank_template..sJlllZ]SXX%E%E#e*%E%E%EEEUUUUUlllr2r'z#Template schema validation failed: z; rzTemplate validation failed: cg|] }|j Sr+rrs rrzF_register_routes..api_import_bank_template..s*T*T*TA14*T*T*Tr2cg|] }|j Sr+rrs rrzF_register_routes..api_import_bank_template..s'P'P'P1'P'P'Pr2T)r$rrrrrw)rr$rrrrz /import: rH)rpydanticrrmodel_validaterr rrrrrkrlrwrrrr{rr@rrrr{rrrr) r$r6rrraw_bodyrrrrvalidation_errorsrr r]s rapi_import_bank_templatez2_register_routes..api_import_bank_templatews&3 @%\\^^++++++H 0 0 0 0 0 0 +::8DD"   llabaiaiakaklll# #T6ARARTT !7t < <   # #X$))DU:V:VXX 1##'9D#8*T*T$:L:RPR*T*T*T'P'P9NB'P'P'P )"33G_3]] ] ] ] ] ] ] ]5y' /    @ @ @CA??? ?' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL\G\\l\\ ] ] ]CA??? ?  @s\ EAEBAB  BA9E A E H/E<< H/ F$$H/A(H**H/z"/v1/default/banks/{bank_id}/exportzExport bank templatezExport a bank's current configuration, mental models, and directives as a template manifest. The exported manifest can be imported into another bank to replicate the setup.export_bank_templatec DK jj||dd{V}|tdd|djj|d{Vjjj|d{V}ttj fd| D}|r tdi|nd}jj || d{V}g}|D]}| d i} | r tdi| n t} |t!|d |d |d | dg| dd| jj|d|d{V} g} | D]q} | t%| d | d| dd| dd| dgrt't(||r|nd| r| ndS#t*$r }t|j|jd}~wt0tf$rt2$rm}ddl}t7|d|}t:d|d|tdt7|d}~wwxYw)z@Export a bank's config and mental models as a template manifest.FrNr.rr0rc$i|] \}}|v || Sr+r+)r{r|rvtemplate_config_fieldss rr}zF_register_routes..api_export_bank_template..s*!i!i!i41aQRhMhMh!QMhMhMhr2rrBrr[r@rorKrLrMrrr'rr(T)r[rr'r(rorrrz /export: rHr+)rwrrr _authenticate_tenantr_load_bank_configrrarrrrr+r5rr[rrrrr@rrrr{rrrrr)r$rrbank_overridesfiltered_overrides bank_configmental_models_rawtemplate_mental_modelsr trigger_datarBdirectives_rawtemplate_directivesrrrr rDr]s @rapi_export_bank_templatez2_register_routes..api_export_bank_templates#D @I,==E>G#3G3G3I3I!i!i!i FXb,BB/ABBB^bK'*i&6&I&I'J''!!!!!! EG "'  !vvi44 @Lf,<<|<<.api_get_bank_template_schemas$55777r2z(/v1/default/banks/{bank_id}/observationszClear all observationszcDelete all observations for a memory bank. This is useful for resetting the consolidated knowledge.clear_observationsc:K jj||d{V}tdd|ddd|ddS#t $r }t |j|j d}~wtt f$rt$rm}ddl }t|d | }td |d |t d t| d}~wwxYw)z"Clear all observations for a bank.rwNTzCleared rrz observationsrrrr/observations: rH)rwrrTrr+r@r rrrr{rrrrrr/s rapi_clear_observationsz0_register_routes..api_clear_observationssa @9+>>wXg>hhhhhhhhF!P6::oq#A#APPP$jj!<<  ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLdgddVbdd e e eCA??? ?  @s%A$A** D4BD-A(DDz1/v1/default/banks/{bank_id}/consolidation/recoverzRecover failed consolidationzReset all memories that were permanently marked as failed during consolidation (after exhausting all LLM retries and adaptive batch splitting) so they are picked up again on the next consolidation run. Does not delete any observations.recover_consolidationcK jj||d{V}t|dS#t$r }t |j|jd}~wtt f$rt$rm}ddl }t|d| }td|d |t d t|d}~wwxYw) z1Reset consolidation-failed memories for recovery.rwNr)rrrrrz/consolidation/recover: rH)rwrretry_failed_consolidationrr@r rrrr{rrrrrr/s rapi_recover_consolidationz3_register_routes..api_recover_consolidation<s. @9+FFw`oFppppppppF/f_>UVVV V' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLkGkk]ikk l l lCA??? ?  @s$.api_clear_memory_observationsYsW" @9+II# /JF 3AXYYY Y' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLpWpp ppbnpp    CA??? ? @s$=A C6 A((C6A+C11C6z"/v1/default/banks/{bank_id}/configzGet bank configurationuGet fully resolved configuration for a bank including all hierarchical overrides (global → tenant → bank). The 'config' field contains all resolved config values. The 'overrides' field shows only bank-specific overrides.get_bank_configcKtjstdd jj|d{V jjjr[ddlm}||d|} jj jjj |d{V jjj ||d{V} jjj |d{V}t||| S#t$r }t|j|jd}~wt$tf$rt&$rm}ddl}t+|d |}t.d |d |td t+|d}~wwxYw)zEGet configuration for a bank with all hierarchical overrides applied.r._Bank configuration API is disabled. Set HINDSIGHT_API_ENABLE_BANK_CONFIG_API=true to re-enable.rNr)BankReadContextr`r$ operationrrrr /config: rH)r4r r rwrrE_operation_validatorhindsight_api.extensionsrc_validate_operationvalidate_bank_readrr`rFrr@rrrr{rrrrr) r$rrcr config_dictrGrrr r]s rapi_get_bank_configz-_register_routes..api_get_bank_config~sG||2 x  @)"77HH H H H H H H Hy4 DDDDDD%ogARdsttti&::I$9LLSQQ !$ 0 A Q QRY[j k kkkkkkkK$'9#3#D#V#VW^#_#_______N%gkUcddd d' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL[7[[\[[ \ \ \CA??? ?  @s%C7D!! G+EG$A(G  GzUpdate bank configurationzUpdate configuration overrides for a bank. Only hierarchical fields can be overridden (LLM settings, retention parameters, etc.). Keys can be provided in Python field format (llm_provider) or environment variable format (HINDSIGHT_API_LLM_PROVIDER).rc`Ktjstdd jj|d{V jjjr[ddlm}||d|} jj jjj |d{V jjj ||j |d{V jjj ||d{V} jjj |d{V}t!||| S#t"$r }t|j|jd}~wt($r#}td t+|d}~wt,tf$rt.$rm}ddl}t+|d |} t4d |d | tdt+|d}~wwxYw)z*Update configuration overrides for a bank.r.rbrNrBankWriteContextrrdrr'rrrfrH)r4r r rwrrErgrhrorivalidate_bank_writerrrr`rFrr@rrr{rrr{rrrr) r$r6rrorrkrGrrr r]s rapi_update_bank_configz0_register_routes..api_update_bank_configs||2 x  @)"77HH H H H H H H Hy4 EEEEEE&&wBVhwxxxi&::I$9MMcRR )"3FFwPWP_apqq q q q q q q q!$ 0 A Q QRY[j k kkkkkkkK#&9#3#D#V#VW^#_#_______N%gkUcddd d' L L LAM!(KKK K @ @ @CA??? ?#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL]W]]|]] ^ ^ ^CA??? ?  @s1D(E H-E77 H-F""H-A(H((H-zReset bank configurationzReset bank configuration to defaults by removing all bank-specific overrides. The bank will then use global and tenant-level configuration only.reset_bank_configcKtjstdd jj|d{V jjjr[ddlm}||d|} jj jjj |d{V jjj |d{V jjj ||d{V} jjj |d{V}t||| S#t $r }t|j|jd}~wt&tf$rt($rm}ddl}t-|d |}t0d |d |td t-|d}~wwxYw)z.api_reset_bank_configsw||2 x  @)"77HH H H H H H H Hy4 EEEEEE&&wBUgvwwwi&::I$9MMcRR )"3EEgNN N N N N N N N!$ 0 A Q QRY[j k kkkkkkkK#&9#3#D#V#VW^#_#_______N%gkUcddd d' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL^g^^P\^^ _ _ _CA??? ?  @s%D!E G;E00G;A(G66G;z'/v1/default/banks/{bank_id}/consolidatezTrigger consolidationzLRun memory consolidation to create/update observations from recent memories.trigger_consolidation consolidationcK jj||d{V}t|d|ddS#t $r }t |j|jd}~wtt f$rt$rm}ddl }t|d | }td |d |t d t|d}~wwxYw) z)Trigger consolidation for a bank (async).rNr)rF)r)rrrrrz/consolidate: rH)rwrsubmit_async_consolidationrr+r@r rrrr{rrrrrr/s rapi_trigger_consolidationz3_register_routes..api_trigger_consolidationsJ @9+FFwhwFxxxxxxxxF(#N3#ZZ>> ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLaGaaS_aa b b bCA??? ?  @s%AA D!A<<DA(DDz$/v1/default/banks/{bank_id}/webhookszRegister webhookzIRegister a webhook endpoint to receive event notifications for this bank.create_webhookWebhooks)rr>rJr)rorcK tj} jj|||j|j|j|j|j |d{V}|r|dng}t|trtj|}|r|dnd}t|trtj|}t#t|d|d|dd|rt%|ngt'|d|rt)j|n t)t-|d d r|d nt|d t-|d d r|d nt|d  S#t0t2f$rt4$rm}d dl}t|d|} t:d|d| t3dt|d}~wwxYw)zRegister a webhook for a bank.)r!rrrrhttp_config_jsonrNrrrr$rrr isoformatr rr$rrrrrrrrrr /webhooks: rHr)ruuid4rwrrzrrrrrmodel_dump_jsonrrrrrdumpsrr,rrmodel_validate_jsonrCrrr r{rrrr) r$r6rr!r(event_types_valhttp_config_valrrr r]s rapi_create_webhookz,_register_routes..api_create_webhook.s , @J (77%K~#/!(!4!D!D!F!F /8        C58?c-00RO/3// >"&*_"="=47Ac-00TO/400 >"&*_"="="s4y>>IJ5DLD111"S^,,")-A/RRR&((3|,k::,3|,66888\*++3|,k::,3|,66888\*++ "$]3     @ @ @    !!ffNNi6J6J6L6LNNL LL^G^^P\^^ _ _ _CA??? ?  @sGGI%8A(I  I%z List webhooksz(List all webhooks registered for a bank. list_webhookscK jj||d{V}dtfd|DS#tt f$rt $rm}ddl}t|d| }t d|d |t d t| d}~wwxYw) zList webhooks for a bank.rwNc|d}t|trtj|}|d}t|trtj|}t t|d|d|dd|rt|ngt|d|rtj |n tt|ddr|d nt|dt|d dr|d  nt|d  S) Nrrrr$rrrrrr) rrrrrrrr,rrrrCr)r(rrs r_parse_webhook_rowzG_register_routes..api_list_webhooks.._parse_webhook_rowsO"%m"4os33B&*j&A&AO"%m"4ot44B&*j&A&AO&3t9~~ NE 9H P_ 5 5 5b Y00&!- 1 Eo V V V*,,s<0+>> 0s<0::<<<S.//s<0+>> 0s<0::<<<S.//r2c&g|] }|Sr+r+)r{r(rs rrz?_register_routes..api_list_webhooks..s%-V-V-V#.@.@.E.E-V-V-Vr2rrrrrrHr) rwrrrrr r{rrrrr)r$rrowsrrr rr]s @rapi_list_webhooksz+_register_routes..api_list_webhooksls3' @)77 /8D    2'-V-V-V-VQU-V-V-VWWW W#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL]7]]|]] ^ ^ ^CA??? ?  @sAA C'A(CCz1/v1/default/banks/{bank_id}/webhooks/{webhook_id}zDelete webhookzRemove a registered webhook.delete_webhookr!c K jj|tj||d{V}|st ddt dS#tt f$rt$rp}ddl }t|d | }t d |d |d |t d t|d}~wwxYw)zDelete a webhook.rwNr.Webhook not foundrTrrrr /webhooks/r2rH)rwrrrrr rrr{rrrrr)r$r!rrrrr r]s rapi_delete_webhookz,_register_routes..api_delete_webhooksA @I,;; *%% /<G  Q#.api_update_webhooks A @%'K Ij117;F-F gk***""#:S[[#:#:;;;6!! gn---""#=F #=#=>>>&& g1222""#BS[[#B#BCCCF"" go...""#>V#>#>???&& g1AACCDDD""#IS[[#I#I#IJJJ \#"&*_"="=!-0O/400 >"&*_"="="s4y>>IJ5DLD111"S^,,")-A/RRR&((3|,k::,3|,66888\*++3|,k::,3|,66888\*++ "$]3     @ @ @    !!ffNNi6J6J6L6LNNL LLlWllPZll^jll m m mCA??? ?  @sMM O(A+OOzInspect delivery history for a webhook (useful for debugging).list_webhook_deliveriesrr z&Maximum number of deliveries to return)r*rrJz+Pagination cursor (created_at of last item)cursorc xK jj|tj||||d{V}n#t $rt ddwxYwt||k}|d|}|r|r|ddnd}td|D| S#tt f$rt$rp} d dl } t| d | } td |d |d| t dt| d} ~ wwxYw)zUList deliveries for a specific webhook, newest first. Use next_cursor for pagination.)rrrNr.rrrYrc\g|])}tt|*Sr+)r r/r)r{r(s rrzI_register_routes..api_list_webhook_deliveries..6s.cccWZ.GGS RRcccr2)rr2rrrrz /deliveries: rH)rwrrrr LookupErrorr rOr1rr{rrrrr) r$r!rrrrhas_morepager2rrr r]s rapi_list_webhook_deliveriesz5_register_routes..api_list_webhook_deliveriess  @ Q Y-EEIj))!$3 F Q Q Q#.api_retain..us+/u/u/ubcI\S\0]0]/u/u/ur2r]rorrr)rrrr)r%Tr)r#r$r%r r)r*r3r'aJBatch API is enabled (HINDSIGHT_API_RETAIN_BATCH_ENABLED=true) but async=false. Batch operations can take several minutes to hours and will timeout in synchronous mode. Please set async=true in your request to use background processing, or disable batch API by setting HINDSIGHT_API_RETAIN_BATCH_ENABLED=false in your environment.rrrr<)r$r)r$contentsr)rm)r$rrrr return_usageoutbox_callbackFr"rz...z [z ] content=z , context=z , timestamp=rPz Input (z items): rrz/memories (retain): rH).rCrrrrrrrr]rorrrr rwrsubmit_async_retainrrr=rOrur4retain_batch_enabledr r<rSretain_batch_async_build_retain_outbox_callbackr6r+rr r!r@rrrr{rrrrrrr)r$r6rrWstrategy_groupsitem effective content_dictall_operation_idstotal_items_countgroup_strategyrrr4r total_usager&rr input_summaryrcontent_preview input_debugr r]s r api_retainz$_register_routes..api_retainBsA<())~ @<>O  @ @ M O3313OI.&/%> >W,,15L..^@15L.<;.2lL+==/3}L,#C262BL/=v/u/ugkgt/u/u/uL,95+/9L(*69=9PL!56#/262BL/ *11,????~K $&!$%!0?0E0E0G0G ? ?,NH#&9#3#G#G &-&;!/(7 $H$$F&,,VN-CDDD% )>>%%%44#'#*'8!%@Q([(9!(<(ABS>T>TWX>X>X):):^b    <;;;;;#. '$'g%&!(aqWXYYY --hPU-VV4C4I4I4K4K0.1i.>.Q.Q$+%-*1*?%3,;)-,/I,<,Z,Z(/)1-1'6':'<'< -[--/R / / ) ) ) ) ) ) *S]]:) *4-8-EHZ-Z.9.G%J].]-8-EHZ-Z+++K#0&44#'#*'8!&!, ( L L LAM!(KKK K#]3     @ @ @    M$W]33  4@CDL@Q@QTW@W@W$,tt"4u"<"<]a]i$$n!nnnnDLnn^b^lnn))M22Kq6688gm,,888C88(335588  LLbwbbT`bb c c cCA??? ?% @sQFL 0AL CK L K##L &K#'"L Q L//Q D QQ z(/v1/default/banks/{bank_id}/files/retainzConvert files to memoriesuUpload files (PDF, DOCX, etc.), convert them to markdown, and retain as memories. This endpoint handles file upload, conversion, and memory creation in a single operation. **Features:** - Supports PDF, DOCX, PPTX, XLSX, images (with OCR), audio (with transcription) - Automatic file-to-markdown conversion using pluggable parsers - Files stored in object storage (PostgreSQL by default, S3 for production) - Each file becomes a separate document with optional metadata/tags - Always processes asynchronously — returns operation IDs immediately **The system automatically:** 1. Stores uploaded files in object storage 2. Converts files to markdown 3. Creates document records with file metadata 4. Extracts facts and creates memory units (same as regular retain) Use the operations endpoint to monitor progress. **Request format:** multipart/form-data with: - `files`: One or more files to upload - `request`: JSON string with FileRetainRequest model **Parser selection:** - Set `parser` in the request body to override the server default for all files. - Set `parser` inside a `files_metadata` entry for per-file control. - Pass a list (e.g. `['iris', 'markitdown']`) to define an ordered fallback chain — each parser is tried in sequence until one succeeds. - Falls back to the server default (`HINDSIGHT_API_FILE_PARSER`) if not specified. - Only parsers enabled on the server may be requested; others return HTTP 400. file_retainFiles.zFiles to upload and convertz(JSON string with FileRetainRequest modelfilesc Kddlm}|jstdd t|}n3#t $r&}tddt|d}~wwxYwt|j krtdd j d |j r\t|j t|kr7tdd t|j d t|d j j j }jjn|dtt tzdzdt tffd }dt tdtddffd } |j| ||jdddl} g} d} t'|D]\} }|d{V}| t|z } Gdd}|||j|j}|j r |j | n t/}|jpdt3j}|j|jn|j}||}| |d|jd|||j|jpi|jpg|j||jd}| | | j!kr#| dz }tdd|ddj"dj j #|| d| d{V}tH%d!|d!iS#tL$r }t|j'|j(d}~wtRtf$rt $rm}ddl*}t|d"|+}tX-d#|d$|td%t|d}~wwxYw)&z%Upload and convert files to memories.rr3r.zUFile upload API is disabled. Set HINDSIGHT_API_ENABLE_FILE_UPLOAD_API=true to enable.rr'zInvalid request JSON: NzToo many files. Maximum z files per request.zfiles_metadata count (z) must match files count (rqr-rcd|jSt|tr|gnt|S)z4Normalize parser value to a non-empty list of names.) file_parserrrr,)r-rs r_resolve_parserzB_register_routes..api_file_retain.._resolve_parser0s2;!-- *3 4 4Cuu$s))Cr2parsersrc \fd|D}|rtdd|d|ddS)z:Raise HTTP 400 if any parser name is not in the allowlist.cg|]}|v| Sr+r+)r{p allowlists rrzX_register_routes..api_file_retain.._validate_parsers..8s#GGGAAY4F4Fa4F4F4Fr2r'zParser(s) not available (z): z . Available: rNr)rr disallowedrs r_validate_parserszD_register_routes..api_file_retain.._validate_parsers6sdGGGGGGG '$'k7kkzkk`ikkr2zrequest-level parserceZdZdZdZdS)>_register_routes..api_file_retain..FileWrapperc0||_||_||_dSry)_contentfilenamer)rrrrs r__init__zG_register_routes..api_file_retain..FileWrapper.__init__Ps(/ (0 ,8)))r2cK|jSry)rrs rreadzC_register_routes..api_file_retain..FileWrapper.readUs#},r2N)rMrNrOrrr+r2r FileWrapperrOs2999 -----r2rfile_zfile 'r)filerrrrorrrizTotal batch size (z.1fzMB) exceeds maximum of MB)r$ file_itemsrrr*rrz/files/retain: rH).rur4r r rrr{rrOfile_conversion_max_batch_sizerrwr_parser_registry list_parsersfile_parser_allowlistr,riorrrrrrrrrrrorrr$file_conversion_max_batch_size_bytes!file_conversion_max_batch_size_mbsubmit_async_file_retainr,r=r@rrrrrrr)r$rr6rr4 request_datarregistered_parsersrrrrtotal_batch_sizerr file_contentr wrapped_file file_metadoc_id raw_parser parser_chainrtotal_mbrrr rrr]s @@rapi_file_retainz)_register_routes..api_file_retainsN 433333, n  y @ 0DDWMM    # #8T8`44fxI DS49_t%; DS  D D D D D D  49 s t      ".!!//,2E"F"FH^___ IIIJ $U++% (% (4%)YY[[000000  C $5$55 -------- +{<HYZZ ?K>YsL7::_q_s_s ".H2H$*,,2H2H2;1A1MY--S_Sf .z:: !!,0I0I0I0IJJJ)#)(0 ) 2 8b%N0b!*!4* ) 2  !!$'''' &"MMM+{;# #BBBBU[U}BBB 9+DD%" / EF &44#VO%<  ( L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LL]w]]|]] ^ ^ ^CA??? ?  @sCA M A;!A66A;;KM P M;;PA(PPzClear memory bank memorieszDelete memory units for a memory bank. Optionally filter by type (world, experience, opinion) to delete only specific types. This is a destructive operation that cannot be undone. The bank profile (disposition and background) will be preserved.clear_bank_memoriesclear_memoriesz6Optional fact type filter (world, experience, opinion)cK jj||d|d{VtdS#t$r }t |j|jd}~wtt f$rt$rm}ddl }t|d| }td |d |t d t|d}~wwxYw) z>Clear memories for a memory bank, optionally filtered by type.F)r%delete_bank_profilerNTrrrrrz /memories: rH)rwrr+rr@r rrrr{rrrrr)r$rrrrr r]s rapi_clear_bank_memoriesz1_register_routes..api_clear_bank_memoriessD @)"..4UTc/       "$/// /' L L LAM!(KKK K#]3     @ @ @    !!ffNNi6J6J6L6LNNL LLYwYY<YY Z Z ZCA??? ?  @s"8> C.A##C.A(C))C.ceZdZUdZeed<eed<eed<edzed<edzed<edzed<edd Zedzed <e ee fdzed <e ee fdzed <e ee fed<dS)'_register_routes..AuditLogEntryzA single audit log entry.rr9r>Nr$r?rEu^Server-computed duration in milliseconds (started_at → ended_at). Null if not yet completed.rIrcr6rDr) rMrNrOrPrrRr#rcrQrrr+r2r AuditLogEntryrs''  t$J*"'%x# # # S4Z   c3h$&&&&sCx.4''''sCx.     r2rcTeZdZUdZeed<eed<eed<eed<eed<dS)._register_routes..AuditLogListResponsez,Response model for list audit logs endpoint.r$rrrrN)rMrNrOrPrrRrQr,)rsrAuditLogListResponsersN::    M""""""r2rcBeZdZUdZeed<eeefed<eed<dS)-_register_routes..AuditLogStatsBucketz(A single time bucket in audit log stats.ractionsrN)rMrNrOrPrrRrrQr+r2rAuditLogStatsBucketrs<66 c3h r2rcTeZdZUdZeed<eed<eed<eed<eed<dS)/_register_routes..AuditLogStatsResponsez,Response model for audit log stats endpoint.r$r!r"startr$N)rMrNrOrPrrRr,)rsrAuditLogStatsResponsersO::    )******r2rz&/v1/default/banks/{bank_id}/audit-logszList audit logsz@List audit log entries for a bank, ordered by most recent first.list_audit_logsAudit)r>rJr)rorzFilter by action typez'Filter by transport (http, mcp, system)z)Filter from this ISO datetime (inclusive)z*Filter until this ISO datetime (exclusive)rHzMax items to returnr)rrJr9r> start_dateend_datecbK ddlm}jjd{V} jj||dd{V t dd|d dd lm} | | 4d{V} d g} |g} d }|r2| d || ||dz }|r2| d|| ||dz }|rZtj | dd}| d|| ||dz }|rZtj | dd}| d|| ||dz }d | }|d}| jd|d|g| Rd{V}|r|dnd}| || || jd|d|d|d|dzd g| Rd{V}g}|D]!}d}|d}|d}|r:|r8t!|d r(t#||z d!z}nD|rB|r@ t#||z d!z}n#t&t(f$rYnwxYwd"}d#}| t+|d$|d%|d&|d'|||||||d(||d)||d*pid+ #|||||d,cdddd{VS#1d{VswxYwYdS#t,$r }t |j|j d}~wt2t f$rt4$rV}ddl}t8d-|t d.t+| d}~wwxYw)/z"List audit log entries for a bank.rr8NFrr.rr0racquire_with_retry bank_id = $1rx action = $rz transport = $rrzstarted_at >= $zstarted_at < $ AND audit_logzSELECT COUNT(*) as total FROM z WHERE rz SELECT id, action, transport, bank_id, started_at, ended_at, request, response, metadata FROM  WHERE zI ORDER BY started_at DESC LIMIT $z OFFSET $z r?rE total_secondsrcp|dSt|dr|nt|S)Nr)rCrrvals r _safe_isoz@_register_routes..api_list_audit_logs.._safe_iso?s7;#'429#{2K2KYs}}QTUXQYQYYr2c|dSt|tr|St|trtj|n|Sry)rrrrrr s r _safe_jsonzA_register_routes..api_list_audit_logs.._safe_jsonDsD;#'4%c400'#&J2r$r6rDr) rr9r>r$r?rErcr6rDr)r$rrrrzError listing audit logs: rH)"hindsight_api.engine.memory_enginer8rwr _get_backendrr hindsight_api.engine.db_utilsrrrrrrfetchrowfetchrCrQrrAttributeErrorrr@rrrr{rrrr) r$r9r>rrrrrr8poolrconn where_clausesridx parsed_start parsed_end where_sqltable count_rowrrrr(rcstartedendedr rrrr]s rapi_list_audit_logsz-_register_routes..api_list_audit_logss&{ @ C C C C C C)6688888888Di&77_PU8 $)>)>???MM),,,1HC#+#9*:L:LSRZ:[:[#\#\L!(()@3)@)@AAAMM,///1HC!)!78H8Hh8W8W!X!XJ!(()?#)?)?@@@MM*---1HC#LL77  --#0$-NUNN9NN#### /8> '**Q e$$$ f%%%'TZ %    +.'           %%C"&K!,/G OE!5!WWo-N-N!&)57?*I*I*K*Kd*R&S&S  !U!!*-uw.M.M.O.ORV.V*W*WKK )>:!!! D!ZZZ PPPLL"%c$i..&)(m),[)9'*9~*3)G*<*<(1 %(8(8+6'1z#i.'A'A(2 3z?(C(C(2 3z?(C(C(Ir       '""$" yb b b b b b b b b b b b b b b b b b b b b b b b b b b b b b F( L L LAM!(KKK K#]3     @ @ @     LLNi6J6J6L6LNN O O OCA??? ?  @soA?NHN'KNKNKBN/N N  NN N P.N::P.AP))P.z,/v1/default/banks/{bank_id}/audit-logs/statszAudit log statisticsz9Get audit log counts grouped by time bucket for charting.audit_log_statszTime period: 1d, 7d, or 30dc 4K ddlm}ddlm}jjd{V}jj||dd{V tdd|d  dd l m }tj tj }d } |d kr||dz } n%|dkr||dz } n||dz } |d} ||4d{V} ddg} || g}d}|r2| d||||dz }d| }| jd| d| d|dg|Rd{V}i}|D]<}|d}||vri||<|d|||d<=||| | d |Dd!cdddd{VS#1d{VswxYwYdS#t&$r }t|j|j d}~wt,tf$rt.$rV}ddl}t2d"|td#t9| d}~wwxYw)$z,Get audit log counts grouped by time bucket.rrrNFrr.rr0r) timedeltaday1dr)days30drrrrzstarted_at >= $2rrrz( SELECT date_trunc('z', started_at) AS bucket, action, COUNT(*) AS count FROM rzi GROUP BY bucket, action ORDER BY bucket ASC bucketrr9c^g|]*\}}||t|d+S))rrr)rrrzs rrzA_register_routes..api_audit_log_stats..s7pppX\XY[\q3qxxzz?? S Spppr2)r$r!r"rr$zError getting audit log stats: rH)rrrr8rwrrrr rr#rArrBrrrrrr@rrrr{rrrrr)r$r9r!rrr8r_tdrAr"rrrrrrrrr$r( bucket_keyrrr]s rapi_audit_log_statsz-_register_routes..api_audit_log_statsksZK @ H H H H H H C C C C C C)6688888888Di&77_PU8 $0C(G+G>+ G55G>8G59G>> JH##JAJJ)OrXr rrEexception_handlerrr+r rrrrQr,rpostrrarqr8rrr rrrrGrr?rUrIrpatchrXdeleter*rr&r,r3rrrrrrrrrrrrrrputrrrrrrrrrrrrrrrrrr1rrr,r r rr!)Jr]rTrrrr rr!r)r5r9rfrsrxrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrr'r*r0r@rOrSrWr[r_rlrqrtryrrrrrrrrrrr r,rrsJ` @@rrr0 s-!!Q!Q!Q!QRRG8>t8L8L8L//3:/Q_////& .// 9L   0/  WW'J^   E E E E  E WW&3Q^"  O    2 WW-G^   NN  N WW+('t Z   !&t&"&#*12E*F*F"@"@"@Dj"@"@ : "@ 3i$ "@  "@4Z"@*"@("@"@"@"@"@"@H WW3.#F$Z   *.*12E*F*F.@.@.@Dj.@ :.@!4Z .@  .@  .@(.@.@.@.@.@.@` WW:!b!Z  +22E*F*F@@@@(@@@@@@8 WWB)u.Z  +22E*F*F@@@@(@@@@@@4 XX5%g'Z   WXPWXkPlPlk@k@k@,k@?Mk@k@k@k@k@  k@Z XX-&-:Z   WYQXYlQmQms@s@s@-s@@Ns@s@s@s@s@  s@j WW''B!Y  @GGZ?[?[ @ @n @ @ @ @ @ @ WW+(0O&Y  +22E*F*F+@+@+@'+@+@+@+@+@+@Z WW?1.e.Y   [   +22E*F*F@@@@@(@@@@@@< WW.)H$\  34Z[[[A3JKKK*12E*F*F @@@@@( @@@@@@8 WW4*0l'\  45fgggq6efff*12E*F*F @@@@@( @@@@@@, WW:+$e!\  IPPcHdHd@@@!$@7E@@@@@@B XXE+=k5\+22E*F*F       (       WW3.$K)   ).d&N^(_(_(_5:5Na5b5b5b9> J: : : 31...A!nnn*12E*F*F!@!@!@#Y%!@12!@56 !@!@!@(!@!@!@!@!@!@F WWE*"8'   :? J: : : +22E*F*F @ @ @ @56 @( @ @ @ @ @ @D WWM*c/   +22E*F*F@@@@(@@@@@@< XX30%B+    W "&999+22E*F*F%@%@%@&%@(%@%@%@%@%@:9  %@N XXM3&m+   W #4888+22E*F*F@@@@(@@@@@98@< YYE*%G*   W "&999 +22E*F*F @@@@'@( @@@@@:9@@ ZZE%,*   W "$777+22E*F*F@@@@(@@@@@87@@ WW0,!E&^  ).d&N^(_(_(_5:5Na5b5b5b!$4STTT31...A!nnn*12E*F*F@@@#Y%@12@ @  @  @(@@@@@@@ WW?(5$^  +22E*F*F@@@@(@@@@@@4 XX0("L'^  W v666+22E*F*F@@@$@(@@@@@76@< YY?("6'^  W v666 +22E*F*F @@@@%@( @@@@@76@@ ZZ?")'^  W t444+22E*F*F@@@@(@@@@@54@4 WW/, R%]   v   "'t9S!T!T!T &c   *12E*F*F,@,@,@ :,@ 3i$ ,@  ,@,@,@(,@,@,@,@,@,@\ WWI)&S+]  31CghhhA!9PQQQ*12E*F*F $@$@$@$@$@ $@ ( $@$@$@$@$@$@L XXL0$]*]   W !""+22E*F*F"@"@"@"@("@"@"@"@"@#"  "@H WWB'&I#]  KRReJfJf@@@#&@9G@@@@@@4 WW*']!Z  5   8=i8 8 8 34VWWWA3JKKK*12E*F*F:@:@:@ ::@34:@:@:@(:@:@:@:@:@  :@x WW,$#4 ]  NUUhMiMi@@c@N@@@@@@. YYB-!/ ']   W f555 +22E*F*F #@#@#@#@$#@( #@#@#@#@#@65  #@J ZZB-#+ ']   W d333JQReJfJf@@@#&@9G@@@@@43  @B WW0-'j&^  #&n   !G   2!AijjjA!9WXXX %eAo p p p*12E*F*F)@)@)@d )@ Dj )@)@)@)@()@)@)@)@)@)@V WW?.&s+^ !&i! ! ! +22E*F*F@@@@@(@@@@@@@ ZZ?.2T'^  W t444KRSfKgKg@@@$'@:H@@@@@54@4 XXE-0W&^  W d333KRSfKgKg@@@$'@:H@@@@@43@2 WW-*)s'Y T[[nSoSo#@#@C#@.#@#@#@#@#@#@J WW-*0X.Y \ccv[w[w"@"@"@7"@JX"@"@"@"@"@"@H XX0)?h*YX__rWsWs@@@3@FT@@@@@@* WW%*.I,Y   W]T[\oTpTp-@-@-@0-@CQ-@-@-@-@-@-@^ YY%*,`"Y  W]T[\oTpTp-@-@-@0-@CQ-@-@-@-@-@-@^ ZZ%%$A"Y W]$///NUViNjNj@@s@^@@@@@0/@4 XX,1&N,    W #4888e9^___*12E*F*F :@:@:@:@:@( :@:@:@:@:@98  :@x WW,+&Z+  +22E*F*FI@I@I@'I@I@I@I@I@I@V WW"/D/   888 ZZ2%(y)Y  W !666U\]pUqUq@@c@N@@@@@76@( XX;3. _-Y   W $D999X_`sXtXt@@@~@@@@@:9  @  ZZG61I1Z   W (===+22E*F*F@@@@(@@@@@>=  @4 WW,)(|&Y SZZmRnRn"@"@3"@"@"@"@"@"@"@H YY,)+B)Y W !""SZ[nSoSo(@(@(@/(@BP(@(@(@(@(@#"(@T ZZ,)*M(Y W 555T[\oTpTp#@#@S#@>#@#@#@#@#@65#@J XX1,'b,Y  W_D111X_`sXtXt@@@~@@@@@21@. XX.&"_%\ W +22E*F*F2@2@2@%2@(2@2@2@2@2@2@h WW.*>$\  +22E*F*F,@,@,@',@,@,@,@,@,@\ ZZ;% 2%\  W T222+22E*F*F@@@@(@@@@@32@0 YY;& j%\  W  +22E*F*F H@H@H@H@&H@( H@H@H@H@H@H@T WWF2)T.\  2#;cddd"4=jkkk*12E*F*F "@"@"@"@"@d "@ ( "@"@"@"@"@"@H XX.%!p$'Z/2 WXPWXkPlPlD@D@D@,D@?MD@D@D@D@D@34D@L XX2)+Y0#Y;> W]$///#'s8U"V"V"VC-WXXX*12E*F*F K@K@K@JK@K@( K@K@K@K@K@0/?@K@Z ZZ.%,K*Z  W T222!3klll*12E*F*F@@@Dj@(@@@@@32@2!!!!! !!!"#######y###i+++++++ +++ WW0!V&Y+  #45LMMM %d8a b b b!&t9d!e!e!e$T7cddd2!9NOOOA!1HIII*12E*F*FF@F@F@d F@:F@$J F@ * F@  F@F@(F@F@F@F@F@F@P WW6&O&Y,  #45LMMMD.KLLL*12E*F*F R@R@R@d R@R@( R@R@R@R@R@R@R@R@r2)TN)rPrsrryr]r contextlibrrrrVrrfastapirr r r r r rrrhindsight_api.engine.auditrrrhrrrrr r<r!r"r#r$r%rr&r1rur4rr5r6r7r8'hindsight_api.engine.providers.none_llmr9$hindsight_api.engine.response_modelsr:r;r< hindsight_api.engine.search.tagsr=r>r?r@rAhindsight_api.metricsrBrCrDhindsight_api.modelsrE getLoggerrMrrGrTrWr\rarrrrrrrrrrrrrrrr,r/r1r4r8rVrZr]r_rfrirnrqrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r&r*r,r3r5r?rGrIrUrXrr[rarrrr,rrrrrrrrrrrr hindsight_api.webhooks.modelsrrrrrr r1rXrrrr+r2rr<sK  ******''''''''cccccccccccccccccccccc>>>>>>>>888888 c d38n    SSSSSSSSSSSSSS&&&&&&ZhZSZZZZ>,+++++hhhhhhhhhhhhHHHHHH``````````@@@@@@@@\\\\\\\\\\eeeeeeeeee//////  8 $ $_____9___ mmmmm)mmm       Y    >>>>>I>>>B%%%%%9%%%P$$$$$ $$$22222)222+++++Y+++.8#####)###L2222292222sssss sss33333Y333lrrrrr)rrrb\b\b\b\b\b\b\b\JI@( 6!!!!!Y!!!H(     )   i     I   OOOOOYOOOd$$$$$)$$$4:::::y:::PPPPPPPP j j j j ji j j jKKKKKYKKKtttttYtttmmmmm9mmm44444i444nvvvvv vvv`````)```,#####y### ooooo ooo     i        9   11111111" ( ( ( ( (9 ( ( (y2fffff fffRy,uuuuuuuu6 Bi:I>GGGGGiGGGy0 l l l l ly l l lFI$Y Y(I0  % % % % %Y % % %i9-[-[-[-[-[ -[-[-[`]]]]]Y]]]8 " " " " " " " "#####I### OOOOOYOOOIIIIIYIIIIIIIIIIIX)<%%%%%i%%% gggggyggg4TTTTT TTT]]]]]y]]]6!$i(UMUMUMUMUMUMUMUMp O O O O OI O O OYYYYY9YYYx _ _ _ _ _ _ _ _%;S @m m%m& m " mmmm`''''' '''TiiiiiIiii(((((Y(((<i$Y$%%%%%9%%%/////i///d     9    _____9___HHHHHiHHH6<;;;;;     9    " " " " "i " " " k k k k k9 k k k!!!!!)!!! 3 3 3 3 3 i3 3 3 l#####)###@HRt9K5K,L@@@@J#+/yy yy"D(y yyyyx U6@'U6@U6@U6@U6@U6@U6@r2