TF-838 Implement State for Interactor

This commit is contained in:
dab246
2022-08-16 10:36:40 +07:00
committed by Dat H. Pham
parent 982c698dd2
commit 9d0c9ca1f0
36 changed files with 462 additions and 116 deletions
@@ -6,15 +6,18 @@ import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_reposit
import 'package:tmail_ui_user/features/mailbox/domain/state/create_new_mailbox_state.dart';
class CreateNewMailboxInteractor {
final MailboxRepository mailboxRepository;
final MailboxRepository _mailboxRepository;
CreateNewMailboxInteractor(this.mailboxRepository);
CreateNewMailboxInteractor(this._mailboxRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, CreateNewMailboxRequest newMailboxRequest) async* {
try {
final newMailbox = await mailboxRepository.createNewMailbox(accountId, newMailboxRequest);
final currentMailboxState = await _mailboxRepository.getMailboxState();
final newMailbox = await _mailboxRepository.createNewMailbox(accountId, newMailboxRequest);
if (newMailbox != null) {
yield Right<Failure, Success>(CreateNewMailboxSuccess(newMailbox));
yield Right<Failure, Success>(CreateNewMailboxSuccess(
newMailbox,
currentMailboxState: currentMailboxState));
} else {
yield Left<Failure, Success>(CreateNewMailboxFailure(null));
}
@@ -7,15 +7,18 @@ import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_reposit
import 'package:tmail_ui_user/features/mailbox/domain/state/delete_multiple_mailbox_state.dart';
class DeleteMultipleMailboxInteractor {
final MailboxRepository mailboxRepository;
final MailboxRepository _mailboxRepository;
DeleteMultipleMailboxInteractor(this.mailboxRepository);
DeleteMultipleMailboxInteractor(this._mailboxRepository);
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, List<MailboxId> mailboxIds, MailboxId mailboxIdDeleted) async* {
try {
final result = await mailboxRepository.deleteMultipleMailbox(session, accountId, mailboxIds);
final currentMailboxState = await _mailboxRepository.getMailboxState();
final result = await _mailboxRepository.deleteMultipleMailbox(session, accountId, mailboxIds);
if (result) {
yield Right<Failure, Success>(DeleteMultipleMailboxSuccess(mailboxIdDeleted));
yield Right<Failure, Success>(DeleteMultipleMailboxSuccess(
mailboxIdDeleted,
currentMailboxState: currentMailboxState));
} else {
yield Left<Failure, Success>(DeleteMultipleMailboxFailure(null));
}
@@ -4,13 +4,15 @@ import 'package:core/core.dart';
import 'package:dartz/dartz.dart';
import 'package:jmap_dart_client/jmap/account_id.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/mailbox/domain/state/mark_as_mailbox_read_state.dart';
class MarkAsMailboxReadInteractor {
final MailboxRepository _mailboxRepository;
final EmailRepository _emailRepository;
MarkAsMailboxReadInteractor(this._mailboxRepository);
MarkAsMailboxReadInteractor(this._mailboxRepository, this._emailRepository);
Stream<Either<Failure, Success>> execute(
AccountId accountId,
@@ -23,6 +25,14 @@ class MarkAsMailboxReadInteractor {
yield Right<Failure, Success>(MarkAsMailboxReadLoading());
onProgressController.add(Right(MarkAsMailboxReadLoading()));
final listState = await Future.wait([
_mailboxRepository.getMailboxState(),
_emailRepository.getEmailState(),
], eagerError: true);
final currentMailboxState = listState.first;
final currentEmailState = listState.last;
final listEmails = await _mailboxRepository.markAsMailboxRead(
accountId,
mailboxId,
@@ -30,9 +40,16 @@ class MarkAsMailboxReadInteractor {
onProgressController);
if (totalEmailUnread == listEmails.length) {
yield Right(MarkAsMailboxReadAllSuccess(mailboxName));
yield Right(MarkAsMailboxReadAllSuccess(
mailboxName,
currentEmailState: currentEmailState,
currentMailboxState: currentMailboxState));
} else if (listEmails.isNotEmpty) {
yield Right(MarkAsMailboxReadHasSomeEmailFailure(mailboxName, listEmails.length));
yield Right(MarkAsMailboxReadHasSomeEmailFailure(
mailboxName,
listEmails.length,
currentEmailState: currentEmailState,
currentMailboxState: currentMailboxState));
} else {
yield Left(MarkAsMailboxReadAllFailure());
}
@@ -6,20 +6,22 @@ import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_reposit
import 'package:tmail_ui_user/features/mailbox/domain/state/move_mailbox_state.dart';
class MoveMailboxInteractor {
final MailboxRepository mailboxRepository;
final MailboxRepository _mailboxRepository;
MoveMailboxInteractor(this.mailboxRepository);
MoveMailboxInteractor(this._mailboxRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, MoveMailboxRequest request) async* {
try {
final result = await mailboxRepository.moveMailbox(accountId, request);
final currentMailboxState = await _mailboxRepository.getMailboxState();
final result = await _mailboxRepository.moveMailbox(accountId, request);
if (result) {
yield Right<Failure, Success>(MoveMailboxSuccess(
request.mailboxId,
request.moveAction,
parentId: request.parentId,
destinationMailboxId: request.destinationMailboxId,
destinationMailboxName: request.destinationMailboxName));
destinationMailboxName: request.destinationMailboxName,
currentMailboxState: currentMailboxState));
} else {
yield Left<Failure, Success>(MoveMailboxFailure(null));
}
@@ -6,15 +6,17 @@ import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_reposit
import 'package:tmail_ui_user/features/mailbox/domain/state/rename_mailbox_state.dart';
class RenameMailboxInteractor {
final MailboxRepository mailboxRepository;
final MailboxRepository _mailboxRepository;
RenameMailboxInteractor(this.mailboxRepository);
RenameMailboxInteractor(this._mailboxRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, RenameMailboxRequest request) async* {
try {
final result = await mailboxRepository.renameMailbox(accountId, request);
final currentMailboxState = await _mailboxRepository.getMailboxState();
final result = await _mailboxRepository.renameMailbox(accountId, request);
if (result) {
yield Right<Failure, Success>(RenameMailboxSuccess());
yield Right<Failure, Success>(RenameMailboxSuccess(currentMailboxState: currentMailboxState));
} else {
yield Left<Failure, Success>(RenameMailboxFailure(null));
}