TF-657 Separate interactor/repository/datasource of identity

This commit is contained in:
dab246
2022-10-19 17:53:34 +07:00
committed by Dat H. Pham
parent 9a5fa29035
commit 398654a79d
26 changed files with 353 additions and 313 deletions
@@ -0,0 +1,16 @@
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
import 'package:jmap_dart_client/jmap/identities/identity.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';
abstract class IdentityRepository {
Future<IdentitiesResponse> getAllIdentities(AccountId accountId, {Properties? properties});
Future<Identity> createNewIdentity(AccountId accountId, CreateNewIdentityRequest identityRequest);
Future<bool> deleteIdentity(AccountId accountId, IdentityId identityId);
Future<bool> editIdentity(AccountId accountId, EditIdentityRequest editIdentityRequest);
}
@@ -2,28 +2,15 @@ import 'dart:ui';
import 'package:forward/forward/tmail_forward.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
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/add_recipients_in_forwarding_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/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/delete_recipient_in_forwarding_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_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/edit_local_copy_in_forwarding_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/identities_response.dart';
abstract class ManageAccountRepository {
Future<IdentitiesResponse> getAllIdentities(AccountId accountId, {Properties? properties});
Future<Identity> createNewIdentity(AccountId accountId, CreateNewIdentityRequest identityRequest);
Future<bool> deleteIdentity(AccountId accountId, IdentityId identityId);
Future<bool> editIdentity(AccountId accountId, EditIdentityRequest editIdentityRequest);
Future<void> persistLanguage(Locale localeCurrent);
Future<List<TMailRule>> getAllTMailRule(AccountId accountId);
@@ -1,6 +1,8 @@
import 'package:core/core.dart';
import 'package:jmap_dart_client/jmap/identities/identity.dart';
class CreateNewIdentityLoading extends UIState {}
class CreateNewIdentitySuccess extends UIState {
final Identity newIdentity;
@@ -1,5 +1,7 @@
import 'package:core/core.dart';
class DeleteIdentityLoading extends UIState {}
class DeleteIdentitySuccess extends UIState {
DeleteIdentitySuccess();
@@ -1,5 +1,7 @@
import 'package:core/core.dart';
class EditIdentityLoading extends UIState {}
class EditIdentitySuccess extends UIState {
EditIdentitySuccess();
@@ -2,6 +2,8 @@ import 'package:core/core.dart';
import 'package:jmap_dart_client/jmap/core/state.dart';
import 'package:jmap_dart_client/jmap/identities/identity.dart';
class GetAllIdentitiesLoading extends UIState {}
class GetAllIdentitiesSuccess extends UIState {
final List<Identity>? identities;
final State? state;
@@ -4,17 +4,18 @@ import 'package:core/core.dart';
import 'package:dartz/dartz.dart';
import 'package:jmap_dart_client/jmap/account_id.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/repository/manage_account_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/identity_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/state/create_new_identity_state.dart';
class CreateNewIdentityInteractor {
final ManageAccountRepository manageAccountRepository;
final IdentityRepository _identityRepository;
CreateNewIdentityInteractor(this.manageAccountRepository);
CreateNewIdentityInteractor(this._identityRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, CreateNewIdentityRequest identityRequest) async* {
try {
final newIdentity = await manageAccountRepository.createNewIdentity(accountId, identityRequest);
yield Right(CreateNewIdentityLoading());
final newIdentity = await _identityRepository.createNewIdentity(accountId, identityRequest);
yield Right(CreateNewIdentitySuccess(newIdentity));
} catch (exception) {
yield Left(CreateNewIdentityFailure(exception));
@@ -4,17 +4,18 @@ 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/identities/identity.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/manage_account_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/identity_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/state/delete_identity_state.dart';
class DeleteIdentityInteractor {
final ManageAccountRepository manageAccountRepository;
final IdentityRepository _identityRepository;
DeleteIdentityInteractor(this.manageAccountRepository);
DeleteIdentityInteractor(this._identityRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, IdentityId identityId) async* {
try {
final result = await manageAccountRepository.deleteIdentity(accountId, identityId);
yield Right(DeleteIdentityLoading());
final result = await _identityRepository.deleteIdentity(accountId, identityId);
yield result ? Right(DeleteIdentitySuccess()) : Left(DeleteIdentityFailure(null));
} catch (exception) {
yield Left(DeleteIdentityFailure(exception));
@@ -4,20 +4,21 @@ import 'package:core/core.dart';
import 'package:dartz/dartz.dart';
import 'package:jmap_dart_client/jmap/account_id.dart';
import 'package:tmail_ui_user/features/manage_account/domain/model/edit_identity_request.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/manage_account_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/identity_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/state/edit_identity_state.dart';
class EditIdentityInteractor {
final ManageAccountRepository manageAccountRepository;
final IdentityRepository _identityRepository;
EditIdentityInteractor(this.manageAccountRepository);
EditIdentityInteractor(this._identityRepository);
Stream<Either<Failure, Success>> execute(
AccountId accountId,
EditIdentityRequest editIdentityRequest
) async* {
try {
final result = await manageAccountRepository.editIdentity(accountId, editIdentityRequest);
yield Right(EditIdentityLoading());
final result = await _identityRepository.editIdentity(accountId, editIdentityRequest);
yield result ? Right(EditIdentitySuccess()) : Left(EditIdentityFailure(null));
} catch (exception) {
yield Left(EditIdentityFailure(exception));
@@ -4,18 +4,18 @@ 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/core/properties/properties.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/manage_account_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/repository/identity_repository.dart';
import 'package:tmail_ui_user/features/manage_account/domain/state/get_all_identities_state.dart';
class GetAllIdentitiesInteractor {
final ManageAccountRepository manageAccountRepository;
final IdentityRepository _identityRepository;
GetAllIdentitiesInteractor(this.manageAccountRepository);
GetAllIdentitiesInteractor(this._identityRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId, {Properties? properties}) async* {
try {
yield Right<Failure, Success>(LoadingState());
final identitiesResponse = await manageAccountRepository.getAllIdentities(accountId, properties: properties);
yield Right<Failure, Success>(GetAllIdentitiesLoading());
final identitiesResponse = await _identityRepository.getAllIdentities(accountId, properties: properties);
yield Right(GetAllIdentitiesSuccess(identitiesResponse.identities, identitiesResponse.state));
} catch (exception) {
yield Left(GetAllIdentitiesFailure(exception));