PE-9129: Sync and login resiliency quick wins

assets/config/dev.json

@@ -1,6 +1,6 @@
 {
-  "configVersion": 2,
-  "defaultArweaveGatewayUrl": "https://ardrive.net",
+  "configVersion": 3,
+  "defaultArweaveGatewayUrl": "https://turbo-gateway.com",
   "defaultArweaveGatewayForDataRequest": {
     "label": "Turbo Gateway",
     "url": "https://turbo-gateway.com"
@@ -12,5 +12,7 @@
   "allowedDataItemSizeForTurbo": 100000,
   "stripePublishableKey": "pk_test_51JUAtwC8apPOWkDLh2FPZkQkiKZEkTo6wqgLCtQoClL6S4l2jlbbc5MgOdwOUdU9Tn93NNvqAGbu115lkJChMikG00XUfTmo2z",
   "uploadThumbnails": true,
-  "autoSync": false
+  "autoSync": false,
+  "maxConcurrentDriveSyncs": 5,
+  "driveHistoryGqlPageSize": 1000
 }

assets/config/prod.json

@@ -1,6 +1,6 @@
 {
-  "configVersion": 2,
-  "defaultArweaveGatewayUrl": "https://ardrive.net",
+  "configVersion": 3,
+  "defaultArweaveGatewayUrl": "https://turbo-gateway.com",
   "defaultArweaveGatewayForDataRequest": {
     "label": "Turbo Gateway",
     "url": "https://turbo-gateway.com"
@@ -12,5 +12,7 @@
   "allowedDataItemSizeForTurbo": 100000,
   "stripePublishableKey": "pk_live_51JUAtwC8apPOWkDLMQqNF9sPpfneNSPnwX8YZ8y1FNDl6v94hZIwzgFSYl27bWE4Oos8CLquunUswKrKcaDhDO6m002Yj9AeKj",
   "uploadThumbnails": true,
-  "autoSync": false
+  "autoSync": false,
+  "maxConcurrentDriveSyncs": 5,
+  "driveHistoryGqlPageSize": 1000
 }

assets/config/staging.json

@@ -1,6 +1,6 @@
 {
-  "configVersion": 2,
-  "defaultArweaveGatewayUrl": "https://ardrive.net",
+  "configVersion": 3,
+  "defaultArweaveGatewayUrl": "https://turbo-gateway.com",
   "defaultArweaveGatewayForDataRequest": {
     "label": "Turbo Gateway",
     "url": "https://turbo-gateway.com"
@@ -12,5 +12,7 @@
   "allowedDataItemSizeForTurbo": 100000,
   "stripePublishableKey": "pk_live_51JUAtwC8apPOWkDLMQqNF9sPpfneNSPnwX8YZ8y1FNDl6v94hZIwzgFSYl27bWE4Oos8CLquunUswKrKcaDhDO6m002Yj9AeKj",
   "uploadThumbnails": true,
-  "autoSync": false
+  "autoSync": false,
+  "maxConcurrentDriveSyncs": 5,
+  "driveHistoryGqlPageSize": 1000
 }

lib/authentication/ardrive_auth.dart

@@ -435,7 +435,17 @@ class ArDriveAuthImpl implements ArDriveAuth {
 
   @override
   Future<void> refreshBalance() async {
-    _updateBalance();
+    // Await the fetch so callers (e.g. ProfileCubit.refreshBalance, which
+    // re-emits currentUser right after) observe the refreshed value instead
+    // of the stale one.
+    try {
+      final balance = await _userRepository.getBalance(currentUser.wallet);
+      _currentUser = _currentUser!.copyWith(walletBalance: balance);
+      _userStreamController.add(_currentUser);
+    } catch (e) {
+      logger.e('Error refreshing wallet balance', e);
+      // Keep the previous value on error.
+    }
   }
 }
 

lib/core/arfs/use_cases/bulk_import_files.dart

@@ -418,8 +418,22 @@ class BulkImportFiles {
                   ? 1
                   : 5,
           taskQueue: fileEntries,
-          onWorkerError: (e) {
-            logger.e('Bulk import worker error', e, StackTrace.current);
+          onWorkerError: (file) {
+            // WorkerPool passes the failed TASK (the FileEntity), not the
+            // exception. Record it so BulkImportResult stays truthful:
+            // imported + failures should account for every file.
+            logger.e(
+                'Bulk import worker failed for file: ${file.name}', null,
+                StackTrace.current);
+            final manifestFile =
+                file.dataTxId != null ? fileDataTxIdToFile[file.dataTxId] : null;
+            final path = manifestFile?.path ?? file.name ?? 'unknown';
+            failures.add(FileImportFailure(
+              path: path,
+              dataTxId: file.dataTxId ?? '',
+              error: 'Import failed during metadata upload',
+            ));
+            onFileFailure?.call(path);
           },
           execute: (file) async {
             if (_isCancelled) {
@@ -442,6 +456,10 @@ class BulkImportFiles {
               originalOwnerAddress: originalOwnerAddress,
             );
 
+            // WorkerPool discards execute's return value, so successful
+            // imports must be collected here for BulkImportResult.
+            importedFiles.add(fileEntry);
+
             onFileUploadSuccess?.call(file.name!);
 
             return fileEntry;

lib/gar/domain/repositories/gar_repository.dart

@@ -8,6 +8,7 @@ import 'package:collection/collection.dart';
 
 abstract class GarRepository {
   Future<List<Gateway>> getGateways();
+  Future<List<Gateway>> refreshGateways();
   List<Gateway> searchGateways(String query);
   Future<Gateway> getSelectedGateway();
   Future<void> updateGateway(Gateway gateway);
@@ -35,10 +36,21 @@ class GarRepositoryImpl implements GarRepository {
 
   final List<Gateway> _gateways = [];
 
+  /// Serves the persisted/session gateway list; the network is hit at most
+  /// once ever (on the very first use). Use [refreshGateways] for an
+  /// explicit, user-initiated re-fetch.
   @override
   Future<List<Gateway>> getGateways() async {
     _gateways.clear();
-    _gateways.addAll(await arioSDK.getGateways());
+    _gateways.addAll(await arweave.gatewayFallback.getGatewaysCached());
+
+    return _gateways;
+  }
+
+  @override
+  Future<List<Gateway>> refreshGateways() async {
+    _gateways.clear();
+    _gateways.addAll(await arweave.gatewayFallback.refreshGateways());
 
     return _gateways;
   }

lib/gar/presentation/bloc/gar_bloc.dart

@@ -33,6 +33,25 @@ class GarBloc extends Bloc<GarEvent, GarState> {
       }
     });
 
+    on<RefreshGateways>((event, emit) async {
+      try {
+        emit(LoadingGateways());
+
+        final gateways = await garRepository.refreshGateways();
+        final currentGateway = await garRepository.getSelectedGateway();
+
+        emit(
+          GatewaysLoaded(
+            gateways: gateways,
+            currentGateway: currentGateway,
+          ),
+        );
+      } catch (e) {
+        logger.e('Failed to refresh gateways from AR.IO', e);
+        emit(const GatewaysError());
+      }
+    });
+
     on<SelectGateway>((event, emit) async {
       emit(VerifyingGateway());
 

lib/gar/presentation/bloc/gar_event.dart

@@ -9,6 +9,9 @@ abstract class GarEvent extends Equatable {
 
 final class GetGateways extends GarEvent {}
 
+/// User-initiated refresh of the gateway list from the network.
+final class RefreshGateways extends GarEvent {}
+
 final class SelectGateway extends GarEvent {
   final Gateway gateway;
 

lib/gar/presentation/widgets/gar_modal.dart

@@ -139,6 +139,12 @@ class _ArIOGatewaySelectorModalContentState extends State<_ArIOGatewaySelectorMo
               ),
             ),
             actions: [
+              ModalAction(
+                action: () {
+                  garBloc.add(RefreshGateways());
+                },
+                title: 'Refresh list',
+              ),
               ModalAction(
                 action: () {
                   Navigator.of(context).pop();

lib/main.dart

@@ -494,7 +494,6 @@ class AppState extends State<App> {
               configService: configService,
               arioSDK: ArioSDKFactory().create(),
             ),
-            arnsRepository: _.read<ARNSRepository>(),
             userPreferencesRepository: _.read<UserPreferencesRepository>(),
           ),
         ),

lib/services/arweave/arweave_service.dart

@@ -118,6 +118,8 @@ class ArweaveService {
   /// Data requests (GET /tx/{id}/data, wallet balance, etc.) continue using
   /// the configured arweaveGatewayForDataRequest.
   void updateGraphQLEndpoint(String gatewayUrl) {
+    // The old endpoint's capabilities no longer apply.
+    _gqlOwnersPreferringFallback.clear();
     final previousClient = _gql;
     final graphqlUrl = _graphqlUrlFromGateway(gatewayUrl);
     _gql = ArtemisClient(graphqlUrl);
@@ -152,6 +154,18 @@ class ArweaveService {
   /// Cache for drive signatures (immutable on-chain, never change).
   final Map<String, DriveSignatureEntity?> _cachedDriveSignatures = {};
 
+  /// Single [MetadataCache] instance reused across all sync batches.
+  /// Previously a new cache was rebuilt from SharedPreferences for every
+  /// parsed batch of every drive during sync.
+  MetadataCache? _metadataCache;
+
+  Future<MetadataCache> _getMetadataCache() async {
+    _metadataCache ??= await MetadataCache.fromCacheStore(
+      await newSharedPreferencesCacheStore(),
+    );
+    return _metadataCache!;
+  }
+
   /// Clears the cached result of [getUniqueUserDriveEntityTxs] and entity data.
   /// Call after creating/updating a drive or after a full sync completes.
   void clearUserDriveTxsCache() {
@@ -341,6 +355,12 @@ class ArweaveService {
     return (activeDriveIds: activeDriveIds, isComplete: isComplete);
   }
 
+  /// Owners whose drive-history queries the primary GraphQL endpoint could
+  /// not serve this session (e.g. indexer scan limits for very large
+  /// owners). Shared across strategy instances so the probing cost is paid
+  /// once per owner, not once per drive.
+  final Set<String> _gqlOwnersPreferringFallback = <String>{};
+
   Stream<List<DriveEntityHistoryTransactionModel>>
       getSegmentedTransactionsFromDrive(
     String driveId, {
@@ -352,6 +372,8 @@ class ArweaveService {
     strategy ??=
         GetSegmentedTransactionFromDriveWithoutEntityTypeFilterStrategy(
       graphQLRetry,
+      pageSize: _configService.config.driveHistoryGqlPageSize.clamp(1, 1000),
+      ownersPreferringFallback: _gqlOwnersPreferringFallback,
     );
 
     logger.d(
@@ -545,9 +567,7 @@ class ArweaveService {
       );
     }
 
-    final metadataCache = await MetadataCache.fromCacheStore(
-      await newSharedPreferencesCacheStore(),
-    );
+    final metadataCache = await _getMetadataCache();
 
     final blockHistory = <BlockEntities>[];
 
@@ -1735,9 +1755,13 @@ class ArweaveService {
 
   /// Fetches transaction info for multiple transactions in batches.
   /// Returns a stream of transaction info batches.
+  ///
+  /// The batch size matches the query's `first: 100` page size (the same
+  /// pattern as [getTransactionConfirmations] and [getLicenseAssertions]),
+  /// so each batch resolves in a single request.
   Stream<Map<String, TxInfo>> getInfoOfTxsToBePinned(
     List<String> transactionIds, {
-    int batchSize = 5,
+    int batchSize = 100,
   }) async* {
     for (var i = 0; i < transactionIds.length; i += batchSize) {
       final end = (i + batchSize < transactionIds.length)