stack_wallet/lib/services/ethereum/ethereum_api.dart

554 lines
16 KiB
Dart
Raw Normal View History

2023-02-23 22:59:58 +00:00
import 'dart:convert';
import 'dart:math';
import 'package:decimal/decimal.dart';
2023-02-23 22:59:58 +00:00
import 'package:http/http.dart';
import 'package:stackwallet/dto/ethereum/eth_token_tx_dto.dart';
import 'package:stackwallet/dto/ethereum/eth_token_tx_extra_dto.dart';
import 'package:stackwallet/dto/ethereum/eth_tx_dto.dart';
import 'package:stackwallet/models/isar/models/ethereum/eth_contract.dart';
2023-02-23 22:59:58 +00:00
import 'package:stackwallet/models/paymint/fee_object_model.dart';
import 'package:stackwallet/utilities/default_nodes.dart';
2023-02-23 22:59:58 +00:00
import 'package:stackwallet/utilities/eth_commons.dart';
import 'package:stackwallet/utilities/logger.dart';
2023-02-28 22:03:36 +00:00
class EthApiException with Exception {
EthApiException(this.message);
final String message;
@override
String toString() => "$runtimeType: $message";
}
2023-02-23 22:59:58 +00:00
class EthereumResponse<T> {
EthereumResponse(this.value, this.exception);
2023-02-23 22:59:58 +00:00
final T? value;
2023-02-28 22:03:36 +00:00
final EthApiException? exception;
2023-02-23 22:59:58 +00:00
@override
toString() => "EthereumResponse: { value: $value, exception: $exception }";
2023-02-23 22:59:58 +00:00
}
abstract class EthereumAPI {
static String get stackBaseServer => DefaultNodes.ethereum.host;
static Future<EthereumResponse<List<EthTxDTO>>> getEthTransactions(
2023-03-01 20:50:14 +00:00
String address) async {
2023-02-23 22:59:58 +00:00
try {
final response = await get(
Uri.parse(
"$stackBaseServer/export?addrs=$address",
),
);
2023-02-23 22:59:58 +00:00
if (response.statusCode == 200) {
if (response.body.isNotEmpty) {
final json = jsonDecode(response.body) as Map;
final list = json["data"] as List?;
final List<EthTxDTO> txns = [];
for (final map in list!) {
final txn = EthTxDTO.fromMap(Map<String, dynamic>.from(map as Map));
2023-03-03 17:36:40 +00:00
if (txn.hasToken == 0) {
txns.add(txn);
}
}
return EthereumResponse(
txns,
null,
);
} else {
throw EthApiException(
"getEthTransactions($address) response is empty but status code is "
"${response.statusCode}",
);
}
2023-02-23 22:59:58 +00:00
} else {
throw EthApiException(
"getEthTransactions($address) failed with status code: "
"${response.statusCode}",
);
2023-02-23 22:59:58 +00:00
}
} on EthApiException catch (e) {
return EthereumResponse(
null,
e,
);
2023-02-23 22:59:58 +00:00
} catch (e, s) {
Logging.instance.log(
"getEthTransactions($address): $e\n$s",
level: LogLevel.Error,
);
return EthereumResponse(
null,
EthApiException(e.toString()),
);
2023-02-23 22:59:58 +00:00
}
}
static Future<EthereumResponse<List<EthTokenTxExtraDTO>>>
getEthTokenTransactionsByTxids(List<String> txids) async {
try {
final response = await get(
Uri.parse(
"$stackBaseServer/transactions?transactions=${txids.join(" ")}",
),
);
if (response.statusCode == 200) {
if (response.body.isNotEmpty) {
final json = jsonDecode(response.body) as Map;
final list = json["data"] as List?;
final List<EthTokenTxExtraDTO> txns = [];
for (final map in list!) {
final txn = EthTokenTxExtraDTO.fromMap(
Map<String, dynamic>.from(map as Map),
);
txns.add(txn);
}
return EthereumResponse(
txns,
null,
);
} else {
throw EthApiException(
"getEthTransaction($txids) response is empty but status code is "
"${response.statusCode}",
);
}
} else {
throw EthApiException(
"getEthTransaction($txids) failed with status code: "
"${response.statusCode}",
);
}
} on EthApiException catch (e) {
return EthereumResponse(
null,
e,
);
} catch (e, s) {
Logging.instance.log(
"getEthTransaction($txids): $e\n$s",
level: LogLevel.Error,
);
return EthereumResponse(
null,
EthApiException(e.toString()),
);
}
}
static Future<EthereumResponse<List<EthTokenTxDto>>> getTokenTransactions({
2023-02-24 16:22:25 +00:00
required String address,
required String tokenContractAddress,
2023-02-24 16:22:25 +00:00
}) async {
try {
final response = await get(
Uri.parse(
"$stackBaseServer/export?addrs=$address&emitter=$tokenContractAddress&logs=true",
),
);
2023-02-24 16:22:25 +00:00
if (response.statusCode == 200) {
if (response.body.isNotEmpty) {
final json = jsonDecode(response.body) as Map;
final list = json["data"] as List?;
final List<EthTokenTxDto> txns = [];
for (final map in list!) {
final txn =
EthTokenTxDto.fromMap(Map<String, dynamic>.from(map as Map));
2023-02-24 16:22:25 +00:00
txns.add(txn);
}
2023-02-24 16:22:25 +00:00
return EthereumResponse(
txns,
2023-02-24 16:22:25 +00:00
null,
);
} else {
throw EthApiException(
"getTokenTransactions($address, $tokenContractAddress) response is empty but status code is "
"${response.statusCode}",
);
2023-02-24 16:22:25 +00:00
}
} else {
2023-02-28 22:03:36 +00:00
throw EthApiException(
"getTokenTransactions($address, $tokenContractAddress) failed with status code: "
2023-02-24 16:22:25 +00:00
"${response.statusCode}",
);
}
2023-02-28 22:03:36 +00:00
} on EthApiException catch (e) {
return EthereumResponse(
null,
e,
);
2023-02-24 16:22:25 +00:00
} catch (e, s) {
Logging.instance.log(
"getTokenTransactions($address, $tokenContractAddress): $e\n$s",
2023-02-24 16:22:25 +00:00
level: LogLevel.Error,
);
return EthereumResponse(
null,
2023-02-28 22:03:36 +00:00
EthApiException(e.toString()),
2023-02-24 16:22:25 +00:00
);
}
}
2023-03-01 00:36:54 +00:00
// ONLY FETCHES WALLET TOKENS WITH A NON ZERO BALANCE
// static Future<EthereumResponse<List<EthToken>>> getWalletTokens({
// required String address,
// }) async {
// try {
// final uri = Uri.parse(
// "$blockExplorer?module=account&action=tokenlist&address=$address",
// );
// final response = await get(uri);
//
// if (response.statusCode == 200) {
// final json = jsonDecode(response.body);
// if (json["message"] == "OK") {
// final result =
// List<Map<String, dynamic>>.from(json["result"] as List);
// final List<EthToken> tokens = [];
// for (final map in result) {
// if (map["type"] == "ERC-20") {
// tokens.add(
// Erc20Token(
// balance: int.parse(map["balance"] as String),
// contractAddress: map["contractAddress"] as String,
// decimals: int.parse(map["decimals"] as String),
// name: map["name"] as String,
// symbol: map["symbol"] as String,
// ),
// );
// } else if (map["type"] == "ERC-721") {
// tokens.add(
// Erc721Token(
// balance: int.parse(map["balance"] as String),
// contractAddress: map["contractAddress"] as String,
// decimals: int.parse(map["decimals"] as String),
// name: map["name"] as String,
// symbol: map["symbol"] as String,
// ),
// );
// } else {
// throw EthApiException(
// "Unsupported token type found: ${map["type"]}");
// }
// }
//
// return EthereumResponse(
// tokens,
// null,
// );
// } else {
// throw EthApiException(json["message"] as String);
// }
// } else {
// throw EthApiException(
// "getWalletTokens($address) failed with status code: "
// "${response.statusCode}",
// );
// }
// } on EthApiException catch (e) {
// return EthereumResponse(
// null,
// e,
// );
// } catch (e, s) {
// Logging.instance.log(
// "getWalletTokens(): $e\n$s",
// level: LogLevel.Error,
// );
// return EthereumResponse(
// null,
// EthApiException(e.toString()),
// );
// }
// }
2023-02-23 22:59:58 +00:00
static Future<EthereumResponse<int>> getWalletTokenBalance({
required String address,
required String contractAddress,
}) async {
try {
final uri = Uri.parse(
"$stackBaseServer/tokens?addrs=$contractAddress $address",
);
final response = await get(uri);
if (response.statusCode == 200) {
final json = jsonDecode(response.body);
if (json["data"] is List) {
final map = json["data"].first as Map;
final bal = Decimal.tryParse(map["balance"].toString());
final int balance;
if (bal == null) {
balance = 0;
} else {
final int decimals = map["decimals"] as int;
balance = (bal * Decimal.fromInt(pow(10, decimals).truncate()))
.toBigInt()
.toInt();
}
return EthereumResponse(
balance,
null,
);
} else {
throw EthApiException(json["message"] as String);
}
} else {
throw EthApiException(
2023-03-02 00:02:53 +00:00
"getWalletTokenBalance($address) failed with status code: "
"${response.statusCode}",
);
}
} on EthApiException catch (e) {
return EthereumResponse(
null,
e,
);
} catch (e, s) {
Logging.instance.log(
2023-03-02 00:02:53 +00:00
"getWalletTokenBalance(): $e\n$s",
level: LogLevel.Error,
);
return EthereumResponse(
null,
EthApiException(e.toString()),
);
}
}
2023-02-23 22:59:58 +00:00
static Future<GasTracker> getGasOracle() async {
2023-03-29 18:49:12 +00:00
final response = await get(
Uri.parse(
"https://api.etherscan.io/api?module=gastracker&action=gasoracle&apikey=EG6J7RJIQVSTP2BS59D3TY2G55YHS5F2HP",
),
);
2023-02-23 22:59:58 +00:00
if (response.statusCode == 200) {
2023-03-29 18:49:12 +00:00
final json = jsonDecode(response.body) as Map;
return GasTracker.fromJson(json["result"] as Map<String, dynamic>);
2023-02-23 22:59:58 +00:00
} else {
throw Exception('Failed to load gas oracle');
}
}
static Future<FeeObject> getFees() async {
GasTracker fees = await getGasOracle();
final feesFast = fees.fast * (pow(10, 9));
final feesStandard = fees.average * (pow(10, 9));
final feesSlow = fees.slow * (pow(10, 9));
return FeeObject(
numberOfBlocksFast: 1,
numberOfBlocksAverage: 3,
numberOfBlocksSlow: 3,
fast: feesFast.toInt(),
medium: feesStandard.toInt(),
slow: feesSlow.toInt());
}
static Future<EthereumResponse<EthContract>> getTokenContractInfoByAddress(
2023-02-23 22:59:58 +00:00
String contractAddress) async {
try {
final response = await get(
Uri.parse(
"$stackBaseServer/tokens?addrs=$contractAddress&parts=all",
),
);
2023-02-23 22:59:58 +00:00
if (response.statusCode == 200) {
2023-03-24 14:37:47 +00:00
final json = jsonDecode(response.body) as Map;
if (json["data"] is List) {
final map = Map<String, dynamic>.from(json["data"].first as Map);
EthContract? token;
if (map["isErc20"] == true) {
token = EthContract(
address: map["address"] as String,
decimals: map["decimals"] as int,
2023-02-23 22:59:58 +00:00
name: map["name"] as String,
symbol: map["symbol"] as String,
type: EthContractType.erc20,
2023-02-23 22:59:58 +00:00
);
} else if (map["isErc721"] == true) {
token = EthContract(
address: map["address"] as String,
decimals: map["decimals"] as int,
2023-02-23 22:59:58 +00:00
name: map["name"] as String,
symbol: map["symbol"] as String,
type: EthContractType.erc721,
2023-02-23 22:59:58 +00:00
);
} else {
2023-02-28 22:03:36 +00:00
throw EthApiException(
"Unsupported token type found: ${map["type"]}");
2023-02-23 22:59:58 +00:00
}
return EthereumResponse(
token,
null,
);
} else {
2023-03-24 14:37:47 +00:00
throw EthApiException(response.body);
2023-02-23 22:59:58 +00:00
}
} else {
2023-02-28 22:03:36 +00:00
throw EthApiException(
2023-02-23 22:59:58 +00:00
"getTokenByContractAddress($contractAddress) failed with status code: "
"${response.statusCode}",
);
}
2023-02-28 22:03:36 +00:00
} on EthApiException catch (e) {
return EthereumResponse(
null,
e,
);
2023-02-23 22:59:58 +00:00
} catch (e, s) {
Logging.instance.log(
2023-03-02 00:02:53 +00:00
"getTokenByContractAddress(): $e\n$s",
2023-02-23 22:59:58 +00:00
level: LogLevel.Error,
);
return EthereumResponse(
null,
2023-02-28 22:03:36 +00:00
EthApiException(e.toString()),
2023-02-23 22:59:58 +00:00
);
}
}
2023-03-24 00:04:47 +00:00
static Future<EthereumResponse<String>> getTokenAbi({
required String name,
required String contractAddress,
}) async {
2023-03-02 00:02:53 +00:00
try {
final response = await get(
Uri.parse(
2023-03-24 00:04:47 +00:00
"$stackBaseServer/abis?addrs=$contractAddress&verbose=true",
),
);
2023-03-02 00:02:53 +00:00
if (response.statusCode == 200) {
final json = jsonDecode(response.body)["data"] as List;
return EthereumResponse(
jsonEncode(json),
null,
);
2023-03-02 00:02:53 +00:00
} else {
throw EthApiException(
2023-03-24 00:04:47 +00:00
"getTokenAbi($name, $contractAddress) failed with status code: "
2023-03-02 00:02:53 +00:00
"${response.statusCode}",
);
}
} on EthApiException catch (e) {
return EthereumResponse(
null,
e,
);
} catch (e, s) {
Logging.instance.log(
2023-03-24 00:04:47 +00:00
"getTokenAbi($name, $contractAddress): $e\n$s",
2023-03-02 00:02:53 +00:00
level: LogLevel.Error,
);
return EthereumResponse(
null,
EthApiException(e.toString()),
);
}
}
2023-03-24 00:05:35 +00:00
// static Future<EthereumResponse<String>> getTokenAbi22(
// String contractAddress) async {
// try {
// final response = await get(
// Uri.parse(
// "https://api.etherscan.io/api?module=contract&action=getabi&address=$contractAddress&apikey=EG6J7RJIQVSTP2BS59D3TY2G55YHS5F2HP",
// ),
// );
//
// if (response.statusCode == 200) {
// final json = jsonDecode(response.body) as Map;
// print("========================== 222222222222222 ================");
// dev.log((jsonDecode(json["result"] as String)).toString());
// print(
// "============================ 2222222222222222222 ==============");
//
// return EthereumResponse(
// json["result"] as String,
// null,
// );
// } else {
// throw EthApiException(
// "getTokenAbi($contractAddress) failed with status code: "
// "${response.statusCode}",
// );
// }
// } on EthApiException catch (e) {
// return EthereumResponse(
// null,
// e,
// );
// } catch (e, s) {
// Logging.instance.log(
// "getTokenAbi(): $e\n$s",
// level: LogLevel.Error,
// );
// return EthereumResponse(
// null,
// EthApiException(e.toString()),
// );
// }
// }
2023-03-02 00:02:53 +00:00
2023-03-24 00:05:35 +00:00
// /// Fetch the underlying contract address that a proxy contract points to
// static Future<EthereumResponse<String>> getProxyTokenImplementation(
// String contractAddress) async {
// try {
// final response = await get(Uri.parse(
// "$stackURI?module=contract&action=getsourcecode&address=$contractAddress"));
// // "$etherscanApi?module=contract&action=getsourcecode&address=$contractAddress&apikey=EG6J7RJIQVSTP2BS59D3TY2G55YHS5F2HP"));
// if (response.statusCode == 200) {
// final json = jsonDecode(response.body);
// if (json["message"] == "OK") {
// final list = json["result"] as List;
// final map = Map<String, dynamic>.from(list.first as Map);
//
// return EthereumResponse(
// map["Implementation"] as String,
// null,
// );
// } else {
// throw EthApiException(json["message"] as String);
// }
// } else {
// throw EthApiException(
// "fetchProxyTokenImplementation($contractAddress) failed with status code: "
// "${response.statusCode}",
// );
// }
// } on EthApiException catch (e) {
// return EthereumResponse(
// null,
// e,
// );
// } catch (e, s) {
// Logging.instance.log(
// "fetchProxyTokenImplementation(): $e\n$s",
// level: LogLevel.Error,
// );
// return EthereumResponse(
// null,
// EthApiException(e.toString()),
// );
// }
// }
2023-02-23 22:59:58 +00:00
}