qidZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z mZmZmZmZmZmZmZdd lmZGd d eZy) z8Vonage Audio Connector WebSocket serializer for Pipecat.N)Optional)logger) BaseModel) KeypadEntry)create_stream_resampler) AudioRawFrameFrameInputAudioRawFrameInputDTMFFrameInterruptionFrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrame)FrameSerializerc~eZdZdZGddeZd deefdZdefdZ de d e e zdzfd Z d e e zd e dzfd Zy)VonageFrameSerializeraSerializer for Vonage Video API Audio Connector WebSocket protocol. This serializer converts between Pipecat frames and the Vonage Audio Connector WebSocket streaming protocol. Note: Ref docs: https://developer.vonage.com/en/video/guides/audio-connector c4eZdZUdZdZeed<dZeeed<y)!VonageFrameSerializer.InputParamsa$Configuration parameters for VonageFrameSerializer. Parameters: vonage_sample_rate: Sample rate used by Vonage, defaults to 16000 Hz. Common values: 8000, 16000, 24000 Hz. sample_rate: Optional override for pipeline input sample rate. i>vonage_sample_rateN sample_rate) __name__ __module__ __qualname____doc__rint__annotations__rrm/home/ccuser/rateright-growth/voice-assistant/venv/lib/python3.12/site-packages/pipecat/serializers/vonage.py InputParamsr(s" #(C'%) Xc])rr Nparamsc|xstj|_|jj|_d|_t |_t |_y)zkInitialize the VonageFrameSerializer. Args: params: Configuration parameters. rN) rr _paramsr_vonage_sample_rate _sample_rater_input_resampler_output_resampler)selfr!s r__init__zVonageFrameSerializer.__init__4sJ D!6!B!B!D #'<<#B#B  7 9!8!:rframec^K|jjxs |j|_yw)zSets up the serializer with pipeline configuration. Args: frame: The StartFrame containing pipeline configuration. N)r#raudio_in_sample_rater%)r(r*s rsetupzVonageFrameSerializer.setupBs% !LL44R8R8Rs+-returncKt|trddi}tj|St|trX|j }|j j||j|jd{}|t|dk(ry|St|ttfrtj|jSy7Mw)aPSerializes a Pipecat frame to Vonage WebSocket format. Handles conversion of various frame types to Vonage WebSocket messages. Args: frame: The Pipecat frame to serialize. Returns: Serialized data as string (JSON commands) or bytes (audio), or None if the frame isn't handled. actionclearNr) isinstancer jsondumpsraudior'resamplerr$lenr rmessage)r(r*answerdataserialized_datas r serializezVonageFrameSerializer.serializeJs e. /(F::f% % } -;;D%)$:$:$C$Ce'')A)A%O&#o*>!*C# "  ;=^_ `::emm, ,sA:C <C =AC r:c.Kt|trf|}|jj||j|j d{}|t |dk(ryt|d|j }|S tj|}|jd}|dk(r(tjd|jdy|d k(rtjd y|d k(r(tjd |jd y|dk(r|jdxs!|jdijd}|tjd|yt|}tjd| tt!|Stjd|y7q#t"$rtjd|YywxYw#tj$$rtjd|YywxYww)aDeserializes Vonage WebSocket data to Pipecat frames. Handles conversion of Vonage events to appropriate Pipecat frames. - Binary messages contain audio data (16-bit linear PCM) - Text messages contain JSON events (websocket:connected, websocket:cleared, dtmf, etc.) Args: data: The raw WebSocket data from Vonage. Returns: A Pipecat frame corresponding to the Vonage event, or None if unhandled. Nr)r5 num_channelsreventzwebsocket:connectedz)Vonage WebSocket connected: content-type=z content-typezwebsocket:clearedzVonage audio buffer clearedzwebsocket:notifyzVonage notify event: payloadzwebsocket:dtmfdigitdtmfz(DTMF event received but no digit found: zReceived DTMF digit: zInvalid DTMF digit received: zVonage event: z*Failed to parse JSON message from Vonage: )r2bytesr&r6r$r%r7r r3loadsgetrdebugwarningstrr r ValueErrorJSONDecodeError)r(r:rAdeserialized_data audio_framer8r@rBs r deserializez!VonageFrameSerializer.deserializels dE "G'+&;&;&D&D((!!'!  !(C0A,Ba,G,' --K  % **T* G,11LLCGKKP^D_C`a 11LL!>?00LL#8Y9O8P!QR..$KK0XGKK4K4O4OPW4XE})QRYQZ'[\#JELL#8!@A$-k%.@AA LL>%!9:e!Z&$)Fug'NO#$'' !KD6RS sAH F: /H:AG$ H G$'H(,G$HAG$(H)#G$ F= H!G$9H=!G!G$H G!!G$$+HHHH)N)rrrrrr rr)rr-r rIrDr<rNrrrrrsm *i * ;x 4 ;SS U sU{T/A DIcEkIedlIrr)rr3typingrlogururpydanticrpipecat.audio.dtmf.typesrpipecat.audio.utilsrpipecat.frames.framesrr r r r r rr#pipecat.serializers.base_serializerrrrrrrVs?? 07   @WOWr