TF-233 Implement create new mailbox and sub-folder

This commit is contained in:
dab246
2022-02-23 12:39:37 +07:00
committed by Dat H. Pham
parent 9c521cde9b
commit e739e23c62
30 changed files with 460 additions and 172 deletions
@@ -3,6 +3,7 @@ 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/mail/mailbox/mailbox.dart';
import 'package:tmail_ui_user/features/mailbox/data/model/mailbox_change_response.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/mailbox_response.dart';
abstract class MailboxDataSource {
@@ -13,4 +14,6 @@ abstract class MailboxDataSource {
Future<MailboxChangeResponse> getChanges(AccountId accountId, State sinceState);
Future<void> update({List<Mailbox>? updated, List<Mailbox>? created, List<MailboxId>? destroyed});
Future<Mailbox?> createNewMailbox(AccountId accountId, CreateNewMailboxRequest newMailboxRequest);
}
@@ -6,6 +6,7 @@ import 'package:tmail_ui_user/features/mailbox/data/datasource/mailbox_datasourc
import 'package:tmail_ui_user/features/mailbox/data/model/mailbox_change_response.dart';
import 'package:tmail_ui_user/features/mailbox/data/local/mailbox_cache_manager.dart';
import 'package:tmail_ui_user/features/mailbox/data/extensions/mailbox_extension.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/mailbox_response.dart';
class MailboxCacheDataSourceImpl extends MailboxDataSource {
@@ -43,4 +44,9 @@ class MailboxCacheDataSourceImpl extends MailboxDataSource {
throw error;
});
}
@override
Future<Mailbox?> createNewMailbox(AccountId accountId, CreateNewMailboxRequest newMailboxRequest) {
throw UnimplementedError();
}
}
@@ -4,6 +4,7 @@ import 'package:jmap_dart_client/jmap/core/state.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:tmail_ui_user/features/mailbox/data/datasource/mailbox_datasource.dart';
import 'package:tmail_ui_user/features/mailbox/data/model/mailbox_change_response.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/mailbox_response.dart';
import 'package:tmail_ui_user/features/mailbox/data/network/mailbox_api.dart';
@@ -40,4 +41,13 @@ class MailboxDataSourceImpl extends MailboxDataSource {
Future<List<Mailbox>> getAllMailboxCache() {
throw UnimplementedError();
}
@override
Future<Mailbox?> createNewMailbox(AccountId accountId, CreateNewMailboxRequest newMailboxRequest) {
return Future.sync(() async {
return await mailboxAPI.createNewMailbox(accountId, newMailboxRequest);
}).catchError((error) {
throw error;
});
}
}
@@ -8,17 +8,17 @@ import 'package:tmail_ui_user/features/mailbox/data/extensions/mailbox_rights_ca
extension MailboxCacheExtension on MailboxCache {
Mailbox toMailbox() {
return Mailbox(
MailboxId(Id(id)),
name != null ? MailboxName(name!) : null,
parentId != null ? MailboxId(Id(parentId!)) : null,
role != null ? Role(role!) : null,
sortOrder != null ? SortOrder(sortValue: sortOrder!) : null,
totalEmails != null ? TotalEmails(UnsignedInt(totalEmails!)) : null,
unreadEmails != null ? UnreadEmails(UnsignedInt(unreadEmails!)) : null,
totalThreads != null ? TotalThreads(UnsignedInt(totalThreads!)) : null,
unreadThreads != null ? UnreadThreads(UnsignedInt(unreadThreads!)) : null,
myRights != null ? myRights!.toMailboxRights() : null,
isSubscribed != null ? IsSubscribed(isSubscribed!) : null
id: MailboxId(Id(id)),
name: name != null ? MailboxName(name!) : null,
parentId: parentId != null ? MailboxId(Id(parentId!)) : null,
role: role != null ? Role(role!) : null,
sortOrder: sortOrder != null ? SortOrder(sortValue: sortOrder!) : null,
totalEmails: totalEmails != null ? TotalEmails(UnsignedInt(totalEmails!)) : null,
unreadEmails: unreadEmails != null ? UnreadEmails(UnsignedInt(unreadEmails!)) : null,
totalThreads: totalThreads != null ? TotalThreads(UnsignedInt(totalThreads!)) : null,
unreadThreads: unreadThreads != null ? UnreadThreads(UnsignedInt(unreadThreads!)) : null,
myRights: myRights != null ? myRights!.toMailboxRights() : null,
isSubscribed: isSubscribed != null ? IsSubscribed(isSubscribed!) : null
);
}
}
@@ -6,7 +6,7 @@ extension MailboxExtension on Mailbox {
MailboxCache toMailboxCache() {
return MailboxCache(
id.id.value,
id!.id.value,
name: name?.name,
parentId: parentId?.id.value,
role: role?.value,
@@ -12,7 +12,11 @@ import 'package:jmap_dart_client/jmap/mail/mailbox/changes/changes_mailbox_respo
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.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/set/set_mailbox_method.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/set/set_mailbox_response.dart';
import 'package:model/model.dart';
import 'package:tmail_ui_user/features/mailbox/data/model/mailbox_change_response.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/mailbox_response.dart';
class MailboxAPI {
@@ -95,4 +99,33 @@ class MailboxAPI {
hasMoreChanges: resultChanges?.hasMoreChanges ?? false,
updatedProperties: resultChanges?.updatedProperties);
}
Future<Mailbox?> createNewMailbox(AccountId accountId, CreateNewMailboxRequest request) async {
final setMailboxMethod = SetMailboxMethod(accountId)
..addCreate(request.creationId, Mailbox(name: request.newName, parentId: request.parentId));
final requestBuilder = JmapRequestBuilder(httpClient, ProcessingInvocation());
final setMailboxInvocation = requestBuilder.invocation(setMailboxMethod);
final response = await (requestBuilder
..usings(setMailboxMethod.requiredCapabilities))
.build()
.execute();
final setMailboxResponse = response.parse<SetMailboxResponse>(
setMailboxInvocation.methodCallId,
SetMailboxResponse.deserialize);
return Future.sync(() async {
final newMailbox = setMailboxResponse?.created?[request.creationId];
if (newMailbox != null) {
return newMailbox.addMailboxName(newMailbox, request.newName, parentId: request.parentId);
} else {
return null;
}
}).catchError((error) {
throw error;
});
}
}
@@ -7,6 +7,7 @@ import 'package:model/model.dart';
import 'package:tmail_ui_user/features/mailbox/data/datasource/mailbox_datasource.dart';
import 'package:tmail_ui_user/features/mailbox/data/datasource/state_datasource.dart';
import 'package:tmail_ui_user/features/mailbox/data/extensions/state_extension.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/create_new_mailbox_request.dart';
import 'package:tmail_ui_user/features/mailbox/domain/model/mailbox_response.dart';
import 'package:tmail_ui_user/features/mailbox/data/model/state_type.dart';
import 'package:tmail_ui_user/features/mailbox/domain/repository/mailbox_repository.dart';
@@ -83,7 +84,7 @@ class MailboxRepositoryImpl extends MailboxRepository {
if (updatedProperties == null) {
return mailboxUpdated;
} else {
final mailboxOld = mailboxCacheList?.findMailbox(mailboxUpdated.id);
final mailboxOld = mailboxCacheList?.findMailbox(mailboxUpdated.id!);
if (mailboxOld != null) {
return mailboxOld.combineMailbox(mailboxUpdated, updatedProperties);
} else {
@@ -134,4 +135,9 @@ class MailboxRepositoryImpl extends MailboxRepository {
yield newMailboxResponse;
}
@override
Future<Mailbox?> createNewMailbox(AccountId accountId, CreateNewMailboxRequest newMailboxRequest) {
return mapDataSource[DataSourceType.network]!.createNewMailbox(accountId, newMailboxRequest);
}
}