qiFdZddlZddlmZddlmZddlmZddlm Z ddl m Z m Z m Z mZmZmZmZmZddlmZGd d eZy) z8Vonage Audio Connector WebSocket serializer for Pipecat.N)Optional)logger) KeypadEntry)create_stream_resampler) AudioRawFrameFrameInputAudioRawFrameInputDTMFFrameInterruptionFrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrame)FrameSerializerceZdZdZGddej Zd deeffd ZdefdZ de d e e zdzfd Z d e e zd e dzfd ZxZS)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. ignore_rtvi_messages: Inherited from base FrameSerializer, defaults to True. i>vonage_sample_rateN sample_rate) __name__ __module__ __qualname____doc__rint__annotations__rrL/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/serializers/vonage.py InputParamsr's" #(C'%) Xc])rrNparamsct||xstj|jj |_d|_t|_ t|_ y)zkInitialize the VonageFrameSerializer. Args: params: Configuration parameters. rN) super__init__rr_paramsr_vonage_sample_rate _sample_rater_input_resampler_output_resampler)selfr __class__s rr#zVonageFrameSerializer.__init__4sQ F#8#D#D#FG#'<<#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|ttfr1|j|rytj|jSy7_w)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 r should_ignore_framemessage)r)r+answerdataserialized_datas r serializezVonageFrameSerializer.serializeJs e. /(F::f% % } -;;D%)$:$:$C$Ce'')A)A%O&#o*>!*C# "  ;=^_ `''.::emm, ,sA:C<C=A Cr<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)r6 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: )r3bytesr'r7r%r&r8r r4loadsgetrdebugwarningstrr r ValueErrorJSONDecodeError)r)r<rCdeserialized_data audio_framer:rBrDs r deserializez!VonageFrameSerializer.deserializens 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)rrrrrrrr#rr.rrKrFr>rP __classcell__)r*s@rrrst *o11 * ;x 4 ;SS"U"sU{T/A"HIcEkIedlIrr)rr4typingrlogururpipecat.audio.dtmf.typesrpipecat.audio.utilsrpipecat.frames.framesrrr r r r r r#pipecat.serializers.base_serializerrrrrrrXs<? 07   @ZOZr