You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
68 lines
2.1 KiB
68 lines
2.1 KiB
package hmy
|
|
|
|
import (
|
|
"math/big"
|
|
|
|
"github.com/ethereum/go-ethereum/common"
|
|
"github.com/ethereum/go-ethereum/core/bloombits"
|
|
"github.com/ethereum/go-ethereum/ethdb"
|
|
"github.com/ethereum/go-ethereum/event"
|
|
"github.com/ethereum/go-ethereum/params"
|
|
"github.com/harmony-one/harmony/accounts"
|
|
"github.com/harmony-one/harmony/core"
|
|
"github.com/harmony-one/harmony/core/types"
|
|
)
|
|
|
|
// Harmony implements the Harmony full node service.
|
|
type Harmony struct {
|
|
// Channel for shutting down the service
|
|
shutdownChan chan bool // Channel for shutting down the Harmony
|
|
bloomRequests chan chan *bloombits.Retrieval // Channel receiving bloom data retrieval requests
|
|
|
|
blockchain *core.BlockChain
|
|
txPool *core.TxPool
|
|
accountManager *accounts.Manager
|
|
eventMux *event.TypeMux
|
|
// DB interfaces
|
|
chainDb ethdb.Database // Block chain database
|
|
|
|
bloomIndexer *core.ChainIndexer // Bloom indexer operating during block imports
|
|
APIBackend *APIBackend
|
|
|
|
nodeAPI NodeAPI
|
|
}
|
|
|
|
// NodeAPI is the list of functions from node used to call rpc apis.
|
|
type NodeAPI interface {
|
|
AddPendingTransaction(newTx *types.Transaction)
|
|
Blockchain() *core.BlockChain
|
|
AccountManager() *accounts.Manager
|
|
GetBalanceOfAddress(address common.Address) (*big.Int, error)
|
|
}
|
|
|
|
// New creates a new Harmony object (including the
|
|
// initialisation of the common Harmony object)
|
|
func New(nodeAPI NodeAPI, txPool *core.TxPool, eventMux *event.TypeMux) (*Harmony, error) {
|
|
chainDb := nodeAPI.Blockchain().ChainDB()
|
|
hmy := &Harmony{
|
|
shutdownChan: make(chan bool),
|
|
bloomRequests: make(chan chan *bloombits.Retrieval),
|
|
blockchain: nodeAPI.Blockchain(),
|
|
txPool: txPool,
|
|
accountManager: nodeAPI.AccountManager(),
|
|
eventMux: eventMux,
|
|
chainDb: chainDb,
|
|
bloomIndexer: NewBloomIndexer(chainDb, params.BloomBitsBlocks, params.BloomConfirms),
|
|
nodeAPI: nodeAPI,
|
|
}
|
|
|
|
hmy.APIBackend = &APIBackend{hmy}
|
|
|
|
return hmy, nil
|
|
}
|
|
|
|
// TxPool ...
|
|
func (s *Harmony) TxPool() *core.TxPool { return s.txPool }
|
|
|
|
// BlockChain ...
|
|
func (s *Harmony) BlockChain() *core.BlockChain { return s.blockchain }
|
|
|