Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2025-01-03 17:29:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

lints clean up

Browse source
This commit is contained in:
julian 2024-05-09 12:44:56 -06:00
parent cccf1a7012
commit 51807ac8e6
1 changed files with 93 additions and 50 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

143
lib/electrumx_rpc/electrumx_client.dart
View file

@ -210,15 +210,19 @@ class ElectrumXClient {
if (_torService.status != TorConnectionStatus.connected) { if (_torService.status != TorConnectionStatus.connected) {
// And the killswitch isn't set... // And the killswitch isn't set...
if (!_prefs.torKillSwitch) { if (!_prefs.torKillSwitch) {
// Then we'll just proceed and connect to ElectrumX through clearnet at the bottom of this function. // Then we'll just proceed and connect to ElectrumX through
// clearnet at the bottom of this function.
Logging.instance.log( Logging.instance.log(
"Tor preference set but Tor is not enabled, killswitch not set, connecting to Electrum adapter through clearnet", "Tor preference set but Tor is not enabled, killswitch not set,"
" connecting to Electrum adapter through clearnet",
level: LogLevel.Warning, level: LogLevel.Warning,
); );
} else { } else {
// ... But if the killswitch is set, then we throw an exception. // ... But if the killswitch is set, then we throw an exception.
throw Exception( throw Exception(
"Tor preference and killswitch set but Tor is not enabled, not connecting to Electrum adapter"); "Tor preference and killswitch set but Tor is not enabled, "
"not connecting to Electrum adapter",
);
// TODO [prio=low]: Try to start Tor. // TODO [prio=low]: Try to start Tor.
} }
} else { } else {
@ -392,7 +396,7 @@ class ElectrumXClient {
} }
try { try {
var futures = <Future<dynamic>>[]; final futures = <Future<dynamic>>[];
getElectrumAdapter()!.peer.withBatch(() { getElectrumAdapter()!.peer.withBatch(() {
for (final arg in args) { for (final arg in args) {
futures.add(getElectrumAdapter()!.request(command, arg)); futures.add(getElectrumAdapter()!.request(command, arg));
@ -765,12 +769,16 @@ class ElectrumXClient {
bool verbose = true, bool verbose = true,
String? requestID, String? requestID,
}) async { }) async {
Logging.instance.log("attempting to fetch blockchain.transaction.get...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch blockchain.transaction.get...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
dynamic response = await getElectrumAdapter()!.getTransaction(txHash); final dynamic response = await getElectrumAdapter()!.getTransaction(txHash);
Logging.instance.log("Fetching blockchain.transaction.get finished", Logging.instance.log(
level: LogLevel.Info); "Fetching blockchain.transaction.get finished",
level: LogLevel.Info,
);
if (!verbose) { if (!verbose) {
return {"rawtx": response as String}; return {"rawtx": response as String};
@ -798,14 +806,18 @@ class ElectrumXClient {
String blockhash = "", String blockhash = "",
String? requestID, String? requestID,
}) async { }) async {
Logging.instance.log("attempting to fetch lelantus.getanonymityset...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch lelantus.getanonymityset...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
Map<String, dynamic> response = final Map<String, dynamic> response =
await (getElectrumAdapter() as FiroElectrumClient) await (getElectrumAdapter() as FiroElectrumClient)
.getLelantusAnonymitySet(groupId: groupId, blockHash: blockhash); .getLelantusAnonymitySet(groupId: groupId, blockHash: blockhash);
Logging.instance.log("Fetching lelantus.getanonymityset finished", Logging.instance.log(
level: LogLevel.Info); "Fetching lelantus.getanonymityset finished",
level: LogLevel.Info,
);
return response; return response;
} }
@ -817,13 +829,17 @@ class ElectrumXClient {
dynamic mints, dynamic mints,
String? requestID, String? requestID,
}) async { }) async {
Logging.instance.log("attempting to fetch lelantus.getmintmetadata...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch lelantus.getmintmetadata...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
dynamic response = await (getElectrumAdapter() as FiroElectrumClient) final dynamic response = await (getElectrumAdapter() as FiroElectrumClient)
.getLelantusMintData(mints: mints); .getLelantusMintData(mints: mints);
Logging.instance.log("Fetching lelantus.getmintmetadata finished", Logging.instance.log(
level: LogLevel.Info); "Fetching lelantus.getmintmetadata finished",
level: LogLevel.Info,
);
return response; return response;
} }
@ -833,8 +849,10 @@ class ElectrumXClient {
String? requestID, String? requestID,
required int startNumber, required int startNumber,
}) async { }) async {
Logging.instance.log("attempting to fetch lelantus.getusedcoinserials...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch lelantus.getusedcoinserials...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
int retryCount = 3; int retryCount = 3;
@ -844,8 +862,10 @@ class ElectrumXClient {
response = await (getElectrumAdapter() as FiroElectrumClient) response = await (getElectrumAdapter() as FiroElectrumClient)
.getLelantusUsedCoinSerials(startNumber: startNumber); .getLelantusUsedCoinSerials(startNumber: startNumber);
// TODO add 2 minute timeout. // TODO add 2 minute timeout.
Logging.instance.log("Fetching lelantus.getusedcoinserials finished", Logging.instance.log(
level: LogLevel.Info); "Fetching lelantus.getusedcoinserials finished",
level: LogLevel.Info,
);
retryCount--; retryCount--;
} }
@ -857,13 +877,17 @@ class ElectrumXClient {
/// ///
/// ex: 1 /// ex: 1
Future<int> getLelantusLatestCoinId({String? requestID}) async { Future<int> getLelantusLatestCoinId({String? requestID}) async {
Logging.instance.log("attempting to fetch lelantus.getlatestcoinid...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch lelantus.getlatestcoinid...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
int response = final int response =
await (getElectrumAdapter() as FiroElectrumClient).getLatestCoinId(); await (getElectrumAdapter() as FiroElectrumClient).getLatestCoinId();
Logging.instance.log("Fetching lelantus.getlatestcoinid finished", Logging.instance.log(
level: LogLevel.Info); "Fetching lelantus.getlatestcoinid finished",
level: LogLevel.Info,
);
return response; return response;
} }
@ -888,15 +912,21 @@ class ElectrumXClient {
String? requestID, String? requestID,
}) async { }) async {
try { try {
Logging.instance.log("attempting to fetch spark.getsparkanonymityset...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch spark.getsparkanonymityset...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
Map<String, dynamic> response = final Map<String, dynamic> response =
await (getElectrumAdapter() as FiroElectrumClient) await (getElectrumAdapter() as FiroElectrumClient)
.getSparkAnonymitySet( .getSparkAnonymitySet(
coinGroupId: coinGroupId, startBlockHash: startBlockHash); coinGroupId: coinGroupId,
Logging.instance.log("Fetching spark.getsparkanonymityset finished", startBlockHash: startBlockHash,
level: LogLevel.Info); );
Logging.instance.log(
"Fetching spark.getsparkanonymityset finished",
level: LogLevel.Info,
);
return response; return response;
} catch (e) { } catch (e) {
rethrow; rethrow;
@ -911,16 +941,20 @@ class ElectrumXClient {
}) async { }) async {
try { try {
// Use electrum_adapter package's getSparkUsedCoinsTags method. // Use electrum_adapter package's getSparkUsedCoinsTags method.
Logging.instance.log("attempting to fetch spark.getusedcoinstags...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch spark.getusedcoinstags...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
Map<String, dynamic> response = final Map<String, dynamic> response =
await (getElectrumAdapter() as FiroElectrumClient) await (getElectrumAdapter() as FiroElectrumClient)
.getUsedCoinsTags(startNumber: startNumber); .getUsedCoinsTags(startNumber: startNumber);
// TODO: Add 2 minute timeout. // TODO: Add 2 minute timeout.
// Why 2 minutes? // Why 2 minutes?
Logging.instance.log("Fetching spark.getusedcoinstags finished", Logging.instance.log(
level: LogLevel.Info); "Fetching spark.getusedcoinstags finished",
level: LogLevel.Info,
);
final map = Map<String, dynamic>.from(response); final map = Map<String, dynamic>.from(response);
final set = Set<String>.from(map["tags"] as List); final set = Set<String>.from(map["tags"] as List);
return await compute(_ffiHashTagsComputeWrapper, set); return await compute(_ffiHashTagsComputeWrapper, set);
@ -945,14 +979,18 @@ class ElectrumXClient {
required List<String> sparkCoinHashes, required List<String> sparkCoinHashes,
}) async { }) async {
try { try {
Logging.instance.log("attempting to fetch spark.getsparkmintmetadata...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch spark.getsparkmintmetadata...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
List<dynamic> response = final List<dynamic> response =
await (getElectrumAdapter() as FiroElectrumClient) await (getElectrumAdapter() as FiroElectrumClient)
.getSparkMintMetaData(sparkCoinHashes: sparkCoinHashes); .getSparkMintMetaData(sparkCoinHashes: sparkCoinHashes);
Logging.instance.log("Fetching spark.getsparkmintmetadata finished", Logging.instance.log(
level: LogLevel.Info); "Fetching spark.getsparkmintmetadata finished",
level: LogLevel.Info,
);
return List<Map<String, dynamic>>.from(response); return List<Map<String, dynamic>>.from(response);
} catch (e) { } catch (e) {
Logging.instance.log(e, level: LogLevel.Error); Logging.instance.log(e, level: LogLevel.Error);
@ -967,13 +1005,17 @@ class ElectrumXClient {
String? requestID, String? requestID,
}) async { }) async {
try { try {
Logging.instance.log("attempting to fetch spark.getsparklatestcoinid...", Logging.instance.log(
level: LogLevel.Info); "attempting to fetch spark.getsparklatestcoinid...",
level: LogLevel.Info,
);
await _checkElectrumAdapter(); await _checkElectrumAdapter();
int response = await (getElectrumAdapter() as FiroElectrumClient) final int response = await (getElectrumAdapter() as FiroElectrumClient)
.getSparkLatestCoinId(); .getSparkLatestCoinId();
Logging.instance.log("Fetching spark.getsparklatestcoinid finished", Logging.instance.log(
level: LogLevel.Info); "Fetching spark.getsparklatestcoinid finished",
level: LogLevel.Info,
);
return response; return response;
} catch (e) { } catch (e) {
Logging.instance.log(e, level: LogLevel.Error); Logging.instance.log(e, level: LogLevel.Error);
@ -995,7 +1037,8 @@ class ElectrumXClient {
return await getElectrumAdapter()!.getFeeRate(); return await getElectrumAdapter()!.getFeeRate();
} }
/// Return the estimated transaction fee per kilobyte for a transaction to be confirmed within a certain number of [blocks]. /// Return the estimated transaction fee per kilobyte for a transaction to be
/// confirmed within a certain number of [blocks].
/// ///
/// Returns a Decimal fee rate /// Returns a Decimal fee rate
/// Ex: /// Ex: