
    ,:jb                    l   U d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl	Z	d dl
Z
d dlZd dlm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mZmZ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$Z$d dl%Z%d dl&Z&d dl'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/m0Z0m1Z1 d
dl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZE d
dlFmGZGmHZHmIZI d
dlJmKZKmLZL d
dlMmNZNmOZOmPZPmQZQ d
dlRmSZS d
dlTmUZUmVZVmWZWmXZX d
dlYmZZZm[Z[ d
dl,m\Z\m]Z]m^Z^  ej                  e`      Zadebd<    edd      Zc edd      Zd ed      Ze edd       Zf ed!eZe         Zg ed"e[e         Zherd d#limjZk n	 d d#limjZk  G d% d&      Zm G d' d(eNee7         Zn G d) d*ene7   ee7         Zo G d+ d,ee7edf         Zp G d- d.ene7   ee7         Zq ed/ee%j                  e%j                  f         Zt ed0eeZe   e[e   f         Zu G d1 d2eeteuf         Zv G d3 d4eve%j                  eZe   f         Zw G d5 d6eve%j                  e[e   f         Zxddddde3e3d7	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dDd8Zy G d9 d:      Zzeeze"d;   f   Z{dEd<Z| G d= d>      Z}ee}e"d?   f   Z~dFd@Z	 	 	 	 	 	 dGdAZ G dB dCeE      Zy# el$ r  e9d$      ZkY Aw xY w)H    )annotationsN)TracebackType)random)TYPE_CHECKINGAnyDictTypeUnionGenericMappingTypeVarIterableIteratorOptional	GeneratorAsyncIteratorcastoverload)	lru_cache)Literaloverride)URLLimits)PrivateAttr   )_exceptionsQuerystring)to_httpx_filesasync_to_httpx_files)	NOT_GIVENBodyOmitQueryModelTHeadersTimeoutNotGiven	ResponseT	Transport
AnyMapping
PostParserProxiesTypesRequestFilesAsyncTransportRequestOptionsUnknownResponseModelBuilderProtocolBinaryResponseContent)is_dictis_given
is_mapping)
model_copy
model_dump)GenericModelFinalRequestOptionsvalidate_typeconstruct_type)APIResponse)DEFAULT_LIMITSDEFAULT_TIMEOUTDEFAULT_MAX_RETRIESRAW_RESPONSE_HEADER)StreamAsyncStream)APIStatusErrorAPITimeoutErrorAPIConnectionErrorzlogging.Loggerlog	SyncPageTzBaseSyncPage[Any])bound
AsyncPageTzBaseAsyncPage[Any]_T_T_coT)	covariant_StreamT_AsyncStreamT)DEFAULT_TIMEOUT_CONFIGg      @c                  t    e Zd ZU dZded<   ded<   e	 	 	 	 dd       Ze	 	 	 	 dd       Zeed	 	 	 	 	 dd	Zy
)PageInfozStores the necesary information to build the request to retrieve the next page.

    Either `url` or `params` must be set.
    URL | NotGivenurlQuery | NotGivenparamsc                    y N selfrT   s     U/var/www/html/tokenscope/api/venv/lib/python3.12/site-packages/openai/_base_client.py__init__zPageInfo.__init__o        	    c                    y rX   rY   )r[   rV   s     r\   r]   zPageInfo.__init__w   r^   r_   rT   rV   c                    || _         || _        y rX   ra   )r[   rT   rV   s      r\   r]   zPageInfo.__init__   s     r_   N)rT   r   returnNone)rV   r$   rc   rd   )rT   rS   rV   rU   rc   rd   )__name__
__module____qualname____doc____annotations__r   r]   r!   rY   r_   r\   rR   rR   f   s    
 
  
	    
	  (#,	  !	
 
r_   rR   c                  j    e Zd ZU dZ e       Zded<    e       Zded<   ddZddZ	ddZ
dd	Zdd
Zy)BasePagea<  
    Defines the core interface for pagination.

    Type Args:
        ModelT: The pydantic model that represents an item in the response.

    Methods:
        has_next_page(): Check if there is another page available
        next_page_info(): Get the necessary information to make a request for the next page
    r:   _optionsType[ModelT]_modelc                L    | j                         }|sy| j                         d uS )NF)_get_page_itemsnext_page_info)r[   itemss     r\   has_next_pagezBasePage.has_next_page   s*    $$&""$D00r_   c                     y rX   rY   r[   s    r\   rq   zBasePage.next_page_info       r_   c                     y rX   rY   ru   s    r\   rp   zBasePage._get_page_items   rv   r_   c                    t        j                  t        t        | j                  j
                              j                  |j
                        S rX   )httpxQueryParamsr   r   rl   rV   mergerZ   s     r\   _params_from_urlzBasePage._params_from_url   s3      c4==+?+?!@AGG

SSr_   c                   t        | j                        }|j                          t        |j                  t
              s!i |j                  |j                  |_        |S t        |j                  t
              sc| j                  |j                        }|j                  j                  |      }t        |j                        |_        t        |      |_        |S t        d      )N)rV   zUnexpected PageInfo state)r7   rl   _strip_raw_response_header
isinstancerV   r(   rT   r|   	copy_withdictstr
ValueError)r[   infooptionsrV   rT   s        r\   _info_to_optionszBasePage._info_to_options   s    T]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455r_   Nrc   bool)rc   zOptional[PageInfo])rc   zIterable[ModelT])rT   r   rc   zhttpx.QueryParams)r   rR   rc   r:   )re   rf   rg   rh   r   rl   ri   rn   rs   rq   rp   r|   r   rY   r_   r\   rk   rk      s<    	 %0MH!1&=FL(1T6r_   rk   c                  j    e Zd ZU  ej                         Zded<   	 	 	 	 	 	 	 	 ddZd	dZd
dZ	ddZ
y)BaseSyncPageSyncAPIClient_clientc                .    || _         || _        || _        y rX   rn   r   rl   )r[   clientmodelr   s       r\   _set_private_attributesz$BaseSyncPage._set_private_attributes        r_   c              #  h   K   | j                         D ]  }|j                         D ]  }|   y wrX   
iter_pagesrp   r[   pageitems      r\   __iter__zBaseSyncPage.__iter__   s9     OO% 	D,,. 
	s   02c              #  ^   K   | }	 | |j                         r|j                         }ny 'wrX   rs   get_next_pager[   r   s     r\   r   zBaseSyncPage.iter_pages   s5     J!!#))+ s   +-c                    | j                         }|st        d      | j                  |      }| j                  j	                  | j
                  | j                  |      S NzYNo next page expected; please check `.has_next_page()` before calling `.get_next_page()`.)r   r   rq   RuntimeErrorr   r   _request_api_listrn   	__class__r[   r   r   s      r\   r   zBaseSyncPage.get_next_page   sZ    ""$k  ''-||--dkkX_-``r_   N)r   r   r   rm   r   r:   rc   rd   )rc   zIterator[ModelT])r[   rH   rc   zIterator[SyncPageT])r[   rH   rc   rH   )re   rf   rg   pydanticr   r   ri   r   r   r   r   rY   r_   r\   r   r      sR    1X113G]3     %	 
 
 $
ar_   r   c                  @    e Zd Z	 	 	 	 	 	 	 	 	 	 ddZddZddZd	dZy)
AsyncPaginatorc                <    || _         || _        || _        || _        y rX   )rn   r   rl   	_page_cls)r[   r   r   page_clsr   s        r\   r]   zAsyncPaginator.__init__   s      !r_   c                >    | j                         j                         S rX   )	_get_page	__await__ru   s    r\   r   zAsyncPaginator.__await__   s    ~~))++r_   c                    K   d fd}| j                   _         j                  j                   j                   j                          d {   S 7 w)Nc                l    | j                  j                  j                  j                         | S )N)r   r   r   )r   rn   rl   r   )respr[   s    r\   _parserz)AsyncPaginator._get_page.<locals>._parser   s2    ((kk|| ) 
 Kr_   )r   rJ   rc   rJ   )rl   post_parserr   requestr   )r[   r   s   ` r\   r   zAsyncPaginator._get_page   s?     	 %,!\\))$..$--HHHHs   AAAAc               h   K   t        t        |  d {         }|2 3 d {   }| 7 7 6 y wrX   )r   rJ   r   s      r\   	__aiter__zAsyncPaginator.__aiter__  s<     J
  	 	$J 	$s$   2,

