-
Notifications
You must be signed in to change notification settings - Fork 47
/
blockchain.go
79 lines (68 loc) · 2.79 KB
/
blockchain.go
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
// Copyright 2022 The AmazeChain Authors
// This file is part of the AmazeChain library.
//
// The AmazeChain library is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// The AmazeChain library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with the AmazeChain library. If not, see <http://www.gnu.org/licenses/>.
package common
import (
"github.com/amazechain/amc/common/block"
"github.com/amazechain/amc/common/types"
"github.com/amazechain/amc/internal/consensus"
"github.com/amazechain/amc/modules/state"
"github.com/amazechain/amc/params"
"github.com/holiman/uint256"
"github.com/ledgerwatch/erigon-lib/kv"
"github.com/libp2p/go-libp2p/core/peer"
)
type IHeaderChain interface {
GetHeaderByNumber(number *uint256.Int) block.IHeader
GetHeaderByHash(h types.Hash) (block.IHeader, error)
InsertHeader(headers []block.IHeader) (int, error)
GetBlockByHash(h types.Hash) (block.IBlock, error)
GetBlockByNumber(number *uint256.Int) (block.IBlock, error)
}
type IBlockChain interface {
IHeaderChain
Config() *params.ChainConfig
CurrentBlock() block.IBlock
Blocks() []block.IBlock
Start() error
GenesisBlock() block.IBlock
NewBlockHandler(payload []byte, peer peer.ID) error
InsertChain(blocks []block.IBlock) (int, error)
InsertBlock(blocks []block.IBlock, isSync bool) (int, error)
SetEngine(engine consensus.Engine)
GetBlocksFromHash(hash types.Hash, n int) (blocks []block.IBlock)
SealedBlock(b block.IBlock) error
Engine() consensus.Engine
GetReceipts(blockHash types.Hash) (block.Receipts, error)
GetLogs(blockHash types.Hash) ([][]*block.Log, error)
SetHead(head uint64) error
AddFutureBlock(block block.IBlock) error
GetHeader(types.Hash, *uint256.Int) block.IHeader
// alias for GetBlocksFromHash?
GetBlock(hash types.Hash, number uint64) block.IBlock
StateAt(tx kv.Tx, blockNr uint64) *state.IntraBlockState
GetTd(hash types.Hash, number *uint256.Int) *uint256.Int
HasBlock(hash types.Hash, number uint64) bool
DB() kv.RwDB
Quit() <-chan struct{}
Close() error
WriteBlockWithState(block block.IBlock, receipts []*block.Receipt, ibs *state.IntraBlockState, nopay map[types.Address]*uint256.Int) error
GetDepositInfo(address types.Address) (*uint256.Int, *uint256.Int)
GetAccountRewardUnpaid(account types.Address) (*uint256.Int, error)
}
type IMiner interface {
Start()
PendingBlockAndReceipts() (block.IBlock, block.Receipts)
}