o
    'hw                     @   sj  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 ddlmZ dd	l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mZ ddl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.m/Z/m0Z0m1Z1m2Z2m3Z3 ej4dkrej5Z6nejZ6efddZ7efddZ8G dd dZ9G dd de9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)OrderedDict)	timedelta   )to_native_string)HTTPAdapter)_basic_auth_str)Mapping	cookieliburljoinurlparse)RequestsCookieJarcookiejar_from_dictextract_cookies_to_jarmerge_cookies)ChunkedEncodingErrorContentDecodingErrorInvalidSchemaTooManyRedirects)default_hooksdispatch_hook)DEFAULT_REDIRECT_LIMITREDIRECT_STATIPreparedRequestRequest)codes)CaseInsensitiveDict)
DEFAULT_PORTSdefault_headersget_auth_from_urlget_environ_proxiesget_netrc_authrequote_uriresolve_proxiesrewind_bodyshould_bypass_proxiesto_key_val_listwin32c                 C   sp   |du r| S | du r|S t |trt | ts| S |t|}|t|  dd | 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`
    Nc                 S   s   g | ]
\}}|d u r|qS N ).0kvr(   r(   M/var/www/html/olx_land/venv/lib/python3.10/site-packages/requests/sessions.py
<listcomp>T   s    z!merge_setting.<locals>.<listcomp>)
isinstancer   r%   updateitems)request_settingsession_setting
dict_classmerged_setting	none_keyskeyr(   r(   r,   merge_setting=   s   r7   c                 C   s@   |du s| dg kr| S | du s|  dg kr|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)getr7   )request_hookssession_hooksr3   r(   r(   r,   merge_hooks[   s
   r<   c                   @   sJ   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 }|d}t|dS dS )z7Receives a Response. Returns a redirect URI or ``None``locationlatin1utf8N)is_redirectheadersencoder   )selfrespr>   r(   r(   r,   get_redirect_targetk   s
   


z(SessionRedirectMixin.get_redirect_targetc                 C   s   t |}t |}|j|jkrdS |jdkr&|jdv r&|jdkr&|jdv r&dS |j|jk}|j|jk}t|jddf}|sI|j|v rI|j|v rIdS |pL|S )zFDecide whether Authorization header should be removed when redirectingThttp)P   Nhttps)i  NFN)r   hostnameschemeportr   r9   )rD   old_urlnew_url
old_parsed
new_parsedchanged_portchanged_schemedefault_portr(   r(   r,   should_strip_auth   s$   





z&SessionRedirectMixin.should_strip_authFNTc	              
   k   sB   g }
|  |}t|jj}|r| }|
| |
dd |_z|j W n tt	t
fy9   |jjdd Y nw t|j| jkrMtd| j d|d|  |dret|j}d	t|j|g}t|}|jd
krw|rw|j|d}n|jr}|j}| }|jst|jt|}nt|}t||_| || |jtjtjfvrd}|D ]	}|j |d qd|_!|j}| dd t"|j#||j t$|j#| j% |&|j# | '||}| (|| |j)duod|v pd|v }|rt*| |}|r|V  n | j+|f|||||dd|	}t"| j%||j |  |}|V  |sdS dS )zBReceives a Response. Returns a generator of Responses or Requests.r   NF)decode_contentz	Exceeded z redirects.)r8   z//: )fragment)Content-LengthzContent-TypeTransfer-EncodingCookierY   rZ   )streamtimeoutverifycertproxiesallow_redirects),rF   r   urlrX   copyappendhistorycontentr   r   RuntimeErrorrawreadlenmax_redirectsr   close
startswithjoinr   rK   _replacegeturlnetlocr
   r!   rebuild_methodstatus_coder   temporary_redirectpermanent_redirectrB   popbodyr   _cookiesr   cookiesprepare_cookiesrebuild_proxiesrebuild_auth_body_positionr#   send)rD   rE   reqr\   r]   r^   r_   r`   yield_requestsadapter_kwargshistrb   previous_fragmentprepared_requestparsed_rurlparsedpurged_headersheaderrB   
