TF-4141 Add Action required folder to left menu
This commit is contained in:
@@ -16,6 +16,7 @@ import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/user_name.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email_filter_condition.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/keyword_identifier.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
|
||||
import 'package:model/model.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox/data/datasource/state_datasource.dart';
|
||||
@@ -523,4 +524,22 @@ class ThreadRepositoryImpl extends ThreadRepository {
|
||||
);
|
||||
yield emailResponse;
|
||||
}
|
||||
|
||||
@override
|
||||
Future<int> getCountUnreadEmailsInFolder({
|
||||
required Session session,
|
||||
required AccountId accountId,
|
||||
}) async {
|
||||
final networkDataSource = mapDataSource[DataSourceType.network]!;
|
||||
final emailResponse = await networkDataSource.getAllEmail(
|
||||
session,
|
||||
accountId,
|
||||
filter: EmailFilterCondition(
|
||||
hasKeyword: KeyWordIdentifierExtension.needActionMail.value,
|
||||
notKeyword: KeyWordIdentifier.emailSeen.value,
|
||||
),
|
||||
properties: Properties({EmailProperty.id}),
|
||||
);
|
||||
return emailResponse.emailList?.length ?? 0;
|
||||
}
|
||||
}
|
||||
@@ -1,2 +1,3 @@
|
||||
class NotFoundEmailsDeletedException implements Exception {}
|
||||
|
||||
class NotFoundEmailsDeletedException implements Exception {}
|
||||
class InteractorIsNullException implements Exception {}
|
||||
@@ -93,4 +93,9 @@ abstract class ThreadRepository {
|
||||
);
|
||||
|
||||
Future<void> clearEmailCacheAndStateCache(AccountId accountId, Session session);
|
||||
|
||||
Future<int> getCountUnreadEmailsInFolder({
|
||||
required Session session,
|
||||
required AccountId accountId,
|
||||
});
|
||||
}
|
||||
@@ -0,0 +1,18 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
|
||||
class GettingCountUnreadEmailsInFolder extends LoadingState {}
|
||||
|
||||
class GetCountUnreadEmailsInFolderSuccess extends UIState {
|
||||
final int count;
|
||||
|
||||
GetCountUnreadEmailsInFolderSuccess({required this.count});
|
||||
|
||||
@override
|
||||
List<Object> get props => [count];
|
||||
}
|
||||
|
||||
class GetCountUnreadEmailsInFolderFailure extends FeatureFailure {
|
||||
GetCountUnreadEmailsInFolderFailure(dynamic exception)
|
||||
: super(exception: exception);
|
||||
}
|
||||
@@ -0,0 +1,29 @@
|
||||
import 'package:core/presentation/state/failure.dart';
|
||||
import 'package:core/presentation/state/success.dart';
|
||||
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:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
|
||||
import 'package:tmail_ui_user/features/thread/domain/state/get_count_emails_in_folder_state.dart';
|
||||
|
||||
class GetCountUnreadEmailsInFolderInteractor {
|
||||
final ThreadRepository _threadRepository;
|
||||
|
||||
GetCountUnreadEmailsInFolderInteractor(this._threadRepository);
|
||||
|
||||
Stream<Either<Failure, Success>> execute({
|
||||
required Session session,
|
||||
required AccountId accountId,
|
||||
}) async* {
|
||||
try {
|
||||
yield Right(GettingCountUnreadEmailsInFolder());
|
||||
final count = await _threadRepository.getCountUnreadEmailsInFolder(
|
||||
session: session,
|
||||
accountId: accountId,
|
||||
);
|
||||
yield Right(GetCountUnreadEmailsInFolderSuccess(count: count));
|
||||
} catch (e) {
|
||||
yield Left(GetCountUnreadEmailsInFolderFailure(e));
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user