zKl2L d Z ddlZddlmZmZmZ ddlZddlmZ ddl m
Z
ddl m Z m
Z
ddlmZmZmZmZmZmZ dd lmZ dd
lmZmZ dd lmZm Z m Z m 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 JSONEncoderc 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
s/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/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)r8 cancelr6 r? s r@ _cancel_heartbeatz)ClientWebSocketResponse._cancel_heartbeatH s\ ! - " ) ) + + +%)D " ) % % ' ' '!%D * )rB c | | j 't | j | j | j | _ d S d S rD )rG r5 r _send_heartbeatr9 r6 rF s r@ r> z(ClientWebSocketResponse._reset_heartbeatQ sJ ? &!+$dotz" "D ' &rB c | j | j sz| j | j | j | j t | j | j
| j | _ d S d S d S rD ) r5 r. r9 create_taskr+ pingr8 rE r _pong_not_receivedr7 rF s r@ rI z'ClientWebSocketResponse._send_heartbeatY s ? &t| &
J " "4<#4#4#6#6 7 7 7%1&--///%/')=tz& &D " " " ' & & &rB c | j sKd| _ t j | _ t j | _ | j d S d S )NT) r. r ABNORMAL_CLOSUREr0 asyncio TimeoutErrorr; r( closerF s r@ rM z*ClientWebSocketResponse._pong_not_receivedf sR | # DL * ;D % 2 4 4DO N " " " " " # #rB c | j S rD )r. rF s r@ closedz ClientWebSocketResponse.closedm s
|rB c | j S rD )r0 rF s r@
close_codez"ClientWebSocketResponse.close_codeq s rB c | j S rD )r- rF s r@ r z ClientWebSocketResponse.protocolu
~ rB c | j S rD )r< rF s r@ r z ClientWebSocketResponse.compressy rX rB c | j S rD )r= rF s r@ r z)ClientWebSocketResponse.client_notakeover} s &&rB namedefaultc d | j j }||S |j }||S | || S )z$extra info from connection transport)r( r) transportget_extra_info)r? r[ r\ connr^ s r@ r_ z&ClientWebSocketResponse.get_extra_info s> ~( <NN N''g666rB c | j S rD )r; rF s r@ exceptionz!ClientWebSocketResponse.exception s
rB rB messagec J K | j | d {V d S rD )r+ rL r? rc s r@ rL z ClientWebSocketResponse.ping 4 l (((((((((((rB c J K | j | d {V d S rD )r+ pongre s r@ rh z ClientWebSocketResponse.pong rf rB datac K t |t s t dt | z | j |d| d {V d S )Nz data argument must be str (%r)Fbinaryr )
isinstancestr TypeErrortyper+ sendr? ri r s r@ send_strz ClientWebSocketResponse.send_str sh $$$ K ?? P ADJJ NOO Ol TH EEEEEEEEEEErB )dumpsry c V K | || | d {V d S )N)r )rs )r? ri r ry s r@ send_jsonz!ClientWebSocketResponse.send_json s> mmEE$KK(m;;;;;;;;;;;rB )coderc r| c K | j 4| j s-| 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 )Nr TF)r: r. r, feed_datar rG r+ rR rP CancelledErrorr rO r0 r( Exceptionr; r/
async_timeoutr" r1 readrp r CLOSEri )r? r| rc excmsgs r@ rR z ClientWebSocketResponse.close s = $T\ $ 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 AD1C>>D* F
E;)F
;
FF
F F
AH 1HH c 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 r
rP r rQ r rO r0 r OKr r CLOSEDr r
r| ERRORr r; rp r ri r3 CLOSINGPINGr4 rh PONG)r? r" r waiterr s r@ receivez ClientWebSocketResponse.receive s/ 7 }("#PQQQ|
)((
)jjll"""""""((
= $
8 8 : :
- , 4W5U@U V V 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))+++ !]F$(DM vt,,,, "]F$(DM vt,,,,,*G,@A
#.#?
?
?
?#.> 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{{rB c | S rD rF s r@ __aiter__z!ClientWebSocketResponse.__aiter__% s rB c K | d {V }|j t j t j t j fv rt |S rD )r rp r r r r StopAsyncIteration)r? r s r@ __anext__z!ClientWebSocketResponse.__anext__( sL LLNN"""""" 8 ):I rI rM propertyrT rV r r r r r_
BaseExceptionrb ru rL rh rs rx r r r{ r r rR r r r r r r r r r r rB r@ r r s ,0%)"' ( ( ( 1( ( 3- (
! (
( ( ( '( "% ( E?( ( (
( ( ( ( T& & & & # # # # X HSM X (3- X # X '4 ' ' ' X'7 73 7 7 7 7 7 7 8M2 ) )% )$ ) ) ) )) )% )$ ) ) ) )G G3 G(3- G4 G G G G
F FU Fhsm Ft F F F F #'<
2 < < << 3-<
<
< < < < *5 # - - -3 -% -RV - - - -^8 8Xe_ 8 8 8 8 8t ?C # # #HUO #s # # # # AE % % %huo % % % % % 2#' %
rB r ) __doc__rP typingr r r r client_exceptionsr
client_reqrepr helpersr r
httpr r r
r r r http_websocketr streamsr r typedefsr r r r r r rB r@ r sn # # & & & & & & & & & & * * * * * * ) ) ) ) ) ) + + + + + + + + , + + + + + 4 4 4 4 4 4 4 4 O O O O O O O O O OrB