iW@ d dl Z d dlmZmZ d dlZd dlZd dlZd dlZd dlZd dlm Z ddl
m Z ddl m
Z
ej Z ej Z G d d ZdS ) N)datetimetimezone)parse_qs ) EventBuffer)ConnectionRefusedErrorc e Zd Z d dZd Zd Zd Zd
Zd d Zd d Z d d
Z
d Z d Z d Z
d dZd Z d dZd Zd Zd dZd Zd Zd Zd Zd dZdS ) InstrumentedAsyncServerN/adminF development c f |t d || _ || _ || _ || _ |p1t | j j d r| j j j nt | _ || _
|| _ g | _ t | _ d| _ d| _ | dS )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 ?/usr/local/lib/python3.11/dist-packages/socketio/async_admin.py__init__z InstrumentedAsyncServer.__init__ s
< 566 6 ( ""
(/0@)(L(L
DH $ $
%:" 'MM !%
c | j d| j | j | j dk r}| j s| j d| j | j | j d| j | j | j d| 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 d| j | j j d| j d d
lm} | j j j | j j _ | j | j j _ |j |_ tC j" | j# j$ | |_ |j% |_& tC j" | j# j' | |_% | j dk r2|j( |_) tC j" | j# j* | |_( d S d S ) Nconnectr! r emitjoinleave _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 " 2 4 4 4 9
% %>
< FDO&*&: < < < FD$9&*&: < < < GT%:&*&: < < < M4+@&*&: < < < ,.DH ( (,x'>DH $&*&9DH # 1
H /040FDH - 1
H /040FDH - '+h&6&;DH #$(JDH !
4#;<<< d&ABBB 655555 HL , 2 ,7,K )*3*A N 3T+; +; ' +6*H ')2)@ N 14*9 *9 & 9
% %&1& r( r@ rE rD rC r. rH rG rN rM rQ rP rS s r" uninstrumentz$InstrumentedAsyncServer.uninstrumentg s 9
% %&*h&>DH # 3
H - 3
H -$(H$4$;DH ! 8<, 555555*5*K ')4)H & 9
% %%0%.config s (..%% % % % % % % % ,,H>
6 6 6 6 6yM)) ---(--+>*I#&$2F H H
H
H
H
H
H
H
H yM)) 8+::<< F FC(,(8(I(I )' )' F F W#** 1 1#sG D DF F F FF hmmM;3.2.B $ D D D D D D D D D D D *)r$ ) r
isinstancedictlistinspectiscoroutinefunctionr r start_background_task)r rk environ client_auth
authenticatedra s ` r" r0 z%InstrumentedAsyncServer.admin_connectw s
9 F !M$)T**
; +ty 8
DIt,,
; +ty 8
.ty99 ;*.))K*@*@$@$@$@$@$@$@MM$(IIk$:$:M
F,-DEEE D D D D D0
&&vs33333r$ c R K | j |||| d {V d S )Nrc )r r( )r _r! room_filtereventdatas r" r1 z"InstrumentedAsyncServer.admin_emit s: hmmE4K9mMMMMMMMMMMMr$ c K | j j || D ](\ }}| j ||| d {V )d S Nr' )r r ri
enter_roomr ry r! roomrz rk s r" r2 z(InstrumentedAsyncServer.admin_enter_room s h&77;( ( F FFC(%%c49%EE E E E E E E E E F Fr$ c K | j j || D ](\ }}| j ||| d {V )d S r~ )r r ri
leave_roomr s r" r3 z(InstrumentedAsyncServer.admin_leave_room r r$ c K | j j || D ]'\ }}| j || d {V (d S r~ )r r ri r, )r ry r! closerz rk s r" r4 z(InstrumentedAsyncServer.admin_disconnect sq h&77;( ( @ @FC(%%cY%?? ? ? ? ? ? ? ? ? @ @r$ c K | j rZ| j t j | j d {V d | _ | j d S d S N)r r setasynciogatherclear)r s r" shutdownz InstrumentedAsyncServer.shutdown su ? * ! % % ' ' '. 11 1 1 1 1 1 1 1 "DO ! ' ' ) ) ) ) ) * *r$ c
K t j }|d }|dk r| j j || }|| j j j |< | ||| }| j d|t j |t j
f| j d {V | j j
| j s"| j | j ||| n|dk rv| j j j |= |d }| j d|||t j |t j
f| j d {V ng| j d|||g|dd R t j |t j
f| j d {V | j j ||g|R d {V S ) Nr r& socket_connectedr' r, r socket_disconnectedevent_received)timer r eio_sid_from_sidr5 rj r( r
fromtimestampr utc isoformatr r@ _get_socketupgradedrt _check_for_upgrader7 ) r r{ r! argstrk rn serialized_socketreasons r" r6 z&InstrumentedAsyncServer._trigger_event st IKK1g I h&77YGGG01DH ( - $ 5 5c9g N N (-- 2!&q(,77AACC5 - / /
/
/
/
/
/
/
/ 8<++G44=
F..+Wc9F F F
l
"
" ,S1!WF(-- 5&q(,77AACC 8
- / /
/
/
/
/
/
/
/
/ (-- 0"abb""&q(,77AACC 3
- / /
/
/
/
/
/
/
/ .TX-eYFFFFFFFFFFFr$ c 6 K t d D ]}| j d d {V | j j | j r/| j d||dd| j d {V d S w# t $ r Y w xY wd S )N socket_updated websocket)idrm transportr' ) ranger rf r@ r r r( r KeyError)r rn rk r! ry s r" r z*InstrumentedAsyncServer._check_for_upgrade s q A(..## # # # # # # #
8<++G44= (--(8 ! (%0; ; "&!5 ( 7 7 7 7 7 7 7 7 7
EE
s AB
BBc | j j |||| }|rN| j d|||t j t j ff |S )N room_joined)
r r r9 r rg r nowr r r )r rk r! r rn rets r" r: z)InstrumentedAsyncServer._basic_enter_room s h 11#y$29; ; # #] X\**4466 5 %
r$ c |rN| j d|||t j t j ff | j j ||| S )N room_left)
r rg r r r r r r r r< )r rk r! r s r" r= z)InstrumentedAsyncServer._basic_leave_room st # #[ X\**4466 3 %
x 223 4HHHr$ c
K | j j j |||f|||d| d {V }|| j k rt |t
r|gt
| z n||g} t |t s|g}| j j || D ]c\ }
} |
|vrZ| j d||
| t j
t j
f| j d {V d|S )N)r skip_sidcallback
event_sentr' )r r r> r ro tuplerq ri r( r r r r r ) r r{ r| r! r r r kwargsr
event_datark ry s r" r? z InstrumentedAsyncServer._emit s` +DH$+ 4))- ) )!') ) ) ) ) ) ) ) , , ,1;D%1H1H #%4::--T]
h--
& $: (*;;ItLL
7
7Qh&& (-- !" X\22<<>> 7
"&!5 ( 7 7 7 7 7 7 7 7 7
r$ c & K | j #| j j | _ | j $| j | j | _ | j d | j || d {V S )N
rawConnection)
r r r@ create_eventr rt _emit_server_statsr pushrA )r rn ru s r" rA z+InstrumentedAsyncServer._handle_eio_connect s ($(HL$=$=$?$?D ! ? " "h < <' ) )DO
///X11'7CCCCCCCCCr$ c | K | j d | j || d {V S )NrawDisconnection)r r r rB )r rn r s r" rB z.InstrumentedAsyncServer._handle_eio_disconnect sH 1222X44WfEEEEEEEEEr$ c | j j ||| }| j d | j dt |d |S )N)packetsheaders jsonp_index
packetsOutbytesOutresponse)r r@ rE r r len)r r r r r s r" rF z*InstrumentedAsyncServer._eio_http_response! sh hl ,7 9 9 |,,, z3s:+?+?@@@
r$ c K | j | d {V }|j d |j dt | dd |S )N packetsInbytesInCONTENT_LENGTHr )rH r r intget)socketr ru r s r" rL z0InstrumentedAsyncServer._eio_handle_post_request( s} 0F099999999 {+++ s7;;'7;;<< > > >
r$ c K fd}fd}|j |_ t j || |_ |j |_ t j || |_ | j | d {V S )Nc K j d j dt | | | d {V S )Nr r )r r r _InstrumentedAsyncServer__send)wsr| r s r" _sendz=InstrumentedAsyncServer._eio_websocket_handler.._send0 s_ " "< 0 0 0 " ":s4yy 9 9 94 (((((( (r$ c K | d {V }j d j dt |pd |S )Nr r ) _InstrumentedAsyncServer__waitr r r )r r r s r" _waitz=InstrumentedAsyncServer._eio_websocket_handler.._wait5 se ######C " "; / / / " "9c#)nn = = =Jr$ )sendr rI partialwaitr rN )r r r r r s ` r" rO z.InstrumentedAsyncServer._eio_websocket_handler/ s ) ) ) ) )
G #E2..G #E2../V/333333333r$ c K | j }t j }|j j D ]}|j j || }|rp| ||| }|j d|t j |t j f|j
d {V | j d {V S )Nr r' )rk r r r rh sid_from_eio_sidrj r( r r r r r r rQ )r r rn r r! rk r s r" rR z&InstrumentedAsyncServer._eio_send_pingA s * IKK )88:: 3 3I("33GYGGC
3$($9$9#y:A%C %C!hmm$6% *1hl;;EEGG9 " 1 $ 3 3 3 3 3 3 3 3 3 (V')))))))))r$ c
K t j }t j j }| j s_ j j d {V j
d j t t t j |z
t j j j t d j j j D j fd|D d j d {V j rL j d \ }} j
|| j d {V j L j ]d S d S )N server_statsc g | ] }|j | S )r ).0ss r"
z>InstrumentedAsyncServer._emit_server_stats..\ s. ( ( (1 J(Q ( ( (r$ c
g | ]M}|t j j j |d g i d g dNS )N)name socketsCount)r r r roomsr )r rm r s r" r z>InstrumentedAsyncServer._emit_server_stats.._ sr ) ) ) $'(8(>(B(BdBZ)) ))),T2 %8 %8 ) ) )r$ )serverIdhostnamepiduptime clientsCountpollingClientsCountaggregatedEvents
namespacesr' r )r rq r handlerskeyssortr is_setrf r r( r r PIDr r@ socketsvaluesr
get_and_clearr r pop)r
start_timer r{ r s ` r" r z*InstrumentedAsyncServer._emit_server_statsO s( Y[[
$(+002233
'..00 D(..!;<< < < < < < < <(-- N $ )++
2 #DHL$8 9 9'*( ( 4 ; ; = = ( ( (() () %)$5$C$C$E$E ) ) ) ) ( ) ) )1 1 - / /
/
/
/
/
/
/
/ "
D " . 2 21 5 5 thmmE4.2.B $ D D D D D D D D D "
D% '..00 D D D D Dr$ c * | | j j | }| j j | }| j j |i }|| j j j v r| j j j | nd}|||j rdnd|i | dd d | D d t | dd D | d d d
k | d d |d z |r1t j |t j ndd
| j j || dS )Nr r polling REMOTE_ADDRr c x i | ]7\ }}| d |dd |8S )HTTP_r N)
startswithlowerr kvs r"
z.y sN 6 6 6A ||G 4 4 6AabbEKKMM1 6 6 6r$ c P i | ]#\ }}|t | d k r|d n|$S )r r )r r s r" r z.{ s@ > > >DAq!SVVq[[QqTTa > > >r$ QUERY_STRINGzwsgi.url_schemehttps PATH_INFOi )addressr querysecureurlissuedr )r clientIdr rm r| handshaker )r r r r@ r ru r r5 r itemsr r r r r r get_rooms)r rk r! rn r ru tms r" rj z(InstrumentedAsyncServer.serialize_socketj s ?h&77< >HKK33E5 E55:UWW> > >!++&7<<G {{;33 t) .r8<@@JJLLL X%//Y??%
r$ )Nr FNr r
r )NNN)__name__
__module__ __qualname__r# r rU r0 r1 r2 r3 r4 r r6 r r: r= r? rA rB rF rL rO rR r rj r r$ r" r
r
s EJKL 695 95 95v= = = (4 (4 (4TN N NF F F F
F F F F
@ @ @ @
* * * G G G@
I I I GK ! (D D DF F F 4 4 4$ * * * D D D6
r$ r
)r r r rI rr osr r urllib.parser adminr
exceptionsr gethostnamer getpidr r
r r$ r" r s ' ' ' ' ' ' ' '
! ! ! ! ! ! . . . . . . 6 bikkt
t
t
t
t
t
t
t
t
t
r$