rewindabler(   r(   r,   resolve_redirects   s   







z&SessionRedirectMixin.resolve_redirectsc                 C   sV   |j }|j}d|v r| |jj|r|d= | jrt|nd}|dur)|| dS 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)rB   rb   rT   request	trust_envr    prepare_auth)rD   r   r8   rB   rb   new_authr(   r(   r,   r|     s   z!SessionRedirectMixin.rebuild_authc                 C   s   |j }t|jj}t||| j}d|v r|d= z
t|| \}}W n ty.   d\}}Y nw |ds?|r?|r?t	|||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
        zProxy-AuthorizationNNrI   )
rB   r   rb   rK   r"   r   r   KeyErrorrm   r   )rD   r   r`   rB   rK   new_proxiesusernamepasswordr(   r(   r,   r{   .  s   z$SessionRedirectMixin.rebuild_proxiesc                 C   sX   |j }|jtjkr|dkrd}|jtjkr|dkrd}|jtjkr'|dkr'd}||_ 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)methodrs   r   	see_otherfoundmoved)rD   r   r8   r   r(   r(   r,   rr   M  s   
z#SessionRedirectMixin.rebuild_method)FNTNNF)	__name__
__module____qualname__rF   rT   r   r|   r{   rr   r(   r(   r(   r,   r=   j   s    $
{r=   c                   @   s   e Zd ZdZg dZdd Zdd Zdd Zd	d
 Z														d+ddZ	dd Z
dd Zdd Zd,ddZd-ddZd-ddZdd Zdd Zdd  Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* 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]>
    )rB   ry   authr`   hooksparamsr^   r_   adaptersr\   r   rk   c                 C   sr   t  | _d | _i | _t | _i | _d| _d| _d | _	t
| _d| _ti | _t | _| dt  | dt  d S )NFTzhttps://zhttp://)r   rB   r   r`   r   r   r   r\   r^   r_   r   rk   r   r   ry   r   r   mountr   rD   r(   r(   r,   __init__  s   

zSession.__init__c                 C   s   | S r'   r(   r   r(   r(   r,   	__enter__  s   zSession.__enter__c                 G   s   |    d S r'   )rl   )rD   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r)|s)| js)t	|j
}t }|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
        )r3   )
r   rb   filesdatajsonrB   r   r   ry   r   )ry   r.   r	   	CookieJarr   r   r   r   r   r    rb   r   preparer   upperr   r   r   r7   rB   r   r   r<   r   )rD   r   ry   merged_cookiesr   pr(   r(   r,   prepare_request  s2   




zSession.prepare_requestNTc                 C   sx   t | ||||p
i ||pi |||d
}| |}|pi }| |j||||}|	|
d}|| | j|fi |}|S )a	  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 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
        )
r   rb   rB   r   r   r   r   r   ry   r   )r]   ra   )r   r   r   merge_environment_settingsrb   r/   r~   )rD   r   rb   r   r   rB   ry   r   r   r]   ra   r`   r   r\   r^   r_   r   r   prepsettingssend_kwargsrE   r(   r(   r,   r     s.   ?

zSession.requestc                 K       | dd | jd|fi |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
        ra   Tr   
setdefaultr   rD   rb   kwargsr(   r(   r,   r9   Q     zSession.getc                 K   r   )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
        ra   TOPTIONSr   r   r(   r(   r,   options\  r   zSession.optionsc                 K   r   )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
        ra   Fr   r   r   r(   r(   r,   headg  r   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   )rD   rb   r   r   r   r(   r(   r,   postr  s   zSession.postc                 K      | 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   rD   rb   r   r   r(   r(   r,   put     
zSession.putc                 K   r   )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   r(   r(   r,   patch  r   zSession.patchc                 K   s   | j d|fi |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
        DELETEr   r   r(   r(   r,   delete  s   zSession.deletec                 K   s  | d| j | d| j | d| j d|vr#t|| j| j|d< t|tr,t	d|
dd}|d}|j}| j|jd}t }|j|fi |}t | }	t|	d	|_td
||fi |}|jrt|jD ]}
t| j|
j|
j qht| j||j |r| j||fi |}dd |D }ng }|r|d| |
 }||_|szt| j||fddi||_W n	 ty   Y nw |s|j |S )zISend a given PreparedRequest.

        :rtype: requests.Response
        r\   r^   r_   r`   z#You can only send PreparedRequests.ra   T)rb   )secondsr8   c                 S   s   g | ]}|qS r(   r(   )r)   rE   r(   r(   r,   r-     s    z Session.send.<locals>.<listcomp>r   r   )r   r\   r^   r_   r"   r`   r   r.   r   
