&thddlmZddlZddlZddlmZddlmZddlm Z ddgZ d Z d Z ddZ ejdZejdZddZddZddZddZdS) ) annotationsN)Tuple)Headers) SecurityError read_request read_responseivaluebytesreturnstrc.|dS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)r s j/var/www/html/mycamper/aliexpress-site/backend/venv/lib/python3.11/site-packages/websockets/legacy/http.pydrs <<1< 2 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*streamasyncio.StreamReaderTuple[str, Headers]cK t|d{V}n"#t$r}td|d}~wwxYw |dd\}}}n.#t$r!tdt |dwxYw|dkrtdt ||dkrtd t ||d d }t |d{V}||fS) a Read an HTTP/1.1 GET request and return ``(path, headers)``. ``path`` isn't URL-decoded or validated in any way. ``path`` and ``headers`` are expected to contain only ASCII characters. Other characters are represented with surrogate escapes. :func:`read_request` doesn't attempt to read the request body because WebSocket handshake requests don't have one. If the request contains a body, it may be read from ``stream`` after this coroutine returns. Args: stream: input to read the request from Raises: EOFError: if the connection is closed without a full HTTP request SecurityError: if the request exceeds a security limit ValueError: if the request isn't well formatted Nz1connection closed while reading HTTP request line rzinvalid HTTP request line: sGETzunsupported HTTP method: HTTP/1.1unsupported HTTP version: asciisurrogateescape) read_lineEOFErrorsplit ValueErrorrr read_headers)r request_lineexcmethodraw_pathversionpathheaderss rrr-sS8U&v........ UUUJKKQTTUT$0$6$6tQ$?$?!'' TTTHqHHIItST@QvYY@@AAA+BajjBBCCC ??7$5 6 6D ((((((((G =s 949A+BTuple[int, str, Headers]cK t|d{V}n"#t$r}td|d}~wwxYw |dd\}}}n.#t$r!tdt |dwxYw|dkrtdt | t |}n.#t$r!tdt |dwxYwd |cxkrd ks!ntd t |t |std t ||}t|d{V}|||fS) a Read an HTTP/1.1 response and return ``(status_code, reason, headers)``. ``reason`` and ``headers`` are expected to contain only ASCII characters. Other characters are represented with surrogate escapes. :func:`read_request` doesn't attempt to read the response body because WebSocket handshake responses don't have one. If the response contains a body, it may be read from ``stream`` after this coroutine returns. Args: stream: input to read the response from Raises: EOFError: if the connection is closed without a full HTTP response SecurityError: if the response exceeds a security limit ValueError: if the response isn't well formatted Nz0connection closed while reading HTTP status linerrzinvalid HTTP status line: rrzinvalid HTTP status code: dizunsupported HTTP status code: zinvalid HTTP reason phrase: ) rr r!r"rint _value_re fullmatchrr#) r status_liner%r(raw_status_code raw_reason status_codereasonr*s rr r ^s2T%f-------- TTTIJJPSSTR/:/@/@q/I/I,** RRRFa nnFFGGTQR+BajjBBCCCV/** VVVJa6H6HJJKKQUUV + $ $ $ $ $ $ $ $N!O:L:LNNOOO   z * *IG* GGHHH    F ((((((((G  ''s' 949A+B,B<<+C'rcKt}ttdzD]E} t|d{V}n"#t$r}t d|d}~wwxYw|dkrn |dd\}}n.#t $r!t dt|dwxYwt |st dt|| d}t |st d t|| d }| d d }|||<Gtd |S) zo Read HTTP headers from ``stream``. Non-ASCII characters are represented with surrogate escapes. Nz,connection closed while reading HTTP headersr:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: rrztoo many HTTP headers)rrange MAX_HEADERSrr r!r"r _token_rer0stripr/rr) rr*_liner%raw_name raw_valuenamer s rr#r#siiG ;? # #55 T"6********DD T T TIJJPS S T 3;; E O"&**T1"5"5 Hii O O OC!D''CCDD$ N O""8,, IG!H++GGHH HOOF++ ""9-- KI1Y<<IIJJ Jw''  *;<< 3444 Ns#A A! AA!.B+B3cK|d{V}t|tkrtd|dst d|ddS)z[ Read a single line from ``stream``. CRLF is stripped from the return value. Nz line too longs zline without CRLF)readlinelenMAX_LINErendswithr )rr>s rrrsy"" " " " " " "D 4yy8O,,, == ! !,*+++ 9r)r r r r)rrr r)rrr r+)rrr r)rrr r ) __future__rasyncioretypingrdatastructuresr exceptionsr__all__r:rFrcompiler;r/rr r#rrrrQs"""""" $$$$$$&&&&&& ? + 3333 BJ7 8 8  BJ4 5 5 ....b1(1(1(1(h%%%%Pr