20.0202N)
r   AsyncAPIClientr   r:   r   Type[AsyncPageT]r   rm   rc   rd   )rc   z Generator[Any, None, AsyncPageT])rc   rJ   rc   zAsyncIterator[ModelT])re   rf   rg   r]   r   r   r   rY   r_   r\   r   r      sG    
"
" %
" #	
"
 
" 

",Ir_   r   c                  j    e Zd ZU  ej                         Zded<   	 	 	 	 	 	 	 	 ddZd	dZd
dZ	ddZ
y)BaseAsyncPager   r   c                .    || _         || _        || _        y rX   r   )r[   r   r   r   s       r\   r   z%BaseAsyncPage._set_private_attributes  r   r_   c               z   K   | j                         2 3 d {   }|j                         D ]  }| 	 $7 6 y wrX   r   r   s      r\   r   zBaseAsyncPage.__aiter__  sB     //+ 	 	$,,. 
	+s   ;979;9;c               t   K   | }	 | |j                         r|j                          d {   }ny 07 wrX   r   r   s     r\   r   zBaseAsyncPage.iter_pages!  s=     J!!#!//11  2s   ,868c                   K   | j                         }|st        d      | j                  |      }| j                  j	                  | j
                  | j                  |       d {   S 7 wr   r   r   s      r\   r   zBaseAsyncPage.get_next_page*  sd     ""$k  ''-\\33DKKdnn^e3ffffs   A$A-&A+'A-N)r   rm   r   r   r   r:   rc   rd   r   )r[   rJ   rc   zAsyncIterator[AsyncPageT])r[   rJ   rc   rJ   )re   rf   rg   r   r   r   ri   r   r   r   r   rY   r_   r\   r   r     sR    2h224G^4     %	 
 
 
gr_   r   _HttpxClientT_DefaultStreamTc                  R   e Zd ZU ded<   ded<   ded<   ded<   d	ed
<   ded<   ded<   ded<   ded<   ded<   dZded<   eeddd	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d1dZd2dZ	 	 	 	 d3dZ		 	 	 	 	 	 	 	 d4dZ
	 	 	 	 	 	 d5dZd6dZd7dZ	 	 	 	 d8d Zd9d!Z	 	 	 	 	 	 	 	 	 	 	 	 d:d"Z	 	 	 	 	 	 	 	 d;d#Zed<d$       Zed=d%       Zed>d&       Zed?d'       Z	 	 	 	 	 	 d@d(ZedAd)       ZedBd*       Zej4                  dCd+       Z ed,      dDd-       Z	 dE	 	 	 	 	 	 	 dFd.ZdGd/ZdAd0Zy)H
BaseClientr   r   r   _versionr   	_base_urlintmax_retrieszUnion[float, Timeout, None]timeouthttpx.Limits_limitsProxiesTypes | None_proxies!Transport | AsyncTransport | None
_transportr   _strict_response_validation
str | None_idempotency_headerNztype[_DefaultStreamT] | None_default_stream_cls)r   r   custom_headerscustom_queryc       
            || _         | j                  t        |            | _        || _        || _        || _        || _        || _        |	xs i | _	        |
xs i | _
        || _        d | _        y rX   )r   _enforce_trailing_slashr   r   r   r   r   r   r   _custom_headers_custom_queryr   r   )r[   versionbase_urlr   r   r   limits	transportproxiesr   r   s              r\   r]   zBaseClient.__init__F  so      55c(mD&#-3)/R+F(#' r_   c                z    |j                   j                  d      r|S |j                  |j                   dz         S )N   /raw_path)r   endswithr   rZ   s     r\   r   z"BaseClient._enforce_trailing_slash`  s3    <<  &J}}cllT&9}::r_   c                    |j                   j                         }|}	 t        j                  |      }d|j                   d| }| j                  |||      S # t
        $ r |xs d|j                   }Y 2w xY w)NzError code: z - )bodyresponse)textstripjsonloadsstatus_code	Exception_make_status_error)r[   r   err_textr   err_msgs        r\    _make_status_error_from_responsez+BaseClient._make_status_error_from_responsee  s     ==&&(	H::h'D$X%9%9$:#dVDG &&wTH&MM  	HGL1E1E0F"GG	Hs   'A A87A8c                   t               rX   )NotImplementedError)r[   r   r   r   s       r\   r   zBaseClient._make_status_errort  s     "##r_   c                @    ||S |j                  | j                        S rX   )get_max_retriesr   )r[   remaining_retriesr   s      r\   _remaining_retrieszBaseClient._remaining_retries}  s'    
 %6$A pwG^G^_c_o_oGppr_   c                ^   |j                   xs i }t        | j                  |      }| j                  ||       t	        j
                  |      }| j                  }|rQ|j                  j                         dk7  r4||vr0|j                  s| j                         |_	        |j                  ||<   |S )Nget)headers_merge_mappingsdefault_headers_validate_headersry   r&   r   methodloweridempotency_key_idempotency_key)r[   r   r   headers_dictr   idempotency_headers         r\   _build_headerszBaseClient._build_headers  s     .B&t';';^L|^<---!55'.."6"6"8E"AFX`gFg***.*?*?*A'*1*A*AG&'r_   c                    t        |      }|j                  rN| j                  j                  |j                  j	                  d      z   }| j                  j                  |      S |S )z
        Merge a URL argument together with any 'base_url' on the client,
        to create the URL used for the outgoing request.
        r   r   )r   is_relative_urlr   r   lstripr   )r[   rT   	merge_urlmerge_raw_paths       r\   _prepare_urlzBaseClient._prepare_url  sZ     H	$$!]]33i6H6H6O6OPT6UUN==**N*CCr_   c                   t         j                  t        j                        r!t         j	                  dt        |d             i }|j                  }|j                  W|t        t        |j                        }n:t        |      rt        ||j                        }nt        dt        |       d      | j                  |      }t        | j                  |j                         }|j#                  d      dk(  rJ|j%                  d       |r7t'        |      st)        dt        |       d	      | j+                  |      |d
