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

TF-3372 Adding onProgressController to interactor layer

Browse Source
This commit is contained in:
Dat PHAM HOANG
2024-12-30 22:07:22 +07:00
committed by Dat H. Pham
parent a81d33f98b
commit da0a3a9da6
2 changed files with 36 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/thread/domain/usecases/empty_spam_folder_interactor.dart
+18 -2
View File
@@ -1,3 +1,5 @@
import 'dart:async';
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
@@ -12,10 +14,24 @@ class EmptySpamFolderInteractor {
EmptySpamFolderInteractor(this.threadRepository);
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, MailboxId spamMailboxId) async* {
Stream<Either<Failure, Success>> execute(
Session session,
AccountId accountId,
MailboxId spamMailboxId,
int totalEmails,
StreamController<Either<Failure, Success>> onProgressController
) async* {
try {
yield Right<Failure, Success>(EmptySpamFolderLoading());
final emailIdDeleted = await threadRepository.emptySpamFolder(session, accountId, spamMailboxId);
onProgressController.add(Right(EmptySpamFolderLoading()));
final emailIdDeleted = await threadRepository.emptySpamFolder(
session,
accountId,
spamMailboxId,
totalEmails,
onProgressController
);
yield Right<Failure, Success>(EmptySpamFolderSuccess(emailIdDeleted));
} catch (e) {
yield Left<Failure, Success>(EmptySpamFolderFailure(e));
lib/features/thread/domain/usecases/empty_trash_folder_interactor.dart
+18 -2
View File
@@ -1,3 +1,5 @@
import 'dart:async';
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:dartz/dartz.dart';
@@ -12,10 +14,24 @@ class EmptyTrashFolderInteractor {
EmptyTrashFolderInteractor(this.threadRepository);
Stream<Either<Failure, Success>> execute(Session session, AccountId accountId, MailboxId trashMailboxId) async* {
Stream<Either<Failure, Success>> execute(
Session session,
AccountId accountId,
MailboxId trashMailboxId,
int totalEmails,
StreamController<Either<Failure, Success>> onProgressController
) async* {
try {
yield Right<Failure, Success>(EmptyTrashFolderLoading());
final emailIdDeleted = await threadRepository.emptyTrashFolder(session, accountId, trashMailboxId);
onProgressController.add(Right(EmptyTrashFolderLoading()));
final emailIdDeleted = await threadRepository.emptyTrashFolder(
session,
accountId,
trashMailboxId,
totalEmails,
onProgressController
);
yield Right<Failure, Success>(EmptyTrashFolderSuccess(emailIdDeleted,));
} catch (e) {
yield Left<Failure, Success>(EmptyTrashFolderFailure(e));