
    %Gg                       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 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' d dl&m(Z( d	d
l)m*Z* d	dl+m,Z, d	dl-m.Z.m/Z/ d	dl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z? d	dl@mAZAmBZBmCZCmDZDmEZEmFZF d	dlGmHZHmIZImJZJ d	dlKmLZLmMZMmNZNmOZO d	dlPmQZQmRZRmSZSmTZT d	dlUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\ d	dl]m^Z^m_Z_m`Z`maZa d	dl*mbZbmcZcmdZdmeZe  e	j                  eg      Zhdeid<    edd      Zj edd      Zk ed      Zl edd      Zm ed e^e         Zn ed!e`e         Zoerd d"lpmqZr n	 d d"lpmqZr  G d$ d%      Zt G d& d'eLeel         Zu G d( d)euel   eel         Zv G d* d+eelekf         Zw G d, d-euel   eel         Zx ed.ee$j                  e$j                  f         Z{ ed/ee^e   e`e   f         Z| G d0 d1ee{e|f         Z} G d2 d3e$j                        Z~ere$j                  Zne~Z G d4 d5e      Z G d6 d7e}e$j                  e^e   f         Z G d8 d9e$j                        Zere$j                  ZneZ G d: d;e      Z G d< d=e}e$j                  e`e   f         Zddddde1e1d>	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dOd?Z G d@ dAeedf         Z G dB dC      Zeee dD   f   ZdPdEZ eEdF      dQdG       Z G dH dI      Zeee dJ   f   ZdRdKZdRdLZdSdMZ	 	 	 	 	 	 dTdNZy# es$ r  e6d#      ZrY w xY w)U    )annotationsN)TracebackType)random)TYPE_CHECKINGAnyDictTypeUnionGenericMappingTypeVarIterableIteratorOptional	GeneratorAsyncIteratorcastoverload)Literaloverride
get_origin)URL)PrivateAttr   )_exceptionsQuerystring)to_httpx_filesasync_to_httpx_files)	NOT_GIVENBodyOmitQueryHeadersTimeoutNotGiven	ResponseT
AnyMapping
PostParserRequestFilesHttpxSendArgsRequestOptionsHttpxRequestFilesModelBuilderProtocol)is_dictis_listasyncifyis_given	lru_cache
is_mapping)PYDANTIC_V2
model_copy
model_dump)GenericModelFinalRequestOptionsvalidate_typeconstruct_type)APIResponseBaseAPIResponseAsyncAPIResponseextract_response_type)DEFAULT_TIMEOUTMAX_RETRY_DELAYDEFAULT_MAX_RETRIESINITIAL_RETRY_DELAYRAW_RESPONSE_HEADEROVERRIDE_CAST_TO_HEADERDEFAULT_CONNECTION_LIMITS)Stream
SSEDecoderAsyncStreamSSEBytesDecoder)APIStatusErrorAPITimeoutErrorAPIConnectionErrorAPIResponseValidationErrorzlogging.Loggerlog	SyncPageTzBaseSyncPage[Any])bound
AsyncPageTzBaseAsyncPage[Any]_T_T_coT)	covariant_StreamT_AsyncStreamT)DEFAULT_TIMEOUT_CONFIGg      @c                      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edd
       Z	y)PageInfozStores the necessary 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 selfr\   s     n/home/kushmeetdev/apache_webroot/langgraph_flaskproject/venv/lib/python3.12/site-packages/groq/_base_client.py__init__zPageInfo.__init__w       
     c                    y r`   ra   )rc   r^   s     rd   re   zPageInfo.__init__~   rf   rg   r\   r^   c                    || _         || _        y r`   ri   )rc   r\   r^   s      rd   re   zPageInfo.__init__   s     rg   c                    | j                   r&| j                  j                   d| j                    dS | j                  j                   d| j                   dS )Nz(url=)z(params=)r\   	__class____name__r^   rc   s    rd   __repr__zPageInfo.__repr__   sM    88nn--.eDHH:Q??..))*(4;;-qAArg   N)r\   r   returnNone)r^   r#   rq   rr   )r\   r[   r^   r]   rq   rr   rq   str)
rn   
__module____qualname____doc____annotations__r   re   r    r   rp   ra   rg   rd   rZ   rZ   n   s    
 
  
	    
	  (#,	  !	
 
 B Brg   rZ   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
    r9   _optionsType[_T]_modelc                L    | j                         }|sy| j                         d uS )NF)_get_page_itemsnext_page_info)rc   itemss     rd   has_next_pagezBasePage.has_next_page   s*    $$&""$D00rg   c                     y r`   ra   ro   s    rd   r   zBasePage.next_page_info   s    rg   c                     y r`   ra   ro   s    rd   r   zBasePage._get_page_items   s    rg   c                    t        j                  t        t        | j                  j
                              j                  |j
                        S r`   )httpxQueryParamsr   r   r{   r^   mergerb   s     rd   _params_from_urlzBasePage._params_from_url   s3      c4==+?+?!@AGG

SSrg   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)r^   zUnexpected PageInfo state)r6   r{   _strip_raw_response_header
isinstancer^   r&   r\   r   	copy_withdictrt   
ValueError)rc   infooptionsr^   r\   s        rd   _info_to_optionszBasePage._info_to_options   s    T]]+**,$++x0>>$++>GNN$((H-**4884F(($$F$3C!#**-GNc(GKN455rg   Nrq   bool)rq   zOptional[PageInfo])rq   zIterable[_T])r\   r   rq   zhttpx.QueryParams)r   rZ   rq   r9   )rn   ru   rv   rw   r   r{   rx   r}   r   r   r   r   r   ra   rg   rd   rz   rz      s<    	 %0MH!1"}FH$1 8T6rg   rz   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                b    t         rt        | dd       i | _        || _        || _        || _        y N__pydantic_private__r5   getattrr   r}   r   r{   )rc   clientmodelr   s       rd   _set_private_attributesz$BaseSyncPage._set_private_attributes   3     74)?FN(*D%rg   c              #  h   K   | j                         D ]  }|j                         D ]  }|   y wr`   
iter_pagesr   rc   pageitems      rd   __iter__zBaseSyncPage.__iter__   s9     OO% 	D,,. 
	s   02c              #  ^   K   | }	 | |j                         r|j                         }ny 'wr`   r   get_next_pagerc   r   s     rd   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   r   RuntimeErrorr   r   _request_api_listr}   rm   rc   r   r   s      rd   r   zBaseSyncPage.get_next_page   sZ    ""$k  ''-||--dkkX_-``rg   N)r   r   r   r|   r   r9   rq   rr   )rq   zIterator[_T])rc   rP   rq   zIterator[SyncPageT])rc   rP   rq   rP   )rn   ru   rv   pydanticr   r   rx   r   r   r   r   ra   rg   rd   r   r      sR    1X113G]3     %	 
 
 *
arg   r   c                  @    e Zd Z	 	 	 	 	 	 	 	 	 	 ddZddZddZd	dZy)
AsyncPaginatorc                <    || _         || _        || _        || _        y r`   )r}   r   r{   	_page_cls)rc   r   r   page_clsr   s        rd   re   zAsyncPaginator.__init__   s      !rg   c                >    | j                         j                         S r`   )	_get_page	__await__ro   s    rd   r   zAsyncPaginator.__await__  s    ~~))++rg   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   r}   r{   r   )resprc   s    rd   _parserz)AsyncPaginator._get_page.<locals>._parser  s2    ((kk|| ) 
 Krg   )r   rR   rq   rR   )r{   post_parserr   requestr   )rc   r   s   ` rd   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r`   )r   rR   r   s      rd   	__aiter__zAsyncPaginator.__aiter__  s<     J
  	 	$J 	$s$   2,

