TF-32 Add domain layer of export attachment for ios platform

2021-09-16 09:46:14 +07:00
parent 20f98ce541
commit 0158142e45
15 changed files with 268 additions and 5 deletions
@@ -0,0 +1,29 @@
+
+import 'dart:io';
+
+import 'package:core/core.dart';
+import 'package:dio/dio.dart';
+
+class DownloadClient {
+
+  final DioClient _dioClient;
+
+  DownloadClient(this._dioClient);
+
+  Future<ResponseBody> downloadFile(
+      String url,
+      String baseAuth,
+      CancelToken? cancelToken,
+  ) async {
+    final headerParam = _dioClient.getHeaders();
+    headerParam[HttpHeaders.authorizationHeader] = baseAuth;
+    headerParam[HttpHeaders.acceptHeader] = DioClient.jmapHeader;
+
+    final responseBody = await _dioClient.get(
+      url,
+      options: Options(headers: headerParam, responseType: ResponseType.stream),
+      cancelToken: cancelToken);
+
+    return (responseBody as ResponseBody);
+  }
+}
@@ -0,0 +1,76 @@
+import 'dart:async';
+import 'dart:io';
+
+import 'package:core/core.dart';
+import 'package:core/data/network/download/download_client.dart';
+import 'package:dio/dio.dart';
+
+class DownloadManager {
+  final DownloadClient _downloadClient;
+
+  DownloadManager(this._downloadClient);
+
+  Future<String> downloadFile(
+      String downloadUrl,
+      Future<Directory> directoryToSave,
+      String filename,
+      String baseAuth,
+      {CancelToken? cancelToken}
+  ) async {
+    final streamController = StreamController<String>();
+
+    try {
+      await Future.wait([
+        _downloadClient.downloadFile(downloadUrl, baseAuth, cancelToken),
+        directoryToSave
+      ]).then((values) {
+        final fileStream = (values[0] as ResponseBody).stream;
+        final tempFilePath = '${(values[1] as Directory).absolute.path}/$filename';
+
+        final file = File(tempFilePath);
+        file.createSync(recursive: true);
+        var randomAccessFile = file.openSync(mode: FileMode.write);
+        late StreamSubscription subscription;
+
+        subscription = fileStream
+            .takeWhile((_) => cancelToken == null || !cancelToken.isCancelled)
+            .listen((data) {
+              subscription.pause();
+              randomAccessFile.writeFrom(data).then((_randomAccessFile) {
+                randomAccessFile = _randomAccessFile;
+                subscription.resume();
+                if (cancelToken != null && cancelToken.isCancelled) {
+                  streamController.sink.addError(CancelDownloadFileException(cancelToken.cancelError?.message));
+                }
+              }).catchError((error) async {
+                await subscription.cancel();
+                streamController.sink.addError(CommonDownloadFileException(error.toString()));
+                await streamController.close();
+              });
+        }, onDone: () async {
+          await randomAccessFile.close();
+          if (cancelToken != null && cancelToken.isCancelled) {
+            streamController.sink.addError(CancelDownloadFileException(cancelToken.cancelError?.message));
+          } else {
+            streamController.sink.add(tempFilePath);
+          }
+          await streamController.close();
+        }, onError: (error) async {
+          await randomAccessFile.close();
+          await file.delete();
+          streamController.sink.addError(CommonDownloadFileException(error.toString()));
+          await streamController.close();
+        });
+      });
+    } catch(exception) {
+      if (cancelToken != null && cancelToken.isCancelled) {
+        streamController.sink.addError(CancelDownloadFileException(cancelToken.cancelError?.message));
+        await streamController.close();
+        return streamController.stream.first;
+      } else {
+        throw exception;
+      }
+    }
+    return streamController.stream.first;
+  }
+}