wgFddlZddlmZddlmZddlmZGddeZy)N)packet) BaseManagercTeZdZdZdZ d dZfdZdZd dZdZ dZ d Z xZ S) AsyncManagerz+Manage a client list for an asyncio server.c.K|j||SwN) is_connected)selfsid namespaces [/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/socketio/async_manager.pycan_disconnectzAsyncManager.can_disconnect s  i00c K|xs|}||jvryt|tr t|}n||g}ng}t|ts|g}g} |s|jj t j||g|z} | j} t| ts| g} | D cgc]&} tjtj| (} } |j||D]O\}}||vs | D]@} | jtj|jj!|| BQn|j||D]\}}||vs |j#||}|jj t j||g|z|} | jtj|jj%|| | gk(rytj&| d{ycc} w7 w)zEmit a message to a single client, a room, or all the clients connected to the namespace. Note: this method is a coroutine. N)r data)r rid)rooms isinstancetuplelistserver packet_classrEVENTencode eio_packetPacketMESSAGEget_participantsappendasyncio create_task_send_eio_packet_generate_ack_id _send_packetwait)r eventrr roomskip_sidcallbacktokwargstaskspktencoded_packetpeio_pktr eio_sidrs remitzAsyncManager.emit szT DJJ &  dE ":D  6DD(D) zH++** $+HC ZZ\Nnd3"0!1 .0"((););Q?0G0 $ 5 5i F G Wh&$G W%8%8 KK88!D&FGG G!% 5 5i F A Wh&..sH=B++22 $3CLL!4!4 00#>"@A  A B; ll5!!!-0, "s,B(H*+HH4A$HB!H:H; Hc,Kt|||Sw)z`Register a client connection to a namespace. Note: this method is a coroutine. )superconnect)r r2r __class__s rr6zAsyncManager.connectBs ww 22sc2K|j||fi|Sw)zHDisconnect a client. Note: this method is a coroutine. )basic_disconnect)r r r r,s r disconnectzAsyncManager.disconnectIs" %t$$S)>v>>sc4K|j||||Sw)zKAdd a client to a room. Note: this method is a coroutine. )r2)basic_enter_room)r r r r(r2s r enter_roomzAsyncManager.enter_roomPs" $$S)T7$KKsc0K|j|||Sw)zPRemove a client from a room. Note: this method is a coroutine. )basic_leave_room)r r r r(s r leave_roomzAsyncManager.leave_roomWs $$S)T::sc.K|j||Sw)zXRemove all participants from a room. Note: this method is a coroutine. )basic_close_room)r r(r s r close_roomzAsyncManager.close_room^s $$T955rc:Kd} |j||}|j||=|'||}t j |r |d{yyy#t$r"|jjdYTwxYw75#tj $rYywxYww)zSInvoke an application callback. Note: this method is a coroutine. Nz$Unknown callback received, ignoring.) callbacksKeyError _get_loggerwarningr! iscoroutineCancelledError)r r rrr*rets rtrigger_callbackzAsyncManager.trigger_callbackes  (~~c*2.H s#B'  D/C""3'II(  O     & &'M N O--s]BA,BB B BB(A=:B<A==BBBBBB)NNNNr ) __name__ __module__ __qualname____doc__rr3r6r:r=r@rCrL __classcell__)r7s@rrrs:51FJ%)3"j3?L;6r)r!engineiorrsocketio base_managerrrrRrrWs)%p;prR