Remove empty onParseTxsCompleteAfterBatchProcessing methods

Make onParseTxsCompleteAfterBatchProcessing default in listener
This commit is contained in:
Manfred Karrer 2019-01-29 14:59:10 +01:00
parent 32f4c20175
commit 5804ff3cf0
No known key found for this signature in database
GPG key ID: 401250966A6B2C46
13 changed files with 3 additions and 60 deletions

View file

@ -55,7 +55,6 @@ import bisq.core.dao.governance.proposal.role.RoleProposalFactory;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.DaoStateStorageService;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.blockchain.Tx;
import bisq.core.dao.state.model.blockchain.TxOutput;
import bisq.core.dao.state.model.blockchain.TxOutputKey;
@ -188,10 +187,6 @@ public class DaoFacade implements DaoSetupService {
periodService.getCurrentCycle().getPhaseForHeight(blockHeight).ifPresent(phaseProperty::set);
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -23,7 +23,6 @@ import bisq.core.dao.governance.blindvote.storage.BlindVotePayload;
import bisq.core.dao.governance.blindvote.storage.BlindVoteStorageService;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.network.p2p.P2PService;
import bisq.network.p2p.storage.payload.PersistableNetworkPayload;
@ -98,10 +97,6 @@ public class BlindVoteListService implements AppendOnlyDataStoreListener, DaoSta
public void onNewBlockHeight(int blockHeight) {
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
fillListFromAppendOnlyDataStore();

View file

@ -35,7 +35,6 @@ import bisq.core.dao.governance.period.PeriodService;
import bisq.core.dao.governance.proposal.MyProposalListService;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.governance.BallotList;
import bisq.core.dao.state.model.governance.CompensationProposal;
import bisq.core.dao.state.model.governance.DaoPhase;
@ -176,10 +175,6 @@ public class MyBlindVoteListService implements PersistedDataHost, DaoStateListen
public void onNewBlockHeight(int blockHeight) {
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
rePublishOnceWellConnected();

View file

@ -22,7 +22,6 @@ import bisq.core.dao.governance.param.Param;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.GenesisTxInfo;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.governance.Cycle;
import bisq.core.dao.state.model.governance.DaoPhase;
@ -83,10 +82,6 @@ public class CycleService implements DaoStateListener, DaoSetupService {
.ifPresent(daoStateService.getCycles()::add);
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -25,7 +25,6 @@ import bisq.core.dao.governance.period.PeriodService;
import bisq.core.dao.governance.proposal.storage.temp.TempProposalPayload;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.blockchain.Tx;
import bisq.core.dao.state.model.governance.DaoPhase;
import bisq.core.dao.state.model.governance.Proposal;
@ -125,10 +124,6 @@ public class MyProposalListService implements PersistedDataHost, DaoStateListene
public void onNewBlockHeight(int blockHeight) {
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
rePublishOnceWellConnected();

View file

@ -33,7 +33,6 @@ import bisq.core.dao.governance.votereveal.VoteRevealConsensus;
import bisq.core.dao.governance.votereveal.VoteRevealService;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.blockchain.Tx;
import bisq.core.dao.state.model.blockchain.TxOutput;
import bisq.core.dao.state.model.governance.Ballot;
@ -155,10 +154,6 @@ public class VoteResultService implements DaoStateListener, DaoSetupService {
maybeCalculateVoteResult(blockHeight);
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -36,7 +36,6 @@ import bisq.core.dao.node.BsqNode;
import bisq.core.dao.node.BsqNodeProvider;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.DaoStateService;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.blockchain.TxOutput;
import bisq.core.dao.state.model.governance.DaoPhase;
@ -157,10 +156,6 @@ public class VoteRevealService implements DaoStateListener, DaoSetupService {
maybeRevealVotes();
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -22,14 +22,15 @@ import bisq.core.dao.state.model.blockchain.Block;
public interface DaoStateListener {
void onNewBlockHeight(int blockHeight);
void onParseTxsCompleteAfterBatchProcessing(Block block);
void onParseBlockChainComplete();
// Never used but we still want to provide the event
default void onEmptyBlockAdded(Block block) {
}
default void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
default void onParseTxsComplete(Block block, boolean parseBlockChainComplete) {
}
}

View file

@ -74,10 +74,6 @@ public class DaoStateSnapshotService implements DaoStateListener {
public void onNewBlockHeight(int blockHeight) {
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
// We listen to each ParseTxsComplete event even the batch processing of all blocks at startup is not completed
// as we need to write snapshots during that batch processing.
@Override

View file

@ -22,7 +22,6 @@ import bisq.desktop.util.Layout;
import bisq.core.dao.DaoFacade;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.governance.DaoPhase;
import bisq.core.locale.Res;
@ -96,10 +95,6 @@ public class PhasesView implements DaoStateListener {
applyData(height);
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -25,7 +25,6 @@ import bisq.desktop.util.Layout;
import bisq.core.dao.DaoFacade;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.governance.DaoPhase;
import bisq.core.locale.Res;
import bisq.core.util.BSFormatter;
@ -111,10 +110,6 @@ public class GovernanceDashboardView extends ActivatableView<GridPane, Void> imp
applyData(height);
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -38,7 +38,6 @@ import bisq.core.dao.governance.proposal.ProposalWithTransaction;
import bisq.core.dao.governance.proposal.TxException;
import bisq.core.dao.governance.proposal.param.ChangeParamValidator;
import bisq.core.dao.state.DaoStateListener;
import bisq.core.dao.state.model.blockchain.Block;
import bisq.core.dao.state.model.governance.DaoPhase;
import bisq.core.dao.state.model.governance.Proposal;
import bisq.core.dao.state.model.governance.Role;
@ -187,10 +186,6 @@ public class MakeProposalView extends ActivatableView<GridPane, Void> implements
proposalTypeComboBox.getSelectionModel().clearSelection();
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}

View file

@ -184,10 +184,6 @@ public class VoteResultView extends ActivatableView<GridPane, Void> implements D
fillCycleList();
}
@Override
public void onParseTxsCompleteAfterBatchProcessing(Block block) {
}
@Override
public void onParseBlockChainComplete() {
}