cake_wallet/cw_nano/lib/nano_wallet.dart

// import 'dart:async';
// import 'dart:io';
// import 'package:cw_core/pathForWallet.dart';
// import 'package:cw_core/transaction_priority.dart';
// import 'package:cw_nano/nano_balance.dart';
// import 'package:cw_nano/nano_transaction_history.dart';
// import 'package:cw_nano/nano_transaction_info.dart';
// import 'package:cw_nano/nano_wallet_addresses.dart';
// import 'package:cw_nano/nano_wallet_keys.dart';
// import 'package:mobx/mobx.dart';
// import 'package:cw_core/pending_transaction.dart';
// import 'package:cw_core/wallet_base.dart';
// import 'package:cw_core/sync_status.dart';
// import 'package:cw_core/wallet_info.dart';
// import 'package:cw_core/node.dart';
// import 'package:cw_core/crypto_currency.dart';

// part 'nano_wallet.g.dart';

// const moneroBlockSize = 1000;

// class NanoWallet = NanoWalletBase with _$NanoWallet;

// abstract class NanoWalletBase
//     extends WalletBase<NanoBalance, NanoTransactionHistory, NanoTransactionInfo> with Store {
//   NanoWalletBase({
//     required WalletInfo walletInfo,
//     required String mnemonic,
//     required String password,
//   })  : balance = ObservableMap<CryptoCurrency, NanoBalance>.of({
//           CryptoCurrency.nano:
//               NanoBalance(currentBalance: BigInt.zero, receivableBalance: BigInt.zero)
//         }),
//         _isTransactionUpdating = false,
//         _hasSyncAfterStartup = false,
//         _password = password,
//         _mnemonic = mnemonic,
//         walletAddresses = NanoWalletAddresses(walletInfo),
//         syncStatus = NotConnectedSyncStatus(),
//         super(walletInfo) {
//     transactionHistory = NanoTransactionHistory();

//     // _onAccountChangeReaction = reaction((_) => walletAddresses.account, (Account? account) {
//     //   if (account == null) {
//     //     return;
//     //   }

//     //   balance = ObservableMap<CryptoCurrency, MoneroBalance>.of(<CryptoCurrency, MoneroBalance>{
//     //     currency: MoneroBalance(
//     //         fullBalance: monero_wallet.getFullBalance(accountIndex: account.id),
//     //         unlockedBalance: monero_wallet.getUnlockedBalance(accountIndex: account.id))
//     //   });
//     //   walletAddresses.updateSubaddressList(accountIndex: account.id);
//     // });
//   }

//   final String _mnemonic;
//   final String _password;

//   static const int _autoSaveInterval = 30;

//   @override
//   NanoWalletAddresses walletAddresses;

//   @override
//   @observable
//   SyncStatus syncStatus;

//   @override
//   @observable
//   ObservableMap<CryptoCurrency, NanoBalance> balance;

//   @override
//   String get seed {
//     throw UnimplementedError();
//   }

//   @override
//   NanoWalletKeys get keys => NanoWalletKeys(
//         derivationType: "bip39",
//         mnemonic: "todo",
//         privateKey: "todo",
//       );
//   // NanoWalletKeys get keys => NanoWalletKeys(
//   //     privateSpendKey: monero_wallet.getSecretSpendKey(),
//   //     privateViewKey: monero_wallet.getSecretViewKey(),
//   //     publicSpendKey: monero_wallet.getPublicSpendKey(),
//   //     publicViewKey: monero_wallet.getPublicViewKey());

//   // SyncListener? _listener;
//   ReactionDisposer? _onAccountChangeReaction;
//   bool _isTransactionUpdating;
//   bool _hasSyncAfterStartup;
//   Timer? _autoSaveTimer;

//   Future<void> init() async {
//     // await walletAddresses.init();
//     // balance = ObservableMap<CryptoCurrency, MoneroBalance>.of(<CryptoCurrency, MoneroBalance>{
//     //   currency: MoneroBalance(
//     //       fullBalance: monero_wallet.getFullBalance(accountIndex: walletAddresses.account!.id),
//     //       unlockedBalance:
//     //           monero_wallet.getUnlockedBalance(accountIndex: walletAddresses.account!.id))
//     // });
//     // _setListeners();
//     // await updateTransactions();

//     // if (walletInfo.isRecovery) {
//     //   monero_wallet.setRecoveringFromSeed(isRecovery: walletInfo.isRecovery);

//     //   if (monero_wallet.getCurrentHeight() <= 1) {
//     //     monero_wallet.setRefreshFromBlockHeight(height: walletInfo.restoreHeight);
//     //   }
//     // }

//     // _autoSaveTimer = Timer.periodic(
//     //    Duration(seconds: _autoSaveInterval),
//     //    (_) async => await save());
//   }

