gM: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_576valuebytesreturnstrc.|dS)zG Decode a bytestring for interpolating into an error message. backslashreplaceerrors)decode)rs ]/var/www/html/nodeJS/PythonScripts/venv3.11/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_line-Callable[[int], Generator[None, None, bytes]]Generator[None, None, Request]c#ZK 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|vrtd|||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 ValueErrorr r parse_headersNotImplementedError) 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 & &788 8s4!!!s 949A+Brcxd|jd}||jz }|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )r#encoder$ serialize)r-requests rrJzRequest.serializes?211188::4<))+++r!rr%)r/r0rr1rr) __name__ __module__ __qualname____doc____annotations__r&propertyr. classmethodrGrJr!rr r NsIII$(J'''' X="="="[="~      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. int 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!Tr/r0 read_exact read_to_eof include_bodyboolGenerator[None, None, Response]c#PK t|Ed{V}n"#t$r}td|d}~wwxYw |dd\}}} n.#t$r!tdt |dwxYw|dkrtdt | t |} n.#t$r!tdt |dwxYwd | cxkrd ks!ntd t |t | std t | | d d} t|Ed{V} |rt| | |||Ed{V} 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 liner3r4zinvalid HTTP status line: 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 rW _value_re fullmatchrr? read_body)rAr/r\r]r^ status_linerCrFraw_status_code raw_reasonrXreasonr$rZs rrGzResponse.parses[B X%/ %:%:::::::KK X X XMNNTW W X V4?4E4EdA4N4N 1Hozz V V VJ!K..JJKKQU U V { " "LAkNNLL  o..KK   Ra>P>PRR  k''''C''''T/@R@RTT "":.. MKAjMMKKLL L""7,=>>*955555555  'Wi[DDDs;666s' 949A+B,B<<+C'cd|jd|jd}||jz }||jz }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rXrYrIr$rJrZ)r-responses rrJzResponse.serializesXKt/JJ$2DJJJQQSSDL**,,,DIr!rL)T) r/r0r\r0r]r0r^r_rr`rM) rNrOrPrQrRrZr&rSr.rTrGrJrUr!rr r s  D#'J'''' X " D7D7D7D7[D7L      r!r r/r0Generator[None, None, bytes]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_rerdstriprcrr) r/r$_rtrCraw_name raw_valuenamers rr?r?>s,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+B3rXrWr$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)Nrbi0r!r9chunkedztransfer coding z isn't supportedT;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r4rozchunk without CRLFr:zbody too large: zbody too large: over ) getr@r;r=lenrrrW MAX_BODY_SIZEr>r?rr) rXr$r/r\r]codingrZchunk_size_lineraw_chunk_sizestr_chunk_size chunk_sizeraw_content_lengthcontent_lengths rrereqs 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/r0rrm)r/r0rru) rXrWr$rr/r0r\r0r]r0rrm)' __future__r dataclassesosresysr)collections.abcrtypingrdatastructuresr exceptionsrr websockets_version__all__format version_infoPYTHON_VERSIONenvironrr r rWryrqrr compilerzrc dataclassr r r;r?rerUr!rrs"""""" %%%%%%######%%%%%%222222    !12Z^^>n>>*<>> >n>>*<>>   #bjnn%A5IIJJ#bjnn%A6JJKKBJNN#={KKLL 3333 BJ7 8 8  BJ4 5 5  ````````F mmmmmmmm`60000f:O:O:O:O:O:Or!