qiq)dZddlZddlZddlmZddlZddlmZddlm Z ddl m Z ddl m Z mZmZmZmZddlmZmZmZmZmZmZmZmZdd lmZGd d eZy) z.Telnyx WebSocket frame serializer for Pipecat.N)Optional)logger) BaseModel) KeypadEntry) alaw_to_pcmcreate_stream_resampler pcm_to_alaw pcm_to_ulaw ulaw_to_pcm) AudioRawFrame CancelFrameEndFrameFrameInputAudioRawFrameInputDTMFFrameInterruptionFrame StartFrame)FrameSerializerceZdZdZGddeZ ddedededeed eed eef d Zd e fd Z d e dee zdzfdZ dZdee zde dzfdZy)TelnyxFrameSerializeraSerializer for Telnyx WebSocket protocol. This serializer handles converting between Pipecat frames and Telnyx's WebSocket media streams protocol. It supports audio conversion, DTMF events, and automatic call termination. When auto_hang_up is enabled (default), the serializer will automatically terminate the Telnyx call when an EndFrame or CancelFrame is processed, but requires Telnyx credentials to be provided. c^eZdZUdZdZeed<dZeeed<dZ e ed<dZ e ed<d Z e ed <y) !TelnyxFrameSerializer.InputParamsaConfiguration parameters for TelnyxFrameSerializer. Parameters: telnyx_sample_rate: Sample rate used by Telnyx, defaults to 8000 Hz. sample_rate: Optional override for pipeline input sample rate. inbound_encoding: Audio encoding for data sent to Telnyx (e.g., "PCMU"). outbound_encoding: Audio encoding for data received from Telnyx (e.g., "PCMU"). auto_hang_up: Whether to automatically terminate call on EndFrame. i@telnyx_sample_rateN sample_ratePCMUinbound_encodingoutbound_encodingT auto_hang_up)__name__ __module__ __qualname____doc__rint__annotations__rrrstrrrboolL/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/serializers/telnyx.py InputParamsr2sB #'C&%) Xc]) &#&!'3'! d!r(r*N stream_idrrcall_control_idapi_keyparamsc:||_||_||_|xstj |_||j _||j _|j j|_ d|_ t|_ t|_ d|_y)aInitialize the TelnyxFrameSerializer. Args: stream_id: The Stream ID for Telnyx. outbound_encoding: The encoding type for outbound audio (e.g., "PCMU"). inbound_encoding: The encoding type for inbound audio (e.g., "PCMU"). call_control_id: The Call Control ID for the Telnyx call (optional, but required for auto hang-up). api_key: Your Telnyx API key (required for auto hang-up). params: Configuration parameters. rFN) _stream_id_call_control_id_api_keyrr*_paramsrrr_telnyx_sample_rate _sample_rater_input_resampler_output_resampler_hangup_attempted)selfr+rrr,r-r.s r)__init__zTelnyxFrameSerializer.__init__Cs&$ / D!6!B!B!D ): &(8 %#'<<#B#B  7 9!8!:!&r(framec^K|jjxs |j|_yw)zSets up the serializer with pipeline configuration. Args: frame: The StartFrame containing pipeline configuration. N)r3raudio_in_sample_rater5)r9r;s r)setupzTelnyxFrameSerializer.setupds% !LL44R8R8Rs+-returnctK|jjrB|js6t|tt fr d|_|j d{yt|trddi}tj|St|tr|j}|jjdk(r5t||j|j|j d{}np|jjdk(r5t#||j|j|j d{}n"t%d|jj|t'|dk(ryt)j*|j-d }d d |id }tj|Sy7\77~w) aSerializes a Pipecat frame to Telnyx WebSocket format. Handles conversion of various frame types to Telnyx WebSocket messages. For EndFrames and CancelFrames, initiates call termination if auto_hang_up is enabled. Args: frame: The Pipecat frame to serialize. Returns: Serialized data as string or bytes, or None if the frame isn't handled. Raises: ValueError: If an unsupported encoding is specified. TNeventclearrPCMAUnsupported encoding: rzutf-8mediapayload)rArE)r3rr8 isinstancerr _hang_up_callrjsondumpsr audiorr rr4r7r ValueErrorlenbase64 b64encodedecode)r9r;answerdataserialized_datarFs r) serializezTelnyxFrameSerializer.serializels LL % %**58["9:%)D "$$& & & 0 1w'F::f% % } -;;D||,,6(3%++T-E-EtG]G])#..&8(3%++T-E-EtG]G])#!#9$,,:W:W9X!YZZ&#o*>!*C&&7>>wGG #W-F ::f% %C '##s9AF8F1BF8)F4*A F87F68A:F84F86F8c K |j}|j}|r|stjdyd|d}dd|d}t j 4d{}|j ||4d{}|jd k(rtjd |n|jd k(r |jd{}td |jd gDr;tjd|d dddd{dddd{y |jd{}tjd|d|jd|n@|jd{}tjd|d|jd|dddd{dddd{y7r7Y7 77#t$rYwxYw77k75#1d{7swYExYw7<#1d{7swYyxYw#t$r"} tjd| Yd} ~ yd} ~ wwxYww)z0Hang up the Telnyx call using Telnyx's REST API.zHCannot hang up Telnyx call: call_control_id and api_key must be providedNz https://api.telnyx.com/v2/calls/z/actions/hangupzapplication/jsonzBearer )z Content-Type Authorization)headersz$Successfully terminated Telnyx call ic3DK|]}|jddk(yw)code90018N)get).0errors r) z6TelnyxFrameSerializer._hang_up_call..s&#$)!& & 1W <#s errorsz Telnyx call z was already terminatedz Failed to terminate Telnyx call z : Status z , Response: zFailed to hang up Telnyx call: )r1r2rwarningaiohttp ClientSessionpoststatusinforIanyr\debug Exceptiontextr^) r9r,r-endpointrWsessionresponse error_data error_textes r)rHz#TelnyxFrameSerializer._hang_up_calls[5 @"33OmmG"'^:/9J/ZH(:gV]U^L_`G,,.! ! '"<<'<B  h#- &J?J[$\]!C/ !/7}})>J"#-7^^Hb-I# !' &2?2CCZ$[!"!'!  ! ! !  ,4==?%:  >>OP&&.oo%6l:,P ,4==?%:  >>OP&&.oo%6l:,P;  ! ! !  *? ! $ )! !&;&;9    ! ! ! ! F @ LL:1#> ? ? @s_I 1HI &HGH H8G9H<9G06G G ?G HGH H%G&H*I +G0?G*AG0G,,G0- H8G.9H= HH H I HHGHH G'$G0&G''G0,G0.H0H 6G97H >HHH H HHI H I%I=I II rRcKtj|}|ddk(r|dd}tj|}|jj dk(r5t ||j|j|jd{}np|jj dk(r5t||j|j|jd{}n"td|jj |t|dk(ryt|d |j }|S|dd k(r6|jd ijd } tt!|Sy77#t$r }Yd}~yd}~wwxYww) aDeserializes Telnyx WebSocket data to Pipecat frames. Handles conversion of Telnyx media events to appropriate Pipecat frames, including audio data and DTMF keypresses. Args: data: The raw WebSocket data from Telnyx. Returns: A Pipecat frame corresponding to the Telnyx event, or None if unhandled. Raises: ValueError: If an unsupported encoding is specified. rArErFrNrCrDr)rK num_channelsrdtmfdigit)rIloadsrN b64decoder3rr r4r5r6rrLrMrr\rr) r9rRmessagepayload_base64rFdeserialized_data audio_framerurps r) deserializez!TelnyxFrameSerializer.deserializes}**T" 7 w &$W-i8N&&~6G||--7*5,,%%)) +%! //69*5,,%%)) +%!!#9$,,:X:X9Y!Z[[ (C0A,Ba,G,'aTEVEVK  W  'KK+//8E %k%&899 C%%,  sJBFE&A FE(A;FE*$F(F* E=3F8E==F)NNN)rr r!r"rr*r%rr:rr>rbytesrTrHr|r'r(r)rr&s "i",*.!%(,''' ' "# ' # '%'BSS6U6sU{T/A6p7@r8cEk8edl8r(r)r"rNrItypingrrblogururpydanticrpipecat.audio.dtmf.typesrpipecat.audio.utilsrrr r r pipecat.frames.framesr r rrrrrr#pipecat.serializers.base_serializerrrr'r(r)rsL5 0   @oOor(