import 'dart:async'; import 'dart:convert'; import 'package:ethereum_addresses/ethereum_addresses.dart'; import 'package:http/http.dart'; import 'package:isar/isar.dart'; import 'package:stackwallet/models/balance.dart'; import 'package:stackwallet/models/isar/models/blockchain_data/address.dart'; import 'package:stackwallet/models/isar/models/blockchain_data/transaction.dart'; import 'package:stackwallet/models/isar/models/blockchain_data/v2/input_v2.dart'; import 'package:stackwallet/models/isar/models/blockchain_data/v2/output_v2.dart'; import 'package:stackwallet/models/isar/models/blockchain_data/v2/transaction_v2.dart'; import 'package:stackwallet/models/paymint/fee_object_model.dart'; import 'package:stackwallet/services/ethereum/ethereum_api.dart'; import 'package:stackwallet/services/event_bus/events/global/updated_in_background_event.dart'; import 'package:stackwallet/services/event_bus/global_event_bus.dart'; import 'package:stackwallet/utilities/amount/amount.dart'; import 'package:stackwallet/utilities/enums/coin_enum.dart'; import 'package:stackwallet/utilities/eth_commons.dart'; import 'package:stackwallet/utilities/logger.dart'; import 'package:stackwallet/wallets/crypto_currency/coins/ethereum.dart'; import 'package:stackwallet/wallets/crypto_currency/crypto_currency.dart'; import 'package:stackwallet/wallets/models/tx_data.dart'; import 'package:stackwallet/wallets/wallet/intermediate/bip39_wallet.dart'; import 'package:stackwallet/wallets/wallet/wallet_mixin_interfaces/private_key_interface.dart'; import 'package:web3dart/web3dart.dart' as web3; // Eth can not use tor with web3dart class EthereumWallet extends Bip39Wallet with PrivateKeyInterface { EthereumWallet(CryptoCurrencyNetwork network) : super(Ethereum(network)); Timer? timer; late web3.EthPrivateKey _credentials; Future updateTokenContracts(List contractAddresses) async { await info.updateContractAddresses( newContractAddresses: contractAddresses.toSet(), isar: mainDB.isar, ); GlobalEventBus.instance.fire( UpdatedInBackgroundEvent( "$contractAddresses updated/added for: $walletId ${info.name}", walletId, ), ); } web3.Web3Client getEthClient() { final node = getCurrentNode(); // Eth can not use tor with web3dart as Client does not support proxies final client = Client(); return web3.Web3Client(node.host, client); } // ==================== Private ============================================== Future _initCredentials( String mnemonic, String mnemonicPassphrase, ) async { String privateKey = getPrivateKey(mnemonic, mnemonicPassphrase); _credentials = web3.EthPrivateKey.fromHex(privateKey); } Future _generateAndSaveAddress( String mnemonic, String mnemonicPassphrase, ) async { await _initCredentials(mnemonic, mnemonicPassphrase); final address = Address( walletId: walletId, value: _credentials.address.hexEip55, publicKey: [], // maybe store address bytes here? seems a waste of space though derivationIndex: 0, derivationPath: DerivationPath()..value = "$hdPathEthereum/0", type: AddressType.ethereum, subType: AddressSubType.receiving, ); await mainDB.updateOrPutAddresses([address]); } // delete @override Future
getCurrentReceivingAddress() async { return Address( walletId: walletId, value: checksumEthereumAddress("0x6Cc3006944070B32D80107D51d843a66EaC00686"), publicKey: [], // maybe store address bytes here? seems a waste of space though derivationIndex: 0, derivationPath: DerivationPath()..value = "$hdPathEthereum/0", type: AddressType.ethereum, subType: AddressSubType.receiving, ); } // ==================== Overrides ============================================ @override FilterOperation? get changeAddressFilterOperation => FilterGroup.and(standardChangeAddressFilters); @override FilterOperation? get receivingAddressFilterOperation => FilterGroup.and(standardReceivingAddressFilters); @override Future init({bool? isRestore}) { // TODO: implement init return super.init(); } @override Future estimateFeeFor(Amount amount, int feeRate) async { return estimateFee( feeRate, (cryptoCurrency as Ethereum).gasLimit, cryptoCurrency.fractionDigits, ); } @override Future get fees => EthereumAPI.getFees(); @override Future pingCheck() async { web3.Web3Client client = getEthClient(); try { await client.getBlockNumber(); return true; } catch (_) { return false; } } @override Future updateBalance() async { try { final client = getEthClient(); final addressHex = (await getCurrentReceivingAddress())!.value; final address = web3.EthereumAddress.fromHex(addressHex); web3.EtherAmount ethBalance = await client.getBalance(address); final balance = Balance( total: Amount( rawValue: ethBalance.getInWei, fractionDigits: cryptoCurrency.fractionDigits, ), spendable: Amount( rawValue: ethBalance.getInWei, fractionDigits: cryptoCurrency.fractionDigits, ), blockedTotal: Amount.zeroWith( fractionDigits: cryptoCurrency.fractionDigits, ), pendingSpendable: Amount.zeroWith( fractionDigits: cryptoCurrency.fractionDigits, ), ); await info.updateBalance( newBalance: balance, isar: mainDB.isar, ); } catch (e, s) { Logging.instance.log( "$runtimeType wallet failed to update balance: $e\n$s", level: LogLevel.Warning, ); } } @override Future updateChainHeight() async { try { final client = getEthClient(); final height = await client.getBlockNumber(); await info.updateCachedChainHeight( newHeight: height, isar: mainDB.isar, ); } catch (e, s) { Logging.instance.log( "$runtimeType Exception caught in chainHeight: $e\n$s", level: LogLevel.Warning, ); } } @override Future updateNode() async { // do nothing } @override Future updateTransactions({bool isRescan = false}) async { String thisAddress = (await getCurrentReceivingAddress())!.value; int firstBlock = 0; if (!isRescan) { firstBlock = await mainDB.isar.transactionV2s .where() .walletIdEqualTo(walletId) .heightProperty() .max() ?? 0; if (firstBlock > 10) { // add some buffer firstBlock -= 10; } } final response = await EthereumAPI.getEthTransactions( address: thisAddress, firstBlock: isRescan ? 0 : firstBlock, includeTokens: true, ); if (response.value == null) { Logging.instance.log( "Failed to refresh transactions for ${cryptoCurrency.coin.prettyName} ${info.name} " "$walletId: ${response.exception}", level: LogLevel.Warning, ); return; } if (response.value!.isEmpty) { // no new transactions found return; } final txsResponse = await EthereumAPI.getEthTransactionNonces(response.value!); if (txsResponse.value != null) { final allTxs = txsResponse.value!; final List txns = []; for (final tuple in allTxs) { final element = tuple.item1; //Calculate fees (GasLimit * gasPrice) // int txFee = element.gasPrice * element.gasUsed; Amount txFee = element.gasCost; final transactionAmount = element.value; final addressFrom = checksumEthereumAddress(element.from); final addressTo = checksumEthereumAddress(element.to); bool isIncoming; bool txFailed = false; if (addressFrom == thisAddress) { if (element.isError) { txFailed = true; } isIncoming = false; } else if (addressTo == thisAddress) { isIncoming = true; } else { continue; } // hack epic tx data into inputs and outputs final List outputs = []; final List inputs = []; OutputV2 output = OutputV2.isarCantDoRequiredInDefaultConstructor( scriptPubKeyHex: "00", valueStringSats: transactionAmount.raw.toString(), addresses: [ addressTo, ], walletOwns: addressTo == thisAddress, ); InputV2 input = InputV2.isarCantDoRequiredInDefaultConstructor( scriptSigHex: null, sequence: null, outpoint: null, addresses: [addressFrom], valueStringSats: transactionAmount.raw.toString(), witness: null, innerRedeemScriptAsm: null, coinbase: null, walletOwns: addressFrom == thisAddress, ); final TransactionType txType; if (isIncoming) { if (addressFrom == addressTo) { txType = TransactionType.sentToSelf; } else { txType = TransactionType.incoming; } } else { txType = TransactionType.outgoing; } outputs.add(output); inputs.add(input); final otherData = { "nonce": tuple.item2, "isCancelled": txFailed, "anonFees": txFee.toJsonString(), }; final txn = TransactionV2( walletId: walletId, blockHash: element.blockHash, hash: element.hash, txid: element.hash, timestamp: element.timestamp, height: element.blockNumber, inputs: List.unmodifiable(inputs), outputs: List.unmodifiable(outputs), version: -1, type: txType, subType: TransactionSubType.none, otherData: jsonEncode(otherData), ); txns.add(txn); } await mainDB.updateOrPutTransactionV2s(txns); } else { Logging.instance.log( "Failed to refresh transactions with nonces for ${cryptoCurrency.coin.prettyName} " "${info.name} $walletId: ${txsResponse.exception}", level: LogLevel.Warning, ); } } @override Future updateUTXOs() async { // not used in eth return false; } @override Future confirmSend({required TxData txData}) { // TODO: implement confirmSend throw UnimplementedError(); } @override Future prepareSend({required TxData txData}) { // TODO: implement prepareSend throw UnimplementedError(); } @override Future recover({required bool isRescan}) async { if (isRescan) { await mainDB.deleteWalletBlockchainData(walletId); await _generateAndSaveAddress( await getMnemonic(), await getMnemonicPassphrase(), ); await updateBalance(); await updateTransactions(isRescan: true); } else { // } } @override Future exit() async { timer?.cancel(); timer = null; await super.exit(); } }