20.0202N)
r   AsyncAPIClientr   r9   r   Type[AsyncPageT]r   r|   rq   rr   )rq   z Generator[Any, None, AsyncPageT])rq   rR   rq   zAsyncIterator[_T])rn   ru   rv   re   r   r   r   ra   rg   rd   r   r      sG    
"
" %
" #	
"
 
" 

",Irg   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                b    t         rt        | dd       i | _        || _        || _        || _        y r   r   )rc   r   r   r   s       rd   r   z%BaseAsyncPage._set_private_attributes   r   rg   c               z   K   | j                         2 3 d {   }|j                         D ]  }| 	 $7 6 y wr`   r   r   s      rd   r   zBaseAsyncPage.__aiter__-  sB     //+ 	 	$,,. 
	+s   ;979;9;c               t   K   | }	 | |j                         r|j                          d {   }ny 07 wr`   r   r   s     rd   r   zBaseAsyncPage.iter_pages2  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      rd   r   zBaseAsyncPage.get_next_page;  sd     ""$k  ''-\\33DKKdnn^e3ffffs   A$A-&A+'A-N)r   r|   r   r   r   r9   rq   rr   r   )rc   rR   rq   zAsyncIterator[AsyncPageT])rc   rR   rq   rR   )rn   ru   rv   r   r   r   rx   r   r   r   r   ra   rg   rd   r   r     sR    2h224G^4     %	 
 
 
grg   r   _HttpxClientT_DefaultStreamTc                     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Zded<   eeddd	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d/dZd0dZ	 	 	 	 d1dZ		 	 	 	 	 	 	 	 d2dZ
ddd3dZd4dZd5dZdd	 	 	 	 	 d6dZd7dZd8dZd9dZ	 	 	 	 	 	 	 	 d:d Ze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j8                  dCd)       ZdDd*ZdEdFd+Z	 dE	 	 	 	 	 	 	 dGd,ZdHd-Z dAd.Z!y)I
BaseClientr   r   rt   _versionr   	_base_urlintmax_retrieszUnion[float, Timeout, None]timeoutr   _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 | _	        d | _
        |t        d      y )Nzmax_retries cannot be None. If you want to disable retries, pass `0`; if you want unlimited retries, pass `math.inf` or a very high number; if you want the default behavior, pass `groq.DEFAULT_MAX_RETRIES`)r   _enforce_trailing_slashr   r   r   r   _custom_headers_custom_queryr   r   	_platform	TypeError)rc   versionbase_urlr   r   r   r   r   s           rd   re   zBaseClient.__init__T  s      55c(mD&-3)/R+F(#' *. `  rg   c                z    |j                   j                  d      r|S |j                  |j                   dz         S )N   /raw_path)r   endswithr   rb   s     rd   r   z"BaseClient._enforce_trailing_slashn  s3    <<  &J}}cllT&9}::rg   c                J   |j                   r|j                  sd }d|j                   }nD|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)		is_closedis_stream_consumedstatus_codetextstripjsonloads	Exception_make_status_error)rc   r   r   err_msgerr_texts        rd    _make_status_error_from_responsez+BaseClient._make_status_error_from_responses  s     h&A&A D$X%9%9$:;G}}**,HDLzz(+()=)=(>c$H &&wTH&MM  L"KX5I5I4J&KLs   'B B"!B"c                   t               r`   )NotImplementedError)rc   r   r   r   s       rd   r   zBaseClient._make_status_error  s     "##rg   r   retries_takenc               l   |j                   xs i }t        | j                  |      }| j                  ||       t	        j
                  |      }| j                  }|rB|j                  j                         dk7  r%||vr!|j                  xs | j                         ||<   |D cg c]  }|j                          }}d|vrt        |      |d<   d|vr^t        |j                  t              r| j                  n|j                  }	t        |	t              r|	j                   }	|	t        |	      |d<   |S c c}w )Ngetzx-stainless-retry-countzx-stainless-read-timeout)headers_merge_mappingsdefault_headers_validate_headersr   r$   r   methodloweridempotency_key_idempotency_keyrt   r   r   r&   r%   read)
rc   r   r   r   headers_dictr   idempotency_headerheaderlower_custom_headersr   s
             rd   _build_headerszBaseClient._build_headers  s    .B&t';';^L|^< ---!55'.."6"6"8E"AFX`gFg*1*A*A*\TEZEZE\G&' >LL6LL$,@@14]1CG-.%-AA&0(&KdllQXQ`Q`G'7+!,,"69'l23  Ms   "D1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   )rc   r\   	merge_urlmerge_raw_paths       rd   _prepare_urlzBaseClient._prepare_url  sZ     H	$$!]]33i6H6H6O6OPT6UUN==**N*CCrg   c                    t               S r`   )rH   ro   s    rd   _make_sse_decoderzBaseClient._make_sse_decoder  s
    |rg   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      }|j$                  }|y|j'                  d      rhd	|vr|j)                  d       |r7t+        |      st-        d
