ipld-eth-server/pkg/geth/geth_blockchain.go

package geth

import (
	"fmt"

	"math/big"

	"github.com/8thlight/vulcanizedb/pkg/core"
	"github.com/ethereum/go-ethereum"
	"github.com/ethereum/go-ethereum/core/types"
	"github.com/ethereum/go-ethereum/ethclient"
	"golang.org/x/net/context"
)

type GethBlockchain struct {
	client              *ethclient.Client
	readGethHeaders     chan *types.Header
	outputBlocks        chan core.Block
	newHeadSubscription ethereum.Subscription
}

func (blockchain *GethBlockchain) GetBlockByNumber(blockNumber int64) core.Block {
	gethBlock, _ := blockchain.client.BlockByNumber(context.Background(), big.NewInt(blockNumber))
	return GethBlockToCoreBlock(gethBlock, blockchain.client)
}

func NewGethBlockchain(ipcPath string) *GethBlockchain {
	blockchain := GethBlockchain{}
	client, _ := ethclient.Dial(ipcPath)
	blockchain.client = client
	return &blockchain
}

func (blockchain *GethBlockchain) SubscribeToBlocks(blocks chan core.Block) {
	blockchain.outputBlocks = blocks
	fmt.Println("SubscribeToBlocks")
	inputHeaders := make(chan *types.Header, 10)
	myContext := context.Background()
	blockchain.readGethHeaders = inputHeaders
	subscription, _ := blockchain.client.SubscribeNewHead(myContext, inputHeaders)
	blockchain.newHeadSubscription = subscription
}

func (blockchain *GethBlockchain) StartListening() {
	for header := range blockchain.readGethHeaders {
		block := blockchain.GetBlockByNumber(header.Number.Int64())
		blockchain.outputBlocks <- block
	}
}

func (blockchain *GethBlockchain) StopListening() {
	blockchain.newHeadSubscription.Unsubscribe()
}
Reorganize files into separate packages 2017-11-02 19:37:07 +00:00			`package geth`
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			`import (`
			`"fmt"`
Added fields for: Time, Gas Limit, and Gas Used 2017-10-25 22:24:38 +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			`"math/big"`

Nest packages under pkg 2017-11-06 18:53:43 +00:00			`"github.com/8thlight/vulcanizedb/pkg/core"`
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			`"github.com/ethereum/go-ethereum"`
Implement GethBlockchain 2017-10-23 18:58:33 +00:00			`"github.com/ethereum/go-ethereum/core/types"`
			`"github.com/ethereum/go-ethereum/ethclient"`
			`"golang.org/x/net/context"`
			`)`
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			`type GethBlockchain 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			`client *ethclient.Client`
			`readGethHeaders chan *types.Header`
			`outputBlocks chan core.Block`
			`newHeadSubscription ethereum.Subscription`
Implement GethBlockchain 2017-10-23 18:58:33 +00:00			`}`
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 *GethBlockchain) GetBlockByNumber(blockNumber int64) core.Block {`
			`gethBlock, _ := blockchain.client.BlockByNumber(context.Background(), big.NewInt(blockNumber))`
Added From field to transactions 2017-11-08 20:55:35 +00:00			`return GethBlockToCoreBlock(gethBlock, blockchain.client)`
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			`}`

Pass in IPC path as command line argument 2017-10-23 19:33:08 +00:00			`func NewGethBlockchain(ipcPath string) *GethBlockchain {`
Implement GethBlockchain 2017-10-23 18:58:33 +00:00			`blockchain := GethBlockchain{}`
Pass in IPC path as command line argument 2017-10-23 19:33:08 +00:00			`client, _ := ethclient.Dial(ipcPath)`
Implement GethBlockchain 2017-10-23 18:58:33 +00:00			`blockchain.client = client`
			`return &blockchain`
			`}`
Add integration test * Update Travis to run integration tests 2017-10-24 14:24:07 +00:00
Reorganize files into separate packages 2017-11-02 19:37:07 +00:00			`func (blockchain *GethBlockchain) SubscribeToBlocks(blocks chan core.Block) {`
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			`blockchain.outputBlocks = blocks`
			`fmt.Println("SubscribeToBlocks")`
			`inputHeaders := make(chan *types.Header, 10)`
			`myContext := context.Background()`
			`blockchain.readGethHeaders = inputHeaders`
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			`subscription, _ := blockchain.client.SubscribeNewHead(myContext, inputHeaders)`
			`blockchain.newHeadSubscription = subscription`
Implement GethBlockchain 2017-10-23 18:58:33 +00:00			`}`
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 *GethBlockchain) StartListening() {`
			`for header := range blockchain.readGethHeaders {`
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			`block := blockchain.GetBlockByNumber(header.Number.Int64())`
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			`blockchain.outputBlocks <- block`
Implement GethBlockchain 2017-10-23 18:58:33 +00:00			`}`
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			`}`
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 *GethBlockchain) StopListening() {`
			`blockchain.newHeadSubscription.Unsubscribe()`
			`}`