a њhM:@svddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZgd Zd jejZejd d ed eZejdd ed eZeejddZeejddZeejddZdddddZedZedZ ej!GdddZ"ej!GdddZ#d d!d"d#d$Z$d d%d"d&d'Z%d(d)d d d d!d*d+d,Z&dS)-) annotationsN) Generator)Callable)Headers) SecurityError)version)SERVER USER_AGENTRequestResponsez{}.{}ZWEBSOCKETS_USER_AGENTzPython/z websockets/ZWEBSOCKETS_SERVERZWEBSOCKETS_MAX_NUM_HEADERSZ128ZWEBSOCKETS_MAX_LINE_LENGTHZ8192ZWEBSOCKETS_MAX_BODY_SIZEZ 1_048_576bytesstr)valuereturncCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)rrL/wd/webapps/venvs/v2025_4um/lib/python3.9/site-packages/websockets/http11.pyd2srs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*c@sbeZdZUdZded<ded<dZded<edd d d Zed d dddZ dd ddZ dS)r z WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. rpathrheadersNException | None _exceptionrcCstdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningrselfrrr exception^s zRequest.exception-Callable[[int], Generator[None, None, bytes]]zGenerator[None, None, Request] read_linerc cszt|EdH}Wn.ty@}ztd|WYd}~n d}~00z|dd\}}}Wn&ty~tdt|dYn0|dkrtdt||dkrtd t||d d }t|EdH}d |vrtd d|vrtd|||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: HTTP/1.1)unsupported protocol; expected HTTP/1.1: sGETz+unsupported HTTP method; expected GET; got asciisurrogateescapeTransfer-Encodingz!transfer codings aren't supportedContent-Lengthzunsupported request body) parse_lineEOFErrorsplit ValueErrorrr parse_headersNotImplementedError) clsr&Z request_lineexcmethodraw_pathprotocolrrrrrparsefs*#    z Request.parser cCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )rencoder serialize)r"requestrrrr<szRequest.serialize) __name__ __module__ __qualname____doc____annotations__rpropertyr# classmethodr:r<rrrrr Ns  ?r c@s~eZdZUdZded<ded<ded<dZd ed <d Zd ed <ed dddZe dddddddddZ d dddZ d S)r z WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body. int status_coder reason_phraserrr bodyNrrrcCstdt|jS)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadrr!rrrr#s zResponse.exceptionTr$boolzGenerator[None, None, Response])r& read_exact read_to_eof include_bodyrc cs^zt|EdH}Wn.ty@}ztd|WYd}~n d}~00z|dd\}}} Wn&ty~tdt|dYn0|dkrtdt|z t|} Wn&tytdt|dYn0d | krd ksntd t|t| std t| | d d} t |EdH} |rLt | | |||EdH} nd} || | | | 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*z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r+r,rH) r/r0r1r2rrE _value_re fullmatchrr3 read_body)r5r&rKrLrMZ status_liner6r9Zraw_status_codeZ raw_reasonrFreasonrrIrrrr:sD!          zResponse.parsecCs6d|jd|jd}||j7}||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rFrGr;rr<rI)r"responserrrr<s zResponse.serialize)T) r>r?r@rArBrIrrCr#rDr:r<rrrrr s    Fr r$zGenerator[None, None, bytes]r%ccsLz|tEdH}Wnty,tdYn0|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 long zline without CRLF)MAX_LINE_LENGTH RuntimeErrorrendswithr0)r&linerrrr/#s  r/zGenerator[None, None, Headers]c cst}ttdD]}zt|EdH}Wn.tyV}ztd|WYd}~n d}~00|dkrfq z|dd\}}Wn&tytdt|dYn0t |stdt|| d}t |std t|| d }| d d }|||<qt d |S) 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 headersrH:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r+r,ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr/r0r1r2r _token_rerPstriprOrr) r&r_rZr6raw_name raw_valuenamerrrrr3>s,        r3rEr)rFrr&rKrLrc csd|krdks&n|dks&|dkr*dS|d}dur |dkrVtd|d d}t|EdH}|d d d }t|d kr|jdd} td| dt|d} | d krqt|| tkrtd| dt|d||| EdH7}|dEdHdkrZt dqZt |EdH|S|d} durt| dkrRtd| dt| } | tkrttd| d|| EdHSz|tEdHWSt ytdtdYn0dS)NrNi0rHr-chunkedztransfer coding z isn't supported;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r(rUzchunk without CRLFr.zbody too large: zbody too large: over ) getr4r/r1lenrrrE MAX_BODY_SIZEr2r3rX) rFrr&rKrLZcodingrIZchunk_size_lineZraw_chunk_sizeZstr_chunk_size chunk_sizeZraw_content_lengthcontent_lengthrrrrQqsD &     rQ)' __future__r dataclassesosresysrcollections.abcrtypingrZdatastructuresr exceptionsrrZwebsockets_version__all__format version_infoPYTHON_VERSIONenvironrkr r rEr]rWrmrcompiler^rO dataclassr r r/r3rQrrrrsB        cp3