Ethereum Listener

+ added callback for db preloaded blocks
This commit is contained in:
romanman 2014-08-09 18:28:58 +03:00
parent c7dd99e358
commit d479f5cb72
5 changed files with 27 additions and 2 deletions

View File

@ -7,6 +7,8 @@ import org.ethereum.core.Blockchain;
import org.ethereum.core.Genesis;
import org.ethereum.crypto.HashUtil;
import org.ethereum.json.JSONHelper;
import org.ethereum.listener.EthereumListener;
import org.ethereum.manager.WorldManager;
import org.ethereum.trie.TrackTrie;
import org.ethereum.trie.Trie;
import org.ethereum.util.ByteUtil;
@ -127,6 +129,12 @@ public class Repository {
this.addBalance (Hex.decode(address), Genesis.getPremineAmount());
}
blockchain.storeBlock(Genesis.getInstance());
EthereumListener listener = WorldManager.getInstance().getListener();
if (listener != null){
listener.onPreloadedBlock(Genesis.getInstance());
}
logger.debug("Block #{} -> {}", Genesis.NUMBER, blockchain.getLastBlock().toFlatString());
dumpState(0, 0, null);
} else {
@ -136,6 +144,11 @@ public class Repository {
Block block = new Block(iterator.next().getValue());
blockchain.getBlockCache().put(block.getNumber(), block.getHash());
blockchain.setLastBlock(block);
EthereumListener listener = WorldManager.getInstance().getListener();
if (listener != null){
listener.onPreloadedBlock(block);
}
logger.debug("Block #{} -> {}", block.getNumber(), block.toFlatString());
}
logger.info(

View File

@ -24,9 +24,10 @@ public interface Ethereum {
public void connect(String ip, int port);
public Block getBlockByIndex(long index);
public long getBlockChainSize();
public void addListener(EthereumListener listener);
public void loadBlockChain();
}

View File

@ -23,7 +23,7 @@ public class EthereumImpl implements Ethereum {
private Logger logger = LoggerFactory.getLogger("facade");
public EthereumImpl() {
WorldManager.getInstance().loadBlockchain();
}
/**
@ -112,4 +112,9 @@ public class EthereumImpl implements Ethereum {
}
}
@Override
public void loadBlockChain() {
WorldManager.getInstance().loadBlockchain();
}
}

View File

@ -14,6 +14,7 @@ public interface EthereumListener {
public void trace(String output);
public void onBlock(Block block);
public void onPreloadedBlock(Block block);
public void onRecvMessage(Message message);
public void onSendMessage(Message message);
public void onPeerDisconnect(String host, long port);

View File

@ -22,6 +22,11 @@ public class EthereumListenerAdapter implements EthereumListener {
}
@Override
public void onPreloadedBlock(Block block) {
}
@Override
public void onRecvMessage(Message message) {