//   @override
//   Future<void>? updateBalance() => null;

//   @override
//   void close() {
//     // _listener?.stop();
//     // _onAccountChangeReaction?.reaction.dispose();
//     // _autoSaveTimer?.cancel();
//   }

//   @override
//   Future<void> connectToNode({required Node node}) async {
//     // try {
//     //   syncStatus = ConnectingSyncStatus();
//     //   await monero_wallet.setupNode(
//     //       address: node.uri.toString(), useSSL: node.isSSL, isLightWallet: false);

//     //   monero_wallet.setTrustedDaemon(node.trusted);
//     //   syncStatus = ConnectedSyncStatus();
//     // } catch (e) {
//     //   syncStatus = FailedSyncStatus();
//     //   print(e);
//     // }
//   }

//   @override
//   Future<void> startSync() async {
//     // try {
//     //   _setInitialHeight();
//     // } catch (_) {}

//     // try {
//     //   syncStatus = AttemptingSyncStatus();
//     //   monero_wallet.startRefresh();
//     //   _setListeners();
//     //   _listener?.start();
//     // } catch (e) {
//     //   syncStatus = FailedSyncStatus();
//     //   print(e);
//     //   rethrow;
//     // }
//   }

//   @override
//   Future<PendingTransaction> createTransaction(Object credentials) async {
//     // final _credentials = credentials as MoneroTransactionCreationCredentials;
//     // return null;
//     throw UnimplementedError();
//   }

//   @override
//   int calculateEstimatedFee(TransactionPriority priority, int? amount) {
//     // FIXME: hardcoded value;
//     return 0;
//   }

//   @override
//   Future<void> save() async {
//     // await walletAddresses.updateAddressesInBox();
//     // await backupWalletFiles(name);
//     // await monero_wallet.store();
//   }

//   @override
//   Future<void> renameWalletFiles(String newWalletName) async {
//     final currentWalletDirPath = await pathForWalletDir(name: name, type: type);

//     try {
//       // -- rename the waller folder --
//       final currentWalletDir = Directory(await pathForWalletDir(name: name, type: type));
//       final newWalletDirPath = await pathForWalletDir(name: newWalletName, type: type);
//       await currentWalletDir.rename(newWalletDirPath);

//       // -- use new waller folder to rename files with old names still --
//       final renamedWalletPath = newWalletDirPath + '/$name';

//       final currentCacheFile = File(renamedWalletPath);
//       final currentKeysFile = File('$renamedWalletPath.keys');
//       final currentAddressListFile = File('$renamedWalletPath.address.txt');

//       final newWalletPath = await pathForWallet(name: newWalletName, type: type);

//       if (currentCacheFile.existsSync()) {
//         await currentCacheFile.rename(newWalletPath);
//       }
//       if (currentKeysFile.existsSync()) {
//         await currentKeysFile.rename('$newWalletPath.keys');
//       }
//       if (currentAddressListFile.existsSync()) {
//         await currentAddressListFile.rename('$newWalletPath.address.txt');
//       }
//     } catch (e) {
//       final currentWalletPath = await pathForWallet(name: name, type: type);

//       final currentCacheFile = File(currentWalletPath);
//       final currentKeysFile = File('$currentWalletPath.keys');
//       final currentAddressListFile = File('$currentWalletPath.address.txt');

//       final newWalletPath = await pathForWallet(name: newWalletName, type: type);

//       // Copies current wallet files into new wallet name's dir and files
//       if (currentCacheFile.existsSync()) {
//         await currentCacheFile.copy(newWalletPath);
//       }
//       if (currentKeysFile.existsSync()) {
//         await currentKeysFile.copy('$newWalletPath.keys');
//       }
//       if (currentAddressListFile.existsSync()) {
//         await currentAddressListFile.copy('$newWalletPath.address.txt');
//       }

//       // Delete old name's dir and files
//       await Directory(currentWalletDirPath).delete(recursive: true);
//     }
//   }

//   @override
//   Future<void> changePassword(String password) async {
//     // monero_wallet.setPasswordSync(password);
//   }

//   // Future<int> getNodeHeight() async => nano_wallet.getNodeHeight();

//   // Future<bool> isConnected() async => nano_wallet.isConnected();

//   Future<void> setAsRecovered() async {
//     walletInfo.isRecovery = false;
//     await walletInfo.save();
//   }

//   @override
//   Future<void> rescan({required int height}) async {
//     // walletInfo.restoreHeight = height;
//     // walletInfo.isRecovery = true;
//     // monero_wallet.setRefreshFromBlockHeight(height: height);
//     // monero_wallet.rescanBlockchainAsync();
//     // await startSync();
//     // _askForUpdateBalance();
//     // walletAddresses.accountList.update();
//     // await _askForUpdateTransactionHistory();
//     // await save();
//     // await walletInfo.save();
//   }

