From d6cd0e719cee867d2eea25ebca72af1a8e8424d1 Mon Sep 17 00:00:00 2001 From: benya Date: Sun, 8 Mar 2026 20:02:46 +0300 Subject: [PATCH] fix(realtime): flush activity state during forced disconnect cleanup --- app/realtime/service.py | 1 + 1 file changed, 1 insertion(+) diff --git a/app/realtime/service.py b/app/realtime/service.py index 10c9fe6..123dd14 100644 --- a/app/realtime/service.py +++ b/app/realtime/service.py @@ -347,6 +347,7 @@ class RealtimeGateway: await self._publish_chat_event(chat_id, event=event_name, payload=payload) async def _cleanup_disconnected_user(self, user_id: int) -> None: + await self._flush_user_activity(user_id) self._connections.pop(user_id, None) affected_chat_ids: list[int] = [] for chat_id, subscribers in list(self._chat_subscribers.items()):