t        |       d      | j/                  |      |d<   |st        t0        t3                     }| j5                  |j6                        }	d|	j8                  v r!d|	j8                  j;                  dd      i|d<    | j<                  j>                  d|tA        |jB                  tD              r| jB                  n|jB                  |jF                  |	|r6| jH                  jK                  t        tL        tN        tP        f   |            nd tS        |      r|nd |d|S )NzRequest options: %sT)exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body`r   Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z	 instead.data_sni_hostname-
extensions)r   r   r  r\   r^   r   filesra   )*rO   isEnabledForloggingDEBUGdebugr7   	json_data
extra_jsonr   r!   r4   r   r   typer  default_queryr^   r   r  
startswithpopr/   r   _serialize_multipartformr-   ForceMultipartDictr  r\   hostreplacer   build_requestr   r   r&   r  qs	stringifyr   rt   r   r2   )
rc   r   r   kwargsr"  r   r^   content_typer  prepared_urls
             rd   _build_requestzBaseClient._build_request  s.    GMM*II+Zt-TU!#%%	)  w'9'9:	I&+Iw7I7IJ	"%@i@QQq#rss%%g]%K !3!3W^^D{{>2 #(?(?@U(V- N+ y)#abfgpbqarr{|  "&!>!>y!Iv .0B0DE((5,###$2L4E4E4M4McSV4W#XF<  *t||)) 
$.w$IDLLw>>
 JP477$$T'#s(*;V%DEUY&y1t
 
 	
rg   c                    | j                   j                  |d      }i }|D ]B  \  }}|j                  |      }|s|||<   t        |      r|j	                  |       <||g||<   D |S )Nbrackets)array_format)r-  stringify_itemsr   r0   append)rc   r  r   
serializedkeyvalueexistings          rd   r(  z#BaseClient._serialize_multipartform  s    '' #	 ( 
 )+
 	4JC!~~c*H"'
3 x &#+U"3
3%	4( rg   c                    t        |j                        s|S t        |j                        }|j                  t        t
              }t        |      r||_        t        t        t           |      S |S r`   )	r2   r   r   r'  rE   r    r   r	   r'   )rc   cast_tor   r   override_cast_tos        rd   _maybe_override_cast_toz"BaseClient._maybe_override_cast_to%  s^    (N w'
 #;;'>	J$%%GOY)9::rg   c                F    |j                   j                  t              dk(  S )Nstream)r   r   rD   rc   r   s     rd   _should_stream_response_bodyz'BaseClient._should_stream_response_body6  s    ""#678CCrg   c                  |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 # t        j                  $ r}t        ||      |d }~ww xY w)N)r   r  )type_r:  )r   r   )r   r'   objectinspectisclass
issubclassr.   buildr   r:   r;   r   ValidationErrorrN   )rc   r  r=  r   errs        rd   _process_response_dataz!BaseClient._process_response_data9  s     <	4((f	4((		Tw'Jw@T,UIw}}hT}'RSS//I}7$'OPP	>t#LMM'' 	T,hTJPSS	Ts$   AB4 2&B4 B4 4CCCc                    t               S r`   r   ro   s    rd   r-  zBaseClient.qsQ  s
    }rg   c                     y r`   ra   ro   s    rd   custom_authzBaseClient.custom_authU  s    rg   c                    i S r`   ra   ro   s    rd   auth_headerszBaseClient.auth_headersY  s    	rg   c                r    dd| j                   d| j                         | j                  | j                  S )Nzapplication/json)Acceptr  z
User-Agent)
user_agentplatform_headersrR  r   ro   s    rd   r   zBaseClient.default_headers]  sN     ).//
 ##%	

 
 ""
 	
