&thddlmZddlZddlmZmZmZmZmZm Z m Z ddl m Z m Z ddlmZmZ ddlmZn#e$r ddlmZYnwxYwGdd eZdd l mZmZmZddZddZdS)) annotationsN)Any AwaitableCallable NamedTupleOptionalSequenceTuple) extensionsframes) PayloadTooBig ProtocolError) apply_maskceZdZUded<ded<ded<dZded<dZded <dZded <ed d Zd!dZ d"dZ e dddd#dZ ddd$dZ dS)%Frameboolfinz frames.OpcodeopcodebytesdataFrsv1rsv2rsv3return frames.Framecptj|j|j|j|j|j|jSN)r rrrrrrrselfs m/var/www/html/mycamper/aliexpress-site/backend/venv/lib/python3.11/site-packages/websockets/legacy/framing.py new_framezFrame.new_frames4| K I H I I I    strc*t|jSr)r$r"rs r!__str__z Frame.__str__$s4>"""r#Nonec4|jSr)r"checkrs r!r)z Frame.check's~##%%%r#N)max_sizer reader!Callable[[int], Awaitable[bytes]]maskr* Optional[int]r (Optional[Sequence[extensions.Extension]]cK|dd{V}tjd|\}}|dzrdnd}|dzrdnd} |dzrdnd} |d zrdnd} tj|d z} n"#t$r} t d | d} ~ wwxYw|dzrdnd|krt d |d z}|dkr)|dd{V}tjd|\}n.|d kr(|dd{V}tjd|\}|||krt d|d|d|r|dd{V}||d{V}|rt||}tj| ||| | | }|g}t|D]}| ||}| ||j |j |j|j|j|jS)a@ Read a WebSocket frame. Args: reader: coroutine that reads exactly the requested number of bytes, unless the end of file is reached. mask: whether the frame should be masked i.e. whether the read happens on the server side. max_size: maximum payload size in bytes. extensions: list of extensions, applied in reverse order. Raises: PayloadTooBig: if the frame exceeds ``max_size``. ProtocolError: if the frame contains incorrect values. r Nz!BBTF@ zinvalid opcodezincorrect masking~z!Hz!Qzover size limit (z > z bytes))r*)structunpackr Opcode ValueErrorrrrrreverseddecoder)rrrrrr)clsr+r-r*r rhead1head2rrrrrexclength mask_bitsr" extensions r!readz Frame.read*s6VAYY}UD11 uj(3ddez)4ttuz)4ttuz)4ttu ;]5:#566FF ; ; ; 011s : ;J& 1DDEd : : 344 4# S==??????D dD11IVV s]]??????D dD11IV  FX$5$5 PF P Px P P PQQ Q  ($fQiiIVF^^######  /dI..DLsD$EE  J!*-- G GI!((X(FFIIs M   N N N N    sA)) B3BB)r writeCallable[[bytes], Any]cP||j||dS)a Write a WebSocket frame. Args: frame: frame to write. write: function that writes bytes. mask: whether the frame should be masked i.e. whether the write happens on the client side. extensions: list of extensions, applied in order. Raises: ProtocolError: if the frame contains incorrect values. )r-r N)r" serialize)r rHr-r s r!rHz Frame.writeys/0 dn&&DZ&HHIIIIIr#)rr)rr$)rr') r+r,r-rr*r.r r/rr)rHrIr-rr r/rr')__name__ __module__ __qualname____annotations__rrrpropertyr"r&r) classmethodrGrHr#r!rrs IIIKKKDDD    X ####&&&& #'?C L L L L L [L f@D JJJJJJJJr#r)Close prepare_ctrl prepare_datarrrTuple[int, str]cFtj|}|j|jfS)z Parse the payload from a close frame. Returns: Tuple[int, str]: close code and reason. Raises: ProtocolError: if data is ill-formed. UnicodeDecodeError: if the reason isn't valid UTF-8. )rSparsecodereason)rcloses r! parse_closer\s" K  E :u| ##r#rYintrZr$cFt||S)z3 Serialize the payload for a close frame. )rSrK)rYrZs r!serialize_closer_s v   ( ( * **r#)rrrrV)rYr]rZr$rr) __future__rr:typingrrrrrr r r r exceptionsrrspeedupsr ImportErrorutilsrrSrT encode_datarUr\r_rRr#r!rhsa"""""" RRRRRRRRRRRRRRRRRR!!!!!!!!55555555#%%%%%%%###""""""""#AJAJAJAJAJJAJAJAJLFEEEEEEEEE $ $ $ $ ++++++s5 AA