qiN xdZddlZddlZddlZddlmZmZmZmZddl m Z ddl m Z ddl mZmZmZmZddlmZded efd Zd e fd Zd eded efdZ d#d ededefdZ d#d ededefdZdeded efdZded efdZdedeed efdZdedeeefd efdZ d$d e deededed ef d Z d!edeeefd efd"Z!y)%aTransport utility functions and FastAPI route setup helpers. This module provides common functionality for setting up transport-specific FastAPI routes and handling WebRTC/WebSocket connections. It includes SDP manipulation utilities for WebRTC compatibility and transport detection helpers. Key features: - WebRTC route setup with connection management - WebSocket route setup for telephony providers - SDP munging for ESP32 and other WebRTC compatibility - Transport client ID detection across different transport types - Video capture utilities for Daily transports The utilities are designed to be transport-agnostic where possible, with specific handlers for each transport type's unique requirements. Example:: from pipecat.runner.utils import parse_telephony_websocket async def telephony_websocket_handler(websocket: WebSocket): transport_type, call_data = await parse_telephony_websocket(websocket) N)AnyCallableDictOptional) WebSocket)logger)DailyRunnerArgumentsLiveKitRunnerArgumentsSmallWebRTCRunnerArgumentsWebSocketRunnerArguments) BaseTransport message_datareturnctjd|jddk(rBd|vr>d|jdivr*d|jdivrtjdyd|vr.d|vr*d |jdivrtjd y d|vr>d |jdivr*d |jdivrtjdy|jddk(rVd|vrRd|jdivr>d|jdivr*d|jdivrtjdytjdy)zGAttempt to auto-detect transport type from WebSocket message structure.z=== Auto-Detection Analysis ===eventstart streamSidcallSidzAuto-detected: TWILIOtwilio stream_idcall_control_idzAuto-detected: TELNYXtelnyxstreamIdcallIdzAuto-detected: PLIVOplivo stream_sidcall_sid account_sidzAuto-detected: EXOTELexotelz&Auto-detection failed - unknown formatunknown)rtraceget)rs F/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/runner/utils.py#_detect_transport_type_from_messager$1s] LL23 !W, | # <++GR8 8 ))'26 6 ,- |# | # !1!1'2!> > ,- < ,**7B7 7  (("5 5 +, !W, | # L,,Wb9 9 ,**7B7 7 \--gr: : ,- LL9:  websocketc K|j}i}i} |jd{}tjd||rt j |ni} |jd{}tjd||rt j |ni} t|}t|}|dk7r|}|} tjd|dn<|dk7r|}|} tjd|d nd}|} tjd |d k(rJ| jd i} | jd i} | jd| jd| d} nf|dk(r| jd| jd ijd| jd ijdijd| jd ijdd| jd ijddd} n|dk(r6| jd i} | jd| jdd} n|dk(ry| jd i} | jd| jd | jd!| jdd| jdd| jd"dd#} ni} tjd$|d%| || fS7#tj $rYt$r tdwxYw7#tj $rYt$rtjdYwxYw#t$r} tjd&| d} ~ wwxYww)'aParse telephony WebSocket messages and return transport type and call data. Args: websocket: FastAPI WebSocket connection from telephony provider. Returns: tuple: (transport_type: str, call_data: dict) call_data contains provider-specific fields: - Twilio:: { "stream_id": str, "call_id": str, "body": dict } - Telnyx:: { "stream_id": str, "call_control_id": str, "outbound_encoding": str, "from": str, "to": str, } - Plivo:: { "stream_id": str, "call_id": str, } - Exotel:: { "stream_id": str, "call_id": str, "account_sid": str, "from": str, "to": str, } Raises: ValueError: If WebSocket closes before sending any messages. Example usage:: transport_type, call_data = await parse_telephony_websocket(websocket) if transport_type == "twilio": user_id = call_data["body"]["user_id"] NzFirst message: z>WebSocket closed before receiving telephony handshake messageszSecond message: z1Only received one WebSocket message, expected twor zDetected transport: z (from first message)z (from second message)z$Could not auto-detect transport typerrcustomParametersrr)rcall_idbodyrrr media_formatencodingfromto)rroutbound_encodingr-r/rrr)rr)rrrrcustom_parameters)rr)rr-r/r1zParsed - Type: z, Data: z#Error parsing telephony WebSocket: ) iter_text __anext__rr!jsonloadsJSONDecodeErrorStopAsyncIteration ValueErrorwarningr$debugr" Exceptionerror)r&message_stream first_messagesecond_messagefirst_message_rawsecond_message_rawdetected_type_firstdetected_type_secondtransport_type call_data_raw start_data body_data call_dataes r#parse_telephony_websocketrJ`sp((*NMN["0":":"<< '8&9:;9J #45PR L#1#;#;#== '(:';<=;M$67SU CA-PB>R ) +0N)M LL//??TU V !Y .1N*M LL//??UV W&N*M NNA B X %&**7B7J"'92>I'^^K8%>>)4! Ix '*..{;#0#4#4Wb#A#E#EFW#X%2%6%6w%C^R(Z%))'26::62F#''488rBIw &&**7B7J'^^J7%>>(3I x '&**7B7J'^^L9%>>*5)~~m<"vr2 nnT2.%/^^4G%L II ~&6hykJKy((c=     [YZZ[ >     LJKLH  :1#>? sN K8K55K8"L(5L%65L(,IM"4N 5K88L" N L""N %L((M;N >MN MN " N +NN  N  transportclientc ddlm}t||r |jS ddlm}t||r|dS tjdt|y#t$rYFwxYw#t$rY F OO E yyD)"))It2L MM$   ;;v  ''r%sdphostc8t|}|r t||}|S)zApply SDP modifications for SmallWebRTC compatibility. Args: sdp: Original SDP string. host: Host address for ICE candidate filtering. Returns: Modified SDP string with fingerprint and ICE candidate cleanup. )rxrv)ryrzs r#smallwebrtc_sdp_mungingr|xs" 0 4C 5c4@ Jr% transport_keytransport_paramscv||vrtd|d|d||}tjd||S)aaGet transport parameters from factory function. Args: transport_key: The transport key to look up transport_params: Dict mapping transport names to parameter factory functions Returns: Transport parameters from the factory function Raises: ValueError: If transport key is missing from transport_params zMissing transport params for 'z'. Please add 'z$' key to your transport_params dict.zUsing transport params for )r8rr:)r}r~paramss r#_get_transport_paramsrs_,,,]O<(/)M O  - m , .F LL.}o>? Mr%rrDrHc Kddlm}| tdd|_t j d||dk(rFddlm}||d|d tjd d tjd d  |_ n|dk(r6ddl m }||d|d|ddtjdd |_ n{|dk(rFddl m}||d|d tjdd tjdd |_ n0|dk(rddlm}||d|d |_ ntd|d|||Sw) aCreate a telephony transport with pre-parsed WebSocket data. Args: websocket: FastAPI WebSocket connection from telephony provider params: FastAPIWebsocketParams (required) transport_type: Pre-detected provider type ("twilio", "telnyx", "plivo") call_data: Pre-parsed call data dict with provider-specific fields Returns: Configured FastAPIWebsocketTransport ready for telephony use. r)FastAPIWebsocketTransportzeFastAPIWebsocketParams must be provided. The serializer and add_wav_header will be set automatically.Fz'Using pre-detected telephony provider: r)TwilioFrameSerializerrr)TWILIO_ACCOUNT_SIDr.TWILIO_AUTH_TOKEN)rrr auth_tokenr)TelnyxFrameSerializerrr0PCMUTELNYX_API_KEY)rrr0inbound_encodingapi_keyr)PlivoFrameSerializer PLIVO_AUTH_IDPLIVO_AUTH_TOKEN)rr)auth_idrr)ExotelFrameSerializer)rrz Unsupported telephony provider: z4. Supported providers: twilio, telnyx, plivo, exotel)r&r)$pipecat.transports.websocket.fastapirr8add_wav_headerrinfopipecat.serializers.twiliorosgetenv serializerpipecat.serializers.telnyxrpipecat.serializers.plivorpipecat.serializers.exotelr) r&rrDrHrrrrrs r#_create_telephony_transportrsr"O ~ K  "F KK9.9IJK!D1 -y) "6;yy!4b9   8 #D1 ,%&78'(;<#II.3   7 "B0 ,i(IIor2yy!3R8   8 #D1 -y)  .~.>?A B  %y HHsD>E runner_argscKt|tr2td|}ddlm}||j |j d|St|tr&td|}ddlm }|||jSt|trLt|jd {\}}t||}t|j|||d {St|tr9    K!7 8&y2BCI OO     ! !   >tK?P>QRSS)%[ s%B!D>#D:$.D>D<A(D><D>)r)NNN)"__doc__r4rrotypingrrrrfastapirlogururpipecat.runner.typesr r r r !pipecat.transports.base_transportr dictstrr$rJrYintrcrgrvrxr|rrrr%r#rs2 00 <,d,s,^SySl}cc@=>  &) 69 <=>  &) 69 <(#(((,((($  HSM c  S(]@SX[4! GIGI SMGIGI GI  GITkTkT(,S(](;kTkTr%