mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-23 15:00:30 +01:00
Code Issues Projects Releases Packages Wiki Activity

Add BurningManAccountingStore resource file.

Browse source 
Use resourceDataStoreService and extend StoreService

Signed-off-by: HenrikJannsen <boilingfrog@gmx.com>
This commit is contained in:
HenrikJannsen 2022-11-25 15:05:26 -05:00
parent a03b0eadfc
commit 1bb4b55220
No known key found for this signature in database
GPG key ID: 02AA2BAE387C8307
3 changed files with 37 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

61
core/src/main/java/bisq/core/dao/burningman/accounting/storage/BurningManAccountingStoreService.java
View file

@ -19,12 +19,18 @@ package bisq.core.dao.burningman.accounting.storage;
import bisq.core.dao.burningman.accounting.blockchain.AccountingBlock;
import bisq.network.p2p.storage.persistence.ResourceDataStoreService;
import bisq.network.p2p.storage.persistence.StoreService;
import bisq.common.config.Config;
import bisq.common.persistence.PersistenceManager;
import bisq.common.proto.persistable.PersistedDataHost;
import javax.inject.Inject;
import javax.inject.Named;
import javax.inject.Singleton;
import java.io.File;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
@ -33,29 +39,16 @@ import lombok.extern.slf4j.Slf4j;
@Slf4j
@Singleton
public class BurningManAccountingStoreService implements PersistedDataHost {
private final PersistenceManager<BurningManAccountingStore> persistenceManager;
private final BurningManAccountingStore burningManAccountingStore = new BurningManAccountingStore(new ArrayList<>());
public class BurningManAccountingStoreService extends StoreService<BurningManAccountingStore> {
private static final String FILE_NAME = "BurningManAccountingStore";
@Inject
public BurningManAccountingStoreService(PersistenceManager<BurningManAccountingStore> persistenceManager) {
this.persistenceManager = persistenceManager;
public BurningManAccountingStoreService(ResourceDataStoreService resourceDataStoreService,
@Named(Config.STORAGE_DIR) File storageDir,
PersistenceManager<BurningManAccountingStore> persistenceManager) {
super(storageDir, persistenceManager);
this.persistenceManager.initialize(burningManAccountingStore, PersistenceManager.Source.PRIVATE_LOW_PRIO);
}
///////////////////////////////////////////////////////////////////////////////////////////
// PersistedDataHost implementation
///////////////////////////////////////////////////////////////////////////////////////////
@Override
public void readPersisted(Runnable completeHandler) {
persistenceManager.readPersisted(persisted -> {
burningManAccountingStore.getBlocks().addAll(persisted.getBlocks());
completeHandler.run();
},
completeHandler);
resourceDataStoreService.addService(this);
}
@ -68,16 +61,16 @@ public class BurningManAccountingStoreService implements PersistedDataHost {
}
public List<AccountingBlock> getBlocks() {
return Collections.unmodifiableList(burningManAccountingStore.getBlocks());
return Collections.unmodifiableList(store.getBlocks());
}
public void addBlock(AccountingBlock block) {
burningManAccountingStore.getBlocks().add(block);
store.getBlocks().add(block);
requestPersistence();
}
public void purgeLastTenBlocks() {
List<AccountingBlock> blocks = burningManAccountingStore.getBlocks();
List<AccountingBlock> blocks = store.getBlocks();
if (blocks.size() <= 10) {
blocks.clear();
requestPersistence();
@ -89,4 +82,24 @@ public class BurningManAccountingStoreService implements PersistedDataHost {
blocks.addAll(purged);
requestPersistence();
}
///////////////////////////////////////////////////////////////////////////////////////////
// Protected
///////////////////////////////////////////////////////////////////////////////////////////
@Override
protected BurningManAccountingStore createStore() {
return new BurningManAccountingStore(new ArrayList<>());
}
@Override
protected void initializePersistenceManager() {
persistenceManager.initialize(store, PersistenceManager.Source.NETWORK);
}
@Override
public String getFileName() {
return FILE_NAME;
}
}

2
core/src/main/java/bisq/core/setup/CorePersistedDataHost.java
View file

@ -18,7 +18,6 @@
package bisq.core.setup;
import bisq.core.btc.model.AddressEntryList;
import bisq.core.dao.burningman.accounting.storage.BurningManAccountingStoreService;
import bisq.core.dao.governance.ballot.BallotListService;
import bisq.core.dao.governance.blindvote.MyBlindVoteListService;
import bisq.core.dao.governance.bond.reputation.MyReputationListService;
@ -81,7 +80,6 @@ public class CorePersistedDataHost {
persistedDataHosts.add(injector.getInstance(MyReputationListService.class));
persistedDataHosts.add(injector.getInstance(MyProofOfBurnListService.class));
persistedDataHosts.add(injector.getInstance(UnconfirmedBsqChangeOutputListService.class));
persistedDataHosts.add(injector.getInstance(BurningManAccountingStoreService.class));
return persistedDataHosts;
}
}

BIN
p2p/src/main/resources/BurningManAccountingStore_BTC_MAINNET Normal file
View file

Binary file not shown.