8j,RddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZmZerddlmZdd lmZdd lmZej2ej4ej6ej8fZ ed Gd d eZed GddeZddZ y)) annotations) TYPE_CHECKINGN)override)DEFAULT_MAX_RETRIES!DEFAULT_MIN_DELAY_BETWEEN_RETRIESDEFAULT_TIMEOUT_LONGDEFAULT_TIMEOUT_MAXDEFAULT_TIMEOUT_MEDIUMDEFAULT_TIMEOUT_SHORT) docs_group) HttpClientHttpClientAsync) timedelta)ClientStatistics)HttpCompressorz HTTP clientsc eZdZdZdeeeeee dddd d fdZ e d fd Z e d dZ e d dZe d dZdd ZxZS)Httpx2HttpClientaSynchronous HTTP client for the Apify API built on top of [HTTPX2](https://github.com/pydantic/httpx2). This client wraps `httpx2.Client` and adds automatic retries with exponential backoff for rate-limited (HTTP 429) and server error (HTTP 5xx) responses. HTTPX2 applies a request timeout to each socket operation rather than to the request as a whole, so a response whose body arrives slowly keeps resetting it and can outlast both the requested timeout and `timeout_max`. The default Impit client enforces the same value as a deadline for the whole request, body included. Requires the `httpx2` extra: `pip install "apify-client[httpx2]"`. The `httpx2` package is Pydantic's maintained continuation of HTTPX. N token timeout_shorttimeout_medium timeout_long timeout_max max_retriesmin_delay_between_retries statisticsheadershttp_compressorc t |||||||||| |  tjdd|jgi|_y)aInitialize the HTTPX2-based synchronous HTTP client. Args: token: Apify API token for authentication. timeout_short: Default timeout for short-duration API operations (simple CRUD operations, ...). timeout_medium: Default timeout for medium-duration API operations (batch operations, listing, ...). timeout_long: Default timeout for long-duration API operations (long-polling, streaming, ...). timeout_max: Maximum timeout cap for any single request attempt, including tier and per-call timeouts. max_retries: Maximum number of retry attempts for failed requests. min_delay_between_retries: Minimum delay between retries (increases exponentially with each attempt). statistics: Statistics tracker for API calls. Created automatically if not provided. headers: Additional HTTP headers to include in all requests. http_compressor: Compressor used to compress request bodies. Defaults to `GzipHttpCompressor`. rTresponsefollow_redirects event_hooksN)super__init__httpx2Client_clear_response_cookies_httpx2_client selfrrrrrrrrrr __class__s X/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/http_clients/_httpx2.pyr%zHttpx2HttpClient.__init__7s\8 ')%##&?!+  %mm!#d&B&B%CD cZt||xst|tjSNr$is_timeout_error isinstancer&TimeoutExceptionr+excr,s r-r2z!Httpx2HttpClient.is_timeout_errore%w',X 3@W@W0XXr.c\t|tjxrt|t Sr0r3r& HTTPError_PERMANENT_ERRORSr+r6s r-is_retryable_transport_errorz-Httpx2HttpClient.is_retryable_transport_errori' #v//0[CIZ9[5[[r.c8|jjy)z,Close the underlying HTTPX2 connection pool.N)r)closer+s r-r@zHttpx2HttpClient.closeqs !!#r.c|jj|||||}t|||jj||SN)methodurlrcontenttimeout)stream)r) build_request_restore_explicit_cookie_headersendr+rDrErrFrGrHrequests r- send_requestzHttpx2HttpClient.send_requestvsV%%33 4  (9""'''??r.cL|jjjyzWPrevent HTTPX2's shared cookie jar from leaking server cookies into later API requests.N)r)cookiesclearr+ _responses r-r(z(Httpx2HttpClient._clear_response_cookiess ##))+r.rz str | NonerrrrrrrrrintrrrzClientStatistics | Nonerzdict[str, str] | NonerzHttpCompressor | NonereturnNoner6 ExceptionrWboolrWrXrDstrrEr^rdict[str, str]rFz bytes | NonerGz float | NonerHr[rWhttpx2.ResponserTr`rWrX)__name__ __module__ __qualname____doc__r r rr rrr%rr2r=r@rNr( __classcell__r,s@r-rr(sD  !#8$:"6!4./P.2)-15, , ! , " ,  , , , $-, ,, ', /,  , \YY\\$$@@ @  @  @@@ @@(,r.rc eZdZdZdeeeeee dddd d fdZ e d fd Z e d dZ e d dZe d dZdd ZxZS)Httpx2HttpClientAsyncaAsynchronous HTTP client for the Apify API built on top of [HTTPX2](https://github.com/pydantic/httpx2). This client wraps `httpx2.AsyncClient` and adds automatic retries with exponential backoff for rate-limited (HTTP 429) and server error (HTTP 5xx) responses. HTTPX2 applies a request timeout to each socket operation rather than to the request as a whole, so a response whose body arrives slowly keeps resetting it and can outlast both the requested timeout and `timeout_max`. The default Impit client enforces the same value as a deadline for the whole request, body included. Requires the `httpx2` extra: `pip install "apify-client[httpx2]"`. The `httpx2` package is Pydantic's maintained continuation of HTTPX. Nrc t |||||||||| |  tjdd|jgi|_y)aInitialize the HTTPX2-based asynchronous HTTP client. Args: token: Apify API token for authentication. timeout_short: Default timeout for short-duration API operations (simple CRUD operations, ...). timeout_medium: Default timeout for medium-duration API operations (batch operations, listing, ...). timeout_long: Default timeout for long-duration API operations (long-polling, streaming, ...). timeout_max: Maximum timeout cap for any single request attempt, including tier and per-call timeouts. max_retries: Maximum number of retry attempts for failed requests. min_delay_between_retries: Minimum delay between retries (increases exponentially with each attempt). statistics: Statistics tracker for API calls. Created automatically if not provided. headers: Additional HTTP headers to include in all requests. http_compressor: Compressor used to compress request bodies. Defaults to `GzipHttpCompressor`. rTr r!N)r$r%r& AsyncClientr(_httpx2_async_clientr*s r-r%zHttpx2HttpClientAsync.__init__s^8 ')%##&?!+  %+$6$6!#d&B&B%CD% !r.cZt||xst|tjSr0r1r5s r-r2z&Httpx2HttpClientAsync.is_timeout_errorr7r.c\t|tjxrt|t Sr0r9r<s r-r=z2Httpx2HttpClientAsync.is_retryable_transport_errorr>r.cTK|jjd{y7w)z9Close the underlying asynchronous HTTPX2 connection pool.N)rlacloserAs r-rpzHttpx2HttpClientAsync.acloses ''..000s (&(cK|jj|||||}t|||jj||d{S7wrC)rlrIrJrKrLs r-rNz"Httpx2HttpClientAsync.send_requests`++99 :  (9..33GF3KKKKsA AAAcTK|jjjywrP)rlrQrRrSs r-r(z-Httpx2HttpClientAsync._clear_response_cookiess !!))//1s&(rUrYr\r]ra)rbrcrdrer r rr rrr%rr2r=rprNr(rfrgs@r-ririsD  !#8$:"6!4./P.2)-15, , ! , " ,  , , , $-, ,, ', /,  , \YY\\11LL L  L  LLL LL(2r.rictd|jDd}||jjddy||jd<y)aKeep only cookies explicitly supplied for this request, never cookies from HTTPX2's shared jar. HTTPX2 drops the `Cookie` header when it builds a redirect request and rebuilds it from the jar, so an explicit cookie only reaches the first hop of a redirected request. c3NK|]\}}|jdk(s|yw)cookieN)lower).0keyvalues r- z2_restore_explicit_cookie_header..s"_jc5syy{V^G^E_s%%Nru)nextitemsrpop)rMrexplicit_cookies r-rJrJsE _GMMO_aefOHd+$3!r.)rMzhttpx2.Requestrr_rWrX)! __future__rtypingrr&typing_extensionsrapify_client._constsrrrr r r apify_client._docsr apify_client.http_clients._baser rdatetimerapify_client._statisticsr#apify_client.http_compressors._baserLocalProtocolErrorUnsupportedProtocolTooManyRedirectsHTTPStatusErrorr;rrirJr.r-rs" &*G"9B      q Nd,zd,d,N Nd2Od2d2N 4r.