LBRYCommunity/lbcd
1
0
Fork 0
Code Issues 17 Pull requests 4 Projects Releases 28 Packages Wiki Activity

Abstract filter generation to a separate function

Browse source
This commit is contained in:
pedro martelletto 2017-01-12 10:55:31 +00:00 • committed by Olaoluwa Osuntokun
parent 05d2fdeb11
commit cf74c8c3ca
1 changed files with 18 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
blockchain/indexers/cbfindex.go
View file

@ -78,19 +78,14 @@ func (idx *CBFIndex) Create(dbTx database.Tx) error {
return err return err
} }
// ConnectBlock is invoked by the index manager when a new block has been func generateFilterForBlock(block *btcutil.Block) ([]byte, error) {
// connected to the main chain. This indexer adds a hash-to-CBF mapping for
// every passed block.
//
// This is part of the Indexer interface.
func (idx *CBFIndex) ConnectBlock(dbTx database.Tx, block *btcutil.Block, view *blockchain.UtxoViewpoint) error {
txSlice := block.Transactions() // XXX can this fail? txSlice := block.Transactions() // XXX can this fail?
txHashes := make([][]byte, len(txSlice)) txHashes := make([][]byte, len(txSlice))
for i := 0; i < len(txSlice); i++ { for i := 0; i < len(txSlice); i++ {
txHash, err := block.TxHash(i) txHash, err := block.TxHash(i)
if err != nil { if err != nil {
return err return nil, err
} }
txHashes = append(txHashes, txHash.CloneBytes()) txHashes = append(txHashes, txHash.CloneBytes())
} }
@ -103,13 +98,28 @@ func (idx *CBFIndex) ConnectBlock(dbTx database.Tx, block *btcutil.Block, view *
} }
filter, err := gcs.BuildGCSFilter(P, key, txHashes) filter, err := gcs.BuildGCSFilter(P, key, txHashes)
if err != nil {
return nil, err
}
return filter.Bytes(), nil
}
// ConnectBlock is invoked by the index manager when a new block has been
// connected to the main chain. This indexer adds a hash-to-CBF mapping for
// every passed block.
//
// This is part of the Indexer interface.
func (idx *CBFIndex) ConnectBlock(dbTx database.Tx, block *btcutil.Block,
view *blockchain.UtxoViewpoint) error {
filterBytes, err := generateFilterForBlock(block)
if err != nil { if err != nil {
return err return err
} }
meta := dbTx.Metadata() meta := dbTx.Metadata()
index := meta.Bucket(cbfIndexKey) index := meta.Bucket(cbfIndexKey)
err = index.Put(block.Hash().CloneBytes(), filter.Bytes()) err = index.Put(block.Hash().CloneBytes(), filterBytes)
if err != nil { if err != nil {
return err return err
} }