TF-48 Implement save email address to local storage

lib/features/composer/data/datasource/composer_datasource.dart

@@ -0,0 +1,5 @@
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+
+abstract class ComposerDataSource {
+  Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress);
+}

lib/features/composer/data/datasource_impl/composer_datasource_impl.dart

@@ -0,0 +1,12 @@
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+import 'package:tmail_ui_user/features/composer/data/datasource/composer_datasource.dart';
+
+class ComposerDataSourceImpl extends ComposerDataSource {
+
+  ComposerDataSourceImpl();
+
+  @override
+  Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress) {
+    throw UnimplementedError();
+  }
+}

lib/features/composer/data/datasource_impl/local_composer_datasource_impl.dart

@@ -0,0 +1,19 @@
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+import 'package:tmail_ui_user/features/composer/data/datasource/composer_datasource.dart';
+import 'package:tmail_ui_user/features/composer/data/local/email_address_database_manager.dart';
+
+class LocalComposerDataSourceImpl extends ComposerDataSource {
+
+  final EmailAddressDatabaseManager emailAddressDatabaseManager;
+
+  LocalComposerDataSourceImpl(this.emailAddressDatabaseManager);
+
+  @override
+  Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress) {
+    return Future.sync(() async {
+      return await emailAddressDatabaseManager.insertMultipleData(listEmailAddress);
+    }).catchError((error) {
+      throw error;
+    });
+  }
+}

lib/features/composer/data/local/email_address_database_manager.dart

@@ -0,0 +1,81 @@
+
+import 'package:core/core.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+import 'package:model/model.dart';
+
+class EmailAddressDatabaseManager implements DatabaseManager<EmailAddress> {
+  final DatabaseClient _databaseClient;
+
+  EmailAddressDatabaseManager(this._databaseClient);
+
+  @override
+  Future<bool> deleteData(String key) async {
+    final res = await _databaseClient.deleteData(EmailAddressTable.TABLE_NAME, EmailAddressTable.EMAIL, key);
+    return res > 0 ? true : false;
+  }
+
+  @override
+  Future<EmailAddress?> getData(String key) async {
+    final res = await _databaseClient.getData(EmailAddressTable.TABLE_NAME, EmailAddressTable.EMAIL, key);
+    return res.isNotEmpty ? EmailAddressCache.fromJson(res.first).toEmailAddress() : null;
+  }
+
+  @override
+  Future<List<EmailAddress>> getListData({String? word, int? limit, String? orderBy}) async {
+    final res = await _databaseClient.getListData(EmailAddressTable.TABLE_NAME, limit: limit ?? 10, orderBy: orderBy ?? EmailAddressTable.NAME);
+    return res.isNotEmpty
+      ? res.map((mapObject) => EmailAddressCache.fromJson(mapObject).toEmailAddress()).toList()
+      : [];
+  }
+
+  @override
+  Future<bool> insertData(EmailAddress emailAddress) async {
+    final res = await _databaseClient.insertData(EmailAddressTable.TABLE_NAME, emailAddress.toEmailAddressCache().toJson());
+    return res > 0 ? true : false;
+  }
+
+  @override
+  Future<bool> updateData(EmailAddress emailAddress) async {
+    final res = await _databaseClient.updateData(
+      EmailAddressTable.TABLE_NAME,
+      EmailAddressTable.EMAIL,
+      emailAddress.getEmail(),
+      emailAddress.toEmailAddressCache().toJson());
+    return res > 0 ? true : false;
+  }
+
+  @override
+  Future<bool> insertMultipleData(List<EmailAddress> listObject) async {
+    final listEmailAddressNotExist = await Future.wait(listObject
+      .map((emailAddress) async {
+        final emailAddressExist = await _databaseClient.getData(
+            EmailAddressTable.TABLE_NAME,
+            EmailAddressTable.EMAIL,
+            emailAddress.email ?? '');
+        return emailAddressExist.isEmpty ? emailAddress : null;})
+      .toList());
+
+    listEmailAddressNotExist.removeWhere((element) => element == null);
+
+    final mapObjects = listEmailAddressNotExist
+      .map((emailAddress) => emailAddress!.toEmailAddressCache().toJson())
+      .toList();
+
+    final res = await _databaseClient.insertMultipleData(EmailAddressTable.TABLE_NAME, mapObjects);
+    return res.isNotEmpty ? true : false;
+  }
+
+  @override
+  Future<List<EmailAddress>> getListDataWithCondition(String condition, {String? word, int? limit, String? orderBy}) async {
+    final sqlQuery = 'SELECT * FROM ${EmailAddressTable.TABLE_NAME} '
+        'WHERE $condition '
+        'ORDER BY ${orderBy ?? EmailAddressTable.NAME} '
+        'LIMIT ${limit ?? 10}';
+
+    final res = await _databaseClient.getDataBySql(sqlQuery);
+
+    return res.isNotEmpty
+      ? res.map((mapObject) => EmailAddressCache.fromJson(mapObject).toEmailAddress()).toList()
+      : [];
+  }
+}

lib/features/composer/data/repository/composer_repository_impl.dart

@@ -0,0 +1,17 @@
+
+import 'package:core/core.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+import 'package:tmail_ui_user/features/composer/data/datasource/composer_datasource.dart';
+import 'package:tmail_ui_user/features/composer/domain/repository/composer_repository.dart';
+
+class ComposerRepositoryImpl extends ComposerRepository {
+
+  final Map<DataSourceType, ComposerDataSource> composerDataSources;
+
+  ComposerRepositoryImpl(this.composerDataSources);
+
+  @override
+  Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress) {
+    return composerDataSources[DataSourceType.local]!.saveEmailAddresses(listEmailAddress);
+  }
+}

lib/features/composer/domain/repository/composer_repository.dart

@@ -0,0 +1,5 @@
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+
+abstract class ComposerRepository {
+  Future<bool> saveEmailAddresses(List<EmailAddress> listEmailAddress);
+}

lib/features/composer/domain/state/save_email_address_state.dart

@@ -0,0 +1,18 @@
+import 'package:core/core.dart';
+
+class SaveEmailAddressSuccess extends UIState {
+
+  SaveEmailAddressSuccess();
+
+  @override
+  List<Object?> get props => [];
+}
+
+class SaveEmailAddressFailure extends FeatureFailure {
+  final exception;
+
+  SaveEmailAddressFailure(this.exception);
+
+  @override
+  List<Object> get props => [exception];
+}

lib/features/composer/domain/usecases/save_email_addresses_interactor.dart

@@ -0,0 +1,20 @@
+import 'package:core/core.dart';
+import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email_address.dart';
+import 'package:tmail_ui_user/features/composer/domain/repository/composer_repository.dart';
+import 'package:tmail_ui_user/features/composer/domain/state/save_email_address_state.dart';
+
+class SaveEmailAddressesInteractor {
+  final ComposerRepository composerRepository;
+
+  SaveEmailAddressesInteractor(this.composerRepository);
+
+  Future<Either<Failure, Success>> execute(List<EmailAddress> emailAddress) async {
+    try {
+      final result = await composerRepository.saveEmailAddresses(emailAddress);
+      return result ? Right(SaveEmailAddressSuccess()) : Left(SaveEmailAddressFailure(result));
+    } catch (e) {
+      return Left(SaveEmailAddressFailure(e));
+    }
+  }
+}