tni=ddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZgd Zd jejZejd d ed eZejdd ed eZeejddZeejddZeejddZd-dZejdZejdZ ej!GddZ"ej!GddZ#d.d#Z$d/d%Z%d0d,Z&dS)1) 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_576valuebytes | bytearrayreturnstrc.|dS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)rs N/var/www/html/gpu-tools/venv/lib/python3.11/site-packages/websockets/http11.pydr 2s <<1< 2 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*cneZdZUdZded<ded<dZded<edd ZeddZ ddZ dS)r z WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. rpathrheadersNException | None _exceptionrcDtjdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningr&selfs r exceptionzRequest.exception^s& W    r! read_line9Callable[[int], Generator[None, None, bytes | bytearray]]Generator[None, None, Request]c#K t|Ed{V}n"#t$r}td|d}~wwxYw |dd\}}}n.#t$r!tdt |dwxYw|dkrtdt ||dkrtd t ||d d }t |Ed{V}d |vrtd d|vr(t|ddkrtd|||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-Lengthrzunsupported request body) parse_lineEOFErrorsplit ValueErrorr r parse_headersNotImplementedErrorint) clsr/ request_lineexcmethodraw_pathprotocolr#r$s rparsez Request.parsefsF Y&0&;&;;;;;;;LL Y Y YNOOUX X Y X)5););D!)D)D &FHhh X X XL1\??LLMMSW W X { " "MAlOOMM  V  V1V99VVWW Ww(9::*955555555 ' ) )%&IJJ J w & &7+,--22 !;<<<s4!!!s 949A+Bbytescxd|jd}||jz }|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )r#encoder$ serialize)r-requests rrLzRequest.serializes?211188::4<))+++r!rr%)r/r0rr1rrI) __name__ __module__ __qualname____doc____annotations__r&propertyr. classmethodrHrLr!rr r NsIII$(J'''' X@"@"@"[@"D      r!r ceZdZUdZded<ded<ded<dZd ed <d Zd ed <eddZe dddZ ddZ d S)r z WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body. rA status_coder reason_phraserr$r!rbodyNr%r&rcDtjdt|jS)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr(r,s rr.zResponse.exceptions(  7    r!Fr/r0 read_exact read_to_eofproxyboolGenerator[None, None, Response]c#K t|Ed{V}n"#t$r}td|d}~wwxYw |dd\}}} n.#t$r!tdt |dwxYw|r$|dvrtdt |n%|dkrtd t | t |} n.#t$r!td t |dwxYwd | cxkrd ks!ntd t |t | stdt | | dd} t|Ed{V} |rd} nt| | |||Ed{V} || | | | 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 liner3r4zinvalid HTTP status line: )r5sHTTP/1.0z5unsupported protocol; expected HTTP/1.1 or HTTP/1.0: r5r6z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r7r8r!) r;r<r=r>r rA _value_re fullmatchrr? read_body)rBr/r]r^r_ status_linerDrGraw_status_code raw_reasonrYreasonr$r[s rrHzResponse.parsesB X%/ %:%:::::::KK 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""7,=>>*955555555  DD'Wi[Ds;666s' 949A+BC""+D rIcd|jd|jd}||jz }||jz }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rYrZrKr$rLr[)r-responses rrLzResponse.serialize!sXKt/JJ$2DJJJQQSSDL**,,,DIr!rN)F) r/r0r]r0r^r0r_r`rrarO) rPrQrRrSrTr[r&rUr.rVrHrLrWr!rr r s  !D!!!!#'J'''' X  L7L7L7L7[L7\      r!r r/r0(Generator[None, None, bytes | bytearray]c#K |tEd{V}n#t$rtdwxYw|dst d|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 RuntimeErrorrendswithr<)r/lines rr;r;.s"-#)O44444444 ---O,,,- == ! !,*+++ 9s5Generator[None, None, Headers]c#Kt}ttdzD]E} t|Ed{V}n"#t$r}t d|d}~wwxYw|dkrn |dd\}}n.#t $r!t dt|dwxYwt |st dt|| d}t |st d t|| d }| d d }|||<Gtd |S) 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 headersr!:zinvalid HTTP header line: zinvalid HTTP header name: s zinvalid HTTP header value: r7r8ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr;r<r=r>r _token_rerestriprdrr) r/r$_rurDraw_name raw_valuenamers rr?r?Is,iiG ?Q& ' '55 T(33333333DD 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''  *;<< 3444 Ns#A A! AA!.B+B3rYrAr$rr]r^c#<Kd|cxkrdksn|dks|dkrdS|dx}.|dkrtd|d d} t|Ed{V}|d d d }t |dkr)|d} t d| dt|d} | d krnwt || ztkr#t d| dt |d||| Ed{Vz }|dEd{Vdkrtdt|Ed{V|S|dx} dt | dkrt d| dt| } | tkrt d| d|| Ed{VS |tEd{VS#t$rt dtdwxYw)Nrci0r!r9chunkedztransfer coding z isn't supportedT;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r4rpzchunk without CRLFr:zbody too large: zbody too large: over ) getr@r;r=lenrrrA MAX_BODY_SIZEr>r?rs) rYr$r/r]r^codingr[chunk_size_lineraw_chunk_sizestr_chunk_size chunk_sizeraw_content_lengthcontent_lengths rrfrf|s kC;##5#59K9KsKK 344 4& A Y  %&Q&Q&Q&QRR R 7)3I)>)>>>>>>>O,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 O*{=99999999 : O O O M M M MNN N Os "G88#H)rrrr)r/r0rrn)r/r0rrv) rYrAr$rr/r0r]r0r^r0rrn)' __future__r dataclassesosresysr)collections.abcrtypingrdatastructuresr exceptionsrr websockets_version__all__format version_infoPYTHON_VERSIONenvironrr r rArzrrrr compiler{rd dataclassr r r;r?rfrWr!rrs"""""" %%%%%%######%%%%%%222222    !12Z^^>n>>*<>> >n>>*<>>   #bjnn%A5IIJJ#bjnn%A6JJKKBJNN#={KKLL 3333 BJ7 8 8  BJ4 5 5  ccccccccL uuuuuuuup60000f:O:O:O:O:O:Or!