mirror of
https://github.com/cypherstack/stack_wallet.git
synced 2024-12-24 04:19:23 +00:00
100 lines
2.7 KiB
Dart
100 lines
2.7 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:async';
|
|
|
|
import 'package:decimal/decimal.dart';
|
|
import 'package:flutter/foundation.dart';
|
|
import 'package:isar/isar.dart';
|
|
import 'package:stackwallet/db/isar/main_db.dart';
|
|
import 'package:stackwallet/models/isar/models/isar_models.dart';
|
|
import 'package:stackwallet/networking/http.dart';
|
|
import 'package:stackwallet/services/price.dart';
|
|
import 'package:stackwallet/utilities/enums/coin_enum.dart';
|
|
import 'package:tuple/tuple.dart';
|
|
|
|
class PriceService extends ChangeNotifier {
|
|
late final String baseTicker;
|
|
Future<Set<String>> get tokenContractAddressesToCheck async =>
|
|
(await MainDB.instance.getEthContracts().addressProperty().findAll())
|
|
.toSet();
|
|
final Duration updateInterval = const Duration(seconds: 60);
|
|
|
|
Timer? _timer;
|
|
final Map<Coin, Tuple2<Decimal, double>> _cachedPrices = {
|
|
for (final coin in Coin.values) coin: Tuple2(Decimal.zero, 0.0)
|
|
};
|
|
|
|
final Map<String, Tuple2<Decimal, double>> _cachedTokenPrices = {};
|
|
|
|
final _priceAPI = PriceAPI(HTTP());
|
|
|
|
Tuple2<Decimal, double> getPrice(Coin coin) => _cachedPrices[coin]!;
|
|
|
|
Tuple2<Decimal, double> getTokenPrice(String contractAddress) =>
|
|
_cachedTokenPrices[contractAddress.toLowerCase()] ??
|
|
Tuple2(Decimal.zero, 0);
|
|
|
|
PriceService(this.baseTicker);
|
|
|
|
Future<void> updatePrice() async {
|
|
final priceMap =
|
|
await _priceAPI.getPricesAnd24hChange(baseCurrency: baseTicker);
|
|
|
|
bool shouldNotify = false;
|
|
for (final map in priceMap.entries) {
|
|
if (_cachedPrices[map.key] != map.value) {
|
|
_cachedPrices[map.key] = map.value;
|
|
shouldNotify = true;
|
|
}
|
|
}
|
|
|
|
final _tokenContractAddressesToCheck = await tokenContractAddressesToCheck;
|
|
|
|
if (_tokenContractAddressesToCheck.isNotEmpty) {
|
|
final tokenPriceMap = await _priceAPI.getPricesAnd24hChangeForEthTokens(
|
|
contractAddresses: _tokenContractAddressesToCheck,
|
|
baseCurrency: baseTicker,
|
|
);
|
|
|
|
for (final map in tokenPriceMap.entries) {
|
|
if (_cachedTokenPrices[map.key] != map.value) {
|
|
_cachedTokenPrices[map.key] = map.value;
|
|
shouldNotify = true;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (shouldNotify) {
|
|
notifyListeners();
|
|
}
|
|
}
|
|
|
|
void cancel() {
|
|
_timer?.cancel();
|
|
_timer = null;
|
|
}
|
|
|
|
void start(bool rightAway) {
|
|
if (rightAway) {
|
|
updatePrice();
|
|
}
|
|
_timer?.cancel();
|
|
_timer = Timer.periodic(updateInterval, (_) {
|
|
updatePrice();
|
|
});
|
|
}
|
|
|
|
@override
|
|
void dispose() {
|
|
cancel();
|
|
super.dispose();
|
|
}
|
|
}
|