qi!vdZddlZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZGddeZy) zBThis module defines a controller for managing user idle detection.N)Optional) BotStartedSpeakingFrameBotStoppedSpeakingFrameFrameFunctionCallCancelFrameFunctionCallResultFrameFunctionCallsStartedFrameUserIdleTimeoutUpdateFrameUserStartedSpeakingFrameUserStoppedSpeakingFrame)BaseTaskManager) BaseObjectcxeZdZdZdddeffdZedefdZdefd Z fd Z d e fd Z d Z dZdZxZS)UserIdleControlleraController for managing user idle detection. This class monitors user activity and triggers an event when the user has been idle (not speaking) for a configured timeout period after the bot finishes speaking. The timer starts when BotStoppedSpeakingFrame is received and is cancelled when someone starts speaking again (UserStartedSpeakingFrame or BotStartedSpeakingFrame). The timer is suppressed while a user turn is in progress to avoid false triggers during interruptions (where BotStoppedSpeakingFrame arrives while the user is still speaking). Event handlers available: - on_user_turn_idle: Emitted when the user has been idle for the timeout period. Example:: @controller.event_handler("on_user_turn_idle") async def on_user_turn_idle(controller): # Handle user idle - send reminder, prompt, etc. ... r)user_idle_timeoutrct|||_d|_d|_d|_d|_|jddy)zInitialize the user idle controller. Args: user_idle_timeout: Timeout in seconds before considering the user idle. 0 disables idle detection. NFron_user_turn_idleT)sync)super__init___user_idle_timeout _task_manager_user_turn_in_progress_function_calls_in_progress_idle_timer_task_register_event_handler)selfr __class__s T/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/turns/user_idle_controller.pyrzUserIdleController.__init__4sL "38<,1#01(8< $$%8t$DreturncN|jst|d|jS)z$Returns the configured task manager.z, user idle controller was not properly setup)r RuntimeErrorrs r task_managerzUserIdleController.task_managerKs,!!$'STU U!!!r r%cK||_yw)zInitialize the controller with the given task manager. Args: task_manager: The task manager to be associated with this instance. N)r)rr%s rsetupzUserIdleController.setupRs *s crKt|d{|jd{y77w)zCleanup the controller.N)rcleanup_cancel_idle_timer)rrs rr)zUserIdleController.cleanupZs2go%%''' 's737577framec0Kt|tr9|j|_|jdkr|j d{yt|t r6|j s)|jdk(r|jd{yyyt|tr|j d{yt|tr d|_|j d{yt|trd|_yt|trA|xjt|jz c_|j d{yt|tt frt#d|jdz |_yy7D7777Ew)z}Process an incoming frame to track user activity state. Args: frame: The frame to be processed. rNTF) isinstancer timeoutrr*rrr_start_idle_timerrr r r lenfunction_callsrrmax)rr+s r process_framez UserIdleController.process_frame_s\ e7 8&+mmD #&&!+--///  e4 5..43S3SWX3X,,...4Y. 6 7))+ + + 7 8*.D '))+ + + 7 8*/D ' 8 9  , ,E4H4H0I I ,))+ + +  79PQ R/21d6V6VYZ6Z/[D ,S=0&/ + , ,s\AFF AF F  *F5F6/F%F&A(FFrJs6I   ?0B<B