Merge pull request #1209 from cypherstack/ada-updates

Ada updates

Author: julian-CStack

lib/db/isar/main_db.dart

@@ -92,11 +92,10 @@ class MainDB {
   Future<void> updateWalletInfo(WalletInfo walletInfo) async {
     try {
       await isar.writeTxn(() async {
-        final info =
-            await isar.walletInfo
-                .where()
-                .walletIdEqualTo(walletInfo.walletId)
-                .findFirst();
+        final info = await isar.walletInfo
+            .where()
+            .walletIdEqualTo(walletInfo.walletId)
+            .findFirst();
         if (info == null) {
           throw Exception(
             "updateWalletInfo() called with new WalletInfo."
@@ -189,6 +188,7 @@ class MainDB {
   }
 
   Future<List<int>> putAddresses(List<Address> addresses) async {
+    if (addresses.isEmpty) return [];
     try {
       return await isar.writeTxn(() async {
         return await isar.addresses.putAll(addresses);
@@ -199,6 +199,7 @@ class MainDB {
   }
 
   Future<List<int>> updateOrPutAddresses(List<Address> addresses) async {
+    if (addresses.isEmpty) return [];
     try {
       final List<int> ids = [];
       await isar.writeTxn(() async {
@@ -269,6 +270,7 @@ class MainDB {
   }
 
   Future<List<int>> putTransactions(List<Transaction> transactions) async {
+    if (transactions.isEmpty) return [];
     try {
       return await isar.writeTxn(() async {
         return await isar.transactions.putAll(transactions);
@@ -306,9 +308,11 @@ class MainDB {
     await isar.utxos.put(utxo);
   });
 
-  Future<void> putUTXOs(List<UTXO> utxos) => isar.writeTxn(() async {
-    await isar.utxos.putAll(utxos);
-  });
+  Future<void> putUTXOs(List<UTXO> utxos) => utxos.isEmpty
+      ? Future.value()
+      : isar.writeTxn(() async {
+          await isar.utxos.putAll(utxos);
+        });
 
   Future<bool> updateUTXOs(String walletId, List<UTXO> utxos) async {
     bool newUTXO = false;
@@ -317,11 +321,10 @@ class MainDB {
       final set = utxos.toSet();
       for (final utxo in utxos) {
         // check if utxo exists in db and update accordingly
-        final storedUtxo =
-            await isar.utxos
-                .where()
-                .txidWalletIdVoutEqualTo(utxo.txid, utxo.walletId, utxo.vout)
-                .findFirst();
+        final storedUtxo = await isar.utxos
+            .where()
+            .txidWalletIdVoutEqualTo(utxo.txid, utxo.walletId, utxo.vout)
+            .findFirst();
 
         if (storedUtxo != null) {
           // update
@@ -441,8 +444,10 @@ class MainDB {
   //
   Future<void> deleteWalletBlockchainData(String walletId) async {
     final transactionCount = await getTransactions(walletId).count();
-    final transactionCountV2 =
-        await isar.transactionV2s.where().walletIdEqualTo(walletId).count();
+    final transactionCountV2 = await isar.transactionV2s
+        .where()
+        .walletIdEqualTo(walletId)
+        .count();
     final addressCount = await getAddresses(walletId).count();
     final utxoCount = await getUTXOs(walletId).count();
     // final lelantusCoinCount =
@@ -453,41 +458,37 @@ class MainDB {
 
       // transactions
       for (int i = 0; i < transactionCount; i += paginateLimit) {
-        final txnIds =
-            await getTransactions(
-              walletId,
-            ).offset(i).limit(paginateLimit).idProperty().findAll();
+        final txnIds = await getTransactions(
+          walletId,
+        ).offset(i).limit(paginateLimit).idProperty().findAll();
         await isar.transactions.deleteAll(txnIds);
       }
 
       // transactions V2
       for (int i = 0; i < transactionCountV2; i += paginateLimit) {
-        final txnIds =
-            await isar.transactionV2s
-                .where()
-                .walletIdEqualTo(walletId)
-                .offset(i)
-                .limit(paginateLimit)
-                .idProperty()
-                .findAll();
+        final txnIds = await isar.transactionV2s
+            .where()
+            .walletIdEqualTo(walletId)
+            .offset(i)
+            .limit(paginateLimit)
+            .idProperty()
+            .findAll();
         await isar.transactionV2s.deleteAll(txnIds);
       }
 
       // addresses
       for (int i = 0; i < addressCount; i += paginateLimit) {
-        final addressIds =
-            await getAddresses(
-              walletId,
-            ).offset(i).limit(paginateLimit).idProperty().findAll();
+        final addressIds = await getAddresses(
+          walletId,
+        ).offset(i).limit(paginateLimit).idProperty().findAll();
         await isar.addresses.deleteAll(addressIds);
       }
 
       // utxos
       for (int i = 0; i < utxoCount; i += paginateLimit) {
-        final utxoIds =
-            await getUTXOs(
-              walletId,
-            ).offset(i).limit(paginateLimit).idProperty().findAll();
+        final utxoIds = await getUTXOs(
+          walletId,
+        ).offset(i).limit(paginateLimit).idProperty().findAll();
         await isar.utxos.deleteAll(utxoIds);
       }
 
@@ -504,10 +505,9 @@ class MainDB {
     await isar.writeTxn(() async {
       const paginateLimit = 50;
       for (int i = 0; i < addressLabelCount; i += paginateLimit) {
-        final labelIds =
-            await getAddressLabels(
-              walletId,
-            ).offset(i).limit(paginateLimit).idProperty().findAll();
+        final labelIds = await getAddressLabels(
+          walletId,
+        ).offset(i).limit(paginateLimit).idProperty().findAll();
         await isar.addressLabels.deleteAll(labelIds);
       }
     });
@@ -518,10 +518,9 @@ class MainDB {
     await isar.writeTxn(() async {
       const paginateLimit = 50;
       for (int i = 0; i < noteCount; i += paginateLimit) {
-        final labelIds =
-            await getTransactionNotes(
-              walletId,
-            ).offset(i).limit(paginateLimit).idProperty().findAll();
+        final labelIds = await getTransactionNotes(
+          walletId,
+        ).offset(i).limit(paginateLimit).idProperty().findAll();
         await isar.transactionNotes.deleteAll(labelIds);
       }
     });
@@ -531,6 +530,7 @@ class MainDB {
     List<Tuple2<Transaction, Address?>> transactionsData,
     String walletId,
   ) async {
+    if (transactionsData.isEmpty) return;
     try {
       await isar.writeTxn(() async {
         for (final data in transactionsData) {
@@ -570,15 +570,15 @@ class MainDB {
   Future<List<int>> updateOrPutTransactionV2s(
     List<TransactionV2> transactions,
   ) async {
+    if (transactions.isEmpty) return [];
     try {
       final List<int> ids = [];
       await isar.writeTxn(() async {
         for (final tx in transactions) {
-          final storedTx =
-              await isar.transactionV2s
-                  .where()
-                  .txidWalletIdEqualTo(tx.txid, tx.walletId)
-                  .findFirst();
+          final storedTx = await isar.transactionV2s
+              .where()
+              .txidWalletIdEqualTo(tx.txid, tx.walletId)
+              .findFirst();
 
           Id id;
           if (storedTx == null) {

lib/wallets/wallet/impl/cardano_wallet.dart

@@ -8,6 +8,7 @@ import 'package:blockchain_utils/bip/cardano/mnemonic/cardano_icarus_seed_genera
 import 'package:blockchain_utils/bip/cardano/shelley/cardano_shelley.dart';
 import 'package:isar_community/isar.dart';
 import 'package:on_chain/ada/ada.dart';
+import 'package:on_chain/ada/src/provider/exception/blockfrost_api_error.dart';
 import 'package:socks5_proxy/socks.dart';
 import 'package:tuple/tuple.dart';
 
@@ -418,19 +419,45 @@ class CardanoWallet extends Bip39Wallet<Cardano> {
     });
   }
 
+  Future<bool> _checkAddressIsFound() async {
+    try {
+      await blockfrostProvider!.request(
+        BlockfrostRequestSpecificAddress(
+          ADAAddress.fromAddress((await getCurrentReceivingAddress())!.value),
+        ),
+      );
+      return true;
+    } on BlockfrostError catch (e, s) {
+      if (e.statusCode == 404 && e.error == "Not found") {
+        Logging.instance.i(
+          "Ada address not seen on network yet",
+          error: e,
+          stackTrace: s,
+        );
+        return false;
+      } else {
+        rethrow;
+      }
+    }
+  }
+
   @override
   Future<void> updateBalance() async {
     try {
       await updateProvider();
 
-      final addressUtxos = await blockfrostProvider!.request(
-        BlockfrostRequestAddressUTXOsOfAGivenAsset(
-          address: ADAAddress.fromAddress(
-            (await getCurrentReceivingAddress())!.value,
-          ),
-          asset: "lovelace",
-        ),
-      );
+      final addressExists = await _checkAddressIsFound();
+
+      final addressUtxos = addressExists
+          ? await blockfrostProvider!.request(
+              BlockfrostRequestAddressUTXOsOfAGivenAsset(
+                address: ADAAddress.fromAddress(
+                  (await getCurrentReceivingAddress())!.value,
+                ),
+                asset: "lovelace",
+              ),
+            )
+          : <ADAAccountUTXOResponse>[];
 
       BigInt totalBalanceInLovelace = BigInt.parse("0");
       for (final utxo in addressUtxos) {
@@ -498,13 +525,17 @@ class CardanoWallet extends Bip39Wallet<Cardano> {
     try {
       await updateProvider();
 
+      final addressExists = await _checkAddressIsFound();
+
       final currentAddr = (await getCurrentReceivingAddress())!.value;
 
-      final txsList = await blockfrostProvider!.request(
-        BlockfrostRequestAddressTransactions(
-          ADAAddress.fromAddress(currentAddr),
-        ),
-      );
+      final txsList = addressExists
+          ? await blockfrostProvider!.request(
+              BlockfrostRequestAddressTransactions(
+                ADAAddress.fromAddress(currentAddr),
+              ),
+            )
+          : <ADATransactionSummaryInfoResponse>[];
 
       final parsedTxsList = List<Tuple2<isar.Transaction, Address>>.empty(
         growable: true,