eth/filters: check reorgBlock in idempotent

Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
jsvisa 2023-07-25 17:18:05 +08:00
parent 7763574908
commit 6d0d8ac38a

View file

@ -380,13 +380,10 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from
} }
continue continue
} }
// TODO: if reorg occured in more than once? reorgBlock = logs[0].BlockNumber
if reorgBlock == 0 { if reorgBlock <= delivered {
reorgBlock = logs[0].BlockNumber logger.Info("Reorg detected", "reorgBlock", reorgBlock, "delivered", delivered)
if reorgBlock <= delivered { reorged = true
logger.Info("Reorg detected", "reorgBlock", reorgBlock, "delivered", delivered)
reorged = true
}
} }
if !reorged { if !reorged {
continue continue