o iD@s2ddlZddlmZddlmZGdddZdS)N)Optional)Configc @speZdZdZed*dededefddZedededefd d Zededefd d Z ed+dedede defddZ ededefddZ edede efddZedede efddZedede efddZedede efddZedede efddZed ede fd!d"Zed ede fd#d$Zed ede fd%d&Zed'ede efd(d)ZdS), McubeServiceaq Provides all Mcube call service integration logic for the application. - Handles Mcube WebSocket protocol for incoming calls - Creates Mcube-compatible messages (playAudio, checkpoint, clearAudio, transfer, terminate) - Extracts and interprets Mcube event payloads This class is the main entry point for all Mcube-related operations. N audio_payloadnamereturncCs8|durdtjdd}dtjtj||ddS)a: Create a Mcube playAudio message with audio payload. Args: audio_payload: Base64 encoded audio data name: Unique name for the audio segment (generated if not provided) Returns: Dictionary containing Mcube playAudio message Naudio_ playAudio) contentType sampleRatepayloadr)eventmedia)uuiduuid4hexrMCUBE_AUDIO_FORMATMCUBE_SAMPLE_RATE)rrr;/var/www/html/live_calls/homebook/services/mcube_service.pycreate_play_audio_messages z&McubeService.create_play_audio_message stream_idcCs d||dS)a' Create a Mcube checkpoint message for audio synchronization. Args: stream_id: Mcube stream identifier name: Name of the audio segment to checkpoint Returns: Dictionary containing Mcube checkpoint message checkpoint)rstreamIdrr)rrrrrcreate_checkpoint_message*s z&McubeService.create_checkpoint_messagecC d|dS)z Create a Mcube clearAudio message to clear audio buffer. Args: stream_id: Mcube stream identifier Returns: Dictionary containing Mcube clearAudio message clearAudiorrrrrrrcreate_clear_audio_message< z'McubeService.create_clear_audio_messageT transfer_toshow_original_caller_idcCsd|||dS)a Create a Mcube transfer message to transfer the call. Args: stream_id: Mcube stream identifier transfer_to: Phone number to transfer call to in E.164 format show_original_caller_id: Whether to show caller's phone number as callerId Returns: Dictionary containing Mcube transfer message transfer)rr transferToshowOriginalCallerIdr)rr"r#rrrcreate_transfer_messageLs z$McubeService.create_transfer_messagecCr)z Create a Mcube terminate message to end the call. Args: stream_id: Mcube stream identifier Returns: Dictionary containing Mcube terminate message terminaterrrrrrcreate_terminate_message`r!z%McubeService.create_terminate_messagestart_event_datac C(z|ddWSttfyYdSw)z Extract call ID from Mcube start event data. Args: start_event_data: Mcube start event data Returns: Call ID if found, None otherwise startcallIdNKeyError TypeErrorr*rrrextract_call_idq  zMcubeService.extract_call_idc Cr+)z Extract stream ID from Mcube start event data. Args: start_event_data: Mcube start event data Returns: Stream ID if found, None otherwise r,rNr.r1rrrextract_stream_idr3zMcubeService.extract_stream_idmedia_event_datac Cr+)z Extract audio payload from Mcube media event data. Args: media_event_data: Mcube media event data Returns: Audio payload if found, None otherwise rr Nr.r5rrrextract_media_payloadr3z"McubeService.extract_media_payloadc Cr+)z Extract timestamp from Mcube media event data. Args: media_event_data: Mcube media event data Returns: Timestamp if found, None otherwise r timestampNr.r6rrrextract_media_timestampr3z$McubeService.extract_media_timestampc Cr+)z Extract track from Mcube media event data. Args: media_event_data: Mcube media event data Returns: Track if found, None otherwise rtrackNr.r6rrrextract_media_trackr3z McubeService.extract_media_track event_datacC|ddkS)z3Check if event data represents a Mcube media event.rrgetr<rrris_media_eventzMcubeService.is_media_eventcCr=)z3Check if event data represents a Mcube start event.rr,r>r@rrris_start_eventrBzMcubeService.is_start_eventcCr=)z:Check if event data represents a Mcube playedStream event.r playedStreamr>r@rrris_played_stream_eventrBz#McubeService.is_played_stream_eventplayed_stream_event_datac Cs$z|dWSttfyYdSw)z Extract name from Mcube playedStream event data. Args: played_stream_event_data: Mcube playedStream event data Returns: Name if found, None otherwise rNr.)rFrrrextract_played_stream_names  z'McubeService.extract_played_stream_name)N)T)__name__ __module__ __qualname____doc__ staticmethodstrdictrrr boolr'r)rr2r4r7r9r;rArCrErGrrrrrs< r)rtypingrconfigrrrrrrs