rg   c                    i | j                   S r`   )r   ro   s    rd   r%  zBaseClient.default_queryh  s    
  
 	
rg   c                     y)zaValidate the given default headers and custom headers.

        Does nothing by default.
        Nra   )rc   r   r   s      rd   r  zBaseClient._validate_headersn  s     	rg   c                L    | j                   j                   d| j                   S )Nz/Python )rm   rn   r   ro   s    rd   rU  zBaseClient.user_agenty  s"    ..))*(4==/BBrg   c                    | j                   S r`   )r   ro   s    rd   r   zBaseClient.base_url}  s    ~~rg   c                z    | j                  t        |t              r|      | _        y t        |            | _        y r`   )r   r   r   r   rb   s     rd   r   zBaseClient.base_url  s-    55ZS=Qc`WZ[^W_`rg   c                D    t        | j                  | j                        S )N)platform)rV  r   r   ro   s    rd   rV  zBaseClient.platform_headers  s      GGrg   c                   |y	 |j                  dd      }t        |      dz  S # t        t        f$ r Y nw xY w|j                  d      }	 t        |      S # t        t        f$ r Y nw xY wt        j
                  j                  |      }|yt        j
                  j                  |      }t        |t        j                         z
        S )a@  Returns a float of the number of seconds (not milliseconds) to wait after retrying, or None if unspecified.

        About the Retry-After header: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Retry-After
        See also  https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Retry-After#syntax
        Nzretry-after-ms  zretry-after)	r   floatr   r   emailutilsparsedate_tz	mktime_tztime)rc   response_headersretry_ms_headerretry_headerretry_date_tuple
retry_dates         rd   _parse_retry_after_headerz$BaseClient._parse_retry_after_header  s     #	.223CTJO)D00:& 		 (++M:	 &&:& 		 !;;33LA#[[**+;<
Z$))+-..s   % 77
A A)(A)c                   |j                  | j                        }| j                  |      }|d|cxk  rdk  r|S  t        ||z
  d      }t        t        t        d|      z  t              }ddt               z  z
  }||z  }	|	dk\  r|	S dS )Nr   <   r_  g       @r   g      ?)get_max_retriesr   rk  minrC   powrA   r   )
rc   remaining_retriesr   rf  r   retry_after
nb_retriessleep_secondsjitterr   s
             rd   _calculate_retry_timeoutz#BaseClient._calculate_retry_timeout  s     --d.>.>? 445EF"q;'<"'< (= '88$?
 /#c:2FFX TFH_$&(!Q,w-A-rg   c                P   |j                   j                  d      }|dk(  rt        j                  d       y|dk(  rt        j                  d       y|j                  dk(  r!t        j                  d	|j                         y|j                  d
k(  r!t        j                  d	|j                         y|j                  dk(  r!t        j                  d	|j                         y|j                  dk\  r!t        j                  d	|j                         yt        j                  d       y)Nzx-should-retrytruez4Retrying as header `x-should-retry` is set to `true`Tfalsez9Not retrying as header `x-should-retry` is set to `false`Fi  zRetrying due to status code %ii  i  i  zNot retrying)r   r   rO   r!  r   )rc   r   should_retry_headers      rd   _should_retryzBaseClient._should_retry  s    &..223CD &(IILM')IIQR 3&II68L8LM 3&II68L8LM 3&II68L8LM 3&II68L8LM		.!rg   c                0    dt        j                          S )Nzstainless-python-retry-)uuiduuid4ro   s    rd   r  zBaseClient._idempotency_key  s    (77rg   )r   rt   r   	str | URLr   r   r   r   r   zfloat | Timeout | Noner   Mapping[str, str] | Noner   Mapping[str, object] | Nonerq   rr   )r\   r   rq   r   )r   httpx.Responserq   rK   )r   rt   r   rF  r   r  rq   z_exceptions.APIStatusError)r   r9   r   r   rq   zhttpx.Headers)r\   rt   rq   r   )rq   zSSEDecoder | SSEBytesDecoder)r   r9   r   r   rq   httpx.Request)r  zMapping[object, object]rq   dict[str, object])r=  type[ResponseT]r   r9   rq   r  )r   r  rq   r   )r  rF  r=  r  r   r  rq   r'   )rq   r   )rq   zhttpx.Auth | None)rq   zdict[str, str])rq   zdict[str, str | Omit])rq   r  )r   r$   r   r$   rq   rr   rs   )rq   r   )r\   z	URL | strrq   rr   )rq   Dict[str, str]r`   )rf  Optional[httpx.Headers]rq   zfloat | None)rq  r   r   r9   rf  r  rq   r`  )r   r  rq   r   )"rn   ru   rv   rx   r   rB   r@   re   r   r   r   r  r  r  r2  r(  r?  rC  rM  propertyr-  rP  rR  r   r%  r  rU  r   setterrV  rk  rv  r{  r  ra   rg   rd   r   r   J  sv   MN((!%%##8<5< /*93748  	
 &*  ( 1 2 
4;
N N 
N,$$ 	$
 !$ 
$$ TU 4 	I
$I
 	I

 
I
V<"DT T !	T
 !T 
T0       
 
 
 

		  	 
		 C C   __a aH /L 59	.. %. 2	.
 
.0!F8rg   r   c                        e Zd Zd fdZ xZS )_DefaultHttpxClientc                    |j                  dt               |j                  dt               |j                  dd       t        |   di | y Nr   limitsfollow_redirectsTra   
setdefaultr@   rF   superre   rc   r/  rm   s     rd   re   z_DefaultHttpxClient.__init__  E    )_5($=>,d3"6"rg   r/  r   rq   rr   rn   ru   rv   re   __classcell__rm   s   @rd   r  r        # #rg   r  c                      e Zd ZddZy)SyncHttpxClientWrapperc                ^    | j                   ry 	 | j                          y # t        $ r Y y w xY wr`   )r   closer   ro   s    rd   __del__zSyncHttpxClientWrapper.__del__  s,    >>	JJL 		s     	,,Nrq   rr   rn   ru   rv   r  ra   rg   rd   r  r     s    rg   r  c                  "    e Zd ZU ded<   dZded<   eedddd	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d3 fdZd4dZd5d	Z	d6d
Z
	 	 	 	 	 	 	 	 d7dZ	 	 	 	 d8dZ	 	 	 	 d9dZe	 d:	 	 	 	 	 	 	 	 	 	 	 d;d       Ze	 d:dd	 	 	 	 	 	 	 	 	 d<d       Ze	 d:ddd	 	 	 	 	 	 	 	 	 	 	 d=d       Z	 d:ddd	 	 	 	 	 	 	 	 	 	 	 d>dZ	 	 	 	 	 	 	 	 	 	 	 	 d?dZ	 	 	 	 	 	 	 	 	 	 	 	 	 	 d@dZdd	 	 	 	 	 	 	 	 	 	 	 	 	 dAdZ	 	 	 	 	 	 	 	 dBdZei dd	 	 	 	 	 	 	 	 	 dCd       Zei d	 	 	 	 	 	 	 	 	 	 	 dDd       Zei dd	 	 	 	 	 	 	 	 	 	 	 dEd        Zi ddd!	 	 	 	 	 	 	 	 	 	 	 dEd"Zedi ddd#	 	 	 	 	 	 	 	 	 	 	 	 	 dFd$       Zedi dd%	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dGd&       Zedi ddd'	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dHd(       Zdi dddd)	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dHd*Zdi d+	 	 	 	 	 	 	 	 	 dId,Zddi d-	 	 	 	 	 	 	 	 	 	 	 dJd.Zdi d+	 	 	 	 	 	 	 	 	 dId/Zdi d0d1	 	 	 	 	 	 	 	 	 	 	 	 	 dKd2Z xZS )Lr   zhttpx.Clientr   Nztype[Stream[Any]] | Noner   r   r   http_clientr   r   c          	     b   t        |      s(|r |j                  t        k7  r|j                  }nt        }|1t	        |t
        j                        st        dt        |             t        	| )  |t        t        |      |||||       |xs t        |t        t        |            | _        y )NzOInvalid `http_client` argument; Expected an instance of `httpx.Client` but got )r   r   r   r   r   r   r   r   r   )r2   r   HTTPX_DEFAULT_TIMEOUTr@   r   r   Clientr   r$  r  re   r   r%   r  r   )
rc   r   r   r   r   r  r   r   r   rm   s
            rd   re   zSyncAPIClient.__init__  s       {226KK%--)":k5<<+Pabfgrbsatu  	'*#%)(C 	 		
 # 
&<'*'
rg   c                .    | j                   j                  S r`   r   r   ro   s    rd   r   zSyncAPIClient.is_closed=      ||%%%rg   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   r  ro   s    rd   r  zSyncAPIClient.close@  s#     4#LL  $rg   c                    | S r`   ra   ro   s    rd   	__enter__zSyncAPIClient.__enter__J  s    rg   c                $    | j                          y r`   r  rc   exc_typeexcexc_tbs       rd   __exit__zSyncAPIClient.__exit__M  s     	

rg   c                    |S z#Hook for mutating the given optionsra   rc   r   s     rd   _prepare_optionszSyncAPIClient._prepare_optionsU  s	    
 rg   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.
        Nra   rB  s     rd   _prepare_requestzSyncAPIClient._prepare_request\  s     rg   c                    y r`   ra   rc   r=  r   rq  rA  
stream_clss         rd   r   zSyncAPIClient.requestg       rg   FrA  c                    y r`   ra   )rc   r=  r   rq  rA  s        rd   r   zSyncAPIClient.requestr       rg   rA  r  c                    y r`   ra   r  s         rd   r   zSyncAPIClient.request|        #rg   c               t    ||j                  | j                        |z
  }nd}| j                  |||||      S Nr   )r=  r   rA  r  r   rn  r   _request)rc   r=  r   rq  rA  r  r   s          rd   r   zSyncAPIClient.request  sP     (#33D4D4DEHYYMM}}!'  
 	
rg   c          	     r   t        |      }| j                  ||      }| j                  |      }|j                  | j                        |z
  }| j                  ||      }| j                  |       i }	| j                  | j                  |	d<   t        j                  d|j                  |j                         	  | j                  j                  |fd|xs | j                  |      i|	}
