o [h>0@sddlmZddlZddlZddlmZmZmZddlm Z m Z dZ dZ dZ dd dZedZedZejGdddZejGdddZdddZdddZdS) ) annotationsN)Callable GeneratorOptional)datastructures exceptionsiivaluebytesreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)r rx/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/websockets/http11.pyds rs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*c@sFeZdZUdZded<ded<dZded<edd dZdddZdS)Requesta  WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. exception: If processing the response triggers an exception, the exception is stored in this attribute. r pathdatastructures.HeadersheadersNOptional[Exception] exception read_line-Callable[[int], Generator[None, None, bytes]]r Generator[None, None, Request]c csz t|EdH}Wnty}ztd|d}~wwz |dd\}}}Wnty8tdt|dw|dkrFtdt||dkrStd t||d d }t|EdH}d |vrhtd d|vrptd|||S)a Parse a WebSocket handshake request. This is a generator-based coroutine. The request path isn't URL-decoded or validated in any way. The request path and headers are expected to contain only ASCII characters. Other characters are represented with surrogate escapes. :meth:`parse` 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 the data stream after :meth:`parse` returns. Args: read_line: generator-based coroutine that reads a LF-terminated line or raises an exception if there isn't enough data 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 zinvalid HTTP request line: sGETzunsupported HTTP method: HTTP/1.1unsupported HTTP version: asciisurrogateescapeTransfer-Encoding!transfer codings aren't supportedContent-Lengthzunsupported request body) parse_lineEOFErrorsplit ValueErrorrr parse_headersNotImplementedError) clsrZ request_lineexcmethodraw_pathversionrrrrrparseFs.#    z Request.parser cCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )rencoder serialize)selfrequestrrrr3szRequest.serialize)rrr rr r ) __name__ __module__ __qualname____doc____annotations__r classmethodr1r3rrrrr4s    >rc@sZeZdZUdZded<ded<ded<dZd ed <dZd ed <edddZdddZ dS)ResponseaI WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body, if any. exception: if processing the response triggers an exception, the exception is stored in this attribute. int status_coder reason_phraserrNzOptional[bytes]bodyrrrr read_exact read_to_eofr Generator[None, None, Response]c csz t|EdH}Wnty}ztd|d}~wwz |dd\}}}Wnty8tdt|dw|dkrFtdt|zt|} Wnty]tdt|dwd | krhd ksrntd t|t|std t||} t |EdH} d | vrt dd | krdksn| dks| dkrd} nHz| d} Wn t yd}Ynwt| }|durz |t EdH} Wn$t ytdt dw|t krtd|d||EdH} || | | | S)a Parse a WebSocket handshake response. This is a generator-based coroutine. The reason phrase and headers are expected to contain only ASCII characters. Other characters are represented with surrogate escapes. Args: read_line: generator-based coroutine that reads a LF-terminated line or raises an exception if there isn't enough data. read_exact: generator-based coroutine that reads the requested bytes or raises an exception if there isn't enough data. read_to_eof: generator-based coroutine that reads until the end of the strem. Raises: EOFError: if the connection is closed without a full HTTP response. SecurityError: if the response exceeds a security limit. LookupError: if the response isn't well formatted. ValueError: if the response isn't well formatted. Nz0connection closed while reading HTTP status linerrzinvalid HTTP status line: rr zinvalid HTTP status code: dizunsupported HTTP status code: zinvalid HTTP reason phrase: r#r$i0r%zbody too large: over z byteszbody too large: )r&r'r(r)rr> _value_re fullmatchrr*r+KeyErrorMAX_BODY RuntimeErrorr SecurityError)r,rrBrCZ status_liner-r0Zraw_status_codeZ raw_reasonr?reasonrrAZraw_content_lengthcontent_lengthrrrr1sj       &     zResponse.parser cCs@d|jd|jd}||j7}|jdur||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z N)r?r@r2rr3rA)r4responserrrr3s   zResponse.serialize)rrrBrrCrr rDr6) r7r8r9r:r;rArr<r1r3rrrrr=s     ^r=rr-Generator[None, None, datastructures.Headers]c cst}ttdD]p}z t|EdH}Wnty'}ztd|d}~ww|dkr/|Sz |dd\}}WntyJtdt|dwt |sYtdt|| d}t |sltd t|| d }| d d }|||<q td ) a Parse HTTP headers. Non-ASCII characters are represented with surrogate escapes. Args: read_line: generator-based coroutine that reads a LF-terminated line or raises an exception if there isn't enough data. Raises: EOFError: if the connection is closed without complete headers. SecurityError: if the request exceeds a security limit. ValueError: if the request isn't well formatted. rNz,connection closed while reading HTTP headers:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r!r"ztoo many HTTP headers)rZHeadersrange MAX_HEADERSr&r'r(r)r _token_rerIstriprHrrrM) rr_liner-raw_nameZ raw_valuenamer rrrr*s4         r*Generator[None, None, bytes]ccsLz |tEdH}Wn tytdw|ds td|ddS)ao Parse a single line. CRLF is stripped from the return value. Args: read_line: generator-based coroutine that reads a LF-terminated line or raises an exception if there isn't enough data. Raises: EOFError: if the connection is closed without a CRLF. SecurityError: if the response exceeds a security limit. Nz line too longs zline without CRLF)MAX_LINErLrrMendswithr')rrZrrrr&Gs    r&)r r r r )rrr rR)rrr r]) __future__r dataclassesretypingrrrrrrVr_rKrcompilerWrH dataclassrr=r*r&rrrrs$   \ 3