o i1 @s^dZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z m Z mZmZmZmZddlZddlmZddlmZdd lmZdd lmZmZdd lmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0dd l1m2Z2m3Z3dd l4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;mZ>z ddl?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZIddl?mJZKWn eLyZMzeNdeMeNdeOdeMdZM[MwwdZPeGddde)ZQeGddde*ZReGdddeQZSeGdddeRZTeGd d!d!e%ZUGd"d#d#eUZVeGd$d%d%e ZWeGd&d'd'e ZXeGd(d)d)e ZYGd*d+d+eZZGd,d-d-eZ[Gd.d/d/eZ\Gd0d1d1eZ]Gd2d3d3eZ^Gd4d5d5e<Z_Gd6d7d7eZ`d8d9ZaeGd:d;d;ZbeGdd?d?eGZfGd@dAdAe7ZgGdBdCdCe9ZhGdDdEdEe;ZidS)FzDaily transport implementation for Pipecat. This module provides comprehensive Daily video conferencing integration including audio/video streaming, transcription, recording, dial-in/out functionality, and real-time communication features. N)CancelledError)ThreadPoolExecutor) dataclassfield)Any AwaitableCallableDictMappingOptionalTuple)logger) BaseModel) KeypadEntry) VADAnalyzer VADParams)BotConnectedFrame CancelFrameClientConnectedFrame DataFrameEndFrameFrameInputAudioRawFrameInputDTMFFrameInputTransportMessageFrameInterimTranscriptionFrameOutputAudioRawFrameOutputImageRawFrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame SpriteFrame StartFrameTranscriptionFrameUserAudioRawFrameUserImageRawFrameUserImageRequestFrame)FrameDirectionFrameProcessorSetup)Language)BaseInputTransport)BaseOutputTransport) BaseTransportTransportParams)BaseTaskManager) AudioData CallClientCustomAudioSourceCustomAudioTrackCustomVideoSourceCustomVideoTrackDaily EventHandler VideoFrameVirtualSpeakerDevice)LogLevelz Exception: zQIn order to use the Daily transport, you need to `pip install pipecat-ai[daily]`.zMissing module: ic@"eZdZUdZdZeeed<dS) DailyOutputTransportMessageFramezFrame for transport messages in Daily calls. Parameters: participant_id: Optional ID of the participant this message is for/from. Nparticipant_id__name__ __module__ __qualname____doc__r;r str__annotations__rCrCV/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/transports/daily/transport.pyr:P r:c@r9)&DailyOutputTransportMessageUrgentFramezFrame for urgent transport messages in Daily calls. Parameters: participant_id: Optional ID of the participant this message is for/from. Nr;r<rCrCrCrDrF[rErFc eZdZdZfddZZS)DailyTransportMessageFramea2Frame for transport messages in Daily calls. .. deprecated:: 0.0.87 This frame is deprecated and will be removed in a future version. Instead, use `DailyOutputTransportMessageFrame`. Parameters: participant_id: Optional ID of the participant this message is for/from. cZtddl}||d|jdtddWddS1s&wYdS)NralwayszDailyTransportMessageFrame is deprecated and will be removed in a future version. Instead, use DailyOutputTransportMessageFrame. stacklevelsuper __post_init__warningscatch_warnings simplefilterwarnDeprecationWarningselfrQ __class__rCrDrPr   "z(DailyTransportMessageFrame.__post_init__r=r>r?r@rP __classcell__rCrCrXrDrHf rHcrG) DailyTransportMessageUrgentFramea?Frame for urgent transport messages in Daily calls. .. deprecated:: 0.0.87 This frame is deprecated and will be removed in a future version. Instead, use `DailyOutputTransportMessageUrgentFrame`. Parameters: participant_id: Optional ID of the participant this message is for/from. crI)NrrJzDailyTransportMessageUrgentFrame is deprecated and will be removed in a future version. Instead, use DailyOutputTransportMessageUrgentFrame.rKrLrNrVrXrCrDrPrZz.DailyTransportMessageUrgentFrame.__post_init__r[rCrCrXrDr^r]r^c@r9)DailyInputTransportMessageFramezFrame for input urgent transport messages in Daily calls. Parameters: participant_id: Optional ID of the participant this message is for/from. Nr;r<rCrCrCrDr_rEr_crG)%DailyInputTransportMessageUrgentFramea>Frame for input urgent transport messages in Daily calls. .. deprecated:: 0.0.87 This frame is deprecated and will be removed in a future version. Instead, use `DailyInputTransportMessageFrame`. Parameters: participant_id: Optional ID of the participant this message is for/from. crI)NrrJzDailyInputTransportMessageUrgentFrame is deprecated and will be removed in a future version. Instead, use DailyInputTransportMessageFrame.rKrLrNrVrXrCrDrPrZz3DailyInputTransportMessageUrgentFrame.__post_init__r[rCrCrXrDr`s r`c@,eZdZUdZeedZeee fe d<dS)DailySIPTransferFramea<SIP call transfer frame for transport queuing. A SIP call transfer that will be queued. The transfer will happen after any preceding audio finishes playing, allowing the bot to complete its current utterance before the transfer occurs. Parameters: settings: SIP call transfer settings. default_factorysettingsN r=r>r?r@rdictrer rArrBrCrCrCrDrb  rbc@ra)DailySIPReferFrameaSIP REFER frame for transport queuing. A SIP REFER that will be queued. The REFER will happen after any preceding audio finishes playing, allowing the bot to complete its current utterance before the REFER occurs. Parameters: settings: SIP REFER settings. rcreNrfrCrCrCrDrirhric@ra)"DailyUpdateRemoteParticipantsFramezFrame to update remote participants in Daily calls. Parameters: remote_participants: See https://reference-python.daily.co/api_reference.html#daily.CallClient.update_remote_participants. rcremote_participantsN) r=r>r?r@rrgrkr rArrBrCrCrCrDrjs rjcsVeZdZdZddddeedeeffddZdefd d Zde fd d Z Z S) WebRTCVADAnalyzerz~Voice Activity Detection analyzer using WebRTC. Implements voice activity detection using Daily's native WebRTC VAD. N sample_rateparamsrnrocs2tj||dtjt|jdd|_tddS)zInitialize the WebRTC VAD analyzer. Args: sample_rate: Audio sample rate in Hz. params: VAD configuration parameters. rm)reset_period_msrnchannelszLoaded native WebRTC VADN) rO__init__r4create_native_vadVAD_RESET_PERIOD_MSrn _webrtc_vadr debug)rWrnrorXrCrDrss zWebRTCVADAnalyzer.__init__returncCst|jdS)zGet the number of audio frames required for VAD analysis. Returns: The number of frames needed (equivalent to 10ms of audio). gY@)intrnrWrCrCrDnum_frames_requiredsz%WebRTCVADAnalyzer.num_frames_requiredcCs d}t|dkr|j|}|S)zAnalyze audio buffer and return voice confidence score. Args: buffer: Audio buffer to analyze. Returns: Voice confidence score between 0.0 and 1.0. r)lenrvanalyze_frames)rWbuffer confidencerCrCrDvoice_confidences  z"WebRTCVADAnalyzer.voice_confidence) r=r>r?r@r ryrrsr{floatrr\rCrCrXrDrls &rlc@s*eZdZUdZdZeed<dZeed<dS)DailyDialinSettingsaSettings for Daily's dial-in functionality. Parameters: call_id: CallId is represented by UUID and represents the sessionId in the SIP Network. call_domain: Call Domain is represented by UUID and represents your Daily Domain on the SIP Network. call_id call_domainN)r=r>r?r@rrArBrrCrCrCrDrs  rc@s~eZdZUdZdZeed<dZeed<dZe ed<dZ e ed <dZ e ed <dZ e ed <dZ e ed <d diZeeefed<dS)DailyTranscriptionSettingsawConfiguration settings for Daily's transcription service. Parameters: language: ISO language code for transcription (e.g. "en"). model: Transcription model to use (e.g. "nova-2-general"). profanity_filter: Whether to filter profanity from transcripts. redact: Whether to redact sensitive information. endpointing: Whether to use endpointing to determine speech segments. punctuate: Whether to add punctuation to transcripts. includeRawResponse: Whether to include raw response data. extra: Additional parameters passed to the Deepgram transcription service. enlanguageznova-2-generalmodelTprofanity_filterFredact endpointing punctuateincludeRawResponseinterim_resultsextraN)r=r>r?r@rrArBrrboolrrrrrr rrCrCrCrDrs       rc@sNeZdZUdZdZeed<dZeed<dZe ed<dZ e e e e fed <dS) DailyCustomVideoTrackParamsaConfiguration for a custom video track. If ``send_settings`` is not provided, the track will use the default video publishing settings (framerate, bitrate, codec, etc.). Parameters: width: Video width in pixels. height: Video height in pixels. color_format: Video color format (e.g., "RGB", "RGBA", "BGRA"). send_settings: Optional Daily sendSettings dict for this track. See https://reference-python.daily.co/types.html#videopublishingsettings iwidthiheightRGB color_formatN send_settings)r=r>r?r@rryrBrrrArr r rrCrCrCrDr6s   rc@sFeZdZUdZdZeeed<dZeed<dZ ee e e fed<dS)DailyCustomAudioTrackParamsaConfiguration for a custom audio track. If ``send_settings`` is not provided, the track will use the default audio publishing settings (bitrate, channel config, etc.). Parameters: sample_rate: Audio sample rate in Hz. Defaults to transport's output sample rate. channels: Number of audio channels. send_settings: Optional Daily sendSettings dict for this track. See https://reference-python.daily.co/types.html#audiopublishingsettings Nrnrprrr) r=r>r?r@rnr ryrBrrrr rArrCrCrCrDrJs  rc@seZdZUdZdZeed<dZeed<dZe ed<dZ e ed<d Z e e eefed <d Ze e eefed <d Ze eed <dZe ed <dZe ed<eZeed<d S) DailyParamsaConfiguration parameters for Daily transport. Parameters: api_url: Daily API base URL. api_key: Daily API authentication key. audio_in_user_tracks: Receive users' audio in separate tracks camera_out_enabled: Whether to enable the main camera output track. custom_audio_track_params: Per-destination configuration for custom audio tracks. custom_video_track_params: Per-destination configuration for custom video tracks. dialin_settings: Optional settings for dial-in functionality. microphone_out_enabled: Whether to enable the main microphone track. transcription_enabled: Whether to enable speech transcription. transcription_settings: Configuration for transcription service. zhttps://api.daily.co/v1api_urlrapi_keyTaudio_in_user_trackscamera_out_enabledNcustom_audio_track_paramscustom_video_track_paramsdialin_settingsmicrophone_out_enabledFtranscription_enabledtranscription_settings)r=r>r?r@rrArBrrrrrr r rrrrrrrrrrCrCrCrDr\s       rc@seZdZUdZeeeefgedfe d<eeeefgedfe d<egedfe d<egedfe d<eegedfe d<eeegedfe d<eegedfe d <eeeefgedfe d <eeeefgedfe d <eegedfe d <eegedfe d <eegedfe d<eegedfe d<eegedfe d<eegedfe d<eegedfe d<eegedfe d<eegedfe d<eegedfe d<eegedfe d<eeeefgedfe d<eeeefegedfe d<eeeefgedfe d<eeeefgedfe d<eee gedfe d<eegedfe d<eeeefgedfe d<eegedfe d<eeegedfe d<dS) DailyCallbacksaCallback handlers for Daily events. Parameters: on_active_speaker_changed: Called when the active speaker of the call has changed. on_joined: Called when bot successfully joined a room. on_left: Called when bot left a room. on_before_leave: Called when bot is about to leave the room. on_error: Called when an error occurs. on_app_message: Called when receiving an app message. on_call_state_updated: Called when call state changes. on_client_connected: Called when a client (participant) connects. on_client_disconnected: Called when a client (participant) disconnects. on_dialin_connected: Called when dial-in is connected. on_dialin_ready: Called when dial-in is ready. on_dialin_stopped: Called when dial-in is stopped. on_dialin_error: Called when dial-in encounters an error. on_dialin_warning: Called when dial-in has a warning. on_dialout_answered: Called when dial-out is answered. on_dialout_connected: Called when dial-out is connected. on_dialout_stopped: Called when dial-out is stopped. on_dialout_error: Called when dial-out encounters an error. on_dialout_warning: Called when dial-out has a warning. on_dtmf_event: Called when a DTMF tone happens. on_participant_joined: Called when a participant joins. on_participant_left: Called when a participant leaves. on_participant_updated: Called when participant info is updated. on_transcription_message: Called when receiving transcription. on_transcription_stopped: Called when transcription is stopped. on_transcription_error: Called when transcription encounters an error. on_recording_started: Called when recording starts. on_recording_stopped: Called when recording stops. on_recording_error: Called when recording encounters an error. Non_active_speaker_changed on_joinedon_lefton_before_leaveon_erroron_app_messageon_call_state_updatedon_client_connectedon_client_disconnectedon_dialin_connectedon_dialin_readyon_dialin_stoppedon_dialin_erroron_dialin_warningon_dialout_answeredon_dialout_connectedon_dialout_stoppedon_dialout_erroron_dialout_warning on_dtmf_eventon_participant_joinedon_participant_lefton_participant_updatedon_transcription_messageon_transcription_stoppedon_transcription_erroron_recording_startedon_recording_stoppedon_recording_error) r=r>r?r@rr rArrrBrrCrCrCrDrxs> " rcsfdd}|S)zCreate a completion callback for Daily API calls. Args: future: The asyncio Future to set the result on. Returns: A callback function that sets the future result. cs$dd}j|g|RdS)NcWsDzt|dkr||WdS|j|WdStjy!YdSw)Nrp)r| set_resultasyncioInvalidStateError)futureargsrCrCrDrs z:completion_callback.._callback..set_result)get_loopcall_soon_threadsafe)rrrrCrD _callbacks z&completion_callback.._callbackrC)rrrCrrDcompletion_callbacks  rc@"eZdZUdZeed<eed<dS)DailyAudioTrackzContainer for Daily audio track components. Parameters: source: The custom audio source for the track. track: The custom audio track instance. sourcetrackN)r=r>r?r@r0rBr1rCrCrCrDr  rc@r)DailyVideoTrackzContainer for Daily video track components. Parameters: source: The custom video source for the track. track: The custom video track instance. rrN)r=r>r?r@r2rBr3rCrCrCrDrrrc s eZdZUdZdZeed<fddZdede eded e d e d ef fd d Z ddZ edefddZedefddZedefddZedefddZdeeBde efddZde efddZdefdd Zdefd!d"Zdedefd#d$Zdedefd%d&Zd'e fd(d)Z!d*d+Z"de#fd,d-Z$d.d/Z%d0d1Z&d2d3Z'd4d5Z(d6d7Z)de*ee+ffd8d9Z,de*ee+ffd:d;Z-de.ee effdd?Z0de efd@dAZ1de efdBdCZ2de efdDdEZ3de.ee effdFdGZ4de efdHdIZ5de efdJdKZ6de efdLdMZ7 NddOedPe ede efdQdRZ8dSefdTdUZ9 V W XddSedYe:dZed[ed\ef d]d^Z; _ ` addSedYe:dbedceddef dedfZ< Nddged e e=de>fdhdiZ?dgede efdjdkZ@ Nddged e eAdeBfdldmZCdgede efdndoZD Ndde efdpdqZE Ndde efdrdsZFdte*ee+fde efdudvZGdwe*ee+fde efdxdyZHdzd{ZIdOe+d|efd}d~ZJdefddZKde+fddZLdefddZMde+fddZNde+fddZOde+fddZPde+fddZQde+fddZRde+fddZSde+fddZTde+fddZUde+fddZVddZWddZXddZYddZZddZ[ddZ\ddZ]ddZ^ddZ_ddZ`dSedeadZefddZbdSedecdcefddZdddZeddZfddZgdehjifddZjdehjifddZkddZldehjmfdd„ZnddĄZoZpS)DailyTransportClientzCore client for interacting with Daily's API. Manages the connection to Daily rooms and handles all low-level API interactions including room management, media streaming, transcription, and event handling. F_daily_initializedcs t|S)zPOverride EventHandler's __new__ method to ensure Daily is initialized only once.)rO__new__)clsrkwargsrXrCrDr zDailyTransportClient.__new__room_urltokenbot_namero callbackstransport_namecsttjsdt_t||_||_||_||_ ||_ ||_ d|_ i|_ i|_g|_d|_d|_d|_d|_d|_t|_d|_d|_tdd|_t|d|_d|_d|_d|_ g|_!d|_"d|_#d|_$d|_%d|_&i|_'i|_(dS) aInitialize the Daily transport client. Args: room_url: URL of the Daily room to connect to. token: Optional authentication token for the room. bot_name: Display name for the bot in the call. params: Configuration parameters for the transport. callbacks: Event callback handlers. transport_name: Name identifier for the transport. TrNFrrp) max_workers) event_handler))rOrsrrr4init _room_url_token _bot_name_params _callbacks_transport_name_participant_id_audio_renderers_video_renderers_transcription_ids_transcription_status_dial_out_session_id_dial_in_session_id_joining_joinedrEvent _joined_event_leave_counter _task_managerr _executorr/_client _event_task _audio_task _video_task_join_message_queue_in_sample_rate_out_sample_rate_speaker _camera_track_microphone_track_custom_audio_tracks_custom_video_tracks)rWrrrrorrrXrCrDrssF      zDailyTransportClient.__init__cCs d|S)z@Generate a unique virtual speaker name for this client instance.zspeaker-rCrzrCrCrD _speaker_nameLs z"DailyTransportClient._speaker_namerxcC|jS)zhGet the Daily room URL. Returns: The room URL this client is connected to. )rrzrCrCrDrPzDailyTransportClient.room_urlcCr)ztGet the participant ID for this client. Returns: The participant ID assigned by Daily. )rrzrCrCrDr;Yrz#DailyTransportClient.participant_idcCr)zdGet the input audio sample rate. Returns: The input sample rate in Hz. )rrzrCrCrDin_sample_ratebrz#DailyTransportClient.in_sample_ratecCr)zfGet the output audio sample rate. Returns: The output sample rate in Hz. )rrzrCrCrDout_sample_ratekrz$DailyTransportClient.out_sample_rateframecs^|js |j|dSd}t|ttfr|j}|}|j j |j |t |d|IdHS)zSend an application message to participants. Args: frame: The message frame to send. Returns: error: An error description or None. N completion) rrappend isinstancer:rFr;_get_event_loop create_futurersend_app_messagemessager)rWrr;rrCrCrD send_messagets    z!DailyTransportClient.send_messagecs|jsdS|j}|jj}t|dd}|}|jj|t|d|IdH}t |dkr7t |||dSt dIdHdS)z9Reads the next 20ms audio frame from the virtual speaker.NdrKrr)audiorn num_channelsg{Gz?) rrraudio_in_channelsryr r  read_framesrr|rrsleep)rWrnr num_framesrrrCrCrDread_next_audio_frames   z*DailyTransportClient.read_next_audio_frame destinationcf|jjpi|}|j||dIdH|j|<d|dii}|r+|jr+d|ji|d|<|j|dS)zRegister a custom audio destination for multi-track output. Args: destination: The destination identifier to register. roN customAudioT sendSettings)rrgetadd_custom_audio_trackrrrupdate_publishingrWrro publishingrCrCrDregister_audio_destination  z/DailyTransportClient.register_audio_destinationcr)zRegister a custom video destination for multi-track output. Args: destination: The destination identifier to register. rN customVideoTr)rrradd_custom_video_trackrrrrrrCrCrDregister_video_destinationr"z/DailyTransportClient.register_video_destinationcs|}|j}d}|s|jr|jj}n|r%||jvr%|j|}|j}|r2|j|jt|dnt |d|d| d|IdH}|dkS)zWrite an audio frame to the appropriate audio track. Args: frame: The audio frame to write. Returns: True if the audio frame was written successfully, False otherwise. Nrz. unable to write audio frames to destination []r) r r transport_destinationrrr write_framesrrr warningr)rWrrr audio_sourcerrrCrCrDwrite_audio_frames      z&DailyTransportClient.write_audio_framecsl|j}d}|s|jr|jj}n|r||jvr|j|}|j}|r)||jdSt|d|ddS)zWrite a video frame to the appropriate video track. Args: frame: The image frame to write. Returns: True if the video frame was written successfully, False otherwise. NTz. unable to write video frames to destination [r&F)r'rrr write_frameimager r))rWrr video_sourcerrCrCrDwrite_video_frames     z&DailyTransportClient.write_video_framesetupcs@|jrdS|j|_t|_|j||j|d|_dS)zSetup the client with task manager and event queues. Args: setup: The frame processor setup configuration. Nz::event_callback_task)r task_managerrQueue _event_queue create_task_callback_task_handlerrrWr0rCrCrDr0s   zDailyTransportClient.setupcs|jr|jr|j|jIdHd|_|jr'|jr'|j|jIdHd|_|jr:|jr:|j|jIdHd|_||j|jIdHdS)z*Cleanup client resources and cancel tasks.N) rr cancel_taskrrr run_in_executorr_cleanuprzrCrCrDcleanup s   zDailyTransportClient.cleanupcsR|jjp|j|_|jjp|j|_|jjrM|jjr4|js4|jr4t |_ |j | |j |d|_n|jsMtj||j|jjdd|_t||jjrk|jsk|jrkt |_|j | |j|d|_|jjr|jst|jj|jj|jj}t|}t||d|_|jjr|j st!|j|jj"}t#|}t$||d|_ dSdSdS)zStart the client and initialize audio/video components. Args: frame: The start frame containing initialization parameters. z::audio_callback_taskT)rnrr non_blockingz::video_callback_taskrrN)%raudio_in_sample_rateraudio_out_sample_rateraudio_in_enabledrrrrr2 _audio_queuer4r5rr4create_speaker_devicerrselect_speaker_devicevideo_in_enabledr _video_queuevideo_out_enabledrr2video_out_widthvideo_out_heightvideo_out_color_formatr3raudio_out_enabledrr0audio_out_channelsr1r)rWrr. video_trackr* audio_trackrCrCrDstartsJ    zDailyTransportClient.startcs<|js|jr|jd7_dStd|jd|_|jddddi|j|j | IdH\}}|sd|_d|_|jd7_| d i d i d }| d i d }td |jd|d||j |IdH|j|IdHdSd|jd|}t||j |IdHd|_dS)z-Join the Daily room with configured settings.rpNzJoining Tbase unsubscribedcamera screenVideoF participantslocalidmeetingSessionzJoined z. Participant ID: z, Meeting ID: zError joining : )rrrr inforrupdate_subscription_profiles set_user_namer_joinrrrrset_flush_join_messageserrorr)rWdatar^r; meeting_id error_msgrCrCrDjoinFs6     zDailyTransportClient.joinc s|jsdS|}|jjo|jj}|jjo|jj}|jj|j |j t ||dd|j r1|j j jndiid|dd|jrA|jj jndiidddd d i|jjrVd |jjinid d |jj|jjd iiid|jjdkrodnd|jjdiddd|IdHS)z'Execute the actual room join operation.N customTrackrUzno-camera-track) isEnabledrezno-microphone-track)rQ microphoner maxQualitylowpreferredCodec encodings) maxBitrate maxFrameraterKstereomono) channelConfigbitrate)inputsr )rclient_settings)rr r rrErrIrrbrrrrrrUrvideo_out_codecvideo_out_bitratevideo_out_frameraterJaudio_out_bitrate)rWrcamera_enabledmicrophone_enabledrCrCrDr[rsn      8zDailyTransportClient._joincs|jd8_|jr|jdkrdSd|_|jtd|j|jIdH|j D] \}}| |IdHq0|j D] \}}| |IdHqB|IdH}|sktd|j|jIdHdSd|jd|}t||j|IdHdS) z+Leave the Daily room and cleanup resources.rprNFzLeaving zLeft zError leaving rW)rrrclearr rXrrrritemsremove_custom_audio_trackrremove_custom_video_track_leaverr^r)rW track_name_r^rarCrCrDleaves&  zDailyTransportClient.leavecs4|jsdS|}|jjt|d|IdHS)z(Execute the actual room leave operation.Nr)rr r rrrWrrCrCrDr|s   zDailyTransportClient._leavecCs|jr |jd|_dSdS)z"Cleanup the Daily client instance.N)rreleaserzrCrCrDr9s  zDailyTransportClient._cleanupcC |jSzGet current participants in the room. Returns: Dictionary of participants keyed by participant ID. rrSrzrCrCrDrS z!DailyTransportClient.participantscCrztGet participant count information. Returns: Dictionary with participant count details. rparticipant_countsrzrCrCrDrrz'DailyTransportClient.participant_countsc,|}|jj|t|d|IdHS)Start a dial-out call to a phone number. Args: settings: Dial-out configuration settings. Returns: session_id: Dail-out session ID. error: An error description or None. rN)r r r start_dialoutrrWrerrCrCrDrs  z"DailyTransportClient.start_dialoutcr)Stop a dial-out call for a specific participant. Args: participant_id: ID of the participant to stop dial-out for. Returns: error: An error description or None. rN)r r r stop_dialoutr)rWr;rrCrCrDr  z!DailyTransportClient.stop_dialoutcsL|dp|j}|s dS||d<|}|jj|t|d|IdHS)zSend DTMF tones during a call. Args: settings: DTMF settings including tones and target session. Returns: error: An error description or None. sessionIdz)Can't send DTMF if 'sessionId' is not setrN)rrr r r send_dtmfrrWre session_idrrCrCrDrs   zDailyTransportClient.send_dtmfcsR|dp |jp |j}|sdS||d<|}|jj|t|d|IdHS)Transfer a SIP call to another destination. Args: settings: SIP call transfer settings. Returns: error: An error description or None. rz1Can't transfer SIP call if 'sessionId' is not setrN)rrrr r rsip_call_transferrrrCrCrDr$s   z&DailyTransportClient.sip_call_transfercr)Send a SIP REFER request. Args: settings: SIP REFER settings. Returns: error: An error description or None. rN)r r r sip_referrrrCrCrDr:rzDailyTransportClient.sip_refercs0|}|jj|||t|d|IdHS)}Start recording the call. Args: streaming_settings: Recording configuration settings. stream_id: Unique identifier for the recording stream. force_new: Whether to force a new recording session. Returns: stream_id: Unique identifier for the recording stream. error: An error description or None. rN)r r rstart_recordingr)rWstreaming_settings stream_id force_newrrCrCrDrGs    z$DailyTransportClient.start_recordingcr)Stop recording the call. Args: stream_id: Unique identifier for the recording stream to stop. Returns: error: An error description or None. rN)r r rstop_recordingr)rWrrrCrCrDr[rz#DailyTransportClient.stop_recordingcs6|jsdS|}|jj|t|d|IdHS)Start transcription for the call. Args: settings: Transcription configuration settings. Returns: error: An error description or None. z3Transcription can't be started without a room token)rerN)rr r rstart_transcriptionrrrCrCrDrhs    z(DailyTransportClient.start_transcriptioncs4|jsdS|}|jjt|d|IdHS)lStop transcription for the call. Returns: error: An error description or None. z3Transcription can't be stopped without a room tokenrN)rr r rstop_transcriptionrrrCrCrDrxs   z'DailyTransportClient.stop_transcriptionNr  user_namecs8|jsdS|}|jj||t|d|IdHS)Send a chat message to Daily's Prebuilt main room. Args: message: The chat message to send. user_name: Optional user name that will appear as sender of the message. Returns: error: An error description or None. z Can't send message if not joined)rrN)rr r rsend_prebuilt_chat_messager)rWr rrrCrCrDrs    z/DailyTransportClient.send_prebuilt_chat_messager;csD|jjsdS|j||jr|jr ||jIdHdSdSdSzEnable transcription capture for a specific participant. Args: participant_id: ID of the participant to capture transcription for. N)rrrrrrupdate_transcriptionrWr;rCrCrD!capture_participant_transcriptions  z6DailyTransportClient.capture_participant_transcriptionre>callbackr*rncallback_interval_mscs|dvr d|dii}ndd|diii}|j||idIdH||j|i|<td|d||jj||j|||d dS) aCapture audio from a specific participant. Args: participant_id: ID of the participant to capture audio from. callback: Callback function to handle audio data. audio_source: Audio source to capture (microphone, screenAudio, or custom). sample_rate: Desired sample rate for audio capture. callback_interval_ms: Interval between audio callbacks in milliseconds. )re screenAudiomedia subscribedrparticipant_settingsNStarting to capture [z] audio from participant )r*rnr)update_subscriptionsr setdefaultr rwrset_audio_renderer_audio_data_received)rWr;rr*rnrrrCrCrDcapture_participant_audios  z.DailyTransportClient.capture_participant_audiorQr framerater.rcs|dvr d|dii}ndd|diii}|j||idIdH||j|i|<td|d||jj||j||d dS) aCapture video from a specific participant. Args: participant_id: ID of the participant to capture video from. callback: Callback function to handle video frames. framerate: Desired framerate for video capture. video_source: Video source to capture (camera, screenVideo, or custom). color_format: Color format for video frames. rPrrr#rNrz] video from participant )r.r)rrrr rwrset_video_renderer_video_frame_received)rWr;rrr.rrrCrCrDcapture_participant_videos z.DailyTransportClient.capture_participant_videor}c sv|}|r|jr|jn|j}|r|jnd}t||}t|}|jj||dt |d|IdHt ||d}|S)a(Add a custom audio track for multi-stream output. Args: track_name: Name for the custom audio track. params: Optional per-track configuration for sample rate, channels, and sendSettings. Returns: The created DailyAudioTrack instance. rpT)r}rLignore_audio_levelrNr<) r r rnrrrr0r1rrrr) rWr}rorrnrrr*rLrrCrCrDrs    z+DailyTransportClient.add_custom_audio_trackcr)zRemove a custom audio track. Args: track_name: Name of the custom audio track to remove. Returns: error: An error description or None. r}rN)r r rrzrrWr}rrCrCrDrz  z.DailyTransportClient.remove_custom_audio_trackc s|}|r |jn|jj}|r|jn|jj}|r|jn|jj}t |||}t |}|j j ||t |d|IdHt||dS)a+Add a custom video track for multi-stream output. Args: track_name: Name for the custom video track. params: Optional per-track configuration for dimensions, color format, and sendSettings. Returns: The created DailyVideoTrack instance. )r}rKrNr<)r r rrrFrrGrrHr2r3rr$rr) rWr}rorrrrr.rKrCrCrDr$(s    z+DailyTransportClient.add_custom_video_trackcr)zRemove a custom video track. Args: track_name: Name of the custom video track to remove. Returns: error: An error description or None. rN)r r rr{rrrCrCrDr{Jrz.DailyTransportClient.remove_custom_video_trackc.|}|jj||t|d|IdHS)aUpdate transcription settings for specific participants. Args: participants: List of participant IDs to enable transcription for. instance_id: Optional transcription instance ID. Returns: error: An error description or None. rN)r r rrr)rWrS instance_idrrCrCrDrZs    z)DailyTransportClient.update_transcriptioncr) Update media subscription settings. Args: participant_settings: Per-participant subscription settings. profile_settings: Global subscription profile settings. Returns: error: An error description or None. )rprofile_settingsrN)r r rrr)rWrrrrCrCrDrls  z)DailyTransportClient.update_subscriptionspublishing_settingscr)Update media publishing settings. Args: publishing_settings: Publishing configuration settings. Returns: error: An error description or None. )rrN)r r rrr)rWrrrCrCrDrs  z&DailyTransportClient.update_publishingrkcr)Update settings for remote participants. Args: remote_participants: Remote participant configuration settings. Returns: error: An error description or None. )rkrN)r r rupdate_remote_participantsr)rWrkrrCrCrDrs   z/DailyTransportClient.update_remote_participantscC||jj|dS)z~Handle active speaker change events. Args: participant: The new active speaker participant info. N)_call_event_callbackrrrW participantrCrCrDrz.DailyTransportClient.on_active_speaker_changedsendercC||jj||dS)zHandle application message events. Args: message: The received message data. sender: ID of the message sender. N)rrrrWr rrCrCrDrz#DailyTransportClient.on_app_messagestatecCr)z_Handle call state update events. Args: state: The new call state. N)rrrrWrrCrCrDrrz*DailyTransportClient.on_call_state_updatedr_cC*d|vr|dnd|_||jj|dS)zcHandle dial-in connected events. Args: data: Dial-in connection data. rrN)rrrrrWr_rCrCrDrz(DailyTransportClient.on_dialin_connected sip_endpointcCr)zlHandle dial-in ready events. Args: sip_endpoint: The SIP endpoint for dial-in. N)rrrrWrrCrCrDrrz$DailyTransportClient.on_dialin_readycC*|d|jkr d|_||jj|dS)z[Handle dial-in stopped events. Args: data: Dial-in stop data. rrN)rrrrrrrCrCrDrz&DailyTransportClient.on_dialin_stoppedcCr)zZHandle dial-in error events. Args: data: Dial-in error data. rrN)rrrrrrrCrCrDrrz$DailyTransportClient.on_dialin_errorcCr)z^Handle dial-in warning events. Args: data: Dial-in warning data. N)rrrrrCrCrDrrz&DailyTransportClient.on_dialin_warningcCr)zbHandle dial-out answered events. Args: data: Dial-out answered data. N)rrrrrCrCrDrrz(DailyTransportClient.on_dialout_answeredcCr)zeHandle dial-out connected events. Args: data: Dial-out connection data. rrN)rrrrrrCrCrDrrz)DailyTransportClient.on_dialout_connectedcCr)z]Handle dial-out stopped events. Args: data: Dial-out stop data. rrN)rrrrrrrCrCrDrrz'DailyTransportClient.on_dialout_stoppedcCr)z\Handle dial-out error events. Args: data: Dial-out error data. rrN)rrrrrrrCrCrDr rz%DailyTransportClient.on_dialout_errorcCr)z`Handle dial-out warning events. Args: data: Dial-out warning data. N)rrrrrCrCrDrrz'DailyTransportClient.on_dialout_warningcCr)zQHandle incoming DTMF events. Args: data: DTMF data. N)rrrrrCrCrDrrz"DailyTransportClient.on_dtmf_eventcCr)zoHandle participant joined events. Args: participant: The participant that joined. N)rrrrrCrCrDr'rz*DailyTransportClient.on_participant_joinedcCr)zHandle participant left events. Args: participant: The participant that left. reason: Reason for leaving. N)rrr)rWrreasonrCrCrDr/rz(DailyTransportClient.on_participant_leftcCr)zqHandle participant updated events. Args: participant: The updated participant info. N)rrrrrCrCrDr8rz+DailyTransportClient.on_participant_updatedcCs*td|||_||j|jdS)zlHandle transcription started events. Args: status: Transcription start status. zTranscription started: N)r rwrrrrrWstatusrCrCrDon_transcription_started@sz-DailyTransportClient.on_transcription_startedcCs td||jj||dS)zHandle transcription stopped events. Args: stopped_by: Who stopped the transcription. stopped_by_error: Whether stopped due to error. zTranscription stoppedN)r rwrrrrW stopped_bystopped_by_errorrCrCrDrJs  z-DailyTransportClient.on_transcription_stoppedcCr)z^Handle transcription error events. Args: message: Error message. N)rrrrWr rCrCrDrVrz+DailyTransportClient.on_transcription_errorcCr)zqHandle transcription message events. Args: message: The transcription message data. N)rrrrrCrCrDr^rz-DailyTransportClient.on_transcription_messagecC$td|||jj|dS)zdHandle recording started events. Args: status: Recording start status. zRecording started: N)r rwrrrrrCrCrDrfz)DailyTransportClient.on_recording_startedcCr)zsHandle recording stopped events. Args: stream_id: ID of the stopped recording stream. zRecording stopped: N)r rwrrrrWrrCrCrDrorz)DailyTransportClient.on_recording_stoppedcCs,td|d|||jj||dS)zHandle recording error events. Args: stream_id: ID of the recording stream with error. message: Error message. zRecording error for rWN)r r^rrrrWrr rCrCrDrxsz'DailyTransportClient.on_recording_error audio_datacC"|j||}|||||dS)z-Handle received audio data from participants.N)r_call_audio_callback)rWr;rr*rrCrCrDrsz)DailyTransportClient._audio_data_received video_framecCr)z/Handle received video frames from participants.N)r_call_video_callback)rWr;rr.rrCrCrDrsz*DailyTransportClient._video_frame_receivedcG|j|j|g|RdS)z,Queue an audio callback for async execution.N)_call_async_callbackr@rWrrrCrCrDrz)DailyTransportClient._call_audio_callbackcGr)z+Queue a video callback for async execution.N)rrDrrCrCrDrrz)DailyTransportClient._call_video_callbackcGr)z,Queue an event callback for async execution.N)rr3rrCrCrDrrz)DailyTransportClient._call_event_callbackqueuecGsBzt||g|R|}|WdSty YdSw)z7Queue a callback for async execution on the event loop.N)rrun_coroutine_threadsafeputr resultFuturesCancelledError)rWrrrrrCrCrDrs z)DailyTransportClient._call_async_callbackcs> |jIdH|IdH^}}||IdH|q)z1Handle queued callbacks from the specified queue.TN)rwaitr task_done)rWrrrrCrCrDr5sz+DailyTransportClient._callback_task_handlercs,|jD] }||IdHq|jdS)z9Send any messages that were queued before join completed.N)rrrxrWrrCrCrDr]s z)DailyTransportClient._flush_join_messagescCs|js t|d|jS)z)Get the event loop from the task manager.z.: missing task manager (pipeline not started?))r Exceptionget_event_looprzrCrCrDr s z$DailyTransportClient._get_event_loopcCs |jdS)z2String representation of the DailyTransportClient.z::DailyTransportClient)rrzrCrCrD__str__rzDailyTransportClient.__str__N)rerrrrQrNN)qr=r>r?r@rrrBrrAr rrrsrpropertyrr;ryrrrrCallClientErrorrrrr!r%rr+rr/r'r0r:r!rMrbr[rr|r9r rrSrr rrrrrrrrrrrrrrrrrrzrrr$r{rrrrrrrrrrrrrrrrrrrrrrrrrrrrr.rr6rrrrrr2rr5r]AbstractEventLoopr rr\rCrCrXrDrsT   M -,D        + ) $ "                      rc sZeZdZdZdededeffdd Zede e fdd Z d d Z d e ffd d ZfddZdeffdd Zdeffdd Zdeffdd Zdedeffdd ZdeeBfddZdedefdd Z ! "d:d#ed$ed%efd&d'Z d#ed(e!d$efd)d*Z"d+d,Z# - . /d;d#ed0ed1ed2efd3d4Z$de%fd5d6Z&d#ed7e'd1efd8d9Z(Z)S)<DailyInputTransportzHandles incoming media streams and events from Daily calls. Processes incoming audio, video, transcriptions and other events from Daily room participants, including participant media capture and event forwarding. transportclientroc sPtj|fi|||_||_||_i|_d|_d|_g|_d|_ |j |_ dS)aInitialize the Daily input transport. Args: transport: The parent transport instance. client: DailyTransportClient instance. params: Configuration parameters. **kwargs: Additional arguments passed to parent class. FN) rOrs _transportrrr _initialized_streaming_started_capture_participant_audio_audio_in_task vad_analyzer _vad_analyzerrWrrrorrXrCrDrss zDailyInputTransport.__init__rxcCr)zzGet the Voice Activity Detection analyzer. Returns: The VAD analyzer instance if configured. )r rzrCrCrDr rz DailyInputTransport.vad_analyzercsv|jjsdStd|jjr6|jjr+|jD]\}}}|j||j||IdHqn |j s6| | |_ d|_ dS)z(Start receiving audio from participants.NzStart receiving audioT) rr?r rwrrrr_on_participant_audio_datar r4_audio_in_task_handlerrrWr;r*rnrCrCrDstart_audio_in_streamings    z,DailyInputTransport.start_audio_in_streamingr0c*t|IdH|j|IdHdS)zSetup the input transport with shared client setup. Args: setup: The frame processor setup configuration. NrOr0rr6rXrCrDr0zDailyInputTransport.setupc6tIdH|jIdH|jIdHdS)z-Cleanup input transport and shared resources.NrOr:rrrzrXrCrDr:zDailyInputTransport.cleanuprcstt|IdH|jrdSd|_|j|IdH|jIdH||IdH|jjr8|IdHdSdS)zStart the input transport and join the Daily room. Args: frame: The start frame containing initialization parameters. NT) rOrMrrrbset_transport_readyraudio_in_stream_on_startrrrXrCrDrM szDailyInputTransport.startcJt|IdH|jIdH|jr#||jIdHd|_dSdS)zStop the input transport and leave the Daily room. Args: frame: The end frame signaling transport shutdown. N)rOstoprrr r7rrXrCrDr: zDailyInputTransport.stopcr)zCancel the input transport and leave the Daily room. Args: frame: The cancel frame signaling immediate cancellation. N)rOcancelrrr r7rrXrCrDrIrzDailyInputTransport.cancel directioncs8t||IdHt|tr||IdHdSdS)zProcess incoming frames, including user image requests. Args: frame: The frame to process. direction: The direction of frame flow in the pipeline. N)rO process_framer r%request_participant_image)rWrrrXrCrDr\s  z!DailyInputTransport.process_framecs||IdHdS)zrPush a transcription frame downstream. Args: frame: The transcription frame to push. N) push_framerrCrCrDpush_transcription_framelsz,DailyInputTransport.push_transcription_framer rcs|jt||dIdHdS)zPush an application message as an urgent transport frame. Args: message: The message data to send. sender: ID of the message sender. )r r;N)broadcast_framer_rrCrCrDpush_app_messagetsz$DailyInputTransport.push_app_messagererr;r*rncs<|jr|j||j||IdHdS|j|||fdSaCapture audio from a specific participant. Args: participant_id: ID of the participant to capture audio from. audio_source: Audio source to capture from. sample_rate: Desired sample rate for audio capture. N)rrrr rrrrCrCrDrs   z-DailyInputTransport.capture_participant_audiorcs2t||j|j|jd}||_||IdHdS)z'Handle received participant audio data.)user_idrrnrN)r# audio_framesrnrtransport_sourcepush_audio_frame)rWr;rr*rrCrCrDr sz.DailyInputTransport._on_participant_audio_datacs* |jIdH}|r||IdHqr)rrr(rrCrCrDrs z*DailyInputTransport._audio_in_task_handlerrrQrrr.rcsL||jvr i|j|<|dgd|j||<|j||j|||IdHdS)8Capture video from a specific participant. Args: participant_id: ID of the participant to capture video from. framerate: Desired framerate for video capture. video_source: Video source to capture from. color_format: Color format for video frames. r)r timestamprender_next_frameN)rrr_on_participant_video_framerWr;rr.rrCrCrDrs   z-DailyInputTransport.capture_participant_videocs@|j|jvr|jr |jnd}|j|j|d|dSdS)z{Request a video frame from a specific participant. Args: frame: The user image request frame. rQr+N)r%rr.r)rWrr.rCrCrDrs  z-DailyInputTransport.request_participant_imagerc sd}t}|j||d}|j||d}d}|dkr+|d|} | |dk}|j||drB|j||dd}d }|rut||j|j|jf|j|rT|jnd|rZ|j nd|d } || _ | | IdH||j||d<dSdS) z)Handle received participant video frames.Fr*rNrrpg?r+T)r%r-sizeformattextappend_to_contextrequest) timerpopr$r~rrrr0r1r'push_video_frame) rWr;rr. render_frame curr_time prev_timer request_frame next_timerrCrCrDr,s<       z/DailyInputTransport._on_participant_video_framererr)*r=r>r?r@r+rrrsrr rr rr'r0r:r!rMrrrrrr&rr"rr!rrAr#ryrr.r rrr%rr6r,r\rCrCrXrDrsr&       rcseZdZdZdededeffdd Zdeffdd Z fd d Z d e ffd d Z d e ffdd Zd effdd Zd eeBfddZdefddZdefddZd edefddZd edefddZd efdd Zdefd!d"Zd#d$ZZ S)%DailyOutputTransportzHandles outgoing media streams and events to Daily calls. Manages sending audio, video and other data to Daily calls, including audio destination registration and message transmission. rrroc s*tj|fi|||_||_d|_dS)aInitialize the Daily output transport. Args: transport: The parent transport instance. client: DailyTransportClient instance. params: Configuration parameters. **kwargs: Additional arguments passed to parent class. FN)rOrsrrrr rXrCrDrss  zDailyOutputTransport.__init__r0cr)zSetup the output transport with shared client setup. Args: setup: The frame processor setup configuration. Nrr6rXrCrDr0rzDailyOutputTransport.setupcr)z.Cleanup output transport and shared resources.NrrzrXrCrDr:rzDailyOutputTransport.cleanuprcsZt|IdH|jrdSd|_|j|IdH|jIdH||IdHdS)zStart the output transport and join the Daily room. Args: frame: The start frame containing initialization parameters. NT)rOrMrrrbrrrXrCrDrM#szDailyOutputTransport.startc(t|IdH|jIdHdS)zStop the output transport and leave the Daily room. Args: frame: The end frame signaling transport shutdown. N)rOrrrrrXrCrDr:zDailyOutputTransport.stopcr=)zCancel the output transport and leave the Daily room. Args: frame: The cancel frame signaling immediate cancellation. N)rOrrrrrXrCrDrEr>zDailyOutputTransport.cancelcs6|j|IdH}|r|d|IdHdSdS)zySend a transport message to participants. Args: frame: The transport message frame to send. NzUnable to send message: )rr push_errorrWrr^rCrCrDrPs z!DailyOutputTransport.send_messagerc|j|IdHdS)z}Register a video output destination. Args: destination: The destination identifier to register. N)rr%rWrrCrCrDr%\z/DailyOutputTransport.register_video_destinationcrA)zRegister an audio output destination. Args: destination: The destination identifier to register. Returns: True if the audio frame was written successfully, False otherwise. N)rr!rBrCrCrDr!ds z/DailyOutputTransport.register_audio_destinationrxc|j|IdHS)zWrite an audio frame to the Daily call. Args: frame: The audio frame to write. Returns: True if the audio frame was written successfully, False otherwise. N)rr+rrCrCrDr+o z&DailyOutputTransport.write_audio_framecrD)zWrite a video frame to the Daily call. Args: frame: The video frame to write. Returns: True if the video frame was written successfully, False otherwise. N)rr/rrCrCrDr/zrEz&DailyOutputTransport.write_video_framecst|tr!|j|jIdH}|r|d|IdHdSdSt|trA|j|jIdH}|r?|d|IdHdSdSt|tr_|j |j IdH}|ra|d|IdHdSdSdS)z}Handle queued SIP frames after preceding audio has been sent. Args: frame: The frame to handle. NUnable to transfer SIP call: Unable to perform SIP REFER: &Unable to update remote participants: ) r rbrrrer?rirrjrrkr@rCrCrDwrite_transport_frames"   z*DailyOutputTransport.write_transport_framecCsdS)zDaily supports native DTMF via telephone events. Returns: True, as Daily supports native DTMF transmission. TrCrzrCrCrD_supports_native_dtmfsz*DailyOutputTransport._supports_native_dtmfcs$|j|j|jjdIdHdS)z}Use Daily's native send_dtmf method for telephone events. Args: frame: The DTMF frame to write. )rtonesN)rrr'buttonvaluerrCrCrD_write_dtmf_natives z'DailyOutputTransport._write_dtmf_native)!r=r>r?r@r+rrrsr'r0r:r!rMrrrrrrrrAr%r!rrr+rr/rrIrJrNr\rCrCrXrDr<s0        r<cseZdZdZ   ddedeededeedeedeef fd d Zd efd d Z d e fddZ e d efddZ e d efddZdefddZdeeBfddZdefddZd eeeffddZd eeeffddZdd eeeeffd d!Zd eefd"d#Zd eefd$d%Zd eefd&d'Z dd eeeeffd(d)Z dd eefd*d+Z!dd eefd,d-Z"d eefd.d/Z# dd0ed1eed eefd2d3Z$d4efd5d6Z% 7 8dd4ed9ed:e&fd;d<Z' = > ?dd4ed@e&dAedBefdCdDZ(dEeeefd eefdFdGZ) dd eefdHdIZ*dJeeefd eefdKdLZ+dMefdNdOZ,dPdQZ-dRdSZ.dTdUZ/dVdWZ0d0edXefdYdZZ1d[efd\d]Z2dMefd^d_Z3dMefd`daZ4dbefdcddZ5dedfZ6dgdhZ7didjZ8dkdlZ9dmdnZ:dodpZ;dqdrZdwdxZ?dydzZ@d{d|ZAd}d~ZBddZCd0eeefd dfddZDddZEddZFddZGddZHddZIZJS)DailyTransporta] Transport implementation for Daily audio and video calls. Provides comprehensive Daily integration including audio/video streaming, transcription, recording, dial-in/out functionality, and real-time communication features for conversational AI applications. Event handlers available: - on_joined: Called when the bot joins the room. Args: (data: dict) - on_connected: Called when the bot connects to the room (alias for on_joined). Args: (data: dict) - on_left: Called when the bot leaves the room. - on_before_leave: [sync] Called just before the bot leaves the room. - on_error: Called when a transport error occurs. Args: (error: str) - 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: dict) - on_participant_joined: Called when any participant joins. Args: (participant: dict) - on_participant_left: Called when a participant leaves. Args: (participant: dict, reason: str) - on_participant_updated: Called when a participant's state changes. Args: (participant: dict) - on_client_connected: Called when a participant connects (alias for on_participant_joined). Args: (participant: dict) - on_client_disconnected: Called when a participant disconnects (alias for on_participant_left). Args: (participant: dict) - on_active_speaker_changed: Called when the active speaker changes. Args: (participant: dict) - on_app_message: Called when an app message is received. Args: (message: Any, sender: str) - on_transcription_message: Called when a transcription message is received. Args: (message: dict) - on_recording_started: Called when recording starts. Args: (status: str) - on_recording_stopped: Called when recording stops. Args: (stream_id: str) - on_recording_error: Called when a recording error occurs. Args: (stream_id: str, message: str) - on_dialin_connected: Called when a dial-in call connects. Args: (data: dict) - on_dialin_ready: Called when the SIP endpoint is ready. Args: (sip_endpoint: str) - on_dialin_stopped: Called when a dial-in call stops. Args: (data: dict) - on_dialin_error: Called when a dial-in error occurs. Args: (data: dict) - on_dialin_warning: Called when a dial-in warning occurs. Args: (data: dict) - on_dialout_answered: Called when a dial-out call is answered. Args: (data: dict) - on_dialout_connected: Called when a dial-out call connects. Args: (data: dict) - on_dialout_stopped: Called when a dial-out call stops. Args: (data: dict) - on_dialout_error: Called when a dial-out error occurs. Args: (data: dict) - on_dialout_warning: Called when a dial-out warning occurs. Args: (data: dict) Example:: @transport.event_handler("on_first_participant_joined") async def on_first_participant_joined(transport, participant): await task.queue_frame(TTSSpeakFrame("Hello!")) @transport.event_handler("on_participant_left") async def on_participant_left(transport, participant, reason): await task.queue_frame(EndFrame()) @transport.event_handler("on_app_message") async def on_app_message(transport, message, sender): logger.info(f"Message from {sender}: {message}") Nrrrro input_name output_namecsbtj||dtd%id|jd|jd|jd|jd|jd|jd|j d |j d |j d |j d |j d |jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|j}|pt |_!t"||||j!||j#|_$d|_%d|_&d |_'|(d|(d!|(d|(d|(d|(d|(d|(d |(d |(d |(d |(d |(d|(d|(d|(d|(d|(d|(d|(d|(d"|(d|(d|(d|(d|(d|(d|(d|j(dd#d$dS)&aInitialize the Daily transport. Args: room_url: URL of the Daily room to connect to. token: Optional authentication token for the room. bot_name: Display name for the bot in the call. params: Configuration parameters for the transport. input_name: Optional name for the input transport. output_name: Optional name for the output transport. )rPrQrrrrrrrrrrrrrrrrrrrrrrrrrrrrrNF on_connectedon_first_participant_joinedT)syncrC))rOrsr_on_active_speaker_changed _on_joined_on_left_on_before_leave _on_error_on_app_message_on_call_state_updated_on_client_connected_on_client_disconnected_on_dialin_connected_on_dialin_ready_on_dialin_stopped_on_dialin_error_on_dialin_warning_on_dialout_answered_on_dialout_connected_on_dialout_stopped_on_dialout_error_on_dialout_warning_on_dtmf_event_on_participant_joined_on_participant_left_on_participant_updated_on_transcription_message_on_transcription_stopped_on_transcription_error_on_recording_started_on_recording_stopped_on_recording_errorrrrnamer_input_output_other_participant_has_joined_register_event_handler)rWrrrrorPrQrrXrCrDrss                                  zDailyTransport.__init__rxcC$|jst||j|j|jd|_|jS)zGet the input transport for receiving media and events. Returns: The Daily input transport instance. rr)rsrrr _input_namerzrCrCrDinputQ zDailyTransport.inputcCrw)zGet the output transport for sending media and events. Returns: The Daily output transport instance. rx)rtr<rr _output_namerzrCrCrDoutput] r{zDailyTransport.outputcC|jjS)zkGet the Daily room URL. Returns: The room URL this transport is connected to. )rrrzrCrCrDrm zDailyTransport.room_urlcCr~)zwGet the participant ID for this transport. Returns: The participant ID assigned by Daily. )rr;rzrCrCrDr;v rzDailyTransport.participant_idlevelcCst|dS)a;Set the logging level for Daily's internal logging system. Args: level: The log level to set. Should be a member of the DailyLogLevel enum, such as DailyLogLevel.Info, DailyLogLevel.Debug, etc. Example: transport.set_log_level(DailyLogLevel.Info) N)r4 set_log_level)rWrrCrCrDr s zDailyTransport.set_log_levelrc&|jr|j|tjIdHdSdS)zjSend an image frame to the Daily call. Args: frame: The image frame to send. Nrt queue_framer& DOWNSTREAMrrCrCrD send_image zDailyTransport.send_imagecr)zjSend an audio frame to the Daily call. Args: frame: The audio frame to send. NrrrCrCrD send_audio rzDailyTransport.send_audiocCrrrrzrCrCrDrS rzDailyTransport.participantscCrrrrzrCrCrDr rz!DailyTransport.participant_countscsDtd||j|IdH\}}|rtd|||fS)rzStarting dialout: settings=NzUnable to start dialout: )r rwrrr^)rWrerr^rCrCrDr s  zDailyTransport.start_dialoutc<td||j|IdH}|rtd||S)rz!Stopping dialout: participant_id=NzUnable to stop dialout: )r rwrrr^)rWr;r^rCrCrDr  zDailyTransport.stop_dialoutcr)rz$Staring SIP call transfer: settings=NrF)r rwrrr^rWrer^rCrCrDr rz DailyTransport.sip_call_transfercr)rzStaring SIP REFER: settings=NrG)r rwrrr^rrCrCrDr rzDailyTransport.sip_refercsTtd|d|d||j|||IdH\}}|r&td|||fS)rzStarting recording: stream_id=z force_new=z settings=NzUnable to start recording: )r rwrrr^)rWrrrr_idr^rCrCrDr szDailyTransport.start_recordingcr)rzStopping recording: stream_id=NzUnable to stop recording: )r rwrrr^)rWrr^rCrCrDr rzDailyTransport.stop_recordingcr)rz!Starting transcription: settings=NUnable to start transcription: )r rwrrr^rrCrCrDr rz"DailyTransport.start_transcriptioncs4td|jIdH}|rtd||S)rzStopping transcriptionNUnable to stop transcription: )r rwrrr^rWr^rCrCrDr% s  z!DailyTransport.stop_transcriptionr rcs.|j||IdH}|rtd||S)rNz&Unable to send prebuilt chat message: )rrr r^)rWr rr^rCrCrDr2 s  z)DailyTransport.send_prebuilt_chat_messager;crAr)rrrrCrCrDrC rCz0DailyTransport.capture_participant_transcriptionrerr*rncs&|jr|j|||IdHdSdSr$)rsrrrCrCrDrK s z(DailyTransport.capture_participant_audiorrQrrr.rcs(|jr|j||||IdHdSdS)r)N)rsrr-rCrCrDr[ s z(DailyTransport.capture_participant_videorc>td||jj|dIdH}|rtd||S)rz'Updating publishing settings: settings=)rNz&Unable to update publishing settings: )r rwrrr^)rWrr^rCrCrDro s  z DailyTransport.update_publishingcsFtd|d||jj||dIdH}|r!td||S)rz-Updating subscriptions: participant_settings=z profile_settings=)rrNz(Unable to update subscription settings: )r rwrrr^)rWrrr^rCrCrDr s  z#DailyTransport.update_subscriptionsrkcr)rz2Updating remote participants: remote_participants=)rkNrH)r rwrrr^)rWrkr^rCrCrDr s  z)DailyTransport.update_remote_participantsrc|d|IdHdS)z$Handle active speaker change events.rN_call_event_handlerrrCrCrDrU z)DailyTransport._on_active_speaker_changedcs|jjr"|jjjdd}||IdH}|r"|d|IdH|d|IdH|d|IdH|jrC|jt IdHdSdS)zHandle room joined events.T) exclude_noneNrrrR) rrr model_dumprrYrrsr r)rWr_rer^rCrCrDrV szDailyTransport._on_joinedcs|dIdHdS)zHandle room left events.rNrrzrCrCrDrW szDailyTransport._on_leftcsF|jjr|IdH}|r|d|IdH|dIdHdS)z Handle before leave room events.Nrr)rrrrYrrrCrCrDrX s zDailyTransport._on_before_leavecsb|d|IdH|jr|jj|dIdHdS|jr(|jj|dIdHdStdtd)z*Handle error events and push error frames.rN)raz9Both input and output are None while trying to push errorz.No valid input or output channel to push error)rrsr?rtr r^rrrCrCrDrY s zDailyTransport._on_errorrcs4|jr|j||IdH|d||IdHdS)z"Handle application message events.Nr)rsr#rrrCrCrDrZ szDailyTransport._on_app_messagercr)z Handle call state update events.rNrrrCrCrDr[ rz%DailyTransport._on_call_state_updatedcr)zHandle client connected events.rNrrrCrCrDr\ rz#DailyTransport._on_client_connectedcr)z"Handle client disconnected events.rNrrrCrCrDr] rz&DailyTransport._on_client_disconnectedrc s|jjsdSt4IdH}d|jjdd}|jjj|jjj|d}|jjd}z]|j|||tj ddd 4IdH?}|j d kro| IdH}t d |j d |d  WdIdHWWdIdHdSt dWdIdHn 1IdHswYWn/tjyt d|d Yn(ty}zt d|d|WYd}~nd}~wwWdIdHdSWdIdHdSWdIdHdS1IdHswYdS)z:Handle dial-in ready events by updating SIP configuration.NzBearer zapplication/json) Authorizationz Content-Type)callId callDomainsipUriz/dialin/pinlessCallUpdate )total)headersjsontimeoutz-Unable to handle dialin-ready event (status: z , error: )z+Event dialin-ready was handled successfullyz%Timeout handling dialin-ready event (z#Error handling dialin-ready event (): )rraiohttp ClientSessionrrrrpost ClientTimeoutrr0r r^rwr TimeoutErrorr) rWrsessionrr_urlrr0erCrCrD_handle_dialin_ready sP   ( ".z#DailyTransport._handle_dialin_readyc,t|d||d|IdHdS)z Handle dial-in connected events.z dial-in connected: rNr rwrrrCrCrDr^ z#DailyTransport._on_dialin_connectedcsDt|d||jjr||IdH|d|IdHdS)zHandle dial-in ready events.z dial-in ready: Nr)r rwrrrrrrCrCrDr_ s zDailyTransport._on_dialin_readycr)zHandle dial-in stopped events.z dial-in stopped: rNrrrCrCrDr` rz!DailyTransport._on_dialin_stoppedcr)zHandle dial-in error events.z dial-in error: rNr r^rrrCrCrDra rzDailyTransport._on_dialin_errorcr)zHandle dial-in warning events.z dial-in warning: rNr r)rrrCrCrDrb# rz!DailyTransport._on_dialin_warningcr)z Handle dial-out answered events.z dial-out answered: rNrrrCrCrDrc( rz#DailyTransport._on_dialout_answeredcr)z!Handle dial-out connected events.z dial-out connected: rNrrrCrCrDrd- rz$DailyTransport._on_dialout_connectedcr)zHandle dial-out stopped events.z dial-out stopped: rNrrrCrCrDre2 rz"DailyTransport._on_dialout_stoppedcr)zHandle dial-out error events.z dial-out error: rNrrrCrCrDrf7 rz DailyTransport._on_dialout_errorcr)zHandle dial-out warning events.z dial-out warning: rNrrrCrCrDrg< rz"DailyTransport._on_dialout_warningcsZt|d||d|IdH|jr+tt|dd}|j|IdHdSdS)zHandle incoming DTMF events.z DTMF event: rNtone)rL)r rwrrsrrr )rWr_rrCrCrDrhA szDailyTransport._on_dtmf_eventcs|d}td||jr%|jjr%|jjr%|j|d|jjIdH|j s4d|_ | d|IdH| d|IdH| d|IdH|jrU|j t IdHdSdS) z!Handle participant joined events.rUzParticipant joined reNTrSrr) r rXrsrr?rrrrrurr r)rWrrUrCrCrDriJ s  z%DailyTransport._on_participant_joinedcsD|d}td||d||IdH|d|IdHdS)zHandle participant left events.rUzParticipant left rNr)r rXr)rWrrrUrCrCrDrj^ s z#DailyTransport._on_participant_leftcr)z"Handle participant updated events.z participant updated: rN)r tracerrrCrCrDrkf rz&DailyTransport._on_participant_updatedc s|d|IdHd}d|vr|d}|sdS|d}|d}|dd}|di}|d d }z|d d d dd }t|}Wn tyOd}Ynw|rht|||||d} td|d|dn t|||||d} || _|j r|j | IdHdSdS)z$Handle transcription message events.rNr participantIdr0r* trackType rawResponseis_finalFchannel alternativesr languages)rzTranscription (from: z): [r&) rrr(KeyErrorr"r rwrr'rsr!) rWr r;r0r* track_type raw_responserrrrCrCrDrlk s@     z(DailyTransport._on_transcription_messagecs6t|d|d|d|d||IdHdS)z$Handle transcription stopped events.z transcription stopped by: z (error: rrNrrrCrCrDrm sz(DailyTransport._on_transcription_stoppedcr)z"Handle transcription error events.z transcription error: rNrrrCrCrDrn rz&DailyTransport._on_transcription_errorcr)z Handle recording started events.z recording started: rNrrrCrCrDro rz$DailyTransport._on_recording_startedcs.t|d|d|d|IdHdS)z Handle recording stopped events.z recording stopped (id: rrNrrrCrCrDrp sz$DailyTransport._on_recording_stoppedcs4t|d|d||d||IdHdS)zHandle recording error events.z recording error (id: rrNrrrCrCrDrq sz"DailyTransport._on_recording_error)NNNrr;rr)Kr=r>r?r@rAr rrsrrzr<r}rrr; DailyLogLevelrrr rrrr rrSrr rrrrrrrrrrrryrrrrrrUrVrWrXrYrZr[r\r]rr^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqr\rCrCrXrDrOsEb                # $rO)jr@rr3concurrent.futuresrrr dataclassesrrtypingrrrr r r r rlogurur pydanticrpipecat.audio.dtmf.typesrpipecat.audio.vad.vad_analyzerrrpipecat.frames.framesrrrrrrrrrrrrrrr r!r"r#r$r%"pipecat.processors.frame_processorr&r'pipecat.transcriptions.languager(pipecat.transports.base_inputr)pipecat.transports.base_outputr*!pipecat.transports.base_transportr+r,"pipecat.utils.asyncio.task_managerr-dailyr.r/r0r1r2r3r4r5r6r7r8rModuleNotFoundErrorrr^rrur:rFrHr^r_r`rbrirjrlrrrrrrrrrrArrrr<rOrCrCrCrDs  $   X    0     + B ]65