TF-138 Add domain layer for search mail with text pattern

This commit is contained in:
dab246
2021-10-26 13:17:12 +07:00
committed by Dat H. Pham
parent 03f5921025
commit 62d416c4a4
11 changed files with 254 additions and 4 deletions
@@ -0,0 +1,11 @@
import 'package:equatable/equatable.dart';
class SearchQuery with EquatableMixin {
final String value;
SearchQuery(this.value);
@override
List<Object?> get props => [value];
}
@@ -4,6 +4,7 @@ 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/state.dart' as jmap;
import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
import 'package:jmap_dart_client/jmap/mail/mailbox/mailbox.dart';
import 'package:model/model.dart';
import 'package:tmail_ui_user/features/thread/domain/model/email_response.dart';
@@ -40,4 +41,14 @@ abstract class ThreadRepository {
Properties? properties,
}
);
Future<List<Email>> searchEmails(
AccountId accountId,
{
UnsignedInt? limit,
Set<Comparator>? sort,
Filter? filter,
Properties? properties,
}
);
}
@@ -0,0 +1,39 @@
import 'package:core/core.dart';
import 'package:model/email/presentation_email.dart';
import 'package:tmail_ui_user/features/thread/domain/model/search_query.dart';
class SearchingState extends UIState {
SearchingState();
@override
List<Object> get props => [];
}
class SearchEmailNewQuery extends UIState {
final SearchQuery searchQuery;
SearchEmailNewQuery(this.searchQuery);
@override
List<Object> get props => [searchQuery];
}
class SearchEmailSuccess extends UIState {
final List<PresentationEmail> emailList;
SearchEmailSuccess(this.emailList);
@override
List<Object> get props => [emailList];
}
class SearchEmailFailure extends FeatureFailure {
final exception;
SearchEmailFailure(this.exception);
@override
List<Object> get props => [exception];
}
@@ -0,0 +1,47 @@
import 'package:core/core.dart';
import 'package:model/model.dart';
import 'package:dartz/dartz.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/unsigned_int.dart';
import 'package:jmap_dart_client/jmap/core/sort/comparator.dart';
import 'package:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
import 'package:tmail_ui_user/features/thread/domain/state/search_email_state.dart';
class SearchEmailInteractor {
final ThreadRepository threadRepository;
SearchEmailInteractor(this.threadRepository);
Stream<Either<Failure, Success>> execute(
AccountId accountId,
{
UnsignedInt? limit,
Set<Comparator>? sort,
Filter? filter,
Properties? properties,
}
) async* {
try {
yield Right(SearchingState());
final emailList = await threadRepository.searchEmails(
accountId,
limit: limit,
sort: sort,
filter: filter,
properties: properties);
final presentationEmailList = emailList
.map((email) => email.toPresentationEmail())
.toList();
yield Right(SearchEmailSuccess(presentationEmailList));
} catch (e) {
yield Left(SearchEmailFailure(e));
}
}
}