LA-1352 added unit test for getListDataForRecipient

linagora · Nov 15, 2024 · 15a4665 · 15a4665
1 parent 49ca084
commit 15a4665
Show file tree

Hide file tree

Showing 3 changed files with 85 additions and 9 deletions.
diff --git a/data/lib/src/local/received_share_database_manager.dart b/data/lib/src/local/received_share_database_manager.dart
@@ -100,10 +100,14 @@ class ReceivedShareDatabaseManager
   }
 
   Future<List<ReceivedShare>> getListDataForRecipient(String mail) async {
-    String todayDate = DateTime.now().toIso8601String();
+    final now = DateTime.now();
+    final todayDate =
+        DateTime(now.year, now.month, now.day, now.hour, now.minute).toIso8601String();
+    final queryCondition =
+        '${ReceivedShareTable.MAIL_RECIPIENT} !="" AND ${ReceivedShareTable.MAIL_RECIPIENT} = ? AND ${ReceivedShareTable.EXPIRATION_DATE} >= ?';
     final res = await _databaseClient.getListDataWithCondition(
         ReceivedShareTable.TABLE_NAME,
-        '${ReceivedShareTable.MAIL_RECIPIENT} !="" AND ${ReceivedShareTable.MAIL_RECIPIENT} = ? AND ${ReceivedShareTable.EXPIRATION_DATE} >= ?',
+        queryCondition,
         [mail, todayDate]);
     return res.isNotEmpty
         ? res

diff --git a/data/test/local/received_share_database_manager_test.dart b/data/test/local/received_share_database_manager_test.dart
@@ -0,0 +1,66 @@
+import 'package:data/data.dart';
+import 'package:data/src/local/config/received_share_table.dart';
+import 'package:data/src/local/model/received_share_cache.dart';
+import 'package:domain/domain.dart';
+import 'package:flutter_test/flutter_test.dart';
+import 'package:mockito/mockito.dart';
+import 'package:mockito/annotations.dart';
+import 'package:testshared/fixture/received_share_fixture.dart';
+import 'document_database_manager_test.mocks.dart';
+
+@GenerateMocks([DatabaseClient])
+void main() {
+  late MockDatabaseClient mockDatabaseClient;
+  late ReceivedShareDatabaseManager receivedShareDatabaseManager;
+  late DateTime now;
+  late String todayDate;
+  setUp(() {
+    mockDatabaseClient = MockDatabaseClient();
+    receivedShareDatabaseManager =
+        ReceivedShareDatabaseManager(mockDatabaseClient);
+    now = DateTime.now();
+    todayDate = DateTime(now.year, now.month, now.day, now.hour, now.minute)
+        .toIso8601String();
+  });
+
+  group('getListDataForRecipient', () {
+    test(
+        'getListDataForRecipient returns filtered and mapped data for a specific recipient',
+        () async {
+      when(mockDatabaseClient.getListDataWithCondition(
+        ReceivedShareTable.TABLE_NAME,
+        '${ReceivedShareTable.MAIL_RECIPIENT} !="" AND ${ReceivedShareTable.MAIL_RECIPIENT} = ? AND ${ReceivedShareTable.EXPIRATION_DATE} >= ?',
+        [RECIPIENT_1.mail, todayDate],
+      )).thenAnswer((_) async => [
+            receivedShare1.toReceivedShareCache().toJson(),
+          ]);
+
+      final result = await receivedShareDatabaseManager
+          .getListDataForRecipient(RECIPIENT_1.mail);
+
+      expect(result, isA<List<ReceivedShare>>());
+      expect(result.length, 1);
+      expect(result.first.shareId, receivedShare1.shareId);
+    });
+    test(
+      'getListDataForRecipient returns an empty list when no data matches the recipient',
+      () async {
+        when(mockDatabaseClient.getListDataWithCondition(
+          ReceivedShareTable.TABLE_NAME,
+          '${ReceivedShareTable.MAIL_RECIPIENT} !="" AND ${ReceivedShareTable.MAIL_RECIPIENT} = ? AND ${ReceivedShareTable.EXPIRATION_DATE} >= ?',
+          [RECIPIENT_1.mail, todayDate],
+        )).thenAnswer((_) async => []);
+
+        final result = await receivedShareDatabaseManager
+            .getListDataForRecipient(RECIPIENT_1.mail);
+        expect(result, isA<List<ReceivedShare>>());
+        expect(result.isEmpty, true);
+        verify(mockDatabaseClient.getListDataWithCondition(
+          ReceivedShareTable.TABLE_NAME,
+          '${ReceivedShareTable.MAIL_RECIPIENT} !="" AND ${ReceivedShareTable.MAIL_RECIPIENT} = ? AND ${ReceivedShareTable.EXPIRATION_DATE} >= ?',
+          [RECIPIENT_1.mail, todayDate],
+        )).called(1);
+      },
+    );
+  });
+}
diff --git a/domain/lib/src/usecases/received/remove_deleted_received_share_from_local_database.dart b/domain/lib/src/usecases/received/remove_deleted_received_share_from_local_database.dart
@@ -1,5 +1,5 @@
+import 'dart:developer';
 import 'package:domain/domain.dart';
-import 'package:collection/collection.dart';
 
 class RemoveDeletedReceivedShareFromLocalDatabaseInteractor {
   final ReceivedShareRepository _receivedShareRepository;
@@ -9,13 +9,19 @@ class RemoveDeletedReceivedShareFromLocalDatabaseInteractor {
 
   Future<void> execute(
       List<ReceivedShare> receivedShares, String recipient) async {
-    var localReceivedShares = await _receivedShareRepository
-        .getAllReceivedShareOfflineByRecipient(recipient);
-    final receivedShareIds = receivedShares.map((received) => received.shareId).toSet();
-    for (final local in localReceivedShares) {
-      if (!receivedShareIds.contains(local.shareId)) {
-        await _receivedShareRepository.disableOffline(local.shareId, local.localPath ?? '');
+    try {
+      var localReceivedShares = await _receivedShareRepository
+          .getAllReceivedShareOfflineByRecipient(recipient);
+      final receivedShareIds =
+          receivedShares.map((received) => received.shareId).toSet();
+      for (final local in localReceivedShares) {
+        if (!receivedShareIds.contains(local.shareId)) {
+          await _receivedShareRepository.disableOffline(
+              local.shareId, local.localPath ?? '');
+        }
       }
+    } catch (exception) {
+      log('RemoveDeletedReceivedShareFromLocalDatabaseInteractor: $exception');
     }
   }
 }