[Thread Detail] [Part 1] TF-3639 data layer and controller (#3645)

lib/features/thread_detail/domain/exceptions/empty_thread_detail_exception.dart

@@ -0,0 +1 @@
+class EmptyThreadDetailException implements Exception {}

lib/features/thread_detail/domain/repository/thread_detail_repository.dart

@@ -0,0 +1,9 @@
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+
+abstract class ThreadDetailRepository {
+  Future<List<EmailId>> getThreadById(
+    ThreadId threadId,
+    AccountId accountId,
+  );
+}

lib/features/thread_detail/domain/state/get_thread_by_id_state.dart

@@ -0,0 +1,18 @@
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+
+class GettingThreadById extends LoadingState {}
+
+class GetThreadByIdSuccess extends UIState {
+  final List<EmailId> emailIds;
+
+  GetThreadByIdSuccess(this.emailIds);
+
+  @override
+  List<Object> get props => [emailIds];
+}
+
+class GetThreadByIdFailure extends FeatureFailure {
+  GetThreadByIdFailure({super.exception});
+}

lib/features/thread_detail/domain/usecases/get_thread_by_id_interactor.dart

@@ -0,0 +1,37 @@
+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/mail/email/email.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/exceptions/empty_thread_detail_exception.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/repository/thread_detail_repository.dart';
+import 'package:tmail_ui_user/features/thread_detail/domain/state/get_thread_by_id_state.dart';
+
+class GetThreadByIdInteractor {
+  const GetThreadByIdInteractor(this._threadDetailRepository);
+
+  final ThreadDetailRepository _threadDetailRepository;
+
+  Stream<Either<Failure, Success>> execute(
+    ThreadId threadId,
+    AccountId accountId,
+  ) async* {
+    try {
+      yield Right(GettingThreadById());
+      final result = await _threadDetailRepository.getThreadById(
+        threadId,
+        accountId,
+      );
+
+      if (result.isEmpty) {
+        throw EmptyThreadDetailException();
+      }
+
+      yield Right(GetThreadByIdSuccess(result));
+    } catch (e) {
+      logError('GetEmailIdsByThreadIdInteractor::execute(): Exception: $e');
+      yield Left(GetThreadByIdFailure(exception: e));
+    }
+  }
+}