deep-stack/ipld-eth-server
6
0
Fork 0
forked from cerc-io/ipld-eth-server
Code Pull Requests Activity
e510154c81
ipld-eth-server/pkg/fakes/blockchain.go

43 lines
1.0 KiB
Go
Raw Normal View History

Start introducing domain concepts * Potential observers include a logger and/or an observer that writes to the DB
2017-10-23 15:56:29 +00:00
package fakes
Nest packages under pkg
2017-11-06 18:53:43 +00:00
import "github.com/8thlight/vulcanizedb/pkg/core"
Start introducing domain concepts * Potential observers include a logger and/or an observer that writes to the DB
2017-10-23 15:56:29 +00:00
type Blockchain struct {
Add ability to populate missing blocks * The command populates up to the highest known block number * The anticipated use case is that the listener will be running in parallel to the populateBlocks command * This will mean that the listener is responsible for picking up new blocks, and the populateBlocks command is reposible for historical blocks * Reformat SQL statements
2017-11-06 20:36:12 +00:00
blocks map[int64]core.Block
blocksChannel chan core.Block
Close subscription in integration test * This was causing issues in future tests, since the subscription was causing blocks and transactions to be added to the DB
2017-11-03 13:54:32 +00:00
WasToldToStop bool
Start introducing domain concepts * Potential observers include a logger and/or an observer that writes to the DB
2017-10-23 15:56:29 +00:00
}
Add ability to populate missing blocks * The command populates up to the highest known block number * The anticipated use case is that the listener will be running in parallel to the populateBlocks command * This will mean that the listener is responsible for picking up new blocks, and the populateBlocks command is reposible for historical blocks * Reformat SQL statements
2017-11-06 20:36:12 +00:00
func NewBlockchain() *Blockchain {
return &Blockchain{blocks: make(map[int64]core.Block)}
}
func NewBlockchainWithBlocks(blocks []core.Block) *Blockchain {
blockNumberToBlocks := make(map[int64]core.Block)
for _, block := range blocks {
blockNumberToBlocks[block.Number] = block
}
return &Blockchain{
blocks: blockNumberToBlocks,
}
}
func (blockchain *Blockchain) GetBlockByNumber(blockNumber int64) core.Block {
return blockchain.blocks[blockNumber]
}
Refactor to use listener * This removes some duplication between the fake blockchain and geth blockchain. * This pulls the observers into the blockchain listener
2017-11-02 11:41:24 +00:00
func (blockchain *Blockchain) SubscribeToBlocks(outputBlocks chan core.Block) {
Add ability to populate missing blocks * The command populates up to the highest known block number * The anticipated use case is that the listener will be running in parallel to the populateBlocks command * This will mean that the listener is responsible for picking up new blocks, and the populateBlocks command is reposible for historical blocks * Reformat SQL statements
2017-11-06 20:36:12 +00:00
blockchain.blocksChannel = outputBlocks
Start introducing domain concepts * Potential observers include a logger and/or an observer that writes to the DB
2017-10-23 15:56:29 +00:00
}
Add ability to populate missing blocks * The command populates up to the highest known block number * The anticipated use case is that the listener will be running in parallel to the populateBlocks command * This will mean that the listener is responsible for picking up new blocks, and the populateBlocks command is reposible for historical blocks * Reformat SQL statements
2017-11-06 20:36:12 +00:00
func (blockchain *Blockchain) AddBlock(block core.Block) {
blockchain.blocks[block.Number] = block
blockchain.blocksChannel <- block
Start introducing domain concepts * Potential observers include a logger and/or an observer that writes to the DB
2017-10-23 15:56:29 +00:00
}
Implement GethBlockchain
2017-10-23 18:58:33 +00:00
Refactor to use listener * This removes some duplication between the fake blockchain and geth blockchain. * This pulls the observers into the blockchain listener
2017-11-02 11:41:24 +00:00
func (*Blockchain) StartListening() {}
Close subscription in integration test * This was causing issues in future tests, since the subscription was causing blocks and transactions to be added to the DB
2017-11-03 13:54:32 +00:00
func (blockchain *Blockchain) StopListening() {
blockchain.WasToldToStop = true
}
Copy Permalink