o _i=@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{}.{}WEBSOCKETS_USER_AGENTzPython/z websockets/WEBSOCKETS_SERVERWEBSOCKETS_MAX_NUM_HEADERS128WEBSOCKETS_MAX_LINE_LENGTH8192WEBSOCKETS_MAX_BODY_SIZE 1_048_576valuebytes | bytearrayreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)rrS/sda-disk/www/egybert/egybert_env/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 insteadwarningswarnDeprecationWarningr#selfrrr 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, request_lineexcmethodraw_pathprotocolr r!rrrparsefs4#     z Request.parsebytescCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )r encoder! serialize)r*requestrrrrGszRequest.serializerr")r,r-rr.rrE) __name__ __module__ __qualname____doc____annotations__r#propertyr+ classmethodrDrGrrrrr 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. r= status_coder reason_phraserr!rbodyNr"r#rcCr$)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr%r)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/r0zinvalid HTTP status line: )r1sHTTP/1.0z5unsupported protocol; expected HTTP/1.1 or HTTP/1.0: r1r2z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r3r4rT) r7r8r9r:rr= _value_re fullmatchrr; read_body)r>r,rVrWrX status_liner@rCraw_status_code raw_reasonrRreasonr!rUrrrrDs^!           zResponse.parserEcCs6d|jd|jd}||j7}||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rRrSrFr!rGrU)r*responserrrrG!s zResponse.serializerI)F) r,r-rVr-rWr-rXrYrrZrJ) rKrLrMrNrOrUr#rPr+rQrDrGrrrrr 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 RuntimeErrorrendswithr8)r,linerrrr7.s   r7Generator[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 headersrT:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r3r4ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr7r8r9r:r _token_rer]stripr\rr) r,r!_rkr@raw_name raw_valuenamerrrrr;Is4        r;rRr=r!rrVrWc 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)Nr[i0rTr5chunkedztransfer coding z isn't supportedT;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r0rfzchunk without CRLFr6zbody too large: zbody too large: over ) getr<r7r9lenrrr= MAX_BODY_SIZEr:r;ri) rRr!r,rVrWcodingrUchunk_size_lineraw_chunk_sizestr_chunk_size chunk_sizeraw_content_lengthcontent_lengthrrrr^|sL&      r^)rrrr)r,r-rre)r,r-rrl) rRr=r!rr,r-rVr-rWr-rre)' __future__r dataclassesosresysr&collections.abcrtypingrdatastructuresr exceptionsrrwebsockets_version__all__format version_infoPYTHON_VERSIONenvironr}r r r=rorhrrcompilerpr\ dataclassr r r7r;r^rrrrsD         f x 3