o g"@sddlZddlZddlmZmZmZz ddlZddlZWn ey'e dwddl m Z m Z m Z ddlmZGdddejZGdd d ejjjZGd d d ejjjjZGd d d ejjjZdS)N)AnyDictOptionalzGPlease install the OpenAI SDK to use this feature: 'pip install openai')call_llm_and_track_usageget_model_paramswith_privacy_mode)Clientcs0eZdZUdZeed<deffdd ZZS)OpenAIz_ A wrapper around the OpenAI SDK that automatically sends LLM usage events to PostHog. _ph_clientposthog_clientc s0tjdi|||_t||_t||_dS)a- Args: api_key: OpenAI API key. posthog_client: If provided, events will be captured via this client instead of the global posthog. **openai_config: Any additional keyword args to set on openai (e.g. organization="xxx"). N)super__init__r WrappedChatchatWrappedEmbeddings embeddings)selfr kwargs __class__r O/var/www/visachat/venv/lib/python3.10/site-packages/posthog/ai/openai/openai.pyrs zOpenAI.__init__)__name__ __module__ __qualname____doc__ PostHogClient__annotations__r __classcell__r r rrr s r c@s"eZdZUeed<eddZdS)r_clientcCs t|jS)N)WrappedCompletionsr)rr r r completions's zWrappedChat.completionsN)rrrr rpropertyr!r r r rr$s rcseZdZUeed<     ddeedeedeeeefde deeeefd ef fd d Z deedeedeeeefde deeeefd ef fd d Z deedeedeeeefde deeeefd eeefdeee fde defddZZS)r rNFposthog_distinct_idposthog_trace_idposthog_propertiesposthog_privacy_modeposthog_groupsrc sb|durt}|ddr|j|||||fi|St||jjd|||||jjtj f i|S)NstreamFopenai) uuiduuid4get_create_streamingrrr base_urlr create)rr#r$r%r&r'rrr rr//s2    zWrappedCompletions.createc sdt i gdvrid<ddd<tjdi f dd}|S)Nstream_optionsT include_usagec3szSD]3tdrjrfdddD tdr4jr4tjdkr4jdjj}|r4|VqWt}| }d}  || dSt}| }d}  || w)Nusagecsi|] }|tj|dqS)r)getattrr2).0kchunkr r iszKWrappedCompletions._create_streaming..generator..) prompt_tokenscompletion_tokens total_tokenschoicesr) hasattrr2r<lendeltacontentappendtimejoin_capture_streaming_event)rAend_timelatencyoutput accumulated_contentrr#r'r&r%r$responser start_time usage_statsr6r generatorcsR     z7WrappedCompletions._create_streaming..generatorr )rCr r/)rr#r$r%r&r'rrNrrIrr-Rs   &z$WrappedCompletions._create_streamingrMrGrHc Cs|durt}d|dt|t|jj||dt|jj|| ddgd|dd|d d||t|jjd |} |durDd | d <t |jjd rZ|jjj |pR|d| |ddSdS)Nr)modelmessages assistant)rAroler9rr:) $ai_provider $ai_modelz$ai_model_parameters $ai_inputz$ai_output_choices$ai_http_status$ai_input_tokensz$ai_output_tokens $ai_latency $ai_trace_id $ai_base_urlF$process_person_profilecapturez$ai_generation distinct_idevent propertiesgroups) r*r+r,rrrr strr.r>r]) rr#r$r%r&r'rrMrGrHevent_propertiesr r rrEs<      z+WrappedCompletions._capture_streaming_eventNNNFN)rrrr rrrcrrboolr/r-intfloatrErr r rrr ,sh #9    r csleZdZUeed<     d deedeedeeeefde deeeefd ef fd d Z Z S) rrNFr#r$r%r&r'rc s|durt}t}tjdi|}t} i} t|dr2|jr2t|jddt|jddd} | |} d|dt |j j ||d d | dd| |t |j j d |} |dur_d | d <t|j j drs|j j j|pm|d| |d|S)a Create an embedding using OpenAI's 'embeddings.create' method, but also track usage in PostHog. Args: posthog_distinct_id: Optional ID to associate with the usage event. posthog_trace_id: Optional trace UUID for linking events. posthog_properties: Optional dictionary of extra properties to include in the event. **kwargs: Any additional parameters for the OpenAI Embeddings API. Returns: The response from OpenAI's embeddings.create call. Nr2r9rr;)r9r;r)rOinputrS)rTrUrVrWrXrYrZr[Fr\r]z $ai_embeddingr^r )r*r+rCr r/r>r2r3r,rrr rcr.r]) rr#r$r%r&r'rrLrKrFrMrGrdrr rr/s@      zWrappedEmbeddings.createre) rrrr rrrcrrrfr/rr r rrrs( r)rCr*typingrrrr)openai.resources ImportErrorModuleNotFoundErrorposthog.ai.utilsrrrposthog.clientrrr resourcesrChatrr! Completionsr r Embeddingsrr r r rs