|
Server : Apache System : Linux server.mata-lashes.com 3.10.0-1160.90.1.el7.x86_64 #1 SMP Thu May 4 15:21:22 UTC 2023 x86_64 User : matalashes ( 1004) PHP Version : 8.1.29 Disable Function : NONE Directory : /usr/local/lib/python3.6/site-packages/requests/__pycache__/ |
Upload File : |
3
F�Kd�t � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z ddl
m Z m Z m
Z
mZmZ ddlmZmZmZmZ dd lmZmZmZ dd
lmZmZ dd l m Z dd l m Z m Z m!Z! dd
l"m#Z#m$Z$m%Z%m&Z& ddl'm(Z( ddl)m*Z* ddl m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1 ddl2m3Z3 ddlm4Z4 ej5dk�rZy
ej6Z7W n e8k
�rV ej9Z7Y nX nejZ7efdd�Z:efdd�Z;G dd� de<�Z=G dd� de=�Z>d d � Z?dS ) 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�resolve_proxies)�codes)�REDIRECT_STATI�win32c C st |dkr | S | dkr|S t |t�o*t | t�s0| S |t|��}|jt| �� dd� |j� D �}x|D ]
}||= qbW |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`
Nc S s g | ]\}}|d kr|�qS )N� )�.0�k�vr( r( �5/tmp/pip-build-8nxjc3nm/requests/requests/sessions.py�
<listcomp>J s z!merge_setting.<locals>.<listcomp>)�
isinstancer
r �update�items)�request_setting�session_setting�
dict_class�merged_setting� none_keys�keyr( r( r, �
merge_setting2 s
r7 c C s@ |dks|j d�g kr| S | dks0| j d�g kr4|S t| ||�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)�getr7 )�
request_hooks�
session_hooksr3 r( r( r, � merge_hooksQ s
r< c @ s> e Zd Zdd� Zdd� Zddd �Zd
d � Zd d
� Zdd� ZdS )�SessionRedirectMixinc C s, |j r(|jd }tr |jd�}t|d�S dS )z7Receives a Response. Returns a redirect URI or ``None``�location�latin1�utf8N)� is_redirect�headersr �encoder )�self�respr> r( r( r, �get_redirect_targetb s
z(SessionRedirectMixin.get_redirect_targetc C s� t |�}t |�}|j|jkr dS |jdkrL|jdkrL|jdkrL|jd krLdS |j|jk}|j|jk}tj|jd�df}| r�|j|kr�|j|kr�dS |p�|S )
zFDecide whether Authorization header should be removed when redirectingT�http�P N�https� F)rH N)rJ N)r �hostname�scheme�portr r9 )rD �old_url�new_url�
old_parsed�
new_parsed� changed_port�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|� |
dd� |_y
|j W n( tt t
fk
rv |j j dd� Y nX t
|j�| jkr�tdj| j�|d��|j� | jd�r�t|j�}djt|j�| g�} t| �}|jd kr�| r�|j| d
�}n |jr�|j} |j� } |j�s t|jt| ��} nt| �} t| �|
_| j|
|� |j t j t j fk�rxd}x |D ]}|
j j!|d� �qZW d|
_"|
j }|j!dd� t#|
j$||j � t%|
j$| j&� |
j'|
j$� | j(|
|�}| j)|
|� |
j*dk �o�d |k�p�d
|k}|�r�t+|
� |
}|�r
|V q | j,|f|||||dd�| ��}t#| j&|
|j � | j |�} |V q W dS )zBReceives a Response. Returns a generator of Responses or Requests.r NF)�decode_contentzExceeded {} redirects.)r8 z//�:� )�fragment�Content-Length� Content-Type�Transfer-Encoding�Cookie)�stream�timeout�verify�cert�proxies�allow_redirects)rZ r[ r\ )-rF r �urlrY �copy�append�history�contentr r � RuntimeError�raw�read�len�
max_redirectsr �format�close�
startswith�joinr rL �_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` ra rb �yield_requests�adapter_kwargs�histrd Zprevious_fragment�prepared_request� parsed_rurl�parsed�purged_headers�headerrB �
rewindabler( r( r, �resolve_redirects� sv
z&SessionRedirectMixin.resolve_redirectsc C sR |j }|j}d|kr*| j|jj|�r*|d= | jr8t|�nd}|dk rN|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.
�
AuthorizationN)rB rd rU �request� trust_envr � prepare_auth)rD r� r8 rB rd �new_authr( r( r, r � s z!SessionRedirectMixin.rebuild_authc C sz |j }t|j�j}t||| j�}d|kr.|d= yt|| �\}}W n tk
r^ d\}}Y nX |rv|rvt||�|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
zProxy-AuthorizationN)NN) rB r rd rL r$ r� r" �KeyErrorr )rD r� rb rB rL � new_proxies�username�passwordr( r( r, r~ s z$SessionRedirectMixin.rebuild_proxiesc C sX |j }|jtjkr |dkr d}|jtjkr6|dkr6d}|jtjkrN|dkrNd}||_ dS )z�When being redirected we may want to change the method of the request
based on certain specs or browser behavior.
�HEAD�GET�POSTN)�methodrv r% � see_other�found�moved)rD r� r8 r� r( r( r, ru - s z#SessionRedirectMixin.rebuild_method)FNTNNF) �__name__�
__module__� __qualname__rF rU r� r r~ ru r( r( r( r, r= ` s
m r= c @ s� e Zd ZdZdddddddd d
d d d
g Zdd� Zdd� Zdd� Zdd� Zd6dd�Z dd� Z
d d � Z d d � Z d7d d!�Z
d8d"d#�Zd9d$d%�Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� ZdS ):�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 r| �authrb �hooks�paramsr` ra �adaptersr^ r� rm c C sr t � | _d | _i | _t� | _i | _d| _d| _d | _ t
| _ d| _ t
i �| _t� | _| jdt� � | jdt� � d S )NFTzhttps://zhttp://)r rB r� rb r r� r� r^ r` ra r rm r� r r| r r� �mountr )rD r( r( r, �__init__] s
zSession.__init__c C s | S )Nr( )rD r( r( r, � __enter__� s zSession.__enter__c G s | j � d S )N)ro )rD �argsr( r( r, �__exit__� s zSession.__exit__c
C s� |j pi }t|tj�s t|�}ttt� | j �|�}|j}| jrV| rV| j rVt |j
�}t � }|j |j
j� |j
|j|j|jt|j| jtd�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� rd �files�data�jsonrB r� r� r| r� )r| r. r � CookieJarr r r
r� r� r rd r �preparer� �upperr� r� r� r7 rB r r� r< r� )rD r� r| �merged_cookiesr� �pr( r( r, �prepare_request� s*
zSession.prepare_requestNTc C st t |j� ||||pi ||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� rd rB r� r� r� r� r� r| r� )r_ rc )r r� r� �merge_environment_settingsrd r/ r� )rD r� rd r� r� rB r| r� r� r_ rc rb r� r^ r` ra r� r� �prep�settings� send_kwargsrE r( r( r, r� � s( .
zSession.requestc K s |j dd� | jd|f|�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.
:rtype: requests.Response
rc Tr� )�
setdefaultr� )rD rd �kwargsr( r( r, r9 s z Session.getc K s |j dd� | jd|f|�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.
:rtype: requests.Response
rc T�OPTIONS)r� r� )rD rd r� r( r( r, �options s zSession.optionsc K s |j dd� | jd|f|�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.
:rtype: requests.Response
rc Fr� )r� r� )rD rd r� r( r( r, �head+ 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� )rD rd r� r� r� r( r( r, �post6 s z Session.postc K s | j d|fd|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 rd r� r� r( r( r, �putC s
z Session.putc K s | j d|fd|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� )rD rd r� r� r( r( r, �patchO s
z
Session.patchc K s | j d|f|�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.
:rtype: requests.Response
�DELETE)r� )rD rd r� r( r( r, �delete[ s zSession.deletec
K s� |j d| j� |j d| j� |j d| j� d|krFt|| j| j�|d< t|t�rXt d��|j
dd�}|j d�}|j }| j
|jd�}t� }|j|f|�}t� | } t| d �|_td
||f|�}|jr�x |jD ]}
t| j|
j|
j� q�W t| j||j� |�r| j||f|�} d d � | D �} ng } | �r>| jd
|� | j
� }| |_|�s~y"t| j||fddi|���|_ W n t k
�r| Y nX |�s�|j |S )zISend a given PreparedRequest.
:rtype: requests.Response
r^ r` ra rb z#You can only send PreparedRequests.rc T)rd )�secondsr8 c S s g | ]}|�qS r( r( )r) rE r( r( r, r- � s z Session.send.<locals>.<listcomp>r r� ) r� r^ r` ra r$ rb r� r. r �
ValueErrorry r9 r� � get_adapterrd �preferred_clockr� r �elapsedr rg r r| r� rj r� �insert�next�_next�
StopIterationrh )
rD r� r� rc r^ r� �adapter�start�rr� rE �genrg r( r( r, r� e sJ
"z Session.sendc
C s� | j rr|dk r|jd�nd}t||d�}x |j� D ]\}} |j|| � q2W |dksZ|dkrrtjjd�pptjjd�}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` rb r^ ra ) r� r9 r r0 r� �os�environr7 rb r^ r` ra )
rD rd rb r^ r` ra r� � 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 tdj|���dS )z~
Returns the appropriate connection adapter for the given URL.
:rtype: requests.adapters.BaseAdapter
z*No connection adapters were found for {!r}N)r� r0 �lowerrp r rn )rD rd �prefixr� r( r( r, r� � s zSession.get_adapterc C s x| j j� D ] }|j� q W dS )z+Closes all adapters and as such the sessionN)r� �valuesro )rD r+ r( r( r, ro � s z
Session.closec sB || j � < � fdd�| j D �}x |D ]}| j j|�| j |< q$W dS )zwRegisters a connection adapter to a prefix.
Adapters are sorted in descending order by prefix length.
c s g | ]}t |�t � �k r|�qS r( )rl )r) r* )r� r( r, r- � s z!Session.mount.<locals>.<listcomp>N)r� ry )rD r� r� � keys_to_mover6 r( )r� r, r� � s
z
Session.mountc s � fdd�� j D �}|S )Nc s i | ]}t � |d �|�qS )N)�getattr)r) �attr)rD r( r, �
<dictcomp>� s z(Session.__getstate__.<locals>.<dictcomp>)� __attrs__)rD �stater( )rD r, � __getstate__� s zSession.__getstate__c C s& x |j � D ]\}}t| ||� q
W d S )N)r0 �setattr)rD r� r� �valuer( r( r, � __setstate__� s zSession.__setstate__)NNNNNNNTNNNNNN)NN)N)N)r� r� r� �__doc__r� r� r� r� r� r� r9 r� r� r� r� r� r� r� r� r� ro r� r� r� r( r( r( r, r� D s2 >)
I
N 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
r| 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# r$ � status_codesr% r& �platform� perf_counterr� �AttributeError�clockr7 r< �objectr= r� r� r( r( r( r, �<module> sB $
e 6