A>qjEG ddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZddlmZgd Zd j,ej.Zej2j5d d ed eZej2j5dd ed eZeej2j5ddZeej2j5ddZeej2j5ddZ ddZ!ejDdZ#ejDdZ$ejJGddZ&ejJGddZ'ef d dZ( d!dZ) d"dZ*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. backslashreplaceerrors)decode)values P/opt/rentech/trading_bot/.venv/lib/python3.12/site-packages/websockets/http11.pydr!8s <<1< 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*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.exceptionns  W  r"c#,K t|tEd{} |jdd\}}}|dvrt dt ||j d}|j d}|j d} t|Ed{} d | vr td d | vrt| d d k7r 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. 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) cls read_line request_lineexc raw_methodraw_path raw_protocolr(r)r%r&s r parsez Request.parsevsOP Y&0DC C* C%%C**D-"DDc|jd|jd|jd}|jd}||jj z }|S)z; Serialize a WebSocket handshake request.   r:)r(r%r)encoder& serialize)r2rFrequests r rPzRequest.serializesT++a {!DMM?$G %%g.4<<))++r"returnr*)rEJCallable[[int, type[Exception]], Generator[None, None, bytes | bytearray]]rSzGenerator[None, None, Request]rSbytes) __name__ __module__ __qualname____doc____annotations__r(r)r+propertyr3 classmethodrKrPr"r rrTs{  I FCHc$(J ' I4 I4 ( I4I4V 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. rC status_coder$ reason_phraserr&r"bytes | bytearraybodyNr*r+cNtjdt|jS)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr-r1s r r3zResponse.exceptions"  7  r"c#K t|tEd{} |jdd\}}} |r|dvr3t dt ||dk7rt 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 |dwxYw#t$rt d t |dwxYw77zw)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. Nz0connection closed while reading HTTP status liner5r6zinvalid HTTP status line: r7r9r8z)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!rC _value_re fullmatchrrA read_body)rDrE read_exact read_to_eofproxy status_linerGr)raw_status_code raw_reasonr`reasonr&rcs r rKzResponse.parsesR X%/ ;L%MMK V4?4E4EdA4N 1Hoz 99 K~&( ;& ?+?OP o.K k'C'?/@R?ST "":.;AjM?KL L""<0*955 D'Wi[D;66]N XMNTW W X  V9!K.9IJKQU U V =a>P=QR  6 sFDDDD29F- E8A/F'E<(FE>FD D/ D**D//F2"EF"E99F>Fcd|jd|jd}|jd}||jj z }||j z }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1 rMrNrg)r`rarOr&rPrc)r2rnresponses r rPzResponse.serializeJs` "$"2"2!31T5G5G4HM %%l3DLL**,,DIIr"rR)F) rErTrk9Callable[[int], Generator[None, None, bytes | bytearray]]rlrTrmboolrSzGenerator[None, None, Response]rU) rWrXrYrZr[rcr+r\r3r]rKrPr^r"r rrs  !D !#'J ' W7 W7 N W7  W7W7 )W7W7r 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>)rEtoo_long_exc_typelines r r=r=WsB, 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: r:rgzexpected no more than z headers)rrangeMAX_NUM_HEADERSr=rr>r?r@r! _token_reristriprhr set_insecurer ) rEr&_r|rGraw_name raw_valuenamers r rArAtsc4iG ?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#jKd|cxkrdks n|dk(s|dk(ry|jdx}|dk7rtd|d d} t|tEd{}|j d d d }t |d kDr!|j d} td| dt|d} | d k(rnbt || ztkDrtd| dt |d||| Ed{z }|dEd{dk7r tdt|Ed{|S|jdx} Pt | dkDrtd| dt| } | tkDrtd| d|| Ed{S|ttEd{S7N7777&7w)Nrfi0r"r;chunkedztransfer coding z isn't supported;rrrrzchunk too large: 0xz byteszchunk too large: z bytes after r6rwzchunk without CRLFr<zbody too large: ) getrBr=r r?lenrrC MAX_BODY_SIZEr@rA) r`r&rErkrlcodingrcchunk_size_lineraw_chunk_sizestr_chunk_size chunk_sizeraw_content_lengthcontent_lengths r rjrjs kC;##59KKK 34 4& A Y %(8@P&QR R)3I})MMO,224;A>N>"R'!/!6!6>P!6!Q#&9.9I$PQQ^R0JQ4y:% 5#' |=T 6R z*55 5D%a=(W4 !566!$!+++ ' ,< = =  J ! "R '"23E2Ff MN N/0 M )"2>2B& IJ J%n556'}mDDE=N6( ,6EsnAF3F&BF3/F)0F3F+!F3#F-$A$F3F/ F3!F1"F3)F3+F3-F3/F31F3)rrbrSr$)rErTr{ztype[Exception]rS(Generator[None, None, bytes | bytearray])rErTrSzGenerator[None, None, Headers]) r`rCr&rrErTrkrtrlrTrSr)+ __future__r dataclassesosresysr.collections.abcrtypingrdatastructuresr exceptionsrr r r r r websockets_version__all__format version_infoPYTHON_VERSIONenvironrrrrCrryrr!compilerrh dataclassrrr=rArjr^r"r rs" %#3  !1!12ZZ^^ n \*<)=>  n \*<)=>  bjjnn%A5IJbjjnn%A6JKBJJNN#={KL 3 BJJ7 8  BJJ4 5  wwwt DDDV*7 '  . :;;$ ;|;F;F ;F;F J ;F;F.;Fr"