diff options
| author | Péter Szilágyi <peterke@gmail.com> | 2018-01-05 18:39:24 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2018-01-24 16:54:13 +0800 |
| commit | 1bf508b449ebd42653f521ada92c782e8cb664d2 (patch) | |
| tree | 1895aeb44d68b189a40a4023ca4869b1f3d1b955 /eth/filters/api.go | |
| parent | 02aeb3d76652a4c0451e5c3734e6881aefe46249 (diff) | |
| download | go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.tar go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.tar.gz go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.tar.bz2 go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.tar.lz go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.tar.xz go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.tar.zst go-tangerine-1bf508b449ebd42653f521ada92c782e8cb664d2.zip | |
accounts/abi/bind: support event filtering in abigen
Diffstat (limited to 'eth/filters/api.go')
| -rw-r--r-- | eth/filters/api.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/eth/filters/api.go b/eth/filters/api.go index 03c1d6afc..406c9442e 100644 --- a/eth/filters/api.go +++ b/eth/filters/api.go @@ -25,6 +25,7 @@ import ( "sync" "time" + ethereum "github.com/ethereum/go-ethereum" "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common/hexutil" "github.com/ethereum/go-ethereum/core/types" @@ -240,7 +241,7 @@ func (api *PublicFilterAPI) Logs(ctx context.Context, crit FilterCriteria) (*rpc matchedLogs = make(chan []*types.Log) ) - logsSub, err := api.events.SubscribeLogs(crit, matchedLogs) + logsSub, err := api.events.SubscribeLogs(ethereum.FilterQuery(crit), matchedLogs) if err != nil { return nil, err } @@ -267,6 +268,8 @@ func (api *PublicFilterAPI) Logs(ctx context.Context, crit FilterCriteria) (*rpc } // FilterCriteria represents a request to create a new filter. +// +// TODO(karalabe): Kill this in favor of ethereum.FilterQuery. type FilterCriteria struct { FromBlock *big.Int ToBlock *big.Int @@ -289,7 +292,7 @@ type FilterCriteria struct { // https://github.com/ethereum/wiki/wiki/JSON-RPC#eth_newfilter func (api *PublicFilterAPI) NewFilter(crit FilterCriteria) (rpc.ID, error) { logs := make(chan []*types.Log) - logsSub, err := api.events.SubscribeLogs(crit, logs) + logsSub, err := api.events.SubscribeLogs(ethereum.FilterQuery(crit), logs) if err != nil { return rpc.ID(""), err } |