
    IiXJ                       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@y)"    )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
y)r*   c                    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
        )EventsWithRawResponseselfs    o/volume1/homes/robertsu/coba/app/.venv/lib/python3.12/site-packages/anthropic/resources/beta/sessions/events.pywith_raw_responsezEvents.with_raw_response   s     %T**    c                    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
        )EventsWithStreamingResponser0   s    r2   with_streaming_responsezEvents.with_streaming_response)   s     +400r4   Nlimitorderpagebetasextra_headersextra_query
extra_bodytimeoutc                  |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  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  2   K   | ]  }t        |        y wNstr.0es     r2   	<genexpr>zEvents.list.<locals>.<genexpr>[        5Lec!fe   managed-agents-2026-04-01*/v1/sessions/{session_id}/events?beta=true
session_idr:   r;   r<   r>   r?   r@   rA   queryr<   optionsmodel)
ValueErrorr   r   joinr   r   _get_api_listr   r   r'   r"   r   r#   EventListParamsr   r   
r1   rT   r:   r;   r<   r=   r>   r?   r@   rA   s
             r2   listzEvents.list2   s    H XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!FS]^ =>(+'%%!&!& $
 &55 2# " 
 	
r4   r=   r>   r?   r@   rA   c          
     Z   |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  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
        rD   rE   rF   c              3  2   K   | ]  }t        |        y wrH   rI   rK   s     r2   rN   zEvents.send.<locals>.<genexpr>   rO   rP   rQ   rR   rS   eventsr>   r?   r@   rA   bodyrY   cast_to)r[   r   r   r\   r   r   _postr   r   r$   EventSendParamsr"   r(   r1   rT   re   r=   r>   r?   r@   rA   s           r2   sendzEvents.sendy   s    : XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`zzFS]^ (F!35F5V5VW(+Q[el 7  
 	
r4   c          
     Z   |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  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
        rD   rE   rF   c              3  2   K   | ]  }t        |        y wrH   rI   rK   s     r2   rN   z Events.stream.<locals>.<genexpr>   rO   rP   rQ   1/v1/sessions/{session_id}/events/stream?beta=truerS   rf   TrY   ri   stream
