o 3in:@sddlZddlZddlZddlmZmZmZddlmZm Z ddl m Z zddl m Z Wn ey7edwddlmZddl mZmZmZdd lmZmZmZdd lmZdd lmZGd d d ZGdddZdS)N)AnyDictOptional) TokenUsageStreamingEventDatamerge_system_prompt)genaizTPlease install the Google Gemini SDK to use this feature: 'pip install google-genai')setup)call_llm_and_track_usagecapture_streaming_eventmerge_usage_stats)extract_gemini_usage_from_chunk!extract_gemini_content_from_chunkformat_gemini_streaming_output)sanitize_gemini)Clientc@seZdZUdZeed<            ddeedeedee deed eed ee d ee d eed eedee ee fdedee ee ffddZ dS)ra; A drop-in replacement for genai.Client that automatically sends LLM usage events to PostHog. Usage: client = Client( api_key="your_api_key", posthog_client=posthog_client, posthog_distinct_id="default_user", # Optional defaults posthog_properties={"team": "ai"} # Optional defaults ) response = client.models.generate_content( model="gemini-2.0-flash", contents=["Hello world"], posthog_distinct_id="specific_user" # Override default ) _ph_clientNFapi_keyvertexai credentialsprojectlocation debug_config http_optionsposthog_clientposthog_distinct_idposthog_propertiesposthog_privacy_modeposthog_groupsc KsN|pt|_|jdurtdtd||||||||j| | | | d | |_dS)a Args: api_key: Google AI API key. If not provided, will use GOOGLE_API_KEY or API_KEY environment variable (not required for Vertex AI) vertexai: Whether to use Vertex AI authentication credentials: Vertex AI credentials object project: GCP project ID for Vertex AI location: GCP location for Vertex AI debug_config: Debug configuration for the client http_options: HTTP options for the client posthog_client: PostHog client for tracking usage posthog_distinct_id: Default distinct ID for all calls (can be overridden per call) posthog_properties: Default properties for all calls (can be overridden per call) posthog_privacy_mode: Default privacy mode for all calls (can be overridden per call) posthog_groups: Default groups for all calls (can be overridden per call) **kwargs: Additional arguments (for future compatibility) N/posthog_client is required for PostHog tracking) rrrrrrrrrrrr)r r ValueErrorModelsmodels)selfrrrrrrrrrrrrkwargsr!r!f/lsinfo/ai/hellotax_ai/llm_service/venv_embed/lib/python3.10/site-packages/posthog/ai/gemini/gemini.py__init__3s& !  zClient.__init__ NNNNNNNNNNFN) __name__ __module__ __qualname____doc__ PostHogClient__annotations__rstrboolrrr(r!r!r!r'rsP      rc@s@eZdZUdZeed<            d/deedeedee deed eed ee d ee d eed eedee ee fdedee ee ffddZ deedeedee ee fdeedee ee ff ddZ     d0ded eedeedee ee fdeedee ee fde fddZ dedeed eed!ee ee fd"ed#ee ee fde fd$d%Zdedeed eed!ee ee fd"ed#ee ee fde ee fd&ed'ed(e fd)d*Zd+d,Z     d0ded eedeedee ee fdeedee ee fde fd-d.ZdS)1r#zS Models interface that mimics genai.Client().models with PostHog tracking. rNFrrrrrrrrrrrrc Ks|pt|_|jdurtd| |_| pi|_| |_| |_i}|dur'||d<|dur/||d<|dur7||d<|dur?||d<|durG||d<|durO||d<|rZ|durY||d <n|durjtj d pitj d }|durrtd ||d <t j di||_ d |_ dS)au Args: api_key: Google AI API key. If not provided, will use GOOGLE_API_KEY or API_KEY environment variable (not required for Vertex AI) vertexai: Whether to use Vertex AI authentication credentials: Vertex AI credentials object project: GCP project ID for Vertex AI location: GCP location for Vertex AI debug_config: Debug configuration for the client http_options: HTTP options for the client posthog_client: PostHog client for tracking usage posthog_distinct_id: Default distinct ID for all calls posthog_properties: Default properties for all calls posthog_privacy_mode: Default privacy mode for all calls posthog_groups: Default groups for all calls **kwargs: Additional arguments (for future compatibility) Nr rrrrrrrGOOGLE_API_KEYAPI_KEYz_API key must be provided either as parameter or via GOOGLE_API_KEY/API_KEY environment variablez)https://generativelanguage.googleapis.comr!)r rr"_default_distinct_id_default_properties_default_privacy_mode_default_groupsosenvirongetr r_client _base_url)r%rrrrrrrrrrrrr& client_argsr!r!r'r(qsB !   zModels.__init__call_distinct_id call_trace_idcall_propertiescall_privacy_mode call_groupsc Csp|dur|n|j}|dur|n|j}|dur|n|j}t|j} |r'| ||dur1tt}||| ||fS)z9Merge call-level PostHog parameters with client defaults.N) r4r6r7dictr5updater0uuiduuid4) r%r>r?r@rArB distinct_id privacy_modegroups propertiesr!r!r'_merge_posthog_paramss    zModels._merge_posthog_paramsmodelposthog_trace_idr&c KsT||||||\} } } } } ||d|}t| |jd| | | | |j|jjjf i|S)a Generate content using Gemini's API while tracking usage in PostHog. This method signature exactly matches genai.Client().models.generate_content() with additional PostHog tracking parameters. Args: model: The model to use (e.g., 'gemini-2.0-flash') contents: The input content for generation posthog_distinct_id: ID to associate with the usage event (overrides client default) posthog_trace_id: Trace UUID for linking events (auto-generated if not provided) posthog_properties: Extra properties to include in the event (merged with client defaults) posthog_privacy_mode: Whether to redact sensitive information (overrides client default) posthog_groups: Group analytics properties (overrides client default) **kwargs: Arguments passed to Gemini's generate_content rLcontentsgemini)rKr rr<r;r$generate_content)r%rLrOrrMrrrr&rGtrace_idrJrHrIkwargs_with_contentsr!r!r'rQs,   zModels.generate_contentrGrRrJrHrIc sdt tddd gd} jjjdi|  f dd} | S)Nr) input_tokens output_tokensrNc3sz<D]}t|}|rt |ddt|}|dur ||VqWt}| }   | dSt}| }   | w)N cumulative)mode)rr rappendtime_capture_streaming_event)chunk chunk_usage content_blockend_timelatency accumulated_contentrOrGrIr&rLrHrJresponser% start_timerR usage_statsr!r' generator1sR z5Models._generate_content_streaming..generatorr!)rYrr;r$generate_content_stream) r%rLrOrGrRrJrHrIr&kwargs_without_streamrer!r`r'_generate_content_streamings $&z"Models._generate_content_streamingrdr_outputc CsR|j|fi|} t| } td||j|| t| | | |||||d }t|j|dS)NrP) providerrLbase_urlr&formatted_inputformatted_outputrdr_rGrRrJrHrI) _format_inputrrr<rr r)r%rLrOrGrRrJrHrIr&rdr_rirlsanitized_input event_datar!r!r'rZYs$zModels._capture_streaming_eventcKsd|i|}t|dS)z*Format input contents for PostHog trackingrOrPr)r%rOr& input_kwargsr!r!r'rn~s  zModels._format_inputcKs:||||||\} } } } } |j||| | | | | fi|S)N)rKrh)r%rLrOrrMrrrr&rGrRrJrHrIr!r!r'rfs&   zModels.generate_content_streamr))NNNNN)r*r+r,r-r.r/rr0r1rrr(rKrQrhrfloatrZrnrfr!r!r!r'r#js      V & 6 :    %  r#)r8rYrEtypingrrrposthog.ai.typesrrposthog.ai.utilsrgoogler ImportErrorModuleNotFoundErrorposthogr r r r "posthog.ai.gemini.gemini_converterrrrposthog.ai.sanitizationrposthog.clientrr.r#r!r!r!r's(     K