graph: rename HasLightningNode

to HasNode
This commit is contained in:
Elle Mouton committed 2025-09-03 10:14:35 +02:00
1 parent 7a1b548e07
commit 330f697937
8 files changed
+16 -18

No files matched your search

+1 -1
View File
@@ -873,7 +873,7 @@ func (b *Builder) assertNodeAnnFreshness(ctx context.Context, node route.Vertex,
// node announcements, we will ignore such nodes. If we do know about // node announcements, we will ignore such nodes. If we do know about
// this node, check that this update brings info newer than what we // this node, check that this update brings info newer than what we
// already have. // already have.
lastUpdate, exists, err := b.cfg.Graph.HasLightningNode(ctx, node) lastUpdate, exists, err := b.cfg.Graph.HasNode(ctx, node)
if err != nil { if err != nil {
return fmt.Errorf("unable to query for the "+ return fmt.Errorf("unable to query for the "+
"existence of node: %w", err) "existence of node: %w", err)
+3 -3
View File
@@ -130,7 +130,7 @@ func TestNodeInsertionAndDeletion(t *testing.T) {
dbNode, err := graph.FetchNode(ctx, testPub) dbNode, err := graph.FetchNode(ctx, testPub)
require.NoError(t, err, "unable to locate node") require.NoError(t, err, "unable to locate node")
_, exists, err := graph.HasLightningNode(ctx, dbNode.PubKeyBytes) _, exists, err := graph.HasNode(ctx, dbNode.PubKeyBytes)
require.NoError(t, err) require.NoError(t, err)
require.True(t, exists) require.True(t, exists)
@@ -301,7 +301,7 @@ func TestPartialNode(t *testing.T) {
dbNode2, err := graph.FetchNode(ctx, pubKey2) dbNode2, err := graph.FetchNode(ctx, pubKey2)
require.NoError(t, err) require.NoError(t, err)
_, exists, err := graph.HasLightningNode(ctx, dbNode1.PubKeyBytes) _, exists, err := graph.HasNode(ctx, dbNode1.PubKeyBytes)
require.NoError(t, err) require.NoError(t, err)
require.True(t, exists) require.True(t, exists)
@@ -315,7 +315,7 @@ func TestPartialNode(t *testing.T) {
} }
compareNodes(t, expectedNode1, dbNode1) compareNodes(t, expectedNode1, dbNode1)
_, exists, err = graph.HasLightningNode(ctx, dbNode2.PubKeyBytes) _, exists, err = graph.HasNode(ctx, dbNode2.PubKeyBytes)
require.NoError(t, err) require.NoError(t, err)
require.True(t, exists) require.True(t, exists)
+2 -3
View File
@@ -118,13 +118,12 @@ type V1Store interface { //nolint:interfacebloat
FetchNode(ctx context.Context, nodePub route.Vertex) (*models.Node, FetchNode(ctx context.Context, nodePub route.Vertex) (*models.Node,
error) error)
// HasLightningNode determines if the graph has a vertex identified by // HasNode determines if the graph has a vertex identified by
// the target node identity public key. If the node exists in the // the target node identity public key. If the node exists in the
// database, a timestamp of when the data for the node was lasted // database, a timestamp of when the data for the node was lasted
// updated is returned along with a true boolean. Otherwise, an empty // updated is returned along with a true boolean. Otherwise, an empty
// time.Time is returned with a false boolean. // time.Time is returned with a false boolean.
HasLightningNode(ctx context.Context, nodePub [33]byte) (time.Time, HasNode(ctx context.Context, nodePub [33]byte) (time.Time, bool, error)
bool, error)
// IsPublicNode is a helper method that determines whether the node with // IsPublicNode is a helper method that determines whether the node with
// the given public key is seen as a public node in the graph from the // the given public key is seen as a public node in the graph from the
+1 -1
View File
@@ -3124,7 +3124,7 @@ func (c *KVStore) fetchLightningNode(tx kvdb.RTx,
// timestamp of when the data for the node was lasted updated is returned along // timestamp of when the data for the node was lasted updated is returned along
// with a true boolean. Otherwise, an empty time.Time is returned with a false // with a true boolean. Otherwise, an empty time.Time is returned with a false
// boolean. // boolean.
func (c *KVStore) HasLightningNode(_ context.Context, func (c *KVStore) HasNode(_ context.Context,
nodePub [33]byte) (time.Time, bool, error) { nodePub [33]byte) (time.Time, bool, error) {
var ( var (
+2 -2
View File
@@ -283,14 +283,14 @@ func (s *SQLStore) FetchNode(ctx context.Context,
return node, nil return node, nil
} }
// HasLightningNode determines if the graph has a vertex identified by the // HasNode determines if the graph has a vertex identified by the
// target node identity public key. If the node exists in the database, a // target node identity public key. If the node exists in the database, a
// timestamp of when the data for the node was lasted updated is returned along // timestamp of when the data for the node was lasted updated is returned along
// with a true boolean. Otherwise, an empty time.Time is returned with a false // with a true boolean. Otherwise, an empty time.Time is returned with a false
// boolean. // boolean.
// //
// NOTE: part of the V1Store interface. // NOTE: part of the V1Store interface.
func (s *SQLStore) HasLightningNode(ctx context.Context, func (s *SQLStore) HasNode(ctx context.Context,
pubKey [33]byte) (time.Time, bool, error) { pubKey [33]byte) (time.Time, bool, error) {
var ( var (
+2 -3
View File
@@ -234,13 +234,12 @@ type DB interface {
UpdateEdgePolicy(ctx context.Context, edge *models.ChannelEdgePolicy, UpdateEdgePolicy(ctx context.Context, edge *models.ChannelEdgePolicy,
op ...batch.SchedulerOption) error op ...batch.SchedulerOption) error
// HasLightningNode determines if the graph has a vertex identified by // HasNode determines if the graph has a vertex identified by
// the target node identity public key. If the node exists in the // the target node identity public key. If the node exists in the
// database, a timestamp of when the data for the node was lasted // database, a timestamp of when the data for the node was lasted
// updated is returned along with a true boolean. Otherwise, an empty // updated is returned along with a true boolean. Otherwise, an empty
// time.Time is returned with a false boolean. // time.Time is returned with a false boolean.
HasLightningNode(ctx context.Context, nodePub [33]byte) (time.Time, HasNode(ctx context.Context, nodePub [33]byte) (time.Time, bool, error)
bool, error)
// FetchNode attempts to look up a target node by its identity // FetchNode attempts to look up a target node by its identity
// public key. If the node isn't found in the database, then // public key. If the node isn't found in the database, then
+4 -4
View File
@@ -2718,11 +2718,11 @@ func TestAddEdgeUnknownVertexes(t *testing.T) {
copy(pub2[:], priv2.PubKey().SerializeCompressed()) copy(pub2[:], priv2.PubKey().SerializeCompressed())
// The two nodes we are about to add should not exist yet. // The two nodes we are about to add should not exist yet.
_, exists1, err := ctx.graph.HasLightningNode(ctxb, pub1) _, exists1, err := ctx.graph.HasNode(ctxb, pub1)
require.NoError(t, err, "unable to query graph") require.NoError(t, err, "unable to query graph")
require.False(t, exists1) require.False(t, exists1)
_, exists2, err := ctx.graph.HasLightningNode(ctxb, pub2) _, exists2, err := ctx.graph.HasNode(ctxb, pub2)
require.NoError(t, err, "unable to query graph") require.NoError(t, err, "unable to query graph")
require.False(t, exists2) require.False(t, exists2)
@@ -2779,11 +2779,11 @@ func TestAddEdgeUnknownVertexes(t *testing.T) {
// After adding the edge between the two previously unknown nodes, they // After adding the edge between the two previously unknown nodes, they
// should have been added to the graph. // should have been added to the graph.
_, exists1, err = ctx.graph.HasLightningNode(ctxb, pub1) _, exists1, err = ctx.graph.HasNode(ctxb, pub1)
require.NoError(t, err, "unable to query graph") require.NoError(t, err, "unable to query graph")
require.True(t, exists1) require.True(t, exists1)
_, exists2, err = ctx.graph.HasLightningNode(ctxb, pub2) _, exists2, err = ctx.graph.HasNode(ctxb, pub2)
require.NoError(t, err, "unable to query graph") require.NoError(t, err, "unable to query graph")
require.True(t, exists2) require.True(t, exists2)
+1 -1
View File
@@ -1783,7 +1783,7 @@ func (r *rpcServer) VerifyMessage(ctx context.Context,
// //
// TODO(phlip9): Require valid nodes to have capital in active channels. // TODO(phlip9): Require valid nodes to have capital in active channels.
graph := r.server.graphDB graph := r.server.graphDB
_, active, err := graph.HasLightningNode(ctx, pub) _, active, err := graph.HasNode(ctx, pub)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to query graph: %w", err) return nil, fmt.Errorf("failed to query graph: %w", err)
} }