yj dZddlZddlZddlmZmZddlmZddlmZm Z  dde dede d e dzd e f d Z Gd d eZ dS)z Base event classes and idempotency key generation for CloudEvents telemetry. This module provides: - BaseEvent: Abstract base class for all Honcho telemetry events - generate_event_id(): Deterministic event ID generation for idempotency N)UTCdatetime)ClassVar) BaseModelField event_type timestamp resource_idhoncho_versionreturncD|pd}|d|d|d|}tj|dd}t j|d}d|S)uUGenerate a deterministic event ID for idempotency. Same inputs always produce the same ID, so retries are automatically deduplicated on the receiving end. `honcho_version` is folded into the payload so two deploys emitting the same logical event produce distinct IDs — protects against silently merging events whose payload shape may have shifted between versions. Args: event_type: The CloudEvents type (e.g., "honcho.work.representation.completed") timestamp: When the event occurred resource_id: A unique identifier for the resource (can include workspace_id if relevant) honcho_version: The honcho package version emitting the event; included in the hash so cross-deploy events don't dedupe. Returns: A deterministic event ID in the format "evt_{base64_hash}" :N=evt_) isoformathashlibsha256encodedigestbase64urlsafe_b64encodedecoderstrip)rr r r version_segmentpayload hash_bytesencodeds A/DATA/AppData/hermes/projects/honcho/src/telemetry/events/base.pygenerate_event_idr!s0%*OUUkUUI,?,?,A,AUUOUUG 0 01188::3B3?J&z2299;;BB3GGG '  ceZdZUdZeeed<eeed<eeed<dZeeed<e dd Z e ed <e d efd Z e d efd Ze d efdZe d efdZd efdZd efdZdS) BaseEventa Base class for all Honcho telemetry events. All events inherit from this class and define: - _event_type: The CloudEvents type string - _schema_version: Integer version for schema evolution - _category: Event category (work, activity, resource) Subclasses must implement the abstract class methods by setting class variables and providing get_resource_id(). Subclasses define their own context fields (e.g., workspace_id, workspace_name) as needed - not all events have workspace context. _event_type_schema_version _category ground_truth _volume_classc4tjtSN)rnowrr"r zBaseEvent.Ks S 1 1r"zWhen the event occurred (UTC))default_factory descriptionr r c|jS)z2Return the CloudEvents type string for this event.)r%clss r rzBaseEvent.event_typeOs r"c|jS)z)Return the schema version for this event.)r&r2s r schema_versionzBaseEvent.schema_versionTs ""r"c|jS)z8Return the event category (work, activity, or resource).)r'r2s r categoryzBaseEvent.categoryYs }r"c|jS)zFReturn the volume class for sampling: 'ground_truth' or 'high_volume'.)r)r2s r volume_classzBaseEvent.volume_class^s   r"c td)zReturn the resource ID for idempotency key generation. This should be a unique identifier for the specific operation, such as a task_id or a hash of message IDs. Must be implemented by subclasses. z+Subclasses must implement get_resource_id())NotImplementedError)selfs r get_resource_idzBaseEvent.get_resource_idcs""OPPPr"cddlm}t||j||S)u&Generate a deterministic event ID for this event instance. Folds in the honcho package version so the same logical event from two different deploys produces distinct ids — downstream dedupe by id won't silently merge events whose body shape may have shifted. r)HONCHO_VERSION)rr r r ) src._versionr?r!rr r=)r<r?s r generate_idzBaseEvent.generate_idmsQ 0///// ((n,,..)     r"N)__name__ __module__ __qualname____doc__rstr__annotations__intr)rr r classmethodrr5r7r9r=rAr-r"r r$r$1sq  #c]"""} $2M8C=111 %113Ix 3[#s###[#[!S!!![!QQQQQ S      r"r$r+) rErrrrtypingrpydanticrrrFr!r$r-r"r rLs """"""""%%%%%%%%"& $J   @J J J J J J J J J J r"