TF-1118 Create repository and datasource for forwarding

lib/features/manage_account/data/datasource/forwarding_datasource.dart

@@ -0,0 +1,15 @@
+import 'package:forward/forward/tmail_forward.dart';
+import 'package:jmap_dart_client/jmap/account_id.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/delete_recipient_in_forwarding_request.dart';
+import 'package:tmail_ui_user/features/manage_account/domain/model/edit_local_copy_in_forwarding_request.dart';
+
+abstract class ForwardingDataSource {
+  Future<TMailForward> getForward(AccountId accountId);
+
+  Future<TMailForward> deleteRecipientInForwarding(AccountId accountId, DeleteRecipientInForwardingRequest deleteRequest);
+
+  Future<TMailForward> addRecipientsInForwarding(AccountId accountId, AddRecipientInForwardingRequest addRequest);
+
+  Future<TMailForward> editLocalCopyInForwarding(AccountId accountId, EditLocalCopyInForwardingRequest editRequest);
+}

lib/features/manage_account/data/datasource/manage_account_datasource.dart

@@ -1,14 +1,10 @@
 import 'dart:ui';
 
-import 'package:forward/forward/tmail_forward.dart';
 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/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/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_local_copy_in_forwarding_request.dart';
 
 abstract class ManageAccountDataSource {
   Future<void> persistLanguage(Locale localeCurrent);
@@ -20,12 +16,4 @@ abstract class ManageAccountDataSource {
   Future<List<TMailRule>> createNewEmailRuleFilter(AccountId accountId, CreateNewEmailRuleFilterRequest ruleFilterRequest);
 
   Future<List<TMailRule>> editEmailRuleFilter(AccountId accountId, EditEmailRuleFilterRequest ruleFilterRequest);
-
-  Future<TMailForward> getForward(AccountId accountId);
-
-  Future<TMailForward> deleteRecipientInForwarding(AccountId accountId, DeleteRecipientInForwardingRequest deleteRequest);
-
-  Future<TMailForward> addRecipientsInForwarding(AccountId accountId, AddRecipientInForwardingRequest addRequest);
-
-  Future<TMailForward> editLocalCopyInForwarding(AccountId accountId, EditLocalCopyInForwardingRequest editRequest);
 }

lib/features/manage_account/data/datasource_impl/forwarding_data_source_impl.dart

@@ -0,0 +1,52 @@
+import 'package:forward/forward/tmail_forward.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:tmail_ui_user/features/manage_account/data/datasource/forwarding_datasource.dart';
+import 'package:tmail_ui_user/features/manage_account/data/network/forwarding_api.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/delete_recipient_in_forwarding_request.dart';
+import 'package:tmail_ui_user/features/manage_account/domain/model/edit_local_copy_in_forwarding_request.dart';
+import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
+
+class ForwardingDataSourceImpl extends ForwardingDataSource {
+
+  final ForwardingAPI _forwardingAPI;
+  final ExceptionThrower _exceptionThrower;
+
+  ForwardingDataSourceImpl(this._forwardingAPI, this._exceptionThrower);
+
+  @override
+  Future<TMailForward> getForward(AccountId accountId) {
+    return Future.sync(() async {
+      return await _forwardingAPI.getForward(accountId);
+    }).catchError((error) {
+      _exceptionThrower.throwException(error);
+    });
+  }
+
+  @override
+  Future<TMailForward> deleteRecipientInForwarding(AccountId accountId, DeleteRecipientInForwardingRequest deleteRequest) {
+    return Future.sync(() async {
+      return await _forwardingAPI.updateForward(accountId, deleteRequest.newTMailForward);
+    }).catchError((error) {
+      _exceptionThrower.throwException(error);
+    });
+  }
+
+  @override
+  Future<TMailForward> addRecipientsInForwarding(AccountId accountId, AddRecipientInForwardingRequest addRequest) {
+    return Future.sync(() async {
+      return await _forwardingAPI.updateForward(accountId, addRequest.newTMailForward);
+    }).catchError((error) {
+      _exceptionThrower.throwException(error);
+    });
+  }
+
+  @override
+  Future<TMailForward> editLocalCopyInForwarding(AccountId accountId, EditLocalCopyInForwardingRequest editRequest) {
+    return Future.sync(() async {
+      return await _forwardingAPI.updateForward(accountId, editRequest.newTMailForward);
+    }).catchError((error) {
+      _exceptionThrower.throwException(error);
+    });
+  }
+}

lib/features/manage_account/data/datasource_impl/manage_account_datasource_impl.dart

@@ -1,17 +1,13 @@
 import 'dart:ui';
 
-import 'package:forward/forward/tmail_forward.dart';
 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/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/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_local_copy_in_forwarding_request.dart';
 import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
 
 class ManageAccountDataSourceImpl extends ManageAccountDataSource {
@@ -23,7 +19,8 @@ class ManageAccountDataSourceImpl extends ManageAccountDataSource {
   ManageAccountDataSourceImpl(
     this.manageAccountAPI,
     this._languageCacheManager,
-    this._exceptionThrower);
+    this._exceptionThrower
+  );
 
   @override
   Future<void> persistLanguage(Locale localeCurrent) {
@@ -72,40 +69,4 @@ class ManageAccountDataSourceImpl extends ManageAccountDataSource {
       _exceptionThrower.throwException(error);
     });
   }
-
-  @override
-  Future<TMailForward> getForward(AccountId accountId) {
-    return Future.sync(() async {
-      return await manageAccountAPI.getForward(accountId);
-    }).catchError((error) {
-      _exceptionThrower.throwException(error);
-    });
-  }
-
-  @override
-  Future<TMailForward> deleteRecipientInForwarding(AccountId accountId, DeleteRecipientInForwardingRequest deleteRequest) {
-    return Future.sync(() async {
-      return await manageAccountAPI.updateForward(accountId, deleteRequest.newTMailForward);
-    }).catchError((error) {
-      _exceptionThrower.throwException(error);
-    });
-  }
-
-  @override
-  Future<TMailForward> addRecipientsInForwarding(AccountId accountId, AddRecipientInForwardingRequest addRequest) {
-    return Future.sync(() async {
-      return await manageAccountAPI.updateForward(accountId, addRequest.newTMailForward);
-    }).catchError((error) {
-      _exceptionThrower.throwException(error);
-    });
-  }
-
-  @override
-  Future<TMailForward> editLocalCopyInForwarding(AccountId accountId, EditLocalCopyInForwardingRequest editRequest) {
-    return Future.sync(() async {
-      return await manageAccountAPI.updateForward(accountId, editRequest.newTMailForward);
-    }).catchError((error) {
-      _exceptionThrower.throwException(error);
-    });
-  }
 }

