This commit is contained in:
Matthew Fosse 2024-03-04 10:35:52 -08:00
parent 0977711b7a
commit 96be5d2697

View file

@ -1,90 +0,0 @@
import 'dart:convert';
import 'package:cw_core/pathForWallet.dart';
import 'package:cw_core/transaction_history.dart';
import 'package:cw_core/utils/file.dart';
import 'package:cw_core/wallet_info.dart';
import 'package:cw_lightning/lightning_transaction_info.dart';
import 'package:mobx/mobx.dart';
part 'lightning_transaction_history.g.dart';
const transactionsHistoryFileName = 'transactions.json';
class LightningTransactionHistory = LightningTransactionHistoryBase
with _$LightningTransactionHistory;
abstract class LightningTransactionHistoryBase
extends TransactionHistoryBase<LightningTransactionInfo> with Store {
LightningTransactionHistoryBase(
{required this.walletInfo, required String password})
: _password = password,
_height = 0 {
transactions = ObservableMap<String, LightningTransactionInfo>();
}
final WalletInfo walletInfo;
String _password;
int _height;
Future<void> init() async => await _load();
@override
void addOne(LightningTransactionInfo transaction) =>
transactions[transaction.id] = transaction;
@override
void addMany(Map<String, LightningTransactionInfo> transactions) =>
transactions.forEach((_, tx) => _update(tx));
@override
Future<void> save() async {
try {
final dirPath =
await pathForWalletDir(name: walletInfo.name, type: walletInfo.type);
final path = '$dirPath/$transactionsHistoryFileName';
final data =
json.encode({'height': _height, 'transactions': transactions});
await writeData(path: path, password: _password, data: data);
} catch (e) {
print('Error while save bitcoin transaction history: ${e.toString()}');
}
}
Future<void> changePassword(String password) async {
_password = password;
await save();
}
Future<Map<String, dynamic>> _read() async {
final dirPath =
await pathForWalletDir(name: walletInfo.name, type: walletInfo.type);
final path = '$dirPath/$transactionsHistoryFileName';
final content = await read(path: path, password: _password);
return json.decode(content) as Map<String, dynamic>;
}
Future<void> _load() async {
try {
final content = await _read();
final txs = content['transactions'] as Map<String, dynamic>? ?? {};
txs.entries.forEach((entry) {
final val = entry.value;
if (val is Map<String, dynamic>) {
final tx = LightningTransactionInfo.fromJson(val, walletInfo.type);
_update(tx);
}
});
_height = content['height'] as int;
} catch (e) {
print(e);
}
}
void _update(LightningTransactionInfo transaction) =>
transactions[transaction.id] = transaction;
}