stack_wallet/lib/services/mixins/coin_control_interface.dart

97 lines
2.7 KiB
Dart
Raw Normal View History

import 'dart:async';
import 'package:isar/isar.dart';
2023-03-22 15:25:21 +00:00
import 'package:stackwallet/db/isar/main_db.dart';
import 'package:stackwallet/models/balance.dart';
import 'package:stackwallet/services/event_bus/events/global/balance_refreshed_event.dart';
import 'package:stackwallet/services/event_bus/global_event_bus.dart';
2023-04-06 21:24:56 +00:00
import 'package:stackwallet/utilities/amount/amount.dart';
import 'package:stackwallet/utilities/enums/coin_enum.dart';
mixin CoinControlInterface {
late final String _walletId;
late final String _walletName;
late final Coin _coin;
late final MainDB _db;
late final Future<int> Function() _getChainHeight;
late final Future<void> Function(Balance) _refreshedBalanceCallback;
void initCoinControlInterface({
required String walletId,
required String walletName,
required Coin coin,
required MainDB db,
required Future<int> Function() getChainHeight,
required Future<void> Function(Balance) refreshedBalanceCallback,
}) {
_walletId = walletId;
_walletName = walletName;
_coin = coin;
_db = db;
_getChainHeight = getChainHeight;
_refreshedBalanceCallback = refreshedBalanceCallback;
}
Future<void> refreshBalance({bool notify = false}) async {
final utxos = await _db.getUTXOs(_walletId).findAll();
final currentChainHeight = await _getChainHeight();
2023-04-05 22:06:31 +00:00
Amount satoshiBalanceTotal = Amount(
rawValue: BigInt.zero,
fractionDigits: _coin.decimals,
);
Amount satoshiBalancePending = Amount(
rawValue: BigInt.zero,
fractionDigits: _coin.decimals,
);
Amount satoshiBalanceSpendable = Amount(
rawValue: BigInt.zero,
fractionDigits: _coin.decimals,
);
Amount satoshiBalanceBlocked = Amount(
rawValue: BigInt.zero,
fractionDigits: _coin.decimals,
);
for (final utxo in utxos) {
2023-04-05 22:06:31 +00:00
final utxoAmount = Amount(
rawValue: BigInt.from(utxo.value),
fractionDigits: _coin.decimals,
);
2023-04-09 19:07:09 +00:00
satoshiBalanceTotal += utxoAmount;
if (utxo.isBlocked) {
2023-04-09 19:07:09 +00:00
satoshiBalanceBlocked += utxoAmount;
} else {
if (utxo.isConfirmed(
currentChainHeight,
_coin.requiredConfirmations,
)) {
2023-04-09 19:07:09 +00:00
satoshiBalanceSpendable += utxoAmount;
} else {
2023-04-09 19:07:09 +00:00
satoshiBalancePending += utxoAmount;
}
}
}
final balance = Balance(
coin: _coin,
total: satoshiBalanceTotal,
spendable: satoshiBalanceSpendable,
blockedTotal: satoshiBalanceBlocked,
pendingSpendable: satoshiBalancePending,
);
await _refreshedBalanceCallback(balance);
if (notify) {
GlobalEventBus.instance.fire(
BalanceRefreshedEvent(
_walletId,
),
);
}
}
}