From 5124978a9b51f441ed845063564b8c2b6a0aec4e Mon Sep 17 00:00:00 2001 From: Wilmer Paulino Date: Fri, 9 Aug 2019 17:52:24 -0700 Subject: [PATCH] chain: prevent filtering blocks when BitcoindClient has an empty filter --- chain/bitcoind_client.go | 23 ++++++++++++++++++++--- 1 file changed, 20 insertions(+), 3 deletions(-) diff --git a/chain/bitcoind_client.go b/chain/bitcoind_client.go index 6b0584d..0da4776 100644 --- a/chain/bitcoind_client.go +++ b/chain/bitcoind_client.go @@ -378,6 +378,12 @@ func (c *BitcoindClient) RescanBlocks( continue } + // Prevent fetching the block completely if we know we shouldn't + // filter it. + if !c.shouldFilterBlock(time.Unix(header.Time, 0)) { + continue + } + block, err := c.GetBlock(&hash) if err != nil { log.Warnf("Unable to get block %s from bitcoind: %s", @@ -1128,14 +1134,25 @@ func (c *BitcoindClient) rescan(start chainhash.Hash) error { return nil } +// shouldFilterBlock determines whether we should filter a block based on its +// timestamp or our watch list. +func (c *BitcoindClient) shouldFilterBlock(blockTimestamp time.Time) bool { + c.watchMtx.RLock() + hasEmptyFilter := len(c.watchedAddresses) == 0 && + len(c.watchedOutPoints) == 0 && len(c.watchedTxs) == 0 + c.watchMtx.RUnlock() + + return !(blockTimestamp.Before(c.birthday) || hasEmptyFilter) +} + // filterBlock filters a block for watched outpoints and addresses, and returns // any matching transactions, sending notifications along the way. func (c *BitcoindClient) filterBlock(block *wire.MsgBlock, height int32, notify bool) []*wtxmgr.TxRecord { - // If this block happened before the client's birthday, then we'll skip - // it entirely. - if block.Header.Timestamp.Before(c.birthday) { + // If this block happened before the client's birthday or we have + // nothing to filter for, then we'll skip it entirely. + if !c.shouldFilterBlock(block.Header.Timestamp) { return nil }