TF-611 Add data layer for create a new filter email rule

This commit is contained in:
dab246
2022-08-10 17:30:42 +07:00
committed by Dat H. Pham
parent 8b6de12fd4
commit c6ec5baf9b
5 changed files with 44 additions and 18 deletions
@@ -6,6 +6,7 @@ import 'package:jmap_dart_client/jmap/identities/identity.dart';
import 'package:rule_filter/rule_filter/tmail_rule.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/delete_email_rule_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_email_rule_filter_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/identities_response.dart';
@@ -24,4 +25,5 @@ abstract class ManageAccountDataSource {
Future<List<TMailRule>> deleteTMailRule(AccountId accountId, DeleteEmailRuleRequest deleteEmailRuleRequest);
Future<List<TMailRule>> createNewEmailRuleFilter(AccountId accountId, CreateNewEmailRuleFilterRequest ruleFilterRequest);
}
@@ -9,10 +9,12 @@ import 'package:tmail_ui_user/features/manage_account/data/local/language_cache_
import 'package:tmail_ui_user/features/manage_account/data/network/manage_account_api.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/delete_email_rule_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_email_rule_filter_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/identities_response.dart';
class ManageAccountDataSourceImpl extends ManageAccountDataSource {
final ManageAccountAPI manageAccountAPI;
final LanguageCacheManager _languageCacheManager;
@@ -23,19 +25,16 @@ class ManageAccountDataSourceImpl extends ManageAccountDataSource {
Future<IdentitiesResponse> getAllIdentities(AccountId accountId,
{Properties? properties}) {
return Future.sync(() async {
return await manageAccountAPI.getAllIdentities(accountId,
properties: properties);
return await manageAccountAPI.getAllIdentities(accountId, properties: properties);
}).catchError((error) {
throw error;
});
}
@override
Future<Identity> createNewIdentity(
AccountId accountId, CreateNewIdentityRequest identityRequest) {
Future<Identity> createNewIdentity(AccountId accountId, CreateNewIdentityRequest identityRequest) {
return Future.sync(() async {
return await manageAccountAPI.createNewIdentity(
accountId, identityRequest);
return await manageAccountAPI.createNewIdentity(accountId, identityRequest);
}).catchError((error) {
throw error;
});
@@ -51,11 +50,9 @@ class ManageAccountDataSourceImpl extends ManageAccountDataSource {
}
@override
Future<bool> editIdentity(
AccountId accountId, EditIdentityRequest editIdentityRequest) {
Future<bool> editIdentity(AccountId accountId, EditIdentityRequest editIdentityRequest) {
return Future.sync(() async {
return await manageAccountAPI.editIdentity(
accountId, editIdentityRequest);
return await manageAccountAPI.editIdentity(accountId, editIdentityRequest);
}).catchError((error) {
throw error;
});
@@ -90,4 +87,13 @@ class ManageAccountDataSourceImpl extends ManageAccountDataSource {
throw error;
});
}
}
@override
Future<List<TMailRule>> createNewEmailRuleFilter(AccountId accountId, CreateNewEmailRuleFilterRequest ruleFilterRequest) {
return Future.sync(() async {
return await manageAccountAPI.updateListTMailRule(accountId, ruleFilterRequest.newListTMailRules);
}).catchError((error) {
throw error;
});
}
}
@@ -0,0 +1,16 @@
import 'package:jmap_dart_client/jmap/core/id.dart';
import 'package:rule_filter/rule_filter/rule_id.dart';
import 'package:rule_filter/rule_filter/tmail_rule.dart';
extension ListTMailRuleExtensions on List<TMailRule> {
List<TMailRule> get withIds {
return asMap()
.map((key, rule) => MapEntry(
key,
rule.copyWith(id: RuleId(id: Id(key.toString())))))
.values
.toList();
}
}
@@ -14,9 +14,9 @@ import 'package:jmap_dart_client/jmap/jmap_request.dart';
import 'package:rule_filter/rule_filter/get/get_rule_filter_method.dart';
import 'package:rule_filter/rule_filter/get/get_rule_filter_response.dart';
import 'package:rule_filter/rule_filter/rule_filter_id.dart';
import 'package:rule_filter/rule_filter/rule_id.dart';
import 'package:rule_filter/rule_filter/set/set_rule_filter_method.dart';
import 'package:rule_filter/rule_filter/tmail_rule.dart';
import 'package:tmail_ui_user/features/manage_account/data/extensions/list_tmail_rule_extensions.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/identities_response.dart';
@@ -149,17 +149,13 @@ class ManageAccountAPI {
Future<List<TMailRule>> updateListTMailRule(AccountId accountId, List<TMailRule> listTMailRule) async {
final List<TMailRule> listTMailRuleWithId = listTMailRule
.asMap()
.map((key, value) => MapEntry(key, value.copyWith(id: RuleId(id: Id(key.toString())))))
.values
.toList();
final newListTMailRuleWithIds = listTMailRule.withIds;
final processingInvocation = ProcessingInvocation();
final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation);
final setRuleFilterMethod = SetRuleFilterMethod(accountId)
..addUpdateRuleFilter({Id(RuleFilterIdType.singleton.value): listTMailRuleWithId});
..addUpdateRuleFilter({Id(RuleFilterIdType.singleton.value): newListTMailRuleWithIds});
requestBuilder.invocation(setRuleFilterMethod);
@@ -7,6 +7,7 @@ import 'package:rule_filter/rule_filter/tmail_rule.dart';
import 'package:tmail_ui_user/features/manage_account/data/datasource/manage_account_datasource.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/delete_email_rule_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/create_new_email_rule_filter_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/identities_response.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/manage_account_repository.dart';
@@ -51,4 +52,9 @@ class ManageAccountRepositoryImpl extends ManageAccountRepository {
Future<List<TMailRule>> deleteTMailRule(AccountId accountId, DeleteEmailRuleRequest deleteEmailRuleRequest) {
return dataSource.deleteTMailRule(accountId, deleteEmailRuleRequest);
}
@override
Future<List<TMailRule>> createNewEmailRuleFilter(AccountId accountId, CreateNewEmailRuleFilterRequest ruleFilterRequest) {
return dataSource.createNewEmailRuleFilter(accountId, ruleFilterRequest);
}
}