Ecosystem/cake_wallet
1
0
Fork 0
mirror of https://github.com/cake-tech/cake_wallet.git synced 2024-12-23 03:59:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fixes when switching wallets

Browse source
This commit is contained in:
Matthew Fosse 2024-05-14 16:03:45 -07:00
parent 12724acfd9
commit 179dd405c5
1 changed files with 30 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
cw_lightning/lib/lightning_wallet.dart
View file

@ -1,3 +1,4 @@
import 'dart:async';
import 'dart:convert'; import 'dart:convert';
import 'dart:io'; import 'dart:io';
@ -92,6 +93,8 @@ abstract class LightningWalletBase extends ElectrumWallet with Store {
} }
late final ObservableMap<CryptoCurrency, LightningBalance> _balance; late final ObservableMap<CryptoCurrency, LightningBalance> _balance;
StreamSubscription<List<Payment>>? _paymentsSub;
StreamSubscription<NodeState?>? _nodeStateSub;
@override @override
@computed @computed
@ -177,14 +180,16 @@ abstract class LightningWalletBase extends ElectrumWallet with Store {
); );
String workingDir = (await getApplicationDocumentsDirectory()).path; String workingDir = (await getApplicationDocumentsDirectory()).path;
workingDir = "$workingDir/wallets/lightning/${walletInfo.name}/breez/"; workingDir = "$workingDir/wallets/lightning/${walletInfo.address}/breez/";
new Directory(workingDir).createSync(recursive: true); new Directory(workingDir).createSync(recursive: true);
breezConfig = breezConfig.copyWith(workingDir: workingDir); breezConfig = breezConfig.copyWith(workingDir: workingDir);
// disconnect if already connected // disconnect if already connected
try { try {
await sdk.disconnect(); await sdk.disconnect();
} catch (_) {} } catch (e, s) {
print("ERROR disconnecting from Breez: $e\n$s");
}
try { try {
await sdk.connect( await sdk.connect(
@ -197,7 +202,7 @@ abstract class LightningWalletBase extends ElectrumWallet with Store {
print("Error connecting to Breez: $e"); print("Error connecting to Breez: $e");
} }
sdk.nodeStateStream.listen((event) { _nodeStateSub = sdk.nodeStateStream.listen((event) {
if (event == null) return; if (event == null) return;
_balance[CryptoCurrency.btcln] = LightningBalance( _balance[CryptoCurrency.btcln] = LightningBalance(
confirmed: event.maxPayableMsat ~/ 1000, confirmed: event.maxPayableMsat ~/ 1000,
@ -206,7 +211,7 @@ abstract class LightningWalletBase extends ElectrumWallet with Store {
); );
}); });
sdk.paymentsStream.listen((payments) { _paymentsSub = sdk.paymentsStream.listen((payments) {
_isTransactionUpdating = true; _isTransactionUpdating = true;
final txs = convertToTxInfo(payments); final txs = convertToTxInfo(payments);
transactionHistory.addMany(txs); transactionHistory.addMany(txs);
@ -225,6 +230,13 @@ abstract class LightningWalletBase extends ElectrumWallet with Store {
print("initialized breez: ${(await sdk.isInitialized())}"); print("initialized breez: ${(await sdk.isInitialized())}");
} }
Future<void> stopBreez() async {
final sdk = await BreezSDK();
await sdk.disconnect();
await _nodeStateSub?.cancel();
await _paymentsSub?.cancel();
}
@action @action
@override @override
Future<void> startSync() async { Future<void> startSync() async {
@ -344,4 +356,18 @@ abstract class LightningWalletBase extends ElectrumWallet with Store {
String get seed => mnemonic; String get seed => mnemonic;
Future<String> makePath() async => pathForWallet(name: walletInfo.name, type: walletInfo.type); Future<String> makePath() async => pathForWallet(name: walletInfo.name, type: walletInfo.type);
@override
Future<void> close() async {
try {
await electrumClient.close();
} catch (_) {}
try {
print("stopping breez");
await stopBreez();
print("stopped breez @@@@@@@@@@@@@@@@@@@@@@@@@@@@");
} catch (e, s) {
print("Error stopping breez: $e\n$s");
}
}
} }