TF-3082 Restore identity from cache

2024-08-22 09:13:04 +07:00
parent fdbbf855b6
commit 5a1fdbb123
20 changed files with 456 additions and 45 deletions
@@ -0,0 +1,31 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:core/utils/app_logger.dart';
+import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/user_name.dart';
+import 'package:tmail_ui_user/features/identity_creator/domain/repository/identity_creator_repository.dart';
+import 'package:tmail_ui_user/features/identity_creator/domain/state/get_identity_cache_on_web_state.dart';
+
+class GetIdentityCacheOnWebInteractor {
+  GetIdentityCacheOnWebInteractor(this._identityCreatorRepository);
+
+  final IdentityCreatorRepository _identityCreatorRepository;
+
+  Stream<Either<Failure, Success>> execute(
+    AccountId accountId,
+    UserName userName
+  ) async* {
+    try {
+      yield Right(GettingIdentityCacheOnWeb());
+      final result = await _identityCreatorRepository.getIdentityCacheOnWeb(
+        accountId,
+        userName);
+      
+      yield Right(GetIdentityCacheOnWebSuccess(result));
+    } catch (exception) {
+      logError("$runtimeType::execute: $exception");
+      yield Left(GetIdentityCacheOnWebFailure(exception: exception));
+    }
+  }
+}
@@ -0,0 +1,24 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:core/utils/app_logger.dart';
+import 'package:dartz/dartz.dart';
+import 'package:tmail_ui_user/features/identity_creator/domain/repository/identity_creator_repository.dart';
+import 'package:tmail_ui_user/features/identity_creator/domain/state/remove_identity_cache_on_web_state.dart';
+
+class RemoveIdentityCacheOnWebInteractor {
+  RemoveIdentityCacheOnWebInteractor(this._identityCreatorRepository);
+
+  final IdentityCreatorRepository _identityCreatorRepository;
+
+  Stream<Either<Failure, Success>> execute() async* {
+    try {
+      yield Right(RemovingIdentityCacheOnWeb());
+      await _identityCreatorRepository.removeIdentityCacheOnWeb();
+
+      yield Right(RemoveIdentityCacheOnWebSuccess());
+    } catch (exception) {
+      logError("$runtimeType::execute: $exception");
+      yield Left(RemoveIdentityCacheOnWebFailure(exception: exception));
+    }
+  }
+}