TF-2681 Create get always read receipt setting interactor

This commit is contained in:
DatDang
2024-03-07 11:18:16 +07:00
committed by Dat H. Pham
parent 1f1327471d
commit f856981053
3 changed files with 96 additions and 0 deletions
@@ -0,0 +1,18 @@
import 'package:core/presentation/state/failure.dart';
import 'package:core/presentation/state/success.dart';
class GettingAlwaysReadReceiptSetting extends LoadingState {}
class GetAlwaysReadReceiptSettingSuccess extends UIState {
final bool alwaysReadReceiptEnabled;
GetAlwaysReadReceiptSettingSuccess({required this.alwaysReadReceiptEnabled});
@override
List<Object?> get props => [alwaysReadReceiptEnabled];
}
class GetAlwaysReadReceiptSettingFailure extends FeatureFailure {
GetAlwaysReadReceiptSettingFailure(dynamic exception)
: super(exception: exception);
}
@@ -0,0 +1,23 @@
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:tmail_ui_user/features/server_settings/domain/repository/server_settings_repository.dart';
import 'package:tmail_ui_user/features/server_settings/domain/state/get_always_read_receipt_setting_state.dart';
class GetAlwaysReadReceiptSettingInteractor {
final ServerSettingsRepository _serverSettingsRepository;
GetAlwaysReadReceiptSettingInteractor(this._serverSettingsRepository);
Stream<Either<Failure, Success>> execute(AccountId accountId) async* {
try {
yield Right(GettingAlwaysReadReceiptSetting());
final result = await _serverSettingsRepository.getServerSettings(accountId);
yield Right(GetAlwaysReadReceiptSettingSuccess(
alwaysReadReceiptEnabled: result.settings?.alwaysReadReceipts ?? true));
} catch (e) {
yield Left(GetAlwaysReadReceiptSettingFailure(e));
}
}
}