o i@sLdZddlmZmZmZmZddlmZmZddl m Z GdddeZ dS)zText sentence aggregation processor for Pipecat. This module provides a frame processor that accumulates text frames into complete sentences, only outputting when a sentence-ending pattern is detected. )EndFrameFrameInterimTranscriptionFrame TextFrame)FrameDirectionFrameProcessor)match_endofsentencecs6eZdZdZfddZdedeffdd ZZS)SentenceAggregatoraAggregates text frames into complete sentences. This processor accumulates incoming text frames until a sentence-ending pattern is detected, then outputs the complete sentence as a single frame. Useful for ensuring downstream processors receive coherent, complete sentences rather than fragmented text. Frame input/output:: TextFrame("Hello,") -> None TextFrame(" world.") -> TextFrame("Hello, world.") cstd|_dS)zInitialize the sentence aggregator. Sets up internal state for accumulating text frames into complete sentences. N)super__init__ _aggregation)self __class__[/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/processors/aggregators/sentence.pyr s  zSentenceAggregator.__init__frame directioncst||IdHt|trdSt|tr6|j|j7_t|jr4|t|jIdHd|_dSdSt|t rS|jrI|t|jIdH||IdHdS|||IdHdS)zProcess incoming frames and aggregate text into complete sentences. Args: frame: The incoming frame to process. direction: The direction of frame flow in the pipeline. Nr ) r process_frame isinstancerrr textr push_framer)rrrrrrr(s     z SentenceAggregator.process_frame) __name__ __module__ __qualname____doc__r rrr __classcell__rrrrr s r N) rpipecat.frames.framesrrrr"pipecat.processors.frame_processorrrpipecat.utils.stringrr rrrrs