
    Kh%                       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 ddl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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, ddl-m.Z. ddl/m0Z0 ddgZ1 G d de&      Z2 G d de'      Z3 G d d      Z4 G d d      Z5 G d d      Z6 G d d      Z7y)    )annotations)AnyMappingcastN   )_legacy_response   )ThreadsAsyncThreadsThreadsWithRawResponseAsyncThreadsWithRawResponseThreadsWithStreamingResponse!AsyncThreadsWithStreamingResponse)SessionsAsyncSessionsSessionsWithRawResponseAsyncSessionsWithRawResponseSessionsWithStreamingResponse"AsyncSessionsWithStreamingResponse)BodyQueryHeadersNotGiven	FileTypes	not_given)extract_filesmaybe_transformdeepcopy_minimalasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)chatkit_upload_file_params)make_request_options)ChatKitUploadFileResponseChatKitAsyncChatKitc                  ~    e Zd Zedd       Zed	d       Zed
d       Zedd       Zddded	 	 	 	 	 	 	 	 	 	 	 ddZ	y)r(   c                ,    t        | j                        S N)r   _clientselfs    X/var/www/html/venv/lib/python3.12/site-packages/openai/resources/beta/chatkit/chatkit.pysessionszChatKit.sessions'   s    %%    c                ,    t        | j                        S r,   )r
   r-   r.   s    r0   threadszChatKit.threads+   s    t||$$r2   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
        )ChatKitWithRawResponser.   s    r0   with_raw_responsezChatKit.with_raw_response/   s     &d++r2   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
        )ChatKitWithStreamingResponser.   s    r0   with_streaming_responsezChatKit.with_streaming_response9   s     ,D11r2   Nextra_headersextra_query
extra_bodytimeoutc               H   ddi|xs i }t        d|i      }t        t        t        t        t
        f   |      dgg      }|rd|d<   t        t        | j                  dt        |t        j                        |t        ||||      t        t        t              	            S )
  
        Upload a ChatKit file

        Args:
          file: Binary file contents to store with the ChatKit session. Supports PDFs and PNG,
              JPG, JPEG, GIF, or WEBP images.

          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filepathsmultipart/form-dataContent-Type/chatkit/filesr=   bodyfilesoptionscast_to)r   r   r   r   strobjectr'   _postr   r%   ChatKitUploadFileParamsr&   r   r/   rF   r>   r?   r@   rA   rM   rN   s           r0   upload_filezChatKit.upload_fileB   s    4 '(9Sm>QrS/d73;#7>xjQ -BM.)%JJ $T+E+]+]^,"/[U_ip 2  

 	
r2   )returnr   )rW   r
   )rW   r7   )rW   r;   rF   r   r>   zHeaders | Noner?   zQuery | Noner@   zBody | NonerA   z'float | httpx.Timeout | None | NotGivenrW   r'   
