aboutsummaryrefslogtreecommitdiffstats
path: root/rpc
diff options
context:
space:
mode:
Diffstat (limited to 'rpc')
-rw-r--r--rpc/api/admin.go20
-rw-r--r--rpc/api/admin_args.go40
-rw-r--r--rpc/api/admin_js.go2
3 files changed, 44 insertions, 18 deletions
diff --git a/rpc/api/admin.go b/rpc/api/admin.go
index 0230937fa..5d214e8d8 100644
--- a/rpc/api/admin.go
+++ b/rpc/api/admin.go
@@ -43,7 +43,6 @@ var (
"admin_datadir": (*adminApi).DataDir,
"admin_startRPC": (*adminApi).StartRPC,
"admin_stopRPC": (*adminApi).StopRPC,
- "admin_sleepBlocks": (*adminApi).SleepBlocks,
"admin_setGlobalRegistrar": (*adminApi).SetGlobalRegistrar,
"admin_setHashReg": (*adminApi).SetHashReg,
"admin_setUrlHint": (*adminApi).SetUrlHint,
@@ -54,6 +53,8 @@ var (
"admin_stopNatSpec": (*adminApi).StopNatSpec,
"admin_getContractInfo": (*adminApi).GetContractInfo,
"admin_httpGet": (*adminApi).HttpGet,
+ "admin_sleepBlocks": (*adminApi).SleepBlocks,
+ "admin_sleep": (*adminApi).Sleep,
}
)
@@ -303,14 +304,15 @@ func sleepBlocks(wait chan *big.Int, height *big.Int, timer <-chan time.Time) (n
return
}
-// sec, err := call.Argument(0).ToInteger()
-// if err != nil {
-// fmt.Println(err)
-// return otto.FalseValue()
-// }
-// time.Sleep(time.Duration(sec) * time.Second)
-// return otto.UndefinedValue()
-// }
+func (self *adminApi) Sleep(req *shared.Request) (interface{}, error) {
+ args := new(SleepArgs)
+ if err := self.coder.Decode(req.Params, &args); err != nil {
+ return nil, shared.NewDecodeParamError(err.Error())
+ }
+ time.Sleep(time.Duration(args.S) * time.Second)
+ return nil, nil
+}
+
func (self *adminApi) SetGlobalRegistrar(req *shared.Request) (interface{}, error) {
args := new(SetGlobalRegistrarArgs)
if err := self.coder.Decode(req.Params, &args); err != nil {
diff --git a/rpc/api/admin_args.go b/rpc/api/admin_args.go
index a4d692c0a..e7548c7be 100644
--- a/rpc/api/admin_args.go
+++ b/rpc/api/admin_args.go
@@ -149,6 +149,30 @@ func (args *StartRPCArgs) UnmarshalJSON(b []byte) (err error) {
return nil
}
+type SleepArgs struct {
+ S int
+}
+
+func (args *SleepArgs) UnmarshalJSON(b []byte) (err error) {
+
+ var obj []interface{}
+ if err := json.Unmarshal(b, &obj); err != nil {
+ return shared.NewDecodeParamError(err.Error())
+ }
+ if len(obj) >= 1 {
+ if obj[0] != nil {
+ if n, err := numString(obj[0]); err == nil {
+ args.S = int(n.Int64())
+ } else {
+ return shared.NewInvalidTypeError("N", "not an integer: "+err.Error())
+ }
+ } else {
+ return shared.NewInsufficientParamsError(0, 1)
+ }
+ }
+ return nil
+}
+
type SleepBlocksArgs struct {
N int64
Timeout int64
@@ -163,19 +187,19 @@ func (args *SleepBlocksArgs) UnmarshalJSON(b []byte) (err error) {
args.N = 1
args.Timeout = 0
- if len(obj) >= 1 {
- if n, ok := obj[0].(int64); ok {
- args.N = n
+ if len(obj) >= 1 && obj[0] != nil {
+ if n, err := numString(obj[0]); err == nil {
+ args.N = n.Int64()
} else {
- return shared.NewInvalidTypeError("N", "not an integer")
+ return shared.NewInvalidTypeError("N", "not an integer: "+err.Error())
}
}
- if len(obj) >= 2 {
- if n, ok := obj[1].(int64); ok {
- args.Timeout = n
+ if len(obj) >= 2 && obj[1] != nil {
+ if n, err := numString(obj[1]); err == nil {
+ args.Timeout = n.Int64()
} else {
- return shared.NewInvalidTypeError("N", "not an integer")
+ return shared.NewInvalidTypeError("Timeout", "not an integer: "+err.Error())
}
}
diff --git a/rpc/api/admin_js.go b/rpc/api/admin_js.go
index 17be63575..2a9197da7 100644
--- a/rpc/api/admin_js.go
+++ b/rpc/api/admin_js.go
@@ -57,7 +57,7 @@ web3._extend({
new web3._extend.Method({
name: 'stopRPC',
call: 'admin_stopRPC',
- params: 0,
+ params: 2,
inputFormatter: [],
outputFormatter: web3._extend.formatters.formatOutputBool
}),