<    | j,                  j.                  d|t1        |j2                  t4              r| j2                  n|j2                  |j6                  | j9                  |j:                        |r6| j<                  j?                  t        t@        tB        tD        f   |            nd ||jF                  d|S )NzRequest options: %sT)exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body`Content-Typezmultipart/form-datazGExpected query input to be a dictionary for multipart requests but got z	 instead.data)r   r   r   rT   rV   r   filesrY   )$rG   isEnabledForloggingDEBUGdebugr8   	json_data
extra_jsonr   r"   r6   r   r   typer  r   rV   r   popr4   	TypeError_serialize_multipartformr   build_requestr   r   r(   r   r  rT   qs	stringifyr   r   r   r  )r[   r   kwargsr  r   rV   s         r\   _build_requestzBaseClient._build_request  s    GMM*II+Zt-TU!#%%	)  w'9'9:	I&+Iw7I7IJ	"%@i@QQq#rss%%g. !3!3W^^D ;;~&*??KK' y)#abfgpbqarr{|  "&!>!>y!Iv *t||)) 
$.w$IDLLw>>!!'++.
 JP477$$T'#s(*;V%DEUY--
 
 	
r_   c                    | j                   j                  |d      }i }|D ]  \  }}||v rt        d| d      |||<    |S )Nbrackets)array_formatzDuplicate key encountered: z!; This behaviour is not supported)r  stringify_itemsr   )r[   r  rr   
serializedkeyvalues         r\   r  z#BaseClient._serialize_multipartform  sl    '' #	 ( 
 )+
 	$JCj  #>seCd!eff#JsO	$ r_   c                   t        || ||||      }|j                  j                  j                  t              dk(  rt        t        |      S |j                         S )N)rawr   cast_tostream
stream_clsr   true)r=   r   r   r   rA   r   r)   parse)r[   r%  r   r   r&  r'  api_responses          r\   _process_responsezBaseClient._process_response  s^     #!
 ##''(;<F	<00!!##r_   c               f   |t        t        d       S |t        u rt        t        |      S t        j                  |      r1t        |t              r!t        t        |j                  ||            S | j                  rt        t        t        ||            S t        t        t        ||            S )N)r   r  )type_r"  )r   r)   r1   inspectisclass
issubclassr2   buildr   r;   r<   )r[   r  r%  r   s       r\   _process_response_dataz!BaseClient._process_response_data  s     <	4((o%	4((??7#
7<P(Q	7==(=#NOO++	=wd#KLLI~G4HIIr_   c                    t               S rX   r   ru   s    r\   r  zBaseClient.qs  s
    }r_   c                     y rX   rY   ru   s    r\   custom_authzBaseClient.custom_auth  s    r_   c                    i S rX   rY   ru   s    r\   auth_headerszBaseClient.auth_headers  s    	r_   c                r    dd| j                   d| j                         | j                  | j                  S )Nzapplication/json)Acceptr
  z
User-Agent)
user_agentplatform_headersr7  r   ru   s    r\   r   zBaseClient.default_headers  sN     ).//
 ##%	

 
 ""
 	
r_   c                     y)zaValidate the given default headers and custom headers.

        Does nothing by default.
        NrY   )r[   r   r   s      r\   r   zBaseClient._validate_headers(  s     	r_   c                L    | j                   j                   d| j                   S )Nz/Python )r   re   r   ru   s    r\   r:  zBaseClient.user_agent3  s"    ..))*(4==/BBr_   c                    | j                   S rX   )r   ru   s    r\   r   zBaseClient.base_url7  s    ~~r_   c                |    t        |t              r|| j                  _        y t        |      | j                  _        y rX   )r   r   r   r   rZ   s     r\   r   zBaseClient.base_url;  s&    '1#s';Sr_   )maxsizec                    d| j                   t        t                     t        t                     t	        j
                         t	        j                         dS )Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)r   r   get_platformget_architectureplatformpython_implementationpython_versionru   s    r\   r;  zBaseClient.platform_headers?  sF     !)+/==!,.1 #$4$6 7#+#A#A#C+3+B+B+D
 	
r_   c                    |j                  | j                        }	 ||j                  d      }	 t        |      }nd}d|cxk  rdk  r|S  d}	d}
||z
  }t        |	t        d|      z  |
      }dd	t               z  z
  }||z  }|dk\  r|S dS # t        $ rf t
        j                  j                  |      }|d}n?t
        j                  j                  |      }t        |t        j                         z
        }Y w xY w# t        $ r d}Y w xY w)
Nzretry-afterr   <   g      ?g       @g       @r   g      ?)r   r   r   r   r   emailutilsparsedate_tz	mktime_tztimeminpowr   )r[   r   r   response_headersr   retry_headerretry_afterretry_date_tuple
retry_dateinitial_retry_delaymax_retry_delay
nb_retriessleep_secondsjitterr   s                  r\   _calculate_retry_timeoutz#BaseClient._calculate_retry_timeoutJ  s;    --d.>.>?	
  +/33MBD"%l"3K ! { b  ! " #44
 /#c:2FFX TFH_$&(!Q,w-A-7 ! D',{{'?'?'M$'/&(%*[[%:%:;K%L
&)*tyy{*B&CD  	K	s4   C? B C? A,C<9C? ;C<<C? ?DDc                    |j                   j                  d      }|dk(  ry|dk(  ry|j                  dk(  ry|j                  dk(  ry|j                  dk(  ry|j                  d	k\  ryy)
Nzx-should-retryr(  TfalseFi  i  i  i  )r   r   r   )r[   r   should_retry_headers      r\   _should_retryzBaseClient._should_retryw  s    &..223CD &(') 3& 3& 3& 3&r_   c                0    dt        j                          S )Nzstainless-python-retry-)uuiduuid4ru   s    r\   r   zBaseClient._idempotency_key  s    (77r_   )r   r   r   	str | URLr   r   r   r   r   zfloat | Timeout | Noner   r   r   r   r   r   r   Mapping[str, str] | Noner   Mapping[str, object] | Nonerc   rd   )rT   r   rc   r   )r   httpx.Responserc   rD   )r   r   r   objectr   rg  rc   z_exceptions.APIStatusError)r   Optional[int]r   r:   rc   r   )r   r:   rc   zhttpx.Headers)rT   r   rc   r   )r   r:   rc   httpx.Request)r  zMapping[object, object]rc   zdict[str, object])r%  Type[ResponseT]r   r:   r   rg  r&  r   r'  z1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerc   r)   )r  rh  r%  ztype[ResponseT]r   rg  rc   r)   )rc   r   )rc   zhttpx.Auth | None)rc   zdict[str, str])rc   zdict[str, str | Omit])r   r&   r   r&   rc   rd   rc   r   )rc   r   )rT   z	URL | strrc   rd   )rc   zDict[str, str]rX   )r   r   r   r:   rR  Optional[httpx.Headers]rc   float)r   rg  rc   r   ) re   rf   rg   ri   r   r@   r?   r]   r   r   r   r   r  r  r  r  r+  r2  propertyr  r5  r7  r   r   r:  r   setterr   r;  r\  r`  r   rY   r_   r\   r   r   9  s   MN((!!11!%%##8<5< /*9 4848( ( 	(
 &*( ( (( ( 5( %( 1( 2( 
(4;
N N 
N$$ 	$
 !$ 
$$q(q %q 
	q 4
$4
 
4
l$ !$ %	$
 !$ $ F$ 
$.J J !	J
 !J 
J*       
 
		  	 
		 C C   __J J t
 
 59	+.+. %+. 2	+.
 
+.Z88r_   r   c            	          e Zd ZU ded<   ded<   dZded<   eeddddddd	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d2 fd	Zd3d
Zd4dZ	d5dZ
	 	 	 	 	 	 	 	 d6dZ	 	 	 	 d7dZ	 	 	 	 d8dZe	 d9	 	 	 	 	 	 	 	 	 	 	 d:d       Ze	 d9dd	 	 	 	 	 	 	 	 	 d;d       Ze	 d9ddd	 	 	 	 	 	 	 	 	 	 	 d<d       Z	 d9ddd	 	 	 	 	 	 	 	 	 	 	 d=dZ	 	 	 	 	 	 	 	 	 	 	 	 d>dZ	 d9	 	 	 	 	 	 	 	 	 	 	 	 	 d?dZ	 	 	 	 	 	 	 	 d@dZei dd	 	 	 	 	 	 	 	 	 dAd       Zei d	 	 	 	 	 	 	 	 	 	 	 dBd       Zei dd	 	 	 	 	 	 	 	 	 	 	 dCd       Zi ddd 	 	 	 	 	 	 	 	 	 	 	 dCd!Zedi ddd"	 	 	 	 	 	 	 	 	 	 	 	 	 dDd#       Zedi dd$	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dEd%       Zedi ddd&	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dFd'       Zdi dddd(	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dFd)Zdi d*	 	 	 	 	 	 	 	 	 dGd+Zddi d,	 	 	 	 	 	 	 	 	 	 	 dHd-Zdi d*	 	 	 	 	 	 	 	 	 dGd.Zdi d/d0	 	 	 	 	 	 	 	 	 	 	 	 	 dId1Z xZS )Jr   zhttpx.Clientr   r   _has_custom_http_clientNztype[Stream[Any]] | Noner   r   r   r   r   r   http_clientr   r   c               J   |)t        j                  dt        d       |t        d      t        }|)t        j                  dt        d       |t        d      |)t        j                  dt        d       |t        d      t        |      s(|r |j                  t        k7  r|j                  }nt        }t        | )  ||t        t        |      |||||
|	|	
       |xs( t        j                  |t        t        |      |||
      | _        t!        |      | _        y )NhThe `connection_pool_limits` argument is deprecated. The `http_client` argument should be passed instead   category
stacklevelNThe `http_client` argument is mutually exclusive with `connection_pool_limits`[The `transport` argument is deprecated. The `http_client` argument should be passed insteadAThe `http_client` argument is mutually exclusive with `transport`YThe `proxies` argument is deprecated. The `http_client` argument should be passed instead?The `http_client` argument is mutually exclusive with `proxies`)
r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   )warningswarnDeprecationWarningr   r>   r5   r   HTTPX_DEFAULT_TIMEOUTr?   superr]   r   r'   ry   Clientr   r   rr  )r[   r   r   r   r   r   r   r   rt  r   r   r   r   s               r\   r]   zSyncAPIClient.__init__  s7    MMz+
 & !qrr#F MMm+
 & !deeMMk+
 & !bcc  {226KK%--)'*#%)(C 	 	
 # 
ell'*'
 (,K'8$r_   c                .    | j                   j                  S rX   r   	is_closedru   s    r\   r  zSyncAPIClient.is_closed      ||%%%r_   c                R    t        | d      r| j                  j                          yy)`Close the underlying HTTPX client.

        The client will *not* be usable after this.
        r   N)hasattrr   closeru   s    r\   r  zSyncAPIClient.close  s#     4#LL  $r_   c                    | S rX   rY   ru   s    r\   	__enter__zSyncAPIClient.__enter__  s    r_   c                $    | j                          y rX   r  r[   exc_typeexcexc_tbs       r\   __exit__zSyncAPIClient.__exit__  s     	

r_   c                     yz#Hook for mutating the given optionsNrY   r[   r   s     r\   _prepare_optionszSyncAPIClient._prepare_options  s    
 r_   c                     ya  This method is used as a callback for mutating the `Request` object
        after it has been constructed.
        This is useful for cases where you want to add certain headers based off of
        the request properties, e.g. `url`, `method` etc.
        NrY   r[   r   s     r\   _prepare_requestzSyncAPIClient._prepare_request  s     r_   c                    y rX   rY   r[   r%  r   r   r&  r'  s         r\   r   zSyncAPIClient.request       	r_   Fr&  c                    y rX   rY   )r[   r%  r   r   r&  s        r\   r   zSyncAPIClient.request"       	r_   r&  r'  c                    y rX   rY   r  s         r\   r   zSyncAPIClient.request-  r  r_   c               .    | j                  |||||      S N)r%  r   r&  r'  r   _requestr  s         r\   r   zSyncAPIClient.request9  s)     }}!/  
 	
r_   c          	        | j                  |       | j                  ||      }| j                  |      }| j                  |       	 | j                  j                  || j                  |      }t        j                  d|j                  |j                  |j                  |j                         |j                          | j5                  |||||      S # t        j                  $ r}	|dkD  rK| j!                  |	j"                        r0| j%                  ||||	j"                  j&                  ||      cY d }	~	S |	j"                  j)                          | j+                  |	j"                        d d }	~	wt        j,                  $ r2}	|dkD  r| j%                  |||||      cY d }	~	S t/        |      |	d }	~	wt0        $ r2}	|dkD  r| j%                  |||||      cY d }	~	S t3        |      |	d }	~	ww xY wN)authr&  zHTTP Request: %s %s "%i %s"r   r  )r   )r%  r   r   r&  r'  )r  r   r  r  r   sendr5  rG   r  r   rT   r   reason_phraseraise_for_statusry   HTTPStatusErrorr`  r   _retry_requestr   readr   TimeoutExceptionrE   r   rF   r+  )
r[   r%  r   r   r&  r'  retriesr   r   errs
             r\   r  zSyncAPIClient._requestJ  s    	g&))*;WE%%g.g&(	?||((t7G7GPV(WHII-w~~w{{HL`L`bjbxbx %%'J %%! & 
 	
I $$ 	P{t11#,,?**LL((!) +   LL77E4O%% 		<{**!) +   "'2; 		?{**!) +   %W53>		?sV   A9C G0)A
E/3G096E//G0F2G0%F22G0>G+G0G++G0c                   |dz
  }| j                  |||      }t        j                  d|j                  |       t	        j
                  |       | j                  |||||      S Nr   z$Retrying request to %s in %f seconds)r   r%  r   r&  r'  )r\  rG   r   rT   rO  sleepr  	r[   r   r%  r   rR  r&  r'  	remainingr   s	            r\   r  zSyncAPIClient._retry_request  sk     &)	//	7DTU7gN 	

7}}'!  
 	
r_   c                N     d fd}|_          j                  |d      S )Nc                0    | j                         | S )N)r   r   r   )r   )r   r   r   r[   s    r\   r   z0SyncAPIClient._request_api_list.<locals>._parser  s&    (( ) 
 Kr_   Fr  )r   rH   rc   rH   )r   r   )r[   r   r   r   r   s   `` ` r\   r   zSyncAPIClient._request_api_list  s'    	 &||D'%|88r_   r   r&  c                    y rX   rY   r[   pathr%  r   r&  s        r\   r   zSyncAPIClient.get  r  r_   r   c                    y rX   rY   r[   r  r%  r   r&  r'  s         r\   r   zSyncAPIClient.get  r  r_   r   r'  c                    y rX   rY   r  s         r\   r   zSyncAPIClient.get  r  r_   r   r&  r'  c          	     x    t        j                  dd|d|}t        t        | j	                  ||||            S Nr   )r   rT   r  rY   )r:   	constructr   r)   r   r[   r  r%  r   r&  r'  optss          r\   r   zSyncAPIClient.get  s?     #,,OEtOwO It||GT&U_|`aar_   )r   r   r  r&  c                    y rX   rY   )r[   r  r%  r   r   r  r&  s          r\   postzSyncAPIClient.post  s     	r_   )r   r   r  c                    y rX   rY   r[   r  r%  r   r   r  r&  r'  s           r\   r  zSyncAPIClient.post       	r_   )r   r   r  r'  c                    y rX   rY   r  s           r\   r  zSyncAPIClient.post  r  r_   )r   r   r  r&  r'  c          	         t        j                  dd||t        |      d|}t        t        | j                  ||||            S Nr  r   rT   r  r  r  rY   )r:   r  r   r   r)   r   )	r[   r  r%  r   r   r  r&  r'  r  s	            r\   r  zSyncAPIClient.post  sP     #,, 
tt>%;P
T[
 It||GT&U_|`aar_   r   r   c               X    t        j                  dd||d|}| j                  ||      S Npatchr   rT   r  rY   r:   r  r   r[   r  r%  r   r   r  s         r\   r  zSyncAPIClient.patch!  s3     #,,aGQUaY`a||GT**r_   r   r  r   c          	     l    t        j                  dd||t        |      d|}| j                  ||      S Nputr  rY   )r:   r  r   r   r[   r  r%  r   r  r   r  s          r\   r  zSyncAPIClient.put,  sB     #,, 
dd.:O
SZ
 ||GT**r_   c               X    t        j                  dd||d|}| j                  ||      S Ndeleter  rY   r  r  s         r\   r  zSyncAPIClient.delete:  s3     #,,bH$RVbZab||GT**r_   r   r   r   r   c               Z    t        j                  d|||d|}| j                  |||      S Nr  rY   r:   r  r   r[   r  r   r   r   r   r   r  s           r\   get_api_listzSyncAPIClient.get_api_listE  s7     #,,`FPT`X_`%%eT488r_   )r   r   r   rd  r   r   r   !float | Timeout | None | NotGivenr   zTransport | Noner   r   r   Limits | Nonert  zhttpx.Client | Noner   re  r   rf  r   r   rc   rd   r   rc   rd   r[   rK   rc   rK   r  ztype[BaseException] | Noner  zBaseException | Noner  zTracebackType | Nonerc   rd   r   r:   rc   rd   r   rj  rc   rd   rX   )r%  rk  r   r:   r   ri  r&  Literal[True]r'  zType[_StreamT]rc   rN   )
