o 6Wjȅ@sdZddlmZddlZddlZddlZddlmZddlm 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@erddlAmBZBddlCmDZDmEZEddlFmZGddlmHZHejIdkrejJZKnejZKefd-d d!ZLefd.d%d&ZMGd'd(d(ZNGd)d*d*eNZOd/d+d,ZPdS)0z 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) BaseAdapterwin32request_settingr session_setting dict_classtypereturncCsp|dur|S|dur |St|trt|ts|S|t|}|t|dd|D}|D]}||=q0|S)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` NcSsg|] \}}|dur|qSN).0kvr:r:`/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/requests/sessions.py esz!merge_setting..) isinstancerr-updateitems)r4r5r6merged_setting none_keyskeyr:r:r> merge_settingLs rF request_hooks _t.HooksType session_hookscCs@|dus |dgkr |S|dus|dgkr|St|||S)zProperly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. Nresponse)getrF)rGrIr6r:r:r> merge_hooksls   rLc@szeZdZUded<ded<ded<d4d dZd5ddZd6ddZ      d7d8d(d)Zd9d-d.Zd:d0d1Z d9d2d3Z dS);SessionRedirectMixinint max_redirectsbool trust_envrcookiesrequestrkwargsr r8r!cKsdSr9r:)selfrSrTr:r:r>sendszSessionRedirectMixin.sendresp str | NonecCs(|jr|jd}|d}t|dSdS)z7Receives a Response. Returns a redirect URI or ``None``locationlatin1utf8N) is_redirectheadersencoder )rUrWrYr:r:r>get_redirect_targets    z(SessionRedirectMixin.get_redirect_targetold_urlstrnew_urlcCst|}t|}|j|jkrdS|jdkr&|jdvr&|jdkr&|jdvr&dS|j|jk}|j|jk}t|jddf}|sI|j|vrI|j|vrIdS|pL|S)zFDecide whether Authorization header should be removed when redirectingThttp)PNhttps)iNFN)rhostnameschemeportr$rK)rUr`rb old_parsed new_parsed changed_portchanged_scheme default_portr:r:r>should_strip_auths$         z&SessionRedirectMixin.should_strip_authFNTreqstreamtimeout_t.TimeoutTypeverify _t.VerifyTypecert _t.CertTypeproxiesdict[str, str] | Noneyield_requestsadapter_kwargsGenerator[Response, None, None]c  ksHg} ||} t|jj} | r"|} | dd|_| |z|jWntt t fy9|j j ddYnwt |j|jkrMtd|jd|d|| dret|j}dt|j| g} t| }|jd krw| rw|j| d }n|jr}|j} |} |jst|jt| } nt| } t| | _|| ||jtjtjfvrd }|D] }| j |dqd| _!| j}| d dt"d | j#}t$|||j t%||j&| '||(| |}|)| || j*duod|vpd|v}|rt+| | }|r|Vn |j,|f|||||dd| }t$|j&| |j ||} |V| sdSdS)zBReceives a Response. Returns a generator of Responses or Requests.NF)decode_contentz Exceeded z redirects.)rJz//:)fragment)Content-Lengthz Content-TypeTransfer-EncodingCookier.rr)rprqrsrurwallow_redirects)-r_rurlrcopyhistoryappendcontentrr RuntimeErrorrawreadlenrOrclose startswithjoinr rg_replacegeturlnetlocrr)rebuild_method status_coder"temporary_redirectpermanent_redirectr]popbodyr _cookiesrrrRprepare_cookiesrebuild_proxies rebuild_auth_body_positionr+rV)rUrWrorprqrsrurwryrzhistrprevious_fragmentprepared_request parsed_rurlparsedpurged_headersheaderr] cookie_jar rewindabler:r:r>resolve_redirectss                 z&SessionRedirectMixin.resolve_redirectsrrJNonecCsv|j}t|s Jt|sJ|j}|j}|j}d|vr%|||r%|d=|jr,t|nd}|dur9||dSdS)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)rS _is_preparedr]rrnrQr( prepare_auth)rUrrJoriginal_requestr] original_urlrnew_authr:r:r>r5s  z!SessionRedirectMixin.rebuild_authdict[str, str]cCst|sJ|j}t|jj}t|||j}d|vr|d=z t||\}}Wn ty4d\}}Ynw| dsE|rE|rEt |||d<|S)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-AuthorizationNNre) rr]rrrgr*rQr&KeyErrorrr)rUrrwr]rg new_proxiesusernamepasswordr:r:r>rNs    z$SessionRedirectMixin.rebuild_proxiescCsX|j}|jtjkr|dkrd}|jtjkr|dkrd}|jtjkr'|dkr'd}||_dS)zWhen being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOSTN)methodrr" see_otherfoundmoved)rUrrJrr:r:r>rrs z#SessionRedirectMixin.rebuild_methodrSrrTr r8r!)rWr!r8rX)r`rarbrar8rP)FNTNNF)rWr!rorrprPrqrrrsrtrurvrwrxryrPrzr r8r{)rrrJr!r8r)rrrwrxr8r) __name__ __module__ __qualname____annotations__rVr_rnrrrrr:r:r:r>rMs"    $ { $rMc@speZdZUdZded<ded<ded<ded <d ed <d ed <ded<ded<ded<d ed<ded<ded<gdZded<dkddZdld!d"Zdmd%d&Zdnd*d+Z , , , , , , , - , , , , , ,dodpdCdDZ ,dqdrdGdHZ dsdJdKZ dsdLdMZ , ,dtdudOdPZ ,dqdvdRdSZ ,dqdvdTdUZdsdVdWZdwdXdYZdxd[d\Zdyd^d_Zdkd`daZdzdddeZd{dfdgZd|didjZd,S)}SessionaA 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.AuthTypeauthrrwzdict[str, list[_t.HookType]]hookszMutableMapping[str, Any]paramsrPrprtrsrvrurNrOrQrrRz MutableMapping[str, BaseAdapter]adapters) r]rRrrwrrrsrurrprQrOz list[str] __attrs__r8rcCsrt|_d|_i|_t|_i|_d|_d|_d|_ t |_ d|_ t i|_t|_|dt|dtdS)NFTzhttps://zhttp://)r%r]rrwrrrrprsrurrOrQrrRrrmountrrUr:r:r>__init__s  zSession.__init__r/cCs|Sr9r:rr:r:r> __enter__szSession.__enter__argsr cGs |dSr9)r)rUrr:r:r>__exit__s zSession.__exit__rSr rc Cstd|j}tt|j}|jpi}t|tjst|}t t t |j|}|j }|j r4|s4|j s4t |}t}|j|||j|j|jt|j|jtdt|j|jt||j |t|j|jd |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)r6) rrfilesdatajsonr]rrrRr)r rrarrRr@rr.rrrrrQr(rprepareupperrrrrFr]r#rrLr)rUrSrrrRmerged_cookiesrpr:r:r>prepare_requests6       zSession.prepare_requestNTrrarr _t.ParamsTyper _t.DataType_t.HeadersType5RequestsCookieJar | CookieJar | dict[str, str] | Noner _t.FilesTyperqrrrrx_t.HooksInputType | None bool | None_t.VerifyType | Noner _t.JsonTyper!c Cst|tr |d}t|||||pi||pi||| d }||}t|s)J| p,i} ||j| | ||}| | d}| ||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) rrr]rrrrrrRr)rqr) r@bytesdecoder rrrmerge_environment_settingsrrArV)rUrrrrr]rRrrrqrrwrrprsrurroprepsettings send_kwargsrWr:r:r>rS-s4 >    zSession.requestrTUnpack[_t.GetKwargs]cKs$|dd|jd|fd|i|S)aiSends a GET request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param params: (optional) Dictionary, list of tuples or bytes to send in the query string for the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response rTrr setdefaultrS)rUrrrTr:r:r>rKs z Session.getUnpack[_t.RequestKwargs]cK |dd|jd|fi|S)zSends a OPTIONS request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response rTOPTIONSrrUrrTr:r:r>options zSession.optionscKr)zSends a HEAD request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response rFrrrr:r:r>headrz Session.headUnpack[_t.PostKwargs]cKs|jd|f||d|S)aSends a POST request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :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 \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response r)rrrS)rUrrrrTr:r:r>postsz Session.postUnpack[_t.DataKwargs]cK|jd|fd|i|S)auSends a PUT request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response PUTrrrUrrrTr:r:r>put z Session.putcKr)awSends a PATCH request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, list of tuples, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response PATCHrrrr:r:r>patchrz Session.patchcKs|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 DELETErrr:r:r>deleteszSession.deletec Ks|d|j|d|j|d|jd|vr#t||j|j|d<t|tr,t dt |s2J| dd}| d}|j }|j|jd}t}|j|fi|}t|} t| d |_td ||fi|}|jrz|jD] } t|j| j| jqnt|j||j|r|j||fi|} d d | D} ng} | r| d || }| |_|szt|j||fddi||_Wn tyYnw|s|j|S)zISend a given PreparedRequest. :rtype: requests.Response rprsrurwz#You can only send PreparedRequests.rT)r)secondsrJcSsg|]}|qSr:r:)r;rWr:r:r>r?%sz Session.send..rry) rrprsrur*rwrQr@r ValueErrorrrrKr get_adapterrpreferred_clockrVrelapsedrrrrRrSrrinsertnext_next StopIterationr) rUrSrTrrpradapterstartrrrWgenrr:r:r>rVsP         z Session.senddict[str, Any]c Cs|jr=|dur |dnd}t||d}|dur'|D] \}} ||| q|dus/|dur=tjdpr?s"       z"Session.merge_environment_settingsr2cCs<|jD]\}}||r|Sqtd|)z~ Returns the appropriate connection adapter for the given URL. :rtype: requests.adapters.BaseAdapter z&No connection adapters were found for )rrBlowerrr)rUrprefixrr:r:r>rfs zSession.get_adaptercCs|jD]}|qdS)z+Closes all adapters and as such the sessionN)rvaluesr)rUr=r:r:r>rss z Session.closerrcs>||j<fdd|jD}|D] }|j||j|<qdS)zwRegisters a connection adapter to a prefix. Adapters are sorted in descending order by prefix length. cs g|] }t|tkr|qSr:)r)r;r<rr:r>r?~s z!Session.mount..N)rr)rUrr keys_to_moverEr:rr>rxs z Session.mountcsfddjD}|S)Ncsi|] }|t|dqSr9)getattr)r;attrrr:r> sz(Session.__getstate__..)r)rUstater:rr> __getstate__szSession.__getstate__rcCs"|D] \}}t|||qdSr9)rBsetattr)rUrrvaluer:r:r> __setstate__szSession.__setstate__)r8r)r8r/)rr r8r)rSr r8r)NNNNNNNTNNNNNN)"rrarrrrrrr]rrRrrrrrrqrrrrPrwrxrrrprrsrrurvrrr8r!r9)rrrrrTrr8r!)rrrTrr8r!r) rrrrrrrTrr8r!)rrrrrTrr8r!r) rrarwrxrprrsrrurvr8r )rrar8r2)rrarr2r8r)r8r )rr r8r)rrr__doc__rrrrrrrSrKrrrrrrrVrrrrrrr:r:r:r>rsj   ?  2 e      O '  rcCstS)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 )rr:r:r:r>sessions r)r4r r5r r6r7r8r )rGrHrIrHr6r7r8rH)r8r)Qr __future__rrsystime collectionsrcollections.abcrrrdatetimertypingrr r _internal_utilsr r1r rrrrrcompatrrrrRrrrr exceptionsrrrrrrrmodelsrrrr r! status_codesr" structuresr#utilsr$r%r&r'r(r)r*r+r,r-http.cookiejarr.typing_extensionsr/r0r~_tr2platform perf_counterrrFrLrMrrr:r:r:r>sT         0     #