o 6Wjy@sUddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl ZddlmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#ddl$m%Z%m&Z&m'Z'ddl(Z(ddl)Z)ddl*Z*ddl+Z+ddl)m,Z,m-Z-m.Z.m/Z/ddl+m0Z0d d l1m2Z2d d l3m4Z4d d l5m6Z6m7Z7d d l8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZId dlJmKZKmLZLmMZMmNZNmOZOmPZPd dlQmRZRmSZSmTZTd dlUmVZVmWZWmXZXmYZYd dlZm[Z[d dl\m]Z]m^Z^m_Z_m`Z`d dlambZbmcZcmdZdmeZemfZfmgZgmhZhd dlimjZjmkZkmlZlmmZmd dl2mnZnmoZompZpmqZqmrZrmsZsd dltmuZumvZvmwZwmxZxmyZymzZzm{Z{m|Z|d dl}m~Z~d dlmZd dlmZe eZded<edddZedd dZed!Zed"d#d$Zed%ejedZed&eledZerdd'lmZeZnzdd'lmZWneye=d(ZYnwGd)d*d*ZGd+d,d,eVeeZGd-d.d.eeeeZGd/d0d0eeefZGd1d2d2eeeeZed3ee)je)jfdZed4eejeelefdZGd5d6d6eeefZGd7d8d8e)jZere)jZneZGd9d:d:eZGd;d<dd>e)jZzddlZWneyXGd?d@d@e)jZYn wGdAd@d@ejZerme)jZ e)jZneZeZGdBdCdCeZGdDdEdEee)jelefZdddddeIeIdFddVdWZGdXdYdYeedfZGdZd[d[Zeee%d\fZdd^d_ZeOdd`ddfdgZGdhdidiZeee%djfZddkdlZddmdnZddpdqZddudvZddydzZed{hZdd~dZdddZdddZdddZdddZdS)) annotationsN) TracebackType)random) TYPE_CHECKINGAnyDictListTypeTupleUnionGenericMappingTypeVarIterableIteratorOptionalSequence Generator AsyncIteratorcastoverload)Literaloverride get_origin)URLProxy HTTPTransportAsyncHTTPTransport) PrivateAttr) _exceptions Querystring)to_httpx_filesasync_to_httpx_files)BodyOmitQueryHeadersTimeoutNotGiven ResponseT AnyMapping PostParser BinaryTypes RequestFiles HttpxSendArgsRequestOptionsAsyncBinaryTypesHttpxRequestFilesModelBuilderProtocol not_given)is_dictis_listasyncifyis_given lru_cache is_mapping) PYDANTIC_V1 model_copy model_dump) GenericModelFinalRequestOptions validate_typeconstruct_type) APIRequest) APIResponseBaseAPIResponseAsyncAPIResponseextract_response_type)DEFAULT_TIMEOUTMAX_RETRY_DELAYDEFAULT_MAX_RETRIESINITIAL_RETRY_DELAYRAW_RESPONSE_HEADEROVERRIDE_CAST_TO_HEADERDEFAULT_CONNECTION_LIMITS)Stream SSEDecoder AsyncStreamSSEBytesDecoder)AnthropicErrorAPIStatusErrorRetryableErrorAPITimeoutErrorAPIConnectionErrorAPIResponseValidationError)CallNext Middleware AsyncCallNextMiddlewareInputMiddlewareCallableAsyncMiddlewareCallablevalidate_sync_middlewarevalidate_async_middleware) openapi_dumps)get_environment_proxies)LegacyAPIResponsezlogging.Loggerlog SyncPageTzBaseSyncPage[Any])bound AsyncPageTzBaseAsyncPage[Any]_T_T_coT) covariant_StreamT _AsyncStreamT)DEFAULT_TIMEOUT_CONFIG@c@sveZdZUdZded<ded<ded<edd d Zeddd Zeddd Zeeedddd ZedddZ dS)PageInfozStores the necessary information to build the request to retrieve the next page. Either `url` or `params` must be set. URL | NotGivenurlQuery | NotGivenparamsBody | NotGivenjsonrreturnNonecCdSNselfrqrzrze/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anthropic/_base_client.py__init__zPageInfo.__init__r'cCrxryrz)r|rsrzrzr}r~rr%cCrxryrz)r|rurzrzr}r~rrqrurscCs||_||_||_dSryr)r|rqrursrzrzr}r~s strcCsN|jr|jjd|jdS|jr|jjd|jdS|jjd|jdS)Nz(url=)z(json=z(params=)rq __class____name__rursr|rzrzr}__repr__s zPageInfo.__repr__N)rqrrvrw)rsr'rvrw)rur%rvrw)rqrprurtrsrrrvrwrvr) r __module__ __qualname____doc____annotations__rr~r5rrrzrzrzr}ros"      roc@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]_modelrvboolcCs|}|sdS|duS)NF)_get_page_itemsnext_page_info)r|itemsrzrzr} has_next_pages zBasePage.has_next_pageOptional[PageInfo]cCrxryrzrrzrzr}rszBasePage.next_page_info Iterable[_T]cCrxryrzrrzrzr}rzBasePage._get_page_itemsrqrhttpx.QueryParamscCsttt|jj|jSry)httpx QueryParamsrrrrsmerger{rzrzr}_params_from_urlszBasePage._params_from_urlinforocCst|j}|t|jtsi|j|j|_|St|jts:||j}|jj|d}t |j|_t ||_|St|j tsht |j sIt d|jsTi|j |_|St |js]t di|j|j |_|Std)N)rsz*Pagination is only supported with mappingszUnexpected PageInfo state)r=r_strip_raw_response_header isinstancersr*rqr copy_withdictrrur; TypeError json_data ValueError)r|roptionsrsrqrzrzr}_info_to_optionss,          zBasePage._info_to_optionsNrvr)rvr)rvr)rqrrvr)rrorvr@) rrrrrrrrrrrrrrzrzrzr}rs      rc@FeZdZUeZded<dd d Zdd dZdddZ dddZ dS) BaseSyncPage SyncAPIClient_clientclientmodelrrr@rvrwcCs0ts t|dddur i|_||_||_||_dSN__pydantic_private__r<getattrrrrr)r|rrrrzrzr}_set_private_attributes  z$BaseSyncPage._set_private_attributes Iterator[_T]ccs(|D] }|D]}|Vq qdSry iter_pagesrr|pageitemrzrzr}__iter__s   zBaseSyncPage.__iter__r|reIterator[SyncPageT]ccs&|} |V|r|}ndSqryr 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()`.)rrr RuntimeErrorrr_request_api_listrrr|rrrzrzr}rs zBaseSyncPage.get_next_pageN)rrrrrr@rvrw)rvr)r|rervr)r|rervre) rrrpydanticrrrrrrrrzrzrzr}rs     rc@s4eZdZdd d ZdddZdddZdddZdS)AsyncPaginatorrAsyncAPIClientrr@page_clsType[AsyncPageT]rrrvrwcCs||_||_||_||_dSry)rrr _page_cls)r|rrrrrzrzr}r~+s zAsyncPaginator.__init__ Generator[Any, None, AsyncPageT]cCs |Sry) _get_page __await__rrzrzr}r7s zAsyncPaginator.__await__rgcs0dfdd }|j_jjjIdHS)Nresprgrvcs|jjjjd|S)N)rrr)rrrrrrrzr}_parser;s z)AsyncPaginator._get_page.._parser)rrgrvrg)r post_parserrrequestr)r|rrzrr}r:szAsyncPaginator._get_pageAsyncIterator[_T]cCs0tt|IdH}|2z 3dHW}|Vq 6dSry)rrgrrzrzr} __aiter__GszAsyncPaginator.__aiter__N) rrrr@rrrrrvrw)rvr)rvrgrvr)rrrr~rrrrzrzrzr}r*s    rc@r) BaseAsyncPagerrrrrrr@rvrwcCs0ts t|dddur i|_||_||_||_dSrr)r|rrrrzrzr}rTrz%BaseAsyncPage._set_private_attributesrcCs2|2z3dHW}|D]}|Vqq6dSryrrrzrzr}ras  zBaseAsyncPage.__aiter__r|rgAsyncIterator[AsyncPageT]cCs,|} |V|r|IdH}ndSqryrrrzrzr}rfszBaseAsyncPage.iter_pagescs<|}|s td||}|jj|j|j|dIdHSrrrrzrzr}ros zBaseAsyncPage.get_next_pageN)rrrrrr@rvrwr)r|rgrvr)r|rgrvrg) rrrrrrrrrrrrzrzrzr}rQs    r _HttpxClientT_DefaultStreamTc@seZdZUded<ded<ded<ded<d ed <d ed <d ed<dZded<ded<eedddddd!d"Zdd$d%Zdd)d*Z dd/d0Z d1d2dd7d8Z dd9d:Z dd|j r>||vr>|j ||<dd|D}d|vrOt||d<d|vrqt|jtr\|jn|j} t| trg| j} | durqt| |d<|S)Nzx-stainless-timeoutcSsg|]}|qSrz)lower).0headerrzrzr} z-BaseClient._build_headers..zx-stainless-retry-countzx-stainless-read-timeout)headers merge_headersrrr)rreaddefault_headers _strip_omit_validate_headersrr(ridempotency_keyr*) r|rr rmerged_headers headers_dictridempotency_headerlower_custom_headersrrzrzr}_build_headerss6        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|rq merge_urlmerge_raw_pathrzrzr} _prepare_urls zBaseClient._prepare_urlSSEDecoder | SSEBytesDecodercCtSry)rPrrzrzr}_make_sse_decoderszBaseClient._make_sse_decoder httpx.Requestc Csttjrtdt|dtrdhnidi}|j}|jdur@|dur+t t |j}nt |r6t ||j}n t dt|d|j||d}t |j|j}|d}|j}|dur|d rd |vrh|d|rt|sxtd t|d |||d <|st tt}||j} |r| jrit| j|}| j | j!"dddd} d| j#vrd| j#$ddi|d<|j%&dk} | r |j'dur|durtd|j'dur|durtd|j'dur|j'|d<nt(|t)r||d<n|st*|r|durt+|nd|d<||d<n |dd|d d|j,j-d|t(|j.t/r(|j.n|j.|j%| |r=|j01t t2t3t4f|ndd|S)NzRequest options: %sTcontent) exclude_unsetexcludezUnexpected 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?rrr_ sni_hostname- extensionsgetz7Passing both `content` and `json_data` is not supportedz3Passing both `content` and `files` is not supportedfiles)rrmethodrqrsrz)5rd isEnabledForloggingDEBUGdebugr>r<r extra_jsonrr%r;_merge_mappingsrtyper default_queryrsr2r3 startswithpopr6r_serialize_multipartformr3ForceMultipartDictr"rqqueryrrrrsplithostreplacer4r r'rbytesr9rar build_requestrr*qs stringifyr rr) r|rr kwargsrrrs content_typer3 prepared_urlis_body_allowedrzrzr}_build_requests             $   " 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)rGstringify_itemsr2r7append)r|r,r serializedkeyvalueexistingrzrzr}r?hs   z#BaseClient._serialize_multipartformcast_totype[ResponseT]cCsDt|js|St|j}|tt}t|r ||_ttt|S|Sry) r9rrr>rMr5rr r+)r|rXrroverride_cast_torzrzr}_maybe_override_cast_tos   z"BaseClient._maybe_override_cast_tosourceBaseAPIResponse[Any]LegacyAPIResponse[Any]c Cs"t|j|j||j|j|j|jdS)zVConvert an `APIResponse` / `AsyncAPIResponse` into the equivalent `LegacyAPIResponse`.)rawrXrstream stream_clsrr )rc http_response_cast_to_is_sse_stream _stream_clsrr )r|r\rzrzr}_convert_to_legacy_responsesz&BaseClient._convert_to_legacy_responsercCs|jtdkS)Nr`)rr2rLr|rrzrzr}_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_rV)rr)rr+rinspectisclass issubclassr4buildrrArBrValidationErrorrX)r|r,rXrerrrzrzr}_process_response_datas  z!BaseClient._process_response_datar"cCr$ryr!rrzrzr}rGz BaseClient.qshttpx.Auth | NonecCrxryrzrrzrzr} custom_authzBaseClient.custom_authdict[str, str]cCsiSryrzrrzrzr} auth_headersrtzBaseClient.auth_headersdict[str, str | Omit]cCs"dd|jd||j|jS)Nzapplication/json)Acceptr*z User-Agent) user_agentplatform_headersrvrrrzrzr}rszBaseClient.default_headerscCs i|jSry)rrrzrzr}r<szBaseClient.default_queryrr(cCdS)zaValidate the given default headers and custom headers. Does nothing by default. Nrz)r|rrrzrzr}r zBaseClient._validate_headerscCs|jjd|jS)Nz/Python )rrrrrzrzr}ryszBaseClient.user_agentcC|jSry)rrrzrzr}rrqzBaseClient.base_url URL | strcCs"|t|tr |nt||_dSry)rrrrr{rzrzr}rs"cCr})zThe client-level middleware, outermost first. To run extra middleware for specific calls, derive a client with `client.with_options(middleware=[*client.middleware, extra])`. )rrrzrzr}rr zBaseClient.middlewareDict[str, str]cCst|j|jdS)N)platform)rzrrrrzrzr}rzszBaseClient.platform_headers max_tokensmax_nonstreaming_tokens int | Noner)cCs<d}d}||d}||ks|r||krtdt|ddS)NiiXizStreaming is required for operations that may take longer than 10 minutes. See https://github.com/anthropics/anthropic-sdk-python#long-requests for more detailsrn)connect)rr))r|rr maximum_time default_time expected_timerzrzr}_calculate_nonstreaming_timeouts z*BaseClient._calculate_nonstreaming_timeoutresponse_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-msz retry-after) r2floatrremailutils parsedate_tz mktime_tztime)r|rretry_ms_header retry_headerretry_date_tuple retry_daterzrzr}_parse_retry_after_headers&     z$BaseClient._parse_retry_after_headerremaining_retriesrc Cs~||j}||}|durd|krdkr|St||d}tttd|t}ddt}||} | dkr=| SdS)Nr<rg@rg?)get_max_retriesrrminrKpowrIr) r|rrrr retry_after nb_retries sleep_secondsjitterrrzrzr}_calculate_retry_timeout2s  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)rr2rdr8r)r|rshould_retry_headerrzrzr} _should_retryJs*        zBaseClient._should_retryro BaseException"tuple[bool, httpx.Response | None]cCst}|}|dur?t||vr?|t|t|trdSt|tr+||j|jfSt|tr2dS|j }|dur?t||vsdS)alWhether an exception raised by a request attempt should be retried. Also returns the HTTP response behind the failure, when there is one, so retry timing can honor `retry-after` headers. Exceptions raised by middleware propagate to the caller as-is, except the ones that opt into the retry policy by type: `APIStatusError` (subject to the usual status-code policy), `APIConnectionError` / `APITimeoutError`, and `RetryableError`. The check walks each error's `__cause__` chain, so wrapping a retryable failure via `raise ... from err` preserves retries. N)TN)FN) setidaddrrUrTrrrW __cause__)r|roseencurrentrzrzr}_should_retry_exceptionms     z"BaseClient._should_retry_exceptioncCsdtS)Nzstainless-python-retry-)uuiduuid4rrzrzr}_idempotency_keyszBaseClient._idempotency_key)rrrrrrrrrrrrrrrrrvrw)rqrrvr)rrrvrT)rrrrrrrvr)rr@r rrvr )rqrrvr)rvr#)rr@r rrvr&)r,rNrvrO)rXrYrr@rvrY)r\r]rvr^)rr&rvr)r,rrXrYrrrvr+)rvr")rvrr)rvru)rvrw)rvrO)rr(rr(rvrwr)rvr)rqr~rvrw)rvr)rvr)rrrrrvr)ry)rrrvr)rrrr@rrrvr)rrrvr)rorrvr)&rrrrrrJrHr~rrrrr"r%rMr?r[rfrhrppropertyrGrsrvrr<rryrsetterrrzrrrrrrrzrzrzr}r~sp      #  l                &  #rceZdZdfdd ZZS)_DefaultHttpxClientrIrrvrwc  bdtdtdddvrtjtjdfg}ttdd}|dur2|tj|dfnt j dkrFttd d }|tj|dfttd d}|durY|tj|d fttd d}|durl|tj|dfddt D}fdddD|d<fdd| D}t di} |di|d<| d<tjdidS)Nrlimitsfollow_redirectsT transport TCP_KEEPINTVLrdarwin TCP_KEEPALIVE TCP_KEEPCNT TCP_KEEPIDLEcS(i|]\}}||dur dnt|dqSN)rqrrrUrqrzrzr} (z0_DefaultHttpxClient.__init__..ci|] }|vr||qSrzrzrargrIrzr}rverifycert trust_envhttp1http2rsocket_optionsc0i|]\}}||dur dntdd|iqSNproxyrz)rrrUrtransport_kwargsrzr}rmountsrz) setdefaultrHrNsocket SOL_SOCKET SO_KEEPALIVErrS IPPROTO_TCPsysrrbrrupdater2superr~ r|rIrrrrr proxy_map proxy_mountsdefault_transportrrIrr}r~<          z_DefaultHttpxClient.__init__rIrrvrwrrrr~ __classcell__rzrzrr}rrc@eZdZdddZdS)SyncHttpxClientWrapperrvrwcCs.|jrdSz|WdStyYdSwry)rcloserrrzrzr}__del__s zSyncHttpxClientWrapper.__del__Nrvrwrrrrrzrzrzr}rrcs@eZdZUded<dZded<dZded<dZded <eeddddd dfdd Z dd!d"Z dd#d$Z dd'd(Z dd/d0Z dd3d4Zdd7d8Zedd@dAZedBdCddFdAZedBddGddJdAZdBddGddLdAZddMdNZddRdSZdBdTdUddXdYZdd\d]ZdTd^ddadbZddhdiZeidBdjddmdnZeidoddqdnZeiddrddsdnZidBddtddudnZeddiddBdvdd}d~Zeddiddddd~Zeddidddddd~ZddiddBddddd~ZdddiddddZdddiddddZddiddddZdidddddZZS)rz httpx.ClientrNztype[Stream[Any]] | NonerCallNext | None_middleware_chainr webhook_keyrr http_clientrrrrrrrrrr!float | Timeout | None | NotGivenrhttpx.Client | Nonerrrrrrrrrvrwc st|s|r|jtkr|j}nt}|dur$t|tjs$tdt|t |p(d}|r0t |t j |t t||||||| d||_|pPt|t t|d|_dS)NzOInvalid `http_client` argument; Expected an instance of `httpx.Client` but got rz)rrrrrrrrrr)r9rHTTPX_DEFAULT_TIMEOUTrHrrClientrr;rr_rr~rr)_build_middleware_chainrrr) r|rrrrrrrrrrrzr}r~s4     zSyncAPIClient.__init__cC|jjSryrrrrzrzr}rzSyncAPIClient.is_closedcCst|dr |jdSdS)`Close the underlying HTTPX client. The client will *not* be usable after this. rN)hasattrrrrrzrzr}rs zSyncAPIClient.closer|rhcCs|Sryrzrrzrzr} __enter__rzSyncAPIClient.__enter__exc_typetype[BaseException] | NoneexcBaseException | Noneexc_tbTracebackType | NonecCs |dSryrr|rrr rzrzr}__exit__ s zSyncAPIClient.__exit__rr@cCs|Sz#Hook for mutating the given optionsrzr|rrzrzr}_prepare_options(rzSyncAPIClient._prepare_optionsrr&cCr{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. Nrzrgrzrzr}_prepare_request/r|zSyncAPIClient._prepare_requestrXType[ResponseT]r` Literal[True]raType[_StreamT]rkcCrxryrzr|rXrr`rarzrzr}r:zSyncAPIClient.requestFr`Literal[False]r+cCrxryrzr|rXrr`rzrzr}rDsr`raType[_StreamT] | NoneResponseT | _StreamTcCrxryrzrrzrzr}rMrtype[_StreamT] | Nonec Cs|||}t|}|jdur|jdkr||_|j}||j}t |dD]}||} zO|durS|j t|||d\} } | j rR|j || | |||dWSn+t t|||||d} || } t| trk| jj r{ttttf|| | WS| j} Wn4ty}z(||\}}| dks|s|dur|js||j||||dWYd}~q*d}~ww| dkr|| r| js| |j|||| dq*| js| || dtd Nr2rr`r rXrrr`rar )rrXr`rar r)r rrrz0could not resolve response (should never happen))r[r=rr4r rrrrrange_attempt_request is_success_process_responserCrrErbrr r+rk_finalize_middleware_resultrrrr_sleep_for_retryrrrrr|rXrr`ra input_optionschainrr rrpreparedrresultro should_retryfailed_responserzrzr}rWs           cDjsdSdfdd }dd d }|}tjD]}|||}q|S)Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at construction time. It is invoked once per HTTP attempt, inside the SDK's retry loop, with that attempt's `APIRequest`. NreqrCrvAPIResponse[Any]c sDt|}j||j|jd\}}tdj|j|||j|j|jdS)Nr!r3r"_prepare_middleware_optionsr$r`r rr&rXrar2rrr,rrzr} base_handlersz;SyncAPIClient._build_middleware_chain..base_handlerrr\ call_nextrYc.t|tr|jntt|dfdd }|S)Nr2rCrvr3cs |Sryrzr2r8handlerrzr}handle zCSyncAPIClient._build_middleware_chain..wrap..handler2rCrvr3)rrZr=rr]rr8r=rzr;r}wrapsz3SyncAPIClient._build_middleware_chain..wrapr?)rr\r8rYrvrYrreversedr|r7rAr+entryrzrr}rs  z%SyncAPIClient._build_middleware_chainr-rrCcCs\t|ts|Std|}t|}|dks|dkr|S|dkr#||St|jr*|S|S)aConvert the `APIResponse` returned by the middleware chain into the value the original caller expects. The middleware chain operates on `APIResponse` objects; the original caller may have asked for a parsed model (the default), a `LegacyAPIResponse` (`.with_raw_response`) or the `APIResponse` wrapper itself (`.with_streaming_response` / a `cast_to` that is itself a response class). r3r_r`rrrEr_middleware_entry_moderf_expects_response_wrapperrXparser|r-rr entry_moderzrzr}r's    z)SyncAPIClient._finalize_middleware_resultrr!r *tuple[httpx.Response, FinalRequestOptions]c Cs4||}|j||d}||i}|jdur|j|d<|jdur'|j|d<td|j|jz|j j |fd|p>|j |di|}Wn8t j y^}z tjdd d t|d|d}~wty|}zt|trktjd d d t|d|d}~wwtd |j|j|j|j|jtd |jd||fS)Prepare, build and send a single HTTP attempt. Returns the response regardless of its status code, along with the prepared options it was sent with — status handling (the retry policy, raising typed errors for the caller) happens above, where middleware can inspect error responses first. Connection failures raise typed errors (`APITimeoutError`, `APIConnectionError`). r NauthrSending HTTP Request: %s %sr`r"Encountered httpx.TimeoutExceptionTexc_infoEncountered ExceptionHTTP Response: %s %s "%i %s" %srequest_id: %s request-idrrMrrsrrdr8r4rqrsendrhrTimeoutExceptionrVrrrSrWr reason_phraserr2r|rr`r rrIrrorzrzr}r$sL          zSyncAPIClient._attempt_requestrhttpx.Response | NonecCs^||}|dkrtdntd|||||r|jnd}td|j|t|dSNrz 1 retry leftz%i retries leftz$Retrying request to %s in %f seconds)rdr8rrrrqrsleepr|r rrrrrrzrzr}r(+s  zSyncAPIClient._sleep_for_retryr r1type[Stream[Any]] | type[AsyncStream[Any]] | Nonec Cs|jjtdkrttt|||||||dSt|p|}t |rVt |t rV|r2t |jjtrVt |t sAtdt d|td|}tt|||t|||||dS|tjkr`tt|St ||td|||||d} t |jjtr|tt| S| S)Nrr_rrXr`rarr !API Response types must subclass ; Received type[BaseAPIResponse[Any]]rY)rrr2rLrr+rcrrjrkrlrErrDrrGrResponserI r|rXrrr`rar origin response_cls api_responserzrzr}r&9sf      zSyncAPIClient._process_responser Type[object]rType[SyncPageT]recs(dfdd }|_j|ddS) Nrrervcs|jd|S)N)rrr)rrrrr|rzr}rs z0SyncAPIClient._request_api_list.._parserFr)rrervre)rr)r|rrrrrzrmr}r}szSyncAPIClient._request_api_listrr`pathr1cCrxryrzr|rorXrr`rzrzr}r2rzSyncAPIClient.getrtype[_StreamT]cCrxryrzr|rorXrr`rarzrzr}r2r|rracCrxryrzrsrzrzr}r2r|rr`racCs.tjdd|d|}tt|j||||dSNr2)r4rqrrz)r@ constructrr+rr|rorXrr`raoptsrzrzr}r2s )rr'rr3r`r Body | Noner'BinaryTypes | Noner3RequestFiles | NonecCrxryrz)r|rorXrr'rr3r`rzrzr}posts zSyncAPIClient.post)rr'rr3c Crxryrz r|rorXrr'rr3r`rarzrzr}r} )rr'rr3rac Crxryrzr~rzrzr}r}r)rr'rr3r`rac Cs|dur |dur td|dur|durtdt|tr%tjdtddtjd d|||t|d|} t t |j || ||dS N2Passing both `body` and `content` is not supported3Passing both `files` and `content` is not supportedPassing raw bytes as `body` is deprecated and will be removed in a future version. Please pass raw bytes via the `content` parameter instead. stacklevelr}r4rqrr'r3rrz) rrrEwarningswarnDeprecationWarningr@rwr#rr+r) r|rorXrr'rr3r`raryrzrzr}r}s   rr'r3rcCv|dur |dur td|dur|durtdt|tr%tjdtddtjdd|||t|d|}| ||S Nrrrrrpatchrrz rrrErrrr@rwr#rr|rorXrr'r3rryrzrzr}r    zSyncAPIClient.patchcCr Nrrrrrputrrzrrrzrzr}rrzSyncAPIClient.putrr'rcCsX|dur |dur tdt|trtjdtddtjdd|||d|}|||SNrrrrdelete)r4rqrr'rz rrrErrrr@rwrr|rorXrr'rryrzrzr}r6s   zSyncAPIClient.deleter2rrr4r4cC&tjd|||d|}||||SN)r4rqrrzr@rwrr|rorrrrr4ryrzrzr} get_api_listK zSyncAPIClient.get_api_list)rrrrrrrrrrrrrrrrrrrvrwrrr|rhrvrhrrrr r r rvrwrr@rvr@rr&rvrw) rXrrr@r`rrarrvrkrXrrr@r`rrvr+) rXrrr@r`rrarrvr) rXrrr@r`rrarrvr)rvrr-rrrCrvrrr@r`rr rrvrL r rrrrr@rr]rvrwrXrrr@rrr`rrarar rrvr+)rrkrrlrr@rvre rorrXrrr1r`rrvr+) rorrXrrr1r`rrarrrvrk) rorrXrrr1r`rrarrvr)rorrXrrrzr'r{rr1r3r|r`rrvr+)rorrXrrrzr'r{rr1r3r|r`rrarrrvrk)rorrXrrrzr'r{rr1r3r|r`rrarrvr)rorrXrrrzr'r{r3r|rr1rvr+) rorrXrrrzr'r{rr1rvr+)rorrrkrrlrrzrr1r4rrvre)rrrrrrrrJr5r~rrrrrrrrrr'r$r(r&rr2r}rrrrrrzrzrr}rs     8       X &  : D    !rcr)_DefaultAsyncHttpxClientrIrrvrwc  r)NrrrTrrrrrrrrrcSrrrrrzrzr}rrrz5_DefaultAsyncHttpxClient.__init__..crrzrzrrrzr}rtrrrcrr)rrrrzr}rzrrrz)rrHrNrrrrrSrrrrbrrrr2rr~rrrr}r~Zrz!_DefaultAsyncHttpxClient.__init__rrrzrzrr}rYrrc@seZdZdddZdS) _DefaultAioHttpClient_kwargsrrvrwcKstd)NzVTo use the aiohttp client you must have installed the package with the `aiohttp` extra)r)r|rrzrzr}r~r_DefaultAioHttpClient.__init__N)rrrvrw)rrrr~rzrzrzr}rrrcr)rrIrrvrwc s:|dt|dt|ddtjdi|dS)NrrrTrz)rrHrNrr~)r|rIrrzr}r~s   rrrrzrzrr}rrc@r)AsyncHttpxClientWrapperrvrwcCs8|jrdSz t|WdStyYdSwry)rasyncioget_running_loop create_taskacloserrrzrzr}rs zAsyncHttpxClientWrapper.__del__Nrrrzrzrzr}rrrcs>eZdZUded<dZded<dZded<dZded <eeddddd dfdd Z dd!d"Z dd#d$Z dd'd(Z dd/d0Z dd3d4Zdd7d8Zed9d:dd@dAZeddFdAZeddGddJdAZd9ddKddLdAZddMdNZddRdSZd9dTdUddXdYZdd\d]ZdTd^ddadbZddhdiZeid9djddmdnZeidoddpdnZeiddqddrdnZid9ddsddtdnZedddid9dudd|d}Zedddid~ddd}Zedddiddddd}Zdddid9ddddd}Zdddid~dddZdddid~dddZddiddddZdidddddZZS)rzhttpx.AsyncClientrNztype[AsyncStream[Any]] | NonerAsyncCallNext | Nonerrrrrrrrrrrrrrrhttpx.AsyncClient | Nonerrrrrrrvrwc st|s|r|jtkr|j}nt}|dur$t|tjs$tdt|t | p(d} | r0t | t j ||t t||||| |d||_|pPt|t t|d|_dS)NzTInvalid `http_client` argument; Expected an instance of `httpx.AsyncClient` but got rz)rrrrrrrrr)r9rrrHrr AsyncClientrr;rr`rr~rr)rrrr) r|rrrrrrrrrrrzr}r~s4     zAsyncAPIClient.__init__cCrryrrrzrzr}rrzAsyncAPIClient.is_closedcs|jIdHdS)rN)rrrrzrzr}rszAsyncAPIClient.closer|rhcs|Sryrzrrzrzr} __aenter__szAsyncAPIClient.__aenter__rrrr r r cs|IdHdSryr r rzrzr} __aexit__szAsyncAPIClient.__aexit__rr@cs|Srrzrrzrzr}r szAsyncAPIClient._prepare_optionsrr&csdSrrzrgrzrzr}r zAsyncAPIClient._prepare_requestFrrXrr`rr+cdSryrzrrzrzr}rszAsyncAPIClient.requestrratype[_AsyncStreamT]rlcrryrzrrzrzr}r&)ratype[_AsyncStreamT] | NoneResponseT | _AsyncStreamTcrryrzrrzrzr}r0rrc s|jdurttIdH|_|||}t|}|jdur*|jdkr*||_|j }| |j }t |dD]}||} z[|durh|j t|||dIdH\} } | jrg|j|| | |||dIdHWSn1tt|||||d} || IdH} t| tr| jjrttttf|| | IdHWS| j} Wn:ty}z.||\}}| dks|s|dur|js|IdH|j||||dIdHWYd}~q9d}~ww| dkr|| r| js| IdH|j|||| dIdHq9| js| IdH| | dt!dr )"rr8 get_platformr[r=rr4r rrrrr#r$r%r&rCrrErbrr r+rlr'rrrrr(rareadrrr)rzrzr}r:s           cr0)r1Nr2rCrvAsyncAPIResponse[Any]c sRt|}j||j|jdIdH\}}tdj|j|||j|j|jdIdHS)Nr!rr"r4r6rrzr}r7s   z.base_handlerrr\r8r[cr9)Nr2rCrvrcs|IdHSryrzr:r;rzr}r=szDAsyncAPIClient._build_middleware_chain..wrap..handler2rCrvr)rrZ handle_asyncrr^r@rzr;r}rAs z4AsyncAPIClient._build_middleware_chain..wrapr)rr\r8r[rvr[rBrDrzrr}rs   z&AsyncAPIClient._build_middleware_chainr-rrCcsdt|ts|Std|}t|}|dks|dkr|S|dkr$||St|jr+|S|IdHS)aConvert the `AsyncAPIResponse` returned by the middleware chain into the value the original caller expects. The middleware chain operates on `AsyncAPIResponse` objects; the original caller may have asked for a parsed model (the default), a `LegacyAPIResponse` (`.with_raw_response`) or the `AsyncAPIResponse` wrapper itself (`.with_streaming_response` / a `cast_to` that is itself a response class). rr_r`rNrFrJrzrzr}r's    z*AsyncAPIClient._finalize_middleware_resultrr!r rLc sH||IdH}|j||d}||IdHi}|jdur$|j|d<|jdur.|j|d<td|j|jz|j j |fd|pE|j |di|IdH}Wn8t j yh}z tjdd d t|d|d}~wty}zt|trutjd d d t|d|d}~wwtd |j|j|j|j|jtd |jd||fS)rMNr rNrrOr`rPrQTrRrTrUrVrWrXr\rzrzr}r$sN       zAsyncAPIClient._attempt_requestrr]csf||}|dkrtdntd|||||r|jnd}td|j|t|IdHdSr^)rdr8rrrrqanyior_r`rzrzr}r(s  zAsyncAPIClient._sleep_for_retryr rrac s|jjtdkrttt|||||||dSt|p|}t |rWt |t rW|r3t |jjtrWt |t sBtdt d|td|}td|||t|||||dS|tjkratt|St ||td|||||d} t |jjtr}tt| S| IdHS)Nrrbrcrdrer+rY)rrr2rLrr+rcrrjrkrlrErrFrrGrrfrIrgrzrzr}r&)sh      z AsyncAPIClient._process_responserrrrAsyncPaginator[_T, AsyncPageT]cCst||||dS)N)rrrr)r)r|rrrrzrzr}rmsz AsyncAPIClient._request_api_listrnror1crryrzrprzrzr}r2urzAsyncAPIClient.getrqcrryrzrsrzrzr}r2rrtcrryrzrsrzrzr}r2rrucs0tjdd|d|}|j||||dIdHSrv)r@rwrrxrzrzr}r2s )rr'r3rr`rrzr'AsyncBinaryTypes | Noner3r|crryrz)r|rorXrr'r3rr`rzrzr}r}s zAsyncAPIClient.postrc rryrz r|rorXrr'r3rr`rarzrzr}r} )rr'r3rrac rryrzrrzrzr}r}r)rr'r3rr`rac s|dur |dur td|dur|durtdt|tr&tjdtddtjd d|||t|IdHd|} |j || ||dIdHSr rrrErrrr@rwr$r) r|rorXrr'r3rr`raryrzrzr}r}s"  c|dur |dur td|dur|durtdt|tr&tjdtddtjdd|||t|IdHd|}| ||IdHSrrrrzrzr}rs*   zAsyncAPIClient.patchcrrrrrzrzr}r s"  zAsyncAPIClient.putrcs`|dur |dur tdt|trtjdtddtjdd|||d|}|||IdHSrrrrzrzr}r s  zAsyncAPIClient.deleter2rr4cCrrrrrzrzr}r4 rzAsyncAPIClient.get_api_list)rrrrrrrrrrrrrrrrrrrvrwrrrrrrr) rXrrr@r`rrarrvrl) rXrrr@r`rrarrvr)rvrrrrr)rrrrrr@rvrr) rorrXrrr1r`rrarrvrl) rorrXrrr1r`rrarrvr)rorrXrrrzr'rr3r|rr1r`rrvr+)rorrXrrrzr'rr3r|rr1r`rrarrvrl)rorrXrrrzr'rr3r|rr1r`rrarrvr)rorrXrrrzr'rr3r|rr1rvr+) rorrXrrrzr'rrr1rvr+)rorrrrrrrzrr1r4rrvr)rrrrrrrrJr5r~rrrrrrrrrr'r$r(r&rr2r}rrrrrrzrzrr}rs     8         _ ,  : D     !$r)rA extra_headers extra_query extra_bodyrrrrA Query | NonerHeaders | Nonerrrzrrr'float | httpx.Timeout | None | NotGivenrPostParser | NotGivenrvr1cCsi}|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.Nrr9rsrrr)rr,r2rr*r9)rArrrrrrrrzrzr}make_request_optionsB s   rc@r)r@rvrcCr{)NTrzrrzrzr}__bool__h rzForceMultipartDict.__bool__Nr)rrrrrzrzrzr}r@g rr@c@$eZdZd ddZed ddZd S) OtherPlatformnamerrvrwcC ||_dSryrr|rrzrzr}r~m r>zOtherPlatform.__init__cC d|jS)NzOther:rrrzrzr}__str__p  zOtherPlatform.__str__Nrrrvrwrrrrr~rrrzrzrzr}rl  r)MacOSLinuxWindowsFreeBSDOpenBSDiOSAndroidUnknownPlatformcCszt}t}Wn tyYdSwd|vs!d|vr#dS|dkr)dS|dkr/dSd |vr5d S|d krKt}|d krCd S|dkrIdSdS|rQt|SdS)Nriphoneipadrrrwindowsrandroidrlinuxfreebsdropenbsdrr)rsystemr rdistrorr)r platform_name distro_idrzrzr}r s0  r)maxsizerrrPlatform | NonercCs&d|t|ptttttdS)Npython)zX-Stainless-LangzX-Stainless-Package-VersionzX-Stainless-OSzX-Stainless-ArchzX-Stainless-RuntimezX-Stainless-Runtime-Version)rrget_architectureget_python_runtimeget_python_version)rrrzrzr}rz s rzc@r) OtherArchrrrvrwcCrryrrrzrzr}r~ r>zOtherArch.__init__cCr)Nzother:rrrzrzr}r rzOtherArch.__str__Nrrrrzrzrzr}r rr)x32x64armarm64unknowncC ztWStyYdSwNr)rpython_implementationrrzrzrzr}r   rcCrr)rpython_versionrrzrzrzr}r rrArchcCshzt}Wn tyYdSw|dvrdS|dkrdS|dkr%dStjdkr,dS|r2t|SdS) Nr)raarch64rrx86_64rlr)rmachiner rrrr)rrzrzr}r s   rmappingMapping[_T_co, Union[_T, Omit]]Dict[_T_co, _T]cCsdd|DS)z5Drop entries whose value is an `Omit` removal marker.cSs i|] \}}t|ts||qSrz)rr&)rrUrVrzrzr}r s z_strip_omit..)r)rrzrzr}r srobj1obj2cCsti||S)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. )r)r r rzrzr}r: sr:zx-stainless-helperrWadditioncCsXdddd|dDD}dd|dDD] }|r&||vr&||qd|S)aAppend `addition` to a comma-separated header value, skipping tokens that are already present so the same helper isn't recorded twice. Values are joined with `", "`, the same format `lib._stainless_helpers` uses when it builds the `x-stainless-helper` header. cSsg|]}|r|qSrzrz)rtokenrzrzr}r rz(_append_header_value..cs|]}|VqdSryrrr_rzrzr}  z'_append_header_value..,csrryrrrzrzr}r rz, )rBrSjoin)rWr tokensrrzrzr}_append_header_value s    rmappingsMapping[str, Union[str, Omit]]cGszi}|D]3}|D],\}}|}|tvr|||<q ||}t|tr2t|tr2t||||<q |||<q qtd|S)aMerge header mappings, with later mappings taking precedence on a key clash, exactly like `_merge_mappings`. The exception is the headers in `_APPEND_HEADERS`: those keys are matched case-insensitively (and stored under their lowercase form) and their string values accumulate into a single comma-separated, deduplicated value instead of the later one overriding the earlier one. `Omit` values are preserved (they mark a header for removal and are only dropped at request-build time, e.g. with `_strip_omit`); the `Dict[str, str]` return type is the same fudge the rest of the header plumbing already uses for `Omit`-bearing header mappings. r)rr _APPEND_HEADERSr2rrrr)rmergedrrUrVr rWrzrzr}r s   rrrC'Literal['raw', 'stream', 'true'] | NonecCs8|jj}t|r |tnd}t|tr|dvr|SdS)zLThe raw-response mode the original caller entered the middleware chain with.N)r_r`r)rrr9r2rLrr)rrmoderzrzr}rG8 s rGr@cCsBt|j}t|jrt|jni}|tdvrd|t<||_|S)atBuild the options the base middleware handler hands to `_attempt_request()`. Returns a copy so that mutations made by the request pipeline never leak back into the `APIRequest` between separate `call_next(...)` invocations, with the raw-response header set so that the pipeline produces an `APIResponse` / `AsyncAPIResponse` for the middleware chain. )r_r`r_)r=rr9rrr2rL)rrrrzrzr}r5B s r5rXrrcCs t|p|}t|ot|tS)zFWhether the given `cast_to` asks for the `APIResponse` wrapper itself.)rrjrkrlrE)rXrhrzrzr}rHX s rH)rArrrrrrrzrrrrrrrvr1)rvr)rrrrrvrr)rvr)rr rvr )r r r r rvr )rWrr rrvr)rrrvr)rrCrvr)rrCrvr@)rXrrvr) __future__rrrurrrrrrjr6rr email.utilstypesrrtypingrrrrr r r r r rrrrrrrrrtyping_extensionsrrrrrrrrrrrrr _qsr"_filesr#r$_typesr%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5_utilsr6r7r8r9r:r;_compatr<r=r>_modelsr?r@rArB_requestrC _responserDrErFrG _constantsrHrIrJrKrLrMrN _streamingrOrPrQrRrSrTrUrVrWrXrrYrZr[r\r]r^r_r` _utils._jsonra _utils._httpxrb_legacy_responserc getLoggerrrdrrergrhrirkrl httpx._configrmr ImportErrorrorrrrrrrrrrDefaultHttpxClientrrr httpx_aiohttprHttpxAiohttpClientDefaultAsyncHttpxClientDefaultAioHttpClientrrrrr@rrrrzrrrrrrr: frozensetrrrrGr5rHrzrzrzr}s  P   L  $ (       3=1')1  1   %  *           #