vKg`SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK J r J r JrJrJr SSKJr SSKJrJr SSKJrJrJrJr SSKJrJrJrJrJ r SS K!J"r"J#r# SS K$J%r%J&r&J'r'J(r(J)r) SS KJ*r*J+r+J,r, S S K-J.r.J/r/J0r0J1r1J2r2 S SK3J4r4 S/r5"SS\RP5r6SSSjjr7S\7l8g)) annotationsN) AsyncIterable AsyncIterator AwaitableIterableMapping) TracebackType)Anycast)ConcurrencyErrorConnectionClosedConnectionClosedOK ProtocolError) DATA_OPCODES BytesLike CloseCodeFrameOpcode)RequestResponse)CLOSEDOPENEventProtocolState)Data LoggerLike Subprotocol) TimeoutErroraiteranextasyncio_timeoutasyncio_timeout_at) Assembler Connectionc(\rSrSrSrSSSSSS.S,Sjjr\S-S j5r\S-S j5r\S.S j5r \S/S j5r \S0S j5r \S1Sj5r S2Sjr S3SjrS4SjrS5S6SjjrS5S7SjjrS5S8SjjrS9S:SjjrS;SjrS5SSjjrS?SjrS@SjrS;SjrS;SjrS;Sjr\R:\S.SAS jj5rS;S!jr SBS"jr!S;S#jr"SCS$jr#SDS%jr$S;S&jr%S;S'jr&S;S(jr'S@S)jr(S;S*jr)S+r*g)Er''a' :mod:`asyncio` implementation of a WebSocket connection. :class:`Connection` provides APIs shared between WebSocket servers and clients. You shouldn't use it directly. Instead, use :class:`~websockets.asyncio.client.ClientConnection` or :class:`~websockets.asyncio.server.ServerConnection`.  i) ping_interval ping_timeout close_timeout max_queue write_limitcXlX lX0lX@l[ U[ 5(dUcUS4nXPl[ U[ 5(aUS4nX`l[R"URRSU05URl URRUl URRUl URRUl SUl SUl[R "5UlU SUlSUl0UlSUlSUlSUlUR"R15UlSUl[6R8"5Ulg)N websocketrF)protocolr-r.r/ isinstanceintr0r1logging LoggerAdapterloggeriddebugrequestresponseasyncioget_running_looploopclose_deadlinefragmented_send_waiter pong_waiterslatencykeepalive_taskrecv_exc create_futureconnection_lost_waiterpaused collectionsdeque drain_waiters)selfr4r-r.r/r0r1s ]/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/websockets/asyncio/connection.py__init__Connection.__init__4se! *(* i % %):"D)I" k3 ' '&-K& '44 MM $    "]]--B"&--"6"6 )]](( (, ()- ),,.  -1DH#OQ  :>/3 =AIIshieldrH close_excrF)rMdecodeexcs rNrzConnection.recvs^ ++//77 77   "< " ((** ""**zzl- {;+****** nnT88999mm%%4==8sD6)')D6) C)D6C)C$'A*(C$,AC0 C$;B><C$D6C! C C! C$D6!C$$C))&D6D&D6c# URRU5ShvN nU7v MN g![a O[a [S5Se[anUR 5IShvN UR R[RURSUR35 SSS5IShvN SnAO&!,IShvN (df  SnAO =fSnAff=f[R"UR5IShvN UR RUR e7f)a Receive the next message frame by frame. This method is designed for receiving fragmented messages. It returns an asynchronous iterator that yields each fragment as it is received. This iterator must be fully consumed. Else, future calls to :meth:`recv` or :meth:`recv_streaming` will raise :exc:`~websockets.exceptions.ConcurrencyError`, making the connection unusable. :meth:`recv_streaming` raises the same exceptions as :meth:`recv`. Canceling :meth:`recv_streaming` before receiving the first frame is safe. Canceling it after receiving one or more frames leaves the iterator in a partially consumed state, making the connection unusable. Instead, you should close the connection with :meth:`close`. Args: decode: Set this flag to override the default behavior of returning :class:`str` or :class:`bytes`. See below for details. Returns: An iterator of strings (:class:`str`) for a Text_ frame or bytestrings (:class:`bytes`) for a Binary_ frame. .. _Text: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 .. _Binary: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 You may override this behavior with the ``decode`` argument: * Set ``decode=False`` to disable UTF-8 decoding of Text_ frames and return bytestrings (:class:`bytes`). This may be useful to optimize performance when decoding isn't needed. * Set ``decode=True`` to force UTF-8 decoding of Binary_ frames and return strings (:class:`str`). This is useful for servers that send binary frames instead of text frames. Raises: ConnectionClosed: When the connection is closed. ConcurrencyError: If two coroutines call :meth:`recv` or :meth:`recv_streaming` concurrently. Nz\cannot call recv_streaming while another coroutine is already running recv or recv_streamingr~)rget_iterrr rrr4rrrrrr>rrHrrF)rMrframers rNrecv_streamingConnection.recv_streaming;sX #11::6B e  B    "< " ((** ""**zzl- {;+****** nnT88999mm%%4==8sE31/1313E C3EC3C.1A42C.6AC: C.CC. EC+ C C+ #C.&E+C..C33&ED&EcL# URb7[R"UR5IShvN URbM7[U[5(aUR 5IShvN USLa*UR RUR55 O)UR RUR55 SSS5IShvN g[U[5(afUR 5IShvN USLaUR RU5 OUR RU5 SSS5IShvN g[U[5(a [S5e[U[5(Ga[U5n[U5nURbeUR"R%5Ul[U[5(aUR 5IShvN USLa)UR RUR5SS9 O(UR RUR5SS9 SSS5IShvN SnO[U[5(afUR 5IShvN USLaUR RUSS9 OUR RUSS9 SSS5IShvN SnO [S5eUHn[U[5(aZU(aSUR 5IShvN UR R'UR5SS9 SSS5IShvN Mr[U[5(aLU(dEUR 5IShvN UR R'USS9 SSS5IShvN M[S5e UR 5IShvN UR R'SSS9 SSS5IShvN URR1S5 SUlg[U[25(Ga[5U5n[7U5IShvN nURbeUR"R%5Ul[U[5(aUSLaRUR 5IShvN UR RUR5SS9 SSS5IShvN OQUR 5IShvN UR RUR5SS9 SSS5IShvN SnO[U[5(aUSLaDUR 5IShvN UR RUSS9 SSS5IShvN OCUR 5IShvN UR RUSS9 SSS5IShvN SnO [S 5eUShvN n[U[5(aZU(aSUR 5IShvN UR R'UR5SS9 SSS5IShvN Mx[U[5(aLU(dEUR 5IShvN UR R'USS9 SSS5IShvN M[S 5e[S 5eGNGNGN,!,IShvN (df  g=fGNGN!,IShvN (df  g=f![ a gf=fGNSGN!,IShvN (df  GN=fGNGN!,IShvN (df  GN=fGNlGN7!,IShvN (df  GM=fGNGN!,IShvN (df  GM=fGNGN!,IShvN (df  GN=f![(aq UR 5IShvN UR R+[,R.S 5 SSS5IShvN e!,IShvN (df  e=ff=f!URR1S5 SUlf=fGN3![8a gf=fGNGN!,IShvN (df  GNs=fGNGN~!,IShvN (df  GN=fGNfGN?!,IShvN (df  GN=fGNCGN!,IShvN (df  GN2=fGN!GNGN!,IShvN (df  GMG=fGNGN{!,IShvN (df  GMi=f UR 5IShvN UR R'SSS9 SSS5IShvN O!,IShvN (df  O=f![(aq UR 5IShvN UR R+[,R.S 5 SSS5IShvN e!,IShvN (df  e=ff=fURR1S5 SUlg!URR1S5 SUlf=f7f) aK Send a message. A string (:class:`str`) is sent as a Text_ frame. A bytestring or bytes-like object (:class:`bytes`, :class:`bytearray`, or :class:`memoryview`) is sent as a Binary_ frame. .. _Text: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 .. _Binary: https://datatracker.ietf.org/doc/html/rfc6455#section-5.6 You may override this behavior with the ``text`` argument: * Set ``text=True`` to send a bytestring or bytes-like object (:class:`bytes`, :class:`bytearray`, or :class:`memoryview`) as a Text_ frame. This improves performance when the message is already UTF-8 encoded, for example if the message contains JSON and you're using a JSON library that produces a bytestring. * Set ``text=False`` to send a string (:class:`str`) in a Binary_ frame. This may be useful for servers that expect binary frames instead of text frames. :meth:`send` also accepts an iterable or an asynchronous iterable of strings, bytestrings, or bytes-like objects to enable fragmentation_. Each item is treated as a message fragment and sent in its own frame. All items must be of the same type, or else :meth:`send` will raise a :exc:`TypeError` and the connection will be closed. .. _fragmentation: https://datatracker.ietf.org/doc/html/rfc6455#section-5.4 :meth:`send` rejects dict-like objects because this is often an error. (If you really want to send the keys of a dict-like object as fragments, call its :meth:`~dict.keys` method and pass the result to :meth:`send`.) Canceling :meth:`send` is discouraged. Instead, you should close the connection with :meth:`close`. Indeed, there are only two situations where :meth:`send` may yield control to the event loop and then get canceled; in both cases, :meth:`close` has the same effect and is more clear: 1. The write buffer is full. If you don't want to wait until enough data is sent, your only alternative is to close the connection. :meth:`close` will likely time out then abort the TCP connection. 2. ``message`` is an asynchronous iterator that yields control. Stopping in the middle of a fragmented message will cause a protocol error and the connection will be closed. When the connection is closed, :meth:`send` raises :exc:`~websockets.exceptions.ConnectionClosed`. Specifically, it raises :exc:`~websockets.exceptions.ConnectionClosedOK` after a normal connection closure and :exc:`~websockets.exceptions.ConnectionClosedError` after a protocol error or a network failure. Args: message: Message to send. Raises: ConnectionClosed: When the connection is closed. TypeError: If ``message`` doesn't have a supported type. NFTzdata is a dict-like object)finz"iterable must contain bytes or strz#iterable must contain uniform typesrQzerror in fragmented messagez(async iterable must contain bytes or strz)async iterable must contain uniform typesz4data must be str, bytes, iterable, or async iterable)rBr>rr5strrr4 send_binaryencode send_textrr TypeErrorriternext StopIterationr@rGsend_continuation Exceptionrrrs set_resultrr"r#StopAsyncIteration)rMmessagetextchunkschunkrachunkss rNsendConnection.sendsH))5..!?MM++GNN,<= +**  + +((**4<MM++G4MM--g6 +** ) )89 9 * *']F V ..6 66*.))*A*A*CD '. 3eS))#00225= MM55elln%5P MM33ELLN3N 32 "Fy11#00224< MM33Eu3E MM55e5G 32 #F#$HII$E!%--&#'#4#4#6#6 MM;;ELLNPU;V$7#6#6#E955f#'#4#4#6#6 MM;;Eu;M$7#6#6((MNN$ ,,..MM33CT3B/.++66t<.2+ / /GnG #Gn,..6 66*.))*A*A*CD '0 3eS))u}#'#4#4#6#6 MM55elln%5P$7#6#6$(#4#4#6#6 MM33ELLN3N$7#6!Fy11t|#'#4#4#6#6 MM33Eu3E$7#6#6$(#4#4#6#6 MM55e5G$7#6"F#$NOO$+U%!%--&#'#4#4#6#6 MM;;ELLNPU;V$7#6#6#E955f#'#4#4#6#6 MM;;Eu;M$7#6#6((STT*RS Sc > +***+***"!   3222 3222$7#6#6#6$7#6#6#6 /...  ,,..MM&&!005/..  /..  ++66t<.2+-%  $7#6#6#6$7#6#6#6 $7#6#6#6$7#6#6#6U#6#6#6#6$7#6#6#6 $+ ,,..MM33CT3B/.....  ,,..MM&&!005/..  /..  ++66t<.2+++66t<.2+s$1j$[>j$)j$0\1j$4A\ j$\.j$\!j$ =\' j$\$Aj$ ]&.j$)_8>]?_8A] _8$]%0_8]2_8;]8 _8]5 A_8'^(_8+)^ _8^ 6_8^5_8^;5 _8^8'_8(_)_8,_ _8__8Aj$b *b+b /.j$.g b0 g)b69 gb3gcg")c gc5g c2 gc8+ g6c57gdgd/ g:d;ge;d4e;1gd7 g )d=5 gd:6g7e8g;e g!e"g3 j$j$j$\ \  \j$$j$'\>-\0 . \>:j$ ] j$ ]j$_8_8]/]  ]/* _85_88^>^ ? ^ _8_8^2 ^" ^2 , _88_8;_ _ _  _8_8_5#_& $ _50_83a65_88a3`a3+a a3aa3a/ a! a/ +a33a66$bj$b b-*j$,b--j$0g3g6c<b? = c ggc/c  c/* g5g8d>d ? d ggd1d" d1,g4e;7g:g=e e e  gge8 %e(& e8 2gfgg0 g;f><gi=gg ggi=gi:g=;i?+h<* i5h86i<i i i ii=#j$=$j!!j$cb# UR5IShvN URb+URR[R S5 OURR X5 SSS5IShvN gNhN!,IShvN (df  g=f![a gf=f7f)a* Perform the closing handshake. :meth:`close` waits for the other end to complete the handshake and for the TCP connection to terminate. :meth:`close` is idempotent: it doesn't do anything once the connection is closed. Args: code: WebSocket close code. reason: WebSocket close reason. Nzclose during fragmented message)rrBr4rrrs send_closer)rMcoders rNrrConnection.closeWs ((**..:MM&&!009 MM,,T:+*****    szB/BBBAB0 B;B<BB/BBB B BBB/B B,)B/+B,,B/c`# [R"UR5IShvN gN7f)z Wait until the connection is closed. :meth:`wait_closed` waits for the closing handshake to complete and for the TCP connection to terminate. N)r>rrHrWs rN wait_closedConnection.wait_closedvsnnT88999s $.,.c# [U[5(a [U5nO4[U[5(aUR 5nOUb [ S5eUR 5IShvN XR;a [S5eUbXR;aA[R"S[R"S55nUcM0XR;aMAURR5nURR5nX#4URU'UR R#U5 UsSSS5IShvN $NN!,IShvN (df  g=f7f)ax Send a Ping_. .. _Ping: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.2 A ping may serve as a keepalive or as a check that the remote endpoint received all messages up to this point Args: data: Payload of the ping. A :class:`str` will be encoded to UTF-8. If ``data`` is :obj:`None`, the payload is four random bytes. Returns: A future that will be completed when the corresponding pong is received. You can ignore it if you don't intend to wait. The result of the future is the latency of the connection in seconds. :: pong_waiter = await ws.ping() # only if you want to wait for the corresponding pong latency = await pong_waiter Raises: ConnectionClosed: When the connection is closed. ConcurrencyError: If another ping was sent with the same data and the corresponding pong wasn't received yet. Ndata must be str or bytes-likez-already waiting for a pong with the same dataz!I )r5rbytesrrrrrCr structpackrandom getrandbitsr@rGtimer4 send_ping)rMdata pong_waiterping_timestamps rNpingConnection.pings< dI & &;D c " ";;=D  <= =$$&&(((&'VWW,$*;*;";{{4););B)?@,$*;*;";))113K"YY^^-N'2&CD  d # MM # #D )'&&&&&sVA*E.,E-E.0AE EA E> E. E E.E.E+E  E+'E.ct# [U[5(a [U5nO1[U[5(aUR 5nO [ S5eUR 5IShvN URRU5 SSS5IShvN gN0N!,IShvN (df  g=f7f)a" Send a Pong_. .. _Pong: https://datatracker.ietf.org/doc/html/rfc6455#section-5.5.3 An unsolicited pong may serve as a unidirectional heartbeat. Args: data: Payload of the pong. A :class:`str` will be encoded to UTF-8. Raises: ConnectionClosed: When the connection is closed. rN) r5rrrrrrr4 send_pongrMrs rNpongConnection.pongsv dI & &;D c " ";;=D<= =$$&& MM # #D )'&&&&&sHA'B8)B*B8-B B8BB8B8B5$B' % B51B8c[U[5(deUR[;aURR U5 UR[ RLa%UR[UR55 gg)z` Process one incoming event. This method is overridden in subclasses to handle the handshake. N) r5ropcoderrputrPONGacknowledge_pingsrr)rMevents rN process_eventConnection.process_eventsc%'''' <<< '    " "5 ) <<6;; &  " "5#4 5 'rQcTXR;agURR5nSn/nURR5H;unupVUR U5 X&- nUR U5 X1:XdM5Xpl O [S5eUHnURU M g)z+ Acknowledge pings when receiving a pong. Nz!solicited pong not found in pings)rCr@ritemsappendrrDAssertionError)rMrpong_timestampping_idping_idsrrrDs rNrConnection.acknowledge_pingss (( ( )6:6G6G6M6M6O 2G2k OOG $$5G  " "7 +&  7P!!DE E G!!'* rQcTURR[LdeURRnURR 5H;up#UR 5(dURU5 UR5 M= URR5 g)zh Raise ConnectionClosed in pending pings. They'll never receive a pong once the connection is closed. N) r4r`rrrCvaluesdone set_exceptioncancelclear)rMrr_ping_timestamps rN abort_pingsConnection.abort_pingss}}""f,,,mm%%,0,=,=,D,D,F (K##%%))#.    -G !rQc# URceSn[R"URU- 5IShvN URR S5 UR 5IShvN nUR bT[UR 5IShvN UIShvN nSSS5IShvN URR S5 MNNiN?N7N)!,IShvN (df  N>=f![Ra UR(aURR S5 UR5IShvN URR[RS5 SSS5IShvN O!,IShvN (df  O=f[S5ef=f![a URR!S SS 9 gf=f7f) zD Send a Ping frame and wait for a Pong frame at regular intervals. NgTz% sending keepalive pingz% received keepalive pongz&- timed out waiting for keepalive pongzkeepalive ping timeoutzKsend_context() should wait for connection_lost(), which cancels keepalive()zkeepalive ping failedexc_info)r-r>sleepr9r;rr.r$r!rr4rrrsrrerror)rMrDrs rN keepaliveConnection.keepalives !!--- FmmD$6$6$@AAA !!"<=$(IIK/ $$0#243D3D#E#E -8&7G $F#E  ))*EF#B0$F '8 $F#E#E#E#// :: KK--.VW#'#4#4#6#6 MM.. ) 8 8 8$7#6#6#6#6#6 -8  F KK  5  E FsG$'F:C2F:/C0F:C;CC;C!%C&C!* C;5C6C;F:F:C;C!C;!C8'C* ( C84C;;AF7EF7+F? F7 F  F7F( F F( $F77F::$G!G$ G!!G$c|URb/URRUR55Ulgg)zA Run :meth:`keepalive` in a task, unless keepalive is disabled. N)r-r@ create_taskrrErWs rNstart_keepaliveConnection.start_keepalive:s3    )"&))"7"78H"ID  *rQ)expected_statecR# SnSnSnURRULaS7v URR5(aJSnURb;URbeUR R 5UR-UlUR5 UR5IShvN OJSnURb9URc,UR R 5UR-UlSnU(aW[UR5IShvN [ R""UR$5IShvN SSS5IShvN U(aOUR+5 [ R""UR$5IShvN URR,UegGN![a;nUR(aURRSSS9 SnSnUnSnANSnAff=f![[4a e[a+nURRSSS9 SnSnUnSnAGN@SnAff=fGN'GNN!,IShvN (df  GN =f![&a' Ube['S5nSnUR)U5 GN=f=fGN7f)a  Create a context for writing to the connection from user code. On entry, :meth:`send_context` checks that the connection is open; on exit, it writes outgoing data to the socket:: async with self.send_context(): self.protocol.send_text(message.encode()) When the connection isn't open on entry, when the connection is expected to close on exit, or when an unexpected error happens, terminating the connection, :meth:`send_context` waits until the connection is closed then raises :exc:`~websockets.exceptions.ConnectionClosed`. FNT! error while sending datarzunexpected internal errorz"timed out while closing connection)r4r`close_expectedr/rAr@r send_datadrainrr;r9rr rr%r>rrHr! set_recv_excclose_transportr)rMrwait_for_closeraise_close_exc original_excrs rNrConnection.send_contextBsQ,-1 ==  . 0# '==//11%)N ))5#22:::.2iinn.>ASAS.S+ 'NN$**,&&"N!!-&&.*.))..*:T=O=O*OD'"O  0-d.A.ABB!..)D)DEEECB   "..!s J'HA)J'#F=5F:6F=:AJ' I0&I 'I0*$III I0II0#:J'J$J':F== H1G=8J'=HJ'I  I?J'I  J' I0II0I-I  I-(I0+J'-I00-J!J' J!!J'cURR5HnU(aURRU5 M'URR 5(aIUR (aUR R S5 URR5 MUR (aUR R S5 URR5 M g![[4a Mf=f)zL Send outgoing data. Raises: OSError: When a socket operations fails. zx half-closing TCP connectionzx closing TCP connectionN) r4 data_to_sendrUwrite can_write_eofr;r9 write_eofOSError RuntimeErrorrrrs rNrConnection.send_datasMM..0D$$T*>>//11zz ))*IJ002 zz ))*DENN((*%1$\2sC55D D c,URcXlgg)z Set recv_exc, if not set yet. N)rF)rMrs rNrConnection.set_recv_excs == M !rQclURR5 URR5 g)z) Close transport and message assembler. N)rUrrrrWs rNrConnection.close_transports&    "rQc[[RU5n[URUR UR S.6UlUR"UR6 Xl g)N)pauseresume) r r> Transportr&r0 pause_readingresume_readingrset_write_buffer_limitsr1rU)rMrUs rNconnection_madeConnection.connection_madesU**I6 & ^^))++  ))4+;+;<"rQcDURR5 URR[LdeUR U5 UR R 5 UR5 URbURR5 URRS5 UR(aYSUl URHAnUR5(aMUcURS5 M0URU5 MC ggNF)r4 receive_eofr`rrrrrrrErrHrrIrLrr)rMrwaiters rNconnection_lostConnection.connection_losts !!#}}""f,,, #   "     *    & & ( ##..t4 ;;DK,,{{}}{))$/,,S1 - rQc8UR(aeSUlg)NT)rIrWs rN pause_writingConnection.pause_writings;; rQcUR(deSUlURH+nUR5(aMURS5 M- gr)rIrLrrrMr s rNresume_writingConnection.resume_writings>{{{ ((F;;==!!$')rQc# URR5(a[R"S5IShvN UR(a\UR R 5nURRU5 UIShvN URRU5 ggNrN#!URRU5 f=f7f)Nr) rU is_closingr>rrIr@rGrLrremovers rNrConnection.drains >> $ $ & &--" " " ;;YY,,.F    % %f - 2 ""))&1  #""))&1s:9CB.A CB2 B0 B2C0B22CCc4URRU5 URR5nUR5 URR5(aFURb9URc,URR5UR-Ul UHnURU5 M g![aFnUR (aUR R SSS9 URU5 SnANSnAff=f)NrTr)r4 receive_dataevents_receivedrrr;r9rrr/rAr@rr)rMreventsrrs rN data_receivedConnection.data_received"s ""4(..0 # NN  == ' ' ) )!!-&&.*.))..*:T=O=O*OD'E   u % #zz !!">!N   c " " #sC DS 2S  S n 9 9 9 9 # #)) ( ( * * 7, 7( 7( 7  7$C9JB9N!VT<VTVT  VTp>:4l*6 6+:"*'FRJ##!%b<b<  b<$b  ")"HJ0*==' ()BC &5#!!),,!!))D33_-'   s*,D66 G)G/A GGzwebsockets.asyncio.server)F)r>zIterable[Connection]rrr?boolr"r#)9 __future__rr>rJr.r7rrr4rvuuidcollections.abcrrrrrtypesr typingr r rAr rrrframesrrrrrhttp11rrr4rrrrrrrr compatibilityr!r"r#r$r%messagesr&__all__r'rEr)rnrQrNrQs"  VV GF&;;22  .g&!!g&r!#d>%d> d>d> d>P3 rQ