r%  rk  r   r:   r   ri  r&  Literal[False]rc   r)   )r%  rk  r   r:   r   ri  r&  r   r'  zType[_StreamT] | Nonerc   ResponseT | _StreamT)r%  rk  r   r:   r   ri  r&  r   r'  type[_StreamT] | Nonerc   r  )r%  rk  r   r:   r   
int | Noner&  r   r'  r  rc   r  )r   r:   r%  rk  r   r   rR  rm  r&  r   r'  r  rc   r  )r   rm   r   Type[SyncPageT]r   r:   rc   rH   
r  r   r%  rk  r   r0   r&  r  rc   r)   )r  r   r%  rk  r   r0   r&  r  r'  type[_StreamT]rc   rN   )r  r   r%  rk  r   r0   r&  r   r'  r  rc   r  )r  r   r%  rk  r   Body | Noner   r0   r  RequestFiles | Noner&  r  rc   r)   )r  r   r%  rk  r   r  r   r0   r  r  r&  r  r'  r  rc   rN   )r  r   r%  rk  r   r  r   r0   r  r  r&  r   r'  r  rc   r  
r  r   r%  rk  r   r  r   r0   rc   r)   r  r   r%  rk  r   r  r  r  r   r0   rc   r)   )r  r   r   rm   r   r  r   r  r   r0   r   r   rc   rH   )re   rf   rg   ri   r   r@   r!   r]   r  r  r  r  r  r  r   r   r  r  r   r   r  r  r  r  r  __classcell__r   s   @r\   r   r     sH   !!4818 /5>&*'+ $+/3748N9 N9 	N9
 N9 3N9 $N9 %N9 N9 )N9 1N9 2N9 &*N9 
