j0dZddlmZddlZddlmZmZddlmZddl m Z m Z ddl m Z dd lmZdd lmZdd lmZer dd lmZdd lmZgdZGddeZGddZGddZy)z6Conclusion types and scoped access for the Honcho SDK.) annotationsN) TYPE_CHECKINGAny) BaseModel)ConclusionResponseRepresentationResponse) SessionBase)routes)SyncPage) resolve_idConclusionScopeAio)Honcho) ConclusionConclusionScopeConclusionCreateParamsc&eZdZUded<dZded<y)rstrcontentN str | None session_id)__name__ __module__ __qualname____annotations__r/home/cube/projects/richard/traning coach/.omo/evidence/nutricoach-v150-combined/st_01a0560c-r63-installed-wheel-first-claim-qa/venv/lib/python3.12/site-packages/honcho/conclusions.pyrrs L!J !rrceZdZUdZded<ded<ded<ded<dZded <d ed < dd Zedd ZddZ ddZ y)ra A conclusion from Honcho's reasoning system. Conclusions are facts derived from messages that help build a representation of a peer. Attributes: id: Unique identifier for this conclusion content: The conclusion content/text observer_id: The peer ID who made this conclusion observed_id: The peer ID this conclusion is about session_id: The session this conclusion relates to created_at: Timestamp for when the conclusion was created ridr observer_id observed_idNrrdatetime.datetime created_atcX||_||_||_||_||_||_yNr!rr"r#rr%)selfr!rr"r#rr%s r__init__zConclusion.__init__8s0 &&$$rc||j|j|j|j|j|j S)z)Create a Conclusion from an API response.r(r()clsdatas rfrom_api_responsezConclusion.from_api_responseHs?wwLL((((   rct|jdkDr|jdddn |j}d|jd|dS)N2z...zConclusion(id='z ', content='z'))lenrr!)r) truncateds r__repr__zConclusion.__repr__TsN),T\\):R)?t||CR ! %T\\ ! i[CCrc|jSr')rr)s r__str__zConclusion.__str__Zs ||r)r!rrrr"rr#rrrr%r$returnNone)r-rr7z 'Conclusion'r7r) rrr__doc__rrr* classmethodr.r3r6rrrrr!s  G L!J !!!% %% %  %  %&% %     D rrceZdZUdZded<ded<ded<ded< ddZedd Z d dd Z d dd Z dd Z ddZ d ddZ ddZ y )raK Scoped access to conclusions for a specific observer/observed relationship. This class provides convenient methods to list, query, create, and delete conclusions that are automatically scoped to a specific observer/observed pair. Typically accessed via `peer.conclusions` (for self-conclusions) or `peer.conclusions_of(target)` (for conclusions about another peer). Example: ```python # Get self-conclusions conclusions = peer.conclusions obs_list = conclusions.list() search_results = conclusions.query("preferences") # Get conclusions about another peer bob_conclusions = peer.conclusions_of("bob") bob_list = bob_conclusions.list() # Async operations via .aio accessor obs_list = await peer.conclusions.aio.list() ``` 'Honcho'_honchor workspace_idobserverobservedc<||_||_||_||_y)z Initialize a ConclusionScope. Args: honcho: The Honcho client instance workspace_id: The workspace ID observer: The observer peer ID observed: The observed peer ID N)r>r?r@rA)r)honchor?r@rAs rr*zConclusionScope.__init__}s!  (    rcddlm}||S)a Access async versions of all ConclusionScope methods. Returns a ConclusionScopeAio view that provides async versions of all methods while sharing state with this ConclusionScope instance. Example: ```python # Async operations obs_list = await scope.aio.list() results = await scope.aio.query("preferences") ``` rr)aior)r)rs rrEzConclusionScope.aios ,!$''rNcrjjt|}jjd|r|d<jj j tjjdi|d}dd d fd t|tS) a7 List conclusions in this scope. Args: page: Page number (1-indexed) size: Number of results per page session: Optional session (ID string or Session object) to filter by Returns: Paginated response containing Conclusion objects r"r#rfilterspagesizebodyqueryc,tj|Sr')rr.)responses r transformz'ConclusionScope.list..transforms//9 9rcjjjtjj di|d}t |tS)NrHrIrL)r>_httppostr conclusions_listr?r r)rJ next_data fetch_nextrHr)rKrQs rrWz(ConclusionScope.list..fetch_nexts\ **//''(9(9:)#T20I I'99jQ Qr)rPrr7r)rJintr7(SyncPage[ConclusionResponse, Conclusion]) r>_ensure_workspacer r@rArSrTr rUr?r r) r)rJrKsessionresolved_session_idr-rWrHrQs ` ` @@@rlistzConclusionScope.lists" &&((1====#  $7GL !||!!&&  # #D$5$5 6W%.'   : R R 5 R R0)ZHHrc|jj|j|jd}|||d}|||d<|jjj t j|j|}|Dcgc]*}tjtj|,c}Scc}w)a5 Semantic search for conclusions in this scope. Args: query: The search query string top_k: Maximum number of results to return distance: Maximum cosine distance threshold (0.0-1.0) Returns: List of matching Conclusion objects rG)rNtop_krHdistancerM) r>rZr@rArSrTr conclusions_queryr?rr.rmodel_validate)r)rNr_r`rHrMr-items rrNzConclusionScope.querys" &&(====#     'D ||!!&&  $ $T%6%6 7'     ( ();)J)J4)P Q   s /B;c|jj|jjjt j |j |y)zy Delete a conclusion by ID. Args: conclusion_id: The ID of the conclusion to delete N)r>rZrSdeleter conclusionr?)r) conclusion_ids rrfzConclusionScope.deletes? &&( !!&"3"3D4E4E}"UVrcjj dfd }|Dcgc] }|| }}jjjt j j d|i}|Dcgc]*}tjtj|,c}Scc}wcc}w)ag Create conclusions in this scope. Args: conclusions: List of conclusions to create. Each conclusion can be a ConclusionCreateParams object or a dictionary with a required 'content' key and an optional 'session_id' key. Returns: List of created Conclusion objects Example: ```python conclusions = peer.conclusions.create([ {"content": "User prefers dark mode", "session_id": "session1"}, {"content": "User is interested in AI"}, ]) ``` cjjd}t|tr,|j|d<|j |j |d<|S|d|d<|j d}|||d<|S)a Build a single conclusion create payload. This normalizes both `ConclusionCreateParams` instances and plain dictionaries into the wire format expected by the Honcho API. Notes: - `content` is required. - `session_id` is optional; when not provided it is omitted from the payload. - `observer_id` and `observed_id` are always injected from this scope. Args: item: A `ConclusionCreateParams` instance or a dict with a required `content` key and an optional `session_id` key. Returns: A dictionary suitable for inclusion in the `conclusions` array for the create conclusions endpoint. rGrr)r@rA isinstancerrrget)rdpayloadrr)s rbuild_conclusion_payloadz8ConclusionScope.create..build_conclusion_payload s. $}}#}}'G$ 67%)\\ "??.,0OOGL)!%iGI ,/J%(2 %Nr conclusionsra)rdz'ConclusionCreateParams | dict[str, Any]r7zdict[str, Any]) r>rZrSrTr ror?rr.rrc)r)rorncconclusion_paramsr-rds` rcreatezConclusionScope.creates. &&($ 9$  $ LCNN+Q5a8+N||!!&&   t00 1!23'     ( ();)J)J4)P Q  O  s B7/B<cx|jjd|ji}|||d<|||d<|||d<|||d<|||d<|jjj t j |j|j|}tj|}|jS)a Get the computed representation for this scope. This returns the working representation (narrative) built from the conclusions in this scope. Args: search_query: Optional semantic search query to curate the representation search_top_k: Number of semantically relevant facts to return search_max_distance: Maximum semantic distance for search results (0.0-1.0) include_most_frequent: Whether to include the most frequent conclusions max_conclusions: Maximum number of conclusions to include Returns: A Representation string target search_query search_top_ksearch_max_distanceinclude_most_frequentmax_conclusionsra) r>rZrArSrTr peer_representationr?r@r rcrepresentation) r)rurvrwrxryrMr-rPs rr{zConclusionScope.representationQs0 &&( ($--8  ##/D  ##/D  **=D& ' ,,AD( )  &&5D" #||!!&&  & &t'8'8$-- H' *88>&&&rcVd|jd|jd|jdS)NzConclusionScope(workspace_id=z , observer=z , observed=))r?r@rAr5s rr3zConclusionScope.__repr__}s8+D,=,=+@A ( DMM3DA G r)rCr=r?rr@rrAr)r7z'ConclusionScopeAio')rr0N)rJrXrKrXr[zstr | SessionBase | Noner7rY) N)rNrr_rXr` float | Noner7list[Conclusion])rhrr7r8)roz-list[ConclusionCreateParams | dict[str, Any]]r7r)NNNNN) rurrv int | Nonerwrrxz bool | Noneryrr7rr9)rrrr:rr*propertyrEr]rNrfrrr{r3rrrrr^sE2MM!!! !  !*((*,0 -I-I-I* -I 2 -Id!% & & &  &  & PWH BH  H X$(#',0-1&* *' *'!*'* *' + *' $ *' *'X rr)r: __future__rdatetimetypingrrpydanticr api_typesrr baser httpr paginationr utilsr rErclientr__all__rrrrrrrsV<"%A ' "Y" ::zc c r