t        j                  d|j                  |j                  |
j*                  |
j,                  |
j.                         	 |
j1                          | jA                  |||
|||      S # t        j                   $ r_}t        j                  dd       |d	kD  r| j#                  |||||d 
      cY d }~S t        j                  d       t%        |      |d }~wt&        $ r_}t        j                  dd       |d	kD  r| j#                  |||||d 
      cY d }~S t        j                  d       t)        |      |d }~ww xY w# t        j2                  $ r}t        j                  dd       |d	kD  re| j5                  |j6                        rJ|j6                  j9                          | j#                  ||||j6                  j.                  ||      cY d }~S |j6                  j:                  s|j6                  j=                          t        j                  d       | j?                  |j6                        d d }~ww xY w)Nr   authzSending HTTP Request: %s %srA  r   "Encountered httpx.TimeoutExceptionTexc_infor   r   rA  r  rf  Raising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %s!Encountered httpx.HTTPStatusErrorr   rf  rA  r  Re-raising status errorr=  r   r   rA  r  r   )!r6   r?  r  rn  r   r2  r  rP  rO   r!  r  r\   r   sendrC  r   TimeoutException_retry_requestrL   r   rM   r   reason_phraser   raise_for_statusHTTPStatusErrorr{  r   r  r   r  r   _process_response)rc   r=  r   r   rA  r  input_optionsrq  r   r/  r   rL  s               rd   r  zSyncAPIClient._request  s    #7+..w@''0#33D4D4DEU%%g]%Kg& "'!--F6N		/M#	?(t||((S!B!B7!B!S HH 			-NNKK  ""	
	P%%'. %%!' & 
 	
A %% 	<II:TIJ 1$**!"/!)%) +   II-.!'2; 	?II-I= 1$**!"/!)%) +   II01$W53>	?6 $$ 	PII9DII 1$););CLL)I""$**!"/%(\\%9%9!) +   <<))!!#II/077E4O)	Psb   :3E! :H< !H942G&H9,"GH92H4H9"H44H9<L6A;L1
L6A!L11L6c               d   |j                  | j                        |z
  }|dk(  rt        j                  d       nt        j                  d|       | j	                  |||      }t        j                  d|j                  |       t        j                  |       | j                  |||dz   ||      S Nr   z1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)r   r=  r   rA  r  )
rn  r   rO   r!  rv  r   r\   re  sleepr  	rc   r   r=  r   rf  rA  r  rq  r   s	            rd   r  zSyncAPIClient._retry_request  s     $33D4D4DEU!IIn%II'):;//0A7L\]7gN 	

7}}'!+!  
 	
rg   r   r   c               :   t        |      xs |}t        j                  |      rgt        |t              rWt        |t
              st        dt
         d|       t        d|      }t        t         ||| t        |      ||||            S |t        j                  k(  rt        t        |      S t        || t        d|      ||||      }	t        |j                  j                  j                  t                     rt        t        |	      S |	j#                         S )N!API Response types must subclass ; Received type[BaseAPIResponse[Any]]rawr   r=  rA  r  r   r   r  )r   rG  rH  rI  r=   r<   r   r   r'   r?   r   Responser   r   r   r   rD   parse
rc   r=  r   r   rA  r  r   originresponse_clsapi_responses
             rd   r  zSyncAPIClient._process_response&  s    G$/??6"z&/'Jfk2"CK=P[\b[c dee <gFL 1,?!)#"/  enn$	8,,"*G4!'
   ((,,-@AB	<00!!##rg   c                N     d fd}|_          j                  |d      S )Nc                0    | j                         | S )N)r   r   r   )r   )r   r   r   rc   s    rd   r   z0SyncAPIClient._request_api_list.<locals>._parser[  s&    (( ) 
 Krg   Fr  )r   rP   rq   rP   )r   r   )rc   r   r   r   r   s   `` ` rd   r   zSyncAPIClient._request_api_listU  s'    	 &||D'%|88rg   r   rA  c                    y r`   ra   rc   pathr=  r   rA  s        rd   r   zSyncAPIClient.getg  r  rg   r   c                    y r`   ra   rc   r  r=  r   rA  r  s         rd   r   zSyncAPIClient.getq  r  rg   r   r  c                    y r`   ra   r  s         rd   r   zSyncAPIClient.get|  r  rg   r   rA  r  c          	     x    t        j                  dd|d|}t        t        | j	                  ||||            S Nr   )r  r\   r  ra   )r9   	constructr   r'   r   rc   r  r=  r   rA  r  optss          rd   r   zSyncAPIClient.get  s?     #,,OEtOwO It||GT&U_|`aarg   )r   r   r  rA  c                    y r`   ra   )rc   r  r=  r   r   r  rA  s          rd   postzSyncAPIClient.post  s     rg   )r   r   r  c                    y r`   ra   rc   r  r=  r   r   r  rA  r  s           rd   r  zSyncAPIClient.post  s     rg   )r   r   r  r  c                    y r`   ra   r  s           rd   r  zSyncAPIClient.post  s      #rg   )r   r   r  rA  r  c          	         t        j                  dd||t        |      d|}t        t        | j                  ||||            S Nr  r  r\   r"  r  r  ra   )r9   r   r   r   r'   r   )	rc   r  r=  r   r   r  rA  r  r  s	            rd   r  zSyncAPIClient.post  sP     #,, 
tt>%;P
T[
 It||GT&U_|`aarg   r   r   c               X    t        j                  dd||d|}| j                  ||      S Npatchr  r\   r"  ra   r9   r   r   rc   r  r=  r   r   r  s         rd   r  zSyncAPIClient.patch  s3     #,,aGQUaY`a||GT**rg   r   r  r   c          	     l    t        j                  dd||t        |      d|}| j                  ||      S Nputr
  ra   )r9   r   r   r   rc   r  r=  r   r  r   r  s          rd   r  zSyncAPIClient.put  sB     #,, 
