Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2024-11-17 17:57:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove stream watching walletinfo due to flaky updates. Just grab walletinfo from db when wanted

Browse source
This commit is contained in:
julian 2024-01-16 19:11:35 -06:00
parent 07b750189f
commit 33e0059ea9
1 changed files with 6 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
lib/wallets/wallet/wallet.dart
View file

@ -68,7 +68,9 @@ abstract class Wallet<T extends CryptoCurrency> {
final refreshMutex = Mutex();
WalletInfo get info => _walletInfo;
late final String _walletId;
WalletInfo get info =>
mainDB.isar.walletInfo.where().walletIdEqualTo(walletId).findFirstSync()!;
bool get isConnected => _isConnected;
bool get shouldAutoSync => _shouldAutoSync;
@ -88,9 +90,6 @@ abstract class Wallet<T extends CryptoCurrency> {
// ===== private properties ===========================================
late WalletInfo _walletInfo;
late final Stream<WalletInfo?> _walletInfoStream;
Timer? _periodicRefreshTimer;
Timer? _networkAliveTimer;
@ -106,7 +105,7 @@ abstract class Wallet<T extends CryptoCurrency> {
//============================================================================
// ========== Wallet Info Convenience Getters ================================
String get walletId => info.walletId;
String get walletId => _walletId;
/// Attempt to fetch the most recent chain height.
/// On failure return the last cached height.
@ -223,9 +222,7 @@ abstract class Wallet<T extends CryptoCurrency> {
wallet.secureStorageInterface = ethWallet.secureStorageInterface;
wallet.mainDB = ethWallet.mainDB;
return wallet
.._walletInfo = ethWallet.info
.._watchWalletInfo();
return wallet.._walletId = ethWallet.info.walletId;
}
//============================================================================
@ -275,8 +272,7 @@ abstract class Wallet<T extends CryptoCurrency> {
return wallet
..secureStorageInterface = secureStorageInterface
..mainDB = mainDB
.._walletInfo = walletInfo
.._watchWalletInfo();
.._walletId = walletInfo.walletId;
}
static Wallet _loadWallet({
@ -349,19 +345,6 @@ abstract class Wallet<T extends CryptoCurrency> {
}
}
// listen to changes in db and updated wallet info property as required
void _watchWalletInfo() {
_walletInfoStream = mainDB.isar.walletInfo.watchObject(
_walletInfo.id,
fireImmediately: true,
);
_walletInfoStream.forEach((element) {
if (element != null) {
_walletInfo = element;
}
});
}
void _startNetworkAlivePinging() {
// call once on start right away
_periodicPingCheck();