U _r@sdZddlZddlZddlZddlmZddlmZddlm Z ddl m Z m Z m Z mZmZddlmZmZmZmZdd lmZmZmZdd lmZmZdd lmZdd lmZm Z m!Z!dd l"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(ddl)m*Z*ddlm+Z+m,Z,m-Z-m.Z.m/Z/m0Z0ddl1m2Z2ddlm3Z3ej4dkrVz ej5Z6Wne7k rRej8Z6YnXnejZ6efddZ9efddZ:Gddde;ZdS)z requests.session ~~~~~~~~~~~~~~~~ This module provides a Session object to manage and persist settings across requests (cookies, auth, proxies). N) timedelta) OrderedDict)_basic_auth_str) cookielibis_py3urljoinurlparseMapping)cookiejar_from_dictextract_cookies_to_jarRequestsCookieJar merge_cookies)RequestPreparedRequestDEFAULT_REDIRECT_LIMIT) default_hooks dispatch_hook)to_native_string)to_key_val_listdefault_headers DEFAULT_PORTS)TooManyRedirects InvalidSchemaChunkedEncodingErrorContentDecodingError)CaseInsensitiveDict) HTTPAdapter) requote_uriget_environ_proxiesget_netrc_authshould_bypass_proxiesget_auth_from_url rewind_body)codes)REDIRECT_STATIwin32cCsp|dkr |S|dkr|St|tr,t|ts0|S|t|}|t|dd|D}|D] }||=q`|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|]\}}|dkr|qSN).0kvr(r(P/home/toby/toby_env/lib/python3.8/site-packages/pip/_vendor/requests/sessions.py Jsz!merge_setting..) isinstancer rupdateitems)Zrequest_settingZsession_setting dict_classZmerged_settingZ none_keyskeyr(r(r, merge_setting2s r3cCs@|dks|dgkr|S|dks0|dgkr4|St|||S)zProperly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. Nresponse)getr3)Z request_hooksZ session_hooksr1r(r(r, merge_hooksQs r6c@s>eZdZddZddZddd Zd d Zd d ZddZdS)SessionRedirectMixincCs,|jr(|jd}tr|d}t|dSdS)z7Receives a Response. Returns a redirect URI or ``None``locationlatin1utf8N) is_redirectheadersrencoder)selfrespr8r(r(r,get_redirect_targetbs    z(SessionRedirectMixin.get_redirect_targetcCst|}t|}|j|jkr dS|jdkrL|jdkrL|jdkrL|jdkrLdS|j|jk}|j|jk}t|jddf}|s|j|kr|j|krdS|p|S)zFDecide whether Authorization header should be removed when redirectingThttp)PNhttps)iNFN)r hostnameschemeportrr5)r>Zold_urlZnew_urlZ old_parsedZ new_parsedZ changed_portZchanged_scheme default_portr(r(r,should_strip_authws$   z&SessionRedirectMixin.should_strip_authFNTc  ksHg} ||} t|jj} | rD|} | || dd|_z |jWn(tt t fk rr|j j ddYnXt |j|jkrtd|j|d|| drt|j}dt|j| g} t| }|jd kr| r|j| d }n |jr|j} |} |jst|jt| } nt| } t| | _|| ||jtjtjfkrpd }|D]}| j !|dqTd| _"| j }|!d dt#| j$||j t%| j$|j&| '| j$|(| |}|)| || j*dk od |kpd|k}|rt+| | }|r|Vq|j,|f|||||dd| }t#|j&| |j ||} |VqdS)zBReceives a Response. Returns a generator of Responses or Requests.rNF)decode_contentzExceeded {} redirects.)r4z//:)fragment)Content-Lengthz Content-TypeTransfer-EncodingCookierMrN)streamtimeoutverifycertproxiesallow_redirects)-r@r urlrLcopyappendhistorycontentrr RuntimeErrorrawreadlen max_redirectsrformatclose startswithjoinrrE_replacegeturlnetlocrrrebuild_method status_coder$temporary_redirectpermanent_redirectr<popbodyr _cookiesrcookiesprepare_cookiesrebuild_proxies rebuild_auth_body_positionr#send)r>r?reqrPrQrRrSrTyield_requestsZadapter_kwargsZhistrVZprevious_fragmentprepared_requestZ parsed_rurlparsedZpurged_headersheaderr<Z rewindabler(r(r,resolve_redirectss~               z&SessionRedirectMixin.resolve_redirectscCsR|j}|j}d|kr*||jj|r*|d=|jr8t|nd}|dk rN||dS)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)r<rVrHrequest trust_envr prepare_auth)r>rvr4r<rVZnew_authr(r(r,rqsz!SessionRedirectMixin.rebuild_authc Cs|dk r |ni}|j}|j}t|j}|}|d}t||d}|jr||s|t||d} | || d} | r|| || d|kr|d=zt ||\} } Wnt k rd\} } YnX| r| rt | | |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 Nno_proxyr~allzProxy-Authorization)NN) r<rVr rErWr5r!r|r setdefaultr"KeyErrorr) r>rvrTr<rVrEZ new_proxiesr~Z bypass_proxyZenviron_proxiesproxyusernamepasswordr(r(r,rps*       z$SessionRedirectMixin.rebuild_proxiescCsX|j}|jtjkr|dkrd}|jtjkr6|dkr6d}|jtjkrN|dkrNd}||_dS)zWhen being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOSTN)methodrhr$ see_otherfoundmoved)r>rvr4rr(r(r,rg:sz#SessionRedirectMixin.rebuild_method)FNTNNF) __name__ __module__ __qualname__r@rHryrqrprgr(r(r(r,r7`s n)r7c@seZdZdZdddddddd d d d d g ZddZddZddZddZd6ddZ ddZ ddZ ddZ d7d d!Z d8d"d#Zd9d$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3Zd4d5ZdS):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') r<rnauthrThooksparamsrRrSadaptersrPr|r_cCsrt|_d|_i|_t|_i|_d|_d|_d|_ t |_ d|_ t i|_t|_|dt|dtdS)NFTzhttps://zhttp://)rr<rrTrrrrPrRrSrr_r|r rnrrmountrr>r(r(r,__init__js zSession.__init__cCs|Sr'r(rr(r(r, __enter__szSession.__enter__cGs |dSr')ra)r>argsr(r(r,__exit__szSession.__exit__c Cs|jpi}t|tjst|}ttt|j|}|j}|jrR|sR|jsRt |j }t }|j |j |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 )r1) rrVfilesdatajsonr<rrrnr)rnr.r CookieJarr rr rr|r rVrpreparerupperrrrr3r<rrr6r)r>r{rnZmerged_cookiesrpr(r(r,prepare_requests0        zSession.prepare_requestNTc Cstt|||||pi||pi||| d }||}| p8i} ||j| | ||}| | d}|||j|f|}|S)aConstructs 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 long 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 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``. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair. :rtype: requests.Response ) rrVr<rrrrrrnr)rQrU)rrrmerge_environment_settingsrVr/rs)r>rrVrrr<rnrrrQrUrTrrPrRrSrrtprepZsettingsZ send_kwargsr?r(r(r,r{s6)  zSession.requestcKs|dd|jd|f|S)zSends a GET request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. :rtype: requests.Response rUTrrr{r>rVkwargsr(r(r,r5s z Session.getcKs|dd|jd|f|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 rUTOPTIONSrrr(r(r,options!s zSession.optionscKs|dd|jd|f|S)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 rUFrrrr(r(r,head,s z Session.headcKs|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)rrr{)r>rVrrrr(r(r,post7s z Session.postcKs|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 PUTrrr>rVrrr(r(r,putDs z Session.putcKs|jd|fd|i|S)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,patchPs z Session.patchcKs|jd|f|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,delete\szSession.deletec Ks||d|j|d|j|d|j|d|jt|trJtd|dd}| d}|j }|j |j d}t }|j|f|}t |} t| d |_td ||f|}|jr|jD]} t|j| j| jqt|j||j|r|j||f|} d d | D} ng} | r,| d || }| |_|slz"t|j||fddi||_Wntk rjYnX|sx|j|S)zISend a given PreparedRequest. :rtype: requests.Response rPrRrSrTz#You can only send PreparedRequests.rUT)rV)secondsr4cSsg|]}|qSr(r()r)r?r(r(r,r-sz Session.send..rru)rrPrRrSrTr.r ValueErrorrkr5r get_adapterrVpreferred_clockrsrelapsedrrYr rnr{r\ryinsertnext_next StopIterationrZ) r>r{rrUrPradapterstartrrr?genrYr(r(r,rsfsF       "z Session.sendc Cs|jrn|dk r|dnd}t||d}|D]\}} ||| q0|dksV|dkrntjdpltjd}t||j}t||j }t||j }t||j }||||dS)z^ Check the environment and merge it with some settings. :rtype: dict Nr~rTZREQUESTS_CA_BUNDLEZCURL_CA_BUNDLE)rRrTrPrS) r|r5rr0rosenvironr3rTrPrRrS) r>rVrTrPrRrSr~Z env_proxiesr*r+r(r(r,rs        z"Session.merge_environment_settingscCs@|jD]"\}}||r |Sq td|dS)z~ Returns the appropriate connection adapter for the given URL. :rtype: requests.adapters.BaseAdapter z*No connection adapters were found for {!r}N)rr0lowerrbrr`)r>rVprefixrr(r(r,rs zSession.get_adaptercCs|jD] }|q dS)z+Closes all adapters and as such the sessionN)rvaluesra)r>r+r(r(r,rasz Session.closecs>||j<fdd|jD}|D]}|j||j|<q"dS)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-sz!Session.mount..N)rrk)r>rrZ keys_to_mover2r(rr,rs z Session.mountcsfddjD}|S)Ncsi|]}|t|dqSr')getattr)r)attrrr(r, sz(Session.__getstate__..) __attrs__)r>stater(rr, __getstate__szSession.__getstate__cCs"|D]\}}t|||qdSr')r0setattr)r>rrvaluer(r(r, __setstate__szSession.__setstate__)NNNNNNNTNNNNNN)NN)N)N)rrr__doc__rrrrrr{r5rrrrrrrsrrrarrrr(r(r(r,rQs^7) G    K 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)?rrsystimedatetimer collectionsrrrcompatrrrr r rnr r r rmodelsrrrrrr_internal_utilsrutilsrrr exceptionsrrrr structuresrrrrrr r!r"r# status_codesr$r%platform perf_counterrAttributeErrorZclockr3r6objectr7rrr(r(r(r,sB             r'