1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
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/consensus"
"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/core/vm"
"github.com/dexon-foundation/dexon/event"
"github.com/dexon-foundation/dexon/params"
"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
Config() *params.ChainConfig
CurrentBlock() *types.Block
CurrentFastBlock() *types.Block
CurrentHeader() *types.Header
Engine() consensus.Engine
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
GetVMConfig() *vm.Config
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}
}
|
