ZiN3ddlZddlZddlZddlmZmZmZ ddlmZn#e $r e dwxYwddl m Z m Z mZddlmZGddZGd 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)ClientceZdZdZ d deedeedeedeeeefde d eeeeff 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 X|tdtd||||||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 rrrr) ValueErrorModelsmodelsselfr r rrrrkwargss S/root/projects/butler/venv/lib/python3.11/site-packages/posthog/ai/gemini/gemini.py__init__zClient.__init__'sT(  !NOO O ) 31!5)      NNNNFN) __name__ __module__ __qualname____doc__rstr PostHogClientrrboolrrrrr r s&"&26-17;%*37  # !/ &c]  %T#s(^4  #  !c3h0      rr cReZdZUdZeed< d"deedeedeedeeee fd e d eeee ff d Z d eed eedeeee fdee deeee ff dZ d#dedeedeedeeee fd ee d eeee fde fdZ dedeedeedeeee fde deeee fde fdZdedeedeedeeee fde deeee fdeee fdeeefdedefdZd Z d#dedeedeedeeee fd ee d eeee fde fd!ZdS)$rzS Models interface that mimics genai.Client().models with PostHog tracking. _ph_clientNFr r rrrrc V|td||_||_|pi|_||_||_|>t jdpt jd}|tdtj ||_ 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_urlrs rrzModels.__init__Ps(  !NOO O(%8!#5#; %9"- ?jnn%566S"*..:S:SG ?q |G444 Drcall_distinct_id call_trace_idcall_propertiescall_privacy_mode call_groupsc||n|j}||n|j}||n|j}t|j} |r| || t tj}||| ||fS)z9Merge call-level PostHog parameters with client defaults.) r+r-r.dictr,updater#uuiduuid4) rr4r5r6r7r8 distinct_id privacy_modegroups propertiess r_merge_posthog_paramszModels._merge_posthog_params{s +  * !,  +  !, 7T=Q$233  /   o . . .   --MM:|VKKrmodelposthog_trace_idrc ||||||\} } } } } ||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 rCcontentsgemini)rBrr'r3r2rgenerate_content)rrCrGrrDrrrrr>trace_idrAr?r@kwargs_with_contentss rrIzModels.generate_contents:  & &# "$    @ Xz<*/HOOO'  O      N L  0   #   rr>rJrAr?r@c  tj dddg d} jjjdi|   f d} | S)Nr input_tokens output_tokensrFc3F K D]{}t|dr4|jr-t|jddt|jdddt|dr!|jr|j|V| t j}|z }d}   || dS#t j}|z }d}   || wxYw)Nusage_metadataprompt_token_countrcandidates_token_countrMtext)hasattrrQgetattrrTappendtimejoin_capture_streaming_event)chunkend_timelatencyoutputaccumulated_contentrGr>r@rrCr?rAresponser start_timerJ usage_statss r generatorz5Models._generate_content_streaming..generators" %  Eu&677E>>KKKK " 9;;"Z/!455--        9;;"Z/!455--     s A>CAD r)rYr2rgenerate_content_stream)rrCrGr>rJrAr?r@rkwargs_without_streamrdr`rarbrcs````````` @@@@r_generate_content_streamingz"Models._generate_content_streamingsY[[ 781&M&M  */X P P P>4<&>WWAVWW% % % % % % % % % % % % % % % % % Ny{{rrcr^r_c | ttj}d|t|t |j|||t |j|| ddgd| dd| dd| ||jd |pi} |d | d <t|jd r |j |d | | dSdS)NrH assistant)contentrolerNrrO) 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)r>eventrAr@) r#r<r=rr r' _format_inputr1r3rVrm) rrCrGr>rJrAr?r@rrcr^r_event_propertiess rr[zModels._capture_streaming_event s0  4:<<((H%$4V$<$<*""8,, #4#[99:## # + B B!,!!D!D"$ N'  (R) .  :? 6 7 4?I . .  O # #'&+ $       rct|trd|dgSt|trg}|D]}t|tr|d|d0t |dr|d|jd^|dt|d|Sdt|dgS)z*Format input contents for PostHog trackinguser)rkrjrT) isinstancer#listrXrVrT)rrG formatteditems rrozModels._format_input>s h $ $ @#99: : $ ' ' @I  M MdC((M$$f%F%FGGGGT6**M$$f%K%KLLLL$$fT%K%KLLLL #H >>? ?rc h||||||\} } } } } |j||| | | | | fi|S)N)rBrg)rrCrGrrDrrrrr>rJrAr?r@s rrezModels.generate_content_streamOss  & &# "$    @ Xz<0t/             rr)NNNNN)rr r!r"r$__annotations__rr#rrr%rrBrIrgintfloatr[rorerrrrrIs"&26-17;%*37)E)E#)E!/)E&c] )E %T#s(^4 )E # )E!c3h0)E)E)E)EVL"3-L }L"$sCx.1 L $D> L d38n- LLLLH.2*.7;/3373 3 3 &c] 3 #3- 3 %T#s(^4 3 'tn3 !c3h03 3 3 3 3 j99c] 9 3- 9 T#s(^, 99c3h(99999v11c] 1 3- 1 T#s(^, 11c3h(1S#X1#s(^111111f@@@*.2*.7;/337   &c]  #3-  %T#s(^4  'tn !c3h0       rr)r/rYr<typingrrrgoogler ImportErrorModuleNotFoundErrorposthog.ai.utilsrrr posthog.clientr r$rrrrrs6 &&&&&&&&&&  ^    3222221 1 1 1 1 1 1 1 he e e e e e e e e e s0