qi(dZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZddlmZddlmZddlmZmZddlmZmZdd lmZmZmZmZmZm 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-m.Z.m/Z/dd l0m1Z1m2Z2ddl3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:m;Z;ddlZ>ddl?m@Z@mAZAmBZBmCZCmDZDddlEmFZFdejd< ddlHmIZIddlJmKZKddlLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTdeIj_VGdde>Z[Gd d!e=Z\eGd"d#Z]Gd$d%e1Z^Gd&d'eZ_eGd(d)eAZ`Gd*d+e;Zay#eW$r7ZXejdeXejdeZdeXdZX[XwwxYw),zGoogle Gemini integration for Pipecat. This module provides Google Gemini integration for the Pipecat framework, including LLM services, context management, and message aggregation. N) dataclassfield)Any AsyncIteratorDictListLiteralOptional)logger)Image) BaseModelField)GeminiLLMAdapterGeminiLLMInvocationParams)AssistantImageRawFrame AudioRawFrameFrameFunctionCallCancelFrameFunctionCallInProgressFrameFunctionCallResultFrameLLMContextFrameLLMFullResponseEndFrameLLMFullResponseStartFrameLLMMessagesAppendFrameLLMMessagesFrameLLMThoughtEndFrameLLMThoughtStartFrameLLMThoughtTextFrame) LLMTokenUsage) LLMContext)LLMAssistantAggregatorParamsLLMUserAggregatorParams)OpenAILLMContextOpenAILLMContextFrame)FrameDirection)LLMSearchResponseFrame)!update_google_client_http_options)FunctionCallFromLLM LLMService) OpenAIAssistantContextAggregatorOpenAIUserContextAggregator) NOT_GIVEN LLMSettings _NotGiven_warn_deprecated_paramis_given) traced_llmfalseGRPC_ENABLE_FORK_SUPPORT)genai)DeadlineExceeded)BlobContent FunctionCallFunctionResponseGenerateContentConfigGenerateContentResponse HttpOptionsPartiPz Exception: zHIn order to use Google AI, you need to `pip install pipecat-ai[google]`.zMissing module: ceZdZdZdefdZy)GoogleUserContextAggregatoraGoogle-specific user context aggregator. Extends OpenAI user context aggregator to handle Google AI's specific Content and Part message format for user messages. .. deprecated:: 0.0.99 `OpenAIUserContextAggregator` is deprecated and will be removed in a future version. Use the universal `LLMContext` and `LLMContextAggregatorPair` instead. See `OpenAILLMContext` docstring for migration guide. aggregationcnK|jjtdt|gyw)zAdd the aggregated user text to the context as a Google Content message. Args: aggregation: The aggregated user text to add as a user message. usertextrolepartsN_context add_messager7r=selfr@s M/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/google/llm.pyhandle_aggregationz.GoogleUserContextAggregator.handle_aggregationls) !!'vd >T=U"VW35N)__name__ __module__ __qualname____doc__strrNrMr?r?^s XCXrVr?cTeZdZdZdefdZdefdZdefdZ de fdZ ded ed e fd Z y ) GoogleAssistantContextAggregatoraGoogle-specific assistant context aggregator. Extends OpenAI assistant context aggregator to handle Google AI's specific Content and Part message format for assistant responses and function calls. .. deprecated:: 0.0.99 `GoogleAssistantContextAggregator` is deprecated and will be removed in a future version. Use the universal `LLMContext` and `LLMContextAggregatorPair` instead. See `OpenAILLMContext` docstring for migration guide. r@cnK|jjtdt|gyw)zHandle aggregated assistant text response. Args: aggregation: The aggregated text response from the assistant. modelrCrENrHrKs rMrNz3GoogleAssistantContextAggregator.handle_aggregations) !!'wt?U>V"WXrOframec hK|jjtdtt |j |j |jg|jjtdtt|j |j ddi gy w) zzHandle function call in progress frame. Args: frame: Frame containing function call details. rZ)idnameargs function_callrErBresponse IN_PROGRESS)r]r^rbfunction_responseN) rIrJr7r=r8 tool_call_id function_name argumentsr9rLr[s rM handle_function_call_in_progresszAGoogleAssistantContextAggregator.handle_function_call_in_progresss !! &2$118K8KRWRaRa'   !! *:$11!&!4!4&0-%@+  sB0B2cK|jr:|j|j|j|jd{y|j|j|jdd{y757w)ztHandle function call result frame. Args: frame: Frame containing function call result. N COMPLETED)result_update_function_call_resultrgrfris rMhandle_function_call_resultzeZdZUdZeed<eed<defdZdefdZy)GoogleContextAggregatorPairaPair of Google context aggregators for user and assistant messages. .. deprecated:: 0.0.99 `GoogleContextAggregatorPair` is deprecated and will be removed in a future version. Use the universal `LLMContext` and `LLMContextAggregatorPair` instead. See `OpenAILLMContext` docstring for migration guide. Parameters: _user: User context aggregator for handling user messages. _assistant: Assistant context aggregator for handling assistant responses. _user _assistantreturnc|jS)zmGet the user context aggregator. Returns: The user context aggregator instance. )r|rLs rMrBz GoogleContextAggregatorPair.users zzrVc|jS)zwGet the assistant context aggregator. Returns: The assistant context aggregator instance. )r}rs rM assistantz%GoogleContextAggregatorPair.assistants rVN) rPrQrRrSr?__annotations__rXrBrrUrVrMr{r{s/  '&001;rVr{c eZdZdZ ddeeedeeedeeffd Zede ddfd Z defd Z defd Z dee eeffd Zdd dedeeefdedefdZdd deedefdZdZdefdZdZxZS)GoogleLLMContextaGoogle AI LLM context that extends OpenAI context for Google-specific formatting. This class handles conversion between OpenAI-style messages and Google AI's Content/Part format, including system messages, function calls, and media. .. deprecated:: 0.0.99 `GoogleLLMContext` is deprecated and will be removed in a future version. Use the universal `LLMContext` and `LLMContextAggregatorPair` instead. See `OpenAILLMContext` docstring for migration guide. Nrutools tool_choicec8t||||d|_y)zInitialize GoogleLLMContext. Args: messages: Initial messages in OpenAI format. tools: Available tools/functions for the model. tool_choice: Tool choice configuration. )rurrN)super__init__system_message)rLrurr __class__s rMrzGoogleLLMContext.__init__s! (%[Q"rVobjr~ct|trCt|ts3tjd|t|_|j |S)zUpgrade an OpenAI context to a Google context. Args: obj: OpenAI LLM context to upgrade. Returns: GoogleLLMContext instance with converted messages. zUpgrading to Google: ) isinstancer#rr debugr!_restructure_from_openai_messages)rs rMupgrade_to_googlez"GoogleLLMContext.upgrade_to_googlesE c+ ,ZEU5V LL06 7,CM  1 1 3 rVcB||jdd|jy)z{Set messages and restructure them for Google format. Args: messages: List of messages to set. N) _messagesr)rLrus rM set_messageszGoogleLLMContext.set_messagess %q ..0rVcg}|D]I}t|tr|j|%|j|}|9|j|K|jj |y)zAdd messages to the context, converting to Google format as needed. Args: messages: List of messages to add (can be mixed formats). N)rr7appendfrom_standard_messagerextend)rLruconverted_messagesmsg converteds rM add_messageszGoogleLLMContext.add_messages(sl  9C#w'"))#.!66s; (&--i8 9 01rVcg}|jD]?}|j} d|vr|dD]}d|vsd|dd<|j |A|S#t$r"}tjd|Yd}~;d}~wwxYw)zGet messages formatted for logging with sensitive data redacted. Returns: List of messages in a format ready for logging. rG inline_dataz...datazError: N)ru to_json_dict Exceptionr rr)rLmsgsrxrryes rMget_messages_for_loggingz)GoogleLLMContext.get_messages_for_logging=s }} G&&(C ,c> #G @(D0:?D/7@ KK    , wqc]++ ,sA A A>A99A>rCformatsizeimagerDc Ztj}tj|||j |dg}|r|j t ||j t td|j|jtd|y ) aAdd an image message to the context. Args: format: Image format (e.g., 'RGB', 'RGBA'). size: Image dimensions as (width, height). image: Raw image bytes. text: Optional text to accompany the image. JPEG)rrC image/jpeg mime_typerrrBrEN) ioBytesIOr frombytessaverr=r6getvaluerJr7)rLrrrrDbufferrGs rMadd_image_frame_messagez(GoogleLLMContext.add_image_frame_messagePs{ e,11&1H  LL4 ) Td\HY&Z[\ fE:;rVz Audio follows audio_framesc|sy|dj}|dj}g}djd|D}|jt ||jt t dt |j||dt||z |jtd | y) zAdd audio frames as a message to the context. Args: audio_frames: List of audio frames to add. text: Text description of the audio content. NrrVc34K|]}|jywN)audio).0r[s rM z.us> >srCz audio/wavrrrBrE) sample_rate num_channelsjoinrr=r6bytescreate_wav_headerlenrJr7)rLrrDrrrGrs rMadd_audio_frames_messagez)GoogleLLMContext.add_audio_frames_messagees "1o11 #A33 xx>>>  Tt_%  ) 22; bRUVZR[\_cc   fE:;rVc |d}|jdg}|dk(rFt|tr||_yt|trdj d|D|_y|dk(rd}g}|jd rQ|d D]G}|j tt|d d tj|d d  In]|dk(rYd} tj|d}t|tr|}nd|i}|j ttd|nt|tr|j t|nt|tr|D]} | ddk(r|j t| d*| ddk(s3| dd} | jdr&| jddjddnd} |j tt!| t#j$| jdd !t'||"}|S#t$r}d|di}Yd}~Kd}~wwxYw)#aConvert standard format message to Google Content object. Handles conversion of text, images, and function calls to Google's format. System messages are stored separately and return None. Args: message: Message in standard format. Returns: Content object with role and parts, or None for system messages. Examples: Standard text message:: { "role": "user", "content": "Hello there" } Converts to Google Content with:: Content( role="user", parts=[Part(text="Hello there")] ) Standard function call message:: { "role": "assistant", "tool_calls": [ { "function": { "name": "search", "arguments": '{"query": "test"}' } } ] } Converts to Google Content with:: Content( role="model", parts=[Part(function_call=FunctionCall(name="search", args={"query": "test"}))] ) System message returns None and stores content in self.system_message. rFcontentsystem c3PK|]}|jddk(s|d yw)typerDN)get)rrys rMrz9GoogleLLMContext.from_standard_message..s)/%)8HF8RDL/s& &NrrZ tool_callsfunctionr^rh)r^r_r`toolrttool_call_result)r^rbrdrCrrD image_urlurldata::;rr,rrrE)rrrTrlistrrr=r8rvloadsdictrr9 startswithsplitr6base64 b64decoder7) rLrxrFrrGtcrb response_dictrcrrs rMrz&GoogleLLMContext.from_standard_messagesSdv++i, 8 '3'&-#  GT*&)hh/-4/'# [ D ;;| $l+  &2!#J!7!%BzN;,G!H' V^D >::gi&89h-$,M%,h$7M LL&6/!.'  % LL7+ ,  & V9&LL1V9!56vY+-K./C;>>>';R #q)//4Q7XdLL(,*3%+%5%5ciinQ6G%H) $t51C >!(')*< =  >s/H:: IIIc |jgd}|ddk(rd|d<|jD]}|jr"|djd|jd2|jrlt j |jjjd}|djd d d |jjd |id |jrxt|jdr|jjni}|jjd|jjtj|ddg|d<.|j s"} } ] } ] )rFrrFrZrrrD)rrDzutf-8rrrz;base64,)rrr_r)r^rh)r]rrrrrbrf)rFrGrDrrr b64encoderdecoderrahasattrr_r^rvrwrerb)rLrrryencodedr_resps rMto_standard_messagesz%GoogleLLMContext.to_standard_messagessTxxB/ v;' !%CKII 2DyyI%%vtyy&IJ!! **4+;+;+@+@AHHQI%% +&+uT5E5E5O5O4PPXY`Xa-b%c ##29$:L:Lf2Ut))..[]#0055 *$($6$6$;$;)-D)9% %L!''$F t55zB**33 '+&<&<&A&AN#!%D!1IA 2F9~Iu rVcd|_g}|jD]I}t|tr|j |%|j |}|9|j |K||jddt d|jD}|jr=|s;|jj tdt|jg|jDcgc]}|js|c}|_ycc}w)aRestructures messages to ensure proper Google format and message ordering. This method handles conversion of OpenAI-formatted messages to Google format, with special handling for function calls, function responses, and system messages. System messages are added back to the context as user messages when needed. The final message order is preserved as: 1. Function calls (from model) 2. Function responses (from user) 3. Text messages (converted from system messages) Note: System messages are only added back when there are no regular text messages in the context, ensuring proper conversation continuity after function calls. Nc3K|]r}t|jdk(xrTt|jdddxr8t|jddd xrt|jddd tyw)rrrDNrare)rrGgetattr)rrs rMrzEGoogleLLMContext._restructure_from_openai_messages..s#   Na  E ! fd3 ECIIaL/4@@ ECIIaL*=tDD E# sA8A:rBrCrE) rrrr7rranyr=rG)rLrrxrhas_regular_messagesms rMrz2GoogleLLMContext._restructure_from_openai_messagesus"#~~ 5G'7+"))'2227;I$")))4 5/q ## ~~ #     '; NN ! !'vdH[H[>\=]"^ _&*^^?qww!??s $D6DNNN)rPrQrRrSr rrr staticmethodr#rrrrrTrrtupleintrrrrrrrr __classcell__rs@rMrrs *.&*&* #4:&#T ##d^ #" / 4F  1T12T2*$tCH~*>(PT<<$)#s(O<zGoogleLLMSettings.syrVdefault_factorythinkingct||}t|jr4t |jt rt di|j|_|S)zConvert a plain dict to settings, coercing thinking dicts. For backward compatibility, a ``thinking`` value that is a plain dict is converted to a :class:`GoogleThinkingConfig`. rU)r from_mappingr0rrrr)clssettingsinstancers rMrzGoogleLLMSettings.from_mappingsL7'1 H%% &:h6G6G+N 4 Ix7H7H IH rV) rPrQrRrSrrrr.r classmethodrrrs@rMrrs2 27GX1YH"Y.Y  rVrc,eZdZUdZeZeed<eZe Z Gdde Z ddddddddde dee d ee d eed ee d eeee efd eee efdeeffdZdefdZdZ d(deezdeed ee dee fdZ d)d ee d eed eee efdee effdZdee effdZdedeefdZ dedeefdZ!dedeefdZ"e#deezfdZ$de%de&ffd Z'fd!Z(fd"Z)d#Z*e+e,d$ded%e+d&e,de-fd'Z.xZ/S)*GoogleLLMServicezGoogle AI (Gemini) LLM service implementation. This class implements inference with Google's AI models, translating internally from an OpenAILLMContext or a universal LLMContext to the messages format expected by the Google AI model. _settingsceZdZUdZeddZeeed<eddd Z ee ed <edd Z eeed <eddd Z ee ed<edZ eeed<eeZeeeefed<y)GoogleLLMService.InputParamsaInput parameters for Google AI models. .. deprecated:: 0.0.105 Use ``settings=GoogleLLMSettings(...)`` instead. Parameters: max_tokens: Maximum number of tokens to generate. temperature: Sampling temperature between 0.0 and 2.0. top_k: Top-k sampling parameter. top_p: Top-p sampling parameter between 0.0 and 1.0. thinking: Thinking configuration with thinking_budget, thinking_level, and include_thoughts. Used to control the model's internal "thinking" process used before generating a response. Gemini 2.5 series models use thinking_budget; Gemini 3 models use thinking_level. If this is not provided, Pipecat disables thinking for all models where that's possible (the 2.5 series, except 2.5 Pro), to reduce latency. extra: Additional parameters as a dictionary. r)rge max_tokensNgg@)rrle temperaturertop_kg?top_prrrextra)rPrQrRrSrrr rrrfloatrrrrrrrrTrrUrVrM InputParamsrs &%*$1$= HSM=',Tcc'J Xe_J$Ta8x}8!&t!DxD383F(/0F*/*ExS#X'ErVrN)rZparamsr system_instructionr tool_config http_optionsapi_keyrZrr rrrrc xtddddddddddddi } |tdtd|| _|tdtd|| _|tdt|s|j| _|j | _|j | _|j| _|j| _t|jtr|j| _ || j|t |8d d | i| ||_t!||_||_||_|j)y) a1Initialize the Google LLM service. Args: api_key: Google AI API key for authentication. model: Model name to use. .. deprecated:: 0.0.105 Use ``settings=GoogleLLMSettings(model=...)`` instead. params: Optional model parameters for inference. .. deprecated:: 0.0.105 Use ``settings=GoogleLLMSettings(...)`` instead. settings: Runtime-updatable settings for this service. When both deprecated parameters and *settings* are provided, *settings* values take precedence. system_instruction: System instruction/prompt for the model. .. deprecated:: 0.0.105 Use ``settings=GoogleLLMSettings(system_instruction=...)`` instead. tools: List of available tools/functions. tool_config: Configuration for tool usage. http_options: HTTP options for the client. **kwargs: Additional arguments passed to parent class. gemini-2.5-flashNrF) rZrrrrrfrequency_penaltypresence_penaltyseedfilter_incomplete_user_turnsuser_turn_completion_configrrrZrrr rU)rr/rZrrrrrrrrr apply_updaterr_api_keyr' _http_options_tools _tool_config create_client) rLr rZrr rrrrkwargsdefault_settingsrs rMrzGoogleLLMService.__init__ sGP-$#"!).(, "   "7,=w G%*  "  ) "#79JL` a2D  /   "8-> ?.4.?.? +/5/A/A ,)/ &)/ &,2OO )fllD1-3\\$*    ) )( 3 ="2=f= >|L ' rVr~cy)zCheck if the service can generate usage metrics. Returns: True, as Google AI provides token usage metrics. TrUrs rMcan_generate_metricsz%GoogleLLMService.can_generate_metricsgs rVcdtj|j|j|_y)z@Create the Gemini client instance. Subclasses can override this.)r rN)r4Clientr)r*_clientrs rMr-zGoogleLLMService.create_clientos||DMMHZHZ[ rVcontextrcKg}g}g}t|tr1|j}|j|}|d}|d}|d}n>tj |}|j }t|dd}|jxsg}||rtj|d|}|j||r|nd} ||| d<td i| } |jjjj!|j"j$|| d{} | j&r[| j&d j(rB| j&d j(j*D]} | j,s| j,cSy7lw) aVRun a one-shot, out-of-band (i.e. out-of-pipeline) inference with the given LLM context. Args: context: The LLM context containing conversation history. max_tokens: Optional maximum number of tokens to generate. If provided, overrides the service's default max_tokens setting. system_instruction: Optional system instruction to use for this inference. If provided, overrides any system instruction in the context. Returns: The LLM's response as a string, or None if no response is generated. rurrrN\: Both system_instruction and a system message in context are set. Using system_instruction.)rrmax_output_tokensrZcontentsconfigrrU)rr get_llm_adapterget_llm_invocation_paramsrrrurrr warning_build_generation_paramsr:r4aiomodelsgenerate_contentrrZ candidatesrrGrD) rLr5rrrurradapterrgeneration_paramsgeneration_configrbrys rM run_inferencezGoogleLLMService.run_inferencess$ gz ***,G070Q0QRY0ZFj)H01F7OE&88AG''HW&6=FMM'RE  )f11(F!99%eU:   !5? 1 21F4EF))00AA..&&$B     8#6#6q#9#A#A ++A.66<< %9999$ % sDFFAF5Fc||jj|jj|jj|jj||dj Dcic] \}}||| }}}|jj r)|jj jd|d<|jjr%|j|jj|Scc}}w)aWBuild generation parameters for Google AI API. Args: system_instruction: Optional system instruction to use. tools: Optional list of tools to include. tool_config: Optional tool configuration. Returns: Dictionary of generation parameters with None values filtered out. )rrrrr8rrT) exclude_unsetthinking_config) rrrrritemsr model_dumprupdate)rLrrrkvrEs rMr?z)GoogleLLMService._build_generation_paramss('9#~~99----%)^^%>%>*eg  1} qD     >> " "37>>3J3J3U3U"4V4 / 0 >>    $ $T^^%9%9 :  /  s,C:rEc |jjjdsyd|jjvryd|vryd|jdid<y#t$r"}t j d|Yd}~yd}~wwxYw)Nr"rrJrrz!Failed to unset thinking budget: )rrZr setdefaultrr error)rLrErs rM_maybe_unset_thinking_budgetz-GoogleLLMService._maybe_unset_thinking_budgets B>>''223EF$..... $55UV  ( ():B ?@Q R B LLr+r,r?rSr:start_ttfb_metricsr4r@rAgenerate_content_streamrZ)rLrTrurrrrErFs rM_stream_contentz GoogleLLMService._stream_contentsF'z2 >> , ,1DEY1Z NN&22  NN - - Z1DEY1Z  w ''0E [[KKE   ++K!991#:  ))*;<1F4EF%%'''\\%%,,DD..&&$E    ( s%CD1D-A D1(D/)D1/D1cKtj|d|jd|jt |j |j|j }|j|d{S7w)Nz-: Generating chat from LLM-specific context [] | )rurr)r rrrrrurrX)rLr5rs rM _stream_content_specific_contextz1GoogleLLMService._stream_content_specific_contexts  fA'BXBXAYY]^e^~^~_A^B C +%%&55--  ))&1111sA6A?8A=9A?c K|j}|j|}tj|d|dd|j ||j |d{S7w)Nz*: Generating chat from universal context [rrZ)r<r=r rrrX)rLr5rDrs rM!_stream_content_universal_contextz2GoogleLLMService._stream_content_universal_context,s&&(,3,M,Mg,V f>vFZ?[>\\`ahbBbBCJbKaL M ))&1111sA%A.'A,(A.cK|jtd{d}d}d}d}d}d}d} t|tr|j |n|j |d{} g} | 23d{} |j d{| jr| jjxsd}| jjxsd}| jjxsd}| jjxsd}| jjxsd}| js| jD]|} | jr#| jjr | jjD]} d}| j r| j"rp|jt%d{|jt'| j d{|jt)d{n|| j z }|j+| j d{nd| j,r| j,}|j.xst1t3j4}t7j8d|j:d|| j=t?|||j:|j@xsin| jBr| jBjDrtGjHtKjL| jBjD}|jtO|jQ|jRd| jBjD| jBjTd{| jVs4i}| j,r||d<nY| jBr&| jBjDr| jB|d <n'| j ||d <nt7jXd |s|jt[|j]j_d | jV|d gd{| j`sB| j`jbsZ| j`}|jdr|jdjfnd}ti|jbr |jbngDcgc]\}}|jjr|jjjlnd|jjr|jjjnnd|jpr |jpngDcgc]M}|jrr?||jrvr1|jtr|jtj nd|jvdOc}d}}}}||d}J77V7L7777777;7qcc}wcc}}}w6|jy| d{7nY#tz$r|j}dd{7Yn4t~$r)}|jd||d{7Yd}~nd}~wwxYw|r>t|tr.t||d|d}|j|d{7|jt|||||d{7|jtd{7y#|r>t|tr.t||d|d}|j|d{7|jt|||||d{7|jtd{7wxYww)NrzFunction call: r)r5rfrgrhRGB)rrr original_dataoriginal_mime_typerarrDz.Thought signature found on unhandled Part typethought_signature)r signaturebookmark)rD confidence)site_uri site_titleresults)rendered_contentoriginson_completion_timeoutzUnknown error occurred: ) error_msg exceptionrkrj) search_resultrkrj) prompt_tokenscompletion_tokens total_tokenscache_read_input_tokensreasoning_tokens)F push_framerrr#r[r]stop_ttfb_metricsusage_metadataprompt_token_countcandidates_token_counttotal_token_countcached_content_token_countthoughts_token_countrCrrGrDthoughtrrr_push_llm_textrar]rTuuiduuid4r rr^rr(r_rrr openrrrtobytesrrrcr>rr<create_llm_specific_messagegrounding_metadatagrounding_chunkssearch_entry_pointrj enumerateweburititlegrounding_supportsgrounding_chunk_indicessegmentconfidence_scoresrun_function_callsr5_call_event_handlerr push_errorrr&start_llm_usage_metricsrr)rLr5rprqrrrsrtraccumulated_textrbfunction_callschunk candidateryfunction_call_idrarrerrjindexgrounding_chunkgrounding_supportrkrllm_search_frames rM_process_contextz!GoogleLLMService._process_context8soo79:::  "#!s =g'7855g>;;GDH  N'Q Q e,,...''$)$8$8$K$K$PqM(-(<(<(S(S(XWX%#(#7#7#I#I#NQL.3.B.B.].].bab+',';';'P'P'UTU$''!&!1!1~I ((Y->->-D-D$-$5$5$;$;U&D/3,#yy#'<<+///:N:P*Q$Q$Q*.//:Mdii:X*Y$Y$Y*.//:L:N*O$O$O$4 $A$4*.*=*=dii*H$H$H!%!3!3040B0B 3@3C3C3Xs4::N>N>S>S3T(U&*oo$:.3mmo-2ZZ/46:6F6F6K6K;?;K;K;U;U %&'"!"!"2 $55 ,.#'#5#5@PH_$=%)%5%5$:J:J:O:O>B>N>NH]$;%)YY%:8HHV$4$*NN3c$d#+*.//(>040D0D0F0b0b@SEIE[E[DL5612-. )* +& %& %&SU&p"44%88II%88EFEYEYA00AA_c)2;D676H6H 2 2b;-##,!7'$3#6#6-<,?,?,C,C%)#2#6#6/>.A.A.G.G%)AB@T@T(<()X1W%5W6W%9X WD#X1W 2+XW  X>W ?3X2W 3E%XW X+A/XA X%W &X;XAX*A*W AW&W -X;]4>XW%XX X XXXXW X:W=;X[%YX!Y$[%&Y.YY Y [%Y[%:]4Z']4<Z?=!]4[!]4%;]1 \#!']1]  !]1*]-+]11]4r[ directioncKt|||d{d}t|tr tj |j }n]t|tr |j }n@t|trt |j}n|j||d{|r|j|d{yy77#7 w)zProcess incoming frames and handle different frame types. Args: frame: The frame to process. direction: Direction of frame processing. N) r process_framerr$rrr5rrrurur)rLr[rr5rs rMrzGoogleLLMService.process_framesg#E9555 e2 3&88GG  /mmG / 0'u~~6G//%3 3 3 ''0 0 0 ! 6 4 1s4CCBC&C 'CC C C CctKt||d{|jd{y77w)z-Override stop to gracefully close the client.N)rstop _close_clientrLr[rs rMrzGoogleLLMService.stops4gl5!!!  """ ""848688ctKt||d{|jd{y77w)z/Override cancel to gracefully close the client.N)rcancelrrs rMrzGoogleLLMService.cancels4gnU###  """ $"rcK |jjjd{y7#t$rYywxYwwr)r4r@acloserrs rMrzGoogleLLMService._close_clients8 ,,""))+ + +   s,A'313A3 ?A?A) user_paramsassistant_paramsrrc|j|jt|trtj |}t ||}t||}t||S)aCreate Google-specific context aggregators. Creates a pair of context aggregators optimized for Google's message format, including support for function calls, tool usage, and image handling. Args: context: The LLM context to create aggregators for. user_params: Parameters for user message aggregation. assistant_params: Parameters for assistant message aggregation. Returns: GoogleContextAggregatorPair: A pair of context aggregators, one for the user and one for the assistant, encapsulated in an GoogleContextAggregatorPair. .. deprecated:: 0.0.99 `create_context_aggregator()` is deprecated and will be removed in a future version. Use the universal `LLMContext` and `LLMContextAggregatorPair` instead. See `OpenAILLMContext` docstring for migration guide. )r)r|r}) set_llm_adapterr<rr#rrr?rXr{)rLr5rrrBrs rMcreate_context_aggregatorz*GoogleLLMService.create_context_aggregator%s^6  4 4 67 g/ 0&88AG+7;G4WEUV *)LLrV)NNr)0rPrQrRrSrSettingsrr adapter_classrThinkingConfigr rrTr rrrr<rrr1r-r r#rrGr?rSrrr;rXr[r]r1rrr%rrrrr"r!r{rrrs@rMrrs}!H  %M*NFiF> $(,04,00404.2XX} X % X ,- X%SMXT#s(^,-Xd38n-X{+Xtd\%),0 B..BSMB%SM B # BL-1 $04 (!$SM(!~(!d38n- (! c3h (!TBd38nB") #<) . /) V 2' 2 . / 2 2! 2 . / 2=.>.K==B11>14# # 0G/H9U9W $M!$M- $M 7 $M % $MrVr)brSrrrvosr dataclassesrrtypingrrrrr r logurur PILr pydanticr r(pipecat.adapters.services.gemini_adapterrrpipecat.frames.framesrrrrrrrrrrrrrrpipecat.metrics.metricsr*pipecat.processors.aggregators.llm_contextr +pipecat.processors.aggregators.llm_responser!r"1pipecat.processors.aggregators.openai_llm_contextr#r$"pipecat.processors.frame_processorr%pipecat.services.google.framesr&pipecat.services.google.utilsr'pipecat.services.llm_servicer(r)pipecat.services.openai.llmr*r+pipecat.services.settingsr,r-r.r/r0(pipecat.utils.tracing.service_decoratorsr1environgoogler4google.api_core.exceptionsr5google.genai.typesr6r7r8r9r:r;r<r= _api_clientREAD_BUFFER_SIZEModuleNotFoundErrorrrRrr?rXr{rrrrrUrVrMrs  (DD%` 2A>AKH@*1 %&,;   *9E&X"=X.WX'GWXt  Dt@'t@n ;9;B   ,h Mzh MS,FLL;qc"#FLL[\ &qc* ++,s 1EF2F  F