mirror of
https://github.com/cypherstack/stack_wallet.git
synced 2024-12-30 15:29:41 +00:00
357 lines
12 KiB
Dart
357 lines
12 KiB
Dart
/*
|
|
* This file is part of Stack Wallet.
|
|
*
|
|
* Copyright (c) 2023 Cypher Stack
|
|
* All Rights Reserved.
|
|
* The code is distributed under GPLv3 license, see LICENSE file for details.
|
|
* Generated by Cypher Stack on 2023-05-26
|
|
*
|
|
*/
|
|
|
|
import 'dart:isolate';
|
|
|
|
import 'package:cw_core/wallet_info.dart' as xmr;
|
|
import 'package:hive/hive.dart' show Box;
|
|
import 'package:hive/src/hive_impl.dart';
|
|
import 'package:mutex/mutex.dart';
|
|
|
|
import '../../app_config.dart';
|
|
import '../../models/exchange/response_objects/trade.dart';
|
|
import '../../models/node_model.dart';
|
|
import '../../models/notification_model.dart';
|
|
import '../../models/trade_wallet_lookup.dart';
|
|
import '../../services/wallets_service.dart';
|
|
import '../../utilities/logger.dart';
|
|
import '../../wallets/crypto_currency/crypto_currency.dart';
|
|
|
|
class DB {
|
|
final hive = HiveImpl();
|
|
|
|
// legacy (required for migrations)
|
|
@Deprecated("Left over for migration from old versions of Stack Wallet")
|
|
static const String boxNameAddressBook = "addressBook";
|
|
static const String boxNameTrades = "exchangeTransactionsBox";
|
|
static const String boxNameAllWalletsData = "wallets";
|
|
static const String boxNameFavoriteWallets = "favoriteWallets";
|
|
|
|
// in use
|
|
// TODO: migrate
|
|
static const String boxNameNodeModels = "nodeModels";
|
|
static const String boxNamePrimaryNodes = "primaryNodes";
|
|
static const String boxNameNotifications = "notificationModels";
|
|
static const String boxNameWatchedTransactions =
|
|
"watchedTxNotificationModels";
|
|
static const String boxNameWatchedTrades = "watchedTradesNotificationModels";
|
|
static const String boxNameTradesV2 = "exchangeTradesBox";
|
|
static const String boxNameTradeNotes = "tradeNotesBox";
|
|
static const String boxNameTradeLookup = "tradeToTxidLookUpBox";
|
|
static const String boxNameWalletsToDeleteOnStart = "walletsToDeleteOnStart";
|
|
static const String boxNamePriceCache = "priceAPIPrice24hCache";
|
|
|
|
// in use (keep for now)
|
|
static const String boxNameDBInfo = "dbInfo";
|
|
static const String boxNamePrefs = "prefs";
|
|
static const String boxNameOneTimeDialogsShown = "oneTimeDialogsShown";
|
|
|
|
String _boxNameTxCache({required CryptoCurrency currency}) =>
|
|
"${currency.identifier}_txCache";
|
|
|
|
// firo only
|
|
String _boxNameSetCache({required CryptoCurrency currency}) =>
|
|
"${currency.identifier}_anonymitySetCache";
|
|
String _boxNameUsedSerialsCache({required CryptoCurrency currency}) =>
|
|
"${currency.identifier}_usedSerialsCache";
|
|
|
|
Box<NodeModel>? _boxNodeModels;
|
|
Box<NodeModel>? _boxPrimaryNodes;
|
|
Box<dynamic>? _boxAllWalletsData;
|
|
Box<NotificationModel>? _boxNotifications;
|
|
Box<NotificationModel>? _boxWatchedTransactions;
|
|
Box<NotificationModel>? _boxWatchedTrades;
|
|
Box<Trade>? _boxTradesV2;
|
|
Box<String>? _boxTradeNotes;
|
|
Box<String>? _boxFavoriteWallets;
|
|
Box<xmr.WalletInfo>? _walletInfoSource;
|
|
Box<dynamic>? _boxPrefs;
|
|
Box<TradeWalletLookup>? _boxTradeLookup;
|
|
Box<dynamic>? _boxDBInfo;
|
|
// Box<String>? _boxDesktopData;
|
|
|
|
final Map<String, Box<dynamic>> _walletBoxes = {};
|
|
|
|
final Map<String, Box<dynamic>> _txCacheBoxes = {};
|
|
final Map<String, Box<dynamic>> _setCacheBoxes = {};
|
|
final Map<String, Box<dynamic>> _usedSerialsCacheBoxes = {};
|
|
final Map<String, Box<dynamic>> _getSparkUsedCoinsTagsCacheBoxes = {};
|
|
|
|
// exposed for monero
|
|
Box<xmr.WalletInfo> get moneroWalletInfoBox => _walletInfoSource!;
|
|
|
|
// mutex for stack backup
|
|
final mutex = Mutex();
|
|
|
|
DB._();
|
|
static final DB _instance = DB._();
|
|
static DB get instance {
|
|
// "This name does not uniquely identify an isolate. Multiple isolates in the same process may have the same debugName."
|
|
// if (Isolate.current.debugName != "main") {
|
|
// TODO: make sure this works properly
|
|
if (Isolate.current.debugName != "main") {
|
|
throw Exception(
|
|
"DB.instance should not be accessed outside the main isolate!",
|
|
);
|
|
}
|
|
|
|
return _instance;
|
|
}
|
|
|
|
// open hive boxes
|
|
Future<void> init() async {
|
|
if (hive.isBoxOpen(boxNameDBInfo)) {
|
|
_boxDBInfo = hive.box<dynamic>(boxNameDBInfo);
|
|
} else {
|
|
_boxDBInfo = await hive.openBox<dynamic>(boxNameDBInfo);
|
|
}
|
|
await hive.openBox<String>(boxNameWalletsToDeleteOnStart);
|
|
|
|
if (hive.isBoxOpen(boxNamePrefs)) {
|
|
_boxPrefs = hive.box<dynamic>(boxNamePrefs);
|
|
} else {
|
|
_boxPrefs = await hive.openBox<dynamic>(boxNamePrefs);
|
|
}
|
|
|
|
if (hive.isBoxOpen(boxNameNodeModels)) {
|
|
_boxNodeModels = hive.box<NodeModel>(boxNameNodeModels);
|
|
} else {
|
|
_boxNodeModels = await hive.openBox<NodeModel>(boxNameNodeModels);
|
|
}
|
|
|
|
if (hive.isBoxOpen(boxNamePrimaryNodes)) {
|
|
_boxPrimaryNodes = hive.box<NodeModel>(boxNamePrimaryNodes);
|
|
} else {
|
|
_boxPrimaryNodes = await hive.openBox<NodeModel>(boxNamePrimaryNodes);
|
|
}
|
|
|
|
if (hive.isBoxOpen(boxNameAllWalletsData)) {
|
|
_boxAllWalletsData = hive.box<dynamic>(boxNameAllWalletsData);
|
|
} else {
|
|
_boxAllWalletsData = await hive.openBox<dynamic>(boxNameAllWalletsData);
|
|
}
|
|
|
|
_boxNotifications =
|
|
await hive.openBox<NotificationModel>(boxNameNotifications);
|
|
_boxWatchedTransactions =
|
|
await hive.openBox<NotificationModel>(boxNameWatchedTransactions);
|
|
_boxWatchedTrades =
|
|
await hive.openBox<NotificationModel>(boxNameWatchedTrades);
|
|
_boxTradesV2 = await hive.openBox<Trade>(boxNameTradesV2);
|
|
_boxTradeNotes = await hive.openBox<String>(boxNameTradeNotes);
|
|
_boxTradeLookup = await hive.openBox<TradeWalletLookup>(boxNameTradeLookup);
|
|
_walletInfoSource =
|
|
await hive.openBox<xmr.WalletInfo>(xmr.WalletInfo.boxName);
|
|
_boxFavoriteWallets = await hive.openBox<String>(boxNameFavoriteWallets);
|
|
|
|
await Future.wait([
|
|
hive.openBox<dynamic>(boxNamePriceCache),
|
|
_loadWalletBoxes(),
|
|
]);
|
|
}
|
|
|
|
Future<void> _loadWalletBoxes() async {
|
|
final names = _boxAllWalletsData!.get("names") as Map? ?? {};
|
|
names.removeWhere((name, dyn) {
|
|
final jsonObject = Map<String, dynamic>.from(dyn as Map);
|
|
try {
|
|
AppConfig.getCryptoCurrencyFor(jsonObject["coin"] as String);
|
|
return false;
|
|
} catch (e, s) {
|
|
Logging.instance.log(
|
|
"Error, ${jsonObject["coin"]} does not exist, $name wallet cannot be loaded",
|
|
level: LogLevel.Error,
|
|
);
|
|
return true;
|
|
}
|
|
});
|
|
final mapped = Map<String, dynamic>.from(names).map(
|
|
(name, dyn) => MapEntry(
|
|
name,
|
|
WalletInfo.fromJson(Map<String, dynamic>.from(dyn as Map)),
|
|
),
|
|
);
|
|
|
|
for (final entry in mapped.entries) {
|
|
if (hive.isBoxOpen(entry.value.walletId)) {
|
|
_walletBoxes[entry.value.walletId] =
|
|
hive.box<dynamic>(entry.value.walletId);
|
|
} else {
|
|
_walletBoxes[entry.value.walletId] =
|
|
await hive.openBox<dynamic>(entry.value.walletId);
|
|
}
|
|
}
|
|
}
|
|
|
|
Future<Box<dynamic>> getTxCacheBox({required CryptoCurrency currency}) async {
|
|
if (_txCacheBoxes[currency.identifier]?.isOpen != true) {
|
|
_txCacheBoxes.remove(currency.identifier);
|
|
}
|
|
return _txCacheBoxes[currency.identifier] ??=
|
|
await hive.openBox<dynamic>(_boxNameTxCache(currency: currency));
|
|
}
|
|
|
|
Future<void> closeTxCacheBox({required CryptoCurrency currency}) async {
|
|
await _txCacheBoxes[currency.identifier]?.close();
|
|
}
|
|
|
|
Future<Box<dynamic>> getAnonymitySetCacheBox({
|
|
required CryptoCurrency currency,
|
|
}) async {
|
|
if (_setCacheBoxes[currency.identifier]?.isOpen != true) {
|
|
_setCacheBoxes.remove(currency.identifier);
|
|
}
|
|
return _setCacheBoxes[currency.identifier] ??=
|
|
await hive.openBox<dynamic>(_boxNameSetCache(currency: currency));
|
|
}
|
|
|
|
Future<void> closeAnonymitySetCacheBox({
|
|
required CryptoCurrency currency,
|
|
}) async {
|
|
await _setCacheBoxes[currency.identifier]?.close();
|
|
}
|
|
|
|
Future<Box<dynamic>> getUsedSerialsCacheBox({
|
|
required CryptoCurrency currency,
|
|
}) async {
|
|
if (_usedSerialsCacheBoxes[currency.identifier]?.isOpen != true) {
|
|
_usedSerialsCacheBoxes.remove(currency.identifier);
|
|
}
|
|
return _usedSerialsCacheBoxes[currency.identifier] ??=
|
|
await hive.openBox<dynamic>(
|
|
_boxNameUsedSerialsCache(currency: currency),
|
|
);
|
|
}
|
|
|
|
Future<void> closeUsedSerialsCacheBox({
|
|
required CryptoCurrency currency,
|
|
}) async {
|
|
await _usedSerialsCacheBoxes[currency.identifier]?.close();
|
|
}
|
|
|
|
/// Clear all cached transactions for the specified coin
|
|
Future<void> clearSharedTransactionCache({
|
|
required CryptoCurrency currency,
|
|
}) async {
|
|
await deleteAll<dynamic>(boxName: _boxNameTxCache(currency: currency));
|
|
if (currency is Firo) {
|
|
await deleteAll<dynamic>(boxName: _boxNameSetCache(currency: currency));
|
|
await deleteAll<dynamic>(
|
|
boxName: _boxNameUsedSerialsCache(currency: currency),
|
|
);
|
|
}
|
|
}
|
|
|
|
/////////////////////////////////////////
|
|
|
|
Future<void> addWalletBox({required String walletId}) async {
|
|
if (_walletBoxes[walletId] != null) {
|
|
throw Exception("Attempted overwrite of existing wallet box!");
|
|
}
|
|
_walletBoxes[walletId] = await hive.openBox<dynamic>(walletId);
|
|
}
|
|
|
|
Future<void> removeWalletBox({required String walletId}) async {
|
|
_walletBoxes.remove(walletId);
|
|
}
|
|
|
|
///////////////////////////////////////////
|
|
|
|
// reads
|
|
|
|
List<dynamic> keys<T>({required String boxName}) =>
|
|
hive.box<T>(boxName).keys.toList(growable: false);
|
|
|
|
List<T> values<T>({required String boxName}) =>
|
|
hive.box<T>(boxName).values.toList(growable: false);
|
|
|
|
T? get<T>({
|
|
required String boxName,
|
|
required dynamic key,
|
|
}) =>
|
|
hive.box<T>(boxName).get(key);
|
|
|
|
bool containsKey<T>({required String boxName, required dynamic key}) =>
|
|
hive.box<T>(boxName).containsKey(key);
|
|
|
|
// writes
|
|
|
|
Future<void> put<T>({
|
|
required String boxName,
|
|
required dynamic key,
|
|
required T value,
|
|
}) async =>
|
|
await mutex
|
|
.protect(() async => await hive.box<T>(boxName).put(key, value));
|
|
|
|
Future<void> add<T>({required String boxName, required T value}) async =>
|
|
await mutex.protect(() async => await hive.box<T>(boxName).add(value));
|
|
|
|
Future<void> addAll<T>({
|
|
required String boxName,
|
|
required Iterable<T> values,
|
|
}) async =>
|
|
await mutex
|
|
.protect(() async => await hive.box<T>(boxName).addAll(values));
|
|
|
|
Future<void> delete<T>({
|
|
required dynamic key,
|
|
required String boxName,
|
|
}) async =>
|
|
await mutex.protect(() async => await hive.box<T>(boxName).delete(key));
|
|
|
|
Future<void> deleteAll<T>({required String boxName}) async {
|
|
await mutex.protect(() async {
|
|
final box = await hive.openBox<T>(boxName);
|
|
await box.clear();
|
|
});
|
|
}
|
|
|
|
Future<void> deleteBoxFromDisk({required String boxName}) async =>
|
|
await mutex.protect(() async => await hive.deleteBoxFromDisk(boxName));
|
|
|
|
///////////////////////////////////////////////////////////////////////////
|
|
Future<bool> deleteEverything() async {
|
|
try {
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameAddressBook);
|
|
await DB.instance.deleteBoxFromDisk(boxName: "debugInfoBox");
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameNodeModels);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNamePrimaryNodes);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameAllWalletsData);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameNotifications);
|
|
await DB.instance
|
|
.deleteBoxFromDisk(boxName: DB.boxNameWatchedTransactions);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameWatchedTrades);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameTrades);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameTradesV2);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameTradeNotes);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameTradeLookup);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameFavoriteWallets);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNamePrefs);
|
|
await DB.instance
|
|
.deleteBoxFromDisk(boxName: DB.boxNameWalletsToDeleteOnStart);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNamePriceCache);
|
|
await DB.instance.deleteBoxFromDisk(boxName: DB.boxNameDBInfo);
|
|
await DB.instance.deleteBoxFromDisk(boxName: "theme");
|
|
return true;
|
|
} catch (e, s) {
|
|
Logging.instance.log("$e $s", level: LogLevel.Error);
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
abstract class DBKeys {
|
|
static const String cachedBalance = "cachedBalance";
|
|
static const String cachedBalanceSecondary = "cachedBalanceSecondary";
|
|
static const String isFavorite = "isFavorite";
|
|
static const String id = "id";
|
|
static const String storedChainHeight = "storedChainHeight";
|
|
}
|