3
gu                 @   s  d Z ddlZddlZddlZddlmZ ddlmZ ddlm	Z	 ddl
mZmZmZmZmZ ddlmZmZmZmZ dd	lmZmZmZ dd
lmZmZ ddlmZ ddlmZm Z m!Z! ddl"m#Z#m$Z$m%Z%m&Z& ddl'm(Z( ddl)m*Z* ddlm+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 ddl1m2Z2 ddlm3Z3 ej4dkrVy
ej5Z6W n e7k
rR   ej8Z6Y nX nejZ6efddZ9efddZ:G dd de;Z<G dd de<Z=dd Z>dS )z
requests.sessions
~~~~~~~~~~~~~~~~~

This module provides a Session object to manage and persist settings across
requests (cookies, auth, proxies).
    N)	timedelta)OrderedDict   )_basic_auth_str)	cookielibis_py3urljoinurlparseMapping)cookiejar_from_dictextract_cookies_to_jarRequestsCookieJarmerge_cookies)RequestPreparedRequestDEFAULT_REDIRECT_LIMIT)default_hooksdispatch_hook)to_native_string)to_key_val_listdefault_headersDEFAULT_PORTS)TooManyRedirectsInvalidSchemaChunkedEncodingErrorContentDecodingError)CaseInsensitiveDict)HTTPAdapter)requote_uriget_environ_proxiesget_netrc_authshould_bypass_proxiesget_auth_from_urlrewind_body)codes)REDIRECT_STATIwin32c             C   st   |dkr| S | dkr|S t |to*t | ts0| S |t|}|jt|  dd |j D }x|D ]
}||= qbW |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`
    Nc             S   s   g | ]\}}|d kr|qS )N ).0kvr'   r'   [/var/www/tester-filtro-web/env/lib/python3.6/site-packages/pip/_vendor/requests/sessions.py
<listcomp>J   s    z!merge_setting.<locals>.<listcomp>)
isinstancer
   r   updateitems)Zrequest_settingZsession_setting
dict_classZmerged_settingZ	none_keyskeyr'   r'   r+   merge_setting2   s    



r2   c             C   s@   |dks|j dg kr| S | dks0| j dg kr4|S t| ||S )zProperly merges both requests and session hooks.

    This is necessary because when request_hooks == {'response': []}, the
    merge breaks Session hooks entirely.
    Nresponse)getr2   )Zrequest_hooksZsession_hooksr0   r'   r'   r+   merge_hooksQ   s
    r5   c               @   s>   e Zd Zdd Zdd Zddd	Zd
d Zdd Zdd ZdS )SessionRedirectMixinc             C   s,   |j r(|jd }tr|jd}t|dS dS )z7Receives a Response. Returns a redirect URI or ``None``locationlatin1utf8N)is_redirectheadersr   encoder   )selfrespr7   r'   r'   r+   get_redirect_targetb   s    


z(SessionRedirectMixin.get_redirect_targetc             C   s   t |}t |}|j|jkr dS |jdkrL|jdkrL|jdkrL|jd	krLdS |j|jk}|j|jk}tj|jddf}| r|j|kr|j|krdS |p|S )
zFDecide whether Authorization header should be removed when redirectingThttpP   Nhttps  F)rA   N)rC   N)r	   hostnameschemeportr   r4   )r=   Zold_urlZnew_urlZ
old_parsedZ
new_parsedZchanged_portZchanged_schemedefault_portr'   r'   r+   should_strip_authw   s    
z&SessionRedirectMixin.should_strip_authFNTc	             k   sR  g }
| j |}t|jj}x0|rL|j }|
j| |
dd |_y
|j W n( tt	t
fk
rv   |jjdd Y nX t|j| jkrtdj| j|d|j  |jdrt|j}djt|j|g}t|}|jd	kr|r|j|d
}n|jr|j}|j }|jst|jt|}nt|}t||_| j|| |jtjtjfkrxd}x|D ]}|j j!|d qZW d|_"|j }|j!dd t#|j$||j t%|j$| j& |j'|j$ | j(||}| j)|| |j*dk	od|kpd|k}|rt+| |}|r
|V  q| j,|f|||||dd|	}t#| j&||j | j |}|V  qW dS )zBReceives a Response. Returns a generator of Responses or Requests.r   NF)decode_contentzExceeded {} redirects.)r3   z//: )fragmentContent-LengthContent-TypeTransfer-EncodingCookie)streamtimeoutverifycertproxiesallow_redirects)rM   rN   rO   )-r?   r	   urlrL   copyappendhistorycontentr   r   RuntimeErrorrawreadlenmax_redirectsr   formatclose
startswithjoinr   rE   _replacegeturlnetlocr   r   rebuild_methodstatus_coder$   temporary_redirectpermanent_redirectr;   popbodyr   _cookiesr   cookiesprepare_cookiesrebuild_proxiesrebuild_auth_body_positionr#   send)r=   r>   reqrQ   rR   rS   rT   rU   yield_requestsZadapter_kwargsZhistrW   Zprevious_fragmentprepared_requestZparsed_rurlparsedZpurged_headersheaderr;   Z
rewindabler'   r'   r+   resolve_redirects   sv    








z&SessionRedirectMixin.resolve_redirectsc             C   sR   |j }|j}d|kr*| j|jj|r*|d= | jr8t|nd}|dk	rN|j| dS )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;   rW   rH   request	trust_envr    prepare_auth)r=   rw   r3   r;   rW   Znew_authr'   r'   r+   rr      s    z!SessionRedirectMixin.rebuild_authc             C   s   |dk	r|ni }|j }|j}t|j}|j }|jd}t||d}| jr~| r~t||d}	|	j||	jd}
|
r~|j	||
 d|kr|d= yt
|| \}}W n tk
r   d\}}Y nX |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.

        :rtype: dict
        Nno_proxy)r   allzProxy-Authorization)NN)r;   rW   r	   rE   rX   r4   r!   r}   r   
setdefaultr"   KeyErrorr   )r=   rw   rU   r;   rW   rE   Znew_proxiesr   Zbypass_proxyZenviron_proxiesproxyusernamepasswordr'   r'   r+   rq     s*    

z$SessionRedirectMixin.rebuild_proxiesc             C   sX   |j }|jtjkr|dkrd}|jtjkr6|dkr6d}|jtjkrN|dkrNd}||_ dS )zWhen being redirected we may want to change the method of the request
        based on certain specs or browser behavior.
        HEADGETPOSTN)methodri   r$   	see_otherfoundmoved)r=   rw   r3   r   r'   r'   r+   rh   :  s    z#SessionRedirectMixin.rebuild_method)FNTNNF)	__name__
__module____qualname__r?   rH   rz   rr   rq   rh   r'   r'   r'   r+   r6   `   s    
m)r6   c               @   s   e Zd ZdZdddddddd	d
dddgZdd Zdd Zdd Zdd Zd6ddZ	dd Z
dd Zdd Zd7d d!Zd8d"d#Zd9d$d%Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ Zd0d1 Zd2d3 Zd4d5 ZdS ):Sessiona  A Requests session.

    Provides cookie persistence, connection-pooling, and configuration.

    Basic Usage::

      >>> import requests
      >>> s = requests.Session()
      >>> s.get('https://httpbin.org/get')
      <Response [200]>

    Or as a context manager::

      >>> with requests.Session() as s:
      ...     s.get('https://httpbin.org/get')
      <Response [200]>
    r;   ro   authrU   hooksparamsrS   rT   adaptersrQ   r}   r`   c             C   sr   t  | _d | _i | _t | _i | _d| _d| _d | _	t
| _d| _ti | _t | _| jdt  | jdt  d S )NFTzhttps://zhttp://)r   r;   r   rU   r   r   r   rQ   rS   rT   r   r`   r}   r   ro   r   r   mountr   )r=   r'   r'   r+   __init__j  s    

