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

create isolate worker for empty

Browse Source
This commit is contained in:
ManhNTX
2022-08-11 10:36:51 +07:00
committed by Dat H. Pham
parent bd5478a6cc
commit 64d6ad6272
2 changed files with 199 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/thread/data/model/empty_trash_folder_arguments.dart
+26
View File
@@ -0,0 +1,26 @@
import 'package:equatable/equatable.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/state.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/data/network/email_api.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
class EmptyTrashFolderArguments with EquatableMixin {
AccountId accountId;
MailboxId trashMailboxId;
Future<void> Function(State state) updateState;
Future<void> Function({
List<Email>? newUpdated,
List<Email>? newCreated,
List<EmailId>? newDestroyed,
}) updateEmailCache;
final ThreadAPI threadAPI;
final EmailAPI emailAPI;
EmptyTrashFolderArguments(this.threadAPI, this.emailAPI, this.accountId,
this.trashMailboxId, this.updateEmailCache, this.updateState);
@override
List<Object?> get props => [accountId, trashMailboxId];
}
lib/features/thread/data/network/thread_isolate_worker.dart
+173
View File
@@ -0,0 +1,173 @@
import 'dart:async';
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:core/utils/app_logger.dart';
import 'package:core/utils/build_utils.dart';
import 'package:dartz/dartz.dart' as dartz;
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
import 'package:jmap_dart_client/jmap/core/state.dart';
import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
import 'package:jmap_dart_client/jmap/mail/email/email_comparator.dart';
import 'package:jmap_dart_client/jmap/mail/email/email_comparator_property.dart';
import 'package:jmap_dart_client/jmap/mail/email/email_filter_condition.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:model/email/email_property.dart';
import 'package:tmail_ui_user/features/email/data/network/email_api.dart';
import 'package:tmail_ui_user/features/thread/data/model/empty_trash_folder_arguments.dart';
import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
import 'package:tmail_ui_user/features/thread/domain/state/empty_trash_folder_state.dart';
import 'package:worker_manager/worker_manager.dart';
class ThreadIsolateWorker {
final ThreadAPI _threadAPI;
final EmailAPI _emailAPI;
final Executor _isolateExecutor;
ThreadIsolateWorker(this._threadAPI, this._emailAPI, this._isolateExecutor);
Future<List<EmailId>> emptyTrashFolder(
AccountId accountId,
MailboxId mailboxId,
int totalEmailUnread,
Future<void> Function(State state) updateState,
Future<void> Function({
List<Email>? newUpdated,
List<Email>? newCreated,
List<EmailId>? newDestroyed,
}) updateEmailCache,
StreamController<dartz.Either<Failure, Success>> onProgressController,
) async {
if (BuildUtils.isWeb) {
return _emptyTrashFolderOnWeb(accountId, mailboxId, updateState, updateEmailCache, onProgressController);
} else {
final result = await _isolateExecutor.execute(
arg1: EmptyTrashFolderArguments(_threadAPI, _emailAPI, accountId, mailboxId, updateEmailCache, updateState),
fun1: _emptyTrashFolderAction,
notification: (value) {
if (value is List<Email>) {
log('ThreadIsolateWorker::markAsThreadRead(): onUpdateProgress: PERCENT ${value.length / totalEmailUnread}');
onProgressController.add(dartz.Right(UpdatingEmptyTrashFolderState(
mailboxId: mailboxId,
countRemove: value.length,
)));
}
});
return result;
}
}
static Future<List<EmailId>> _emptyTrashFolderAction(EmptyTrashFolderArguments args, TypeSendPort sendPort) async {
List<EmailId> emailListCompleted = List.empty(growable: true);
try {
var hasEmails = true;
while (hasEmails) {
Email? lastEmail;
final emailsResponse = await args.threadAPI.getAllEmail(args.accountId,
sort: <Comparator>{}..add(
EmailComparator(EmailComparatorProperty.receivedAt)
..setIsAscending(false)),
filter: EmailFilterCondition(inMailbox: args.trashMailboxId, before: lastEmail?.receivedAt),
properties: Properties({EmailProperty.id}));
if (emailsResponse.state != null) {
await args.updateState.call(emailsResponse.state!);
}
var newEmailList = emailsResponse.emailList ?? <Email>[];
if (lastEmail != null) {
newEmailList = newEmailList.where((email) => email.id != lastEmail!.id).toList();
}
log('ThreadRepositoryImpl::emptyTrashFolder(): ${newEmailList.length}');
if (newEmailList.isNotEmpty == true) {
lastEmail = newEmailList.last;
hasEmails = true;
final emailIds = newEmailList.map((email) => email.id).toList();
final listEmailIdDeleted = await args.emailAPI.deleteMultipleEmailsPermanently(args.accountId, emailIds);
if (listEmailIdDeleted.isNotEmpty && listEmailIdDeleted.length == emailIds.length) {
await args.updateEmailCache(newDestroyed: listEmailIdDeleted);
}
emailListCompleted.addAll(listEmailIdDeleted);
sendPort.send(emailListCompleted);
} else {
hasEmails = false;
}
}
} catch (e) {
log('ThreadIsolateWorker::_emptyTrashFolderOnWeb(): ERROR: $e');
}
log('ThreadIsolateWorker::_emptyTrashFolderOnWeb(): TOTAL_REMOVE: ${emailListCompleted.length}');
return emailListCompleted;
}
Future<List<EmailId>> _emptyTrashFolderOnWeb(
AccountId accountId,
MailboxId trashMailboxId,
Future<void> Function(State state) updateState,
Future<void> Function({
List<Email>? newUpdated,
List<Email>? newCreated,
List<EmailId>? newDestroyed,
}) updateEmailCache,
StreamController<dartz.Either<Failure, Success>> onProgressController,
) async {
List<EmailId> emailListCompleted = List.empty(growable: true);
try {
var hasEmails = true;
while (hasEmails) {
Email? lastEmail;
final emailsResponse = await _threadAPI.getAllEmail(accountId,
sort: <Comparator>{}..add(
EmailComparator(EmailComparatorProperty.receivedAt)
..setIsAscending(false)),
filter: EmailFilterCondition(inMailbox: trashMailboxId, before: lastEmail?.receivedAt),
properties: Properties({EmailProperty.id}));
if (emailsResponse.state != null) {
await updateState.call(emailsResponse.state!);
}
var newEmailList = emailsResponse.emailList ?? <Email>[];
if (lastEmail != null) {
newEmailList = newEmailList.where((email) => email.id != lastEmail!.id).toList();
}
log('ThreadRepositoryImpl::emptyTrashFolder(): ${newEmailList.length}');
if (newEmailList.isNotEmpty == true) {
lastEmail = newEmailList.last;
hasEmails = true;
final emailIds = newEmailList.map((email) => email.id).toList();
final listEmailIdDeleted = await _emailAPI.deleteMultipleEmailsPermanently(accountId, emailIds);
if (listEmailIdDeleted.isNotEmpty && listEmailIdDeleted.length == emailIds.length) {
await updateEmailCache(newDestroyed: listEmailIdDeleted);
}
emailListCompleted.addAll(listEmailIdDeleted);
onProgressController.add(dartz.Right(UpdatingEmptyTrashFolderState(
mailboxId: trashMailboxId,
countRemove: emailListCompleted.length)));
} else {
hasEmails = false;
}
}
} catch (e) {
log('ThreadIsolateWorker::_emptyTrashFolderOnWeb(): ERROR: $e');
}
log('ThreadIsolateWorker::_emptyTrashFolderOnWeb(): TOTAL_REMOVE: ${emailListCompleted.length}');
return emailListCompleted;
}
}