!߷iVddlZddlZddlmZddlmZddlmZGddeZdS)N)packet) BaseManagercTeZdZdZdZ d dZfdZdZd dZdZ d Z d Z xZ S) AsyncManagerz+Manage a client list for an asyncio server.c2K|||SN) is_connected)selfsid namespaces [/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/socketio/async_manager.pycan_disconnectzAsyncManager.can_disconnect s  i000Nc K|p|}||jvrdSt|trt|}n||g}ng}t|ts|g}g} |s|jt j||g|z} | } t| ts| g} d| D} | ||D]N\} }| |vrE| D]B}| tj |j ||COn| ||D]\} }| |vr|| |}|jt j||g|z|} | tj |j|| | gkrdStj| d{VdS)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 datacLg|]!}tjtj|"S) eio_packetPacketMESSAGE).0ps r z%AsyncManager.emit..+s8000"();Q??000r)r rid)rooms isinstancetuplelistserver packet_classrEVENTencodeget_participantsappendasyncio create_task_send_eio_packet_generate_ack_id _send_packetwait)r eventrr roomskip_sidcallbacktokwargstaskspktencoded_packeteio_pktr eio_sidrrs remitzAsyncManager.emitsmzT DJ & & F dE " " ::DD  6DDD(D)) " zH A+** $+HHC ZZ\\Nnd33 2"0!100 .000G $ 5 5i F F G G Wh&&$GG W%8 K88!DD&F&FGGGG G!% 5 5i F F A A Wh&&..sH==B+22 $3CLL!4 00#>>"@"@AAA B;; Fl5!!!!!!!!!!!rcLKt||S)z`Register a client connection to a namespace. Note: this method is a coroutine. )superconnect)r r6r __class__s rr:zAsyncManager.connectCs! www 222rc$K|j||fi|S)zHDisconnect a client. Note: this method is a coroutine. )basic_disconnect)r r r r1s r disconnectzAsyncManager.disconnectJs% %t$S)>>v>>>rc8K|||||S)zKAdd a client to a room. Note: this method is a coroutine. )r6)basic_enter_room)r r r r-r6s r enter_roomzAsyncManager.enter_roomQs% $$S)T7$KKKrc4K||||S)zPRemove a client from a room. Note: this method is a coroutine. )basic_leave_room)r r r r-s r leave_roomzAsyncManager.leave_roomXs $$S)T:::rc2K|||S)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 $$T9555rc>Kd} |j||}|j||=n7#t$r*|dYnwxYw|:||}t j|r# |d{VdS#t j$rYdSwxYwdSdS)zSInvoke an application callback. Note: this method is a coroutine. Nz$Unknown callback received, ignoring.) callbacksKeyError _get_loggerwarninginspect iscoroutiner&CancelledError)r r rrr/rets rtrigger_callbackzAsyncManager.trigger_callbackfs  (~c*2.H s#B''  O O O      & &'M N N N N N O  (D/C"3'' IIIIIIIII-DD   s!(1AA;BBB)NNNNr ) __name__ __module__ __qualname____doc__rr7r:r>rArDrGrQ __classcell__)r;s@rrr s55111FJ%)3"3"3"3"j33333???LLLL;;;666rr) r&rMengineiorrsocketio base_managerrrrrrrZs))))))%%%%%%ppppp;pppppr