如何使用 geth1.8来监听合约事件

新功能介绍

geth1.8版本带来了新的事件处理方式,使用 abigen 可以自动生成包含合约事件监听以及过滤相关代码.
这样就不用自己去写代码解析 log.
比如:

abigen --sol token.sol --pkg token --out token.go

一个例子

通过监听谁给我转账,来说明如何使用新的接口

创建 Filter

只需指定合约地址即可.

filter, err := token.NewTokenFilterer(tokenAddr, c)

监听将要发生的事件

这个应该放在过滤历史事件之前,因为有可能在处理历史事件过程中产生了新的事件.如果顺序错了,就会造成事件丢失.

ch := make(chan *token.TokenTransfer, 10)
    sub, err := filter.WatchTransfer(nil, ch, nil, []common.Address{toAddr})
    if err != nil {
        log.Fatalf("watch transfer err %s", err)
    }
    go func() {
        for {
            select {
            case <-sub.Err():
                return
            case e := <-ch:
                log.Printf("new transfer event from %s to %s value=%s,at %d",
                    e.From.String(), e.To.String(), e.Value, e.Raw.BlockNumber)
            }
        }
    }()

简单直观,不用去关心 log 的细节.
感兴趣的话,可以看一下 TokenTranser 结构

// TokenTransfer represents a Transfer event raised by the Token contract.
type TokenTransfer struct {
    From  common.Address
    To    common.Address
    Value *big.Int
    Raw   types.Log // Blockchain specific contextual infos

过滤历史事件

也很直观,把你感兴趣的事件范围传递进去,会返回一个 Iterator, 遍历就 ok 了.

    history, err := filter.FilterTransfer(&bind.FilterOpts{Start: 480000}, nil, []common.Address{toAddr})
    for history.Next() {
        e := history.Event
        log.Printf("%s transfer to %s value=%s, at %d", e.From.String(), e.To.String(), e.Value, e.Raw.BlockNumber)
    }

结论

有了这些自动生成的代码以后,我们就不用费劲去理解过滤时候的 Topic 怎么设置,Log怎么解析. 直接关注我们想要的事件本身就可以了.
当然也不是没有问题,如果我关注的不是某个合约上发生了转账事件,而是所有的ERC20token, 那么该怎么写呢?
目前我是没想到怎么实现,要想这么做还是要回到老办法上.