lib/features/manage_account/data/network/forwarding_api.dart

@@ -0,0 +1,72 @@
+import 'package:forward/forward/forward_id.dart';
+import 'package:forward/forward/get/get_forward_method.dart';
+import 'package:forward/forward/get/get_forward_response.dart';
+import 'package:forward/forward/set/set_forward_method.dart';
+import 'package:forward/forward/tmail_forward.dart';
+import 'package:jmap_dart_client/http/http_client.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/jmap_request.dart';
+import 'package:tmail_ui_user/features/manage_account/domain/exceptions/forward_exception.dart';
+
+class ForwardingAPI {
+  final HttpClient _httpClient;
+
+  ForwardingAPI(this._httpClient);
+
+  Future<TMailForward> getForward(AccountId accountId) async {
+    final processingInvocation = ProcessingInvocation();
+    final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation);
+
+    final getForwardMethod = GetForwardMethod(
+      accountId,
+    )..addIds({ForwardIdSingleton.forwardIdSingleton.id});
+
+    final getForwardInvocation = requestBuilder.invocation(getForwardMethod);
+    final response = await (requestBuilder
+        ..usings(getForwardMethod.requiredCapabilities))
+      .build()
+      .execute();
+
+    final result = response.parse<GetForwardResponse>(
+      getForwardInvocation.methodCallId,
+      GetForwardResponse.deserialize);
+
+    final tMailForwardResult = result?.list.first;
+    if (tMailForwardResult == null) {
+      throw NotFoundForwardException();
+    }
+
+    return tMailForwardResult;
+  }
+
+  Future<TMailForward> updateForward(AccountId accountId, TMailForward forward) async {
+    final setForwardMethod = SetForwardMethod(accountId)
+      ..addUpdatesSingleton({
+        ForwardIdSingleton.forwardIdSingleton.id : forward
+      });
+
+    final processingInvocation = ProcessingInvocation();
+    final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation)
+      ..invocation(setForwardMethod);
+
+    final getForwardMethod = GetForwardMethod(accountId)
+      ..addIds({ForwardIdSingleton.forwardIdSingleton.id});
+    final getForwardInvocation = requestBuilder.invocation(getForwardMethod);
+
+    final response = await (requestBuilder
+        ..usings(setForwardMethod.requiredCapabilities))
+      .build()
+      .execute();
+
+    final getForwardResponse = response.parse<GetForwardResponse>(
+      getForwardInvocation.methodCallId,
+      GetForwardResponse.deserialize);
+
+    final newForward = getForwardResponse?.list.first;
+    if (newForward == null) {
+      throw NotFoundForwardException();
+    }
+
+    return newForward;
+  }
+}

lib/features/manage_account/data/network/manage_account_api.dart

@@ -1,10 +1,5 @@
 import 'dart:async';
 
-import 'package:forward/forward/forward_id.dart';
-import 'package:forward/forward/get/get_forward_method.dart';
-import 'package:forward/forward/get/get_forward_response.dart';
-import 'package:forward/forward/set/set_forward_method.dart';
-import 'package:forward/forward/tmail_forward.dart';
 import 'package:jmap_dart_client/http/http_client.dart';
 import 'package:jmap_dart_client/jmap/account_id.dart';
 import 'package:jmap_dart_client/jmap/core/id.dart';