//   // String getTransactionAddress(int accountIndex, int addressIndex) =>
//   //     monero_wallet.getAddress(accountIndex: accountIndex, addressIndex: addressIndex);

//   @override
//   Future<Map<String, NanoTransactionInfo>> fetchTransactions() async {
//     throw UnimplementedError();
//     // monero_transaction_history.refreshTransactions();
//     // return _getAllTransactions(null)
//     //     .fold<Map<String, MoneroTransactionInfo>>(<String, MoneroTransactionInfo>{},
//     //         (Map<String, MoneroTransactionInfo> acc, MoneroTransactionInfo tx) {
//     //   acc[tx.id] = tx;
//     //   return acc;
//     // });
//   }

//   Future<void> updateTransactions() async {
//     // try {
//     //   if (_isTransactionUpdating) {
//     //     return;
//     //   }

//     //   _isTransactionUpdating = true;
//     //   final transactions = await fetchTransactions();
//     //   transactionHistory.addMany(transactions);
//     //   await transactionHistory.save();
//     //   _isTransactionUpdating = false;
//     // } catch (e) {
//     //   print(e);
//     //   _isTransactionUpdating = false;
//     // }
//   }

//   // String getSubaddressLabel(int accountIndex, int addressIndex) {
//   //   // return monero_wallet.getSubaddressLabel(accountIndex, addressIndex);
//   // }

//   // List<MoneroTransactionInfo> _getAllTransactions(dynamic _) => monero_transaction_history
//   //     .getAllTransations()
//   //     .map((row) => MoneroTransactionInfo.fromRow(row))
//   //     .toList();

//   void _setListeners() {
//     // _listener?.stop();
//     // _listener = monero_wallet.setListeners(_onNewBlock, _onNewTransaction);
//   }

//   void _setInitialHeight() {
//     // if (walletInfo.isRecovery) {
//     //   return;
//     // }

//     // final currentHeight = getCurrentHeight();

//     // if (currentHeight <= 1) {
//     //   final height = _getHeightByDate(walletInfo.date);
//     //   monero_wallet.setRecoveringFromSeed(isRecovery: true);
//     //   monero_wallet.setRefreshFromBlockHeight(height: height);
//     // }
//   }

//   Future<void> _askForUpdateTransactionHistory() async => await updateTransactions();

//   // int _getFullBalance() => monero_wallet.getFullBalance(accountIndex: walletAddresses.account!.id);

//   // int _getUnlockedBalance() =>
//   //     monero_wallet.getUnlockedBalance(accountIndex: walletAddresses.account!.id);

//   void _onNewTransaction() async {
//     // try {
//     //   await _askForUpdateTransactionHistory();
//     //   _askForUpdateBalance();
//     //   await Future<void>.delayed(Duration(seconds: 1));
//     // } catch (e) {
//     //   print(e.toString());
//     // }
//   }
// }

import 'dart:convert';

import 'package:cw_core/crypto_currency.dart';
import 'package:cw_core/erc20_token.dart';
import 'package:cw_core/node.dart';
import 'package:cw_core/pathForWallet.dart';
import 'package:cw_core/pending_transaction.dart';
import 'package:cw_core/sync_status.dart';
import 'package:cw_core/transaction_priority.dart';
import 'package:cw_core/wallet_addresses.dart';
import 'package:cw_core/wallet_info.dart';
import 'package:cw_nano/nano_balance.dart';
import 'package:cw_nano/nano_transaction_history.dart';
import 'package:cw_nano/nano_transaction_info.dart';
import 'package:mobx/mobx.dart';
import 'package:web3dart/credentials.dart';
import 'dart:async';
import 'dart:io';
import 'package:cw_nano/nano_wallet_addresses.dart';
import 'package:cw_nano/nano_wallet_keys.dart';
import 'package:cw_core/wallet_base.dart';
import 'package:web3dart/web3dart.dart';

part 'nano_wallet.g.dart';

class NanoWallet = NanoWalletBase with _$NanoWallet;

