PE-4885: use new downloader on share file page

lib/blocs/file_download/file_download_cubit.dart

@@ -9,7 +9,6 @@ import 'package:ardrive/entities/constants.dart';
 import 'package:ardrive/models/models.dart';
 import 'package:ardrive/services/services.dart';
 import 'package:ardrive/utils/logger/logger.dart';
-import 'package:ardrive_http/ardrive_http.dart';
 import 'package:ardrive_io/ardrive_io.dart' as io;
 import 'package:ardrive_io/ardrive_io.dart';
 import 'package:ardrive_utils/ardrive_utils.dart';

lib/blocs/file_download/shared_file_download_cubit.dart

@@ -6,15 +6,16 @@ class SharedFileDownloadCubit extends FileDownloadCubit {
   final SecretKey? fileKey;
   final ARFSFileEntity revision;
   final ArweaveService _arweave;
-  final ArDriveCrypto _crypto;
+  final ArDriveDownloader _arDriveDownloader;
 
   SharedFileDownloadCubit({
     this.fileKey,
     required this.revision,
     required ArweaveService arweave,
     required ArDriveCrypto crypto,
+    required ArDriveDownloader arDriveDownloader,
   })  : _arweave = arweave,
-        _crypto = crypto,
+        _arDriveDownloader = arDriveDownloader,
         super(FileDownloadStarting()) {
     download();
   }
@@ -28,53 +29,71 @@ class SharedFileDownloadCubit extends FileDownloadCubit {
   }
 
   Future<void> _downloadFile(ARFSFileEntity revision) async {
-    late Uint8List dataBytes;
-
     emit(
       FileDownloadInProgress(
         fileName: revision.name,
         totalByteCount: revision.size,
       ),
     );
 
-    final dataRes = await ArDriveHTTP().getAsBytes(
-        '${_arweave.client.api.gatewayUrl.origin}/${revision.dataTxId}');
-
-    if (fileKey != null) {
-      final isPinFile = revision.pinnedDataOwnerAddress != null;
-      if (isPinFile) {
-        emit(
-          FileDownloadSuccess(
-            bytes: dataRes.data,
-            fileName: revision.name,
-            mimeType: revision.contentType ?? io.lookupMimeType(revision.name),
-            lastModified: revision.lastModifiedDate,
-          ),
-        );
-        return;
-      }
+    String? cipher;
+    String? cipherIvTag;
+    final isPinFile = revision.pinnedDataOwnerAddress != null;
 
+    if (fileKey != null && !isPinFile) {
       final dataTx = await (_arweave.getTransactionDetails(revision.dataTxId!));
 
-      if (dataTx != null) {
-        dataBytes = await _crypto.decryptDataFromTransaction(
-          dataTx,
-          dataRes.data,
-          fileKey!,
-        );
+      if (dataTx == null) {
+        throw StateError('Data transaction not found');
       }
-    } else {
-      dataBytes = dataRes.data;
+
+      cipher = dataTx.getTag(EntityTag.cipher);
+      cipherIvTag = dataTx.getTag(EntityTag.cipherIv);
     }
 
-    emit(
-      FileDownloadSuccess(
-        bytes: dataBytes,
-        fileName: revision.name,
-        mimeType: revision.contentType ?? io.lookupMimeType(revision.name),
-        lastModified: revision.lastModifiedDate,
-      ),
+    final downloadStream = _arDriveDownloader.downloadFile(
+      dataTx: revision.dataTxId!,
+      fileName: revision.name,
+      fileSize: revision.size,
+      lastModifiedDate: revision.lastModifiedDate,
+      contentType:
+          revision.contentType ?? lookupMimeTypeWithDefaultType(revision.name),
+      cipher: cipher,
+      cipherIvString: cipherIvTag,
+      fileKey: fileKey,
+      isManifest: revision.contentType == ContentType.manifest,
     );
+
+    logger.d(
+        'Downloading file ${revision.name} and dataTxId is ${revision.txId} of size ${revision.size}');
+
+    await for (var progress in downloadStream) {
+      if (state is FileDownloadAborted) {
+        return;
+      }
+
+      if (progress == 100) {
+        emit(FileDownloadFinishedWithSuccess(fileName: revision.name));
+        logger.d('Download finished');
+        return;
+      }
+
+      logger.d('Download progress: $progress');
+
+      emit(
+        FileDownloadWithProgress(
+          fileName: revision.name,
+          progress: progress.toInt(),
+          fileSize: revision.size,
+          contentType: revision.contentType ??
+              lookupMimeTypeWithDefaultType(revision.name),
+        ),
+      );
+    }
+
+    logger.d('Download finished');
+
+    emit(FileDownloadFinishedWithSuccess(fileName: revision.name));
   }
 
   @override

lib/components/file_download_dialog.dart

@@ -101,6 +101,11 @@ Future<void> promptToDownloadSharedFile({
   required ARFSFileEntity revision,
 }) {
   final cubit = SharedFileDownloadCubit(
+    arDriveDownloader: ArDriveDownloader(
+      ardriveIo: ArDriveIO(),
+      ioFileAdapter: IOFileAdapter(),
+      arweave: context.read<ArweaveService>(),
+    ),
     crypto: ArDriveCrypto(),
     revision: revision,
     fileKey: fileKey,