qidZddlZddlZddlZddlmZddlmZddlm Z m Z m Z m Z ddl mZddlmZmZeGdd ZGd d eZy) aBase object class providing event handling and lifecycle management. This module provides the foundational BaseObject class that offers common functionality including unique identification, naming, event handling, and async cleanup for all Pipecat components. N)ABC) dataclass)AnyDictListOptional)logger) obj_countobj_idc6eZdZUdZeed<eeed<eed<y) EventHandleraData class to store event handlers information. This data class stores the event name, a list of handlers to run for this event, and whether these handlers will be executed in a task. Parameters: name (str): The name of the event handler. handlers (List[Any]): A list of functions to be called when this event is triggered. is_sync (bool): Indicates whether the functions are executed in a task. namehandlersis_syncN) __name__ __module__ __qualname____doc__str__annotations__rrboolK/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/utils/base_object.pyr r s  I3i Mrr ceZdZdZdddeefdZedefdZ edefdZ d Z d efd Z d efd Z dd ed efdZd efdZd efdZdej&fdZdZy) BaseObjecta!Abstract base class providing common functionality for Pipecat objects. Provides unique identification, naming, event handling capabilities, and async lifecycle management for all Pipecat components. All major classes in the framework should inherit from this base class. Nrrc t|_|xs$|jjdt ||_i|_t|_y)aInitialize the base object. Args: name: Optional custom name for the object. If not provided, generates a name using the class name and instance count. **kwargs: Additional arguments passed to parent class. #N) r _id __class__rr _name_event_handlersset _event_tasks)selfrkwargss r__init__zBaseObject.__init__5sJK 7 78)D/9JK 9;  Erreturnc|jS)zGet the unique identifier for this object. Returns: The unique integer ID assigned to this object instance. )r r&s ridz BaseObject.idHs xxrc|jS)zGet the name of this object. Returns: The object's name, either custom-provided or auto-generated. )r"r+s rrzBaseObject.nameQszzrcK|jrWt|j\}}tj|dt |dt j |d{yy7w)zClean up resources and wait for running event handlers to complete. This method should be called when the object is no longer needed. It waits for all currently executing event handler tasks to finish before returning. z&: waiting on event handlers to finish z...N)r%zipr debuglistasynciowait)r& event_namestaskss rcleanupzBaseObject.cleanupZsc   !$d&7&7!8 K LLD6!G[HYGZZ]^ _,,u% % %  &sAA) A'!A) event_namecfd}|S)zDecorator for registering event handlers. Args: event_name: The name of the event to handle. Returns: The decorator function that registers the handler. c,j||S)N)add_event_handler)handlerr7r&s r decoratorz+BaseObject.event_handler..decoratorps  " ":w 7Nrr)r&r7r<s`` r event_handlerzBaseObject.event_handlerfs rc||jvr)|j|jj|ytj|d|dy)zAdd an event handler for the specified event. Args: event_name: The name of the event to handle. handler: The function to call when the event occurs. Can be sync or async. : event handler z not registeredN)r#rappendr warning)r&r7r;s rr:zBaseObject.add_event_handlervsK -- -   , 5 5 < z2BaseObject._event_task_finished..sMa! Ms N)nextr%discard)r&rLtuple_to_removes ` rrJzBaseObject._event_task_finisheds9 M4+<+<MtT     % %o 6 rc|jS)zReturn the string representation of this object. Returns: The object's name as its string representation. rr+s r__str__zBaseObject.__str__s yyr)F)rrrrrrr(propertyintr,rr6r=r:rrDrMrFr2TaskrJrgrrrrr-s15" "&Cc & QC Q U# UT UBCB>S*77rr)rr2rQrTabcr dataclassesrtypingrrrrlogurur pipecat.utils.utilsr r r rrrrrpsN!,,1  $hhr