o DRh@4@sDddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZgdZd jejZejd d ed eZejd d ed eZeejddZeejddZeejddZd(ddZedZedZej GdddZ!ej GdddZ"d)d#d$Z#d*d&d'Z$dS)+) annotationsN)Callable Generator)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. backslashreplace)errors)decode)rrS/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/websockets/http11.pyd,s 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 exceptionX 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-Encoding!transfer codings aren't supportedContent-Lengthzunsupported request body) parse_lineEOFErrorsplit ValueErrorrr parse_headersNotImplementedError) clsr, request_lineexcmethodraw_pathprotocolrr rrrparseas2#     z Request.parsercCs$d|jd}||j7}|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )rencoder serialize)r)requestrrrrFszRequest.serializerr!)r,r-rr.rr) __name__ __module__ __qualname____doc____annotations__r"propertyr* classmethodrDrFrrrrr Hs    ?r c@sheZdZUdZded<ded<ded<dZd ed <dZd ed <edddZe dddZ dddZ dS)r z WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body, if any. int status_coder reason_phraserr Nz bytes | Nonebodyr!r"rcCr#)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr$r(rrrr*r+zResponse.exceptionr,r- read_exact read_to_eofGenerator[None, None, Response]c csz t|EdH}Wnty}ztd|d}~wwz |dd\}}}Wnty8tdt|dw|dkrFtdt|zt|} Wnty]tdt|dwd | krhd ksrntd t|t|std t||d d} t |EdH} d| vrt dd | krdksn| dks| dkrd} nFz| d} Wn t yd}Ynwt| }|durz |t EdH} Wn"t ytdt dw|t krtd|d||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: r1r2z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r3r4r5r6i0r7zbody too large: over z byteszbody too large: )r8r9r:r;rrQ _value_re fullmatchrr<r=KeyError MAX_BODY_SIZE RuntimeErrorr)r>r,rUrV status_liner@rCraw_status_code raw_reasonrRreasonr rTraw_content_lengthcontent_lengthrrrrDsj          &   zResponse.parsercCs@d|jd|jd}||j7}|jdur||j7}|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z N)rRrSrEr rFrT)r)responserrrrF(s   zResponse.serializerH)r,r-rUr-rVr-rrWrI) rJrKrLrMrNrTr"rOr*rPrDrFrrrrr s      ]r r,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 headers:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r3r4ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr8r9r:r;r _token_rer\stripr[rr) r,r _liner@raw_name raw_valuenamerrrrr<6s4        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 longs zline without CRLF)MAX_LINE_LENGTHr_rendswithr9)r,rprrrr8is   r8)rrrr)r,r-rrh)r,r-rrt)% __future__r dataclassesosresysr%typingrrdatastructuresr exceptionsrrwebsockets_version__all__format version_infoPYTHON_VERSIONenvirongetr r rQrlrvr^rcompilermr[ dataclassr r r<r8rrrrsB       d 3