TF-3333 Remove Mailbox/query & Mailbox/get when performing display spam banner

This commit is contained in:
dab246
2024-12-19 16:51:30 +07:00
committed by Dat H. Pham
parent e386848af8
commit 091d52e635
12 changed files with 25 additions and 286 deletions
@@ -1,73 +0,0 @@
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/core/unsigned_int.dart';
import 'package:jmap_dart_client/jmap/core/user_name.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/data/network/spam_report_api.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/spam_report_state.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
class SpamReportDataSourceImpl extends SpamReportDataSource {
final SpamReportApi _spamReportApi;
final ExceptionThrower _exceptionThrower;
SpamReportDataSourceImpl(this._spamReportApi, this._exceptionThrower);
@override
Future<bool> deleteLastTimeDismissedSpamReported() {
throw UnimplementedError();
}
@override
Future<UnreadSpamEmailsResponse> findNumberOfUnreadSpamEmails(
Session session,
AccountId accountId,
{
MailboxFilterCondition? mailboxFilterCondition,
UnsignedInt? limit
}
) {
return Future.sync(() async {
final unreadSpamEmailsResponse = await _spamReportApi.getUnreadSpamEmailbox(
session,
accountId,
mailboxFilterCondition: mailboxFilterCondition,
limit: limit);
return unreadSpamEmailsResponse;
}).catchError(_exceptionThrower.throwException);
}
@override
Future<DateTime> getLastTimeDismissedSpamReported() {
throw UnimplementedError();
}
@override
Future<bool> storeLastTimeDismissedSpamReported(DateTime lastTimeDismissedSpamReported) {
throw UnimplementedError();
}
@override
Future<void> deleteSpamReportState() {
throw UnimplementedError();
}
@override
Future<SpamReportState> getSpamReportState() {
throw UnimplementedError();
}
@override
Future<void> storeSpamReportState(SpamReportState spamReportState) {
throw UnimplementedError();
}
@override
Future<Mailbox> getSpamMailboxCached(AccountId accountId, UserName userName) {
throw UnimplementedError();
}
}
@@ -1,60 +0,0 @@
import 'package:jmap_dart_client/http/http_client.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/request/reference_path.dart';
import 'package:jmap_dart_client/jmap/core/session/session.dart';
import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
import 'package:jmap_dart_client/jmap/jmap_request.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/get/get_mailbox_method.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/get/get_mailbox_response.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/query/query_mailbox_method.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/exceptions/spam_report_exception.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
import 'package:tmail_ui_user/main/error/capability_validator.dart';
class SpamReportApi {
final HttpClient _httpClient;
static const int _deafaultLimit = 1;
SpamReportApi(this._httpClient);
Future<UnreadSpamEmailsResponse> getUnreadSpamEmailbox(
Session session,
AccountId accountId,
{
MailboxFilterCondition? mailboxFilterCondition,
UnsignedInt? limit
}
) async {
final processingInvocation = ProcessingInvocation();
final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation);
final spamReportQueryMethod = QueryMailboxMethod(accountId)..addLimit(limit ?? UnsignedInt(_deafaultLimit));
if(mailboxFilterCondition != null) spamReportQueryMethod.addFilters(mailboxFilterCondition);
final spamReportQueryMethodInvocation = requestBuilder.invocation(spamReportQueryMethod);
final getMailBoxMethod = GetMailboxMethod(accountId)
..addReferenceIds(processingInvocation.createResultReference(
spamReportQueryMethodInvocation.methodCallId,
ReferencePath.idsPath,
));
final getMailboxInvocation = requestBuilder.invocation(getMailBoxMethod);
final capabilities = getMailBoxMethod.requiredCapabilities
.toCapabilitiesSupportTeamMailboxes(session, accountId);
final result = await (requestBuilder
..usings(capabilities))
.build()
.execute();
final mailboxResponse = result
.parse<GetMailboxResponse>(getMailboxInvocation.methodCallId, GetMailboxResponse.deserialize);
if (mailboxResponse?.list.isNotEmpty == true) {
return UnreadSpamEmailsResponse(unreadSpamMailbox: mailboxResponse!.list.first);
} else {
throw NotFoundSpamMailboxException();
}
}
}
@@ -1,13 +1,9 @@
import 'package:core/data/model/source_type/data_source_type.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/core/unsigned_int.dart';
import 'package:jmap_dart_client/jmap/core/user_name.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox_filter_condition.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/data/datasource/spam_report_datasource.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/spam_report_state.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/model/unread_spam_emails_response.dart';
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/repository/spam_report_repository.dart';
class SpamReportRepositoryImpl extends SpamReportRepository {
@@ -30,22 +26,6 @@ class SpamReportRepositoryImpl extends SpamReportRepository {
return mapDataSource[DataSourceType.local]!.deleteLastTimeDismissedSpamReported();
}
@override
Future<UnreadSpamEmailsResponse> getUnreadSpamMailbox(
Session session,
AccountId accountId,
{
MailboxFilterCondition? mailboxFilterCondition,
UnsignedInt? limit
}
) {
return mapDataSource[DataSourceType.network]!.findNumberOfUnreadSpamEmails(
session,
accountId,
mailboxFilterCondition: mailboxFilterCondition,
limit: limit);
}
@override
Future<SpamReportState> getSpamReportState() async {
return await mapDataSource[DataSourceType.local]!.getSpamReportState();