| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 |
- package api
- import "github.com/ethereum/go-ethereum/rpc/shared"
- // combines multiple API's
- type mergedApi struct {
- apis []string
- methods map[string]EthereumApi
- }
- // create new merged api instance
- func newMergedApi(apis ...EthereumApi) *mergedApi {
- mergedApi := new(mergedApi)
- 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
- func (self *mergedApi) Methods() []string {
- 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
- func (self *mergedApi) Execute(req *shared.Request) (interface{}, error) {
- 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)
- }
- func (self *mergedApi) Name() string {
- return MergedApiName
- }
- func (self *mergedApi) handle(req *shared.Request) (interface{}, error) {
- if req.Method == "support_apis" { // provided API's
- return self.apis, nil
- }
- return nil, nil
- }
|