From c49e48ae1bf57595e8eec000eb2a4cfbdd57d82e Mon Sep 17 00:00:00 2001
From: dab246 <tdvu@linagora.com>
Date: Tue, 3 Feb 2026 18:15:25 +0700
Subject: [PATCH] feat: Add repository/interactor for get label changes

---
 .../data/datasource/label_datasource.dart     |  9 ++++
 .../label_datasource_impl.dart                | 18 +++++++
 .../repository/label_repository_impl.dart     | 49 +++++++++++++++++++
 .../domain/model/label_changes_result.dart    | 26 ++++++++++
 .../domain/repository/label_repository.dart   |  9 ++++
 .../domain/state/get_label_changes_state.dart | 18 +++++++
 .../get_label_changes_interactor.dart         | 32 ++++++++++++
 .../mailbox/data/network/mailbox_api.dart     |  3 +-
 8 files changed, 163 insertions(+), 1 deletion(-)
 create mode 100644 lib/features/labels/domain/model/label_changes_result.dart
 create mode 100644 lib/features/labels/domain/state/get_label_changes_state.dart
 create mode 100644 lib/features/labels/domain/usecases/get_label_changes_interactor.dart

diff --git a/lib/features/labels/data/datasource/label_datasource.dart b/lib/features/labels/data/datasource/label_datasource.dart
index 58fc28010..3536817cd 100644
--- a/lib/features/labels/data/datasource/label_datasource.dart
+++ b/lib/features/labels/data/datasource/label_datasource.dart
@@ -1,6 +1,9 @@
 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/core/state.dart';
 import 'package:labels/model/label.dart';
 import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
+import 'package:tmail_ui_user/features/labels/data/model/label_change_response.dart';
 
 abstract class LabelDatasource {
   Future<List<Label>> getAllLabels(AccountId accountId);
@@ -10,4 +13,10 @@ abstract class LabelDatasource {
   Future<Label> editLabel(AccountId accountId, EditLabelRequest labelRequest);
 
   Future<void> deleteLabel(AccountId accountId, Label label);
+
+  Future<LabelChangeResponse> getLabelChanges(
+    Session session,
+    AccountId accountId,
+    State sinceState,
+  );
 }
diff --git a/lib/features/labels/data/datasource_impl/label_datasource_impl.dart b/lib/features/labels/data/datasource_impl/label_datasource_impl.dart
index 784c37f53..6c50e1a0c 100644
--- a/lib/features/labels/data/datasource_impl/label_datasource_impl.dart
+++ b/lib/features/labels/data/datasource_impl/label_datasource_impl.dart
@@ -1,6 +1,9 @@
 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/core/state.dart';
 import 'package:labels/model/label.dart';
 import 'package:tmail_ui_user/features/labels/data/datasource/label_datasource.dart';
+import 'package:tmail_ui_user/features/labels/data/model/label_change_response.dart';
 import 'package:tmail_ui_user/features/labels/data/network/label_api.dart';
 import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
 import 'package:tmail_ui_user/main/exceptions/exception_thrower.dart';
@@ -38,4 +41,19 @@ class LabelDatasourceImpl extends LabelDatasource {
       return await _labelApi.deleteLabel(accountId, label);
     }).catchError(_exceptionThrower.throwException);
   }
+
+  @override
+  Future<LabelChangeResponse> getLabelChanges(
+    Session session,
+    AccountId accountId,
+    State sinceState,
+  ) {
+    return Future.sync(() async {
+      return await _labelApi.getLabelChangesWithResult(
+        session,
+        accountId,
+        sinceState,
+      );
+    }).catchError(_exceptionThrower.throwException);
+  }
 }
diff --git a/lib/features/labels/data/repository/label_repository_impl.dart b/lib/features/labels/data/repository/label_repository_impl.dart
index 7e59c39ca..35ac2a84d 100644
--- a/lib/features/labels/data/repository/label_repository_impl.dart
+++ b/lib/features/labels/data/repository/label_repository_impl.dart
@@ -1,7 +1,11 @@
 import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/id.dart';