N9`&!, " %	
 
$ 
		 
	 
 ,0		 	 %	 )		 	 #	 
	 	 
 ,0	 "'  % )	  
  
 ,0		 ,0	 	 %	 )		 	 *	 
	 	 ,0	
 ,0
 
 %
 )	
 
 *
 

"?
 !?
 %	?

 &?
 ?
 *?
 
?
L 59
$
 !
 	

 2
 
 *
 

499 9 %	9
 
9$  #%!& !	
    
   #%		 !		
  	 	 #	 
	 	  #%,0		 !		
  	 	 *	 
	 	  #%,0bb !	b
  b b *b 
b  !"$%)!&

 !	

 
  
 #
 
 

 
  !"$%) !	
    #  # 
   !"$%),0 !	
    #  * 
 $ !"$%),0bb !	b
 b  b #b b *b 
b* !"$	+	+ !		+
 	+  	+ 
	+  !%)"$++ !	+
 + #+  + 
+& !"$	+	+ !		+
 	+  	+ 
	+" !"$99 	9
 9 9  9 9 
9r_   r   c            	          e Zd ZU ded<   ded<   dZded<   eeddddddd	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d3 fd	Zd4d
Zd5dZ	d6dZ
	 	 	 	 	 	 	 	 d7dZ	 	 	 	 d8dZ	 	 	 	 d9dZeddd	 	 	 	 	 	 	 	 	 d:d       Zedd	 	 	 	 	 	 	 	 	 	 	 d;d       Zeddd	 	 	 	 	 	 	 	 	 	 	 d<d       Zdddd	 	 	 	 	 	 	 	 	 	 	 d<dZ	 	 	 	 	 	 	 	 	 	 	 	 d=dZ	 d>	 	 	 	 	 	 	 	 	 	 	 	 	 d?dZ	 	 	 	 	 	 	 	 d@dZei dd	 	 	 	 	 	 	 	 	 dAd       Zei d	 	 	 	 	 	 	 	 	 	 	 dBd       Zei dd 	 	 	 	 	 	 	 	 	 	 	 dCd!       Zi ddd"	 	 	 	 	 	 	 	 	 	 	 dCd#Zeddi dd$	 	 	 	 	 	 	 	 	 	 	 	 	 dDd%       Zeddi d&	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dEd'       Zeddi dd(	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dFd)       Zddi ddd*	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dFd+Zdi d,	 	 	 	 	 	 	 	 	 dGd-Zddi d&	 	 	 	 	 	 	 	 	 	 	 dHd.Zdi d,	 	 	 	 	 	 	 	 	 dGd/Zdi d0d1	 	 	 	 	 	 	 	 	 	 	 	 	 dId2Z xZS )Jr   zhttpx.AsyncClientr   r   rr  Nztype[AsyncStream[Any]] | Noner   rs  c               J   |)t        j                  dt        d       |	t        d      t        }|)t        j                  dt        d       |	t        d      |)t        j                  dt        d       |	t        d      t        |      s(|	r |	j                  t        k7  r|	j                  }nt        }t        | )  |||t        t        |      |||||
|	
       |	xs( t        j                  |t        t        |      |||
      | _        t!        |	      | _        y )Nrv  rw  rx  r{  r|  r}  r~  r  )
r   r   r   r   r   r   r   r   r   r   r  )r  r  r  r   r>   r5   r   r  r?   r  r]   r   r'   ry   AsyncClientr   r   rr  )r[   r   r   r   r   r   r   r   r   rt  r   r   r   s               r\   r]   zAsyncAPIClient.__init__X  s9    MMz+
 & !qrr#F MMm+
 & !deeMMk+
 & !bcc  {226KK%--)'*#%)(C 	 	
 # 
e&7&7'*'
 (,K'8$r_   c                .    | j                   j                  S rX   r  ru   s    r\   r  zAsyncAPIClient.is_closed  r  r_   c                T   K   | j                   j                          d{    y7 w)r  N)r   acloseru   s    r\   r  zAsyncAPIClient.close  s     
 ll!!###s   (&(c                   K   | S wrX   rY   ru   s    r\   
__aenter__zAsyncAPIClient.__aenter__  s     s   c                @   K   | j                          d {    y 7 wrX   r  r  s       r\   	__aexit__zAsyncAPIClient.__aexit__  s      jjls   c                   K   ywr  rY   r  s     r\   r  zAsyncAPIClient._prepare_options  s     
    c                   K   ywr  rY   r  s     r\   r  zAsyncAPIClient._prepare_request  s      r  F)r&  r   c                  K   y wrX   rY   )r[   r%  r   r&  r   s        r\   r   zAsyncAPIClient.request        	r  )r   c                  K   y wrX   rY   r[   r%  r   r&  r'  r   s         r\   r   zAsyncAPIClient.request        	r  )r'  r   c                  K   y wrX   rY   r  s         r\   r   zAsyncAPIClient.request  r  r  )r&  r'  r   c               J   K   | j                  |||||       d {   S 7 wr  r  r  s         r\   r   zAsyncAPIClient.request  s7      ]]!/ # 
 
 	
 
s   #!#c          	     
  K   | j                  |       d {    | j                  ||      }| j                  |      }| j                  |       d {    	 | j                  j                  || j                  |       d {   }t        j                  d|j                  |j                  |j                  |j                         |j                          | j7                  |||||      S 7 7 7 o# t        j                  $ r}	|dkD  rT| j!                  |	j"                        r9| j%                  ||||	j"                  j&                  ||       d {  7  cY d }	~	S |	j"                  j)                          d {  7   | j+                  |	j"                        d d }	~	wt        j,                  $ r;}	|dkD  r$| j%                  |||||       d {  7  cY d }	~	S t/        |      |	d }	~	wt        j0                  $ r;}	|dkD  r$| j%                  |||||       d {  7  cY d }	~	S t/        |      |	d }	~	wt2        $ r;}	|dkD  r$| j%                  |||||       d {  7  cY d }	~	S t5        |      |	d }	~	ww xY wwr  )r  r   r  r  r   r  r5  rG   r  r   rT   r   r  r  ry   r  r`  r   r  r   areadr   ConnectTimeoutrE   r  r   rF   r+  )