dd.:O
SZ
 ||GT**rg   c               X    t        j                  dd||d|}| j                  ||      S Ndeleter  ra   r  r  s         rd   r  zSyncAPIClient.delete  s3     #,,bH$RVbZab||GT**rg   r   r   r   r  c               Z    t        j                  d|||d|}| j                  |||      S Nr  ra   r9   r   r   rc   r  r   r   r   r   r  r  s           rd   get_api_listzSyncAPIClient.get_api_list  7     #,,`FPT`X_`%%eT488rg   )r   rt   r   r  r   r   r   !float | Timeout | None | NotGivenr  zhttpx.Client | Noner   r  r   r  r   r   rq   rr   r   r  rc   rS   rq   rS   r  ztype[BaseException] | Noner  zBaseException | Noner  zTracebackType | Nonerq   rr   r   r9   rq   r9   r   r  rq   rr   r`   )r=  Type[ResponseT]r   r9   rq  Optional[int]rA  Literal[True]r  zType[_StreamT]rq   rV   )
r=  r&  r   r9   rq  r'  rA  Literal[False]rq   r'   )r=  r&  r   r9   rq  r'  rA  r   r  zType[_StreamT] | Nonerq   ResponseT | _StreamT)r=  r&  r   r9   rq  r'  rA  r   r  type[_StreamT] | Nonerq   r*  )r=  r&  r   r9   r   r   rA  r   r  r+  rq   r*  )r   r9   r=  r&  r   r   rf  httpx.Headers | NonerA  r   r  r+  rq   r*  r=  r&  r   r9   r   r  rA  r   r  z1type[Stream[Any]] | type[AsyncStream[Any]] | Noner   r   rq   r'   )r   Type[object]r   Type[SyncPageT]r   r9   rq   rP   
r  rt   r=  r&  r   r,   rA  r)  rq   r'   )r  rt   r=  r&  r   r,   rA  r(  r  type[_StreamT]rq   rV   )r  rt   r=  r&  r   r,   rA  r   r  r+  rq   r*  )r  rt   r=  r&  r   Body | Noner   r,   r  RequestFiles | NonerA  r)  rq   r'   )r  rt   r=  r&  r   r2  r   r,   r  r3  rA  r(  r  r1  rq   rV   )r  rt   r=  r&  r   r2  r   r,   r  r3  rA  r   r  r+  rq   r*  
r  rt   r=  r&  r   r2  r   r,   rq   r'   r  rt   r=  r&  r   r2  r  r3  r   r,   rq   r'   )r  rt   r   r.  r   r/  r   r2  r   r,   r  rt   rq   rP   )rn   ru   rv   rx   r   rB   r    re   r   r  r  r  r  r  r   r   r  r  r  r   r   r  r  r  r  r  r  r  s   @rd   r   r     sc   4818 /5>+/3748,
 ,
 	,

 ,
 3,
 ),
 1,
 2,
 &*,
 
,
\&!, " %	
 
$ 
		 
	 
 ,0	  % )	  # 
  
 ,0	 "'  % )	  
  
 ,0	# ,0# # %# )	# # *# 
# # ,0	
 ,0
 
 %
 )	
 
 *
 

,h
 !h
 %	h

 h
 h
 *h
 
h
T
$
 !

 
 /
 
 *
 

N -$ !-$ %	-$
 !-$ -$ F-$ -$ 
-$^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 
9rg   r   c                        e Zd Zd fdZ xZS )_DefaultAsyncHttpxClientc                    |j                  dt               |j                  dt               |j                  dd       t        |   di | y r  r  r  s     rd   re   z!_DefaultAsyncHttpxClient.__init__  r  rg   r  r  r  s   @rd   r7  r7    r  rg   r7  c                      e Zd ZddZy)AsyncHttpxClientWrapperc                    | j                   ry 	 t        j                         j                  | j	                                y # t
        $ r Y y w xY wr`   )r   asyncioget_running_loopcreate_taskacloser   ro   s    rd   r  zAsyncHttpxClientWrapper.__del__  s@    >>	$$&224;;=A 		s   1A 	AANr  r  ra   rg   rd   r:  r:    s    rg   r:  c                      e Zd ZU ded<   dZded<   eedddd	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d4 fdZd5dZd6d	Z	d7d
Z
	 	 	 	 	 	 	 	 d8dZ	 	 	 	 d9dZ	 	 	 	 d:d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Zdd	 	 	 	 	 	 	 	 	 	 	 	 	 d@dZ	 	 	 	 	 	 	 	 dAdZei dd	 	 	 	 	 	 	 	 	 dBd       Zei d	 	 	 	 	 	 	 	 	 	 	 dCd        Zei dd!	 	 	 	 	 	 	 	 	 	 	 dDd"       Zi ddd#	 	 	 	 	 	 	 	 	 	 	 dDd$Zeddi dd%	 	 	 	 	 	 	 	 	 	 	 	 	 dEd&       Zeddi d'	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dFd(       Zeddi dd)	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dGd*       Zddi ddd+	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 dGd,Zdi d-	 	 	 	 	 	 	 	 	 dHd.Zddi d'	 	 	 	 	 	 	 	 	 	 	 dId/Zdi d-	 	 	 	 	 	 	 	 	 dHd0Zdi d1d2	 	 	 	 	 	 	 	 	 	 	 	 	 dJd3Z xZS )Kr   zhttpx.AsyncClientr   Nztype[AsyncStream[Any]] | Noner   r  c          	     b   t        |      s(|r |j                  t        k7  r|j                  }nt        }|1t	        |t
        j                        st        dt        |             t        	| )  ||t        t        |      ||||       |xs t        |t        t        |            | _        y )NzTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got )r   r   r   r   r   r   r   r  )r2   r   r  r@   r   r   AsyncClientr   r$  r  re   r   r%   r:  r   )
rc   r   r   r   r   r   r  r   r   rm   s
            rd   re   zAsyncAPIClient.__init__!  s       {226KK%--)":k5CTCT+Ufgklwgxfyz  	'*#%)(C 	 		
 # 
&='*'
rg   c                .    | j                   j                  S r`   r  ro   s    rd   r   zAsyncAPIClient.is_closedO  r  rg   c                T   K   | j                   j                          d{    y7 w)r  N)r   r?  ro   s    rd   r  zAsyncAPIClient.closeR  s     
 ll!!###s   (&(c                   K   | S wr`   ra   ro   s    rd   
