o i @s2dZddlZddlZddlmZddlmZmZmZm Z m Z ddl m Z ddl mZddlmZddlmZdd lmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!dd l"m#Z#m$Z$dd l%m&Z&dd l'm(Z(dd l)m*Z*m+Z+ddl,m-Z-zddl.m/Z/ddl0m1Z2ddl3m4Z4m5Z5m6Z6Wn e7yZ8ze 9de8e 9de:de8dZ8[8wwddddddddddddd Z;eGd!d"d"eZeGd'd(d(e=Z?Gd)d*d*e+Z@Gd+d,d,eZAGd-d.d.ZBGd/d0d0e&ZCGd1d2d2e(ZDGd3d4d4e*ZEdS)5zLiveKit transport implementation for Pipecat. This module provides comprehensive LiveKit real-time communication integration including audio streaming, data messaging, participant management, and room event handling for conversational AI applications. N) dataclass)Any AwaitableCallableListOptional)logger) BaseModel)create_stream_resampler) VADAnalyzer) AudioRawFrameBotConnectedFrame CancelFrameClientConnectedFrameEndFrame ImageRawFrameOutputAudioRawFrameOutputDTMFFrameOutputDTMFUrgentFrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrameUserAudioRawFrameUserImageRawFrame)FrameDirectionFrameProcessorSetup)BaseInputTransport)BaseOutputTransport) BaseTransportTransportParams)BaseTaskManager)rtc)video_frame_pb2)retrystop_after_attemptwait_exponentialz Exception: zGIn order to use LiveKit, you need to `pip install pipecat-ai[livekit]`.zMissing module:  ) 0123456789*#c@"eZdZUdZdZeeed<dS)"LiveKitOutputTransportMessageFrameFrame for transport messages in LiveKit rooms. Parameters: participant_id: Optional ID of the participant this message is for/from. Nparticipant_id__name__ __module__ __qualname____doc__r@rstr__annotations__rHrHX/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/transports/livekit/transport.pyr>H r>c@r=)(LiveKitOutputTransportMessageUrgentFrameFrame for urgent transport messages in LiveKit rooms. Parameters: participant_id: Optional ID of the participant this message is for/from. Nr@rArHrHrHrIrKSrJrKc eZdZdZfddZZS)LiveKitTransportMessageFramer?cZtddl}||d|jdtddWddS1s&wYdS)NralwayszLiveKitTransportMessageFrame is deprecated and will be removed in a future version. Instead, use LiveKitOutputTransportMessageFrame.r' stacklevelsuper __post_init__warningscatch_warnings simplefilterwarnDeprecationWarningselfrV __class__rHrIrUf   "z*LiveKitTransportMessageFrame.__post_init__rBrCrDrErU __classcell__rHrHr]rIrN^rNcrM)"LiveKitTransportMessageUrgentFramerLcrO)NrrPzLiveKitTransportMessageUrgentFrame is deprecated and will be removed in a future version. Instead, use LiveKitOutputTransportMessageUrgentFrame.r'rQrSr[r]rHrIrU|r_z0LiveKitTransportMessageUrgentFrame.__post_init__r`rHrHr]rIrctrbrcc@seZdZdZdS) LiveKitParamszConfiguration parameters for LiveKit transport. Inherits all parameters from TransportParams without additional configuration. N)rBrCrDrErHrHrHrIrdsrdc@seZdZUdZegedfed<egedfed<egedfed<eegedfed<eegedfed<eegedfed<eegedfed <eegedfed <eegedfed <eeegedfed <eegedfed <dS)LiveKitCallbacksaCallback handlers for LiveKit events. Parameters: on_connected: Called when connected to the LiveKit room. on_disconnected: Called when disconnected from the LiveKit room. on_participant_connected: Called when a participant joins the room. on_participant_disconnected: Called when a participant leaves the room. on_audio_track_subscribed: Called when an audio track is subscribed. on_audio_track_unsubscribed: Called when an audio track is unsubscribed. on_data_received: Called when data is received from a participant. on_first_participant_joined: Called when the first participant joins. N on_connectedon_disconnectedon_before_disconnecton_participant_connectedon_participant_disconnectedon_audio_track_subscribedon_audio_track_unsubscribedon_video_track_subscribedon_video_track_unsubscribedon_data_receivedon_first_participant_joined) rBrCrDrErrrGrFbytesrHrHrHrIres  rec @s`eZdZdZdedededededef dd Zed efd d Z ed e j fd dZ de fddZddZdefddZeededddddddZdd Zdbd"ed#eefd$d%Zd&efd'd(Zd)e jd efd*d+Zd eefd,d-Zd#ed e fd.d/Z!d0efd1d2Z"d#efd3d4Z#d#efd5d6Z$d7e j%fd8d9Z&d7e j%fd:d;Z'dd?Z*dsz;LiveKitTransportClient.get_participants..)rremote_participantsvaluesrrHrHrIrsz'LiveKitTransportClient.get_participantscs.|jj|}|r|j|j|j|jdSiS)Get metadata for a specific participant. Args: participant_id: ID of the participant to get metadata for. Returns: Dictionary containing participant metadata. )idnamemetadata is_speaking)rrgetrrrr)r\r@ participantrHrHrIget_participant_metadatas z/LiveKitTransportClient.get_participant_metadatarcs|jj|IdHdSzmSet metadata for the local participant. Args: metadata: Metadata string to set. N)rr set_metadatar\rrHrHrIset_participant_metadatasz/LiveKitTransportClient.set_participant_metadatacF|jj|}|r|jD]}|jdkr|dIdHqdSdS)~Mute a specific participant's audio tracks. Args: participant_id: ID of the participant to mute. audioFNrrrtracksrkind set_enabledr\r@rtrackrHrHrImute_participant z'LiveKitTransportClient.mute_participantcr)Unmute a specific participant's audio tracks. Args: participant_id: ID of the participant to unmute. rTNrrrHrHrIunmute_participantrz)LiveKitTransportClient.unmute_participantrcC|j|||ddS)z)Wrapper for participant connected events.z!::_async_on_participant_connectedN)r create_task_async_on_participant_connectedr\rrHrHrIrz8LiveKitTransportClient._on_participant_connected_wrappercCr)z,Wrapper for participant disconnected events.z$::_async_on_participant_disconnectedN)rr"_async_on_participant_disconnectedrrHrHrIrrz;LiveKitTransportClient._on_participant_disconnected_wrapperr publicationcC"|j|||||ddS)z$Wrapper for track subscribed events.z::_async_on_track_subscribedN)rr_async_on_track_subscribedr\rrrrHrHrIr z3LiveKitTransportClient._on_track_subscribed_wrappercCr)z&Wrapper for track unsubscribed events.z::_async_on_track_unsubscribedN)rr_async_on_track_unsubscribedrrHrHrIrrz5LiveKitTransportClient._on_track_unsubscribed_wrappercCr)z!Wrapper for data received events.z::_async_on_data_receivedN)rr_async_on_data_receivedr\rrHrHrIrrz0LiveKitTransportClient._on_data_received_wrappercC|j||ddS)zWrapper for connected events.z::_async_on_connectedN)rr_async_on_connectedrrHrHrIrsz,LiveKitTransportClient._on_connected_wrappercCr )z Wrapper for disconnected events.z::_async_on_disconnectedN)rr_async_on_disconnectedrrHrHrIrsz/LiveKitTransportClient._on_disconnected_wrappercsPtd|j|j|jIdH|js&d|_|j|jIdHdSdS)$Handle participant connected events.zParticipant connected: NT)rridentityr~rirrrprrHrHrIrsz6LiveKitTransportClient._async_on_participant_connectedcsFtd|j|j|jIdHt|dkr!d|_dSdS)'Handle participant disconnected events.zParticipant disconnected: NrF) rrr r~rjrlenrrrrHrHrIrs  z9LiveKitTransportClient._async_on_participant_disconnectedcs|jtjjkr;td|jd|j||j|j<t|}|j | ||j|d|j |jIdHdS|jtjjkrytd|jd|j||j|j<|jjrmt|}|j |||j|d|j |jIdHdSdS)zHandle track subscribed events.zAudio track subscribed: z from participant z::_process_audio_streamNzVideo track subscribed: z::_process_video_stream)rr! TrackKind KIND_AUDIOrrrr AudioStreamrr_process_audio_streamr~rk KIND_VIDEOrr}video_in_enabled VideoStream_process_video_streamrm)r\rrr audio_stream video_streamrHrHrIr s*      z1LiveKitTransportClient._async_on_track_subscribedcsltd|jd|j|jtjjkr!|j |jIdHdS|jtjj kr4|j |jIdHdSdS)z!Handle track unsubscribed events.zTrack unsubscribed: z from N) rrrr rr!rrr~rlrrnrrHrHrIr*sz3LiveKitTransportClient._async_on_track_unsubscribedcs |j|j|jjIdHdS)Handle data received events.N)r~rorrrrrHrHrIr7sz.LiveKitTransportClient._async_on_data_receivedcs|jIdHdS)zHandle connected events.N)r~rfrrHrHrIr ;z*LiveKitTransportClient._async_on_connectedcs4d|_td|jd||jIdHdS)zHandle disconnected events.Frz . Reason: N)rrrr|r~rg)r\reasonrHrHrIr ?sz-LiveKitTransportClient._async_on_disconnectedrcbtd||2z"3dHW}t|tjr#|j||fIdHq tdt|q 6dS)z1Process incoming audio stream from a participant.z0Started processing audio stream for participant N Received unexpected event type: ) rr isinstancer!AudioFrameEventrputrtype)r\rr@eventrHrHrIrE z,LiveKitTransportClient._process_audio_streamcC$ |jIdH\}}||fVq)z(Get the next audio frame from the queue.TN)rrr\rr@rHrHrIget_next_audio_frameN  z+LiveKitTransportClient.get_next_audio_framercr)z1Process incoming video stream from a participant.z0Started processing video stream for participant Nr) rrrr!VideoFrameEventrr!rr")r\rr@r#rHrHrIrTr$z,LiveKitTransportClient._process_video_streamcCr%)z(Get the next video frame from the queue.TN)rrr&rHrHrIget_next_video_frame]r(z+LiveKitTransportClient.get_next_video_framecCs |jdS)z6String representation of the LiveKit transport client.z::LiveKitTransportClient)rrrHrHrI__str__cs zLiveKitTransportClient.__str__N)>rBrCrDrErFrdrerpropertyr@r!rrrrrrrr#r$r%rrrqrrr AudioFrameboolrrrdictrrrrRemoteParticipantrrTrackRemoteTrackPublicationrr DataPacketrrrrrrrrr r rrr'rrr*r+rHrHrHrIrrs '  -            rrcseZdZdZdededeffdd Zede e fdd Z d e ffd d Z d effd d Zd effdd Zdeffdd ZfddZdedefddZddZddZdejdefdd Zd!ejdefd"d#Z Z!S)$LiveKitInputTransportzHandles incoming media streams and events from LiveKit rooms. Processes incoming audio streams from room participants and forwards them as Pipecat frames, including audio resampling and VAD integration. transportclientrvc sFtj|fi|||_||_d|_d|_|j|_t|_ d|_ dS)aInitialize the LiveKit input transport. Args: transport: The parent transport instance. client: LiveKitTransportClient instance. params: Configuration parameters. **kwargs: Additional arguments passed to parent class. NF) rTr _transport_client_audio_in_task_video_in_task vad_analyzer _vad_analyzerr _resampler _initializedr\r6r7rvkwargsr]rHrIros zLiveKitInputTransport.__init__rcCr)zzGet the Voice Activity Detection analyzer. Returns: The VAD analyzer instance if configured. )r=rrHrHrIr<rz"LiveKitInputTransport.vad_analyzerrcst|IdH|jrdSd|_|j|IdH|jIdH|js2|jjr2|| |_|j sA|jj rA|| |_ | |IdHtddS)zStart the input transport and connect to LiveKit room. Args: frame: The start frame containing initialization parameters. NTzLiveKitInputTransport started)rTrr?r9rr:r}audio_in_enabledr_audio_in_task_handlerr;r_video_in_task_handlerset_transport_readyrrrr]rHrIrszLiveKitInputTransport.startcsbt|IdH|jIdH|jr||jIdH|jr*||jIdHtddS)zStop the input transport and disconnect from LiveKit room. Args: frame: The end frame signaling transport shutdown. NzLiveKitInputTransport stopped) rTrr9rr: cancel_taskr;rrrr]rHrIrszLiveKitInputTransport.stopcspt|IdH|jIdH|jr"|jjr"||jIdH|jr4|jj r6||jIdHdSdSdS)zCancel the input transport and disconnect from LiveKit room. Args: frame: The cancel frame signaling immediate cancellation. N) rTcancelr9rr:r}rBrFr;rrr]rHrIrGszLiveKitInputTransport.cancelrc*t|IdH|j|IdHdS)zSetup the input transport with shared client setup. Args: setup: The frame processor setup configuration. NrTrr9rr]rHrIrzLiveKitInputTransport.setupc&tIdH|jIdHdS)z-Cleanup input transport and shared resources.NrTrr8rr]rHrIrzLiveKitInputTransport.cleanupmessagesendercs"t||d}||IdHdS)zPush an application message as an urgent transport frame. Args: message: The message data to send. sender: ID of the message sender. rNr@N)rK push_frame)r\rNrOrrHrHrIpush_app_messages z&LiveKitInputTransport.push_app_messagecstd|j}|2z/3dHW}|r<|\}}||IdH}t|jdkr)q t||j|j|j d}| |IdHq 6dS)z/Handle incoming audio frames from participants.zAudio input task startedNr)user_idr sample_rate num_channels) rrr9r'!_convert_livekit_audio_to_pipecatrrrrTrUpush_audio_frame)r\audio_iterator audio_dataaudio_frame_eventr@pipecat_audio_frameinput_audio_framerHrHrIrCs(   z,LiveKitInputTransport._audio_in_task_handlercstd|j}|2z03dHW}|r=|\}}|j|dIdH}t|jdkr*q t||j|j|j d}| |IdHq 6dS)z/Handle incoming video frames from participants.zVideo input task startedN)video_frame_eventr)rSimagesizeformat) rrr9r*!_convert_livekit_video_to_pipecatrr^rr_r`push_video_frame)r\video_iterator video_datar]r@pipecat_video_frameinput_video_framerHrHrIrDs(   z,LiveKitInputTransport._video_in_task_handlerrZcs:|j}|j|j|j|jIdH}t||j|jdS)z3Convert LiveKit audio frame to Pipecat audio frame.N)rrTrU)rr>resamplertobytesrTr rU)r\rZrrYrHrHrIrV s z7LiveKitInputTransport._convert_livekit_audio_to_pipecatr]cs.|jtjj}t|j|j|jfdd}|S)z3Convert LiveKit video frame to Pipecat video frame.RGB)r^r_r`) rconvertproto_video_frameVideoBufferTypeRGB24rrwidthheight)r\r] rgb_frame image_framerHrHrIras z7LiveKitInputTransport._convert_livekit_video_to_pipecat)"rBrCrDrErrrrdrr-rr r<rrrrrrGrrrrrFrRrCrDr!r r rVr)rrararHrHr]rIr5hs:   r5cseZdZdZdededeffdd Zdeffdd Z de ffd d Z de ffd d Z deffdd ZfddZdeeBfddZdedefddZdefddZdeeBfddZdedejfddZZS)LiveKitOutputTransportzHandles outgoing media streams and events to LiveKit rooms. Manages sending audio frames and data messages to LiveKit room participants, including audio format conversion for LiveKit compatibility. r6r7rvc s*tj|fi|||_||_d|_dS)aInitialize the LiveKit output transport. Args: transport: The parent transport instance. client: LiveKitTransportClient instance. params: Configuration parameters. **kwargs: Additional arguments passed to parent class. FN)rTrr8r9r?r@r]rHrIr/s zLiveKitOutputTransport.__init__rcsdt|IdH|jrdSd|_|j|IdH|jIdH||IdHtddS)zStart the output transport and connect to LiveKit room. Args: frame: The start frame containing initialization parameters. NTzLiveKitOutputTransport started)rTrr?r9rrErrrr]rHrIrEszLiveKitOutputTransport.startcs2t|IdH|jIdHtddS)zStop the output transport and disconnect from LiveKit room. Args: frame: The end frame signaling transport shutdown. NzLiveKitOutputTransport stopped)rTrr9rrrrr]rHrIrWszLiveKitOutputTransport.stopcs(t|IdH|jIdHdS)zCancel the output transport and disconnect from LiveKit room. Args: frame: The cancel frame signaling immediate cancellation. N)rTrGr9rrr]rHrIrGaszLiveKitOutputTransport.cancelrcrH)zSetup the output transport with shared client setup. Args: setup: The frame processor setup configuration. NrIrr]rHrIrjrJzLiveKitOutputTransport.setupcrK)z.Cleanup output transport and shared resources.NrLrr]rHrIrsrMzLiveKitOutputTransport.cleanupcsf|j}t|trtj|dd}t|ttfr&|j| |j IdHdS|j| IdHdS)zySend a transport message to participants. Args: frame: The transport message frame to send. F) ensure_asciiN) rNrr0jsondumpsr>rKr9rencoder@)r\rrNrHrHrI send_messagexs z#LiveKitOutputTransport.send_messagercs ||j}|j|IdHS)zWrite an audio frame to the LiveKit room. Args: frame: The audio frame to write. Returns: True if the audio frame was written successfully, False otherwise. N)!_convert_pipecat_audio_to_livekitrr9r)r\r livekit_audiorHrHrIwrite_audio_frames z(LiveKitOutputTransport.write_audio_framecCsdS)zLiveKit supports native DTMF via telephone events. Returns: True, as LiveKit supports native DTMF transmission. TrHrrHrHrI_supports_native_dtmfsz,LiveKitOutputTransport._supports_native_dtmfcs|j|jjIdHdS)zUse LiveKit's native publish_dtmf method for telephone events. Args: frame: The DTMF frame to write. N)r9rbuttonvaluerrHrHrI_write_dtmf_nativesz)LiveKitOutputTransport._write_dtmf_native pipecat_audiocCs4d}t||}||jj}tj||j|jj|dS)z2Convert Pipecat audio data to LiveKit audio frame.r')rrTrUsamples_per_channel)rr}rr!r.rT)r\rbytes_per_sample total_samplesrrHrHrIrxs  z8LiveKitOutputTransport._convert_pipecat_audio_to_livekit) rBrCrDrErrrrdrrrrrrrGrrrrrrwrr/rzr{rrr~rqr!r.rxrarHrHr]rIrr(s*    rrcseZdZdZ   dFdedededeedeedeef fd d Zd efd d Z d e fddZ e d efddZ defddZd eefddZded efddZdefddZdefddZdefdd Zd!d"Zd#d$Zd%d&Zdefd'd(Zdefd)d*Zdefd+d,Zdefd-d.Zdefd/d0Zdefd1d2Zd3e defd4d5Z!dGd6edeefd7d8Z"dGd6edeefd9d:Z#d;d<Z$d=d>Z%d?d@Z&dAefdBdCZ'defdDdEZ(Z)S)HLiveKitTransportaTransport implementation for LiveKit real-time communication. Provides comprehensive LiveKit integration including audio streaming, data messaging, participant management, and room event handling for conversational AI applications. Event handlers available: - on_connected: Called when the bot connects to the room. - on_disconnected: Called when the bot disconnects from the room. - on_before_disconnect: [sync] Called just before the bot disconnects. - on_call_state_updated: Called when the call state changes. Args: (state: str) - on_first_participant_joined: Called when the first participant joins. Args: (participant_id: str) - on_participant_connected: Called when a participant connects. Args: (participant_id: str) - on_participant_disconnected: Called when a participant disconnects. Args: (participant_id: str) - on_participant_left: Called when a participant leaves. Args: (participant_id: str, reason: str) - on_audio_track_subscribed: Called when an audio track is subscribed. Args: (participant_id: str) - on_audio_track_unsubscribed: Called when an audio track is unsubscribed. Args: (participant_id: str) - on_video_track_subscribed: Called when a video track is subscribed. Args: (participant_id: str) - on_video_track_unsubscribed: Called when a video track is unsubscribed. Args: (participant_id: str) - on_data_received: Called when data is received from a participant. Args: (data: bytes, participant_id: str) Example:: @transport.event_handler("on_first_participant_joined") async def on_first_participant_joined(transport, participant_id): await task.queue_frame(TTSSpeakFrame("Hello!")) @transport.event_handler("on_participant_disconnected") async def on_participant_disconnected(transport, participant_id): await task.queue_frame(EndFrame()) Nrsrtrurv input_name output_namec stj||dt|j|j|j|j|j|j|j |j |j |j |j d }|p&t|_t||||j||j|_d|_d|_|d|d|d|d|d|d |d |d |d |d |d|d|jddddS)aInitialize the LiveKit transport. Args: url: LiveKit server URL to connect to. token: Authentication token for the room. room_name: Name of the LiveKit room to join. params: Configuration parameters for the transport. input_name: Optional name for the input transport. output_name: Optional name for the output transport. )rr) rfrgrhrirjrkrlrmrnrorpNrfrgrirjrkrlrmrnrorpon_participant_lefton_call_state_updatedrhT)sync)rTrre _on_connected_on_disconnected_on_before_disconnect_on_participant_connected_on_participant_disconnected_on_audio_track_subscribed_on_audio_track_unsubscribed_on_video_track_subscribed_on_video_track_unsubscribed_on_data_received_on_first_participant_joinedrdr}rrrr9_input_output_register_event_handler)r\rsrtrurvrrrwr]rHrIrsB             zLiveKitTransport.__init__rcC$|jst||j|j|jd|_|jS)zGet the input transport for receiving media and events. Returns: The LiveKit input transport instance. r)rr5r9r} _input_namerrHrHrIinput zLiveKitTransport.inputcCr)zGet the output transport for sending media and events. Returns: The LiveKit output transport instance. r)rrrr9r} _output_namerrHrHrIoutput$rzLiveKitTransport.outputcCs|jjS)zyGet the participant ID for this transport. Returns: The participant ID assigned by LiveKit. )r9r@rrHrHrIr@0szLiveKitTransport.participant_idrcs&|jr|j|tjIdHdSdS)zlSend an audio frame to the LiveKit room. Args: frame: The audio frame to send. N)r queue_framer DOWNSTREAMrrHrHrI send_audio9szLiveKitTransport.send_audiocCs |jS)r)r9rrrHrHrIrBs z!LiveKitTransport.get_participantsr@cs|j|IdHS)rN)r9rr\r@rHrHrIrJs z)LiveKitTransport.get_participant_metadatarc|j|IdHdSr)r9rrrHrHrIrUzLiveKitTransport.set_metadatacr)rN)r9rrrHrHrIr]rz!LiveKitTransport.mute_participantcr)rN)r9rrrHrHrIrerz#LiveKitTransport.unmute_participantcs4|dIdH|jr|jtIdHdSdS)zHandle room connected events.rfN)_call_event_handlerrrQr rrHrHrIrms zLiveKitTransport._on_connectedc|dIdHdS)z Handle room disconnected events.rgNrrrHrHrIrsrz!LiveKitTransport._on_disconnectedcr)z(Handle before disconnection room events.rhNrrrHrHrIrwrz&LiveKitTransport._on_before_disconnectcs6|d|IdH|jr|jtIdHdSdS)r riN)rrrQrrrHrHrIr{s z*LiveKitTransport._on_participant_connectedcs,|d|IdH|d|dIdHdS)rrjNrrrrrHrHrIrsz-LiveKitTransport._on_participant_disconnectedcR|d|IdH|jjj|}|r%|jD] }|j|j||qdSdS)z%Handle audio track subscribed events.rkN) rr9rrr audio_tracksrrrr\r@rrrHrHrIrz+LiveKitTransport._on_audio_track_subscribedc|d|IdHdS)z'Handle audio track unsubscribed events.rlNrrrHrHrIrz-LiveKitTransport._on_audio_track_unsubscribedcr)z%Handle video track subscribed events.rmN) rr9rrr video_tracksrrrrrHrHrIrrz+LiveKitTransport._on_video_track_subscribedcr)z'Handle video track unsubscribed events.rnNrrrHrHrIrrz-LiveKitTransport._on_video_track_unsubscribedrcs8|jr|j||IdH|d||IdHdS)rNro)rrRdecoder)r\rr@rHrHrIrsz"LiveKitTransport._on_data_receivedrNc.|jrt||d}|j|IdHdSdS)zSend a message to participants in the room. Args: message: The message string to send. participant_id: Optional specific participant to send to. rPN)rr>rwr\rNr@rrHrHrIrwzLiveKitTransport.send_messagecr)zSend an urgent message to participants in the room. Args: message: The urgent message string to send. participant_id: Optional specific participant to send to. rPN)rrKrwrrHrHrIsend_message_urgentrz$LiveKitTransport.send_message_urgentcdS)zXHandle room events. Args: event: The room event to handle. NrHr\r#rHrHrI on_room_eventzLiveKitTransport.on_room_eventcr)zfHandle participant events. Args: event: The participant event to handle. NrHrrHrHrIon_participant_eventrz%LiveKitTransport.on_participant_eventcr)zZHandle track events. Args: event: The track event to handle. NrHrrHrHrIon_track_eventrzLiveKitTransport.on_track_eventstatecr)z Handle call state update events.rNr)r\rrHrHrI_on_call_state_updatedrz'LiveKitTransport._on_call_state_updatedcr)z'Handle first participant joined events.rpNrrrHrHrIrrz-LiveKitTransport._on_first_participant_joined)NNNr,)*rBrCrDrErFrrdrr5rrrrr-r@rrrrr0rrrrrrrrrrrrrrqrrwrrrrrrrarHrHr]rIrsZ/8           r)FrErrt dataclassesrtypingrrrrrlogururpydanticr pipecat.audio.utilsr pipecat.audio.vad.vad_analyzerr pipecat.frames.framesr r rrrrrrrrrrrr"pipecat.processors.frame_processorrrpipecat.transports.base_inputrpipecat.transports.base_outputr!pipecat.transports.base_transportrr"pipecat.utils.asyncio.task_managerr livekitr!livekit.rtc._protor"rktenacityr#r$r%ModuleNotFoundErrorrrrrr>rKrNrcrdrerrr5rrrrHrHrHrIsr     @         =A