Add data layer for get list Email in Mailbox

lib/features/thread/data/datasource/thread_datasource.dart

@@ -0,0 +1,19 @@
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/filter/filter.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+
+abstract class ThreadDataSource {
+  Future<List<Email>> getAllEmail(
+    AccountId accountId,
+    {
+      int? position,
+      UnsignedInt? limit,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  );
+}

lib/features/thread/data/datasource_impl/thread_datasource_impl.dart

@@ -0,0 +1,39 @@
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/filter/filter.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:tmail_ui_user/features/thread/data/datasource/thread_datasource.dart';
+import 'package:tmail_ui_user/features/thread/data/network/thread_api.dart';
+
+class ThreadDataSourceImpl extends ThreadDataSource {
+
+  final ThreadAPI threadAPI;
+
+  ThreadDataSourceImpl(this.threadAPI);
+
+  @override
+  Future<List<Email>> getAllEmail(
+    AccountId accountId,
+    {
+      int? position,
+      UnsignedInt? limit,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  ) {
+    return Future.sync(() async {
+      return await threadAPI.getAllEmail(
+        accountId,
+        position: position,
+        limit: limit,
+        sort: sort,
+        filter: filter,
+        properties: properties);
+    }).catchError((error) {
+      throw error;
+    });
+  }
+}

lib/features/thread/data/network/thread_api.dart

@@ -0,0 +1,68 @@
+import 'dart:async';
+
+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/filter/filter.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/request/reference_path.dart';
+import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/jmap_request.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:jmap_dart_client/jmap/mail/email/get/get_email_method.dart';
+import 'package:jmap_dart_client/jmap/mail/email/get/get_email_response.dart';
+import 'package:jmap_dart_client/jmap/mail/email/query/query_email_method.dart';
+
+class ThreadAPI {
+
+  final HttpClient httpClient;
+
+  ThreadAPI(this.httpClient);
+
+  Future<List<Email>> getAllEmail(
+    AccountId accountId,
+    {
+      int? position,
+      UnsignedInt? limit,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  ) async {
+    final processingInvocation = ProcessingInvocation();
+
+    final jmapRequestBuilder = JmapRequestBuilder(httpClient, processingInvocation);
+
+    final queryEmailMethod = QueryEmailMethod(accountId);
+
+    if (position != null) queryEmailMethod..addPosition(position);
+
+    if (limit != null) queryEmailMethod..addLimit(limit);
+
+    if (sort != null) queryEmailMethod..addSorts(sort);
+
+    if (filter != null) queryEmailMethod..addFilters(filter);
+
+    final queryEmailInvocation = jmapRequestBuilder.invocation(queryEmailMethod);
+
+    final getEmailMethod = GetEmailMethod(accountId);
+
+    if (properties != null) getEmailMethod..addProperties(properties);
+
+    getEmailMethod..addReferenceIds(processingInvocation.createResultReference(
+      queryEmailInvocation.methodCallId,
+      ReferencePath.idsPath));
+
+    final getEmailInvocation = jmapRequestBuilder.invocation(getEmailMethod);
+
+    final result = await (jmapRequestBuilder
+        ..usings(getEmailMethod.requiredCapabilities))
+      .build()
+      .execute();
+
+    final resultList = result.parse<GetEmailResponse>(
+        getEmailInvocation.methodCallId, GetEmailResponse.deserialize);
+
+    return resultList == null ? [] : resultList.list;
+  }
+}

lib/features/thread/data/repository/thread_repository_impl.dart

@@ -0,0 +1,37 @@
+
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:jmap_dart_client/jmap/core/filter/filter.dart';
+import 'package:jmap_dart_client/jmap/core/properties/properties.dart';
+import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
+import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
+import 'package:jmap_dart_client/jmap/mail/email/email.dart';
+import 'package:tmail_ui_user/features/thread/data/datasource/thread_datasource.dart';
+import 'package:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
+
+class ThreadRepositoryImpl extends ThreadRepository {
+
+  final ThreadDataSource threadDataSource;
+
+  ThreadRepositoryImpl(this.threadDataSource);
+
+  @override
+  Future<List<Email>> getAllEmail(
+    AccountId accountId,
+    {
+      int? position,
+      UnsignedInt? limit,
+      Set<Comparator>? sort,
+      Filter? filter,
+      Properties? properties
+    }
+  ) {
+    return threadDataSource.getAllEmail(
+      accountId,
+      position: position,
+      limit: limit,
+      sort: sort,
+      filter: filter,
+      properties: properties
+    );
+  }
+}