3
Rer @ 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/m0Z0 ddl1m2Z2 ddlm3Z3 ej4dkrVy
ej5Z6W n e7k
rR ej8Z6Y nX nejZ6efddZ9efddZ:G dd de;ZdS ) z
requests.session
~~~~~~~~~~~~~~~~
This module provides a Session object to manage and persist settings across
requests (cookies, auth, proxies).
N) timedelta) OrderedDict )_basic_auth_str) cookielibis_py3urljoinurlparseMapping)cookiejar_from_dictextract_cookies_to_jarRequestsCookieJar
merge_cookies)RequestPreparedRequestDEFAULT_REDIRECT_LIMIT)
default_hooks
dispatch_hook)to_native_string)to_key_val_listdefault_headers
DEFAULT_PORTS)TooManyRedirects
InvalidSchemaChunkedEncodingErrorContentDecodingError)CaseInsensitiveDict) HTTPAdapter) requote_uriget_environ_proxiesget_netrc_authshould_bypass_proxiesget_auth_from_url rewind_body)codes)REDIRECT_STATIwin32c C st |dkr | S | dkr|S t |to*t | ts0| S |t|}|jt| dd |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 kr|qS )N ).0kvr' r' /builddir/build/BUILDROOT/alt-python36-pip-20.2.4-5.el9.x86_64/opt/alt/python36/lib/python3.6/site-packages/pip/_vendor/requests/sessions.py
J s z!merge_setting..)
isinstancer
r updateitems)request_settingsession_setting
dict_classmerged_setting none_keyskeyr' r' r+
merge_setting2 s
r6 c C s@ |dks|j dg kr| S | dks0| j dg kr4|S t| ||S )zProperly merges both requests and session hooks.
This is necessary because when request_hooks == {'response': []}, the
merge breaks Session hooks entirely.
Nresponse)getr6 )
request_hooks
session_hooksr2 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|dS dS )z7Receives a Response. Returns a redirect URI or ``None``locationlatin1utf8N) is_redirectheadersr encoder )selfrespr= 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|jddf}| r|j|kr|j|krdS |p|S )
zFDecide whether Authorization header should be removed when redirectingThttpP Nhttps F)rG N)rI N)r hostnameschemeportr r8 )rC old_urlnew_url
old_parsed
new_parsed changed_portchanged_scheme default_portr' r' r+ should_strip_authw s
z&SessionRedirectMixin.should_strip_authFNTc k sR g }
| j |} t|jj} x0| rL|j }
|
j| |
dd |_y
|j W n( tt t
fk
rv |j j dd Y nX t
|j| jkrtdj| j|d|j | jdrt|j}djt|j| g} t| }|jd kr| r|j| d
}n |jr|j} |j } |js t|jt| } nt| } t| |
_| j|
| |j t j t j fkrxd}x |D ]}|
j j!|d qZW d|
_"|
j }|j!dd t#|
j$||j t%|
j$| j& |
j'|
j$ | j(|
|}| j)|
| |
j*dk od |kpd
|k}|rt+|
|
}|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.)r7 z//: )fragmentContent-Length Content-TypeTransfer-EncodingCookie)streamtimeoutverifycertproxiesallow_redirects)rY rZ r[ )-rE r urlrX copyappendhistorycontentr r RuntimeErrorrawreadlen
max_redirectsr formatclose
startswithjoinr rK _replacegeturlnetlocr r rebuild_method status_coder$ temporary_redirectpermanent_redirectrA popbodyr _cookiesr cookiesprepare_cookiesrebuild_proxies rebuild_auth_body_positionr# send)rC rD reqr] r^ r_ r` ra yield_requestsadapter_kwargshistrc previous_fragmentprepared_request parsed_rurlparsedpurged_headersheaderrA
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 )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)rA rc rT request trust_envr prepare_auth)rC r r7 rA rc new_authr' r' r+ r~ s z!SessionRedirectMixin.rebuild_authc
C s |dk r |ni }|j }|j}t|j}|j }|jd}t||d}| jr~| r~t||d} | j|| jd}
|
r~|j ||
d|kr|d= yt
|| \} } W n t k
r d\} } Y nX | 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
Nno_proxy)r allzProxy-Authorization)NN)
rA rc r rK rd r8 r! r r
setdefaultr" KeyErrorr )
rC r ra rA rc rK new_proxiesr bypass_proxyenviron_proxiesproxyusernamepasswordr' r' r+ r} s*
z$SessionRedirectMixin.rebuild_proxiesc C sX |j }|jtjkr |dkr d}|jtjkr6|dkr6d}|jtjkrN|dkrNd}||_ dS )zWhen being redirected we may want to change the method of the request
based on certain specs or browser behavior.
HEADGETPOSTN)methodru r$ see_otherfoundmoved)rC r r7 r r' r' r+ rt : s z#SessionRedirectMixin.rebuild_method)FNTNNF) __name__
__module__ __qualname__rE rT r r~ r} rt r' r' r' r+ r< ` s
m)r< c @ s e Zd ZdZdddddddd d
d d d
g Zdd Zdd Zdd Zdd Zd6ddZ 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')
Or as a context manager::
>>> with requests.Session() as s:
... s.get('https://httpbin.org/get')
rA r{ authra hooksparamsr_ r` adaptersr] r rl c C sr t | _d | _i | _t | _i | _d| _d| _d | _ t
| _ d| _ t
i | _t | _| jdt | jdt d S )NFTzhttps://zhttp://)r rA r ra r r r r] r_ r` r rl r r r{ r r mountr )rC r' r' r+ __init__j s
zSession.__init__c C s | S )Nr' )rC r' r' r+ __enter__ s zSession.__enter__c G s | j d S )N)rn )rC argsr' r' r+ __exit__ s zSession.__exit__c
C s |j pi }t|tjs t|}ttt | j |}|j}| jrV| rV| j rVt |j
}t }|j |j
j |j
|j|j|jt|j| jtdt|j| jt|| j|t|j| jd
|S )a Constructs 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.
:rtype: requests.PreparedRequest
)r2 )
r rc filesdatajsonrA r r r{ r )r{ r- r CookieJarr r r
r r r rc r preparer upperr r r r6 rA r r r; r )rC 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 )a Constructs 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, 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) ` 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``.
:param cert: (optional) if String, path to ssl client cert file (.pem).
If Tuple, ('cert', 'key') pair.
:rtype: requests.Response
)
r rc rA r r r r r r{ r )r^ rb )r r r merge_environment_settingsrc r. r )rC r rc r r rA r{ r r r^ rb ra r r] r_ r` r r prepsettings send_kwargsrD r' r' r+ r s( )
zSession.requestc K s |j dd | jd|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
rb Tr )r r )rC rc kwargsr' r' r+ r8 s z Session.getc K s |j dd | jd|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
rb TOPTIONS)r r )rC rc r r' r' r+ options! s zSession.optionsc K s |j dd | jd|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
rb Fr )r r )rC rc 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 )rC rc r r r r' r' r+ post7 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 )rC rc r r r' r' r+ putD 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 )rC rc r r r' r' r+ patchP 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 )rC rc r r' r' r+ delete\ s zSession.deletec
K s |j d| j |j d| j |j d| j |j d| j t|trJtd|jdd}|j d}|j
}| j |j d}t
}|j|f|}t
| } t| d |_td
||f|}|jrx |jD ]}
t| j|
j|
j qW t| j||j |r | j||f|} d d | D } ng } | r0| jd
| | j }| |_|spy"t| j||fddi||_W n tk
rn Y nX |s||j |S )zISend a given PreparedRequest.
:rtype: requests.Response
r] r_ r` ra z#You can only send PreparedRequests.rb T)rc )secondsr7 c S s g | ]}|qS r' r' )r( rD r' r' r+ r, s z Session.send..r r ) r r] r_ r` ra r- r
ValueErrorrx r8 r get_adapterrc preferred_clockr r elapsedr rf r r{ r ri r insertnext_next
StopIterationrg )
rC r r rb r] r adapterstartrr rD genrf r' r' r+ r f sF
"z Session.sendc
C s | j rr|dk r|jdnd}t||d}x |j D ]\}} |j|| q2W |dksZ|dkrrtjjdpptjjd}t|| j}t|| j }t|| j
}t|| j }||||dS )z^
Check the environment and merge it with some settings.
:rtype: dict
Nr )r TREQUESTS_CA_BUNDLECURL_CA_BUNDLE)r_ ra r] r` ) r r8 r r/ r osenvironr6 ra r] r_ r` )
rC rc ra r] r_ r` 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 r/ lowerro r rm )rC rc 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 valuesrn )rC r* r' r' r+ rn 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' )rk )r( r) )r r' r+ r, s z!Session.mount..N)r rx )rC r r keys_to_mover5 r' )r r+ r s
z
Session.mountc s fdd j D }|S )Nc s i | ]}t |d |qS )N)getattr)r( attr)rC r' r+
s z(Session.__getstate__..) __attrs__)rC stater' )rC r+ __getstate__ s zSession.__getstate__c C s& x |j D ]\}}t| || q
W d S )N)r/ setattr)rC r r valuer' r' r+ __setstate__ s zSession.__setstate__)NNNNNNNTNNNNNN)NN)N)N)r r r __doc__r r r r r r r8 r r r r r r r r r rn r r r r' r' r' r+ r Q s2 7)
D
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 systimedatetimer 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# status_codesr$ r% platform perf_counterr AttributeErrorclockr6 r; objectr< r r r' r' r' r+ sB
r '