)X d@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)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` NcSs(g|]\}}|dkr|qS)N).0kvr$r$A/home/ubuntu/projects/ifolica/build/requests/requests/sessions.py As z!merge_setting..) isinstancerrupdateitems)request_settingsession_setting dict_classmerged_settingZ none_keyskeyr$r$r( merge_setting)s    r2cCsZ|dks!|jdgkr%|S|dksF|jdgkrJ|St|||S)zProperly merges both requests and session hooks. This is necessary because when request_hooks == {'response': []}, the merge breaks Session hooks entirely. Nresponse)getr2) request_hooks session_hooksr/r$r$r( merge_hooksHs !!r7c@sOeZdZdddddddZddZdd Zd d ZdS) SessionRedirectMixinFNTcksd} g} x|jr|j} | dkrU| j|t| } | |_ny |jWn.tttfk r|j j ddYnX| |j krt d|j d|n|j |jd} | jdrt|j}d|j| f} nt| }|j} |jsCt|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') rOr]authrChooksparamsrArBprefetchadaptersr?rnrMcCst|_d|_i|_t|_i|_d|_d|_d|_ t |_ d|_ t i|_t|_|jdt|jdttt|_dS)NFTzhttps://zhttp://)rrOrrCrrrr?rArBrrMrnr r]rrmountrrREDIRECT_CACHE_SIZErU)rbr$r$r(__init__'s           zSession.__init__cCs|S)Nr$)rbr$r$r( __enter__`szSession.__enter__cGs|jdS)N)rN)rbargsr$r$r(__exit__cszSession.__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) aConstructs 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 r}rQfilesdatajsonrOr/rrr]r)r]r*r CookieJarr r r rrnrrQrpreparer}upperrrrr2rOrrr7r)rbrlr]merged_cookiesrpr$r$r(prepare_requestfs*        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) aConstructs 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. :rtype: requests.Response r}rQrOrrrrrr]rr@rD)rrrmerge_environment_settingsrQr+ra)rbr}rQrrrOr]rrr@rDrCrr?rArBrrdprepZsettings send_kwargsrcr$r$r(rls*3       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. :rtype: requests.Response rDTr{)rtrl)rbrQkwargsr$r$r(r4sz 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. :rtype: requests.Response rDTOPTIONS)rtrl)rbrQrr$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. :rtype: requests.Response rDFrz)rtrl)rbrQrr$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. :rtype: requests.Response r|rr)rl)rbrQrrrr$r$r(posts z Session.postcKs|jd|d||S)aYSends 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. :rtype: requests.Response PUTr)rl)rbrQrrr$r$r(put s z Session.putcKs|jd|d||S)a[Sends 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. :rtype: requests.Response PATCHr)rl)rbrQrrr$r$r(patchs z 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. :rtype: requests.Response DELETE)rl)rbrQrr$r$r(delete"szSession.deletecKs|jd|j|jd|j|jd|j|jd|jt|trjtdn|jdd}|j d}|j }|rt }xW|j |j kr|j|j |j j |j }||krPn||_ qWn|jd|j }tj} |j||} tj| | _td || |} | jrx-| jD]} t|j| j| jqkWnt|j|| j|j| ||} |rd d | Dng} | r | jd | | j} | | _n|s| jn| S) zR Send a given PreparedRequest. :rtype: requests.Response r?rArBrCz#You can only send PreparedRequests.rDTrQr3cSsg|] }|qSr$r$)r%rcr$r$r(r)is z Session.send..r)rtr?rArBrCr*r ValueErrorrYr4rsetrQrUadd get_adapterrutcnowraelapsedrrHr r]rlrKrjinsertrI)rbrlrrDr?rZ checked_urlsZnew_urladapterstartrrcgenrHr$r$r(ra,sF         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) z^ Check the environment and merge it with some settings. :rtype: dict TNREQUESTS_CA_BUNDLECURL_CA_BUNDLErArCr?rB) rnrr,rtosenvironr4r2rCr?rArB) rbrQrCr?rArB env_proxiesr&r'r$r$r(rxs z"Session.merge_environment_settingscCsMx6|jjD]%\}}|jj|r|SqWtd|dS)z~ Returns the appropriate connection adapter for the given URL. :rtype: requests.adapters.BaseAdapter z*No connection adapters were found for '%s'N)rr,lowerrPr)rbrQprefixrr$r$r(rszSession.get_adaptercCs(x!|jjD]}|jqWdS)z+Closes all adapters and as such the sessionN)rvaluesrN)rbr'r$r$r(rNsz Session.closecsW||j<fdd|jD}x'|D]}|jj||j|.N)rrY)rbrr keys_to_mover1r$)rr(rs  z Session.mountcs9tfddjD}tj|d<|S)Nc3s'|]}|t|dfVqdS)N)getattr)r%attr)rbr$r( sz'Session.__getstate__..rU)dict __attrs__rU)rbstater$)rbr( __getstate__s"zSession.__getstate__cCs||jdi}x*|jD]\}}t|||qWtt|_x'|jD]\}}||j| s. """(