EjȅBdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z ddlmZmZmZdd lmZdd lmZdd lmZdd lmZdd lmZmZmZddlm Z m!Z!m"Z"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@erddlAmBZBddlCmDZDmEZEddlFmZGddlmHZHejdk(r ejZKn ej ZKef d!dZLef d"dZMGddZNGddeNZOd#d ZPy)$z requests.sessions ~~~~~~~~~~~~~~~~~ This module provides a Session object to manage and persist settings across requests (cookies, auth, proxies). ) annotationsN) OrderedDict) GeneratorMappingMutableMapping) timedelta) TYPE_CHECKINGAnycast)to_native_string) is_prepared) HTTPAdapter)_basic_auth_str) cookieliburljoinurlparse)RequestsCookieJarcookiejar_from_dictextract_cookies_to_jar merge_cookies)ChunkedEncodingErrorContentDecodingError InvalidSchemaTooManyRedirects) default_hooks dispatch_hook)DEFAULT_REDIRECT_LIMITREDIRECT_STATIPreparedRequestRequestResponse)codes)CaseInsensitiveDict) DEFAULT_PORTSdefault_headersget_auth_from_urlget_environ_proxiesget_netrc_auth requote_uriresolve_proxies rewind_bodyshould_bypass_proxiesto_key_val_list) CookieJar)SelfUnpack)_types) BaseAdapterwin32c||S||St|trt|ts|S|t|}|jt||j Dcgc] \}}| | }}}|D]}||=|Scc}}w)zDetermines appropriate setting for a given request, taking into account the explicit setting on that request, and the setting in the session. If a setting is a dictionary, they will be merged together using `dict_class` ) isinstancerr.updateitems)request_settingsession_setting dict_classmerged_settingkv none_keyskeys O/root/workspace/ytshorts/venv/lib/python3.12/site-packages/requests/sessions.py merge_settingrBLs ?G,OW1U @AN//:;"0!5!5!7Ev119EIE  3    Fs ) B4Bc|||jdgk(r|S||jdgk(r|St|||S)zProperly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. response)getrB) request_hooks session_hooksr;s rA merge_hooksrHlsO 1 1* = C 1 1* = C  z BBceZdZUded<ded<ded<ddZddZdd Z d dd Z dd Z dd Z ddZ y )SessionRedirectMixinint max_redirectsbool trust_envrcookiesc yN)selfrequestkwargss rAsendzSessionRedirectMixin.sendsrIct|jr,|jd}|jd}t|dSy)z7Receives a Response. Returns a redirect URI or ``None``locationlatin1utf8N) is_redirectheadersencoder )rTresprYs rAget_redirect_targetz(SessionRedirectMixin.get_redirect_targets;   ||J/H x0H#Hf5 5rIct|}t|}|j|jk7ry|jdk(r,|jdvr|jdk(r|jdvry|j|jk7}|j|jk7}t j |jddf}|s|j|vr|j|vry|xs|S)zFDecide whether Authorization header should be removed when redirectingThttp)PNhttps)iNFN)rhostnameschemeportr%rE)rTold_urlnew_url old_parsed new_parsed changed_portchanged_scheme default_ports rAshould_strip_authz&SessionRedirectMixin.should_strip_authsg& g&   *"5"5 5    ':-!!W,;."*//9 #**j.?.??%))**;*;TBDI </</-~-rINc +Kg} |j|} t|jj} | r|j } | dd|_| j | |jt|j |jk\rtd|jd||j!| j#dr;t|j}dj%t'|j(| g} t| }|jd k(r| r|j+| }n|jr |j} |j-} |j.s t1|jt3| } n t3| } t'| | _|j5| ||j6t8j:t8j<fvr,d }|D]}| j>jA|d d| _!| j>}|jAd dtEd | jF}tI|||jtK||jL| jO||jQ| |}|jS| || jTduxr d|vxsd|v}|r tW| | }|r|nP|jX|f|||||dd| }tI|jL| |j|j|} || ryy#tttf$r |jjdYwxYww)zBReceives a Response. Returns a generator of Responses or Requests.NF)decode_contentz Exceeded z redirects.)rDz//:)fragment)Content-Lengthz Content-TypeTransfer-EncodingCookier/rurv)streamtimeoutverifycertproxiesallow_redirects)-r`rurlrtcopyhistoryappendcontentrr RuntimeErrorrawreadlenrMrclose startswithjoinr rf_replacegeturlnetlocrr*rebuild_method status_coder#temporary_redirectpermanent_redirectr]popbodyr _cookiesrrrPprepare_cookiesrebuild_proxies rebuild_auth_body_positionr,rW)rTr_reqrxryrzr{r|yield_requestsadapter_kwargshistr~previous_fragmentprepared_request parsed_rurlparsedpurged_headersheaderr] cookie_jar rewindables rAresolve_redirectsz&SessionRedirectMixin.resolve_redirectss. "&&t,$SWW-66"xxz  7DL KK  4 4<< D$6$66& 2 23;?$ JJL~~d#&txx0 hh 01C1C DcJKc]F"$):2CD$*OO!--/C ==dhh C(89!#&#3C#8     0$ 7((((( "Y,?F$,,00>?(, %&..G KK$ ' k+;+D+DEJ ":sDHH = *dll 3  , ,Z 8**+;WEG   . 5 *88D G+M/Bg/M  ,-#C  tyy !#!#$) % 't||5EtxxP..t4 O)*> M 4 U 3 4s1A!M$$ L-0J9M$+M$-0M!M$ M!!M$c$|j}t|sJt|sJ|j}|j}|j}d|vr|j ||r|d=|j r t |nd}||j|yy)zWhen being redirected we may want to strip authentication from the request to avoid leaking credentials. This method intelligently removes and reapplies authentication where possible to avoid credential loss. AuthorizationN)rU _is_preparedr]r~rorOr) prepare_auth)rTrrDoriginal_requestr] original_urlr~new_auths rArz!SessionRedirectMixin.rebuild_auth5s$++,---,---"**'++ "" g %$*@*@s*S(+/..>#&d    ) )( 3 rIcFt|sJ|j}t|jj}t |||j }d|vr|d= t||\}}|jds|r|rt|||d<|S#t$rd\}}Y6wxYw)aThis method re-evaluates the proxy configuration by considering the environment variables. If we are redirected to a URL covered by NO_PROXY, we strip the proxy configuration. Otherwise, we set missing proxy keys for this URL (in case they were stripped by a previous redirect). This method also replaces the Proxy-Authorization header where necessary. :rtype: dict zProxy-AuthorizationNNrd) rr]rr~rfr+rOr'KeyErrorrr)rTrr|r]rf new_proxiesusernamepasswords rArz$SessionRedirectMixin.rebuild_proxiesNs ,---"***../66%&6P G +-. ,!2;v3F!G Hh   )h8-d+Zd0d,Zd?d-Zd@d.ZdAd/Zy )BSessionaA Requests session. Provides cookie persistence, connection-pooling, and configuration. Basic Usage:: >>> import requests >>> s = requests.Session() >>> s.get('https://httpbin.org/get') Or as a context manager:: >>> with requests.Session() as s: ... s.get('https://httpbin.org/get') zCaseInsensitiveDict[str]r] _t.AuthTypeauthrr|zdict[str, list[_t.HookType]]hookszMutableMapping[str, Any]paramsrNrxrrzrr{rLrMrOrrPz MutableMapping[str, BaseAdapter]adapters) r]rPrr|rrrzr{rrxrOrMz list[str] __attrs__c^t|_d|_i|_t |_i|_d|_d|_d|_ t|_ d|_ ti|_t|_|j#dt%|j#dt%y)NFTzhttps://zhttp://)r&r]rr|rrrrxrzr{rrMrOrrPrrmountrrTs rA__init__zSession.__init__s'(   #_     4 +2. $   :{}- 9km,rIc|SrRrSrs rA __enter__zSession.__enter__s rIc$|jyrR)r)rTargss rA__exit__zSession.__exit__s  rIc td|j}tt|j}|jxsi}t |t js t|}ttt|j|}|j}|jr|s|js t|}t}|j|j!||j"|j$|j&t)|j*|j*t,t)|j.|j.t)||j|t1|j2|j2 |S)aConstructs a :class:`PreparedRequest ` for transmission and returns it. The :class:`PreparedRequest` has settings merged from the :class:`Request ` instance and those of the :class:`Session`. :param request: :class:`Request` instance to prepare with this session's settings. :rtype: requests.PreparedRequest _t.UriType)r;) rr~filesdatajsonr]rrrPr)r r~rrrPr6rr/rrrrrOr)r prepareupperrrrrBr]r$rrHr)rTrUr~rrPmerged_cookiesrps rAprepare_requestzSession.prepare_requests"<-c7>>*//'R'9#6#67)'2G' +-t|| >$tyy!#&D   <<>--!:M!=tTYY/"gmmTZZ8  rINc vt|tr|jd}t|j ||||xsi||xsi|||  }|j |}t |sJ| xsi} |j|j| | ||}| | d}|j||j|fi|}|S)a Constructs a :class:`Request `, prepares it and sends it. Returns :class:`Response ` object. :param method: method for the new :class:`Request` object. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary or bytes to be sent in the query string for the :class:`Request`. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param json: (optional) json to send in the body of the :class:`Request`. :param headers: (optional) Dictionary of HTTP Headers to send with the :class:`Request`. :param cookies: (optional) Dict or CookieJar object to send with the :class:`Request`. :param files: (optional) Dictionary of ``'filename': file-like-objects`` for multipart encoding upload. :param auth: (optional) Auth tuple or callable to enable Basic/Digest/Custom HTTP Auth. :param timeout: (optional) How many seconds to wait for the server to send data before giving up, as a float, or a :ref:`(connect timeout, read timeout) ` tuple. :type timeout: float or tuple :param allow_redirects: (optional) Set to True by default. :type allow_redirects: bool :param proxies: (optional) Dictionary mapping protocol or protocol and hostname to the URL of the proxy. :param hooks: (optional) Dictionary mapping hook name to one event or list of events, event must be callable. :param stream: (optional) whether to immediately download the response content. Defaults to ``False``. :param verify: (optional) Either a boolean, in which case it controls whether we verify the server's TLS certificate, or a string, in which case it must be a path to a CA bundle to use. Defaults to ``True``. When set to ``False``, requests will accept any TLS certificate presented by the server, and will ignore hostname mismatches and/or expired certificates, which will make your application vulnerable to man-in-the-middle (MitM) attacks. Setting verify to ``False`` may be useful during local development or testing. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair. :rtype: requests.Response zutf-8) rr~r]rrrrrrPr)ryr}) r6bytesdecoder!rrrmerge_environment_settingsr~r7rW)rTrr~rrr]rPrrryr}r|rrxrzr{rrprepsettings send_kwargsr_s rArUzSession.request-s| c5 !**W%C<<>t>v>>rIc *|jd|fi|S)zSends a DELETE request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response DELETErrs rAdeletezSession.deletest||Hc4V44rIc |jd|j|jd|j|jd|jd|vr$t ||j |j |d<t|tr tdt|sJ|jdd}|jd}|j}|j|j}t!}|j"|fi|}t!|z } t%| |_t)d ||fi|}|j*r<|j*D]-} t-|j.| j0| j2/t-|j.||j2|r$|j4||fi|} | D cgc]} | } } ng} | r)| j7d || j}| |_|s% t9|j4||fd di||_|s |j>|Scc} w#t<$rY wxYw) zISend a given PreparedRequest. :rtype: requests.Response rxrzr{r|z#You can only send PreparedRequests.r}T)r~)secondsrDrr) rrxrzr{r+r|rOr6r! ValueErrorrrrEr get_adapterr~preferred_clockrWrelapsedrrrrPrUrrinsertnext_next StopIterationr) rTrUrVr}rxradapterstartrrr_genrs rArWz Session.sends  (DKK0(DKK0&$)), F " /t~~ VF9  gw 'BC CG$$$!**%6=H% ""w{{"3 ! GLL +F +"#e+g.  *eQ 9& 9 99  M&t||T\\488L M t||Waee< ($((G>v>C(+,t,G,G  NN1a  AAI *D**1gUdUfU  II1-$!  s< H,8$H11 H=<H=c|jr||jdnd}t||}|*|jD]\}} |j || |dus|Dt j jdxs#t j jdxs|}t||j}t||j}t||j}t||j}||||dS)z^ Check the environment and merge it with some settings. :rtype: dict Nno_proxy)rTREQUESTS_CA_BUNDLECURL_CA_BUNDLE)r|rxrzr{) rOrEr(r8rosenvironrBr|rxrzr{) rTr~r|rxrzr{r env_proxiesr=r>s rArz"Session.merge_environment_settings?s >>292Ew{{:.4H-cHEK"'--/-DAq&&q!,- ~JJNN#78zz~~&67 6vt{{3vt{{3T499-"fPTUUrIc|jjD]6\}}|jj|js4|cSt d|)z~ Returns the appropriate connection adapter for the given URL. :rtype: requests.adapters.BaseAdapter z&No connection adapters were found for )rr8lowerrr)rTr~prefixr s rArzSession.get_adapterfsX $}}224 OFGyy{%%flln5  DSGLMMrIcb|jjD]}|jy)z+Closes all adapters and as such the sessionN)rvaluesr)rTr>s rArz Session.closess'%%' A GGI rIc||j|<|jDcgc]}t|t|ks|}}|D]*}|jj||j|<,ycc}w)zwRegisters a connection adapter to a prefix. Adapters are sorted in descending order by prefix length. N)rrr)rTrr r= keys_to_mover@s rArz Session.mountxsj !( f#'==IaCFS[4HI I 8C!%!2!23!7DMM#  8Js A1A1c Z|jDcic]}|t||d}}|Scc}wrR)rgetattr)rTattrstates rA __getstate__zSession.__getstate__s2=A^^LTwtT400LL Ms(cN|jD]\}}t|||yrR)r8setattr)rTrrvalues rA __setstate__zSession.__setstate__s' ;;= 'KD% D$ & 'rI)rr)rr0)rr rr)rUr!rr )NNNNNNNTNNNNNN)"rrr~rr _t.ParamsTyper _t.DataTyper]z_t.HeadersTyperPz5RequestsCookieJar | CookieJar | dict[str, str] | Nonerz _t.FilesTyperrryrr}rNr|rrz_t.HooksInputType | Nonerx bool | Nonerz_t.VerifyType | Noner{rr _t.JsonTyperr"rR)r~rrr$rVzUnpack[_t.GetKwargs]rr")r~rrVzUnpack[_t.RequestKwargs]rr"r) r~rrr%rr(rVzUnpack[_t.PostKwargs]rr")r~rrr%rVzUnpack[_t.DataKwargs]rr"r) r~rr|rrxr&rzr'r{rrdict[str, Any])r~rrr3)rrr r3rr)rr))rr)rr)rrr__doc__rrrrrrrUrErrrrrrrWrrrrrr#rSrIrArrs$&%   '' $$ L  O .. Iy =-~,d!% "&IM" "& $)-*."'+  #``` `  `  `G``` ``'`(``%` !`"#`$ %`J!%A AA' A  A$ 6 3! I II I ( I  I(48 = =%0 =CX =  =48 ? ?%0 ?CX ?  ?5M^%V %V'%V %V % %V  %V %VN N 8'rIrctS)aZ Returns a :class:`Session` for context-management. .. deprecated:: 1.0.0 This method has been deprecated since version 1.0.0 and is only kept for backwards compatibility. New code should use :class:`~requests.sessions.Session` to create a session. This may be removed at a future date. :rtype: Session )rrSrIrAsessionr,s  9rI)r9r r:r r;typerr )rF _t.HooksTyperGr.r;r-rr.)rr)Qr* __future__rrsystime collectionsrcollections.abcrrrdatetimertypingr r r _internal_utilsr r2rrrrrrcompatrrrrPrrrr exceptionsrrrrrrrmodelsrrr r!r" status_codesr# structuresr$utilsr%r&r'r(r)r*r+r,r-r.http.cookiejarr/typing_extensionsr0r1rs_tr3platform perf_counterrrBrHrKrr,rSrIrArBs+# #>>++-/!!00  0 +   (.%<<7''OiiODO+.<@F#CCCC C&I)I)X~'"~'B rI