qi"dZddlZddlZddlZddlmZmZmZddlm Z m Z m Z m Z m Z mZmZmZddlmZmZGddeZy)z5User idle detection and timeout handling for Pipecat.N) AwaitableCallableUnion)BotSpeakingFrame CancelFrameEndFrameFrameFunctionCallInProgressFrameFunctionCallResultFrameUserStartedSpeakingFrameUserStoppedSpeakingFrame)FrameDirectionFrameProcessorceZdZdZdeedgedfedegeeffde ffd Z deedgedfedegeeffdedegeeffdZ ddZ e defd Zdd Zd ed eddffd Zdfd ZddZxZS)UserIdleProcessoraMonitors user inactivity and triggers callbacks after timeout periods. .. deprecated:: 0.0.100 UserIdleProcessor is deprecated in 0.0.100 and will be removed in a future version. Use LLMUserAggregator with user_idle_timeout parameter instead. This processor tracks user activity and triggers configurable callbacks when users become idle. It starts monitoring only after the first conversation activity and supports both basic and retry-based callback patterns. Example:: # Retry callback: async def handle_idle(processor: "UserIdleProcessor", retry_count: int) -> bool: if retry_count < 3: await send_reminder("Are you still there?") return True return False # Basic callback: async def handle_idle(processor: "UserIdleProcessor") -> None: await send_reminder("Are you still there?") processor = UserIdleProcessor( callback=handle_idle, timeout=5.0 ) callbackNtimeoutc t|di|tjdt|j ||_||_d|_d|_ d|_ d|_ tj|_y)aInitialize the user idle processor. Args: callback: Function to call when user is idle. Can be either a basic callback taking only the processor, or a retry callback taking the processor and retry count. Retry callbacks should return True to continue monitoring or False to stop. timeout: Seconds to wait before considering user idle. **kwargs: Additional arguments passed to FrameProcessor. zUserIdleProcessor is deprecated in 0.0.100 and will be removed in a future version. Use LLMUserAggregator with user_idle_timeout parameter instead.rFN)super__init__warningswarnDeprecationWarning_wrap_callback _callback_timeout _retry_count _interrupted_conversation_started _idle_taskasyncioEvent _idle_event)selfrrkwargs __class__s X/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/processors/user_idle_processor.pyrzUserIdleProcessor.__init__9ss( "6"     ,,X6 !%*""==?returnctj}t|jdddtdt ffd }|S)zWraps callback to support both basic and retry signatures. Args: callback: The callback function to wrap. Returns: A wrapped callback that returns bool to indicate whether to continue monitoring. processorr retry_countr*cbKdk(r|d{y||d{S77w)NTr)r,r-r param_counts r(wrapperz1UserIdleProcessor._wrap_callback..wrapperps=ay)))&i=== *>s/+/-//)inspect signaturelen parametersintbool)r%rsigr1r0s ` @r(rz UserIdleProcessor._wrap_callback^sE)#..)  >%8 >s >t >r)cf|js%|j|j|_yy)z4Creates the idle task if it hasn't been created yet.N)r! create_task_idle_task_handlerr%s r(_create_idle_taskz#UserIdleProcessor._create_idle_task{s)"..t/F/F/HIDOr)c|jS)z}Get the current retry count. Returns: The number of times the idle callback has been triggered. )rr<s r(r-zUserIdleProcessor.retry_counts   r)c~K|jr+|j|jd{d|_yy7 w)z-Stops and cleans up the idle monitoring task.N)r! cancel_taskr<s r(_stopzUserIdleProcessor._stops4 ??""4??3 3 3"DO  3s +=;=frame directioncKt|||d{t|ttfr3|j d{|j ||d{y|j ||d{|js-t|ttfrd|_|j|jrt|tr)d|_ d|_ |jjyt|tr"d|_ |jjyt|tr|jjyt|t r"d|_ |jjyt|t"r"d|_ |jjyyy77~7g7Ow)zProcesses incoming frames and manages idle monitoring state. Args: frame: The frame to process. direction: Direction of the frame flow. NTrF)r process_frame isinstancerrrA push_framer r rr=rrr$setr r r )r%rBrCr's r(rEzUserIdleProcessor.process_framesg#E9555 eh 4 5**,  //%3 3 3 ooeY///))j ,.>?/ *.D &  " " $  % %%!9:$%!$(!  $$&E#;<$)!  $$&E#34  $$&E#>?$(!  $$&E#:;$)!  $$&< &) 6  3 0sFG G-G GG G G :G ;EG G G  G cKt|d{|jr|jd{yy7*7w)z4Cleans up resources when processor is shutting down.N)rcleanupr!rA)r%r's r(rJzUserIdleProcessor.cleanups;go ??**,    sAA#AAAAcKd}|r` tj|jj|jd{|jj|r_yy7##tj $rI|j s:|xjdz c_|j||jd{7}Y|wxYw#|jjwxYww)zMonitors for idle timeout and triggers callbacks. Runs in a loop until cancelled or callback indicates completion. T)rNr/) r"wait_forr$waitr TimeoutErrorrrrclear)r%runnings r(r;z$UserIdleProcessor._idle_task_handlers  )&&t'7'7'<'<'> VVV   &&(V'' L((%%*%$(NN49J9J$KKKG L   &&(sYC(CC CC C%%C()r*N)__name__ __module__ __qualname____doc__rrrr6r7floatrrr=propertyr-rAr rrErJr; __classcell__)r's@r(rrs:#+ )*IdO; < )3/4@ A C #+#+J )*IdO; < )3/4@ A C  &,io= > :J !S!!# ,','>,'d,'\ )r)r)rTr"r2rtypingrrrpipecat.frames.framesrrrr r r r r "pipecat.processors.frame_processorrrrrr)r(r[s<<--   Nv)v)r)