eduvia/workavia-mail-front
11
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

TF-898 Create repository/datasource for rule filter

Browse Source
This commit is contained in:
dab246
2022-11-11 04:08:28 +07:00
committed by Dat H. Pham
parent ce76e16232
commit 927151ec8e
13 changed files with 142 additions and 118 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/features/manage_account/data/datasource_impl/manage_account_datasource_impl.dart
-47
View File
@@ -1,23 +1,15 @@
import 'dart:ui';
import 'package:jmap_dart_client/jmap/account_id.dart';
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/data/local/language_cache_manager.dart';
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_email_rule_filter_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/edit_email_rule_filter_request.dart';
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
class ManageAccountDataSourceImpl extends ManageAccountDataSource {
final ManageAccountAPI manageAccountAPI;
final LanguageCacheManager _languageCacheManager;
final ExceptionThrower _exceptionThrower;
ManageAccountDataSourceImpl(
this.manageAccountAPI,
this._languageCacheManager,
this._exceptionThrower
);
@@ -30,43 +22,4 @@ class ManageAccountDataSourceImpl extends ManageAccountDataSource {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> getAllTMailRule(AccountId accountId) {
return Future.sync(() async {
return await manageAccountAPI.getListTMailRule(accountId);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> deleteTMailRule(AccountId accountId, DeleteEmailRuleRequest deleteEmailRuleRequest) {
deleteEmailRuleRequest.currentEmailRules.remove(deleteEmailRuleRequest.emailRuleDelete);
return Future.sync(() async {
return await manageAccountAPI.updateListTMailRule(accountId, deleteEmailRuleRequest.currentEmailRules);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> createNewEmailRuleFilter(AccountId accountId, CreateNewEmailRuleFilterRequest ruleFilterRequest) {
return Future.sync(() async {
return await manageAccountAPI.updateListTMailRule(accountId, ruleFilterRequest.newListTMailRules);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> editEmailRuleFilter(AccountId accountId, EditEmailRuleFilterRequest ruleFilterRequest) {
return Future.sync(() async {
return await manageAccountAPI.updateListTMailRule(accountId, ruleFilterRequest.listTMailRulesUpdated);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
}
lib/features/manage_account/data/datasource_impl/rule_filter_datasource_impl.dart
+59
View File
@@ -0,0 +1,59 @@
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:rule_filter/rule_filter/tmail_rule.dart';
import 'package:tmail_ui_user/features/manage_account/data/datasource/rule_filter_datasource.dart';
import 'package:tmail_ui_user/features/manage_account/data/network/rule_filter_api.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/delete_email_rule_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_email_rule_filter_request.dart';
import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
class RuleFilterDataSourceImpl extends RuleFilterDataSource {
final RuleFilterAPI _ruleFilterAPI;
final ExceptionThrower _exceptionThrower;
RuleFilterDataSourceImpl(
this._ruleFilterAPI,
this._exceptionThrower
);
@override
Future<List<TMailRule>> getAllTMailRule(AccountId accountId) {
return Future.sync(() async {
return await _ruleFilterAPI.getListTMailRule(accountId);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> deleteTMailRule(AccountId accountId, DeleteEmailRuleRequest deleteEmailRuleRequest) {
deleteEmailRuleRequest.currentEmailRules.remove(deleteEmailRuleRequest.emailRuleDelete);
return Future.sync(() async {
return await _ruleFilterAPI.updateListTMailRule(accountId, deleteEmailRuleRequest.currentEmailRules);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> createNewEmailRuleFilter(AccountId accountId, CreateNewEmailRuleFilterRequest ruleFilterRequest) {
return Future.sync(() async {
return await _ruleFilterAPI.updateListTMailRule(accountId, ruleFilterRequest.newListTMailRules);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
@override
Future<List<TMailRule>> editEmailRuleFilter(AccountId accountId, EditEmailRuleFilterRequest ruleFilterRequest) {
return Future.sync(() async {
return await _ruleFilterAPI.updateListTMailRule(accountId, ruleFilterRequest.listTMailRulesUpdated);
}).catchError((error) {
_exceptionThrower.throwException(error);
});
}
}