iW@ S SK r S SKJrJr S SKrS SKrS SKrS SKrS SKrS SKJ r SSK
J r SSK J
r
\R " 5 r\R " 5 r " S S5 rg) N)datetimetimezone)parse_qs ) EventBuffer)ConnectionRefusedErrorc \ rS rSr SS jrS rS rS rS rSS jr SS jr
SS
jr S r S r
S
rSS jrS r S S jrS rS rS S jrS rS rS rS rSS jrSrg) InstrumentedAsyncServer Nc Uc [ S5 eXl X l X0l X@l U=( dK [ U R R S5 ( a U R R R O[ U l X`l
Xpl / U l [ 5 U l SU l SU l U R# 5 g)zuInstrument 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 Q/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/socketio/async_admin.py__init__ InstrumentedAsyncServer.__init__ s
< 56 6 ( ""
(/0@0@)(L(LDHH $ $
%:" 'M !%
c 8 U R R SU R U R S9 U R S:X GaB U R
( d U R R SU R U R S9 U R R SU R U R S9 U R R SU R U R S9 U R R SU R U R S9 0 U R R l U R R U R l
U R U R l U R R R U R R l U R U R R l U R R R" U R R l U R& U R R l U R R R( U R R l U R, U R R l U R R. R SU R0 5 U R R. R SU R2 5 S S
KJn U R R. R8 U R R. l U R< U R R. l UR> Ul [B RD " U RF RH U 5 Ul URJ Ul& [B RD " U RF RN U 5 Ul% U R S:X aB URP Ul) [B RD " U RF RT U 5 Ul( g g ) 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 "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&<& r( r@ rE rD rC r. rH rG rN rM rQ rP rS s r uninstrument$InstrumentedAsyncServer.uninstrumentg s 99
%&*hh&>&>DHH # 33
HH - 33
HH -$(HH$4$4$;$;DHH ! 88<<,, 5*5*K*K ')4)H)H & 99
%%0%<%# TR R S5 I S h vN S/nTR ( d U/ SQ-
nTR S:X a UR S5 TR R SSU0U TR S9I S h vN TR S:X a / nTR R R 5 HS nTR R R US 5 H& u pUR TR XU5 5 M( MU TR R S X TR S9I S h vN g g GN- N N 7f)
Ng?AGGREGATED_EVENTS)EMITJOINLEAVE
DISCONNECTMJOINMLEAVE MDISCONNECTr'
ALL_EVENTSconfigsupportedFeaturestor all_sockets) r sleepr r appendr( r r get_namespacesget_participantsserialize_socket)sidfeaturesrg nspeio_sidr s r rc 5InstrumentedAsyncServer.admin_connect..config sG ((..% % % ,,H>> 6 6yyM) -((--+>*I#&$2F2F H
H
H yyM) 88++:: #7
sE -B6B!B6A B%B#B%B6#B%%
B3/B62B33B6c U R R R XUU5 nU( aQ U R R SUUU[
R " [ R 5 R 5 445 U$ )N room_joined)
r r r9 r ri r nowr r r )r rm r r rp rets r r: )InstrumentedAsyncServer._basic_enter_room so hh 11#$29; # #] X\\*446 5 %
r# c U( aQ U R R SUUU[ R " [ R
5 R
5 445 U R R R XU5 $ )N room_left)
r ri r r r r r r r r< )r rm r r s r r= )InstrumentedAsyncServer._basic_leave_room sf # #[ X\\*446 3 %
xx 2234HHr# c
D # U R R R " XU4XEUS.UD6I S h vN nX0R :w a [ U[
5 ( a U/[
U5 - OX/n [ U[ 5 ( d U/nU R R R X45 Hm u pX; d M U R R SUU
U [ R " [ R 5 R 5 4U R S9I S h vN Mo U$ N N 7f)N)r skip_sidcallback
event_sentr& )r r r> r rr tuplert rk r( r r r r r ) r r r r r r r kwargsr
event_datarm r} s r r? InstrumentedAsyncServer._emit s HH$$++ ))- )!') ) ,, ,1;D%1H1H%4:-]
h-- $: ((**;;IL& ((-- !" X\\2<<> 7
"&!5!5 ( 7 7 7 M
!)7s) /D D A?D 5A D D D D c d # U R c) U R R R 5 U l U R c* U R R U R 5 U l U R R S5 U R R X5 I S h vN $ N7f)N
rawConnection)
r r r@ create_eventr rw _emit_server_statsr pushrA )r rp rx s r rA +InstrumentedAsyncServer._handle_eio_connect s ($(HHLL$=$=$?D ! ?? " "hh < <'' )DO
/XX11'CCCCs B'B0)B.*B0c # U R R S5 U R R X5 I S h vN $ N7f)NrawDisconnection)r r r rB )r rp r s r rB .InstrumentedAsyncServer._handle_eio_disconnect s5 12XX44WEEEEs :AAAc U R R R XUS9nU R R S5 U R R S[ US 5 5 U$ )N)packetsheaders jsonp_index
packetsOutbytesOutresponse)r r@ rE r r len)r r r r r s r rF *InstrumentedAsyncServer._eio_http_response! s\ hhll ,7 9 |, z3s:+?@
r# c # U R " U5 I S h vN nUR R S5 UR R S[ UR SS5 5 5 U$ NV7f)N packetsInbytesInCONTENT_LENGTHr )rH r r intget)socketr rx r s r rL 0InstrumentedAsyncServer._eio_handle_post_request( s` 0099 {+ s7;;'7;< >
:s A1A/AA1c ^# U4S jnU4S jnUR Ul [ R " X25 Ul UR Ul [ R " XB5 Ul U R " U5 I S h vN $ N7f)Nc ># TR R S5 TR R S[ U5 5 U R U5 I S h vN $ N7f)Nr r )r r r _InstrumentedAsyncServer__send)wsr r s r _send=InstrumentedAsyncServer._eio_websocket_handler.._send0 sH " "< 0 " ":s4y 94 ( ((s AA A A c ># U R 5 I S h vN nTR R S5 TR R S[ U=( d S5 5 U$ NO7f)Nr r ) _InstrumentedAsyncServer__waitr r r )r r r s r _wait=InstrumentedAsyncServer._eio_websocket_handler.._wait5 sP #C " "; / " "9c#)n =J $s A)A'AA))sendr rI partialwaitr rN )r r r r r s ` r rO .InstrumentedAsyncServer._eio_websocket_handler/ sc )
GG ##E.GG ##E.//3333s A:B=B>Bc # U R n[ R " 5 nUR R R 5 H nUR R R X$5 nU( d M1 UR
XTU5 nUR R SU[ R " U[ R 5 R 5 4UR S9I S h vN M U R " 5 I S h vN $ N! N7f)Nr r& )rm r r r rj sid_from_eio_sidrl r( r r r r r r rQ )r r rp r r rm r s r rR &InstrumentedAsyncServer._eio_send_pingA s ** IIK ))88:I((""33GGCs$($9$9#:A%C!hhmm$6% **1hll;EEG9 " 1 1 $ 3 3 3 ; ''))) 3 *s+ A3D 9A-D &D' D D
D
D c 2 # [ R " 5 n[ U R R R 5 5 nUR 5 U R R 5 ( Gd U R R U R 5 I S h vN U R R SU R [ [ [ R " 5 U-
[ U R R R 5 [ U R R R R# 5 Vs/ s H nUR$ ( a M UPM sn5 U R& R) 5 U Vs/ s HQ nU[ U R R* R, R/ US / 05 R/ S / 5 5 S.PMS snS.U R0 S9I S h vN U R2 ( a\ U R2 R5 S5 u pVU R R XVU R0 S9I S h vN U R2 ( a M\ U R R 5 ( d GM g g GNs snf s snf N NJ7f)N server_stats)name socketsCount)serverIdhostnamepiduptime clientsCountpollingClientsCountaggregatedEvents
namespacesr& r )r rt r handlerskeyssortr is_setrh r r( r r PIDr r@ socketsvaluesr r
get_and_clearr roomsr r r pop)r
start_timer sro r r s r r *InstrumentedAsyncServer._emit_server_statsO s YY[
$((++0023
''..00((..!;!;< < <((-- NN $ ))+
2 #DHHLL$8$8 9'* $ 4 4 ; ; = ( =1 JJ = (() %)$5$5$C$C$E
( ) (c $'(8(8(>(>(B(BdBZ))),T2 %8 ( )1 -- /
/
/ "" " . . 2 21 5 hhmmE.2.B.B $ D D D """% ''..00 <( )
/$Dsc BJ J B#JJ J #JAJJ0J1AJ
J J" JJ JJc > Uc% U R R R U5 nU R R R U5 nU R R
R
U0 5 nUU R R R ; a# U R R R U OSnUUUR ( a SOSU0 UR
SS5 UR 5 VVs0 s H1 u pxUR S5 ( d M USS R 5 U_M3 snn[ UR
SS5 5 R 5 VVs0 s H u pxU[ U5 S :X a US OU_M snnUR
S
S5 S :H UR
S S5 US
- U( a3 [ R " U[ R" 5 R% 5 OSS.U R R R' X5 S.$ s snnf s snnf )Nr r polling REMOTE_ADDRr HTTP_r QUERY_STRINGr zwsgi.url_schemehttps PATH_INFOi )addressr querysecureurlissuedr )r clientIdr ro r handshaker )r r r r@ r rx r r5 r items
startswithlowerr r r r r r r get_rooms) r rm r rp r rx tmkvs r rl (InstrumentedAsyncServer.serialize_socketj s ?hh&&77 E=DA!SVq[QqTa7 E= >!++&7<G {{;3 t) !..r8<<@JJL XX%%//?%
6>s 9 HH #H) r r r r r r r r r r r )Nz/adminFNr' r )NNN)__name__
__module__ __qualname____firstlineno__r! r rV r0 r1 r2 r3 r4 r r6 r r: r= r? rA rB rF rL rO rR r rl __static_attributes__ r# r r
r
s EJKL695v= (4TNF
F
@
* G@
I GK !(DF4$ * D6
r# r
)r r r rI ru osr r urllib.parser adminr
exceptionsr gethostnamer getpidr r
r# r# r r* sH '
! . iikt
t
r#