TF-1705 Auto create default folder if missing on server CYRUS

Signed-off-by: dab246 <tdvu@linagora.com>
(cherry picked from commit 1a5bad168cddf07662f4c682189840bc8c4bdcef)
This commit is contained in:
dab246
2023-10-31 01:30:11 +07:00
committed by Dat Vu
parent 5e69c8bd1c
commit c279730309
18 changed files with 375 additions and 36 deletions
@@ -1,3 +0,0 @@
class MailboxConstants {
static const MAILBOX_LEVEL_SEPARATOR = "/";
}
@@ -0,0 +1,14 @@
import 'package:jmap_dart_client/jmap/core/error/set_error.dart';
import 'package:jmap_dart_client/jmap/core/id.dart';
class SetMailboxMethodException implements Exception {
final Map<Id, SetError> mapErrors;
SetMailboxMethodException(this.mapErrors);
}
class NotFoundMailboxCreatedException implements Exception {}
class NotFoundMailboxUpdatedRoleException implements Exception {}
@@ -0,0 +1,24 @@
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:model/mailbox/presentation_mailbox.dart';
extension RoleExtension on Role {
String get mailboxName {
if (this == PresentationMailbox.roleInbox) {
return 'Inbox';
} else if (this == PresentationMailbox.roleSent) {
return 'Sent';
} else if (this == PresentationMailbox.roleOutbox) {
return 'Outbox';
} else if (this == PresentationMailbox.roleDrafts) {
return 'Drafts';
} else if (this == PresentationMailbox.roleTrash) {
return 'Trash';
} else if (this == PresentationMailbox.roleSpam) {
return 'Spam';
} else {
return '';
}
}
}
@@ -43,4 +43,8 @@ abstract class MailboxRepository {
Future<bool> subscribeMailbox(Session session, AccountId accountId, SubscribeMailboxRequest request);
Future<List<MailboxId>> subscribeMultipleMailbox(Session session, AccountId accountId, SubscribeMultipleMailboxRequest subscribeRequest);
Future<List<Mailbox>> createDefaultMailbox(Session session, AccountId accountId, List<Role> listRole);
Future<List<MailboxId>> setRoleDefaultMailbox(Session session, AccountId accountId, List<Mailbox> listMailbox);
}
@@ -0,0 +1,33 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:tmail_ui_user/features/base/state/ui_action_state.dart';
import 'package:jmap_dart_client/jmap/core/state.dart' as jmap;
class CreateDefaultMailboxLoading extends LoadingState {}
class CreateDefaultMailboxAllSuccess extends UIActionState {
CreateDefaultMailboxAllSuccess({
jmap.State? currentEmailState,
jmap.State? currentMailboxState,
}) : super(currentEmailState, currentMailboxState);
@override
List<Object?> get props => [...super.props];
}
class CreateDefaultMailboxHasSomeFailure extends UIActionState {
CreateDefaultMailboxHasSomeFailure({
jmap.State? currentEmailState,
jmap.State? currentMailboxState,
}) : super(currentEmailState, currentMailboxState);
@override
List<Object?> get props => [...super.props];
}
class CreateDefaultMailboxFailure extends FeatureFailure {
CreateDefaultMailboxFailure(dynamic exception) : super(exception: exception);
@override
List<Object?> get props => [exception];
}
@@ -0,0 +1,54 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
import 'package:core/utils/app_logger.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:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
import 'package:tmail_ui_user/features/mailbox/domain/state/create_default_mailbox_state.dart';
class CreateDefaultMailboxInteractor {
final MailboxRepository _mailboxRepository;
CreateDefaultMailboxInteractor(this._mailboxRepository);
Stream<Either<Failure, Success>> execute(
Session session,
AccountId accountId,
List<Role> listRole
) async* {
try {
yield Right<Failure, Success>(CreateDefaultMailboxLoading());
final currentMailboxState = await _mailboxRepository.getMailboxState(session, accountId);
final listMailboxCreated = await _mailboxRepository.createDefaultMailbox(
session,
accountId,
listRole
);
log('CreateDefaultMailboxInteractor::execute:listMailboxCreated: ${listMailboxCreated.length}');
final listMailboxIdNotSetRole = await _mailboxRepository.setRoleDefaultMailbox(
session,
accountId,
listMailboxCreated
);
log('CreateDefaultMailboxInteractor::execute:listMailboxIdNotSetRole: ${listMailboxIdNotSetRole.length}');
if (listMailboxIdNotSetRole.isEmpty) {
yield Right<Failure, Success>(CreateDefaultMailboxAllSuccess(currentMailboxState: currentMailboxState));
} else if (listMailboxIdNotSetRole.length < listMailboxCreated.length) {
yield Right<Failure, Success>(CreateDefaultMailboxHasSomeFailure(currentMailboxState: currentMailboxState));
} else {
final mapError = await _mailboxRepository.deleteMultipleMailbox(
session,
accountId,
listMailboxIdNotSetRole
);
yield Left<Failure, Success>(CreateDefaultMailboxFailure(mapError));
}
} catch (e) {
yield Left<Failure, Success>(CreateDefaultMailboxFailure(e));
}
}
}