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

Define FilterHeaderByBlockHash()

Browse source
This commit is contained in:
pedro martelletto 2017-02-01 13:43:09 +00:00 committed by Olaoluwa Osuntokun
parent e620538343
commit a5bf8941d5
1 changed files with 22 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
blockchain/indexers/cfindex.go
View file

@ -244,18 +244,36 @@ func (idx *CfIndex) DisconnectBlock(dbTx database.Tx, block *btcutil.Block,
return dbDeleteFilter(dbTx, cfExtendedIndexKey, block.Hash()) return dbDeleteFilter(dbTx, cfExtendedIndexKey, block.Hash())
} }
func (idx *CfIndex) FilterByBlockHash(hash *chainhash.Hash, extended bool) ([]byte, error) { // FilterByBlockHash() returns the serialized contents of a block's basic or
var filterBytes []byte // extended committed filter.
func (idx *CfIndex) FilterByBlockHash(h *chainhash.Hash, extended bool) ([]byte, error) {
var f []byte
err := idx.db.View(func(dbTx database.Tx) error { err := idx.db.View(func(dbTx database.Tx) error {
var err error var err error
key := cfBasicIndexKey key := cfBasicIndexKey
if extended { if extended {
key = cfExtendedIndexKey key = cfExtendedIndexKey
} }
filterBytes, err = dbFetchFilter(dbTx, key, hash) f, err = dbFetchFilter(dbTx, key, h)
return err return err
}) })
return filterBytes, err return f, err
}
// FilterHeaderByBlockHash() returns the serialized contents of a block's basic
// or extended committed filter header.
func (idx *CfIndex) FilterHeaderByBlockHash(h *chainhash.Hash, extended bool) ([]byte, error) {
var fh []byte
err := idx.db.View(func(dbTx database.Tx) error {
var err error
key := cfBasicHeaderKey
if extended {
key = cfExtendedHeaderKey
}
fh, err = dbFetchFilterHeader(dbTx, key, h)
return err
})
return fh, err
} }
// NewCfIndex returns a new instance of an indexer that is used to create a // NewCfIndex returns a new instance of an indexer that is used to create a