TiUddlZddlmZejddZiZeeefed<d dedefd Z defd Z d Z d Z y)N)Dict*asgi)cors_allowed_origins async_modeactive_connections socket_id user_infocZ|xsit|<td|dtty)NzNew connection added: , total connections: rprintlen)r r s R/home/jay/workspace/tools/ai-image-gen/jaaz-app/server/services/websocket_state.pyadd_connectionr s/$-Oy! "9+-B3GYCZB[ \]c`|tvr&t|=td|dttyy)NzConnection removed: r r )r s rremove_connectionrs6&& y ) $YK/DSI[E\D]^_'rc<ttjSN)listrkeysrrget_all_socket_idsrs "'') **rc ttSr)rrrrrget_connection_countrs ! ""rr) socketiotypingr AsyncServersiorstrdict__annotations__rrrrrrrr$sfh ')DdO(^c^d^`` +#r