From a5ba67aa1d3a44de01d1ef931931f951a9db4429 Mon Sep 17 00:00:00 2001
From: julian <julian@cypherstack.com>
Date: Mon, 24 Jul 2023 09:42:29 -0600
Subject: [PATCH] WIP migrate lcoins hive => isar

---
 lib/models/isar/models/isar_models.dart |  1 +
 lib/models/lelantus_coin.dart           |  2 +
 lib/utilities/constants.dart            |  2 +-
 lib/utilities/db_version_migration.dart | 65 ++++++++++++++++++++++++-
 4 files changed, 68 insertions(+), 2 deletions(-)

diff --git a/lib/models/isar/models/isar_models.dart b/lib/models/isar/models/isar_models.dart
index ce7652a46..9de91fc84 100644
--- a/lib/models/isar/models/isar_models.dart
+++ b/lib/models/isar/models/isar_models.dart
@@ -15,5 +15,6 @@ export 'blockchain_data/output.dart';
 export 'blockchain_data/transaction.dart';
 export 'blockchain_data/utxo.dart';
 export 'ethereum/eth_contract.dart';
+export 'firo_specific/lelantus_coin.dart';
 export 'log.dart';
 export 'transaction_note.dart';
diff --git a/lib/models/lelantus_coin.dart b/lib/models/lelantus_coin.dart
index 0e32d33bf..56557c1cd 100644
--- a/lib/models/lelantus_coin.dart
+++ b/lib/models/lelantus_coin.dart
@@ -12,6 +12,7 @@ import 'package:hive/hive.dart';
 
 part 'type_adaptors/lelantus_coin.g.dart';
 
+@Deprecated("Use Isar object instead")
 // @HiveType(typeId: 9)
 class LelantusCoin {
   // @HiveField(0)
@@ -27,6 +28,7 @@ class LelantusCoin {
   // @HiveField(5)
   bool isUsed;
 
+  @Deprecated("Use Isar object instead")
   LelantusCoin(
     this.index,
     this.value,
diff --git a/lib/utilities/constants.dart b/lib/utilities/constants.dart
index 2dd7be287..ad9d68997 100644
--- a/lib/utilities/constants.dart
+++ b/lib/utilities/constants.dart
@@ -58,7 +58,7 @@ abstract class Constants {
   // Enable Logger.print statements
   static const bool disableLogger = false;
 
-  static const int currentDataVersion = 10;
+  static const int currentDataVersion = 11;
 
   static const int rescanV1 = 1;
 
diff --git a/lib/utilities/db_version_migration.dart b/lib/utilities/db_version_migration.dart
index 293b5d48c..3f69161f4 100644
--- a/lib/utilities/db_version_migration.dart
+++ b/lib/utilities/db_version_migration.dart
@@ -180,7 +180,6 @@ class DbVersionMigrator with WalletDB {
         // clear possible broken firo cache
         await DB.instance.clearSharedTransactionCache(coin: Coin.firo);
 
-
         // update version
         await DB.instance.put<dynamic>(
             boxName: DB.boxNameDBInfo, key: "hive_data_version", value: 4);
@@ -343,12 +342,76 @@ class DbVersionMigrator with WalletDB {
         // try to continue migrating
         return await migrate(10, secureStore: secureStore);
 
+      case 10:
+        // migrate
+        await _v10(secureStore);
+
+        // update version
+        await DB.instance.put<dynamic>(
+            boxName: DB.boxNameDBInfo, key: "hive_data_version", value: 11);
+
+        // try to continue migrating
+        return await migrate(11, secureStore: secureStore);
+
       default:
         // finally return
         return;
     }
   }
 
+  Future<void> _v10(SecureStorageInterface secureStore) async {
+    await Hive.openBox<dynamic>(DB.boxNameAllWalletsData);
+    await Hive.openBox<dynamic>(DB.boxNamePrefs);
+    final walletsService = WalletsService(secureStorageInterface: secureStore);
+    final prefs = Prefs.instance;
+    final walletInfoList = await walletsService.walletNames;
+    await prefs.init();
+    await MainDB.instance.initMainDB();
+
+    for (final walletId in walletInfoList.keys) {
+      final info = walletInfoList[walletId]!;
+      assert(info.walletId == walletId);
+
+      if (info.coin == Coin.firo &&
+          MainDB.instance.isar.lelantusCoins
+                  .where()
+                  .walletIdEqualTo(walletId)
+                  .countSync() ==
+              0) {
+        final walletBox = await Hive.openBox<dynamic>(walletId);
+
+        final hiveLCoins = DB.instance.get<dynamic>(
+              boxName: walletId,
+              key: "_lelantus_coins",
+            ) as List? ??
+            [];
+
+        final List<isar_models.LelantusCoin> coins = [];
+        for (final e in hiveLCoins) {
+          final lcoin = e as LelantusCoin;
+
+          final coin = isar_models.LelantusCoin(
+            walletId: walletId,
+            publicCoin: lcoin.publicCoin,
+            txid: lcoin.txId,
+            value: lcoin.value.toString(),
+            index: lcoin.index,
+            anonymitySetId: lcoin.anonymitySetId,
+            isUsed: lcoin.isUsed,
+          );
+
+          coins.add(coin);
+        }
+
+        if (coins.isNotEmpty) {
+          await MainDB.instance.isar.writeTxn(() async {
+            await MainDB.instance.isar.lelantusCoins.putAll(coins);
+          });
+        }
+      }
+    }
+  }
+
   Future<void> _v4(SecureStorageInterface secureStore) async {
     await Hive.openBox<dynamic>(DB.boxNameAllWalletsData);
     await Hive.openBox<dynamic>(DB.boxNamePrefs);