qi\HdZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z mZddlmZddlmZddlmZdd lmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*dd l+m,Z,dd l-m.Z.dd l/m0Z0m1Z1dd l2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9m:Z:ddl;mZ>m?Z?m@Z@ddlAmBZBddlCmDZD ddlEmFZGeGddZLeGdde=ZMGdde:ZNy#eH$r7ZIejdeIejdeKdeIdZI[IwwxYw)zGrok Realtime Voice Agent LLM service implementation with WebSocket support. Based on xAI's Grok Voice Agent API documentation: https://docs.x.ai/docs/guides/voice/agent N) dataclassfield)fields)AnyDictMappingOptionalType)logger) ToolsSchema)GrokRealtimeLLMAdapter)AggregationTypeBotStoppedSpeakingFrame CancelFrameEndFrameFrameInputAudioRawFrameInterruptionFrameLLMContextFrameLLMFullResponseEndFrameLLMFullResponseStartFrameLLMMessagesAppendFrameLLMSetToolsFrame LLMTextFrame StartFrameTranscriptionFrameTTSAudioRawFrameTTSStartedFrameTTSStoppedFrame TTSTextFrameUserStartedSpeakingFrameUserStoppedSpeakingFrame) LLMTokenUsage) LLMContext)LLMAssistantAggregatorParamsLLMUserAggregatorParams)LLMContextAggregatorPair)OpenAILLMContext)FrameDirection)FunctionCallFromLLM LLMService) NOT_GIVEN LLMSettings _NotGiven_warn_deprecated_paramis_given)time_now_iso8601)events)connectz Exception: zJIn order to use Grok Realtime, you need to `pip install pipecat-ai[grok]`.zMissing module: c>eZdZUdZeed<eed<eed<dZeed<y)CurrentAudioResponseaoTracks the current audio response from the assistant. Parameters: item_id: Unique identifier for the audio response item. content_index: Index of the audio content within the item. start_time_ms: Timestamp when the audio response started in milliseconds. total_size: Total size of audio data received in bytes. Defaults to 0. item_id content_index start_time_msr total_sizeN)__name__ __module__ __qualname____doc__str__annotations__intr:T/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/grok/realtime/llm.pyr6r6Ns$LJrCr6ceZdZUdZedZejeze d<e d dZ ddde e efffd Zed eddee efddfd ZxZS) GrokRealtimeLLMSettingsaSettings for GrokRealtimeLLMService. Parameters: session_properties: Grok Realtime session properties (voice, audio config, tools, etc.). ``instructions`` is synced bidirectionally with the top-level ``system_instruction`` field. ctS)N)r,rBrCrDz GrokRealtimeLLMSettings.js rC)default_factorysession_propertiessettingsct|jsy|j}t|jr|j|_yy)zBPush top-level ``system_instruction`` into ``session_properties``.N)r0rJsystem_instruction instructions)rKsps rD_sync_top_level_to_spz-GrokRealtimeLLMSettings._sync_top_level_to_spos@334   ( ( H// 0&99BO 1rCdeltareturnct||}d|vrbt|jrM|j}d|vr=|j1|j }|j|_||j k7r||d<|j ||S)a Merge a delta, keeping ``system_instruction`` in sync with SP. When the delta contains ``session_properties``, it **replaces** the stored SP wholesale (matching legacy behaviour). Top-level field values always take precedence over conflicting SP values. rJrM)super apply_updater0rJrNrMrP)selfrQchangedrOold_si __class__s rDrUz$GrokRealtimeLLMSettings.apply_updatezs'&u- 7 *x8O8O/P((B#72r7R00*,//'T4444:G01 ""4(rCclsct|Dchc]}|jc}dhz }i}i}i}ttjj j }|jD]:\}} |jj||} | |vr| || <,| |vr| || <6| ||<<|rtjdi||d<|di|} || _ | Scc}w)a1Build a delta from a plain dict, routing SP keys into ``session_properties``. Keys that correspond to ``SessionProperties`` fields are collected into a nested ``session_properties`` value. ``model`` is always routed to the top-level field. Unknown keys go to ``extra``. extrarJrB) dataclass_fieldsnamesetr3SessionProperties model_fieldskeysitems_aliasesgetr\) rZrKfown_field_namestopsp_dictr\sp_keyskeyvalue canonicalinstances rD from_mappingz$GrokRealtimeLLMSettings.from_mappings,rrJr3r`r.r@ staticmethodrPrr?rrU classmethodr rro __classcell__rYs@rDrFrF_s@E)@009< ::";S#X<! + ,!8?S8I! "!!rCrFc beZdZUdZeZeed<eZdddddde de d e e jd e ed e f fd Zd e fdZde fdZde d e efdZd efdZd e fdZdZdZdZdZ dLdededed efdZdZdedefd Zd!effd" Zd!effd# Zd!e ffd$ Z!d!e"de#ffd% Z$d&e%fd'Z&d(Z'd)e jPfd*Z)d+Z*d,Z+d-Z,fd.Z-d/Z.d0Z/d1Z0d2Z1d3Z2d4Z3d5Z4d6Z5d7Z6d8Z7d9Z8d:e fd;Z9d<Z:d=Z;d>ZdAZ?dBe fdCZ@dDZAdEe dFe fdGZBeCeDdHd&eEdIeCdJeDd eFfdKZGxZHS)MGrokRealtimeLLMServiceaGrok Realtime Voice Agent LLM service providing real-time audio and text communication. Implements the Grok Voice Agent API with WebSocket communication for low-latency bidirectional audio and text interactions. Supports function calling, conversation management, and real-time transcription. Features: - Real-time audio streaming (PCM, PCMU, PCMA formats) - Configurable sample rates (8kHz to 48kHz for PCM) - Multiple voice options (Ara, Rex, Sal, Eve, Leo) - Built-in tools (web_search, x_search, file_search) - Custom function calling - Server-side VAD (Voice Activity Detection) _settingszwss://api.x.ai/v1/realtimeNF)base_urlrJrKstart_audio_pausedapi_keyrwrJrKrxc `tdddddddddddtj }|5tdtd||_|j |j |_tj|||j|t|(d ||d|||_ ||_ ||_ d|_d|_d|_d|_d|_d|_d|_d|_d|_i|_i|_t3|_|j7d|j7dy) aInitialize the Grok Realtime Voice Agent LLM service. Args: api_key: xAI API key for authentication. base_url: WebSocket base URL for the realtime API. Defaults to "wss://api.x.ai/v1/realtime". session_properties: Configuration properties for the realtime session. If None, uses default SessionProperties with voice "Ara". .. deprecated:: 0.0.105 Use ``settings=GrokRealtimeLLMSettings(session_properties=...)`` instead. To set a different voice, configure it in session_properties: session_properties = events.SessionProperties(voice="Rex") Available voices: Ara, Rex, Sal, Eve, Leo. settings: Runtime-updatable settings for this service. start_audio_paused: Whether to start with audio input paused. Defaults to False. **kwargs: Additional arguments passed to parent LLMService. NF) modelrM temperature max_tokenstop_ptop_kfrequency_penaltypresence_penaltyseedfilter_incomplete_user_turnsuser_turn_completion_configrJrJ)rwrKTon_conversation_item_createdon_conversation_item_updatedrB)rFr3r`r/rJrNrMrPrUrT__init__ryrw_audio_input_paused _websocket _receive_task_context_llm_needs_conversation_setup_disconnecting_api_session_ready_run_llm_when_api_session_ready_current_assistant_response_current_audio_response_messages_added_manually_pending_function_callsr__completed_tool_calls_register_event_handler) rVryrwrJrKrxkwargsdefault_settingsrYs rDrzGrokRealtimeLLMService.__init__s]B3#"!).(,%779    ) "$'$  3E  /!..:6H6U6U 3 556FG    ) )( 3  %     #5 !$( -1*#"'/4,+/('+$(*%')$%(U" $$%CD $$%CDrCrRcy)zCheck if the service can generate usage metrics. Returns: True if metrics generation is supported. TrBrVs rDcan_generate_metricsz+GrokRealtimeLLMService.can_generate_metrics4s rCpausedc||_y)zzSet whether audio input is paused. Args: paused: True to pause audio input, False to resume. N)r)rVrs rDset_audio_input_pausedz-GrokRealtimeLLMService.set_audio_input_paused<s $* rC directionc|jjjsy|dk(r*|jjjjn)|jjjj}|rQ|j rEt |j dr|j jS|j jdvryy)a!Get manually configured sample rate for input or output. Args: direction: Either "input" or "output". Returns: Configured sample rate or None if not manually configured. For PCMU/PCMA formats, returns 8000 Hz (G.711 standard). Ninputrate)z audio/pcmuz audio/pcmai@) rvrJaudioroutputformathasattrrtype)rVr audio_configs rD_get_configured_sample_ratez2GrokRealtimeLLMService._get_configured_sample_rateDs~~0066G# NN - - 3 3 9 92288??  L//|**F3#**///$$))-IIrCcB|jd}| td|S)zGet the output sample rate from session properties. Returns: Output sample rate in Hz. Note: This assumes start() has been called, which guarantees session_properties.audio.output exists. rz"Output sample rate not configured.)r RuntimeError)rVrs rD_get_output_sample_ratez.GrokRealtimeLLMService._get_output_sample_rateas*//9 <CD D rCc|jjjr-|jjjjdk(Sy)z$Check if server-side VAD is enabled. server_vadF)rvrJturn_detectionrrs rD_is_turn_detection_enabledz1GrokRealtimeLLMService._is_turn_detection_enabledps9 >> , , ; ;>>44CCHHLX XrCcK|jsV|jtjd{|jtjd{|j d{|j d{|jrC|jtd{|jtd{yy777p7Z7/7w)z-Handle user interruption of assistant speech.N) rsend_client_eventr3InputAudioBufferClearEventResponseCancelEvent _truncate_current_audio_responsestop_all_metricsr push_framerrrs rD_handle_interruptionz+GrokRealtimeLLMService._handle_interruptionvs..0(()J)J)LM M M(()C)C)EF F F33555##%%%  + +//"9";< < <///"34 4 4 , N F5% = 4si7C5C)*C5$C+%C5<C-=C5C/,C5C1 C5"C3#C5+C5-C5/C51C53C5c Kyw)z#Handle user started speaking event.NrBrVframes rD_handle_user_started_speakingz4GrokRealtimeLLMService._handle_user_started_speaking  cK|jsW|jtjd{|jtjd{yy717w)z#Handle user stopped speaking event.N)rrr3InputAudioBufferCommitEventResponseCreateEventrs rD_handle_user_stopped_speakingz4GrokRealtimeLLMService._handle_user_stopped_speakingsX..0(()K)K)MN N N(()C)C)EF F F1 N Fs!7A/A+*A/$A-%A/-A/cKd|_yw)z"Handle bot stopped speaking event.N)rrs rD_handle_bot_stopped_speakingz3GrokRealtimeLLMService._handle_bot_stopped_speakings'+$s  total_bytes sample_ratebytes_per_samplecV||j}||z }||z }t|dzS)zGCalculate audio duration in milliseconds based on PCM audio parameters.)rrA)rVrrrsamplesduration_secondss rD_calculate_audio_duration_msz3GrokRealtimeLLMService._calculate_audio_duration_mss?  668K 00"[0#d*++rCcK|jsy d|_y#t$r"}tjd|Yd}~yd}~wwxYww)zTruncates the current audio response. Note: Grok may not support truncation events like OpenAI. This is a best-effort cleanup. Nz-Audio truncation cleanup failed (non-fatal): )r Exceptionr warningrVes rDrz7GrokRealtimeLLMService._truncate_current_audio_responsesJ ++  P+/D ( P NNJ1#N O O Ps'AA A?AAAinput_sample_rateoutput_sample_ratec|jj}|jstj|_|jj s9tj tj||j_|jjs:tjtj||j_yy)a)Ensure session_properties.audio has input and output configs. Fills in any missing audio configuration using the given sample rates. Args: input_sample_rate: Sample rate for audio input (Hz). output_sample_rate: Sample rate for audio output (Hz). )r)rN) rvrJrr3AudioConfigurationr AudioInputPCMAudioFormatr AudioOutput)rVrrpropss rD_ensure_audio_configz+GrokRealtimeLLMService._ensure_audio_configs11{{ 335EK{{  & 1 1,,2CD!EKK {{!!!'!3!3,,2DE"EKK "rCrcKt||d{|j|j|j|j d{y7C7w)zStart the service and establish WebSocket connection. Args: frame: The start frame triggering service initialization. N)rTstartraudio_in_sample_rateaudio_out_sample_rate_connectrVrrYs rDrzGrokRealtimeLLMService.startsO gmE""" !!%"<"Y>YZmmo #s!AA=AAAActKt||d{|jd{y77w)zStop the service and close WebSocket connection. Args: frame: The end frame triggering service shutdown. N)rTstop _disconnectrs rDrzGrokRealtimeLLMService.stops6 gl5!!!    " 848688ctKt||d{|jd{y77w)zCancel the service and close WebSocket connection. Args: frame: The cancel frame triggering service cancellation. N)rTcancelrrs rDrzGrokRealtimeLLMService.cancels6 gnU###    $ rcKt|||d{t|trndt|tr%|j |j d{n/t|tr'|js|j|d{nt|tr|jd{nt|tr|j|d{nt|tr|j|d{n{t|t r|j#d{nRt|t$r|j'|d{n(t|t(r|j+d{|j-||d{y77T777777Y727w)zProcess incoming frames from the pipeline. Args: frame: The frame to process. direction: The direction of frame flow in the pipeline. N)rT process_frame isinstancerr_handle_contextcontextrr_send_user_audiorrr!rr"rrrr_handle_messages_appendr_send_session_updater)rVrrrYs rDrz$GrokRealtimeLLMService.process_frameskg#E9555 e/ 0   /&&u}}5 5 5 1 2++++E222 0 1++- - - 7 844U; ; ; 7 844U; ; ; 6 7335 5 5 5 6..u5 5 5 / 0++- - -ooeY///- 6 63 - ; ; 5 5 -/sGF-AGF07GF3(G=F6>)G'F8()GF:(G:F<;)G$F>%(G GG'G(G0G3G6G8G:G<G>GGGrcK|js:||_|jdd{|jd{y||_|jdd{y7?7)7 w)zHandle LLM context updates.Fsend_new_resultsNT)r!_process_completed_function_calls_create_response)rVrs rDrz&GrokRealtimeLLMService._handle_contextsl}}#DM88%8P P P'') ) )#DM88$8O O O Q ) Ps3)A1A+A1A-!A1%A/&A1-A1/A1c6Ktjdyw)z)Handle appending messages to the context.z 66x@ 077 7 *zk  % %j+ >')=> <<>G #++- - - --gllnw.FG8 .s"5B.B*AB.B,)B.,B.cK|jj}|j}|jr9|j |j}|dr |d|_|dr |d|_|j r:t|j tr |j|j |_|jtj|d{y7w)z&Update session settings on the server.toolsrM)sessionN) rvrJget_llm_adapterrget_llm_invocation_paramsrrNrr from_standard_toolsrr3SessionUpdateEvent)rVrKadapterllm_invocation_paramss rDrz+GrokRealtimeLLMService._send_session_update]s>>44*.*>*>*@ ==$+$E$Edmm$T !$W-!6w!?$%9:(=>R(S% >>jE$88HHN$$V%>%>x%PQQQsCC$C"C$cK|j23d{} tj|}|j dk(r/|j dk(r|j|d{X|j dk(r|j|d{|j dk(r|j|d{|j dk(r|j|d{|j dk(r|j|d{|j d k(r |j d k(r|j d k(r|j|d{H|j d k(rY|j d k(r|j|d{|j dk(r|j|d{|j dk(r|j|d{|j dk(r|j|d{|j dk(r|j!|d{+|j dk(r|j#|d{U|j dk(rf|j dk(r|j%|d{|j dk(s|j&j(dvr0t j*|d|j&j,|j/|d{y7#t$r#}t j d|Yd}~.d}~wwxYw7777r7L7777~7W707 77^6yw)z#Handle incoming WebSocket messages.NzFailed to parse server event: pingzconversation.createdzsession.updatedzresponse.createdzresponse.output_audio.deltazresponse.output_audio.donezresponse.content_part.addedzresponse.content_part.donezresponse.output_item.addedzresponse.output_item.donezconversation.item.addedz5conversation.item.input_audio_transcription.completedz response.donez!input_audio_buffer.speech_startedz!input_audio_buffer.speech_stoppedz&response.output_audio_transcript.deltaz&response.function_call_arguments.deltaz%response.function_call_arguments.doneerror)response_cancel_not_active(conversation_already_has_active_response )rr3parse_server_eventrr rr _handle_evt_conversation_created_handle_evt_session_updated_handle_evt_response_created_handle_evt_audio_delta_handle_evt_audio_done#_handle_evt_conversation_item_added/_handle_evt_input_audio_transcription_completed_handle_evt_response_done_handle_evt_speech_started_handle_evt_speech_stopped"_handle_evt_audio_transcript_delta(_handle_evt_function_call_arguments_donercodedebugmessage_handle_evt_error)rVr1evtrs rDrz,GrokRealtimeLLMService._receive_task_handlerus!__8 8 ' //8 xx6!33;;C@@@..66s;;;//77<<<::2237779911#666::9999>>sCCC8866>>sCCCTTJJ3OOO_,44S999@@55c:::@@55c:::EE==cBBBEEDDCCCHHHW$99>>&LLD6399+<+<*=!>?00555q8  !?sCD A;<76D DO9::B I6o-sK M/M-LM-M/L3M/!M"(M/ M (M/3M 4(M/M(M/MA M/M:M/ M )M/5M6)M/M )M/ M  )M/3M#4)M/M&:M/M)M/0AM/ M+ M/M- ML=7M/=MM/M/ M/M/M/M/M/M/M/ M/#M/&M/)M/+M/-M/c@K|jd{y7w)zAHandle conversation.created event - first event after connecting.N)rrVr3s rDr#z7GrokRealtimeLLMService._handle_evt_conversation_createds'')))s c Kyw)z ~chh.>.>-??YZ[&&'Esxx{{TWT\T\]]]  ( ( , ,SXX[[ 9--chhkk:  88==K '/2xxD ,//";"=> > > ( ^ ?s%C E4 E0BE4)E2*E42E4c.K|jd|jdd{|jr|jjnd}|r>|j t |dt |tjd{yy7m7w)z1Handle input audio transcription completed event.rN)result) rEr7 transcriptstriprrr1r)UPSTREAM)rVr3rKs rDr)zFGrokRealtimeLLMService._handle_evt_input_audio_transcription_completeds&&'Es{{TXYYY03~~S^^))+2 //":r3C3EcR''    Z  s"!BBA&B B BBcK|jxs|jj}|r]|jrQt|jxsd|j xsd|jxsd}|j |d{|jd{|jtd{d|_ |jjdk(rRd}|jjrt|jj}|j|d{y|jjD]'}|j!d|j"|d{)y7777L7w)zHandle response.done event.r) prompt_tokenscompletion_tokens total_tokensNfailedzResponse failedrr)usageresponserQr# input_tokens output_tokensstart_llm_usage_metricsstop_processing_metricsrrrstatusstatus_detailsr?rrrErF)rVr3rTtokensrrCs rDr*z0GrokRealtimeLLMService._handle_evt_response_donesK /S\\// U''"#005A"'"5"5":"//41F ..v6 6 6**,,,oo57888+/( <<  ( *)I||** ; ;< //I/6 6 6 LL'' ZD**+I477TXY Y Y Z 7,8 7 Zs[A?E<E2E<E4 E<:E6;A0E<+E8,>E<*E:+E<4E<6E<8E<:E<cpK|jr$|j|jd{yy7w)z$Handle audio transcript delta event.N)rQ#_push_output_transcript_text_framesr5s rDr-z9GrokRealtimeLLMService._handle_evt_audio_transcript_deltas- 99::399E E E  Es +646textcKt|}d|_|j|d{t|tj }d|_|j|d{y7@7w)NF) aggregated_byT)rappend_to_contextrr rSENTENCEincludes_inter_frame_spaces)rVr_llm_text_frametts_text_frames rDr^z:GrokRealtimeLLMService._push_output_transcript_text_framesse&d++0(oon---&d/:R:RS592oon--- . .s!'A.A*:A.$A,%A.,A.c@K tj|j}|jj |j }|r|j|j =t |j|j |j|g}|j|d{tjd|jytjd|j y7J#t$r"}tjd|Yd}~yd}~wwxYww)z*Handle function call arguments done event.)r tool_call_id function_name argumentsNzProcessed function call: z,No tracked function call found for call_id: z+Failed to process function call arguments: )r loadsrjrrerDr*rr^run_function_callsr r0rrr)rVr3argsfunction_call_itemfunction_callsrs rDr.z?GrokRealtimeLLMService._handle_evt_function_call_arguments_done0s L::cmm,D!%!=!=!A!A#++!N !00=( $ %([[&)hh"& "--n=== 8 CD!Mckk][\>  L LLFqcJ K K LsMDBC0#C.$&C0 D "C0-D.C00 D9DDDDcK|jd{|jtd{|jd{y7:77 w)z%Handle speech started event from VAD.N)rbroadcast_framer!broadcast_interruptionr5s rDr+z1GrokRealtimeLLMService._handle_evt_speech_startedJsL33555""#;<<<))+++ 6<+s1AAAAA A AAAcK|jd{|jd{|jtd{y7:7$7 w)z%Handle speech stopped event from VAD.N)start_ttfb_metricsstart_processing_metricsrqr"r5s rDr,z1GrokRealtimeLLMService._handle_evt_speech_stoppedPsL%%'''++---""#;<<< (-77 w)z9Reset the conversation by disconnecting and reconnecting.zResetting Grok conversationNTFr)r r0rrrrrs rDreset_conversationz)GrokRealtimeLLMService.reset_conversation^sc 23   -1*44e4LLLmmo ! Ms3)A0A* A0 A, A0$A.%A0,A0.A0chK|jsd|_y|j}|jrt j d|j |j|j|j}|d}|D]T}tj|}d|j|jj<|j|d{V|jd{d|_t j d|j!t#d{|j%d{|j'd{|jtj(tj*dd g  d{y777|7f7P7w) zCreate an assistant response.TNz4Setting up Grok conversation with initial messages: messagesrCFzCreating Grok responser_r) modalities)rU)rrrrr r0get_messages_for_loggingrrr3ConversationItemCreateEventrrCrFrrrrrurtrResponseProperties)rVrrrzrCr3s rDrz'GrokRealtimeLLMService._create_responsehs&&37D 0 *.*>*>*@  - - LLF33DMMBCE  %,$E$Edmm$T !,Z8H  288dC=A--chhkk:,,S111 2 ++- - -16D . -.oo79:::++---%%'''$$  & &22vw>OP    2 - ;-' smCF2F&F20F(1||jvsM|r+d}|j ||jdd{|jj ||r|j d{yy7=7w)zAProcess completed function calls and send results to the service.FrGcontent IN_PROGRESSrhTN)r get_messagesrer_send_tool_resultaddr)rVrsent_new_resultr1rhs rDrz8GrokRealtimeLLMService._process_completed_function_callss}}113 AG{{6"w{{9'='N&{{>: L8R8R$R'*."44\7;;yCYZZZ..22<@ A '') ) ) [ *s:1CC CC,(CC6C C CCcK|jrytj|jj d}|j t j|d{y7w)zSend user audio to Grok.Nzutf-8)r)rr< b64encoderdecoderr3InputAudioBufferAppendEvent)rVrpayloads rDrz'GrokRealtimeLLMService._send_user_audiosR  - - ""5;;/66w?$$V%G%Gg%VWWWsA$A.&A,'A.rhrJcKtjd|tj|}|j tj |d{y7w)z Send a tool call result to Grok.function_call_output)rrDrr{N)r3ConversationItemr r rr~)rVrhrJrCs rDrz(GrokRealtimeLLMService._send_tool_resultsI&&' ::f%  $$V%G%GT%RSSSsAAAA user_paramsassistant_paramsrrcVtj|}d|_t|||S)aNCreate context aggregators for the Grok Realtime service. Args: context: The LLM context. user_params: User aggregator parameters. assistant_params: Assistant aggregator parameters. Returns: LLMContextAggregatorPair for user and assistant context aggregation. Fr)r$from_openai_contextexpect_stripped_wordsr')rVrrrs rDcreate_context_aggregatorz0GrokRealtimeLLMService.create_context_aggregators2"00916.' ?O  rC)N)Ir;r<r=r>rFSettingsr@r adapter_classr?r r3r`boolrrrrArrrrrrrrrrrrrrrrrr)rr$rr ClientEventrrrrrrrr#r%r$r&r'r(r)r*r-r^r.r+r,r2rxrrrrr&r%r(r'rrrrss@rDrurus_ 'H&&+M 5AE6:#(_E_E _E %V%=%=> _E 23 _E!_EBd*T*SXc]:  D 5 G , RS,,-0,KN, , P$cs*!!!+!00>0>PZPWAV-?-?A#"V(]&R0:x* *%,5 ?* Z8F .c.&L4, = U# J** XTCTT0G/H9U9W  ! -  7  "  rCru)Or>r<r r; dataclassesrrrr]typingrrrr r logurur %pipecat.adapters.schemas.tools_schemar /pipecat.adapters.services.grok_realtime_adapterr pipecat.frames.framesrrrrrrrrrrrrrrrrrrr r!r"pipecat.metrics.metricsr#*pipecat.processors.aggregators.llm_contextr$+pipecat.processors.aggregators.llm_responser%r&5pipecat.processors.aggregators.llm_response_universalr'1pipecat.processors.aggregators.openai_llm_contextr("pipecat.processors.frame_processorr)pipecat.services.llm_servicer*r+pipecat.services.settingsr,r-r.r/r0pipecat.utils.timer1rIr3websockets.asyncio.clientr4rModuleNotFoundErrorrrrr6rFrurBrCrDrs  (255=R.2AO=H0,F       ZkZ ZzK  ZK  k,FLL;qc"#FLL]^ &qc* ++,s4C%%D!*2DD!