highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-09-07 11:22:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

graph/db: add channelIDToBytes helper

Browse Source
This commit is contained in:
Elle Mouton
2025-06-24 18:58:52 +02:00
parent c648c7a22d
commit 137fc09230
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
graph/db/sql_store.go
View File

@@ -1288,13 +1288,10 @@ func (s *SQLStore) FilterChannelRange(startHeight, endHeight uint32,
TxIndex: math.MaxUint32 & 0x00ffffff, TxIndex: math.MaxUint32 & 0x00ffffff,
TxPosition: math.MaxUint16, TxPosition: math.MaxUint16,
} }
chanIDStart = channelIDToBytes(startSCID.ToUint64())
chanIDEnd = channelIDToBytes(endSCID.ToUint64())
) )
var chanIDStart [8]byte
byteOrder.PutUint64(chanIDStart[:], startSCID.ToUint64())
var chanIDEnd [8]byte
byteOrder.PutUint64(chanIDEnd[:], endSCID.ToUint64())
// 1) get all channels where channelID is between start and end chan ID. // 1) get all channels where channelID is between start and end chan ID.
// 2) skip if not public (ie, no channel_proof) // 2) skip if not public (ie, no channel_proof)
// 3) collect that channel. // 3) collect that channel.
@@ -1638,9 +1635,8 @@ func updateChanEdgePolicy(ctx context.Context, tx SQLQueries,
var ( var (
node1Pub, node2Pub route.Vertex node1Pub, node2Pub route.Vertex
isNode1 bool isNode1 bool
chanIDB [8]byte chanIDB = channelIDToBytes(edge.ChannelID)
) )
byteOrder.PutUint64(chanIDB[:], edge.ChannelID)
// Check that this edge policy refers to a channel that we already // Check that this edge policy refers to a channel that we already
// know of. We do this explicitly so that we can return the appropriate // know of. We do this explicitly so that we can return the appropriate
@@ -2334,8 +2330,7 @@ func marshalExtraOpaqueData(data []byte) (map[uint64][]byte, error) {
func insertChannel(ctx context.Context, db SQLQueries, func insertChannel(ctx context.Context, db SQLQueries,
edge *models.ChannelEdgeInfo) error { edge *models.ChannelEdgeInfo) error {
var chanIDB [8]byte chanIDB := channelIDToBytes(edge.ChannelID)
byteOrder.PutUint64(chanIDB[:], edge.ChannelID)
// Make sure that the channel doesn't already exist. We do this // Make sure that the channel doesn't already exist. We do this
// explicitly instead of relying on catching a unique constraint error // explicitly instead of relying on catching a unique constraint error
@@ -2920,3 +2915,12 @@ func extractChannelPolicies(row any) (*sqlc.ChannelPolicy, *sqlc.ChannelPolicy,
"extractChannelPolicies: %T", r) "extractChannelPolicies: %T", r)
} }
} }
// channelIDToBytes converts a channel ID (SCID) to a byte array
// representation.
func channelIDToBytes(channelID uint64) [8]byte {
var chanIDB [8]byte
byteOrder.PutUint64(chanIDB[:], channelID)
return chanIDB
}