
    Ng,                         d Z ddlmZ ddlZddlmZmZmZmZ ddl	m
Z
 ddlmZmZmZ ddlmZ dd	lmZmZmZ  G d
 d          ZdS )zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.   )SDKConfiguration    N)CallableListOptionalTuple)utils)AfterErrorContextAfterSuccessContextBeforeRequestContext)errors)RetryConfigSerializedRequestBodyget_body_contentc            	       
   e Zd ZU eed<   deddfdZd Z	 	 	 	 	 ddee         dee	g ee
         f                  d	ee         dej        fd
Z	 	 	 	 	 ddee         dee	g ee
         f                  d	ee         dej        fdZ	 	 	 	 	 ddee         dee	g ee
         f                  d	ee         dej        fdZ	 	 ddeeeee         f                  dej        fdZ	 	 ddeeeee         f                  dej        fdZdS )BaseSDKsdk_configuration
sdk_configreturnNc                     || _         d S N)r   )selfr   s     W/var/www/html/ai-engine/env/lib/python3.11/site-packages/unstructured_client/basesdk.py__init__zBaseSDK.__init__   s    !+    c                 t    | j                                         \  }}||}||}t          j        ||          S r   )r   get_server_detailsr	   template_url)r   base_urlurl_variablessdk_urlsdk_variabless        r   get_urlzBaseSDK.get_url   sD    !%!7!J!J!L!LH )M!(M:::r   
timeout_msget_serialized_bodyurl_overridec                 b    | j         j        }|                     ||||||||||	|
|||||          S r   )r   async_clientbuild_request_with_clientr   methodpathr   r    requestrequest_body_requiredrequest_has_path_paramsrequest_has_query_paramsuser_agent_headeraccept_header_value_globalssecurityr$   r%   r&   clients                    r   build_request_asynczBaseSDK.build_request_async%   sW    ( '4--!#$!
 
 	
r   c                 b    | j         j        }|                     ||||||||||	|
|||||          S r   )r   r5   r)   r*   s                    r   build_requestzBaseSDK.build_requestM   sW    ( '.--!#$!
 
 	
r   c           
         i }|}|Pt          j        |                     ||          ||r|nd |r|nd           }t          j        |	r|nd |	r|nd           }t          j        ||          }||d<   | j        j        ||
<   |t          |          r
 |            }|#t          j        |          \  }}i ||}i ||}t          d          }|! |            }|r|t          d          ||}|j        |j        dvr
|j        |d<   ||dz  nd }|                    ||||j        |j        |j        ||          S )NAcceptzapplication/octet-streamzrequest body is required)zmultipart/form-datazmultipart/mixedzcontent-typei  )paramscontentdatafilesheaderstimeout)r	   generate_urlr#   get_query_paramsget_headersr   
user_agentcallableget_securityr   
ValueError
media_typer8   r<   r=   r>   )r   r5   r+   r,   r   r    r-   r.   r/   r0   r1   r2   r3   r4   r$   r%   r&   query_paramsurlr?   security_headerssecurity_query_paramsserialized_request_bodyrbr@   s                            r   r)   z!BaseSDK.build_request_with_clientu   s   * ;$X}552<3=	 C !13=4>$ L
 #GX66/%)%;%F!"!! &#8::6;6H6R6R3355$45GDlD.CDL"78R"S"S*$$&&B$ = !;<<<~*,' $.:'2  '>&HGN#'1'=*t##4##+3(-)/ $ 	
 	
 		
r   Fretry_configc                    	  j         j         j         j        		 fd}|5t          j        |t          j        |d         |d                             }n
 |            }t          j        |j                  s: j                                         	                    t                    |          }|S )Nc            	         d } 	 j                                                             t                    
          }	                    d|j        |j        |j        t          |                     	                    |          } np# t          $ rc}j                                                             t                    d |          \  }}|	                    dd           |Y d }~nd }~ww xY w| )	                    d           t          j        d          	                    d| j        | j        | j        rd	n| j                   t#          j        | j                  rj                                                             t                    | d           \  }}|	                    dd           |||} n)	                    d
           t          j        d          | S Nz0Request:
