diff --git a/rpc/api.go b/rpc/api.go index d0181463d9..9d00ae3403 100644 --- a/rpc/api.go +++ b/rpc/api.go @@ -571,7 +571,8 @@ func (p *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) error return p.Call(args, reply) case "eth_flush": return errNotImplemented - case "eth_getBlockByNumber", "eth_getBlockByHash": + case "eth_getBlockByNumber": + case "eth_getBlockByHash": // TODO handle second param for "include transaction objects" args, err := req.ToGetBlockArgs() if err != nil { @@ -601,12 +602,12 @@ func (p *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) error return err } return p.NewFilter(args, reply) - // case "eth_newFilterString": - // args, err := req.ToFilterStringArgs() - // if err != nil { - // return err - // } - // return p.NewFilterString(args, reply) + case "eth_newBlockFilter": + args, err := req.ToFilterStringArgs() + if err != nil { + return err + } + return p.NewFilterString(args, reply) case "eth_newBlockFilter": return errNotImplemented case "eth_uninstallFilter": @@ -691,7 +692,7 @@ func (p *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) error return p.NewWhisperFilter(args, reply) case "shh_uninstallFilter": return errNotImplemented - case "shh_changed": + case "shh_getFilterChanges": args, err := req.ToIdArgs() if err != nil { return err