o #`^h @sUddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Zddl mZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddl m!Z!m"Z"m#Z#ddl$Z$ddl%Z%ddl&Z&ddl'Z'ddl%m(Z(m)Z)ddl'm*Z*d d l+m,Z,d d l-m.Z.d d l/m0Z0m1Z1d d l2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDd dlEmFZFmGZGmHZHmIZImJZJmKZKd dlLmMZMmNZNd dlOmPZPmQZQmRZRmSZSd dlTmUZUmVZVmWZWmXZXd dlYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`d dlambZbmcZcmdZdmeZed dl,mfZfmgZgmhZhmiZid dljmkZke lemZndeod<edddZpedddZqedZreddd Zsed!ebedZted"ededZuer^dd#lvmwZxnzdd#lvmwZxWneyyte8d$ZxYnwGd%d&d&ZzGd'd(d(ePeerZ{Gd)d*d*e{ereerZ|Gd+d,d,eereqfZ}Gd-d.d.e{ereerZ~ed/ee%je%jfdZed0eebeedefdZGd1d2d2eeefZGd3d4d4e%jZere%jZneZGd5d6d6eZGd7d8d8ee%jebefZGd9d:d:e%jZer e%jZneZGd;d<dd>ee%jedefZddddde3e3d?dqdOdPZGdQdRdReedfZGdSdTdTZeee!dUfZdrdWdXZeJddYdsd_d`ZGdadbdbZeee!dcfZdtdddeZdtdfdgZdudidjZdvdodpZdS)w) annotationsN) TracebackType)random) TYPE_CHECKINGAnyDictTypeUnionGenericMappingTypeVarIterableIteratorOptional Generator AsyncIteratorcastoverload)Literaloverride get_origin)URLLimits) PrivateAttr) _exceptions Querystring)to_httpx_filesasync_to_httpx_files) NOT_GIVENBodyOmitQueryHeadersTimeoutNotGiven ResponseT Transport AnyMapping PostParser ProxiesTypes RequestFiles HttpxSendArgsAsyncTransportRequestOptionsHttpxRequestFilesModelBuilderProtocol)is_dictis_listasyncifyis_given lru_cache is_mapping) model_copy model_dump) GenericModelFinalRequestOptions validate_typeconstruct_type) APIResponseBaseAPIResponseAsyncAPIResponseextract_response_type)DEFAULT_TIMEOUTMAX_RETRY_DELAYDEFAULT_MAX_RETRIESINITIAL_RETRY_DELAYRAW_RESPONSE_HEADEROVERRIDE_CAST_TO_HEADERDEFAULT_CONNECTION_LIMITS)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^rereQ/home/air/shanriGPT/back/venv/lib/python3.10/site-packages/openai/_base_client.py__init__|zPageInfo.__init__r#cCrcrdre)rgr`rererhrirjr^r`cCs||_||_dSrdrk)rgr^r`rererhris N)r^rrarb)r`r#rarb)r^r]r`r_rarb)__name__ __module__ __qualname____doc____annotations__rrir rerererhr\ss    r\c@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 r;_optionsType[_T]_modelraboolcCs|}|sdS|duS)NF)_get_page_itemsnext_page_info)rgitemsrererh has_next_pages zBasePage.has_next_pageOptional[PageInfo]cCrcrdrergrererhrwszBasePage.next_page_info Iterable[_T]cCrcrdrer{rererhrvzBasePage._get_page_itemsr^rhttpx.QueryParamscCsttt|jj|jSrd)httpx QueryParamsrrrrr`mergerfrererh_params_from_urlszBasePage._params_from_urlinfor\cCs|t|j}|t|jtsi|j|j|_|St|jts:||j}|jj|d}t |j|_t ||_|St d)N)r`zUnexpected PageInfo state) r8rr_strip_raw_response_header isinstancer`r&r^r copy_withdictstr ValueError)rgroptionsr`r^rererh_info_to_optionss      zBasePage._info_to_optionsNraru)rarz)rar|)r^rrar~)rr\rar;) rlrmrnrorrrrprtryrwrvrrrerererhrqs      rqc@FeZdZUeZded<dd d Zdd dZdddZ dddZ dS) BaseSyncPage SyncAPIClient_clientclientmodelrsrr;rarbcCs||_||_||_dSrdrtrrr)rgrrrrererh_set_private_attributes z$BaseSyncPage._set_private_attributes Iterator[_T]ccs(|D] }|D]}|Vq qdSrd iter_pagesrvrgpageitemrererh__iter__s   zBaseSyncPage.__iter__rgrSIterator[SyncPageT]ccs&|} |V|r|}ndSqrdry get_next_pagergrrererhrs zBaseSyncPage.iter_pagescCs4|}|s td||}|jj|j|j|dSNzYNo next page expected; please check `.has_next_page()` before calling `.get_next_page()`.)rrrw RuntimeErrorrr_request_api_listrt __class__rgrrrererhrs zBaseSyncPage.get_next_pageN)rrrrsrr;rarb)rar)rgrSrar)rgrSrarS) rlrmrnpydanticrrrprrrrrerererhrs     rc@s4eZdZdd d ZdddZdddZdddZdS)AsyncPaginatorrAsyncAPIClientrr;page_clsType[AsyncPageT]rrsrarbcCs||_||_||_||_dSrd)rtrrr _page_cls)rgrrrrrererhris zAsyncPaginator.__init__ Generator[Any, None, AsyncPageT]cCs |Srd) _get_page __await__r{rererhrs zAsyncPaginator.__await__rUcs0dfdd }|j_jjjIdHS)NresprUracs|jjjjd|S)N)rrr)rrtrrrrr{rerh_parsers z)AsyncPaginator._get_page.._parser)rrUrarU)rr post_parserrrequestr)rgrrer{rhrszAsyncPaginator._get_pageAsyncIterator[_T]cCs0tt|IdH}|2z 3dHW}|Vq 6dSrd)rrUrrererh __aiter__szAsyncPaginator.__aiter__N) rrrr;rrrrsrarb)rar)rarUrar)rlrmrnrirrrrerererhrs    rc@r) BaseAsyncPagerrrrsrrr;rarbcCs||_||_||_dSrdr)rgrrrrererhrrz%BaseAsyncPage._set_private_attributesrcCs2|2z3dHW}|D]}|Vqq6dSrdrrrererhr&s  zBaseAsyncPage.__aiter__rgrUAsyncIterator[AsyncPageT]cCs,|} |V|r|IdH}ndSqrdrrrererhr+szBaseAsyncPage.iter_pagescs<|}|s td||}|jj|j|j|dIdHSrrrrererhr4s zBaseAsyncPage.get_next_pageN)rrsrrrr;rarbr)rgrUrar)rgrUrarU) rlrmrnrrrrprrrrrerererhrs    r _HttpxClientT_DefaultStreamTc@seZdZUded<ded<ded<ded<d ed <d ed <d ed<ded<ded<ded<dZded<eedddd}d&d'Zd~d)d*Zdd.d/Z dd4d5Z d6d7ddd?Z ddAdBZ d6d7ddDdEZddIdJZddMdNZddPdQZddSdTZeddVdWZeddYdZZedd\d]Zedd_d`ZeddadbZddedfZeddgdhZeddidjZejddldjZddndoZdddsdtZ dddwdxZddydzZ dd{d|Z!dS) BaseClientrrr_versionr _base_urlint max_retrieszUnion[float, Timeout, None]timeout httpx.Limits_limitsProxiesTypes | None_proxies!Transport | AsyncTransport | None _transportru_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] | Nonerarbc Csn||_|t||_||_||_||_||_||_| pi|_ | p"i|_ ||_ d|_ d|_ |dur5tddS)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 `openai.DEFAULT_MAX_RETRIES`)r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr _platform TypeError) rgrrrrrrrrrrrererhriPs"  zBaseClient.__init__r^cCs"|jdr|S|j|jddS)N/raw_path)rendswithrrfrererhrps z"BaseClient._enforce_trailing_slashresponsehttpx.ResponserMcCs|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)rgrrerr_msgerr_textrererh _make_status_error_from_responseus    z+BaseClient._make_status_error_from_responserrobject_exceptions.APIStatusErrorcCstrd)NotImplementedError)rgrrrrererhrszBaseClient._make_status_errorr retries_takenrr;r httpx.HeaderscCs|jpi}t|j|}|||t|}|j}|r/|jdkr/||vr/|j p,| ||<ddd|Dvr>t ||d<|S)Ngetzx-stainless-retry-countcss|]}|VqdSrd)lower).0headerrererh sz,BaseClient._build_headers..) headers_merge_mappingsdefault_headers_validate_headersrr$rmethodridempotency_key_idempotency_keyr)rgrrr headers_dictridempotency_headerrererh_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)rgr^ merge_urlmerge_raw_pathrererh _prepare_urls zBaseClient._prepare_urlSSEDecoder | SSEBytesDecodercCtSrd)rJr{rererh_make_sse_decoderszBaseClient._make_sse_decoder httpx.Requestc Csttjrtdt|ddi}|j}|jdur:|dur%tt |j}nt |r0t ||j}n t dt |d|j||d}t |j|j}|d}|j}|dur|drd |vrb|d|ryt|srtd t |d |||d <|sttt}||j} d | jvrd| jd di|d<|jjd|t |j!t"r|j!n|j!|j#| |r|j$%tt&t't(f|nd||d|S)NzRequest options: %sT) exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body`r Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z instead.data_ sni_hostname- extensions)rrrr^r`rfilesre))rR isEnabledForloggingDEBUGdebugr9 json_data extra_jsonrr!r7rrtyper default_queryr`rr startswithpopr2r_serialize_multipartformr0ForceMultipartDictrr^hostreplacer build_requestrrr&rqs stringifyr rr) rgrrkwargsrrr` content_typer prepared_urlrererh_build_requestsN         zBaseClient._build_requestrMapping[object, object]dict[str, object]cCs^|jj|dd}i}|D] \}}||}|s|||<q t|r&||q ||g||<q |S)Nbrackets) array_format)r%stringify_itemsrr3append)rgrrx serializedkeyvalueexistingrererhr s   z#BaseClient._serialize_multipartformcast_totype[ResponseT]cCsDt|js|St|j}|tt}t|r ||_ttt|S|Srd) r5rrrrGr rrr')rgr5rroverride_cast_torererh_maybe_override_cast_to s   z"BaseClient._maybe_override_cast_torcCs|jtdkS)Nstream)rrrFrgrrererh_should_stream_response_body1sz'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_r3)rr)rr'rinspectisclass issubclassr1buildrr<r=rValidationErrorrP)rgrr5rerrrererh_process_response_data4s  z!BaseClient._process_response_datarcCr rdrr{rererhr%Lz BaseClient.qshttpx.Auth | NonecCrcrdrer{rererh custom_authPzBaseClient.custom_authdict[str, str]cCsiSrdrer{rererh auth_headersTrGzBaseClient.auth_headersdict[str, str | Omit]cCs"dd|jd||j|jS)Nzapplication/json)Acceptrz User-Agent) user_agentplatform_headersrIrr{rererhrXszBaseClient.default_headerscCs i|jSrd)rr{rererhrcszBaseClient.default_queryrr$cCdS)zaValidate the given default headers and custom headers. Does nothing by default. Nre)rgrrrererhri zBaseClient._validate_headerscCs|jjd|jS)Nz/Python )rrlrr{rererhrLtszBaseClient.user_agentcCs|jSrd)rr{rererhrxrDzBaseClient.base_url URL | strcCs"|t|tr |nt||_dSrd)rrrrrfrererhr|s"Dict[str, str]cCst|j|jdS)N)platform)rMrrr{rererhrMszBaseClient.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)rgrSretry_ms_header retry_headerretry_date_tuple retry_daterererh_parse_retry_after_headers&     z$BaseClient._parse_retry_after_headerremaining_retriesrVc Csx||j}||}|durd|krdkr|S||}tttd|t}ddt}||} | dkr:| SdS)Nr<g@rg?)get_max_retriesrr`minrEpowrCr) rgrarrSr retry_after nb_retries sleep_secondsjitterrrererh_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)rrrRrr)rgrshould_retry_headerrererh _should_retrys*        zBaseClient._should_retrycCsdtS)Nzstainless-python-retry-)uuiduuid4r{rererhrszBaseClient._idempotency_key)rrrrrrurrrrrrrrrrrrrrrarb)r^rrar)rrrarM)rrrrrrrar)rr;rrrar)r^rrar)rar )rr;rrrar )rr+rar,)r5r6rr;rar6)rr raru)rrr5r6rrrar')rar)rarE)rarH)rarJ)rar,)rr$rr$rarbrar)rar)r^rPrarb)rarQrd)rSrTrarU)rarrr;rSrTrarV)rrraru)"rlrmrnrprrDrBrirrrrrr r*r r8r;rCpropertyr%rFrIrrrrLrsetterrMr`rjrnrrerererhrCsh       K              & #rceZdZdfdd ZZS)_DefaultHttpxClientr'rrarbc :|dt|dt|ddtjdi|dSNrrfollow_redirectsTre setdefaultrBrHsuperrirgr'rrerhri   z_DefaultHttpxClient.__init__r'rrarbrlrmrnri __classcell__rerer}rhruruc@eZdZdddZdS)SyncHttpxClientWrapperrarbcCs$z|WdStyYdSwrd)closerr{rererh__del__s  zSyncHttpxClientWrapper.__del__Nrarbrlrmrnrrerererhrrc seZdZUded<dZded<eeddddddddfdd Zdd!d"Zdd#d$Z dd'd(Z dd/d0Z dd3d4Z dd7d8Z e dddBdCZe ddDdEddHdCZe ddDddIddLdCZ ddDddIddNdCZddPdQZddTdUZdVdWdd[d\ZddbdcZeidDddddgdhZeididdkdhZeiddlddmdhZidDddnddodhZediddDdpddudvZediddwddxdvZedidddyddzdvZdiddDdd{dd|dvZdid}dd~dZddiddddZdid}dddZdidddddZZS)rz httpx.ClientrNztype[Stream[Any]] | Nonerrrrrr http_clientrrrrrrrrr!float | Timeout | None | NotGivenrTransport | Nonerrr Limits | Nonerhttpx.Client | Nonerrrrrrurarbc 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 ) rrrrrrrrrrTrrrrrrx)warningswarnDeprecationWarningrrHr5rHTTPX_DEFAULT_TIMEOUTrBrrClientrrr{rirr%rr) rgrrrrrrrrrrrr}rerhrisl   zSyncAPIClient.__init__cC|jjSrdrrr{rererhr[zSyncAPIClient.is_closedcCst|dr |jdSdS)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrr{rererhr^s zSyncAPIClient.closergrVcCs|Srdrer{rererh __enter__hr}zSyncAPIClient.__enter__exc_typetype[BaseException] | NoneexcBaseException | Noneexc_tbTracebackType | NonecCs |dSrdrrgrrrrererh__exit__ks zSyncAPIClient.__exit__rr;cCs|Sz#Hook for mutating the given optionsrergrrererh_prepare_optionssrjzSyncAPIClient._prepare_optionsrr cCrNaThis 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. Nrer:rererh_prepare_requestzrOzSyncAPIClient._prepare_requestr5Type[ResponseT]ra Optional[int]r9 Literal[True] stream_clsType[_StreamT]rYcCrcrdrergr5rrar9rrererhrrOzSyncAPIClient.requestFr9Literal[False]r'cCrcrdre)rgr5rrar9rererhrr9rType[_StreamT] | NoneResponseT | _StreamTcCrcrdrerrererhrrOtype[_StreamT] | NonecCs2|dur ||j|}nd}|j|||||dSNr)r5rr9rrrcr_request)rgr5rrar9rrrererhrs rc CsZt|}|||}||}||j|}|j||d}||i} |jdur/|j| d<t d|j |j z|j j |fd|pF|j|di| } Wnftjy} z'tj ddd|d krq|j|||||dd WYd} ~ St d t|d| d} ~ wty} z'tj d dd|d kr|j|||||dd WYd} ~ St d t|d| d} ~ wwt d|j |j | j| j| jt d| jdz| WnOtjy!} zAtj ddd|d kr|| jr| j|j|||| jj||dWYd} ~ S| jjs| jt d| | jdd} ~ ww|j!||| |||dS)NrauthzSending HTTP Request: %s %sr9r"Encountered httpx.TimeoutExceptionTexc_inforrr9rrSRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz x-request-id!Encountered httpx.HTTPStatusErrorrrSr9rRe-raising status errorr5rrr9rr)"r8r8rrcrr*rrFrRrrr^rsendr;rTimeoutException_retry_requestrNrrOr reason_phraserrraise_for_statusHTTPStatusErrorrnrrrreadr_process_response) rgr5rrr9r input_optionsrarr'rrBrererhrs            zSyncAPIClient._requestrShttpx.Headers | Nonec Csp||j|}|dkrtdntd|||||}td|j|t||j |||d||dSNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rr5rr9r) rcrrRrrjrr^r[sleepr rgrr5rrSr9rrarrererhr&s    zSyncAPIClient._retry_requestrrrr1type[Stream[Any]] | type[AsyncStream[Any]] | Nonec Cs|jjtdkrttt|||||||dSt|p|}t |rKt |t rKt |t s6t dt d|td|}tt|||t|||||dS|tjkrUtt|St ||td|||||d} t|jjtrqtt| S| S)Nrkrawrr5r9rrr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r6)rrrrFrr'rQrr=r>r?r?r>rrArResponseruparse rgr5rrr9rrorigin response_cls api_responserererhrEsX      zSyncAPIClient._process_responser Type[object]rType[SyncPageT]rScs(dfdd }|_j|ddS) NrrSracs|jd|S)N)rrr)rrrrrgrerhrs z0SyncAPIClient._request_api_list.._parserFr)rrSrarS)rr)rgrrrrrerrhrszSyncAPIClient._request_api_listrr9pathr/cCrcrdrergrr5rr9rererhrrzSyncAPIClient.getrtype[_StreamT]cCrcrdrergrr5rr9rrererhrrOrrcCrcrdrerrererhrrOrr9rcCs.tjdd|d|}tt|j||||dSNr)rr^rre)r; constructrr'rrgrr5rr9roptsrererhrs )rrrr9r Body | NonerRequestFiles | NonecCrcrdre)rgrr5rrrr9rererhposts zSyncAPIClient.post)rrrcCrcrdrergrr5rrrr9rrererhr )rrrrcCrcrdrerrererhrr)rrrr9rc Cs6tjdd||t|d|}tt|j||||dSNrrr^rrrre)r;rrrr'r) rgrr5rrrr9rrrererhrs  rrcC$tjdd||d|}|||SNpatchrr^rrer;rrrgrr5rrrrererhr zSyncAPIClient.patchrrrcCs*tjdd||t|d|}|||SNputrre)r;rrrrgrr5rrrrrererhr s   zSyncAPIClient.putcCrNdeleterrerrrererhr rzSyncAPIClient.deleterrrrrcC&tjd|||d|}||||SNrrer;rrrgrrrrrrrrererh get_api_list zSyncAPIClient.get_api_list)rrrrrrrrrrrrrrrrrrrrrrurarbrrrgrVrarVrrrrrrrarbrr;rar;rr rarbrd) r5rrr;rarr9rrrrarY) r5rrr;rarr9rrar') r5rrr;rarr9rurrrar) r5rrr;rarr9rurrrar) r5rrr;rrr9rurrrar)rr;r5rrrrSrr9rurrrarr5rrr;rrr9rurrrrrar')rrrrrr;rarS rrr5rrr/r9rrar') rrr5rrr/r9rrrrarY) rrr5rrr/r9rurrrar)rrr5rrrrr/rrr9rrar')rrr5rrrrr/rrr9rrrrarY)rrr5rrrrr/rrr9rurrrar rrr5rrrrr/rar' rrr5rrrrrrr/rar')rrrrrrrrrr/rrrarS)rlrmrnrprrDr rirrrrrrrrrrrrrrrr r rrrerer}rhrs   U         k' =    rcrt)_DefaultAsyncHttpxClientr'rrarbc rvrwryr|r}rerhri+r~z!_DefaultAsyncHttpxClient.__init__rrrerer}rhr*rrc@r)AsyncHttpxClientWrapperrarbcCs.z t|WdStyYdSwrd)asyncioget_running_loop create_taskacloserr{rererhr?s  zAsyncHttpxClientWrapper.__del__Nrrrerererhr>rrc s eZdZUded<dZded<eeddddddddfdd Zdd!d"Zdd#d$Z dd'd(Z dd/d0Z dd3d4Z dd7d8Z ed9dd:ddBdCZeddDddIdCZedddJddMdCZd9dddNddOdCZddQdRZddUdVZdWdXdd\d]ZddcddZeid9deddhdiZeidjddkdiZeiddlddmdiZid9ddnddodiZeddid9dpddudvZeddidwddxdvZeddiddyddzdvZddid9dd{dd|dvZdid}dd~dZddidwdddZdid}dddZdidddddZZS)rzhttpx.AsyncClientrNztype[AsyncStream[Any]] | NonerrrrrrrrurrrrrAsyncTransport | Nonerrrrrhttpx.AsyncClient | Nonerrrrrarbc 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) NrrrrrrrrzTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got ) rrrrrrrrrrTr)rrrrrHr5rrrBrr AsyncClientrrr{rirr%rr) rgrrrrrrrrrrrr}rerhriKsl   zAsyncAPIClient.__init__cCrrdrr{rererhrrzAsyncAPIClient.is_closedcs|jIdHdS)rN)rr"r{rererhrszAsyncAPIClient.closergrVcs|Srdrer{rererh __aenter__szAsyncAPIClient.__aenter__rrrrrrcs|IdHdSrdrrrererh __aexit__szAsyncAPIClient.__aexit__rr;cs|SrrerrererhrszAsyncAPIClient._prepare_optionsrr csdSrrer:rererhr zAsyncAPIClient._prepare_requestF)r9rar5rr9rrarr'cdSrdre)rgr5rr9rarererhrzAsyncAPIClient.request)rarrtype[_AsyncStreamT]rZcr)rdrergr5rr9rrarererhrr()rratype[_AsyncStreamT] | NoneResponseT | _AsyncStreamTcr)rdrer,rererhrr()r9rracs:|dur||j|}nd}|j|||||dIdHSrr)rgr5rr9rrarrererhrs  rc s|jdurttIdH|_t|}|||}||IdH}||j|}|j||d}| |IdHi} |j durD|j | d<z|j j |fd|pR|j |di| IdH} Wnltjy} z*tjddd|dkr|j|||||dd IdHWYd} ~ Std t|d| d} ~ wty} z*tjd dd|dkr|j|||||dd IdHWYd} ~ Std t|d| d} ~ wwtd |j|j| j| jz| WnXtjy3} zJtjddd|dkr|| jr| jIdH|j|||| jj||dIdHWYd} ~ S| jj s#| j!IdHtd|"| jdd} ~ ww|j#||| |||dIdHS)Nrrr9rrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)$rr4 get_platformr8r8rrcrr*rrFrrr;rrrRrrrNrrOrr^rrrrrnrr"rrareadrr) rgr5rr9rrrrarr'rrBrererhrs          zAsyncAPIClient._requestrSrc s~||j|}|dkrtdntd|||||}td|j|t|IdH|j |||d||dIdHSr) rcrrRrrjrr^anyiorrrrererhres    zAsyncAPIClient._retry_requestrrrrrc s|jjtdkrttt|||||||dSt|p|}t |rLt |t rLt |t s7t dt d|td|}td|||t|||||dS|tjkrVtt|St ||td|||||d} t|jjtrrtt| S| IdHS)Nrkrrrrr'r6)rrrrFrr'rQrr=r>r?r?r@rrArrrurrrererhrsZ      z AsyncAPIClient._process_responserrsrrAsyncPaginator[_T, AsyncPageT]cCst||||dS)N)rrrr)r)rgrrrrererhrsz AsyncAPIClient._request_api_listrrr/cr)rdrerrererhrr*zAsyncAPIClient.getrcr)rdrerrererhrr(rcr)rdrerrererhrr(rcs0tjdd|d|}|j||||dIdHSrrrrererhrs )rrrr9rrrrcr)rdre)rgrr5rrrr9rererhrs zAsyncAPIClient.postrcr)rdrergrr5rrrr9rrererhr )rrrrcr)rdrer3rererhr r4)rrrr9rc s>tjdd||t|IdHd|}|j||||dIdHSrr;rrr) rgrr5rrrr9rrrererhrs rc,tjdd||d|}|||IdHSrrrrererhr)zAsyncAPIClient.patchcs8tjdd||t|IdHd|}|||IdHSr r5r rererhr 4s zAsyncAPIClient.putcr6r rrrererhr Br7zAsyncAPIClient.deleterrrcCrrrrrererhrMrzAsyncAPIClient.get_api_list)rrrrrrurrrrrr#rrrrrr$rrrrrarbrrrrrr) r5rrr;r9rrarrar') r5rrr;r9rrr+rarrarZ) r5rrr;r9rurr-rarrar.) r5rrr;r9rurr-rrrar.)rr;r5rrrrSrr9rurr-rar.r)rrsrrrr;rar2r) rrr5rrr/r9rrr+rarZ) rrr5rrr/r9rurr-rar.)rrr5rrrrrrr/r9rrar')rrr5rrrrrrr/r9rrr+rarZ)rrr5rrrrrrr/r9rurr-rar.rr)rrrrsrrrrrr/rrrar2)rlrmrnrprrDr rirrr&r'rrrrrrrrrrrr r rrrerer}rhrGs   U          h% =     r)query extra_headers extra_query extra_bodyrrrr8 Query | Noner9Headers | Noner:r;rrrr'float | httpx.Timeout | None | NotGivenrPostParser | NotGivenrar/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.Nrrr`rrr)rr)rrr&r5)r8r9r:r;rrrrrererhmake_request_options[s   r@c@r)r!rarucCrN)NTrer{rererh__bool__r}zForceMultipartDict.__bool__Nr)rlrmrnrArerererhr!rr!c@$eZdZd ddZed ddZd S) OtherPlatformnamerrarbcC ||_dSrdrDrgrDrererhri zOtherPlatform.__init__cC d|jS)NzOther:rFr{rererh__str__ zOtherPlatform.__str__NrDrrarbrqrlrmrnrirrJrerererhrC rC)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownPlatformcCszt}t}Wn tyYdSwd|vs!d|vr#dS|dkr)dS|dkr/dSd |vr5d S|d krKt}|d krCd S|dkrIdSdS|rQt|SdS)NrViphoneipadrTdarwinrOwindowsrQandroidrUlinuxfreebsdrRopenbsdrSrP)rRsystemrrdistroidrC)r` platform_name distro_idrererhr/s0  r/)maxsizerrrRPlatform | NonerQcCs&d|t|ptttttdS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rr/get_architectureget_python_runtimeget_python_version)rrRrererhrMs rMc@rB) OtherArchrDrrarbcCrErdrFrGrererhrirHzOtherArch.__init__cCrI)Nzother:rFr{rererhrJrKzOtherArch.__str__NrLrqrMrerererhrkrNrk)x32x64armarm64unknowncC ztWStyYdSwNrp)rRpython_implementationrrerererhri   ricCrqrr)rRpython_versionrrerererhrjrtrjArchcCshzt}Wn tyYdSw|dvrdS|dkrdS|dkr%dStjdkr,dS|r2t|SdS) Nrp)roaarch64rornx86_64rmlrl)rRmachinerrsysrerk)ryrererhrhs   rhobj1Mapping[_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||qSre)rr")rr2r3rererh s z#_merge_mappings..)rx)r{r}mergedrererhrs r)r8r<r9r=r:r<r;rrrrr>rr?rar/)rarW)rrrRrfrarQrq)rarv)r{r|r}r|rar~) __future__rrzrr[rorWrr=rrRr email.utilstypesrrtypingrrrrr r r r r rrrrrrtyping_extensionsrrrr1rrarrrrr_qsr_filesrr_typesr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1_utilsr2r3r4r5r6r7_compatr8r9_modelsr:r;r<r= _responser>r?r@rA _constantsrBrCrDrErFrGrH _streamingrIrJrKrLrMrNrOrP_legacy_responserQ getLoggerrlrRrprSrUrVrWrYrZ httpx._configr[r ImportErrorr\rqrrrrr%rrrruDefaultHttpxClientrrrDefaultAsyncHttpxClientrrr@rr!rCrWr/rMrkrvrirjrhrrerererhs  D   P $      !0.'&&, %  *