Method: %s
URL: %s
Headers: %s
Body: %s)streamzRequest ExceptionT)exc_infozRaising no response SDK errorzNo response receivedz6Response:
Status Code: %s
URL: %s
Headers: %s
Body: %sz<streaming response>zRaising unexpected SDK errorzUnexpected error occurredr   	get_hooksbefore_requestr   debugr+   rJ   r?   r   send	Exceptionafter_errorr
   r   SDKErrorstatus_codetextr	   match_status_codeshttp_resreqe_resulterrr5   error_status_codeshook_ctxloggerr-   r   rS   s         r   dozBaseSDK.do_request.<locals>.do   s$   H,6688GG(22G  JJGK$S))   ";;s6;::   -7799EE%h//q 1 =LL!4tLDDDG !====	 <===o&<===LLL$ *0C&&hm   '(:H<PQQ G"4>>@@LL%h//4  ?LL!4tLDDDI%%HHLL!?@@@ /*EFFFOs   BB 
C9AC44C9r   r   )r   r5   debug_loggerr	   retryRetriesr_   r]   rV   after_successr   
r   rh   r-   rg   rS   rO   rj   ra   r5   ri   s
   `````   @@r   
do_requestzBaseSDK.do_request   s     '.'4/	 /	 /	 /	 /	 /	 /	 /	 /	 /	 /	b #{2u}\!_lSTo'V'VWWHHrttH'(:H<PQQ 	-7799GG#H--x H r   c                    	K    j         j         j         j        		 fd}|;t          j        |t          j        |d         |d                              d {V }n |             d {V }t          j        |j                  s: j                                         	                    t                    |          }|S )Nc            	        K   d } 	 j                                                             t                    
          }	                    d|j        |j        |j        t          |                     	                    |           d {V } np# t          $ rc}j                                                             t                    d |          \  }}|	                    dd           |Y d }~nd }~ww xY w| )	                    d           t          j        d          	                    d| j        | j        | j        rd	n| j                   t#          j        | j                  rj                                                             t                    | d           \  }}|	                    dd           |||} n)	                    d
           t          j        d          | S rR   rU   r`   s         r   rj   z$BaseSDK.do_request_async.<locals>.do  s:     H,6688GG(22G  JJGK$S))   "(S!@!@@@@@@@   -7799EE%h//q 1 =LL!4tLDDDG !====	 <===o&<===LLL$ *0C&&hm   '(:H<PQQ G"4>>@@LL%h//4  ?LL!4tLDDDI%%HHLL!?@@@ /*EFFFOs   BB 
DAC<<Dr   r   )r   r(   rk   r	   retry_asyncrm   r_   r]   rV   rn   r   ro   s
   `````   @@r   do_request_asynczBaseSDK.do_request_async  s      '4'4/	 /	 /	 /	 /	 /	 /	 /	 /	 /	 /	b #".EM,q/<?CC       HH  RTTzzzzzzH'(:H<PQQ 	-7799GG#H--x H r   )NNNNN)FN)__name__
__module____qualname__r   __annotations__r   r#   r   intr   r   strhttpxRequestr6   r8   r)   r   r   r   Responserp   rt    r   r   r   r      sg        '''',#3 , , , , ,	; 	; 	;. $( &*%&
 &
 SM&
 &R"7889
&
$ sm%&
& 
'&
 &
 &
 &
h $( &*%&
 &
 SM&
 &R"7889
&
$ sm%&
& 
'&
 &
 &
 &
j $( &*'P
 P
 SMP
  &R"7889
!P
& sm'P
( 
)P
 P
 P
 P
n @DF F u[$s)%;<=F 
F F F FZ @DH H u[$s)%;<=H 
H H H H H Hr   r   )__doc__sdkconfigurationr   r{   typingr   r   r   r   unstructured_clientr	   unstructured_client._hooksr
   r   r   unstructured_client.modelsr   unstructured_client.utilsr   r   r   r   r~   r   r   <module>r      s   G G . . . . . .  2 2 2 2 2 2 2 2 2 2 2 2 % % % % % %         
 . - - - - -         C C C C C C C C C Cr   