a یxd@sddlmZddlZddlZddlmZddlmZddlm Z ddgZ d Z d Z d d d ddZ edZedZdddddZdddddZdddddZdd dddZdS)) annotationsN)Tuple)Headers) SecurityError read_request read_responsei bytesstr)valuereturncCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)r rN/var/www/html/Ranjet/env/lib/python3.9/site-packages/websockets/legacy/http.pydsrs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*zasyncio.StreamReaderzTuple[str, Headers])streamr c szt|IdH}Wn.ty@}ztd|WYd}~n d}~00z|dd\}}}Wn&ty~tdt|dYn0|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: HTTP/1.1unsupported HTTP version: asciisurrogateescape) read_lineEOFErrorsplit ValueErrorrr read_headers)rZ request_lineexcmethodraw_pathversionpathheadersrrrr-s   zTuple[int, str, Headers]c s4zt|IdH}Wn.ty@}ztd|WYd}~n d}~00z|dd\}}}Wn&ty~tdt|dYn0|dkrtdt|z t|}Wn&tytdt|dYn0d |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: rrzinvalid HTTP status code: dizunsupported HTTP status code: zinvalid HTTP reason phrase: ) rrrrrint _value_re fullmatchrr) r status_linerr"Zraw_status_codeZ raw_reason status_codereasonr$rrrr^s*     rc st}ttdD]}zt|IdH}Wn.tyV}ztd|WYd}~n d}~00|dkrfq z|dd\}}Wn&tytdt|dYn0t |stdt|| d}t |std t|| d }| d d }|||<qt 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$_linerraw_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)rr4rrrrs   r) __future__rasyncioretypingrZdatastructuresr exceptionsr__all__r0r:rcompiler1r'rrrrrrrrs     14(