@@ -15,7 +10,6 @@ import 'package:rule_filter/rule_filter/rule_filter_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/exceptions/forward_exception.dart';
 
 class ManageAccountAPI {
 
@@ -81,61 +75,4 @@ class ManageAccountAPI {
 
     return result?.list.first.rules ?? <TMailRule>[];
   }
-
-  Future<TMailForward> getForward(AccountId accountId) async {
-    final processingInvocation = ProcessingInvocation();
-    final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation);
-
-    final getForwardMethod = GetForwardMethod(
-      accountId,
-    )..addIds({ForwardIdSingleton.forwardIdSingleton.id});
-
-    final getForwardInvocation = requestBuilder.invocation(getForwardMethod);
-    final response = await (requestBuilder
-        ..usings(getForwardMethod.requiredCapabilities))
-      .build()
-      .execute();
-
-    final result = response.parse<GetForwardResponse>(
-        getForwardInvocation.methodCallId,
-        GetForwardResponse.deserialize);
-
-    final tMailForwardResult = result?.list.first;
-    if (tMailForwardResult == null) {
-      throw NotFoundForwardException();
-    }
-
-    return tMailForwardResult;
-  }
-
-  Future<TMailForward> updateForward(AccountId accountId, TMailForward forward) async {
-    final setForwardMethod = SetForwardMethod(accountId)
-      ..addUpdatesSingleton({
-        ForwardIdSingleton.forwardIdSingleton.id : forward
-      });
-
-    final processingInvocation = ProcessingInvocation();
-    final requestBuilder = JmapRequestBuilder(_httpClient, processingInvocation)
-      ..invocation(setForwardMethod);
-
-    final getForwardMethod = GetForwardMethod(accountId)
-      ..addIds({ForwardIdSingleton.forwardIdSingleton.id});
-    final getForwardInvocation = requestBuilder.invocation(getForwardMethod);
-
-    final response = await (requestBuilder
-        ..usings(setForwardMethod.requiredCapabilities))
-      .build()
-      .execute();
-
-    final getForwardResponse = response.parse<GetForwardResponse>(
-        getForwardInvocation.methodCallId,
-        GetForwardResponse.deserialize);
-
-    final newForward = getForwardResponse?.list.first;
-    if (newForward == null) {
-      throw NotFoundForwardException();
-    }
-
-    return newForward;
-  }
 }

lib/features/manage_account/data/repository/forwarding_repository_impl.dart

@@ -0,0 +1,33 @@
+import 'package:forward/forward/tmail_forward.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:tmail_ui_user/features/manage_account/data/datasource/forwarding_datasource.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/delete_recipient_in_forwarding_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/repository/forwarding_repository.dart';
+
+class ForwardingRepositoryImpl extends ForwardingRepository {
+  final ForwardingDataSource dataSource;
+
+  ForwardingRepositoryImpl(this.dataSource);
+
+  @override
+  Future<TMailForward> addRecipientsInForwarding(AccountId accountId, AddRecipientInForwardingRequest addRequest) {
+    return dataSource.addRecipientsInForwarding(accountId, addRequest);
+  }
+
+  @override
+  Future<TMailForward> deleteRecipientInForwarding(AccountId accountId, DeleteRecipientInForwardingRequest deleteRequest) {
+    return dataSource.deleteRecipientInForwarding(accountId, deleteRequest);
+  }
+
+  @override
+  Future<TMailForward> editLocalCopyInForwarding(AccountId accountId, EditLocalCopyInForwardingRequest editRequest) {
+    return dataSource.editLocalCopyInForwarding(accountId, editRequest);
+  }
+
+  @override
+  Future<TMailForward> getForward(AccountId accountId) {
+    return dataSource.getForward(accountId);
+  }
+}

lib/features/manage_account/data/repository/manage_account_repository_impl.dart

@@ -1,15 +1,11 @@
 import 'dart:ui';
 
-import 'package:forward/forward/tmail_forward.dart';
 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/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/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_local_copy_in_forwarding_request.dart';
 import 'package:tmail_ui_user/features/manage_account/domain/repository/manage_account_repository.dart';
 
 class ManageAccountRepositoryImpl extends ManageAccountRepository {
@@ -42,24 +38,4 @@ class ManageAccountRepositoryImpl extends ManageAccountRepository {
   Future<List<TMailRule>> editEmailRuleFilter(AccountId accountId, EditEmailRuleFilterRequest ruleFilterRequest) {
     return dataSource.editEmailRuleFilter(accountId, ruleFilterRequest);
   }
-
-  @override
-  Future<TMailForward> getForward(AccountId accountId) {
-    return dataSource.getForward(accountId);
-  }
-
-  @override
-  Future<TMailForward> deleteRecipientInForwarding(AccountId accountId, DeleteRecipientInForwardingRequest deleteRequest) {
-    return dataSource.deleteRecipientInForwarding(accountId, deleteRequest);
-  }
-
-  @override
-  Future<TMailForward> addRecipientsInForwarding(AccountId accountId, AddRecipientInForwardingRequest addRequest) {
-    return dataSource.addRecipientsInForwarding(accountId, addRequest);
-  }
-
-  @override
-  Future<TMailForward> editLocalCopyInForwarding(AccountId accountId, EditLocalCopyInForwardingRequest editRequest) {
-    return dataSource.editLocalCopyInForwarding(accountId, editRequest);
-  }
 }