o i+ @s~dZddlmZddlmZddlmZddlmm m m Z ddl mZmZmZmZddlmZGdd d eZdS) z+Frame serialization interfaces for Pipecat.)abstractmethod)Optional) BaseModelN)FrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrame) BaseObjectcseZdZdZGdddeZddeeffdd Zded e fd d Z de fd d Z e ded eeBdBfddZe deeBd edBfddZZS)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@seZdZUdZdZeed<dS)zFrameSerializer.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__r bool__annotations__rrW/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/serializers/base_serializer.py InputParams s rNparamsc s$tjdi||pt|_dS)zInitialize the FrameSerializer. Args: params: Configuration parameters. **kwargs: Additional arguments passed to BaseObject (e.g., name). Nr)super__init__r r_params)selfrkwargs __class__rrr*szFrameSerializer.__init__framereturncCs0|jjrt|ttfr|jdtjkrdSdS)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_LABELrrrrrshould_ignore_frame4s  z#FrameSerializer.should_ignore_framecdS)zInitialize the serializer with startup configuration. Args: frame: StartFrame containing initialization parameters. Nrr%rrrsetupHszFrameSerializer.setupcr')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%rrr serializeP zFrameSerializer.serializedatacr')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)rr+rrr deserialize\r*zFrameSerializer.deserialize)N)r r rrrrrrrrr&rr(rstrbytesr)r, __classcell__rrrrr s   $r )rabcrtypingrpydanticr)pipecat.processors.frameworks.rtvi.models processors frameworksrtvimodelsr#pipecat.frames.framesrrrrpipecat.utils.base_objectr r rrrrs