Ë
    îO´jb0  ã                  óh  — d dl mZ d dlmZmZ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mZ ddl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# ddl$m%Z% ddl&m'Z' ddl(m)Z) 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«      Z0y)é    )Úannotations)ÚAnyÚIterableÚcastNé   )Ú_legacy_response)ÚBodyÚOmitÚQueryÚHeadersÚNoneTypeÚNotGivenÚomitÚ	not_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)Úmake_request_options)Úevent_create_params)ÚAgentSessionEvent)ÚAgentSessionInputParamÚEventsÚAsyncEventsc                  óŽ   — e Zd Zedd„«       Zed	d„«       Zedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
d„Z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/openai/openai-python#accessing-raw-response-data-eg-headers
        )ÚEventsWithRawResponse©Úselfs    úƒ/var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/openai/resources/beta/agents/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/openai/openai-python#with_streaming_response
        )ÚEventsWithStreamingResponser&   s    r(   Úwith_streaming_responsezEvents.with_streaming_response#   s   € ô +¨4Ó0Ð0r*   N©Úidempotency_keyÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutc               ó  — |st        d|›�«      ‚ddi|xs i ¥}i t        d|i«      ¥|xs i ¥}ddi|xs i ¥}| j                  t        d|¬«      t	        d	|it
        j                  «      t        ||||d
di¬«      t        ¬«      S )áW  
        Submits message, cancellation, or tool-result events to a managed agent session.
        Cancellation can recover a still-open turn whose backend execution has ended by
        marking it cancelled and abandoning unpublished outputs. Saved results,
        published files, and existing terminal outcomes are preserved. HTTP 202 confirms
        acceptance, not durable completion. See
        [session events](https://developers.openai.com/api/docs/guides/agents-api/sessions/events).

        Args:
          events: The input events to submit to the session.

          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 ÚAcceptú*/*úIdempotency-KeyúOpenAI-Betaú	agents=v1ú$/agents/sessions/{session_id}/events©Ú
session_idÚeventsÚbearer_authT©r1   r2   r3   r4   Úsecurity©ÚbodyÚoptionsÚcast_to)	Ú
ValueErrorr   Ú_postr   r   r   ÚEventCreateParamsr   r   ©r'   r?   r@   r0   r1   r2   r3   r4   s           r(   ÚcreatezEvents.create,   s¾   € ñ@ ÜÐXÐYcÐXfÐgÓhÐhØ! 5ÐB¨]Ò-@¸bÐBˆØjœ?Ð,=¸Ð+OÓPÐjÐUbÒUhÐfhÐjˆØ&¨ÐM¸Ò8KÈÐMˆØ�z‰zÜÐ@ÈZÔXÜ  (¨FÐ!3Ô5H×5ZÑ5ZÓ[Ü(Ø+Ø'Ø%ØØ'¨Ð.ôô ð ó 
ð 	
r*   ©r1   r2   r3   r4   c               óæ   — |st        d|›�«      ‚ddi|xs i ¥}ddi|xs i ¥}| j                  t        d|¬«      t        ||||dd	i¬
«      t	        t
        t        «      d	t        t           ¬«      S )áÅ  Streams live events for an agent session.

        See
        [session events](https://developers.openai.com/api/docs/guides/agents-api/sessions/events).

        Args:
          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
        r7   r8   útext/event-streamr;   r<   r=   r>   rA   TrB   ©rF   rG   ÚstreamÚ
stream_cls)rH   Ú_getr   r   r   r   r   r   ©r'   r?   r1   r2   r3   r4   s         r(   rR   zEvents.stream^   s›   € ñ2 ÜÐXÐYcÐXfÐgÓhÐhØ!Ð#6ÐP¸=Ò;NÈBÐPˆØ&¨ÐM¸Ò8KÈÐMˆØ�y‰yÜÐ@ÈZÔXÜ(Ø+Ø'Ø%ØØ'¨Ð.ôô œÔ/Ó0ØÜÔ/Ñ0ð ó 
ð 	
r*   )Úreturnr%   )rV   r-   ©r?   Ústrr@   z Iterable[AgentSessionInputParam]r0   z
str | Omitr1   úHeaders | Noner2   úQuery | Noner3   úBody | Noner4   ú(float | httpx2.Timeout | None | NotGivenrV   ÚNone)r?   rX   r1   rY   r2   rZ   r3   r[   r4   r\   rV   zStream[AgentSessionEvent]©
Ú__name__Ú
__module__Ú__qualname__r   r)   r.   r   r   rL   rR   © r*   r(   r    r       sÜ   „ Øò+ó ð+ð ò1ó ð1ð '+ð )-Ø$(Ø"&Ø<Eñ0
àð0
ð 1ð	0
ð
 $ð0
ð &ð0
ð "ð0
ð  ð0
ð :ð0
ð 
ó0
ðp )-Ø$(Ø"&Ø<Eñ)
àð)
ð &ð)
ð "ð)
ð  ð)
ð :ð)
ð 
#ô)
r*   c                  óŽ   — e Zd Zedd„«       Zed	d„«       Zedddedœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
d„Zdddedœ	 	 	 	 	 	 	 	 	 	 	 dd„Z	y)r!   c                ó   — t        | «      S r$   )ÚAsyncEventsWithRawResponser&   s    r(   r)   zAsyncEvents.with_raw_response‹   s   € ô *¨$Ó/Ð/r*   c                ó   — t        | «      S r,   )Ú AsyncEventsWithStreamingResponser&   s    r(   r.   z#AsyncEvents.with_streaming_response•   s   € ô 0°Ó5Ð5r*   Nr/   c             ƒ  ó@  K  — |st        d|›�«      ‚ddi|xs i ¥}i t        d|i«      ¥|xs i ¥}ddi|xs i ¥}| j                  t        d|¬«      t	        d	|it
        j                  «      ƒ d
{  –—† t        ||||ddi¬«      t        ¬«      ƒ d
{  –—† S 7 Œ'7 Œ­w)r6   r7   r8   r9   r:   r;   r<   r=   r>   r@   NrA   TrB   rD   )	rH   r   rI   r   r   r   rJ   r   r   rK   s           r(   rL   zAsyncEvents.createž   sÓ   è ø€ ñ@ ÜÐXÐYcÐXfÐgÓhÐhØ! 5ÐB¨]Ò-@¸bÐBˆØjœ?Ð,=¸Ð+OÓPÐjÐUbÒUhÐfhÐjˆØ&¨ÐM¸Ò8KÈÐMˆØ—Z‘ZÜÐ@ÈZÔXÜ,¨h¸Ð-?ÔAT×AfÑAfÓg×gÜ(Ø+Ø'Ø%ØØ'¨Ð.ôô ð  ó 
÷ 
ð 	
àgøð
ús$   ‚A0BÁ2B
Á3"BÂBÂBÂBrM   c             ƒ  ó  K  — |st        d|›�«      ‚ddi|xs i ¥}ddi|xs i ¥}| j                  t        d|¬«      t        ||||dd	i¬
«      t	        t
        t        «      d	t        t           ¬«      ƒ d{  –—† S 7 Œ­w)rO   r7   r8   rP   r;   r<   r=   r>   rA   TrB   rQ   N)rH   rT   r   r   r   r   r   r   rU   s         r(   rR   zAsyncEvents.streamÐ   s©   è ø€ ñ2 ÜÐXÐYcÐXfÐgÓhÐhØ!Ð#6ÐP¸=Ò;NÈBÐPˆØ&¨ÐM¸Ò8KÈÐMˆØ—Y‘YÜÐ@ÈZÔXÜ(Ø+Ø'Ø%ØØ'¨Ð.ôô œÔ/Ó0ØÜ"Ô#4Ñ5ð ó 
÷ 
ð 	
ð 
ús   ‚A6A?Á8A=Á9A?)rV   re   )rV   rg   rW   )r?   rX   r1   rY   r2   rZ   r3   r[   r4   r\   rV   zAsyncStream[AgentSessionEvent]r^   rb   r*   r(   r!   r!   Š   sÜ   „ Øò0ó ð0ð ò6ó ð6ð '+ð )-Ø$(Ø"&Ø<Eñ0
àð0
ð 1ð	0
ð
 $ð0
ð &ð0
ð "ð0
ð  ð0
ð :ð0
ð 
ó0
ðp )-Ø$(Ø"&Ø<Eñ)
àð)
ð &ð)
ð "ð)
ð  ð)
ð :ð)
ð 
(ô)
r*   c                  ó   — e Zd Zdd„Zy)r%   c                ó¢   — || _         t        j                  |j                  «      | _        t        j                  |j                  «      | _        y ©N)Ú_eventsr   Úto_raw_response_wrapperrL   rR   ©r'   r@   s     r(   Ú__init__zEventsWithRawResponse.__init__ý   s=   € ØˆŒä&×>Ñ>Ø�M‰Mó
ˆŒô '×>Ñ>Ø�M‰Mó
ˆ�r*   N©r@   r    rV   r]   ©r_   r`   ra   rp   rb   r*   r(   r%   r%   ü   ó   „ ô
r*   r%   c                  ó   — e Zd Zdd„Zy)re   c                ó¢   — || _         t        j                  |j                  «      | _        t        j                  |j                  «      | _        y rl   )rm   r   Úasync_to_raw_response_wrapperrL   rR   ro   s     r(   rp   z#AsyncEventsWithRawResponse.__init__	  s=   € ØˆŒä&×DÑDØ�M‰Mó
ˆŒô '×DÑDØ�M‰Mó
ˆ�r*   N©r@   r!   rV   r]   rr   rb   r*   r(   re   re     rs   r*   re   c                  ó   — e Zd Zdd„Zy)r-   c                óz   — || _         t        |j                  «      | _        t        |j                  «      | _        y rl   )rm   r   rL   rR   ro   s     r(   rp   z$EventsWithStreamingResponse.__init__  s1   € ØˆŒä2Ø�M‰Mó
ˆŒô 3Ø�M‰Mó
ˆ�r*   Nrq   rr   rb   r*   r(   r-   r-     rs   r*   r-   c                  ó   — e Zd Zdd„Zy)rg   c                óz   — || _         t        |j                  «      | _        t        |j                  «      | _        y rl   )rm   r   rL   rR   ro   s     r(   rp   z)AsyncEventsWithStreamingResponse.__init__!  s1   € ØˆŒä8Ø�M‰Mó
ˆŒô 9Ø�M‰Mó
ˆ�r*   Nrw   rr   rb   r*   r(   rg   rg      rs   r*   rg   )1Ú
__future__r   Útypingr   r   r   Úhttpx2Ú r   Ú_typesr	   r
   r   r   r   r   r   r   Ú_utilsr   r   r   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser   r   Ú
_streamingr   r   Ú_base_clientr   Útypes.beta.agents.sessionsr   Útypes.beta.agent_session_eventr   Ú$types.beta.agent_session_input_paramr   Ú__all__r    r!   r%   re   r-   rg   rb   r*   r(   ú<module>r‹      sŽ   ðõ #ç &Ñ &ã å "ß W× WÓ Wß ^Ó ^Ý (ß <ß [ß /Ý 2Ý ?Ý AÝ Là�]Ð
#€ôo
ˆ_ô o
ôdo
Ð"ô o
÷d	
ñ 	
÷	
ñ 	
÷	
ñ 	
÷	
ò 	
r*   