
    iXJ                       d dl mZ d dlmZmZmZmZ d dlmZ d dl	m
Z
 d dlZddlmZ ddlmZmZmZmZmZ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m Z  ddl!m"Z"m#Z# ddl$m%Z%m&Z& ddl'm(Z(m)Z) ddl*m+Z+m,Z, ddl-m.Z.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddgZ: G d de          Z; G d de           Z< G d d          Z= G d d          Z> G d d          Z? G d  d!          Z@dS )"    )annotations)AnyListIterablecast)chain)LiteralN   )_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)is_givenpath_templatemaybe_transformstrip_not_givenasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)StreamAsyncStream)SyncPageCursorAsyncPageCursor)AsyncPaginatormake_request_options)event_list_paramsevent_send_params)AnthropicBetaParam)BetaManagedAgentsEventParams)BetaManagedAgentsSessionEvent)"BetaManagedAgentsSendSessionEvents)$BetaManagedAgentsStreamSessionEventsEventsAsyncEventsc            	          e Zd Zed#d            Zed$d            Zeeeedddedd%dZedddedd&d Z	edddedd'd"Z
dS )(r*   returnEventsWithRawResponsec                     t          |           S a  
        This property can be used as a prefix for any HTTP method call to return
        the raw response object instead of the parsed content.

        For more information, see https://www.github.com/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers
        )r.   selfs    r/home/agentuser/.hermes/hermes-agent/venv/lib/python3.11/site-packages/anthropic/resources/beta/sessions/events.pywith_raw_responsezEvents.with_raw_response   s     %T***    EventsWithStreamingResponsec                     t          |           S z
        An alternative to `.with_raw_response` that doesn't eagerly read the response body.

        For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response
        )r6   r1   s    r3   with_streaming_responsezEvents.with_streaming_response)   s     +4000r5   Nlimitorderpagebetasextra_headersextra_query
extra_bodytimeout
session_idstrr;   
int | Omitr<   Literal['asc', 'desc'] | Omitr=   
str | Omitr>   List[AnthropicBetaParam] | Omitr?   Headers | Noner@   Query | NonerA   Body | NonerB   'float | httpx.Timeout | None | NotGiven-SyncPageCursor[BetaManagedAgentsSessionEvent]c                  |st          d|          i t          dt          |          r.d                    t	          d |D             dg                    nt
          i          |pi }ddi|pi }|                     t          d|          t          t                   t          ||||	t          |||dt          j                  	          t          t          t                    
          S )  
        List Events

        Args:
          limit: Query parameter for limit

          order: Sort direction for results, ordered by created_at. Defaults to asc
              (chronological).

          page: Opaque pagination cursor from a previous response's next_page.

          betas: Optional header to specify the beta version(s) you want to use.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        9Expected a non-empty value for `session_id` but received anthropic-beta,c              3  4   K   | ]}t          |          V  d S NrD   .0es     r3   	<genexpr>zEvents.list.<locals>.<genexpr>[   (      5L5Lc!ff5L5L5L5L5L5Lr5   managed-agents-2026-04-01*/v1/sessions/{session_id}/events?beta=truerC   r;   r<   r=   r?   r@   rA   rB   queryr=   optionsmodel)
ValueErrorr   r   joinr   r   _get_api_listr   r   r'   r"   r   r#   EventListParamsr   r   
r2   rC   r;   r<   r=   r>   r?   r@   rA   rB   s
             r3   listzEvents.list2   s@   H  	igYcgghhh	
$'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m" 	
 "	
 *+F`=K^\^`!!FS]^^^ =>(+'%%!&!& $ 
 &5    2 # " 
 
 	
r5   r>   r?   r@   rA   rB   events&Iterable[BetaManagedAgentsEventParams]r(   c          
        |st          d|          i t          dt          |          r.d                    t	          d |D             dg                    nt
          i          |pi }ddi|pi }|                     t          d|          t          d|it          j
                  t          ||||	          t          
          S )  
        Send Events

        Args:
          events: Events to send to the `session`.

          betas: Optional header to specify the beta version(s) you want to use.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rP   rQ   rR   c              3  4   K   | ]}t          |          V  d S rT   rU   rV   s     r3   rY   zEvents.send.<locals>.<genexpr>   rZ   r5   r[   r\   r]   rk   r?   r@   rA   rB   bodyrb   cast_to)rd   r   r   re   r   r   _postr   r   r$   EventSendParamsr"   r(   r2   rC   rk   r>   r?   r@   rA   rB   s           r3   sendzEvents.sendy   s   :  	igYcgghhh	
