B `R@sHddlZddlZddlZddlZddlZddlZddlZy ddlZWne k r`ddlZYnXddl Z ddl m Z m Z mZmZddlmZmZddlmZmZmZmZmZmZmZmZmZmZmZmZddl m!Z!ddl"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6ddl7m8Z8dd l9m:Z:m;Z;mGd ddZ?e?Z@dZAdZBGdd d eCZDGdd d eDZEGdddeCZFGdd d eFeDZGddZHd,ddZIGdddeJZKGdddejLZMddZNeNe_OGd d!d!ejLZPd"d#ZQd-d$d%ZRd&d'ZSd(d)ZTGd*d+d+eCZUdS).N)accept_charset_propertyaccept_encoding_propertyaccept_language_propertyaccept_property) CacheControlserialize_cache_control) PY2bytes_native_parse_qsl_textreraise text_type url_encode url_quote url_unquote quote_plusurlparsecgi_FieldStorage)RequestCookies) CHARSET_RE SCHEME_RE converterconverter_dateenviron_getterenviron_decoder parse_auth parse_intparse_int_safe parse_rangeserialize_authserialize_if_range serialize_intserialize_rangeupath_property)IfRangeAnyETagNoETag etag_property)EnvironHeaders)NestedMultiDict MultiDictNoVarsGetDict BaseRequestRequest LegacyRequestc@seZdZddZdS) _NoDefaultcCsdS)Nz (No Default))selfr1r1U/home/kop/projects/devel/pgwui/test_venv/lib/python3.7/site-packages/webob/request.py__repr__Psz_NoDefault.__repr__N)__name__ __module__ __qualname__r4r1r1r1r3r0Osr0z/~!$&'()*+,;=:@) asciizlatin-1latinlatin_1l1latin1z iso-8859-1 iso8859_1 iso_8859_1iso88598859c@s8eZdZdZdZdddZedfddZdddZe d d Z e j d d Z dd dZ dZ e ddZej ddZejddZedZe ddZeddZedZeddZedZeedddeedZed dZed!dZed"dZed#d$Zed%Zeed&e edZ!e"d'd$d(d)Z#e"d*d(d)Z$e#Z%e$Z&ed+d$Z'd,d-Z(dd.d/Z)e e(e)e)e(j*Z+dZ,d0d1Z-d2d3Z.e e-e.e-j*d4Z/e d5d6Z0e d7d8Z1e d9d:Z2e d;d<Z3e d=d>Z4e d?d@Z5e dAdBZ6e dCdDZ7ddFdGZ8ddHdIZ9dJdKZ:dLdMZ;dNdOZdRdSZ?dTdUZ@dVdWZAe e?e@eAe?j*ZBe dXdYZCdZd[ZDd\d]ZEd^d_ZFe eDeEeFeDj*d4ZGe d`daZHe dbdcZIeIj dddcZIeIjdedcZIdfdgZJdhdiZKdjdkZLe eJeKeLZMZNdldmZOdndoZPdpdqZQe eOePeQeOj*d4ZRe drdsZSe dtduZTdvdwZUe dxdyZVe dzd{ZWeWj d|d{ZWd}d~ZXddZYeddEZZe ddZ[e[j ddZ[ddZ\ddZ]ddZ^dddZ_e`ZaebZcedZeefZgeedddeheiZjddZkddZlddZmddZne ekelemekj*d4ZoepdeqdZrepdesddEdZteuedddZveuedddZweuedddZxeedddeyjze{dZ|eeddde edZ}edddZ~eedddeedZedddZeZedddZddZdddZddZeZeddZeddZeddZdddZdZdddZeZddZedddÄZdS)r-i(Nc Kst|tk rtd|f|dk r4td|ft|dk rNtd|ftt|sbtd||j}||d<|r|j}d|kr| d|_ x:| D].\}} t ||std|| ft ||| qWdS)Nz*WSGI environ must be a dict; you passed %rzYou unicode_errors=%r to the Request constructor. Passing a ``unicode_errors`` value to the Request is no longer supported in WebOb 1.2+. This value has been ignored zYou passed decode_param_names=%r to the Request constructor. Passing a ``decode_param_names`` value to the Request is no longer supported in WebOb 1.2+. This value has been ignored zYou passed charset=%r to the Request constructor. As of WebOb 1.2, if your application needs a non-UTF-8 request charset, please construct the request without a charset or with a charset of 'None', then use ``req = req.decode(charset)``environmethodzUnexpected keyword: %s=%r)typedict TypeErrorwarningswarnDeprecationWarning_is_utf8__dict__ __class__poprBitemshasattrsetattr) r2rAcharsetunicode_errorsZdecode_param_nameskwdclsnamevaluer1r1r3__init__cs8    zBaseRequest.__init__cCsf|j||}|tkrt|||kr*|S|s2|St||}trJ||S|tkrV|St|d|S)Nzlatin-1) rAget NoDefaultKeyErrorgetattrrdecode_LATIN_ENCODINGSr )r2keydefaultencattrvalencodingr1r1r3encgets  zBaseRequest.encgetcCsD|rt||}nd}tr*t|||j|<nt||d|j|<dS)Nr8zlatin-1)r[rr rAr\)r2r^rar`rbr1r1r3encsets  zBaseRequest.encsetcCs,|jdkr&t|j}t|r d}||_|jS)NzUTF-8)_charsetdetect_charset_content_type_rawrI)r2rPr1r1r3rPs   zBaseRequest.charsetcCs&t|r d}||jkr"td|dS)NzUTF-8zUse req = req.decode(%r))rIrPrH)r2rPr1r1r3rPs strictc Cs|p|j}|dkr|St||}td|j}|j}|j|j| |j |d}|dkrtt | t |j |_ |S|dkr|S|j}|ddd|d <trt|j|d d }nt|j|d ||d }|||j} | |_| |_| d |S)NzUTF-8z; charset="UTF-8") query_string content_typez!application/x-www-form-urlencodedzmultipart/form-dataCONTENT_LENGTH0 QUERY_STRINGT)fprAkeep_blank_values)rorArprberrorsr)rP TranscoderrsubrgrjrKrAcopytranscode_queryrir r body setdefaultrr body_file transcode_fstellcontent_lengthseek) r2rPrqtZnew_content_typerjr fs_environfsfoutr1r1r3r\sB        zBaseRequest.decodecCsn|jstS|j}|j}|jsj|dk rj|j}|dd\}}||k rft||}t |}||f|d<|}|S)z Input stream of the request (wsgi.input). Setting this property resets the content_length and seekable flag (unlike setting req.body_file_raw). Nzwebob._body_file)rr) is_body_readableioBytesIO body_file_rawr{is_body_seekablerArXLimitedLengthFileBufferedReader)r2r~clenenvwrappedrawr1r1r3rxs   zBaseRequest.body_filecCs.t|trtdd|_||_d|_d|_dS)Nz$Excepted fileobj but received bytes.FT) isinstancebytes ValueErrorr{rrr)r2rVr1r1r3rxs  cCs d|_dS)N)rv)r2r1r1r3rxsz wsgi.inputcCs|js||jS)a Get the body of the request (wsgi.input) as a seekable file-like object. Middleware and routing applications should use this attribute over .body_file. If you access this value, CONTENT_LENGTH will also be updated. )rmake_body_seekabler)r2r1r1r3body_file_seekable"s zBaseRequest.body_file_seekablezwebob.url_encodingzUTF-8zwsgi.url_schemeREQUEST_METHODGETSERVER_PROTOCOLrkz14.13intZ REMOTE_USERZ REMOTE_HOST REMOTE_ADDRrnrm SERVER_NAME SERVER_PORT SCRIPT_NAME url_encoding)r` PATH_INFO CONTENT_TYPEcCs|jdddS)aUReturn the content type, but leaving off any parameters (like charset, but also things like the type in ``application/atom+xml; type=entry``) If you set this property, you can include parameters, or if you don't include any parameters in the value then existing parameters will be preserved. ;r)rgsplit)r2r1r1r3_content_type__getHs zBaseRequest._content_type__getcCsH|dk r>t|}d|kr>|j}d|kr>|d|ddd7}||_dS)Nrr)strrgr)r2rVrjr1r1r3_content_type__setRszBaseRequest._content_type__setcCs|jdkrt|j|_|jS)z_ All the request headers as a case-insensitive dictionary-like object. N)_headersr(rA)r2r1r1r3 _headers__getbs  zBaseRequest._headers__getcCs|j|j|dS)N)headersclearupdate)r2rVr1r1r3 _headers__setks zBaseRequest._headers__set)doccCs:|j}|d}|dk r,|dd}n |d}|S)a_ The effective client IP address as a string. If the ``HTTP_X_FORWARDED_FOR`` header exists in the WSGI environ, this attribute returns the client IP address present in that header (e.g. if the header value is ``192.168.1.1, 192.168.1.2``, the value will be ``192.168.1.1``). If no ``HTTP_X_FORWARDED_FOR`` header is present in the environ at all, this attribute will return the value of the ``REMOTE_ADDR`` header. If the ``REMOTE_ADDR`` header is unset, this attribute will return the value ``None``. .. warning:: It is possible for user agents to put someone else's IP or just any string in ``HTTP_X_FORWARDED_FOR`` as it is a normal HTTP header. Forward proxies can also provide incorrect values (private IP addresses etc). You cannot "blindly" trust the result of this method to provide you with valid data unless you're certain that ``HTTP_X_FORWARDED_FOR`` has the correct values. The WSGI server must be behind a trusted proxy for this to be true. ZHTTP_X_FORWARDED_FORN,rr)rArXrstrip)r2eZxffaddrr1r1r3 client_addrqs   zBaseRequest.client_addrcCsf|j}|d}|dk rZd|kr>|ddkr>|dd\}}qb|d}|dkrTd }qbd }n|d }|S) a` The effective server port number as a string. If the ``HTTP_HOST`` header exists in the WSGI environ, this attribute returns the port number present in that header. If the ``HTTP_HOST`` header exists but contains no explicit port number: if the WSGI url scheme is "https" , this attribute returns "443", if the WSGI url scheme is "http", this attribute returns "80" . If no ``HTTP_HOST`` header is present in the environ at all, this attribute will return the value of the ``SERVER_PORT`` header (which is guaranteed to be present). HTTP_HOSTN:]rzwsgi.url_schemehttps44380r)rArXrsplit)r2rhostport url_schemer1r1r3 host_ports  zBaseRequest.host_portcCs|j}|d}|d}|d}|dk rVd|krP|ddkrP|dd\}}qjd}n|d }|d }|d kr|d krd}n|d kr|dkrd}||7}|r|d|7}|S)z4 The URL through the host (no path) zwsgi.url_schemez://rNrrrrrrrrhttprz:%s)rArXr)r2rschemeurlrrr1r1r3host_urls(     zBaseRequest.host_urlcCst|j|j}|jt|tS)zN The URL including SCRIPT_NAME (no PATH_INFO or query string) )r script_namerrr PATH_SAFE)r2Z bscript_namer1r1r3application_urlszBaseRequest.application_urlcCst|j|j}|jt|tS)zS The URL including SCRIPT_NAME and PATH_INFO, but not QUERY_STRING )r path_inforrrr)r2Z bpath_infor1r1r3path_urlszBaseRequest.path_urlcCs0t|j|j}t|j|j}t|tt|tS)zG The path of the request, without host or query string )r rrrrr)r2Zbscriptbpathr1r1r3pathszBaseRequest.pathcCs&|j}|jd}|r"|d|7}|S)zM The path of the request, without host but with query string rn?)rrArX)r2rqsr1r1r3path_qss   zBaseRequest.path_qscCs&|j}|jd}|r"|d|7}|S)z> The full request URL, including QUERY_STRING rnr)rrArX)r2rrr1r1r3rs   zBaseRequest.urlFcCs0|r|j}|ds$|d7}n|j}t||S)z Resolve other_url relative to the request URL. If ``to_application`` is True, then resolve it relative to the URL with only SCRIPT_NAME /)rendswithrrurljoin)r2Z other_urlZto_applicationrr1r1r3 relative_urls   zBaseRequest.relative_urlcCs|j}|sdSd}x"|dr4|d7}|dd}qW|d}|dkrPt|}|d|}|dkspt||r|j||7_||d|_|SdS)a 'Pops' off the next segment of PATH_INFO, pushing it onto SCRIPT_NAME, and returning the popped segment. Returns None if there is nothing left on PATH_INFO. Does not return ``''`` when there's an empty segment (like ``/path//path``); these segments are just ignored. Optional ``pattern`` argument is a regexp to match the return value before returning. If there is no match, no changes are made to the request and None is returned. Nrmrrr)r startswithfindlenrematchr)r2patternrZslashesidxr~r1r1r3 path_info_pops    zBaseRequest.path_info_popcCs(|j}|sdS|d}|dddS)z Returns the next segment on PATH_INFO, or None if there is no next segment. Doesn't modify the environment. Nrrr)rlstripr)r2rr1r1r3path_info_peek!s  zBaseRequest.path_info_peekcCsFd|jkr|jdSd|jkr,|jddSi}d|f|jd<|SdS)z Return any *named* variables matched in the URL. Takes values from ``environ['wsgiorg.routing_args']``. Systems like ``routes`` set this value. z paste.urlvarszwsgiorg.routing_argsrr1N)rA)r2resultr1r1r3 _urlvars__get,s   zBaseRequest._urlvars__getcCsT|j}d|kr2|dd|f|d<d|krP|d=nd|krD||d<n d|f|d<dS)Nzwsgiorg.routing_argsrz paste.urlvarsr1)rA)r2rVrAr1r1r3 _urlvars__set<s zBaseRequest._urlvars__setcCsPd|jkr|jd=d|jkrL|jdds4|jd=n|jddif|jd<dS)Nz paste.urlvarszwsgiorg.routing_argsr)rA)r2r1r1r3 _urlvars__delHs    zBaseRequest._urlvars__delcCs d|jkr|jddSdSdS)z Return any *positional* variables matched in the URL. Takes values from ``environ['wsgiorg.routing_args']``. Systems like ``routes`` set this value. zwsgiorg.routing_argsrr1N)rA)r2r1r1r3 _urlargs__getWs zBaseRequest._urlargs__getcCsL|j}d|kr||df}n"d|kr8||ddf}n|if}||d<dS)Nz paste.urlvarszwsgiorg.routing_argsr)rArL)r2rVrAZ routing_argsr1r1r3 _urlargs__seteszBaseRequest._urlargs__setcCs>d|jkr:|jdds"|jd=nd|jddf|jd<dS)Nzwsgiorg.routing_argsrr1)rA)r2r1r1r3 _urlargs__delqs  zBaseRequest._urlargs__delcCs|jdddkS)aEIs X-Requested-With header present and equal to ``XMLHttpRequest``? Note: this isn't set by every XMLHttpRequest request, it is only set if you are using a Javascript library that sets it (or you set the header yourself manually). Currently Prototype and jQuery are known to set this header.ZHTTP_X_REQUESTED_WITHrmZXMLHttpRequest)rArX)r2r1r1r3is_xhr~szBaseRequest.is_xhrcCs"d|jkr|jdSd|jSdS)z>Host name provided in HTTP_HOST, with fall-back to SERVER_NAMErz%(SERVER_NAME)s:%(SERVER_PORT)sN)rA)r2r1r1r3 _host__gets  zBaseRequest._host__getcCs||jd<dS)Nr)rA)r2rVr1r1r3 _host__setszBaseRequest._host__setcCsd|jkr|jd=dS)Nr)rA)r2r1r1r3 _host__dels zBaseRequest._host__delcCs.|j}d|kr*|ddkr*|ddd}|S)a Returns the domain portion of the host value. Equivalent to: .. code-block:: python domain = request.host if ':' in domain and domain[-1] != ']': # Check for ] because of IPv6 domain = domain.rsplit(':', 1)[0] This will be equivalent to the domain portion of the ``HTTP_HOST`` value in the environment if it exists, or the ``SERVER_NAME`` value in the environment if it doesn't. For example, if the environment contains an ``HTTP_HOST`` value of ``foo.example.com:8000``, ``request.domain`` will return ``foo.example.com``. Note that this value cannot be *set* on the request. To set the host value use :meth:`webob.request.Request.host` instead. rrrrr)rr)r2domainr1r1r3rszBaseRequest.domaincCs0|js dS||j|j}|jd|S)z9 Return the content of the request body. rr)rrrxreadr{rr|)r2r~r1r1r3rvs  zBaseRequest.bodycCsF|dkr d}t|ts&tdt|t||_t||_d|_ dS)Nrz/You can only set Request.body to bytes (not %r)T) rrrErCrr{rrrr)r2rVr1r1r3rvs    cCs d|_dS)Nr)rv)r2r1r1r3rvscCst|j|jS)z&Access the body of the request as JSON)jsonloadsrvr\rP)r2r1r1r3_json_body__getszBaseRequest._json_body__getcCstj|dd|j|_dS)N)rr) separators)rdumpsencoderPrv)r2rVr1r1r3_json_body__setszBaseRequest._json_body__setcCs|`dS)N)rv)r2r1r1r3_json_body__delszBaseRequest._json_body__delcCs |jstd|j}||jS)z4 Get/set the text value of the body z4You cannot access Request.text unless charset is set)rPAttributeErrorrvr\)r2rvr1r1r3 _text__gets zBaseRequest._text__getcCs:|jstdt|ts(tdt|||j|_dS)Nz5You cannot access Response.text unless charset is setz:You can only set Request.text to a unicode string (not %s))rPrrr rErCrrv)r2rVr1r1r3 _text__sets  zBaseRequest._text__setcCs|`dS)N)rv)r2r1r1r3 _text__delszBaseRequest._text__delcCs|j}d|kr(|d\}}||jkr(|S|j}|jdkr<|rD|dkrPtd|S|||jd|}| ddd|d <t rt |j |d d }nt |j |d d d }t |}||jf|d<|S)a# Return a MultiDict containing all the variables from a form request. Returns an empty dict-like object for non-form requests. Form requests are typically POST requests, however any other requests with an appropriate Content-Type are also supported. zwebob._parsed_post_varsPOST)rmz!application/x-www-form-urlencodedzmultipart/form-dataz.Not an HTML form submission (Content-Type: %s)rrkrlrmrnT)rorArputf8)rorArprb)rArrjrBr+_check_charsetrr|rtrwrrrxr*Zfrom_fieldstorage)r2rvarsrxrjrrr1r1r3rs<       zBaseRequest.POSTcCs\|j}|dd}d|kr2|d\}}||kr2|Sg}|rBt|}t||}||f|d<|S)z` Return a MultiDict containing all the variables from the QUERY_STRING. rnrmzwebob._parsed_query_vars)rArXr r,)r2rsourcerrdatar1r1r3r s    zBaseRequest.GETcCs"|jdkrtd|j|jfdS)NzUTF-8zhRequests are expected to be submitted in UTF-8, not %s. You can fix this by doing req = req.decode('%s'))rPrH)r2r1r1r3r9s zBaseRequest._check_charsetcCst|j|j}|S)zy A dictionary-like object containing both the parameters from the query string and request body. )r)rr)r2paramsr1r1r3rAszBaseRequest.paramscCs t|jS)zI Return a dictionary of cookies as found in the request. )rrA)r2r1r1r3cookiesJszBaseRequest.cookiescCs&|jddt|j}||dS)NZ HTTP_COOKIE)rArLrr)r2rar~r1r1r3rQs cCs(||j}||}||S)zw Copy the request and environment object. This only does a shallow copy, except of wsgi.input )rrArtrK copy_body)r2rZnew_reqr1r1r3rtWs   zBaseRequest.copycCs|j}|j|ddddS)z Copies the request and environment object, but turning this request into a GET along the way. If this was a POST request (or any other verb) then it becomes GET, and the request body is thrown away. rNr)rBrjrv)rArtrK)r2rr1r1r3copy_getcs  zBaseRequest.copy_getzwebob.is_body_seekablecCs>|j}|dk r|dkrdS|dkr:|jd|jddSdS)z webob.is_body_readable is a flag that tells us that we can read the input stream even though CONTENT_LENGTH is missing. NrTzwsgi.input_terminatedzwebob.is_body_readableF)r{rArX)r2rr1r1r3rqszBaseRequest.is_body_readablecCst||jd<dS)Nzwsgi.input_terminated)boolrA)r2flagr1r1r3rscCs |jr|jdn|dS)a This forces ``environ['wsgi.input']`` to be seekable. That means that, the content is copied into a BytesIO or temporary file and flagged as seekable, so that it will not be unnecessarily copied again. After calling this method the .body_file is always seeked to the start of file and .content_length is not None. The choice to copy to BytesIO is made from ``self.request_body_tempfile_limit`` rN)rrr|r)r2r1r1r3rs zBaseRequest.make_body_seekablecCs|jr|jr|jd|j}|jdk r0|jnd}d}d}|j}x|dkr|t|d}|sn|jdkrnPn|s~t d||r| |n*||7}t ||kr| }| |d}|jdk rD|t |8}qDW|r| |_|d||_d|_d|_n||_nd|_dS)z Copies the body, in cases where it might be shared with another request object and that is not desired. This copies the body either into a BytesIO object (through setting req.body) or a temporary file. rNirz1Client disconnected (%s more bytes were expected)T)rrrr|request_body_tempfile_limitr{rxrminDisconnectionErrorwriter make_tempfilerzrv)r2Ztempfile_limittodoZnewbodyfileobjinputrr1r1r3rs@          zBaseRequest.copy_bodycCstS)z Create a tempfile to store big request body. This API is not stable yet. A 'size' argument might be added. )tempfile TemporaryFile)r2r1r1r3rszBaseRequest.make_tempfileTcCsbg}|r|ddg7}|r"|d|r0|d|r>|dx|D]}||jkrD|j|=qDWdS)a* Remove headers that make the request conditional. These headers can cause the response to be 304 Not Modified, which in some cases you may not want to be possible. This does not remove headers like If-Match, which are used for conflict detection. HTTP_IF_RANGE HTTP_RANGEHTTP_IF_NONE_MATCHHTTP_IF_MODIFIED_SINCEZHTTP_ACCEPT_ENCODINGN)appendrA)r2Zremove_encodingZ remove_rangeZ remove_matchZremove_modifiedZ check_keysr^r1r1r3remove_conditional_headerss      z&BaseRequest.remove_conditional_headersZHTTP_AUTHORIZATIONz14.8cCsX|j}|dd}|dd\}}|dk r6||kr6|Stj||jdd}||f|d<|S)z Get/set/modify the Cache-Control header (`HTTP spec section 14.9 `_) HTTP_CACHE_CONTROLrmzwebob._cache_control)NNNrequest)Z updates_torC)rArXrparse_update_cache_control)r2rrVZ cache_headerZ cache_objr1r1r3_cache_control__get#s  zBaseRequest._cache_control__getcCsd|j}|p d}t|tr$t|dd}t|trLt|}||d<||f|d<nt||d<d|d<dS)Nrmr)rCrzwebob._cache_control)NN)rArrDrr)r2rVrZ str_valuer1r1r3_cache_control__set3s    zBaseRequest._cache_control__setcCs&|j}d|kr|d=d|kr"|d=dS)Nrzwebob._cache_control)rA)r2rr1r1r3_cache_control__del@s zBaseRequest._cache_control__delcCst||jd<dS)Nr)rrA)r2Z prop_dictr1r1r3rGsz!BaseRequest._update_cache_controlZ HTTP_IF_MATCHz14.24r z14.26)strongZ HTTP_DATEr z14.25ZHTTP_IF_UNMODIFIED_SINCEz14.28rz14.27zIfRange objectZHTTP_MAX_FORWARDSz14.31Z HTTP_PRAGMAz14.32r z14.35z Range objectZ HTTP_REFERERz14.36ZHTTP_USER_AGENTz14.43cCsLyd|j|jf}Wntk r,d}YnXd|jjtt||f}|S)Nz%s %sz(invalid WSGI environ)z<%s at 0x%x %s>)rBrrZrKr5absid)r2rUmsgr1r1r3r4ms zBaseRequest.__repr__c Cs|j}|j}||st|t|d}td|j||jfg}d}|jr|dkrzt|j |krvtdt|j }nd}|s|j }x4t |j D]"\}}td||f}| |qW|r|d|gd|S) z Return HTTP bytes representing this request. If skip_body is True, exclude the body. If skip_body is an integer larger than one, skip body only if its length is bigger than that number. Nz%s %s %srzFz%s: %srs )rrrAssertionErrorrr rB http_versionrrvsortedrrMr extendjoin) r2Z skip_bodyrrpartsrvkvheaderr1r1r3as_bytesws&zBaseRequest.as_bytescCs|}||jS)N)r"r\rP)r2rr1r1r3as_textszBaseRequest.as_textcCs0t|}||}|t|kr,td|S)z Create a request from HTTP bytes data. If the bytes contain extra data after the request, raise a ValueError. z+The string contains more data than expected)rr from_filerzrr)rTbfr~r1r1r3 from_bytess   zBaseRequest.from_bytescCst|d}||S)Nzutf-8)r r')rTsr%r1r1r3 from_texts zBaseRequest.from_textcCsJ|}t|t}|r d}d}nd}d}y>||}|dd\}}} t|d}t|d}t| d} Wn tk rtd|YnX|t|| |d } | j d =xd|} | sP| |d \} } t| d} t| d } | | j kr| j | d | } | | j | <qW| j }|dkr&| }n | |}|r@t|d}|| _| S) aRead a request from a file-like object (it must implement ``.read(size)`` and ``.readline()``). It will read up to the end of the request, not the end of the file (unless the request is a POST or PUT and has no Content-Length, in that case, the entire file is read). This reads the request as represented by ``str(req)``; it may not read every valid HTTP request properly. z rs :Nrzutf-8zBad HTTP request line: %r)rrBrrz, )readlinerr rstriprr renviron_from_urlupperrArrr{rr rv)rTroZ start_lineZis_textZcrlfcolonr!rBresourcerr~linehnameZhvalrrvr1r1r3r$sJ            zBaseRequest.from_filec s|jr|jdggdfdd }||j|}s@shz|Wdt|drb|X}rdd|dfSdd|fSdS) a Call the given WSGI application, returning ``(status_string, headerlist, app_iter)`` Be sure to call ``app_iter.close()`` if it's there. If catch_exc_info is true, then returns ``(status_string, headerlist, app_iter, exc_info)``, where the fourth item may be None, but won't be if there was an exception. If you don't do this and there was an exception, the exception will be raised directly. rNcs,|dk rst||||gdd<jS)N)r r )statusrexc_info)capturedcatch_exc_infooutputr1r3start_responses z4BaseRequest.call_application..start_responsecloserr)N)rrr|rArrNr9)r2 applicationr6r8app_iterr1)r5r6r7r3call_applications     zBaseRequest.call_applicationcCsV|dkr|}|r.|j|dd\}}}}~n|j|dd\}}}|j|t||dS)a Like ``.call_application(application)``, except returns a response object with ``.status``, ``.headers``, and ``.body`` attributes. This will use ``self.ResponseClass`` to figure out the class of the response object to return. If ``application`` is not given, this will send the request to ``self.make_default_send_app()`` NT)r6F)r3Z headerlistr;)make_default_send_appr< ResponseClasslist)r2r:r6r3rr;r4r1r1r3sends zBaseRequest.sendcCs4yt}Wn$tk r,ddlm}|aYnX|jS)Nr)client)Z_client NameErrorZwebobrAZsend_request_app)r2rAr1r1r3r=(s   z!BaseRequest.make_default_send_appcKs,t|}|rt|\}} }} } | s(| r4td||r@||d<| rd| kr||dkr^| d7} n|dkrp| d7} n td|| dd \} } | |d <| |d <| |d <|rt||d <|r|||d|d}|rd|kr|d}|dk r||d<t|||d||f|}|dk r(|j ||S)a( Create a blank request environ (and Request wrapper) with the given path (path should be urlencoded), and any keys from environ. The path will become path_info, with any query string split off and used. All necessary keys will be added to the environ, but the values you pass in will take precedence. If you pass in base_url then wsgi.url_scheme, HTTP_HOST, and SCRIPT_NAME will be filled in from that value. Any extra keyword will be passed to ``__init__``. z-base_url (%r) cannot have a query or fragmentzwsgi.url_schemerrz:80rz:443zUnknown scheme: %rrrrrrrjrz Content-TypeN)rj) r-rurlsplitrrrrrXenviron_add_POSTr)rTrrAbase_urlrrrRrrnetlocqueryfragmentrrrjobjr1r1r3blank1sF         zBaseRequest.blank)NNN)N)Nrh)N)F)N)TTTT)F)F)NF)NNNN)r5r6r7rrerWrYrcrdpropertyrPsetterr\_setattr_stacklevelrxdeleterrrrrrrBrrrr!r{Z remote_userZ remote_host remote_addrriZ server_namerZ server_portrrr uscript_name upath_inforgrr__doc__rjrrrrrrrrrrrrrrrrrrZurlvarsrrrZurlargsrrrrrrrvrrrrZ json_bodyrrrtextrrrrrrtrrrrrrr racceptrZaccept_charsetraccept_encodingrZaccept_languagerr authorizationrrrrZ cache_controlr'r%Zif_matchr&Z if_none_matchrdateZif_modified_sinceZif_unmodified_sincer$rr Zif_rangeZ max_forwardsZpragmarr"rangeZrefererZreferrer user_agentr4r"r#__str__ classmethodr'r)r$r<r>r@Z get_responser=rJr1r1r1r3r-[s8 2  /                                  2     S               "  8 $  c@s*eZdZedZedZedfddZdS)r/rrNcCs.|j||}|tkrt|||kr*|S|S)N)rArXrYrZ)r2r^r_r`rar1r1r3rcls zLegacyRequest.encget)r5r6r7r#rPrQrYrcr1r1r1r3r/hsc@s:eZdZdZefddZefddZefddZdS) AdhocAttrMixincCsBt|j|||k s|dr,t|||n||jdi|<dS)N_zwebob.adhoc_attrs)r[rKrobject __setattr__rArw)r2attrrVDEFAULTr1r1r3r`ws zAdhocAttrMixin.__setattr__cCs0y|jd|Stk r*t|YnXdS)Nzwebob.adhoc_attrs)rArZr)r2rarbr1r1r3 __getattr__~szAdhocAttrMixin.__getattr__cCsPt|j|||k rt||Sy|jd|=Wntk rJt|YnXdS)Nzwebob.adhoc_attrs)r[rKr_ __delattr__rArZr)r2rarbr1r1r3rds  zAdhocAttrMixin.__delattr__N)r5r6r7rMr_r`rcrdr1r1r1r3r\tsr\c@seZdZdZdS)r.z$ The default request implementation N)r5r6r7rRr1r1r1r3r.scCst|rxt|\}}}}}|r.td||r>|d|7}d|kr|dkrX|d7}q|dkrj|d7}qtd|nd}d }|rd|kr|dd \}}t|}n t|}d }d d |pd ||dd |dd |dd|tt j dddd}|S)Nz#Path cannot contain a fragment (%r)rrrz:80rz:443zUnknown scheme: %rz localhost:80rrmrrzHTTP/1.0)rrF)rrrrnrrrrz wsgi.versionzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_once) rsearchrrCrErrrrsysstderr)rrrFrrHrrirr1r1r3r-sF         r-cCs.|dkr dSt|tr |d}|ddkr4d|d<d}t|drtt|}x$|D]\}}t|ttfrTd}PqTW|dkr|rd}nd }|drt|tst ||\}}nD|d r|rt d |t|tst |}nt|tst d |t |d }t ||d <d|d<tt||d<||d<dS)Nr8r)rPUTrFrMTzmultipart/form-dataz!application/x-www-form-urlencodedz4Submiting files is not allowed for content type `%s`z9Please provide `POST` data as bytes for content type `%s`rz wsgi.inputzwebob.is_body_seekablerkr)rr rrNr?rMtuplerr_encode_multipartrrr rrrr)rrrjZ has_filesrr r1r1r3rDsD            rDc@s eZdZdS)rN)r5r6r7r1r1r1r3rsrc@s8eZdZddZddZddZeddZd d Zd S) rcCs||_||_||_dS)N)filemaxlen remaining)r2rkrlr1r1r3rWszLimitedLengthFile.__init__cCsd|jj|j|jfS)Nz<%s(%r, maxlen=%s)>)rKr5rkrl)r2r1r1r3r4szLimitedLengthFile.__repr__cCs |jS)N)rkfileno)r2r1r1r3rnszLimitedLengthFile.filenocCsdS)NTr1r1r1r1r3readableszLimitedLengthFile.readablecCsj|js dStt||j}|j|}t|}|j|8_||krZ|jrZtd|jf||d|<|S)NrzLThe client disconnected while sending the body (%d more bytes were expected))rmrrrkrr)r2buffZsz0rszr1r1r3readintos   zLimitedLengthFile.readintoN) r5r6r7rWr4rn staticmethodrorrr1r1r1r3rs  rcCs*|jrd|j|jfSd|j|j|jfS)z monkey patch for FieldStorage.__repr__ Unbelievably, the default __repr__ on FieldStorage reads the entire file content instead of being sane about it. This is a simple replacement that doesn't do that zFieldStorage(%r, %r)zFieldStorage(%r, %r, %r))rkrUfilenamerV)r2r1r1r3_cgi_FieldStorage__repr__patchsruc@s8eZdZddZddZddZeddZd d Zd S) FakeCGIBodycCs@tdt|dr*t|s*td|||_||_d|_dS)NzFakeCGIBody is no longer used by WebOb and will be removed from a future version of WebOb. If you require FakeCGIBody please make a copy into you own projectzmultipart/form-dataz*Content-type: %r does not contain boundary) rFrGrHr_get_multipart_boundaryrrrjrk)r2rrjr1r1r3rWs zFakeCGIBody.__init__cCsLt|j}t|dkr2|ddd|dd}d|jjtt||fS)Nz...z<%s at 0x%x viewing %s>)reprrrrKr5rr)r2innerr1r1r3r4-s   zFakeCGIBody.__repr__cCsdS)Nr1)r2r1r1r3rn5szFakeCGIBody.filenocCsdS)NTr1r1r1r1r3ro8szFakeCGIBody.readablecCs|jdkr|jdrBddd|jD}tt||_nL|jdr|t |j|jtdd|_|j dndst d |j|j |S) Nz!application/x-www-form-urlencoded&css2|]*\}}dtt|dtt|dfVqdS)z%s=%srN)rr ).0rr r1r1r3 @sz'FakeCGIBody.readinto..zmultipart/form-data)rrrzBad content type: %r) rkrjrrrrMrrr rjr|rrr)r2rprr1r1r3rr<s    zFakeCGIBody.readintoN) r5r6r7rWr4rnrsrorrr1r1r1r3rvs  rvcCs,td|tj}|r(t|ddSdS)Nzboundary=([^ ]+)r")rreIr groupr)ctypemr1r1r3rwRsrwc s|p t}|jfdd}d}t|}|sNtttd}|d|7}xl|D]b\}}d||||d|dk r|d |d} t |d dr|j } n(t |t t fr|\} }t|d r|}| dk r|d | t| d } nd} |t |ddr`|d|j|jrVx,t|jD]\} } |d| | fq8W|n| rz|d| ||t|dr|j}t |tr|n|||qVW|d||r||fS||fSdS)z-Encode a multipart request body into a stringcs|ddS)Nr)r)r})wr1r3wt[sz_encode_multipart..wts z ; boundary=%ss--zContent-Disposition: form-dataNz ; name="%s"rtrz; filename="%s"rrCzContent-type: %sz ; %s="%s"rVz--%s--)rrrrwr binasciihexlifyosurandomr[rtrr?rirNr mimetypes guess_typerC type_optionsrrMrVrgetvalue) rrjrr&rCRLFboundaryrUrVrtZ mime_typeZct_nameZct_valuer1)rr3rjWs^              rjcCs&t|}|r"|ddSdS)Nrr)rrerr)rrr1r1r3rfs rfcCs |sdS|dddkSdS)NT-rmr)lowerreplace)rPr1r1r3rIsrIc@s&eZdZd ddZddZddZdS) rrrhcs |_|_fdd|_dS)Ncs|dS)Nr)r\r)r%)rPrqr1r3rz%Transcoder.__init__..)rPrq_trans)r2rPrqr1)rPrqr3rWszTranscoder.__init__csT|}d|kr|Strsz.Transcoder.transcode_query..)rr parse_qslrPrr?r r)r2qZq_origr1)r}r3ruszTranscoder.transcode_querycstrfdd}ndd}g}xX|jp(dD]J}||j|_|jr^||j|_||j|fq*||j||jfq*Wt||td\}}|S)Ncs |dk r|jjS|SdS)N)r\rPrq)r%)r2r1r3r\sz'Transcoder.transcode_fs..decodecSs|S)Nr1)r%r1r1r3r\sr1)r) rr?rUrtr rVrjrr)r2rrjr\rfieldrr1)r2r3rys  zTranscoder.transcode_fsN)rh)r5r6r7rWruryr1r1r1r3rrs rr)N)N)VrrrrrfrrZ simplejsonr ImportErrorrFZwebob.acceptparserrrrZwebob.cachecontrolrrZ webob.compatrr r r r r rrrrrrZ webob.cookiesrZwebob.descriptorsrrrrrrrrrrrr r!r"r#Z webob.etagr$r%r&r'Z webob.headersr(Zwebob.multidictr)r*r+r,__all__r0rYrr]r_r-r/r\r.r-rDIOErrorr RawIOBaserrur4rvrwrjrfrIrrr1r1r1r3sd 8 D   , +$ 6 ;