
    2Rj1                    p   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 ddl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mZmZ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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      Z-y)    )annotationsN   )_legacy_response)BodyOmitQueryHeadersNotGivenomit	not_given)path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)make_request_options)ChatSessionWorkflowParamChatSessionRateLimitsParamChatSessionExpiresAfterParam$ChatSessionChatKitConfigurationParamsession_create_params)ChatSession)r   )r   )r   )r   SessionsAsyncSessionsc                      e Zd Zedd       Zed	d       Zee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
        )SessionsWithRawResponseselfs    n/var/www/html/meridian/meridian-ai/venv/lib/python3.12/site-packages/openai/resources/beta/chatkit/sessions.pywith_raw_responsezSessions.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
        )SessionsWithStreamingResponser"   s    r$   with_streaming_responsez Sessions.with_streaming_response)   s     -T22r&   Nchatkit_configurationexpires_afterrate_limitsextra_headersextra_query
extra_bodytimeoutc       	            ddi|xs i }| j                  dt        |||||dt        j                        t	        ||||	ddi      t
              S )	u  
        Create a ChatKit session.

        Args:
          user: A free-form string that identifies your end user; ensures this Session can
              access other objects that have the same `user` scope.

          workflow: Workflow that powers the session.

          chatkit_configuration: Optional overrides for ChatKit runtime configuration features

          expires_after: Optional override for session expiration timing in seconds from creation.
              Defaults to 10 minutes.

          rate_limits: Optional override for per-minute request limits. When omitted, defaults to 10.

          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
        OpenAI-Betachatkit_beta=v1/chatkit/sessionsuserworkflowr,   r-   r.   bearer_authTr/   r0   r1   r2   securitybodyoptionscast_to)_postr   r   SessionCreateParamsr   r   
r#   r9   r:   r,   r-   r.   r/   r0   r1   r2   s
             r$   createzSessions.create2   s}    N '(9Sm>QrSzz   (-B%2#. &99	 )+'%'.  '  
 	
r&   r/   r0   r1   r2   c                   |st        d|      ddi|xs i }| j                  t        d|      t        ||||ddi      t        	      S )
  
        Cancel an active ChatKit session and return its most recent metadata.

        Cancelling prevents new requests from using the issued client secret.

        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
        9Expected a non-empty value for `session_id` but received r5   r6   %/chatkit/sessions/{session_id}/cancel
session_idr;   Tr<   r@   rA   
ValueErrorrB   r   r   r   r#   rL   r/   r0   r1   r2   s         r$   cancelzSessions.cancelp   ss    2 XYcXfghh&(9Sm>QrSzzAjY(+'%'.    

 
	
r&   )returnr!   )rR   r)   r9   strr:   r   r,   z+ChatSessionChatKitConfigurationParam | Omitr-   z#ChatSessionExpiresAfterParam | Omitr.   z!ChatSessionRateLimitsParam | Omitr/   Headers | Noner0   Query | Noner1   Body | Noner2   'float | httpx.Timeout | None | NotGivenrR   r   rL   rT   r/   rU   r0   rV   r1   rW   r2   rX   rR   r   
__name__
__module____qualname__r   r%   r*   r   r   rE   rQ    r&   r$   r   r      s    - - 3 3 NR=A9= )-$("&;D<
 <
 +	<

  K<
 ;<
 7<
 &<
 "<
  <
 9<
 
<
H )-$("&;D&
&
 &&
 "&
  &
 9&
 
&
r&   c                      e Zd Zedd       Zed	d       Zeeeddded	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d
dZddded	 	 	 	 	 	 	 	 	 	 	 ddZ	y)r   c                    t        |       S r    )AsyncSessionsWithRawResponser"   s    r$   r%   zAsyncSessions.with_raw_response   s     ,D11r&   c                    t        |       S r(   )"AsyncSessionsWithStreamingResponser"   s    r$   r*   z%AsyncSessions.with_streaming_response   s     2$77r&   Nr+   c       	           K   ddi|xs i }| j                  dt        |||||dt        j                         d{   t	        ||||	ddi      t
        	       d{   S 7 '7 w)
r4   r5   r6   r7   r8   Nr;   Tr<   r>   )rB   r   r   rC   r   r   rD   s
             r$   rE   zAsyncSessions.create   s     N '(9Sm>QrSZZ,  (-B%2#. &99	 	 )+'%'.  '   
 
 	
	
s!   :A(A$
"A(A& A(&A(rF   c                  K   |st        d|      ddi|xs i }| j                  t        d|      t        ||||ddi      t        	       d
{   S 7 w)rH   rI   r5   r6   rJ   rK   r;   Tr<   rM   NrN   rP   s         r$   rQ   zAsyncSessions.cancel   s     2 XYcXfghh&(9Sm>QrSZZAjY(+'%'.     

 

 
	
 

s   AAAA)rR   ra   )rR   rc   rS   rY   rZ   r^   r&   r$   r   r      s    2 2 8 8 NR=A9= )-$("&;D<
 <
 +	<

  K<
 ;<
 7<
 &<
 "<
  <
 9<
 
<
H )-$("&;D&
&
 &&
 "&
  &
 9&
 
&
r&   c                      e Zd ZddZy)r!   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y N)	_sessionsr   to_raw_response_wrapperrE   rQ   r#   sessionss     r$   __init__z SessionsWithRawResponse.__init__  s=    !&>>OO
 '>>OO
r&   Nrl   r   rR   Noner[   r\   r]   rm   r^   r&   r$   r!   r!         
r&   r!   c                      e Zd ZddZy)ra   c                    || _         t        j                  |j                        | _        t        j                  |j                        | _        y rh   )ri   r   async_to_raw_response_wrapperrE   rQ   rk   s     r$   rm   z%AsyncSessionsWithRawResponse.__init__!  s=    !&DDOO
 'DDOO
r&   Nrl   r   rR   ro   rp   r^   r&   r$   ra   ra      rq   r&   ra   c                      e Zd ZddZy)r)   c                z    || _         t        |j                        | _        t        |j                        | _        y rh   )ri   r   rE   rQ   rk   s     r$   rm   z&SessionsWithStreamingResponse.__init__-  s1    !2OO
 3OO
r&   Nrn   rp   r^   r&   r$   r)   r)   ,  rq   r&   r)   c                      e Zd ZddZy)rc   c                z    || _         t        |j                        | _        t        |j                        | _        y rh   )ri   r   rE   rQ   rk   s     r$   rm   z+AsyncSessionsWithStreamingResponse.__init__9  s1    !8OO
 9OO
r&   Nru   rp   r^   r&   r$   rc   rc   8  rq   r&   rc   ).
__future__r   httpx r   _typesr   r   r   r	   r
   r   r   _utilsr   r   r   _compatr   	_resourcer   r   	_responser   r   _base_clientr   types.beta.chatkitr   r   r   r   r   types.beta.chatkit.chat_sessionr   .types.beta.chatkit.chat_session_workflow_param1types.beta.chatkit.chat_session_rate_limits_param3types.beta.chatkit.chat_session_expires_after_param;types.beta.chatkit.chat_session_chatkit_configuration_param__all__r   r   r!   ra   r)   rc   r^   r&   r$   <module>r      s    #  ! L L L L L ' ; Z 1  < W \ ` p
'x
 x
vx
$ x
v	
 	
	
 	
	
 	
	
 	
r&   