qiRdZddlmZmZmZmZddlmZmZddl m Z GddeZ y)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_endofsentencec6eZdZdZfdZdedeffd ZxZS)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.") c0t|d|_y)zInitialize the sentence aggregator. Sets up internal state for accumulating text frames into complete sentences. N)super__init__ _aggregation)self __class__s Y/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/processors/aggregators/sentence.pyrzSentenceAggregator.__init__ s frame directionc`Kt|||d{t|tryt|tri|xj |j z c_t|j r4|jt |j d{d|_yyt|trR|j r,|jt |j d{|j|d{y|j||d{y7 77>7'7w)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 isinstancerrrtextr push_framer)rrrrs rrz SentenceAggregator.process_frame(sg#E9555 e6 7  eY '    + "4#4#45ooi0A0A&BCCC$&!6x (  ooi0A0A&BCCC//%( ( (//%3 3 3! 6DD ( 3sYD.D#BD.D&AD.)D(*D.D*D.D,D.&D.(D.*D.,D.) __name__ __module__ __qualname____doc__rrrr __classcell__)rs@rr r s% 44>44rr N) rpipecat.frames.framesrrrr"pipecat.processors.frame_processorrrpipecat.utils.stringr r rrr%s% XWM4-4-4r