diddlmZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZmZmZmZmZmZmZd d lmZmZd d lmZmZm Z m!Z!d d l"m#Z#m$Z$d dl%m&Z&ddl'm(Z(m)Z)ddl*m+Z+ddl%m,Z,m-Z-erddl.m/Z/d dlm0Z0d dl"m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7m8Z8m9Z9ddl:m;Z;me1gdfZ?edee>e@fgdfZAede$gdfZBedgdfZCedeDe@gdfZEeFee>eGfeDfZHeFe>ee!eDffZIe edZGdde ZJGd d!e$ZKGd"d#eKe(ZLGd$d%eKe)ZMGd&d'ZNed(ZOGd)deNZPGd*d+eNZQy),) annotationsN)Callable)suppress)IntEnum)partial)dumpsloads)select) TYPE_CHECKINGAnyClassVarLiteralOptionalTypeVarUnion)CURL_SOCKET_BAD get_selector) CurlECodeCurlInfoCurlOpt CurlWsFlag)Curl CurlError)CurlCffiWarning) SessionClosedTimeout)Response)not_setset_curl_options)Self)CurlHttpVersion) CurlWsFrame) CookieTypes) HeaderTypes)BrowserTypeLiteralExtraFingerprints ExtraFpDict) AsyncSession ProxySpecT WebSocket),:) separatorscXeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZy) WsCloseCodez?See: https://www.iana.org/assignments/websocket/websocket.xhtmliiiiiiiiiiiiiii i i N)__name__ __module__ __qualname____doc__OK GOING_AWAYPROTOCOL_ERRORUNSUPPORTED_DATAUNKNOWNABNORMAL_CLOSURE INVALID_DATAPOLICY_VIOLATIONMESSAGE_TOO_BIGMANDATORY_EXTENSIONINTERNAL_ERRORSERVICE_RESTARTTRY_AGAIN_LATER BAD_GATEWAY TLS_HANDSHAKE UNAUTHORIZED FORBIDDENTIMEOUTT/root/funda.leads/venv/lib/python3.12/site-packages/curl_cffi/requests/websockets.pyr2r20scI BJNGLONOOKMLIGrKr2c.eZdZdZ d dfd ZxZS)WebSocketErrorzWebSocket-specific error.c&t|||yN)super__init__)selfmessagecode __class__s rLrRzWebSocketError.__init__Js $'rK)r)rTstrrUz)Union[WsCloseCode, CurlECode, Literal[0]])r4r5r6r7rR __classcell__rVs@rLrNrNGs'#OP(("K((rKrNceZdZdZy)WebSocketClosedzWebSocket is already closed.Nr4r5r6r7rJrKrLr[r[Ps&rKr[ceZdZdZy)WebSocketTimeoutzWebSocket operation timed out.Nr\rJrKrLr^r^Ts(rKr^c~eZdZdZdddd dZedZeddZeddZe dd Z e dd Z d Z y ) BaseWebSocket_curl autoclose _close_code _close_reasondebugclosedTF)rcrfcX||_||_d|_d|_||_d|_y)NFra)rScurlrcrfs rLrRzBaseWebSocket.__init__bs. (*.,0  rKct|jturt|j|_|jS)N)rf)rbr rrfrSs rLrizBaseWebSocket.curljs( :: DJJ/DJzzrKc|jS)zThe WebSocket close reason, if the connection has been closed.)rerks rL close_reasonzBaseWebSocket.close_reasonus!!!rKc4tjd||zS)N!H)structpack)rUreasons rL_pack_close_framezBaseWebSocket._pack_close_framezs{{4&//rKct|dkrtj}d}||fS tjd|d}|ddj }|tjk(s |dks|dk\rt d|tj||fS#t$r }t dtj|d}~wt$r }t d tj|d}~wwxYw) Nrrqrr3izInvalid close code: zInvalid close messagezInvalid close frame) lenr2r<rr unpack_fromdecoderNr:UnicodeDecodeErrorr> Exception)framerUrtes rL_unpack_close_framez!BaseWebSocket._unpack_close_frame~s u:>&&DF$V|! ))$6q9qr))+;...$+(.tf5{7Q7QV|& $+[-E-E $);+E+E s#,B C B44 C CC cFd|_|jjy)z$Terminate the underlying connection.TN)rgricloserks rL terminatezBaseWebSocket.terminates  rKN)rirrcboolrfr)returnz Optional[int])r Optional[str])rUintrtbytesrr)r}rrztuple[int, str]) r4r5r6 __slots__rRpropertyrirmro staticmethodrurrrJrKrLr`r`Xs~I9=E   ""00.rKr`)openrdatarTerrorceZdZdZdZefddddddddd dfdZd dZd!d Zd"d Z ddddedd dddddd dddddd dddddf d#dZ d$dZ d%dZ d&dZ edd'dZej"f d(dZd)dZd)dZd*dZedd+dZd,dZd-d.dZej6dfd/dZxZS)0r-z)A WebSocket implementation using libcurl.)skip_utf8_validation _emitters keep_runningTFN)rcrrfon_openon_closeon_data on_messageon_errorct ||||||_d|_i|_|r||jd<|r||jd<|r||jd<|r||jd<| r| |jd<yy) a| Args: autoclose: whether to close the WebSocket after receiving a close frame. skip_utf8_validation: whether to skip UTF-8 validation for text frames in run_forever(). debug: print extra curl debug info. on_open: open callback, ``def on_open(ws)`` on_close: close callback, ``def on_close(ws, code, reason)`` on_data: raw data receive callback, ``def on_data(ws, data, frame)`` on_message: message receive callback, ``def on_message(ws, message)`` on_error: error callback, ``def on_error(ws, exception)`` rircrfFrrrrTrN)rQrRrrr) rSrircrrfrrrrrrVs rLrRzWebSocket.__init__s4 diuE$8!!;= %,DNN6 " &.DNN7 # %,DNN6 " (2DNN9 % &.DNN7 # rKc4|jr td|S)NWebSocket is closedrgr[rks rL__iter__zWebSocket.__iter__s ;;!"78 8 rKc^|j\}}|tjzrt|SrP)recvrCLOSE StopIterationrSmsgflagss rL__next__zWebSocket.__next__s*YY[ U :## #  rKc|jj|}|r ||g|yy#t$rV}|jjd}|r |||n%tjd|dt dYd}~yYd}~yd}~wwxYw)NrzWebSocket callback 'z' failedr stacklevel)rgetr|warningswarnr)rS event_typeargscallbackr~error_callbacks rL_emitzWebSocket._emits>>%%j1  %%  !%!3!3G!<!"4+MM.zl(C'#$, s * B ABB zgzip, deflate, brrwrcF|j}tdid|ddd|dd|gdd|gdd|gd |d |d |d |d d| gd| d| dd| gd| d|d|d|d|d|d|d|d|d|d|d|d||jtjd|j |S) a Connect to the WebSocket. libcurl automatically handles pings and pongs. ref: https://curl.se/libcurl/c/libcurl-ws.html Args: url: url for the requests. params: query string for the requests. headers: headers to send. cookies: cookies to use. auth: HTTP basic auth, a tuple of (username, password), only basic auth is supported. timeout: how many seconds to wait before giving up. allow_redirects: whether to allow redirection. max_redirects: max redirect counts, default 30, use -1 for unlimited. proxies: dict of proxies to use, prefer to use ``proxy`` if they are the same. format: ``{"http": proxy_url, "https": proxy_url}``. proxy: proxy to use, format: "http://user@pass:proxy_url". Can't be used with `proxies` parameter. proxy_auth: HTTP basic auth for proxy, a tuple of (username, password). verify: whether to verify https certs. referer: shortcut for setting referer header. accept_encoding: shortcut for setting accept-encoding header. impersonate: which browser version to impersonate. ja3: ja3 string to impersonate. akamai: akamai string to impersonate. extra_fp: extra fingerprints options, in complement to ja3 and akamai str. default_headers: whether to set default browser headers. default_encoding: encoding for decoding response content if charset is not found in headers. Defaults to "utf-8". Can be set to a callable for automatic detection. quote: Set characters to be quoted, i.e. percent-encoded. Default safe string is ``!#$%&'()*+,/:;=?@[]~``. If set to a sting, the character will be removed from the safe string, thus quoted. If set to False, the url will be kept as is, without any automatic percent-encoding, you must encode the URL yourself. curl_options: extra curl options to use. http_version: limiting http version, defaults to http2. interface: which interface to use. cert: a tuple of (cert, key) filenames for client cert. max_recv_speed: maximum receive speed, bytes per second. curl_options: extra curl options to use. rimethodGETurl params_listN headers_list cookies_listauthtimeoutallow_redirects max_redirects proxies_listproxy proxy_auth verify_listrefereraccept_encoding impersonateja3akamaiextra_fpdefault_headersquote http_version interfacemax_recv_speedcert curl_optionsrrJ)rir!setoptr CONNECT_ONLYperform)rSrparamsheaderscookiesrrrrproxiesrrverifyrrrrrrrrrrrrrris rLconnectzWebSocket.connectsXPyy    v        , (   " v  ,! "$# $% &' () *,+ ,- .&/ 0 1 2*3 45 6&7 > G((!,  rKc|jr td|jj\}}|jt j zr; |j|\|_|_ |jr|j||fS#t$r2}|j|_|j|jd}~wwxYw)z2Receive a single curl websocket fragment as bytes.WebSocket is already closedN)rgr[riws_recvrrrrrdrerNrUrrc)rSchunkr}r~s rL recv_fragmentzWebSocket.recv_fragmentZs ;;!"?@ @yy((* u ;;)) ) 7;7O7OPU7V4 $"4~~ e|" $%66  166"  sB C -CC c g}d}|jjtj}|tk(rt dt j |j\}}|j}|j||jdk(r|tjzdk(rnXdj%||fS#t$r<}|jt j k(rt#|gggd\}}}nYd}~Td}~wwxYw)z Receive a frame as bytes. libcurl splits frames into fragments, so we have to collect all the chunks for a frame. rInvalid active socket?NrK)rigetinfor ACTIVESOCKETrrNrNO_CONNECTION_AVAILABLErrappend bytesleftrCONTrrUAGAINr join)rSchunksrsock_fdrr}r~_s rLrzWebSocket.recvps ))##H$9$9: o % ')J)J  #113 u  e$??a'EJOO,Cq,H xx&& 66Y__,%gYBrz)rSrrs rLrecv_strzWebSocket.recv_strs=iik e ' !79Q9QR R{{}rK)r c2|j}||S)zeReceive a JSON frame. Args: loads: JSON decoder, default is json.loads. )r)rSr rs rL recv_jsonzWebSocket.recv_jsons }}T{rKcv|tjzrd|_|jr t dt |t r|j}|jjtj}|tk(rtdtjd}|t!|kr6||d} |jj#||}||z }|t!|kr6|S#t$$rI}|j&tj(k(r&t+g|ggd\}} }| s td|Yd}~d}~wwxYw)zuSend a data frame. Args: payload: data to send. flags: flags for the frame. FrrrNrzSocket write timeout)rrrrgr[ isinstancerWencoderirrrrrNrrrxws_sendrrUrr ) rSpayloadrroffsetcurrent_buffern_sentr~r writeables rLsendzWebSocket.sends+ :## # %D  ;;!"?@ @ gs #nn&G))##H$9$9: o % ')J)J  s7|#$VW-N **>5A f Fs7|#  66Y__,&,R'B&DOAy!$,-CD!K  s4C&& D8/>D32D33D8cB|j|tjS)zVSend a binary frame. Args: payload: binary data to send. rrBINARYrSrs rL send_binaryzWebSocket.send_binary yy*"3"344rKcB|j|tjS)ztSend a binary frame, alias of :meth:`send_binary`. Args: payload: binary data to send. rrs rL send_byteszWebSocket.send_bytesrrKcB|j|tjS)zRSend a text frame. Args: payload: text data to send. rrrrs rLsend_strzWebSocket.send_str yy*//22rKrc0|j||S)zSend a JSON frame. Args: payload: data to send. dumps: JSON encoder, default is json.dumps. rrSrrs rL send_jsonzWebSocket.send_jsons}}U7^,,rKcB|j|tjS)zMSend a ping frame. Args: payload: data to send. rrPINGrs rLpingzWebSocket.pingrrKc |r|j|fi||jjtj}|t k(rt dtj|jdg}d|_ |jrK |j\}}|j}|jd|||j||jdk(r|tj zdk(swd|j"vrydj%|}|tj&zr|j(s |j+}|tj6zs|tj&zr|jd|g}|tj8zr6d |_ |jd |j2xsd|j:xsd |jrJy y #t,$rT} t.j0|_|j5t.j0t dt.j0| d } ~ wwxYw#t<$r} | j>tj@k(rtC|gggd \} } } n\|jd| |jDs=t.jF} tI| t r | j>} |j5| Yd } ~  d } ~ wwxYw)zRun the WebSocket forever. See :meth:`connect` for details on parameters. libcurl automatically handles pings and pongs. ref: https://curl.se/libcurl/c/libcurl-ws.html rrTrrrTrKz Invalid UTF-8NFrrwrr)%rrirrrrrNrrrrrrrrrrrrrrrzr{r2r>rdrrrrerrUrr rgr<r) rSrkwargsrrrr}rrr~rrUs rL run_foreverzWebSocket.run_foreversY  DLL ' '))##H$9$9: o % ')J)J  6 + #113 u  65%0 e$1,1HA1M.((6*C /9R9R%"%**,C 1 11uz7N 9c2:+++(-D%JJw(8(8(=At?Q?Q?WUWXA$ 2%/:/G/GD, JJ{'?'?@"0 /1I1I##$%%  66Y__,$gYBH52GBH5 H2AH--H22H55 K>B KKrKc|jtury|j||}|j|tj |j y)znClose the connection. Args: code: close code. message: close reason. N)rir rurrrr)rSrUrTrs rLrzWebSocket.close<sE 99  $$T73 #z''( rK)rizUnion[Curl, Any]rcrrrrfrrzOptional[ON_OPEN_T]rzOptional[ON_CLOSE_T]rzOptional[ON_DATA_T]rzOptional[ON_MESSAGE_T]rzOptional[ON_ERROR_T])rr-rr)rEventTypeLiteralrNone)2rrWrz"Optional[Union[dict, list, tuple]]rzOptional[HeaderTypes]rzOptional[CookieTypes]rOptional[tuple[str, str]]rz3Optional[Union[float, tuple[float, float], object]]rrrrrzOptional[ProxySpec]rrrrrzOptional[bool]rrrrrzOptional[BrowserTypeLiteral]rrrrrz/Optional[Union[ExtraFingerprints, ExtraFpDict]]rrrzUnion[str, Literal[False]]rzOptional[CurlHttpVersion]rrrz%Optional[Union[str, tuple[str, str]]]rrrzOptional[dict[CurlOpt, str]])rztuple[bytes, CurlWsFrame])rztuple[bytes, int])rrW)r zCallable[[str], T]rr,)rzUnion[str, bytes, memoryview]rr)rr)rrW)rr rCallable[[Any], str]rzUnion[str, bytes])rw)rrW)rUrrTr)r4r5r6r7rr rRrrrrrrrr rrrrrrrrrr rr2r8rrXrYs@rLr-r-s{3I")(/%*'+)-'+-1)-(/(/ (/ # (/  (/%(/'(/%(/+(/'(/T  &6:)-)-*.GN $'+#04!%!%)<48! $DH $,.26#'6:595k k3k' k ' k ( kEkkk%kk.kkk'k 2!k"#k$%k&B'k()k**+k,0-k.!/k041k23k435kZ,'@8='---.--^553HM-3BH!,rKc eZdZUdZdZdZded<dZded<dZd ed <d d d ddd d dd dd d1fdZ e d2dZ e d3dZ d4dZ d5dZd6dZd7dZd5dZdd d8dZddd9dZedd d:dZej.f d;d Zdd%Zd?d&Zej@d'd(f d@d)Z!d5fd* Z"d5d+Z#d5d,Z$dAd-Z%dBdCd.Z&d5fd/ Z'dDd0Z(xZ)S)EAsyncWebSocketz An asyncio WebSocket implementation using libcurl. NOTE: This object represents a single WebSocket connection. Once closed, it cannot be reopened. A new instance must be created to reconnect. )session_loop_sock_fd _close_lock_terminate_lock _read_task _write_task _close_handle_receive_queue _send_queue_max_send_batch_size_coalesce_framesretry_on_recv_error_yield_interval_use_fair_scheduling _yield_mask_recv_error_retries _terminated_terminated_eventiz ClassVar[int]_MAX_CURL_FRAME_SIZE_MAX_RECV_RETRIESg333333?zClassVar[float]_RECV_RETRY_DELAYTFigMbP??) rcrfrecv_queue_sizesend_queue_sizemax_send_batch_sizecoalesce_framesr%yield_intervalfair_scheduling yield_maskc t ||||||_d|_d|_t j |_tj |_ t j|_ d|_ d|_ d|_t j||_t j||_||_||_| |_| |_| |_| |_d|_d|_y)as Initializes an Async WebSocket session. This class should not be instantiated directly. It is intended to be created via the `AsyncSession.ws_connect()` method, which correctly handles setup and initialization of the underlying I/O tasks. Important: This WebSocket implementation uses a decoupled I/O model. Network operations occur in background tasks. As a result, network-related errors that occur during a `send()` operation will not be raised by `send()`. Instead, they are placed into the receive queue and will be raised by the next call to `recv()`. Args: session (AsyncSession): An instantiated AsyncSession object. curl (Curl): The underlying Curl to use. autoclose (bool, optional): Close the WS on receiving a close frame. debug (bool, optional): Enable debug messages. Defaults to False. recv_queue_size (int, optional): The maximum number of incoming WebSocket messages to buffer internally. This queue stores messages received by the Curl socket that are waiting to be consumed by calling `recv()` send_queue_size (int, optional): The maximum number of outgoing WebSocket messages to buffer before applying network backpressure. When you call `send(...)` the message is placed in this queue and transmitted when the Curl socket is next available for sending. max_send_batch_size (int, optional): The max number of messages per batch. coalesce_frames (bool, optional): Combine multiple frames into a batch. retry_on_recv_error (bool, optional): Retry recv on some transient errors. yield_interval (float, optional): How often to yield control in seconds. fair_scheduling (bool, optional): Change the ~5:1 ratio in favor of `recv`:`send` to a fairer 1:1 ratio. This decreases recv throughput. yield_mask (int, optional): A bitmask that sets the yield frequency for cooperative multitasking, checked every `yield_mask + 1` operations. Must be a power of two minus one (e.g., `63`, `127`, `255`) for efficient bitwise checks. Lower values increase fairness; higher values increase throughput. rN)maxsizerF)rQrRrrrasyncioLockr threadingrEventr+rrr Queuer!r"r#r$r%r&r'r(r)r*)rSrrircrfr2r3r4r5r%r6r7r8rVs rLrRzAsyncWebSocket.__init__qsj diuE/6 :>  )0/8~~/?07 8<9=7;>Emm#? &>&@ADJzzrKc6|jjS)z6Returns the current number of items in the send queue.)r"qsizerks rLr3zAsyncWebSocket.send_queue_sizes%%''rKc|js |jry|jr|jjry|jxr|jj S)a Checks if the background I/O tasks are still running. Returns `False` if either the read or write task has terminated due to an error or a clean shutdown. Note: This is a snapshot in time. A return value of `True` does not guarantee the next network operation will succeed, but `False` definitively indicates the connection is no longer active. F)rgr*rdonerrks rLis_alivezAsyncWebSocket.is_alivesR ;;$** ??t335$$@)9)9)>)>)@AArKct|ddrytt5tjd|dt ddddy#1swYyxYw)z1Warn if the user forgets to close the connection.rgTNzUnclosed WebSocket zN was garbage collected. Always call await ws.close() to ensure clean shutdown.rr)getattrrr|rrResourceWarningrks rL__del__zAsyncWebSocket.__del__sU 44 (  i   MM%dX.II     s !AAc4|jr td|S)NzWebSocket has been closedrrks rL __aiter__zAsyncWebSocket.__aiter__s ;;!"=> > rKc~K|jd{\}}||tjzrt|S7$wrP)rrrStopAsyncIterationrs rL __anext__zAsyncWebSocket.__anext__s:99;& U KUZ%5%55$ $ 's =;%=c|jy|jjtj|_|j t k(rtdtjdt|d}|jj|j|d|_|jj|j|d|_y) aStart the read/write I/O loop tasks. This should be called only once after object creation by the factory. Once started, the tasks cannot be restarted again, this is a one-shot. Raises: WebSocketError: The WebSocket FD was invalid. NzInvalid active socket.)rUz WebSocket-z#xz-read)namez-write)rrirrrrrrNrridrC create_task _read_loop _write_loopr)rSws_ids rL_start_io_taskszAsyncWebSocket._start_io_taskss ?? &  ))(*?*?@ ==O + (y/P/P  ""T(2/))//0A5'QV/X9900    wf%51 rKNrc|K|jr%|jjr td t j |jj |d{\}}t|tr|||fS7#tj$r }tdtj|d}~wwxYww)aReceive a frame as bytes. This method waits for and returns the next complete data frame from the receive queue. Args: timeout: how many seconds to wait before giving up. Raises: WebSocketClosed: If `recv()` is called on a closed connection after the receive queue is empty. WebSocketTimeout: If the operation times out. WebSocketError: A protocol or network error that occurred in a background I/O task, including errors from previous `send()` operations. Returns: tuple[bytes, int]: A tuple with the received payload and flags. rNzWebSocket recv() timed out) rgr!emptyr[r<wait_forrrr| TimeoutErrorr^rOPERATION_TIMEDOUT)rSrresultrr~s rLrzAsyncWebSocket.recvs, ;;4..446!"78 8 ")"2"243F3F3J3J3Lg"VVMFE&), 5= W ## ",i.J.J  s:2B<1B&B'BB<BB9B44B99B<c"K|j|d{\}}||tjzstdtj  |j dS7H#t$r }tdtj |d}~wwxYww)zmReceive a text frame. Args: timeout: how many seconds to wait before giving up. rZNzNot a valid text frameutf-8zInvalid UTF-8 in text frame)rrrrNr2r>rzr{)rSrrrr~s rLrzAsyncWebSocket.recv_str8s !IIgI66 e <  7 !9;;S;ST T ;;w' ' 7 "  -{/G/G  s3BA!6BA# B# B ,BB  B)r rc>K|j|d{\}}|tdtj|tj zr ||j dS||S7V#t$r }tdtj|d}~wwxYww)zReceive a JSON frame. Args: loads: JSON decoder, default is json.loads. timeout: how many seconds to wait before giving up. rZNz(Received empty frame, cannot decode JSONrbz Invalid UTF-8 in JSON text frame)rrNr2r>rrrzr{)rSr rrrr~s rLrzAsyncWebSocket.recv_jsonHs!IIgI66 e < :K2222s $"$c^K|j|tjd{S7w)zSend a ping frame. Args: payload: data to send. For more info, see the docstring for `send(...)` Nr rs rLr zAsyncWebSocket.pingrorlrKg@c K|j4d{|jr dddd{yd|_ |jr|jjs|j ||}t t j5t j|jj|tjf|d{dddt tt5|j|d{ddd|j!t t j5t j|j"j%|d{ddddddd{y7|7b7#1swYxYw7#1swYxYw7?#1swY>xYw#|j!t t j5t j|j"j%|d{7dddw#1swYwxYwxYw7#1d{7swYyxYww)a# Performs a graceful WebSocket closing handshake and terminates the connection. This method sends a WebSocket close frame to the peer, waits for queued outgoing messages to be sent, and then shuts down the connection. This is the recommended way to close the session. Args: code (int, optional): Close code. Defaults to `WsCloseCode.OK`. message (bytes, optional): Close reason. Defaults to `b""`. timeout (float, optional): How long in seconds to wait closed. NTrZ)rrgrrGrurr<r^r]r"rirrr^rNflushrr+wait)rSrUrTr close_frames rLrzAsyncWebSocket.closes## S S{{ S S SDK S##D,<,<,A,A,C"&"8"8w"GK!'"6"67%.. ,,00+z?O?O1PQ$+ ""2NC2"jj1112 g223S!**4+A+A+F+F+H'RRRS+ S S S S 222SSS g223S!**4+A+A+F+F+H'RRRSSS+ S S S SsIFIH; IFIH;AF?AFFFF?4F% F# F%F?)H;?2F31F12F36H;> I H9 IIFF F?#F%%F. *F?1F33F< 8H;?*H6)2H* H H* ! H6*H3 /H66H;9I;I I I  Icj5jr dddyd_jr>jj r$jj fd_net!jrKjjs5jjdjjdddy#1swYyxYw)a3 Immediately terminates the connection without a graceful handshake. This method is a forceful shutdown that cancels all background I/O tasks and cleans up resources. It should be used for final cleanup or after an unrecoverable error. Unlike `close()`, it does not attempt to send a close frame or wait for pending messages. It schedules the cleanup to run on the event loop and returns immediately. It does not wait for cleanup completion. This method is thread-safe, task-safe, and idempotent. NTcVjjjSrP)rCrU_terminate_helperrksrLz*AsyncWebSocket.terminate..sDII11$2H2H2JKrK)rr*rrC is_runningcall_soon_threadsafer rQrr_closed push_curlr+set)rSrVs`rLrzAsyncWebSocket.terminates ! ! 1 1 1 $D zzdii224%)YY%C%CK&" !#<< (<(<LL**40**..0# 1 1 1sC%B6C%%C.cX K|jj}|jj}|jj}|j }|j }|j}|j}g}d} |js|j} |j|j| jd | d{|jdk7r|j/|j |j1} |\} }|j2}|j4dkDrd|_|t6j8zr|tt j"5|| |fddd|j;| d{ tt j"5|t-ddfdddy|j=| |j>dkrB|t6j@zdk(r,djC|}|jE |||f| dz } | |zdk(}|j1| z |kD}|r|s|r2n|r/|r-t!jFdd{|j1} {tt j"5|t-ddfdddy#t$r} tt j"5|t%d| t&j(dfdddn #1swYnxYw|j+Yd} ~ tt j"5|t-ddfdddy#1swYyxYwd} ~ wwxYw7#|jdk7r|j/|jwwxYw#1swY=xYw7,#1swYyxYw#t j"$r|||fd{7YwxYw7#tH$rI}|jJt&jLk(rYd}~n)|jJt&jNk(ru|jPri|j4|jRkrP|xj4dz c_t!jF|jT|j4zd{7Yd}~tt j"5||dfdddn #1swYnxYw|j+Yd}~tt j"5|t-ddfdddy#1swYyxYwd}~wwxYw|jsΐ#t jV$rYt$r`}|js9tt j"5||dfdddn #1swYnxYw|j+Yd}~Od}~wwxYw#1swYyxYw#tt j"5|t-ddfdddw#1swYwxYwxYww)aThe main asynchronous task for reading incoming WebSocket frames. This method is fully event-driven. It waits for the underlying socket to become readable, and upon being woken by the event loop, it drains all buffered data from libcurl until it receives an EAGAIN error. This error signals that the buffer is empty, and the loop returns to an idle state, waiting for the next readability event. To ensure cooperative multitasking during high-volume message streams, the loop yields control to the asyncio event loop periodically. If the receive queue becomes full, await `self._receive_queue.put(...)` will block the reader loop and stall the socket read task. Thus, appropriate queue sizes should be set by the user, even though the defaults are generous and should be suitable for most use cases. rNzadd_reader failed: zConnection closed.r:rKr),rbrr!rgrirCr'r(r&rg create_future add_readerr set_resultr|rr<rhrNrrrr[ remove_readertimerr)rr_handle_close_framerrrrclearsleeprrUr RECV_ERRORr%r.r/CancelledError)rS curl_ws_recvqueue_put_nowait queue_putrCr7r8r6r msg_counter read_futureexc start_timerr}rrTop_check time_checkr~s rLrVzAsyncWebSocket._read_loops{&zz)) ..99''++ yy33%% --  e Mkk"002 OODMM;3I3I4P:%%%}}***4==9"YY[ :'3~ u%*[[33a778D4!:#3#33!)'*;*;!<A 0% @A"&":":5"AAA"r'++, M /2F"G!KL M Mm e,!??a/UZ__5LQR4R&)hhv&6G"LLNB 0'51A B$q( *5 *Bq)H+/99;+Cn+T  /&"*z")--"222)-JIJ'++, M /2F"G!KL M My! !'"3"34 ( .&9#$?$-$E$E!"!"    NN$`'++, M /2F"G!KL M M My &}}***4==9+AAAt M M]$+#4#4B&/%0@&A A AB3%66Y__4!FFi&:&:: $ 8 8 $ 8 84;Q;Q Q 4494")-- $ 6 69Q9Q Q#%&g&7&785,aV4555('++, M /2F"G!KL M M M?Gkkt%%   ;;g//0-$aV,--- NN      M M'++, M /2F"G!KL M M Ms A7X*:U'J7M5M2M5 :X* O+!O$"O+'O1*O++O11 U;T?UBT?$R'%T?*U0T? S T?S& "T?9U=X*T3* X*3T<8X*?UUW*W$-W5%W V.% W.V7 3W W$WW$W!X*$X'>X X'X$ X''X*c> Ktjtjz}|j}|jj }|jj } |d{\}}||fg}|tjzsdt||jkrL |\}}|j||f|tjzrn t||jkrL |jri} |D].\}}||zr| jD]y\} } |dj| | d{r'tt|D]} |jj! |j"s|j%yy| j'|||d{rtt|D]} |jj! |j"s|j%yy| j)|gj|1| jD]x\} } |dj| | d{r'tt|D]} |jj! |j"s|j%yynn|D]i\}}|||d{rtt|D]} |jj! |j"s|j%yytt|D]} |jj! |ddtjzrn |j"s|j%yy71#tj$rYwxYw7z77[7#tt|D]} |jj!wxYw#tj*$rYt,$rb} |j"sLt/tj05|j2j5| dfdddn #1swYnxYwYd} ~ d} ~ wwxYw#|j"s|j%wwxYww)a( The high-level send manager. It efficiently gathers pending messages from the send queue and orchestrates their transmission. This method runs a continuous loop that consumes messages from the `_send_queue`. To improve performance and reduce system call overhead, it implements an adaptive batching strategy. It greedily gathers multiple pending messages from the queue and then coalesces the payloads of messages that share the same flags (e.g., all text frames) into a single, larger payload, ONLY if `coalesce_frames=True` and the frame is not a CONTROL frame, as the spec requires them to be whole. It will batch as many as possible, then iterate over the batch and send the frames, one at a time. This batching and coalescing significantly improves throughput for high volumes of small messages where the message boundaries do not matter. The final, consolidated payloads are then passed to the `_send_payload` method for transmission. NrKr:rr)rrr  _send_payloadr"r get_nowaitrxr#rr< QueueEmptyr$itemsrrange task_donergrr setdefaultrr|rrhr!rg)rScontrol_frame_flags send_payload queue_getqueue_get_nowaitrrbatchr}data_to_coalesce frame_grouppayloadsrr~s rLrWzAsyncWebSocket._write_loopsS&$.#3#3joo#E)) $$(( ++66B !'0{!2"5)*z///e*t'@'@@"-=-?NGU!LL'5)9:$z'7'77 % 8 e*t'@'@@ 5,,CE(.3 WNGU$'::=M=S=S=U!/$9K1=(+(:K2&,&,&)/(#3u:.5((2245";; S!/ !1 6 6 8-9'5-I'I'I$* #3u:.5((2245";; ?!1 ; ;E2 F M Mg V W 6F5K5K5M'1K)5chhx6H+)V#V#V &#3u:.5((2245";; 9' /4'NGU)5gu)E#E#E &#3u:.5((2245";; /' #3u:.5((22459Q<*"2"22ih;; "3 '11"!",& (J$W $F #3u:.5((2245%%   ;;;g//0;''22Aq6:;;; ;;; s_AR O9(N)7O9!0NO9-AO<N6=OO3O98RO3N94O9O:3O9.R AO!N<"O'O(3O9R:ON?OO3O9 R)O*AO9:Q;;RO9N3/O92N33O96O9O<O?O5O66O99Q8 Q;Q8%Q3;Q" Q3"Q+ 'Q3.Q;3Q88Q;;RRc K|jj}|jj}|j}t |}d}d}|j } |t|kr||jzdk(s |j | z |jkDr-tjdd{|j } ||||jz} || |} | dk(rEttj5|tdt j"dfdddy|| z }|dz }|t|kry7#1swYyxYw#t$$rt} | j&t j(k7r>ttj5|| dfdddn #1swYnxYwYd} ~ y|j+} |j-|j.| j0dnn#t2$rb}ttj5|td|t j4dfdddn #1swYnxYwYd}~Yd} ~ yd}~wwxYw | d{7|j.dk7rL|j7|j.n0#|j.dk7r|j7|j.wwxYwYd} ~ d} ~ wwxYww) at The low-level I/O Handler. It transmits a single payload, handling fragmentation, backpressure (EAGAIN), and cooperative multitasking. Returns False on a non-recoverable error. Args: payload: The complete byte payload to be sent. flags: The `CurlWsFlag` indicating the frame type (e.g., `TEXT`, `BINARY`). rNzws_send returned 0 bytesFrzadd_writer failed: r:T)rbrr!rgrCrfrrxr(r&r<rr,rrhrNr SEND_ERRORrrUrr add_writerrrr|r remove_writer)rSrr curl_ws_sendrrCviewr write_opsrrrr~ write_futurers rLrzAsyncWebSocket._send_payloadszz)) ..99yy'"  IIK s4y D,,,2 j($$7%mmA&&&!YY[ / :Vft/H/H&HI%eU3Q;!'"3"34 ( .$>$-$8$8!"!"  !& Q 1s4y pg' ! :66Y__,!'"3"341(!Q0111  $113  !OODMM<3J3JDQ !!'"3"34 ( .&9#$?$-$E$E!"!"    !5 !:&&&}}***4==9}}***4==9+9 :sB0K2E3K9E#E $E,K- E7KK EEKE K6K F) K)F2 .K5K:K 'G32K3 I<I&I; II IKKIK"J'I*(J-+K-KKKKKcdK|jr?|jjr%|jjs t d t j |jj|d{y7#t j$r}td|d}~wwxYww)aWaits until all items in the send queue have been processed. This ensures that all messages passed to `send()` have been handed off to the underlying socket for transmission. It does not guarantee that the data has been received by the remote peer. Args: timeout (Optional[float], optional): The maximum number of seconds to wait for the queue to drain. Raises: WebSocketTimeout: If the send queue is not fully processed within the specified ``timeout`` period. WebSocketError: If the writer task has already terminated while unsent messages remain in the queue. z6Cannot flush, writer task has terminated unexpectedly.rZNz*Timed out waiting for send queue to flush.) rrGr"r\rNr<r]rr^r^)rSrr~s rLrszAsyncWebSocket.flush=s$     %%'$$**, H  X""4#3#3#8#8#:GL L L## X"#OPVW W Xs<A B02B BB B0B B- B((B--B0cDKt}d} |j|jfD]6} |r1|js!|j |j |8|rTtt j5t jt j|ddi|d{ddd|jjsP |jj|jj!|jjsP|j&dk7rztt(5|j*j-|j&dddtt(5|j*j/|j&dddd|_t0|e|j4r1|j4j6s|j4j9d|j:jy#t jtf$rY wxYw7#1swYxYw#t j"t$f$rYBwxYw#1swYxYw#1swYxYw#|j:jwxYww)z)Utility method for connection terminationr-return_exceptionsTrZNr:)r~rrrGcanceladdr<r RuntimeErrorrr^r]gatherr"r\rrr ValueErrorrr|rCrrrQrrr|r}r+)rStasks_to_cancel max_timeoutio_taskrVs rLrxz AsyncWebSocket._terminate_helper\s365 * ) OOT-=-=> w||~('++G4  g223!**P4P +&&,,.$$//1$$..0&&,,.}}"i(;II++DMM:;i(;II++DMM:;DM G  ||DLL$8$8 &&t,  " " & & (G .. =  **J7 ;;;;  " " & & (s J J3H J=.H;+H8,H;0"J4IJ"J&I(&J=&I5#AJ=J H51J4H55J8H;;IJI%!J$I%%J(I2-J5I>:JJJ cXK |j|\|_|_|j rB|j s6|j|jxstjd{y|jy#t$r}|j|_Yd}~~d}~wwxYw7=w)z>$++**T--?@ @ @ NN  & vvD   & As:B*BAB**B(+B* B% B B* B%%B*)rr*rirrcrrfrr2rr3rr4rr5rr%rr6floatr7rr8rrr)rzasyncio.AbstractEventLoop)rr)rr)rr)rr"r)rOptional[float]rztuple[Optional[bytes], int])rrrrW)r z Callable[[Union[str, bytes]], T]rrrr,)rz(Union[str, bytes, bytearray, memoryview]rr)rrrr)rrWrr)rr rrrrr)rUrrTrrrrr)rrrrrrrP)rrrr)rTrrr)*r4r5r6r7rr,__annotations__r.r/rRrrCr3rHrLrNrQrYrrr rrrrrrrrrr r2r8rrrVrWrrsrxrrXrYs@rLrrNs9I.+0-/'(}(),,""#& %$) % %L'L'L'  L'  L'L'L'!L'L'"L'L'L'L' L'\ ((B&    <-1")" $"H<@&38#' 0!  :'--.99.9.9`;;9>C 3 3&: 3  39&..3QT%S%S38%SIN%S %SN1@BMHZ!xM^X>/)b rKr)R __future__rr<rrr>rcollections.abcr contextlibrenumr functoolsrjsonrr r typingr r r rrrraiorrconstrrrrrirrutilsr exceptionsrrmodelsrr r!typing_extensionsr"r#r$rr%rr&rr'r(r)rr*r+r,r ON_DATA_TrW ON_MESSAGE_T ON_ERROR_T ON_OPEN_Tr ON_CLOSE_Ttupler|RECV_QUEUE_ITEMSEND_QUEUE_ITEMr2rNr[r^r`rr-rrJrKrLrs" $RRR/<<"#.,&'"$$OO0 A+uk:D@AI[%s *;