&thq\ddlmZddlZddlZddlZddlmZmZmZm Z m Z ddl m Z m Z mZmZmZmZddlmZddlmZmZmZmZmZmZmZmZmZddlmZm Z dd l!m"Z"dd lm#Z#m$Z$m%Z%gd Z&e ee efZ' Gd d ej(Z)e)j*Z*e)j+Z+Gddej(Z,e,j-Z-e,j.Z.e,j/Z/e,j0Z0dZ1 GddZ2dS)) annotationsN) GeneratorListOptionalTypeUnion)ConnectionClosedConnectionClosedErrorConnectionClosedOK InvalidState PayloadTooBig ProtocolError) Extension) OK_CLOSE_CODES OP_BINARYOP_CLOSEOP_CONTOP_PINGOP_PONGOP_TEXTCloseFrame)RequestResponse) StreamReader) LoggerLikeOrigin Subprotocol) ConnectionSideStateSEND_EOFc.eZdZdZed\ZZdS)r!z6A WebSocket connection is either a server or a client.N)__name__ __module__ __qualname____doc__rangeSERVERCLIENTi/var/www/html/mycamper/aliexpress-site/backend/venv/lib/python3.11/site-packages/websockets/connection.pyr!r!,s%@@U1XXNFFFFr.r!c2eZdZdZed\ZZZZdS)r"z6A WebSocket connection is in one of these four states.N) r&r'r(r)r* CONNECTINGOPENCLOSINGCLOSEDr-r.r/r"r"6s*@@(-a%Jgvvvr.r"r.c4eZdZdZeddfd6dZed7dZejd8dZed9dZ ed:dZ ed;dZ ddZd?d>dZd?d>dZd@dAd$Zd` for details. iNsider!stater"max_size Optional[int]loggerOptional[LoggerLike]returnNonecRtj|_ |.tjd|j}||_ |tj |_ ||_ ||_ ||_ d|_d|_d|_g|_d|_d|_d|_d|_d|_ d|_t1|_g|_g|_||_t=|jd|_dS)Nz websockets.F) uuiduuid4idlogging getLoggernamelowerr; isEnabledForDEBUGdebugr7r8r9cur_sizeexpect_continuation_frameorigin extensions subprotocol close_rcvd close_sentclose_rcvd_then_sent handshake_exceof_sentrreadereventswritesparseparsernext parser_exc)selfr7r8r9r;s r/__init__zConnection.__init__Vs"Z\\B >&'HTY__5F5F'H'HIIF"( )((77   ! (, */&)- +-26,0+/48!37  #nn #% #% jjll  T[/3r.c|jS)zm WebSocket connection state. Defined in 4.1, 4.2, 7.1.3, and 7.1.4 of :rfc:`6455`. )_stater[s r/r8zConnection.states {r.cb|jr |jd|j||_dS)Nz= connection is %s)rIr;rEr^)r[r8s r/r8zConnection.states3 : @ K  2EJ ? ? ? r.cL|jturdS|jdS|jjS)z `WebSocket close code`_. .. _WebSocket close code: https://www.rfc-editor.org/rfc/rfc6455.html#section-7.1.5 :obj:`None` if the connection isn't closed yet. N)r8r5rOcoder_s r/ close_codezConnection.close_codes. :V # #4 _ $4?' 'r. Optional[str]cL|jturdS|jdS|jjS)z `WebSocket close reason`_. .. _WebSocket close reason: https://www.rfc-editor.org/rfc/rfc6455.html#section-7.1.6 :obj:`None` if the connection isn't closed yet. N)r8r5rOreasonr_s r/ close_reasonzConnection.close_reasons. :V # #4 _ $2?) )r.r c |jtus Jd|j5|j.|jjt vr|jjt vrt }nt}||j|j|j}|j |_ |S)a Exception to raise when trying to interact with a closed connection. Don't raise this exception while the connection :attr:`state` is :attr:`~websockets.connection.State.CLOSING`; wait until it's :attr:`~websockets.connection.State.CLOSED`. Indeed, the exception includes the close code and reason, which are known only once the connection is closed. Raises: AssertionError: if the connection isn't closed yet. zconnection isn't closed yet) r8r5rOrPrcrr r rQrZ __cause__)r[exc_typeexcs r/ close_exczConnection.close_excs zV###%B### O '+$66$66)HH,H ( O O  %! !    r.databytescb|j|t|jdS)aH Receive data from the network. After calling this method: - You must call :meth:`data_to_send` and send this data to the network. - You should call :meth:`events_received` and process resulting events. Raises: EOFError: if :meth:`receive_eof` was called earlier. N)rT feed_datarYrXr[ros r/ receive_datazConnection.receive_datas0 d### T[r.c`|jt|jdS)aw Receive the end of the data stream from the network. After calling this method: - You must call :meth:`data_to_send` and send this data to the network. - You aren't expected to call :meth:`events_received`; it won't return any new events. Raises: EOFError: if :meth:`receive_eof` was called earlier. N)rTfeed_eofrYrXr_s r/ receive_eofzConnection.receive_eofs.  T[r.finboolc|jstd| |_|tt||dS)a Send a `Continuation frame`_. .. _Continuation frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 Parameters: data: payload containing the same kind of data as the initial frame. fin: FIN bit; set it to :obj:`True` if this is the last frame of a fragmented message and to :obj:`False` otherwise. Raises: ProtocolError: if a fragmented message isn't in progress. unexpected continuation frameN)rKr send_framerrr[rorxs r/send_continuationzConnection.send_continuationsM"- A ?@@ @-0& gtS1122222r.Tc|jrtd| |_|tt||dS)a Send a `Text frame`_. .. _Text frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 Parameters: data: payload containing text encoded with UTF-8. fin: FIN bit; set it to :obj:`False` if this is the first frame of a fragmented message. Raises: ProtocolError: if a fragmented message is in progress. expected a continuation frameN)rKrr|rrr}s r/ send_textzConnection.send_text,sM  ) A ?@@ @-0& gtS1122222r.c|jrtd| |_|tt||dS)a Send a `Binary frame`_. .. _Binary frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 Parameters: data: payload containing arbitrary binary data. fin: FIN bit; set it to :obj:`False` if this is the first frame of a fragmented message. Raises: ProtocolError: if a fragmented message is in progress. rN)rKrr|rrr}s r/ send_binaryzConnection.send_binaryAsM  ) A ?@@ @-0& is3344444r.rgrcrhstrcD|jrtd|(|dkrtdtdd}d}n$t||}|}|t t |||_t|_ dS)a Send a `Close frame`_. .. _Close frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.1 Parameters: code: close code. reason: close reason. Raises: ProtocolError: if a fragmented message is being sent, if the code isn't valid, or if a reason is provided without a code rNrgz#cannot send a reason without a codeir.) rKrr serializer|rrrPr4r8r[rcrhcloseros r/ send_closezConnection.send_closeVs  ) A ?@@ @ <||#$IJJJ$OOEDD$''E??$$D h--... r.cV|tt|dS)z Send a `Ping frame`_. .. _Ping frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.2 Parameters: data: payload containing arbitrary binary data. N)r|rrrss r/ send_pingzConnection.send_pingv& gt,,-----r.cV|tt|dS)z Send a `Pong frame`_. .. _Pong frame: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.3 Parameters: data: payload containing arbitrary binary data. N)r|rrrss r/ send_pongzConnection.send_pongrr.intc|jture|dkr_t||}|}|t t |||_t|_|j tur|j s| | |_t|jdS)a? `Fail the WebSocket connection`_. .. _Fail the WebSocket connection: https://datatracker.ietf.org/doc/html/rfc6455#section-7.1.7 Parameters: code: close code reason: close reason Raises: ProtocolError: if the code isn't valid. rbN)r8r3rrr|rrrPr4r7r+rSsend_eofdiscardrXrYrs r/failzConnection.fails& :  t||dF++((h 5 5666"'$ 9  t}  MMOOO llnn  T[r. List[Event]c$|jgc}|_|S)a7 Fetch events generated from data received from the network. Call this method immediately after any of the ``receive_*()`` methods. Process resulting events, likely by passing them to the application. Returns: List[Event]: Events read from the connection. )rU)r[rUs r/events_receivedzConnection.events_receiveds#k2  r. List[bytes]c$|jgc}|_|S)a Obtain data to send to the network. Call this method immediately after any of the ``receive_*()``, ``send_*()``, or :meth:`fail` methods. Write resulting data to the connection. The empty bytestring :data:`~websockets.connection.SEND_EOF` signals the end of the data stream. When you receive it, half-close the TCP connection. Returns: List[bytes]: Data to write to the connection. )rV)r[rVs r/ data_to_sendzConnection.data_to_sends"#k2  r.c0|jtup|jduS)a Tell if the TCP connection is expected to close soon. Call this method immediately after any of the ``receive_*()`` or :meth:`fail` methods. If it returns :obj:`True`, schedule closing the TCP connection after a short timeout if the other side hasn't already closed it. Returns: bool: Whether the TCP connection is expected to close soon. N)r8r4rRr_s r/close_expectedzConnection.close_expecteds,zW$F(:$(FFr.Generator[None, None, None]c#K |jEd{Vr0|jr|jdt d|jd}n|j|j}n|j|jz }tj|jj |j tu||j Ed{V}|jr|jd|| |#t$r5}|dt!|||_Yd}~nd}~wt$r4}|dt!|||_Yd}~nd}~wt$$r6}|d |jd |j||_Yd}~nd}~wt*$r4}|d t!|||_Yd}~nRd}~wt,$rB}|jd d |d||_Yd}~nd}~wwxYwdVt1d)z Parse incoming data into frames. :meth:`receive_data` and :meth:`receive_eof` run this generator coroutine until it needs more data or reaches EOF. TN< EOFzunexpected end of stream)maskr9rMz< %sirbiz at position iz parser failed)exc_infoiz"parse() shouldn't step after error)rTat_eofrIr;EOFErrorr9rJrrW read_exactr7r+rM recv_framerrrrZUnicodeDecodeErrorrhstartr ExceptionerrorAssertionError)r[r9framerms r/rWzConnection.parses5 " '#{1133333333?z3 ))'222 ##=>>>=(#HH]*#}HH#}t} %s)rrM) r8r3r rErIr;rVrrr7r,rM)r[rs r/r|zConnection.send_frames :T ! !MdjoMMM  : - K  fe , , ,  OOf!4O Q Q     r.c|jrJd|_|jr|jd|jt dS)NTz> EOF)rSrIr;rVrr#r_s r/rzConnection.send_eofsS=    : ' K  g & & & 8$$$$$r.) r7r!r8r"r9r:r;r<r=r>)r=r")r8r"r=r>)r=r:)r=re)r=r )rorpr=r>)r=r>)rorprxryr=r>)T)Nrg)rcr:rhrr=r>)rg)rcrrhrr=r>)r=r)r=r)r=ry)r=r)rrr=r>)r&r'r(r)r3r\propertyr8setterrdrirnrtrwr~rrrrrrrrrrWrrr|rr-r.r/r r Fsk  $"''+ A4A4A4A4A4FX \\ (((X("***X*"!!!X!J &3333,33333*55555*@ . . . . . . . .'''''V     (GGGG4BCBCBCBCHCCCCrsl""""""  99999999999999"!!!!!                      &%%%%%%%!!!!!!3333333333    gx&'A4<  11111DL111    z -  Ex %x %x %x %x %x %x %x %x %x %r.