__aenter__zAsyncAPIClient.__aenter__Y  s        c                @   K   | j                          d {    y 7 wr`   r  r  s       rd   	__aexit__zAsyncAPIClient.__aexit__\  s      jjls   c                   K   |S wr  ra   r  s     rd   r  zAsyncAPIClient._prepare_optionsd  s     
 rG  c                   K   ywr  ra   rB  s     rd   r  zAsyncAPIClient._prepare_requestk  s         F)rA  rq  c                  K   y wr`   ra   )rc   r=  r   rA  rq  s        rd   r   zAsyncAPIClient.requestv        rL  )rq  c                  K   y wr`   ra   rc   r=  r   rA  r  rq  s         rd   r   zAsyncAPIClient.request        rL  )r  rq  c                  K   y wr`   ra   rP  s         rd   r   zAsyncAPIClient.request        %(rL  )rA  r  rq  c                  K   ||j                  | j                        |z
  }nd}| j                  |||||       d {   S 7 wr  r  )rc   r=  r   rA  r  rq  r   s          rd   r   zAsyncAPIClient.request  s^      (#33D4D4DEHYYMM]]!' # 
 
 	
 
s   =AA Ac          	       K   | j                   ! t        t                      d {   | _         t        |      }| j	                  ||      }| j                  |       d {   }|j                  | j                        |z
  }| j                  ||      }| j                  |       d {    i }	| j                  | j                  |	d<   	  | j                  j                  |fd|xs | j                  |      i|	 d {   }
t         j#                  d|j,                  |j.                  |
j0                  |
j2                         	 |
j5                          | jG                  |||
|||       d {   S 7 T7 7 7 }# t        j                  $ rh}t         j#                  dd       |dkD  r%| j%                  |||||d 	       d {  7  cY d }~S t         j#                  d
       t'        |      |d }~wt(        $ rh}t         j#                  dd       |dkD  r%| j%                  |||||d 	       d {  7  cY d }~S t         j#                  d       t+        |      |d }~ww xY w# t        j6                  $ r}t         j#                  dd       |dkD  rw| j9                  |j:                        r\|j:                  j=                          d {  7   | j%                  ||||j:                  j>                  ||       d {  7  cY d }~S |j:                  j@                  s#|j:                  jC                          d {  7   t         j#                  d       | jE                  |j:                        d d }~ww xY w7 w)Nr   r  rA  r  r  Tr  r   r  r  r  r  zHTTP Request: %s %s "%i %s"r  r  r  r  )$r   r1   get_platformr6   r?  r  rn  r   r2  r  rP  r   r  rC  r   r  rO   r!  r  rL   r   rM   r  r\   r   r  r  r  r{  r   r?  r   r   areadr   r  )rc   r=  r   rA  r  r   r  rq  r   r/  r   rL  s               rd   r  zAsyncAPIClient._request  sh     >>! $:8L#9#;;DN
 #7+..w@--g66#33D4D4DEU%%g]%K##G,,, "'!--F6N#	?.T\\..S!B!B7!B!S  HH 			)7>>7;;H\H\^f^t^t	
	P%%'. ++!' , 
 
 	
g < 7 	-
 %% 	<II:TIJ 1$!00!"/!)%) 1     II-.!'2; 	?II-I= 1$!00!"/!)%) 1     II01$W53>	?, $$ 	PII9DII 1$););CLL)Ill))+++!00!"/%(\\%9%9!) 1     <<))ll((***II/077E4O)	P,
