stack_wallet/lib/wallets/isar/providers/all_wallets_info_provider.dart

74 lines
1.8 KiB
Dart
Raw Normal View History

import 'dart:async';
import 'package:flutter/foundation.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:isar/isar.dart';
import 'package:stackwallet/providers/db/main_db_provider.dart';
2023-11-15 16:59:03 +00:00
import 'package:stackwallet/utilities/enums/coin_enum.dart';
import 'package:stackwallet/wallets/isar/models/wallet_info.dart';
final pAllWalletsInfo = Provider((ref) {
2023-11-15 16:59:03 +00:00
return ref.watch(_pAllWalletsInfo.select((value) => value.value));
});
final pAllWalletsInfoByCoin = Provider((ref) {
final infos = ref.watch(pAllWalletsInfo);
final Map<Coin, ({Coin coin, List<WalletInfo> wallets})> map = {};
for (final info in infos) {
if (map[info.coin] == null) {
map[info.coin] = (coin: info.coin, wallets: []);
}
map[info.coin]!.wallets.add(info);
}
final List<({Coin coin, List<WalletInfo> wallets})> results = [];
for (final coin in Coin.values) {
if (map[coin] != null) {
results.add(map[coin]!);
}
}
return results;
});
_WalletInfoWatcher? _globalInstance;
final _pAllWalletsInfo = ChangeNotifierProvider((ref) {
if (_globalInstance == null) {
final isar = ref.watch(mainDBProvider).isar;
_globalInstance = _WalletInfoWatcher(
isar.walletInfo.where().findAllSync(),
isar,
);
}
2023-11-15 16:59:03 +00:00
return _globalInstance!;
});
class _WalletInfoWatcher extends ChangeNotifier {
late final StreamSubscription<void> _streamSubscription;
List<WalletInfo> _value;
List<WalletInfo> get value => _value;
_WalletInfoWatcher(this._value, Isar isar) {
_streamSubscription =
isar.walletInfo.watchLazy(fireImmediately: true).listen((event) {
isar.walletInfo.where().findAll().then((value) {
_value = value;
notifyListeners();
});
});
}
@override
void dispose() {
_streamSubscription.cancel();
super.dispose();
}
}