From 38c47ca373346b3734a4dbf9242ef33cf376bea1 Mon Sep 17 00:00:00 2001
From: dab246 <tdvu@linagora.com>
Date: Wed, 26 Nov 2025 16:32:53 +0700
Subject: [PATCH] TF-4178 Add datasource/repository/interactor for create new
 label

---
 .../base/mixin/handle_error_mixin.dart        | 23 +++++++++++
 .../data/datasource/label_datasource.dart     |  2 +
 .../label_datasource_impl.dart                | 10 +++++
 .../labels/data/network/label_api.dart        | 38 ++++++++++++++++++-
 .../repository/label_repository_impl.dart     |  5 +++
 .../domain/repository/label_repository.dart   |  2 +
 .../domain/state/create_new_label_state.dart  | 18 +++++++++
 .../usecases/create_new_label_interactor.dart | 29 ++++++++++++++
 .../label_interactor_bindings.dart            |  3 +-
 .../mailbox/data/network/mailbox_api.dart     | 20 +---------
 10 files changed, 128 insertions(+), 22 deletions(-)
 create mode 100644 lib/features/labels/domain/state/create_new_label_state.dart
 create mode 100644 lib/features/labels/domain/usecases/create_new_label_interactor.dart

diff --git a/lib/features/base/mixin/handle_error_mixin.dart b/lib/features/base/mixin/handle_error_mixin.dart
index 153bf7108..242cfdd96 100644
--- a/lib/features/base/mixin/handle_error_mixin.dart
+++ b/lib/features/base/mixin/handle_error_mixin.dart
@@ -1,5 +1,6 @@
 import 'package:core/utils/app_logger.dart';
 import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/core/error/method/error_method_response.dart';
 import 'package:jmap_dart_client/jmap/core/error/set_error.dart';
 import 'package:jmap_dart_client/jmap/core/id.dart';
 import 'package:jmap_dart_client/jmap/core/method/response/set_response.dart';
@@ -76,4 +77,26 @@ mixin HandleSetErrorMixin {
     logWarning('HandleSetErrorMixin::handleSetResponse():remainedErrors: $remainedErrors');
     return remainedErrors;
   }
+
+  parseErrorForSetResponse(SetResponse? response, Id requestId) {
+    final mapError =
+        response?.notCreated ?? response?.notUpdated ?? response?.notDestroyed;
+    if (mapError != null && mapError.containsKey(requestId)) {
+      final setError = mapError[requestId];
+      log('HandleSetErrorMixin::parseErrorForSetResponse():setError: $setError');
+      if (setError?.type == ErrorMethodResponse.invalidArguments) {
+        throw InvalidArgumentsMethodResponse(
+          description: setError?.description,
+        );
+      } else if (setError?.type == ErrorMethodResponse.invalidResultReference) {
+        throw InvalidResultReferenceMethodResponse(
+          description: setError?.description,
+        );
+      } else {
+        throw UnknownMethodResponse(description: setError?.description);
+      }
+    } else {
+      throw UnknownMethodResponse();
+    }
+  }
 }
diff --git a/lib/features/labels/data/datasource/label_datasource.dart b/lib/features/labels/data/datasource/label_datasource.dart
index 49385740e..18e227e95 100644
--- a/lib/features/labels/data/datasource/label_datasource.dart
+++ b/lib/features/labels/data/datasource/label_datasource.dart
@@ -3,4 +3,6 @@ import 'package:labels/model/label.dart';
 
 abstract class LabelDatasource {
   Future<List<Label>> getAllLabels(AccountId accountId);
+
+  Future<Label> createNewLabel(AccountId accountId, Label labelData);
 }
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 0012ea5e4..22ad004c4 100644
--- a/lib/features/labels/data/datasource_impl/label_datasource_impl.dart
+++ b/lib/features/labels/data/datasource_impl/label_datasource_impl.dart
@@ -19,4 +19,14 @@ class LabelDatasourceImpl extends LabelDatasource {
       throw error;
     });
   }
+
+  @override
+  Future<Label> createNewLabel(AccountId accountId, Label labelData) {
+    return Future.sync(() async {
+      return await _labelApi.createNewLabel(accountId, labelData);
+    }).catchError((error, stackTrace) async {
+      await _exceptionThrower.throwException(error, stackTrace);
+      throw error;
+    });
+  }
 }
