� �ReW�@s�dZddlZddlmZddlmZddlmZddlmZm Z m Z mZmZddl mZmZmZmZdd lmZmZmZdd lmZmZddlmZmZmZddlmZmZm Z m!Z!dd l"m#Z#ddl$m%Z%ddlm&Z&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,ddlm-Z-e dd�Z.e dd�Z/Gdd�de0�Z1Gdd�de1�Z2dd�Z3dS)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�OrderedDict�urljoin�urlparse�builtin_str)�cookiejar_from_dict�extract_cookies_to_jar�RequestsCookieJar� merge_cookies)�Request�PreparedRequest�DEFAULT_REDIRECT_LIMIT)� default_hooks� dispatch_hook)�to_key_val_list�default_headers�to_native_string)�TooManyRedirects� InvalidSchema�ChunkedEncodingError�ContentDecodingError)�CaseInsensitiveDict)�HTTPAdapter)�requote_uri�get_environ_proxies�get_netrc_auth�should_bypass_proxies�get_auth_from_url)�codes)�REDIRECT_STATIcCs�|dkr|S|dkr |St|t�o;t|t�sB|S|t|��}|jt|��x0|j�D]"\}}|dkrt||=qtqtWtdd�|j�D��}|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-|]#\}}|dk r||fVqdS)N�)�.0�k�vr$r$�8/tmp/pip-ztkk0jow-build/pip/_vendor/requests/sessions.py� Csz merge_setting..)� isinstancerr�update�items�dict)�request_setting�session_setting� dict_class�merged_settingr&r'r$r$r(� merge_setting'sr2cCsZ|dks!|jd�gkr%|S|dksF|jd�gkrJ|St|||�S)z� Properly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. N�response)�getr2)� request_hooks� session_hooksr0r$r$r(�merge_hooksHs !!r7c@sCeZdZddddddd�Zdd�Zdd �ZdS) �SessionRedirectMixinFNTccs�d}x�|jr�|j�} y|jWn.tttfk rY|jjdd�YnX||jkrt d|j��n|j �|jd} |j}| j d�r�t|j�}d|j| f} nt| �} | j�} t| �jst|jt| ��} nt| �} t| �| _|jtjkrW|dkrWd }n|jtjkr~|dkr~d }n|jtjkr�|d kr�d }n|| _|jtjtjfkr�d| jkr�| jd=nd| _n| j}y|d =Wntk rYnXt| j | |j�| j j!|j"�| j#| j �|j$| |�}|j%| |�| }|j&|d|d|d|d|d|dd�}t|j"| |j�|d7}|Vq WdS)z6Receives a Response. Returns a generator of Responses.r�decode_contentFzExceeded %s redirects.�locationz//z%s:%s�HEAD�GET�POSTzContent-LengthN�Cookie�stream�timeout�verify�cert�proxies�allow_redirectsr)'�is_redirect�copy�contentrr�RuntimeError�raw�read� max_redirectsr�close�headers�method� startswithr �url�scheme�geturl�netlocrrr�status_coder"� see_other�found�moved� temporary�resume�body�KeyErrorr�_cookiesr+�cookies�prepare_cookies�rebuild_proxies�rebuild_auth�send)�self�resp�reqr?r@rArBrC�i�prepared_requestrPrN�parsed_rurl�parsedrMr$r$r(�resolve_redirectsYsn z&SessionRedirectMixin.resolve_redirectscCs�|j}|j}d|kr[t|jj�}t|�}|j|jkr[|d=q[n|jrpt|�nd}|dk r�|j|�ndS)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. � AuthorizationN)rMrPr �request�hostname� trust_envr�prepare_auth)rbrfr3rMrP�original_parsed�redirect_parsed�new_authr$r$r(r`�s z!SessionRedirectMixin.rebuild_authcCs|j}|j}t|�j}|dk r9|j�ni}|jr�t|�r�t|�}|j|�}|r�|j |||�q�nd|kr�|d=nyt ||�\} } Wntk r�d\} } YnX| r| rt| | �|d>> import requests >>> s = requests.Session() >>> s.get('http://httpbin.org/get') 200 rMr]�authr@rC�hooks�paramsrArB�prefetch�adaptersr?rmrKcCs�t�|_d|_i|_t�|_i|_d|_d|_d|_ t |_d|_t i�|_t�|_|jdt��|jdt��dS)NFTzhttps://zhttp://)rrMr|rCrr}r~r?rArBrrKrmrr]rr��mountr)rbr$r$r(�__init__s zSession.__init__cCs|S)Nr$)rbr$r$r(� __enter__?szSession.__enter__cGs|j�dS)N)rL)rb�argsr$r$r(�__exit__BszSession.__exit__cCs!|jpi}t|tj�s0t|�}nttt�|j�|�}|j}|jr�|r�|jr�t |j �}nt�}|jd|j j�d|j d|jd|jdt|j|jdt�dt|j|j�dt||j�d |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. rNrP�files�datarMr0r~r|r]r})r]r*r� CookieJarrrr r|rmrrPr�preparerN�upperr�r�r2rMrr~r7r})rbrkr]�merged_cookiesr|�pr$r$r(�prepare_requestEs( zSession.prepare_requestNTcCs�t|�}td|j�d|d|d|d|p9id|pEid|d|d |� }|j|�}|pui}|jrt|�p�i}x*|j�D]\}}|j||�q�W|r�|d k r�tj j d�}n|r|d k rtj j d�}qnt||j�}t| |j �} t||j�}t||j�}i| d 6| d6|d6|d6|d6| d6}|j||�}|S)a4Constructs 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 or bytes 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) Float describing the timeout of the request in seconds. :param allow_redirects: (optional) Boolean. Set to True by default. :param proxies: (optional) Dictionary mapping protocol to the URL of the proxy. :param stream: (optional) whether to immediately download the response content. Defaults to ``False``. :param verify: (optional) if ``True``, the SSL cert will be verified. A CA_BUNDLE path can also be provided. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair. rNrPrMr�r�r~r|r]r}F�REQUESTS_CA_BUNDLE�CURL_CA_BUNDLEr?r@rArBrCrD)r rr�r�rmrr,rr�os�environr4r2rCr?rArBra)rbrNrPr~r�rMr]r�r|r@rDrCr}r?rArBrd�prep�env_proxiesr&r'�send_kwargsrcr$r$r(rklsD, zSession.requestcKs#|jdd�|jd||�S)z�Sends a GET request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. rDTr<)rrrk)rbrP�kwargsr$r$r(r4�szSession.getcKs#|jdd�|jd||�S)z�Sends a OPTIONS request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. rDT�OPTIONS)rrrk)rbrPr�r$r$r(�options�szSession.optionscKs#|jdd�|jd||�S)z�Sends a HEAD request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. rDFr;)rrrk)rbrPr�r$r$r(�head�szSession.headcKs|jd|d||�S)a8Sends 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 \*\*kwargs: Optional arguments that ``request`` takes. r=r�)rk)rbrPr�r�r$r$r(�post�szSession.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. �PUTr�)rk)rbrPr�r�r$r$r(�put�szSession.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. �PATCHr�)rk)rbrPr�r�r$r$r(�patch�sz Session.patchcKs|jd||�S)z�Sends a DELETE request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param \*\*kwargs: Optional arguments that ``request`` takes. �DELETE)rk)rbrPr�r$r$r(�deleteszSession.deletec Ks|jd|j�|jd|j�|jd|j�|jd|j�t|t�sjtd��n|jdd�}|j d�}|j d�}|j d�}|j d�}|j d�}|j } |jd |j�} t j�}| j||�}t j�||_td | ||�}|jrdx-|jD]} t|j| j| j�q>Wnt|j||j�|j||d|d|d|d|d|�}|r�dd�|D�ng}|r�|jd |�|j�}||_n|s|jn|S)zSend a given PreparedRequest.r?rArBrCz#You can only send PreparedRequests.rDTr@rPr3cSsg|]}|�qSr$r$)r%rcr$r$r(� Is z Session.send..r)rrr?rArBrCr*r� ValueError�popr4r}�get_adapterrPr�utcnowra�elapsedr�historyrr]rkrIri�insertrG)rbrkr�rDr?r@rArBrCr}�adapter�start�rrc�genr�r$r$r(rasH zSession.sendcCsMx6|jj�D]%\}}|j�j|�r|SqWtd|��dS)z>Returns the appropriate connnection adapter for the given URL.z*No connection adapters were found for '%s'N)r�r,�lowerrOr)rbrP�prefixr�r$r$r(r�XszSession.get_adaptercCs(x!|jj�D]}|j�qWdS)z+Closes all adapters and as such the sessionN)r��valuesrL)rbr'r$r$r(rLbsz Session.closecsW||j�<�fdd�|jD�}x'|D]}|jj|�|j|.N)r�r�)rbr�r��keys_to_move�keyr$)r�r(r�gs z Session.mountcs t�fdd��jD��S)Nc3s'|]}|t�|d�fVqdS)N)�getattr)r%�attr)rbr$r(r)ssz'Session.__getstate__..)r-� __attrs__)rbr$)rbr(�__getstate__rszSession.__getstate__cCs1x*|j�D]\}}t|||�q WdS)N)r,�setattr)rb�stater��valuer$r$r(�__setstate__uszSession.__setstate__)rxryrz�__doc__r�r�r�r�r�rkr4r�r�r�r�r�r�rar�rLr�r�r�r$r$r$r(r{�sD3(S G r{cCst�S)z2Returns a :class:`Session` for context-management.)r{r$r$r$r(�sessionzsr�)4r�r��collectionsrrr|r�compatrrrr r r]rrr r�modelsrrrr}rr�utilsrrr� exceptionsrrrr� structuresrr�rrrrr r!�status_codesr"r#r2r7�objectr8r{r�r$r$r$r(� s*(""(!��