op-geth/rpc/api/mergedapi.go

57 lines
1.3 KiB
Go
Raw Normal View History

2015-06-08 10:43:58 +00:00
package api
import "github.com/ethereum/go-ethereum/rpc/shared"
// combines multiple API's
2015-06-09 14:06:51 +00:00
type MergedApi struct {
2015-06-08 12:50:11 +00:00
apis []string
2015-06-08 10:43:58 +00:00
methods map[string]EthereumApi
}
// create new merged api instance
2015-06-09 14:06:51 +00:00
func newMergedApi(apis ...EthereumApi) *MergedApi {
mergedApi := new(MergedApi)
2015-06-08 10:43:58 +00:00
mergedApi.apis = make([]string, len(apis))
mergedApi.methods = make(map[string]EthereumApi)
for i, api := range apis {
mergedApi.apis[i] = api.Name()
for _, method := range api.Methods() {
mergedApi.methods[method] = api
}
}
return mergedApi
}
// Supported RPC methods
2015-06-09 14:06:51 +00:00
func (self *MergedApi) Methods() []string {
2015-06-08 10:43:58 +00:00
all := make([]string, len(self.methods))
for method, _ := range self.methods {
all = append(all, method)
}
return all
}
// Call the correct API's Execute method for the given request
2015-06-09 14:06:51 +00:00
func (self *MergedApi) Execute(req *shared.Request) (interface{}, error) {
2015-06-08 10:43:58 +00:00
if res, _ := self.handle(req); res != nil {
return res, nil
}
if api, found := self.methods[req.Method]; found {
return api.Execute(req)
}
return nil, shared.NewNotImplementedError(req.Method)
}
2015-06-09 14:06:51 +00:00
func (self *MergedApi) Name() string {
2015-06-08 10:43:58 +00:00
return MergedApiName
}
2015-06-09 14:06:51 +00:00
func (self *MergedApi) handle(req *shared.Request) (interface{}, error) {
2015-06-08 12:50:11 +00:00
if req.Method == "support_apis" { // provided API's
2015-06-08 10:43:58 +00:00
return self.apis, nil
}
return nil, nil
}