121 lines
2.7 KiB
Go
121 lines
2.7 KiB
Go
|
package eth
|
||
|
|
|
||
|
|
import (
|
||
|
|
"blockbook/bchain"
|
||
|
|
"blockbook/common"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/ethereum/go-ethereum/ethclient"
|
||
|
|
)
|
||
|
|
|
||
|
|
// EthRPC is an interface to JSON-RPC eth service.
|
||
|
|
type EthRPC struct {
|
||
|
|
client *ethclient.Client
|
||
|
|
rpcURL string
|
||
|
|
user string
|
||
|
|
password string
|
||
|
|
Parser *EthParser
|
||
|
|
Testnet bool
|
||
|
|
Network string
|
||
|
|
Mempool *bchain.Mempool
|
||
|
|
ParseBlocks bool
|
||
|
|
metrics *common.Metrics
|
||
|
|
}
|
||
|
|
|
||
|
|
// NewEthRPC returns new EthRPC instance.
|
||
|
|
func NewEthRPC(url string, user string, password string, timeout time.Duration, parse bool, metrics *common.Metrics) (bchain.BlockChain, error) {
|
||
|
|
c, err := ethclient.Dial(url)
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
s := &EthRPC{
|
||
|
|
client: c,
|
||
|
|
rpcURL: url,
|
||
|
|
user: user,
|
||
|
|
password: password,
|
||
|
|
ParseBlocks: parse,
|
||
|
|
metrics: metrics,
|
||
|
|
}
|
||
|
|
|
||
|
|
// always create parser
|
||
|
|
s.Parser = &EthParser{}
|
||
|
|
|
||
|
|
// // parameters for getInfo request
|
||
|
|
// if s.Parser.Params.Net == wire.MainNet {
|
||
|
|
// s.Testnet = false
|
||
|
|
// s.Network = "livenet"
|
||
|
|
// } else {
|
||
|
|
// s.Testnet = true
|
||
|
|
// s.Network = "testnet"
|
||
|
|
// }
|
||
|
|
|
||
|
|
// s.Mempool = bchain.NewMempool(s, metrics)
|
||
|
|
|
||
|
|
// glog.Info("rpc: block chain ", s.Parser.Params.Name)
|
||
|
|
return s, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) IsTestnet() bool {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetNetworkName() string {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetBestBlockHash() (string, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetBestBlockHeight() (uint32, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetBlockHash(height uint32) (string, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetBlockHeader(hash string) (*bchain.BlockHeader, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetBlock(hash string, height uint32) (*bchain.Block, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetMempool() ([]string, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetTransaction(txid string) (*bchain.Tx, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) EstimateSmartFee(blocks int, conservative bool) (float64, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) SendRawTransaction(tx string) (string, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) ResyncMempool(onNewTxAddr func(txid string, addr string)) error {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetMempoolTransactions(outputScript []byte) ([]string, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetMempoolSpentOutput(outputTxid string, vout uint32) string {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetMempoolEntry(txid string) (*bchain.MempoolEntry, error) {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (b *EthRPC) GetChainParser() bchain.BlockChainParser {
|
||
|
|
panic("not implemented")
|
||
|
|
}
|