forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-23 13:16:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

eth/filters: fix the issue of wrong check on from block

Browse source 
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
jsvisa 2023-06-27 00:46:39 +08:00
parent a43785332f
commit a374b1b6ea
1 changed files with 19 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
eth/filters/api.go
View file

@ -288,28 +288,32 @@ func (api *FilterAPI) logs(ctx context.Context, notifier notifier, rpcSub *rpc.S
return errInvalidToBlock return errInvalidToBlock
} }
switch from { // do live filter only
case rpc.LatestBlockNumber: if from == rpc.LatestBlockNumber {
// do live filter only
return api.liveLogs(ctx, notifier, rpcSub, crit) return api.liveLogs(ctx, notifier, rpcSub, crit)
case rpc.SafeBlockNumber, rpc.FinalizedBlockNumber: }
if from == rpc.SafeBlockNumber || from == rpc.FinalizedBlockNumber {
header, err := api.sys.backend.HeaderByNumber(ctx, from) header, err := api.sys.backend.HeaderByNumber(ctx, from)
if err != nil { if err != nil {
return err return err
} }
go func() { from = rpc.BlockNumber(header.Number.Int64())
// do historical sync first }
_, err := api.histLogs(ctx, notifier, rpcSub, header.Number.Int64(), crit) if from < 0 {
if err != nil {
return
}
// then subscribe from the header
api.liveLogs(ctx, notifier, rpcSub, crit)
}()
return nil
default:
return errInvalidFromBlock return errInvalidFromBlock
} }
go func() {
// do historical sync first
_, err := api.histLogs(ctx, notifier, rpcSub, int64(from), crit)
if err != nil {
return
}
// then subscribe from the header
api.liveLogs(ctx, notifier, rpcSub, crit)
}()
return nil
} }
// liveLogs only retrieves live logs // liveLogs only retrieves live logs