o RhN3@sddlZddlZddlZddlmZmZmZzddlmZWn e y)e dwddl m Z m Z mZddlmZGdddZGd d d ZdS) N)AnyDictOptional)genaizTPlease install the Google Gemini SDK to use this feature: 'pip install google-genai')call_llm_and_track_usageget_model_paramswith_privacy_mode)Clientc@sdeZdZdZ      d deedeedeedeeeefde d eeeeff d d Z dS) r a; 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 ) NFapi_keyposthog_clientposthog_distinct_idposthog_propertiesposthog_privacy_modeposthog_groupsc Ks2|durtdtd||||||d||_dS)a Args: api_key: Google AI API key. If not provided, will use GOOGLE_API_KEY or API_KEY environment variable 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)r r r r rr) ValueErrorModelsmodelsselfr r r r rrkwargsrrZ/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/posthog/ai/gemini/gemini.py__init__'s zClient.__init__NNNNFN) __name__ __module__ __qualname____doc__rstr PostHogClientrrboolrrrrrr s*r c@s eZdZUdZeed<      d)deedeedeedeeee fd e d eeee ff d d Z d eedeedeeee fdee deeee ff ddZ     d*dedeedeedeeee fd ee d eeee fde fddZ dedeedeedeeee fde deeee fde fddZdedeedeedeeee fde deeee fdeee fd eeefd!ed"efd#d$Zd%d&Z     d*dedeedeedeeee fd ee d eeee fde fd'd(ZdS)+rzS Models interface that mimics genai.Client().models with PostHog tracking. _ph_clientNFr r r r rrcKsz|durtd||_||_|pi|_||_||_|dur)tjdp(tjd}|dur1tdt j |d|_ d|_ dS)a Args: api_key: Google AI API key. If not provided, will use GOOGLE_API_KEY or API_KEY environment variable 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) NrGOOGLE_API_KEYAPI_KEYz_API key must be provided either as parameter or via GOOGLE_API_KEY/API_KEY environment variable)r z)https://generativelanguage.googleapis.com) rr"_default_distinct_id_default_properties_default_privacy_mode_default_groupsosenvirongetrr _client _base_urlrrrrrPs  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) r%r'r(dictr&updateruuiduuid4) rr.r/r0r1r2 distinct_id privacy_modegroups propertiesrrr_merge_posthog_params{s    zModels._merge_posthog_paramsmodelposthog_trace_idrc 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 r<contentsgemini)r;rr"r-r,rgenerate_content)rr<r?r r=r rrrr7trace_idr:r8r9kwargs_with_contentsrrrrAs,   zModels.generate_contentr7rBr:r8r9c sbt ddd gd} jjjdi|  f dd} | S)Nr input_tokens output_tokensr>c3szLD]*}t|dr|jrt|jddt|jddd t|dr+|jr+|j|VqWt}| }d}   || dSt}| }d}   || w)Nusage_metadataprompt_token_countrcandidates_token_countrDtext)hasattrrGgetattrrJappendtimejoin_capture_streaming_event)chunkend_timelatencyoutput accumulated_contentr?r7r9rr<r8r:responser start_timerB usage_statsrr generators^   z5Models._generate_content_streaming..generatorr)rOr,rgenerate_content_stream) rr<r?r7rBr:r8r9rkwargs_without_streamr[rrVr_generate_content_streamings $'z"Models._generate_content_streamingrZrTrUc Cs|dur tt}d|t|t|j|||t|j|| ddgd| dd| dd| ||jd |p6i} |dur@d | d <t |jd rR|jj |d | |d dSdS)Nr@ assistant)contentrolerErrF) z $ai_providerz $ai_modelz$ai_model_parametersz $ai_inputz$ai_output_choicesz$ai_http_statusz$ai_input_tokensz$ai_output_tokensz $ai_latencyz $ai_trace_idz $ai_base_urlFz$process_person_profilecapturez$ai_generation)r7eventr:r9) rr5r6rrr" _format_inputr+r-rLrc) rr<r?r7rBr:r8r9rrZrTrUevent_propertiesrrrrQ sD      zModels._capture_streaming_eventcCst|tr d|dgSt|tr@g}|D])}t|tr$|d|dqt|dr3|d|jdq|dt|dq|Sdt|dgS)z*Format input contents for PostHog trackinguser)rar`rJ) isinstancerlistrNrLrJ)rr? formatteditemrrrre>s     zModels._format_inputcKs:||||||\} } } } } |j||| | | | | fi|S)N)r;r^)rr<r?r r=r rrrr7rBr:r8r9rrrr\Os&   zModels.generate_content_streamr)NNNNN)rrrrr __annotations__rrrrr!rr;rAr^intfloatrQrer\rrrrrIs  + $ 5 ;    3 r)r)rOr5typingrrrgoogler ImportErrorModuleNotFoundErrorposthog.ai.utilsrrrposthog.clientr r rrrrrs  4