TF-3334 Add more concurrence test cases for WebSocketQueueHandler

linagora · Dec 24, 2024 · 2e47f18 · 2e47f18
1 parent f7dd28a
commit 2e47f18
Show file tree

Hide file tree

Showing 4 changed files with 311 additions and 22 deletions.
diff --git a/lib/features/mailbox_dashboard/presentation/controller/mailbox_dashboard_controller.dart b/lib/features/mailbox_dashboard/presentation/controller/mailbox_dashboard_controller.dart
@@ -1465,10 +1465,6 @@ class MailboxDashBoardController extends ReloadableController with UserSettingPo
   void dispatchRoute(DashboardRoutes route) {
     log('MailboxDashBoardController::dispatchRoute(): $route');
     dashboardRoute.value = route;
-
-    if (dashboardRoute.value == DashboardRoutes.searchEmail) {
-      searchController.activateSimpleSearch();
-    }
   }
 
   @override

diff --git a/lib/features/push_notification/presentation/websocket/web_socket_queue_handler.dart b/lib/features/push_notification/presentation/websocket/web_socket_queue_handler.dart
@@ -38,11 +38,16 @@ class WebSocketQueueHandler {
       return;
     }
 
-    if (queueSize >= _maxQueueSize) {
-      log('WebSocketQueueHandler::enqueue:Queue full, removing oldest message');
-      _messageQueue.removeFirst();
+    try {
+      if (queueSize >= _maxQueueSize) {
+        log('WebSocketQueueHandler::enqueue:Queue full, removing oldest message');
+        _messageQueue.removeFirst();
+      }
+    } catch (e) {
+      logError('WebSocketQueueHandler::enqueue:Exception = $e');
     }
 
+    log('WebSocketQueueHandler::enqueue(): ${message.id}');
     _messageQueue.add(message);
     _queueController.add(message);
   }
@@ -57,6 +62,7 @@ class WebSocketQueueHandler {
     try {
       while (queueSize > 0) {
         final message = _messageQueue.removeFirst();
+        log('WebSocketQueueHandler::_processQueue(): processing message ${message.id}');
 
         try {
           await processMessageCallback(message);
@@ -78,27 +84,40 @@ class WebSocketQueueHandler {
   }
 
   void _addToProcessedMessages(String messageId) {
-    if (_processedMessageIds.length >= _maxProcessedIdsSize) {
-      _processedMessageIds.removeFirst();
+    log('WebSocketQueueHandler::_addToProcessedMessages(): adding message $messageId to processed messages');
+    try {
+      if (_processedMessageIds.length >= _maxProcessedIdsSize) {
+        _processedMessageIds.removeFirst();
+      }
+    } catch (e) {
+      logError('WebSocketQueueHandler::_addToProcessedMessages:Exception = $e');
     }
+
     _processedMessageIds.add(messageId);
   }
 
   void removeMessagesUpToCurrent(String messageId) {
-    final isCurrentStateExist = _messageQueue
-        .any((message) => message.id == messageId);
+    try {
+      log('WebSocketQueueHandler::removeMessagesUpToCurrent(): removing messages up to $messageId');
+      final isCurrentStateExist = _messageQueue
+          .any((message) => message.id == messageId);
 
-    if (!isCurrentStateExist) {
-      log('WebSocketQueueHandler::removeMessagesUpToCurrent:Current state $messageId not found in the queue.');
-      return;
-    }
-    while (queueSize > 0) {
-      final removedMessage = _messageQueue.removeFirst();
-      if (removedMessage.id == messageId) {
-        break;
+      if (!isCurrentStateExist) {
+        log('WebSocketQueueHandler::removeMessagesUpToCurrent:Current state $messageId not found in the queue.');
+        return;
+      }
+
+      while (queueSize > 0) {
+        final removedMessage = _messageQueue.removeFirst();
+        log('WebSocketQueueHandler::removeMessagesUpToCurrent(): removing message ${removedMessage.id} up to $messageId');
+        if (removedMessage.id == messageId) {
+          break;
+        }
       }
+      log('WebSocketQueueHandler::removeMessagesUpToCurrent:Updated Queue: $queueSize');
+    } catch (e) {
+      logError('WebSocketQueueHandler::removeMessagesUpToCurrent:Exception = $e');
     }
-    log('WebSocketQueueHandler::removeMessagesUpToCurrent:Updated Queue: $queueSize');
   }
 
   @visibleForTesting

diff --git a/lib/features/thread/presentation/thread_controller.dart b/lib/features/thread/presentation/thread_controller.dart
@@ -567,8 +567,6 @@ class ThreadController extends BaseController with EmailActionController {
       ),
       beforeOption: const None(),
     );
-    searchController.activateSimpleSearch();
-
     final searchViewState = await _searchEmailInteractor.execute(
       _session!,
       _accountId!,