3
V'íct ã @ 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 ej5dkrZy
ej6Z7W n e8k
rV ej9Z7Y nX nejZ7efddZ:efddZ;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 |to*t | ts0| 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-gk9425m9/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 dg kr| S | dks0| j dg 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|dS 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|jddf}| r|j|kr|j|krdS |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_parsedZ changed_portZchanged_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 | jdrÌt|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 oèd |kpè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)rX rY rZ )-rF r ÚurlrW Ú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^ r_ r` Úyield_requestsÚadapter_kwargsÚhistrb 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 rb rS ÚrequestÚ trust_envr Ú prepare_auth)rD r r8 rB rb Únew_authr( r( r, r} þ s z!SessionRedirectMixin.rebuild_authc C sz |j }t|jj}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 rb rL r$ r r" ÚKeyErrorr )rD r r` 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 )zWhen being redirected we may want to change the method of the request
based on certain specs or browser behavior.
ÚHEADÚGETÚPOSTN)Úmethodrt r% Ú see_otherÚfoundÚmoved)rD r r8 r r( r( r, rs - s z#SessionRedirectMixin.rebuild_method)FNTNNF) Ú__name__Ú
__module__Ú __qualname__rF rS r r} r| rs 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')
<Response [200]>
Or as a context manager::
>>> with requests.Session() as s:
... s.get('https://httpbin.org/get')
<Response [200]>
rB rz Úauthr` ÚhooksÚparamsr^ r_ Úadaptersr\ r rk 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 r` r r r¡ r\ r^ r_ r rk r r rz 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)rm )rD Ú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 <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 rz r )rz r. r Ú CookieJarr r r
r r r rb r Úpreparer Úupperr¨ r© rª r7 rB r r¡ r< r )rD r rz Ú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 rb rB r¨ r© rª r¡ r rz r )r] ra )r r r° Úmerge_environment_settingsrb r/ r )rD r rb r¡ r© rB rz r¨ r r] ra r` r r\ r^ r_ 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
ra Tr )Ú
setdefaultr )rD rb Ú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
ra TÚOPTIONS)rµ r )rD rb 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
ra Fr )rµ r )rD rb 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 rb 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 rb 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 rb 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 rb 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|trXt 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^ r_ r` z#You can only send PreparedRequests.ra T)rb )Ú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^ r_ r$ r` r r. r Ú
ValueErrorrw r9 r Ú get_adapterrb Úpreferred_clockr r Úelapsedr re r rz r rh r ÚinsertÚnextÚ_nextÚ
StopIterationrf )
rD r r¶ ra r\ r ÚadapterÚstartÚrrÅ rE Úgenre r( r( r, r e sJ
"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
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@ 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 Úlowerrn r rl )rD rb Ú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¢ Úvaluesrm )rD r+ r( r( r, rm Þ 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( )rj )r) r* )rÕ r( r, r- é s z!Session.mount.<locals>.<listcomp>N)r¢ rw )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à rm 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
rz 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