Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2025-01-22 10:34:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

listen to correct socket depending on tor preference

Browse source
This commit is contained in:
sneurlax 2024-02-05 14:45:33 -06:00
parent 7646f97cc1
commit dbaf184bb8
1 changed files with 29 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
lib/electrumx_rpc/subscribable_electrumx_client.dart
View file

@ -206,12 +206,35 @@ class SubscribableElectrumXClient {
_updateConnectionStatus(true); _updateConnectionStatus(true);
_socket!.listen( if (_prefs.useTor) {
_dataHandler, if (_socksSocket == null) {
onError: _errorHandler, final String msg = "SubscribableElectrumXClient.connect(): "
onDone: _doneHandler, "cannot listen to $host:$port via SOCKSSocket because it is not connected.";
cancelOnError: true, Logging.instance.log(msg, level: LogLevel.Fatal);
); throw Exception(msg);
}
_socksSocket!.listen(
_dataHandler,
onError: _errorHandler,
onDone: _doneHandler,
cancelOnError: true,
);
} else {
if (_socket == null) {
final String msg = "SubscribableElectrumXClient.connect(): "
"cannot listen to $host:$port via socket because it is not connected.";
Logging.instance.log(msg, level: LogLevel.Fatal);
throw Exception(msg);
}
_socket!.listen(
_dataHandler,
onError: _errorHandler,
onDone: _doneHandler,
cancelOnError: true,
);
}
_aliveTimer?.cancel(); _aliveTimer?.cancel();
_aliveTimer = Timer.periodic( _aliveTimer = Timer.periodic(