B ]b@sddlmZddlZddlZddlmZddlmZddlm Z ddgZ d Z d Z d d d ddZ edZedZdddddZdddddZdddddZdd dddZdS)) annotationsN)Tuple)Headers) SecurityError read_request read_responseibytesstr)valuereturncCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)r r5lib/python3.7/site-packages/websockets/legacy/http.pydsrs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*zasyncio.StreamReaderzTuple[str, Headers])streamr c syt|IdH}Wn,tk r>}ztd|Wdd}~XYnXy|dd\}}}Wn(tk r~tdt|dYnX|dkrtdt||dkrtd t||d d }t|IdH}||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: sHTTP/1.1zunsupported HTTP version: asciisurrogateescape) read_lineEOFErrorsplit ValueErrorrr read_headers)rZ request_lineexcmethodZraw_pathversionpathheadersrrrr-s zTuple[int, str, Headers]c s6yt|IdH}Wn,tk r>}ztd|Wdd}~XYnXy|dd\}}}Wn(tk r~tdt|dYnX|dkrtdt|y t|}Wn(tk rtdt|dYnXd |krd ksntd t|t|std t||}t |IdH}|||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: sHTTP/1.1zunsupported HTTP version: zinvalid HTTP status code: dizunsupported HTTP status code: zinvalid HTTP reason phrase: ) rrrrrint _value_re fullmatchrr) rZ status_linerrZraw_status_codeZ raw_reasonZ status_codereasonr!rrrr^s*  rc st}xttdD]}yt|IdH}Wn,tk rX}ztd|Wdd}~XYnX|dkrdPy|dd\}}Wn(tk rtdt|dYnXt |stdt|| d}t |std t|| d }| d d }|||<qWt d |S) zo Read HTTP headers from ``stream``. Non-ASCII characters are represented with surrogate escapes. Nz,connection closed while reading HTTP headers:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: rrztoo many HTTP headers)rrange MAX_HEADERSrrrrr _token_rer%stripr$rr) rr!_linerZraw_nameZ raw_valuenamer rrrrs,       rcs@|IdH}t|tkr"td|ds4td|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/rrrrs   r)Z __future__rZasyncioretypingrZdatastructuresr exceptionsr__all__r+r4rcompiler,r$rrrrrrrrs     14(