feat(chat): WIP: Issue-1594

lib/core/app_router.dart

@@ -373,10 +373,10 @@ class AppRouter {
         name: 'chatScreen',
         builder: (context, state) {
           final data = state.extra as Map<String, dynamic>;
-          final chatId = data['chatId'] as String;
+          final uuid = data['uuid'] as String;
           final sendInitialMessage = data['sendInitialMessage'] as bool?;
           return ChatScreen(
-            chatId: chatId,
+            uuid: uuid,
             sendInitialMessage: sendInitialMessage,
           );
         },

lib/core/const.dart

@@ -1,4 +1,4 @@
-String baseUrl = 'https://eatvio.ru';
+String baseUrl = 'https://mobile-stage.eatvio.ru';
 
 const List<int> durationValues = [7, 14, 21];
 

lib/core/token_storage.dart

@@ -21,3 +21,25 @@ abstract class TokenStorage {
 
   static Future<void> removeTokenInStorage() async => (await const FlutterSecureStorage().delete(key: 'token'));
 }
+
+abstract class SocketIdStorage {
+  static Future<bool> haveSocketIdInStorage() async {
+    try {
+      if (await const FlutterSecureStorage().read(key: 'socketId') == null) {
+        return false;
+      } else {
+        return true;
+      }
+    } catch (e) {
+      return false;
+    }
+  }
+
+  static Future<String?> getSocketIdFromStorage() async => await const FlutterSecureStorage().read(key: 'socketId');
+
+  static Future<void> saveSocketIdInStorage(String socketId) async {
+    await const FlutterSecureStorage().write(key: 'socketId', value: socketId);
+  }
+
+  static Future<void> removeSocketIdInStorage() async => (await const FlutterSecureStorage().delete(key: 'socketId'));
+}

lib/core/websockets/ws_manager.dart

@@ -1,3 +1,4 @@
+import 'dart:convert';
 import 'dart:developer';
 
 import 'package:dart_pusher_channels/dart_pusher_channels.dart';
@@ -59,6 +60,24 @@ class WsManager {
           ),
         );
 
+        String? extractSocketId(String? data) {
+          if (data == null) return null;
+          try {
+            final decoded = jsonDecode(data);
+            return decoded['socket_id'] as String?;
+          } catch (_) {
+            return null;
+          }
+        }
+
+        client?.eventStream.listen((event) async {
+          if (event.name == 'pusher:connection_established') {
+            final data = event.data;
+            final socketId = extractSocketId(data);
+            await SocketIdStorage.saveSocketIdInStorage(socketId!);
+          }
+        });
+
         await client?.connect();
 
         client = client;
@@ -77,7 +96,7 @@ class WsManager {
           EasyDebounce.debounce(
             'searchChatRoom',
             const Duration(milliseconds: 300),
-                () => sl<ChatsCubit>().getChatRooms(),
+            () => sl<ChatsCubit>().getChatRooms(),
           );
           log(event.rootObject.toString());
         });