r[   r%  r   r&  r'  r   r  r   r   r  s
             r\   r  zAsyncAPIClient._request  s_     ##G,,,))*;WE%%g.##G,,, 	?!\\..wT=M=MV\.]]HII-w~~w{{HL`L`bjbxbx %%': %%! & 
 	
Q 	- 	- ^
 $$ 	P{t11#,,?!00LL((!) 1     ,,$$&&&77E4O## 	<{!00'7SYfp0qqqq!'2;%% 	<{!00'7SYfp0qqqq!'2; 	?{!00'7SYfp0qqqq$W53>	?s  JC0;JC2J+C6 C4AC6 J2J4C6 6J 	AF!EF!J J"F!?F !F!!J 7G-GG-J J G--J H9!H$"H9&J 'J,H99J I;#I&$I;(J )J.I;;J  Jc                  K   |dz
  }| j                  |||      }t        j                  d|j                  |       t	        j
                  |       d {    | j                  |||||       d {   S 7 "7 wr  )r\  rG   r   rT   anyior  r  r  s	            r\   r  zAsyncAPIClient._retry_request<  s      &)	//	7DTU7gNkk'"""]]'! # 
 
 	
 	#
s$   AA;A7A;2A93A;9A;c                     t        | |||      S )N)r   r   r   r   )r   )r[   r   r   r   s       r\   r   z AsyncAPIClient._request_api_listT  s     T7TQVWWr_   r  c                  K   y wrX   rY   r  s        r\   r   zAsyncAPIClient.get\  r  r  r  c                  K   y wrX   rY   r  s         r\   r   zAsyncAPIClient.getg  r  r  r  c                  K   y wrX   rY   r  s         r\   r   zAsyncAPIClient.gets  r  r  r  c               x   K   t        j                  dd|d|}| j                  ||||       d {   S 7 wr  r  r  s          r\   r   zAsyncAPIClient.get  s?      #,,OEtOwO\\'4:\VVVVs   1:8:)r   r  r   r&  c                  K   y wrX   rY   )r[   r  r%  r   r  r   r&  s          r\   r  zAsyncAPIClient.post  s      	r  r  c                  K   y wrX   rY   r[   r  r%  r   r  r   r&  r'  s           r\   r  zAsyncAPIClient.post        	r  )r   r  r   r'  c                  K   y wrX   rY   r!  s           r\   r  zAsyncAPIClient.post  r"  r  )r   r  r   r&  r'  c          	        K   t        j                  dd||t        |       d {   d|}| j                  ||||       d {   S 7 &7 wr  r:   r  r    r   )	r[   r  r%  r   r  r   r&  r'  r  s	            r\   r  zAsyncAPIClient.post  s^      #,, 
ttAUV[A\;\
`g
 \\'4:\VVV <]Vs!   "AA!AAAAr  c               t   K   t        j                  dd||d|}| j                  ||       d {   S 7 wr  r  r  s         r\   r  zAsyncAPIClient.patch  s=      #,,aGQUaY`a\\'40000   /868c          	        K   t        j                  dd||t        |       d {   d|}| j                  ||       d {   S 7 #7 wr  r%  r  s          r\   r  zAsyncAPIClient.put  sX      #,, 
dd@TUZ@[:[
_f
 \\'4000 ;\0s!   "AAAA
A
Ac               t   K   t        j                  dd||d|}| j                  ||       d {   S 7 wr  r  r  s         r\   r  zAsyncAPIClient.delete  s=      #,,bH$RVbZab\\'40000r'  r   r  c               Z    t        j                  d|||d|}| j                  |||      S r  r  r  s           r\   r  zAsyncAPIClient.get_api_list  s7     #,,`FPT`X_`%%eT488r_   )r   r   r   rd  r   r   r   r   r   r  r   zAsyncTransport | Noner   r   r   r  rt  zhttpx.AsyncClient | Noner   re  r   rf  rc   rd   r   r  r  r  r  r  )
r%  rk  r   r:   r&  r  r   ri  rc   r)   )r%  rk  r   r:   r&  r  r'  type[_AsyncStreamT]r   ri  rc   rO   )r%  rk  r   r:   r&  r   r'  type[_AsyncStreamT] | Noner   ri  rc   ResponseT | _AsyncStreamT)r%  rk  r   r:   r&  r   r'  r,  r   r  rc   r-  rX   )r   r:   r%  rk  r   r   rR  rm  r&  r   r'  r,  rc   r-  )r   rm   r   r   r   r:   rc   "AsyncPaginator[ModelT, AsyncPageT]r  )r  r   r%  rk  r   r0   r&  r  r'  r+  rc   rO   )r  r   r%  rk  r   r0   r&  r   r'  r,  rc   r-  )r  r   r%  rk  r   r  r  r  r   r0   r&  r  rc   r)   )r  r   r%  rk  r   r  r  r  r   r0   r&  r  r'  r+  rc   rO   )r  r   r%  rk  r   r  r  r  r   r0   r&  r   r'  r,  rc   r-  r  r  )r  r   r   rm   r   r   r   r  r   r0   r   r   rc   r.  )re   rf   rg   ri   r   r@   r!   r]   r  r  r  r
  r  r  r   r   r  r  r   r   r  r  r  r  r  r  r   s   @r\   r   r   S  s3   !!9=6= /5>+/'+ $043748N9 N9 	N9
 &*N9 N9 3N9 )N9 %N9 N9 .N9 1N9 2N9 
