qig,jdZddlZddlmZddlmZmZmZddlm Z ddl m Z ddl m Z mZmZmZmZmZmZddlmZ dd lmZdd lmZdd lmZdd lmZdd lmZeGddeZ$Gdde Z%y#e $r7Z!e jDde!e jDde#de!dZ![!wwxYw)zService for accessing Gemini Live via Google Vertex AI. This module provides integration with Google's Gemini Live model via Vertex AI, supporting both text and audio modalities with voice transcription, streaming responses, and tool usage. N) dataclass)ListOptionalUnion)logger) ToolsSchema)GeminiLiveLLMServiceGeminiLiveLLMSettingsGeminiMediaResolutionGeminiModalities HttpOptions InputParamslanguage_to_gemini_language)_warn_deprecated_param)default)GoogleAuthError)Request)Client)service_accountz Exception: zOIn order to use Google Vertex AI, you need to `pip install pipecat-ai[google]`.zMissing module: ceZdZdZy)GeminiLiveVertexLLMSettingsz(Settings for GeminiLiveVertexLLMService.N)__name__ __module__ __qualname____doc__`/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/google/gemini_live/vertex/llm.pyrr-s2rrc eZdZUdZeZeed<dddddddddddddd d eed eed ed ed eedede de deedee e e e fdeedeede dedeeffdZdZedZed eed eedefdZxZS)GeminiLiveVertexLLMServicezProvides access to Google's Gemini Live model via Vertex AI. This service enables real-time conversations with Gemini, supporting both text and audio modalities. It handles voice transcription, streaming audio responses, and tool usage. _settingsNCharonFTz6https://generativelanguage.googleapis.com/v1beta/files) credentialscredentials_pathmodelvoice_idstart_audio_pausedstart_video_pausedsystem_instructiontoolsparamssettings#inference_on_context_initializationfile_api_base_url http_optionsr#r$location project_idr%r&r'r(r)r*r+r,r-r.r/c d|vr tjdtd|j|||_||_||_td"idddddd d d d d d d dd dd dd dddd dtjdddtjdd dididddidi}|tdtd||_ |dk7rtdtd||_| ktdt| sX| j|_| j |_| j"|_| j$|_| j&|_| j(|_| j*|_| j,rt/| j,nd|_| j0|_| j2|_| j4r| j4j7ni|_| j8xsi|_| j:xsd|_| j<xsi|_t?| j@tBr| j@|_ | |jE| tG|d"d ||| | || ||d! |y )#a*Initialize the service for accessing Gemini Live via Google Vertex AI. Args: credentials: JSON string of service account credentials. credentials_path: Path to the service account JSON file. location: GCP region for Vertex AI endpoint (e.g., "us-east4"). project_id: Google Cloud project ID. model: Model identifier to use. .. deprecated:: 0.0.105 Use ``settings=GeminiLiveLLMSettings(model=...)`` instead. voice_id: TTS voice identifier. Defaults to "Charon". .. deprecated:: 0.0.105 Use ``settings=GeminiLiveVertexLLMSettings(voice=...)`` instead. start_audio_paused: Whether to start with audio input paused. Defaults to False. start_video_paused: Whether to start with video input paused. Defaults to False. system_instruction: System prompt for the model. Defaults to None. tools: Tools/functions available to the model. Defaults to None. params: Configuration parameters for the model along with Vertex AI location and project ID. .. deprecated:: 0.0.105 Use ``settings=GeminiLiveLLMSettings(...)`` instead. settings: Gemini Live LLM settings. If provided together with deprecated top-level parameters, the ``settings`` values take precedence. inference_on_context_initialization: Whether to generate a response when context is first set. Defaults to True. file_api_base_url: Base URL for the Gemini File API. Defaults to the official endpoint. http_options: HTTP options for the client. **kwargs: Additional arguments passed to parent GeminiLiveLLMService. api_keyzGeminiLiveVertexLLMService does not accept 'api_key' parameter. Use 'credentials' or 'credentials_path' instead for Vertex AI authentication.zbInvalid parameter 'api_key'. Use 'credentials' or 'credentials_path' for Vertex AI authentication.r%z)google/gemini-live-2.5-flash-native-audiovoicer"frequency_penaltyN max_tokensipresence_penalty temperaturetop_ktop_pseedfilter_incomplete_user_turnsFuser_turn_completion_config modalitieslanguagezen-USmedia_resolutionvadcontext_window_compressionthinkingenable_affective_dialog proactivityextrar&r+dummy) r3r'r(r)r*r,r-r.r/r)%rerror ValueError_get_credentials _credentials _project_id _locationrr AUDIOr UNSPECIFIEDrr%r4r5r6r7r8r9r:r>r?rr@rArB model_dumprCrDrE isinstancerFdict apply_updatesuper__init__)selfr#r$r0r1r%r&r'r(r)r*r+r,r-r.r/kwargsdefault_settings __class__s rrUz#GeminiLiveVertexLLMService.__init__?sp   LL` t  !11+?OP%!7 =  #   "       */ )- (--  3>>  (*! "# $%*% &' () 0   "7,G Q%*  " x  ":/JG T%-  "   "8-H I5;5M5M 2.4.?.? +4:4K4K 1/5/A/A ,)/ &)/ &.4.?.? +DJOO/@Y`!)5;4K4K 1'-zz $8855@@B!; -3OO,Ar );A;Y;Y;b]b 8/5/A/A/GR ,fllD1-3\\$*    ) )( 3  111%0S/%  rc~td|j|j|j|j|_y)z"Create the Gemini client instance.T)vertexair#projectr0r/N)rrKrLrM _http_options_clientrVs r create_clientz(GeminiLiveVertexLLMService.create_clients3))$$^^++   rctd)z0Gemini File API is not supported with Vertex AI.zWhen using Vertex AI, the recommended approach is to use Google Cloud Storage for file handling. The Gemini File API is not directly supported in this context.)NotImplementedErrorr_s rfile_apiz#GeminiLiveVertexLLMService.file_apis" n  rreturncPd}|r6tjjtj|dg}n6|r#tjj |dg}n t dg\}}|s td|jt|S#t$rY3wxYw)a:Retrieve Credentials using Google service account credentials JSON. Supports multiple authentication methods: 1. Direct JSON credentials string 2. Path to service account JSON file 3. Default application credentials (ADC) Args: credentials: JSON string of service account credentials. credentials_path: Path to the service account JSON file. Returns: OAuth token for API authentication. Raises: ValueError: If no valid credentials are provided or found. Nz.https://www.googleapis.com/auth/cloud-platform)scopeszNo valid credentials provided.) r Credentialsfrom_service_account_infojsonloadsfrom_service_account_filerrrIrefreshr)r#r$credsr1s rrJz+GeminiLiveVertexLLMService._get_credentialss&8< #//II ;'HIJE#//II HIJE  $+LM%!z => > gi  #  s!B B%$B%)rrrrrSettings__annotations__rstrboolrrrRrrr rUr`propertyrc staticmethodrJ __classcell__)rYs@rr r 4sk+H** &**. $ #(#(,0:>(,:>48!Y.2#X c]X #3- X  X  X }X X !X !X %SMX d4j+567X %X 67X .2X !X "{+#X t   -hsm-xPS}-Y\--rr )&rri dataclassesrtypingrrrlogurur%pipecat.adapters.schemas.tools_schemar'pipecat.services.google.gemini_live.llmr r r r r rrpipecat.services.settingsr google.authrgoogle.auth.exceptionsrgoogle.auth.transport.requestsr google.genair google.oauth2rModuleNotFoundErrorerH Exceptionrr rrrrs !((== ,#66#-  "7   d!5d,FLL;qc"#FLLbc &qc* ++,sA66B2;2B--B2