i? S SK J r Jr S SKrS SKrS SKrS SKrS SKJr SSKJ r \R " 5 r \R " 5 r
" S S5 r " S S 5 rg)
)datetimetimezoneN)parse_qs )ConnectionRefusedErrorc * \ rS rSrS rSS jrS rSrg) EventBuffer
c 0 U l g Nbufferselfs K/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/socketio/admin.py__init__EventBuffer.__init__ s c [ [ R " 5 5 S- nU SU 3nX@R ; a UUUS.U R U' g U R U S== U-
ss' g )N ;) timestamptypecountr )inttimer )r r r r keys r pushEventBuffer.push se $t+ 1TF# kk ! & DKK
KK W % . %r c r U R n0 U l UR 5 Vs/ s H o"PM sn$ s snf r )r values)r r values r
get_and_clearEventBuffer.get_and_clear s0 #)==?3?%?333s 4r
N)r )__name__
__module__ __qualname____firstlineno__r r r# __static_attributes__ r r r r
s
/4r r c \ 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) InstrumentedServer# Nc t Uc [ S5 eXl X l X`l X@l U=( dK [ U R R S5 ( a U R R R O[ U l X0l
Xpl [ 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_intervalr event_bufferstop_stats_event
stats_task
instrument)r r1 r2 r9 r4 r8 namespacer: s r r InstrumentedServer.__init__$ s
< 56 6 ( ""
(/0@0@)(L(LDHH $ $
%:" 'M !%
r 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 Socket)+r1 on
admin_connectr3 r9 r4
admin_emitadmin_enter_roomadmin_leave_roomadmin_disconnectr6 _timestamps_trigger_event"_InstrumentedServer__trigger_eventbasic_enter_room%_InstrumentedServer__basic_enter_room_basic_enter_roombasic_leave_room%_InstrumentedServer__basic_leave_room_basic_leave_roomrE _InstrumentedServer__emit_emiteio_handle_eio_connect_handle_eio_disconnectengineio.socketrK _ok_InstrumentedServer__ok_eio_http_responsehandle_post_request(_InstrumentedServer__handle_post_request functools
partialmethod __class___eio_handle_post_request_websocket_handler&_InstrumentedServer__websocket_handler_eio_websocket_handler
_send_ping _InstrumentedServer__send_ping_eio_send_pingr rK s r r> InstrumentedServer.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 + HHLL , , 22 '-'A'A$%.%<%< NN 3 3T&;" &,%>%>"$-$;$; NN 1 14%9! 99
%!'!2!2F ) 7 7--t!5F &r c U R S:X a U R R U R l U R R R
U R R l U R R R U R R l U R R R U R R l
U R R R U R R l
SSKJn UR Ul UR$ Ul U R S:X a UR( Ul g g )NrD r rJ )r9 r1 rT rS r6 rV rU rY rX r[ rE r] rb ra r` rK re rd rk rj rn rm rp s r uninstrument InstrumentedServer.uninstrumenty s 99
%&*hh&>&>DHH # 33
HH - 33
HH -$(HH$4$4$;$;DHH ! 88<<,, *%+%A%A"$*$>$>! 99
% & 2 2F &r c p ^ T R ( a Sn[ T R [ 5 ( a UT R :H nO@[ T R [ 5 ( a UT R ; nOT R U5 nU( d [ S5 eU 4S jnT R
R
XQ5 g )NFzauthentication failedc j > TR R S5 S/nTR ( d U/ SQ-
nTR S:X a UR S5 TR R SSU0U TR S9 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 S9 g g )
Ng?AGGREGATED_EVENTS)EMITJOINLEAVE
DISCONNECTMJOINMLEAVE MDISCONNECTrD
ALL_EVENTSconfigsupportedFeaturestor? all_sockets) r1 sleepr4 r9 appendrE r3 r6 get_namespacesget_participantsserialize_socket)sidfeaturesr nspeio_sidr s r r 0InstrumentedServer.admin_connect..config s HHNN3 ,,H>> 6 6yyM) - HHMM(%8($C D,@,@
B yyM) 88++:: *r )r2
isinstancedictlistr r1 start_background_task)r r environ client_auth
authenticatedr s ` r rM InstrumentedServer.admin_connect s 99 !M$))T** +tyy 8
DIIt,, +tyy 8
$ + 6
,-DEE >0
&&v3r c 8 U R R XEX2S9 g )Nr )r1 rE )r _r? room_filtereventdatas r rN InstrumentedServer.admin_emit s
ek
Gr c U R R R X$5 H u pQU R R XSUS9 M! g NrC )r1 r6 r
enter_roomr r r? roomr r s r rO #InstrumentedServer.admin_enter_room = hh&&77(FC HH Y ?(r c U R R R X$5 H u pQU R R XSUS9 M! g r )r1 r6 r
leave_roomr s r rP #InstrumentedServer.admin_leave_room r r c U R R R X$5 H u pQU R R XRS9 M g r )r1 r6 r rI )r r r? closer r s r rQ #InstrumentedServer.admin_disconnect s; hh&&77(FC HH 9(r c U R ( aV U R R 5 U R R 5 U R R 5 S U l g g r )r= r< setrF clearr s r shutdownInstrumentedServer.shutdown sI ?? ! ! % % ' OO " ! ! ' ' ) "DO r c
h [ R " 5 nUS nUS:X Ga
U R R R XR5 nX@R R R U' U R XRU5 nU R R
SU[ R " U[ R 5 R 5 4U R S9 U R R R U5 R ( d' U R R! U R" XeU5 OUS:X a U R R R U US nU R R
SUUU[ R " U[ R 5 R 5 4U R S9 OaU R R
SUUU/USS Q7[ R " U[ R 5 R 5 4U R S9 U R R$ " X/UQ76 $ ) Nr rB socket_connectedrC rI r socket_disconnectedevent_received)r r1 r6 eio_sid_from_sidrR r rE r
fromtimestampr utc isoformatr3 r] _get_socketupgradedr _check_for_upgraderT ) r r r? argstr r serialized_socketreasons r rS !InstrumentedServer._trigger_event s IIK1g I hh&&77GG01HH ( ( - $ 5 5cg N HHMM,!&&q(,,7AAC/ --
/ 88<<++G4==..++W9F
l
" ,,S1!WF HHMM/&&q(,,7AAC 2
--
/
HHMM*"ab"&&q(,,7AAC -
--
/ xx''@4@@r c @ [ S5 H~ nU R R S5 U R R R U5 R
( a+ U R R
SUUSS.U R S9 g M g ! [ a M f = f)N socket_updated websocket)idr transportrC ) ranger1 r r] r r rE r3 KeyError)r r r r? r s r r %InstrumentedServer._check_for_upgrade s qA HHNN1
88<<++G4==HHMM"2 ! (%05 "&!5!5 " 7
>
s A B
B B c U R R R XUU5 nU( aY U R R SUUU[ R
" [ R 5 R 5 4U R S9 U$ )N room_joinedrC )
r1 r6 rV rE r nowr r r r3 )r r r? r r rets r rW $InstrumentedServer._basic_enter_room sv hh 11#$29; HHMM- X\\*446 *
--
/
r c U( aY U R R SUUU[ R " [ R
5 R
5 4U R S9 U R R R XU5 $ )N room_leftrC )
r1 rE r r r r r r3 r6 rY )r r r? r s r rZ $InstrumentedServer._basic_leave_room sm HHMM+ X\\*446 (
--
/ xx 2234HHr c
U R R R " XU4UXVS.UD6nX0R :w a [ U[
5 ( a U/[
U5 - OX/n [ U[ 5 ( d U/nU R R R X45 He u pX; d M U R R SUU
U [ R " [ R 5 R 5 4U R S9 Mg U$ )N)r skip_sidcallback
event_sentrC )r1 r6 r[ r3 r tupler r rE r r r r r ) r r r r? r r r kwargsr
event_datar r s r r\ InstrumentedServer._emit s hh %%e9 04/70(.0 ,, ,1;D%1H1H%4:-]
h-- $: ((**;;IL&HHMM,!" X\\2<<> 1
"&!5!5 " 7 M
r c H 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 $ )N
rawConnection)
r< r1 r] create_eventr= r _emit_server_statsr; r r^ )r r r s r r^ &InstrumentedServer._handle_eio_connect s{ ($(HHLL$=$=$?D ! ?? " "hh < <'' )DO
/xx++G==r c n U R R S5 U R R X5 $ )NrawDisconnection)r; r r1 r_ )r r r s r r_ )InstrumentedServer._handle_eio_disconnect* s, 12xx..w??r c U R R R XUS9nU R R S5 U R R S[ US 5 5 U$ )N)packetsheaders jsonp_index
packetsOutbytesOutresponse)r1 r] rb r; r len)r r r r r s r rc %InstrumentedServer._eio_http_response. s\ hhll ,7 9 |, z3s:+?@
r c U R " U5 nUR R S5 UR R S[ UR SS5 5 5 U$ )N packetsInbytesInCONTENT_LENGTHr )re r; r r get)socketr r r s r ri +InstrumentedServer._eio_handle_post_request5 sU **73 {+ s7;;'7;< >
r c ^ U4S jnU4S jnUR Ul [ R " X25 Ul UR Ul [ R " XB5 Ul U R " U5 $ )Nc > TR R S5 TR R S[ U5 5 U R " U/UQ70 UD6$ )Nr r )r; r r _InstrumentedServer__send)wsr r r r s r _send8InstrumentedServer._eio_websocket_handler.._send= sJ " "< 0 " ":s4y 999T3D3F3 3r c > U R 5 nTR R S5 TR R S[ U=( d S5 5 U$ )Nr r )_InstrumentedServer__waitr; r r )r r r s r _wait8InstrumentedServer._eio_websocket_handler.._waitB sE ))+C " "; / " "9c#)n =Jr )sendr rf partialwaitr rk )r r r r r s ` r rl )InstrumentedServer._eio_websocket_handler< sZ 4
GG ##E.GG ##E.))"--r c 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 S9 M U R " 5 $ )Nr rC )r r r1 r6 r sid_from_eio_sidr rE r r r r r r3 rn )r r r r r? r r s r ro !InstrumentedServer._eio_send_pingN s ** IIK ))88:I((""33GGCs$($9$9#:A%C!
0% **1hll;EEG3 " 1 1 3 ; !!##r c " [ R " 5 n[ U R R R 5 5 nUR 5 U R R 5 ( Gd U R R U R 5 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 S9 U R R 5 ( d GM g g s snf s snf )N server_stats)name socketsCount)serverIdhostnamepiduptime clientsCountpollingClientsCountaggregatedEvents
namespacesrC )r r r1 handlerskeyssortr< is_setr r: rE r8 r7 PIDr r] socketsr! r r; r# r6 roomsr r3 )r
start_timer
sr s r r %InstrumentedServer._emit_server_stats\ s YY[
$((++0023
''..00 HHNN455 6 HHMM. NN $ ))+
2 #DHHLL$8$8 9'* $ 4 4 ; ; = ( =1 JJ = (() %)$5$5$C$C$E
( ) (c $'(8(8(>(>(B(BdBZ))),T2 %8 ( )+ --
/ ''..00( )s 7HH9AH c > 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_INFOr )addressr querysecureurlissuedr )r clientIdr r r handshaker )r1 r6 r r] r r r rR r items
startswithlowerr r r r r r r get_rooms) r r r? r r r tmkvs r r #InstrumentedServer.serialize_sockets s ?hh&&77 E=DA!SVq[QqTa7 E= >!++&7<G {{;3 t) !..r8<<@JJL XX%%//?%
6>s 9 HH #H)
r3 r2 r; r9 r4 r8 r: r1 r= r< )NrD FNz/admin r )NNN)r% r& r' r( r r> rs rM rN rO rP rQ r rS r rW rZ r\ r^ r_ rc ri rl ro r r r) r* r r r, r, # s EJKL495v3 $4LH@
@
:
# A@
I AE(>@.$ $ /.
r r, )r r rf osr r urllib.parser
exceptionsr gethostnamer7 getpidr r r, r* r r r4 sI '
! . iik4 4,j
j
r