TF-2682 Create update always read receipt setting interactor

2024-03-07 15:14:06 +07:00
parent 0424d27d3f
commit ee49b7e377
3 changed files with 103 additions and 0 deletions
@@ -0,0 +1,17 @@
+import 'package:core/core.dart';
+
+class UpdatingAlwaysReadReceiptSetting extends LoadingState {}
+
+class UpdateAlwaysReadReceiptSettingSuccess extends UIState {
+  final bool isEnabled;
+
+  UpdateAlwaysReadReceiptSettingSuccess({required this.isEnabled});
+
+  @override
+  List<Object?> get props => [isEnabled];
+}
+
+class UpdateAlwaysReadReceiptSettingFailure extends FeatureFailure {
+  UpdateAlwaysReadReceiptSettingFailure(dynamic exception) 
+    : super(exception: exception);
+}
@@ -0,0 +1,31 @@
+import 'package:core/core.dart';
+import 'package:dartz/dartz.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:server_settings/server_settings/tmail_server_settings.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/update_always_read_receipt_setting_state.dart';
+
+class UpdateAlwaysReadReceiptSettingInteractor {
+  final ServerSettingsRepository _serverSettingsRepository;
+
+  UpdateAlwaysReadReceiptSettingInteractor(this._serverSettingsRepository);
+
+  Stream<Either<Failure, Success>> execute(
+    AccountId accountId, 
+    bool isEnabled
+  ) async* {
+    yield Right(UpdatingAlwaysReadReceiptSetting());
+    try {
+      final result = await _serverSettingsRepository.updateServerSettings(
+        accountId, 
+        TMailServerSettings(
+          settings: TMailServerSettingOptions(alwaysReadReceipts: isEnabled)
+        )
+      );
+      yield Right(UpdateAlwaysReadReceiptSettingSuccess(
+        isEnabled: result.settings?.alwaysReadReceipts ?? true));
+    } catch (e) {
+      yield Left(UpdateAlwaysReadReceiptSettingFailure(e));
+    }
+  }
+}