qiBdZddlmZddlmZddlmZGddeZy)zUser response aggregation for text frames. This module provides an aggregator that collects user responses and outputs them as TextFrame objects, useful for capturing and processing user input in conversational pipelines. ) TextFrame) LLMContext)LLMUserAggregatorc(eZdZdZfdZdZxZS)UserResponseAggregatorzAggregates user responses into TextFrame objects. This aggregator extends LLMUserAggregator to specifically handle user input by collecting text responses and outputting them as TextFrame objects when the aggregation is complete. c t|ddti|ddl}|j 5|j d|j dtddddy#1swYyxYw) a Initialize the user response aggregator. .. deprecated:: 0.0.92 `UserResponseAggregator` is deprecated and will be removed in a future version. Args: **kwargs: Additional arguments passed to parent LLMUserAggregator. contextrNalwayszO`UserResponseAggregator` is deprecated and will be removed in a future version.) stacklevel)super__init__rwarningscatch_warnings simplefilterwarnDeprecationWarning)selfkwargsr __class__s ^/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/processors/aggregators/user_response.pyrzUserResponseAggregator.__init__sh 888  $ $ &   ! !( + MMa"     s *A""A+cKt|jdkDr\t|jj}d|_|j |d{|j d{yy77w)zPush the aggregated user response as a TextFrame. Creates a TextFrame from the current aggregation if it contains content, resets the aggregation state, and pushes the frame downstream. rN)len _aggregationrstrip push_framereset)rframes rpush_aggregationz'UserResponseAggregator.push_aggregation0sq t  !A %d//5578E!#D //%( ( (**,   & ) s$AA<A8A<1A:2A<:A<)__name__ __module__ __qualname____doc__rr! __classcell__)rs@rrrs*rN)r%pipecat.frames.framesr*pipecat.processors.aggregators.llm_contextr5pipecat.processors.aggregators.llm_response_universalrrr r'rr+s",AS-.-r'