Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2024-12-24 12:29:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove startSync isolate

Browse source
This commit is contained in:
likho 2023-10-04 15:31:35 +02:00
parent 9746e789a0
commit c08bdd3c08
1 changed files with 6 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
lib/services/coins/epiccash/epiccash_wallet.dart
View file

@ -109,20 +109,6 @@ Future<void> executeNative(Map<String, dynamic> arguments) async {
sendPort.send(result); sendPort.send(result);
return; return;
} }
} else if (function == "startSync") {
final wallet = arguments['wallet'] as String?;
const int refreshFromNode = 1;
Map<String, dynamic> result = {};
if (!(wallet == null)) {
var res = await epiccash.LibEpiccash.getWalletBalances(
wallet: wallet!,
refreshFromNode: refreshFromNode,
minimumConfirmations: 10,
);
result['result'] = res;
sendPort.send(result);
return;
}
} }
Logging.instance.log( Logging.instance.log(
@ -247,28 +233,14 @@ class EpicCashWallet extends CoinServiceAPI
Future<String> startSync() async { Future<String> startSync() async {
Logging.instance.log("request start sync", level: LogLevel.Info); Logging.instance.log("request start sync", level: LogLevel.Info);
final wallet = await _secureStore.read(key: '${_walletId}_wallet'); final wallet = await _secureStore.read(key: '${_walletId}_wallet');
const int refreshFromNode = 1;
if (!syncMutex.isLocked) { if (!syncMutex.isLocked) {
await syncMutex.protect(() async {
Logging.instance.log("sync started", level: LogLevel.Info);
ReceivePort receivePort = await getIsolate({
"function": "startSync",
"wallet": wallet!,
}, name: walletName);
this.receivePort = receivePort;
var message = await receivePort.first; await epiccash.LibEpiccash.getWalletBalances(
if (message is String) { wallet: wallet!,
Logging.instance refreshFromNode: refreshFromNode,
.log("this is a string $message", level: LogLevel.Error); minimumConfirmations: 10,
stop(receivePort); );
throw Exception("startSync isolate failed");
}
stop(receivePort);
Logging.instance
.log('Closing startSync!\n $message', level: LogLevel.Info);
Logging.instance.log("sync ended", level: LogLevel.Info);
});
} else { } else {
Logging.instance.log("request start sync denied", level: LogLevel.Info); Logging.instance.log("request start sync denied", level: LogLevel.Info);
} }