U HiD@s2ddlZddlmZddlmZGdddZdS)N)Optional)Configc@sLeZdZdZed(eeedddZeeeedddZeeed d d Z ed)eee ed ddZ eeed ddZ eee edddZeee edddZeee edddZeee edddZeee edddZeee ddd Zeee dd!d"Zeee dd#d$Zeee ed%d&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|dkr dtjdd}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_idrrcCs 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_message)rrcCs 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<s z'McubeService.create_clear_audio_messageT)r transfer_toshow_original_caller_idrcCsd|||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 Ztransfer)rrZ transferToZshowOriginalCallerIdr)rr r!rrrcreate_transfer_messageLs z$McubeService.create_transfer_messagecCs d|dS)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`s z%McubeService.create_terminate_message)start_event_datarc Cs.z|ddWSttfk r(YdSXdS)z Extract call ID from Mcube start event data. Args: start_event_data: Mcube start event data Returns: Call ID if found, None otherwise startZcallIdNKeyError TypeErrorr%rrrextract_call_idqs zMcubeService.extract_call_idc Cs.z|ddWSttfk r(YdSXdS)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'r*rrrextract_stream_ids zMcubeService.extract_stream_id)media_event_datarc Cs.z|ddWSttfk r(YdSXdS)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'r-rrrextract_media_payloads z"McubeService.extract_media_payloadc Cs.z|ddWSttfk r(YdSXdS)z Extract timestamp from Mcube media event data. Args: media_event_data: Mcube media event data Returns: Timestamp if found, None otherwise r timestampNr'r.rrrextract_media_timestamps z$McubeService.extract_media_timestampc Cs.z|ddWSttfk r(YdSXdS)z Extract track from Mcube media event data. Args: media_event_data: Mcube media event data Returns: Track if found, None otherwise rZtrackNr'r.rrrextract_media_tracks z McubeService.extract_media_track) event_datarcCs|ddkS)z3Check if event data represents a Mcube media event.rrgetr3rrris_media_eventszMcubeService.is_media_eventcCs|ddkS)z3Check if event data represents a Mcube start event.rr&r4r6rrris_start_eventszMcubeService.is_start_eventcCs|ddkS)z:Check if event data represents a Mcube playedStream event.rZ playedStreamr4r6rrris_played_stream_eventsz#McubeService.is_played_stream_event)played_stream_event_datarc Cs*z |dWSttfk r$YdSXdS)z Extract name from Mcube playedStream event data. Args: played_stream_event_data: Mcube playedStream event data Returns: Name if found, None otherwise rNr')r:rrrextract_played_stream_names  z'McubeService.extract_played_stream_name)N)T)__name__ __module__ __qualname____doc__ staticmethodstrdictrrrboolr"r$rr+r,r/r1r2r7r8r9r;rrrrrs: r)rtypingrconfigrrrrrrs