vj@4ddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZgdZd j"ej$Zej(j+d d ed eZej(j+d d ed eZeej(j+ddZeej(j+ddZeej(j+ddZddZej:dZej:dZej@GddZ!ej@GddZ" ddZ# ddZ$y) ) annotationsN)Callable Generator)Headers) SecurityError)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 b/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/websockets/http11.pydr,s <<1< 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*cheZdZUdZded<ded<dZded<ed d Ze d d Z dd Z y)r z WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. strpathrheadersNException | None _exceptioncNtjdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningr#selfs r exceptionzRequest.exceptionX"  7  rc#K t|Ed{} |jdd\}}}|dk7rtdt ||dk7rtd t ||j d d }t |Ed{}d |vr td d|vr td|||S7#t$r}td|d}~wwxYw#t$rtdt |dwxYw7ow)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-Encoding!transfer codings aren't supportedContent-Lengthzunsupported request body) parse_lineEOFErrorsplit ValueErrorrr parse_headersNotImplementedError) cls read_line request_lineexcmethodraw_pathprotocolr r!s rparsez Request.parseas-F Y&0&;;L X)5););D!)D &FHh { ";AlO;LM  V J1V9+VW Ww(9:*955 ' )%&IJ J w &78 84!!5< YNOUX X Y  X:1\?:KLMSW W X6sUC8B4B2B4CAC8C6+C82B44 C= C  CC8"C33C8c|d|jdj}||jjz }|S)z; Serialize a WebSocket handshake request. zGET z HTTP/1.1 )r encoder! serialize)r*requests rrGzRequest.serializes; =188:4<<))++rreturnr")r>-Callable[[int], Generator[None, None, bytes]]rJzGenerator[None, None, Request]rJbytes) __name__ __module__ __qualname____doc____annotations__r#propertyr+ classmethodrDrGrrr r Hs_ I $(J ' ="@=" (="="~ rr ceZdZUdZded<ded<ded<dZd ed <dZd ed <edd Ze ddZ ddZ y)r z WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body, if any. int status_coder reason_phraserr!Nz bytes | Nonebodyr"r#cNtjdt|jS)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadr%r)s rr+zResponse.exceptionr,rc#K t|Ed{} |jdd\}}}|dk7rtdt | t |} d | cxkrd ksntd t |t j|std t ||jd d} t|Ed{} d| vr tdd | cxkrdks n| dk(s| dk(rd} nQ | d} t | }| |tEd{} n(|tkDrtd|d||Ed{} || | | | S7>#t$r}td|d}~wwxYw#t$rtdt |dwxYw#t$rtdt |dwxYw7#t$rd}YwxYw7#t$rtdtdwxYw7w)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 liner.r/zinvalid HTTP status line: r0r1z+invalid status code; expected integer; got diXu-invalid status code; expected 100–599; got zinvalid HTTP reason phrase: r2r3r4r5i0r6zbody too large: over z byteszbody too large: )r7r8r9r:rrW _value_re fullmatchrr;r<KeyError MAX_BODY_SIZE RuntimeErrorr)r=r> read_exact read_to_eof status_liner@rCraw_status_code raw_reasonrXreasonr!rZraw_content_lengthcontent_lengths rrDzResponse.parses`@ X%/ %::K V4?4E4EdA4N 1Hoz { ";AkN;KL  o.K k'C'?/@R?ST "":.;AjM?KL L""7,=>*955 ' )%&IJ J + # #{c'9[C=OD 9&--=%>""%%7!8%W&1-&@@D -/#&6~6Ff$MNN",^"<<;66w; XMNTW W X  V9!K.9IJKQU U V =a>P=QR  6$ &!% &A#W'*? f(UVVW =sG1EEEE0G1 FA0G1F:-G15F<: G1GG G$G1G/G1E E- E((E--G10"FG1"F77G1< G G1 G  G1 GG,,G1cd|jd|jdj}||jj z }|j ||j z }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rXrYrFr!rGrZ)r*responses rrGzResponse.serialize(sct//0$2D2D1ETJQQSDLL**,, 99  !HrrI)r>rKrerKrfrKrJzGenerator[None, None, Response]rL) rNrOrPrQrRrZr#rSr+rTrDrGrUrrr r s  D,#'J ' [7@[7B[7C [7 ) [7[7z rr c#pKt}ttdzD]} t|Ed{}|dk(r|S |j dd\}}tj|st dt||jd}tj|st d t||jd }|jd d }|||<td 7#t$r}t d|d}~wwxYw#t $rt dt|dwxYww) 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: r2r3ztoo many HTTP headers)rrangeMAX_NUM_HEADERSr7r8r9r:r _token_rerastripr`rr) r>r!_liner@raw_name raw_valuenamers rr;r;6sF,iG ?Q& ' T(33D 3; & N# O"&**T1"5 Hi""8,9!H+GH HOOF+ ""9-:1Y<.IJ Jw'  *;< )(.344+4 TIJPS S T O9!D'CD$ N OsO D6C4C2C4D6DBD62C44 D= D  DD6"D33D6c#K |tEd{}|jds t d|ddS7%#t$r tdwxYww)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 longs zline without CRLF)MAX_LINE_LENGTHrdrendswithr8)r>rws rr7r7is\"-#O44 == !*++ 9 5 -O,,-s%A;9;!A;AA)rrMrJr)r>rKrJzGenerator[None, None, Headers])r>rKrJzGenerator[None, None, bytes])% __future__r dataclassesosresysr&typingrrdatastructuresr exceptionsrr websockets_version__all__format version_infoPYTHON_VERSIONenvirongetr r rWrsr}rcrcompilertr` dataclassr r r;r7rUrrrs" &#%2 : !1!12ZZ^^ n \*<)=>  n \*<)=>  bjjnn%A5IJbjjnn%A6JKBJJNN#={KL 3 BJJ7 8  BJJ4 5  aaaH EEEP0<0#0f<!r