1 files changed, 85 insertions, 0 deletions
diff --git a/indexer/blockhain.go b/indexer/blockhain.go
new file mode 100644
index 000000000..bf9a180ce
--- /dev/null
+++ b/indexer/blockhain.go
@@ -0,0 +1,85 @@
+package indexer
+
+import (
+	"math/big"
+
+	coreCommon "github.com/dexon-foundation/dexon-consensus/common"
+	coreTypes "github.com/dexon-foundation/dexon-consensus/core/types"
+
+	"github.com/dexon-foundation/dexon/common"
+	"github.com/dexon-foundation/dexon/core"
+	"github.com/dexon-foundation/dexon/core/state"
+	"github.com/dexon-foundation/dexon/core/types"
+	"github.com/dexon-foundation/dexon/event"
+	"github.com/dexon-foundation/dexon/rlp"
+)
+
+// ReadOnlyBlockChain defines safe reading blockchain interface by removing write
+// methods of core.BlockChain struct.
+type ReadOnlyBlockChain interface {
+	BadBlocks() []*types.Block
+	CurrentBlock() *types.Block
+	CurrentFastBlock() *types.Block
+	CurrentHeader() *types.Header
+	GasLimit() uint64
+	Genesis() *types.Block
+	GetAncestor(common.Hash, uint64, uint64, *uint64) (common.Hash, uint64)
+	GetAddressInfo(uint32, common.Address) (
+		info struct {
+			Nonce   uint64
+			Cost    *big.Int
+			Counter uint64
+		})
+	GetBlock(common.Hash, uint64) *types.Block
+	GetBlockByHash(common.Hash) *types.Block
+	GetBlockByNumber(uint64) *types.Block
+	GetBlockHashesFromHash(common.Hash, uint64) []common.Hash
+	GetBlocksFromHash(common.Hash, int) (blocks []*types.Block)
+	GetBody(common.Hash) *types.Body
+	GetBodyRLP(common.Hash) rlp.RawValue
+	GetChainLastConfirmedHeight(uint32) uint64
+	GetConfirmedBlockByHash(uint32, coreCommon.Hash) (*coreTypes.Block, types.Transactions)
+	GetCostInConfirmedBlocks(uint32, common.Address) (*big.Int, bool)
+	GetGovStateByHash(common.Hash) (*types.GovState, error)
+	GetGovStateByNumber(uint64) (*types.GovState, error)
+	GetHeader(common.Hash, uint64) *types.Header
+	GetHeaderByHash(common.Hash) *types.Header
+	GetHeaderByNumber(number uint64) *types.Header
+	GetLastNonceInConfirmedBlocks(uint32, common.Address) (uint64, bool)
+	GetPending() (*types.Block, *state.StateDB)
+	GetPendingBlockByNumber(uint64) *types.Block
+	GetPendingHeight() uint64
+	GetReceiptsByHash(common.Hash) types.Receipts
+	GetRoundHeight(uint64) (uint64, bool)
+	GetTd(common.Hash, uint64) *big.Int
+	GetTdByHash(common.Hash) *big.Int
+	GetUnclesInChain(*types.Block, int) []*types.Header
+	HasBlock(common.Hash, uint64) bool
+	HasBlockAndState(common.Hash, uint64) bool
+	HasHeader(common.Hash, uint64) bool
+	HasState(common.Hash) bool
+	PendingBlock() *types.Block
+	State() (*state.StateDB, error)
+	StateAt(root common.Hash) (*state.StateDB, error)
+	SubscribeBlockConfirmedEvent(chan<- core.BlockConfirmedEvent) event.Subscription
+	SubscribeChainEvent(chan<- core.ChainEvent) event.Subscription
+	SubscribeChainHeadEvent(chan<- core.ChainHeadEvent) event.Subscription
+	SubscribeChainSideEvent(chan<- core.ChainSideEvent) event.Subscription
+	SubscribeLogsEvent(chan<- []*types.Log) event.Subscription
+	SubscribeRemovedLogsEvent(chan<- core.RemovedLogsEvent) event.Subscription
+}
+
+// access protection
+type ro interface {
+	ReadOnlyBlockChain
+}
+
+// ROBlockChain struct for safe read.
+type ROBlockChain struct {
+	ro
+}
+
+// NewROBlockChain converts original block chain to readonly interface.
+func NewROBlockChain(bc *core.BlockChain) ReadOnlyBlockChain {
+	return &ROBlockChain{ro: bc}
+}