B 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@mAZAmBZBd dlCmDZDmEZEmFZFmGZGmHZHd dlImJZJmKZKd dlLmMZMmNZNmOZOmPZPd dlQmRZRmSZSmTZTmUZUd dlVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]d dl^m_Z_m`Z`maZambZbd dl+mcZcmdZdmeZemfZfd dlgmhZheiejZkdeld<edddZmedddZnedZoeddd Zped!e_edZqed"eaedZrerdd#lsmtZun0ydd#lsmtZuWnevk re7d$ZuYnXGd%d&d&ZwGd'd(d(eMeeoZxGd)d*d*exeoeeoZyGd+d,d,eeoenfZzGd-d.d.exeoeeoZ{ed/ee$j|e$j}fdZ~ed0ee_eeaefdZGd1d2d2ee~efZGd3d4d4e$j|Zere$j|ZneZGd5d6d6eZGd7d8d8ee$j|e_efZGd9d:d:e$j}Zer e$j}ZneZGd;d<dd>ee$j}eaefZddddde2e2d?d@dAd@dBdCdDdEdFdGdHdIZGdJdKdKZeee dLfZdMdNdOdPZeGddQdRdSdTdUdVZGdWdXdXZeee dYfZdRdNdZd[ZdRdNd\d]Zd^dNd_d`ZdadadbdcdddeZdS)f) 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 HttpxSendArgsAsyncTransportRequestOptionsModelBuilderProtocol)is_dictis_listis_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@sdeZdZUdZded<ded<edddd d Zed dd d d Zeeddddddd ZdS)PageInfozStores the necessary information to build the request to retrieve the next page. Either `url` or `params` must be set. zURL | NotGivenurlzQuery | NotGivenparamsrNone)rZreturncCsdS)N)selfrZr^r^Y/home/ankuromar296_gmail_com/.local/lib/python3.7/site-packages/anthropic/_base_client.py__init__zszPageInfo.__init__r")r[r]cCsdS)Nr^)r_r[r^r^r`ras)rZr[)rZr[r]cCs||_||_dS)N)rZr[)r_rZr[r^r^r`rasN)__name__ __module__ __qualname____doc____annotations__rrarr^r^r^r`rYqs  rYc@sxeZdZUdZeZded<eZded<dddd Zd dd d Z d dddZ dddddZ dddddZ 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 r8_optionszType[_T]_modelbool)r]cCs|}|sdS|dk S)NF)_get_page_itemsnext_page_info)r_itemsr^r^r` has_next_pageszBasePage.has_next_pagezOptional[PageInfo]cCsdS)Nr^)r_r^r^r`rlszBasePage.next_page_infoz Iterable[_T]cCsdS)Nr^)r_r^r^r`rkszBasePage._get_page_itemsrzhttpx.QueryParams)rZr]cCsttt|jj|jS)N)httpxZ QueryParamsrrrhr[merge)r_rZr^r^r`_params_from_urlszBasePage._params_from_urlrY)infor]cCs|t|j}|t|jts0|j|j|_|St|jtsp||j}|jj|d}t |j|_t ||_|St ddS)N)r[zUnexpected PageInfo state) r5rhZ_strip_raw_response_header isinstancer[r%rZrq copy_withdictstr ValueError)r_rroptionsr[rZr^r^r`_info_to_optionss      zBasePage._info_to_optionsN) rbrcrdrerrhrfrirnrlrkrqryr^r^r^r`rgs rgc@s`eZdZUeZded<dddddddZd d d d Zd ddddZ d d dddZ dS) BaseSyncPage SyncAPIClient_clientzType[_T]r8r\)clientmodelrxr]cCs||_||_||_dS)N)rir|rh)r_r}r~rxr^r^r`_set_private_attributessz$BaseSyncPage._set_private_attributesz Iterator[_T])r]ccs.x(|D]}x|D] }|VqWq WdS)N) iter_pagesrk)r_pageitemr^r^r`__iter__szBaseSyncPage.__iter__rPzIterator[SyncPageT])r_r]ccs*|}x |V|r|}qdSqWdS)N)rn get_next_page)r_rr^r^r`rs  zBaseSyncPage.iter_pagescCs4|}|std||}|jj|j|j|dS)NzYNo next page expected; please check `.has_next_page()` before calling `.get_next_page()`.)rrx)rl RuntimeErrorryr|_request_api_listri __class__)r_rrrxr^r^r`rs  zBaseSyncPage.get_next_pageN) rbrcrdpydanticrr|rfrrrrr^r^r^r`rzs  rzc@sLeZdZddddddddZd d d d Zd d ddZdd ddZdS)AsyncPaginatorAsyncAPIClientr8zType[AsyncPageT]zType[_T]r\)r}rxpage_clsr~r]cCs||_||_||_||_dS)N)rir|rh _page_cls)r_r}rxrr~r^r^r`raszAsyncPaginator.__init__z Generator[Any, None, AsyncPageT])r]cCs |S)N) _get_page __await__)r_r^r^r`rszAsyncPaginator.__await__rRcs4dddfdd }|j_jjjIdHS)NrR)respr]cs|jjjjd|S)N)r~rxr})rrirhr|)r)r_r^r`_parsers  z)AsyncPaginator._get_page.._parser)rh post_parserr|requestr)r_rr^)r_r`rszAsyncPaginator._get_pagezAsyncIterator[_T]c CsFtt|IdH}x0|2y 3dH}Wn tk s6X|VqYWdS)N)rrRStopAsyncIteration)r_rrr^r^r` __aiter__s  zAsyncPaginator.__aiter__N)rbrcrdrarrrr^r^r^r`rs  rc@s`eZdZUeZded<dddddddZd d d d Zd ddddZ d d dddZ dS) BaseAsyncPagerr|zType[_T]r8r\)r~r}rxr]cCs||_||_||_dS)N)rir|rh)r_r~r}rxr^r^r`rsz%BaseAsyncPage._set_private_attributeszAsyncIterator[_T])r]c CsLxF|2y 3dH}Wn tk sd?Zd@dAdBdCdDZdEd/dEdFdGdHZd=ddIdJdKZd)dEd$dLdMdNdOZedPd:dQdRZedSd:dTdUZedVd:dWdXZedYd:dZd[Zd\d\dd]d^d_Zedd:d`daZedd:dbdcZejdddd!dedcZdfd:dgdhZdvdidjdkdldmZdwdd/didndodpdqZd$dd&drdsZ dd:dtduZ!dS)x BaseClientrr|rv_versionr _base_urlint max_retrieszUnion[float, Timeout, None]timeoutz httpx.Limits_limitszProxiesTypes | None_proxiesz!Transport | AsyncTransport | None _transportrj_strict_response_validationz str | None_idempotency_headerNztype[_DefaultStreamT] | None_default_stream_cls)rrcustom_headers custom_queryz str | URLzfloat | Timeout | NonezMapping[str, str] | NonezMapping[str, object] | Noner\) versionbase_urlrrrlimits transportproxiesrrr]c Csh||_|t||_||_||_||_||_||_| p:i|_ | pDi|_ ||_ d|_ |dkrdt ddS)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 `anthropic.DEFAULT_MAX_RETRIES`)r_enforce_trailing_slashrrrrrrr_custom_headers _custom_queryrr TypeError) r_rrrrrrrrrrr^r^r`raQs  zBaseClient.__init__)rZr]cCs"|jdr|S|j|jddS)N/)raw_path)rendswithrt)r_rZr^r^r`rps z"BaseClient._enforce_trailing_slashzhttpx.ResponserJ)responser]cCs|jr|jsd}d|j}nT|j}|}y t|}d|jd|}Wn$tk rp|pjd|j}YnX|j|||dS)Nz Error code: z - )bodyr) is_closedZis_stream_consumed status_codetextstripjsonloads Exception_make_status_error)r_rrerr_msgZerr_textr^r^r` _make_status_error_from_responseus   z+BaseClient._make_status_error_from_responseobjectz_exceptions.APIStatusError)rrrr]cCs tdS)N)NotImplementedError)r_rrrr^r^r`rszBaseClient._make_status_errorz Optional[int]r8)remaining_retriesrxr]cCs|dk r |S||jS)N)get_max_retriesr)r_rrxr^r^r`_remaining_retriesszBaseClient._remaining_retriesz httpx.Headers)rxr]cCsb|jpi}t|j|}|||t|}|j}|r^|jdkr^||kr^|j pX| ||<|S)Nget) headers_merge_mappingsdefault_headers_validate_headersror#rmethodloweridempotency_key_idempotency_key)r_rxrZ headers_dictrZidempotency_headerr^r^r`_build_headerss    zBaseClient._build_headerscCs4t|}|jr0|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. r)r)rZis_relative_urlrrlstriprt)r_rZZ merge_urlZmerge_raw_pathr^r^r` _prepare_urls zBaseClient._prepare_urlzSSEDecoder | SSEBytesDecoder)r]cCstS)N)rG)r_r^r^r`_make_sse_decoderszBaseClient._make_sse_decoderz httpx.Requestc CsLttjr tdt|ddi}|j}|jdk rt|dkrJtt |j}n*t |r`t ||j}nt dt |d||}t |j|j}|d}|dk r|drd|kr|d|rt|std t |d |||d <|jjf|t|jtr|jn|j|j||j|r8|j tt!t"t#f|nd||j$d |S) NzRequest options: %sT)Z exclude_unsetzUnexpected JSON data type, z , cannot merge with `extra_body`z Content-Typezmultipart/form-databoundaryzGExpected query input to be a dictionary for multipart requests but got z instead.data)rrrrZr[rfiles)%rO isEnabledForloggingDEBUGdebugr6 json_data extra_jsonrr r4rrtyperrr[r startswithpopr0r_serialize_multipartformr|Z build_requestrsrr%rrrZqs stringifyr rvrr)r_rxkwargsrrr[ content_typer^r^r`_build_requests<      "zBaseClient._build_requestzMapping[object, object]zdict[str, object])rr]cCsb|jj|dd}i}xH|D]@\}}||}|s:|||<qt|rN||q||g||<qW|S)NZbrackets)Z array_format)rZstringify_itemsrr1append)r_rrmZ serializedkeyvalueexistingr^r^r`rs   z#BaseClient._serialize_multipartformztype[ResponseT])cast_torxr]cCsDt|js|St|j}|tt}t|r@||_ttt|S|S)N) r2rrurrDrrrr&)r_rrxrZoverride_cast_tor^r^r`_maybe_override_cast_tos   z"BaseClient._maybe_override_cast_to)rr]cCs|jtdkS)Nstream)rrrC)r_rr^r^r`_should_stream_response_body"sz'BaseClient._should_stream_response_bodyr&)rrrr]c Cs|dkrttdS|tkr$tt|SyRt|rNt|trNtt|j||dS|jrfttt ||dSttt ||dSt j k r}zt ||d|Wdd}~XYnXdS)N)rr)type_r)rr)rr&rinspectisclass issubclassr/buildrr9r:rZValidationErrorrM)r_rrrerrr^r^r`_process_response_data%s  z!BaseClient._process_response_datarcCstS)N)r)r_r^r^r`r=sz BaseClient.qszhttpx.Auth | NonecCsdS)Nr^)r_r^r^r` custom_authAszBaseClient.custom_authzdict[str, str]cCsiS)Nr^)r_r^r^r` auth_headersEszBaseClient.auth_headerszdict[str, str | Omit]cCsdd|jd||j|jS)Nzapplication/json)Acceptz Content-Typez User-Agent) user_agentplatform_headersrr)r_r^r^r`rIs zBaseClient.default_headersr#)rrr]cCsdS)zaValidate the given default headers and custom headers. Does nothing by default. Nr^)r_rrr^r^r`rTs zBaseClient._validate_headerscCs|jjd|jS)Nz/Python )rrbr)r_r^r^r`r_szBaseClient.user_agentcCs|jS)N)r)r_r^r^r`rcszBaseClient.base_urlz URL | strcCs"|t|tr|nt||_dS)N)rrsrr)r_rZr^r^r`rgszDict[str, str]cCs t|jS)N)rr)r_r^r^r`rkszBaseClient.platform_headerszOptional[httpx.Headers]z float | None)response_headersr]c Cs|dkr dSy|dd}t|dSttfk r<YnX|d}yt|Sttfk rhYnXtj|}|dkrdStj|}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) rfloatrrwemailutils parsedate_tz mktime_tztime)r_rZretry_ms_headerZ retry_headerretry_date_tuple retry_dater^r^r`_parse_retry_after_headerns"     z$BaseClient._parse_retry_after_headerr)rrxrr]c Cs|||j}||}|dk r:d|kr2dkr:nn|S||}tttd|t}ddt}||} | dkrx| SdS)Nr<g@rg?)rrrminrBpowr@r) r_rrxrr retry_afterZ nb_retriesZ sleep_secondsjitterrr^r^r`_calculate_retry_timeouts   z#BaseClient._calculate_retry_timeoutcCs|jd}|dkr"tddS|dkr8tddS|jdkrTtd |jdS|jd krptd |jdS|jd krtd |jdS|jd krtd |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)rrrOrr)r_rZshould_retry_headerr^r^r` _should_retrys*        zBaseClient._should_retrycCsdtS)Nzstainless-python-retry-)uuiduuid4)r_r^r^r`rszBaseClient._idempotency_key)N)N)"rbrcrdrfrrAr?rarrrrrrrrrrrrpropertyrrrrrrrsetterrrrrrr^r^r^r`rDsP  (  :  &#rcs$eZdZdddfdd ZZS)_DefaultHttpxClientrr\)rr]c s6|dt|dt|ddtjf|dS)Nrrfollow_redirectsT) setdefaultr?rEsuperra)r_r)rr^r`ras   z_DefaultHttpxClient.__init__)rbrcrdra __classcell__r^r^)rr`r sr c@seZdZddddZdS)SyncHttpxClientWrapperr\)r]cCs&y |Wntk r YnXdS)N)closer)r_r^r^r`__del__s zSyncHttpxClientWrapper.__del__N)rbrcrdrr^r^r^r`rsrcs^eZdZUded<dZded<eedddddddddd d d d d dddddd fddZddddZddddZ dddddZ dd d!dd"d#d$Z d%dd&d'd(Z d)dd*d+d,Z ed|d-d%d.d/d0d1d2d3d4Zed}d5d6d-d%d.d7d8d9d:d4Zed~d5dd;d-d%d.ddd4Zdd5dd;d-d%d.dd?d=d2d@d4Zd-d%dAdd?d=d2dBdCZd%d-d dDdd?d=dEdFdGZd-d%dHddId8dJdKdLZdMdNd%dOdPdQdRZeid5dSdd-dTd7d8dUdVdWZeidXdd-dTd/dYd1dZd[dWZeidd\dd-dTdd?d=dZd]dWZid5dd^dd-dTdd?d=dZd_dWZedidd5d`dd-dadTdbd7d8dcdddeZediddfdd-dadTdbd/dYd1dgdhdeZedidddidd-dadTdbdd?d=dgdjdeZdidd5ddkdd-dadTdbdd?d=dgdldeZdidmdd-dadTd8dndodpZddidqdd-dadbdTd8drdsdtZdidmdd-dadTd8dndudvZdidwdxddMdNdadTddOdydzd{ZZS)r{z httpx.Clientr|Nztype[Stream[Any]] | Noner)rrrrr http_clientrrrvz str | URLrz!float | Timeout | None | NotGivenzTransport | NonezProxiesTypes | Nonez Limits | Nonezhttpx.Client | NonezMapping[str, str] | NonezMapping[str, object] | Nonerjr\) rrrrrrrrrrrr]c s|dk r*tjdtdd|dk r.tdnt}|dk rVtjdtdd|dk rVtd|dk r~tjdtdd|dk r~tdt|s|r|jtkr|j}nt}|dk rt |t j st d t |tj||tt|||||| | | d |p t|tt||||d d |_dS) NzhThe `connection_pool_limits` argument is deprecated. The `http_client` argument should be passed instead)category stacklevelzNThe `http_client` argument is mutually exclusive with `connection_pool_limits`z[The `transport` argument is deprecated. The `http_client` argument should be passed insteadzAThe `http_client` argument is mutually exclusive with `transport`zYThe `proxies` argument is deprecated. The `http_client` argument should be passed insteadz?The `http_client` argument is mutually exclusive with `proxies`zOInvalid `http_client` argument; Expected an instance of `httpx.Client` but got ) rrrrrrrrrrT)rrrrrr)warningswarnDeprecationWarningrwrEr2rHTTPX_DEFAULT_TIMEOUTr?rsroClientrrrrarr$rr|) r_rrrrrrrrrrr)rr^r`ras^ zSyncAPIClient.__init__)r]cCs|jjS)N)r|r)r_r^r^r`rCszSyncAPIClient.is_closedcCst|dr|jdS)z`Close the underlying HTTPX client. The client will *not* be usable after this. r|N)hasattrr|r)r_r^r^r`rFs zSyncAPIClient.closerS)r_r]cCs|S)Nr^)r_r^r^r` __enter__PszSyncAPIClient.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | None)exc_typeexcexc_tbr]cCs |dS)N)r)r_r r!r"r^r^r`__exit__SszSyncAPIClient.__exit__r8)rxr]cCsdS)z#Hook for mutating the given optionsNr^)r_rxr^r^r`_prepare_options[szSyncAPIClient._prepare_optionsz httpx.Request)rr]cCsdS)aThis 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. Nr^)r_rr^r^r`_prepare_requestbs zSyncAPIClient._prepare_requestzType[ResponseT]z Optional[int]z Literal[True]zType[_StreamT]rV)rrxrr stream_clsr]cCsdS)Nr^)r_rrxrrr&r^r^r`rms zSyncAPIClient.requestF)rzLiteral[False]r&)rrxrrr]cCsdS)Nr^)r_rrxrrr^r^r`rys )rr&zType[_StreamT] | NonezResponseT | _StreamTcCsdS)Nr^)r_rrxrrr&r^r^r`rs ztype[_StreamT] | NonecCs|j|||||dS)N)rrxrr&r)_request)r_rrxrrr&r^r^r`rs z int | Nonec Cs2|||}|||||}||}||i}|jdk rN|j|d<td|j|j y(|j j |fd|p||j |di|} Wnt jk r} zFtjddd|dkr|j|||||dd Std t|d| Wdd} ~ XYnhtk rT} zHtjd dd|dkr.|j|||||dd Std t|d| Wdd} ~ XYnXtd |j|j | j| j| jy | Wnt jk r} zztjddd|dkr|| jr| j|j|||| jj||dS| jjs| jtd|| jdWdd} ~ XYnX|j||| ||dS)NauthzSending HTTP Request: %s %sr)rz"Encountered httpx.TimeoutExceptionT)exc_infor)rr&rzRaising timeout errorzEncountered ExceptionzRaising connection errorzHTTP Response: %s %s "%i %s" %sz!Encountered httpx.HTTPStatusError)rr&zRe-raising status error)rrxrrr&)rr$rrr%rrOrrrZr|sendrroTimeoutException_retry_requestrKrrLr reason_phraserraise_for_statusHTTPStatusErrorrrrrreadr_process_response) r_rrxrrr&retriesrrrrr^r^r`r's                 zSyncAPIClient._requestzhttpx.Headers | None)rxrrrrr&r]c Csd|d}|dkrtdn td|||||}td|j|t||j|||||dS)Nrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rxrrrr&)rOrrrrrZrsleepr') r_rxrrrrr& remainingrr^r^r`r,s    zSyncAPIClient._retry_requestzhttpx.Responsez1type[Stream[Any]] | type[AsyncStream[Any]] | None)rrxrrr&r]c Cs|jjtdkr,ttt||||||dSt|p6|}t |rt |t rt |t sjt dt d|td|}tt|||t||||dS|tjkrtt|St ||td||||d}t|jjtrtt|S|S)Nr)rawr}rrr&rxz!API Response types must subclass z ; Received ztype[BaseAPIResponse[Any]]ztype[ResponseT])rrrrCrr&rNrrrrr<r;rr>roResponserjparse) r_rrxrrr&origin response_cls api_responser^r^r`r1$sH         zSyncAPIClient._process_responsez Type[object]zType[SyncPageT]rP)r~rrxr]cs.dddfdd }|_j|ddS)NrP)rr]cs|jd|S)N)r}r~rx)r)r)r~rxr_r^r`rcs z0SyncAPIClient._request_api_list.._parserF)r)rr)r_r~rrxrr^)r~rxr_r`r]szSyncAPIClient._request_api_list)rxrr.)pathrrxrr]cCsdS)Nr^)r_r;rrxrr^r^r`ros zSyncAPIClient.get)rxztype[_StreamT])r;rrxrr&r]cCsdS)Nr^)r_r;rrxrr&r^r^r`rzs )rxr&cCsdS)Nr^)r_r;rrxrr&r^r^r`rs )rxrr&cCs.tjfd|d|}tt|j||||dS)Nr)rrZ)rr&)r8 constructrr&r)r_r;rrxrr&optsr^r^r`rs )rrxrrz Body | NonezRequestFiles | None)r;rrrxrrr]cCsdS)Nr^)r_r;rrrxrrr^r^r`posts zSyncAPIClient.post)rrxr)r;rrrxrrr&r]cCsdS)Nr^)r_r;rrrxrrr&r^r^r`r>s )rrxrr&cCsdS)Nr^)r_r;rrrxrrr&r^r^r`r>s )rrxrrr&c Cs6tjfd||t|d|}tt|j||||dS)Nr>)rrZrr)rr&)r8r<rrr&r) r_r;rrrxrrr&r=r^r^r`r>s )rrx)r;rrrxr]cCs$tjfd||d|}|||S)Npatch)rrZr)r8r<r)r_r;rrrxr=r^r^r`r?szSyncAPIClient.patch)rrrx)r;rrrrxr]cCs*tjfd||t|d|}|||S)Nput)rrZrr)r8r<rr)r_r;rrrrxr=r^r^r`r@s zSyncAPIClient.putcCs$tjfd||d|}|||S)Ndelete)rrZr)r8r<r)r_r;rrrxr=r^r^r`rAszSyncAPIClient.deleter)rrxr)r;r~rrrxrr]cCs&tjf|||d|}||||S)N)rrZr)r8r<r)r_r;r~rrrxrr=r^r^r` get_api_lists zSyncAPIClient.get_api_list)N)N)N)N)rbrcrdrfrrArrarrrr#r$r%rrr'r,r1rrr>r?r@rArBrr^r^)rr`r{s  .I    d9  "$$ "    r{cs$eZdZdddfdd ZZS)_DefaultAsyncHttpxClientrr\)rr]c s6|dt|dt|ddtjf|dS)NrrrT)rr?rErra)r_r)rr^r`ra s   z!_DefaultAsyncHttpxClient.__init__)rbrcrdrarr^r^)rr`rC srCc@seZdZddddZdS)AsyncHttpxClientWrapperr\)r]cCs0yt|Wntk r*YnXdS)N)asyncioget_running_loop create_taskacloser)r_r^r^r`r szAsyncHttpxClientWrapper.__del__N)rbrcrdrr^r^r^r`rDsrDcs`eZdZUded<dZded<eedddddddddd d d d d dddddd fddZd dddZddddZ dddddZ dd d!dd"d#d$Z d%dd&d'd(Z d)dd*d+d,Z ed-dd.d/d%d0d1d2d3d4d5Zedd6d/d%d7d8d1d9d:d;d5Zeddd<d/d%d d=d1d>d:d?d5Zd-ddd@d/d%d d=d1d>d:dAd5Zd/d%d d=dBd>d:dCdDZd%d/d dEd d=d>dFdGdHZd/d%dId dJd2dKdLdMZdNdOd%dPdQdRdSZeid-dTdd/dUd0d2dVdWdXZeidYdd/dUd7d8d9dZd[dXZeidd\dd/dUd d=d>dZd]dXZid-dd^dd/dUd d=d>dZd_dXZeddid-d`dd/dadbdUd0d2dcdddeZeddidfdd/dadbdUd7d8d9dgdhdeZeddiddidd/dadbdUd d=d>dgdjdeZddid-ddkdd/dadbdUd d=d>dgdldeZdidmdd/dadUd2dndodpZddidfdd/dadbdUd2dqdrdsZdidmdd/dadUd2dndtduZdidvdwddNdOdadUddPdxdydzZZS){rzhttpx.AsyncClientr|Nztype[AsyncStream[Any]] | Noner)rrrrrrrrrvz str | URLrjrz!float | Timeout | None | NotGivenzAsyncTransport | NonezProxiesTypes | Nonez Limits | Nonezhttpx.AsyncClient | NonezMapping[str, str] | NonezMapping[str, object] | Noner\) rrrrrrrrrrrr]c s|dk r*tjdtdd| dk r.tdnt}|dk rVtjdtdd| dk rVtd|dk r~tjdtdd| dk r~tdt|s| r| jtkr| j}nt}| dk rt | t j st d t | tj|||tt||||| | |d | p t|tt||||d d |_dS) NzhThe `connection_pool_limits` argument is deprecated. The `http_client` argument should be passed insteadr)rrzNThe `http_client` argument is mutually exclusive with `connection_pool_limits`z[The `transport` argument is deprecated. The `http_client` argument should be passed insteadzAThe `http_client` argument is mutually exclusive with `transport`zYThe `proxies` argument is deprecated. The `http_client` argument should be passed insteadz?The `http_client` argument is mutually exclusive with `proxies`zTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got ) rrrrrrrrrrT)rrrrrr)rrrrwrEr2rrr?rsro AsyncClientrrrrarr$rDr|) r_rrrrrrrrrrr)rr^r`ra,s^ zAsyncAPIClient.__init__)r]cCs|jjS)N)r|r)r_r^r^r`rszAsyncAPIClient.is_closedcs|jIdHdS)z`Close the underlying HTTPX client. The client will *not* be usable after this. N)r|rH)r_r^r^r`rszAsyncAPIClient.closerS)r_r]cs|S)Nr^)r_r^r^r` __aenter__szAsyncAPIClient.__aenter__ztype[BaseException] | NonezBaseException | NonezTracebackType | None)r r!r"r]cs|IdHdS)N)r)r_r r!r"r^r^r` __aexit__szAsyncAPIClient.__aexit__r8)rxr]csdS)z#Hook for mutating the given optionsNr^)r_rxr^r^r`r$szAsyncAPIClient._prepare_optionsz httpx.Request)rr]csdS)aThis 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. Nr^)r_rr^r^r`r%s zAsyncAPIClient._prepare_requestF)rrzType[ResponseT]zLiteral[False]z Optional[int]r&)rrxrrr]csdS)Nr^)r_rrxrrr^r^r`rs zAsyncAPIClient.request)rz Literal[True]ztype[_AsyncStreamT]rW)rrxrr&rr]csdS)Nr^)r_rrxrr&rr^r^r`rs )r&rztype[_AsyncStreamT] | NonezResponseT | _AsyncStreamTcsdS)Nr^)r_rrxrr&rr^r^r`rs )rr&rcs|j|||||dIdHS)N)rrxrr&r)r')r_rrxrr&rr^r^r`rs z int | Nonec sR|||}||IdH|||}||}||IdHi}|jdk rZ|j|d<y.|jj|fd|pv|j|di|IdH} Wnt j k r} zLt j ddd|dkr|j |||||ddIdHSt d t|d| Wdd} ~ XYnntk r`} zNt j d dd|dkr:|j |||||ddIdHSt d t|d| Wdd} ~ XYnXt d |j|j| j| jy | Wnt jk r6} zt j d dd|dkr|| jr| jIdH|j |||| jj||dIdHS| jjs| jIdHt d|| jdWdd} ~ XYnX|j||| ||dIdHS)Nr(r)rz"Encountered httpx.TimeoutExceptionT)r)r)rr&rzRaising timeout errorzEncountered ExceptionzRaising connection errorzHTTP Request: %s %s "%i %s"z!Encountered httpx.HTTPStatusError)rr&zRe-raising status error)rrxrrr&)rr$rrr%rr|r*rror+rOrr,rKrrLrrZrr-r.r/rrrHrrZareadrr1) r_rrxrr&rr2rrrrr^r^r`r's|            zAsyncAPIClient._requestzhttpx.Headers | None)rxrrrrr&r]c sp|d}|dkrtdn td|||||}td|j|t|IdH|j|||||dIdHS)Nrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rxrrrr&)rOrrrrrZanyior3r') r_rxrrrrr&r4rr^r^r`r,9s   zAsyncAPIClient._retry_requestzhttpx.Responsez1type[Stream[Any]] | type[AsyncStream[Any]] | None)rrxrrr&r]c s|jjtdkr,ttt||||||dSt|p6|}t |rt |t rt |t sjt dt d|td|}td|||t||||dS|tjkrtt|St ||td||||d}t|jjtrtt|S|IdHS)Nr)r5r}rrr&rxz!API Response types must subclass z ; Received ztype[BaseAPIResponse[Any]]r&ztype[ResponseT])rrrrCrr&rNrrrrr<r=rr>ror6rjr7) r_rrxrrr&r8r9r:r^r^r`r1VsH         z AsyncAPIClient._process_responsezType[_T]zType[AsyncPageT]zAsyncPaginator[_T, AsyncPageT])r~rrxr]cCst||||dS)N)r}rxrr~)r)r_r~rrxr^r^r`rsz AsyncAPIClient._request_api_list)rxrr.)r;rrxrr]csdS)Nr^)r_r;rrxrr^r^r`rs zAsyncAPIClient.get)rx)r;rrxrr&r]csdS)Nr^)r_r;rrxrr&r^r^r`rs )rxr&csdS)Nr^)r_r;rrxrr&r^r^r`rs )rxrr&cs.tjfd|d|}|j||||dIdHS)Nr)rrZ)rr&)r8r<r)r_r;rrxrr&r=r^r^r`rs )rrrxrz Body | NonezRequestFiles | None)r;rrrrxrr]csdS)Nr^)r_r;rrrrxrr^r^r`r>s zAsyncAPIClient.post)rrrx)r;rrrrxrr&r]csdS)Nr^)r_r;rrrrxrr&r^r^r`r>s )rrrxr&csdS)Nr^)r_r;rrrrxrr&r^r^r`r>s )rrrxrr&c s<tjfd||t|IdHd|}|j||||dIdHS)Nr>)rrZrr)rr&)r8r<rr) r_r;rrrrxrr&r=r^r^r`r>s )rrx)r;rrrxr]cs*tjfd||d|}|||IdHS)Nr?)rrZr)r8r<r)r_r;rrrxr=r^r^r`r?szAsyncAPIClient.patch)r;rrrrxr]cs6tjfd||t|IdHd|}|||IdHS)Nr@)rrZrr)r8r<rr)r_r;rrrrxr=r^r^r`r@ s zAsyncAPIClient.putcs*tjfd||d|}|||IdHS)NrA)rrZr)r8r<r)r_r;rrrxr=r^r^r`rAszAsyncAPIClient.deleter)rrxr)r;r~rrrxrr]cCs&tjf|||d|}||||S)N)rrZr)r8r<r)r_r;r~rrrxrr=r^r^r`rB#s zAsyncAPIClient.get_api_list)rbrcrdrfrrArrarrrJrKr$r%rrr'r,r1rrr>r?r@rArBrr^r^)rr`r(s  .H    ]9  "$$ "    r)query extra_headers extra_query extra_bodyrrrz Query | NonezHeaders | Nonez Body | Nonez str | Nonez'float | httpx.Timeout | None | NotGivenzPostParser | NotGivenr.)rMrNrOrPrrrr]cCsi}|dk r||d<|dk r*tt||d<|dk r:||d<|dk rV|di||d<t|tsh||d<|dk rx||d<t|r||d<|S)zECreate a dict of type RequestOptions without keys of NotGiven values.Nrrr[rrr)rr(rrsr%r2)rMrNrOrPrrrrxr^r^r`make_request_options1s  rQc@s.eZdZdddddZeddddZd S) OtherPlatformrvr\)namer]cCs ||_dS)N)rS)r_rSr^r^r`raWszOtherPlatform.__init__)r]cCs d|jS)NzOther:)rS)r_r^r^r`__str__ZszOtherPlatform.__str__N)rbrcrdrarrTr^r^r^r`rRVsrR)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownPlatform)r]cCsyt}t}Wntk r0dSXd|ksBd|krFdS|dkrRdS|dkr^dSd |krjd S|d krt}|d krd S|dkrdSdS|rt|SdS)Nr\iphoneZipadrZdarwinrUwindowsrWZandroidr[linuxfreebsdrXopenbsdrYrV)platformsystemrrdistroidrR)reZ platform_name distro_idr^r^r` get_platformns. ri)maxsizervzDict[str, str])rr]cCs"d|ttttttdS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rvriget_architectureget_python_runtimeget_python_version)rr^r^r`rs rc@s.eZdZdddddZeddddZd S) OtherArchrvr\)rSr]cCs ||_dS)N)rS)r_rSr^r^r`raszOtherArch.__init__)r]cCs d|jS)Nzother:)rS)r_r^r^r`rTszOtherArch.__str__N)rbrcrdrarrTr^r^r^r`rosro)x32x64armarm64unknowncCs"ytStk rdSXdS)Nrt)rdpython_implementationrr^r^r^r`rmsrmcCs"ytStk rdSXdS)Nrt)rdpython_versionrr^r^r^r`rnsrnArchcCsryt\}}t}Wntk r0dSX|dkr>dS|dkrJdS|dkrVdS|dkrbdS|rnt|SdS) Nrt)rsaarch64rsrrx86_64rq32bitrp)rd architecturemachinerrro)Zpython_bitness_r|r^r^r`rls  rlzMapping[_T_co, Union[_T, Omit]]zDict[_T_co, _T])obj1obj2r]cCs||}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||qSr^)rsr!).0rrr^r^r` sz#_merge_mappings..)rm)r~rmergedr^r^r`rsr) __future__rrrr rrErrrdr email.utilstypesrrtypingrrrrr r r r r rrrrrrtyping_extensionsrrrrLrorfrrrrrZ_qsr_filesrr_typesrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/_utilsr0r1r2r3r4_compatr5r6Z_modelsr7r8r9r: _responser;r<r=r> _constantsr?r@rArBrCrDrEZ _streamingrFrGrHrIrJrKrLrMZ_legacy_responserN getLoggerrbrOrfrPrRrSrTrVrWZ httpx._configrXr ImportErrorrYrgrzrrrrIrrrr ZDefaultHttpxClientrr{rCZDefaultAsyncHttpxClientrDrrQrRr]rirrorwrmrnrlrr^r^r^r`s   D   L$     #1.'& % "  *