$'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m" 	
 "	
 *+F`=K^\^`zzFS]^^^ (F!35F5VWW(+Q[el   7  
 
 	
r5   ,Stream[BetaManagedAgentsStreamSessionEvents]c          
        |st          d|          i t          dt          |          r.d                    t	          d |D             dg                    nt
          i          |pi }ddi|pi }|                     t          d|          t          ||||          t          t          t                    d	t          t                   
          S )  
        Stream Events

        Args:
          betas: Optional header to specify the beta version(s) you want to use.

          extra_headers: Send extra headers

          extra_query: Add additional query parameters to the request

          extra_body: Add additional JSON properties to the request

          timeout: Override the client-level default timeout for this request, in seconds
        rP   rQ   rR   c              3  4   K   | ]}t          |          V  d S rT   rU   rV   s     r3   rY   z Events.stream.<locals>.<genexpr>   rZ   r5   r[   1/v1/sessions/{session_id}/events/stream?beta=truer]   rp   Trb   rs   stream
stream_cls)rd   r   r   re   r   r   _getr   r"   r   r   r)   r   r2   rC   r>   r?   r@   rA   rB   s          r3   r~   zEvents.stream   s   4  	igYcgghhh	
$'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m" 	
 "	
 *+F`=K^\^`yyMZdeee(+Q[el   9  BC  

 

 
	
r5   )r-   r.   )r-   r6   )rC   rD   r;   rE   r<   rF   r=   rG   r>   rH   r?   rI   r@   rJ   rA   rK   rB   rL   r-   rM   rC   rD   rk   rl   r>   rH   r?   rI   r@   rJ   rA   rK   rB   rL   r-   r(   )rC   rD   r>   rH   r?   rI   r@   rJ   rA   rK   rB   rL   r-   rx   __name__
__module____qualname__r   r4   r9   r   r   ri   rw   r~    r5   r3   r*   r*      s        + + + _+ 1 1 1 _1 !/315 )-$("&;DE
 E
 E
 E
 E
 E
X 26 )-$("&;D1
 1
 1
 1
 1
 1
n 26 )-$("&;D1
 1
 1
 1
 1
 1
 1
 1
r5   c            	          e Zd Zed#d            Zed$d            Zeeeedddedd%dZedddedd&d Z	edddedd'd"Z
dS )(r+   r-   AsyncEventsWithRawResponsec                     t          |           S r0   )r   r1   s    r3   r4   zAsyncEvents.with_raw_response   s     *$///r5    AsyncEventsWithStreamingResponsec                     t          |           S r8   )r   r1   s    r3   r9   z#AsyncEvents.with_streaming_response   s     0555r5   Nr:   rC   rD   r;   rE   r<   rF   r=   rG   r>   rH   r?   rI   r@   rJ   rA   rK   rB   rL   ]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]]c                  |st          d|          i t          dt          |          r.d                    t	          d |D             dg                    nt
          i          |pi }ddi|pi }|                     t          d|          t          t                   t          ||||	t          |||dt          j                  	          t          t          t                    
          S )rO   rP   rQ   rR   c              3  4   K   | ]}t          |          V  d S rT   rU   rV   s     r3   rY   z#AsyncEvents.list.<locals>.<genexpr>  rZ   r5   r[   r\   r]   r^   r_   ra   )rd   r   r   re   r   r   rf   r   r    r'   r"   r   r#   rg   r   r   rh   s
             r3   ri   zAsyncEvents.list   s@   H  	igYcgghhh	
$'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m" 	
 "	
 *+F`=K^\^`!!FS]^^^ !>?(+'%%!&!& $ 
 &5    2 # " 
 
 	
r5   rj   rk   rl   r(   c          
       K   |st          d|          i t          dt          |          r.d                    t	          d |D             dg                    nt
          i          |pi }ddi|pi }|                     t          d|          t          d|it          j
                   d	{V t          ||||
          t                     d	{V S )rn   rP   rQ   rR   c              3  4   K   | ]}t          |          V  d S rT   rU   rV   s     r3   rY   z#AsyncEvents.send.<locals>.<genexpr>]  rZ   r5   r[   r\   r]   rk   Nrp   rq   )rd   r   r   re   r   r   rt   r   r   r$   ru   r"   r(   rv   s           r3   rw   zAsyncEvents.send;  sE     :  	igYcgghhh	
