o ߥi@sddlZddlmZmZmZmZmZddlmZddl m Z m Z m Z m Z mZmZddlmZmZmZddlmZddlmZddlmZmZdd lmZGd d d eeefeZGd d d eZ dS)N)AnyDictIteratorMappingOptional) parse_qsl)URLAddressFormDataHeaders QueryParams UploadFile) MalformedJSONMalformedMultipartUnsupportedMediaType) parse_stream)MoreInfoFromHeaderMixin)Environ StartResponse)cached_propertyc@seZdZdZ ddedeeddfddZdede fd d Z de efd d Z de fd dZde defddZedefddZedefddZedeee ffddZedefddZedefddZdS)HTTPConnectionz A base class for incoming HTTP connections. It is a valid Mapping type that allows you to directly access the values in any WSGI `environ` dictionary. Nenvironstart_responsereturncCs||_||_dSN)_environ_start_responseselfrrrG/home/ubuntu/.local/lib/python3.10/site-packages/baize/wsgi/requests.py__init__s zHTTPConnection.__init__keycCs |j|Sr)r)rr"rrr __getitem__" zHTTPConnection.__getitem__cC t|jSr)iterrrrrr __iter__%r$zHTTPConnection.__iter__cCr%r)lenrr'rrr __len__(r$zHTTPConnection.__len__othercCs(t||jstS|j|jko|j|jkSr) isinstance __class__NotImplementedrr)rr+rrr __eq__+s   zHTTPConnection.__eq__cCs6|dr|drt|dt|dStdddS)z Client's IP and Port. Note that this depends on the `REMOTE_ADDR` and `REMOTE_PORT` values given by the WSGI Server, and is not necessarily accurate. REMOTE_ADDR REMOTE_PORTN)hostport)getr intr'rrr client3s zHTTPConnection.clientcCs t|jdS)z/ The full URL of this request. )r)rrr'rrr url? zHTTPConnection.urlcCs |diS)z> The path parameters parsed by the framework. PATH_PARAMS)r4r'rrr path_paramsFr8zHTTPConnection.path_paramscCs t|dS)z? Query parameter. It is a multi-value mapping. QUERY_STRING)r r'rrr query_paramsMr8zHTTPConnection.query_paramscCstdd|jDS)z A read-only case-independent mapping. Note that in its internal storage, all keys are in lower case. cssP|]#\}}|ds|dvr|dr|ddn|dd|fVqdS)HTTP_) CONTENT_TYPECONTENT_LENGTHN_-) startswithlowerreplace).0r"valuerrr [s$z)HTTPConnection.headers..)r ritemsr'rrr headersTszHTTPConnection.headersr)__name__ __module__ __qualname____doc__rrrr!strrr#rr(r5r*boolr/rr r6rr7rr:r r<r rJrrrr rs0  rcseZdZ ddedeeddffdd ZedefddZ dd e de e fd d Z ede fd dZedefddZde dedefddZedefddZdddZZS)RequestNrrrcst||d|_dS)NF)superr!_stream_consumedrr-rr r!fs zRequest.__init__cCs|dS)z0 HTTP method. Uppercase string. REQUEST_METHODrr'rrr methodlszRequest.method chunk_sizeccsRd|jvr |jVdS|jrtdd|_|jd} ||}|s%dS|Vq)a" Streaming read request body. e.g. `for chunk in request.stream(): ...` If you access `.stream()` then the byte chunks are provided without storing the entire body to memory. Any subsequent calls to `.body`, `.form`, or `.json` will raise an error. bodyNzStream consumedTz wsgi.input)__dict__rYrS RuntimeErrorrread)rrXrYchunkrrr streamss   zRequest.streamcCsddd|DS)zZ Read all the contents of the request body into the memory and return it. cSsg|]}|qSrr)rFr]rrr sz Request.body..)joinr^r'rrr rYsz Request.bodyc Cs\|jdkr*zt|j|jjddWStjy)}ztt |dd}~wwt d)z Call `self.body` and use `json.loads` parse it. If `content_type` is not equal to `application/json`, an HTTPExcption exception will be thrown. zapplication/jsoncharsetutf8N) content_typejsonloadsrYdecodeoptionsr4JSONDecodeErrorrrOr)rexcrrr res z Request.jsonboundaryrbcCstt|||tdS)N) file_factory)r parse_multipartr^r )rrkrbrrr _parse_multipartszRequest._parse_multipartcCs|jdkr&|jjdd}d|jjvrtd|jjdd}|||S|jdkr@|jj|jjddd}tt |d d St d ) a Parse the data in the form format and return it as a multi-value mapping. If `content_type` is equal to `multipart/form-data`, it will directly perform streaming analysis, and subsequent calls to `self.body` or `self.json` will raise errors. If `content_type` is not equal to `multipart/form-data` or `application/x-www-form-urlencoded`, an HTTPExcption exception will be thrown. zmultipart/form-datarbrcrkz'Missing boundary in header content-typezlatin-1z!application/x-www-form-urlencoded)encodingT)keep_blank_valuesz6multipart/form-data, application/x-www-form-urlencoded) rdrhr4rencodernrYrgr rr)rrbrkrYrrr forms    z Request.formcCsd|jvr |jdSdS)z Close all temporary files in the `self.form`. This can always be called, regardless of whether you use form or not. rrN)rZrrcloser'rrr rss z Request.closer)rW)rN)rKrLrMrrrr!propertyrOrVr5rbytesr^rrYrrer rnrrrs __classcell__rrrTr rQes(rQ)!retypingrrrrr urllib.parserbaize.datastructuresrr r r r r baize.exceptionsrrrbaize.multipart_helperrrmbaize.requestsr baize.typingrr baize.utilsrrOrrQrrrr s     Q