o :h1@sddlmZddlZddlZddlZddlmZmZmZddl m Z m Z dZ dZ dZdd dZedZedZejGdddZejGdddZdddZdddZdS) ) annotationsN)Callable GeneratorOptional)datastructures exceptionsi ivaluebytesreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)r r^/var/www/html/HyperOracle/crypto_trader/venv/lib/python3.10/site-packages/websockets/http11.pyds rs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*c@sTeZdZUdZded<ded<dZded<edd d ZedddZ dddZ dS)Requestz WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. r pathdatastructures.HeadersheadersNOptional[Exception] _exceptionr cCtdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningrselfrrr exceptionC zRequest.exception read_line-Callable[[int], Generator[None, None, bytes]]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) clsr# request_lineexcmethodraw_pathversionrrrrrparseLs.#    z Request.parser cCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )rencoder serialize)r requestrrrr=szRequest.serializer r)r#r$r r%r r ) __name__ __module__ __qualname____doc____annotations__rpropertyr! classmethodr;r=rrrrr3s    >rc@sheZdZUdZded<ded<ded<dZd ed <dZd ed <edddZe dddZ dddZ dS)Responsez WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body, if any. int status_coder reason_phraserrNzOptional[bytes]bodyrrr cCr)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadrrrrrr!r"zResponse.exceptionr#r$ read_exact read_to_eofGenerator[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 stream. 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 liner&r'zinvalid HTTP status line: r(r)zinvalid HTTP status code: dizunsupported HTTP status code: zinvalid HTTP reason phrase: r,r-i0r.zbody too large: over z byteszbody too large: )r/r0r1r2rrI _value_re fullmatchrr3r4KeyErrorMAX_BODY RuntimeErrorr SecurityError)r5r#rMrN status_liner7r:raw_status_code raw_reasonrJreasonrrLraw_content_lengthcontent_lengthrrrr;sj       &     zResponse.parser cCs@d|jd|jd}||j7}|jdur||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z N)rJrKr<rr=rL)r responserrrr=s   zResponse.serializer?)r#r$rMr$rNr$r rOr@) rArBrCrDrErLrrFr!rGr;r=rrrrrHs      ^rHr#r$-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)rHeadersrange MAX_HEADERSr/r0r1r2r _token_rerTstriprSrrrX) r#r_liner7raw_name raw_valuenamer rrrr3!s4         r3Generator[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_LINErWrrXendswithr0)r#rjrrrr/Ts    r/)r r r r )r#r$r ra)r#r$r rn) __future__r dataclassesrertypingrrrrrrfrprVrcompilergrS dataclassrrHr3r/rrrrs&   c 3