s  $NE::N!E="A	N+F ,!N6F FF 	ANI1 N5N
6N=N NF I.6G:GG:I.N"G::I.6I)<H?=I)I.N"I))I..N1NANK3NLNNN3NM6NNNc                 K   |j                  | j                        |z
  }|dk(  rt        j                  d       nt        j                  d|       | j	                  |||      }t        j                  d|j                  |       t        j                  |       d {    | j                  |||dz   ||       d {   S 7 %7 wr  )
rn  r   rO   r!  rv  r   r\   anyior  r  r  s	            rd   r  zAsyncAPIClient._retry_request  s      $33D4D4DEU!IIn%II'):;//0A7L\]7gNkk'"""]]'!+! # 
 
 	
 	#
s$   BCC C?C CCr   r   c               N  K   t        |      xs |}t        j                  |      rct        |t              rSt        |t
              st        dt
         d|       t        d|      }t        d ||| t        |      ||||            S |t        j                  k(  rt        t        |      S t        || t        d|      ||||      }	t        |j                  j                  j                  t                     rt        t        |	      S |	j#                          d {   S 7 w)Nr  r  r  r'   r  r  )r   rG  rH  rI  r=   r>   r   r   r?   r   r  r'   r   r   r   r   rD   r  r  s
             rd   r  z AsyncAPIClient._process_response1  s     G$/??6"z&/'Jf&67"CDTCUU`ag`h ijj <gFL 1,?!)#"/  enn$	8,,'*G4!'
   ((,,-@AB	<00!''))))s   DD%D#D%c                     t        | |||      S )N)r   r   r   r   )r   )rc   r   r   r   s       rd   r   z AsyncAPIClient._request_api_list`  s     T7TQVWWrg   r  c                  K   y wr`   ra   r  s        rd   r   zAsyncAPIClient.geth  rN  rL  r  c                  K   y wr`   ra   r  s         rd   r   zAsyncAPIClient.getr  rQ  rL  r  c                  K   y wr`   ra   r  s         rd   r   zAsyncAPIClient.get}  rS  rL  r  c               x   K   t        j                  dd|d|}| j                  ||||       d {   S 7 wr  r  r  s          rd   r   zAsyncAPIClient.get  s?      #,,OEtOwO\\'4:\VVVVs   1:8:)r   r  r   rA  c                  K   y wr`   ra   )rc   r  r=  r   r  r   rA  s          rd   r  zAsyncAPIClient.post  s      rL  r  c                  K   y wr`   ra   rc   r  r=  r   r  r   rA  r  s           rd   r  zAsyncAPIClient.post  s      rL  )r   r  r   r  c                  K   y wr`   ra   rb  s           rd   r  zAsyncAPIClient.post  s      %(rL  )r   r  r   rA  r  c          	        K   t        j                  dd||t        |       d {   d|}| j                  ||||       d {   S 7 &7 wr	  r9   r   r   r   )	rc   r  r=  r   r  r   rA  r  r  s	            rd   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         rd   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  re  r  s          rd   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         rd   r  zAsyncAPIClient.delete  s=      #,,bH$RVbZab\\'40000rg  r   r  c               Z    t        j                  d|||d|}| j                  |||      S r  r  r  s           rd   r  zAsyncAPIClient.get_api_list  r   rg   )r   rt   r   r  r   r   r   r   r   r!  r  zhttpx.AsyncClient | Noner   r  r   r  rq   rr   r   r  r"  r#  r$  r%  )
r=  r&  r   r9   rA  r)  rq  r'  rq   r'   )r=  r&  r   r9   rA  r(  r  type[_AsyncStreamT]rq  r'  rq   rW   )r=  r&  r   r9   rA  r   r  type[_AsyncStreamT] | Nonerq  r'  rq   ResponseT | _AsyncStreamT)r=  r&  r   r9   rA  r   r  rl  r   r   rq   rm  )r   r9   r=  r&  r   r   rf  r,  rA  r   r  rl  rq   rm  r-  )r   r|   r   r   r   r9   rq   AsyncPaginator[_T, AsyncPageT]r0  )r  rt   r=  r&  r   r,   rA  r(  r  rk  rq   rW   )r  rt   r=  r&  r   r,   rA  r   r  rl  rq   rm  )r  rt   r=  r&  r   r2  r  r3  r   r,   rA  r)  rq   r'   )r  rt   r=  r&  r   r2  r  r3  r   r,   rA  r(  r  rk  rq   rW   )r  rt   r=  r&  r   r2  r  r3  r   r,   rA  r   r  rl  rq   rm  r4  r5  )r  rt   r   r|   r   r   r   r2  r   r,   r  rt   rq   rn  )rn   ru   rv   rx   r   rB   r    re   r   r  rF  rI  r  r  r   r   r  r  r  r   r   r  r  r  r  r  r  r  s   @rd   r   r     sN   9=6= /5>043748,
 ,
 	,

 &*,
 ,
 3,
 .,
 1,
 2,
 
,
\&$, " %	
 
$ 
		 
	  "'+/  %
  ) 
   ,0  %
  ( ) 
   26+/( ( %(
 ( /( )( 
#( ( 15+/
 
 %

 
 /
 )
 
#
,f
 f
 %f

 f
 /f
 f
 
#f
P
$
 !

 
 /
 
 /
 
#
J -* !-* %	-*
 !-* -* F-* -* 
-*^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 
(9rg   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#  r^   r   r  r   )r   r(   r   r   r&   r2   )ro  rp  rq  rr  r  r   r   r   s           rd   make_request_optionsrt    s     !G *	 $Z <!Hw{{8R8HKHgx($	"%4!"!,Nrg   c                      e Zd ZddZy)r)  c                     y)NTra   ro   s    rd   __bool__zForceMultipartDict.__bool__"  s    rg   Nr   )rn   ru   rv   rw  ra   rg   rd   r)  r)  !  s    rg   r)  c                  &    e Zd ZddZedd       Zy)OtherPlatformc                    || _         y r`   namerc   r|  s     rd   re   zOtherPlatform.__init__'  	    	rg   c                     d| j                    S )NzOther:r{  ro   s    rd   __str__zOtherPlatform.__str__*      		{##rg   Nr|  rt   rq   rr   rs   rn   ru   rv   re   r   r  ra   rg   rd   ry  ry  &       $ $rg   ry  )MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownc                 F   	 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# t        $ r Y yw xY w)Nr  iphoneipadr  darwinr  windowsr  androidr  linuxfreebsdr  openbsdr  r  )r]  systemr  r   distroidry  )r  platform_name	distro_ids      rd   rV  rV  >  s    "((* ))+113 = Fm$;
 M! IIK		!	!]++G  s   AB 	B B )maxsizec                   d| t        |xs
 t                     t        t                     t               t	               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)rt   rV  get_architectureget_python_runtimeget_python_version)r   r]  s     rd   rV  rV  h  s;     %'.h8,.9 0 2313'9'; rg   c                  &    e Zd ZddZedd       Zy)	OtherArchc                    || _         y r`   r{  r}  s     rd   re   zOtherArch.__init__u  r~  rg   c                     d| j                    S )Nzother:r{  ro   s    rd   r  zOtherArch.__str__x  r  rg   Nr  rs   r  ra   rg   rd   r  r  t  r  rg   r  )x32x64armarm64unknownc                 J    	 t        j                         S # t        $ r Y yw xY wNr  )r]  python_implementationr   ra   rg   rd   r  r    s(    --//     	""c                 J    	 t        j                         S # t        $ r Y yw xY wr  )r]  python_versionr   ra   rg   rd   r  r    s(    &&(( r  c                     	 t        j                         j                         } | dv ry| dk(  ry| dk(  ryt        j
                  dk  ry| rt        |       S y# t        $ r Y yw xY w)	Nr  )r  aarch64r  r  x86_64r  l        r  )r]  machiner  r   sysr  r  )r  s    rd   r  r    sz    ""$**, && %( {{e!!)  s   "A 	A#"A#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.
    )r   r   r"   )obj1obj2mergedr9  r:  s        rd   r   r     s?     F)/W:3z%QU?VCJWWWs   <<)ro  Query | Nonerp  zHeaders | Nonerq  r  rr  r2  r  r   r   z'float | httpx.Timeout | None | NotGivenr   zPostParser | NotGivenrq   r,   )rq   Platform)r   rt   r]  zPlatform | Nonerq   r  rs   )rq   Arch)r  Mapping[_T_co, Union[_T, Omit]]r  r  rq   zDict[_T_co, _T])
__future__r   r  r   re  r}  ra  r<  rG  r  r]  email.utilstypesr   r   typingr   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   typing_extensionsr   r   r   rY  r   r  r   r   r    r   _qsr   _filesr   r   _typesr    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   _utilsr/   r0   r1   r2   r3   r4   _compatr5   r6   r7   _modelsr8   r9   r:   r;   	_responser<   r=   r>   r?   
_constantsr@   rA   rB   rC   rD   rE   rF   
_streamingrG   rH   rI   rJ   rK   rL   rM   rN   	getLoggerrn   rO   rx   rP   rR   rS   rT   rV   rW   httpx._configrX   r  ImportErrorrZ   rz   r   r   r   r  rB  r   r   r   r  DefaultHttpxClientr  r   r7  DefaultAsyncHttpxClientr:  r   rt  rt   r)  ry  r  rV  rV  r  r  r  r  r  r   ra   rg   rd   <module>r     s   " 
               " < ;          8    " P O 8 8 U U    I H  (g''1^ 1 K':;	\)=>
 T]4(:VC[1{3/?@M-Q$B $BN-6|WR[ -6`.a8B< .ab$WR^, $N&gHRL'"+ &gR uU\\5CTCT5T/UV+5kRUFV9V3WX_878 _8D#%,, #  -/ o9Ju||VC[89 o9d#u00 # #// 7	5 	\9Z 1 1;s3C CD \9B $( $""&7@)2"" "" 	"
 "  " 5" '" "Jc4i 
$ $ 		
'T 4 $ $ Y GHHI4	X
)	X
)	X 	X9  - '-s   7L- -L>=L>