nihilist/haveno-reto
1
0
Fork 0
mirror of https://github.com/retoaccess1/haveno-reto.git synced 2024-11-10 05:03:35 +01:00
Code Issues Packages Projects Releases Wiki Activity

await external prices on startup

Browse Source
This commit is contained in:
woodser 2024-01-02 13:19:38 -05:00
parent f8d9c827ea
commit ba8a9ae21d
3 changed files with 27 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/java/haveno/core/offer/OpenOfferManager.java
View File

@ -403,7 +403,7 @@ public class OpenOfferManager implements PeerManager.Listener, DecryptedDirectMe
HavenoUtils.submitToThread(() -> {
// Wait for prices to be available
priceFeedService.awaitPrices();
priceFeedService.awaitExternalPrices();
// Republish means we send the complete offer object
republishOffers();

37
core/src/main/java/haveno/core/provider/price/PriceFeedService.java
View File

@ -140,17 +140,24 @@ public class PriceFeedService {
/**
* Awaits prices to be available, but does not request them.
*/
public void awaitPrices() {
if (hasPrices()) return;
public void awaitExternalPrices() {
CountDownLatch latch = new CountDownLatch(1);
ChangeListener<? super Number> listener = (observable, oldValue, newValue) -> { latch.countDown(); };
ChangeListener<? super Number> listener = (observable, oldValue, newValue) -> {
if (hasExternalPrices()) latch.countDown();
};
updateCounter.addListener(listener);
if (hasExternalPrices()) {
updateCounter.removeListener(listener);
return;
}
HavenoUtils.awaitLatch(latch);
updateCounter.removeListener(listener);
}
public boolean hasPrices() {
return !cache.isEmpty();
public boolean hasExternalPrices() {
synchronized (cache) {
return cache.values().stream().anyMatch(MarketPrice::isExternallyProvidedPrice);
}
}
public void startRequestingPrices() {
@ -280,16 +287,20 @@ public class PriceFeedService {
@Nullable
public MarketPrice getMarketPrice(String currencyCode) {
return cache.getOrDefault(currencyCode, null);
synchronized (cache) {
return cache.getOrDefault(currencyCode, null);
}
}
private void setHavenoMarketPrice(String currencyCode, Price price) {
UserThread.await(() -> {
if (!cache.containsKey(currencyCode) || !cache.get(currencyCode).isExternallyProvidedPrice()) {
cache.put(currencyCode, new MarketPrice(currencyCode,
MathUtils.scaleDownByPowerOf10(price.getValue(), CurrencyUtil.isCryptoCurrency(currencyCode) ? CryptoMoney.SMALLEST_UNIT_EXPONENT : TraditionalMoney.SMALLEST_UNIT_EXPONENT),
0,
false));
synchronized (cache) {
if (!cache.containsKey(currencyCode) || !cache.get(currencyCode).isExternallyProvidedPrice()) {
cache.put(currencyCode, new MarketPrice(currencyCode,
MathUtils.scaleDownByPowerOf10(price.getValue(), CurrencyUtil.isCryptoCurrency(currencyCode) ? CryptoMoney.SMALLEST_UNIT_EXPONENT : TraditionalMoney.SMALLEST_UNIT_EXPONENT),
0,
false));
}
updateCounter.set(updateCounter.get() + 1);
}
});
@ -456,7 +467,9 @@ public class PriceFeedService {
Map<String, MarketPrice> priceMap = result;
cache.putAll(priceMap);
synchronized (cache) {
cache.putAll(priceMap);
}
resultHandler.run();
});

2
core/src/main/java/haveno/core/support/dispute/DisputeManager.java
View File

@ -1022,7 +1022,7 @@ public abstract class DisputeManager<T extends DisputeList<Dispute>> extends Sup
// proposal). But if gain is larger than this loss he has economically an incentive to default in the trade.
// We do all those calculations to give a hint to mediators to detect option trades.
protected void addPriceInfoMessage(Dispute dispute, int counter) {
if (!priceFeedService.hasPrices()) {
if (!priceFeedService.hasExternalPrices()) {
if (counter < 3) {
log.info("Price provider has still no data. This is expected at startup. We try again in 10 sec.");
UserThread.runAfter(() -> addPriceInfoMessage(dispute, counter + 1), 10);