o KK&h@sddlmZddlZddlZddlZddlmZddlmZddgZ e ej dd Z e ej d d ZdddZedZedZd ddZd!ddZd"ddZd#ddZdS)$) annotationsN)Headers) SecurityError read_request read_responseWEBSOCKETS_MAX_NUM_HEADERS128WEBSOCKETS_MAX_LINE_LENGTH8192valuebytesreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)r rI/var/www/html/venv/lib/python3.10/site-packages/websockets/legacy/http.pyds rs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*streamasyncio.StreamReadertuple[str, Headers]c sz t|IdH}Wnty}ztd|d}~wwz |dd\}}}Wnty8tdt|dw|dkrFtdt||dkrStd 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)r request_lineexcmethodraw_pathversionpathheadersrrrr-s&   tuple[int, str, Headers]c s z t|IdH}Wnty}ztd|d}~wwz |dd\}}}Wnty8tdt|dw|dkrFtdt|zt|}Wnty]tdt|dwd |krhd ksrntd 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: ) rrr r!rint _value_re fullmatchrr") r status_liner$r'raw_status_code raw_reason status_codereasonr)rrrr^s4      rc st}ttdD]p}z t|IdH}Wnty&}ztd|d}~ww|dkr.|Sz |dd\}}WntyItdt|dwt |sXtdt|| d}t |sktd t|| d }| d d }|||<q t d ) 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)rrangeMAX_NUM_HEADERSrrr r!r _token_rer.stripr-rr) rr)_liner$raw_name raw_valuenamer rrrr"s4         r"csB|IdH}t|tkrtd|dstd|ddS)z[ Read a single line from ``stream``. CRLF is stripped from the return value. Nz line too longs zline without CRLF)readlinelenMAX_LINE_LENGTHrendswithr)rr<rrrrs   r)r r rr)rrrr)rrrr*)rrrr)rrrr ) __future__rasyncioosredatastructuresr exceptionsr__all__r,environgetr8rCrcompiler9r-rrr"rrrrrs      1 4(