qiRdZddlmZmZmZddlmZmZddlm Z m Z Gdde Z y)z4Stateless text transformation processor for Pipecat.)Callable CoroutineUnion)Frame TextFrame)FrameDirectionFrameProcessorc jeZdZdZdeeegefeegeddefffffd Zde de ffd Z xZ S)StatelessTextTransformera Processor that applies transformation functions to text frames. This processor intercepts TextFrame objects and applies a user-provided transformation function to the text content. The function can be either synchronous or asynchronous (coroutine). transform_fnNc0t|||_y)zInitialize the text transformer. Args: transform_fn: Function to apply to text content. Can be synchronous (str -> str) or asynchronous (str -> Coroutine[None, None, str]). N)super__init__ _transform_fn)selfr __class__s U/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/processors/text_transformer.pyrz!StatelessTextTransformer.__init__s )frame directioncTKt|||d{t|trY|j |j }t|t r |d{}|jt|d{y|j||d{y77E7$7 w)zProcess frames, applying transformation to text frames. Args: frame: The frame to process. direction: The direction of frame flow in the pipeline. N)text)r process_frame isinstancerrrr push_frame)rrrresultrs rrz&StatelessTextTransformer.process_frame#sg#E9555 eY ''' 3F&),%//)"89 9 9//%3 3 3 6 & 9 3sFB(B AB(B""B(?B$B(B&B("B($B(&B() __name__ __module__ __qualname____doc__rrstrrrrrr __classcell__)rs@rr r s] *!(C5#:"6# RVX\^aRaHbAb8c"cd *44>44rr N) r typingrrrpipecat.frames.framesrr"pipecat.processors.frame_processorrr r rrr's";--2M#4~#4r