TF-3450 Add image attachment preview

2025-02-19 16:22:00 +07:00
parent 5cecdd2e6a
commit 3645fe58f9
7 changed files with 137 additions and 1 deletions
@@ -0,0 +1,31 @@
+import 'dart:typed_data';
+
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:model/email/attachment.dart';
+
+class GettingImageDataFromAttachment extends LoadingState {
+  GettingImageDataFromAttachment({required this.attachment});
+
+  final Attachment attachment;
+
+  @override
+  List<Object> get props => [attachment];
+}
+
+class GetImageDataFromAttachmentSuccess extends UIState {
+  GetImageDataFromAttachmentSuccess({
+    required this.attachment,
+    required this.data,
+  });
+
+  final Attachment attachment;
+  final Uint8List data;
+
+  @override
+  List<Object> get props => [attachment, data];
+}
+
+class GetImageDataFromAttachmentFailure extends FeatureFailure {
+  GetImageDataFromAttachmentFailure({super.exception});
+}
@@ -0,0 +1,62 @@
+import 'dart:async';
+
+import 'package:core/presentation/state/failure.dart';
+import 'package:core/presentation/state/success.dart';
+import 'package:core/utils/app_logger.dart';
+import 'package:dartz/dartz.dart';
+import 'package:dio/dio.dart';
+import 'package:jmap_dart_client/jmap/account_id.dart';
+import 'package:model/download/download_task_id.dart';
+import 'package:model/email/attachment.dart';
+import 'package:tmail_ui_user/features/email/domain/state/download_attachment_for_web_state.dart';
+import 'package:tmail_ui_user/features/email/domain/state/get_image_data_from_attachment_state.dart';
+import 'package:tmail_ui_user/features/email/domain/usecases/download_attachment_for_web_interactor.dart';
+
+class GetImageDataFromAttachmentInteractor {
+  const GetImageDataFromAttachmentInteractor(this._downloadAttachmentForWebInteractor);
+
+  final DownloadAttachmentForWebInteractor _downloadAttachmentForWebInteractor;
+
+  Stream<Either<Failure, Success>> execute(
+    DownloadTaskId taskId,
+    Attachment attachment,
+    AccountId accountId,
+    String baseDownloadUrl,
+    {CancelToken? cancelToken,}
+  ) async* {
+    final onProgressStream = StreamController<Either<Failure, Success>>();
+    try {
+      yield Right(GettingImageDataFromAttachment(attachment: attachment));
+      final downloadState = await _downloadAttachmentForWebInteractor.execute(
+        taskId,
+        attachment,
+        accountId,
+        baseDownloadUrl,
+        onProgressStream,
+        cancelToken: cancelToken,
+      ).last;
+
+      yield downloadState.fold(
+        (failure) {
+          return Left(GetImageDataFromAttachmentFailure(
+            exception: failure is FeatureFailure ? failure.exception : null,
+          ));
+        },
+        (success) {
+          if (success is! DownloadAttachmentForWebSuccess) {
+            return Left(GetImageDataFromAttachmentFailure());
+          }
+
+          return Right(GetImageDataFromAttachmentSuccess(
+            attachment: attachment,
+            data: success.bytes,
+          ));
+        },
+      );
+    } catch (e) {
+      logError('GetImageDataFromAttachmentInteractor::execute(): $e');
+      yield Left(GetImageDataFromAttachmentFailure(exception: e));
+    }
+    onProgressStream.close();
+  }
+}