TF-145 Implement LoadMoreEmails in ThreadView

lib/features/thread/data/datasource/thread_datasource.dart

@@ -10,10 +10,9 @@ import 'package:tmail_ui_user/features/thread/data/model/email_change_response.d
 import 'package:tmail_ui_user/features/thread/domain/model/email_response.dart';
 
 abstract class ThreadDataSource {
-  Future<EmailResponse> getAllEmail(
+  Future<EmailsResponse> getAllEmail(
     AccountId accountId,
     {
-      int? position,
       UnsignedInt? limit,
       Set<Comparator>? sort,
       Filter? filter,

lib/features/thread/data/datasource_impl/local_thread_datasource_impl.dart

@@ -18,10 +18,9 @@ class LocalThreadDataSourceImpl extends ThreadDataSource {
   LocalThreadDataSourceImpl(this._emailCacheManager);
 
   @override
-  Future<EmailResponse> getAllEmail(
+  Future<EmailsResponse> getAllEmail(
       AccountId accountId,
       {
-        int? position,
         UnsignedInt? limit,
         Set<Comparator>? sort,
         Filter? filter,

lib/features/thread/data/datasource_impl/thread_datasource_impl.dart

@@ -18,23 +18,18 @@ class ThreadDataSourceImpl extends ThreadDataSource {
   ThreadDataSourceImpl(this.threadAPI);
 
   @override
-  Future<EmailResponse> getAllEmail(
+  Future<EmailsResponse> getAllEmail(
     AccountId accountId,
     {
-      int? position,
       UnsignedInt? limit,
       Set<Comparator>? sort,
       Filter? filter,
       Properties? properties,
-      Properties? propertiesCreated,
-      Properties? propertiesUpdated,
-      MailboxId? inMailboxId
     }
   ) {
     return Future.sync(() async {
       return await threadAPI.getAllEmail(
         accountId,
-        position: position,
         limit: limit,
         sort: sort,
         filter: filter,
@@ -65,7 +60,7 @@ class ThreadDataSourceImpl extends ThreadDataSource {
   }
 
   @override
-  Future<List<Email>> getAllEmailCache({MailboxId? inMailboxId, Set<Comparator>? sort}) {
+  Future<List<Email>> getAllEmailCache({MailboxId? inMailboxId, Set<Comparator>? sort, UnsignedInt? limit}) {
     throw UnimplementedError();
   }
 

lib/features/thread/data/model/email_change_response.dart

@@ -25,9 +25,9 @@ class EmailChangeResponse with EquatableMixin {
   });
 
   EmailChangeResponse union(EmailChangeResponse other) => EmailChangeResponse(
-    updated: updated.union(other.updated),
-    created: created.union(other.created),
-    destroyed: destroyed.union(other.destroyed),
+    updated: updated.unite(other.updated),
+    created: created.unite(other.created),
+    destroyed: destroyed.unite(other.destroyed),
     newStateEmail: other.newStateEmail,
     newStateChanges: other.newStateChanges,
     hasMoreChanges: other.hasMoreChanges,

lib/features/thread/data/network/thread_api.dart

@@ -24,10 +24,9 @@ class ThreadAPI {
 
   ThreadAPI(this.httpClient);
 
-  Future<EmailResponse> getAllEmail(
+  Future<EmailsResponse> getAllEmail(
     AccountId accountId,
     {
-      int? position,
       UnsignedInt? limit,
       Set<Comparator>? sort,
       Filter? filter,
@@ -40,8 +39,6 @@ class ThreadAPI {
 
     final queryEmailMethod = QueryEmailMethod(accountId);
 
-    if (position != null) queryEmailMethod..addPosition(position);
-
     if (limit != null) queryEmailMethod..addLimit(limit);
 
     if (sort != null) queryEmailMethod..addSorts(sort);
@@ -74,7 +71,7 @@ class ThreadAPI {
       });
     }
 
-    return EmailResponse(emailList: resultList?.list, state: resultList?.state);
+    return EmailsResponse(emailList: resultList?.list, state: resultList?.state);
   }
 
   Future<EmailChangeResponse> getChanges(

lib/features/thread/data/repository/thread_repository_impl.dart

@@ -25,34 +25,31 @@ class ThreadRepositoryImpl extends ThreadRepository {
   ThreadRepositoryImpl(this.mapDataSource, this.stateDataSource);
 
   @override
-  Stream<EmailResponse> getAllEmail(
+  Stream<EmailsResponse> getAllEmail(
     AccountId accountId,
     {
-      int? position,
       UnsignedInt? limit,
       Set<Comparator>? sort,
-      Filter? filter,
+      EmailFilter? emailFilter,
       Properties? propertiesCreated,
       Properties? propertiesUpdated,
-      MailboxId? inMailboxId
     }
   ) async* {
     final localEmailResponse = await Future.wait([
-      mapDataSource[DataSourceType.local]!.getAllEmailCache(inMailboxId: inMailboxId, sort: sort),
+      mapDataSource[DataSourceType.local]!.getAllEmailCache(inMailboxId: emailFilter?.mailboxId, sort: sort),
       stateDataSource.getState(StateType.email)
     ]).then((List response) {
-      return EmailResponse(emailList: response.first, state: response.last);
+      return EmailsResponse(emailList: response.first, state: response.last);
     });
 
-    EmailResponse? networkEmailResponse;
+    EmailsResponse? networkEmailResponse;
 
     if (!localEmailResponse.hasEmails()) {
       networkEmailResponse = await mapDataSource[DataSourceType.network]!.getAllEmail(
         accountId,
-        position: position,
         limit: limit,
         sort: sort,
-        filter: filter,
+        filter: emailFilter?.filter,
         properties: propertiesCreated);
 
       yield networkEmailResponse;
@@ -113,10 +110,10 @@ class ThreadRepositoryImpl extends ThreadRepository {
     }
 
     final newEmailResponse = await Future.wait([
-      mapDataSource[DataSourceType.local]!.getAllEmailCache(inMailboxId: inMailboxId, sort: sort),
+      mapDataSource[DataSourceType.local]!.getAllEmailCache(inMailboxId: emailFilter?.mailboxId, sort: sort),
       stateDataSource.getState(StateType.email)
     ]).then((List response) {
-      return EmailResponse(emailList: response.first, state: response.last);
+      return EmailsResponse(emailList: response.first, state: response.last);
     });
 
     yield newEmailResponse;
@@ -132,7 +129,7 @@ class ThreadRepositoryImpl extends ThreadRepository {
         if (updatedProperties == null) {
           return email;
         } else {
-          final emailOld = emailCacheList?.findEmail(email.id);
+          final emailOld = emailCacheList?.findEmailById(email.id);
           if (emailOld != null) {
             return emailOld.combineEmail(email, updatedProperties);
           } else {
@@ -162,10 +159,11 @@ class ThreadRepositoryImpl extends ThreadRepository {
   }
 
   @override
-  Stream<EmailResponse> refreshChanges(
+  Stream<EmailsResponse> refreshChanges(
       AccountId accountId,
       State currentState,
       {
+        UnsignedInt? limit,
         Set<Comparator>? sort,
         Properties? propertiesCreated,
         Properties? propertiesUpdated,
@@ -173,8 +171,8 @@ class ThreadRepositoryImpl extends ThreadRepository {
       }
   ) async* {
     final localEmailList = await mapDataSource[DataSourceType.local]!.getAllEmailCache(
-        inMailboxId: inMailboxId,
-        sort: sort);
+      inMailboxId: inMailboxId,
+      sort: sort);
 
     EmailChangeResponse? emailChangeResponse;
     bool hasMoreChanges = true;
@@ -217,9 +215,38 @@ class ThreadRepositoryImpl extends ThreadRepository {
       mapDataSource[DataSourceType.local]!.getAllEmailCache(inMailboxId: inMailboxId, sort: sort),
       stateDataSource.getState(StateType.email)
     ]).then((List response) {
-      return EmailResponse(emailList: response.first, state: response.last);
+      return EmailsResponse(emailList: response.first, state: response.last);
     });
 
     yield newEmailResponse;
   }
+
+  @override
+  Stream<EmailsResponse> loadMoreEmails(
+    AccountId accountId,
+    {
+      int? position,
+      UnsignedInt? limit,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties,
+    }
+  ) async* {
+    final emailResponse = await mapDataSource[DataSourceType.network]!.getAllEmail(
+      accountId,
+      limit: limit,
+      sort: sort,
+      filter: filter,
+      properties: properties);
+
+    final newEmailList = emailResponse.emailList != null && emailResponse.emailList!.isNotEmpty
+      ? emailResponse.emailList!.sublist(1)
+      : <Email>[];
+
+    if (newEmailList.isNotEmpty) {
+      await _updateEmailCache(newCreated: newEmailList);
+    }
+
+    yield EmailsResponse(emailList: newEmailList, state: emailResponse.state);
+  }
 }