TF-78 Implement mark as unread when touch the "eye slash" icon on the top of screen EmailView
This commit is contained in:
@@ -13,6 +13,10 @@ abstract class BaseController extends GetxController {
|
||||
);
|
||||
}
|
||||
|
||||
void dispatchState(Either<Failure, Success> newState) {
|
||||
viewState.value = newState;
|
||||
}
|
||||
|
||||
void getState(Future<Either<Failure, Success>> newStateStream) async {
|
||||
final state = await newStateStream;
|
||||
state.fold(
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
|
||||
|
||||
abstract class EmailDataSource {
|
||||
@@ -7,5 +8,5 @@ abstract class EmailDataSource {
|
||||
|
||||
Future<bool> sendEmail(AccountId accountId, EmailRequest emailRequest);
|
||||
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, bool unread);
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, ReadActions readActions);
|
||||
}
|
||||
@@ -1,5 +1,6 @@
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
|
||||
import 'package:tmail_ui_user/features/email/data/datasource/email_datasource.dart';
|
||||
import 'package:tmail_ui_user/features/email/data/network/email_api.dart';
|
||||
@@ -29,9 +30,9 @@ class EmailDataSourceImpl extends EmailDataSource {
|
||||
}
|
||||
|
||||
@override
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, bool unread) {
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, ReadActions readActions) {
|
||||
return Future.sync(() async {
|
||||
return await emailAPI.markAsRead(accountId, emailId, unread);
|
||||
return await emailAPI.markAsRead(accountId, emailId, readActions);
|
||||
}).catchError((error) {
|
||||
throw error;
|
||||
});
|
||||
|
||||
@@ -105,12 +105,10 @@ class EmailAPI {
|
||||
});
|
||||
}
|
||||
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, bool unread) async {
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, ReadActions readAction) async {
|
||||
final setEmailMethod = SetEmailMethod(accountId)
|
||||
..addUpdates({
|
||||
emailId.id: PatchObject({
|
||||
KeyWordIdentifier.emailSeen.generatePath() : unread ? null : true
|
||||
})
|
||||
emailId.id: KeyWordIdentifier.emailSeen.generateReadActionPath(readAction)
|
||||
});
|
||||
|
||||
final requestBuilder = JmapRequestBuilder(httpClient, ProcessingInvocation());
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
|
||||
import 'package:tmail_ui_user/features/email/data/datasource/email_datasource.dart';
|
||||
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
|
||||
@@ -22,7 +23,7 @@ class EmailRepositoryImpl extends EmailRepository {
|
||||
}
|
||||
|
||||
@override
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, bool unread) {
|
||||
return emailDataSource.markAsRead(accountId, emailId, unread);
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, ReadActions readAction) {
|
||||
return emailDataSource.markAsRead(accountId, emailId, readAction);
|
||||
}
|
||||
}
|
||||
@@ -1,5 +1,6 @@
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
import 'package:tmail_ui_user/features/composer/domain/model/email_request.dart';
|
||||
|
||||
abstract class EmailRepository {
|
||||
@@ -7,5 +8,5 @@ abstract class EmailRepository {
|
||||
|
||||
Future<bool> sendEmail(AccountId accountId, EmailRequest emailRequest);
|
||||
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, bool unread);
|
||||
Future<bool> markAsRead(AccountId accountId, EmailId emailId, ReadActions readAction);
|
||||
}
|
||||
@@ -1,20 +1,23 @@
|
||||
import 'package:core/core.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
|
||||
class MarkAsEmailReadSuccess extends UIState {
|
||||
final EmailId emailId;
|
||||
final ReadActions readActions;
|
||||
|
||||
MarkAsEmailReadSuccess(this.emailId);
|
||||
MarkAsEmailReadSuccess(this.emailId, this.readActions);
|
||||
|
||||
@override
|
||||
List<Object?> get props => [];
|
||||
List<Object?> get props => [emailId, readActions];
|
||||
}
|
||||
|
||||
class MarkAsEmailReadFailure extends FeatureFailure {
|
||||
final exception;
|
||||
final ReadActions readActions;
|
||||
|
||||
MarkAsEmailReadFailure(this.exception);
|
||||
MarkAsEmailReadFailure(this.exception, this.readActions);
|
||||
|
||||
@override
|
||||
List<Object> get props => [exception];
|
||||
List<Object> get props => [exception, readActions];
|
||||
}
|
||||
@@ -2,6 +2,7 @@ import 'package:core/core.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
import 'package:tmail_ui_user/features/email/domain/repository/email_repository.dart';
|
||||
import 'package:tmail_ui_user/features/email/domain/state/mark_as_email_read_state.dart';
|
||||
|
||||
@@ -10,12 +11,12 @@ class MarkAsEmailReadInteractor {
|
||||
|
||||
MarkAsEmailReadInteractor(this.emailRepository);
|
||||
|
||||
Future<Either<Failure, Success>> execute(AccountId accountId, EmailId emailId, bool unread) async {
|
||||
Stream<Either<Failure, Success>> execute(AccountId accountId, EmailId emailId, ReadActions readAction) async* {
|
||||
try {
|
||||
final result = await emailRepository.markAsRead(accountId, emailId, unread);
|
||||
return result ? Right(MarkAsEmailReadSuccess(emailId)) : Left(MarkAsEmailReadFailure(null));
|
||||
final result = await emailRepository.markAsRead(accountId, emailId, readAction);
|
||||
yield result ? Right(MarkAsEmailReadSuccess(emailId, readAction)) : Left(MarkAsEmailReadFailure(null, readAction));
|
||||
} catch (e) {
|
||||
return Left(MarkAsEmailReadFailure(e));
|
||||
yield Left(MarkAsEmailReadFailure(e, readAction));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,7 +1,5 @@
|
||||
import 'package:core/core.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flutter/widgets.dart';
|
||||
import 'package:get/get.dart';
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
@@ -13,8 +11,6 @@ import 'package:tmail_ui_user/features/email/domain/usecases/get_email_content_i
|
||||
import 'package:tmail_ui_user/features/email/domain/usecases/mark_as_email_read_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/email/presentation/model/composer_arguments.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/mailbox_dashboard_controller.dart';
|
||||
import 'package:tmail_ui_user/main/actions/app_action.dart';
|
||||
import 'package:tmail_ui_user/main/actions/email_action.dart';
|
||||
import 'package:tmail_ui_user/main/routes/app_routes.dart';
|
||||
import 'package:tmail_ui_user/main/routes/route_navigation.dart';
|
||||
|
||||
@@ -28,7 +24,6 @@ class EmailController extends BaseController {
|
||||
|
||||
final emailAddressExpandMode = ExpandMode.COLLAPSE.obs;
|
||||
EmailContent? emailContent;
|
||||
AppAction? emailActionCurrent;
|
||||
|
||||
EmailController(this._getEmailContentInteractor, this._markAsEmailReadInteractor);
|
||||
|
||||
@@ -37,12 +32,11 @@ class EmailController extends BaseController {
|
||||
super.onReady();
|
||||
mailboxDashBoardController.selectedEmail.listen((presentationEmail) {
|
||||
toggleDisplayEmailAddressAction(expandMode: ExpandMode.COLLAPSE);
|
||||
emailActionCurrent = null;
|
||||
final accountId = mailboxDashBoardController.accountId.value;
|
||||
if (accountId != null && presentationEmail != null) {
|
||||
_getEmailContentAction(accountId, presentationEmail.id);
|
||||
if (presentationEmail.isUnReadEmail()) {
|
||||
markAsEmailRead(unread: false);
|
||||
markAsEmailRead(presentationEmail, ReadActions.markAsRead);
|
||||
}
|
||||
}
|
||||
});
|
||||
@@ -65,11 +59,19 @@ class EmailController extends BaseController {
|
||||
|
||||
@override
|
||||
void onDone() {
|
||||
viewState.value.map((success) {
|
||||
if (success is GetEmailContentSuccess) {
|
||||
emailContent = success.emailContent;
|
||||
}
|
||||
});
|
||||
viewState.value.fold(
|
||||
(failure) {
|
||||
if (failure is MarkAsEmailReadFailure) {
|
||||
_markAsEmailReadFailure(failure);
|
||||
}
|
||||
},
|
||||
(success) {
|
||||
if (success is GetEmailContentSuccess) {
|
||||
emailContent = success.emailContent;
|
||||
} else if (success is MarkAsEmailReadSuccess) {
|
||||
_markAsEmailReadSuccess(success);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
@override
|
||||
@@ -80,36 +82,33 @@ class EmailController extends BaseController {
|
||||
emailAddressExpandMode.value = expandMode;
|
||||
}
|
||||
|
||||
void markAsEmailRead({required bool unread}) async {
|
||||
void markAsEmailRead(PresentationEmail presentationEmail, ReadActions readActions) async {
|
||||
final accountId = mailboxDashBoardController.accountId.value;
|
||||
final presentationEmail = mailboxDashBoardController.selectedEmail.value;
|
||||
final mailboxCurrent = mailboxDashBoardController.selectedMailbox.value;
|
||||
if (accountId != null && presentationEmail != null && mailboxCurrent != null) {
|
||||
_markAsEmailReadInteractor.execute(accountId, presentationEmail.id, unread)
|
||||
.then((result) => result
|
||||
.map((success) {
|
||||
if (success is MarkAsEmailReadSuccess) {
|
||||
emailActionCurrent = MarkAsEmailReadAction(presentationEmail.id, mailboxCurrent);
|
||||
_updateMailboxDashBoardActionForDesktop(emailActionCurrent);
|
||||
}
|
||||
})
|
||||
);
|
||||
if (accountId != null && mailboxCurrent != null) {
|
||||
consumeState(_markAsEmailReadInteractor.execute(accountId, presentationEmail.id, readActions));
|
||||
}
|
||||
}
|
||||
|
||||
void _updateMailboxDashBoardActionForDesktop(AppAction? appAction) {
|
||||
if (Get.context != null && responsiveUtils.isDesktop(Get.context!)) {
|
||||
mailboxDashBoardController.setMailboxDashBoardAction(appAction);
|
||||
void _markAsEmailReadSuccess(Success success) {
|
||||
mailboxDashBoardController.dispatchState(Right(success));
|
||||
|
||||
if (success is MarkAsEmailReadSuccess && success.readActions == ReadActions.markAsUnread) {
|
||||
backToThreadView();
|
||||
}
|
||||
}
|
||||
|
||||
void _markAsEmailReadFailure(Failure failure) {
|
||||
backToThreadView();
|
||||
}
|
||||
|
||||
bool canComposeEmail() => mailboxDashBoardController.sessionCurrent != null
|
||||
&& mailboxDashBoardController.userProfile.value != null
|
||||
&& mailboxDashBoardController.mapMailboxId.containsKey(PresentationMailbox.roleOutbox)
|
||||
&& mailboxDashBoardController.selectedEmail.value != null;
|
||||
|
||||
void goToThreadView(BuildContext context) {
|
||||
popBack(result: emailActionCurrent);
|
||||
void backToThreadView() {
|
||||
popBack();
|
||||
}
|
||||
|
||||
void pressEmailAction(EmailActionType emailActionType) {
|
||||
|
||||
@@ -22,40 +22,37 @@ class EmailView extends GetWidget {
|
||||
|
||||
@override
|
||||
Widget build(BuildContext context) {
|
||||
return WillPopScope(
|
||||
child: Scaffold(
|
||||
resizeToAvoidBottomInset: false,
|
||||
backgroundColor: AppColor.primaryLightColor,
|
||||
body: SafeArea(
|
||||
right: false,
|
||||
left: false,
|
||||
child: Container(
|
||||
alignment: Alignment.center,
|
||||
child: Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
crossAxisAlignment: CrossAxisAlignment.center,
|
||||
children: [
|
||||
_buildAppBar(context),
|
||||
Expanded(child: _buildEmailContent(context)),
|
||||
_buildBottomBar(context),
|
||||
])
|
||||
)
|
||||
)),
|
||||
onWillPop: () async {
|
||||
emailController.goToThreadView(context);
|
||||
return true;
|
||||
});
|
||||
return Scaffold(
|
||||
resizeToAvoidBottomInset: false,
|
||||
backgroundColor: AppColor.primaryLightColor,
|
||||
body: SafeArea(
|
||||
right: false,
|
||||
left: false,
|
||||
child: Container(
|
||||
alignment: Alignment.center,
|
||||
child: Column(
|
||||
mainAxisAlignment: MainAxisAlignment.center,
|
||||
crossAxisAlignment: CrossAxisAlignment.center,
|
||||
children: [
|
||||
_buildAppBar(context),
|
||||
Expanded(child: _buildEmailContent(context)),
|
||||
_buildBottomBar(context),
|
||||
])
|
||||
)
|
||||
));
|
||||
}
|
||||
|
||||
Widget _buildAppBar(BuildContext context) {
|
||||
return Obx(() => Padding(
|
||||
padding: EdgeInsets.only(left: 6, top: 6, right: 6, bottom: 6),
|
||||
child: AppBarMailWidgetBuilder(
|
||||
context,
|
||||
imagePaths,
|
||||
responsiveUtils,
|
||||
emailController.mailboxDashBoardController.selectedEmail.value)
|
||||
.onBackActionClick(() => emailController.goToThreadView(context))
|
||||
child: (AppBarMailWidgetBuilder(
|
||||
context,
|
||||
imagePaths,
|
||||
responsiveUtils,
|
||||
emailController.mailboxDashBoardController.selectedEmail.value)
|
||||
..onBackActionClick(() => emailController.backToThreadView())
|
||||
..onUnreadEmailActionClick((presentationEmail) =>
|
||||
emailController.markAsEmailRead(presentationEmail, ReadActions.markAsUnread)))
|
||||
.build()));
|
||||
}
|
||||
|
||||
|
||||
@@ -7,9 +7,11 @@ import 'package:model/model.dart';
|
||||
import 'package:tmail_ui_user/main/routes/app_routes.dart';
|
||||
|
||||
typedef OnBackActionClick = void Function();
|
||||
typedef OnUnreadEmailActionClick = void Function(PresentationEmail presentationEmail);
|
||||
|
||||
class AppBarMailWidgetBuilder {
|
||||
OnBackActionClick? _onBackActionClick;
|
||||
OnUnreadEmailActionClick? _onUnreadEmailActionClick;
|
||||
|
||||
final BuildContext _context;
|
||||
final ImagePaths _imagePaths;
|
||||
@@ -23,10 +25,12 @@ class AppBarMailWidgetBuilder {
|
||||
this._presentationEmail,
|
||||
);
|
||||
|
||||
AppBarMailWidgetBuilder onBackActionClick(
|
||||
OnBackActionClick onBackActionClick) {
|
||||
void onBackActionClick(OnBackActionClick onBackActionClick) {
|
||||
_onBackActionClick = onBackActionClick;
|
||||
return this;
|
||||
}
|
||||
|
||||
void onUnreadEmailActionClick(OnUnreadEmailActionClick onUnreadEmailActionClick) {
|
||||
_onUnreadEmailActionClick = onUnreadEmailActionClick;
|
||||
}
|
||||
|
||||
Widget build() {
|
||||
@@ -68,17 +72,23 @@ class AppBarMailWidgetBuilder {
|
||||
mainAxisAlignment: MainAxisAlignment.start,
|
||||
crossAxisAlignment: CrossAxisAlignment.center,
|
||||
children: [
|
||||
ButtonBuilder(_imagePaths.icTrash).key(Key('button_delete_message')).build(),
|
||||
ButtonBuilder(_imagePaths.icTrash).key(Key('button_move_to_trash_email')).build(),
|
||||
SizedBox(width: 10),
|
||||
ButtonBuilder(_imagePaths.icEyeDisable).key(Key('button_hide_message')).build(),
|
||||
ButtonBuilder(_imagePaths.icEyeDisable)
|
||||
.key(Key('button_mark_as_unread_email'))
|
||||
.onPressActionClick(() {
|
||||
if (_onUnreadEmailActionClick != null && _presentationEmail != null && _presentationEmail!.isReadEmail()) {
|
||||
_onUnreadEmailActionClick!(_presentationEmail!);
|
||||
}})
|
||||
.build(),
|
||||
SizedBox(width: 10),
|
||||
ButtonBuilder((_presentationEmail != null && _presentationEmail!.isFlaggedEmail())
|
||||
? _imagePaths.icFlagged
|
||||
: _imagePaths.icFlag)
|
||||
.key(Key('button_favorite_message'))
|
||||
.key(Key('button_mark_as_flag_email'))
|
||||
.build(),
|
||||
SizedBox(width: 10),
|
||||
ButtonBuilder(_imagePaths.icFolder).key(Key('button_add_folder_message')).build(),
|
||||
ButtonBuilder(_imagePaths.icFolder).key(Key('button_move_to_mailbox_email')).build(),
|
||||
]
|
||||
);
|
||||
}
|
||||
|
||||
@@ -4,9 +4,9 @@ import 'package:flutter/cupertino.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:get/get.dart';
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
|
||||
import 'package:model/model.dart';
|
||||
import 'package:tmail_ui_user/features/base/base_controller.dart';
|
||||
import 'package:tmail_ui_user/features/email/domain/state/mark_as_email_read_state.dart';
|
||||
import 'package:tmail_ui_user/features/login/domain/usecases/delete_credential_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox/domain/state/get_all_mailboxes_state.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox/domain/usecases/get_all_mailbox_interactor.dart';
|
||||
@@ -14,7 +14,7 @@ import 'package:tmail_ui_user/features/mailbox/presentation/model/mailbox_node.d
|
||||
import 'package:tmail_ui_user/features/mailbox/presentation/model/mailbox_tree.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox/presentation/model/mailbox_tree_builder.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox_dashboard/presentation/mailbox_dashboard_controller.dart';
|
||||
import 'package:tmail_ui_user/main/actions/email_action.dart';
|
||||
import 'package:tmail_ui_user/features/thread/domain/state/mark_as_multiple_email_read_state.dart';
|
||||
import 'package:tmail_ui_user/main/routes/app_routes.dart';
|
||||
|
||||
class MailboxController extends BaseController {
|
||||
@@ -44,12 +44,14 @@ class MailboxController extends BaseController {
|
||||
}
|
||||
});
|
||||
|
||||
mailboxDashBoardController.mailboxDashBoardAction.listen((action) {
|
||||
if (action is MarkAsEmailReadAction) {
|
||||
_updateCountUnReadForMailbox(action.presentationMailbox, countUnreadChange: 1, isUnread: false);
|
||||
} else if (action is MarkAsMultipleEmailReadAndUnreadAction) {
|
||||
_updateCountUnReadForMailbox(action.presentationMailbox, countUnreadChange: action.listEmailId.length, isUnread: action.isUnread);
|
||||
}
|
||||
mailboxDashBoardController.viewState.listen((state) {
|
||||
state.map((success) {
|
||||
if (success is MarkAsEmailReadSuccess ||
|
||||
success is MarkAsMultipleEmailReadAllSuccess ||
|
||||
success is MarkAsMultipleEmailReadHasSomeEmailFailure) {
|
||||
refreshGetAllMailboxAction();
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -57,7 +59,6 @@ class MailboxController extends BaseController {
|
||||
void dispose() {
|
||||
super.dispose();
|
||||
mailboxDashBoardController.accountId.close();
|
||||
mailboxDashBoardController.mailboxDashBoardAction.close();
|
||||
}
|
||||
|
||||
void refreshGetAllMailboxAction() {
|
||||
@@ -134,34 +135,6 @@ class MailboxController extends BaseController {
|
||||
}
|
||||
}
|
||||
|
||||
void _updateCountUnReadForMailbox(
|
||||
PresentationMailbox presentationMailbox,
|
||||
{
|
||||
required int countUnreadChange,
|
||||
required bool isUnread
|
||||
}
|
||||
) {
|
||||
if (presentationMailbox.hasRole()) {
|
||||
final currentCountUnread = presentationMailbox.unreadEmails != null
|
||||
? presentationMailbox.unreadEmails!.value.value
|
||||
: 0;
|
||||
num newCountUnread = 0;
|
||||
if (isUnread) {
|
||||
newCountUnread = currentCountUnread + countUnreadChange;
|
||||
} else {
|
||||
newCountUnread = currentCountUnread > countUnreadChange ? currentCountUnread - countUnreadChange : 0;
|
||||
}
|
||||
final newMailbox = presentationMailbox.toPresentationMailbox(countUnRead: UnsignedInt(newCountUnread));
|
||||
final newDefaultMailboxList = defaultMailboxList
|
||||
.map((mailbox) => mailbox.id == presentationMailbox.id
|
||||
? mailbox.toPresentationMailbox(countUnRead: UnsignedInt(newCountUnread))
|
||||
: mailbox)
|
||||
.toList();
|
||||
defaultMailboxList.value = newDefaultMailboxList;
|
||||
mailboxDashBoardController.setNewFirstSelectedMailbox(newMailbox);
|
||||
}
|
||||
}
|
||||
|
||||
void _deleteCredential() async {
|
||||
await _deleteCredentialInteractor.execute();
|
||||
}
|
||||
|
||||
@@ -9,7 +9,6 @@ import 'package:tmail_ui_user/features/base/base_controller.dart';
|
||||
import 'package:tmail_ui_user/features/email/presentation/email_controller.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/state/get_user_profile_state.dart';
|
||||
import 'package:tmail_ui_user/features/mailbox_dashboard/domain/usecases/get_user_profile_interactor.dart';
|
||||
import 'package:tmail_ui_user/main/actions/app_action.dart';
|
||||
|
||||
class MailboxDashBoardController extends BaseController {
|
||||
|
||||
@@ -20,7 +19,6 @@ class MailboxDashBoardController extends BaseController {
|
||||
final selectedEmail = Rxn<PresentationEmail>();
|
||||
final accountId = Rxn<AccountId>();
|
||||
final userProfile = Rxn<UserProfile>();
|
||||
final mailboxDashBoardAction = Rxn<AppAction>();
|
||||
|
||||
Session? sessionCurrent;
|
||||
Map<Role, MailboxId> mapMailboxId = Map();
|
||||
@@ -78,14 +76,6 @@ class MailboxDashBoardController extends BaseController {
|
||||
selectedEmail.value = newPresentationEmail;
|
||||
}
|
||||
|
||||
void setMailboxDashBoardAction(AppAction? newAction) {
|
||||
mailboxDashBoardAction.value = newAction;
|
||||
}
|
||||
|
||||
void clearMailboxDashBoardAction() {
|
||||
mailboxDashBoardAction.value = null;
|
||||
}
|
||||
|
||||
void clearSelectedEmail() {
|
||||
selectedEmail.value = null;
|
||||
}
|
||||
|
||||
@@ -1,38 +1,43 @@
|
||||
import 'package:core/core.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
|
||||
class MarkAsMultipleEmailReadAllSuccess extends UIState {
|
||||
final List<Either<Failure, Success>> resultList;
|
||||
final ReadActions readActions;
|
||||
|
||||
MarkAsMultipleEmailReadAllSuccess(this.resultList);
|
||||
MarkAsMultipleEmailReadAllSuccess(this.resultList, this.readActions);
|
||||
|
||||
@override
|
||||
List<Object?> get props => [resultList];
|
||||
List<Object?> get props => [resultList, readActions];
|
||||
}
|
||||
|
||||
class MarkAsMultipleEmailReadAllFailure extends FeatureFailure {
|
||||
final List<Either<Failure, Success>> resultList;
|
||||
final ReadActions readActions;
|
||||
|
||||
MarkAsMultipleEmailReadAllFailure(this.resultList);
|
||||
MarkAsMultipleEmailReadAllFailure(this.resultList, this.readActions);
|
||||
|
||||
@override
|
||||
List<Object> get props => [resultList];
|
||||
List<Object> get props => [resultList, readActions];
|
||||
}
|
||||
|
||||
class MarkAsMultipleEmailReadHasSomeEmailFailure extends UIState {
|
||||
final List<Either<Failure, Success>> resultList;
|
||||
final ReadActions readActions;
|
||||
|
||||
MarkAsMultipleEmailReadHasSomeEmailFailure(this.resultList);
|
||||
MarkAsMultipleEmailReadHasSomeEmailFailure(this.resultList, this.readActions);
|
||||
|
||||
@override
|
||||
List<Object> get props => [resultList];
|
||||
List<Object> get props => [resultList, readActions];
|
||||
}
|
||||
|
||||
class MarkAsMultipleEmailReadFailure extends FeatureFailure {
|
||||
final exception;
|
||||
final ReadActions readActions;
|
||||
|
||||
MarkAsMultipleEmailReadFailure(this.exception);
|
||||
MarkAsMultipleEmailReadFailure(this.exception, this.readActions);
|
||||
|
||||
@override
|
||||
List<Object> get props => [exception];
|
||||
List<Object> get props => [exception, readActions];
|
||||
}
|
||||
@@ -2,6 +2,7 @@ import 'package:core/core.dart';
|
||||
import 'package:dartz/dartz.dart';
|
||||
import 'package:jmap_dart_client/jmap/account_id.dart';
|
||||
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||
import 'package:model/email/read_actions.dart';
|
||||
import 'package:tmail_ui_user/features/email/domain/usecases/mark_as_email_read_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/thread/domain/state/mark_as_multiple_email_read_state.dart';
|
||||
|
||||
@@ -10,12 +11,18 @@ class MarkAsMultipleEmailReadInteractor {
|
||||
|
||||
MarkAsMultipleEmailReadInteractor(this.markAsEmailReadInteractor);
|
||||
|
||||
Future<Either<Failure, Success>> execute(AccountId accountId, List<EmailId> listEmailId, bool unread) async {
|
||||
Stream<Either<Failure, Success>> execute(
|
||||
AccountId accountId,
|
||||
List<EmailId> listEmailId,
|
||||
ReadActions readAction
|
||||
) async* {
|
||||
try {
|
||||
final listResult = await Future.wait(listEmailId.map((emailId) =>
|
||||
markAsEmailReadInteractor.execute(accountId, emailId, unread)));
|
||||
final listResult = await Future.wait(listEmailId.map((emailId) async {
|
||||
final result = await markAsEmailReadInteractor.execute(accountId, emailId, readAction).toList();
|
||||
return result.first;
|
||||
}));
|
||||
if (listResult.length == 1) {
|
||||
return listResult.first;
|
||||
yield listResult.first;
|
||||
} else {
|
||||
var failedFileCount = 0;
|
||||
listResult.forEach((element) {
|
||||
@@ -24,14 +31,14 @@ class MarkAsMultipleEmailReadInteractor {
|
||||
}
|
||||
});
|
||||
if (failedFileCount == 0) {
|
||||
return Right(MarkAsMultipleEmailReadAllSuccess(listResult));
|
||||
yield Right(MarkAsMultipleEmailReadAllSuccess(listResult, readAction));
|
||||
} else if (failedFileCount == listResult.length) {
|
||||
return Left(MarkAsMultipleEmailReadAllFailure(listResult));
|
||||
yield Left(MarkAsMultipleEmailReadAllFailure(listResult, readAction));
|
||||
}
|
||||
return Right(MarkAsMultipleEmailReadHasSomeEmailFailure(listResult));
|
||||
yield Right(MarkAsMultipleEmailReadHasSomeEmailFailure(listResult, readAction));
|
||||
}
|
||||
} catch (e) {
|
||||
return Left(MarkAsMultipleEmailReadFailure(e));
|
||||
yield Left(MarkAsMultipleEmailReadFailure(e, readAction));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -26,8 +26,6 @@ import 'package:tmail_ui_user/features/thread/domain/usecases/get_emails_in_mail
|
||||
import 'package:tmail_ui_user/features/thread/domain/usecases/mark_as_multiple_email_read_interactor.dart';
|
||||
import 'package:tmail_ui_user/features/thread/presentation/model/load_more_state.dart';
|
||||
import 'package:tmail_ui_user/features/thread/presentation/widgets/email_context_menu_action_builder.dart';
|
||||
import 'package:tmail_ui_user/main/actions/app_action.dart';
|
||||
import 'package:tmail_ui_user/main/actions/email_action.dart';
|
||||
import 'package:tmail_ui_user/main/localizations/app_localizations.dart';
|
||||
import 'package:tmail_ui_user/main/routes/app_routes.dart';
|
||||
import 'package:tmail_ui_user/main/routes/route_navigation.dart';
|
||||
@@ -70,17 +68,13 @@ class ThreadController extends BaseController {
|
||||
_currentMailboxId = selectedMailbox?.id;
|
||||
refreshGetAllEmailAction();
|
||||
} else {
|
||||
final actionCurrent = mailboxDashBoardController.mailboxDashBoardAction.value;
|
||||
if (actionCurrent is MarkAsEmailReadAction) {
|
||||
final emailCurrent = mailboxDashBoardController.selectedEmail.value;
|
||||
if (Get.context != null && responsiveUtils.isDesktop(Get.context!) && emailCurrent != null) {
|
||||
_updateStateUnReadAllEmail([emailCurrent.id], isUnread: false);
|
||||
mailboxDashBoardController.viewState.value.map((success) {
|
||||
if (success is MarkAsEmailReadSuccess ||
|
||||
success is MarkAsMultipleEmailReadAllSuccess ||
|
||||
success is MarkAsMultipleEmailReadHasSomeEmailFailure) {
|
||||
_refreshListEmailMarkAsRead();
|
||||
}
|
||||
mailboxDashBoardController.clearMailboxDashBoardAction();
|
||||
} else if (actionCurrent is MarkAsMultipleEmailReadAndUnreadAction) {
|
||||
_updateStateUnReadAllEmail(actionCurrent.listEmailId, isUnread: actionCurrent.isUnread);
|
||||
mailboxDashBoardController.clearMailboxDashBoardAction();
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
}
|
||||
@@ -100,22 +94,37 @@ class ThreadController extends BaseController {
|
||||
@override
|
||||
void onDone() {
|
||||
viewState.value.fold(
|
||||
(failure) => _resetPositionCurrentAndLoadMoreState(),
|
||||
(success) => _updateEmailList(success is GetAllEmailSuccess ? success.emailList : [])
|
||||
(failure) {
|
||||
if (failure is GetAllEmailFailure) {
|
||||
_resetPositionCurrentAndLoadMoreState();
|
||||
} else if (failure is MarkAsEmailReadFailure ||
|
||||
failure is MarkAsMultipleEmailReadAllFailure ||
|
||||
failure is MarkAsMultipleEmailReadFailure) {
|
||||
_markAsSelectedEmailReadFailure(failure);
|
||||
}
|
||||
},
|
||||
(success) {
|
||||
if (success is GetAllEmailSuccess) {
|
||||
_getAllEmailSuccess(success);
|
||||
} else if (success is MarkAsEmailReadSuccess ||
|
||||
success is MarkAsMultipleEmailReadAllSuccess ||
|
||||
success is MarkAsMultipleEmailReadHasSomeEmailFailure) {
|
||||
_markAsSelectedEmailReadSuccess(success);
|
||||
}
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
@override
|
||||
void onError(error) {
|
||||
_resetPositionCurrentAndLoadMoreState();
|
||||
}
|
||||
|
||||
void _updateEmailList(List<PresentationEmail> newListEmail) {
|
||||
emailList.value += newListEmail;
|
||||
|
||||
lastGetTotal = emailList.length;
|
||||
|
||||
loadMoreState.value = newListEmail.isEmpty ? LoadMoreState.COMPLETED : LoadMoreState.IDLE;
|
||||
void _getAllEmailSuccess(Success success) {
|
||||
if (success is GetAllEmailSuccess) {
|
||||
emailList.value += success.emailList;
|
||||
lastGetTotal = emailList.length;
|
||||
loadMoreState.value = success.emailList.isEmpty ? LoadMoreState.COMPLETED : LoadMoreState.IDLE;
|
||||
}
|
||||
}
|
||||
|
||||
EmailFilterCondition? _getFilterConditionCurrent() {
|
||||
@@ -226,90 +235,84 @@ class ThreadController extends BaseController {
|
||||
currentSelectMode.value = SelectMode.INACTIVE;
|
||||
}
|
||||
|
||||
void _updateStateUnReadAllEmail(List<EmailId> list, {required bool isUnread}) {
|
||||
final newEmailList = emailList
|
||||
.map((email) => list.contains(email.id) ? email.markAsReadPresentationEmail(isUnread: isUnread) : email)
|
||||
.toList();
|
||||
emailList.value = newEmailList;
|
||||
void _refreshListEmailMarkAsRead() {
|
||||
final newLimit = emailList.isNotEmpty ? UnsignedInt(emailList.length) : ThreadConstants.defaultLimit;
|
||||
loadMoreState.value = LoadMoreState.IDLE;
|
||||
emailList.clear();
|
||||
|
||||
final accountId = mailboxDashBoardController.accountId.value;
|
||||
|
||||
if (accountId != null) {
|
||||
getAllEmailAction(
|
||||
accountId,
|
||||
limit: newLimit,
|
||||
position: 0,
|
||||
sort: _getSortCurrent(),
|
||||
properties: _properties,
|
||||
filter: _getFilterConditionCurrent());
|
||||
}
|
||||
}
|
||||
|
||||
void unreadSelectedEmail(List<PresentationEmail> listEmail, {bool fromContextMenuAction = false}) {
|
||||
void markAsSelectedEmailRead(List<PresentationEmail> listEmail, {bool fromContextMenuAction = false}) {
|
||||
if (fromContextMenuAction) {
|
||||
popBack();
|
||||
}
|
||||
|
||||
final isUnread = _isEmailAllRead(listEmail);
|
||||
final readAction = _isEmailAllRead(listEmail) ? ReadActions.markAsUnread : ReadActions.markAsRead;
|
||||
|
||||
final listEmailId = listEmail
|
||||
.where((email) => isUnread ? email.isReadEmail() : email.isUnReadEmail())
|
||||
.where((email) => readAction == ReadActions.markAsUnread ? email.isReadEmail() : email.isUnReadEmail())
|
||||
.map((email) => email.id)
|
||||
.toList();
|
||||
|
||||
final accountId = mailboxDashBoardController.accountId.value;
|
||||
final mailboxCurrent = mailboxDashBoardController.selectedMailbox.value;
|
||||
|
||||
if (accountId != null && mailboxCurrent != null) {
|
||||
_markAsMultipleEmailReadInteractor
|
||||
.execute(accountId, listEmailId, isUnread)
|
||||
.then((result) => result.fold(
|
||||
(failure) {
|
||||
cancelSelectEmail();
|
||||
|
||||
if (failure is MarkAsEmailReadFailure
|
||||
|| failure is MarkAsMultipleEmailReadAllFailure
|
||||
|| failure is MarkAsMultipleEmailReadFailure) {
|
||||
_appToast.showErrorToast(AppLocalizations.of(Get.context!).an_error_occurred);
|
||||
}
|
||||
},
|
||||
(success) {
|
||||
cancelSelectEmail();
|
||||
final listEmailIdSuccess = _getListEmailIdMarkedAsReadSuccess(success);
|
||||
|
||||
if (success is MarkAsEmailReadSuccess
|
||||
|| success is MarkAsMultipleEmailReadAllSuccess
|
||||
|| success is MarkAsMultipleEmailReadHasSomeEmailFailure) {
|
||||
if (Get.context != null) {
|
||||
_appToast.showSuccessToast(isUnread
|
||||
? AppLocalizations.of(Get.context!).marked_multiple_item_as_unread(listEmail.length)
|
||||
: AppLocalizations.of(Get.context!).marked_multiple_item_as_read(listEmail.length));
|
||||
}
|
||||
|
||||
if (listEmailIdSuccess.isNotEmpty) {
|
||||
_updateStateEmailAndCountUnReadMailbox(MarkAsMultipleEmailReadAndUnreadAction(listEmailIdSuccess, mailboxCurrent, isUnread));
|
||||
}
|
||||
}
|
||||
}));
|
||||
consumeState(_markAsMultipleEmailReadInteractor.execute(accountId, listEmailId, readAction));
|
||||
}
|
||||
}
|
||||
|
||||
List<EmailId> _getListEmailIdMarkedAsReadSuccess(Success success) {
|
||||
final listEmailIdSuccess = <EmailId>[];
|
||||
void _markAsSelectedEmailReadSuccess(Success success) {
|
||||
cancelSelectEmail();
|
||||
|
||||
List<EmailId> listEmailId = <EmailId>[];
|
||||
ReadActions? readActions;
|
||||
|
||||
if (success is MarkAsEmailReadSuccess) {
|
||||
listEmailIdSuccess.add(success.emailId);
|
||||
listEmailId.add(success.emailId);
|
||||
readActions = success.readActions;
|
||||
} else if (success is MarkAsMultipleEmailReadAllSuccess) {
|
||||
success.resultList.forEach((either) {
|
||||
either.map((success) {
|
||||
if (success is MarkAsEmailReadSuccess) {
|
||||
listEmailIdSuccess.add(success.emailId);
|
||||
listEmailId.add(success.emailId);
|
||||
}
|
||||
});
|
||||
});
|
||||
readActions = success.readActions;
|
||||
} else if (success is MarkAsMultipleEmailReadHasSomeEmailFailure) {
|
||||
success.resultList.forEach((either) {
|
||||
either.map((success) {
|
||||
if (success is MarkAsEmailReadSuccess) {
|
||||
listEmailIdSuccess.add(success.emailId);
|
||||
listEmailId.add(success.emailId);
|
||||
}
|
||||
});
|
||||
});
|
||||
readActions = success.readActions;
|
||||
}
|
||||
|
||||
return listEmailIdSuccess;
|
||||
if (Get.context != null && readActions != null) {
|
||||
_appToast.showSuccessToast(readActions == ReadActions.markAsUnread
|
||||
? AppLocalizations.of(Get.context!).marked_multiple_item_as_unread(listEmailId.length)
|
||||
: AppLocalizations.of(Get.context!).marked_multiple_item_as_read(listEmailId.length));
|
||||
}
|
||||
|
||||
mailboxDashBoardController.dispatchState(Right(success));
|
||||
}
|
||||
|
||||
void _updateStateEmailAndCountUnReadMailbox(AppAction? appAction) {
|
||||
mailboxDashBoardController.setMailboxDashBoardAction(appAction);
|
||||
void _markAsSelectedEmailReadFailure(Failure failure) {
|
||||
cancelSelectEmail();
|
||||
_appToast.showErrorToast(AppLocalizations.of(Get.context!).an_error_occurred);
|
||||
}
|
||||
|
||||
void openContextMenuSelectedEmail(BuildContext context, ImagePaths imagePaths, List<PresentationEmail> listEmail) {
|
||||
@@ -322,20 +325,20 @@ class ThreadController extends BaseController {
|
||||
return [
|
||||
_moveToTrashAction(context, imagePaths, listEmail),
|
||||
_moveToMailboxAction(context, imagePaths, listEmail),
|
||||
_markAsSeenAction(context, imagePaths, listEmail),
|
||||
_markAsReadAction(context, imagePaths, listEmail),
|
||||
_markAsFlagAction(context, imagePaths, listEmail),
|
||||
_moveToSpamAction(context, imagePaths, listEmail),
|
||||
SizedBox(height: 40),
|
||||
];
|
||||
}
|
||||
|
||||
Widget _markAsSeenAction(BuildContext context, ImagePaths imagePaths, List<PresentationEmail> listEmail) {
|
||||
Widget _markAsReadAction(BuildContext context, ImagePaths imagePaths, List<PresentationEmail> listEmail) {
|
||||
return (EmailContextMenuActionBuilder(
|
||||
Key('mark_as_seen_context_menu_action'),
|
||||
Key('mark_as_read_context_menu_action'),
|
||||
SvgPicture.asset(imagePaths.icEyeDisable, width: 24, height: 24, fit: BoxFit.fill),
|
||||
_isEmailAllRead(listEmail) ? AppLocalizations.of(context).mark_as_unread : AppLocalizations.of(context).mark_as_read,
|
||||
listEmail)
|
||||
..onActionClick((data) => unreadSelectedEmail(data, fromContextMenuAction: true)))
|
||||
..onActionClick((data) => markAsSelectedEmailRead(data, fromContextMenuAction: true)))
|
||||
.build();
|
||||
}
|
||||
|
||||
@@ -383,13 +386,8 @@ class ThreadController extends BaseController {
|
||||
mailboxDashBoardController.openDrawer();
|
||||
}
|
||||
|
||||
void goToEmail(BuildContext context) async {
|
||||
final action = await push(AppRoutes.EMAIL);
|
||||
if (action is MarkAsEmailReadAction) {
|
||||
_updateStateUnReadAllEmail([action.emailId], isUnread: false);
|
||||
mailboxDashBoardController.setMailboxDashBoardAction(action);
|
||||
}
|
||||
mailboxDashBoardController.clearSelectedEmail();
|
||||
void goToEmail(BuildContext context) {
|
||||
push(AppRoutes.EMAIL);
|
||||
}
|
||||
|
||||
void composeEmailAction() {
|
||||
|
||||
@@ -76,7 +76,7 @@ class ThreadView extends GetWidget<ThreadController> {
|
||||
controller.getListEmailSelected())
|
||||
..addCloseActionClick(() => controller.cancelSelectEmail())
|
||||
..addRemoveEmailActionClick((listEmail) => {})
|
||||
..addUnreadEmailActionClick((listEmail) => controller.unreadSelectedEmail(listEmail))
|
||||
..addOnMarkAsEmailReadActionClick((listEmail) => controller.markAsSelectedEmailRead(listEmail))
|
||||
..addOpenContextMenuActionClick((listEmail) => controller.openContextMenuSelectedEmail(context, imagePaths, listEmail)))
|
||||
.build()));
|
||||
}
|
||||
|
||||
+6
-6
@@ -6,13 +6,13 @@ import 'package:model/email/presentation_email.dart';
|
||||
import 'package:tmail_ui_user/main/localizations/app_localizations.dart';
|
||||
|
||||
typedef OnCloseActionClick = void Function();
|
||||
typedef OnUnreadEmailActionClick = void Function(List<PresentationEmail> listEmail);
|
||||
typedef OnMarkAsEmailReadActionClick = void Function(List<PresentationEmail> listEmail);
|
||||
typedef OnRemoveEmailActionClick = void Function(List<PresentationEmail> listEmail);
|
||||
typedef OnOpenContextMenuActionClick = void Function(List<PresentationEmail> listEmail);
|
||||
|
||||
class AppBarThreadSelectModeActiveBuilder {
|
||||
OnCloseActionClick? _onCloseActionClick;
|
||||
OnUnreadEmailActionClick? _onUnreadEmailActionClick;
|
||||
OnMarkAsEmailReadActionClick? _onMarkAsEmailReadActionClick;
|
||||
OnRemoveEmailActionClick? _onRemoveEmailActionClick;
|
||||
OnOpenContextMenuActionClick? _onOpenContextMenuActionClick;
|
||||
|
||||
@@ -26,8 +26,8 @@ class AppBarThreadSelectModeActiveBuilder {
|
||||
_onCloseActionClick = onCloseActionClick;
|
||||
}
|
||||
|
||||
void addUnreadEmailActionClick(OnUnreadEmailActionClick onUnreadEmailActionClick) {
|
||||
_onUnreadEmailActionClick = onUnreadEmailActionClick;
|
||||
void addOnMarkAsEmailReadActionClick(OnMarkAsEmailReadActionClick onMarkAsEmailReadActionClick) {
|
||||
_onMarkAsEmailReadActionClick = onMarkAsEmailReadActionClick;
|
||||
}
|
||||
|
||||
void addRemoveEmailActionClick(OnRemoveEmailActionClick onRemoveEmailActionClick) {
|
||||
@@ -94,8 +94,8 @@ class AppBarThreadSelectModeActiveBuilder {
|
||||
SizedBox(width: 10),
|
||||
ButtonBuilder(_imagePaths.icEyeDisable).key(Key('button_unread_email_selected'))
|
||||
.onPressActionClick(() {
|
||||
if (_onUnreadEmailActionClick != null) {
|
||||
_onUnreadEmailActionClick!(_listEmail);
|
||||
if (_onMarkAsEmailReadActionClick != null) {
|
||||
_onMarkAsEmailReadActionClick!(_listEmail);
|
||||
}})
|
||||
.build(),
|
||||
SizedBox(width: 10),
|
||||
|
||||
Reference in New Issue
Block a user