TF-3430 Fix reply and forward button are not synced

lib/features/email/data/datasource/email_datasource.dart

@@ -175,4 +175,14 @@ abstract class EmailDataSource {
     AccountId accountId,
     EmailId emailId,
     EventActionType eventActionType);
+
+  Future<void> markAsAnswered(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds);
+
+  Future<void> markAsForwarded(
+    Session session,
+    AccountId accountId,
+    List<EmailId> emailIds);
 }

lib/features/email/data/datasource_impl/email_datasource_impl.dart

@@ -368,4 +368,14 @@ class EmailDataSourceImpl extends EmailDataSource {
         eventActionType);
     }).catchError(_exceptionThrower.throwException);
   }
+
+  @override
+  Future<void> markAsAnswered(Session session, AccountId accountId, List<EmailId> emailIds) {
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> markAsForwarded(Session session, AccountId accountId, List<EmailId> emailIds) {
+    throw UnimplementedError();
+  }
 }

lib/features/email/data/datasource_impl/email_hive_cache_datasource_impl.dart

@@ -476,4 +476,54 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
   Future<Email> storeEventAttendanceStatus(Session session, AccountId accountId, EmailId emailId, EventActionType eventActionType) {
     throw UnimplementedError();
   }
+
+  @override
+  Future<void> markAsAnswered(Session session, AccountId accountId, List<EmailId> emailIds) async {
+    final cacheEmails = await _emailCacheManager.getMultipleStoredEmails(
+      accountId,
+      session.username,
+      emailIds,
+    );
+
+    final storedEmails = cacheEmails
+      .map((emailCache) => emailCache.toEmail())
+      .toList();
+
+    for (var email in storedEmails) {
+      email.keywords?[KeyWordIdentifier.emailAnswered] = true;
+    }
+
+    await _emailCacheManager.storeMultipleEmails(
+      accountId,
+      session.username,
+      storedEmails.map((email) => email.toEmailCache()).toList(),
+    );
+
+    return Future.value();
+  }
+
+  @override
+  Future<void> markAsForwarded(Session session, AccountId accountId, List<EmailId> emailIds) async {
+    final cacheEmails = await _emailCacheManager.getMultipleStoredEmails(
+      accountId,
+      session.username,
+      emailIds,
+    );
+
+    final storedEmails = cacheEmails
+      .map((emailCache) => emailCache.toEmail())
+      .toList();
+
+    for (var email in storedEmails) {
+      email.keywords?[KeyWordIdentifier.emailForwarded] = true;
+    }
+
+    await _emailCacheManager.storeMultipleEmails(
+      accountId,
+      session.username,
+      storedEmails.map((email) => email.toEmailCache()).toList(),
+    );
+
+    return Future.value();
+  }
 }

lib/features/email/data/repository/email_repository_impl.dart

@@ -75,14 +75,38 @@ class EmailRepositoryImpl extends EmailRepository {
       CreateNewMailboxRequest? mailboxRequest,
       CancelToken? cancelToken
     }
-  ) {
-    return emailDataSource[DataSourceType.network]!.sendEmail(
+  ) async {
+    await emailDataSource[DataSourceType.network]!.sendEmail(
       session,
       accountId,
       emailRequest,
       mailboxRequest: mailboxRequest,
       cancelToken: cancelToken,
     );
+
+    if (emailRequest.isEmailAnswered) {
+      try {
+        await emailDataSource[DataSourceType.hiveCache]!.markAsAnswered(
+          session,
+          accountId,
+          [emailRequest.emailIdAnsweredOrForwarded!],
+        );
+      } catch (e) {
+        logError('EmailRepositoryImpl::sendEmail::markAsAnswered:Exception $e');
+      }
+    } else if (emailRequest.isEmailForwarded) {
+      try {
+        await emailDataSource[DataSourceType.hiveCache]!.markAsForwarded(
+          session,
+          accountId,
+          [emailRequest.emailIdAnsweredOrForwarded!],
+        );
+      } catch (e) {
+        logError('EmailRepositoryImpl::sendEmail::markAsForwarded:Exception $e');
+      }
+    }
+
+    return Future.value();
   }
 
   @override