o KK&hM:@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_576valuebytesreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)rrD/var/www/html/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 insteadwarningswarnDeprecationWarningr#selfrrr exception^s 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: 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, request_lineexcmethodraw_pathprotocolr r!rrrparsefs2#     z Request.parsercCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )r encoder! serialize)r*requestrrrrEszRequest.serializerr")r,r-rr.rr) __name__ __module__ __qualname____doc____annotations__r#propertyr+ classmethodrCrErrrrr Ns    ?r c@sleZdZUdZded<ded<ded<dZd ed <d Zd ed <edddZe ddddZ d ddZ 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_phraserr!rbodyNr"r#rcCr$)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr%r)rrrr+s zResponse.exceptionTr,r- read_exact read_to_eof include_bodyboolGenerator[None, None, Response]c csHz t|EdH}Wnty}ztd|d}~wwz |dd\}}} Wnty8tdt|dw|dkrFtdt|zt|} Wnty]tdt|dwd | krhd ksrntd t|t| std t| | d d} t |EdH} |rt | | |||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/r0zinvalid HTTP status line: r1r2z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r3r4rS) r7r8r9r:rrP _value_re fullmatchrr; read_body)r=r,rUrVrW status_liner?rBraw_status_code raw_reasonrQreasonr!rTrrrrCsN!           zResponse.parsecCs6d|jd|jd}||j7}||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rQrRrDr!rErT)r*responserrrrEs zResponse.serializerG)T) r,r-rUr-rVr-rWrXrrYrH) rIrJrKrLrMrTr#rNr+rOrCrErrrrr s     Fr r,r-Generator[None, None, bytes]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 headersrS: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!_rjr?raw_name raw_valuenamerrrrr;>s4        r;rQrPr!rrUrVc 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)NrZi0rSr5chunkedztransfer coding z isn't supportedT;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r0rezchunk without CRLFr6zbody too large: zbody too large: over ) getr<r7r9lenrrrP MAX_BODY_SIZEr:r;rh) rQr!r,rUrVcodingrTchunk_size_lineraw_chunk_sizestr_chunk_size chunk_sizeraw_content_lengthcontent_lengthrrrr]qsL&      r])rrrr)r,r-rrd)r,r-rrk) rQrPr!rr,r-rUr-rVr-rrd)' __future__r dataclassesosresysr&collections.abcrtypingrdatastructuresr exceptionsrrwebsockets_version__all__format version_infoPYTHON_VERSIONenvironr|r r rPrnrgr~rcompileror[ dataclassr r r7r;r]rrrrsD         c p 3