o
    3i!                     @   s   zd dl Z d dlmZ W n ey   edw d dlZd dlZd dlmZm	Z	m
Z
mZ d dlmZmZmZ d dlmZmZ d dlmZmZmZmZmZ d dlmZ d d	lmZ d d
lmZ G dd de j Z G dd deZ!dS )    N)MessageszMPlease install the Anthropic SDK to use this feature: 'pip install anthropic')AnyDictListOptional)StreamingContentBlock
TokenUsageToolInProgress)call_llm_and_track_usagemerge_usage_stats)"extract_anthropic_usage_from_event$handle_anthropic_content_block_starthandle_anthropic_text_deltahandle_anthropic_tool_deltafinalize_anthropic_tool_input)sanitize_anthropic)Client)setupc                       s6   e Zd ZU dZeed< ddee f fddZ  ZS )	Anthropiczb
    A wrapper around the Anthropic SDK that automatically sends LLM usage events to PostHog.
    
_ph_clientNposthog_clientc                    s,   t  jdi | |pt | _t| | _dS )z
        Args:
            posthog_client: PostHog client for tracking usage
            **kwargs: Additional arguments passed to the Anthropic client
        N )super__init__r   r   WrappedMessagesmessages)selfr   kwargs	__class__r   l/lsinfo/ai/hellotax_ai/llm_service/venv_embed/lib/python3.10/site-packages/posthog/ai/anthropic/anthropic.pyr   %   s   zAnthropic.__init__N)	__name__
__module____qualname____doc__PostHogClient__annotations__r   r   __classcell__r   r   r   r    r      s   
  r   c                       s^  e Zd ZU eed< 					ddee dee deeeef  de	deeeef  d	ef fd
dZ
					ddee dee deeeef  de	deeeef  d	efddZdee dee deeeef  de	deeeef  d	ef fddZdee dee deeeef  de	deeeef  d	eeef dededee defddZ  ZS )r   _clientNFposthog_distinct_idposthog_trace_idposthog_propertiesposthog_privacy_modeposthog_groupsr   c              
      sf   |du r
t t }|ddr| j|||||fi |S t|| jjd||||| jjt	 j
f	i |S )a8  
        Create a message using Anthropic's API while tracking 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
            posthog_privacy_mode: Whether to redact sensitive information in tracking
            posthog_groups: Optional group analytics properties
            **kwargs: Arguments passed to Anthropic's messages.create
        NstreamF	anthropic)struuiduuid4get_create_streamingr
   r)   r   base_urlr   creater   r*   r+   r,   r-   r.   r   r   r   r    r7   3   s2   	
zWrappedMessages.createc                 K   s.   |d u r
t t }| j|||||fi |S r!   )r1   r2   r3   r5   r8   r   r   r    r/   b   s   	zWrappedMessages.streamc                    sb   t   tdddd g i d t jdi 	 	
fdd}| S )Nr   )input_tokensoutput_tokens c                  3   s0   z	D ]c} t | }t| t| drA| jdkrAt| \}}|r2| |ddkr0|nd |rA|d d}|rA||< t| }|rL |7  t|  t| drd| jdkrdd t	|  | V  qW t

 }| }
| 
 d S t

 }| }
| 
 w )Ntypecontent_block_starttextblockidcontent_block_stop)r   r   hasattrr<   r   appendr4   r   r   r   time_capture_streaming_event)eventevent_usager?   tooltool_id
delta_textend_timelatencyaccumulated_contentcontent_blockscurrent_text_blockr   r*   r.   r-   r,   r+   responser   
start_timetools_in_progressusage_statsr   r    	generator   sr   


+z4WrappedMessages._create_streaming.<locals>.generatorr   )rD   r   r   r7   )r   r*   r+   r,   r-   r.   r   rU   r   rM   r    r5   w   s   	&Cz!WrappedMessages._create_streamingrT   rL   rO   rN   c                 C   s   ddl m} ddlm}m} ddlm} ||}t|}|d|ddt	| j
j||||	|
|||||||d}|| j
j| d S )	Nr   )StreamingEventData) format_anthropic_streaming_input*format_anthropic_streaming_output_complete)capture_streaming_eventr0   modelunknown)providerrZ   r6   r   formatted_inputformatted_outputrT   rL   distinct_idtrace_id
propertiesprivacy_modegroups)posthog.ai.typesrV   (posthog.ai.anthropic.anthropic_converterrW   rX   posthog.ai.utilsrY   r   r4   r1   r)   r6   r   )r   r*   r+   r,   r-   r.   r   rT   rL   rO   rN   rV   rW   rX   rY   r]   sanitized_input
event_datar   r   r    rE      s.   

z(WrappedMessages._capture_streaming_event)NNNFN)r"   r#   r$   r   r'   r   r1   r   r   boolr7   r/   r5   r   floatr   r   rE   r(   r   r   r   r    r   0   s   
 1
V
	
r   )"r0   anthropic.resourcesr   ImportErrorModuleNotFoundErrorrD   r2   typingr   r   r   r   rd   r   r   r	   rf   r
   r   re   r   r   r   r   r   posthog.ai.sanitizationr   posthog.clientr   r&   posthogr   r   r   r   r   r   r    <module>   s&    