TF-2858 Create store event attendance status interactor

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

@@ -19,6 +19,7 @@ import 'package:model/email/mark_star_action.dart';
 import 'package:model/email/read_actions.dart';
 import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
 import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/restore_deleted_message_request.dart';
 import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
@@ -112,4 +113,10 @@ abstract class EmailDataSource {
   Future<EmailRecoveryAction> restoreDeletedMessage(RestoredDeletedMessageRequest restoredDeletedMessageRequest);
 
   Future<EmailRecoveryAction> getRestoredDeletedMessage(EmailRecoveryActionId emailRecoveryActionId);
+
+  Future<Email> storeEventAttendanceStatus(
+    Session session,
+    AccountId accountId,
+    EmailId emailId,
+    EventActionType eventActionType);
 }

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

@@ -18,6 +18,7 @@ import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart'
 import 'package:tmail_ui_user/features/email/data/datasource/email_datasource.dart';
 import 'package:tmail_ui_user/features/email/data/network/email_api.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
 import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/restore_deleted_message_request.dart';
 import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
@@ -252,4 +253,20 @@ class EmailDataSourceImpl extends EmailDataSource {
       return await emailAPI.getRestoredDeletedMessage(emailRecoveryActionId);
     }).catchError(_exceptionThrower.throwException);
   }
+
+  @override
+  Future<Email> storeEventAttendanceStatus(
+    Session session,
+    AccountId accountId,
+    EmailId emailId,
+    EventActionType eventActionType
+  ) {
+    return Future.sync(() async {
+      return await emailAPI.storeEventAttendanceStatus(
+        session,
+        accountId,
+        emailId,
+        eventActionType);
+    }).catchError(_exceptionThrower.throwException);
+  }
 }

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

@@ -27,6 +27,7 @@ import 'package:tmail_ui_user/features/email/data/datasource/email_datasource.da
 import 'package:tmail_ui_user/features/email/domain/extensions/detailed_email_extension.dart';
 import 'package:tmail_ui_user/features/email/domain/extensions/detailed_email_hive_cache_extension.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
 import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/restore_deleted_message_request.dart';
 import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
@@ -303,4 +304,9 @@ class EmailHiveCacheDataSourceImpl extends EmailDataSource {
   Future<EmailRecoveryAction> getRestoredDeletedMessage(EmailRecoveryActionId emailRecoveryActionId) {
     throw UnimplementedError();
   }
+
+  @override
+  Future<Email> storeEventAttendanceStatus(Session session, AccountId accountId, EmailId emailId, EventActionType eventActionType) {
+    throw UnimplementedError();
+  }
 }

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

@@ -26,6 +26,7 @@ import 'package:tmail_ui_user/features/email/data/datasource/html_datasource.dar
 import 'package:tmail_ui_user/features/email/data/datasource/print_file_datasource.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
 import 'package:tmail_ui_user/features/email/domain/model/email_print.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
 import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/restore_deleted_message_request.dart';
 import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
@@ -237,4 +238,18 @@ class EmailRepositoryImpl extends EmailRepository {
   Future<void> printEmail(EmailPrint emailPrint) {
     return _printFileDataSource.printEmail(emailPrint);
   }
+
+  @override
+  Future<Email> storeEventAttendanceStatus(
+    Session session,
+    AccountId accountId,
+    EmailId emailId,
+    EventActionType eventActionType
+  ) {
+    return emailDataSource[DataSourceType.network]!.storeEventAttendanceStatus(
+      session,
+      accountId,
+      emailId,
+      eventActionType);
+  }
 }

lib/features/email/domain/repository/email_repository.dart

@@ -22,6 +22,7 @@ import 'package:model/email/read_actions.dart';
 import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/detailed_email.dart';
 import 'package:tmail_ui_user/features/email/domain/model/email_print.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
 import 'package:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
 import 'package:tmail_ui_user/features/email/domain/model/restore_deleted_message_request.dart';
 import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
@@ -115,4 +116,10 @@ abstract class EmailRepository {
   Future<EmailRecoveryAction> getRestoredDeletedMessage(EmailRecoveryActionId emailRecoveryActionId);
 
   Future<void> printEmail(EmailPrint emailPrint);
+
+  Future<Email> storeEventAttendanceStatus(
+    Session session,
+    AccountId accountId,
+    EmailId emailId,
+    EventActionType eventActionType);
 }

lib/features/email/domain/state/store_event_attendance_status_state.dart

@@ -0,0 +1,34 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:jmap_dart_client/jmap/core/state.dart' as jmap;
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:tmail_ui_user/features/base/state/ui_action_state.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
+
+class StoreEventAttendanceStatusLoading extends LoadingState {}
+
+class StoreEventAttendanceStatusSuccess extends UIActionState {
+
+  final EventActionType eventActionType;
+  final Email updatedEmail;
+
+  StoreEventAttendanceStatusSuccess(
+    this.eventActionType,
+    this.updatedEmail,
+    {
+      jmap.State? currentEmailState,
+      jmap.State? currentMailboxState,
+    }
+  ) : super(currentEmailState, currentMailboxState);
+
+  @override
+  List<Object?> get props => [
+    eventActionType,
+    updatedEmail,
+    ...super.props];
+}
+
+class StoreEventAttendanceStatusFailure extends FeatureFailure {
+
+  StoreEventAttendanceStatusFailure({dynamic exception}) : super(exception: exception);
+}

lib/features/email/domain/usecases/store_event_attendance_status_interactor.dart

@@ -0,0 +1,41 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:tmail_ui_user/features/email/domain/model/event_action.dart';
+import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
+import 'package:tmail_ui_user/features/email/domain/state/store_event_attendance_status_state.dart';
+
+class StoreEventAttendanceStatusInteractor {
+  final EmailRepository _emailRepository;
+
+  StoreEventAttendanceStatusInteractor(this._emailRepository);
+
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    EmailId emailId,
+    EventActionType eventActionType
+  ) async* {
+    try {
+      yield Right(StoreEventAttendanceStatusLoading());
+
+      final currentEmailState = await _emailRepository.getEmailState(session, accountId);
+
+      final updatedEmail = await _emailRepository.storeEventAttendanceStatus(
+        session,
+        accountId,
+        emailId,
+        eventActionType);
+
+      yield Right(StoreEventAttendanceStatusSuccess(
+        eventActionType,
+        updatedEmail,
+        currentEmailState: currentEmailState));
+    } catch (e) {
+      yield Left(StoreEventAttendanceStatusFailure(exception: e));
+    }
+  }
+}