Populate filter #1 (extended)

blockchain/indexers/cfindex.go

@@ -107,7 +107,8 @@ func (idx *CfIndex) Create(dbTx database.Tx) error {
 }
 
 // makeBasicFilter() builds a block's basic filter, which consists of all
-// outpoints referenced by transactions within the block.
+// outpoints and pkscript data pushes referenced by transactions within the
+// block.
 func makeBasicFilterForBlock(block *btcutil.Block) ([]byte, error) {
  b := builder.WithKeyHash(block.Hash())
  _, err := b.Key()
@@ -129,6 +130,27 @@ func makeBasicFilterForBlock(block *btcutil.Block) ([]byte, error) {
  return f.Bytes(), nil
 }
 
+// makeExtendedFilter() builds a block's extended filter, which consists of
+// all tx hashes and sigscript data pushes contained in the block.
+func makeExtendedFilterForBlock(block *btcutil.Block) ([]byte, error) {
+ b := builder.WithKeyHash(block.Hash())
+ _, err := b.Key()
+ if err != nil {
+ return nil, err
+ }
+ for _, tx := range block.Transactions() {
+ b.AddHash(tx.Hash())
+ for _, txIn := range tx.MsgTx().TxIn {
+ b.AddScript(txIn.SignatureScript)
+ }
+ }
+ f, err := b.Build()
+ if err != nil {
+ return nil, err
+ }
+ return f.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-cf mapping for
 // every passed block. This is part of the Indexer interface.