o .j@sUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZddlmZddlmZmZddlmZmZmZmZmZmZdd lmZm Z m!Z!m"Z"dd lm#Z$e j%d krddl&Z&ndZ&dd l'm(Z(d dl)m)Z)d dl*m+Z+d dl,m-Z-m.Z.m/Z/d dl0m1Z1m2Z2d dl3m4Z4d dl5m6Z6m7Z7m8Z8m9Z9d dl:m;Z;mm?Z?m@Z@d dlAmBZBd dlCmDZDmEZEd dlFmGZGzd dlHmIZIWn eJydZIYnwejKrd dlLmMZMd dlNmOZOmPZPmQZQmRZRd dlmSZSmTZTeeZee Z dZUdd d!ZVd"eWd#<d$Xe Yd%eDd&d'd(ZZd)eWd*<e j%d+krHd d.d/Z[d d1d2Z!d d6d7Z\ed8d9ddd?d@Z]ddCdDZ^ej_ddHdIZ`ddMdNZaebdOZcebdPZdddSdTZeddVdWZfddYdZZgddd\d]ZhddadbZiddedfZjddidjZkddmdnZlddtduZmddxdyZnebdzeoepZqdddZresdZtdddZudddZvdd ddZwedd9d!ddZxd"ddZyd#ddZzd$ddZ{d$ddZ|d%ddZ}d&ddZ~ej_d'ddZd(ddZd)d*ddZd+ddZ &d,d-ddZd.d/ddZd0ddZd1ddZd2dd„Zd3ddńZd4ddDŽZd5dd̄Zd5dd΄Zd6ddӄZd7ddׄZd8dd܄Zd9ddZd:ddZd;dddZd>ddZd?ddZd?ddZd@ddZdAddZdBddZdCddZejdDddZejdEd dZdFd dZdS(Gz requests.utils ~~~~~~~~~~~~~~ This module provides utility functions that are used within Requests that are also useful for external consumption. ) annotationsN) OrderedDict) lru_cache) CookieJar)NetrcParseErrornetrc)quoteunquoteurljoinurlparse urlunparse uses_relative) getproxiesgetproxies_environment proxy_bypassproxy_bypass_environment)parse_http_list emscripten) from_bytes __version__)iscoroutinefunction) InvalidURL MissingSchemaUnrewindableBodyError)RevocationConfigurationRevocationStrategy)ConnectionInfo) BaseResolver ManyResolverProtocolResolverResolverDescription)AsyncBaseResolverAsyncManyResolverAsyncResolverDescription)ExtensionFromHTTPload_extension)AsyncExtensionFromHTTP) make_headers parse_url)CaseInsensitiveDict)BACKENDssl)RequestsCookieJar) AsyncResponsePreparedRequestRequestResponse)AsyncResolverType ResolverType)z.netrc_netrcPihttphttpszdict[str, int] DEFAULT_PORTSz, z,\s*T)accept_encodingzaccept-encodingstrDEFAULT_ACCEPT_ENCODINGwin32returnboolc Cszddl}Wn tyYdSwz||jd}t||dd}||dd}Wn ttfy8YdSw|r=|s?dS|d}t d|}|D]*}|dkrXd|vrXd S| dd }| d d }| d d}t ||t j rud SqKdS)NrFz;Software\Microsoft\Windows\CurrentVersion\Internet Settings ProxyEnable ProxyOverride;z.Tz\.*z.*?)winreg ImportErrorOpenKeyHKEY_CURRENT_USERint QueryValueExOSError ValueErrorsplitfilterreplacerematchI)hostrGinternetSettings proxyEnable proxyOverridetestrZC/home/thesage/.local/lib/python3.10/site-packages/niquests/utils.pyproxy_bypass_registryYs<       r\rUcCstrt|St|S)zReturn True, if the host should be bypassed. Checks proxy settings gathered from the environment, if specified, or the registry. )rrr\)rUrZrZr[rsro typing.AnyrKc Csd}d}t|drt|}n't|dr|j}nt|dr5z|}Wn tjtfy.Ynwt|j}t|dr}t |j s}z| }Wnt yT|durR|}Yn)wt|dr}|dur}z| dd| }| |pndWn t y|d}Ynw|durd}t d||S)Nr__len__lenfilenotellseek)hasattrr`raioUnsupportedOperationAttributeErrorosfstatst_sizerrbrMrcmax)r] total_lengthcurrent_positionrarZrZr[ super_lens@          ro@)maxsizeFurl str | None raise_errorstuple[str, str] | Nonec CsJ|durdStjd}|dur|fntddtD}zsz!get_netrc_auth..css0|]}tjtj|rtj|VqdSN)ripathexists expanduserrwrZrZr[rzs.zSyntax error in netrc filez+Problem accessing or reading the netrc filez6Unexpected error while retrieving netrc authenticators)rienvirongettuple NETRC_FILESnextr*hostnamerauthenticatorsrrNrMrh RuntimeError) rrrt netrc_filenetrc_locations netrc_pathrirUr5login_passworderZrZr[get_netrc_authsT           robj typing.IOcCsBt|dd}|rt|tr|ddkr|ddkrtj|SdS)z0Tries to guess the filename of the given object.nameNr<>)getattr isinstancer<rir|basename)rrrZrZr[guess_filenames & rfilenamestr | bytes | os.PathLike-typing.Generator[typing.BinaryIO, None, None]ccsztjtj|d\}}z"t|d }|VWdn1s"wYt||WdSty<t|w)z-Write a file to the disk in an atomic fashion)dirwbN) tempfilemkstemprir|dirnamefdopenrQ BaseExceptionremove)rtmp_descriptortmp_name tmp_handlerrZrZr[ atomic_opens  rvaluetyping.Any | NoneOrderedDict | NonecCs,|durdSt|tttfstdt|S)aTake an object and test to see if it can be represented as a dictionary. Unless it can not be represented as such, return an OrderedDict, e.g., :: >>> from_key_val_list([('key', 'val')]) OrderedDict([('key', 'val')]) >>> from_key_val_list('string') Traceback (most recent call last): ... ValueError: cannot encode objects that are not 2-tuples >>> from_key_val_list({'key': 'val'}) OrderedDict([('key', 'val')]) N+cannot encode objects that are not 2-tuples)rrlistdictrNrrrZrZr[from_key_val_lists r_KT_VTLdict[_KT, _VT] | typing.Mapping[_KT, _VT] | typing.Iterable[tuple[_KT, _VT]]list[tuple[_KT, _VT]]cCsD|durtdt|ttttfrtdt|dr|}t|S)aTake an object and test to see if it can be represented as a dictionary. If it can be, return a list of tuples, e.g., :: >>> to_key_val_list([('key', 'val')]) [('key', 'val')] >>> to_key_val_list({'key': 'val'}) [('key', 'val')] >>> to_key_val_list('string') Traceback (most recent call last): ... ValueError: cannot encode objects that are not 2-tuples Nz%cannot accept None in to_key_val_listritems) rNrr<bytesr@rKrerrrrZrZr[to_key_val_lists r list[str]cCsXg}t|D]#}|dd|ddkrdkr$nnt|dd}||q|S)aParse lists as described by RFC 2068 Section 2. In particular, parse comma-separated lists where the elements of the list may include quoted-strings. A quoted-string could contain a comma. A non-quoted string could have quotes in the middle. Quotes are removed automatically after parsing. It basically works like :func:`parse_set_header` just that items may appear multiple times and case sensitivity is preserved. The return value is a standard :class:`list`: >>> parse_list_header('token, "quoted value"') ['token', 'quoted value'] To create a header from the :class:`list` again, use the :func:`dump_header` function. :param value: a string with a list header. :return: :class:`list` Nrr")_parse_list_headerunquote_header_valueappend)rresultitemrZrZr[parse_list_header<s  ( rtyping.Mapping[str, str | None]cCsxi}t|D]3}d|vrd||<q|dd\}}|dd|ddkr+dkr5nnt|dd}|||<q|S)aMParse lists of key, value pairs as described by RFC 2068 Section 2 and convert them into a python dict: >>> d = parse_dict_header('foo="is a fish", bar="as well"') >>> type(d) is dict True >>> sorted(d.items()) [('bar', 'as well'), ('foo', 'is a fish')] If there is no value for a key it will be `None`: >>> parse_dict_header('key_without_value') {'key_without_value': None} To create a header from the :class:`dict` again, use the :func:`dump_header` function. :param value: a string with a dict header. :return: :class:`dict` =Nrrr)rrOr)rrrrrZrZr[parse_dict_header[s ( r is_filenamecCs^|r-|d|dkrdkr-n|S|dd}|r#|dddkr-|ddd dS|S) zUnquotes a header value. (Reversal of :func:`quote_header_value`). This does not use the real unquoting but what browsers are actually using for quoting. :param value: the header value to unquote. rrrrNrdz\\\z\")rQ)rrrZrZr[r}s " rcjrdict[str, str | None]cCsdd|D}|S)zoReturns a key/value dictionary from a CookieJar. :param cj: CookieJar object to extract cookies from. cSsi|]}|j|jqSrZ)rr)rxcookierZrZr[ z'dict_from_cookiejar..rZ)r cookie_dictrZrZr[dict_from_cookiejarsrr.RequestsCookieJar | CookieJarcCsddlm}|||S)zReturns a CookieJar from a key/value dictionary. :param cj: CookieJar to insert cookies into. :param cookie_dict: Dict of key/values to insert into CookieJar. r)cookiejar_from_dict)cookiesr)rrrrZrZr[add_dict_to_cookiejars  rheader1tuple[str, dict[str, str | typing.Literal[True]]]c Cs|d}|d|dd}}i}d}|D]0}|}|rH|d}}|d} | dkrB|d| |}|| dd|}|||<q||fS) zReturns content type and parameters from given header :param header: string :return: tuple containing content type and dictionary of parameters rCrrNz"' Trr)rOstripfindlower) rtokens content_typeparams params_dictitems_to_stripparamkeyrindex_of_equalsrZrZr[_parse_content_type_headers    rheaderstyping.Mapping[str, str]cCsV|d}|s dSt|\}}d|vr#t|dtr!|ddSdSd|vr)dSdS)zmReturns encodings from given HTTP Header Dict. :param headers: dictionary to extract encoding from. z content-typeNcharsetz'"zapplication/jsonutf-8)rrrr<r)rrrrZrZr[get_encoding_from_headerss   riterator#typing.Generator[bytes, None, None]rr2)typing.Generator[bytes | str, None, None]ccsj|jdur |EdHdSt|jdd}|D] }||}|r$|Vq|jddd}|r3|VdSdSzStream decodes an iterator.NrQ)errorsT)finalencodingcodecsgetincrementaldecoderdecode)rrdecoderchunkrvrZrZr[stream_decode_response_unicodes    r"typing.AsyncGenerator[bytes, None](typing.AsyncGenerator[bytes | str, None]cCs|jdur|2z 3dHW}|Vq6dSt|jdd}|2z3dHW}||}|r0|Vq 6|jddd}|r@|VdSdSrr)rrrrrrZrZr[astream_decode_response_unicodes"   r_SVstring slice_length int | None!typing.Generator[_SV, None, None]ccsXd}|dus |dkrt|}|t|kr*||||V||7}|t|ksdSdS)z Iterate over slices of a string.rN)r`)rrposrZrZr[ iter_slices s rzBABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-._~uric Cs|d}tdt|D]Q}||dd}t|dkrT|rTz tt|d}Wnty8td|dw|tvrJ|||dd||<q d||||<q d||||<q d |S) zUn-escape any percent-escape sequences in a URI that are unreserved characters. This leaves all reserved, illegal and non-ASCII bytes encoded. %rrrdz"Invalid percent-escape sequence: ''N) rOranger`isalnumchrrKrNrUNRESERVED_SETjoin)rpartsihcrZrZr[unquote_unreserveds   r cCs:d}d}z tt||dWStyt||dYSw)zRe-quote the given URI. This function passes the given URI through an unquote/quote cycle to ensure that it is fully and consistently quoted. z!#$%&'()*+,/:;=?@[]~z!#$&'()*+,/:;=?@[]~)safe)rr r)rsafe_with_percentsafe_without_percentrZrZr[ requote_uri-s r mask totalbitscCsd|>d||>}|S)a Converts a mask from /xx format to an integer to be used as a mask for IP's in int format Example: if mask is 24 function returns 0xFFFFFF00 if mask is 24 and totalbits=128 function returns 0xFFFFFF00000000000000000000000000 rrZ)rrbitsrZrZr[_get_mask_bitsAsraddrcCs t|jS)zCached check for whether an IP address is private. Avoids repeated ``ipaddress.ip_address()`` construction which is expensive, especially for IPv6.) ipaddress ip_address is_private)rrZrZr[ is_private_ipMs ripnetc Cs|d\}}t|r,t|r,tdt|d}tt|}tdt|d}n8t|rbt|rbtdt tj |\}}|d>|A}tt|d}tdt tj |\} } | d>| A}ndS||@||@kS)a!This function allows you to check if an IP belongs to a network subnet Example: returns True if ip = 192.168.1.1 and net = 192.168.1.0/24 returns False if ip = 192.168.1.1 and net = 192.168.100.0/24 returns True if ip = 1:2:3:4::1 and net = 1:2:3:4::/64 /z>Lrz>QQrpF) rOis_ipv4_addressstructunpacksocket inet_atonrrKis_ipv6_address inet_ptonAF_INET6) rrnetaddrripaddrnetmasknetwork ipaddr_msb ipaddr_lsb network_msb network_lsbrZrZr[address_in_networkTs  r0cCs&ddd|>dA}ttd|S)zpConverts mask from /xx format to xxx.xxx.xxx.xxx Example: if mask is 24 function returns 255.255.255.0 lrrz>I)r# inet_ntoar!pack)rrrZrZr[dotted_netmaskksr3 string_ipcCs&zt|WdStyYdSwNFT)r#r$rMr4rZrZr[r ts   r cCs*z ttj|WdStyYdSwr5r#r&r'rMr6rZrZr[r%|s  r%abcCs4zttj|ttj|kWStyYdSw)zD Compare 2 IPs, uses socket.inet_pton to normalize IPv6 IPs Fr7)r8r9rZrZr[ compare_ipv6s  r:string_networkcCs|ddkrB|d\}}t|dks|durdSt|}t|r0|dks,|dkr.dSdSt|r@|dks<|dkr>dSdSdSdS)zD Very simple check of the cidr format in no_proxy variable. rrFrrT)countrOr`isdigitrKr r%)r;addressrmask_intrZrZr[ is_valid_cidrsrAenv_name"typing.Generator[None, None, None]c csz|du}|rtj|}|tj|<zdVW|r*|dur#tj|=dS|tj|<dSdS|r<|dur7tj|=w|tj|<w)zSet the environment variable 'env_name' to 'value' Save previous value, yield, and then restore the previous value stored in the environment variable 'env_name'. If 'value' is None, do nothingN)rirr)rBr value_changed old_valuerZrZr[ set_environs   rFno_proxyc CsZddd}|}|dur|d}t|}|jdurd S|r|td d |d d dD}t|js6t|jr[|D]!}t|rHt|j|rGd Sq8|j|krPd St |j|rYd Sq8n!|j}|j ri|d|j 7}|D]}|j |sx| |r{d Sqkt d|zt |j} Wnttjfyd} YnwWdn1swY| rd SdS)z: Returns whether we should bypass proxies or not. rr<r?rscSstj|p tj|Sr{)rirrupper)rrZrZr[ get_proxysz(should_bypass_proxies..get_proxyNrGTcss|]}|r|VqdSr{rZ)rxrUrZrZr[rzsz(should_bypass_proxies.. r,:F)rr<r?rs)r rrrQrOr r%rAr0r:portendswithrFr TypeErrorr#gaierror) rrrGrI no_proxy_argparsed no_proxy_listproxy_iphost_with_portrUbypassrZrZr[should_bypass_proxiessN        rWdict[str, str]cCs"t}|siSt||driS|S)z/ Return a dict of environment proxies. rG)rrW)rrrGproxiesrZrZr[get_environ_proxiess  r[rZ&typing.Mapping[str, str | None] | Nonec Cs|pi}|sdSt|}|jdur||j|dS|jd|j|jd|jdg}|jdvrk|j}d}d|vrFt|jddd\}}zt||}Wn tyVYnw| |}| || |d|jd}|D] } | |vr||| }|Sqo|S) zSelect a proxy for the url, if applicable. :param url: The url being for the request :param proxies: A dictionary of schemes or schemes and hosts to proxy URLs Nall://zall://r7+r)maxsplit) r rrschemerrrOr'rHscheme_to_http_schemer) rrrZurlparts proxy_keysmaybe_extension_schemeimplementationextension_class parent_schemeproxy proxy_keyrZrZr[ select_proxy s@    rkrequestPreparedRequest | Requestdict[str, str] | None trust_envc Cs|dur|ni}|j}|dusJdt|}|d}|}|r?t||ds?t||d}|||d}|r?||||S)aThis method takes proxy information from a request and configuration input to resolve a mapping of target proxies. This will consider settings such a NO_PROXY to strip proxy configurations. :param request: Request or PreparedRequest :param proxies: A dictionary of schemes or schemes and hosts to proxy URLs :param trust_env: Boolean declaring whether to trust environment configs Nz,PreparedRequest is not initialized correctlyrGrYr])rr parse_schemercopyrWr[ setdefault) rlrZrorrrarG new_proxiesenviron_proxiesrirZrZr[resolve_proxies<s    runiquestsrcCs|dtS)z> Return a string representing the default user agent. rr)rrZrZr[default_user_agent\srwr+cCs(tdkrtttdddStddiS)Nutlsz*/*z keep-alive)z User-AgentzAccept-EncodingAccept Connectionrz)r,r+rwr=rZrZrZr[default_headerscsr{list[dict[str, str]]c Csg}d}||}|s |Std|D]M}z |dd\}}Wnty-|d}}Ynwd|di}|dD] }z |d\}}Wn tyOYn w|||||<q:||q|S) zReturn a list of parsed link headers proxies. i.e. Link: ; rel=front; type="image/jpeg",; rel=back;type="image/jpeg" z '"z, * '"r)rrRrOrNr) rlinks replace_charsvalrrrlinkrrrZrZr[parse_header_linksws*    r new_schemec Cspt|}|\}}}}}}} |j} | s|| } }|r"| r"d|| g} |dur(|}|dur.d}t|| |d|| fS)zGiven a URL that may or may not have a scheme, prepend the given scheme. Does not replace a present scheme with the one provided as an argument. @Nr)r*netlocrr ) rrrrRraauthrUrMr|queryfragmentrrZrZr[prepend_scheme_if_neededs rtuple[str, str]c Csft|}|jr d|jvrdSt|jdd\}}z t|t|f}W|Sttfy2d}Y|Sw)zdGiven a url with authentication components, extract them into a tuple of username,password. rL)rrr)r*rrrOr rhrO)rrrRusernamerrrZrZr[get_auth_from_urlsrcCsFt|\}}}}}}|s||}}|ddd}t|||||dfS)zF Given a url remove the fragment and the authentication part. rrrr)r rsplitr )rrrarr|rrrrZrZr[ urldefragauths  rprepared_requestr0NonecCsRt|jdd}|dur%t|jtr%z||jWdSty$tdwtd)zfMove file pointer back to its recorded starting position so it can be read again on redirect. rcN;An error occurred when rewinding request body for redirect.+Unable to rewind request body for redirect.rbodyr_body_positionrKrMrr body_seekrZrZr[ rewind_bodys rcsZt|jdd}|dur)t|jtr)z ||jIdHWdSty(tdwtd)z!Async counterpart of rewind_body.rcNrrrrrZrZr[ arewind_bodys r definitionResolverType | NonercC|durtjdd}|durt|}nttjSt|t r#|St|t r/t|g}n-t|tr8|g}n$t|t rX|sFttjSt|dt rUdd|D}n|}nt dg}d}|D]_}t|t r| t||djtjkr{d }d |dvr|djd durd|dd <|djd =qb| |d |dvr|djd durd|dd <|djd =|djtjkrd }qb|s| td |D]}d |vrd|vrd|vrt|d <qtdd|DS)AInstantiate a unique resolver, reusable across the Session scope.NNIQUESTS_DNS_URLrcSg|]}t|qSrZ)r"from_urlrxrrZrZr[ rz#create_resolver..!invalid resolver definition givenFrTverify cert_reqs system://default?hosts=localhost ca_cert_data ca_cert_dirca_certscSg|]}|qSrZnewrxrrZrZr[r.)rirrr"rr!SYSTEMrrrr<rrNrprotocolkwargswassimagenerate_ca_bundler r overrule_dnsresolver resolverscan_resolve_localhostresolver_descriptionrdrZrZr[create_resolverV            rAsyncResolverType | Noner#cCr)rNrrcSrrZ)r%rrrZrZr[rErz)create_async_resolver..rFrTrrrrrrcSrrZrrrZrZr[rnr)rirrr%rr!rrrr#r<rrNrrrrrr$rrZrZr[create_async_resolver1rr disable_ipv4 disable_ipv6socket.AddressFamilycCs|rtjS|r tjStjSr{)r#r'AF_INET AF_UNSPEC)rrrZrZr[resolve_socket_familyqs rresponseAsyncResponse | ResponsecCsH|j}t|jdko|jdtu}|r|jd|_dS|d|_dS)Nrr) __class__r` __bases__object__subclasses__)rresponse_classis_asyncrZrZr[ _swap_contextys rConnectionInfo | NonecCs8|durdSt}t|D] \}}t|||q|Sr{)rvarsrsetattr)r]nattrrrZrZr[ _deepcopy_cis r default max_lengthc Csz|d|dd|d}W|StyX}z:|dur&|WYd}~Sz|d|dd|d}|WWYd}~StyGYnwtd|d|d|d}~ww)zWe tend to extract url scheme often enough, but we were crazy enough to use urlparse for it...! We were wasting precious CPU cycles. Return used scheme url, lowercased.Nr^rrLz Invalid URL z0: No scheme supplied. Perhaps you meant https://rF)indexrNrr)rrrrraroutsider_schemerZrZr[rps rpbasecCsbt|dd}|r |tvrt||Sd|t|d}t||}|dr/||tddS|S)zGRFC 3986 relative join that also works for niquests' synthetic schemes.rrr9Nzhttps://)rpr r r` startswith)rrrratempjoinedrZrZr[ urljoin_safes     r conn_infocCH|dus|jdus|jdurdSddt|jdgD}|s"dSdS)NFcSg|] }|dr|qSzhttp://rrxeprZrZr[r z#is_ocsp_capable..OCSPTcertificate_dercertificate_dictrrr endpointsrZrZr[is_ocsp_capablesrcCr)NFcSrrrrrZrZr[rrz"is_crl_capable..crlDistributionPointsTrrrZrZr[is_crl_capablesrrevocation_configurationRevocationConfiguration | NonecC>t|sdS|dur dS|jtjtjhvrdSt|sdSdSr5)rstrategyr PREFER_CRL CHECK_ALLrrrrZrZr[should_check_crlrcCrr5)rrr PREFER_OCSPrrrrZrZr[should_check_ocsprr extensiontype[ExtensionFromHTTP]cddlmmmmmmddlm ddlm m m m ddlm ddlm ddlm ddlmG fdd d |}|S) z We want to properly map exceptions from below (urllib3-future) into our own exceptions. This function purposely wrap the extension class to achieve that. Warning: synchronous context only! rChunkedEncodingErrorConnectionErrorContentDecodingError InvalidHeader ProxyError ReadTimeoutSSLErrorClosedPoolError DecodeError ProtocolErrorReadTimeoutError HTTPErrorrrczeZdZd  f dd Zd  f dd Zd f d d ZZS)z:wrap_extension_for_http.._WrappedExtensionFromHTTPr?str | bytes | Nonec sz tj|i|WSy}z|d}~wy)}z|d}~wy8}z|d}~wyG}z|d}~wwr{super next_payloadselfargsrr rrrr rr RequestsSSLError _SSLErrorrrZr[r*szGwrap_extension_for_http.._WrappedExtensionFromHTTP.next_payloadbuf str | bytesrc sz t|WdStfy}z|d}~wy*}z|d}~w y9}z|d}~w fyb}zt| rK|t|rT|t| r]|d}~wwr{r send_payloadrMrrrerrr rrrr rrr r _HTTPError_InvalidHeader _ProxyErrorrrrZr[r6s*   zGwrap_extension_for_http.._WrappedExtensionFromHTTP.send_payloadc sztWdStfy}z|d}~wy)}z|d}~w y8}z|d}~w fya}zt| rJ|t|rS|t| r\|d}~wwr{rcloserMrrrrr rZr[r%Is*   z@wrap_extension_for_http.._WrappedExtensionFromHTTP.closer?rrrr?rr?r__name__ __module__ __qualname__rrr% __classcell__rZrrrrrrr rrr rr!r"r#rrr[_WrappedExtensionFromHTTP)& .r1 exceptionsrrrrrrrpackages.urllib3.exceptionsrrr r r )rr1rZr/r[wrap_extension_for_http     03r6type[AsyncExtensionFromHTTP]cr) z We want to properly map exceptions from below (urllib3-future) into our own exceptions. This function purposely wrap the extension class to achieve that. Warning: asynchronous context only! rrrrr r rcr)zEasync_wrap_extension_for_http.._AsyncWrappedExtensionFromHTTPr?rc sz tj|i|IdHWSy}z|d}~wy-}z|d}~wy<}z|d}~wyK}z|d}~wwr{rrrrZr[rs zRasync_wrap_extension_for_http.._AsyncWrappedExtensionFromHTTP.next_payloadrrrc sz t|IdHWdStfy}z|d}~wy.}z|d}~w y=}z|d}~w fyf}zt| rO|t|rX|t| ra|d}~wwr{rrr rZr[rs,   zRasync_wrap_extension_for_http.._AsyncWrappedExtensionFromHTTP.send_payloadc sz tIdHWdStfy}z|d}~wy-}z|d}~w y<}z|d}~w fye}zt| rN|t|rW|t| r`|d}~wwr{r$r&r rZr[r%s,   zKasync_wrap_extension_for_http.._AsyncWrappedExtensionFromHTTP.closer'r(r)r*rZr/r0r[_AsyncWrappedExtensionFromHTTPr2r9r3)rr9rZr/r[async_wrap_extension_for_http_r7r:excrcCsLt}|}|r$||vr$t|tjrdS|||jp|j}|r$||vs dS)NTF)setrasyncioCancelledErroradd __cause__ __context__)r;seencurrZrZr[is_cancelled_error_root_causes     rDdatarcCsBt|gdd}|dur|jdkr|jrdS|jddSdS)N)rzutf-16zutf-32z utf-16-lez utf-16-bez utf-32-lez utf-32-be) cp_isolationutf_8z utf-8-sigr-)rbestrbomrQ)rEencoding_guessrZrZr[guess_json_utfs  rLbase_urlcCdSr{rZrMrrrZrZr[merge_base_urlrPcCrNr{rZrOrZrZr[rPrQcCs^|dus|dur |St|dddkr-|dr|dd}|r)|ds)d|}||S|S)Nrrrr)rprNrrOrZrZr[rPs   )r?r@)rUr<r?r@)r]r^r?rK)F)rrrsrtr@r?ru)rrr?rs)rrr?r)rrr?r)rrr?r)rr<r?r)rr<r?r)rr<rr@r?r<)rrr?r)rr.r?r)rr<r?r)rrr?rs)rrrr2r?r)rrrr2r?r)rrrrr?r)rr<r?r<)r)rrKrrKr?rK)rr<r?r@)rr<rr<r?r@)rrKr?r<)r4r<r?r@)r8r<r9r<)r;r<r?r@)rBr<rrsr?rC)rrr<rGrsr?r@r{)rrr<rGrsr?rX)rrr<rZr\r?rs)T)rlrmrZrnror@r?rX)rv)rr<r?r<)r?r+)rr<r?r|)rrr<rr<r?r<)rrr<r?r)rrr<r?r<)rr0r?r)rrr?r)rrr?r#)rr@rr@r?r)rrr?r)r]rr?r)Nr)rrr<rrsrrKr?r<)rr<rrr<r?r<)rrr?r@)rrrrr?r@)rrr?r)rr8r?r8)r;rr?r@)rErr?rs)rMrsrrrr?r)rMrsrrr<r?r<)rMrsrrrsr?rs)__doc__ __future__rr=r contextlibrfrrirRr#r!sysrtyping collectionsr functoolsrhttp.cookiejarrrr urllib.parserr r r r r urllib.requestrrrrrrplatformrcharset_normalizerrr_compatrr4rrrextensions.revocationrrpackages.urllib3r!packages.urllib3.contrib.resolverrr r!r"(packages.urllib3.contrib.resolver._asyncr#r$r%&packages.urllib3.contrib.webextensionsr&r'-packages.urllib3.contrib.webextensions._asyncr(packages.urllib3.utilr)r* structuresr+packages.urllib3.contrib.anytlsr,rH TYPE_CHECKINGrr.modelsr/r0r1r2r3r4rr:__annotations__rrOr=r\rorrcontextmanagerrrTypeVarrrrrrrrrrrrrr<rrr frozensetrr rrrr0r3r r%r:rArFrWr[rkrurwr{rrrrrrrrrrrrprrrrrr6r:rDrLoverloadrPrZrZrZr[s                  $   ' 3 *      "              = 6   #     @ @         ]]