jKjKddlZddlZddlZddlmZmZmZddlmZm Z ddl m Z  ddl m Z ddlmZddl mZmZmZdd lmZmZmZmZmZdd l mZdd lmZdd lmZ Gd dZGddZ!y#e$r edwxYw)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_embedding_token_countextract_gemini_usage_from_chunk!extract_gemini_content_from_chunk%extract_gemini_stop_reason_from_chunkformat_gemini_streaming_output)with_privacy_mode)sanitize_gemini)ClientceZdZUdZeed< ddeedeedee deedeed ee d ee d eed eed ee ee fdedee ee ffdZ y)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_clientNapi_keyvertexai credentialsprojectlocation debug_config http_optionsposthog_clientposthog_distinct_idposthog_propertiesposthog_privacy_modeposthog_groupsc  |xs t|_|j tdtd||||||||j| | | | d | |_y)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) rrrrrrrr r!r"r#r$)r r ValueErrorModelsmodels)selfrrrrrrrr r!r"r#r$kwargss i/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/posthog/ai/gemini/gemini.py__init__zClient.__init__6slB)3EG ?? "NO O #%%?? 31!5)   NNNNNNNNNNFN) __name__ __module__ __qualname____doc__ PostHogClient__annotations__rstrboolrrr.r'r/r-rr"s""&#'%)!%"&&*&*26-17;%*374 #4 4.4 c] 4 # 4 3- 4 sm4 sm4 !/4 &c]4 %T#s(^44 #4 !c3h04 r/rceZdZUdZeed< d)deedeedee deedeed ee d ee d eed eed ee ee fdedee ee ffdZ deedeedee ee fdeedee ee ff dZ d*ded eedeed ee ee fdeedee ee fde fdZ dedeedeedee ee fdedee ee fde fd Z d+dedeedeedee ee fdedee ee fde ee fd!ed"ed#e d$eefd%Zd&Z d*ded eedeed ee ee fdeedee ee fde fd'Z d*ded eedeed ee ee fdeedee ee fde fd(Zy),r)zS Models interface that mimics genai.Client().models with PostHog tracking. rNrrrrrrrr r!r"r#r$c  |xs t|_|j td| |_| xsi|_| |_| |_i}|||d<|||d<|||d<|||d<|||d<|||d<|r|Z||d <nT|@tjjd xstjjd }| td ||d <tjdi||_ d |_ y)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+rrrrrrrr r!r"r#r$r, client_argss r-r.zModels.__init__ts5B)3EG ?? "NO O%8!#5#; %9"-')   &.K #  ")4K &  %,K "  &.K #  #*6K '  #*6K ' ")0 I&**..)9:WbjjnnY>W u&-K "||2k2 Dr/call_distinct_id call_trace_idcall_propertiescall_privacy_mode call_groupsc||n |j}||n |j}||n |j}t|j} |r| j ||t tj}||| ||fS)z9Merge call-level PostHog parameters with client defaults.) r=r?r@dictr>updater7uuiduuid4) r+rGrHrIrJrK distinct_id privacy_modegroups propertiess r-_merge_posthog_paramszModels._merge_posthog_paramss + ** !, ++  !, 7T=Q=Q$223    o .   -MM:|VKKr/modelposthog_trace_idr,c |j|||||\} } } } } ||d|}t| |jd| | | | |j|jj j f 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 rVcontentsgemini)rUr rrErDr*generate_content)r+rVrZr!rWr"r#r$r,rQtrace_idrTrRrSkwargs_with_contentss r-r\zModels.generate_contents<  & &# "$   @ Xz<*/HOO'  OO      NN LL   0 0  #  r/rQr]rTrRrSc  tj tddg dd} jjjdi|   fd} | S)Nr) input_tokens output_tokensrYc3K D]N}t|}|rt|dt|}|j|t |}|||P t j }|z }j  | y#t j }|z }j  | wxYww)N cumulative)mode) stop_reason)rrrappendrtime_capture_streaming_event)chunk chunk_usage content_blockchunk_stop_reasonend_timelatencyaccumulated_contentrZrQrSr,rVrRrTresponser+ start_timerer] usage_statss r- generatorz5Models._generate_content_streaming..generator5s ' %E"A%"HK")+{V%Fe$LM$0+22=A)Ne(T%(4&7 K'&, 99;"Z/-- ' +.  99;"Z/-- ' +. sC AB7C 8CC r')rgrrDr*generate_content_stream)r+rVrZrQr]rTrRrSr,kwargs_without_streamrsrorprqrerrs````````` @@@@@r-_generate_content_streamingz"Models._generate_content_streaming"srYY[ ",!1"M  %) */X P P>4<<&&>>WAVW+ + + Z{r/rrrnoutputrec |j|fi|} t| }td||j||t | | | |||||| }t |j |y)Nr[)providerrVbase_urlr,formatted_inputformatted_outputrrrnrQr]rTrRrSre) _format_inputrrrErr r)r+rVrZrQr]rTrRrSr,rrrnrwrer{sanitized_input event_datas r-rhzModels._capture_streaming_eventdsr -$,,X@@)/:'^^+;FC##!%# $ PQ  !)".t hW#.$0& ( $ #  37 003E  -">C !:; OO # #'38%+ $  KQ 9E!#}a8K 9yy{H+GCK4X>PQ  !)".t hW#.$0& ( $ #  37 003E  -">C !:; OO # #'38%+ $ s*)C== DDD"DD""BF;r0)NNNNN)N)r1r2r3r4r5r6rr7r8rrr.rUr\rvrfloatrhr}rtrr'r/r-r)r)ms"&#'%)!%"&&*&*26-17;%*37TE#TE4.TEc] TE # TE 3- TEsmTEsmTE!/TE&c]TE%T#s(^4TE#TE!c3h0TEl L"3- L } L"$sCx.1 L $D> L d38n- LL.2*.7;/3374 4 &c] 4 #3- 4 %T#s(^4 4 'tn4 !c3h04 4 l@@c] @ 3- @ T#s(^, @@c3h(@@^&*%=%=c] %= 3- %= T#s(^, %=%=c3h(%=S#X%= %=%=%=c]%=N;.2*.7;/3370 0 &c] 0 #3- 0 %T#s(^4 0 'tn0 !c3h00 0 l.2*.7;/337SS&c] S #3- S %T#s(^4 S'tnS!c3h0SSr/r))"rArgrOtypingrrrposthog.ai.typesrrposthog.ai.utilsr googler ImportErrorModuleNotFoundErrorposthogr r r r"posthog.ai.gemini.gemini_converterrrrrrrposthog.ai.sanitizationrposthog.clientrr5r)r'r/r-rs &&;0  /32H H VjjE ^ s A11A?