qi+ dZddlmZddlmZddlmZddlmcm cm cm Z ddl mZmZmZmZddlmZGdd eZy) z+Frame serialization interfaces for Pipecat.)abstractmethod)Optional) BaseModelN)FrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrame) BaseObjectceZdZdZGddeZddeeffd Zdede fd Z de fd Z e dedeezdzfd Ze d eezdedzfd ZxZS)FrameSerializerzAbstract base class for frame serialization implementations. Defines the interface for converting frames to/from serialized formats for transmission or storage. Subclasses must implement the core serialize/deserialize methods. c eZdZUdZdZeed<y)FrameSerializer.InputParamsaBase configuration parameters for FrameSerializer. Parameters: ignore_rtvi_messages: Whether to ignore RTVI protocol messages during serialization. Defaults to True to prevent RTVI messages from being sent to external transports. Tignore_rtvi_messagesN)__name__ __module__ __qualname____doc__rbool__annotations__U/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/serializers/base_serializer.py InputParamsr s &*d)rrNparamsc ^t|di||xstj|_y)zInitialize the FrameSerializer. Args: params: Configuration parameters. **kwargs: Additional arguments passed to BaseObject (e.g., name). Nr)super__init__r r_params)selfrkwargs __class__s rrzFrameSerializer.__init__*s* "6">! rframereturnc|jjrCt|ttfr-|j j dtjk(ryy)aqCheck if a frame should be ignored during serialization. This method filters out RTVI protocol messages when ignore_rtvi_messages is enabled. Subclasses can override this to add additional filtering logic. Args: frame: The frame to check. Returns: True if the frame should be ignored, False otherwise. labelTF) rr isinstancerrmessagegetRTVI MESSAGE_LABELrr"s rshould_ignore_framez#FrameSerializer.should_ignore_frame4sE LL - -5#>@a"bc !!'*d.@.@@rc Kyw)zInitialize the serializer with startup configuration. Args: frame: StartFrame containing initialization parameters. Nrr+s rsetupzFrameSerializer.setupHs c Kyw)zConvert a frame to its serialized representation. Args: frame: The frame to serialize. Returns: Serialized frame data as string, bytes, or None if serialization fails. Nrr+s r serializezFrameSerializer.serializeP  r/datac Kyw)zConvert serialized data back to a frame object. Args: data: Serialized frame data as string or bytes. Returns: Reconstructed Frame object, or None if deserialization fails. Nr)rr3s r deserializezFrameSerializer.deserialize\r2r/)N)rrrrrrrrrrr,r r.rstrbytesr1r5 __classcell__)r!s@rr r s*i*?x 4?4(    U  sU{T/A      cEk  edl    rr )rabcrtypingrpydanticr)pipecat.processors.frameworks.rtvi.models processors frameworksrtvimodelsr)pipecat.frames.framesrrrr pipecat.utils.base_objectr r rrrrCs6288 1N jN r