o Cji8@s8UddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Zddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlm Z ddl!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 l/m0Z0m1Z1d dl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEd dlFmGZGmHZHmIZId dlJmKZKmLZLd dlMmNZNmOZOmPZPmQZQd dlRmSZSd dlTmUZUmVZVmWZWmXZXd dlYmZZZm[Z[d dl,m\Z\m]Z]m^Z^m_Z_e`eaZbdecd<edddZdedddZeedZfeddd Zged!eZedZhed"e[edZierDdd#ljmkZlnzdd#ljmkZlWnemyZe9d$ZlYnwGd%d&d&ZnGd'd(d(eNee7ZoGd)d*d*eoe7ee7ZpGd+d,d,ee7eefZqGd-d.d.eoe7ee7Zred/ee%jse%jtfdZued0eeZee[efdZvGd1d2d2eeuevfZwGd3d4d4ewe%jseZefZxGd5d6d6ewe%jte[efZyddddde3e3d7d]dGdHZzGdIdJdJZ{ee{e"dKfZ|d^dMdNZ}GdOdPdPZ~ee~e"dQfZd_dSdTZd`dYdZZGd[d\d\eEZdS)a) annotationsN) TracebackType)random) TYPE_CHECKINGAnyDictTypeUnionGenericMappingTypeVarIterableIteratorOptional Generator AsyncIteratorcastoverload) lru_cache)Literaloverride)URLLimits) PrivateAttr) _exceptions Querystring)to_httpx_filesasync_to_httpx_files) NOT_GIVENBodyOmitQueryModelTHeadersTimeoutNotGiven ResponseT Transport AnyMapping PostParser ProxiesTypes RequestFilesAsyncTransportRequestOptionsUnknownResponseModelBuilderProtocolBinaryResponseContent)is_dictis_given is_mapping) model_copy model_dump) GenericModelFinalRequestOptions validate_typeconstruct_type) APIResponse)DEFAULT_LIMITSDEFAULT_TIMEOUTDEFAULT_MAX_RETRIESRAW_RESPONSE_HEADER)Stream AsyncStream)APIStatusErrorAPITimeoutErrorAPIConnectionErrorAPIResponseValidationErrorzlogging.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 necesary information to build the request to retrieve the next page. Either `url` or `params` must be set. URL | NotGivenurlQuery | NotGivenparamsrreturnNonecCdSNselfrSrZrZj/var/www/html/Resume-Parser/resume-parser-inhouse/venv/lib/python3.10/site-packages/openai/_base_client.py__init__tzPageInfo.__init__r#cCrXrYrZ)r\rUrZrZr]r^|r_rSrUcCs||_||_dSrYr`)r\rSrUrZrZr]r^s N)rSrrVrW)rUr#rVrW)rSrRrUrTrVrW)__name__ __module__ __qualname____doc____annotations__rr^r rZrZrZr]rQks    rQc@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_options Type[ModelT]_modelrVboolcCs|}|sdS|duS)NF)_get_page_itemsnext_page_info)r\itemsrZrZr] has_next_pages zBasePage.has_next_pageOptional[PageInfo]cCrXrYrZr\rZrZr]rlzBasePage.next_page_infoIterable[ModelT]cCrXrYrZrprZrZr]rkrqzBasePage._get_page_itemsrSrhttpx.QueryParamscCsttt|jj|jSrY)httpx QueryParamsrrrgrUmerger[rZrZr]_params_from_urlszBasePage._params_from_urlinforQcCs|t|j}|t|jtsi|j|j|_|St|jts:||j}|jj|d}t |j|_t ||_|St d)N)rUzUnexpected PageInfo state) r6rg_strip_raw_response_header isinstancerUr'rSrw copy_withdictstr ValueError)r\rxoptionsrUrSrZrZr]_info_to_optionss      zBasePage._info_to_optionsNrVrj)rVro)rVrr)rSrrVrs)rxrQrVr9) rarbrcrdrrgrerirnrlrkrwrrZrZrZr]rfs      rfc@FeZdZUeZded<dd d Zdd dZdddZ dddZ dS) BaseSyncPage SyncAPIClient_clientclientmodelrhrr9rVrWcCs||_||_||_dSrYrirrg)r\rrrrZrZr]_set_private_attributes z$BaseSyncPage._set_private_attributesIterator[ModelT]ccs(|D] }|D]}|Vq qdSrY iter_pagesrkr\pageitemrZrZr]__iter__s   zBaseSyncPage.__iter__r\rHIterator[SyncPageT]ccs&|} |V|r|}ndSqrYrn get_next_pager\rrZrZr]rs zBaseSyncPage.iter_pagescCs4|}|s td||}|jj|j|j|dSNzYNo next page expected; please check `.has_next_page()` before calling `.get_next_page()`.)rrrl RuntimeErrorrr_request_api_listri __class__r\rxrrZrZr]rs zBaseSyncPage.get_next_pageN)rrrrhrr9rVrW)rVr)r\rHrVr)r\rHrVrH) rarbrcpydanticrrrerrrrrZrZrZr]rs     rc@s4eZdZdd d ZdddZdddZdddZdS)AsyncPaginatorrAsyncAPIClientrr9page_clsType[AsyncPageT]rrhrVrWcCs||_||_||_||_dSrY)rirrg _page_cls)r\rrrrrZrZr]r^s zAsyncPaginator.__init__ Generator[Any, None, AsyncPageT]cCs |SrY) _get_page __await__rprZrZr]rs zAsyncPaginator.__await__rJcs0dfdd }|j_jjjIdHS)NresprJrVcs|jjjjd|S)N)rrr)rrirgrrrprZr]_parsers z)AsyncPaginator._get_page.._parser)rrJrVrJ)rg post_parserrrequestr)r\rrZrpr]rszAsyncPaginator._get_pageAsyncIterator[ModelT]cCs0tt|IdH}|2z 3dHW}|Vq 6dSrY)rrJrrZrZr] __aiter__ szAsyncPaginator.__aiter__N) rrrr9rrrrhrVrW)rVr)rVrJrVr)rarbrcr^rrrrZrZrZr]rs    rc@r) BaseAsyncPagerrrrhrrr9rVrWcCs||_||_||_dSrYr)r\rrrrZrZr]rrz%BaseAsyncPage._set_private_attributesrcCs2|2z3dHW}|D]}|Vqq6dSrYrrrZrZr]r!s  zBaseAsyncPage.__aiter__r\rJAsyncIterator[AsyncPageT]cCs,|} |V|r|IdH}ndSqrYrrrZrZr]r&szBaseAsyncPage.iter_pagescs<|}|s td||}|jj|j|j|dIdHSrrrrZrZr]r/s zBaseAsyncPage.get_next_pageN)rrhrrrr9rVrWr)r\rJrVr)r\rJrVrJ) rarbrcrrrrerrrrrZrZrZr]rs    r _HttpxClientT_DefaultStreamTc@seZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<dZded<eeddddwd&d'Zdxd)d*Zdyd.d/Z dzd4d5Z d{d:d;Z d|d=d>Z d}d?d@Z d~dBdCZddGdHZddOdPZddRdSZeddUdVZeddXdYZedd[d\Zedd^d_ZddbdcZeddddeZeddfdgZejddidgZeddjddldmZ dddqdrZddsdtZddudvZdS) BaseClientrrr}_versionr _base_urlint max_retrieszUnion[float, Timeout, None]timeout httpx.Limits_limitsProxiesTypes | None_proxies!Transport | AsyncTransport | None _transportrj_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] | NonerVrWc CsX||_|t||_||_||_||_||_||_| pi|_ | p"i|_ ||_ d|_ dSrY) r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr) r\rrrrrrrrrrrZrZr]r^Ks   zBaseClient.__init__rScCs"|jdr|S|j|jddS)N/raw_path)rendswithr{r[rZrZr]res z"BaseClient._enforce_trailing_slashresponsehttpx.ResponserCcCsb|j}|}zt|}d|jd|}Wnty(|p%d|j}Ynw|j|||dS)Nz Error code: z - )bodyr)textstripjsonloads status_code Exception_make_status_error)r\rerr_textrerr_msgrZrZr] _make_status_error_from_responsejs   z+BaseClient._make_status_error_from_responserrobject_exceptions.APIStatusErrorcCstrY)NotImplementedError)r\rrrrZrZr]ryszBaseClient._make_status_errorremaining_retries Optional[int]rr9cCs|dur|S||jSrY)get_max_retriesr)r\rrrZrZr]_remaining_retriesszBaseClient._remaining_retries httpx.HeaderscCsj|jpi}t|j|}|||t|}|j}|r3|jdkr3||vr3|j s.| |_ |j ||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersrtr%rmethodloweridempotency_key_idempotency_key)r\rr headers_dictridempotency_headerrZrZr]_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{)r\rS merge_urlmerge_raw_pathrZrZr] _prepare_urls zBaseClient._prepare_url httpx.Requestc Cs2ttjrtdt|ddi}|j}|jdur:|dur%tt |j}nt |r0t ||j}n t dt |d||}t |j|j}|ddkri|d|rit|sbtdt |d |||d <|jjd |t|jtrw|jn|j|j||j|r|jtt t!t"f|nd||j#d |S) NzRequest options: %sT) exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body` Content-Typezmultipart/form-datazGExpected query input to be a dictionary for multipart requests but got z instead.data)rrrrSrUrfilesrZ)$rG isEnabledForloggingDEBUGdebugr7 json_data extra_jsonrr!r5rrtyperrrUrpopr3 TypeError_serialize_multipartformr build_requestrzrr'rrrSqs stringifyr r}rr)r\rkwargsrrrUrZrZr]_build_requests>       zBaseClient._build_requestrMapping[object, object]dict[str, object]cCsF|jj|dd}i}|D]\}}||vrtd|d|||<q |S)Nbrackets) array_formatzDuplicate key encountered: z!; This behaviour is not supported)r stringify_itemsr~)r\rrm serializedkeyvaluerZrZr]rs  z#BaseClient._serialize_multipartformcast_toType[ResponseT]stream stream_cls1type[Stream[Any]] | type[AsyncStream[Any]] | Noner(cCs8t||||||d}|jjtdkrtt|S|S)N)rawrrrrrtrue)r<rrrr@rr(parse)r\rrrrr api_responserZrZr]_process_responses  zBaseClient._process_responsetype[ResponseT]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(r0inspectisclass issubclassr1buildrr:r;rValidationErrorrF)r\rrrerrrZrZr]_process_response_datas  z!BaseClient._process_response_datarcCstSrYrrprZrZr]r z BaseClient.qshttpx.Auth | NonecCrXrYrZrprZrZr] custom_authzBaseClient.custom_authdict[str, str]cCsiSrYrZrprZrZr] auth_headers!r+zBaseClient.auth_headersdict[str, str | Omit]cCs"dd|jd||j|jS)Nzapplication/json)Acceptrz User-Agent) user_agentplatform_headersr-rrprZrZr]r%szBaseClient.default_headersrr%cCdS)zaValidate the given default headers and custom headers. Does nothing by default. NrZ)r\rrrZrZr]r0 zBaseClient._validate_headerscCs|jjd|jS)Nz/Python )rrarrprZrZr]r0;szBaseClient.user_agentcCs|jSrY)rrprZrZr]r?r(zBaseClient.base_url URL | strcCst|tr|nt||j_dSrY)rzrrrr[rZrZr]rCs)maxsizeDict[str, str]cCs(d|jttttttdS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rr} get_platformget_architectureplatformpython_implementationpython_versionrprZrZr]r1GszBaseClient.platform_headersresponse_headersOptional[httpx.Headers]floatcCs||j}z8|dur;|d}zt|}Wn&ty:tj|}|dur*d}ntj|}t|t }Ynwd}Wn tyId}Ynwd|krUdkrV|Sd} d} ||} t | t d| | } dd t } | | }|dkry|SdS) Nz retry-afterr<g?g @g@rg?) rrrrremailutils parsedate_tz mktime_tztimeminpowr)r\rrr=r retry_header retry_afterretry_date_tuple retry_dateinitial_retry_delaymax_retry_delay nb_retries sleep_secondsjitterrrZrZr]_calculate_retry_timeoutRs:       z#BaseClient._calculate_retry_timeoutcCs`|jd}|dkr dS|dkrdS|jdkrdS|jdkr dS|jdkr'dS|jd kr.dSdS) Nzx-should-retryrTfalseFiiii)rrr)r\rshould_retry_headerrZrZr] _should_retrys     zBaseClient._should_retrycCsdtS)Nzstainless-python-retry-)uuiduuid4rprZrZr]rszBaseClient._idempotency_key)rr}rrrrjrrrrrrrrrrrrrrrVrW)rSrrVr)rrrVrC)rr}rrrrrVr)rrrr9rVr)rr9rVr)rSr}rVr)rr9rVr)rr rVr) rrrr9rrrrjrrrVr()rrrrrrrVr()rVr)rVr))rVr,)rVr.)rr%rr%rVrWrVr})rVr)rSr4rVrW)rVr6rY)rrrr9r=r>rVr?)rrrVrj) rarbrcrerr?r>r^rrrrrrr rrr'propertyr r*r-rrr0rsetterrr1rRrUrrZrZrZr]r>s`        6            -rc s eZdZUded<ded<dZded<eeddddddddfd d!Zdd"d#Zdd$d%Z dd(d)Z dd0d1Z dd4d5Z dd8d9Z e dddCdDZe ddEdFddIdDZe ddEddJddMdDZ ddEddJddOdDZddQdRZ dddUdVZdd\d]ZeidEd^ddadbZeidcddedbZeiddfddgdbZidEddhddidbZediddEdjddodpZediddqddrdpZedidddsddtdpZdiddEdduddvdpZdidwddxdyZddidzdd{d|Zdidwdd}d~ZdidddddZZS)rz httpx.Clientrrj_has_custom_http_clientNztype[Stream[Any]] | Nonerrrrrr http_clientrrrr}rrrrr!float | Timeout | None | NotGivenrTransport | Nonerrr Limits | Noner]httpx.Client | NonerrrrrrVrWc s|durtjdtdd|durtdnt}|dur+tjdtdd|dur+td|dur?tjdtdd|dur?tdt|sP|rN|jtkrN|j}nt}t j ||t t |||||| | | d |pqt j|t t ||||d |_t||_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`) rrrrrrrrrrrrrrr)warningswarnDeprecationWarningr~r=r4rHTTPX_DEFAULT_TIMEOUTr>superr^rr&rtClientrrjr[) r\rrrrrrrr]rrrrrZr]r^sd zSyncAPIClient.__init__cC|jjSrYr is_closedrprZrZr]rvzSyncAPIClient.is_closedcCst|dr |jdSdS)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrcloserprZrZr]rzs zSyncAPIClient.closer\rKcCs|SrYrZrprZrZr] __enter__rqzSyncAPIClient.__enter__exc_typetype[BaseException] | NoneexcBaseException | Noneexc_tbTracebackType | NonecCs |dSrYrzr\r|r~rrZrZr]__exit__s zSyncAPIClient.__exit__rr9cCr2z#Hook for mutating the given optionsNrZr\rrZrZr]_prepare_options szSyncAPIClient._prepare_optionsrrcCr2aThis 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. NrZr\rrZrZr]_prepare_requestr3zSyncAPIClient._prepare_requestrrrrr Literal[True]rType[_StreamT]rNcCrXrYrZr\rrrrrrZrZr]r zSyncAPIClient.requestFrLiteral[False]r(cCrXrYrZ)r\rrrrrZrZr]r*r3rrType[_StreamT] | NoneResponseT | _StreamTcCrXrYrZrrZrZr]r5rtype[_StreamT] | NonecCs|j|||||dSN)rrrrr_requestrrZrZr]rAs  int | Nonec Cs||||||}||}||z|jj||j|d}td|j |j |j |j | Wntjyh} z)|dkrX|| jrX|j|||| jj||dWYd} ~ S| j|| jdd} ~ wtjy} z|dkr|j|||||dWYd} ~ St|d| d} ~ wty} z|dkr|j|||||dWYd} ~ St|d| d} ~ ww|j|||||dSN)authrzHTTP Request: %s %s "%i %s"rr)r)rrrrr)rrr rrsendr*rGrrrSr reason_phraseraise_for_statusrtHTTPStatusErrorrUr_retry_requestrreadrTimeoutExceptionrDrrEr) r\rrrrrretriesrrr&rZrZr]rRsj        zSyncAPIClient._requestr=r>c CsD|d}||||}td|j|t||j|||||dSNrz$Retrying request to %s in %f seconds)rrrrr)rRrGrxrSrFsleepr r\rrrr=rr remainingrrZrZr]rs  zSyncAPIClient._retry_requestrrhrType[SyncPageT]rHcs(dfdd }|_j|ddS) NrrHrVcs|jd|S)N)rrr)rrrrr\rZr]rs z0SyncAPIClient._request_api_list.._parserFr)rrHrVrH)rr)r\rrrrrZrr]rszSyncAPIClient._request_api_listrrpathr/cCrXrYrZr\rrrrrZrZr]rr3zSyncAPIClient.getrtype[_StreamT]cCrXrYrZr\rrrrrrZrZr]rrrrcCrXrYrZrrZrZr]rrrrrcCs.tjdd|d|}tt|j||||dSNr)rrSrrZ)r9 constructrr(rr\rrrrroptsrZrZr]rs )rrrrr Body | NonerRequestFiles | NonecCrXrYrZ)r\rrrrrrrZrZr]posts zSyncAPIClient.post)rrrcCrXrYrZr\rrrrrrrrZrZr]r )rrrrcCrXrYrZrrZrZr]r r)rrrrrc Cs6tjdd||t|d|}tt|j||||dSNrrrSrrrrZ)r9rrrr(r) r\rrrrrrrrrZrZr]rs  rrcC$tjdd||d|}|||SNpatchrrSrrZr9rrr\rrrrrrZrZr]r) zSyncAPIClient.patchrrrcCs*tjdd||t|d|}|||SNputrrZ)r9rrrr\rrrrrrrZrZr]r4s   zSyncAPIClient.putcCrNdeleterrZrrrZrZr]rBrzSyncAPIClient.deleterrrrrcC&tjd|||d|}||||SNrrZr9rrr\rrrrrrrrZrZr] get_api_listMs zSyncAPIClient.get_api_list)rr}rrrrrr^rr_rrrr`r]rarrrrrrjrVrWrrVrWr\rKrVrKr|r}r~rrrrVrWrr9rVrWrrrVrWrY) rrrr9rrrrrrrVrN) rrrr9rrrrrVr() rrrr9rrrrjrrrVr) rrrr9rrrrjrrrVr) rrrr9rrrrjrrrVr)rr9rrrrr=r>rrjrrrVr)rrhrrrr9rVrH rr}rrrr/rrrVr() rr}rrrr/rrrrrVrN) rr}rrrr/rrjrrrVr)rr}rrrrrr/rrrrrVr()rr}rrrrrr/rrrrrrrVrN)rr}rrrrrr/rrrrjrrrVr rr}rrrrrr/rVr( rr}rrrrrrrr/rVr()rr}rrhrrrrrr/rr}rVrH)rarbrcrerr?r r^rvrzr{rrrrrrrrrrrrrr __classcell__rZrZrsr]rs   P        F     rc seZdZUded<ded<dZded<eeddddddddfd d!Zdd"d#Zdd$d%Z dd(d)Z dd0d1Z dd4d5Z dd8d9Z ed:dd;ddCdDZeddEddJdDZedddKddNdDZd:dddOddPdDZddRdSZ dddVdWZdd]d^Zeid:d_ddbdcZeiddddedcZeiddfddgdcZid:ddhddidcZeddid:djddodpZeddidqddrdpZeddiddsddtdpZddid:dduddvdpZdidwddxdyZddidqddzd{Zdidwdd|d}Zdid~ddddZZS)rzhttpx.AsyncClientrrjr[Nztype[AsyncStream[Any]] | Nonerr\rr}rrrrrrr^rAsyncTransport | Nonerrrr`r]httpx.AsyncClient | NonerrrrrVrWc s|durtjdtdd| durtdnt}|dur+tjdtdd| dur+td|dur?tjdtdd| dur?tdt|sP| rN| jtkrN| j}nt}t j |||t t ||||| | |d | pqt j|t t ||||d |_t| |_dS) Nrbrcrdrgrhrirjrk) rrrrrrrrrrrl)rmrnror~r=r4rrpr>rqr^rr&rt AsyncClientrrjr[) r\rrrrrrrrr]rrrsrZr]r^`sd zAsyncAPIClient.__init__cCrtrYrurprZrZr]rvrwzAsyncAPIClient.is_closedcs|jIdHdS)rxN)racloserprZrZr]rzszAsyncAPIClient.closer\rKcs|SrYrZrprZrZr] __aenter__szAsyncAPIClient.__aenter__r|r}r~rrrcs|IdHdSrYrrrZrZr] __aexit__szAsyncAPIClient.__aexit__rr9cdSrrZrrZrZr]rszAsyncAPIClient._prepare_optionsrrcrrrZrrZrZr]r zAsyncAPIClient._prepare_requestF)rrrrrrrrr(cdSrYrZ)r\rrrrrZrZr]rrzAsyncAPIClient.request)rrrtype[_AsyncStreamT]rOcrrYrZr\rrrrrrZrZr]r )rrtype[_AsyncStreamT] | NoneResponseT | _AsyncStreamTcrrYrZrrZrZr]rr)rrrcs|j|||||dIdHSrrrrZrZr]rs  rc s||IdH|||}||}||IdHz |jj||j|dIdH}td|j |j |j |j | Wntjyx} z/|dkre|| jre|j|||| jj||dIdHWYd} ~ S| jIdH|| jdd} ~ wtjy} z|dkr|j|||||dIdHWYd} ~ St|d| d} ~ wtjy} z|dkr|j|||||dIdHWYd} ~ St|d| d} ~ wty} z|dkr|j|||||dIdHWYd} ~ St|d| d} ~ ww|j|||||dSr)rrr rrrr*rGrrrSrrrrtrrUrrrareadrConnectTimeoutrDrrrEr) r\rrrrrrrrr&rZrZr]r s^    & & & zAsyncAPIClient._requestr=r>c sR|d}||||}td|j|t|IdH|j|||||dIdHSr)rRrGrxrSanyiorrrrZrZr]rDs  zAsyncAPIClient._retry_requestrrhrr"AsyncPaginator[ModelT, AsyncPageT]cCst||||dS)N)rrrr)r)r\rrrrZrZr]r\sz AsyncAPIClient._request_api_listrrr/crrYrZrrZrZr]rdrzAsyncAPIClient.getrcrrYrZrrZrZr]rorrcrrYrZrrZrZr]r{rrcs0tjdd|d|}|j||||dIdHSrrrrZrZr]rs )rrrrrrrrcrrYrZ)r\rrrrrrrZrZr]rs zAsyncAPIClient.postrcrrYrZr\rrrrrrrrZrZr]r )rrrrcrrYrZrrZrZr]rr)rrrrrc s>tjdd||t|IdHd|}|j||||dIdHSrr9rrr) r\rrrrrrrrrZrZr]rs rc,tjdd||d|}|||IdHSrrrrZrZr]rzAsyncAPIClient.patchcs8tjdd||t|IdHd|}|||IdHSrrrrZrZr]rs zAsyncAPIClient.putcrrrrrZrZr]rrzAsyncAPIClient.deleterrrcCrrrrrZrZr]rs zAsyncAPIClient.get_api_list)rr}rrrrjrrrr^rrrrrr`r]rrrrrrVrWrrrrrr) rrrr9rrrrrVr() rrrr9rrrrrrrVrO) rrrr9rrjrrrrrVr) rrrr9rrjrrrrrVrrY)rr9rrrrr=r>rrjrrrVr)rrhrrrr9rVrr) rr}rrrr/rrrrrVrO) rr}rrrr/rrjrrrVr)rr}rrrrrrrr/rrrVr()rr}rrrrrrrr/rrrrrVrO)rr}rrrrrrrr/rrjrrrVrrr)rr}rrhrrrrrr/rr}rVr)rarbrcrerr?r r^rvrzrrrrrrrrrrrrrrrrrZrZrsr]r[s   P         >      r)query extra_headers extra_query extra_bodyrrrr Query | NonerHeaders | Nonerrrrrr'float | httpx.Timeout | None | NotGivenrPostParser | NotGivenrVr/cCsi}|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.NrrrUrrr)rr*rrzr'r4)rrrrrrrrrZrZr]make_request_optionss   rc@$eZdZd ddZed ddZd S) OtherPlatformnamer}rVrWcC ||_dSrYrr\rrZrZr]r^% zOtherPlatform.__init__cC d|jS)NzOther:rrprZrZr]__str__( zOtherPlatform.__str__Nrr}rVrWrXrarbrcr^rrrZrZrZr]r$ r)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownPlatformcCst}t}d|vsd|vrdS|dkrdS|dkr"dSd|vr(d S|d kr>t}|d kr6d S|d krs z#_merge_mappings..)rm)r*r,mergedrZrZr]rs rc@sReZdZUded<d=ddZeed>dd Zeed?d d Zeed@ddZ eed@ddZ edAddZ ed>ddZ edBdCddZ edBdDdd ZedEd!d"ZedBdCd#d$Zedd%dFd)d*ZedGd+d,Zed>d-d.ZedBdHd0d1ZedBdId3d4ZedJd5d6ZedBdHd7d8Zedd%dFd9d:ZedGd;d<ZdS)KHttpxBinaryResponseContentrrrVrWcCrrY)r)r\rrZrZr]r^rz#HttpxBinaryResponseContent.__init__bytescCrtrY)rcontentrprZrZr]r3z"HttpxBinaryResponseContent.contentr}cCrtrY)rrrprZrZr]rr4zHttpxBinaryResponseContent.text Optional[str]cCrtrY)rencodingrprZrZr]r6r4z#HttpxBinaryResponseContent.encodingcCrtrY)rcharset_encodingrprZrZr]r7r4z+HttpxBinaryResponseContent.charset_encodingr rcKs|jjdi|S)NrZ)rr)r\r rZrZr]rszHttpxBinaryResponseContent.jsoncC |jSrY)rrrprZrZr]r zHttpxBinaryResponseContent.readN chunk_sizerIterator[bytes]cC |j|SrY)r iter_bytesr\r:rZrZr]r=rz%HttpxBinaryResponseContent.iter_bytes Iterator[str]cCr<rY)r iter_textr>rZrZr]r@rz$HttpxBinaryResponseContent.iter_textcCr8rY)r iter_linesrprZrZr]rAr9z%HttpxBinaryResponseContent.iter_linescCr<rY)riter_rawr>rZrZr]rBrz#HttpxBinaryResponseContent.iter_raw)r:filestr | os.PathLike[str]rcCsNt|dd}|j|D]}||q WddS1s wYdSNwb)mode)openrr=write)r\rCr:frrZrZr]stream_to_files  "z)HttpxBinaryResponseContent.stream_to_filecCr8rY)rrzrprZrZr]rzr9z HttpxBinaryResponseContent.closec|jIdHSrY)rrrprZrZr]rz HttpxBinaryResponseContent.areadAsyncIterator[bytes]c|j|SrY)r aiter_bytesr>rZrZr]rP z&HttpxBinaryResponseContent.aiter_bytesAsyncIterator[str]crOrY)r aiter_textr>rZrZr]rSrQz%HttpxBinaryResponseContent.aiter_textcs |jSrY)r aiter_linesrprZrZr]rTs z&HttpxBinaryResponseContent.aiter_linescrOrY)r aiter_rawr>rZrZr]rUrQz$HttpxBinaryResponseContent.aiter_rawc st|}|jddIdH4IdH"}|j|2z3dHW}||IdHq6WdIdHdS1IdHs;wYdSrE)rPathrHrrPrI)r\rCr:rrJrrZrZr]astream_to_files .z*HttpxBinaryResponseContent.astream_to_filecrLrY)rrrprZrZr]rrMz!HttpxBinaryResponseContent.aclose)rrrVrW)rVr2rX)rVr5)r rrVrrY)r:rrVr;)r:rrVr?)rVr?)rCrDr:rrVrWr)r:rrVrN)r:rrVrR)rVrR)rarbrcrer^rYrr3rr6r7rrr=r@rArBrKrzrrPrSrTrUrWrrZrZrZr]r1s^         r1)rrrrrrrrrrrrrrrVr/)rVr)rVr")r*r+r,r+rVr-) __future__rosrrFrVrBr!rr:rm email.utilstypesrrtypingrrrrr r r r r rrrrrr functoolsrtyping_extensionsrrrrtrrrrrr_qsr_filesrr_typesr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2_utilsr3r4r5_compatr6r7_modelsr8r9r:r; _responser< _constantsr=r>r?r@ _streamingrArBrCrDrErF getLoggerrarGrerHrJrKrLrNrO httpx._configrPrp ImportErrorrQrfrrrrrrrrrrrrrrr8rr"r9rr1rZrZrZr]s  D    T     #1.'&c?)%  &