ipld-eth-server/pkg/fakes/blockchain.go

package fakes

import "github.com/8thlight/vulcanizedb/pkg/core"

type Blockchain struct {
	outputBlocks  chan core.Block
	WasToldToStop bool
}

func (blockchain *Blockchain) SubscribeToBlocks(outputBlocks chan core.Block) {
	blockchain.outputBlocks = outputBlocks
}

func (blockchain Blockchain) AddBlock(block core.Block) {
	blockchain.outputBlocks <- block
}

func (*Blockchain) StartListening() {}

func (blockchain *Blockchain) StopListening() {
	blockchain.WasToldToStop = true
}
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 {`
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			`outputBlocks chan core.Block`
			`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			`}`

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) {`
			`blockchain.outputBlocks = 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			`}`

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) AddBlock(block core.Block) {`
			`blockchain.outputBlocks <- 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`
			`}`