Persistence - Wallet Addresses Storage

lib/main.dart

@@ -8,6 +8,7 @@ import 'package:komodo_dex/packages/z_coin_activation/bloc/z_coin_activation_blo
 import 'package:komodo_dex/packages/z_coin_activation/bloc/z_coin_activation_state.dart';
 import 'package:komodo_dex/packages/z_coin_activation/bloc/z_coin_notifications.dart';
 import 'package:komodo_dex/packages/z_coin_activation/widgets/z_coin_status_list_tile.dart';
+import 'package:komodo_dex/services/db/persistence_manager.dart';
 import '../app_config/app_config.dart';
 import '../blocs/authenticate_bloc.dart';
 import '../blocs/coins_bloc.dart';
@@ -71,6 +72,9 @@ Future<void> startApp() async {
   await ZCoinProgressNotifications.initNotifications();
   try {
     mmSe.metrics();
+
+    await PersistenceManager.init();
+
     startup.start();
 
     return runApp(

lib/model/wallet.dart

@@ -27,4 +27,10 @@ class Wallet {
         'id': id ?? '',
         'name': name ?? '',
       };
+
+  static bool areWalletsEqual(Wallet wallet1, Wallet wallet2) {
+    assert(wallet1 != null && wallet2 != null, "Can't compare null wallets");
+
+    return wallet1.id == wallet2.id && wallet1.name == wallet2.name;
+  }
 }

lib/packages/account_addresses/api/account_addresses_api_hive.dart

@@ -0,0 +1,214 @@
+import 'dart:async';
+import 'package:hive/hive.dart';
+import 'package:hive_flutter/hive_flutter.dart';
+import 'package:komodo_dex/packages/account_addresses/api/account_addresses_api_interface.dart';
+import 'package:komodo_dex/packages/account_addresses/models/wallet_address.dart';
+import 'package:meta/meta.dart';
+
+class AccountAddressesApiHive implements AccountAddressesApiInterface {
+  final Box<WalletAddress> _box;
+
+  static bool _isAdapterRegistered = false;
+
+  AccountAddressesApiHive._(this._box);
+
+  static FutureOr<AccountAddressesApiHive> initialize() async {
+    if (!_isAdapterRegistered) {
+      Hive.registerAdapter(WalletAddressAdapter());
+      _isAdapterRegistered = true;
+    }
+
+    Box<WalletAddress> box;
+    try {
+      box = await Hive.openBox<WalletAddress>('account_addresses');
+    } catch (e) {
+      throw Exception('Failed to open Hive box: $e');
+    }
+    return AccountAddressesApiHive._(box);
+  }
+
+  String _getKey(String walletId, String address) {
+    return '${walletId}_$address';
+  }
+
+  @override
+  Future<void> create({
+    @required String walletId,
+    @required String address,
+    @required String ticker,
+    @required double availableBalance,
+    @required String accountId,
+  }) async {
+    _validateFields(walletId, address, availableBalance);
+    try {
+      await _box.put(
+        _getKey(walletId, address),
+        WalletAddress(
+          walletId: walletId,
+          address: address,
+          ticker: ticker,
+          availableBalance: availableBalance,
+          accountId: accountId,
+        ),
+      );
+    } catch (e) {
+      throw Exception('Failed to create WalletAddress: $e');
+    }
+  }
+
+  @override
+  Future<void> updateOrCreate({
+    @required String walletId,
+    @required String address,
+    @required String ticker,
+    @required double availableBalance,
+    @required String accountId,
+  }) async {
+    final key = _getKey(walletId, address);
+    if (_box.containsKey(key)) {
+      await update(
+        walletId: walletId,
+        address: address,
+        ticker: ticker,
+        availableBalance: availableBalance,
+        accountId: accountId,
+      );
+    } else {
+      await create(
+        walletId: walletId,
+        address: address,
+        ticker: ticker,
+        availableBalance: availableBalance,
+        accountId: accountId,
+      );
+    }
+  }
+
+  @override
+  Future<void> update({
+    @required String walletId,
+    @required String address,
+    String ticker,
+    double availableBalance,
+    String accountId,
+  }) async {
+    _validateFields(walletId, address, availableBalance);
+    final key = _getKey(walletId, address);
+    final existingWalletAddress = _box.get(key);
+
+    if (existingWalletAddress == null) {
+      throw Exception('WalletAddress not found');
+    }
+
+    final updatedWalletAddress = WalletAddress(
+      walletId: walletId,
+      address: address,
+      ticker: ticker ?? existingWalletAddress.ticker,
+      availableBalance:
+          availableBalance ?? existingWalletAddress.availableBalance,
+      accountId: accountId ?? existingWalletAddress.accountId,
+    );
+
+    try {
+      await _box.put(key, updatedWalletAddress);
+    } catch (e) {
+      throw Exception('Failed to update WalletAddress: $e');
+    }
+  }
+
+  @override
+  Future<void> deleteOne({
+    @required String walletId,
+    @required String address,
+  }) async {
+    try {
+      await _box.delete(_getKey(walletId, address));
+    } catch (e) {
+      throw Exception('Failed to delete WalletAddress: $e');
+    }
+  }
+
+  @override
+  Future<void> deleteAll({@required String walletId}) async {
+    final keys = _box.keys.where((key) => key.startsWith(walletId));
+    try {
+      await _box.deleteAll(keys);
+    } catch (e) {
+      throw Exception('Failed to delete WalletAddresses: $e');
+    }
+  }
+
+  @override
+  Future<WalletAddress> readOne({
+    @required String walletId,
+    @required String address,
+  }) async {
+    try {
+      return _box.get(_getKey(walletId, address));
+    } catch (e) {
+      throw Exception('Failed to read WalletAddress: $e');
+    }
+  }
+
+  @override
+  Future<List<WalletAddress>> readAll({@required String walletId}) async {
+    try {
+      return _box.values
+          .where((walletAddress) => walletAddress.walletId == walletId)
+          .toList();
+    } catch (e) {
+      throw Exception('Failed to read WalletAddresses: $e');
+    }
+  }
+
+  @override
+  Stream<WalletAddress> watchAll({@required String walletId}) {
+    return _box
+        .watch()
+        .where(
+          (event) =>
+              event.key.startsWith(walletId) && event.value is WalletAddress,
+        )
+        .map((event) => event.value as WalletAddress);
+  }
+
+  @override
+  Stream<List<WalletAddress>> watchAllList({@required String walletId}) async* {
+    List<WalletAddress> addresses = await readAll(walletId: walletId);
+    yield addresses;
+
+    yield* watchAll(walletId: walletId).map<List<WalletAddress>>(
+      (walletAddress) => addresses = addresses
+          .map(
+            (address) => address.address == walletAddress.address
+                ? walletAddress
+                : address,
+          )
+          .toList(),
+    );
+  }
+
+  Future<void> close() async {
+    try {
+      await _box.close();
+    } catch (e) {
+      throw Exception('Failed to close Hive box: $e');
+    }
+  }
+
+  void _validateFields(
+    String walletId,
+    String address,
+    double availableBalance,
+  ) {
+    if (walletId == null || walletId.isEmpty) {
+      throw ArgumentError('Wallet ID must not be empty');
+    }
+    if (address == null || address.isEmpty) {
+      throw ArgumentError('Address must not be empty');
+    }
+    if (availableBalance == null || availableBalance < 0) {
+      throw ArgumentError('Available balance must be non-negative');
+    }
+  }
+}

lib/packages/account_addresses/api/account_addresses_api_interface.dart

@@ -0,0 +1,54 @@
+import 'package:meta/meta.dart';
+import 'package:komodo_dex/packages/account_addresses/models/wallet_address.dart';
+
+abstract class AccountAddressesApiInterface {
+  Future<void> create({
+    @required String walletId,
+    @required String address,
+    @required String ticker,
+    @required double availableBalance,
+    @required String accountId,
+  });
+
+  Future<void> update({
+    @required String walletId,
+    @required String address,
+    String ticker,
+    double availableBalance,
+    String accountId,
+  });
+
+  Future<void> updateOrCreate({
+    @required String walletId,
+    @required String address,
+    @required String ticker,
+    @required double availableBalance,
+    @required String accountId,
+  });
+
+  Future<void> deleteOne({
+    @required String walletId,
+    @required String address,
+  });
+
+  Future<void> deleteAll({
+    @required String walletId,
+  });
+
+  Future<WalletAddress> readOne({
+    @required String walletId,
+    @required String address,
+  });
+
+  Future<List<WalletAddress>> readAll({
+    @required String walletId,
+  });
+
+  Stream<WalletAddress> watchAll({
+    @required String walletId,
+  });
+
+  Stream<List<WalletAddress>> watchAllList({
+    @required String walletId,
+  });
+}

lib/packages/account_addresses/models/wallet_address.dart

@@ -0,0 +1,43 @@
+import 'package:meta/meta.dart';
+import 'package:hive/hive.dart';
+
+part 'wallet_address.g.dart';
+
+@HiveType(typeId: 0)
+class WalletAddress {
+  @HiveField(0)
+  final String walletId;
+
+  @HiveField(1)
+  final String address;
+
+  @HiveField(2)
+  final String ticker;
+
+  @HiveField(3)
+  final double availableBalance;
+
+  @HiveField(4)
+  final String accountId;
+
+  WalletAddress({
+    @required this.walletId,
+    @required this.address,
+    @required this.ticker,
+    @required this.availableBalance,
+    @required this.accountId,
+  });
+
+  Map<String, dynamic> toJson() => {
+        'walletId': walletId,
+        'address': address,
+        'ticker': ticker,
+        'availableBalance': availableBalance,
+        'accountId': accountId,
+      };
+
+  @override
+  String toString() {
+    return 'WalletAddress{walletId: $walletId, address: $address, ticker: $ticker, availableBalance: $availableBalance, accountId: $accountId}';
+  }
+}

lib/packages/account_addresses/models/wallet_address.g.dart

@@ -0,0 +1,26 @@
+part of 'wallet_address.dart';
+
+class WalletAddressAdapter extends TypeAdapter<WalletAddress> {
+  @override
+  final typeId = 0;
+
+  @override
+  WalletAddress read(BinaryReader reader) {
+    return WalletAddress(
+      walletId: reader.read(),
+      address: reader.read(),
+      ticker: reader.read(),
+      availableBalance: reader.read(),
+      accountId: reader.read(),
+    );
+  }
+
+  @override
+  void write(BinaryWriter writer, WalletAddress obj) {
+    writer.write(obj.walletId);
+    writer.write(obj.address);
+    writer.write(obj.ticker);
+    writer.write(obj.availableBalance);
+    writer.write(obj.accountId);
+  }
+}