eduvia/workavia-mail-front
11
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

TF-3334 Skip getting stored state in interactor when performing actions with email and mailbox

Browse Source
This commit is contained in:
dab246
2024-12-23 16:10:36 +07:00
committed by Dat H. Pham
parent ba93e7b514
commit 01b320ce89
52 changed files with 138 additions and 602 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/thread/domain/usecases/empty_spam_folder_interactor.dart
+2 -23
View File
@@ -4,40 +4,19 @@ 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/mailbox/mailbox.dart';
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/empty_spam_folder_state.dart';
class EmptySpamFolderInteractor {
final ThreadRepository threadRepository;
final MailboxRepository _mailboxRepository;
final EmailRepository _emailRepository;
EmptySpamFolderInteractor(
this.threadRepository,
this._mailboxRepository,
this._emailRepository
);
EmptySpamFolderInteractor(this.threadRepository);
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, MailboxId spamMailboxId) async* {
try {
yield Right<Failure, Success>(EmptySpamFolderLoading());
final listState = await Future.wait([
_mailboxRepository.getMailboxState(session, accountId),
_emailRepository.getEmailState(session, accountId),
], eagerError: true);
final currentMailboxState = listState.first;
final currentEmailState = listState.last;
final emailIdDeleted = await threadRepository.emptySpamFolder(session, accountId, spamMailboxId);
yield Right<Failure, Success>(EmptySpamFolderSuccess(
emailIdDeleted,
currentMailboxState: currentMailboxState,
currentEmailState: currentEmailState,
));
yield Right<Failure, Success>(EmptySpamFolderSuccess(emailIdDeleted));
} catch (e) {
yield Left<Failure, Success>(EmptySpamFolderFailure(e));
}
lib/features/thread/domain/usecases/empty_trash_folder_interactor.dart
+4 -24
View File
@@ -1,42 +1,22 @@
import 'package:core/core.dart';
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/mailbox/mailbox.dart';
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/empty_trash_folder_state.dart';
class EmptyTrashFolderInteractor {
final ThreadRepository threadRepository;
final MailboxRepository _mailboxRepository;
final EmailRepository _emailRepository;
EmptyTrashFolderInteractor(
this.threadRepository,
this._mailboxRepository,
this._emailRepository
);
EmptyTrashFolderInteractor(this.threadRepository);
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, MailboxId trashMailboxId) async* {
try {
yield Right<Failure, Success>(EmptyTrashFolderLoading());
final listState = await Future.wait([
_mailboxRepository.getMailboxState(session, accountId),
_emailRepository.getEmailState(session, accountId),
], eagerError: true);
final currentMailboxState = listState.first;
final currentEmailState = listState.last;
final emailIdDeleted = await threadRepository.emptyTrashFolder(session, accountId, trashMailboxId);
yield Right<Failure, Success>(EmptyTrashFolderSuccess(
emailIdDeleted,
currentMailboxState: currentMailboxState,
currentEmailState: currentEmailState,
));
yield Right<Failure, Success>(EmptyTrashFolderSuccess(emailIdDeleted,));
} catch (e) {
yield Left<Failure, Success>(EmptyTrashFolderFailure(e));
}
lib/features/thread/domain/usecases/mark_as_multiple_email_read_interactor.dart
+5 -16
View File
@@ -1,18 +1,17 @@
import 'package:core/core.dart';
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:model/model.dart';
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/mark_as_multiple_email_read_state.dart';
class MarkAsMultipleEmailReadInteractor {
final EmailRepository _emailRepository;
final MailboxRepository _mailboxRepository;
MarkAsMultipleEmailReadInteractor(this._emailRepository, this._mailboxRepository);
MarkAsMultipleEmailReadInteractor(this._emailRepository);
Stream<Either<Failure, Success>> execute(
Session session,
@@ -23,14 +22,6 @@ class MarkAsMultipleEmailReadInteractor {
try {
yield Right(LoadingMarkAsMultipleEmailReadAll());
final listState = await Future.wait([
_mailboxRepository.getMailboxState(session, accountId),
_emailRepository.getEmailState(session, accountId),
], eagerError: true);
final currentMailboxState = listState.first;
final currentEmailState = listState.last;
final result = await _emailRepository.markAsRead(
session,
accountId,
@@ -42,16 +33,14 @@ class MarkAsMultipleEmailReadInteractor {
yield Right(MarkAsMultipleEmailReadAllSuccess(
result.length,
readAction,
currentEmailState: currentEmailState,
currentMailboxState: currentMailboxState));
));
} else if (result.isEmpty) {
yield Left(MarkAsMultipleEmailReadAllFailure(readAction));
} else {
yield Right(MarkAsMultipleEmailReadHasSomeEmailFailure(
result.length,
readAction,
currentEmailState: currentEmailState,
currentMailboxState: currentMailboxState));
));
}
} catch (e) {
yield Left(MarkAsMultipleEmailReadFailure(readAction, e));
lib/features/thread/domain/usecases/mark_as_star_multiple_email_interactor.dart
+2 -4
View File
@@ -22,22 +22,20 @@ class MarkAsStarMultipleEmailInteractor {
try {
yield Right(LoadingMarkAsStarMultipleEmailAll());
final currentEmailState = await _emailRepository.getEmailState(session, accountId);
final result = await _emailRepository.markAsStar(session, accountId, emailIds, markStarAction);
if (emailIds.length == result.length) {
yield Right(MarkAsStarMultipleEmailAllSuccess(
emailIds.length,
markStarAction,
currentEmailState: currentEmailState));
));
} else if (result.isEmpty) {
yield Left(MarkAsStarMultipleEmailAllFailure(markStarAction));
} else {
yield Right(MarkAsStarMultipleEmailHasSomeEmailFailure(
result.length,
markStarAction,
currentEmailState: currentEmailState));
));
}
} catch (e) {
yield Left(MarkAsStarMultipleEmailFailure(markStarAction, e));
lib/features/thread/domain/usecases/move_multiple_email_to_mailbox_interactor.dart
+6 -21
View File
@@ -1,19 +1,18 @@
import 'dart:async';
import 'package:core/core.dart';
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:tmail_ui_user/features/email/domain/model/move_to_mailbox_request.dart';
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/move_multiple_email_to_mailbox_state.dart';
class MoveMultipleEmailToMailboxInteractor {
final EmailRepository _emailRepository;
final MailboxRepository _mailboxRepository;
MoveMultipleEmailToMailboxInteractor(this._emailRepository, this._mailboxRepository);
MoveMultipleEmailToMailboxInteractor(this._emailRepository);
Stream<Either<Failure, Success>> execute(
Session session,
@@ -22,20 +21,8 @@ class MoveMultipleEmailToMailboxInteractor {
) async* {
try {
yield Right(LoadingMoveMultipleEmailToMailboxAll());
final listState = await Future.wait([
_mailboxRepository.getMailboxState(session, accountId),
_emailRepository.getEmailState(session, accountId),
], eagerError: true);
final currentMailboxState = listState.first;
final currentEmailState = listState.last;
final result = await _emailRepository.moveToMailbox(session, accountId, moveRequest);
int totalEmail = 0;
for (var element in moveRequest.currentMailboxes.values) {
totalEmail = totalEmail + element.length;
}if (totalEmail == result.length) {
if (moveRequest.totalEmails == result.length) {
yield Right(MoveMultipleEmailToMailboxAllSuccess(
result,
moveRequest.currentMailboxes.keys.first,
@@ -43,8 +30,7 @@ class MoveMultipleEmailToMailboxInteractor {
moveRequest.moveAction,
moveRequest.emailActionType,
destinationPath: moveRequest.destinationPath,
currentEmailState: currentEmailState,
currentMailboxState: currentMailboxState));
));
} else if (result.isEmpty) {
yield Left(MoveMultipleEmailToMailboxAllFailure(moveRequest.moveAction, moveRequest.emailActionType));
} else {
@@ -55,8 +41,7 @@ class MoveMultipleEmailToMailboxInteractor {
moveRequest.moveAction,
moveRequest.emailActionType,
destinationPath: moveRequest.destinationPath,
currentEmailState: currentEmailState,
currentMailboxState: currentMailboxState));
));
}
} catch (e) {
yield Left(MoveMultipleEmailToMailboxFailure(moveRequest.emailActionType, moveRequest.moveAction, e));