stream_cls)r[   r   r   r\   r   r   _getr   r"   r   r   r)   r   r1   rT   r=   r>   r?   r@   rA   s          r2   rs   zEvents.stream   s    4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`yyMZde(+Q[el 9 BC  

 
	
r4   )returnr/   )rw   r7   )rT   rJ   r:   
int | Omitr;   Literal['asc', 'desc'] | Omitr<   
str | Omitr=   List[AnthropicBetaParam] | Omitr>   Headers | Noner?   Query | Noner@   Body | NonerA   'float | httpx.Timeout | None | NotGivenrw   z-SyncPageCursor[BetaManagedAgentsSessionEvent]rT   rJ   re   z&Iterable[BetaManagedAgentsEventParams]r=   r{   r>   r|   r?   r}   r@   r~   rA   r   rw   r(   )rT   rJ   r=   r{   r>   r|   r?   r}   r@   r~   rA   r   rw   z,Stream[BetaManagedAgentsStreamSessionEvents]__name__
__module____qualname__r   r3   r8   r   r   r`   rm   rs    r4   r2   r*   r*      sz   + + 1 1 !/315 )-$("&;DE
E
 	E

 -E
 E
 /E
 &E
 "E
  E
 9E
 
7E
X 26 )-$("&;D1
1
 7	1

 /1
 &1
 "1
  1
 91
 
,1
n 26 )-$("&;D1
1
 /	1
 &1
 "1
  1
 91
 
61
r4   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
y)r+   c                    t        |       S r.   )AsyncEventsWithRawResponser0   s    r2   r3   zAsyncEvents.with_raw_response   s     *$//r4   c                    t        |       S r6   ) AsyncEventsWithStreamingResponser0   s    r2   r8   z#AsyncEvents.with_streaming_response   s     055r4   Nr9   c                  |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d|      t        t           t        ||||	t        |||dt        j                        	      t        t        t              
      S )rC   rD   rE   rF   c              3  2   K   | ]  }t        |        y wrH   rI   rK   s     r2   rN   z#AsyncEvents.list.<locals>.<genexpr>  rO   rP   rQ   rR   rS   rU   rV   rX   )r[   r   r   r\   r   r   r]   r   r    r'   r"   r   r#   r^   r   r   r_   s
             r2   r`   zAsyncEvents.list   s    H XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`!!FS]^ !>?(+'%%!&!& $
 &55 2# " 
 	
r4   ra   c          
       K   |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d|      t        d|it        j                         d	{   t        ||||
      t               d	{   S 7 $7 w)rc   rD   rE   rF   c              3  2   K   | ]  }t        |        y wrH   rI   rK   s     r2   rN   z#AsyncEvents.send.<locals>.<genexpr>]  rO   rP   rQ   rR   rS   re   Nrf   rg   )r[   r   r   r\   r   r   rj   r   r   r$   rk   r"   r(   rl   s           r2   rm   zAsyncEvents.send;  s     : XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`ZZFS]^,h-?ARAbAbcc(+Q[el 7   
 
 	
c
s$   BCB?
C:C;CCc          
     v  K   |st        d|      i t        dt        |      r#dj                  t	        d |D        dg            nt
        i      |xs i }ddi|xs i }| j                  t        d|      t        ||||      t        t        t              d	t        t           
       d{   S 7 w)ro   rD   rE   rF   c              3  2   K   | ]  }t        |        y wrH   rI   rK   s     r2   rN   z%AsyncEvents.stream.<locals>.<genexpr>  rO   rP   rQ   rq   rS   rf   Trr   N)r[   r   r   r\   r   r   ru   r   r"   r   r   r)   r   rv   s          r2   rs   zAsyncEvents.streamn  s     4 XYcXfghh	
$ '*hhu5Le5LOjNk/l&m"	
 "	
 *+F`=K^\^`YYMZde(+Q[el 9 "#GH  

 

 
	
 

s   B0B92B73B9)rw   r   )rw   r   )rT   rJ   r:   rx   r;   ry   r<   rz   r=   r{   r>   r|   r?   r}   r@   r~   rA   r   rw   z]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]]r   )rT   rJ   r=   r{   r>   r|   r?   r}   r@   r~   rA   r   rw   z1AsyncStream[BetaManagedAgentsStreamSessionEvents]r   r   r4   r2   r+   r+      s{   0 0 6 6 !/315 )-$("&;DE
E
 	E

 -E
 E
 /E
 &E
 "E
  E
 9E
 
gE
X 26 )-$("&;D1
1
 7	1

 /1
 &1
 "1
  1
 91
 
,1
n 26 )-$("&;D1
1
 /	1
 &1
 "1
  1
 91
 
;1
r4   c                      e Zd ZddZy)r/   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j
                        | _        y rH   )_eventsr   to_raw_response_wrapperr`   rm   rs   r1   re   s     r2   __init__zEventsWithRawResponse.__init__  sX    $<<KK
	 %<<KK
	 '>>MM
r4   Nre   r*   rw   Noner   r   r   r   r   r4   r2   r/   r/         
r4   r/   c                      e Zd ZddZy)r   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        t        j                  |j
                        | _        y rH   )r   r   async_to_raw_response_wrapperr`   rm   rs   r   s     r2   r   z#AsyncEventsWithRawResponse.__init__  sX    $BBKK
	 %BBKK
	 'DDMM
r4   Nre   r+   rw   r   r   r   r4   r2   r   r     r   r4   r   c                      e Zd ZddZy)r7   c                    || _         t        |j                        | _        t        |j                        | _        t        |j                        | _        y rH   )r   r   r`   rm   rs   r   s     r2   r   z$EventsWithStreamingResponse.__init__  sF    0KK
	 1KK
	 3MM
r4   Nr   r   r   r4   r2   r7   r7     r   r4   r7   c                      e Zd ZddZy)r   c                    || _         t        |j                        | _        t        |j                        | _        t        |j                        | _        y rH   )r   r   r`   rm   rs   r   s     r2   r   z)AsyncEventsWithStreamingResponse.__init__  sF    6KK
	 7KK
	 9MM
r4   Nr   r   r   r4   r2   r   r     r   r4   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   r7   r   r   r4   r2   <module>r      s    # , ,  %  ! L L L g g ' ; Z . : A H = a c n r]
#
_ 
D
" 
D
 

 

 

 
r4   