RPf1,ddlmZddlZddlZddlZddlmZmZmZddl m Z m Z dZ dZ dZdd Zej d Zej d Zej&Gd d Zej&GddZ ddZ ddZy)) annotationsN)Callable GeneratorOptional)datastructures exceptionsi ic&|jdS)zG Decode a bytestring for interpolating into an error message. backslashreplace)errors)decode)values K/var/www/fastapitest/venv/lib/python3.12/site-packages/websockets/http11.pydrs <<1< 22s[-!#$%&\'*+.^_`|~0-9a-zA-Z]+s[\x09\x20-\x7e\x80-\xff]*cheZdZUdZded<ded<dZded<ed d Ze d d Z dd Z y)Requestz WebSocket handshake request. Attributes: path: Request path, including optional query. headers: Request headers. strpathdatastructures.HeadersheadersNOptional[Exception] _exceptioncNtjdt|jS)NzIRequest.exception is deprecated; use ServerProtocol.handshake_exc insteadwarningswarnDeprecationWarningrselfs r exceptionzRequest.exceptionC"  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: sGETzunsupported HTTP method: HTTP/1.1unsupported HTTP version: asciisurrogateescapeTransfer-Encoding!transfer codings aren't supportedContent-Lengthzunsupported request body) parse_lineEOFErrorsplit ValueErrorrr parse_headersNotImplementedError) cls read_line request_lineexcmethodraw_pathversionrrs rparsez Request.parseLs&F Y&0&;;L X(4(:(:4(C %FHg V 86 DE E k !9!G*FG Gw(9:*955 ' )%&IJ J w &78 84!!3< 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 )rencoder serialize)r!requests rr>zRequest.serializes; =188:4<<))++rreturnr)r5-Callable[[int], Generator[None, None, bytes]]rAzGenerator[None, None, Request]rAbytes) __name__ __module__ __qualname____doc____annotations__rpropertyr" classmethodr;r>rrrr3s_ I ##'+J#* <"@<" (<"<"| rrceZdZUdZded<ded<ded<dZd ed <dZd ed <edd Ze ddZ ddZ y)Responsez WebSocket handshake response. Attributes: status_code: Response code. reason_phrase: Response reason. headers: Response headers. body: Response body, if any. int status_coder reason_phraserrNzOptional[bytes]bodyrrcNtjdt|jS)NzJResponse.exception is deprecated; use ClientProtocol.handshake_exc insteadrr s rr"zResponse.exceptionr#rc# K t|Ed{} |jdd\}}}|dk7rtdt | t |} d | cxkrd ksntd t |t j|std t ||j} t|Ed{} d | vr tdd | cxkrdks n| dk(s| dk(rd} n[ | d} t | }| |tEd{} n2|tkDrtjd|d||Ed{} || | | | S7F#t$r}td|d}~wwxYw#t$rtdt |dwxYw#t$rtdt |dwxYw7#t$rd}YwxYw7#t$rtjdtdwxYw7w)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: r'r(zinvalid HTTP status code: dizunsupported HTTP status code: zinvalid HTTP reason phrase: r+r,i0r-zbody too large: over z byteszbody too large: )r.r/r0r1rrO _value_re fullmatchrr2r3KeyErrorMAX_BODY RuntimeErrorr SecurityError)r4r5 read_exact read_to_eof status_liner7r:raw_status_code raw_reasonrPreasonrrRraw_content_lengthcontent_lengths rr;zResponse.parsesb@ X%/ %::K V3>3D3DT13M 0G_j k !9!G*FG G o.K k(D(=a>P=QRS S"":.;AjM?KL L""$*955 ' )%&IJ J + # #{c'9[C=OD 9&--=%>""%%7!8%&1(&;;D  (* ..&~&6f=#-^"<<;66y; XMNTW W X  V9!K.9IJKQU U V ,Q-?,@A  6$ &!% &<#$22/z@=sHEEEE8H FA.HG-H3G8 HGGG.HH HE E5$ E00E55H8"FH"F??H GHGHG'G>>Hcd|jd|jdj}||jj z }|j ||j z }|S)z< Serialize a WebSocket handshake response. z HTTP/1.1  z )rPrQr=rr>rR)r!responses rr>zResponse.serializesct//0$2D2D1ETJQQSDLL**,, 99  !Hrr@)r5rBr^rBr_rBrAzGenerator[None, None, Response]rC) rErFrGrHrIrRrrJr"rKr;r>rLrrrNrNs  ## D/ &*J#* \7@\7B\7C \7 ) \7\7| rrNc#Ktj}ttdzD]} t |Ed{}|dk(r|S |j dd\}}tj|stdt||jd}tj|std t||jd }|jd d }|||<tjd 7#t $r}t d|d}~wwxYw#t$rtdt|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: r)r*ztoo many HTTP headers)rHeadersrange MAX_HEADERSr.r/r0r1r _token_rerYstriprXrr r]) r5r_liner7raw_name raw_valuenamers rr2r2!sY,$$&G ;? #@ T(33D 3; & N# O"&**T1"5 Hi""8,9!H+GH HOOF+ ""9-:1Y<.IJ Jw'  *;< )@.&&'>??+4 TIJPS S T O9!D'CD$ N OsQ*E DDDE  D%B(E D D" DD""E %"EE c#K |tEd{}|j ds t d|ddS7%#t$rtjdwxYww)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_LINEr\r r]endswithr/)r5rqs rr.r.Tsb"8#H-- == !*++ 9 . 8&&778s%A;9;!A;AA)rrDrAr)r5rBrAz-Generator[None, None, datastructures.Headers])r5rBrAzGenerator[None, None, bytes]) __future__r dataclassesrertypingrrrrr rmrwr[rcompilernrX dataclassrrNr2r.rLrrrs" 00(   3 BJJ7 8  BJJ4 5  ```F FFFR0<020f<!r