o {$f@sUddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Zddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlm 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.m/Z/m0Z0d d l1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCd dlDmEZEmFZFmGZGmHZHmIZImJZJd dlKmLZLmMZMd dlNmOZOmPZPmQZQmRZRd dlSmTZTmUZUmVZVmWZWd dlXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_d dl`maZambZbmcZcmdZdd dl+meZemfZfmgZgmhZhd dlimjZjekelZmdend<edddZoedddZpedZqeddd Zred!eaedZsed"ecedZterZdd#lumvZwnzdd#lumvZwWnexype7d$ZwYnwGd%d&d&ZyGd'd(d(eOeeqZzGd)d*d*ezeqeeqZ{Gd+d,d,eeqepfZ|Gd-d.d.ezeqeeqZ}ed/ee$j~e$jfdZed0eeaeecefdZGd1d2d2eeefZGd3d4d4e$j~Zere$j~ZneZGd5d6d6eZGd7d8d8ee$j~eaefZGd9d:d:e$jZere$jZneZGd;d<dd>ee$jecefZddddde2e2d?dqdOdPZGdQdRdReedfZGdSdTdTZeee dUfZdrdWdXZeIddYdsd_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^rereI/var/www/html/dev/env/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\rs    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|dIdHSrrrrererhr3s 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 dd:d;Z dd=d>Z dd?d@Z ddBdCZddEdFZddJdKZddNdOZddQdRZddTdUZeddWdXZeddZd[Zedd]d^Zedd`daZeddbdcZddfdgZeddhdiZeddjdkZejddmdkZddodpZdddtduZ dddwdxZ ddydzZ!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) rgrrrrrrrrrrrererhriOs"  zBaseClient.__init__r^cCs"|jdr|S|j|jddS)N/raw_path)rendswithrrfrererhros 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_responsets    z+BaseClient._make_status_error_from_responserrobject_exceptions.APIStatusErrorcCstrd)NotImplementedError)rgrrrrererhrszBaseClient._make_status_errorremaining_retries Optional[int]rr;cCs|dur|S||jSrd)get_max_retriesr)rgrrrererh_remaining_retriesszBaseClient._remaining_retries httpx.HeaderscCsb|jpi}t|j|}|||t|}|j}|r/|jdkr/||vr/|j p,| ||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersrr$rmethodloweridempotency_key_idempotency_key)rgrr 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 Cs\ttjrtdt|ddi}|j}|jdur:|dur%tt |j}nt |r0t ||j}n t dt |d||}t |j|j}|d}|j}|dur|drd|vr`|d|rwt|sptd t |d |||d <|sttt}|jjd |t|jtr|jn|j|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` Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z instead.data)rrrr^r`rfilesre)'rR isEnabledForloggingDEBUGdebugr9 json_data extra_jsonrr!r7rrtyper default_queryr`rr startswithpopr2r_serialize_multipartformr0ForceMultipartDictr build_requestrrr&rrr^qs stringifyr rr)rgrkwargsrrr` content_typerrererh_build_requestsH         zBaseClient._build_requestrMapping[object, object]dict[str, object]cCs^|jj|dd}i}|D] \}}||}|s|||<q t|r&||q ||g||<q |S)Nbrackets) array_format)rstringify_itemsrr3append)rgrrx serializedkeyvalueexistingrererhrs   z#BaseClient._serialize_multipartformcast_totype[ResponseT]cCsDt|js|St|j}|tt}t|r ||_ttt|S|Srd) r5rrrrGr rrr')rgr-rroverride_cast_torererh_maybe_override_cast_tos   z"BaseClient._maybe_override_cast_torcCs|jtdkS)Nstream)rrrFrgrrererh_should_stream_response_body+sz'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=rValidationErrorrP)rgrr-rerrrererh_process_response_data.s  z!BaseClient._process_response_datarcCr rdrr{rererhrFz BaseClient.qshttpx.Auth | NonecCrcrdrer{rererh custom_authJzBaseClient.custom_authdict[str, str]cCsiSrdrer{rererh auth_headersNr?zBaseClient.auth_headersdict[str, str | Omit]cCs"dd|jd||j|jS)Nzapplication/json)Acceptr z User-Agent) user_agentplatform_headersrArr{rererhrRszBaseClient.default_headerscCs i|jSrd)rr{rererhr]szBaseClient.default_queryrr$cCdS)zaValidate the given default headers and custom headers. Does nothing by default. Nre)rgrrrererhrc zBaseClient._validate_headerscCs|jjd|jS)Nz/Python )rrlrr{rererhrDnszBaseClient.user_agentcCs|jSrd)rr{rererhrrr<zBaseClient.base_url URL | strcCs"|t|tr |nt||_dSrd)rrrrrfrererhrvs"Dict[str, str]cCst|j|jdS)N)platform)rErrr{rererhrEzszBaseClient.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)rgrKretry_ms_header retry_headerretry_date_tuple retry_daterererh_parse_retry_after_headers&     z$BaseClient._parse_retry_after_headerrNc Csx||j}||}|durd|krdkr|S||}tttd|t}ddt}||} | dkr:| SdS)Nr<g@rg?)rrrXminrEpowrCr) rgrrrKr 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)rrrr;rar)rr;rar)r^rrar)rar)rr;rar )rr#rar$)r-r.rr;rar.)rr raru)rrr-r.rrrar')rar)rar=)rar@)rarB)rar$)rr$rr$rarbrar)rar)r^rHrarb)rarIrd)rKrLrarM)rrrr;rKrLrarN)rrraru)#rlrmrnrprrDrBrirrrrrrr r"rr0r3r;propertyrr>rArrrrDrsetterrErXr`rdrrerererhrBsh        D              & #rceZdZdfdd ZZS)_DefaultHttpxClientr rrarbc :|dt|dt|ddtjdi|dSNrrfollow_redirectsTre setdefaultrBrHsuperrirgr rrerhri   z_DefaultHttpxClient.__init__r rrarbrlrmrnri __classcell__rerersrhrkrkc@eZdZdddZdS)SyncHttpxClientWrapperrarbcCs$z|WdStyYdSwrd)closerr{rererh__del__s  zSyncHttpxClientWrapper.__del__Nrarbrlrmrnr|rerererhrzrzc seZdZUded<dZded<eeddddddddfdd Zdd!d"Zdd#d$Z dd'd(Z dd/d0Z dd3d4Z dd7d8Z e dddBdCZe ddDdEddHdCZe ddDddIddLdCZ ddDddIddNdCZddPdQZddTdUZdVdWdd\d]ZddcddZeidDdeddhdiZeidjddldiZeiddmddndiZidDddoddpdiZediddDdqddvdwZediddxddydwZedidddzdd{dwZdiddDdd|dd}dwZdid~dddZddiddddZdid~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 ) rrrrrrrrrrTrrrrrrn)warningswarnDeprecationWarningrrHr5rHTTPX_DEFAULT_TIMEOUTrBrrClientrrrqrirr%rzr) rgrrrrrrrrrrrrsrerhrisl   zSyncAPIClient.__init__cC|jjSrdrrr{rererhrUzSyncAPIClient.is_closedcCst|dr |jdSdS)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrr{r{rererhr{Xs zSyncAPIClient.closergrVcCs|Srdrer{rererh __enter__br}zSyncAPIClient.__enter__exc_typetype[BaseException] | NoneexcBaseException | Noneexc_tbTracebackType | NonecCs |dSrdr{rgrrrrererh__exit__es zSyncAPIClient.__exit__rr;cCs|Sz#Hook for mutating the given optionsrergrrererh_prepare_optionsmrjzSyncAPIClient._prepare_optionsrr cCrFaThis 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. Nrer2rererh_prepare_requesttrGzSyncAPIClient._prepare_requestr-Type[ResponseT]rrr1 Literal[True] stream_clsType[_StreamT]rYcCrcrdrergr-rrr1rrererhrrGzSyncAPIClient.requestFr1Literal[False]r'cCrcrdre)rgr-rrr1rererhrr1rType[_StreamT] | NoneResponseT | _StreamTcCrcrdrerrererhrrGtype[_StreamT] | NonecCs|j|||||dSN)r-rr1rr_requestrrererhrs  int | Nonec Cs^t|}|||}||}|||}||}||i} |jdur+|j| d<td|j |j z|j j |fd|pB|j |di| } Wnftjy|} z'tjddd|dkrm|j|||||dd WYd} ~ Std t|d| d} ~ wty} z'tjd dd|dkr|j|||||dd WYd} ~ Std t|d| d} ~ wwtd |j |j | j| j| jtd| jdz| WnOtjy} zAtjddd|dkr|| jr| j|j|||| jj||dWYd} ~ S| jjs | jtd|| jdd} ~ ww|j ||| |||!|j"|dS)NauthzSending HTTP Request: %s %sr1r"Encountered httpx.TimeoutExceptionTexc_inforr1rrKRaising timeout errorEncountered ExceptionRaising connection errorzHTTP Response: %s %s "%i %s" %szrequest_id: %sz x-request-id!Encountered httpx.HTTPStatusErrorrRe-raising status errorr-rrr1r retries_taken)#r8r0rrr"rr>rRrrr^rsendr3rTimeoutException_retry_requestrNrrOr reason_phraserrraise_for_statusHTTPStatusErrorrdrr{rreadr_process_responserr) rgr-rrr1r input_optionsretriesrr rr:rererhrs              zSyncAPIClient._requestrKhttpx.Headers | Nonec Csd|d}|dkrtdntd|||||}td|j|t||j|||||dSNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rr-rr1r)rRrr`rr^rSsleepr rgrr-rrKr1r remainingrrererhrs    zSyncAPIClient._retry_requestrrrr1type[Stream[Any]] | type[AsyncStream[Any]] | Nonerc Cs|jjtdkrttt|||||||dSt|p|}t |rKt |t rKt |t s6t dt d|td|}tt|||t|||||dS|tjkrUtt|St ||td|||||d} t|jjtrqtt| S| S)Nrarawrr-r1rrr!API Response types must subclass ; Received type[BaseAPIResponse[Any]]r.)rrrrFrr'rQrr5r6r7r?r>rrArResponseruparse rgr-rrr1rrorigin response_cls api_responserererhr:sX      zSyncAPIClient._process_responser Type[object]rType[SyncPageT]rScs(dfdd }|_j|ddS) NrrSracs|jd|S)N)rrr)rrrrrgrerhr}s z0SyncAPIClient._request_api_list.._parserFr)rrSrarS)rr)rgrrrrrerrhrwszSyncAPIClient._request_api_listrr1pathr/cCrcrdrergrr-rr1rererhrrzSyncAPIClient.getrtype[_StreamT]cCrcrdrergrr-rr1rrererhrrGrrcCrcrdrerrererhrrGrr1rcCs.tjdd|d|}tt|j||||dSNr)rr^rre)r; constructrr'rrgrr-rr1roptsrererhrs )rrrr1r Body | NonerRequestFiles | NonecCrcrdre)rgrr-rrrr1rererhposts zSyncAPIClient.post)rrrcCrcrdrergrr-rrrr1rrererhr )rrrrcCrcrdrerrererhrr)rrrr1rc Cs6tjdd||t|d|}tt|j||||dSNrrr^rrrre)r;rrrr'r) rgrr-rrrr1rrrererhrs  rrcC$tjdd||d|}|||SNpatchrr^rrer;rrrgrr-rrrrererhr zSyncAPIClient.patchrrrcCs*tjdd||t|d|}|||SNputrre)r;rrrrgrr-rrrrrererhrs   zSyncAPIClient.putcCrNdeleterrerrrererhrrzSyncAPIClient.deleterrrrrcC&tjd|||d|}||||SNrrer;rrrgrrrrrrrrererh get_api_list zSyncAPIClient.get_api_list)rrrrrrrrrrrrrrrrrrrrrrurarbrr}rgrVrarVrrrrrrrarbrr;rar;rr rarbrd) r-rrr;rrr1rrrrarY) r-rrr;rrr1rrar') r-rrr;rrr1rurrrar) r-rrr;rrr1rurrrar) r-rrr;rrr1rurrrar)rr;r-rrrrKrr1rurrrarr-rrr;rrr1rurrrrrar')rrrrrr;rarS rrr-rrr/r1rrar') rrr-rrr/r1rrrrarY) rrr-rrr/r1rurrrar)rrr-rrrrr/rrr1rrar')rrr-rrrrr/rrr1rrrrarY)rrr-rrrrr/rrr1rurrrar rrr-rrrrr/rar' rrr-rrrrrrr/rar')rrrrrrrrrr/rrrarS)rlrmrnrprrDr rirr{rrrrrrrrrrrrrrrr rwrerersrhrs   U         k' =    rcrj)_DefaultAsyncHttpxClientr rrarbc rlrmrorrrsrerhri rtz!_DefaultAsyncHttpxClient.__init__rurvrerersrhrrxrc@ry)AsyncHttpxClientWrapperrarbcCs.z t|WdStyYdSwrd)asyncioget_running_loop create_taskacloserr{rererhr|4s  zAsyncHttpxClientWrapper.__del__Nr}r~rerererhr3rrc s eZdZUded<dZded<eeddddddddfdd Zdd!d"Zdd#d$Z dd'd(Z dd/d0Z dd3d4Z dd7d8Z ed9dd:ddBdCZeddDddIdCZedddJddMdCZd9dddNddOdCZddQdRZddUdVZdWdXdd]d^ZddddeZeid9dfddidjZeidkddldjZeiddmddndjZid9ddoddpdjZeddid9dqddvdwZeddidxddydwZeddiddzdd{dwZddid9dd|dd}dwZdid~dddZddidxdddZdid~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 AsyncClientrrrqrirr%rr) rgrrrrrrrrrrrrsrerhri@sl   zAsyncAPIClient.__init__cCrrdrr{rererhrrzAsyncAPIClient.is_closedcs|jIdHdS)rN)rrr{rererhr{szAsyncAPIClient.closergrVcs|Srdrer{rererh __aenter__szAsyncAPIClient.__aenter__rrrrrrcs|IdHdSrdrrrererh __aexit__szAsyncAPIClient.__aexit__rr;cs|SrrerrererhrszAsyncAPIClient._prepare_optionsrr csdSrrer2rererhr zAsyncAPIClient._prepare_requestF)r1rr-rr1rrrr'cdSrdre)rgr-rr1rrererhrzAsyncAPIClient.request)rrrtype[_AsyncStreamT]rZcr"rdrergr-rr1rrrererhrr!)rrtype[_AsyncStreamT] | NoneResponseT | _AsyncStreamTcr"rdrer%rererhrr!)r1rrcs|j|||||dIdHSrrr%rererhrs  rc s|jdurttIdH|_t|}|||}||IdH}|||}||}||IdHi} |j dur@|j | d<z|j j |fd|pN|j |di| IdH} Wnlt jy} z*tjddd|dkr|j|||||ddIdHWYd} ~ Std t|d| d} ~ wty} z*tjd dd|dkr|j|||||ddIdHWYd} ~ Std t|d| d} ~ wwtd |j|j| j| jz| WnXt jy/} zJtjd dd|dkr|| jr| jIdH|j|||| jj||dIdHWYd} ~ S| jjs| j IdHtd|!| jdd} ~ ww|j"||| |||#|j$|dIdHS)Nrr1rrTrrrrrrzHTTP Request: %s %s "%i %s"rrrr)%rr4 get_platformr8r0rrr"rr>rrr3rrrRrrrNrrOrr^rrrrrdrrrrareadrrrr) rgr-rr1rrrrrr rr:rererhrs            zAsyncAPIClient._requestrKrc sr|d}|dkrtdntd|||||}td|j|t|IdH|j|||||dIdHSr)rRrr`rr^anyiorrrrererhrUs    zAsyncAPIClient._retry_requestrrrrrrc s|jjtdkrttt|||||||dSt|p|}t |rLt |t rLt |t s7t dt d|td|}td|||t|||||dS|tjkrVtt|St ||td|||||d} t|jjtrrtt| S| IdHS)Nrarrrrr'r.)rrrrFrr'rQrr5r6r7r?r@rrArrrurrrererhrrsZ      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 )rrrr1rrrrcr"rdre)rgrr-rrrr1rererhrs zAsyncAPIClient.postrcr"rdrergrr-rrrr1rrererhr )rrrrcr"rdrer,rererhrr-)rrrr1rc s>tjdd||t|IdHd|}|j||||dIdHSrr;rrr) rgrr-rrrr1rrrererhr s rc,tjdd||d|}|||IdHSrrrrererhrzAsyncAPIClient.patchcs8tjdd||t|IdHd|}|||IdHSrr.rrererhr$s zAsyncAPIClient.putcr/rrrrererhr2r0zAsyncAPIClient.deleterrrcCrr r r rererhr =r zAsyncAPIClient.get_api_list)rrrrrrurrrrrrrrrrrrrrrrrarbrr}rrrr) r-rrr;r1rrrrar') r-rrr;r1rrr$rrrarZ) r-rrr;r1rurr&rrrar') r-rrr;r1rurr&rrrar')rr;r-rrrrKrr1rurr&rar'r)rrsrrrr;rar+r) rrr-rrr/r1rrr$rarZ) rrr-rrr/r1rurr&rar')rrr-rrrrrrr/r1rrar')rrr-rrrrrrr/r1rrr$rarZ)rrr-rrrrrrr/r1rurr&rar'rr)rrrrsrrrrrr/rrrar+)rlrmrnrprrDr rirr{rr rrrrrrrrrrrrrr rwrerersrhr<s   U          h% =     r)query extra_headers extra_query extra_bodyrrrr1 Query | Noner2Headers | Noner3r4rrrr'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)r1r2r3r4rrrrrererhmake_request_optionsKs   r9c@ry)rrarucCrF)NTrer{rererh__bool__qr}zForceMultipartDict.__bool__Nr)rlrmrnr:rerererhrprrc@$eZdZd ddZed ddZd S) OtherPlatformnamerrarbcC ||_dSrdr=rgr=rererhriv zOtherPlatform.__init__cC d|jS)NzOther:r?r{rererh__str__y zOtherPlatform.__str__Nr=rrarbrgrlrmrnrirrCrerererhr<u r<)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownPlatformcCszt}t}Wn tyYdSwd|vs!d|vr#dS|dkr)dS|dkr/dSd |vr5d S|d krKt}|d krCd S|dkrIdSdS|rQt|SdS)NrOiphoneipadrMdarwinrHwindowsrJandroidrNlinuxfreebsdrKopenbsdrLrI)rJsystemrrdistroidr<)rY platform_name distro_idrererhr(s0  r()maxsizerrrJPlatform | NonerIcCs&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)rrJrererhrEs rEc@r;) OtherArchr=rrarbcCr>rdr?r@rererhrirAzOtherArch.__init__cCrB)Nzother:r?r{rererhrCrDzOtherArch.__str__NrErgrFrerererhrdrGrd)x32x64armarm64unknowncC ztWStyYdSwNri)rJpython_implementationrrerererhrb   rbcCrjrk)rJpython_versionrrerererhrcrmrcArchcCsrzt\}}t}Wn tyYdSw|dvrdS|dkr%dS|dkr+dS|dkr1dS|r7t|SdS) Nri)rhaarch64rhrgx86_64rf32bitre)rJ architecturemachinerrrd)python_bitness_rtrererhras"  raobj1Mapping[_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").0r*r+rererh s z#_merge_mappings..)rx)rwrymergedrererhrs r)r1r5r2r6r3r5r4rrrrr7rr8rar/)rarP)rrrJr_rarIrg)raro)rwrxryrxrarz) __future__rrrSrerOrr5rrJr email.utilstypesrrtypingrrrrr r r r r rrrrrrtyping_extensionsrrrr*rrZrrrrr_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\rqrrrrrrrrrkDefaultHttpxClientrzrrDefaultAsyncHttpxClientrrr9rrr<rPr(rErdrorbrcrarrerererhs  D   P $      !0.'&!' %  *