^V_@sdZddlZddlmZddlmZddlmZddlmZm Z m Z m Z ddl m Z mZmZmZdd lmZmZmZdd lmZmZdd lmZmZmZdd lmZmZmZm Z dd l!m"Z"ddl#m$Z$ddl%m&Z&ddlm'Z'm(Z(m)Z)m*Z*m+Z+ddl,m-Z-ddlm.Z.dZ/e ddZ0e ddZ1Gddde2Z3Gddde3Z4ddZ5dS)z requests.session ~~~~~~~~~~~~~~~~ This module provides a Session object to manage and persist settings across requests (cookies, auth, proxies). N)Mapping)datetime)_basic_auth_str) cookielib OrderedDicturljoinurlparse)cookiejar_from_dictextract_cookies_to_jarRequestsCookieJar merge_cookies)RequestPreparedRequestDEFAULT_REDIRECT_LIMIT) default_hooks dispatch_hook)to_key_val_listdefault_headersto_native_string)TooManyRedirects InvalidSchemaChunkedEncodingErrorContentDecodingError)RecentlyUsedContainer)CaseInsensitiveDict) HTTPAdapter) requote_uriget_environ_proxiesget_netrc_authshould_bypass_proxiesget_auth_from_url)codes)REDIRECT_STATIicCs|dkr|S|dkr |St|to;t|tsB|S|t|}|jt|dd|jD}x|D] }||=qW|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` NcSs(g|]\}}|dkr|qS)N).0kvr$r$Cs z!merge_setting..) isinstancerrupdateitems)request_settingsession_setting dict_classmerged_setting none_keyskeyr$r$r( merge_setting*s    r3cCsZ|dks!|jdgkr%|S|dksF|jdgkrJ|St|||S)z Properly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. Nresponse)getr3) request_hooks session_hooksr/r$r$r( merge_hooksJs !!r8c@sCeZdZdddddddZddZdd ZdS) SessionRedirectMixinFNTcks@d} g} x-|jr;|j} | dkrU| j|t| } | |_ny |jWn.tttfk r|j j ddYnX| |j krt d|j n|j |jd} |j}| jdr t|j}d|j| f} nt| }|j} |jsFt|jt| } n t| } t| | _|jr|j| jkr| j|j|j>> import requests >>> s = requests.Session() >>> s.get('http://httpbin.org/get') Or as a context manager:: >>> with requests.Session() as s: >>> s.get('http://httpbin.org/get') rQrcauthrDhooksparamsrBrCprefetchadaptersr@rvrOcCst|_d|_i|_t|_i|_d|_d|_d|_ t |_ d|_ t i|_t|_|jdt|jdttt|_dS)NFTzhttps://zhttp://)rrQrrDrrrr@rBrCrrOrvr rcrrmountrrREDIRECT_CACHE_SIZErY)rhr$r$r(__init__#s           zSession.__init__cCs|S)Nr$)rhr$r$r( __enter__ZszSession.__enter__cGs|jdS)N)rP)rhargsr$r$r(__exit__]szSession.__exit__cCs*|jp i}t|tjs0t|}nttt|j|}|j}|jr| r|j rt |j }nt }|j d|j jd|j d|jd|jd|jdt|j|jdtdt|j|jd t||jd |d t|j|j |S) abConstructs 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. rRrTfilesdatajsonrQr/rrrcr)rcr*r CookieJarr r r rrvrrTrpreparerRupperrrrr3rQrrr8r)rhrtrcmerged_cookiesrpr$r$r(prepare_request`s*        zSession.prepare_requestNTcCstd|jd|d|d|d|p-id|d|p?id|d |d | }|j|}| poi} |j|j| | ||}i| d 6| d 6}|j||j||}|S) aqConstructs 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, 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) whether the SSL cert will be verified. A CA_BUNDLE path can also be provided. Defaults to ``True``. :param cert: (optional) if String, path to ssl client cert file (.pem). If Tuple, ('cert', 'key') pair. rRrTrQrrrrrrcrrArE)rrrmerge_environment_settingsrTr+rg)rhrRrTrrrQrcrrrArErDrr@rBrCrrjprepsettings send_kwargsrir$r$r(rts*2       zSession.requestcKs#|jdd|jd||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. rETr=)r{rt)rhrTkwargsr$r$r(r5sz Session.getcKs#|jdd|jd||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. rETOPTIONS)r{rt)rhrTrr$r$r(optionsszSession.optionscKs#|jdd|jd||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. rEFr<)r{rt)rhrTrr$r$r(headsz Session.headcKs|jd|d|d||S)aSends a POST request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, 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. r>rr)rt)rhrTrrrr$r$r(posts z Session.postcKs|jd|d||S)a7Sends a PUT request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. PUTr)rt)rhrTrrr$r$r(putsz Session.putcKs|jd|d||S)a9Sends a PATCH request. Returns :class:`Response` object. :param url: URL for the new :class:`Request` object. :param data: (optional) Dictionary, bytes, or file-like object to send in the body of the :class:`Request`. :param \*\*kwargs: Optional arguments that ``request`` takes. PATCHr)rt)rhrTrrr$r$r(patch sz Session.patchcKs|jd||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. DELETE)rt)rhrTrr$r$r(deleteszSession.deletecKs|jd|j|jd|j|jd|j|jd|jt|tsjtdnt}xT|j |j kr|j |j |j j |j }||krPn||_ qvW|j dd}|j d}|j}|jd|j }tj} |j||} tj| | _td || |} | jrx-| jD]} t|j| j| jqbWnt|j|| j|j| ||} |rd d | Dng} | r| jd | | j } | | _n|s| jn| S) zSend a given PreparedRequest.r@rBrCrDz#You can only send PreparedRequests.rETrTr4cSsg|] }|qSr$r$)r%rir$r$r(r)Us z Session.send..r)r{r@rBrCrDr*r ValueErrorsetrTrYaddr5popr get_adapterrutcnowrgelapsedrrJr rcrtrMrrinsertrK)rhrtr checked_urlsnew_urlrEr@radapterstartrrigenrJr$r$r(rgsD          z Session.sendc Cs|jrt|pi}x*|jD]\}}|j||q(W|dks`|dkrtjjdptjjd}qnt||j}t||j }t||j }t||j }i|d6|d6|d6|d6S) z6Check the environment and merge it with some settings.TNREQUESTS_CA_BUNDLECURL_CA_BUNDLErBrDr@rC) rvrr,r{osenvironr5r3rDr@rBrC) rhrTrDr@rBrC env_proxiesr&r'r$r$r(rds z"Session.merge_environment_settingscCsMx6|jjD]%\}}|jj|r|SqWtd|dS)z=Returns the appropriate connection adapter for the given URL.z*No connection adapters were found for '%s'N)rr,lowerrSr)rhrTprefixrr$r$r(r|szSession.get_adaptercCs(x!|jjD]}|jqWdS)z+Closes all adapters and as such the sessionN)rvaluesrP)rhr'r$r$r(rPsz Session.closecsW||j<fdd|jD}x'|D]}|jj||j|.N)rr)rhrr keys_to_mover2r$)rr(rs  z Session.mountcs9tfddjD}tj|d<|S)Nc3s'|]}|t|dfVqdS)N)getattr)r%attr)rhr$r( sz'Session.__getstate__..rY)dict __attrs__rY)rhstater$)rhr( __getstate__s"zSession.__getstate__cCs||jdi}x*|jD]\}}t|||qWtt|_x'|jD]\}}||j| s. """(