yj[dZddlmZmZddlmZddlmZGddeZGddeZ Gd d eZ gd Z d S) zQ API events for Honcho telemetry. These events track user-facing API operations )ClassVarLiteral)Field) BaseEventcReZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z eed <e dd Ze ed<e dd Ze ed<e ddZeded<e dd Zeed<defdZdS)MessageCreatedEventaYEmitted when one or more messages are created. This is the canonical API event for counting created messages, including messages created from file uploads. The resource_id keys on `last_message_id` (the trailing message's public nanoid) so two batches of the same size in the same session+source produce distinct event ids. zmessage.created _event_type_schema_versionapi _category.Workspace name descriptionworkspace_name Session name session_namezNumber of messages created message_countz$Total tokens across created messages total_tokenszSource of the created messagesdefaultr)r file_uploadsourceukpublic_id (nanoid) of the trailing message in the batch — used as the stable unique key for this emissionlast_message_idreturncD|jd|jd|jd|jS)zResource ID keys on the trailing message's public_id so two batches of the same size in the same session+source produce distinct event ids. :)rrrrselfs @/DATA/AppData/hermes/projects/honcho/src/telemetry/events/api.pyget_resource_idz#MessageCreatedEvent.get_resource_id'sG " 4 4T%6 4 4{ 4 4!1 4 4 N)__name__ __module__ __qualname____doc__r rstr__annotations__r intr rrrrrrrrr!r"r rrs]"3K#222%&OXc]&&&$Ix}$$$%1ABBBNCBBBc~>>>L#>>>s0LMMMM3MMMc/UVVVL#VVV,1E#C---FG( )!5 BOS        r"rceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z eed <e dd Zeed<e dd Zeed<e ddZedzed<e ddZedzed<e ddZe dzed<e dd Ze ed<e dd Ze ed<defdZdS) FileUploadedEventzEmitted when an uploaded file is converted into messages. This captures file-side metadata. Message creation counts should use MessageCreatedEvent to avoid double-counting file uploads. z file.uploadedr r r r r .rrrrrzPeer that uploaded the file peer_namezGenerated file identifierfile_idNzUploaded filenamerfilenamezUploaded content type content_typezUploaded file size in bytesfile_size_bytesz(Number of messages created from the filerz2Total tokens across messages created from the filerrc4|jd|jd|jS)z?Resource ID includes workspace, session, and generated file ID.r)rrr.rs r r!z!FileUploadedEvent.get_resource_idLs&%JJ(9JJDLJJJr")r#r$r%r&r rr'r(r r)r rrrr-r.r/r0r1rrr!r*r"r r,r,1s "1K#000%&OXc]&&&$Ix}$$$%1ABBBNCBBBc~>>>L#>>>U3,IJJJIsJJJ5*EFFFGSFFF 5;NOOOHcDjOOO$uT?VWWWL#*WWW"'%"?###OS4Z CM3 ML#KKKKKKKr"r,c\eZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z ed ed<e ddZedzed<e ddZedzed<e ddZedzed<e ddZe dzed<e ddZe ed<e ddZeed<e ddZeed <e dd!Zeed"<e dd#Zeed$<e dd%Ze dzed&<e dd'Zedzed(<e dd)Zedzed*<e dd+Ze dzed,<e dd-Zedzed.<e dd/Zeed0<e dd1Z eed2<e dd3 Z!eed4<d5efd6Z"dS)7GetContextEventz8Emitted when context is retrieved for a session or peer.zcontext.retrievedr r r r r .rrrzContext endpoint scope)sessionpeer context_scopeNz'Session name for session-scoped contextrrzObserver peer namer-zObserved peer name target_namezHCaller-supplied tokens query parameter (None = endpoint default applied)tokens_requestedrz&Number of messages returned in contextrFzWhether a summary was returned has_summaryz%Whether a representation was returnedhas_representationz Whether a peer card was returned has_peer_cardz/Whether semantic search query text was providedsearch_query_providedz6Caller-supplied search_top_k (None = endpoint default) search_top_kz=Caller-supplied search_max_distance (None = endpoint default)search_max_distancezsCaller-supplied include_most_frequent (None = endpoint default; defaults differ between peer and session endpoints)include_most_frequentz9Caller-supplied max_conclusions (None = endpoint default)max_conclusionszJWhether summary inclusion was requested; None when unsupported by endpointinclude_summaryz4Whether representation retrieval was session-limitedlimit_to_sessionz9Whether peer_perspective was supplied for session contextpeer_perspective_providedzTotal processing timetotal_duration_msrc|j|jnd}|j|jnd}|jdkr|jd|jd|d|S|jd|d|S)uResource ID identifies the requested context scope. Uses empty string (illegal in peer names — nanoid-derived) as the absent-peer sentinel so that a peer literally named "none" does not collide with the absent-peer case. Nr5z :session:rz:peer:)r-r8r7rr)rr-r8s r r!zGetContextEvent.get_resource_ids'+n&@DNNb *.*:*Fd&&B   * *&--1B----*-- %FFYFFFFFr")#r#r$r%r&r rr'r(r r)r rrr7rrr-r8r9rr:boolr;r<r=r>r?floatr@rArBrCrDrEr!r*r"r r4r4QsBB!4K#444%&OXc]&&&$Ix}$$$%1ABBBNCBBB05 1111M7,- %u"K   L#*"E$RSSSKtSSS#(5^$$$cDjGM3#CK %u#J    %#EM4#(%#T###4 %uL   L#*).S)))*/J***4$;#(%O###OS4Z$)5`$$$OTD[#UJd',eO'''t %uS6MNNNuNNNGGGGGGGr"r4)r,r4rN) r&typingrrpydanticrsrc.telemetry.events.baserrr,r4__all__r*r"r rNs %$$$$$$$//////      )    FKKKKK KKK@OGOGOGOGOGiOGOGOGd   r"