Add domain layer for get list Email in Mailbox
This commit is contained in:
@@ -0,0 +1,5 @@
|
|||||||
|
import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
|
||||||
|
|
||||||
|
class ThreadConstants {
|
||||||
|
static final defaultLimit = UnsignedInt(20);
|
||||||
|
}
|
||||||
@@ -0,0 +1,24 @@
|
|||||||
|
import 'package:jmap_dart_client/jmap/mail/email/email.dart';
|
||||||
|
import 'package:model/model.dart';
|
||||||
|
|
||||||
|
extension EmailExtension on Email {
|
||||||
|
|
||||||
|
PresentationEmail toPresentationEmail({SelectMode selectMode = SelectMode.INACTIVE}) {
|
||||||
|
return PresentationEmail(
|
||||||
|
id,
|
||||||
|
keywords: keywords,
|
||||||
|
size: size,
|
||||||
|
receivedAt: receivedAt,
|
||||||
|
hasAttachment: hasAttachment,
|
||||||
|
preview: preview,
|
||||||
|
subject: subject,
|
||||||
|
sentAt: sentAt,
|
||||||
|
from: from,
|
||||||
|
to: to,
|
||||||
|
cc: cc,
|
||||||
|
bcc: bcc,
|
||||||
|
replyTo: replyTo,
|
||||||
|
selectMode: selectMode
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -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 ThreadRepository {
|
||||||
|
Future<List<Email>> getAllEmail(
|
||||||
|
AccountId accountId,
|
||||||
|
{
|
||||||
|
int? position,
|
||||||
|
UnsignedInt? limit,
|
||||||
|
Set<Comparator>? sort,
|
||||||
|
Filter? filter,
|
||||||
|
Properties? properties
|
||||||
|
}
|
||||||
|
);
|
||||||
|
}
|
||||||
@@ -0,0 +1,20 @@
|
|||||||
|
import 'package:core/core.dart';
|
||||||
|
import 'package:model/model.dart';
|
||||||
|
|
||||||
|
class GetAllEmailSuccess extends UIState {
|
||||||
|
final List<PresentationEmail> emailList;
|
||||||
|
|
||||||
|
GetAllEmailSuccess(this.emailList);
|
||||||
|
|
||||||
|
@override
|
||||||
|
List<Object> get props => [emailList];
|
||||||
|
}
|
||||||
|
|
||||||
|
class GetAllEmailFailure extends FeatureFailure {
|
||||||
|
final exception;
|
||||||
|
|
||||||
|
GetAllEmailFailure(this.exception);
|
||||||
|
|
||||||
|
@override
|
||||||
|
List<Object> get props => [exception];
|
||||||
|
}
|
||||||
@@ -0,0 +1,43 @@
|
|||||||
|
import 'package:core/core.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/sort/comparator.dart';
|
||||||
|
import 'package:jmap_dart_client/jmap/core/unsigned_int.dart';
|
||||||
|
import 'package:tmail_ui_user/features/thread/domain/repository/thread_repository.dart';
|
||||||
|
import 'package:tmail_ui_user/features/thread/domain/state/get_all_email_state.dart';
|
||||||
|
import 'package:tmail_ui_user/features/thread/domain/extensions/email_extension.dart';
|
||||||
|
|
||||||
|
class GetEmailsInMailboxInteractor {
|
||||||
|
final ThreadRepository threadRepository;
|
||||||
|
|
||||||
|
GetEmailsInMailboxInteractor(this.threadRepository);
|
||||||
|
|
||||||
|
Stream<Either<Failure, Success>> execute(
|
||||||
|
AccountId accountId,
|
||||||
|
{
|
||||||
|
int? position,
|
||||||
|
UnsignedInt? limit,
|
||||||
|
Set<Comparator>? sort,
|
||||||
|
Filter? filter,
|
||||||
|
Properties? properties
|
||||||
|
}
|
||||||
|
) async* {
|
||||||
|
try {
|
||||||
|
yield Right<Failure, Success>(UIState.loading);
|
||||||
|
final emailList = await threadRepository.getAllEmail(
|
||||||
|
accountId,
|
||||||
|
position: position,
|
||||||
|
limit: limit,
|
||||||
|
sort: sort,
|
||||||
|
filter: filter,
|
||||||
|
properties: properties
|
||||||
|
);
|
||||||
|
final presentationEmailList = emailList.map((email) => email.toPresentationEmail()).toList();
|
||||||
|
yield Right<Failure, Success>(GetAllEmailSuccess(presentationEmailList));
|
||||||
|
} catch (e) {
|
||||||
|
yield Left(GetAllEmailFailure(e));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user