TF-3385 Update permanently delete emails
This commit is contained in:
@@ -4,6 +4,7 @@ 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: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/email/domain/state/delete_email_permanently_state.dart';
|
||||
|
||||
@@ -12,12 +13,17 @@ class DeleteEmailPermanentlyInteractor {
|
||||
|
||||
DeleteEmailPermanentlyInteractor(this._emailRepository);
|
||||
|
||||
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, EmailId emailId) async* {
|
||||
Stream<Either<Failure, Success>> execute(
|
||||
Session session,
|
||||
AccountId accountId,
|
||||
EmailId emailId,
|
||||
MailboxId? mailboxId,
|
||||
) async* {
|
||||
try {
|
||||
yield Right<Failure, Success>(StartDeleteEmailPermanently());
|
||||
final result = await _emailRepository.deleteEmailPermanently(session, accountId, emailId);
|
||||
if (result) {
|
||||
yield Right<Failure, Success>(DeleteEmailPermanentlySuccess());
|
||||
yield Right<Failure, Success>(DeleteEmailPermanentlySuccess(emailId, mailboxId));
|
||||
} else {
|
||||
yield Left<Failure, Success>(DeleteEmailPermanentlyFailure(null));
|
||||
}
|
||||
|
||||
+9
-3
@@ -4,6 +4,7 @@ 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: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/email/domain/state/delete_multiple_emails_permanently_state.dart';
|
||||
|
||||
@@ -12,14 +13,19 @@ class DeleteMultipleEmailsPermanentlyInteractor {
|
||||
|
||||
DeleteMultipleEmailsPermanentlyInteractor(this._emailRepository);
|
||||
|
||||
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, List<EmailId> emailIds) async* {
|
||||
Stream<Either<Failure, Success>> execute(
|
||||
Session session,
|
||||
AccountId accountId,
|
||||
List<EmailId> emailIds,
|
||||
MailboxId? mailboxId,
|
||||
) async* {
|
||||
try {
|
||||
yield Right<Failure, Success>(LoadingDeleteMultipleEmailsPermanentlyAll());
|
||||
final listResult = await _emailRepository.deleteMultipleEmailsPermanently(session, accountId, emailIds);
|
||||
if (listResult.emailIdsSuccess.length == emailIds.length) {
|
||||
yield Right<Failure, Success>(DeleteMultipleEmailsPermanentlyAllSuccess(listResult.emailIdsSuccess));
|
||||
yield Right<Failure, Success>(DeleteMultipleEmailsPermanentlyAllSuccess(listResult.emailIdsSuccess, mailboxId));
|
||||
} else if (listResult.emailIdsSuccess.isNotEmpty) {
|
||||
yield Right<Failure, Success>(DeleteMultipleEmailsPermanentlyHasSomeEmailFailure(listResult.emailIdsSuccess));
|
||||
yield Right<Failure, Success>(DeleteMultipleEmailsPermanentlyHasSomeEmailFailure(listResult.emailIdsSuccess, mailboxId));
|
||||
} else {
|
||||
yield Left<Failure, Success>(DeleteMultipleEmailsPermanentlyAllFailure());
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user