diff --git a/lib/features/labels/data/network/label_api.dart b/lib/features/labels/data/network/label_api.dart
index 9794083cb..df40fdf75 100644
--- a/lib/features/labels/data/network/label_api.dart
+++ b/lib/features/labels/data/network/label_api.dart
@@ -1,12 +1,16 @@
 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';
 import 'package:jmap_dart_client/jmap/jmap_request.dart';
 import 'package:labels/labels.dart';
+import 'package:tmail_ui_user/features/base/mixin/handle_error_mixin.dart';
+import 'package:uuid/uuid.dart';
 
-class LabelApi {
+class LabelApi with HandleSetErrorMixin {
   final HttpClient _httpClient;
+  final Uuid _uuid;
 
-  LabelApi(this._httpClient);
+  LabelApi(this._httpClient, this._uuid);
 
   Future<List<Label>> getAllLabels(AccountId accountId) async {
     final builder = JmapRequestBuilder(_httpClient, ProcessingInvocation());
@@ -23,4 +27,34 @@ class LabelApi {
 
     return response?.list ?? [];
   }
+
+  Future<Label> createNewLabel(AccountId accountId, Label labelData) async {
+    final generateCreateId = Id(_uuid.v1());
+
+    final method = SetLabelMethod(accountId)
+      ..addCreate(generateCreateId, labelData);
+
+    final builder = JmapRequestBuilder(_httpClient, ProcessingInvocation());
+    final invocation = builder.invocation(method);
+
+    final result =
+        await (builder..usings(method.requiredCapabilities)).build().execute();
+
+    final response = result.parse<SetLabelResponse>(
+      invocation.methodCallId,
+      SetLabelResponse.deserialize,
+    );
+
+    final labelCreated = response?.created?[generateCreateId];
+
+    if (labelCreated != null) {
+      final newLabelCreated = labelCreated.copyWith(
+        displayName: labelData.displayName,
+        color: labelData.color,
+      );
+      return newLabelCreated;
+    } else {
+      throw parseErrorForSetResponse(response, generateCreateId);
+    }
+  }
 }
diff --git a/lib/features/labels/data/repository/label_repository_impl.dart b/lib/features/labels/data/repository/label_repository_impl.dart
index f1cca9153..6e98799cd 100644
--- a/lib/features/labels/data/repository/label_repository_impl.dart
+++ b/lib/features/labels/data/repository/label_repository_impl.dart
@@ -12,4 +12,9 @@ class LabelRepositoryImpl extends LabelRepository {
   Future<List<Label>> getAllLabels(AccountId accountId) {
     return _labelDatasource.getAllLabels(accountId);
   }
+
+  @override
+  Future<Label> createNewLabel(AccountId accountId, Label labelData) {
+    return _labelDatasource.createNewLabel(accountId, labelData);
+  }
 }
diff --git a/lib/features/labels/domain/repository/label_repository.dart b/lib/features/labels/domain/repository/label_repository.dart
index 2ae7b15fd..9f3a9c1a9 100644
--- a/lib/features/labels/domain/repository/label_repository.dart
+++ b/lib/features/labels/domain/repository/label_repository.dart
@@ -3,4 +3,6 @@ import 'package:labels/model/label.dart';
 
 abstract class LabelRepository {
   Future<List<Label>> getAllLabels(AccountId accountId);
+
+  Future<Label> createNewLabel(AccountId accountId, Label labelData);
 }
diff --git a/lib/features/labels/domain/state/create_new_label_state.dart b/lib/features/labels/domain/state/create_new_label_state.dart
new file mode 100644
index 000000000..e9a8fe397
--- /dev/null
+++ b/lib/features/labels/domain/state/create_new_label_state.dart
@@ -0,0 +1,18 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:labels/model/label.dart';
+
+class CreatingNewLabel extends LoadingState {}
+
+class CreateNewLabelSuccess extends UIState {
+  final Label newLabel;
+
+  CreateNewLabelSuccess(this.newLabel);
+
+  @override
+  List<Object> get props => [newLabel];
+}
+
+class CreateNewLabelFailure extends FeatureFailure {
+  CreateNewLabelFailure(dynamic exception) : super(exception: exception);
+}
diff --git a/lib/features/labels/domain/usecases/create_new_label_interactor.dart b/lib/features/labels/domain/usecases/create_new_label_interactor.dart
new file mode 100644
index 000000000..1306de06c
--- /dev/null
+++ b/lib/features/labels/domain/usecases/create_new_label_interactor.dart
@@ -0,0 +1,29 @@
+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:labels/model/label.dart';
+import 'package:tmail_ui_user/features/labels/domain/repository/label_repository.dart';
+import 'package:tmail_ui_user/features/labels/domain/state/create_new_label_state.dart';
+
+class CreateNewLabelInteractor {
+  final LabelRepository _labelRepository;
+
+  CreateNewLabelInteractor(this._labelRepository);
+
+  Stream<Either<Failure, Success>> execute(
+    AccountId accountId,
+    Label labelData,
+  ) async* {
+    try {
+      yield Right(CreatingNewLabel());
+      final newLabel = await _labelRepository.createNewLabel(
+        accountId,
+        labelData,
+      );
+      yield Right(CreateNewLabelSuccess(newLabel));
+    } catch (e) {
+      yield Left(CreateNewLabelFailure(e));
+    }
+  }
+}
diff --git a/lib/features/labels/presentation/label_interactor_bindings.dart b/lib/features/labels/presentation/label_interactor_bindings.dart
index 5c60241fd..1f1384cd1 100644
--- a/lib/features/labels/presentation/label_interactor_bindings.dart
+++ b/lib/features/labels/presentation/label_interactor_bindings.dart
@@ -9,6 +9,7 @@ import 'package:tmail_ui_user/features/labels/domain/repository/label_repository
 import 'package:tmail_ui_user/features/labels/domain/usecases/get_all_label_interactor.dart';
 import 'package:tmail_ui_user/features/mailbox_creator/domain/usecases/verify_name_interactor.dart';
 import 'package:tmail_ui_user/main/exceptions/remote_exception_thrower.dart';
+import 'package:uuid/uuid.dart';
 
 class LabelInteractorBindings extends InteractorsBindings {
   @override
@@ -18,7 +19,7 @@ class LabelInteractorBindings extends InteractorsBindings {
 
   @override
   void bindingsDataSourceImpl() {
-    Get.lazyPut(() => LabelApi(Get.find<HttpClient>()));
+    Get.lazyPut(() => LabelApi(Get.find<HttpClient>(), Get.find<Uuid>()));
     Get.lazyPut(
       () => LabelDatasourceImpl(
         Get.find<LabelApi>(),
diff --git a/lib/features/mailbox/data/network/mailbox_api.dart b/lib/features/mailbox/data/network/mailbox_api.dart
index ca50b2865..997a809a5 100644
--- a/lib/features/mailbox/data/network/mailbox_api.dart
+++ b/lib/features/mailbox/data/network/mailbox_api.dart
@@ -10,7 +10,6 @@ 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/capability/capability_identifier.dart';
 import 'package:jmap_dart_client/jmap/core/capability/core_capability.dart';
-import 'package:jmap_dart_client/jmap/core/error/method/error_method_response.dart';
 import 'package:jmap_dart_client/jmap/core/error/set_error.dart';
 import 'package:jmap_dart_client/jmap/core/id.dart';
 import 'package:jmap_dart_client/jmap/core/patch_object.dart';
@@ -197,24 +196,7 @@ class MailboxAPI with HandleSetErrorMixin, MailAPIMixin {
           parentId: request.parentId);
       return newMailboxCreated;
     } else {
-      throw _parseErrorForSetMailboxResponse(setMailboxResponse, generateCreateId);
-    }
-  }
-
-  _parseErrorForSetMailboxResponse(SetMailboxResponse? response, Id requestId) {
-    final mapError = response?.notCreated ?? response?.notUpdated ?? response?.notDestroyed;
-    if (mapError != null && mapError.containsKey(requestId)) {
-      final setError = mapError[requestId];
-      log('MailboxAPI::_parseErrorForSetMailboxResponse():setError: $setError');
-      if (setError?.type == ErrorMethodResponse.invalidArguments) {
-        throw InvalidArgumentsMethodResponse(description: setError?.description);
-      } else if (setError?.type == ErrorMethodResponse.invalidResultReference) {
-        throw InvalidResultReferenceMethodResponse(description: setError?.description);
-      } else {
-        throw UnknownMethodResponse(description: setError?.description);
-      }
-    }  else {
-      throw UnknownMethodResponse();
+      throw parseErrorForSetResponse(setMailboxResponse, generateCreateId);
     }
   }