Yjl`dZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z mZmZmZddlmZmZmZmZmZmZmZmZdd lmZmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*m+Z+m,Z,e rddl-m.Z.ddl/m0Z0ddl1m2Z2ej3e4Z5Gddee$Z6dS)zSync Peer class for Honcho SDK.) annotationsN) Generator) TYPE_CHECKINGAnyLiteral) ConfigDictField PrivateAttr validate_call)MessageCreateParamsMessageResponsePeerCardResponse PeerConfigPeerContextResponse PeerResponseRepresentationResponseSessionResponse)PeerBase SessionBase)ConclusionScope)routes)Message)MetadataConfigMixin)SyncPage)DialecticStreamResponse)parse_datetimeparse_sse_stream resolve_idPeerAio)HonchoSessionc eZdZUdZedZded<edZded<eZded <e dod Z e dpd Z d Z dqdZ dqdZdrdZdsdZdtdZeeddfdudZe dvdZeed !"edd#d$%edd&fedd'edd(d)dwfd.Zeed !"edd#d/%fdddd0dxd9Zeed !"edd#d/%fdddd0dyd;Z dzd{d>Zeedd?d@%feddAeddBeddCdDd|dJZeedd#dK%eddLedMd#dNdOPfd}dTZeed !" dzd~dVZ dzd~dWZeed !" dzddZZeed !"dddedd#dN[edd\d][dedd#dN[fddfZ eed !"ddedd#dN[edd\d][dedd#dN[fddhZ!e ddjZ"ddlZ#dqdmZ$dqdnZ%xZ&S)Peera Represents a peer in the Honcho system. Peers can send messages, participate in sessions, and maintain both global and local representations for contextual interactions. A peer represents an entity (user, assistant, etc.) that can communicate within the system. Attributes: id: Unique identifier for this peer workspace_id: Workspace ID for scoping operations metadata: Cached metadata for this peer. May be stale if not recently fetched. Call get_metadata() for fresh data. configuration: Cached configuration for this peer. May be stale if not recently fetched. Call get_configuration() for fresh data. N)defaultdict[str, object] | None _metadataPeerConfig | None_configurationz'Honcho'_honchoreturnc|jS)zOCached metadata for this peer. May be stale. Use get_metadata() for fresh data.)r)selfs R/home/ubuntu/.hermes/hermes-agent/venv/lib/python3.11/site-packages/honcho/peer.pymetadataz Peer.metadata>s ~c|jS)zYCached configuration for this peer. May be stale. Use get_configuration() for fresh data.)r+r/s r1 configurationzPeer.configurationCs ""r3cL|j|jjSN)r,_ensure_workspace_httpr/s r1_get_http_clientzPeer._get_http_clientIs! &&(((|!!r3strc4tj|jSr7)rpeers workspace_idr/s r1_get_fetch_routezPeer._get_fetch_routeMs|D-...r3c@tj|j|jSr7)rpeerr>idr/s r1_get_update_routezPeer._get_update_routePs{4,dg666r3dict[str, Any]cd|jiS)NrBrBr/s r1_get_fetch_bodyzPeer._get_fetch_bodySsdgr3data+tuple[dict[str, object], dict[str, object]]crtj|}|jpi|jdfS)NT exclude_none)rmodel_validater2r5 model_dumpr0rHrAs r1_parse_responsezPeer._parse_responseVs:*400}"D$6$A$At$A$T$TTTr3rc8|j|||}t j|}|jpi|_ |j |_ |j S)z Get configuration from the server and update the cache. Returns: A PeerConfig object containing the configuration settings. body) r,r8r:postr?rGrrMr2r)r5r+rOs r1get_configurationzPeer.get_configuration]s &&((($$&&++  ! ! # #$*>*>*@*@,  *400,""0""r3.zConfiguration to set) descriptionr5Nonec||d|di||_dS)z Set configuration on the server and update the cache. Args: configuration: A PeerConfig object with configuration settings. r5TrKrRN)r:putrCrNr+)r0r5s r1set_configurationzPeer.set_configurationmse ##  " " $ $!=#;#;#;#N#NO $   ,r3 'PeerAio'c$ddlm}||S)a Access async versions of all Peer methods. Returns a PeerAio view that provides async versions of all methods while sharing state with this Peer instance. Example: ```python peer = honcho.peer("user-123") # Async operations await peer.aio.chat("query") await peer.aio.get_metadata() ``` r r )aior!)r0r!s r1r]zPeer.aio~s$$ !     wt}}r3T)arbitrary_types_allowed)configr z4Unique identifier for this peer within the workspace) min_lengthrVzHoncho client instancezqOptional metadata dictionary to associate with this peer. If set, will get/create peer immediately with metadata.zaOptional configuration to set for this peer. If set, will get/create peer immediately with flags.)r2r5peer_idhonchorr2ct||j||_||_||_|||jd|i}|||d<||d|d<|j tj |j|}tj |}|j|_|j|_dSdS) aD Initialize a new Peer. Provided metadata and configuration will overwrite any existing data in those locations if given. Args: peer_id: Unique identifier for this peer within the workspace honcho: Honcho client instance metadata: Optional metadata dictionary to associate with this peer. If set, will get/create peer immediately with metadata. configuration: Optional configuration to set for this peer. If set, will get/create peer immediately with flags. )rBr>NrBr2TrKr5rR)super__init__r>r,r)r+r8rNr9rTrr=rrMr2r5) r0rarbr2r5rSrH peer_data __class__s r1rez Peer.__init__sB ,     !+  $(< L * * , , ,$('?D##+Z ((5(@(@d(@(S(S_%<$$V\&2E%F%FT$RRD$3D99I&/DN"+"9D   )=(rBget) r0rkrhrirj target_idresolved_session_idrSrHrts r1chatz Peer.chats@ &&(((v&& (11).%@@  '&DN  5!4D   6&5D" #|!&&  T. 8 8'  ((9%% 4r3rcjt|}t|}|dd|r|d<|r|d<|r|d<d fd }t|S) a Query the peer's representation with a natural language question, streaming the response. Makes an API call to the Honcho dialectic endpoint to query either the peer's global representation (all content associated with this peer) or their local representation of another peer (what this peer knows about the target peer). Args: query: The natural language question to ask. target: Optional target peer for local representation query. If provided, queries what this peer knows about the target peer rather than querying the peer's global representation. Can be a peer ID string or a Peer object. session: Optional session to scope the query to. If provided, only information from that session is considered. Can be a session ID string or a Session object. reasoning_level: Optional reasoning level for the query: "minimal", "low", "medium", "high", or "max". Defaults to "low" if not provided. Returns: DialecticStreamResponse object that can be iterated over and provides final response Trqrhrsrjr-Generator[str, None, None]c 3Ktjjdt jjjEd{VdS)NPOSTrR)rr,r9rrrrur>rB)rSr0sr1stream_responsez)Peer.chat_stream..stream_response,sy' "))$T%6@@*         r3)r-r{)r,r8rr) r0rkrhrirjrwrxr~rSs ` @r1 chat_streamzPeer.chat_streams@ &&(((v&& (11).$??  '&DN  5!4D   6&5D" #       ''8'8999r3filters$SyncPage[SessionResponse, 'Session']c jddlmjjt jjj rdind}dfd dfd t|tS)a Get all sessions this peer is a member of. Makes an API call to retrieve all sessions where this peer is an active participant. Sessions are created when peers are added to them or send messages to them. Returns: A paginated list of Session objects this peer belongs to. Returns an empty list if the peer is not a member of any sessions r r#rNrRrirr-r$c0|jjSr7)rBr,)rir$r0s r1 transformz Peer.sessions..transformMs77:t|44 4r3pageint"SyncPage[SessionResponse, Session]cjjtjjjrdindd|i}t|tS)NrrrSrk) r,r9rTrpeer_sessions_listr>rBrr)r next_data fetch_nextrr0rs r1rz!Peer.sessions..fetch_nextPsf *//)$*;TWEE-4>i))$tn0I I :NN Nr3)rirr-r$)rrr-r) r,r8rir$r9rTrrr>rBrr)r0rrHr$rrs`` @@@r1sessionsz Peer.sessions7s &&((($$$$$$|!&&  %d&7 A A)0:)W%%d'    5 5 5 5 5 5 5 O O O O O O O O Ooy*EEEr3rz The text content for the messagezOptional metadata dictionaryz?Optional configuration dictionary to associate with the messagezOptional created-at timestamp for the message. Accepts a datetime which will be converted to an ISO 8601 string, or a preformatted string.)r2r5 created_atrtdict[str, Any] | Nonerdatetime.datetime | str | Noner cddlm}|dkr'|dkrtdt |}|r|di|nd}t |j||||S)a Build a message object attributed to this peer (synchronous, no API call). This is a convenience method for creating message objects with this peer's ID already set. The returned object can then be passed to `session.add_messages()`. Note: This method is synchronous and does NOT send the message to Honcho. To actually create the message on the server, pass the returned object to `session.add_messages()`. Args: content: The text content for the message metadata: Optional metadata dictionary to associate with the message configuration: Optional configuration dictionary (e.g., reasoning settings) created_at: Optional created-at timestamp Returns: A MessageCreateParams object ready to be passed to `session.add_messages()` Example: ```python msg = peer.message("Hello!") await session.add_messages(msg) # Or batch multiple messages: await session.add_messages([ alice.message("Hi Bob"), bob.message("Hey Alice!"), ]) ``` r )MessageConfigurationz)Message content cannot be only whitespaceN)rartr5r2r) api_typesrstrip ValueErrorrr rB)r0rtr2r5rr created_at_dt config_objs r1messagez Peer.messageZsf 433333 b==W]]__22HII I&z22 >KU))::M:::QU "G$$     r3zThe search query to usezFilters to scope the search dzNumber of results to return)r'gelerVlimitr list[Message]c|j|jjt j|j|j|||d}d|DS)a> Search across all messages in the workspace with this peer as author. Makes an API call to search endpoint. Args: query: The search query to use filters: Filters to scope the search. See [search filters documentation](https://docs.honcho.dev/v3/documentation/core-concepts/features/using-filters). limit: Number of results to return (1-100, default: 10) Returns: A list of Message objects representing the search results. Returns an empty list if no messages are found. )rkrrrRcZg|](}tjtj|)Sr)rfrom_api_responserrM).0items r1 zPeer.search..s>     %o&DT&J&J K K   r3)r,r8r9rTr peer_searchr>rB)r0rkrrrHs r1searchz Peer.searchsz2 &&(((|!&&  t0$' : : WuEE'        r3list[str] | Nonec|jt|}|rd|ind}|jjt j|j|j|}tj |}|jS)a. Get the peer card for this peer. Makes an API call to retrieve the peer card, which contains a representation of what this peer knows. If a target is provided, returns this peer's local representation of the target peer. Args: target: Optional target peer for local card. If provided, returns this peer's card of the target peer. Can be a Peer object or peer ID string. Returns: A list of strings representing the peer card, or None if none is available rhNrk) r,r8rr9rvr peer_cardr>rBrrM)r0rhrwrkrHresponses r1get_cardz Peer.get_cards& &&(((v&& )2<9%%|!%%  T. 8 8&  $2488!!r3cftjdtd||S)z#Deprecated: use get_card() instead.z,card() is deprecated, use get_card() instead) stacklevel)rh)warningswarnDeprecationWarningr)r0rhs r1cardz Peer.cards<  :     }}F}+++r3r list[str]c|jt|}|rd|ind}|jjt j|j|jd|i|}tj |}|jS)a" Set the peer card for this peer. Makes an API call to set the peer card. If a target is provided, sets this peer's local card of the target peer. Args: peer_card: A list of strings to set as the peer card. target: Optional target peer for local card. If provided, sets this peer's card of the target peer. Can be a Peer object or peer ID string. Returns: A list of strings representing the updated peer card, or None if none is available rhNrr) r,r8rr9rYrrr>rBrrM)r0rrhrwrkrHrs r1set_cardz Peer.set_cards( &&(((v&& )2<9%%|!%%  T. 8 8y)&   $2488!!r3)rrgg? search_query search_top_k int | Nonesearch_max_distance float | Noneinclude_most_frequent bool | Nonemax_conclusionsc|jt|}t|} i} |r|| d<| r| | d<||| d<||| d<||| d<||| d<||| d<|jjt j|j|j| } tj | } | j S) a Get a subset of the representation of the peer. Args: session: Optional session to scope the representation to. target: Optional target peer to get the representation of. If provided, returns the representation of the target from the perspective of this peer. search_query: Semantic search query to filter relevant conclusions 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 Example: ```python # Get global representation rep = peer.representation() print(rep) # Get representation scoped to a session session_rep = peer.representation(session='session-123') # Get representation with semantic search searched_rep = peer.representation( search_query='preferences', search_top_k=10, max_conclusions=50 ) ``` rsrhNrrrrrrR) r,r8rr9rTrpeer_representationr>rBrrMrepresentation) r0rirhrrrrrrsrwrSrHrs r1rzPeer.representation sX &&((((( v&& !  ,!+D   '&DN  ##/D  ##/D  **=D& ' ,,AD( )  &&5D" #|!&&  &t'8$' B B'  *8>>&&r3rcV|jt|}i}|r||d<|||d<|||d<|||d<|||d<|||d<|jjt j|j|j|r|nd} tj | S) a Get context for this peer, including representation and peer card. This is a convenience method that retrieves both the working representation and peer card in a single API call. Args: target: Optional target peer to get context for. If provided, returns the context for the target from this peer's perspective. Can be a Peer object or peer ID string. search_query: Semantic search query to filter relevant conclusions 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 PeerContext object containing the representation and peer card Example: ```python # Get own context context = peer.context() print(context.representation) print(context.peer_card) # Get context for another peer context = peer.context(target='other-peer-id') # Get context with semantic search context = peer.context( search_query='preferences', search_top_k=10 ) ``` rhNrrrrrr) r,r8rr9rvr peer_contextr>rBrrM) r0rhrrrrrrwrkrHs r1contextz Peer.contextSs\ &&(((v&& "  ('E(O  #$0E. !  #$0E. !  *+>E' ( ,-BE) *  &'6E# $|!%%   147 ; ; *%%d&  #1$777r3rcNt|j|j|j|jS)a Access this peer's self-conclusions (where observer == observed == self). This property provides a convenient way to access conclusions that this peer has made about themselves. Use this for self-conclusion scenarios. Returns: A ConclusionScope scoped to this peer's self-conclusions Example: ```python # List self-conclusions obs_list = peer.conclusions.list() # Search self-conclusions results = peer.conclusions.query("preferences") # Delete a self-conclusion peer.conclusions.delete("obs-123") ``` )rr,r>rBr/s r1 conclusionszPeer.conclusionss!.t|T->QQQr3str | PeerBasect|tr|jn|}t|j|j|j|S)aQ Access conclusions this peer has made about another peer. This method provides scoped access to conclusions where this peer is the observer and the target is the observed peer. Args: target: The target peer (either a Peer object or peer ID string) Returns: A ConclusionScope scoped to this peer's conclusions of the target Example: ```python # Get conclusions about another peer bob_conclusions = peer.conclusions_of("bob") # List conclusions obs_list = bob_conclusions.list() # Search conclusions results = bob_conclusions.query("work history") # Get the representation from these conclusions rep = bob_conclusions.get_representation() ``` ) isinstancerrBrr,r>)r0rhrws r1conclusions_ofzPeer.conclusions_ofs98",FH!=!=IFII6 t|T->SSSr3cd|jdS)z Return a string representation of the Peer. Returns: A string representation suitable for debugging z Peer(id='z')rFr/s r1__repr__z Peer.__repr__s'47&&&&r3c|jS)zx Return a human-readable string representation of the Peer. Returns: The peer's ID rFr/s r1__str__z Peer.__str__s wr3)r-r()r-r*)r-r;)r-rD)rHrDr-rI)r-r)r5rr-rW)r-r[) rar;rbrr2r(r5r*r-rW) rkr;rhrlrirmrjrnr-ro) rkr;rhrlrirmrjrnr-rr7)rr(r-r) rtr;r2r(r5rrrr-r )rkr;rr(rrr-r)rhrlr-r)rrrhrlr-r)rirmrhrlrrorrrrrrrrr-r;)rhrlrrorrrrrrrrr-r)r-r)rhrr-r)'__name__ __module__ __qualname____doc__r r)__annotations__r+r,propertyr2r5r:r?rCrGrPrUr r rZr]rreryrrrrrrrrrrrrr __classcell__)rgs@r1r&r&)s +6+d*C*C*CICCCC(3 D(A(A(ANAAAA# G%%%% X###X# """////7777UUUU#### %*E#;Q$R$R$R,,,,], X*]**TBBBCCCu N   eC-EFFF4:.3U L. . . ,15 {, , , 4:4:4:4:4:4:4:DC4:l]**TBBBCCCU31:VWWW2)-,022222DC2h]**TBBBCCCU31:VWWW4:)-,04:4:4:4:4:DC4:n37!F!F!F!F!FFu A+M   A .3U <. . . 05u Y0 0 0 6;U e6 6 6 A A A A A ]A FU31:STTT,1E ;- - - U12O       ]  D]**TBBBCCC)-""""DC"@)- , , , , ,]**TBBBCCC)-""""DC">]**TBBBCCC-1(,#'#(5!#<#<#<,1E$33,G,G,G-1&+eDQ3&?&?&?D'D'D'D'DCD'L]**TBBBCCC)-#'#(5!#<#<#<,1E$33,G,G,G-1&+eDQ3&?&?&?B8B8B8B8DCB8HRRRXR0TTTT>''''r3r&)7r __future__rdatetimeloggingrcollections.abcrtypingrrrpydanticrr r r rr rrrrrrrbaserrrrhttprrrmixinsr paginationrtypesrutilsrrrr]r!clientr"rir$ getLoggerrloggerr&rr3r1rs%%%""""""%%%%%%..........BBBBBBBBBBBB                    ('''''''(((((('''''' ******??????????!       8 $ $w w w w w 8(w w w w w r3