N9`&$, " %	
 
$ 
		 
	  "'+/  %
  ) 
   ,0	 	 %	
 	 (	 )	 
	 	  26+/	 	 %	
 	 /	 )	 
#	 	  15+/
 
 %

 
 /
 )
 
#
"7
 7
 %7

 7
 /7
 &7
 
#7
| 59
$
 !
 	

 2
 
 /
 
#
0XX X %	X
 
,X  #%!& !	
    
   #%		 !		
  	 	 (	 
	 	  #%15		 !		
  	 	 /	 
#	 	  #%15
W
W !	
W
  
W 
W /
W 
#
W  !%)"$!&

 !	

 
 #
  
 
 

 
  !%)"$ !	
  #    ( 
   !%)"$15 !	
  #    / 
# $ !%)"$15WW !	W
 W #W  W W /W 
#W* !"$	1	1 !		1
 	1  	1 
	1  !%)"$11 !	1
 1 #1  1 
1& !"$	1	1 !		1
 	1  	1 
	1$ !"$99
 9 9 9  9 9 
,9r_   r   )queryextra_headersextra_query
extra_bodyr   r   r   c                    i }|||d<   |t        t        |      |d<   | | |d<   |i |j                  di       ||d<   t        |t              s||d<   |||d<   t        |      r||d<   |S )zECreate a dict of type RequestOptions without keys of NotGiven values.r   r  rV   r   r   r   )r   r+   r   r   r(   r5   )r/  r0  r1  r2  r   r   r   r   s           r\   make_request_optionsr4    s     !G *	 $Z <!Hw{{8R8HKHgx($	"%4!"!,Nr_   c                  &    e Zd ZddZedd       Zy)OtherPlatformc                    || _         y rX   namer[   r9  s     r\   r]   zOtherPlatform.__init__  	    	r_   c                     d| j                    S )NzOther:r8  ru   s    r\   __str__zOtherPlatform.__str__       		{##r_   Nr9  r   rc   rd   rl  re   rf   rg   r]   r   r=  rY   r_   r\   r6  r6         $ $r_   r6  )MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownc                 &   t        j                         j                         } t        j                          j                         }d|v sd|v ry| dk(  ry| dk(  ryd|v ry	| d
k(  r!t        j                         }|dk(  ry|dk(  ryy|rt        |      S y)NiphoneipadrG  darwinrB  windowsrD  androidrH  linuxfreebsdrE  openbsdrF  rC  rI  )rE  systemr   distroidr6  )rS  platform_name	distro_ids      r\   rC  rC  4  s    __$$&F%%'--/M= Fm$;
 M! IIK		!	!]++r_   c                  &    e Zd ZddZedd       Zy)	OtherArchc                    || _         y rX   r8  r:  s     r\   r]   zOtherArch.__init__[  r;  r_   c                     d| j                    S )Nzother:r8  ru   s    r\   r=  zOtherArch.__str__^  r>  r_   Nr?  rl  r@  rY   r_   r\   rY  rY  Z  rA  r_   rY  )x32x64armarm64unknownc                     t        j                         \  } }t        j                         j                         }|dv ry|dk(  ry|dk(  ry| dk(  ry|rt	        |      S y)	N)r_  aarch64r_  r^  x86_64r]  32bitr\  r`  )rE  architecturemachiner   rY  )python_bitness_rf  s      r\   rD  rD  f  sn     --/NA &&(G&& %(  !!r_   c                    i | |}|j                         D ci c]  \  }}t        |t              r|| c}}S c c}}w )zMerge two mappings of the same type, removing any values that are instances of `Omit`.

    In cases with duplicate keys the second mapping takes precedence.
    )rr   r   r#   )obj1obj2mergedr!  r"  s        r\   r   r   }  s?     F)/W:3z%QU?VCJWWWs   <<c                     e Zd ZU ded<   ddZeedd              Zeedd              Zeedd              Z	eedd              Z
