plugeth/rpc/api/net.go

90 lines
2.0 KiB
Go
Raw Normal View History

2015-06-08 12:50:11 +00:00
package api
import (
"github.com/ethereum/go-ethereum/eth"
"github.com/ethereum/go-ethereum/rpc/codec"
"github.com/ethereum/go-ethereum/rpc/shared"
"github.com/ethereum/go-ethereum/xeth"
)
2015-06-08 12:50:11 +00:00
const (
NetApiVersion = "1.0"
)
2015-06-08 12:50:11 +00:00
var (
// mapping between methods and handlers
netMapping = map[string]nethandler{
2015-06-10 09:29:52 +00:00
"net_version": (*netApi).Version,
2015-06-09 14:06:51 +00:00
"net_peerCount": (*netApi).PeerCount,
"net_listening": (*netApi).IsListening,
"net_peers": (*netApi).Peers,
2015-06-08 12:50:11 +00:00
}
)
// net callback handler
2015-06-09 14:06:51 +00:00
type nethandler func(*netApi, *shared.Request) (interface{}, error)
2015-06-08 12:50:11 +00:00
// net api provider
2015-06-09 14:06:51 +00:00
type netApi struct {
2015-06-08 12:50:11 +00:00
xeth *xeth.XEth
ethereum *eth.Ethereum
methods map[string]nethandler
codec codec.ApiCoder
}
// create a new net api instance
2015-06-09 14:06:51 +00:00
func NewNetApi(xeth *xeth.XEth, eth *eth.Ethereum, coder codec.Codec) *netApi {
return &netApi{
2015-06-08 12:50:11 +00:00
xeth: xeth,
ethereum: eth,
methods: netMapping,
codec: coder.New(nil),
}
}
// collection with supported methods
2015-06-09 14:06:51 +00:00
func (self *netApi) Methods() []string {
2015-06-08 12:50:11 +00:00
methods := make([]string, len(self.methods))
i := 0
for k := range self.methods {
methods[i] = k
i++
}
return methods
}
// Execute given request
2015-06-09 14:06:51 +00:00
func (self *netApi) Execute(req *shared.Request) (interface{}, error) {
2015-06-08 12:50:11 +00:00
if callback, ok := self.methods[req.Method]; ok {
return callback(self, req)
}
return nil, shared.NewNotImplementedError(req.Method)
}
2015-06-09 14:06:51 +00:00
func (self *netApi) Name() string {
2015-06-08 12:50:11 +00:00
return NetApiName
}
2015-06-08 12:50:11 +00:00
func (self *netApi) ApiVersion() string {
return NetApiVersion
}
2015-06-08 12:50:11 +00:00
// Network version
2015-06-10 09:29:52 +00:00
func (self *netApi) Version(req *shared.Request) (interface{}, error) {
2015-06-08 12:50:11 +00:00
return self.xeth.NetworkVersion(), nil
}
// Number of connected peers
2015-06-09 14:06:51 +00:00
func (self *netApi) PeerCount(req *shared.Request) (interface{}, error) {
return newHexNum(self.xeth.PeerCount()), nil
2015-06-08 12:50:11 +00:00
}
2015-06-09 14:06:51 +00:00
func (self *netApi) IsListening(req *shared.Request) (interface{}, error) {
2015-06-08 12:50:11 +00:00
return self.xeth.IsListening(), nil
}
2015-06-09 14:06:51 +00:00
func (self *netApi) Peers(req *shared.Request) (interface{}, error) {
2015-06-08 12:50:11 +00:00
return self.ethereum.PeersInfo(), nil
}