From 829201382b67e95ab31fca887234d1858c11c810 Mon Sep 17 00:00:00 2001 From: Gustav Simonsson Date: Wed, 26 Aug 2015 12:46:50 +0200 Subject: rpc: return error code for eth_getWork when no work ready --- rpc/shared/errors.go | 14 ++++++++++++++ rpc/shared/types.go | 3 +++ 2 files changed, 17 insertions(+) (limited to 'rpc/shared') diff --git a/rpc/shared/errors.go b/rpc/shared/errors.go index 85af1bb2f..d43858a40 100644 --- a/rpc/shared/errors.go +++ b/rpc/shared/errors.go @@ -64,6 +64,20 @@ func NewNotImplementedError(method string) *NotImplementedError { } } +type NotReadyError struct { + Method string +} + +func (e *NotReadyError) Error() string { + return fmt.Sprintf("%s method not ready", e.Method) +} + +func NewNotReadyError(method string) *NotReadyError { + return &NotReadyError{ + Method: method, + } +} + type DecodeParamError struct { err string } diff --git a/rpc/shared/types.go b/rpc/shared/types.go index 659b74bf6..f58924976 100644 --- a/rpc/shared/types.go +++ b/rpc/shared/types.go @@ -94,6 +94,9 @@ func NewRpcResponse(id interface{}, jsonrpcver string, reply interface{}, err er case *NotImplementedError: jsonerr := &ErrorObject{-32601, err.Error()} response = &ErrorResponse{Jsonrpc: jsonrpcver, Id: id, Error: jsonerr} + case *NotReadyError: + jsonerr := &ErrorObject{-32000, err.Error()} + response = &ErrorResponse{Jsonrpc: jsonrpcver, Id: id, Error: jsonerr} case *DecodeParamError, *InsufficientParamsError, *ValidationError, *InvalidTypeError: jsonerr := &ErrorObject{-32602, err.Error()} response = &ErrorResponse{Jsonrpc: jsonrpcver, Id: id, Error: jsonerr} -- cgit v1.2.3