^QjHTddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZddlmZgd Zd j,ej.Zej2j5d d ed eZej2j5dd ed eZeej2j5ddZeej2j5ddZeej2j5ddZ d!dZ!ejDdZ#ejDdZ$ejDdZ%ejDdZ&ejNGddZ(ejNGddZ)ef d"dZ* d#dZ+ d$d Z,y)%) 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_576c&|jdS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)values V/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/websockets/http11.pydr 8s <<1< 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*s [0-9]{1,18}s[0-9a-fA-F]{1,15}ceZdZUdZded<ded<dZded<dZded <d Zd ed <edd Z e ddZ ddZ y )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. strpathrheadersGETmethodzHTTP/1.1protocolNException | None _exceptioncNtjdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningr*selfs r exceptionzRequest.exception{s  W  r!c#>K t|tEd{} |jdd\}}}|dvrt dt ||j d}|j d}|j d} t|Ed{} d | vr td t| jd d hks t d || | ||S7#t$r}td|d}~wwxYw#t$rt dt |dwxYw7w)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. NotImplementedError: If the request uses Transfer-Encoding. 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-Length0zunsupported request body) parse_liner EOFErrorsplit ValueErrorr r parse_headersNotImplementedErrorsetget_all) cls read_line request_lineexc raw_methodraw_path raw_protocolr'r(r$r%s rparsez Request.parsesMR Y&078 84&(33CP YNOUX X Y  X:1\?:KLMSW W X6sVDCCCC6ADDADC C3" C..C33D6"DDc|jd|jd|jd}|jd}||jj z }|S)z; Serialize a WebSocket handshake request.   r9)r'r$r(encoder% serialize)r1rGrequests rrQzRequest.serializesT++a {!DMM?$G %%g.4<<))++r!returnr))rFJCallable[[int, type[Exception]], Generator[None, None, bytes | bytearray]]rTzGenerator[None, None, Request]rTbytes) __name__ __module__ __qualname____doc____annotations__r'r(r*propertyr2 classmethodrLrQr!rrras{  I FCHc$(J ' J4 J4 ( J4J4X r!rceZdZUdZded<ded<ded<dZd ed <d Zd ed <eddZe d ddZ ddZ y )raw WebSocket handshake response. ``reason_phrase`` and ``headers`` should contain only ASCII characters; however, non-ASCII reason phrases and header values are tolerated and encoded as ISO-8859-1. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body. int status_coder# reason_phraserr%r!bytes | bytearraybodyNr)r*cNtjdt|jS)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr,r0s rr2zResponse.exceptions"  7  r!c#K t|tEd{} |jdd\}}} |r|dvr3t dt ||dk7rt d t |t j|st d t |t|} d | cxkrd ksnt d t |tj| st dt | | jd} t|Ed{} |rd} nt| | |||Ed{} || | | | S7'#t$r}td|d}~wwxYw#t$rt dt |dwxYw7p7Vw)a Parse a WebSocket handshake response. This is a generator-based coroutine. The reason phrase and headers should contain only ASCII characters; however, non-ASCII reason phrases and header 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. 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. StatusLineTooLong: If the status line is too long. HeaderLineTooLong: If a header line is too long. TooManyHeaders: If there are too many headers. SecurityError: If the response body exceeds a security limit. LookupError: If the response isn't well formatted. ValueError: If the response isn't well formatted. NotImplementedError: If the response uses Transfer-Encoding, and it isn't "chunked". Nz0connection closed while reading HTTP status liner4r5zinvalid HTTP status line: r6r8r7z)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!) r=r r>r?r@r _digits_re fullmatchra _value_rerrA read_body)rErF read_exact read_to_eofproxy status_linerHr(raw_status_code raw_reasonrbreasonr%res rrLzResponse.parsesV X%/ ;L%MMK V4?4E4EdA4N 1Hoz 99 K~&( ;& ?+?OP##O4=a>P=QR /* k'C'?/@R?ST "":.;AjM?KL L""<0*955 D'Wi[D;66[N XMNTW W X  V9!K.9IJKQU U V:6 sgFED>EECFFF.F/F>E E EEF"FFFcd|jd|jd}|jd}||jj z }||j z }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1 rNrOri)rbrcrPr%rQre)r1rqresponses rrQzResponse.serializeYs` "$"2"2!31T5G5G4HM %%l3DLL**,,DIIr!rS)F) rFrUrn9Callable[[int], Generator[None, None, bytes | bytearray]]rorUrpboolrTzGenerator[None, None, Response]rV) rXrYrZr[r\rer*r]r2r^rLrQr_r!rrrs  !D !#'J ' X7 X7 N X7  X7X7 )X7X7t r!rc#zK|t|Ed{}|jds td|ddS7%w)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_LENGTHendswithr>)rFtoo_long_exc_typelines rr=r=fsB, 1BC CD == !*++ 9 Ds ;9&;c#Kt}ttdzD]} t|tEd{}|dk(r|S |j dd\}}tj|stdt||jd}tj|std t||jd }|jd }|j||td td 7#t $r}t d|d}~wwxYw#t$rtdt|dwxYww)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: r9rizexpected no more than z headers)rrangeMAX_NUM_HEADERSr=rr>r?r@r _token_rerkstriprlr set_insecurer ) rFr%_rrHraw_name raw_valuenamers rrArAsc4iG ?Q& 'Q T(4EFFD 3; 4 N1 O"&**T1"5 Hi""8,9!H+GH HOOF+ ""9-:1Y<.IJ Jw'   . T5)7Q<5o5FhOPP9G TIJPS S T O9!D'CD$ N OsP ED D D ED*B2E D  D' D""D''E*"E  Ec#Kd|cxkrdks n|dk(s|dk(ry|jdx}|dk7rtd|d d} t|tEd{}|j d d d }t j |std t|t|d} | d k(rnbt|| ztkDrtd| dt|d||| Ed{z }|dEd{dk7r tdt|Ed{|S|jdx} etj | jdstd| t| } | tkDrtd| d|| Ed{S|ttEd{S7`7777&7w)Nrhi0r!r:chunkedztransfer coding z isn't supported;rrzinvalid chunk size: zchunk too large: z bytes after z bytesr5rzzchunk without CRLFr;rizinvalid content length: zbody too large: )getrBr=r r? _hexdigits_rerkr ralen MAX_BODY_SIZEr@rArjrP) rbr%rFrnrocodingrechunk_size_lineraw_chunk_size chunk_sizeraw_content_lengthcontent_lengths rrmrms kC;##59KKK 34 4& A Y %(8@P&QR R)3I})MMO,224;A>N **>:#&:1^;L:M$NOO^R0JQ4y:% 5#' |=T 6R z*55 5D%a=(W4 !566 !+++ ' ,< = =  J##$6$=$=l$KL":;M:N OP P/0 M )"2>2B& IJ J%n556'}mDDE7N6( ,6EsnAGF8BG,F;-G>F=?!G F?!A9GGG3G4G;G=G?GGG)rrdrTr#)rFrUr~ztype[Exception]rT(Generator[None, None, bytes | bytearray])rFrUrTzGenerator[None, None, Headers]) rbrar%rrFrUrnrwrorUrTr)- __future__r dataclassesosresysr-collections.abcrtypingrdatastructuresr exceptionsrr r r r r websockets_version__all__format version_infoPYTHON_VERSIONenvironrrrrarr|rr compilerrlrjr dataclassrrr=rArmr_r!rrs" %#3  !1!12ZZ^^ n \*<)=>  n \*<)=>  bjjnn%A5IJbjjnn%A6JKBJJNN#={KL 3 BJJ7 8  BJJ4 5 RZZ (  01  xxxv EEEX*7 '  . :;;$ ;|8F8F 8F8F J 8F8F.8Fr!