import 'dart:async'; import 'dart:ffi'; import 'dart:io'; import 'dart:isolate'; import 'package:cw_core/account.dart'; import 'package:cw_core/crypto_currency.dart'; import 'package:cw_core/monero_transaction_priority.dart'; import 'package:cw_core/monero_wallet_keys.dart'; import 'package:cw_core/monero_wallet_utils.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_direction.dart'; import 'package:cw_core/transaction_priority.dart'; import 'package:cw_core/unspent_coins_info.dart'; import 'package:cw_core/wallet_base.dart'; import 'package:cw_core/wallet_info.dart'; import 'package:cw_core/wownero_amount_format.dart'; import 'package:cw_core/wownero_balance.dart'; import 'package:cw_wownero/api/coins_info.dart'; import 'package:cw_wownero/api/structs/pending_transaction.dart'; import 'package:cw_wownero/api/transaction_history.dart' as transaction_history; import 'package:cw_wownero/api/wallet.dart' as wownero_wallet; import 'package:cw_wownero/api/wallet_manager.dart'; import 'package:cw_wownero/api/wownero_output.dart'; import 'package:cw_wownero/exceptions/wownero_transaction_creation_exception.dart'; import 'package:cw_wownero/exceptions/wownero_transaction_no_inputs_exception.dart'; import 'package:cw_wownero/pending_wownero_transaction.dart'; import 'package:cw_wownero/wownero_transaction_creation_credentials.dart'; import 'package:cw_wownero/wownero_transaction_history.dart'; import 'package:cw_wownero/wownero_transaction_info.dart'; import 'package:cw_wownero/wownero_unspent.dart'; import 'package:cw_wownero/wownero_wallet_addresses.dart'; import 'package:flutter/foundation.dart'; import 'package:hive/hive.dart'; import 'package:mobx/mobx.dart'; import 'package:monero/wownero.dart' as wownero; part 'wownero_wallet.g.dart'; const wowneroBlockSize = 1000; // not sure if this should just be 0 but setting it higher feels safer / should catch more cases: const MIN_RESTORE_HEIGHT = 1000; class WowneroWallet = WowneroWalletBase with _$WowneroWallet; abstract class WowneroWalletBase extends WalletBase with Store { WowneroWalletBase( {required WalletInfo walletInfo, required Box unspentCoinsInfo}) : balance = ObservableMap.of({ CryptoCurrency.wow: WowneroBalance( fullBalance: wownero_wallet.getFullBalance(accountIndex: 0), unlockedBalance: wownero_wallet.getFullBalance(accountIndex: 0)) }), _isTransactionUpdating = false, _hasSyncAfterStartup = false, isEnabledAutoGenerateSubaddress = false, syncStatus = NotConnectedSyncStatus(), unspentCoins = [], this.unspentCoinsInfo = unspentCoinsInfo, super(walletInfo) { transactionHistory = WowneroTransactionHistory(); walletAddresses = WowneroWalletAddresses(walletInfo, transactionHistory); _onAccountChangeReaction = reaction((_) => walletAddresses.account, (Account? account) { if (account == null) return; balance = ObservableMap.of({ currency: WowneroBalance( fullBalance: wownero_wallet.getFullBalance(accountIndex: account.id), unlockedBalance: wownero_wallet.getUnlockedBalance(accountIndex: account.id)) }); _updateSubAddress(isEnabledAutoGenerateSubaddress, account: account); _askForUpdateTransactionHistory(); }); reaction((_) => isEnabledAutoGenerateSubaddress, (bool enabled) { _updateSubAddress(enabled, account: walletAddresses.account); }); } static const int _autoSaveInterval = 30; Box unspentCoinsInfo; void Function(FlutterErrorDetails)? onError; @override late WowneroWalletAddresses walletAddresses; @override @observable bool isEnabledAutoGenerateSubaddress; @override @observable SyncStatus syncStatus; @override @observable ObservableMap balance; @override String get seed => wownero_wallet.getSeed(); String seedLegacy(String? language) { return wownero_wallet.getSeedLegacy(language); } @override MoneroWalletKeys get keys => MoneroWalletKeys( privateSpendKey: wownero_wallet.getSecretSpendKey(), privateViewKey: wownero_wallet.getSecretViewKey(), publicSpendKey: wownero_wallet.getPublicSpendKey(), publicViewKey: wownero_wallet.getPublicViewKey()); wownero_wallet.SyncListener? _listener; ReactionDisposer? _onAccountChangeReaction; bool _isTransactionUpdating; bool _hasSyncAfterStartup; Timer? _autoSaveTimer; List unspentCoins; Future init() async { await walletAddresses.init(); balance = ObservableMap.of({ currency: WowneroBalance( fullBalance: wownero_wallet.getFullBalance(accountIndex: walletAddresses.account!.id), unlockedBalance: wownero_wallet.getUnlockedBalance(accountIndex: walletAddresses.account!.id)) }); _setListeners(); await updateTransactions(); if (walletInfo.isRecovery) { wownero_wallet.setRecoveringFromSeed(isRecovery: walletInfo.isRecovery); if (wownero_wallet.getCurrentHeight() <= 1) { wownero_wallet.setRefreshFromBlockHeight(height: walletInfo.restoreHeight); } } _autoSaveTimer = Timer.periodic(Duration(seconds: _autoSaveInterval), (_) async => await save()); } @override Future? updateBalance() => null; @override void close() async { _listener?.stop(); _onAccountChangeReaction?.reaction.dispose(); _autoSaveTimer?.cancel(); } @override Future connectToNode({required Node node}) async { try { syncStatus = ConnectingSyncStatus(); await wownero_wallet.setupNode( address: node.uri.toString(), login: node.login, password: node.password, useSSL: node.isSSL, isLightWallet: false, // FIXME: hardcoded value socksProxyAddress: node.socksProxyAddress); wownero_wallet.setTrustedDaemon(node.trusted); syncStatus = ConnectedSyncStatus(); } catch (e) { syncStatus = FailedSyncStatus(); print(e); } } @override Future startSync() async { try { _setInitialHeight(); } catch (_) { // our restore height wasn't correct, so lets see if using the backup works: try { await resetCache(name); _setInitialHeight(); } catch (e) { // we still couldn't get a valid height from the backup?!: // try to use the date instead: try { _setHeightFromDate(); } catch (_) { // we still couldn't get a valid sync height :/ } } } try { syncStatus = AttemptingSyncStatus(); wownero_wallet.startRefresh(); _setListeners(); _listener?.start(); } catch (e) { syncStatus = FailedSyncStatus(); print(e); rethrow; } } @override Future createTransaction(Object credentials) async { final _credentials = credentials as WowneroTransactionCreationCredentials; final inputs = []; final outputs = _credentials.outputs; final hasMultiDestination = outputs.length > 1; final unlockedBalance = wownero_wallet.getUnlockedBalance(accountIndex: walletAddresses.account!.id); var allInputsAmount = 0; PendingTransactionDescription pendingTransactionDescription; if (!(syncStatus is SyncedSyncStatus)) { throw WowneroTransactionCreationException('The wallet is not synced.'); } if (unspentCoins.isEmpty) { await updateUnspent(); } for (final utx in unspentCoins) { if (utx.isSending) { allInputsAmount += utx.value; inputs.add(utx.keyImage!); } } final spendAllCoins = inputs.length == unspentCoins.length; if (hasMultiDestination) { if (outputs.any((item) => item.sendAll || (item.formattedCryptoAmount ?? 0) <= 0)) { throw WowneroTransactionCreationException( 'You do not have enough WOW to send this amount.'); } final int totalAmount = outputs.fold(0, (acc, value) => acc + (value.formattedCryptoAmount ?? 0)); final estimatedFee = calculateEstimatedFee(_credentials.priority, totalAmount); if (unlockedBalance < totalAmount) { throw WowneroTransactionCreationException( 'You do not have enough WOW to send this amount.'); } if (!spendAllCoins && (allInputsAmount < totalAmount + estimatedFee)) { throw WowneroTransactionNoInputsException(inputs.length); } final wowneroOutputs = outputs.map((output) { final outputAddress = output.isParsedAddress ? output.extractedAddress : output.address; return WowneroOutput( address: outputAddress!, amount: output.cryptoAmount!.replaceAll(',', '.')); }).toList(); pendingTransactionDescription = await transaction_history.createTransactionMultDest( outputs: wowneroOutputs, priorityRaw: _credentials.priority.serialize(), accountIndex: walletAddresses.account!.id, preferredInputs: inputs); } else { final output = outputs.first; final address = output.isParsedAddress ? output.extractedAddress : output.address; final amount = output.sendAll ? null : output.cryptoAmount!.replaceAll(',', '.'); final formattedAmount = output.sendAll ? null : output.formattedCryptoAmount; if ((formattedAmount != null && unlockedBalance < formattedAmount) || (formattedAmount == null && unlockedBalance <= 0)) { final formattedBalance = wowneroAmountToString(amount: unlockedBalance); throw WowneroTransactionCreationException( 'You do not have enough unlocked balance. Unlocked: $formattedBalance. Transaction amount: ${output.cryptoAmount}.'); } final estimatedFee = calculateEstimatedFee(_credentials.priority, formattedAmount); if (!spendAllCoins && ((formattedAmount != null && allInputsAmount < (formattedAmount + estimatedFee)) || formattedAmount == null)) { throw WowneroTransactionNoInputsException(inputs.length); } pendingTransactionDescription = await transaction_history.createTransaction( address: address!, amount: amount, priorityRaw: _credentials.priority.serialize(), accountIndex: walletAddresses.account!.id, preferredInputs: inputs); } return PendingWowneroTransaction(pendingTransactionDescription); } @override int calculateEstimatedFee(TransactionPriority priority, int? amount) { // FIXME: hardcoded value; if (priority is MoneroTransactionPriority) { switch (priority) { case MoneroTransactionPriority.slow: return 24590000; case MoneroTransactionPriority.automatic: return 123050000; case MoneroTransactionPriority.medium: return 245029999; case MoneroTransactionPriority.fast: return 614530000; case MoneroTransactionPriority.fastest: return 26021600000; } } return 0; } @override Future save() async { await walletAddresses.updateUsedSubaddress(); if (isEnabledAutoGenerateSubaddress) { walletAddresses.updateUnusedSubaddress( accountIndex: walletAddresses.account?.id ?? 0, defaultLabel: walletAddresses.account?.label ?? ''); } await walletAddresses.updateAddressesInBox(); await wownero_wallet.store(); try { await backupWalletFiles(name); } catch (e) { print("¯\\_(ツ)_/¯"); print(e); } } @override Future renameWalletFiles(String newWalletName) async { final currentWalletDirPath = await pathForWalletDir(name: name, type: type); if (openedWalletsByPath["$currentWalletDirPath/$name"] != null) { // NOTE: this is realistically only required on windows. print("closing wallet"); final wmaddr = wmPtr.address; final waddr = openedWalletsByPath["$currentWalletDirPath/$name"]!.address; await Isolate.run(() { wownero.WalletManager_closeWallet( Pointer.fromAddress(wmaddr), Pointer.fromAddress(waddr), true); }); openedWalletsByPath.remove("$currentWalletDirPath/$name"); print("wallet closed"); } 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'); } await backupWalletFiles(newWalletName); } 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 changePassword(String password) async => wownero_wallet.setPasswordSync(password); Future getNodeHeight() async => wownero_wallet.getNodeHeight(); Future isConnected() async => wownero_wallet.isConnected(); Future setAsRecovered() async { walletInfo.isRecovery = false; await walletInfo.save(); } @override Future rescan({required int height}) async { walletInfo.restoreHeight = height; walletInfo.isRecovery = true; wownero_wallet.setRefreshFromBlockHeight(height: height); wownero_wallet.rescanBlockchainAsync(); await startSync(); _askForUpdateBalance(); walletAddresses.accountList.update(); await _askForUpdateTransactionHistory(); await save(); await walletInfo.save(); } Future updateUnspent() async { try { refreshCoins(walletAddresses.account!.id); unspentCoins.clear(); final coinCount = countOfCoins(); for (var i = 0; i < coinCount; i++) { final coin = getCoin(i); final coinSpent = wownero.CoinsInfo_spent(coin); if (coinSpent == false) { final unspent = WowneroUnspent( wownero.CoinsInfo_address(coin), wownero.CoinsInfo_hash(coin), wownero.CoinsInfo_keyImage(coin), wownero.CoinsInfo_amount(coin), wownero.CoinsInfo_frozen(coin), wownero.CoinsInfo_unlocked(coin), ); if (unspent.hash.isNotEmpty) { unspent.isChange = transaction_history.getTransaction(unspent.hash) == 1; } unspentCoins.add(unspent); } } if (unspentCoinsInfo.isEmpty) { unspentCoins.forEach((coin) => _addCoinInfo(coin)); return; } if (unspentCoins.isNotEmpty) { unspentCoins.forEach((coin) { final coinInfoList = unspentCoinsInfo.values.where((element) => element.walletId.contains(id) && element.accountIndex == walletAddresses.account!.id && element.keyImage!.contains(coin.keyImage!)); if (coinInfoList.isNotEmpty) { final coinInfo = coinInfoList.first; coin.isFrozen = coinInfo.isFrozen; coin.isSending = coinInfo.isSending; coin.note = coinInfo.note; } else { _addCoinInfo(coin); } }); } await _refreshUnspentCoinsInfo(); _askForUpdateBalance(); } catch (e, s) { print(e.toString()); onError?.call(FlutterErrorDetails( exception: e, stack: s, library: this.runtimeType.toString(), )); } } Future _addCoinInfo(WowneroUnspent coin) async { final newInfo = UnspentCoinsInfo( walletId: id, hash: coin.hash, isFrozen: coin.isFrozen, isSending: coin.isSending, noteRaw: coin.note, address: coin.address, value: coin.value, vout: 0, keyImage: coin.keyImage, isChange: coin.isChange, accountIndex: walletAddresses.account!.id); await unspentCoinsInfo.add(newInfo); } Future _refreshUnspentCoinsInfo() async { try { final List keys = []; final currentWalletUnspentCoins = unspentCoinsInfo.values.where((element) => element.walletId.contains(id) && element.accountIndex == walletAddresses.account!.id); if (currentWalletUnspentCoins.isNotEmpty) { currentWalletUnspentCoins.forEach((element) { final existUnspentCoins = unspentCoins.where((coin) => element.keyImage!.contains(coin.keyImage!)); if (existUnspentCoins.isEmpty) { keys.add(element.key); } }); } if (keys.isNotEmpty) { await unspentCoinsInfo.deleteAll(keys); } } catch (e) { print(e.toString()); } } String getTransactionAddress(int accountIndex, int addressIndex) => wownero_wallet.getAddress(accountIndex: accountIndex, addressIndex: addressIndex); @override Future> fetchTransactions() async { transaction_history.refreshTransactions(); return _getAllTransactionsOfAccount(walletAddresses.account?.id) .fold>({}, (Map acc, WowneroTransactionInfo tx) { acc[tx.id] = tx; return acc; }); } Future updateTransactions() async { try { if (_isTransactionUpdating) { return; } _isTransactionUpdating = true; transactionHistory.clear(); final transactions = await fetchTransactions(); transactionHistory.addMany(transactions); await transactionHistory.save(); _isTransactionUpdating = false; } catch (e) { print(e); _isTransactionUpdating = false; } } String getSubaddressLabel(int accountIndex, int addressIndex) => wownero_wallet.getSubaddressLabel(accountIndex, addressIndex); List _getAllTransactionsOfAccount(int? accountIndex) => transaction_history .getAllTransactions() .map( (row) => WowneroTransactionInfo( row.hash, row.blockheight, row.isSpend ? TransactionDirection.outgoing : TransactionDirection.incoming, row.timeStamp, row.isPending, row.amount, row.accountIndex, 0, row.fee, row.confirmations, )..additionalInfo = { 'key': row.key, 'accountIndex': row.accountIndex, 'addressIndex': row.addressIndex }, ) .where((element) => element.accountIndex == (accountIndex ?? 0)) .toList(); void _setListeners() { _listener?.stop(); _listener = wownero_wallet.setListeners(_onNewBlock, _onNewTransaction); } // check if the height is correct: void _setInitialHeight() { if (walletInfo.isRecovery) { return; } final height = wownero_wallet.getCurrentHeight(); if (height > MIN_RESTORE_HEIGHT) { // the restore height is probably correct, so we do nothing: return; } throw Exception("height isn't > $MIN_RESTORE_HEIGHT!"); } void _setHeightFromDate() { if (walletInfo.isRecovery) { return; } int height = 0; try { height = _getHeightByDate(walletInfo.date); } catch (_) {} wownero_wallet.setRecoveringFromSeed(isRecovery: true); wownero_wallet.setRefreshFromBlockHeight(height: height); } int _getHeightDistance(DateTime date) { final distance = DateTime.now().millisecondsSinceEpoch - date.millisecondsSinceEpoch; final daysTmp = (distance / 86400).round(); final days = daysTmp < 1 ? 1 : daysTmp; return days * 1000; } int _getHeightByDate(DateTime date) { final nodeHeight = wownero_wallet.getNodeHeightSync(); final heightDistance = _getHeightDistance(date); if (nodeHeight <= 0) { // the node returned 0 (an error state) throw Exception("nodeHeight is <= 0!"); } return nodeHeight - heightDistance; } void _askForUpdateBalance() { final unlockedBalance = _getUnlockedBalance(); final fullBalance = _getFullBalance(); final frozenBalance = _getFrozenBalance(); if (balance[currency]!.fullBalance != fullBalance || balance[currency]!.unlockedBalance != unlockedBalance || balance[currency]!.frozenBalance != frozenBalance) { balance[currency] = WowneroBalance( fullBalance: fullBalance, unlockedBalance: unlockedBalance, frozenBalance: frozenBalance); } } Future _askForUpdateTransactionHistory() async => await updateTransactions(); int _getFullBalance() => wownero_wallet.getFullBalance(accountIndex: walletAddresses.account!.id); int _getUnlockedBalance() => wownero_wallet.getUnlockedBalance(accountIndex: walletAddresses.account!.id); int _getFrozenBalance() { var frozenBalance = 0; for (var coin in unspentCoinsInfo.values.where((element) => element.walletId == id && element.accountIndex == walletAddresses.account!.id)) { if (coin.isFrozen) frozenBalance += coin.value; } return frozenBalance; } void _onNewBlock(int height, int blocksLeft, double ptc) async { try { if (walletInfo.isRecovery) { await _askForUpdateTransactionHistory(); _askForUpdateBalance(); walletAddresses.accountList.update(); } if (blocksLeft < 100) { await _askForUpdateTransactionHistory(); _askForUpdateBalance(); walletAddresses.accountList.update(); syncStatus = SyncedSyncStatus(); if (!_hasSyncAfterStartup) { _hasSyncAfterStartup = true; await save(); } if (walletInfo.isRecovery) { await setAsRecovered(); } } else { syncStatus = SyncingSyncStatus(blocksLeft, ptc); } } catch (e) { print(e.toString()); } } void _onNewTransaction() async { try { await _askForUpdateTransactionHistory(); _askForUpdateBalance(); await Future.delayed(Duration(seconds: 1)); } catch (e) { print(e.toString()); } } void _updateSubAddress(bool enableAutoGenerate, {Account? account}) { if (enableAutoGenerate) { walletAddresses.updateUnusedSubaddress( accountIndex: account?.id ?? 0, defaultLabel: account?.label ?? '', ); } else { walletAddresses.updateSubaddressList(accountIndex: account?.id ?? 0); } } @override void setExceptionHandler(void Function(FlutterErrorDetails) e) => onError = e; @override Future signMessage(String message, {String? address}) async { final useAddress = address ?? ""; return wownero_wallet.signMessage(message, address: useAddress); } }