added RPC/IPC support

1 files changed, 41 insertions, 0 deletions

diff --git a/rpc/api/utils.go b/rpc/api/utils.go
index 76f00c251..a62058140 100644
--- a/rpc/api/utils.go
+++ b/rpc/api/utils.go
@@ -8,6 +8,7 @@ import (
 	"github.com/ethereum/go-ethereum/eth"
 	"github.com/ethereum/go-ethereum/rpc/codec"
 	"github.com/ethereum/go-ethereum/xeth"
+	"github.com/ethereum/go-ethereum/rpc/shared"
 )
 
 const (
@@ -34,3 +35,43 @@ func ParseApiString(apistr string, codec codec.Codec, xeth *xeth.XEth, eth *eth.
 
 	return apis, nil
 }
+
+// combines multiple API's
+type mergedApi struct {
+	apis map[string]EthereumApi
+}
+
+// create new merged api instance
+func newMergedApi(apis ...EthereumApi) *mergedApi {
+	mergedApi := new(mergedApi)
+	mergedApi.apis = make(map[string]EthereumApi)
+
+	for _, api := range apis {
+		for _, method := range api.Methods() {
+			mergedApi.apis[method] = api
+		}
+	}
+	return mergedApi
+}
+
+// Supported RPC methods
+func (self *mergedApi) Methods() []string {
+	all := make([]string, len(self.apis))
+	for method, _ := range self.apis {
+		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 api, found := self.apis[req.Method]; found {
+		return api.Execute(req)
+	}
+	return nil, shared.NewNotImplementedError(req.Method)
+}
+
+// Merge multiple API's to a single API instance
+func Merge(apis ...EthereumApi) EthereumApi {
+	return newMergedApi(apis...)
+}