xj2IddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZddlmZgd Zd jejZejd d ed eZejdd ed eZeejddZeejddZeejddZ d0dZ!ej"dZ#ej"dZ$ej%GddZ&ej%GddZ'efd1d%Z(d2d'Z)d3d/Z*dS)4) annotationsN) Generator)Callable)Headers)HeaderLineTooLongRequestLineTooLong SecurityErrorStatusLineTooLongTooManyHeaders)version)SERVER USER_AGENTRequestResponsez{}.{}WEBSOCKETS_USER_AGENTzPython/z websockets/WEBSOCKETS_SERVERWEBSOCKETS_MAX_NUM_HEADERS128WEBSOCKETS_MAX_LINE_LENGTH8192WEBSOCKETS_MAX_BODY_SIZE 1_048_576valuebytes | bytearrayreturnstrc.|dS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)rs BC:\Projects\Historical\venv\Lib\site-packages\websockets/http11.pydr$8s <<1< 2 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*ceZdZUdZded<ded<dZded<dZded <d Zd ed <eddZ e ddZ ddZ d S)ra WebSocket handshake request. ``method`` and ``path`` must contain only ASCII characters. ``headers`` should contain only ASCII characters; however, non-ASCII header values are tolerated and encoded as ISO-8859-1. Attributes: path: Request path, including optional query. headers: Request headers. method: Request method; WebSocket handshake requests use GET. protocol: Request protocol; WebSocket handshake requests use HTTP/1.1. rpathrheadersGETmethodzHTTP/1.1protocolNException | None _exceptionrcDtjdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningr-selfs r# exceptionzRequest.exceptionns& W    r% read_lineJCallable[[int, type[Exception]], Generator[None, None, bytes | bytearray]]Generator[None, None, Request]c#K t|tEd{V}n"#t$r}td|d}~wwxYw |dd\}}}n.#t$r!t dt |dwxYw|dvrt dt ||d}|d}|d} t|Ed{V} d | vrtd d | vr(t| d d krt d || | ||S)a Parse a WebSocket handshake request. This is a generator-based coroutine. The request method and path must contain only ASCII characters. The request path isn't URL-decoded or validated in any way. Request headers should contain only ASCII characters; however, non-ASCII header values are tolerated and decoded with ISO-8859-1. :meth:`parse` doesn't 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. RequestLineTooLong: If the request line is too long. HeaderLineTooLong: If a header line is too long. TooManyHeaders: If there are too many headers. UnicodeDecodeError: If the request method or path isn't ASCII. ValueError: If the request isn't well formatted. Nz1connection closed while reading HTTP request line zinvalid HTTP request line: HTTP/1.1sHTTP/1.05unsupported protocol; expected HTTP/1.1 or HTTP/1.0: asciiTransfer-Encodingz!transfer codings aren't supportedContent-Lengthrzunsupported request body) parse_liner EOFErrorsplit ValueErrorr$r" parse_headersNotImplementedErrorint) clsr6 request_lineexc raw_methodraw_path raw_protocolr*r+r'r(s r#parsez Request.parsevsP Y&0r=z)unsupported protocol; expected HTTP/1.1: z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: iso-8859-1r%) rBr rCrDrEr$rH _value_re fullmatchr"rF read_body)rIr6rfrhri status_linerKr+raw_status_code raw_reasonrbreasonr(rds r#rOzResponse.parsesR X%/ ;L%M%MMMMMMMKK X X XMNNTW W X V4?4E4EdA4N4N 1Hozz V V VJ!K..JJKKQU U V  999 (~~((: ;&& P+PP o..KK   Ra>P>PRR  k''''C''''T/@R@RTT "":.. MKAjMMKKLL L""<00*955555555  DD'Wi[Ds;666s( ?:?A+B C((+DrPcd|jd|jd}|d}||jz }||jz }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1 rRrSrn)rbrcrTr(rUrd)r4rrresponses r#rUzResponse.serializeJs_ N$"2MMT5GMMM %%l33DL**,,,DIr%rW)F) r6r7rfrgrhr7rirjrrkrX) rYrZr[r\r]rdr-r^r5r_rOrUr`r%r#rrs  !D!!!!#'J'''' XW7W7W7W7[W7r      r%rr6r7too_long_exc_typetype[Exception](Generator[None, None, bytes | bytearray]c#K|t|Ed{V}|dstd|ddS)a 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. too_long_exc_type: exception to raise if the line is too long; defaults to :exc:`SecurityError`. Raises: EOFError: If the connection is closed without a CRLF. SecurityError: If the response exceeds a security limit. N zline without CRLF)MAX_LINE_LENGTHendswithrC)r6rxlines r#rBrBWs], i1BCC C C C C C CD == ! !,*+++ 9r%Generator[None, None, Headers]c#>Kt}ttdzD][} t|tEd{V}n"#t $r}t d|d}~wwxYw|dkrn* |dd\}}n.#t$r!tdt|dwxYwt |stdt|| d}t |std t|| d }| d }|||]td td |S)a- Parse HTTP headers. Headers should contain only ASCII characters; however, non-ASCII values are tolerated and decoded as ISO-8859-1. 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. HeaderLineTooLong: If a header line is too long. TooManyHeaders: If there are too many headers. ValueError: If the request isn't well formatted. rNz,connection closed while reading HTTP headersr%:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r?rnzexpected no more than z headers)rrangeMAX_NUM_HEADERSrBrrCrDrEr$ _token_rerpstripror" set_insecurer ) r6r(_rrKraw_name raw_valuenamers r#rFrFts4iiG ?Q& ' 'QQ T(4EFFFFFFFFDD T T TIJJPS S T 3;; E O"&**T1"5"5 Hii O O OC!D''CCDD$ N O""8,, IG!H++GGHH HOOF++ ""9-- KI1Y<<IIJJ Jw''   .. T5))))OoOOOPPP Ns#A A'A""A'4B+B9rbrHr(rrfrgrhc#Kd|cxkrdksn|dks|dkrdS|dx}5|dkrtd|d d} t|tEd{V}|d d d }t |dkr)|d} td| dt|d} | d krnxt || ztkr#td| dt |d||| Ed{Vz }|dEd{Vdkrtdt|Ed{V|S|dx} dt | dkrtd| dt| } | tkrtd| d|| Ed{VS|ttEd{VS)Nrmi0r%r@chunkedztransfer coding z isn't supportedT;rrrr zchunk too large: 0xz byteszchunk too large: z bytes after r;r|zchunk without CRLFrAzbody too large: ) getrGrBr rDlenr"rH MAX_BODY_SIZErErF) rbr(r6rfrhcodingrdchunk_size_lineraw_chunk_sizestr_chunk_size chunk_sizeraw_content_lengthcontent_lengths r#rqrqs kC;##5#59K9KsKK 344 4& A Y  %&Q&Q&Q&QRR R 7)3I})M)MMMMMMMO,224;;A>N>""R''!/!6!6>P!6!Q!Q#$P.$P$P$PQQQ^R00JQ4yy:% 55#R RRTRRR zz*55555555 5D%:a==((((((W44 !5666! 7$!+++++++++ ' ,< = = =  J ! " "R ' ' M3E M M MNN N/00 M ) ) I> I I IJJ J%:n555555556';}mDDDDDDDDEr%)rrrr)r6r7rxryrrz)r6r7rr) rbrHr(rr6r7rfrgrhr7rrz)+ __future__r dataclassesosresysr0collections.abcrtypingrdatastructuresr exceptionsrr r r r r websockets_version__all__format version_infoPYTHON_VERSIONenvironrrrrHrr~rr$compilerro dataclassrrrBrFrqr`r%r#rs"""""" %%%%%%######322222    !12Z^^>n>>*<>> >n>>*<>>   #bjnn%A5IIJJ#bjnn%A6JJKKBJNN#={KKLL 3333 BJ7 8 8  BJ4 5 5  wwwwwwwwt DDDDDDDDV*7 :;;;;|;F;F;F;F;F;Fr%