wg? d dl Z d dlmZmZ d dlZd dlZd dlZd dlZd dlmZ ddl m
Z
ddl m Z ej Z ej Z G d d Zy) N)datetimetimezone)parse_qs ) EventBuffer)ConnectionRefusedErrorc e Zd Z ddZd Zd Zd Zd ZddZddZ dd Z
d
Z d Z d Z
dd
Zd Z ddZd Zd ZddZd Zd Zd Zd ZddZy)InstrumentedAsyncServerNc x | t d || _ || _ || _ || _ |xsF t | j j d r | j j j nt | _ || _
|| _ g | _ t | _ d| _ d| _ | j# y)zInstrument the Socket.IO server for monitoring with the `Socket.IO
Admin UI `_.
Nzauth must be specifiedhost_id)
ValueErrorsioauthadmin_namespace read_onlyhasattrmanagerr HOSTNAME server_idmodeserver_stats_interval admin_queuer event_bufferstop_stats_event
stats_task
instrument)selfr r namespacer r r r s Y/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/socketio/async_admin.py__init__z InstrumentedAsyncServer.__init__ s
< 56 6 ( ""
(/0@0@)(LDHH $ $
%:" 'M !%
c B | j j d| j | j | j dk( rI| j
s| j j d| j | j | j j d| j | j | j j d| j | j | j j d| j | j i | j j _ | j j | j _
| j | j _ | j j j | j j _ | j | j j _ | j j j" | j j _ | j& | j j _ | j j j( | j j _ | j, | j j _ | j j. j d| j0 | j j. j d| j2 d d
lm} | j j. j8 | j j. _ | j< | j j. _ |j> |_ tC jD | jF jH | |_ |jJ |_& tC jD | jF jN | |_% | j dk( rA|jP |_) tC jD | jF jT | |_( y y ) Nconnectr developmentemitjoinleave _disconnect
disconnectr AsyncSocket)+r on
admin_connectr r r
admin_emitadmin_enter_roomadmin_leave_roomadmin_disconnectr _timestamps_trigger_event'_InstrumentedAsyncServer__trigger_eventbasic_enter_room*_InstrumentedAsyncServer__basic_enter_room_basic_enter_roombasic_leave_room*_InstrumentedAsyncServer__basic_leave_room_basic_leave_roomr& _InstrumentedAsyncServer__emit_emiteio_handle_eio_connect_handle_eio_disconnectengineio.async_socketr, _ok _InstrumentedAsyncServer__ok_eio_http_responsehandle_post_request-_InstrumentedAsyncServer__handle_post_request functools
partialmethod __class___eio_handle_post_request_websocket_handler+_InstrumentedAsyncServer__websocket_handler_eio_websocket_handler
_send_ping#_InstrumentedAsyncServer__send_ping_eio_send_pingr r, s r r z"InstrumentedAsyncServer.instrument+ s It 1 1 " 2 2 4 99
%>> FDOO&*&:&: < FD$9$9&*&:&: < GT%:%:&*&:&: < M4+@+@&*&:&: < ,.DHH ( (,xx'>'>DHH $&*&9&9DHH # 11
HH /040F0FDHH - 11
HH /040F0FDHH - '+hh&6&6&;&;DHH #$(JJDHH !
4#;#;< d&A&AB 6 HHLL , , 22 ,7,K,K )*3*A*A NN 3 3T+; ' +6*H*H ')2)@)@ NN 1 14*9 & 99
%&1&<& rC rB rA r, rF rE rL rK rO rN rQ s r uninstrumentz$InstrumentedAsyncServer.uninstrumentf s 99
%&*hh&>&>DHH # 33
HH - 33
HH -$(HH$4$4$;$;DHH ! 88<<,, 5*5*K*K ')4)H)H & 99
%%0%<%.config s^ ((..% % % ,,H>> 6 6yyM) -((--+>*I#&$2F2F H
H
H yyM) 88++::< FC(,(8(8(I(I )' F W#** 1 1#sG DFFF
hhmmM;3.2.B.B $ D D D *
&
HDs5 EE
A(E E B:EEEEE)r
isinstancedictlistasyncioiscoroutinefunctionr r start_background_taskr> create_eventr _emit_server_statsr )r ri environ client_auth
authenticatedr_ s ` r r. z%InstrumentedAsyncServer.admin_connectv s
99 !M$))T* +tyy 8
DIIt, +tyy 8
..tyy9*.))K*@$@M$(IIk$:M ,-DEE D0
&&vs3 $ 9 9 ; ((88 # #%A %As BD5D3BD5c ^ K | j j |||| d { y 7 w)Nra )r r& )r _r room_filtereventdatas r r/ z"InstrumentedAsyncServer.admin_emit s$ hhmmE4K9mMMMs #-+-c K | j j j || D ]+ \ }}| j j ||| d { - y 7 wNr$ )r r rg
enter_roomr ry r roomrz ri s r r0 z(InstrumentedAsyncServer.admin_enter_room W hh&&77;( FFC((%%c49%E E E F E AAAAc K | j j j || D ]+ \ }}| j j ||| d { - y 7 wr~ )r r rg
leave_roomr s r r1 z(InstrumentedAsyncServer.admin_leave_room r r c K | j j j || D ]* \ }}| j j || d { , y 7 wr~ )r r rg r* )r ry r closerz ri s r r2 z(InstrumentedAsyncServer.admin_disconnect sU hh&&77;( @FC((%%cY%? ? ? @ ?s A
AAAc K | j rB| j j t j | j d { y y 7 wN)r r setrp gather)r s r shutdownz InstrumentedAsyncServer.shutdown s= ?? ! ! % % '.. 1 1 1 1s A A A Ac
K t j }|d }|dk( r| j j j || }|| j j j |< | j ||| }| j j
d|t j |t j j f| j d { n|dk( r| j j j |= |d }| j j
d|||t j |t j j f| j d { nk| j j
d|||g|dd t j |t j j f| j d { | j j ||g| d { S 7 '7 7 /7 w) Nr r# socket_connectedr$ r* r socket_disconnectedevent_received)timer r eio_sid_from_sidr3 rh r& r
fromtimestampr utc isoformatr r5 ) r r{ r argstri rl serialized_socketreasons r r4 z&InstrumentedAsyncServer._trigger_event s IIK1g I hh&&77YGG01DHH ( ( - $ 5 5c9g N ((-- 2!&&q(,,7AAC5 -- /
/
/ l
" ,,S1!WF((-- 5&&q(,,7AAC 8
-- /
/
/ ((-- 0"ab"&&q(,,7AAC 3
-- /
/
/ .TXX--eYFFFF)
/
/
/ GsJ CH
HBH
*H+A+H
H%H
<H=H
H
H
H
c d K t d D ] }| j j d d { | j j j | j
r6| j j
d||dd| j d { y y 7 m7 # t $ r Y w xY ww)N socket_updated websocket)idrk transportr$ ) ranger rd r> _get_socketupgradedr& r KeyError)r rl ri r ry s r _check_for_upgradez*InstrumentedAsyncServer._check_for_upgrade s q A((..# # #
88<<++G4== ((--(8 ! (%0; "&!5!5 ( 7 7 7
> #7
sE -B0B B0A B!B B!B0 B!! B-*B0,B--B0c | j j j |||| }|rP| j j d|||t j t j j ff |S )N room_joined)
r r r7 r re r nowr r r )r ri r r rl rets r r8 z)InstrumentedAsyncServer._basic_enter_room sq hh 11#y$29; # #] X\\*446 5 %
r! c |rP| j j d|||t j t j
j
ff | j j j ||| S )N room_left)
r re r r r r r r r r: )r ri r r s r r; z)InstrumentedAsyncServer._basic_leave_room sh # #[ X\\*446 3 %
xx 223 4HHr! c
6 K | j j j |||f|||d| d { }|| j k7 rt |t
r|gt
| z n||g} t |t s|g}| j j j || D ]m \ }
} |
|vs | j j d||
| t j t j j f| j d { o |S 7 7
w)N)r skip_sidcallback
event_sentr$ )r r r< r rm tuplero rg r& r r r r r ) r r{ r| r r r r kwargsr
event_datari ry s r r= z InstrumentedAsyncServer._emit s +DHH$$++ 4))- )!') ) ,, ,1;D%1H%4:-T]
h- $: ((**;;ItL
7Qh& ((-- !" X\\2<<> 7
"&!5!5 ( 7 7 7
7
!)7s) 1DDA9D.A D D
DDc J K | j S| j j j | _ | j j | j
| _ | j j d | j j || d { S 7 w)N
rawConnection)
r r r> rs rr rt r r pushr? )r rl ru s r r? z+InstrumentedAsyncServer._handle_eio_connect s} ($(HHLL$=$=$?D ! "hh < <'' )DO
/XX11'7CCCCs BB# B! B#c K | j j d | j j || d { S 7 w)NrawDisconnection)r r r r@ )r rl r s r r@ z.InstrumentedAsyncServer._handle_eio_disconnect s8 12XX44WfEEEEs ;AAAc | j j j ||| }| j j d | j j dt |d |S )N)packetsheaders jsonp_index
packetsOutbytesOutresponse)r r> rC r r len)r r r r r s r rD z*InstrumentedAsyncServer._eio_http_response s^ hhll ,7 9 |, z3s:+?@
r! c K | j | d { }|j j d |j j dt |j dd |S 7 Vw)N packetsInbytesInCONTENT_LENGTHr )rF r r intget)socketr ru r s r rJ z0InstrumentedAsyncServer._eio_handle_post_request$ sc 0F0099 {+ s7;;'7;< >
:s A1A/AA1c K fd}fd}|j |_ t j || |_ |j |_ t j || |_ | j | d { S 7 w)Nc K j j d j j dt | | j | d { S 7 w)Nr r )r r r _InstrumentedAsyncServer__send)wsr| r s r _sendz=InstrumentedAsyncServer._eio_websocket_handler.._send, sI " "< 0 " ":s4y 94 ( ((s AA A A c K | j d { }j j d j j dt |xs d |S 7 Jw)Nr r ) _InstrumentedAsyncServer__waitr r r )r r r s r _waitz=InstrumentedAsyncServer._eio_websocket_handler.._wait1 sQ #C " "; / " "9c#)n =J $s A$A"A A$)sendr rG partialwaitr rL )r r r r r s ` r rM z.InstrumentedAsyncServer._eio_websocket_handler+ sj )
GG ##E2.GG ##E2./V//3333s A8B;B <Bc K | j }t j }|j j j D ] }|j j j || }|s,|j
||| }|j j d|t j |t j j f|j d { | j d { S 7 7 w)Nr r$ )ri r r r rf sid_from_eio_sidrh r& r r r r r r rO )r r rl r r ri r s r rP z&InstrumentedAsyncServer._eio_send_ping= s ** IIK ))88: 3I((""33GYGC$($9$9#y:A%C!hhmm$6% **1hll;EEG9 " 1 1 $ 3 3 3 3 (V''))) 3 *s+ A0D3A0D#D$D>D?DDc K t j }t | j j j }|j | j j s| j j | j d { | j j d| j t t t j |z
t | j j j t | j j j j# D cg c] }|j$ s| c} | j& j) |D cg c]P }|t | j j* j, j/ |d g i j/ d g dR c}d| j0 d { | j2 r[| j2 j5 d \ }}| j j ||| j0 d { | j2 r[| j j sy y 7 c c}w c c}w 7 7 >w)N server_stats)name socketsCount)serverIdhostnamepiduptime clientsCountpollingClientsCountaggregatedEvents
namespacesr$ r )r ro r handlerskeyssortr is_setrd r r& r r PIDr r> socketsvaluesr r
get_and_clearr roomsr r r pop)r
start_timer srk r{ r s r rt z*InstrumentedAsyncServer._emit_server_statsK s YY[
$((++0023
''..0((..!;!;< < <((-- NN $ ))+
2 #DHHLL$8$8 9'* $ 4 4 ; ; = (1 JJ (() %)$5$5$C$C$E
( ) $'(8(8(>(>(B(BdBZ))),T2 %8 )1 -- /
/
/ "" " . . 2 21 5 thhmmE4.2.B.B $ D D D ""% ''..00 <( )
/$Ds] BI:I)B"I::I,#I:2AI1I: I6 AI:9I8:I: I:'I:, I:8I:c |%| j j j | }| j j j | }| j j
j
|i }|| j j j v r#| j j j | nd}|||j rdnd|i |j
dd |j D ci c]* \ }}|j d r|dd j |, c}}t |j
dd j D ci c] \ }}|t | d k( r|d n| c}}|j
d
d d k( |j
d d |d
z |r2t j |t j" j% ndd| j j j' || dS c c}}w c c}}w )Nr r polling REMOTE_ADDRr HTTP_r QUERY_STRINGr zwsgi.url_schemehttps PATH_INFOi )addressr querysecureurlissuedr )r clientIdr rk r| handshaker )r r r r> r ru r r3 r items
startswithlowerr r r r r r r get_rooms) r ri r rl r ru tmkvs r rh z(InstrumentedAsyncServer.serialize_socketf s ?hh&&77DAq!SVq[QqTa7 >!++&7<G {{;3 t) !..r8<<@JJL XX%%//Y?%
6>s 1/G: H )Nz/adminFNr% r )NNN)__name__
__module__ __qualname__r r rS r. r/ r0 r1 r2 r r4 r r8 r; r= r? r@ rD rJ rM rP rt rh r! r r
r
s EJKL695v= +%ZNF
F
@
2
G:
I GK !(DF4$ * D6
r! r
)rp r r rG osr r urllib.parser adminr
exceptionsr gethostnamer getpidr r
r r! r r sI '
! . 6 biikq
q
r!