fix(chat): ws manager

lib/features/chat/presentation/bloc/chat_room_cubit/chat_room_cubit.dart

@@ -31,6 +31,7 @@ class ChatRoomCubit extends Cubit<ChatRoomState> {
 
   StreamSubscription<ChannelReadEvent>? typingSubscription;
   StreamSubscription<ChannelReadEvent>? messagesSubscription;
+  StreamSubscription<void>? _reconnectSubscription;
   int currentPage = 1;
   late int lastPage;
   bool isLoading = false;
@@ -126,6 +127,7 @@ class ChatRoomCubit extends Cubit<ChatRoomState> {
       final chatMessages = await chatRepository.getChatMessages(resolvedUuid, currentPage);
       lastPage = chatMessages.meta.lastPage;
       await _subscribeToChatChannel(uuid: resolvedUuid, chatId: chatRoom.id);
+      _listenToReconnect();
       emit(
         ChatRoomState.loaded(
           chatRoom: chatRoom.copyWith(chosenPlan: chosenPlan),
@@ -146,12 +148,48 @@ class ChatRoomCubit extends Cubit<ChatRoomState> {
       log(e.toString());
       typingSubscription?.cancel();
       messagesSubscription?.cancel();
+      _reconnectSubscription?.cancel();
+      _reconnectSubscription = null;
       wsManager.unsubscribeDirectChatChannel();
       emit(const ChatRoomState.error(errorMessage: 'Ошибка получеия данных'));
       return null;
     }
   }
 
+  /// Подписывается на реконнект сокета, чтобы догрузить пропущенное (S5).
+  void _listenToReconnect() {
+    _reconnectSubscription?.cancel();
+    _reconnectSubscription = wsManager.reconnected.listen((_) {
+      unawaited(refreshCurrentChat());
+    });
+  }
+
+  /// Догружает первую страницу сообщений после восстановления соединения (S5).
+  ///
+  /// Мерж по `id` сохраняет уже подгруженные старые страницы: пропущенные
+  /// сообщения добавляются, существующие не дублируются. Порядок — по
+  /// `updatedAt` по убыванию, как его ждёт UI и отдаёт backend (S1).
+  Future<void> refreshCurrentChat() async {
+    final uuid = _activeChatUuid;
+    if (uuid == null) return;
+
+    try {
+      final page = await chatRepository.getChatMessages(uuid, 1);
+      lastPage = page.meta.lastPage;
+      _emitLoaded((current) {
+        final byId = {for (final message in current.chatMessages) message.id: message};
+        for (final message in page.messagesList) {
+          byId.putIfAbsent(message.id, () => message);
+        }
+        final merged = byId.values.toList()
+          ..sort((a, b) => b.updatedAt.compareTo(a.updatedAt));
+        return current.copyWith(chatMessages: merged);
+      });
+    } catch (e, st) {
+      await reportFrom(e, st, this);
+    }
+  }
+
   Future<void> updateChosenPlanState() async {
     try {
       final currentState = state;
@@ -209,9 +247,11 @@ class ChatRoomCubit extends Cubit<ChatRoomState> {
   }
 
   Future<void> _subscribeToChatChannel({required String uuid, required String chatId}) async {
+    // Активный чат запоминаем до проверки клиента: он нужен и для догрузки
+    // пропущенного после реконнекта (S5), даже если сокет появится позже.
+    _activeChatUuid = uuid;
     final client = wsManager.client;
     if (client == null) return;
-    _activeChatUuid = uuid;
     await messagesSubscription?.cancel();
     await typingSubscription?.cancel();
     messagesSubscription = null;
@@ -571,6 +611,7 @@ class ChatRoomCubit extends Cubit<ChatRoomState> {
     _timer?.cancel();
     await messagesSubscription?.cancel();
     await typingSubscription?.cancel();
+    await _reconnectSubscription?.cancel();
     super.close();
   }
 

lib/features/chat/presentation/bloc/chats_cubit/chats_cubit.dart

@@ -17,6 +17,7 @@ class ChatsCubit extends Cubit<ChatsState> {
   final WsManager wsManager;
   StreamSubscription? newIncomingMessagesSubscription;
   StreamSubscription? newLastMessageSubscription;
+  StreamSubscription<void>? reconnectedSubscription;
 
   ChatsCubit({
     required this.chatRepository,
@@ -37,6 +38,11 @@ class ChatsCubit extends Cubit<ChatsState> {
       newIncomingMessagesSubscription = wsManager.newMessagesStream?.listen((event) {
         _handleNewMessageViaSocket(event.data);
       });
+
+      await reconnectedSubscription?.cancel();
+      reconnectedSubscription = wsManager.reconnected.listen((_) {
+        unawaited(getChatRooms());
+      });
     } catch (e, st) {
       await reportFrom(e, st, this);
     }
@@ -199,6 +205,7 @@ class ChatsCubit extends Cubit<ChatsState> {
   @override
   Future<void> close() {
     newIncomingMessagesSubscription?.cancel();
+    reconnectedSubscription?.cancel();
     return super.close();
   }
 }