$'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m" 	
 "	
 *+F`=K^\^`ZZFS]^^^,h-?ARAbcccccccc(+Q[el   7   
 
 
 
 
 
 
 
 	
r5   1AsyncStream[BetaManagedAgentsStreamSessionEvents]c          
       K   |st          d|          i t          dt          |          r.d                    t	          d |D             dg                    nt
          i          |pi }ddi|pi }|                     t          d|          t          ||||          t          t          t                    d	t          t                   
           d{V S )rz   rP   rQ   rR   c              3  4   K   | ]}t          |          V  d S rT   rU   rV   s     r3   rY   z%AsyncEvents.stream.<locals>.<genexpr>  rZ   r5   r[   r|   r]   rp   Tr}   N)rd   r   r   re   r   r   r   r   r"   r   r   r)   r   r   s          r3   r~   zAsyncEvents.streamn  s;     4  	igYcgghhh	
$'#chhu5L5Le5L5L5LOjNk/l/l&m&m&m" 	
 "	
 *+F`=K^\^`YYMZdeee(+Q[el   9  "#GH  

 

 

 

 

 

 

 

 
	
r5   )r-   r   )r-   r   )rC   rD   r;   rE   r<   rF   r=   rG   r>   rH   r?   rI   r@   rJ   rA   rK   rB   rL   r-   r   r   )rC   rD   r>   rH   r?   rI   r@   rJ   rA   rK   rB   rL   r-   r   r   r   r5   r3   r+   r+      s        0 0 0 _0 6 6 6 _6 !/315 )-$("&;DE
 E
 E
 E
 E
 E
X 26 )-$("&;D1
 1
 1
 1
 1
 1
n 26 )-$("&;D1
 1
 1
 1
 1
 1
 1
 1
r5   c                      e Zd ZddZdS )r.   rk   r*   r-   Nonec                    || _         t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        d S rT   )_eventsr   to_raw_response_wrapperri   rw   r~   r2   rk   s     r3   __init__zEventsWithRawResponse.__init__  s\    $<K
 
	 %<K
 
	 '>M
 
r5   Nrk   r*   r-   r   r   r   r   r   r   r5   r3   r.   r.     (        
 
 
 
 
 
r5   r.   c                      e Zd ZddZdS )r   rk   r+   r-   r   c                    || _         t          j        |j                  | _        t          j        |j                  | _        t          j        |j                  | _        d S rT   )r   r   async_to_raw_response_wrapperri   rw   r~   r   s     r3   r   z#AsyncEventsWithRawResponse.__init__  s\    $BK
 
	 %BK
 
	 'DM
 
r5   Nrk   r+   r-   r   r   r   r5   r3   r   r     r   r5   r   c                      e Zd ZddZdS )r6   rk   r*   r-   r   c                    || _         t          |j                  | _        t          |j                  | _        t          |j                  | _        d S rT   )r   r   ri   rw   r~   r   s     r3   r   z$EventsWithStreamingResponse.__init__  sS    0K
 
	 1K
 
	 3M
 
r5   Nr   r   r   r5   r3   r6   r6     r   r5   r6   c                      e Zd ZddZdS )r   rk   r+   r-   r   c                    || _         t          |j                  | _        t          |j                  | _        t          |j                  | _        d S rT   )r   r   ri   rw   r~   r   s     r3   r   z)AsyncEventsWithStreamingResponse.__init__  sS    6K
 
	 7K
 
	 9M
 
r5   Nr   r   r   r5   r3   r   r     r   r5   r   )A
__future__r   typingr   r   r   r   	itertoolsr   typing_extensionsr	   httpx r   _typesr   r   r   r   r   r   r   _utilsr   r   r   r   r   _compatr   	_resourcer   r   	_responser   r   
_streamingr   r   
paginationr   r    _base_clientr!   r"   types.beta.sessionsr#   r$   types.anthropic_beta_paramr%   4types.beta.sessions.beta_managed_agents_event_paramsr&   5types.beta.sessions.beta_managed_agents_session_eventr'   ;types.beta.sessions.beta_managed_agents_send_session_eventsr(   =types.beta.sessions.beta_managed_agents_stream_session_eventsr)   __all__r*   r+   r.   r   r6   r   r   r5   r3   <module>r      s   # " " " " " , , , , , , , , , , , ,       % % % % % %  ! ! ! ! ! ! L L L L L L L L L L L L L L L L L L g g g g g g g g g g g g g g ' ' ' ' ' ' ; ; ; ; ; ; ; ; Z Z Z Z Z Z Z Z . . . . . . . . : : : : : : : : A A A A A A A A H H H H H H H H = = = = = = a a a a a a c c c c c c n n n n n n r r r r r r]
#
 
 
 
 
_ 
 
 
D
 
 
 
 
" 
 
 
D
 
 
 
 
 
 
 

 
 
 
 
 
 
 

 
 
 
 
 
 
 

 
 
 
 
 
 
 
 
 
r5   