From f8213f2066e87535c4a54d40cb314f6f86e93ac8 Mon Sep 17 00:00:00 2001 From: ghubstan <36207203+ghubstan@users.noreply.github.com> Date: Thu, 17 Sep 2020 13:32:15 -0300 Subject: [PATCH] Give core api a simple way to verify init status This change adds a new StatusCheck class, for use by Core*Service instances needing to verify the server is ready to perform trading related functions. Currently implements one method, verifyCanTrade(), that throws an IllegalStateException with a CLI friendly error message if any of the following checks fail: - the p2p network is bootstrapped - the block chain sync is complete - the minimum # of peers are connected - the wallet is available - the wallet balance is available (not null) --- .../main/java/bisq/core/api/StatusCheck.java | 60 +++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 core/src/main/java/bisq/core/api/StatusCheck.java diff --git a/core/src/main/java/bisq/core/api/StatusCheck.java b/core/src/main/java/bisq/core/api/StatusCheck.java new file mode 100644 index 0000000000..43d624fd6a --- /dev/null +++ b/core/src/main/java/bisq/core/api/StatusCheck.java @@ -0,0 +1,60 @@ +package bisq.core.api; + +import bisq.core.btc.Balances; +import bisq.core.btc.setup.WalletsSetup; +import bisq.core.btc.wallet.WalletsManager; +import bisq.core.dao.state.DaoStateService; + +import bisq.network.p2p.P2PService; + +import bisq.common.config.Config; + +import javax.inject.Inject; +import javax.inject.Singleton; + +import lombok.extern.slf4j.Slf4j; + +@Singleton +@Slf4j +class StatusCheck { + + private final Config config; + private final P2PService p2PService; + private final DaoStateService daoStateService; + private final WalletsSetup walletsSetup; + private final WalletsManager walletsManager; + private final Balances balances; + + @Inject + public StatusCheck(Config config, + P2PService p2PService, + DaoStateService daoStateService, + WalletsSetup walletsSetup, + WalletsManager walletsManager, + Balances balances) { + this.config = config; + this.p2PService = p2PService; + this.daoStateService = daoStateService; + this.walletsSetup = walletsSetup; + this.walletsManager = walletsManager; + this.balances = balances; + } + + public void verifyCanTrade() { + if (!p2PService.isBootstrapped()) + throw new IllegalStateException("p2p service is not yet bootstrapped"); + + if (!daoStateService.isParseBlockChainComplete()) + throw new IllegalStateException("dao block chain sync is not yet complete"); + + if (config.baseCurrencyNetwork.isMainnet() + && p2PService.getNumConnectedPeers().get() < walletsSetup.getMinBroadcastConnections()) + throw new IllegalStateException("not enough connected peers"); + + if (!walletsManager.areWalletsAvailable()) + throw new IllegalStateException("wallet is not yet available"); + + if (balances.getAvailableBalance().get() == null) + throw new IllegalStateException("balance is not yet available"); + } +}