qidZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z m Z mZmZmZmZmZmZddlmZGd d eZy) z,Exotel Media Streams serializer for Pipecat.N)Optional)logger) KeypadEntry)create_stream_resampler) AudioRawFrameFrameInputAudioRawFrameInputDTMFFrameInterruptionFrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrame)FrameSerializerceZdZdZGddej Z ddedeedeeffd Zd e fd Z d e d ee zdzfd Z d ee zd e dzfdZxZS)ExotelFrameSerializeraSerializer for Exotel Media Streams WebSocket protocol. This serializer handles converting between Pipecat frames and Exotel's WebSocket media streams protocol. It supports audio conversion, DTMF events, and automatic call termination. Note: Ref docs for events: https://support.exotel.com/support/solutions/articles/3000108630-working-with-the-stream-and-voicebot-applet c4eZdZUdZdZeed<dZeeed<y)!ExotelFrameSerializer.InputParamsaFConfiguration parameters for ExotelFrameSerializer. Parameters: exotel_sample_rate: Sample rate used by Exotel, defaults to 8000 Hz. sample_rate: Optional override for pipeline input sample rate. ignore_rtvi_messages: Inherited from base FrameSerializer, defaults to True. i@exotel_sample_rateN sample_rate) __name__ __module__ __qualname____doc__rint__annotations__rrL/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/serializers/exotel.py InputParamsr)s" #'C&%) Xc])rrN stream_sidcall_sidparamsct||xstj||_||_|j j|_d|_ t|_ t|_ y)aInitialize the ExotelFrameSerializer. Args: stream_sid: The Exotel Media Stream SID. call_sid: The associated Exotel Call SID (optional, not used in this implementation). params: Configuration parameters. rN) super__init__rr _stream_sid _call_sid_paramsr_exotel_sample_rate _sample_rater_input_resampler_output_resampler)selfr r!r" __class__s rr%zExotelFrameSerializer.__init__5s` 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 rsetupzExotelFrameSerializer.setupJs% !LL44R8R8Rs+-returnchKt|tr$d|jd}tj|St|t r|j }|jj||j|jd{}|t|dk(rytj|jd}d|jd|id}tj|St|tt fr1|j#|rytj|j$Sy7w) a8Serializes a Pipecat frame to Exotel WebSocket format. Handles conversion of various frame types to Exotel WebSocket messages. Args: frame: The Pipecat frame to serialize. Returns: Serialized data as string or bytes, or None if the frame isn't handled. clear)event streamSidNrasciimediapayload)r6r7r9) isinstancer r&jsondumpsraudior,resamplerr)lenbase64 b64encodedecoder r should_ignore_framemessage)r-r/answerdataserialized_datar:s r serializezExotelFrameSerializer.serializeRs e. /&T5E5EFF::f% % } -;;D%)$:$:$C$Ce'')A)A%O&#o*>!*C&&7>>wGG!!--#W-F ::f% %  ;=^_ `''.::emm, ,+sBD2D0B)D2rGcKtj|}|ddk(r|dd}tj|}|jj ||j |jd{}|t|dk(ryt|d|j}|S|ddk(r6|jdijd } tt|Sy7n#t$rtjd |YywxYww) a<Deserializes Exotel WebSocket data to Pipecat frames. Handles conversion of Exotel media events to appropriate Pipecat frames. Args: data: The raw WebSocket data from Exotel. Returns: A Pipecat frame corresponding to the Exotel event, or None if unhandled. r6r9r:Nr)r> num_channelsrdtmfdigitzInvalid DTMF digit: )r<loadsrA b64decoder+r?r)r*r@r getr r ValueErrorrinfo)r-rGrEpayload_base64r:deserialized_data audio_framerNs r deserializez!ExotelFrameSerializer.deserialize{s**T" 7 w &$W-i8N&&~6G&*&;&;&D&D((!!'!  !(C0A,Ba,G-' --K   W  'KK+//8E %k%&899 5!*  25':; s7A/D 1C 2AD  C"D "!DD DD )NN)rrrrrrstrrr%rr2rbytesrIrW __classcell__)r.s@rrrs *o11 *`d;;)1#;GOP[G\;*SS'U'sU{T/A'R+cEk+edl+rr)rrAr<typingrlogururpipecat.audio.dtmf.typesrpipecat.audio.utilsrpipecat.frames.framesrrr r r r r r#pipecat.serializers.base_serializerrrrrrras?3 07   @HOHr