+ d Z ddlZddlZddlmZmZmZ ddlmZ ddl m
Z
ddl m Z m
Z
ddlmZmZmZmZmZmZ dd lmZ dd
lmZmZ dd lmZm Z m Z m Z ej d k rddlZ nddl Z G d
d Z!dS )z WebSocket client for asyncio. N)AnyOptionalcast ) ClientError)ClientResponse)
call_later
set_result)WS_CLOSED_MESSAGEWS_CLOSING_MESSAGEWebSocketError WSCloseCode WSMessage WSMsgType)WebSocketWriter) EofStreamFlowControlDataQueue)DEFAULT_JSON_DECODERDEFAULT_JSON_ENCODER JSONDecoder JSONEncoder) c e Zd Zddddddddedee d ed
ed ed ed
e j
dee dee de deddfdZ d7dZ
d7dZd7dZd7dZedefd Zedee fd Zedee fd Zede fd Zedefd Zd8d ed edefd Zdee fd Zd9d"eddfd#Z d9d"eddfd$Z d8d%edee ddfd&Z d8d%edee ddfd'Z d8e d(d%edee d)e!ddfd*Z"e#j$ d!d+d,e d"edefd-Z%d8d
ee de&fd.Z'dd/d
ee defd0Z(dd/d
ee defd1Z)e*dd2d3e+d
ee defd4Z,d:d5Z-de&fd6Z.dS );ClientWebSocketResponseNr F)receive_timeout heartbeatcompressclient_notakeoverreaderz FlowControlDataQueue[WSMessage]writerprotocolresponsetimeout autocloseautopingloopr r r r returnc h || _ |j | _ || _ || _ || _ d| _ d| _ d | _ || _ | | _
|| _ || _ |
| _
d | _ |
|
dz | _ d | _ || _ d | _ d | _ | | _ | | _ | d S )NFg @) _response
connection_conn_writer_reader _protocol_closed_closing _close_code_timeout_receive_timeout
_autoclose _autoping
_heartbeat
_heartbeat_cb_pong_heartbeat_pong_response_cb_loop_waiting
_exception _compress_client_notakeover_reset_heartbeat)
selfr r! r" r# r$ r% r& r' r r r r s
e/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/client_ws.py__init__z ClientWebSocketResponse.__init__" s " (
!
*.
/ #!#<@ #,s?D @D
8<
37!"3 c | j | j d | _ | j "| j d | _ d S d S N)r: cancelr8 rA s rB _cancel_heartbeatz)ClientWebSocketResponse._cancel_heartbeatL s\ ! - " ) ) + + +%)D " ) % % ' ' '!%D * )rD c | | j At | j | j | j | j | j j j nd | _ d S d S N )timeout_ceil_threshold) rI r7 r _send_heartbeatr; r,
_connector_timeout_ceil_thresholdr8 rH s rB r@ z(ClientWebSocketResponse._reset_heartbeatU sl ? &!+$
:) (,z'<'T'T
" " "D ' &rD c J | j | j s| j | j | j | j t | j | j
| j | j | j j j
nd | _ d S d S d S rK )r7 r0 r; create_taskr- pingr: rG r _pong_not_receivedr9 r, rO rP rH s rB rN z'ClientWebSocketResponse._send_heartbeatb s ? &t| &
J " "4<#4#4#6#6 7 7 7%1&--///%/'$
:) (,z'<'T'T
& & &D " " " ' & & &rD c | j sKd| _ t j | _ t j | _ | j d S d S )NT) r0 r ABNORMAL_CLOSUREr2 asyncio TimeoutErrorr= r* closerH s rB rT z*ClientWebSocketResponse._pong_not_receivedt sR | # DL * ;D % 2 4 4DO N " " " " " # #rD c | j S rF )r0 rH s rB closedz ClientWebSocketResponse.closed{ s
|rD c | j S rF )r2 rH s rB
close_codez"ClientWebSocketResponse.close_code s rD c | j S rF )r/ rH s rB r" z ClientWebSocketResponse.protocol
~ rD c | j S rF )r> rH s rB r z ClientWebSocketResponse.compress r_ rD c | j S rF )r? rH s rB r z)ClientWebSocketResponse.client_notakeover s &&rD namedefaultc d | j j }||S |j }||S | || S )z$extra info from connection transport)r* r+ transportget_extra_info)rA rb rc connre s rB rf z&ClientWebSocketResponse.get_extra_info s> ~( <NN N''g666rD c | j S rF )r= rH s rB exceptionz!ClientWebSocketResponse.exception s
rD rD messagec J K | j | d {V d S rF )r- rS rA rj s rB rS z ClientWebSocketResponse.ping 4 l (((((((((((rD c J K | j | d {V d S rF )r- pongrl s rB ro z ClientWebSocketResponse.pong rm rD datac K t |t s t dt | z | j |d| d {V d S )Nz data argument must be str (%r)Fbinaryr )
isinstancestr TypeErrortyper- sendrA rp r s rB send_strz ClientWebSocketResponse.send_str sh $$$ K ?? P ADJJ NOO Ol TH EEEEEEEEEEErD )dumpsr c V K | || | d {V d S )N)r )rz )rA rp r r s rB send_jsonz!ClientWebSocketResponse.send_json s> mmEE$KK(m;;;;;;;;;;;rD )coderj r c K | j ;| j s4d| _ | j t d | j d {V | j s| d| _ | j || d {V n# t j
$ r, t j | _
| j t $ r<}t j | _
|| _ | j Y d }~dS d }~ww xY w| j
r| j dS t# j | j 4 d {V | j d {V }d d d d {V n# 1 d {V swxY w Y n# t j
$ r, t j | _
| j t $ r<}t j | _
|| _ | j Y d }~dS d }~ww xY w|j t, j k r'|j | _
| j dS $dS )NTr F)r< r1 r. feed_datar r0 rI r- rY rW CancelledErrorr rV r2 r* Exceptionr=
async_timeoutr$ r3 readrw r CLOSErp )rA r rj excmsgs rB rY z ClientWebSocketResponse.close s = $T] $ DM L " "#5q 9 9 9- | & " " $ $ $ DL
l((w7777777777)
#.#? $$&&&
#.#? "%$$&&&ttttt
$$&&&t
, 4T] C C 8 8 8 8 8 8 8 8$(L$5$5$7$7 7 7 7 7 7 78 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 - '2'CD$N((*** '2'CD$&)DON((*** 44444 8y..'*xD$N((*** 4#
& 5sV )!B AD
1DD
1 F F0F
F F F F AH1HHc K | j t d | j rt S | j r!| d {V t S | j | _ t j |p| j
4 d {V | j d {V }d d d d {V n# 1 d {V swxY w Y |
| j }d | _ t |d n## | j }d | _ t |d w xY wnl# t j t j f$ r t$ j | _ t* $ rI t$ j | _ | d {V t/ t0 j d d cY S t4 $ r" d| _ t$ j | _ t cY S t6 $ rR}|j | _ | |j d {V t/ t0 j |d cY d }~S d }~wt< $ r^}|| _ d| _ t$ j | _ | d {V t/ t0 j |d cY d }~S d }~ww xY w|j t0 j! k r jjll""""""" !14>>>>>
)
)
) # #.#? ((((!
=
=
=#&8 jjchj///////// #t<<<<<<<<
=
=
="% $
#.#? jjll""""""" #t<<<<<<<<
= x9?** $
#&8 | ' ' **,,&&&&&&&Y ... $
Y^+++ii)))))))))Y^+++Js{ D, 0!D C1D
C
D C
D ( D, D''D, ,A %%g%66666666uT{{rD c | S rF rH s rB __aiter__z!ClientWebSocketResponse.__aiter__4 s rD c K | d {V }|j t j t j t j fv rt |S rF )r rw r r r r StopAsyncIteration)rA r s rB __anext__z!ClientWebSocketResponse.__anext__7 sL LLNN"""""" 8 ):Ir s # #
& & & & & & & & & & * * * * * * ) ) ) ) ) ) + + + + + + + + , + + + + + 4 4 4 4 4 4 4 4 w #####Z Z Z Z Z Z Z Z Z ZrD