__name__
__module____qualname__r    r1   r4   r8   r<   r   rV    r2   r0   r(   r(   &   s    & & % % , , 2 2 )-$("&;D/
 /
 &/
 "/
  /
 9/
 
#/
r2   c                  ~    e Zd Zedd       Zed	d       Zed
d       Zedd       Zddded	 	 	 	 	 	 	 	 	 	 	 ddZ	y)r)   c                ,    t        | j                        S r,   )r   r-   r.   s    r0   r1   zAsyncChatKit.sessionsu   s    T\\**r2   c                ,    t        | j                        S r,   )r   r-   r.   s    r0   r4   zAsyncChatKit.threadsy   s    DLL))r2   c                    t        |       S r6   )AsyncChatKitWithRawResponser.   s    r0   r8   zAsyncChatKit.with_raw_response}   s     +400r2   c                    t        |       S r:   )!AsyncChatKitWithStreamingResponser.   s    r0   r<   z$AsyncChatKit.with_streaming_response   s     166r2   Nr=   c               x  K   ddi|xs i }t        d|i      }t        t        t        t        t
        f   |      dgg      }|rd|d<   t        t        | j                  dt        |t        j                         d{   |t        ||||	      t        t        t              
       d{         S 7 77 
w)rC   rD   rE   rF   rG   rI   rJ   rK   Nr=   rL   )r   r   r   r   rQ   rR   r'   rS   r   r%   rT   r&   r   rU   s           r0   rV   zAsyncChatKit.upload_file   s     4 '(9Sm>QrS/d73;#7>xjQ -BM.)%** 07Q7i7ijj,"/[U_ip 2  
 

 	
 k
s$   A<B:>B6?.B:-B8
.	B:8B:)rW   r   )rW   r   )rW   rb   )rW   rd   rX   rY   r]   r2   r0   r)   r)   t   s    + + * * 1 1 7 7 )-$("&;D/
 /
 &/
 "/
  /
 9/
 
#/
r2   c                  8    e Zd ZddZedd       Zedd       Zy)r7   c                Z    || _         t        j                  |j                        | _        y r,   )_chatkitr   to_raw_response_wrapperrV   r/   chatkits     r0   __init__zChatKitWithRawResponse.__init__   s%    +CC
r2   c                @    t        | j                  j                        S r,   )r   rh   r1   r.   s    r0   r1   zChatKitWithRawResponse.sessions   s    &t}}'='=>>r2   c                @    t        | j                  j                        S r,   )r   rh   r4   r.   s    r0   r4   zChatKitWithRawResponse.threads   s    %dmm&;&;<<r2   Nrk   r(   rW   None)rW   r   )rW   r   rZ   r[   r\   rl   r    r1   r4   r]   r2   r0   r7   r7      s/    
 ? ? = =r2   r7   c                  8    e Zd ZddZedd       Zedd       Zy)rb   c                Z    || _         t        j                  |j                        | _        y r,   )rh   r   async_to_raw_response_wrapperrV   rj   s     r0   rl   z$AsyncChatKitWithRawResponse.__init__   s%    +II
r2   c                @    t        | j                  j                        S r,   )r   rh   r1   r.   s    r0   r1   z$AsyncChatKitWithRawResponse.sessions   s    +DMM,B,BCCr2   c                @    t        | j                  j                        S r,   )r   rh   r4   r.   s    r0   r4   z#AsyncChatKitWithRawResponse.threads   s    *4==+@+@AAr2   Nrk   r)   rW   rp   )rW   r   )rW   r   rq   r]   r2   r0   rb   rb      s3    
 D D B Br2   rb   c                  8    e Zd ZddZedd       Zedd       Zy)r;   c                F    || _         t        |j                        | _        y r,   )rh   r#   rV   rj   s     r0   rl   z%ChatKitWithStreamingResponse.__init__   s    7
r2   c                @    t        | j                  j                        S r,   )r   rh   r1   r.   s    r0   r1   z%ChatKitWithStreamingResponse.sessions   s    ,T]]-C-CDDr2   c                @    t        | j                  j                        S r,   )r   rh   r4   r.   s    r0   r4   z$ChatKitWithStreamingResponse.threads   s    +DMM,A,ABBr2   Nro   )rW   r   )rW   r   rq   r]   r2   r0   r;   r;      s3    
 E E C Cr2   r;   c                  8    e Zd ZddZedd       Zedd       Zy)rd   c                F    || _         t        |j                        | _        y r,   )rh   r$   rV   rj   s     r0   rl   z*AsyncChatKitWithStreamingResponse.__init__   s    =
r2   c                @    t        | j                  j                        S r,   )r   rh   r1   r.   s    r0   r1   z*AsyncChatKitWithStreamingResponse.sessions   s    1$--2H2HIIr2   c                @    t        | j                  j                        S r,   )r   rh   r4   r.   s    r0   r4   z)AsyncChatKitWithStreamingResponse.threads  s    01F1FGGr2   Nrw   )rW   r   )rW   r   rq   r]   r2   r0   rd   rd      s3    
 J J H Hr2   rd   )8
__future__r   typingr   r   r   httpx r   r4   r
   r   r   r   r   r   r1   r   r   r   r   r   r   _typesr   r   r   r   r   r   _utilsr   r   r   r   _compatr    	_resourcer!   r"   	_responser#   r$   
types.betar%   _base_clientr&   'types.beta.chatkit_upload_file_responser'   __all__r(   r)   r7   rb   r;   rd   r]   r2   r0   <module>r      s    # % %  !   L K ^ ^ ' ; Z 5 1 Qn
%K
o K
\K
# K
\= ="B B"C C"H Hr2   