o j@sUddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Zddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlm Z ddl!m"Z"m#Z#m$Z$ddl%Z%ddl&Z&ddl'Z'ddl(Z(ddl&m)Z)m*Z*dd l(m+Z+d d l,m-Z-d d l.m/Z/d d l0m1Z1m2Z2d dl3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDd dlEmFZFmGZGmHZHmIZId dlJmKZKmLZLd dlMmNZNmOZOmPZPmQZQd dlRmSZSmTZTmUZUmVZVd dlWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^d dl_m`Z`maZambZbmcZcd dl-mdZdmeZemfZfmgZgd dlhmiZiejekZldemd<edddZnedddZoedZpedd d!Zqed"e`edZred#ebedZserZdd$ltmuZvnzdd$ltmuZvWnewype9d%ZvYnwGd&d'd'ZxGd(d)d)eNeepZyGd*d+d+eyepeepZzGd,d-d-eepeofZ{Gd.d/d/eyepeepZ|ed0ee&j}e&j~fdZed1ee`eebefdZGd2d3d3eeefZGd4d5d5e&j}ZGd6d7d7ee&j}e`efZGd8d9d9e&j~ZGd:d;d;ee&j~ebefZddddde4e4d<djdLdMZGdNdOdOZeee"dPfZdkdRdSZe ddTdldXdYZGdZd[d[Zeee"d\fZdmd]d^Zdmd_d`ZdndbdcZdodhdiZdS)p) annotationsN) TracebackType)random) TYPE_CHECKINGAnyDictTypeUnionGenericMappingTypeVarIterableIteratorOptional Generator AsyncIteratorcastoverload) lru_cache)Literaloverride get_origin)URLLimits) PrivateAttr) _exceptions Querystring)to_httpx_filesasync_to_httpx_files) NOT_GIVENBodyOmitQueryHeadersTimeoutNotGiven ResponseT Transport AnyMapping PostParser ProxiesTypes RequestFiles HttpxSendArgsAsyncTransportRequestOptionsModelBuilderProtocol)is_dictis_listis_given is_mapping) model_copy model_dump) GenericModelFinalRequestOptions validate_typeconstruct_type) APIResponseBaseAPIResponseAsyncAPIResponseextract_response_type)DEFAULT_LIMITSDEFAULT_TIMEOUTMAX_RETRY_DELAYDEFAULT_MAX_RETRIESINITIAL_RETRY_DELAYRAW_RESPONSE_HEADEROVERRIDE_CAST_TO_HEADER)Stream SSEDecoder AsyncStreamSSEBytesDecoder)APIStatusErrorAPITimeoutErrorAPIConnectionErrorAPIResponseValidationError)LegacyAPIResponsezlogging.Loggerlog SyncPageTzBaseSyncPage[Any])bound AsyncPageTzBaseAsyncPage[Any]_T_T_coT) covariant_StreamT _AsyncStreamT)DEFAULT_TIMEOUT_CONFIGg@c@sPeZdZUdZded<ded<edd d Zedd d Zeed ddd ZdS)PageInfozStores the necessary information to build the request to retrieve the next page. Either `url` or `params` must be set. URL | NotGivenurlQuery | NotGivenparamsrreturnNonecCdSNselfr\rcrcY/var/www/html/fyndo/pharma/fyndo/venv/lib/python3.10/site-packages/openai/_base_client.py__init__{zPageInfo.__init__r$cCrarbrc)rer^rcrcrfrgrhr\r^cCs||_||_dSrbri)rer\r^rcrcrfrgs N)r\rr_r`)r^r$r_r`)r\r[r^r]r_r`)__name__ __module__ __qualname____doc____annotations__rrgr!rcrcrcrfrZrs    rZc@s`eZdZUdZeZded<eZded<ddd Zdd d Z dddZ dddZ dddZ dS)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_optionsType[_T]_modelr_boolcCs|}|sdS|duS)NF)_get_page_itemsnext_page_info)reitemsrcrcrf has_next_pages zBasePage.has_next_pageOptional[PageInfo]cCrarbrcrercrcrfruzBasePage.next_page_info Iterable[_T]cCrarbrcryrcrcrfrtrzzBasePage._get_page_itemsr\rhttpx.QueryParamscCsttt|jj|jSrb)httpx QueryParamsrrrpr^mergerdrcrcrf_params_from_urlszBasePage._params_from_urlinforZcCs|t|j}|t|jtsi|j|j|_|St|jts:||j}|jj|d}t |j|_t ||_|St d)N)r^zUnexpected PageInfo state) r6rp_strip_raw_response_header isinstancer^r'r\r copy_withdictstr ValueError)reroptionsr^r\rcrcrf_info_to_optionss      zBasePage._info_to_optionsNr_rs)r_rx)r_r{)r\rr_r|)rrZr_r9) rjrkrlrmrrprnrrrwrurtrrrcrcrcrfros      roc@FeZdZUeZded<dd d Zdd dZdddZ dddZ dS) BaseSyncPage SyncAPIClient_clientclientmodelrqrr9r_r`cCs||_||_||_dSrbrrrrp)rerrrrcrcrf_set_private_attributes z$BaseSyncPage._set_private_attributes Iterator[_T]ccs(|D] }|D]}|Vq qdSrb iter_pagesrtrepageitemrcrcrf__iter__s   zBaseSyncPage.__iter__rerQIterator[SyncPageT]ccs&|} |V|r|}ndSqrbrw get_next_pagererrcrcrfrs zBaseSyncPage.iter_pagescCs4|}|s td||}|jj|j|j|dSNzYNo next page expected; please check `.has_next_page()` before calling `.get_next_page()`.)rrru RuntimeErrorrr_request_api_listrr __class__rerrrcrcrfrs zBaseSyncPage.get_next_pageN)rrrrqrr9r_r`)r_r)rerQr_r)rerQr_rQ) rjrkrlpydanticrrrnrrrrrcrcrcrfrs     rc@s4eZdZdd d ZdddZdddZdddZdS)AsyncPaginatorrAsyncAPIClientrr9page_clsType[AsyncPageT]rrqr_r`cCs||_||_||_||_dSrb)rrrrp _page_cls)rerrrrrcrcrfrgs zAsyncPaginator.__init__ Generator[Any, None, AsyncPageT]cCs |Srb) _get_page __await__ryrcrcrfrs zAsyncPaginator.__await__rScs0dfdd }|j_jjjIdHS)NresprSr_cs|jjjjd|S)N)rrr)rrrrprrryrcrf_parsers z)AsyncPaginator._get_page.._parser)rrSr_rS)rp post_parserrrequestr)rerrcryrfrszAsyncPaginator._get_pageAsyncIterator[_T]cCs0tt|IdH}|2z 3dHW}|Vq 6dSrb)rrSrrcrcrf __aiter__szAsyncPaginator.__aiter__N) rrrr9rrrrqr_r`)r_r)r_rSr_r)rjrkrlrgrrrrcrcrcrfrs    rc@r) BaseAsyncPagerrrrqrrr9r_r`cCs||_||_||_dSrbr)rerrrrcrcrfrrz%BaseAsyncPage._set_private_attributesrcCs2|2z3dHW}|D]}|Vqq6dSrbrrrcrcrfr(s  zBaseAsyncPage.__aiter__rerSAsyncIterator[AsyncPageT]cCs,|} |V|r|IdH}ndSqrbrrrcrcrfr-szBaseAsyncPage.iter_pagescs<|}|s td||}|jj|j|j|dIdHSrrrrcrcrfr6s zBaseAsyncPage.get_next_pageN)rrqrrrr9r_r`r)rerSr_r)rerSr_rS) rjrkrlrrrrnrrrrrcrcrcrfrs    r _HttpxClientT_DefaultStreamTc@seZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<dZded<eedddd{d&d'Zd|d)d*Zd}d.d/Z d~d4d5Z dd:d;Z dd=d>Z dd?d@Z ddBdCZddEdFZddJdKZddNdOZddQdRZddTdUZeddWdXZeddZd[Zedd]d^Zedd`daZddddeZeddfdgZeddhdiZejddkdiZddmdnZdddrdsZ dddudvZddwdxZ ddydzZ!dS) BaseClientrrr_versionr _base_urlint max_retrieszUnion[float, Timeout, None]timeout httpx.Limits_limitsProxiesTypes | None_proxies!Transport | AsyncTransport | None _transportrs_strict_response_validation str | None_idempotency_headerNztype[_DefaultStreamT] | None_default_stream_cls)rrcustom_headers custom_queryversionbase_url str | URLfloat | Timeout | Nonelimits transportproxiesrMapping[str, str] | NonerMapping[str, object] | Noner_r`c CsX||_|t||_||_||_||_||_||_| pi|_ | p"i|_ ||_ d|_ dSrb) r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr) rerrrrrrrrrrrcrcrfrgRs   zBaseClient.__init__r\cCs"|jdr|S|j|jddS)N/raw_path)rendswithrrdrcrcrfrls z"BaseClient._enforce_trailing_slashresponsehttpx.ResponserKcCs|jr|jsd}d|j}n)|j}|}zt|}d|jd|}Wnty7|p4d|j}Ynw|j|||dS)Nz Error code: z - )bodyr) is_closedis_stream_consumed status_codetextstripjsonloads Exception_make_status_error)rerrerr_msgerr_textrcrcrf _make_status_error_from_responseqs    z+BaseClient._make_status_error_from_responserrobject_exceptions.APIStatusErrorcCstrb)NotImplementedError)rerrrrcrcrfrszBaseClient._make_status_errorremaining_retries Optional[int]rr9cCs|dur|S||jSrb)get_max_retriesr)rerrrcrcrf_remaining_retriesszBaseClient._remaining_retries httpx.HeaderscCsb|jpi}t|j|}|||t|}|j}|r/|jdkr/||vr/|j p,| ||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersr}r%rmethodloweridempotency_key_idempotency_key)rerr headers_dictridempotency_headerrcrcrf_build_headerss    zBaseClient._build_headerscCs4t|}|jr|jj|jd}|jj|dS|S)z Merge a URL argument together with any 'base_url' on the client, to create the URL used for the outgoing request. rr)ris_relative_urlrrlstripr)rer\ merge_urlmerge_raw_pathrcrcrf _prepare_urls zBaseClient._prepare_urlSSEDecoder | SSEBytesDecodercCtSrb)rHryrcrcrf_make_sse_decoderszBaseClient._make_sse_decoder httpx.Requestc CsHttjrtdt|ddi}|j}|jdur:|dur%tt |j}nt |r0t ||j}n t dt |d||}t |j|j}|d}|durt|drtd|vr]|d|rtt|smtd t |d |||d <|jjd |t|jtr|jn|j|j||j|r|j tt!t"t#f|nd||j$d |S)NzRequest options: %sT) exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body` Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z instead.data)rrrr\r^rfilesrc)%rP isEnabledForloggingDEBUGdebugr7 json_data extra_jsonrr"r5rrtyperrr^r startswithpopr2 TypeError_serialize_multipartformr build_requestrrr'rrr\qs stringifyr rrr )rerkwargsrrr^ content_typercrcrf_build_requestsB        zBaseClient._build_requestr Mapping[object, object]dict[str, object]cCs^|jj|dd}i}|D] \}}||}|s|||<q t|r&||q ||g||<q |S)Nbrackets) array_format)rstringify_itemsrr3append)rer rv serializedkeyvalueexistingrcrcrfrs   z#BaseClient._serialize_multipartformcast_totype[ResponseT]cCsDt|js|St|j}|tt}t|r ||_ttt|S|Srb) r4rrrrFr!rrr()rer(rroverride_cast_torcrcrf_maybe_override_cast_to s   z"BaseClient._maybe_override_cast_torcCs|jtdkS)Nstream)rrrErerrcrcrf_should_stream_response_bodysz'BaseClient._should_stream_response_bodyr(c Cs|dur ttdS|turtt|Sz,t|r(t|tr(tt|j||dWS|jr5ttt ||dWSttt ||dWSt j yR}zt ||d|d}~ww)N)rr )type_r&)rr)rr(rinspectisclass issubclassr1buildrr:r;rValidationErrorrN)rer r(rerrrcrcrf_process_response_data!s  z!BaseClient._process_response_datarcCrrbrryrcrcrfr9z BaseClient.qshttpx.Auth | NonecCrarbrcryrcrcrf custom_auth=zBaseClient.custom_authdict[str, str]cCsiSrbrcryrcrcrf auth_headersAr:zBaseClient.auth_headersdict[str, str | Omit]cCs"dd|jd||j|jS)Nzapplication/json)Acceptr z User-Agent) user_agentplatform_headersr<rryrcrcrfrEszBaseClient.default_headersrr%cCdS)zaValidate the given default headers and custom headers. Does nothing by default. Nrc)rerrrcrcrfrP zBaseClient._validate_headerscCs|jjd|jS)Nz/Python )rrjrryrcrcrfr?[szBaseClient.user_agentcCs|jSrb)rryrcrcrfr_r7zBaseClient.base_url URL | strcCs"|t|tr |nt||_dSrb)rrrrrdrcrcrfrcs"Dict[str, str]cCs t|jSrb)r@rryrcrcrfr@g zBaseClient.platform_headersresponse_headersOptional[httpx.Headers] float | Nonec Cs|durdSz |dd}t|dWSttfyYnw|d}zt|WSttfy4Ynwtj|}|durAdStj|}t|tS)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 Nzretry-after-msiz retry-after) rfloatrremailutils parsedate_tz mktime_tztime)rerFretry_ms_header retry_headerretry_date_tuple retry_datercrcrf_parse_retry_after_headerjs&     z$BaseClient._parse_retry_after_headerrIc Csx||j}||}|durd|krdkr|S||}tttd|t}ddt}||} | dkr:| SdS)Nr<g@rg?)rrrSminrDpowrBr) rerrrFr retry_after nb_retries sleep_secondsjitterrrcrcrf_calculate_retry_timeouts  z#BaseClient._calculate_retry_timeoutcCs|jd}|dkrtddS|dkrtddS|jdkr*td |jdS|jd kr8td |jdS|jd krFtd |jdS|jd krTtd |jdStd dS)Nzx-should-retrytruez4Retrying as header `x-should-retry` is set to `true`Tfalsez9Not retrying as header `x-should-retry` is set to `false`FizRetrying due to status code %iiiiz Not retrying)rrrPrr)rershould_retry_headerrcrcrf _should_retrys*        zBaseClient._should_retrycCsdtS)Nzstainless-python-retry-)uuiduuid4ryrcrcrfrszBaseClient._idempotency_key)rrrrrrsrrrrrrrrrrrrrrr_r`)r\rr_r)rrr_rK)rrrrrrr_r)rrrr9r_r)rr9r_r)r\rr_r)r_r)rr9r_r)r rr_r)r(r)rr9r_r))rrr_rs)r rr(r)rrr_r()r_r)r_r8)r_r;)r_r=)rr%rr%r_r`r_r)r_r)r\rCr_r`)r_rDrb)rFrGr_rH)rrrr9rFrGr_rI)rrr_rs)"rjrkrlrnrrCrArgrrrrrrrrrr+r.r6propertyrr9r<rrr?rsetterr@rSr[r_rrcrcrcrfrEsd         :             & #rc@eZdZdddZdS)SyncHttpxClientWrapperr_r`cCs$z|WdStyYdSwrb)closerryrcrcrf__del__s  zSyncHttpxClientWrapper.__del__Nr_r`rjrkrlrhrcrcrcrfrfrfc s eZdZUded<dZded<eeddddddddfdd Zdd!d"Zdd#d$Z dd'd(Z dd/d0Z dd3d4Z dd7d8Z e dddBdCZe ddDdEddHdCZe ddDddIddLdCZ ddDddIddNdCZddPdQZddTdUZddYdZZdd`daZeidDdbddedfZeidgddidfZeiddjddkdfZidDddlddmdfZediddDdnddsdtZedidduddvdtZedidddwddxdtZdiddDddyddzdtZdid{dd|d}Zddid~dddZdid{dddZdidddddZZS)rz httpx.ClientrNztype[Stream[Any]] | Nonerrrrrr http_clientrrrrrrrrr!float | Timeout | None | NotGivenrTransport | Nonerrr Limits | Nonermhttpx.Client | Nonerrrrrrsr_r`c s|durtjdtdd|durtdnt}|dur+tjdtdd|dur+td|dur?tjdtdd|dur?tdt|sP|rN|jtkrN|j}nt}|durct |t j sct d t |tj||tt|||||| | | d |pt|tt||||d d |_dS) NhThe `connection_pool_limits` argument is deprecated. The `http_client` argument should be passed insteadcategory 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`zOInvalid `http_client` argument; Expected an instance of `httpx.Client` but got ) rrrrrrrrrrTrrrrrfollow_redirects)warningswarnDeprecationWarningrr@r4rHTTPX_DEFAULT_TIMEOUTrArr}Clientrrsuperrgrr&rfr) rerrrrrrrrmrrrrrcrfrgsl   zSyncAPIClient.__init__cC|jjSrbrrryrcrcrfr+zSyncAPIClient.is_closedcCst|dr |jdSdS)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrgryrcrcrfrg.s zSyncAPIClient.closererTcCs|Srbrcryrcrcrf __enter__8rzzSyncAPIClient.__enter__exc_typetype[BaseException] | NoneexcBaseException | Noneexc_tbTracebackType | NonecCs |dSrbrgrerrrrcrcrf__exit__;s zSyncAPIClient.__exit__rr9cCrAz#Hook for mutating the given optionsNrcrerrcrcrf_prepare_optionsCszSyncAPIClient._prepare_optionsrrcCrAaThis 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. Nrcr-rcrcrf_prepare_requestJrBzSyncAPIClient._prepare_requestr(Type[ResponseT]rrr, Literal[True] stream_clsType[_StreamT]rWcCrarbrcrer(rrr,rrcrcrfrU zSyncAPIClient.requestFr,Literal[False]r(cCrarbrc)rer(rrr,rcrcrfrarBr,rType[_StreamT] | NoneResponseT | _StreamTcCrarbrcrrcrcrfrlrtype[_StreamT] | NonecCs|j|||||dSN)r(rr,rr_requestrrcrcrfrxs  int | Nonec Cs|||}|||||}||}||i}|jdur'|j|d<z|jj|fd|p5|j|di|} Wnft j yo} z't j ddd|dkr`|j |||||ddWYd} ~ St d t|d| d} ~ wty} z't j d dd|dkr|j |||||ddWYd} ~ St d t|d| d} ~ wwt d |j|j| j| jz| WnLt jy} z>t j d dd|dkr|| jr| j|j |||| jj||dWYd} ~ S| jjs| jt d|| jdd} ~ ww|j||| ||dSNauthr,)rz"Encountered httpx.TimeoutExceptionT)exc_infor)r,rrFzRaising timeout errorzEncountered ExceptionzRaising connection errorzHTTP Request: %s %s "%i %s"z!Encountered httpx.HTTPStatusErrorrzRe-raising status error)r(rrr,r)r+rrrrr9rsendr.r}TimeoutExceptionrPr_retry_requestrLrrMrr\r reason_phraseraise_for_statusHTTPStatusErrorr_rrgrrreadr_process_response) rer(rrr,rretriesrrrr5rcrcrfrs             zSyncAPIClient._requestrFhttpx.Headers | Nonec Csd|d}|dkrtdntd|||||}td|j|t||j|||||dSNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rr(rr,r)rPrr[rr\rNsleepr rerr(rrFr,r remainingrrcrcrfrs    zSyncAPIClient._retry_requestrr1type[Stream[Any]] | type[AsyncStream[Any]] | Nonec Cs|jjtdkrttt||||||dSt|p|}t |rIt |t rIt |t s5t dt d|td|}tt|||t||||dS|tjkrStt|St ||td||||d}t|jjtrntt|S|S)Nr\rawrr(r,rr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r))rrrrErr(rOrr0r1r2r=r<rr?r}Responsersparse rer(rrr,rorigin response_cls api_responsercrcrfrsR      zSyncAPIClient._process_responser Type[object]rType[SyncPageT]rQcs(dfdd }|_j|ddS) NrrQr_cs|jd|S)N)rrr)rrrrrercrfrDs z0SyncAPIClient._request_api_list.._parserFr)rrQr_rQ)rr)rerrrrrcrrfr>szSyncAPIClient._request_api_listrr,pathr0cCrarbrcrerr(rr,rcrcrfrPrBzSyncAPIClient.getrtype[_StreamT]cCrarbrcrerr(rr,rrcrcrfr[rrrcCrarbrcrrcrcrfrgrrr,rcCs.tjdd|d|}tt|j||||dSNr)rr\rrc)r9 constructrr(rrerr(rr,roptsrcrcrfrss )rrr r,r Body | Noner RequestFiles | NonecCrarbrc)rerr(rrr r,rcrcrfposts zSyncAPIClient.post)rrr cCrarbrcrerr(rrr r,rrcrcrfr )rrr rcCrarbrcrrcrcrfrr)rrr r,rc Cs6tjdd||t|d|}tt|j||||dSNrrr\rr rrc)r9rrrr(r) rerr(rrr r,rrrcrcrfrs  rrcC$tjdd||d|}|||SNpatchrr\rrcr9rrrerr(rrrrcrcrfr zSyncAPIClient.patchrr rcCs*tjdd||t|d|}|||SNputrrc)r9rrrrerr(rr rrrcrcrfrs   zSyncAPIClient.putcCrNdeleterrcrrrcrcrfrrzSyncAPIClient.deleterrrrrcC&tjd|||d|}||||SNrrcr9rrrerrrrrrrrcrcrf get_api_list zSyncAPIClient.get_api_list)rrrrrrrrnrrorrrrprmrqrrrrrrsr_r`rrirerTr_rTrrrrrrr_r`rr9r_r`rrr_r`rb) r(rrr9rrr,rrrr_rW) r(rrr9rrr,rr_r() r(rrr9rrr,rsrrr_r) r(rrr9rrr,rsrrr_r) r(rrr9rrr,rsrrr_r)rr9r(rrrrFrr,rsrrr_r r(rrr9rrr,rsrrr_r()rrrrrr9r_rQ rrr(rrr0r,rr_r() rrr(rrr0r,rrrr_rW) rrr(rrr0r,rsrrr_r)rrr(rrrrr0r rr,rr_r()rrr(rrrrr0r rr,rrrr_rW)rrr(rrrrr0r rr,rsrrr_r rrr(rrrrr0r_r( rrr(rrrr rrr0r_r()rrrrrrrrrr0rrr_rQ)rjrkrlrnrrCr!rgrrgrrrrrrrrrrrrrrrr __classcell__rcrcrrfrs   U         ]  9    rc@re)AsyncHttpxClientWrapperr_r`cCs.z t|WdStyYdSwrb)asyncioget_running_loop create_taskacloserryrcrcrfrhs  zAsyncHttpxClientWrapper.__del__Nrirjrcrcrcrfrrkrc seZdZUded<dZded<eeddddddddfdd Zdd!d"Zdd#d$Z dd'd(Z dd/d0Z dd3d4Z dd7d8Z ed9dd:ddBdCZeddDddIdCZedddJddMdCZd9dddNddOdCZddQdRZddUdVZddZd[ZddadbZeid9dcddfdgZeidhddidgZeiddjddkdgZid9ddlddmdgZeddid9dnddsdtZeddiduddvdtZeddiddwddxdtZddid9ddyddzdtZdid{dd|d}Zddidudd~dZdid{dddZdidddddZZS)rzhttpx.AsyncClientrNztype[AsyncStream[Any]] | NonerrlrrrrrrsrrrrnrAsyncTransport | Nonerrrrprmhttpx.AsyncClient | Nonerrrrr_r`c s|durtjdtdd| durtdnt}|dur+tjdtdd| dur+td|dur?tjdtdd| dur?tdt|sP| rN| jtkrN| j}nt}| durct | t j sct d t | tj|||tt||||| | |d | pt|tt||||d d |_dS) Nrrrsrtrwrxryrzr{zTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got ) rrrrrrrrrrTr|)r~rrrr@r4rrrArr} AsyncClientrrrrgrr&rr) rerrrrrrrrrmrrrrcrfrgsl   zAsyncAPIClient.__init__cCrrbrryrcrcrfrNrzAsyncAPIClient.is_closedcs|jIdHdS)rN)rrryrcrcrfrgQszAsyncAPIClient.closererTcs|Srbrcryrcrcrf __aenter__XszAsyncAPIClient.__aenter__rrrrrrcs|IdHdSrbrrrcrcrf __aexit__[szAsyncAPIClient.__aexit__rr9cdSrrcrrcrcrfrcszAsyncAPIClient._prepare_optionsrrcrrrcr-rcrcrfrj zAsyncAPIClient._prepare_requestF)r,rr(rr,rrrr(cdSrbrc)rer(rr,rrcrcrfrurzAsyncAPIClient.request)rrrtype[_AsyncStreamT]rXcrrbrcrer(rr,rrrcrcrfr )rrtype[_AsyncStreamT] | NoneResponseT | _AsyncStreamTcrrbrcrrcrcrfrr )r,rrcs|j|||||dIdHSrrrrcrcrfrs  rc sR|||}||IdH|||}||}||IdHi}|jdur.|j|d<z|jj|fd|p<|j|di|IdH} Wnlt j y|} z*t j ddd|dkrm|j |||||ddIdHWYd} ~ St d t|d| d} ~ wty} z*t j d dd|dkr|j |||||ddIdHWYd} ~ St d t|d| d} ~ wwt d |j|j| j| jz| WnVt jy} zHt j d dd|dkr|| jr| jIdH|j |||| jj||dIdHWYd} ~ S| jjs | jIdHt d|| jdd} ~ ww|j||| ||dIdHSr)r+rrrrr9rrr.r}rrPrrrLrrMrr\rrrrr_rrrrareadrr) rer(rr,rrrrrrr5rcrcrfrs           zAsyncAPIClient._requestrFrc sr|d}|dkrtdntd|||||}td|j|t|IdH|j|||||dIdHSr)rPrr[rr\anyiorrrrcrcrfrs    zAsyncAPIClient._retry_requestrrrc s|jjtdkrttt||||||dSt|p|}t |rJt |t rJt |t s6t dt d|td|}td|||t||||dS|tjkrTtt|St ||td||||d}t|jjtrott|S|IdHS)Nr\rrrrr(r))rrrrErr(rOrr0r1r2r=r>rr?r}rrsrrrcrcrfr#sT      z AsyncAPIClient._process_responserrqrrAsyncPaginator[_T, AsyncPageT]cCst||||dS)N)rrrr)r)rerrrrcrcrfr\sz AsyncAPIClient._request_api_listrrr0crrbrcrrcrcrfrdrzAsyncAPIClient.getrcrrbrcrrcrcrfror rcrrbrcrrcrcrfr{r rcs0tjdd|d|}|j||||dIdHSrrrrcrcrfrs )rr rr,rrr rcrrbrc)rerr(rr rr,rcrcrfrs zAsyncAPIClient.postrcrrbrcrerr(rr rr,rrcrcrfr )rr rrcrrbrcrrcrcrfrr)rr rr,rc s>tjdd||t|IdHd|}|j||||dIdHSrr9rr r) rerr(rr rr,rrrcrcrfrs rc,tjdd||d|}|||IdHSrrrrcrcrfrzAsyncAPIClient.patchcs8tjdd||t|IdHd|}|||IdHSrrrrcrcrfrs zAsyncAPIClient.putcrrrrrcrcrfrrzAsyncAPIClient.deleterrrcCrrrrrcrcrfrrzAsyncAPIClient.get_api_list)rrrrrrsrrrrnrrrrrrprmrrrrrr_r`rrirrrr) r(rrr9r,rrrr_r() r(rrr9r,rrrrrr_rX) r(rrr9r,rsrr rrr_r ) r(rrr9r,rsrr rrr_r )rr9r(rrrrFrr,rsrr r_r r)rrqrrrr9r_rr) rrr(rrr0r,rrrr_rX) rrr(rrr0r,rsrr r_r )rrr(rrrr rrr0r,rr_r()rrr(rrrr rrr0r,rrrr_rX)rrr(rrrr rrr0r,rsrr r_r rr)rrrrqrrrrrr0rrr_r)rjrkrlrnrrCr!rgrrgrrrrrrrrrrrrrrrrrrcrcrrfrs   U          ]  9     r)query extra_headers extra_query extra_bodyrrrr Query | NonerHeaders | Nonerrrrrr'float | httpx.Timeout | None | NotGivenrPostParser | NotGivenr_r0cCsi}|dur ||d<|durtt||d<|dur||d<|dur-i|di||d<t|ts6||d<|dur>||d<t|rF||d<|S)zECreate a dict of type RequestOptions without keys of NotGiven values.Nrrr^rrr)rr*rrr'r4)rrrrrrrrrcrcrfmake_request_optionss   rc@$eZdZd ddZed ddZd S) OtherPlatformnamerr_r`cC ||_dSrbrrerrcrcrfrg$rEzOtherPlatform.__init__cC d|jS)NzOther:r!ryrcrcrf__str__' zOtherPlatform.__str__Nrrr_r`rbrjrkrlrgrr$rcrcrcrfr# r)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownPlatformcCszt}t}Wn tyYdSwd|vs!d|vr#dS|dkr)dS|dkr/dSd |vr5d S|d krKt}|d krCd S|dkrIdSdS|rQt|SdS)Nr0iphoneipadr.darwinr)windowsr+androidr/linuxfreebsdr,openbsdr-r*)platformsystemrrdistroidr)r; platform_name distro_idrcrcrf get_platform;s0  r@)maxsizerrrDcCs"d|ttttttdS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rr@get_architectureget_python_runtimeget_python_version)rrcrcrfr@esr@c@r) OtherArchrrr_r`cCr rbr!r"rcrcrfrgrrEzOtherArch.__init__cCr#)Nzother:r!ryrcrcrfr$ur%zOtherArch.__str__Nr&rbr'rcrcrcrfrFqr(rF)x32x64armarm64unknowncC ztWStyYdSwNrK)r:python_implementationrrcrcrcrfrD}   rDcCrLrM)r:python_versionrrcrcrcrfrErOrEArchcCsrzt\}}t}Wn tyYdSw|dvrdS|dkr%dS|dkr+dS|dkr1dS|r7t|SdS) NrK)rJaarch64rJrIx86_64rH32bitrG)r: architecturemachinerrrF)python_bitness_rVrcrcrfrCs"  rCobj1Mapping[_T_co, Union[_T, Omit]]obj2Dict[_T_co, _T]cCsi||}dd|DS)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. cSs i|] \}}t|ts||qSrc)rr#).0r%r&rcrcrf s z#_merge_mappings..)rv)rYr[mergedrcrcrfrs r)rrrrrrrrrrrrrrr_r0)r_r1)rrr_rDrb)r_rQ)rYrZr[rZr_r\) __future__rrrNr`rJrr0rr:r~ email.utilstypesrrtypingrrrrr r r r r rrrrrr functoolsrtyping_extensionsrrrr r}r<rrrrr_qsr_filesrr _typesr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1_utilsr2r3r4r5_compatr6r7_modelsr8r9r:r; _responser<r=r>r? _constantsr@rArBrCrDrErF _streamingrGrHrIrJrKrLrMrN_legacy_responserO getLoggerrjrPrnrQrSrTrUrWrX httpx._configrYr ImportErrorrZrorrrrrrrrrfrrrrrr1r@r@rFrQrDrErCrrcrcrcrfs  D    L$      #1.'& %  *