TF-3042 Clean up public assets after identity is saved

2024-08-09 15:52:47 +07:00
parent 3b87d591e0
commit 7ea01d74bc
25 changed files with 538 additions and 22 deletions
@@ -0,0 +1,50 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
+import 'package:jmap_dart_client/jmap/identities/identity.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/extensions/public_asset_extension.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/repository/public_asset_repository.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/state/add_identity_to_public_assets_state.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/state/remove_identity_from_public_assets_state.dart';
+import 'package:tmail_ui_user/features/public_asset/presentation/public_asset_controller.dart';
+
+class AddIdentityToPublicAssetsInteractor {
+  AddIdentityToPublicAssetsInteractor(this._publicAssetRepository);
+
+  final PublicAssetRepository _publicAssetRepository;
+
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    {
+      required IdentityId identityId,
+      required List<PublicAssetId> publicAssetIds
+    }
+  ) async* {
+    try {
+      yield Right(AddingIdentityToPublicAssetsState());
+      final publicAssets = await _publicAssetRepository.getPublicAssetsFromIds(
+        session,
+        accountId,
+        publicAssetIds: publicAssetIds
+      );
+      if (publicAssets.isEmpty) {
+        yield Left(NotFoundAnyPublicAssetsFailureState());
+      } else {
+        final publicAssetsWithCurrentIdentity = publicAssets
+          .map((publicAsset) => publicAsset.withAddedIdentityId(identityId))
+          .toList();
+        await _publicAssetRepository.updatePublicAssets(
+          session,
+          accountId,
+          publicAssets: publicAssetsWithCurrentIdentity
+        );
+        yield Right(AddIdentityToPublicAssetsSuccessState());
+      }
+    } catch (exception) {
+      yield Left(AddIdentityToPublicAssetsFailureState(exception: exception));
+    }
+  }
+}
@@ -0,0 +1,124 @@
+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/session/session.dart';
+import 'package:jmap_dart_client/jmap/identities/identity.dart';
+import 'package:model/extensions/list_extension.dart';
+import 'package:rxdart/rxdart.dart';
+import 'package:tmail_ui_user/features/manage_account/presentation/model/identity_action_type.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/extensions/string_to_public_asset_extension.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/model/public_assets_in_identity_arguments.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/state/clean_up_public_assets_state.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/usecase/add_identity_to_public_assets_interactor.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/usecase/delete_public_assets_interactor.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/usecase/remove_identity_from_public_assets_interactor.dart';
+import 'package:tmail_ui_user/features/public_asset/presentation/public_asset_controller.dart';
+
+class CleanUpPublicAssetsInteractor {
+  CleanUpPublicAssetsInteractor(
+    this.removeIdentityFromPublicAssetsInteractor,
+    this.deletePublicAssetsInteractor,
+    this.addIdentityToPublicAssetsInteractor);
+
+  final RemoveIdentityFromPublicAssetsInteractor removeIdentityFromPublicAssetsInteractor;
+  final DeletePublicAssetsInteractor deletePublicAssetsInteractor;
+  final AddIdentityToPublicAssetsInteractor addIdentityToPublicAssetsInteractor;
+
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    {
+      required IdentityId identityId,
+      required IdentityActionType identityActionType,
+      required PublicAssetsInIdentityArguments publicAssetsInIdentityArguments,
+    }
+  ) async* {
+    try {
+      yield Right(CleaningUpPublicAssetsState());
+
+      final publicAssetIds = _filterPublicAssetsIdsForCleanUp(
+        identityId,
+        identityActionType,
+        publicAssetsInIdentityArguments);
+
+      await Rx.merge<Either<Failure, Success>>([
+        if (publicAssetIds.publicAssetsIdsToBeDereferenced.isNotEmpty)
+          removeIdentityFromPublicAssetsInteractor.execute(
+            session,
+            accountId,
+            identityId: identityId,
+            publicAssetIds: publicAssetIds.publicAssetsIdsToBeDereferenced),
+        if (publicAssetIds.publicAssetsIdsToBeDestroyed.isNotEmpty)
+          deletePublicAssetsInteractor.execute(
+            session,
+            accountId,
+            publicAssetIds: publicAssetIds.publicAssetsIdsToBeDestroyed),
+        if (publicAssetIds.publicAssetsIdsToBeReferenced.isNotEmpty)
+          addIdentityToPublicAssetsInteractor.execute(
+            session,
+            accountId,
+            identityId: identityId,
+            publicAssetIds: publicAssetIds.publicAssetsIdsToBeReferenced),
+      ]).last;
+
+      yield Right(CleanUpPublicAssetsSuccessState());
+
+    } catch (exception) {
+      logError('CleanUpPublicAssetsInteractor::execute():error: $exception');
+      yield Left(CleanUpPublicAssetsFailureState(exception: exception));
+    }
+  }
+
+  ({
+    List<PublicAssetId> publicAssetsIdsToBeDestroyed,
+    List<PublicAssetId> publicAssetsIdsToBeReferenced,
+    List<PublicAssetId> publicAssetsIdsToBeDereferenced, 
+  }) _filterPublicAssetsIdsForCleanUp(
+    IdentityId identityId,
+    IdentityActionType identityActionType,
+    PublicAssetsInIdentityArguments publicAssetsInIdentityArguments,
+  ) {
+    final htmlSignature = publicAssetsInIdentityArguments.htmlSignature;
+    final publicAssetIdsInSignature = htmlSignature.publicAssetIdsFromHtmlContent;
+    log('CleanUpPublicAssetsInteractor::publicAssetIdsInSignature: $publicAssetIdsInSignature');
+    final preExistingPublicAssetIds = publicAssetsInIdentityArguments.preExistingPublicAssetIds;
+    log('CleanUpPublicAssetsInteractor::preExistingPublicAssetIds: $preExistingPublicAssetIds');
+    final newlyPickedPublicAssetIds = publicAssetsInIdentityArguments.newlyPickedPublicAssetIds;
+    log('CleanUpPublicAssetsInteractor::newlyPickedPublicAssetIds: $newlyPickedPublicAssetIds');
+
+    final deletedPreExistingPublicAssetIds = List<PublicAssetId>.from(preExistingPublicAssetIds);
+    final notIncludedNewlyPickedPublicAssetIds = List<PublicAssetId>.from(newlyPickedPublicAssetIds);
+    final pastedPublicAssetIds = <PublicAssetId>[];
+    final newPublicAssetsIdsInSignature = <PublicAssetId>[];
+
+    for (var id in publicAssetIdsInSignature) {
+      deletedPreExistingPublicAssetIds.remove(id);
+      notIncludedNewlyPickedPublicAssetIds.remove(id);
+      
+      if (preExistingPublicAssetIds.notContains(id)
+        && newlyPickedPublicAssetIds.notContains(id)
+      ) {
+        pastedPublicAssetIds.add(id);
+      }
+
+      if (identityActionType == IdentityActionType.create 
+        && newlyPickedPublicAssetIds.contains(id)
+      ) {
+        newPublicAssetsIdsInSignature.add(id);
+      }
+    }
+
+    log('CleanUpPublicAssetsInteractor::deletedpreExistingPublicAssetIds: $deletedPreExistingPublicAssetIds');
+    log('CleanUpPublicAssetsInteractor::notIncludednewlyPickedPublicAssetIds: $notIncludedNewlyPickedPublicAssetIds');
+    log('CleanUpPublicAssetsInteractor::pastedPublicAssetIds: $pastedPublicAssetIds');
+    log('CleanUpPublicAssetsInteractor::newPublicAssetsIdsInSignature: $newPublicAssetsIdsInSignature');
+
+    return (
+      publicAssetsIdsToBeDestroyed: notIncludedNewlyPickedPublicAssetIds,
+      publicAssetsIdsToBeReferenced: pastedPublicAssetIds + newPublicAssetsIdsInSignature,
+      publicAssetsIdsToBeDereferenced: deletedPreExistingPublicAssetIds,
+    );
+  }
+}
@@ -0,0 +1,49 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
+import 'package:jmap_dart_client/jmap/identities/identity.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/extensions/public_asset_extension.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/repository/public_asset_repository.dart';
+import 'package:tmail_ui_user/features/public_asset/domain/state/remove_identity_from_public_assets_state.dart';
+import 'package:tmail_ui_user/features/public_asset/presentation/public_asset_controller.dart';
+
+class RemoveIdentityFromPublicAssetsInteractor {
+  RemoveIdentityFromPublicAssetsInteractor(this._publicAssetRepository);
+
+  final PublicAssetRepository _publicAssetRepository;
+
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    {
+      required IdentityId identityId,
+      required List<PublicAssetId> publicAssetIds
+    }
+  ) async* {
+    try {
+      yield Right(RemovingIdentityFromPublicAssetsState());
+      final publicAssets = await _publicAssetRepository.getPublicAssetsFromIds(
+        session,
+        accountId,
+        publicAssetIds: publicAssetIds
+      );
+      if (publicAssets.isEmpty) {
+        yield Left(NotFoundAnyPublicAssetsFailureState());
+      } else {
+        final publicAssetsWithCurrentIdentity = publicAssets
+          .map((publicAsset) => publicAsset.withRemovedIdentityId(identityId))
+          .toList();
+        await _publicAssetRepository.updatePublicAssets(
+          session,
+          accountId,
+          publicAssets: publicAssetsWithCurrentIdentity
+        );
+        yield Right(RemoveIdentityFromPublicAssetsSuccessState());
+      }
+    } catch (exception) {
+      yield Left(RemoveIdentityFromPublicAssetsFailureState(exception: exception));
+    }
+  }
+}