qiFdZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z m Z mZmZmZmZddlZddlmZddlmZdd lmZmZdd lmZmZmZmZmZm 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-dd l.m/Z/m0Z0dd l1m2Z2dd l3m4Z4ddl5m6Z6ddl7m8Z8m9Z9ddl:m;Z; ddlZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFddld?e4ZdGd@dAe6ZeGdBdCe8Zfy#eI$r7ZJejdeJejdeLdeJdZJ[JwwxYw)DzDaily 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) VADAnalyzer VADParams)BotConnectedFrame CancelFrameClientConnectedFrame DataFrameEndFrameFrameInputAudioRawFrameInputTransportMessageFrameInterimTranscriptionFrameOutputAudioRawFrameOutputImageRawFrameOutputTransportMessageFrame!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<y) 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__T/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/transports/daily/transport.pyr9r9N %)NHSM(rCr9c&eZdZUdZdZeeed<y)&DailyOutputTransportMessageUrgentFramezFrame for urgent transport messages in Daily calls. Parameters: participant_id: Optional ID of the participant this message is for/from. Nr:r;rBrCrDrGrGYrErCrGc"eZdZdZfdZxZS)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. ct|ddl}|j5|j d|j dt ddddy#1swYyxYw)NralwayszDailyTransportMessageFrame is deprecated and will be removed in a future version. Instead, use DailyOutputTransportMessageFrame. stacklevelsuper __post_init__warningscatch_warnings simplefilterwarnDeprecationWarningselfrR __class__s rDrQz(DailyTransportMessageFrame.__post_init__ps]   $ $ &   ! !( + MMA"      *AA r<r=r>r?rQ __classcell__rYs@rDrIrId  rCrIc"eZdZdZfdZxZS) 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. ct|ddl}|j5|j d|j dt ddddy#1swYyxYw)NrrKzDailyTransportMessageUrgentFrame is deprecated and will be removed in a future version. Instead, use DailyOutputTransportMessageUrgentFrame.rLrMrOrWs rDrQz.DailyTransportMessageUrgentFrame.__post_init__s]   $ $ &   ! !( + MMG"     rZr[r]s@rDr`r`~r^rCr`c&eZdZUdZdZeeed<y)DailyInputTransportMessageFramezFrame for input urgent transport messages in Daily calls. Parameters: participant_id: Optional ID of the participant this message is for/from. Nr:r;rBrCrDrcrcrErCrcc"eZdZdZfdZxZS)%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. ct|ddl}|j5|j d|j dt ddddy#1swYyxYw)NrrKzDailyInputTransportMessageUrgentFrame is deprecated and will be removed in a future version. Instead, use DailyInputTransportMessageFrame.rLrMrOrWs rDrQz3DailyInputTransportMessageUrgentFrame.__post_init__s]   $ $ &   ! !( + MM@"     rZr[r]s@rDreres  rCrec8eZdZUdZeeZeee fe d<y)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?rdictrkr r@rrArBrCrDrhrh!#("=Hgc3h=rCrhc8eZdZUdZeeZeee fe d<y)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. rirkNrlrBrCrDrprprnrCrpc8eZdZUdZeeZeee fe d<y)"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. riremote_participantsN) r<r=r>r?rrmrsr r@rrArBrCrDrrrrs" .34-Hc*HrCrrcXeZdZdZddddeedeeffdZdefdZde fd Z xZ S) WebRTCVADAnalyzerz~Voice Activity Detection analyzer using WebRTC. Implements voice activity detection using Daily's native WebRTC VAD. N sample_rateparamsrwrxct|||tjt|j d|_tjdy)zInitialize the WebRTC VAD analyzer. Args: sample_rate: Audio sample rate in Hz. params: VAD configuration parameters. rv)reset_period_msrwchannelszLoaded native WebRTC VADN) rP__init__r3create_native_vadVAD_RESET_PERIOD_MSrw _webrtc_vadrdebug)rXrwrxrYs rDr}zWebRTCVADAnalyzer.__init__sG [@ 22/T=M=MXY   /0rCreturnc2t|jdz S)zGet the number of audio frames required for VAD analysis. Returns: The number of frames needed (equivalent to 10ms of audio). gY@)intrwrXs rDnum_frames_requiredz%WebRTCVADAnalyzer.num_frames_requireds 4##e+,,rCc\d}t|dkDr|jj|}|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)lenranalyze_frames)rXbuffer confidences rDvoice_confidencez"WebRTCVADAnalyzer.voice_confidences0 v;?))88@JrC) r<r=r>r?r rrr}rfloatrr\r]s@rDrurusD 8<[_ 1x} 1XiEX 1-S- % rCruc.eZdZUdZdZeed<dZeed<y)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?rr@rArrBrCrDrrsGSKrCrceZdZUdZdZeed<dZeed<dZe ed<dZ e ed <dZ e ed <dZ e ed <dZ e ed <d diZeeefed<y)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?rr@rArrboolrrrrrr rrBrCrDrrsi Hc!E3!!d!FDKIt## 148E738 8rCrcZeZdZUdZdZeed<dZeed<dZe ed<dZ e e e e fed <y) 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?rrrArrr@rr r rrBrCrDrr4s> E3FCL#.2M8DcN+2rCrcReZdZUdZdZeeed<dZeed<dZ ee e e fed<y)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 Nrwrzr|r) r<r=r>r?rwr rrAr|rr r@rrBrCrDrrHs8 "&K#%Hc.2M8DcN+2rCrceZdZUdZdZeed<dZeed<dZe ed<dZ e ed<d Z e e eefed <d Ze e eefed <d Ze eed <dZe ed <dZe ed<eZeed<y ) 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?rr@rArrrrrr r rrrrrrrrrrBrCrDrrZs -GS,GS!%$%##UYx5P0P(QRYUYx5P0P(QRY59OX129#'D'"'4'9S9U6UrCrceZdZUdZeeeefgedfe 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<eeeefgedfe d<eeeefegedfe d<eeeefgedfe d<eeeefgedfe d<eee gedfe d<eegedfe d<eeeefgedfe d<eegedfe d<eeegedfe d<y)DailyCallbacksabCallback 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_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_warningon_participant_joinedon_participant_lefton_participant_updatedon_transcription_messageon_transcription_stoppedon_transcription_erroron_recording_startedon_recording_stoppedon_recording_error) r<r=r>r?r r r@rrrArrBrCrDrrvsB (c):(;Yt_(LMMc*+Yt_<== b)D/) **b)D/122uio-..c3Z4899#SE9T?$:;;!738#4"5y"FGG$gc3h&7%8)D/%IJJ!3%4"899seYt_455y 677seYt_455y 677!3%4"899"C5)D/#9:: # $!788uio566 # $!788#WS#X%6$74$HII!738#4c":IdO"KLL$gc3h&7%8)D/%IJJ&S(9':IdO'KLL&T{IdO'CDD$cUIdO%;<<"GCH$5#6 $#GHH"C5)D/#9:: #sYt_!<==rCrcfd}|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. cPd}jj|g|y)Nc t|dkDr|j|y|j|y#tj$rYywxYw)Nrz)r set_resultasyncioInvalidStateError)futureargss rDrz:completion_callback.._callback..set_resultsH t9q=%%d+%F%%t,,,  s22AA)get_loopcall_soon_threadsafe)rrrs rD _callbackz&completion_callback.._callbacks(  /..z6IDIrCrB)rrs` rDcompletion_callbackrs J rCc&eZdZUdZeed<eed<y)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?r/rAr0rBrCrDrr  rCrc&eZdZUdZeed<eed<y)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?r1rAr2rBrCrDrrrrCrc eZdZUdZdZeed<fdZdede edede d e d ef fd Z d Z ed efdZed efdZed efdZed efdZdeezd e efdZd e efdZdefdZdefdZded efdZded efdZde fdZ!dZ"de#fdZ$dZ%dZ&d Z'd!Z(d"Z)d e*ee+ffd#Z,d e*ee+ffd$Z-d e.ee effd%Z/d e efd&Z0d e efd'Z1d e efd(Z2d e efd)Z3d e.ee effd*Z4d e efd+Z5d e efd,Z6d e efd-Z7 dod.ed/e ed e efd0Z8d1efd2Z9 dpd1ed3e:d4ed5ed6ef d7Z; dqd1ed3e:d8ed9ed:ef d;Z< dodfd=Z?dZ@ dod6I&6Q & ||sB!B*#B($B*cK|jsy|j}|jj}t |dz dz}|j j }|jj|t||d{}t|dkDrt|||Stjdd{y7>7w)z9Reads the next 20ms audio frame from the virtual speaker.NdrLr!r)audiorw num_channelsg{Gz?) rrraudio_in_channelsrr%r& read_framesrrrrsleep)rXrwr- num_framesrr,s rDread_next_audio_framez*DailyTransportClient.read_next_audio_frames}}** ||55 s*+a/ %%'557 !!*9LV9T!U  u:>%< --% % % &s$B C C  8CC C C destinationc8K|jjxsij|}|j||d{|j|<d|dii}|r |j rd|j i|d|<|j j|y7Uw)zRegister a custom audio destination for multi-track output. Args: destination: The destination identifier to register. rxN customAudioT sendSettings)rrgetadd_custom_audio_trackrrr update_publishingrXr3rx publishings rDregister_audio_destinationz/DailyTransportClient.register_audio_destination ,,88>BCCKP7;7R7R 8S8 2 !!+.'4k45H%I f**6DfFZFZ5[J} %k 2 &&z2 2 ABBABc8K|jjxsij|}|j||d{|j|<d|dii}|r |j rd|j i|d|<|j j|y7Uw)zRegister a custom video destination for multi-track output. Args: destination: The destination identifier to register. r5N customVideoTr7)rrr8add_custom_video_trackrrr r:r;s rDregister_video_destinationz/DailyTransportClient.register_video_destinationr>r?cK|jj}|j}d}|s#|jr|jj}n+|r)||j vr|j |}|j}|r'|j |jt|n,tj|d|d|jd|d{}|dkDS7 w)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. Nr!z. unable to write audio frames to destination []r) r%r&transport_destinationrrr write_framesr,rrwarningr)rXrrr3 audio_sourcerr1s rDwrite_audio_framez&DailyTransportClient.write_audio_frames%%'55711 48 t551188L [D,E,EE--k:E <QRX>Y % Z NNdV#QR]Q^^_` a   a !\ A~"sCC%C# C%c:K|j}d}|s#|jr|jj}n+|r)||jvr|j|}|j}|r|j |j yt j|d|dyw)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 [rEF)rFrrr write_frameimagerrH)rXrr3 video_sourcers rDwrite_video_framez&DailyTransportClient.write_video_frames11 48 t11--44L [D,E,EE--k:E <rU|j@sHtC|j|jjD}tG|}tI|||_ yyyw)zStart the client and initialize audio/video components. Args: frame: The start frame containing initialization parameters. z::audio_callback_taskT)rwr| non_blockingz::video_callback_taskrrN)%raudio_in_sample_rateraudio_out_sample_rateraudio_in_enabledrr rrrS _audio_queuerUrVrr3create_speaker_devicerr.select_speaker_devicevideo_in_enabledr  _video_queuevideo_out_enabledrr1video_out_widthvideo_out_heightvideo_out_color_formatr2raudio_out_enabledrr/audio_out_channelsr0r)rXrrN video_trackrI audio_tracks rDstartzDailyTransportClient.starts% $||@@^ED^D^ $ B B aeFaFa << ( (||009I9IdN`N`$+MMO!#'#5#5#A#A//0A0ABf12$ ]] % ; ;&&( $ 4 4!\\;;!% ! ++D,>,>,@A << ( (1A1AdFXFX ' D #11==++D,=,=>&-. D  << ) )$2D2D, ,, -- 33L +<8K!0 K!XD  << ) )$2H2H,T-B-BDLLDcDcdL*<8K%4LP[%\D "3I )sKK!cK|js |jr|xjdz c_ytjd|j d|_|j jddddi|j j|j|jd{\}}|sd|_d|_|xjdz c_|jd ijd ijd }|jd ijd }tjd |j d|d||jj|d{|jj|j!d{yd|j d|}tj"||jj%|d{d|_y7O77\7w)z-Join the Daily room with configured settings.rzNzJoining Tbase unsubscribedcamera screenVideoF participantslocalidmeetingSessionzJoined z. Participant ID: z, Meeting ID: zError joining : )rrrrinforr update_subscription_profiles set_user_namer_joinr8rrrset_flush_join_messageserrorr)rXdatarr: meeting_id error_msgs rDjoinzDailyTransportClient.joinBs <<4==   1 $   ht~~./0  11 ~N O  ""4>>2"jjl* uDL!DM   1 $ !XXnb9==grJNNtTN"2B7;;DAJ KK$..));N;K>ZdYef //++D1 1 1    " " $++- - -((85'BI LL #//**95 5 5!DM/+ 2 . 6sJB0H 2H3CH 7H81H )H*A H 4H5 H H H H c K|jsy|jj}|jjxr|jj }|jj xr|jj}|jj|j|jt||dd|jr |jjjndiid|dd|jr |jjjndiidddd d i|jj rd |jj inid d |jj"|jj$d iiid|jj&dk(rdnd|jj(didd|d{S7w)z'Execute the actual room join operation.N customTrackrxzno-camera-track) isEnabledrkzno-microphone-track)rt microphoner7 maxQualitylowpreferredCodec encodings) maxBitrate maxFrameraterLstereomono) channelConfigbitrate)inputsr<)r"client_settings)r r%r&rrgrrkrrrrrrrrxrvideo_out_codecvideo_out_bitratevideo_out_frameraterlaudio_out_bitrate)rXrcamera_enabledmicrophone_enableds rDr~zDailyTransportClient._joinns|| %%'55777[DLL<[<[!\\;;c @c@c  NN KK*62&4) $#'#5#5'+&8&8&>&>&A&A%6,% &8) $#'#9#9'+&<&<&B&B&E&E%:,% #0'(% )$(<<#?#?"24<<3O3O P%' )( %26,,2P2P48LL4T4T("* )"'#||>>!C.6!''+||'E'E )##/1 6 p||sGGGGcK|xjdzc_|jr|jdkDryd|_|jjt j d|j |jjd{|jjD]\}}|j|d{ |jjD]\}}|j|d{ |jd{}|sEt j d|j |jjd{yd|j d|}t j ||jj#|d{y7%7777Y7w) z+Leave the Daily room and cleanup resources.rzrNFzLeaving zLeft zError leaving rz)rrrclearrr{rrrritemsremove_custom_audio_trackrremove_custom_video_track_leaverrr)rX track_name_rrs rDleavezDailyTransportClient.leaves q ||t22Q6     " ht~~./0oo--///"66<<> =MJ00< < < =!66<<> =MJ00< < < =kkm# KK%/0 1//))+ + +((85'BI LL #//**95 5 5 0 = <# , 6snBGF98G F<:GF> G"G#AG(G)A G3G4G<G>GGGGcK|jsy|jj}|jjt ||d{S7w)z(Execute the actual room leave operation.Nr!)r r%r&rrrXrs rDrzDailyTransportClient._leavesL|| %%'557 &9&&AB||AAAAc`|jr"|jjd|_yy)z"Cleanup the Daily client instance.N)r releasers rDrZzDailyTransportClient._cleanups% << LL "DL rCc6|jjSzGet current participants in the room. Returns: Dictionary of participants keyed by participant ID. r rvrs rDrvz!DailyTransportClient.participants ||((**rCc6|jjSztGet participant count information. Returns: Dictionary with participant count details. r participant_countsrs rDrz'DailyTransportClient.participant_counts ||..00rCcK|jj}|jj|t ||d{S7w)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. r!N)r%r&r  start_dialoutrrXrkrs rDrz"DailyTransportClient.start_dialoutsF%%'557 ""88KF8S"T||A A A AcK|jj}|jj|t ||d{S7w)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. r!N)r%r&r  stop_dialoutr)rXr:rs rDrz!DailyTransportClient.stop_dialoutsG%%'557 !!.=PQW=X!Y||rcK|jdxs |j}|sy||d<|jj}|jj |t ||d{S7w)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 setr!N)r8rr%r&r  send_dtmfrrXrk session_idrs rDrzDailyTransportClient.send_dtmf sq\\+.K$2K2K >!+%%'557 x4G4OP||sA1A:3A84A:cK|jdxs|jxs |j}|sy||d<|jj }|j j |t||d{S7w)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 setr!N)r8rrr%r&r sip_call_transferrrs rDrz&DailyTransportClient.sip_call_transfer s LL % ^)B)B ^dF^F^ F!+%%'557 &&x1J>JZ [  ''   % %%#!5 (  Vs+BBA*B frameraterNrc4K|dvrd|dii}ndd|diii}|j||id{||jj|i|<tjd|d||j j ||j|| y7hw) 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. rsrrrArNrz] video from participant )rNr)rrrrrr set_video_renderer_video_frame_received)rXr:rrrNrrs rDcapture_participant_videoz.DailyTransportClient.capture_participant_videos$ 4 4|\:;E}|\.JKLE''ne=T'UUUMU((<\J #L>1J>JZ [  ''   & &%% (  Vs+BBA)BrcfK|jj}|r|jr |jn |j}|r |jnd}t ||}t |}|jj||dt||d{t||}|S7w)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. rzT)rrnignore_audio_levelr"Nr^) r%r&rwrr|r/r0r r9rr) rXrrxrrwr|rIrnrs rDr9z+DailyTransportClient.add_custom_audio_tracks%%'557,2v7I7If((tOdOd &,6??!(h? &|4  ++!##*62 ,  |;G sBB1B/B1cK|jj}|jj|t ||d{S7w)zRemove a custom audio track. Args: track_name: Name of the custom audio track to remove. Returns: error: An error description or None. rr"N)r%r&r rrrXrrs rDrz.DailyTransportClient.remove_custom_audio_trackM%%'557 ..!*62 / ||rcK|jj}|r |jn|jj}|r |j n|jj }|r |jn|jj}t|||}t|}|jj||t||d{t||S7w)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. )rrmr"Nr^)r%r&rrrhrrirrjr1r2r rBrr) rXrrxrrrrrNrms rDrBz+DailyTransportClient.add_custom_video_track$s%%'557 & DLL,H,H"(dll.K.K.4v**$,,:]:] ( E &|4  ++!#*62 ,  l+FF sCC%C#C%cK|jj}|jj|t ||d{S7w)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&r rrrs rDrz.DailyTransportClient.remove_custom_video_trackFrrcK|jj}|jj||t ||d{S7w)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. r!N)r%r&r rr)rXrv instance_idrs rDrz)DailyTransportClient.update_transcriptionVsO%%'557 )) +2Ef2M * ||A A AAcK|jj}|jj||t ||d{S7w) 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_settingsr"N)r%r&r rr)rXrrrs rDrz)DailyTransportClient.update_subscriptionshsP%%'557 ))!5-*62 * ||rpublishing_settingscK|jj}|jj|t ||d{S7w)Update media publishing settings. Args: publishing_settings: Publishing configuration settings. Returns: error: An error description or None. )rr"N)r%r&r r:r)rXrrs rDr:z&DailyTransportClient.update_publishing|sM%%'557 && 3*62 ' ||rrscK|jj}|jj|t ||d{S7w)Update settings for remote participants. Args: remote_participants: Remote participant configuration settings. Returns: error: An error description or None. )rsr"N)r%r&r update_remote_participantsr)rXrsrs rDrz/DailyTransportClient.update_remote_participantssN%%'557 // 3@STZ@[ 0 ||rcP|j|jj|y)z~Handle active speaker change events. Args: participant: The new active speaker participant info. N)_call_event_callbackrrrX participants rDrz.DailyTransportClient.on_active_speaker_changeds !!$//"K"K[YrCsendercR|j|jj||y)zHandle application message events. Args: message: The received message data. sender: ID of the message sender. N)rrrrXr(r s rDrz#DailyTransportClient.on_app_messages  !!$//"@"@'6RrCstatecP|j|jj|y)z_Handle call state update events. Args: state: The new call state. N)rrrrXr s rDrz*DailyTransportClient.on_call_state_updateds !!$//"G"GOrCrcpd|vr|dnd|_|j|jj|y)zcHandle dial-in connected events. Args: data: Dial-in connection data. rrN)rrrrrXrs rDrz(DailyTransportClient.on_dialin_connecteds6 9Dt8K4 #4QS  !!$//"E"EtLrC sip_endpointcP|j|jj|y)zlHandle dial-in ready events. Args: sip_endpoint: The SIP endpoint for dial-in. N)rrrrXrs rDrz$DailyTransportClient.on_dialin_readys !!$//"A"A<PrCc|jd|jk(rd|_|j|jj|y)z[Handle dial-in stopped events. Args: data: Dial-in stop data. rrN)r8rrrrrs rDrz&DailyTransportClient.on_dialin_stoppeds= 88K D$<$< <')D $ !!$//"C"CTJrCc|jd|jk(rd|_|j|jj|y)zZHandle dial-in error events. Args: data: Dial-in error data. rrN)r8rrrrrs rDrz$DailyTransportClient.on_dialin_errors= 88K D$<$< <')D $ !!$//"A"A4HrCcP|j|jj|y)z^Handle dial-in warning events. Args: data: Dial-in warning data. N)rrrrs rDrz&DailyTransportClient.on_dialin_warnings !!$//"C"CTJrCcP|j|jj|y)zbHandle dial-out answered events. Args: data: Dial-out answered data. N)rrrrs rDrz(DailyTransportClient.on_dialout_answereds !!$//"E"EtLrCcpd|vr|dnd|_|j|jj|y)zeHandle dial-out connected events. Args: data: Dial-out connection data. rrN)rrrrrs rDrz)DailyTransportClient.on_dialout_connecteds6 :E9LD$5RT! !!$//"F"FMrCc|jd|jk(rd|_|j|jj|y)z]Handle dial-out stopped events. Args: data: Dial-out stop data. rrN)r8rrrrrs rDrz'DailyTransportClient.on_dialout_stoppeds= 88K D$=$= =(*D % !!$//"D"DdKrCc|jd|jk(rd|_|j|jj|y)z\Handle dial-out error events. Args: data: Dial-out error data. rrN)r8rrrrrs rDrz%DailyTransportClient.on_dialout_errors= 88K D$=$= =(*D % !!$//"B"BDIrCcP|j|jj|y)z`Handle dial-out warning events. Args: data: Dial-out warning data. N)rrrrs rDrz'DailyTransportClient.on_dialout_warnings !!$//"D"DdKrCcP|j|jj|y)zoHandle participant joined events. Args: participant: The participant that joined. N)rrrrs rDrz*DailyTransportClient.on_participant_joineds !!$//"G"GUrCcR|j|jj||y)zHandle participant left events. Args: participant: The participant that left. reason: Reason for leaving. N)rrr)rXrreasons rDrz(DailyTransportClient.on_participant_left#s! !!$//"E"E{TZ[rCcP|j|jj|y)zqHandle participant updated events. Args: participant: The updated participant info. N)rrrrs rDrz+DailyTransportClient.on_participant_updated,s !!$//"H"H+VrCctjd|||_|j|j|j y)zlHandle transcription started events. Args: status: Transcription start status. zTranscription started: N)rrrrrrrXstatuss rDon_transcription_startedz-DailyTransportClient.on_transcription_started4s<  .vh78%+" !!$";";T=T=TUrCc|tjd|j|jj||y)zHandle transcription stopped events. Args: stopped_by: Who stopped the transcription. stopped_by_error: Whether stopped due to error. zTranscription stoppedN)rrrrrrX stopped_bystopped_by_errors rDrz-DailyTransportClient.on_transcription_stopped>s1  ,- !! OO 4 4jBR rCcP|j|jj|y)z^Handle transcription error events. Args: message: Error message. N)rrrrXr(s rDrz+DailyTransportClient.on_transcription_errorJs !!$//"H"H'RrCcP|j|jj|y)zqHandle transcription message events. Args: message: The transcription message data. N)rrrr)s rDrz-DailyTransportClient.on_transcription_messageRs !!$//"J"JGTrCctjd||j|jj|y)zdHandle recording started events. Args: status: Recording start status. zRecording started: N)rrrrrr!s rDrz)DailyTransportClient.on_recording_startedZs2  *6(34 !!$//"F"FOrCctjd||j|jj|y)zsHandle recording stopped events. Args: stream_id: ID of the stopped recording stream. zRecording stopped: N)rrrrrrXrs rDrz)DailyTransportClient.on_recording_stoppedcs2  *9+67 !!$//"F"F RrCctjd|d||j|jj||y)zHandle recording error events. Args: stream_id: ID of the recording stream with error. message: Error message. zRecording error for rzN)rrrrrrXrr(s rDrz'DailyTransportClient.on_recording_errorls;  +I;b BC !!$//"D"DiQXYrC audio_datacP|j||}|j||||y)z-Handle received audio data from participants.N)r_call_audio_callback)rXr:r0rIrs rDrz)DailyTransportClient._audio_data_receivedzs+((8F !!(NJ UrC video_framecP|j||}|j||||y)z/Handle received video frames from participants.N)r_call_video_callback)rXr:r3rNrs rDrz*DailyTransportClient._video_frame_receiveds-((8F !!(NKVrCc@|j|j|g|y)z,Queue an audio callback for async execution.N)_call_async_callbackrbrXrrs rDr2z)DailyTransportClient._call_audio_callback!!!$"3"3XEErCc@|j|j|g|y)z+Queue a video callback for async execution.N)r7rfr8s rDr5z)DailyTransportClient._call_video_callbackr9rCc@|j|j|g|y)z,Queue an event callback for async execution.N)r7rTr8s rDrz)DailyTransportClient._call_event_callbackr9rCqueuec tj|j|g||j}|j y#t $rYywxYw)z7Queue a callback for async execution on the event loop.N)rrun_coroutine_threadsafeputr%resultFuturesCancelledError)rXr<rrrs rDr7z)DailyTransportClient._call_async_callbacksS 55 8+d+,d.B.B.DF MMO$   sAA AAcK |jjd{|jd{^}}||d{|jZ7<7&7w)z1Handle queued callbacks from the specified queue.N)rwaitr8 task_done)rXr<rrs rDrVz+DailyTransportClient._callback_task_handlers[$$))+ + +&+iik 1 XD/ ! ! OO   + 1 !s1A$AA$A A$A" A$ A$"A$cK|jD]}|j|d{|jjy7!w)z9Send any messages that were queued before join completed.N)rr)rrXrs rDrz)DailyTransportClient._flush_join_messagessF-- +E##E* * * +   &&( +s$A A"A cj|jst|d|jjS)z)Get the event loop from the task manager.z.: missing task manager (pipeline not started?))r Exceptionget_event_looprs rDr%z$DailyTransportClient._get_event_loops3!!tf$RST T!!0022rCc |jdS)z2String representation of the DailyTransportClient.z::DailyTransportClient)rrs rD__str__zDailyTransportClient.__str__s&&''=>>rCN)r>rtrNN)pr<r=r>r?rrrArr@r rrr}rpropertyrr:rrrrrCallClientErrorr)rr2r=rCrrJrrOr&rPr[r rorr~rrrZr rrvrr rrrrrrrrrrrr rrrrr9rrrrBrrrr:rrrrrrrrrrrrrrrrrr#rrrrrrr-rr5rr2r5rrrSr7rVrAbstractEventLoopr%rKr\r]s@rDrrs %$$KCKC}KC KC  KC " KCKCZ!#$$$$$$%%%03TT / "6X6H-I0 3C 3 3C 3-@T8-@T0 !4 " T+]+]Z*"XBH6@ +gc3h/+1GCH$51 uS(?:S5S/T  H_4M 8O+D(8O3L, 8O+D  sH_-- .( /1J Xo5N (?*C 8<'/} / "* Ec E") $& % % %  %  % " % V$! $ $ $  $  $  $ R9=""45"  "H#(?B[&9= G G45 G  GD#(?B[".2 / "&;? / "(#*38#4 / "$#*38#4 / ",ZScS3SP3PMMQCQ Kc K IC IKcKMMNN Ls L JS JLsLV\WV  SUPSZV3VIV]`V W!W0:WJMWFFF'--'--) 3!:!:3 ?rCrc FeZdZdZdededeffd Zede e fdZ dZ d e ffd Zfd Zd effd Zd effd Zd effd Zd edeffd Zd eezfdZdedefdZ d$dededefdZ dede!defdZ"dZ# d%dedededefd Z$d e%fd!Z&ded"e'defd#Z(xZ)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. transportclientrxc t||fi|||_||_||_i|_d|_d|_g|_d|_ |j|_ y)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) rPr} _transportr rr _initialized_streaming_started_capture_participant_audio_audio_in_task vad_analyzer _vad_analyzerrXrWrXrxrrYs rDr}zDailyInputTransport.__init__sj *6*#  ""#(+-'7;4:4G4GrCrc|jS)zzGet the Voice Activity Detection analyzer. Returns: The VAD analyzer instance if configured. )r`rs rDr_z DailyInputTransport.vad_analyzers!!!rCcK|jjsytjd|jjr|jjrM|j D]6\}}}|j j||j||d{8d|_ y|js$|j|j|_ d|_ y7Fw)z(Start receiving audio from participants.NzStart receiving audioT) rrarrrr]r r_on_participant_audio_datar^rU_audio_in_task_handlerr\rXr:rIrws rDstart_audio_in_streamingz,DailyInputTransport.start_audio_in_streamings||,,  ,. << ( (||00AEA`A`=NL+,,@@&(G(GWb#' (('+&6&6t7R7R7T&U#"&sBC"C AC"rPcKt||d{|jj|d{y7(7w)zSetup the input transport with shared client setup. Args: setup: The frame processor setup configuration. NrPrPr rXrPrYs rDrPzDailyInputTransport.setup< gmE"""ll  ''' #'A?"AAAAcKt|d{|jjd{|jjd{y7I7)7 w)z-Cleanup input transport and shared resources.NrPr[r rZrXrYs rDr[zDailyInputTransport.cleanupPgoll""$$$oo%%''' $'1A%A!A%A!!A%A#A%!A%#A%rcKt||d{|jryd|_|jj|d{|jj d{|j |d{|j jr|jd{yy77q7Q7:7w)zStart the input transport and join the Daily room. Args: frame: The start frame containing initialization parameters. NT) rPror[r rset_transport_readyraudio_in_stream_on_startrgrXrrYs rDrozDailyInputTransport.startsgmE"""     ll  '''ll!!!&&u--- << 0 0//1 1 1 1! # ( " . 2sWCB=6C B?!C/C0CC -C6C7C?CCCCcKt||d{|jjd{|jr+|j |jd{d|_yy7^7>7w)zStop the input transport and leave the Daily room. Args: frame: The end frame signaling transport shutdown. N)rPstopr rr^rXrus rDrwzDailyInputTransport.stop.spgl5!!!ll  """   ""4#6#67 7 7"&D   "" 81A;A5!A;A7.A;'A9(A;7A;9A;cKt||d{|jjd{|jr+|j |jd{d|_yy7^7>7w)zCancel the input transport and leave the Daily room. Args: frame: The cancel frame signaling immediate cancellation. N)rPcancelr rr^rXrus rDrzzDailyInputTransport.cancel=spgnU###ll  """   ""4#6#67 7 7"&D   $" 8rx directioncKt|||d{t|tr|j |d{yy7/7w)zProcess incoming frames, including user image requests. Args: frame: The frame to process. direction: The direction of frame flow in the pipeline. N)rP process_framer$r$request_participant_image)rXrr{rYs rDr}z!DailyInputTransport.process_framePsMg#E9555 e2 3007 7 7 4 6 8s!A A(A A A  A cBK|j|d{y7w)zrPush a transcription frame downstream. Args: frame: The transcription frame to push. N) push_framerFs rDpush_transcription_framez,DailyInputTransport.push_transcription_frame`s ooe$$$ r(r cPK|jt||d{y7w)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_framercr s rDpush_app_messagez$DailyInputTransport.push_app_messagehs,"" +WV#   s &$&r:rIrwcK|jr1|jj||j||d{y|jj |||fy7$waCapture 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)r\r rrdr]r#rfs rDrz-DailyInputTransport.capture_participant_audiows_  " ",,88 ? ?{    + + 2 2NLR]3^ _  s8A!A%A!r,cKt||j|j|j}||_|j |d{y7w)z'Handle received participant audio data.)user_idr,rwr-N)r" audio_framesrwr-transport_sourcepush_audio_frame)rXr:r,rIrs rDrdz.DailyInputTransport._on_participant_audio_datasN""$$))++   ".##E***sA A A AcK |jjd{}|r|j|d{>7 7wrL)r r2rrFs rDrez*DailyInputTransport._audio_in_task_handlersA,,<<>>E++E222>2sAAAAAArrNrcK||jvri|j|<|dgd|j||<|jj||j|||d{y7w)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)rr r_on_participant_video_framerXr:rrNrs rDrz-DailyInputTransport.capture_participant_videosx !6!6 646D ! !. 1#!#? n-l; ll44 D<?R S Z Z[` a 2sA#A%r3c TKd}tj}|j||d}|j||d}d}|dkDr|d|z z} | |z dk}|j||dr&|j||djd}d }|rt||j|j |j f|j|r |jnd|r |jnd| } || _ |j| d{||j||d<yy7w) z)Handle received participant video frames.FrrNrrzg?rT)rrMsizeformattextappend_to_contextrequest) timerpopr#rrrrrrrpush_video_frame) rXr:r3rN render_frame curr_time prev_timer request_frame next_timers rDrz/DailyInputTransport._on_participant_video_framesV IIK )).9,G T )).9,G T  q=!A M1I% 1S8L   0 >?R S 11.A,O#c!f  L %&!((!''););<"//+8]''dER-"A"AX\%E&2E "''. . .OXD ! !. 1, ? L  /sDD( D& D(rrMrO)*r<r=r>r?r*rrr}rRr rr_rgr&rPr[r rorrwrrzrr%r}r!rrrr@rrrr-rdrerr$r~r5rr\r]s@rDrVrVsw $H $H%$H $HL"h{3""'*(!4(( 224 ' ' '+ '& 8 8> 8 %4FIb4b%  c  3  $) ``` `( +! +*3 +CF +3$!        8b5Jb#Y!#Y0:#YJM#YrCrVceZdZdZdededeffd Zdeffd Z fdZ d e ffd Z d e ffd Zd effd Zd eezfd ZdefdZdefdZd edefdZd edefdZd efdZdefdZdZxZ 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. rWrXrxc Pt||fi|||_||_d|_y)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)rPr}rZr r[ras rDr}zDailyOutputTransport.__init__s/ *6*# "rCrPcKt||d{|jj|d{y7(7w)zSetup the output transport with shared client setup. Args: setup: The frame processor setup configuration. Nrirjs rDrPzDailyOutputTransport.setuprkrlcKt|d{|jjd{|jjd{y7I7)7 w)z.Cleanup output transport and shared resources.Nrnros rDr[zDailyOutputTransport.cleanuprprqrc0Kt||d{|jryd|_|jj|d{|jj d{|j |d{y7w7B7"7 w)zStart the output transport and join the Daily room. Args: frame: The start frame containing initialization parameters. NT)rPror[r rrsrus rDrozDailyOutputTransport.startsgmE"""     ll  '''ll!!!&&u--- # ( " .sEBB6B B!B/B0BB BBBBcKt||d{|jjd{y7'7w)zStop the output transport and leave the Daily room. Args: frame: The end frame signaling transport shutdown. N)rPrwr rrus rDrwzDailyOutputTransport.stop.s:gl5!!!ll  """ ""A>!AAAAcKt||d{|jjd{y7'7w)zCancel the output transport and leave the Daily room. Args: frame: The cancel frame signaling immediate cancellation. N)rPrzr rrus rDrzzDailyOutputTransport.cancel9s:gnU###ll  """ $"rcK|jj|d{}|r|jd|d{yy7$7w)zySend a transport message to participants. Args: frame: The transport message frame to send. NzUnable to send message: )r r) push_errorrXrrs rDr)z!DailyOutputTransport.send_messageDsJll//66 //$D'DD'6D!7>D'5D#6D'D%D'D'D'!D'#D'%D'cy)zDaily supports native DTMF via telephone events. Returns: True, as Daily supports native DTMF transmission. TrBrs rD_supports_native_dtmfz*DailyOutputTransport._supports_native_dtmfs rCcK|jj|j|jjdd{y7w)z}Use Daily's native send_dtmf method for telephone events. Args: frame: The DTMF frame to write. )rtonesN)r rrFbuttonvaluerFs rD_write_dtmf_nativez'DailyOutputTransport._write_dtmf_natives? ll$$"88++    sAA AA )!r<r=r>r?r*rrr}r&rPr[r rorrwrrzrrr)r@rCr=rrrJrrOrrrrr\r]s@rDrrs "&"0D"NY"&(!4(( ... # # #+ # F03TT FCCC CC C ;-@ ;T ; ;-@ ;T ;XX&t  rCrcNeZdZdZ dPdedeededeedeedeef fd Zd efd Z d e fd Z e d efd Z e d efdZdefdZdeezfdZdefdZd eeeffdZd eeeffdZdQd eeeeffdZd eefdZd eefdZd eefdZ dPd eeeeffdZ dQd eefdZ!dQd eefdZ"d eefdZ# dQdedeed eefd Z$d!efd"Z% dRd!ed#ed$e&fd%Z' dSd!ed&e&d'ed(efd)Z(d*eeefd eefd+Z) dTd eefd,Z*d-eeefd eefd.Z+d/efd0Z,d1Z-d2Z.d3Z/d4Z0ded5efd6Z1d7efd8Z2d/efd9Z3d/efd:Z4d;efd<Z5d=Z6d>Z7d?Z8d@Z9dAZ:dBZ;dCZdFZ?dGZ@dHZAdIZBdeeefd dfdJZCdKZDdLZEdMZFdNZGdOZHxZIS)UDailyTransporta] 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}") Nrrrrx input_name output_namecpt|||td$id|jd|jd|j d|j d|jd|jd|jd |jd |jd |jd |jd |jd|jd|j d|j"d|j$d|j&d|j(d|j*d|j,d|j.d|j0d|j2d|j4d|j6d|j8d|j:d|j<}|xs t?|_ tC||||j@||jD|_#d|_$d|_%d|_&|jOd|jOd |jOd|jOd|jOd|jOd|jOd|jOd |jOd |jOd |jOd |jOd |jOd|jOd|jOd|jOd|jOd|jOd|jOd|jOd!|jOd|jOd|jOd|jOd|jOd|jOd|jOd|jOdd"#y)%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. )rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrNF on_connectedon_first_participant_joinedT)syncrB)(rPr}r_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_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) rXrrrrxrrrrYs rDr}zDailyTransport.__init__s& JKH" &*&E&E oo MM !11  ^^   //  #'"="= !% 9 9 $(#?#? !% 9 9 !11 #55 !11 #55 !% 9 9 "&!;!;! " $77# $"33% & $77' (#'"="=) *!% 9 9+ ,$(#?#?- .&*%C%C/ 0&*%C%C1 2$(#?#?3 4"&!;!;5 6"&!;!;7 8 $779 <. + eXt||Y   6: 7; -2* $$%@A $$^4 $$[1 $$Y/ $$Z0 $$%56 $$%<= $$%:; $$%=> $$%:; $$%67 $$%89 $$%67 $$%89 $$%:; $$%;< $$%9: $$%78 $$%9: $$%BC $$%<= $$%:; $$%=> $$%?@ $$%;< $$%;< $$%9: $$%6T$BrCrc|js2t||j|j|j|_|jS)zGet the input transport for receiving media and events. Returns: The Daily input transport instance. r)rrVr r _input_namers rDinputzDailyTransport.inputC s: {{-dllDLLt7G7GDK{{rCc|js2t||j|j|j|_|jS)zGet the output transport for sending media and events. Returns: The Daily output transport instance. r)rrr r _output_namers rDoutputzDailyTransport.outputO s: ||/dllDLLt7H7HDL||rCc.|jjS)zkGet the Daily room URL. Returns: The room URL this transport is connected to. )r rrs rDrzDailyTransport.room_url_ s||$$$rCc.|jjS)zwGet the participant ID for this transport. Returns: The participant ID assigned by Daily. )r r:rs rDr:zDailyTransport.participant_idh s||***rClevelc.tj|y)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)r3 set_log_level)rXrs rDrzDailyTransport.set_log_levelq s E"rCrcK|jr3|jj|tjd{yy7w)zjSend an image frame to the Daily call. Args: frame: The image frame to send. Nr queue_framer% DOWNSTREAMrFs rD send_imagezDailyTransport.send_image} 7 <<,,**5.2K2KL L L  L:AAAcK|jr3|jj|tjd{yy7w)zjSend an audio frame to the Daily call. Args: frame: The audio frame to send. NrrFs rD send_audiozDailyTransport.send_audio rrc6|jjSrrrs rDrvzDailyTransport.participants rrCc6|jjSrrrs rDrz!DailyTransport.participant_counts rrCcKtjd||jj|d{\}}|rtjd|||fS7%w)rzStarting dialout: settings=NzUnable to start dialout: )rrr rr)rXrkrrs rDrzDailyTransport.start_dialout s`  28*=>"&,,"<">  LL8@ A ?rcKtjd||jj|d{}|rtjd||S7 w)rzStaring SIP REFER: settings=Nr)rrr rrrs rDrzDailyTransport.sip_refer sT  3H:>?ll,,X66  LL8@ A 7rcKtjd|d|d||jj|||d{\}}|rtjd|||fS7%w)rzStarting recording: stream_id=z force_new=z settings=NzUnable to start recording: )rrr rr)rXrrrr_idrs rDrzDailyTransport.start_recording sv  ,YK{9+ZXjWk l !LL889KYXabb e  LL6ug> ?U{cs?A)A'&A)cKtjd||jj|d{}|rtjd||S7 w)rzStopping recording: stream_id=NzUnable to stop recording: )rrr rr)rXrrs rDrzDailyTransport.stop_recording sT  5i[ABll11)<<  LL5eW= > =rcKtjd||jj|d{}|rtjd||S7 w)rz!Starting transcription: settings=NUnable to start transcription: )rrr rrrs rDrz"DailyTransport.start_transcription sU  8 CDll66x@@  LL:5'B C ArcKtjd|jjd{}|rtjd||S7 w)rzStopping transcriptionNUnable to stop transcription: )rrr rrrXrs rDrz!DailyTransport.stop_transcription sK  -/ll5577  LL9%A B 8s3AA!Ar(rcK|jj||d{}|rtjd||S7 w)rNz&Unable to send prebuilt chat message: )r rrr)rXr(rrs rDrz)DailyTransport.send_prebuilt_chat_message$ sCll==gyQQ  LLA%I J Rs AA!Ar:cVK|jj|d{y7wr)r rrs rDrz0DailyTransport.capture_participant_transcription5 s ll<<^LLLrrIrwctK|jr&|jj|||d{yy7wr)rrrfs rDrz(DailyTransport.capture_participant_audio= s4 ;;++77 Vab b b  bs -868rrNrcvK|jr'|jj||||d{yy7w)rN)rrrs rDrz(DailyTransport.capture_participant_videoM s> ;;++77 <    s .979rcKtjd||jj|d{}|rtjd||S7 w)rz'Updating publishing settings: settings=)rNz&Unable to update publishing settings: )rrr r:r)rXrrs rDr:z DailyTransport.update_publishinga s[  >?R>STUll44I\4]]  LLA%I J ^8AA!AcKtjd|d||jj||d{}|rtjd||S7 w)rz-Updating subscriptions: participant_settings=z profile_settings=)rrNz(Unable to update subscription settings: )rrr rr)rXrrrs rDrz#DailyTransport.update_subscriptionss sr  ;    LLA%I J  rrcDK|jd|d{y7w)z$Handle active speaker change events.rN_call_event_handlerrs rDrz)DailyTransport._on_active_speaker_changed s&&'BKPPP   cK|jjr]|jjjd}|j |d{}|r|j d|d{|j d|d{|j d|d{|jr,|jjtd{yy77s7[7C7w)zHandle room joined events.T) exclude_noneNrrr) rrr model_dumprrrrrr)rXrrkrs rDrzDailyTransport._on_joined s << - -||::EESWEXH228<FFFrcDK|jd|d{y7w)zHandle client connected events.rNrrs rDrz#DailyTransport._on_client_connected s&&'K|jjsytj4d{}d|jjdd}|jjj |jjj |d}|jjd} |j|||tjd 4d{}|jd k7r`|jd{}tjd |jd |d  dddd{dddd{ytjddddd{dddd{y7T777R7D7 #1d{7swY0xYw#tj $rtjd|d Yat"$r%}tjd|d|Yd}~d}~wwxYw7#1d{7swYyxYww)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 ClientTimeoutr"rrrrr TimeoutErrorrH) rXrsessionr/rurlrres rD_handle_dialin_readyz#DailyTransport._handle_dialin_ready s||++ ((* P Pg#*4<<+?+?*@!A 2G ,,66>>"ll::FF&D \\))**CDC P"<<tW=R=RY[=\( P Pxx3%&VVX~ KAHH:U^_c^ddef P P P P P0LL!NO P P P P P P . P P P P P P'' M DSEKL P B3%s1#NOO P7 P P P Ps0HFHA8H/-F(F F( #FF +F/ F(:F ;F(? H F HF% F(0F1F(5 HHH F( F F(HF(F% FF% !F((,HHHG>9H>HHHHH HHcxKtj|d||jd|d{y7w)z Handle dial-in connected events.z dial-in connected: rNrrrrs rDrz#DailyTransport._on_dialin_connected 5 v1$89&&'rrs rDrzDailyTransport._on_dialin_ready s_ v-l^<= << ' '++L9 9 9&&'8,GGG :Gs$AA+A'A+!A)"A+)A+cxKtj|d||jd|d{y7w)zHandle dial-in stopped events.z dial-in stopped: rNr@rs rDrz!DailyTransport._on_dialin_stopped s5 v/v67&&':DAAArBcxKtj|d||jd|d{y7w)zHandle dial-in error events.z dial-in error: rNrrrrs rDrzDailyTransport._on_dialin_error s5 v-dV45&&'8$???rBcxKtj|d||jd|d{y7w)zHandle dial-in warning events.z dial-in warning: rNrrHrrs rDrz!DailyTransport._on_dialin_warning s5$1$89&&':DAAArBcxKtj|d||jd|d{y7w)z Handle dial-out answered events.z dial-out answered: rNr@rs rDrz#DailyTransport._on_dialout_answered rArBcxKtj|d||jd|d{y7w)z!Handle dial-out connected events.z dial-out connected: rNr@rs rDrz$DailyTransport._on_dialout_connected s5 v24&9:&&'=tDDDrBcxKtj|d||jd|d{y7w)zHandle dial-out stopped events.z dial-out stopped: rNr@rs rDrz"DailyTransport._on_dialout_stopped$ s5 v078&&';TBBBrBcxKtj|d||jd|d{y7w)zHandle dial-out error events.z dial-out error: rNrFrs rDrz DailyTransport._on_dialout_error) s5 v.tf56&&'94@@@rBcxKtj|d||jd|d{y7w)zHandle dial-out warning events.z dial-out warning: rNrHrs rDrz"DailyTransport._on_dialout_warning. s5$24&9:&&';TBBBrBcnK|d}tjd||jre|jjrO|jj r9|jj |d|jjd{|js!d|_ |jd|d{|jd|d{|jd|d{|jr,|jjtd{yy77s7[7C7w) z!Handle participant joined events.rxzParticipant joined rNTrrr) rr{rrrarrr rrrrr)rXrrxs rDrz%DailyTransport._on_participant_joined3 s   )"./ ;;4<<88T\\=^=^++77L$,,"="=  1115D .**+H+V V V&&'> LLL&&'sADC?AD,DA0D8D9D D DDDcKtj|d|d|d|jd||d{y7w)z$Handle transcription stopped events.z transcription stopped by: z (error: r3rNr@r%s rDrz(DailyTransport._on_transcription_stoppedx sC v8 IN^M__`ab&&'A:O_```s 5?=?cxKtj|d||jd|d{y7w)z"Handle transcription error events.z transcription error: rNrFr)s rDrz&DailyTransport._on_transcription_error} s5 v3G9=>&&'?IIIrBcxKtj|d||jd|d{y7w)z Handle recording started events.z recording started: rNr@r!s rDrz$DailyTransport._on_recording_started s5 v1&:;&&'=vFFFrBczKtj|d|d|jd|d{y7w)z Handle recording stopped events.z recording stopped (id: r3rNr@r-s rDrz$DailyTransport._on_recording_stopped s7 v5i[BC&&'=yIIIs 1;9;cKtj|d|d||jd||d{y7w)zHandle recording error events.z recording error (id: r4rNrFr/s rDrz"DailyTransport._on_recording_error s= v3I;c'KL&&';YPPPs 4><>)NNNrLrrOrQ)Jr<r=r>r?r@r rr}rVrrrrRrr: DailyLogLevelrrrrrrr rrvrr rSrrrrrrrrrrrrrr:rrrrrrrrrrrr>rrrrrrrrrrrrrrrrrrrr\r]s@rDrrs>J)-$(%)ZCZC}ZC ZC % ZC SM ZCc]ZC@ *  ,  %#%%+++ #= #M&9K&GMM&9M+gc3h/+1GCH$51!E#x?X:X4Y!"H_4M 8O3L 8O+D"BF sH_-- ..h6O (?:S (?*C 8<'/} / ""McM) ccc c&$!    (#*38#4 / "&;? / ".#*38#4 / "(QCQ >2: NJSJ#J G#GKcKNN!Ps!PFD HB @ B D E C A C A(NN ">wsCx7H">T">Ha J G J QrCr)gr?rrconcurrent.futuresrrAr dataclassesrrtypingrrr r r r r r5logururpydanticrpipecat.audio.vad.vad_analyzerrrpipecat.frames.framesrrrrrrrrrrrrrrr 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.r/r0r1r2r3r4r5r6r7rbModuleNotFoundErrorr=rrHrr9rGrIr`rcrerhrprrrurrrrrrrrrr@rSrrVrrrBrCrDrrs F1(KKKA*S4<>L>,   0 )'B) ) )-N) ) !A 2 'M 2 )&@) ),K2  >I >  >  > >  > II I( (V ) 9903)3(3)3$V/V8=>Y=>@2          I?<I?X&qY,qYh q .q hm Q]m Q}B,FLL;qc"#FLL[ &qc* ++ ,sG$$H )2HH