o Yi=@sVddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZgd Zd jejZejd d ed eZejdd ed eZeejddZeejddZeejddZd1ddZedZedZ ej!GdddZ"ej!Gdd d Z#d2d$d%Z$d3d'd(Z%d4d/d0Z&dS)5) 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_576valuebytes | bytearrayreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)r rK/home/kim/smarthome/.venv/lib/python3.10/site-packages/websockets/http11.pyd2s rs[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*c@sTeZdZUdZded<ded<dZded<edd d ZedddZ dddZ dS)r z WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. rpathrheadersNException | None _exceptionrcCtdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningrselfrrr exception^s zRequest.exception read_line9Callable[[int], Generator[None, None, bytes | bytearray]]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|vrxt|ddkrxtd|||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-Lengthrzunsupported request body) parse_lineEOFErrorsplit ValueErrorrr parse_headersNotImplementedErrorint) clsr$Z request_lineexcmethodraw_pathprotocolrrrrrparsefs4#     z Request.parsebytescCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )rencoder serialize)r"requestrrrr>szRequest.serializerr)r$r%rr&rr<) __name__ __module__ __qualname____doc____annotations__rpropertyr# classmethodr;r>rrrrr Ns    Br c@sleZdZUdZded<ded<ded<dZd ed <d Zd ed <edddZe dd ddZ d!ddZ d S)"r z WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body. r5 status_coder reason_phraserrrbodyNrrrcCr)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadrr!rrrr#s zResponse.exceptionFr$r% read_exact read_to_eofproxyboolGenerator[None, None, Response]c cshz t|EdH}Wnty}ztd|d}~wwz |dd\}}} Wnty8tdt|dw|rI|dvrHtdt|n |dkrVtd t|zt|} Wntymtd t|dwd | krxd ksntd t|t| stdt| | dd} t |EdH} |rd} n t | | |||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)sHTTP/1.0z5unsupported protocol; expected HTTP/1.1 or HTTP/1.0: r)r*z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r+r,rK) r/r0r1r2rr5 _value_re fullmatchrr3 read_body)r6r$rMrNrOZ status_liner7r:Zraw_status_codeZ raw_reasonrIreasonrrLrrrr;s^!           zResponse.parser<cCs6d|jd|jd}||j7}||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rIrJr=rr>rL)r"responserrrr>!s zResponse.serializer@)F) r$r%rMr%rNr%rOrPrrQrA) rBrCrDrErFrLrrGr#rHr;r>rrrrr s     Nr r$r%(Generator[None, None, bytes | bytearray]ccsJz |tEdH}Wn tytdw|dstd|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/Generator[None, None, Headers]c cst}ttdD]p}z t|EdH}Wnty&}ztd|d}~ww|dkr.|Sz |dd\}}WntyItdt|dwt |sXtdt|| d}t |sktd t|| d }| d d }|||<q t d ) 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 headersrK:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r+r,ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr/r0r1r2r _token_rerTstriprSrr) r$r_r_r7raw_name raw_valuenamer rrrr3Is4        r3rIr5rrrMrNc csd|kr dksn|dks|dkrdS|d}dur|dkr+td|d d} t|EdH}|d d d }t|dkrQ|jdd} td| dt|d} | d kr[n,t|| tkrptd| dt|d||| EdH7}|dEdHdkrt dq.t |EdH|S|d} durt| dkrtd| dt| } | tkrtd| d|| EdHSz|tEdHWSt ytdtdw)NrRi0rKr-chunkedztransfer coding z isn't supportedT;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r(rZzchunk without CRLFr.zbody too large: zbody too large: over ) getr4r/r1lenrrr5 MAX_BODY_SIZEr2r3r]) rIrr$rMrNZcodingrLZchunk_size_lineZraw_chunk_sizeZstr_chunk_size chunk_sizeZraw_content_lengthcontent_lengthrrrrU|sL&      rU)r rrr)r$r%rrY)r$r%rr`) rIr5rrr$r%rMr%rNr%rrY)' __future__r dataclassesosresysrcollections.abcrtypingrZdatastructuresr exceptionsrrZwebsockets_version__all__format version_infoPYTHON_VERSIONenvironrqr r r5rcr\rsrcompilerdrS dataclassr r r/r3rUrrrrsD         f x 3