abstract class NanoWalletBase
    extends WalletBase<NanoBalance, NanoTransactionHistory, NanoTransactionInfo> with Store {
  NanoWalletBase({
    required WalletInfo walletInfo,
    required String mnemonic,
    required String password,
    NanoBalance? initialBalance,
  })  : syncStatus = NotConnectedSyncStatus(),
        _password = password,
        _mnemonic = mnemonic,
        _isTransactionUpdating = false,
        _priorityFees = [],
        walletAddresses = NanoWalletAddresses(walletInfo),
        balance = ObservableMap<CryptoCurrency, NanoBalance>.of({
          CryptoCurrency.eth: initialBalance ??
              NanoBalance(currentBalance: BigInt.zero, receivableBalance: BigInt.zero)
        }),
        super(walletInfo) {
    print("@@@@@ initializing nano wallet @@@@@");
    this.walletInfo = walletInfo;
    transactionHistory = NanoTransactionHistory();
  }

  final String _mnemonic;
  final String _password;

  List<int> _priorityFees;
  int? _gasPrice;
  bool _isTransactionUpdating;

  @override
  WalletAddresses walletAddresses;

  @override
  @observable
  SyncStatus syncStatus;

  @override
  @observable
  late ObservableMap<CryptoCurrency, NanoBalance> balance;

  Future<void> init() async {
    // erc20TokensBox = await Hive.openBox<Erc20Token>(Erc20Token.boxName);
    // await walletAddresses.init();
    // await transactionHistory.init();
    // _privateKey = await getPrivateKey(_mnemonic, _password);
    // walletAddresses.address = _privateKey.address.toString();
    // await save();
  }

  @override
  int calculateEstimatedFee(TransactionPriority priority, int? amount) {
    return 0;
  }

  @override
  Future<void> changePassword(String password) {
    throw UnimplementedError("changePassword");
  }

  @override
  void close() {
    // _client.stop();
  }

  @action
  @override
  Future<void> connectToNode({required Node node}) async {
    throw UnimplementedError();
  }

  @override
  Future<PendingTransaction> createTransaction(Object credentials) async {
    throw UnimplementedError();
  }

  Future<void> updateTransactions() async {
    throw UnimplementedError();
  }

  @override
  Future<Map<String, NanoTransactionInfo>> fetchTransactions() async {
    throw UnimplementedError();
    // final address = _privateKey.address.hex;
    // final transactions = await _client.fetchTransactions(address);

    // final List<Future<List<EthereumTransactionModel>>> erc20TokensTransactions = [];

    // for (var token in balance.keys) {
    //   if (token is Erc20Token) {
    //     erc20TokensTransactions.add(_client.fetchTransactions(
    //       address,
    //       contractAddress: token.contractAddress,
    //     ));
    //   }
    // }

    // final tokensTransaction = await Future.wait(erc20TokensTransactions);
    // transactions.addAll(tokensTransaction.expand((element) => element));

    // final Map<String, EthereumTransactionInfo> result = {};

    // for (var transactionModel in transactions) {
    //   if (transactionModel.isError) {
    //     continue;
    //   }

    //   result[transactionModel.hash] = EthereumTransactionInfo(
    //     id: transactionModel.hash,
    //     height: transactionModel.blockNumber,
    //     ethAmount: transactionModel.amount,
    //     direction: transactionModel.from == address
    //         ? TransactionDirection.outgoing
    //         : TransactionDirection.incoming,
    //     isPending: false,
    //     date: transactionModel.date,
    //     confirmations: transactionModel.confirmations,
    //     ethFee: BigInt.from(transactionModel.gasUsed) * transactionModel.gasPrice,
    //     exponent: transactionModel.tokenDecimal ?? 18,
    //     tokenSymbol: transactionModel.tokenSymbol ?? "ETH",
    //   );
    // }

    // return result;
  }

  @override
  Object get keys => throw UnimplementedError("keys");

  @override
  Future<void> rescan({required int height}) {
    throw UnimplementedError("rescan");
  }

  @override
  Future<void> save() async {
    throw UnimplementedError();
  }

  @override
  String get seed => _mnemonic;

  @action
  @override
  Future<void> startSync() async {
    throw UnimplementedError();
  }

  int feeRate(TransactionPriority priority) {
    throw UnimplementedError();
  }

  // Future<String> makePath() async => pathForWallet(name: walletInfo.name, type: walletInfo.type);

  // String toJSON() => json.encode({
  //       'mnemonic': _mnemonic,
  //       'balance': balance[currency]!.toJSON(),
  //     });

  static Future<NanoWallet> open({
    required String name,
    required String password,
    required WalletInfo walletInfo,
  }) async {
    throw UnimplementedError();
  }

  Future<void> _updateBalance() async {
    // balance[currency] = await _fetchEthBalance();

    // await _fetchErc20Balances();
    await save();
  }

  Future<void> _fetchErc20Balances() async {
    throw UnimplementedError();
  }

  Future<EthPrivateKey> getPrivateKey(String mnemonic, String password) async {
    throw UnimplementedError();
  }

  Future<void>? updateBalance() async => await _updateBalance();

  Future<void> addErc20Token(Erc20Token token) async {
    throw UnimplementedError();
  }

  Future<void> deleteErc20Token(Erc20Token token) async {
    throw UnimplementedError();
  }

  void _onNewTransaction(FilterEvent event) {
    throw UnimplementedError();
  }

  void addInitialTokens() {
    throw UnimplementedError();
  }

  @override
  Future<void> renameWalletFiles(String newWalletName) async {
    print("rename");
    throw UnimplementedError();
  }
}