edd       Zedd	       Zeddd       Zedd d       Zed!d       Zeddd       Zed
d	 	 	 	 	 d"d       Zed#d       Zedd       Zedd$d       Zedd%d       Zed&d       Zedd$d       Zed
d	 	 	 	 	 d"d       Zed#d       Zy
)'HttpxBinaryResponseContentrg  r   c                    || _         y rX   )r   )r[   r   s     r\   r]   z#HttpxBinaryResponseContent.__init__  s	     r_   c                .    | j                   j                  S rX   )r   contentru   s    r\   rq  z"HttpxBinaryResponseContent.content  s     }}$$$r_   c                .    | j                   j                  S rX   )r   r   ru   s    r\   r   zHttpxBinaryResponseContent.text  s     }}!!!r_   c                .    | j                   j                  S rX   )r   encodingru   s    r\   rt  z#HttpxBinaryResponseContent.encoding  s     }}%%%r_   c                .    | j                   j                  S rX   )r   charset_encodingru   s    r\   rv  z+HttpxBinaryResponseContent.charset_encoding  s     }}---r_   c                :     | j                   j                  di |S )NrY   )r   r   )r[   r  s     r\   r   zHttpxBinaryResponseContent.json  s    !t}}!!+F++r_   c                6    | j                   j                         S rX   )r   r  ru   s    r\   r  zHttpxBinaryResponseContent.read  s    }}!!##r_   Nc                8    | j                   j                  |      S rX   )r   
iter_bytesr[   
chunk_sizes     r\   rz  z%HttpxBinaryResponseContent.iter_bytes  s    }}''
33r_   c                8    | j                   j                  |      S rX   )r   	iter_textr{  s     r\   r~  z$HttpxBinaryResponseContent.iter_text  s    }}&&z22r_   c                6    | j                   j                         S rX   )r   
iter_linesru   s    r\   r  z%HttpxBinaryResponseContent.iter_lines  s    }}''))r_   c                8    | j                   j                  |      S rX   )r   iter_rawr{  s     r\   r  z#HttpxBinaryResponseContent.iter_raw  s    }}%%j11r_   )r|  c                   t        |d      5 }| j                  j                  |      D ]  }|j                  |        	 d d d        y # 1 sw Y   y xY wNwb)mode)openr   rz  write)r[   filer|  fr  s        r\   stream_to_filez)HttpxBinaryResponseContent.stream_to_file  sN     $T" 	a00< 	 	 	s   2A

Ac                6    | j                   j                         S rX   )r   r  ru   s    r\   r  z HttpxBinaryResponseContent.close  s    }}""$$r_   c                R   K   | j                   j                          d {   S 7 wrX   )r   r  ru   s    r\   r  z HttpxBinaryResponseContent.aread  s     ]]((****   '%'c                @   K   | j                   j                  |      S wrX   )r   aiter_bytesr{  s     r\   r  z&HttpxBinaryResponseContent.aiter_bytes  s     }}((44   c                @   K   | j                   j                  |      S wrX   )r   
aiter_textr{  s     r\   r  z%HttpxBinaryResponseContent.aiter_text  s     }}''
33r  c                >   K   | j                   j                         S wrX   )r   aiter_linesru   s    r\   r  z&HttpxBinaryResponseContent.aiter_lines  s     }}((**s   c                @   K   | j                   j                  |      S wrX   )r   	aiter_rawr{  s     r\   r  z$HttpxBinaryResponseContent.aiter_raw  s     }}&&z22r  c               V  K   t        j                  |      }|j                  d       d {   4 d {   }| j                  j	                  |      2 3 d {   }|j                  |       d {    #7 K7 D7 "7 6 d d d       d {  7   y # 1 d {  7  sw Y   y xY wwr  )r  Pathr  r   r  r  )r[   r  r|  r  r  r  s         r\   astream_to_filez*HttpxBinaryResponseContent.astream_to_file  s      zz$-- 	$ 	$"mm77
C $ $dggdm## . 	$$# D	$ 	$ 	$ 	$ 	$s   +B)A9B)A;B)BBA=BB3A?4B9B);B)=B?BBB)BB)B&BB&"B)c                R   K   | j                   j                          d {   S 7 wrX   )r   r  ru   s    r\   r  z!HttpxBinaryResponseContent.aclose  s     ]]))++++r  )r   rg  rc   rd   )rc   bytesrl  )rc   zOptional[str])r  r   rc   r   rX   )r|  ri  rc   zIterator[bytes])r|  ri  rc   Iterator[str])rc   r  )r  zstr | os.PathLike[str]r|  r  rc   rd   r  )r|  ri  rc   zAsyncIterator[bytes])r|  ri  rc   AsyncIterator[str])rc   r  )re   rf   rg   ri   r]   ro  r   rq  r   rt  rv  r   r  rz  r~  r  r  r  r  r  r  r  r  r  r  r  rY   r_   r\   rn  rn    s   ! %  % "  " &  & .  . , , $ $ 4 4 3 3 * * 2 2 
 "&	$ 	
 
  % % + + 5 5 4 4 + + 3 3 
 "&		$$	$ 		$
 
	$ 	$ , ,r_   rn  )r/  Query | Noner0  zHeaders | Noner1  r  r2  r  r   r   r   z'float | httpx.Timeout | None | NotGivenr   zPostParser | NotGivenrc   r0   )rc   Platform)rc   Arch)rj  Mapping[_T_co, Union[_T, Omit]]rk  r  rc   zDict[_T_co, _T])
__future__r   osr   rO  rb  rK  r.  r  rE  r  email.utilstypesr   r   typingr   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   	functoolsr   typing_extensionsr   r   r  ry   rT  r   r   r   r    r   _qsr   _filesr   r    _typesr!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   _utilsr4   r5   r6   _compatr7   r8   _modelsr9   r:   r;   r<   	_responser=   
_constantsr>   r?   r@   rA   
_streamingrB   rC   rD   rE   rF   	getLoggerre   rG   ri   rH   rJ   rK   rL   rN   rO   httpx._configrP   r  ImportErrorrR   rk   r   r   r   r  r  r   r   r   r   r   r4  r6  r  rC  rY  r  rD  r   rn  rY   r_   r\   <module>r     sB   " 	               "   /          8     * 2 1 + U U "  , L L'g''1^ 1 K':;	\)=>
 T]4(:VC[1{3/?@M-Q   F.6|WV_ .6b+a8F#WV_ +a\$WVZ/0 $N#gHV$gfo #gL uU\\5CTCT5T/UV+5kRUFV9V3WX[878 [8|
y9Ju||VC[89 y9xa9Z 1 1;s3C CD a9L $( $""&7@)2"" "" 	"
 "  " 5" '" "J$ $ 		
#L$ $ Y GHHI.	X
)	X
)	X 	Xc,!6 c,Q1  - '-s   +J" "J32J3