ValueErrorrv   r9   r   get_adapterrb   preferred_clockr~   r   elapsedr   re   r   ry   r   rh   r   insertnext_nextStopIterationrf   )rD   r   r   ra   r\   r   adapterstartrr   rE   genre   r(   r(   r,   r~     sN   




zSession.sendc           
      C   s   | j r9|dur|dnd}t||d}| D ]
\}}	|||	 q|du s+|du r9tjdp8tjdp8|}t|| j}t|| j	}t|| j
}t|| j}||||dS )z^
        Check the environment and merge it with some settings.

        :rtype: dict
        Nno_proxy)r   TREQUESTS_CA_BUNDLECURL_CA_BUNDLE)r`   r\   r^   r_   )r   r9   r   r0   r   osenvironr7   r`   r\   r^   r_   )
rD   rb   r`   r\   r^   r_   r   env_proxiesr*   r+   r(   r(   r,   r     s    
z"Session.merge_environment_settingsc                 C   s<   | j  D ]\}}| | r|  S qtd|)z~
        Returns the appropriate connection adapter for the given URL.

        :rtype: requests.adapters.BaseAdapter
        z&No connection adapters were found for )r   r0   lowerrm   r   )rD   rb   prefixr   r(   r(   r,   r     s
   zSession.get_adapterc                 C   s   | j  D ]}|  qdS )z+Closes all adapters and as such the sessionN)r   valuesrl   )rD   r+   r(   r(   r,   rl     s   
zSession.closec                    s>   || j  <  fdd| j D }|D ]}| j || j |< q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(   )rj   )r)   r*   r   r(   r,   r-   %  s     z!Session.mount.<locals>.<listcomp>N)r   rv   )rD   r   r   keys_to_mover6   r(   r   r,   r     s
   
zSession.mountc                    s    fdd j D }|S )Nc                    s   i | ]	}|t  |d qS r'   )getattr)r)   attrr   r(   r,   
<dictcomp>+  s    z(Session.__getstate__.<locals>.<dictcomp>)	__attrs__)rD   stater(   r   r,   __getstate__*  s   zSession.__getstate__c                 C   s"   |  D ]
\}}t| || qd S r'   )r0   setattr)rD   r   r   valuer(   r(   r,   __setstate__.  s   zSession.__setstate__)NNNNNNNTNNNNNNr   r'   )r   r   r   __doc__r   r   r   r   r   r   r9   r   r   r   r   r   r   r~   r   r   rl   r   r   r   r(   r(   r(   r,   r   d  sH    =/
]



M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,   session3  s   r   )<r   r   systimecollectionsr   datetimer   _internal_utilsr   r   r   r   r   compatr   r	   r
   r   ry   r   r   r   r   
exceptionsr   r   r   r   r   r   r   modelsr   r   r   r   status_codesr   
structuresr   utilsr   r   r   r   r    r!   r"   r#   r$   r%   platformperf_counterr   r7   r<   r=   r   r   r(   r(   r(   r,   <module>   s:    0
 {   R