diff options
| author | obscuren <geffobscura@gmail.com> | 2015-05-06 23:51:32 +0800 |
|---|---|---|
| committer | obscuren <geffobscura@gmail.com> | 2015-05-07 20:44:32 +0800 |
| commit | 7e160a677d1590f97708a0d297f978a99977d398 (patch) | |
| tree | 9cd71bfad14c06c381e3518f6fb11464225271ab /rpc/api.go | |
| parent | 97c37356fdcfac8b704c3d75b33e322a737c4e55 (diff) | |
| download | go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.tar go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.tar.gz go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.tar.bz2 go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.tar.lz go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.tar.xz go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.tar.zst go-tangerine-7e160a677d1590f97708a0d297f978a99977d398.zip | |
xeth, core, event/filter, rpc: new block and transaction filters
Diffstat (limited to 'rpc/api.go')
| -rw-r--r-- | rpc/api.go | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/rpc/api.go b/rpc/api.go index b79a1306e..a3312075b 100644 --- a/rpc/api.go +++ b/rpc/api.go @@ -322,14 +322,13 @@ func (api *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) err return err } - id := api.xeth().RegisterFilter(args.Earliest, args.Latest, args.Skip, args.Max, args.Address, args.Topics) + id := api.xeth().NewLogFilter(args.Earliest, args.Latest, args.Skip, args.Max, args.Address, args.Topics) *reply = newHexNum(big.NewInt(int64(id)).Bytes()) + case "eth_newBlockFilter": - args := new(FilterStringArgs) - if err := json.Unmarshal(req.Params, &args); err != nil { - return err - } - *reply = newHexNum(api.xeth().NewFilterString(args.Word)) + *reply = newHexNum(api.xeth().NewBlockFilter()) + case "eth_transactionFilter": + *reply = newHexNum(api.xeth().NewTransactionFilter()) case "eth_uninstallFilter": args := new(FilterIdArgs) if err := json.Unmarshal(req.Params, &args); err != nil { @@ -341,7 +340,17 @@ func (api *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) err if err := json.Unmarshal(req.Params, &args); err != nil { return err } - *reply = NewLogsRes(api.xeth().FilterChanged(args.Id)) + + switch api.xeth().GetFilterType(args.Id) { + case xeth.BlockFilterTy: + *reply = NewHashesRes(api.xeth().BlockFilterChanged(args.Id)) + case xeth.TransactionFilterTy: + *reply = NewHashesRes(api.xeth().TransactionFilterChanged(args.Id)) + case xeth.LogFilterTy: + *reply = NewLogsRes(api.xeth().LogFilterChanged(args.Id)) + default: + *reply = []string{} // reply empty string slice + } case "eth_getFilterLogs": args := new(FilterIdArgs) if err := json.Unmarshal(req.Params, &args); err != nil { |