o ZhM:@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_576valuebytesreturnstrcCs |jddS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)r rH/var/www/html/lang_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 insteadwarningswarnDeprecationWarningrselfrrr 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$Z request_lineexcmethodraw_pathprotocolrrrrrparsefs2#     z Request.parsercCs$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    ?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_phraserrrbodyNrrrcCr)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadrr!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'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,rJ) r/r0r1r2rrG _value_re fullmatchrr3 read_body)r5r$rLrMrNZ status_liner6r9Zraw_status_codeZ raw_reasonrHreasonrrKrrrr:sN!           zResponse.parsecCs6d|jd|jd}||j7}||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rHrIr;rr<rK)r"responserrrr<s zResponse.serializer>)T) r$r%rLr%rMr%rNrOrrPr?) r@rArBrCrDrKrrEr#rFr:r<rrrrr 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 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 headersrJ:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r+r,ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr/r0r1r2r _token_rerSstriprRrr) r$r_r^r6raw_nameZ raw_valuenamer rrrr3>s4        r3rHrGrrrLrMc 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)NrQi0rJr-chunkedztransfer coding z isn't supportedT;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r(rYzchunk without CRLFr.zbody too large: zbody too large: over ) getr4r/r1lenrrrG MAX_BODY_SIZEr2r3r\) rHrr$rLrMZcodingrKZchunk_size_lineZraw_chunk_sizeZstr_chunk_size chunk_sizeZraw_content_lengthcontent_lengthrrrrTqsL&      rT)r rrr)r$r%rrX)r$r%rr_) rHrGrrr$r%rLr%rMr%rrX)' __future__r dataclassesosresysrcollections.abcrtypingrZdatastructuresr exceptionsrrZwebsockets_version__all__format version_infoPYTHON_VERSIONenvironror r rGrbr[rqrcompilercrR dataclassr r r/r3rTrrrrsD         c p 3