jKj MddlZddlZddlZddlmZmZmZddlmZddl m Z m Z ddl m Z  ddlmZddlmZdd l mZmZmZdd lmZmZmZmZmZdd l mZdd lmZdd l m!Z"GddZ#GddZ$y#e$r edwxYw)N)AnyDictOptional)AsyncStreamWrapper) TokenUsageStreamingEventDatamerge_system_prompt)genaizTPlease install the Google Gemini SDK to use this feature: 'pip install google-genai')setup)call_llm_and_track_usage_asynccapture_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) AsyncClientaM An async drop-in replacement for genai.Client that automatically sends LLM usage events to PostHog. Usage: client = AsyncClient( api_key="your_api_key", posthog_client=posthog_client, posthog_distinct_id="default_user", # Optional defaults posthog_properties={"team": "ai"} # Optional defaults ) response = await 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) rrrrrr r!r"r#r$r%r&)r r ValueError AsyncModelsmodels)selfrrrrrr r!r"r#r$r%r&kwargss o/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/posthog/ai/gemini/gemini_async.py__init__zAsyncClient.__init__7slB)3EG ?? "NO O! #%%?? 31!5)   NNNNNNNNNNFN) __name__ __module__ __qualname____doc__ PostHogClient__annotations__rstrboolrrr0r)r1r/rr#s""&#'%)!%"&&*&*26-17;%*374 #4 4.4 c] 4 # 4 3- 4 sm4 sm4 !/4 &c]4 %T#s(^44 #4 !c3h04 r1rceZdZUdZeed< 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+z] Async Models interface that mimics genai.Client().aio.models with PostHog tracking. rNrrrrrr r!r"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(rrrrr r!rGOOGLE_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-rrrrrr r!r"r#r$r%r&r. client_argss r/r0zAsyncModels.__init__us5B)3EG ?? "NO O%8!#5#; %9"-')   &.K #  ")4K &  %,K "  &.K #  #*6K '  #*6K ' ")0 I&**..)9:WbjjnnY>W u&-K "||2k2 Dr1call_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?rArBdictr@updater9uuiduuid4) r-rIrJrKrLrM distinct_id privacy_modegroups propertiess r/_merge_posthog_paramsz!AsyncModels._merge_posthog_paramss + ** !, ++  !, 7T=Q=Q$223    o .   -MM:|VKKr1modelposthog_trace_idr.c K|j|||||\} } } } } ||d|}t| |jd| | | | |j|jj j jf i|d{S7w)a Generate content using Gemini's API while tracking usage in PostHog. This method signature exactly matches genai.Client().aio.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 rXcontentsgeminiN)rWr rrGrFaior,generate_content)r-rXr\r#rYr$r%r&r.rStrace_idrVrTrUkwargs_with_contentss r/r_zAsyncModels.generate_contents<  & &# "$   @ Xz<*/HOO3  OO      NN LL   # # 4 4  #    sA6A?8A=9A?rSr`rVrTrUc: Ktj tddg dd} jjjj di| d{  fd} t | S7(w)Nr) input_tokens output_tokensr[cK 23d{}t|}|rt|dt|}|j|t |}|||W7R6 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_contentr\rSrUr.rXrTrVresponser- start_timerhr` usage_statss r/async_generatorz@AsyncModels._generate_content_streaming..async_generator8s ' #+ %"A%"HK")+{V%Fe$LM$0+22=A)Ne(T%(4&7 K' 8, 99;"Z/-- ' +.  99;"Z/-- ' +. s=CBA AA ABA  B"7C8CC)streamr))rjrrFr^r,generate_content_streamr)r-rXr\rSr`rVrTrUr.kwargs_without_streamrvrrrsrtrhrus````````` @@@@@r/_generate_content_streamingz'AsyncModels._generate_content_streaming#sYY[ ",!1"M  %) */X P PH))00HH #  , , , \"/"3HEEe sA B0B1)Brurqoutputrhc |j|fi|} t| }td||j||t | | | |||||| }t |j |y)Nr])providerrXbase_urlr.formatted_inputformatted_outputrurqrSr`rVrTrUrh) _format_inputrrrGrrr)r-rXr\rSr`rVrTrUr.rurqr{rhrsanitized_input event_datas r/rkz$AsyncModels._capture_streaming_eventhsr -$,,X@@)/:'^^+;FC##!%# $ PQ  !)".t hW#.$0& ( $ #  37 003E  -">C !:; OO # #'38%+ $  KW 9E!#}a8K 9yy{H+GCK4X>PQ  !)".t hW#.$0& ( $ #  37 003E  -">C !:; OO # #'38%+ $ sN6G6D/D0D4BGD D5D0+D80D55D88BGGr2)NNNNN)N)r3r4r5r6r7r8rr9r:rrr0rWr_rzrfloatrkrrxrr)r1r/r+r+ns"&#'%)!%"&&*&*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 lCFCFc] CF 3- CF T#s(^, CFCFc3h(CFCFd&*%=%=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!c3h0SSr1r+)%rCrjrQtypingrrrposthog.ai.streamrposthog.ai.typesrrposthog.ai.utilsr googler ImportErrorModuleNotFoundErrorposthogr r rr"posthog.ai.gemini.gemini_converterrrrrrrposthog.ai.sanitizationrposthog.clientrr7rr+r)r1r/rs &&0;0  /32H H VmmE ^ s A77B