o @>c@sNeZdZUded<ded<ded<ded<ddd dZdddZdddZd S)rintstatusDict[str, str]headersstrurlbytescontentNencoding Optional[str]returncCs|p|}|jj|ddS)Nreplace)errors) _get_encodingr$decode)selfr%encr.U/root/parts/websockify/install/lib/python3.10/site-packages/redis/http/http_client.pytext s zHttpResponse.textrcCst|j|dS)N)r%)jsonloadsr0r*r,r.r.r/r1$szHttpResponse.jsoncCsT|jdd}|dD]}|}|dr'|dddp$dSq dS)N content-type;zcharset==utf-8)r getsplitstriplower startswith)r,ctypepartpr.r.r/r*'szHttpResponse._get_encodingN)r%r&r'r!)r'r)r'r!)__name__ __module__ __qualname____annotations__r0r1r*r.r.r.r/rs   rcs eZdZd d fdd ZZS) rNrrr"r!messager&cs4||_||_|pd|d||_t|jdS)NzHTTP z for )rr"rGsuper__init__)r,rr"rG __class__r.r/rI3szHttpError.__init__rB)rrr"r!rGr&)rCrDrErI __classcell__r.r.rJr/r2src @s4eZdZdZddeeedddddd dddddddef dXd!d"Z    dYdZd)d*Z    dYdZd+d,Z      d[d\d1d2Z      d[d\d3d4Z      d[d\d5d6Z    d]d^d:d;Z  d_d`d@dAZdadDdEZ     dbdcdFdGZ d_dddHdIZ dedfdJdKZdgdMdNZdhdQdRZdidVdWZdS)jrz7 A lightweight HTTP client for REST API calls. r5Nr8 )basecap)backoffretriesTbase_urlr!r Optional[Mapping[str, str]]timeoutfloatretryr verify_tlsboolca_filer&ca_pathca_dataOptional[Union[str, bytes]]client_cert_fileclient_key_fileclient_key_password auth_basicOptional[Tuple[str, str]] user_agentr'NonecCs|r |ds |dn||_dd|piD|_||_||_|jtt t j f||_ ||_ ||_||_| |_| |_| |_| |_| |_dS)a  Initialize a new HTTP client instance. Args: base_url: Base URL for all requests. Will be prefixed to all paths. headers: Default headers to include in all requests. timeout: Default timeout in seconds for requests. retry: Retry configuration for failed requests. verify_tls: Whether to verify TLS certificates. ca_file: Path to CA certificate file for TLS verification. ca_path: Path to a directory containing CA certificates. ca_data: CA certificate data as string or bytes. client_cert_file: Path to client certificate for mutual TLS. client_key_file: Path to a client private key for mutual TLS. client_key_password: Password for an encrypted client private key. auth_basic: Tuple of (username, password) for HTTP basic auth. user_agent: User-Agent header value for requests. The client supports both regular HTTPS with server verification and mutual TLS authentication. For server verification, provide CA certificate information via ca_file, ca_path or ca_data. For mutual TLS, additionally provide a client certificate and key via client_cert_file and client_key_file. /cSi|] \}}||qSr.r=.0kvr.r.r/ oz'HttpClient.__init__..N)endswithrstriprSitems_default_headersrUrWupdate_supported_errorsr r sslSSLErrorrXrZr[r\r^r_r`rarc)r,rSr rUrWrXrZr[r\r^r_r`rarcr.r.r/rI?s&- zHttpClient.__init__pathparamsGOptional[Mapping[str, Union[None, str, int, float, bool, list, tuple]]]Optional[float] expect_jsonUnion[HttpResponse, Any]c C|jd||||d|dS)NGETrvr rUbodyry _json_callr,rurvr rUryr.r.r/r: zHttpClient.getc Cr{)NDELETEr}rrr.r.r/deleterzHttpClient.delete json_body Optional[Any]dataOptional[Union[bytes, str]]c C"|jd|||||j||d|dS)NPOSTrrr}r _prepare_bodyr,rurrrvr rUryr.r.r/post  zHttpClient.postc Cr)NPUTrr}rrr.r.r/putrzHttpClient.putc Cr)NPATCHrr}rrr.r.r/patchrzHttpClient.patchmethodr~rc sd||}||}t|tr|dn|} t||| |dd|drSj rHt j j j jdjrGjjjjdn t d_t j_zjfddd dfd dWSty} zsz$HttpClient.request..cSstSrBr)_r.r.r/rscs |SrB)_is_retryable_http_error)errorr3r.r/rs cSrfr.rgrhr.r.r/rl rmz&HttpClient.request..coderrr r"r$) _build_url_prepare_headers isinstancer!encoderupperr=r>rXrscreate_default_contextrZr[r\r^load_cert_chainr_r`check_hostname CERT_NONE verify_moderWcall_with_retryr read Exceptionr rp_maybe_decompressgetattrr)r,rrurvr r~rUr" all_headersreerr_body headers_maprresponser.rr/requests^     zHttpClient.requestrrrOptional[ssl.SSLContext]cCsvt||p|j|d'}|}dd|jD}|||}t|j|||dWdS1s4wYdS)N)rUrcSrfr.rgrhr.r.r/rl3rmz,HttpClient._make_request..r) rrUrr rprrrgeturl)r,rrrUresprawrr.r.r/r+s $zHttpClient._make_requestrrcCst|tr ||jSdS)NF)rr _should_retry_statusr)r,rr.r.r/r<s  z#HttpClient._is_retryable_http_errorc CsR|j||||||d}d|jkrdks!nt|j|j||r'|S|S)N)rrurvr r~rUi)rrrr"r0r1) r,rrurvr rUr~ryrr.r.r/rBs zHttpClient._json_callcCs4|dur |dur td|durtj|dddS|S)Nz+Provide either json_body or data, not both.F),:) ensure_ascii separators) ValueErrorr1dumps)r,rrr.r.r/r\s zHttpClient._prepare_bodycCsZt|jpd|}|r+tdd|Ddd}d|vrdnd}|r)|||n|}|S)Nr5cSsi|] \}}|dur||qSrBr.rhr.r.r/rlpsz)HttpClient._build_url..T)doseq?&)r rSr rp)r,rurvr"query separatorr.r.r/reszHttpClient._build_urlrc Csi}||j|dd|d|j|dd|dur*t|tr*|dd|jrMd|vrM|j\}}t|d | d  d }d ||d<|r^| D] \}}||| <qS|S) Nacceptzapplication/jsonz user-agentzaccept-encodingz gzip, deflater4zapplication/json; charset=utf-8 authorizationrr9asciizBasic ) updaterq setdefaultrcrr!rabase64 b64encoderr+rpr=) r,r r~prepareduserpwdtokenrjrkr.r.r/rvs      zHttpClient._prepare_headersrrcCs|tvSrB)RETRY_STATUS_CODES)r,rr.r.r/rszHttpClient._should_retry_statusr$r#Mapping[str, str]cCs|s|S|dp d}z,d|vrt|WSd|vr7z t|tj WWStjy6t|YWSwW|StyD|YSw)Nzcontent-encodingr5gzipdeflate)r:r=r decompresszlib MAX_WBITSrr)r,r$r r%r.r.r/rs"  zHttpClient._maybe_decompress)rSr!r rTrUrVrWrrXrYrZr&r[r&r\r]r^r&r_r&r`r&rarbrcr!r'rd)NNNT) rur!rvrwr rTrUrxryrYr'rz)NNNNNT)rur!rrrrrvrwr rTrUrxryrYr'rz)NNNN)rr!rur!rvrwr rTr~rrUrxr'r)NN)rrrrrUrx)rrr'rY)NNNNT)rr!rur!rvrwr rTrUrxr~rryrYr'rz)rrrrr'rrB)rur!rvrwr'r!)r rTr~rr'r)rrr'rY)r$r#r rr'r#)rCrDrE__doc__rrrDEFAULT_USER_AGENTrIr:rrrrrrrrrrrrrr.r.r.r/r:s  G      B      r)' __future__rrrr1rsr dataclassesrtypingrrrrrr urllib.errorr r urllib.parser r urllib.requestrr__all__ redis.backoffr redis.retryr redis.utilsrrrrrrrrr.r.r.r/s,