qiUpUdZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZmZddlZddlmZmZddlmZdd lmZmZmZmZ ddlZdd l m!Z!dd l"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*dd lm+Z+m,Z,e!ddej`d<gdZ1da2ee3e4d<da5e3e4d<da6e7e4d<dZ8de(dejrfdZ:dejrfdZ;d e$dejrfd!Zd e$dejrfd$Z?d e$dejrfd%Z@dejrfd&ZAd'e3d(e3fd)ZBd(ee3fd*ZCd(e3fd+ZDd(e7fd,ZEd0d-eejfd.ZGeHd/k(reGyy#e-$r5Z.ej^de.ej^de-de.dZ.[.wwxYw)1aPipecat development runner. This development runner executes Pipecat bots and provides the supporting infrastructure they need - creating Daily rooms and tokens, managing WebRTC connections, and setting up telephony webhook/WebSocket infrastructure. It supports multiple transport types with a unified interface. Install with:: pip install pipecat-ai[runner] All bots must implement a `bot(runner_args)` async function as the entry point. The server automatically discovers and executes this function when connections are established. Single transport example:: async def bot(runner_args: RunnerArguments): transport = DailyTransport( runner_args.room_url, runner_args.token, "Bot", DailyParams(...) ) # Your bot logic here await run_pipeline(transport) if __name__ == "__main__": from pipecat.runner.run import main main() Multiple transport example:: async def bot(runner_args: RunnerArguments): # Type-safe transport detection if isinstance(runner_args, DailyRunnerArguments): transport = setup_daily_transport(runner_args) # Your application code elif isinstance(runner_args, SmallWebRTCRunnerArguments): transport = setup_webrtc_transport(runner_args) # Your application code elif isinstance(runner_args, WebSocketRunnerArguments): transport = setup_telephony_transport(runner_args) # Your application code # Your bot implementation await run_pipeline(transport) Supported transports: - Daily - Creates rooms and tokens, runs bot as participant - WebRTC - Provides local WebRTC interface with prebuilt UI - Telephony - Handles webhook and WebSocket connections for Twilio, Telnyx, Plivo, Exotel To run locally: - WebRTC: `python bot.py -t webrtc` - ESP32: `python bot.py -t webrtc --esp32 --host 192.168.1.100` - Daily (server): `python bot.py -t daily` - Daily (direct, testing only): `python bot.py -d` - Telephony: `python bot.py -t twilio -x your_username.ngrok.io` - Exotel: `python bot.py -t exotel` (no proxy needed, but ngrok connection to HTTP 7860 is required) N)asynccontextmanager) HTTPMethod)Path)AnyDictListOptional TypedDictUnion) FileResponseResponse)logger)DailyRunnerArgumentsRunnerArgumentsSmallWebRTCRunnerArgumentsWebSocketRunnerArguments) load_dotenv)BackgroundTasksFastAPIHeader HTTPExceptionRequest WebSocket)CORSMiddleware) HTMLResponseRedirectResponsez#Runner dependencies not available: zDTo use Pipecat runners, install with: pip install pipecat-ai[runner]zJRunner dependencies required. Install with: pip install pipecat-ai[runner]T)overridelocalENV)twiliotelnyxplivoexotelRUNNER_DOWNLOADS_FOLDER localhost RUNNER_HOSTi RUNNER_PORTcDddl}tjd}t|dr|S ddl}|S#t $rYnwxYwt j}t j|D]}|jds|dk7s |dd}|jj|t jj||}|jj|}|jj!|t|dr|cS#t"$rYwxYwt d) z+Get the bot module from the calling script.rN__main__botz.pyz server.pyzLCould not find 'bot' function. Make sure your bot file has a 'bot' function.)importlib.utilsysmoduleshasattrr* ImportErrorosgetcwdlistdirendswithutilspec_from_file_locationpathjoinmodule_from_specloader exec_module Exception) importlib main_moduler*cwdfilename module_namespecmodules D/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/runner/run.py_get_bot_modulerErs++j)K{E"     ))+CJJsO    U #K(? &sm  ~~==c8!<#88> ''/65)!M*    V s- 99BD DD websocketargsc|Kt}t|}||_|j|d{y7w)z#Run a bot for telephony transports.)rFN)rErcli_argsr*)rFrG bot_module runner_argss rD_run_telephony_botrLs4 "J+Y?KK .. %%%s 2<:<c|t}|jtdgddgdg|jdk(r&t |||j r t |||S|jdk(rt|||S|jtvrt|||Stjd|j|S)z2Create FastAPI app with transport-specific routes.*T) allow_originsallow_credentials allow_methods allow_headerswebrtcdailyzUnknown transport type: ) radd_middlewarer transport_setup_webrtc_routeswhatsapp_setup_whatsapp_routes_setup_daily_routesTELEPHONY_TRANSPORTS_setup_telephony_routesrwarning)rGapps rD_create_server_appr_s )Ceee  ~~!S$' == "3 - J 7 "C& J / /T* J 1$..1ABC Jr^c h  ddlm}ddlm ddlm mmm}Gddtd  G fd d t G fd dtd i|jd||jdd d}|jddtffd }|j j"|j%dddt&f fd |j)ddffd |j%ddt*f fd }|j-dgd d!td"tdt*dt&f fd# }t.d$t0ffd% } t3|| y#t$r"}tjd|Yd}~yd}~wwxYw)&zSet up WebRTC-specific routes.r)SmallWebRTCPrebuiltUISmallWebRTCConnection) IceCandidateSmallWebRTCPatchRequestSmallWebRTCRequestSmallWebRTCRequestHandlerz-WebRTC transport dependencies not installed: Nc(eZdZUeeeefed<y)'_setup_webrtc_routes..IceServerurlsN)__name__ __module__ __qualname__r strr__annotations__r`rD IceServerrjsCcN##r`rrF)totalc"eZdZUeWed<y)'_setup_webrtc_routes..IceConfig iceServersN)rlrmrnrrp)rrsrD IceConfigrus O#r`rwc,eZdZUeed<eWed<y),_setup_webrtc_routes..StartBotResult sessionId iceConfigN)rlrmrnrorpr )rwsrDStartBotResultrysI&&r`r|z/client/)include_in_schemac"KtdSw)z+Redirect root requests to client interface.z/client/)url)rrqr`rD root_redirectz+_setup_webrtc_routes..root_redirects J//s z/files/{filename:path}r@c(Kjstjd|dytj|z }tj j |s tdtj|\}}t|||Sw)zHandle file downloads.zAttempting to dowload z!, but downloads folder not setup.N)r7 media_typer@) folderrr]rr1r7existsr mimetypes guess_typer )r@ file_pathr_rGs rD download_filez+_setup_webrtc_routes..download_files{{{ NN3H:=^_ ` %0 ww~~i($ $!,,Y7 AzHUUsBB) esp32_modehostz /api/offerrequestbackground_taskscbKdffd }j|d{}|S7w)z;Handle WebRTC offer requests via SmallWebRTCRequestHandler. connectioncKt}t|j}|_j |j |yw)N)webrtc_connectionbody)rEr request_datarIadd_taskr*)rrJrKrGrrs rDwebrtc_connection_callbackzG_setup_webrtc_routes..offer..webrtc_connection_callbacksB(*J4",73G3GK$(K  % %jnnk BsAA )rrN)handle_web_request)rrranswerrdrGsmall_webrtc_handlers`` rDofferz#_setup_webrtc_routes..offersD  C9N C,>>'A?    s !/-/czKtjd|j|d{ddiS7w)z)Handle WebRTC new ice candidate requests.zReceived patch request: Nstatussuccess)rdebughandle_patch_request)rrs rD ice_candidatez+_setup_webrtc_routes..ice_candidatesB  /y9:"77@@@)$$ As -;9 ;/startcK |jd{}tjd|t t j}|jdi|<d|i}|jdrdgg |d <|S7z#t$r$}tjd|i}Yd}~d}~wwxYww) z&Mimic Pipecat Cloud's /start endpoint.NReceived request: Failed to parse request body: rrzenableDefaultIceServerszstun:stun.l.google.com:19302)rk)rvr{) jsonrrr<errorrouuiduuid4get) rre session_idresultrwrrr|active_sessionss rD rtvi_startz(_setup_webrtc_routes..rtvi_starts !(/L LL-l^< = & &2&6&6vr&B #"-z!:   5 6"+%,J+KLM#F;  !0  LL9!= >L s>CBBBACB CB=8C=CCz"/sessions/{session_id}/{path:path})GETPOSTPUTPATCHDELETE)methodsrr7c hK j|}| tddS|jdr |jd{}|jt j jk(rh |d|d|jd|jd |jd xs|jd xs| }||d{S|jt jjk(rA |d|jd gDcgc] } di| c}}|d{S tjd|tdS7!7cc}w73#t$r/} tjd| tddcYd} ~ Sd} ~ wwxYww)zMimic Pipecat Cloud's proxy.Nz#Invalid or not-yet-ready session_idr)content status_codez api/offersdptypepc_id restart_pcr requestData)rrrrr candidates)rrz Failed to parse WebRTC request: zInvalid WebRTC requestzReceived request for path: )rrq) rr r4rmethodrrvaluerr<rrinfo)rr7rractive_sessionrwebrtc_requestc patch_requestrrerfrgrrrs rD proxy_requestz+_setup_webrtc_routes..proxy_request.s),,Z8  !$IWZ[ [ == % S%,\\^3 >>Z__%:%::%7(/)&1*..w7#/#3#3L#A%1%5%5n%E&*'++M:&*)&N"'~7G!HHH^^z'7'7'='==$;*73?K?O?OP\^`?a#b!L$51$5#b%M"/}!=== >  1$89C((/ 4I$c= S ?sCD(@cRR Ss3F2E7 E+ BE7E.E7F2AE7E0 .E7E5E7&F2+E7.E70E77 F/$F*$F/%F2*F//F2r^cLKdjd{y7w)z=Manage FastAPI application lifecycle and cleanup connections.N)close)r^rs rDsmallwebrtc_lifespanz2_setup_webrtc_routes..smallwebrtc_lifespanVs "((***s $"$))pipecat_ai_small_webrtc_prebuilt.frontendrb)pipecat.transports.smallwebrtc.connectionrd.pipecat.transports.smallwebrtc.request_handlerrerfrgrhr0rrr mountrroesp32rpostrpatchr api_routerr_add_lifespan_to_app)r^rGrbrhrrrrrrrerwrrrdrfrgr|rrrrs ` @@@@@@@@@@@rDrWrWs SS  $IU$$I$'%' 24OIIi./WWSEW*0+0 WW %& Vc V' V7P::DII7 XXl/?( YY|%%<%%  XXh', ]],9")")"")-4")HW")") ")H+++ 23_  DQCHIsF F1F,,F1ct|jdrT|jj>|jjtdtffd }||j_y|j_y)zAdd a new lifespan context manager to the app, combining with existing if present. Args: app: The FastAPI application instance new_lifespan: The new lifespan context manager to add lifespan_contextNr^cK|4d{|4d{ddddd{dddd{y7;7,7#1d{7swY)xYw7 #1d{7swYyxYwwNrq)r^existing_lifespan new_lifespans rDcombined_lifespanz/_add_lifespan_to_app..combined_lifespanksy(-  ',       s A>A A> A)AA)A A)AA) A>A'A>A)A)A$ AA$ A)'A>)A;/A2 0A;7A>)r/routerrrr)r^rrrs ` @rDrr`shszz-.3::3N3N3ZJJ77      '8 #'3 #r`c  tjdtjd tjd tjd t gstjdy ddlmdd lm}dd l m d |jd d ddtf fd }|jd ddtdfd|dt dtdt"f fd }t$dt&f fd }t)||y#t$r"}tjd |Yd}~yd}~wwxYw)z Set up WhatsApp-specific routes.WHATSAPP_APP_SECRETWHATSAPP_PHONE_NUMBER_IDWHATSAPP_TOKEN#WHATSAPP_WEBHOOK_VERIFICATION_TOKENzMissing required environment variables for WhatsApp transport: WHATSAPP_APP_SECRET WHATSAPP_PHONE_NUMBER_ID WHATSAPP_TOKEN WHATSAPP_WEBHOOK_VERIFICATION_TOKEN Nrrc)WhatsAppWebhookRequest)WhatsAppClientz/WhatsApp transport dependencies not installed: z /whatsappzVerify WhatsApp webhookz8Handles WhatsApp webhook verification requests from Meta)summary descriptionrcK"tjdtddt|j}tj dt |j j|d{}tjd|S7#t$r*}tjd |td d d}~wwxYww) zVerify WhatsApp webhook endpoint. This endpoint is called by Meta's WhatsApp Business API to verify the webhook URL during setup. It validates the verification token and returns the challenge parameter if successful. N"WhatsApp client is not initializedService unavailablerdetailz3Webhook verification request received with params: )paramsexpected_verification_tokenzWebhook verification successfulzWebhook verification failed: izVerification failed) rrrdict query_paramsrlistkeyshandle_verify_webhook_requestr ValueErrorr])rrrrrwhatsapp_clients rDverify_webhookz._setup_whatsapp_routes..verify_webhooks  " LL= >C8MN Ng**+ J4PVP[P[P]K^J_`a O*HH;^IF KK9 :M   O NN:1#> ?C8MN N Os<A)C-B!BB!CB!! C*%CCCzHandle WhatsApp webhook eventsz4Processes incoming WhatsApp messages and call eventsrrx_hub_signature_256cK "tjdtdd|jdk7r/tjd|jtdd tj d |j d f fd } |jd{} j|||| d{}tj d|dddS7>7##t$r6}tjd|tddt|d}~wt$r*}tjd|tddd}~wwxYww)zHandle incoming WhatsApp webhook events. For call events, establishes WebRTC connections and spawns bot instances in the background to handle real-time communication. Nrrrrwhatsapp_business_accountzInvalid webhook object type: rzInvalid object typezProcessing WhatsApp webhook: rcKt}t|}|_j|j|yw)aHandle new WebRTC connections from WhatsApp calls. Called when a WebRTC connection is established for a WhatsApp call. Spawns a bot instance to handle the conversation. Args: connection: The established WebRTC connection )rN)rErrIrr*)rrJrKrGrs rDconnection_callbackzM_setup_whatsapp_routes..whatsapp_webhook..connection_callbacks7)*J4zRK#'K  % %jnnk Bs;>)sha256_signatureraw_bodyz Webhook processed successfully: rzWebhook processed successfully)rmessagez Invalid webhook request format: zInvalid request: z#Internal error processing webhook: z(Internal server error processing webhook) rrrobjectr]r model_dumprhandle_webhook_requestrror<) rrrrrrrverrdrGrs ` rDwhatsapp_webhookz0_setup_whatsapp_routes..whatsapp_webhooks_  " LL= >C8MN N ;;5 5 NN:4;;-H IC8MN N 4T__5F4GHI C2G C d$\\^+H*AA)qcB CC8bc c dsZBE C-*C)+C-C+ C-(E )C-+C-- E61D'' E3%EEE r^cKtj4d{}|tjd dtjdrj d{tjddddd{y77,#tjdrj d{7tjdwxYw7S#1d{7swYyxYww)z9Manage WhatsApp client lifecycle and cleanup connections.N)whatsapp_tokenwhatsapp_secretphone_number_idsessionz(WhatsApp client initialized successfullyz(Cleaning up WhatsApp client resources...zWhatsApp cleanup completed)aiohttp ClientSessionrrterminate_all_calls)r^r rrrrrs rDwhatsapp_lifespanz1_setup_whatsapp_routes..whatsapp_lifespans ((* : :g,- 3 8 O KKB C : FG")==??? 89! : : :@ FG")==??? 89! : : : :szDBD"C-B!*C-2B3C- DC+DC-!+C( C C((C-+D-C?3C6 4C?;D)r1getenvallrrrrdpipecat.transports.whatsapp.apir"pipecat.transports.whatsapp.clientrr0rrrrrrorrr)r^rGrrrrr rdrrrrrrs ` @@@@@@@rDrYrYwsq))$9:!yy)CDYY/0N*,))4Y*Z'   $  /        SJE 15OWW)N  OgO  O0 XX0J$*$< 1d$1d)1d1d! 1d  1df:W:::0/0k  FqcJKsD E (EE c|jdfd}|jddtffd }jr!|jddtffd }yy) zSet up Daily-specific routes.r}cKtdddl}ddlm}|j4d{}||d{\}}t }t ||}|_tj|j|t|cdddd{S7u7g7 #1d{7swYyxYww)z(Launch a Daily bot and redirect to room.z?Starting bot with Daily transport and redirecting to Daily roomrN configureroom_urltoken) printr pipecat.runner.dailyrr rErrIasyncio create_taskr*r)r rr rrrJrKrGs rDcreate_room_and_start_agentz8_setup_daily_routes..create_room_and_start_agents OP2(7((* . .g$-g$66OHe)*J.NK#'K    { ; <#H- . . .6 . . . .sU+B?B$B? B*B&AB* B?B(B?&B*(B?*B<0B3 1B<8B?rrcKtd |jd{}tjd||j dd}|j di}|j dd}|j d d}t}tjd }d} |s|rd dl } d d l m } d d l m} m} | j 4d{}d}|r! | di|}tjd|d}|r! | di|}tjd|| |||d{\}}t#|||}||t%t'j(d} dddd{n t+|}_t/j0|j3|| S7#t$r%}tj d|i}Yd}~d}~wwxYw7#t$r#}tj d|Yd}~d}~wwxYw#t$r#}tj d|Yd}~d}~wwxYw77#1d{7swYxYww)a]Handler for /start endpoints. Expects POST body like:: { "createDailyRoom": true, "dailyRoomProperties": { "start_video_off": true }, "dailyMeetingTokenProperties": { "is_owner": true, "user_name": "Bot" }, "body": { "custom_data": "value" } } z!Starting bot with Daily transportNrrcreateDailyRoomFrdailyRoomPropertiesdailyMeetingTokenPropertiesDAILY_ROOM_URLrr)DailyMeetingTokenPropertiesDailyRoomPropertieszUsing custom room properties: z%Failed to parse dailyRoomProperties: zUsing custom token properties: z-Failed to parse dailyMeetingTokenProperties: )room_propertiestoken_propertiesrrr dailyRoom dailyTokenrz)rrq)rrrrr<rrrEr1rr rrpipecat.transports.daily.utilsr#r$r rrorrrrIrrr*)rrrcreate_daily_roomrdaily_room_properties_dictdaily_token_properties_dictrJexisting_room_urlrr rr#r$r r%r&rrrKrGs rD start_agentz(_setup_daily_routes..start_agent"sv 12 !(/L LL-l^< = ),,->F+%1%5%56KT%R"&2&6&67TVZ&[#$& II&67  1  6  -w,,.  '"&-R*=*[@Z*[ 'EoEV%WX $( .Z+F,9,( 'FGWFX%YZ )2_O_)#%3HEX\] !)"'!$TZZ\!27   B*t4K $  JNN;78 M0  LL9!= >L 6 %R 'LQC%PQQR%Z 'TUVTW%XYYZ#/    s I!F5F2F5BI!G&I!I  G)>I  H#I 1I26I ( I!3I 4>I!2F55 G#>GI!G##I!) H2H I HI  I!H?9I ?II  I! II II!/daily-dialin-webhookc Ktjd |jd{tjdj dsj d rtjd d d iStfd dDs t ddddl}ddl m }ddl m }m }|j4d{} ||j dd{}dddd{t!j"dd}t!j"d} | s"tjdt dd|j dj dj dj dj d } || | |!} t%} t'j(|j*| j-"} | _t1j2| j5| tt7j8}|j(|j*|d#S7%#t$r*}tjd|t ddd}~wwxYw77#t$r6}tjd|t ddt|d}~wwxYw7#1d{7swYxYww)$aHandle incoming Daily PSTN dial-in webhook. This endpoint mimics Pipecat Cloud's dial-in webhook handler. It receives Daily webhook data, creates a SIP-enabled room, and starts the bot. Expected webhook payload:: { "From": "+15551234567", "To": "+15559876543", "callId": "uuid-call-id", "callDomain": "uuid-call-domain", "sipHeaders": {...} // optional } Returns:: { "dailyRoom": "https://...", "dailyToken": "...", "sessionId": "uuid" } zReceived Daily dial-in webhookNzWebhook data: zFailed to parse webhook data: rzInvalid JSON payloadrtestTestz"Webhook verification test receivedrOKc3&K|]}|v ywrrq).0keydatas rD zE_setup_daily_routes..handle_dialin_webhook..sUssd{Us)FromTocallId callDomainz5Missing required fields: From, To, callId, callDomainrr)DailyDialinRequestDialinSettingsr;)sip_caller_phonezFailed to create Daily room: r DAILY_API_URLzhttps://api.daily.co/v1 DAILY_API_KEYz&DAILY_API_KEY not found in environmentz&DAILY_API_KEY not configured on serverr=r>r< sipHeaders)call_id call_domainr<r; sip_headers)dialin_settings daily_api_key daily_api_urlr'r()rrrr<rrrrr rrpipecat.runner.typesr?r@r ror1rrErrrrrIrrr*rr)rrr rr?r@r  room_configrJrIrH request_bodyrJrKrr9rGs @rDhandle_dialin_webhookz2_setup_daily_routes..handle_dialin_webhook|s2 LL9 : T$\\^+ ~dV45 xx488F#3 AB $''U.TUU# #R  6 O-w,,.  '(1'DHHU[L\(]"]K  IIo7PQMIIo6M  EF# #,T -* HH\288D>XXf% HH\2 O. /++L)*J.$--!''!,,.K $(K    { ; <TZZ\*J)11)//' W, T =aSAB# zV/ws" bidirectionalMode="rtp"> z wss://z/ws )r r!r"r}c0Kjdk(r)tjdddjdddStjdjj d j jd }t |d Sw) z1Handle telephony webhook and return XML response.r#zPOST Exotel endpoint - not usedz Exotel doesn't use POST webhookszwss:///wszKConfigure the WebSocket URL above in your Exotel App Bazaar Voicebot Applet)r websocket_urlnotezPOST z XMLzzapplication/xml)rr)rVrrproxyupperrr) xml_content XML_TEMPLATESrGs rD start_callz+_setup_telephony_routes..start_calls >>X % LL: ;;#)$**S!9e  LL5!5!5!7 8= >'++DNN.websocket_endpointsA    45 D111 !1s!A A(A AA A c.KddjiSw)z0Simple status endpoint for telephony transports.rzBot started with )rV)rGsrDr0z,_setup_telephony_routes..start_agents!-dnn-=>??sN)rUrrFrr)r^rGrYr\r0rXs ` @rDr\r\s |$  |$ aaeakak`lm M* XXc] S S ]]52I22  WWS\@@r`cK ddlm}tj dt j4d{}||d{\}}t||}d|_ ||_ t}td|td t|j|d{dddd{y#t$r}tjdYd}~yd}~wwxYw777D76#1d{7swYyxYww) z9Run Daily bot with direct connection (no FastAPI server).rrz+Daily transport dependencies not installed.Nz'Running with direct Daily connection...rTu📞 Joining Daily room: z- (Direct connection - no web server needed))rrr0rrrr r r handle_sigintrIrErr*)rGrrr rrrKrJs rD_run_daily_directr`s2  KK9:$$&**' )' 22%+HEJ $( !# %&  )(45 => nn[)))***  BC *2 *****sD C-D C,D  C4C.A#C4+C0,C40 D ;C2<D  C) C$D $C))D .C40C42D 4D:C= ;DD rUreturnc|s|S|}|jdr1|jddd}tjd|d|d|j d}|S)z@Validate and clean proxy hostname, removing protocol if present.)zhttp://zhttps://z://z(Removed protocol from proxy URL. Using 'z' instead of 'zK'. The --proxy argument expects only the hostname (e.g., 'mybot.ngrok.io').r}) startswithsplitrr]rstrip)rUoriginal_proxys rD_validate_and_clean_proxyrh;sq  N /0 E1%a(6ug^NK[\W X LL E Lr`ctS)z=Returns the folder where files are stored for later download.)r$rqr`rDrunner_downloads_folderrjPs ""r`ctS)z%Returns the host name of this runner.)r&rqr`rD runner_hostrlU r`ctS)z Returns the port of this runner.)r'rqr`rD runner_portroZrmr`parserc|stjd}|jdttd|jdt t d|jdd td d gtd d |jddd|jddddd|jddtd|jddddd |jd!ddd"|jd#ddd$|jd%ddd&|j}|jrt|j|_ |jr|jd k(rd |_ n1|jr%|jd k7rtjd'y(|jr%|j d)k(rtjd*y(|j"r%|jd k7rtjd+y(tj$tj&t(j*|j,rd,nd-.|jr>t/t/d/t/t1j2t5|y(|jd k(rvt/|jr t/d0n#|j6r t/d1n t/d2t/d3|j d4|j8d5t/n|jd k(rt/t/d2|j"r2t/d6|j d4|j8d7t/d8n&t/d3|j d4|j8d9t/|j:a|j a|j8at?|}tAj2||j |j8:y();aStart the Pipecat development runner. Parses command-line arguments and starts a FastAPI server configured for the specified transport type. The runner discovers and runs any ``bot(runner_args)`` function found in the calling module. Command-line arguments: - --host: Server host address (default: localhost) 879 - --port: Server port (default: 7860) - -t/--transport: Transport type (daily, webrtc, twilio, telnyx, plivo, exotel) - -x/--proxy: Public proxy hostname for telephony webhooks - -d/--direct: Connect directly to Daily room (automatically sets transport to daily) - -f/--folder: Path to downloads folder - --dialin: Enable Daily PSTN dial-in webhook handling (requires Daily transport) - --esp32: Enable SDP munging for ESP32 compatibility (requires --host with IP address) - --whatsapp: Ensure requried WhatsApp environment variables are present - -v/--verbose: Increase logging verbosity Args: parser: Optional custom argument parser. If provided, default runner arguments are added to it so bots can define their own CLI arguments. Custom arguments should not conflict with the default ones. Custom args are accessible via `runner_args.cli_args`. zPipecat Development Runner)rz--hostz Host address)rdefaulthelpz--portz Port numberz-tz --transportrTrSzTransport type)rchoicesrrrsz-xz--proxyzPublic proxy host name)rsz-dz--direct store_trueFzFConnect directly to Daily room (automatically sets transport to daily))actionrrrsz-fz--folderzPath to downloads folder)rrsz-vz --verbosecountrzIncrease logging verbosityz--dialinzEEnable Daily PSTN dial-in webhook handling (requires Daily transport)z--esp32zLEnable SDP munging for ESP32 compatibility (requires --host with IP address)z --whatsappz:Ensure requried WhatsApp environment variables are presentz8--direct flag only works with Daily transport (-t daily)Nr%zDFor ESP32, you need to specify `--host IP` so we can do SDP munging.z8--dialin flag only works with Daily transport (-t daily)TRACEDEBUG)levelu)🚀 Connecting directly to Daily room...u🚀 Bot ready! (ESP32 mode)u🚀 Bot ready! (WhatsApp)u🚀 Bot ready!u → Open http://:z/client in your browseru% → Daily dial-in webhook: http://r1u= → Configure this URL in your Daily phone number settingsz# in your browser to start a session)rport)!argparseArgumentParser add_argumentror&intr'r[ parse_argsrUrhdirectrVrrrrrOremoveaddr-stderrverboserrrunr`rXr|rr$r_uvicorn)rprGr^s rDmainr_si< ((5QR sKnU sKmT   (:%9:   i.FG   U  js9ST  k'1;W  T    [    I     D zz.tzz:  {{t~~1  72 OP zzdii;. [\ {{t~~0 OP MMO JJszzDLLgF {{  9:   %d+, ~~!  :: 0 2 ]] . 0 O % #DII;a {:QRS  7 "  ! ;; 7 {!DII;Ncd  Q S ' {!DII;>ab c "kk))K))K T "C KK$))$))4r`r)r)I__doc__r}rrr1r-r contextlibrhttprpathlibrtypingrrrr r r r fastapi.responsesr r logururrKrrrrrdotenvrfastapirrrrrrfastapi.middleware.corsrrrr0rrenvironr[r$rorpr&r'rrE NamespacerLr_rWrrYrZr\r`rhrjrlror~rrlrqr`rDrs;z *>>4  "[[6@ T 5>)-#- S S'T& &9K9K&X//6[4g[4X-?-?[4|3g3.R1R1x/A/AR1j[W[H,>,>[|2@2@0B0B2@j*("4"4*8SS*### S S M5(112M5` zF_ FLL6qc:;FLLWX T    s(E;;F50F00F5