Ecosystem/haveno
Ecosystem/haveno
2
1
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2024-12-22 11:39:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fetch prices repeatedly when run as daemon

Browse source
This commit is contained in:
woodser 2022-07-28 15:45:47 -04:00
parent a3a5b96c06
commit a5f457d8e9
6 changed files with 12 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
core/src/main/java/bisq/core/app/DomainInitialisation.java
View file

@ -216,6 +216,7 @@ public class DomainInitialisation {
signedWitnessService.onAllServicesInitialized(); signedWitnessService.onAllServicesInitialized();
priceFeedService.setCurrencyCodeOnInit(); priceFeedService.setCurrencyCodeOnInit();
priceFeedService.startRequestingPrices();
filterManager.setFilterWarningHandler(filterWarningHandler); filterManager.setFilterWarningHandler(filterWarningHandler);
filterManager.onAllServicesInitialized(); filterManager.onAllServicesInitialized();

2
core/src/main/java/bisq/core/app/P2PNetworkSetup.java
View file

@ -149,7 +149,7 @@ public class P2PNetworkSetup {
// We want to get early connected to the price relay so we call it already now // We want to get early connected to the price relay so we call it already now
priceFeedService.setCurrencyCodeOnInit(); priceFeedService.setCurrencyCodeOnInit();
priceFeedService.initialRequestPriceFeed(); priceFeedService.requestPrices();
} }
@Override @Override

11
core/src/main/java/bisq/core/provider/price/PriceFeedService.java
View file

@ -137,7 +137,7 @@ public class PriceFeedService {
} }
} }
public void initialRequestPriceFeed() { public void requestPrices() {
request(false); request(false);
} }
@ -145,11 +145,14 @@ public class PriceFeedService {
return !cache.isEmpty(); return !cache.isEmpty();
} }
public void requestPriceFeed(Consumer<Double> resultHandler, FaultHandler faultHandler) { public void startRequestingPrices() {
if (requestTimer == null) request(true); // ignore if already repeat requesting
}
public void startRequestingPrices(Consumer<Double> resultHandler, FaultHandler faultHandler) {
this.priceConsumer = resultHandler; this.priceConsumer = resultHandler;
this.faultHandler = faultHandler; this.faultHandler = faultHandler;
startRequestingPrices();
request(true);
} }
public String getProviderNodeAddress() { public String getProviderNodeAddress() {

2
core/src/test/java/bisq/core/provider/price/MarketPriceFeedServiceTest.java
View file

@ -33,7 +33,7 @@ public class MarketPriceFeedServiceTest {
public void testGetPrice() throws InterruptedException { public void testGetPrice() throws InterruptedException {
PriceFeedService priceFeedService = new PriceFeedService(null, null, null); PriceFeedService priceFeedService = new PriceFeedService(null, null, null);
priceFeedService.setCurrencyCode("EUR"); priceFeedService.setCurrencyCode("EUR");
priceFeedService.requestPriceFeed(tradeCurrency -> { priceFeedService.startRequestingPrices(tradeCurrency -> {
log.debug(tradeCurrency.toString()); log.debug(tradeCurrency.toString());
assertTrue(true); assertTrue(true);
}, },

2
desktop/src/main/java/bisq/desktop/main/presentation/MarketPricePresentation.java
View file

@ -132,7 +132,7 @@ public class MarketPricePresentation {
} }
private void setupMarketPriceFeed() { private void setupMarketPriceFeed() {
priceFeedService.requestPriceFeed(price -> marketPrice.set(FormattingUtils.formatMarketPrice(price, priceFeedService.getCurrencyCode())), priceFeedService.startRequestingPrices(price -> marketPrice.set(FormattingUtils.formatMarketPrice(price, priceFeedService.getCurrencyCode())),
(errorMessage, throwable) -> marketPrice.set(Res.get("shared.na"))); (errorMessage, throwable) -> marketPrice.set(Res.get("shared.na")));
marketPriceBinding = EasyBind.combine( marketPriceBinding = EasyBind.combine(

2
statsnode/src/main/java/bisq/statistics/Statistics.java
View file

@ -58,7 +58,7 @@ public class Statistics {
public void onUpdatedDataReceived() { public void onUpdatedDataReceived() {
// we need to have tor ready // we need to have tor ready
log.info("onBootstrapComplete: we start requestPriceFeed"); log.info("onBootstrapComplete: we start requestPriceFeed");
priceFeedService.requestPriceFeed(price -> log.info("requestPriceFeed. price=" + price), priceFeedService.startRequestingPrices(price -> log.info("requestPriceFeed. price=" + price),
(errorMessage, throwable) -> log.warn("Exception at requestPriceFeed: " + throwable.getMessage())); (errorMessage, throwable) -> log.warn("Exception at requestPriceFeed: " + throwable.getMessage()));
tradeStatisticsManager.onAllServicesInitialized(); tradeStatisticsManager.onAllServicesInitialized();