qi)dZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z ddl mZmZmZmZmZmZmZmZmZmZddlmZGd d eZy) z?Twilio Media Streams WebSocket protocol serializer for Pipecat.N)Optional)logger) KeypadEntry)create_stream_resampler pcm_to_ulaw ulaw_to_pcm) AudioRawFrame CancelFrameEndFrameFrameInputAudioRawFrameInputDTMFFrameInterruptionFrameOutputTransportMessageFrame!OutputTransportMessageUrgentFrame StartFrame)FrameSerializerceZdZdZGddej Z ddedeedeedeed eed eed eeffd Zd e fdZ d e dee zdzfdZ dZdee zde dzfdZxZS)TwilioFrameSerializeraSerializer for Twilio Media Streams WebSocket protocol. This serializer handles converting between Pipecat frames and Twilio'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 Twilio call when an EndFrame or CancelFrame is processed, but requires Twilio credentials to be provided. cBeZdZUdZdZeed<dZeeed<dZ e ed<y)!TwilioFrameSerializer.InputParamsaConfiguration parameters for TwilioFrameSerializer. Parameters: twilio_sample_rate: Sample rate used by Twilio, defaults to 8000 Hz. sample_rate: Optional override for pipeline input sample rate. auto_hang_up: Whether to automatically terminate call on EndFrame. ignore_rtvi_messages: Inherited from base FrameSerializer, defaults to True. i@twilio_sample_rateN sample_rateT auto_hang_up) __name__ __module__ __qualname____doc__rint__annotations__rrrboolL/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/serializers/twilio.py InputParamsr,s, #'C&%) Xc])! d!r#r%N stream_sidcall_sid account_sid auth_tokenregionedgeparamscFt ||xstj|jj rtg}|s|j d|s|j d|s|j d|rtddj||r|r|r|std|d|d||_ ||_ ||_ ||_ ||_ ||_|jj|_d |_t%|_t%|_d |_y ) aGInitialize the TwilioFrameSerializer. Args: stream_sid: The Twilio Media Stream SID. call_sid: The associated Twilio Call SID (optional, but required for auto hang-up). account_sid: Twilio account SID (required for auto hang-up). auth_token: Twilio auth token (required for auto hang-up). region: Twilio region (e.g., "au1", "ie1"). Must be specified with edge. edge: Twilio edge location (e.g., "sydney", "dublin"). Must be specified with region. params: Configuration parameters. r'r(r)z9auto_hang_up is enabled but missing required parameters: z, zBoth edge and region parameters are required if one is set. Twilio's FQDN format requires both: api.{edge}.{region}.twilio.com. Got: region='z ', edge=''rFN)super__init__rr%_paramsrappend ValueErrorjoin _stream_sid _call_sid _account_sid _auth_token_region_edger_twilio_sample_rate _sample_rater_input_resampler_output_resampler_hangup_attempted) selfr&r'r(r)r*r+r,missing_credentials __class__s r$r0zTwilioFrameSerializer.__init__:s'* F#8#D#D#FG << $ $"$ #**:6#**=9#**<8" OPTPYPYZmPnOop tf $$*89TF!= &!'%  #'<<#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)r1raudio_in_sample_rater<)r@rCs r$setupzTwilioFrameSerializer.setupws% !LL44R8R8Rs+-returncK|jjrB|js6t|tt fr d|_|j d{yt|tr$d|jd}tj|St|tr|j}t||j|j|j d{}|t#|dk(ryt%j&|j)d}d|jd|id }tj|St|t*t,fr1|j/|rytj|j0Sy7.7w) aSerializes a Pipecat frame to Twilio WebSocket format. Handles conversion of various frame types to Twilio WebSocket messages. For EndFrames, 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. TNclear)event streamSidrzutf-8mediapayload)rJrKrL)r1rr? isinstancer r _hang_up_callrr5jsondumpsr audiorrr;r>lenbase64 b64encodedecoderrshould_ignore_framemessage)r@rCanswerdataserialized_datarMs r$ serializezTwilioFrameSerializer.serializesV LL % %**58["9:%)D "$$& & & 0 1&T5E5EFF::f% % } -;;D%0e'')A)A4CYCY%O&#o*>!*C&&7>>wGG !--#W-F ::f% %  ;=^_ `''.::emm, ,= 's&AFFBFFB)FFc K ddl}|j}|j}|j}|j}|j }|r|dnd}|r|dnd}d||d|d|d} |j ||} d d i} |j4d{} | j| | | 4d{} | jd k(rtjd |n| jdk(r | jd{}|jddk(r;tjd|d dddd{dddd{y | j!d{}tj"d|d| jd|n@| j!d{}tj"d|d| jd|dddd{dddd{y7d7J777#t$rYwxYw77j74#1d{7swYDxYw7;#1d{7swYyxYw#t$r"}tj"d|Yd}~yd}~wwxYww)z0Hang up the Twilio call using Twilio's REST API.rN.z https://api.ztwilio.com/2010-04-01/Accounts/z/Calls/z.jsonStatus completed)authrZz$Successfully terminated Twilio call icodeiOz Twilio call z was already terminatedz Failed to terminate Twilio call z : Status z , Response: zFailed to hang up Twilio call: )aiohttpr7r8r6r9r: BasicAuth ClientSessionpoststatusrinforPgetdebug Exceptiontexterror)r@rer(r)r'r*r+ region_prefix edge_prefixendpointrbr,sessionresponse error_data error_textes r$rOz#TwilioFrameSerializer._hang_up_calls5 @ ++K))J~~H\\F::D,2vhaLM(,TF!*"K&k]=/A`al`mmtu}t~DEH$$[*=D ,F,,.  '"<<t&<IX#- &J8*$UV!C/!/7}})>J)~~f5> & |H:E\-] ^ &    ?,4==?%:  >xjI&&.oo%6l:,P ,4==?%:  >xjI&&.oo%6l:,P1   *?  )! !&;&;/    < @ LL:1#> ? ? @sVI-B H?G2H?H*+G5,H*/8H(G>;G8<1G>. H*9G::H*> H? G< H?I-H#H $AH$H%,H H*HH*! H?,H(-H?1I-2H?5H*8G>:H*<H?> H H H  HHH*H% HH% !H*(H?*H<0H3 1H<8H?;I-<H?? I*I% I-%I**I-rZcKtj|}|ddk(r||dd}tj|}t ||j |j |jd{}|t|dk(ryt|d|j }|S|ddk(r6|jdijd } tt|Sy7n#t$r }Yd}~yd}~wwxYww) a<Deserializes Twilio WebSocket data to Pipecat frames. Handles conversion of Twilio media events to appropriate Pipecat frames. Args: data: The raw WebSocket data from Twilio. Returns: A Pipecat frame corresponding to the Twilio event, or None if unhandled. rJrLrMNr)rR num_channelsrdtmfdigit)rPloadsrT b64decoderr;r<r=rSr rkrrr3) r@rZrXpayload_base64rMdeserialized_data audio_framer|rws r$ deserializez!TwilioFrameSerializer.deserializes**T" 7 w &$W-i8N&&~6G'21143D3DdF[F['! !(C0A,Ba,G,'aTEVEVK  W  'KK+//8E %k%&899 )!   s7A*C3,C-AC3CC3 C0&C3+C00C3)NNNNNN)rrrrrr%strrr0rrFr bytesr\rOr __classcell__)rBs@r$rr s  "o11 ""#'%)$( $"(,;';'3-;'c] ;' SM ;'  ;'sm;'%;'zSS0U0sU{T/A0d7@r&cEk&edl&r#r)rrTrPtypingrlogururpipecat.audio.dtmf.typesrpipecat.audio.utilsrrrpipecat.frames.framesr r r r r rrrrr#pipecat.serializers.base_serializerrrr"r#r$rsCF 0QQ   @pOpr#