+import 'package:jmap_dart_client/jmap/core/session/session.dart';
+import 'package:jmap_dart_client/jmap/core/state.dart';
 import 'package:labels/model/label.dart';
 import 'package:tmail_ui_user/features/labels/data/datasource/label_datasource.dart';
 import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
+import 'package:tmail_ui_user/features/labels/domain/model/label_changes_result.dart';
 import 'package:tmail_ui_user/features/labels/domain/repository/label_repository.dart';
 
 class LabelRepositoryImpl extends LabelRepository {
@@ -28,4 +32,49 @@ class LabelRepositoryImpl extends LabelRepository {
   Future<void> deleteLabel(AccountId accountId, Label label) {
     return _labelDatasource.deleteLabel(accountId, label);
   }
+
+  @override
+  Future<LabelChangesResult> getLabelChanges(
+    Session session,
+    AccountId accountId,
+    State sinceState,
+  ) async {
+    bool hasMoreChanges = true;
+    State? newSinceState = sinceState;
+    List<Label> createdLabels = [];
+    List<Label> updatedLabels = [];
+    List<Id> destroyedLabelIds = [];
+    State? newState;
+
+    while (hasMoreChanges && newSinceState != null) {
+      final changesResponse = await _labelDatasource.getLabelChanges(
+        session,
+        accountId,
+        sinceState,
+      );
+
+      hasMoreChanges = changesResponse.hasMoreChanges;
+      newSinceState = changesResponse.newStateChanges;
+
+      if (changesResponse.created?.isNotEmpty == true) {
+        createdLabels.addAll(changesResponse.created!);
+      }
+      if (changesResponse.updated?.isNotEmpty == true) {
+        updatedLabels.addAll(changesResponse.updated!);
+      }
+      if (changesResponse.destroyed?.isNotEmpty == true) {
+        destroyedLabelIds.addAll(changesResponse.destroyed!);
+      }
+      if (changesResponse.newStateChanges != null) {
+        newState = changesResponse.newStateChanges!;
+      }
+    }
+
+    return LabelChangesResult(
+      createdLabels: createdLabels,
+      updatedLabels: updatedLabels,
+      destroyedLabelIds: destroyedLabelIds,
+      newState: newState,
+    );
+  }
 }
diff --git a/lib/features/labels/domain/model/label_changes_result.dart b/lib/features/labels/domain/model/label_changes_result.dart
new file mode 100644
index 000000000..9e4ffcc8b
--- /dev/null
+++ b/lib/features/labels/domain/model/label_changes_result.dart
@@ -0,0 +1,26 @@
+import 'package:equatable/equatable.dart';
+import 'package:jmap_dart_client/jmap/core/id.dart';
+import 'package:jmap_dart_client/jmap/core/state.dart';
+import 'package:labels/model/label.dart';
+
+class LabelChangesResult with EquatableMixin {
+  final List<Label> createdLabels;
+  final List<Label> updatedLabels;
+  final List<Id> destroyedLabelIds;
+  final State? newState;
+
+  LabelChangesResult({
+    required this.createdLabels,
+    required this.updatedLabels,
+    required this.destroyedLabelIds,
+    required this.newState,
+  });
+
+  @override
+  List<Object?> get props => [
+    createdLabels,
+    updatedLabels,
+    destroyedLabelIds,
+    newState,
+  ];
+}
diff --git a/lib/features/labels/domain/repository/label_repository.dart b/lib/features/labels/domain/repository/label_repository.dart
index df7bd5715..8a11e1d78 100644
--- a/lib/features/labels/domain/repository/label_repository.dart
+++ b/lib/features/labels/domain/repository/label_repository.dart
@@ -1,6 +1,9 @@
 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/core/state.dart';
 import 'package:labels/model/label.dart';
 import 'package:tmail_ui_user/features/labels/domain/model/edit_label_request.dart';
+import 'package:tmail_ui_user/features/labels/domain/model/label_changes_result.dart';
 
 abstract class LabelRepository {
   Future<List<Label>> getAllLabels(AccountId accountId);
@@ -10,4 +13,10 @@ abstract class LabelRepository {
   Future<Label> editLabel(AccountId accountId, EditLabelRequest labelRequest);
 
   Future<void> deleteLabel(AccountId accountId, Label label);
+
+  Future<LabelChangesResult> getLabelChanges(
+    Session session,
+    AccountId accountId,
+    State sinceState,
+  );
 }
diff --git a/lib/features/labels/domain/state/get_label_changes_state.dart b/lib/features/labels/domain/state/get_label_changes_state.dart
new file mode 100644
index 000000000..bdbb3efdd
--- /dev/null
+++ b/lib/features/labels/domain/state/get_label_changes_state.dart
@@ -0,0 +1,18 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:tmail_ui_user/features/labels/domain/model/label_changes_result.dart';
+
+class GettingLabelChanges extends LoadingState {}
+
+class GetLabelChangesSuccess extends UIState {
+  final LabelChangesResult changesResult;
+
+  GetLabelChangesSuccess(this.changesResult);
+
+  @override
+  List<Object> get props => [changesResult];
+}
+
+class GetLabelChangesFailure extends FeatureFailure {
+  GetLabelChangesFailure(dynamic exception) : super(exception: exception);
+}
diff --git a/lib/features/labels/domain/usecases/get_label_changes_interactor.dart b/lib/features/labels/domain/usecases/get_label_changes_interactor.dart
new file mode 100644
index 000000000..68594e33c
--- /dev/null
+++ b/lib/features/labels/domain/usecases/get_label_changes_interactor.dart
@@ -0,0 +1,32 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:dartz/dartz.dart' hide State;
+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/core/state.dart';
+import 'package:tmail_ui_user/features/labels/domain/repository/label_repository.dart';
+import 'package:tmail_ui_user/features/labels/domain/state/get_label_changes_state.dart';
+
+class GetLabelChangesInteractor {
+  final LabelRepository _labelRepository;
+
+  GetLabelChangesInteractor(this._labelRepository);
+
+  Stream<Either<Failure, Success>> execute(
+    Session session,
+    AccountId accountId,
+    State sinceState,
+  ) async* {
+    try {
+      yield Right(GettingLabelChanges());
+      final changesResult = await _labelRepository.getLabelChanges(
+        session,
+        accountId,
+        sinceState,
+      );
+      yield Right(GetLabelChangesSuccess(changesResult));
+    } catch (e) {
+      yield Left(GetLabelChangesFailure(e));
+    }
+  }
+}
diff --git a/lib/features/mailbox/data/network/mailbox_api.dart b/lib/features/mailbox/data/network/mailbox_api.dart
index 997a809a5..126ff3f39 100644
--- a/lib/features/mailbox/data/network/mailbox_api.dart
+++ b/lib/features/mailbox/data/network/mailbox_api.dart
@@ -35,6 +35,7 @@ import 'package:model/mailbox/mailbox_constants.dart';
 import 'package:model/model.dart';
 import 'package:tmail_ui_user/features/base/mixin/handle_error_mixin.dart';
 import 'package:tmail_ui_user/features/base/mixin/mail_api_mixin.dart';
+import 'package:tmail_ui_user/features/base/mixin/session_mixin.dart';
 import 'package:tmail_ui_user/features/composer/domain/exceptions/set_method_exception.dart';
 import 'package:tmail_ui_user/features/mailbox/data/model/mailbox_change_response.dart';
 import 'package:tmail_ui_user/features/mailbox/domain/exceptions/mailbox_exception.dart';
@@ -55,7 +56,7 @@ import 'package:tmail_ui_user/features/mailbox/domain/model/subscribe_multiple_m
 import 'package:tmail_ui_user/main/error/capability_validator.dart';
 import 'package:uuid/uuid.dart';
 
-class MailboxAPI with HandleSetErrorMixin, MailAPIMixin {
+class MailboxAPI with HandleSetErrorMixin, SessionMixin, MailAPIMixin {
 
   final HttpClient httpClient;
   final Uuid _uuid;