• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

lightningnetwork / lnd / 13211764208

08 Feb 2025 03:08AM UTC coverage: 49.288% (-9.5%) from 58.815%
13211764208

Pull #9489

github

calvinrzachman
itest: verify switchrpc server enforces send then track

We prevent the rpc server from allowing onion dispatches for
attempt IDs which have already been tracked by rpc clients.

This helps protect the client from leaking a duplicate onion
attempt. NOTE: This is not the only method for solving this
issue! The issue could be addressed via careful client side
programming which accounts for the uncertainty and async
nature of dispatching onions to a remote process via RPC.
This would require some lnd ChannelRouter changes for how
we intend to use these RPCs though.
Pull Request #9489: multi: add BuildOnion, SendOnion, and TrackOnion RPCs

474 of 990 new or added lines in 11 files covered. (47.88%)

27321 existing lines in 435 files now uncovered.

101192 of 205306 relevant lines covered (49.29%)

1.54 hits per line

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

68.42
/lnwire/channel_id.go
1
package lnwire
2

3
import (
4
        "encoding/binary"
5
        "encoding/hex"
6
        "math"
7

8
        "github.com/btcsuite/btcd/chaincfg/chainhash"
9
        "github.com/btcsuite/btcd/wire"
10
)
11

12
const (
13
        // MaxFundingTxOutputs is the maximum number of allowed outputs on a
14
        // funding transaction within the protocol. This is due to the fact
15
        // that we use 2-bytes to encode the index within the funding output
16
        // during the funding workflow. Funding transaction with more outputs
17
        // than this are considered invalid within the protocol.
18
        MaxFundingTxOutputs = math.MaxUint16
19
)
20

21
// ChannelID is a series of 32-bytes that uniquely identifies all channels
22
// within the network. The ChannelID is computed using the outpoint of the
23
// funding transaction (the txid, and output index). Given a funding output the
24
// ChannelID can be calculated by XOR'ing the big-endian serialization of the
25
// txid and the big-endian serialization of the output index, truncated to
26
// 2 bytes.
27
type ChannelID [32]byte
28

29
// ConnectionWideID is an all-zero ChannelID, which is used to represent a
30
// message intended for all channels to specific peer.
31
var ConnectionWideID = ChannelID{}
32

33
// String returns the string representation of the ChannelID. This is just the
34
// hex string encoding of the ChannelID itself.
35
func (c ChannelID) String() string {
3✔
36
        return hex.EncodeToString(c[:])
3✔
37
}
3✔
38

39
// NewChanIDFromOutPoint converts a target OutPoint into a ChannelID that is
40
// usable within the network. In order to convert the OutPoint into a ChannelID,
41
// we XOR the lower 2-bytes of the txid within the OutPoint with the big-endian
42
// serialization of the Index of the OutPoint, truncated to 2-bytes.
43
func NewChanIDFromOutPoint(op wire.OutPoint) ChannelID {
3✔
44
        // First we'll copy the txid of the outpoint into our channel ID slice.
3✔
45
        var cid ChannelID
3✔
46
        copy(cid[:], op.Hash[:])
3✔
47

3✔
48
        // With the txid copied over, we'll now XOR the lower 2-bytes of the
3✔
49
        // partial channelID with big-endian serialization of output index.
3✔
50
        xorTxid(&cid, uint16(op.Index))
3✔
51

3✔
52
        return cid
3✔
53
}
3✔
54

55
// xorTxid performs the transformation needed to transform an OutPoint into a
56
// ChannelID. To do this, we expect the cid parameter to contain the txid
57
// unaltered and the outputIndex to be the output index
58
func xorTxid(cid *ChannelID, outputIndex uint16) {
3✔
59
        var buf [2]byte
3✔
60
        binary.BigEndian.PutUint16(buf[:], outputIndex)
3✔
61

3✔
62
        cid[30] ^= buf[0]
3✔
63
        cid[31] ^= buf[1]
3✔
64
}
3✔
65

66
// GenPossibleOutPoints generates all the possible outputs given a channel ID.
67
// In order to generate these possible outpoints, we perform a brute-force
68
// search through the candidate output index space, performing a reverse
69
// mapping from channelID back to OutPoint.
UNCOV
70
func (c *ChannelID) GenPossibleOutPoints() [MaxFundingTxOutputs]wire.OutPoint {
×
UNCOV
71
        var possiblePoints [MaxFundingTxOutputs]wire.OutPoint
×
UNCOV
72
        for i := uint16(0); i < MaxFundingTxOutputs; i++ {
×
UNCOV
73
                cidCopy := *c
×
UNCOV
74
                xorTxid(&cidCopy, i)
×
UNCOV
75

×
UNCOV
76
                possiblePoints[i] = wire.OutPoint{
×
UNCOV
77
                        Hash:  chainhash.Hash(cidCopy),
×
UNCOV
78
                        Index: uint32(i),
×
UNCOV
79
                }
×
UNCOV
80
        }
×
81

UNCOV
82
        return possiblePoints
×
83
}
84

85
// IsChanPoint returns true if the OutPoint passed corresponds to the target
86
// ChannelID.
87
func (c ChannelID) IsChanPoint(op *wire.OutPoint) bool {
3✔
88
        candidateCid := NewChanIDFromOutPoint(*op)
3✔
89

3✔
90
        return candidateCid == c
3✔
91
}
3✔
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc