123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148 |
- // Copyright 2015 The go-ethereum Authors
- // This file is part of the go-ethereum library.
- //
- // The go-ethereum 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 go-ethereum 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 go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
- // Package ethapi implements the general Ethereum API functions.
- package ethapi
- import (
- "context"
- "math/big"
- "time"
- "github.com/ethereum/go-ethereum/accounts"
- "github.com/ethereum/go-ethereum/common"
- "github.com/ethereum/go-ethereum/consensus"
- "github.com/ethereum/go-ethereum/core"
- "github.com/ethereum/go-ethereum/core/bloombits"
- "github.com/ethereum/go-ethereum/core/mps"
- "github.com/ethereum/go-ethereum/core/types"
- "github.com/ethereum/go-ethereum/core/vm"
- "github.com/ethereum/go-ethereum/eth/downloader"
- "github.com/ethereum/go-ethereum/ethdb"
- "github.com/ethereum/go-ethereum/event"
- "github.com/ethereum/go-ethereum/params"
- "github.com/ethereum/go-ethereum/rpc"
- "github.com/jpmorganchase/quorum-security-plugin-sdk-go/proto"
- )
- // Backend interface provides the common API services (that are provided by
- // both full and light clients) with access to necessary functions.
- type Backend interface {
- // General Ethereum API
- Downloader() *downloader.Downloader
- SuggestPrice(ctx context.Context) (*big.Int, error)
- ChainDb() ethdb.Database
- AccountManager() *accounts.Manager
- ExtRPCEnabled() bool
- RPCGasCap() uint64 // global gas cap for eth_call over rpc: DoS protection
- RPCTxFeeCap() float64 // global tx fee cap for all transaction related APIs
- UnprotectedAllowed() bool // allows only for EIP155 transactions.
- // Blockchain API
- SetHead(number uint64)
- HeaderByNumber(ctx context.Context, number rpc.BlockNumber) (*types.Header, error)
- HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)
- HeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*types.Header, error)
- CurrentHeader() *types.Header
- CurrentBlock() *types.Block
- BlockByNumber(ctx context.Context, number rpc.BlockNumber) (*types.Block, error)
- BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
- BlockByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (*types.Block, error)
- StateAndHeaderByNumber(ctx context.Context, number rpc.BlockNumber) (vm.MinimalApiState, *types.Header, error)
- StateAndHeaderByNumberOrHash(ctx context.Context, blockNrOrHash rpc.BlockNumberOrHash) (vm.MinimalApiState, *types.Header, error)
- GetReceipts(ctx context.Context, hash common.Hash) (types.Receipts, error)
- GetTd(ctx context.Context, hash common.Hash) *big.Int
- GetEVM(ctx context.Context, msg core.Message, state vm.MinimalApiState, header *types.Header, vmConfig *vm.Config) (*vm.EVM, func() error, error)
- SubscribeChainEvent(ch chan<- core.ChainEvent) event.Subscription
- SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription
- SubscribeChainSideEvent(ch chan<- core.ChainSideEvent) event.Subscription
- // Transaction pool API
- SendTx(ctx context.Context, signedTx *types.Transaction) error
- GetTransaction(ctx context.Context, txHash common.Hash) (*types.Transaction, common.Hash, uint64, uint64, error)
- GetPoolTransactions() (types.Transactions, error)
- GetPoolTransaction(txHash common.Hash) *types.Transaction
- GetPoolNonce(ctx context.Context, addr common.Address) (uint64, error)
- Stats() (pending int, queued int)
- TxPoolContent() (map[common.Address]types.Transactions, map[common.Address]types.Transactions)
- SubscribeNewTxsEvent(chan<- core.NewTxsEvent) event.Subscription
- // Filter API
- BloomStatus() (uint64, uint64)
- GetLogs(ctx context.Context, blockHash common.Hash) ([][]*types.Log, error)
- ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
- SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
- SubscribePendingLogsEvent(ch chan<- []*types.Log) event.Subscription
- SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent) event.Subscription
- ChainConfig() *params.ChainConfig
- Engine() consensus.Engine
- // Quorum
- CallTimeOut() time.Duration
- // AccountExtraDataStateGetterByNumber returns state getter at a given block height
- AccountExtraDataStateGetterByNumber(ctx context.Context, number rpc.BlockNumber) (vm.AccountExtraDataStateGetter, error)
- PSMR() mps.PrivateStateMetadataResolver
- SupportsMultitenancy(rpcCtx context.Context) (*proto.PreAuthenticatedAuthenticationToken, bool)
- // IsPrivacyMarkerTransactionCreationEnabled returns true if privacy marker transactions are enabled and should be created
- IsPrivacyMarkerTransactionCreationEnabled() bool
- }
- func GetAPIs(apiBackend Backend) []rpc.API {
- nonceLock := new(AddrLocker)
- return []rpc.API{
- {
- Namespace: "eth",
- Version: "1.0",
- Service: NewPublicEthereumAPI(apiBackend),
- Public: true,
- }, {
- Namespace: "eth",
- Version: "1.0",
- Service: NewPublicBlockChainAPI(apiBackend),
- Public: true,
- }, {
- Namespace: "eth",
- Version: "1.0",
- Service: NewPublicTransactionPoolProxyAPI(apiBackend, nonceLock),
- Public: true,
- }, {
- Namespace: "txpool",
- Version: "1.0",
- Service: NewPublicTxPoolAPI(apiBackend),
- Public: true,
- }, {
- Namespace: "debug",
- Version: "1.0",
- Service: NewPublicDebugAPI(apiBackend),
- Public: true,
- }, {
- Namespace: "debug",
- Version: "1.0",
- Service: NewPrivateDebugAPI(apiBackend),
- }, {
- Namespace: "eth",
- Version: "1.0",
- Service: NewPublicAccountAPI(apiBackend.AccountManager()),
- Public: true,
- }, {
- Namespace: "personal",
- Version: "1.0",
- Service: NewPrivateAccountProxyAPI(apiBackend, nonceLock),
- Public: false,
- },
- }
- }
|