`[b@sdZddlZddlmZddlmZddlmZddlmZm Z m Z m Z ddl m Z mZmZmZdd lmZmZmZdd lmZmZdd lmZmZmZdd lmZmZmZm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&ddlm'Z'm(Z(m)Z)m*Z*m+Z+ddl,m-Z-ddlm.Z.dZ/e ddZ0e ddZ1Gddde2Z3Gddde3Z4ddZ5dS)z requests.session ~~~~~~~~~~~~~~~~ This module provides a Session object to manage and persist settings across requests (cookies, auth, proxies). N)Mapping)datetime)_basic_auth_str) cookielib OrderedDicturljoinurlparse)cookiejar_from_dictextract_cookies_to_jarRequestsCookieJar merge_cookies)RequestPreparedRequestDEFAULT_REDIRECT_LIMIT) default_hooks dispatch_hook)to_key_val_listdefault_headersto_native_string)TooManyRedirects InvalidSchemaChunkedEncodingErrorContentDecodingError)RecentlyUsedContainer)CaseInsensitiveDict) HTTPAdapter) requote_uriget_environ_proxiesget_netrc_authshould_bypass_proxiesget_auth_from_url)codes)REDIRECT_STATIicCs|dkr|S|dkr |St|to;t|tsB|S|t|}|jt|dd|jD}x|D] }||=qW|S)z Determines 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` NcSs(g|]\}}|dkr|qS)N).0kvr$r$3/usr/lib/python3/dist-packages/requests/sessions.py Cs z!merge_setting..) isinstancerrupdateitems)Zrequest_settingZsession_setting dict_classZmerged_settingZ none_keyskeyr$r$r( merge_setting*s    r/cCsZ|dks!|jdgkr%|S|dksF|jdgkrJ|St|||S)z Properly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. Nresponse)getr/)Z request_hooksZ session_hooksr-r$r$r( merge_hooksJs !!r2c@sOeZdZddZdddddddZdd Zd d ZdS) SessionRedirectMixincCst|}t|}|j|jkr.dS|jdkrn|jdkrn|jdkrn|jd krndS|j|jkp|j|jkS) zFDecide whether Authorization header should be removed when redirectingTZhttpPNZhttpsF)r4N)r5N)r ZhostnameschemeZport)selfZold_urlnew_urlZ old_parsedZ new_parsedr$r$r(should_strip_auth[s  z&SessionRedirectMixin.should_strip_authFNTcks%d} g} x|jr |j} | dkrR| j|t| } | |_y |jWn.tttfk r|j j ddYnX| |j krt d|j |j |jd} |j}| jdrt|j}d|j| f} t| }|j} |js=t|jt| } n t| } t| | _|jr|j| jkr| j|j|j<|jtjkr|dkrd }|jtjkr|dkrd }|jtjkr|d krd }|| _|jtj tj!fkr8d | jkr/| jd =d | _"| j}y |d =Wnt#k r`YnXt$| j%||j | j%j&|j'| j(| j%|j)| |}|j*| || }|j+|d|d|d|d|d|dd|}t$|j'| |j | d7} |VqWd S)z6Receives a Response. Returns a generator of Responses.rZdecode_contentFzExceeded %s redirects.locationz//z%s:%sHEADGETPOSTzContent-LengthNZCookiestreamtimeoutverifycertproxiesallow_redirectsr),Z is_redirectcopyappendlisthistorycontentrr RuntimeErrorrawread max_redirectsrcloseheadersmethod startswithr urlr6ZgeturlZnetlocrrrZis_permanent_redirectredirect_cacheZ status_coder"Z see_otherfoundZmovedZtemporary_redirectZpermanent_redirectZbodyKeyErrorr Z_cookiesr+cookiesZprepare_cookiesrebuild_proxies rebuild_authsend)r7respreqr>r?r@rArBZadapter_kwargsiZhistprepared_requestZnew_histrQrOZ parsed_rurlZparsedrNr$r$r(resolve_redirectsks~                       z&SessionRedirectMixin.resolve_redirectscCsu|j}|j}d|kr=|j|jj|r=|d=|jrRt|nd}|dk rq|j|dS)z When 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. Z AuthorizationN)rNrQr9request trust_envrZ prepare_auth)r7r\r0rNrQZnew_authr$r$r(rWs  $  z!SessionRedirectMixin.rebuild_authc Cs|j}|j}t|j}|dk r9|jni}|jrt| rt|}|j|}|r|j |||d|kr|d=yt ||\} } Wnt k rd\} } YnX| r| rt | | |d<|S)a This 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. NzProxy-Authorization)NN) rNrQr r6rDr_r rr1 setdefaultr!rTr) r7r\rBrNrQr6Z new_proxiesZenviron_proxiesproxyZusernameZpasswordr$r$r(rVs$      z$SessionRedirectMixin.rebuild_proxies)__name__ __module__ __qualname__r9r]rWrVr$r$r$r(r3Zs  o r3c@s]eZdZdZdddddddd d d d d dg ZddZddZddZddZddddddddddddddddZ ddZ ddZ dd Z ddd!d"Z dd#d$Zdd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6ZdS)7Sessiona~A Requests session. Provides cookie persistence, connection-pooling, and configuration. Basic Usage:: >>> import requests >>> s = requests.Session() >>> s.get('http://httpbin.org/get') Or as a context manager:: >>> with requests.Session() as s: >>> s.get('http://httpbin.org/get') rNrUauthrBhooksparamsr@rAZprefetchadaptersr>r_rLcCst|_d|_i|_t|_i|_d|_d|_d|_ t |_ d|_ t i|_t|_|jdt|jdttt|_dS)NFTzhttps://zhttp://)rrNrfrBrrgrhr>r@rArrLr_r rUrrimountrrREDIRECT_CACHE_SIZErR)r7r$r$r(__init__/s           zSession.__init__cCs|S)Nr$)r7r$r$r( __enter__fszSession.__enter__cGs|jdS)N)rM)r7argsr$r$r(__exit__iszSession.__exit__cCs$|jp i}t|tjs-t|}ttt|j|}|j}|jr}| r}|j r}t |j }t }|j d|j jd|j d|jd|jd|jdt|j|jdtdt|j|jd t||jd |d t|j|j |S) abConstructs 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. rOrQfilesdatajsonrNr-rhrfrUrg)rUr*rZ CookieJarr r r rfr_rrQrZpreparerOupperrprqrrr/rNrrhr2rg)r7r^rUZmerged_cookiesrfpr$r$r(prepare_requestls*         zSession.prepare_requestNTcCstd|jd|d|d|d|p-id|d|p?id|d |d | }|j|}| poi} |j|j| | ||}d | d | i}|j||j||}|S) aqConstructs 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, 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) whether the SSL cert will be verified. A CA_BUNDLE path can also be provided. Defaults to ``True``. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair. rOrQrNrprqrrrhrfrUrgr?rC)rrsrumerge_environment_settingsrQr+rX)r7rOrQrhrqrNrUrprfr?rCrBrgr>r@rArrrZZprepZsettingsZ send_kwargsrYr$r$r(r^s(2       zSession.requestcKs#|jdd|jd||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. rCTr<)r`r^)r7rQkwargsr$r$r(r1sz Session.getcKs#|jdd|jd||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. rCTZOPTIONS)r`r^)r7rQrwr$r$r(optionsszSession.optionscKs#|jdd|jd||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. rCFr;)r`r^)r7rQrwr$r$r(headsz Session.headcKs|jd|d|d||S)aSends a POST request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, 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. r=rqrr)r^)r7rQrqrrrwr$r$r(posts z Session.postcKs|jd|d||S)a7Sends a PUT request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. ZPUTrq)r^)r7rQrqrwr$r$r(put sz Session.putcKs|jd|d||S)a9Sends a PATCH request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. ZPATCHrq)r^)r7rQrqrwr$r$r(patchsz Session.patchcKs|jd||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. ZDELETE)r^)r7rQrwr$r$r(delete!szSession.deletecKs|jd|j|jd|j|jd|j|jd|jt|tsgtdt}xQ|j |j kr|j |j |j j |j }||krP||_ qsW|j dd}|j d}|j}|jd|j }tj} |j||} tj| | _td || |} | jrx*| jD]} t|j| j| jq\Wt|j|| j|j| ||} |rd d | Dng} | r| jd | | j } | | _|s| j| S) zSend a given PreparedRequest.r>r@rArBz#You can only send PreparedRequests.rCTrQr0cSsg|] }|qSr$r$)r%rYr$r$r(r)as z Session.send..r)r`r>r@rArBr*r ValueErrorsetrQrRaddr1poprg get_adapterrZutcnowrXelapsedrrGr rUr^rJr]insertrH)r7r^rwZ checked_urlsr8rCr>rgadapterstartrrYgenrGr$r$r(rX*sD         z Session.sendc Cs|jrt|pi}x*|jD]\}}|j||q(W|dks`|dkrtjjdptjjd}t||j}t||j }t||j }t||j }d|d|d|d|iS) z6Check the environment and merge it with some settings.TNZREQUESTS_CA_BUNDLEZCURL_CA_BUNDLEr@rBr>rA) r_rr,r`osenvironr1r/rBr>r@rA) r7rQrBr>r@rAZ env_proxiesr&r'r$r$r(rvps z"Session.merge_environment_settingscCsMx6|jjD]%\}}|jj|r|SqWtd|dS)z=Returns the appropriate connection adapter for the given URL.z*No connection adapters were found for '%s'N)rir,lowerrPr)r7rQprefixrr$r$r(rszSession.get_adaptercCs(x!|jjD]}|jqWdS)z+Closes all adapters and as such the sessionN)rivaluesrM)r7r'r$r$r(rMsz Session.closecsW||j<fdd|jD}x'|D]}|jj||j|.N)rir)r7rrZ keys_to_mover.r$)rr(rjs  z Session.mountcs9tfddjD}tj|d<|S)Nc3s'|]}|t|dfVqdS)N)getattr)r%attr)r7r$r( sz'Session.__getstate__..rR)dict __attrs__rR)r7stater$)r7r( __getstate__s"zSession.__getstate__cCs||jdi}x*|jD]\}}t|||qWtt|_x'|jD]\}}||j| s. """(