@@ -47,7 +47,9 @@ async def connect(self):
4747 get_user_channel_cache_key (self .user ), self .channel_name , ONE_WEEK_IN_SECONDS
4848 )
4949 # set user online
50- cache .delete (get_user_online_cache_key (self .user ))
50+ user_cache_key = get_user_online_cache_key (self .user )
51+ cache .set (user_cache_key , True , ONE_DAY_IN_SECONDS )
52+
5153 online_users = cache .get (get_users_online_cache_key (), set ())
5254 online_users .add (self .user .id )
5355 cache .set (get_users_online_cache_key (), online_users )
@@ -77,6 +79,9 @@ async def disconnect(self, close_code):
7779 online_users = cache .get (get_users_online_cache_key (), set ())
7880 online_users .discard (self .user .id )
7981 cache .set (get_users_online_cache_key (), online_users )
82+
83+ user_cache_key = get_user_online_cache_key (self .user )
84+ cache .set (user_cache_key , False , ONE_DAY_IN_SECONDS )
8085
8186 async def receive_json (self , content , ** kwargs ):
8287 """Receive message from WebSocket in JSON format"""
@@ -231,6 +236,3 @@ async def decode_json(self, text_data) -> dict:
231236 raise error
232237
233238
234- """
235-
236- """
0 commit comments