13035292482

Committed 29 Jan 2025 03:59PM UTC coverage: 49.3% (-9.5%) from 58.777%

Build # 13035292482

Build Type

Pull #9456

github

Committed by

mohamedawnallah

Commit Message

docs: update release-notes-0.19.0.md

In this commit, we warn users about the removal
of RPCs `SendToRoute`, `SendToRouteSync`, `SendPayment`,
and `SendPaymentSync` in the next release 0.20.

Pull Request Pull Request #9456: lnrpc+docs: deprecate warning `SendToRoute`, `SendToRouteSync`, `SendPayment`, and `SendPaymentSync` in Release 0.19

Run Details

100634 of 204126 relevant lines covered (49.3%)

1.54 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.
22	func MigrateChanID(tx kvdb.RwTx) error {	×
23	log.Info("Populating ChannelID index")	×
24		×
25	// First we'll retrieve the set of outpoints we know about.	×
26	ops, err := fetchOutPoints(tx)	×
27	if err != nil {	×
28	return err	×
29	}	×
30
31	return populateChanIDIndex(tx, ops)	×
32	}
33
34	// fetchOutPoints loops through the outpointBucket and returns each stored
35	// outpoint.
36	func fetchOutPoints(tx kvdb.RwTx) ([]*wire.OutPoint, error) {	×
37	var ops []*wire.OutPoint	×
38		×
39	bucket := tx.ReadBucket(outpointBucket)	×
40		×
41	err := bucket.ForEach(func(k, _ []byte) error {	×
42	var op wire.OutPoint	×
43	r := bytes.NewReader(k)	×
44	if err := readOutpoint(r, &op); err != nil {	×
45	return err	×
46	}	×
47
48	ops = append(ops, &op)	×
49	return nil	×
50	})
51	if err != nil {	×
52	return nil, err	×
53	}	×
54
55	return ops, nil	×
56	}
57
58	// populateChanIDIndex uses the set of retrieved outpoints and populates the
59	// ChannelID index.
60	func populateChanIDIndex(tx kvdb.RwTx, ops []*wire.OutPoint) error {	×
61	bucket := tx.ReadWriteBucket(chanIDBucket)	×
62		×
63	for _, op := range ops {	×
64	chanID := NewChanIDFromOutPoint(op)	×
65		×
66	if err := bucket.Put(chanID[:], []byte{}); err != nil {	×
67	return err	×
68	}	×
69	}
70
71	return nil	×
72	}

lightningnetwork / lnd / 13035292482

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