zSession.__init__c             C   s   | S )Nr'   )r=   r'   r'   r+   	__enter__  s    zSession.__enter__c             G   s   | j   d S )N)rb   )r=   argsr'   r'   r+   __exit__  s    zSession.__exit__c             C   s   |j pi }t|tjst|}ttt | j |}|j}| jrV| rV| j rVt	|j
}t }|j|jj |j
|j|j|jt|j| jtdt|j| jt|| j|t|j| jd
 |S )a  Constructs a :class:`PreparedRequest <PreparedRequest>` for
        transmission and returns it. The :class:`PreparedRequest` has settings
        merged from the :class:`Request <Request>` instance and those of the
        :class:`Session`.

        :param request: :class:`Request` instance to prepare with this
            session's settings.
        :rtype: requests.PreparedRequest
        )r0   )
r   rW   filesdatajsonr;   r   r   ro   r   )ro   r-   r   	CookieJarr   r   r   r   r}   r    rW   r   preparer   upperr   r   r   r2   r;   r   r   r5   r   )r=   r|   ro   Zmerged_cookiesr   pr'   r'   r+   prepare_request  s*    



zSession.prepare_requestNTc             C   st   t |j ||||pi ||pi |||d
}| j|}|p8i }| j|j||||}|	|
d}|j| | j|f|}|S )ax	  Constructs a :class:`Request <Request>`, prepares it and sends it.
        Returns :class:`Response <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) <timeouts>` 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``. 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
        )
r   rW   r;   r   r   r   r   r   ro   r   )rR   rV   )r   r   r   merge_environment_settingsrW   r.   rt   )r=   r   rW   r   r   r;   ro   r   r   rR   rV   rU   r   rQ   rS   rT   r   ru   prepZsettingsZsend_kwargsr>   r'   r'   r+   r|     s(    .

zSession.requestc             K   s   |j dd | jd|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
        rV   Tr   )r   r|   )r=   rW   kwargsr'   r'   r+   r4   "  s    zSession.getc             K   s   |j dd | jd|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
        rV   TOPTIONS)r   r|   )r=   rW   r   r'   r'   r+   options-  s    zSession.optionsc             K   s   |j dd | jd|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
        rV   Fr   )r   r|   )r=   rW   r   r'   r'   r+   head8  s    zSession.headc             K   s   | j d|f||d|S )a  Sends 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   )r   r   )r|   )r=   rW   r   r   r   r'   r'   r+   postC  s    zSession.postc             K   s   | j d|fd|i|S )au  Sends 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
        PUTr   )r|   )r=   rW   r   r   r'   r'   r+   putP  s    
zSession.putc             K   s   | j d|fd|i|S )aw  Sends 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
        PATCHr   )r|   )r=   rW   r   r   r'   r'   r+   patch\  s    
zSession.patchc             K   s   | j d|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
        DELETE)r|   )r=   rW   r   r'   r'   r+   deleteh  s    zSession.deletec             K   s  |j d| j |j d| j |j d| j |j d| j|| j t|trRtd|j	dd}|j
d}|j}| j|jd}t }|j|f|}t | }	t|	d	|_td
||f|}|jrx |jD ]}
t| j|
j|
j qW t| j||j |r| j||f|}dd |D }ng }|r8|jd| |j	 }||_|sxy"t| j||fddi||_W n tk
rv   Y nX |s|j |S )zISend a given PreparedRequest.

        :rtype: requests.Response
        rQ   rS   rT   rU   z#You can only send PreparedRequests.rV   T)rW   )secondsr3   c             S   s   g | ]}|qS r'   r'   )r(   r>   r'   r'   r+   r,     s    z Session.send.<locals>.<listcomp>r   rv   )r   rQ   rS   rT   rq   rU   r-   r   
ValueErrorrl   r4   r   get_adapterrW   preferred_clockrt   r   elapsedr   rZ   r   ro   r|   r]   rz   insertnext_nextStopIterationr[   )r=   r|   r   rV   rQ   r   adapterstartrr   r>   genrZ   r'   r'   r+   rt   r  sF    


"zSession.sendc       
      C   s   | j rr|dk	r|jdnd}t||d}x |j D ]\}}	|j||	 q2W |dksZ|dkrrtjjdpptjjd}t|| j}t|| j	}t|| j
}t|| j}||||dS )z^
        Check the environment and merge it with some settings.

        :rtype: dict
        Nr   )r   TZREQUESTS_CA_BUNDLEZCURL_CA_BUNDLE)rS   rU   rQ   rT   )r}   r4   r   r/   r   osenvironr2   rU   rQ   rS   rT   )
r=   rW   rU   rQ   rS   rT   r   Zenv_proxiesr)   r*   r'   r'   r+   r     s    z"Session.merge_environment_settingsc             C   s@   x,| j j D ]\}}|j j|j r|S qW tdj|dS )z~
        Returns the appropriate connection adapter for the given URL.

        :rtype: requests.adapters.BaseAdapter
        z*No connection adapters were found for {!r}N)r   r/   lowerrc   r   ra   )r=   rW   prefixr   r'   r'   r+   r     s    zSession.get_adapterc             C   s    x| j j D ]}|j  qW dS )z+Closes all adapters and as such the sessionN)r   valuesrb   )r=   r*   r'   r'   r+   rb     s    zSession.closec                sB   || j  <  fdd| j D }x|D ]}| j j|| j |< q$W dS )zwRegisters a connection adapter to a prefix.

        Adapters are sorted in descending order by prefix length.
        c                s    g | ]}t |t  k r|qS r'   )r_   )r(   r)   )r   r'   r+   r,     s    z!Session.mount.<locals>.<listcomp>N)r   rl   )r=   r   r   Zkeys_to_mover1   r'   )r   r+   r     s    

zSession.mountc                s    fdd j D }|S )Nc                s   i | ]}t  |d |qS )N)getattr)r(   attr)r=   r'   r+   
<dictcomp>  s    z(Session.__getstate__.<locals>.<dictcomp>)	__attrs__)r=   stater'   )r=   r+   __getstate__  s    zSession.__getstate__c             C   s&   x |j  D ]\}}t| || q
W d S )N)r/   setattr)r=   r   r   valuer'   r'   r+   __setstate__  s    zSession.__setstate__)NNNNNNNTNNNNNN)NN)N)N)r   r   r   __doc__r   r   r   r   r   r|   r4   r   r   r   r   r   r   rt   r   r   rb   r   r   r   r'   r'   r'   r+   r   Q  s2   >)  
I



Kr   c               C   s   t  S )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
    )r   r'   r'   r'   r+   session  s    r   )?r   r   systimedatetimer   collectionsr   r   r   compatr   r   r   r	   r
   ro   r   r   r   r   modelsr   r   r   r   r   r   _internal_utilsr   utilsr   r   r   
exceptionsr   r   r   r   
structuresr   r   r   r   r   r    r!   r"   r#   status_codesr$   r%   platformperf_counterr   AttributeErrorclockr2   r5   objectr6   r   r   r'   r'   r'   r+   <module>	   sB    
 r   3