15561477203

Committed 10 Jun 2025 01:54PM UTC coverage: 58.351% (-10.1%) from 68.487%

Build # 15561477203

Build Type

Pull #9356

github

Committed by

web-flow

Commit Message

Merge 6440b25db into c6d6d4c0b

Pull Request Pull Request #9356: lnrpc: add incoming/outgoing channel ids filter to forwarding history request

Run Details

33 of 36 new or added lines in 2 files covered. (91.67%)

28366 existing lines in 455 files now uncovered.

97715 of 167461 relevant lines covered (58.35%)

1.81 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/channeldb/migration29/migration.go

package migration29

import (
        "bytes"

        "github.com/btcsuite/btcd/wire"
        "github.com/lightningnetwork/lnd/kvdb"
)

var (
        // outpointBucket is the bucket that stores the set of outpoints we
        // know about.
        outpointBucket = []byte("outpoint-bucket")

        // chanIDBucket is the bucket that stores the set of ChannelID's we
        // know about.
        chanIDBucket = []byte("chan-id-bucket")
)

// MigrateChanID populates the ChannelID index by using the set of outpoints
// retrieved from the outpoint bucket.
func MigrateChanID(tx kvdb.RwTx) error {
        log.Info("Populating ChannelID index")

        // First we'll retrieve the set of outpoints we know about.
        ops, err := fetchOutPoints(tx)
        if err != nil {
                return err
        }

        return populateChanIDIndex(tx, ops)
}

// fetchOutPoints loops through the outpointBucket and returns each stored
// outpoint.
func fetchOutPoints(tx kvdb.RwTx) ([]*wire.OutPoint, error) {
        var ops []*wire.OutPoint

        bucket := tx.ReadBucket(outpointBucket)

        err := bucket.ForEach(func(k, _ []byte) error {
                var op wire.OutPoint
                r := bytes.NewReader(k)
                if err := readOutpoint(r, &op); err != nil {
                        return err
                }

                ops = append(ops, &op)
                return nil
        })
        if err != nil {
                return nil, err
        }

        return ops, nil
}

// populateChanIDIndex uses the set of retrieved outpoints and populates the
// ChannelID index.
func populateChanIDIndex(tx kvdb.RwTx, ops []*wire.OutPoint) error {
        bucket := tx.ReadWriteBucket(chanIDBucket)

        for _, op := range ops {
                chanID := NewChanIDFromOutPoint(op)

                if err := bucket.Put(chanID[:], []byte{}); err != nil {
                        return err
                }
        }

        return nil
}

1	package migration29
2
3	import (
4	"bytes"
5
6	"github.com/btcsuite/btcd/wire"
7	"github.com/lightningnetwork/lnd/kvdb"
8	)
9
10	var (
11	// outpointBucket is the bucket that stores the set of outpoints we
12	// know about.
13	outpointBucket = []byte("outpoint-bucket")
14
15	// chanIDBucket is the bucket that stores the set of ChannelID's we
16	// know about.
17	chanIDBucket = []byte("chan-id-bucket")
18	)
19
20	// MigrateChanID populates the ChannelID index by using the set of outpoints
21	// retrieved from the outpoint bucket.
UNCOV 22	func MigrateChanID(tx kvdb.RwTx) error {	×
UNCOV 23	log.Info("Populating ChannelID index")	×
UNCOV 24		×
UNCOV 25	// First we'll retrieve the set of outpoints we know about.	×
UNCOV 26	ops, err := fetchOutPoints(tx)	×
UNCOV 27	if err != nil {	×
28	return err	×
29	}	×
30
UNCOV 31	return populateChanIDIndex(tx, ops)	×
32	}
33
34	// fetchOutPoints loops through the outpointBucket and returns each stored
35	// outpoint.
UNCOV 36	func fetchOutPoints(tx kvdb.RwTx) ([]*wire.OutPoint, error) {	×
UNCOV 37	var ops []*wire.OutPoint	×
UNCOV 38		×
UNCOV 39	bucket := tx.ReadBucket(outpointBucket)	×
UNCOV 40		×
UNCOV 41	err := bucket.ForEach(func(k, _ []byte) error {	×
UNCOV 42	var op wire.OutPoint	×
UNCOV 43	r := bytes.NewReader(k)	×
UNCOV 44	if err := readOutpoint(r, &op); err != nil {	×
45	return err	×
46	}	×
47
UNCOV 48	ops = append(ops, &op)	×
UNCOV 49	return nil	×
50	})
UNCOV 51	if err != nil {	×
52	return nil, err	×
53	}	×
54
UNCOV 55	return ops, nil	×
56	}
57
58	// populateChanIDIndex uses the set of retrieved outpoints and populates the
59	// ChannelID index.
UNCOV 60	func populateChanIDIndex(tx kvdb.RwTx, ops []*wire.OutPoint) error {	×
UNCOV 61	bucket := tx.ReadWriteBucket(chanIDBucket)	×
UNCOV 62		×
UNCOV 63	for _, op := range ops {	×
UNCOV 64	chanID := NewChanIDFromOutPoint(op)	×
UNCOV 65		×
UNCOV 66	if err := bucket.Put(chanID[:], []byte{}); err != nil {	×
67	return err	×
68	}	×
69	}
70
UNCOV 71	return nil	×
72	}

lightningnetwork / lnd / 15561477203

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous