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

TF-80 Move multiple email to mailbox from thread view

Browse Source
This commit is contained in:
dab246
2021-09-21 12:52:27 +07:00
committed by Dat H. Pham
parent 24e52dc6a4
commit a12efc8d2b
43 changed files with 1007 additions and 443 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/thread/domain/state/mark_as_multiple_email_read_state.dart
+8 -10
View File
@@ -1,35 +1,33 @@
import 'package:core/core.dart';
import 'package:dartz/dartz.dart';
import 'package:model/email/read_actions.dart';
class MarkAsMultipleEmailReadAllSuccess extends UIState {
final List<Either<Failure, Success>> resultList;
final int countMarkAsReadSuccess;
final ReadActions readActions;
MarkAsMultipleEmailReadAllSuccess(this.resultList, this.readActions);
MarkAsMultipleEmailReadAllSuccess(this.countMarkAsReadSuccess, this.readActions);
@override
List<Object?> get props => [resultList, readActions];
List<Object?> get props => [countMarkAsReadSuccess, readActions];
}
class MarkAsMultipleEmailReadAllFailure extends FeatureFailure {
final List<Either<Failure, Success>> resultList;
final ReadActions readActions;
MarkAsMultipleEmailReadAllFailure(this.resultList, this.readActions);
MarkAsMultipleEmailReadAllFailure(this.readActions);
@override
List<Object> get props => [resultList, readActions];
List<Object> get props => [readActions];
}
class MarkAsMultipleEmailReadHasSomeEmailFailure extends UIState {
final List<Either<Failure, Success>> resultList;
final int countMarkAsReadSuccess;
final ReadActions readActions;
MarkAsMultipleEmailReadHasSomeEmailFailure(this.resultList, this.readActions);
MarkAsMultipleEmailReadHasSomeEmailFailure(this.countMarkAsReadSuccess, this.readActions);
@override
List<Object> get props => [resultList, readActions];
List<Object> get props => [countMarkAsReadSuccess, readActions];
}
class MarkAsMultipleEmailReadFailure extends FeatureFailure {
lib/features/thread/domain/state/move_multiple_email_to_mailbox_state.dart
+69
View File
@@ -0,0 +1,69 @@
import 'package:core/core.dart';
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:model/model.dart';
class MoveMultipleEmailToMailboxAllSuccess extends UIState {
final List<EmailId> movedListEmailId;
final MailboxId currentMailboxId;
final MailboxId destinationMailboxId;
final MoveAction moveAction;
final String? destinationPath;
MoveMultipleEmailToMailboxAllSuccess(
this.movedListEmailId,
this.currentMailboxId,
this.destinationMailboxId,
this.moveAction,
this.destinationPath);
@override
List<Object?> get props => [
movedListEmailId,
currentMailboxId,
destinationMailboxId,
moveAction,
destinationPath];
}
class MoveMultipleEmailToMailboxAllFailure extends FeatureFailure {
final MoveAction moveAction;
MoveMultipleEmailToMailboxAllFailure(this.moveAction);
@override
List<Object> get props => [moveAction];
}
class MoveMultipleEmailToMailboxHasSomeEmailFailure extends UIState {
final List<EmailId> movedListEmailId;
final MailboxId currentMailboxId;
final MailboxId destinationMailboxId;
final MoveAction moveAction;
final String? destinationPath;
MoveMultipleEmailToMailboxHasSomeEmailFailure(
this.movedListEmailId,
this.currentMailboxId,
this.destinationMailboxId,
this.moveAction,
this.destinationPath);
@override
List<Object?> get props => [
movedListEmailId,
currentMailboxId,
destinationMailboxId,
moveAction,
destinationPath];
}
class MoveMultipleEmailToMailboxFailure extends FeatureFailure {
final exception;
final MoveAction moveAction;
MoveMultipleEmailToMailboxFailure(this.exception, this.moveAction);
@override
List<Object> get props => [exception, moveAction];
}
lib/features/thread/domain/usecases/mark_as_multiple_email_read_interactor.dart
+20 -23
View File
@@ -2,40 +2,37 @@ 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/email/email.dart';
import 'package:model/email/read_actions.dart';
import 'package:tmail_ui_user/features/email/domain/usecases/mark_as_email_read_interactor.dart';
import 'package:model/model.dart';
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/mark_as_multiple_email_read_state.dart';
class MarkAsMultipleEmailReadInteractor {
final MarkAsEmailReadInteractor markAsEmailReadInteractor;
final EmailRepository _emailRepository;
MarkAsMultipleEmailReadInteractor(this.markAsEmailReadInteractor);
MarkAsMultipleEmailReadInteractor(this._emailRepository);
Stream<Either<Failure, Success>> execute(
AccountId accountId,
List<EmailId> listEmailId,
List<Email> emails,
ReadActions readAction
) async* {
try {
final listResult = await Future.wait(listEmailId.map((emailId) async {
final result = await markAsEmailReadInteractor.execute(accountId, emailId, readAction).toList();
return result.first;
}));
if (listResult.length == 1) {
yield listResult.first;
yield Right<Failure, Success>(LoadingState());
final listEmailNeedMarkAsRead = emails
.where((email) => readAction == ReadActions.markAsUnread ? email.isReadEmail() : email.isUnReadEmail())
.toList();
final result = await _emailRepository.markAsRead(accountId, listEmailNeedMarkAsRead, readAction);
if (listEmailNeedMarkAsRead.length == result.length) {
final countMarkAsReadSuccess = emails.length;
yield Right(MarkAsMultipleEmailReadAllSuccess(countMarkAsReadSuccess, readAction));
} else if (result.isEmpty) {
yield Left(MarkAsMultipleEmailReadAllFailure(readAction));
} else {
var failedFileCount = 0;
listResult.forEach((element) {
if (element is Left) {
failedFileCount++;
}
});
if (failedFileCount == 0) {
yield Right(MarkAsMultipleEmailReadAllSuccess(listResult, readAction));
} else if (failedFileCount == listResult.length) {
yield Left(MarkAsMultipleEmailReadAllFailure(listResult, readAction));
}
yield Right(MarkAsMultipleEmailReadHasSomeEmailFailure(listResult, readAction));
final countMarkAsReadSuccess = emails.length - (listEmailNeedMarkAsRead.length - result.length);
yield Right(MarkAsMultipleEmailReadHasSomeEmailFailure(countMarkAsReadSuccess, readAction));
}
} catch (e) {
yield Left(MarkAsMultipleEmailReadFailure(e, readAction));
lib/features/thread/domain/usecases/move_multiple_email_to_mailbox_interactor.dart
+42
View File
@@ -0,0 +1,42 @@
import 'dart:async';
import 'package:core/core.dart';
import 'package:dartz/dartz.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:tmail_ui_user/features/email/domain/model/move_request.dart';
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/move_multiple_email_to_mailbox_state.dart';
class MoveMultipleEmailToMailboxInteractor {
final EmailRepository _emailRepository;
MoveMultipleEmailToMailboxInteractor(this._emailRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, MoveRequest moveRequest) async* {
try {
yield Right<Failure, Success>(LoadingState());
final result = await _emailRepository.moveToMailbox(accountId, moveRequest);
if (moveRequest.emailIds.length == result.length) {
yield Right(MoveMultipleEmailToMailboxAllSuccess(
result,
moveRequest.currentMailboxId,
moveRequest.destinationMailboxId,
moveRequest.moveAction,
moveRequest.destinationPath));
} else if (result.isEmpty) {
yield Left(MoveMultipleEmailToMailboxAllFailure(moveRequest.moveAction));
} else {
yield Right(MoveMultipleEmailToMailboxHasSomeEmailFailure(
result,
moveRequest.currentMailboxId,
moveRequest.destinationMailboxId,
moveRequest.moveAction,
moveRequest.destinationPath));
}
} catch (e) {
yield Left(MoveMultipleEmailToMailboxFailure(e, moveRequest.moveAction));
}
}
}