aboutsummaryrefslogtreecommitdiffstats
path: root/rpc
diff options
context:
space:
mode:
authorBas van Kervel <basvankervel@ziggo.nl>2015-06-08 18:43:58 +0800
committerBas van Kervel <basvankervel@gmail.com>2015-06-11 20:17:27 +0800
commit1b59f890955c3658516daa958d0e4732004a78b7 (patch)
tree0c9e4feb630f89e07cd1b2fe2be0c26c4894ba16 /rpc
parentbbfa0a3dcb82e704828d1438261ff26c50c4ccc3 (diff)
downloaddexon-1b59f890955c3658516daa958d0e4732004a78b7.tar
dexon-1b59f890955c3658516daa958d0e4732004a78b7.tar.gz
dexon-1b59f890955c3658516daa958d0e4732004a78b7.tar.bz2
dexon-1b59f890955c3658516daa958d0e4732004a78b7.tar.lz
dexon-1b59f890955c3658516daa958d0e4732004a78b7.tar.xz
dexon-1b59f890955c3658516daa958d0e4732004a78b7.tar.zst
dexon-1b59f890955c3658516daa958d0e4732004a78b7.zip
added console command
Diffstat (limited to 'rpc')
-rw-r--r--rpc/api/api.go5
-rw-r--r--rpc/api/mergedapi.go22
-rw-r--r--rpc/api/web3.go7
-rw-r--r--rpc/jeth.go54
4 files changed, 62 insertions, 26 deletions
diff --git a/rpc/api/api.go b/rpc/api/api.go
index f62e48772..e431e5c1e 100644
--- a/rpc/api/api.go
+++ b/rpc/api/api.go
@@ -27,11 +27,6 @@ var (
}, ",")
)
-const (
- // List with all API's which are offered over the IPC interface by default
- DefaultIpcApis = "eth"
-)
-
// Ethereum RPC API interface
type EthereumApi interface {
// API identifier
diff --git a/rpc/api/mergedapi.go b/rpc/api/mergedapi.go
index dea8d1289..b62477a14 100644
--- a/rpc/api/mergedapi.go
+++ b/rpc/api/mergedapi.go
@@ -1,21 +1,27 @@
package api
-import "github.com/ethereum/go-ethereum/rpc/shared"
+import (
+ "github.com/ethereum/go-ethereum/rpc/shared"
+)
+
+const (
+ MergedApiVersion = "1.0"
+)
// combines multiple API's
type MergedApi struct {
- apis []string
+ apis map[string]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.apis = make(map[string]string, len(apis))
mergedApi.methods = make(map[string]EthereumApi)
- for i, api := range apis {
- mergedApi.apis[i] = api.Name()
+ for _, api := range apis {
+ mergedApi.apis[api.Name()] = api.ApiVersion()
for _, method := range api.Methods() {
mergedApi.methods[method] = api
}
@@ -47,8 +53,12 @@ func (self *MergedApi) Name() string {
return MergedApiName
}
+func (self *MergedApi) ApiVersion() string {
+ return MergedApiVersion
+}
+
func (self *MergedApi) handle(req *shared.Request) (interface{}, error) {
- if req.Method == "support_apis" { // provided API's
+ if req.Method == "modules" { // provided API's
return self.apis, nil
}
diff --git a/rpc/api/web3.go b/rpc/api/web3.go
index 42b0b7fd9..ed5008446 100644
--- a/rpc/api/web3.go
+++ b/rpc/api/web3.go
@@ -9,7 +9,7 @@ import (
)
const (
- Web3Version = "1.0.0"
+ Web3ApiVersion = "1.0"
)
var (
@@ -63,9 +63,8 @@ func (self *web3Api) Name() string {
return Web3ApiName
}
-// Version of the API this instance provides
-func (self *web3Api) Version() string {
- return Web3Version
+func (self *web3Api) ApiVersion() string {
+ return Web3ApiVersion
}
// Calculates the sha3 over req.Params.Data
diff --git a/rpc/jeth.go b/rpc/jeth.go
index e578775bb..d1b36906f 100644
--- a/rpc/jeth.go
+++ b/rpc/jeth.go
@@ -11,6 +11,10 @@ import (
"github.com/ethereum/go-ethereum/rpc/comms"
"github.com/ethereum/go-ethereum/rpc/shared"
"github.com/robertkrimen/otto"
+ "github.com/ethereum/go-ethereum/rpc/comms"
+ "github.com/ethereum/go-ethereum/rpc/codec"
+ "github.com/ethereum/go-ethereum/rpc/shared"
+ "reflect"
)
type Jeth struct {
@@ -40,6 +44,13 @@ func (self *Jeth) Send(call otto.FunctionCall) (response otto.Value) {
return self.err(call, -32700, err.Error(), nil)
}
+ client, err := comms.NewIpcClient(comms.IpcConfig{self.ipcpath}, codec.JSON)
+ if err != nil {
+ fmt.Println("Unable to connect to geth.")
+ return self.err(call, -32603, err.Error(), -1)
+ }
+ defer client.Close()
+
jsonreq, err := json.Marshal(reqif)
var reqs []RpcRequest
batch := true
@@ -54,22 +65,43 @@ func (self *Jeth) Send(call otto.FunctionCall) (response otto.Value) {
call.Otto.Run("var ret_response = new Array(response_len);")
for i, req := range reqs {
- var respif interface{}
- err = self.ethApi.GetRequestReply(&req, &respif)
+ err := client.Send(&req)
if err != nil {
- fmt.Println("Error response:", err)
+ fmt.Println("Error send request:", err)
return self.err(call, -32603, err.Error(), req.Id)
}
- call.Otto.Set("ret_jsonrpc", jsonrpcver)
- call.Otto.Set("ret_id", req.Id)
- res, _ := json.Marshal(respif)
+ respif, err := client.Recv()
+ if err != nil {
+ fmt.Println("Error recv response:", err)
+ return self.err(call, -32603, err.Error(), req.Id)
+ }
- call.Otto.Set("ret_result", string(res))
- call.Otto.Set("response_idx", i)
- response, err = call.Otto.Run(`
- ret_response[response_idx] = { jsonrpc: ret_jsonrpc, id: ret_id, result: JSON.parse(ret_result) };
- `)
+ if res, ok := respif.(shared.SuccessResponse); ok {
+ call.Otto.Set("ret_id", res.Id)
+ call.Otto.Set("ret_jsonrpc", res.Jsonrpc)
+ resObj, _ := json.Marshal(res.Result)
+ call.Otto.Set("ret_result", string(resObj))
+ call.Otto.Set("response_idx", i)
+
+ response, err = call.Otto.Run(`
+ ret_response[response_idx] = { jsonrpc: ret_jsonrpc, id: ret_id, result: JSON.parse(ret_result) };
+ `)
+ } else if res, ok := respif.(shared.ErrorResponse); ok {
+ fmt.Printf("Error: %s (%d)\n", res.Error.Message, res.Error.Code)
+
+ call.Otto.Set("ret_id", res.Id)
+ call.Otto.Set("ret_jsonrpc", res.Jsonrpc)
+ call.Otto.Set("ret_error", res.Error)
+ call.Otto.Set("response_idx", i)
+
+ response, _ = call.Otto.Run(`
+ ret_response = { jsonrpc: ret_jsonrpc, id: ret_id, error: ret_error };
+ `)
+ return
+ } else {
+ fmt.Printf("unexpected response\n", reflect.TypeOf(respif))
+ }
}
if !batch {