import 'dart:async'; import 'dart:convert'; import 'package:cw_core/crypto_currency.dart'; import 'package:cw_ethereum/erc20_balance.dart'; import 'package:cw_core/erc20_token.dart'; import 'package:cw_ethereum/ethereum_transaction_model.dart'; import 'package:cw_ethereum/pending_ethereum_transaction.dart'; import 'package:flutter/services.dart'; import 'package:http/http.dart'; import 'package:web3dart/web3dart.dart'; import 'package:erc20/erc20.dart'; import 'package:cw_core/node.dart'; import 'package:cw_ethereum/ethereum_transaction_priority.dart'; import 'package:cw_ethereum/.secrets.g.dart' as secrets; class EthereumClient { final _httpClient = Client(); Web3Client? _client; bool connect(Node node) { try { _client = Web3Client(node.uri.toString(), _httpClient); return true; } catch (e) { return false; } } void setListeners(EthereumAddress userAddress, Function() onNewTransaction) async { // _client?.pendingTransactions().listen((transactionHash) async { // final transaction = await _client!.getTransactionByHash(transactionHash); // // if (transaction.from.hex == userAddress || transaction.to?.hex == userAddress) { // onNewTransaction(); // } // }); } Future getBalance(EthereumAddress address) async { try { return await _client!.getBalance(address); } catch (_) { return EtherAmount.zero(); } } Future getGasUnitPrice() async { try { final gasPrice = await _client!.getGasPrice(); return gasPrice.getInWei.toInt(); } catch (_) { return 0; } } Future getEstimatedGas() async { try { final estimatedGas = await _client!.estimateGas(); return estimatedGas.toInt(); } catch (_) { return 0; } } Future signTransaction({ required EthPrivateKey privateKey, required String toAddress, required String amount, required int gas, required EthereumTransactionPriority priority, required CryptoCurrency currency, required int exponent, String? contractAddress, }) async { assert(currency == CryptoCurrency.eth || contractAddress != null); bool _isEthereum = currency == CryptoCurrency.eth; final price = _client!.getGasPrice(); final Transaction transaction = Transaction( from: privateKey.address, to: EthereumAddress.fromHex(toAddress), maxPriorityFeePerGas: EtherAmount.fromInt(EtherUnit.gwei, priority.tip), value: _isEthereum ? EtherAmount.inWei(BigInt.parse(amount)) : EtherAmount.zero(), ); final signedTransaction = await _client!.signTransaction(privateKey, transaction); final Function _sendTransaction; if (_isEthereum) { _sendTransaction = () async => await sendTransaction(signedTransaction); } else { final erc20 = ERC20( client: _client!, address: EthereumAddress.fromHex(contractAddress!), ); _sendTransaction = () async { await erc20.transfer( EthereumAddress.fromHex(toAddress), BigInt.parse(amount), credentials: privateKey, transaction: transaction, ); }; } return PendingEthereumTransaction( signedTransaction: signedTransaction, amount: amount, fee: BigInt.from(gas) * (await price).getInWei, sendTransaction: _sendTransaction, exponent: exponent, ); } Future sendTransaction(Uint8List signedTransaction) async => await _client!.sendRawTransaction(prependTransactionType(0x02, signedTransaction)); Future getTransactionDetails(String transactionHash) async { // Wait for the transaction receipt to become available TransactionReceipt? receipt; while (receipt == null) { receipt = await _client!.getTransactionReceipt(transactionHash); await Future.delayed(Duration(seconds: 1)); } // Print the receipt information print('Transaction Hash: ${receipt.transactionHash}'); print('Block Hash: ${receipt.blockHash}'); print('Block Number: ${receipt.blockNumber}'); print('Gas Used: ${receipt.gasUsed}'); /* Transaction Hash: [112, 244, 4, 238, 89, 199, 171, 191, 210, 236, 110, 42, 185, 202, 220, 21, 27, 132, 123, 221, 137, 90, 77, 13, 23, 43, 12, 230, 93, 63, 221, 116] I/flutter ( 4474): Block Hash: [149, 44, 250, 119, 111, 104, 82, 98, 17, 89, 30, 190, 25, 44, 218, 118, 127, 189, 241, 35, 213, 106, 25, 95, 195, 37, 55, 131, 185, 180, 246, 200] I/flutter ( 4474): Block Number: 17120242 I/flutter ( 4474): Gas Used: 21000 */ // Wait for the transaction receipt to become available TransactionInformation? transactionInformation; while (transactionInformation == null) { print("********************************"); transactionInformation = await _client!.getTransactionByHash(transactionHash); await Future.delayed(Duration(seconds: 1)); } // Print the receipt information print('Transaction Hash: ${transactionInformation.hash}'); print('Block Hash: ${transactionInformation.blockHash}'); print('Block Number: ${transactionInformation.blockNumber}'); print('Gas Used: ${transactionInformation.gas}'); /* Transaction Hash: 0x70f404ee59c7abbfd2ec6e2ab9cadc151b847bdd895a4d0d172b0ce65d3fdd74 I/flutter ( 4474): Block Hash: 0x952cfa776f68526211591ebe192cda767fbdf123d56a195fc3253783b9b4f6c8 I/flutter ( 4474): Block Number: 17120242 I/flutter ( 4474): Gas Used: 53000 */ } Future fetchERC20Balances( EthereumAddress userAddress, String contractAddress) async { final erc20 = ERC20(address: EthereumAddress.fromHex(contractAddress), client: _client!); final balance = await erc20.balanceOf(userAddress); int exponent = (await erc20.decimals()).toInt(); return ERC20Balance(balance, exponent: exponent); } Future getErc20Token(String contractAddress) async { try { final erc20 = ERC20(address: EthereumAddress.fromHex(contractAddress), client: _client!); final name = await erc20.name(); final symbol = await erc20.symbol(); final decimal = await erc20.decimals(); return Erc20Token( name: name, symbol: symbol, contractAddress: contractAddress, decimal: decimal.toInt(), ); } catch (e) { return null; } } void stop() { _client?.dispose(); } Future> fetchTransactions(String address, {String? contractAddress}) async { try { final response = await _httpClient.get(Uri.https("api.etherscan.io", "/api", { "module": "account", "action": contractAddress != null ? "tokentx" : "txlist", if (contractAddress != null) "contractaddress": contractAddress, "address": address, "apikey": secrets.etherScanApiKey, })); final _jsonResponse = json.decode(response.body) as Map; if (response.statusCode >= 200 && response.statusCode < 300 && _jsonResponse['status'] != 0) { return (_jsonResponse['result'] as List) .map((e) => EthereumTransactionModel.fromJson(e as Map)) .toList(); } return []; } catch (e) { print(e); return []; } } Web3Client? getWeb3Client() { return _client; } // Future _getDecimalPlacesForContract(DeployedContract contract) async { // final String abi = await rootBundle.loadString("assets/abi_json/erc20_abi.json"); // final contractAbi = ContractAbi.fromJson(abi, "ERC20"); // // final contract = DeployedContract( // contractAbi, // EthereumAddress.fromHex(_erc20Currencies[erc20Currency]!), // ); // final decimalsFunction = contract.function('decimals'); // final decimals = await _client!.call( // contract: contract, // function: decimalsFunction, // params: [], // ); // // int exponent = int.parse(decimals.first.toString()); // return exponent; // } }