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

multi: use the "errors" package everywhere

Browse Source 
Replace all usages of the "github.com/go-errors/errors" and
"github.com/pkg/errors" packages with the standard lib's "errors"
package. This ensures that error wrapping and `errors.Is` checks will
work as expected.
This commit is contained in:
Elle Mouton
2025-06-30 08:46:50 +02:00
committed by Oliver Gugger
parent 72d4ae0faa
commit 9b877b94c3
44 changed files with 114 additions and 109 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
graph/builder.go
View File

@@ -1,6 +1,7 @@
package graph
import (
"errors"
"fmt"
"sync"
"sync/atomic"
@@ -8,7 +9,6 @@ import (
"github.com/btcsuite/btcd/btcec/v2"
"github.com/btcsuite/btcd/wire"
"github.com/go-errors/errors"
"github.com/lightningnetwork/lnd/batch"
"github.com/lightningnetwork/lnd/chainntnfs"
graphdb "github.com/lightningnetwork/lnd/graph/db"
@@ -874,8 +874,8 @@ func (b *Builder) assertNodeAnnFreshness(node route.Vertex,
// already have.
lastUpdate, exists, err := b.cfg.Graph.HasLightningNode(node)
if err != nil {
return errors.Errorf("unable to query for the "+
"existence of node: %v", err)
return fmt.Errorf("unable to query for the "+
"existence of node: %w", err)
}
if !exists {
return NewErrf(ErrIgnored, "Ignoring node announcement"+
@@ -998,8 +998,8 @@ func (b *Builder) addNode(node *models.LightningNode,
}
if err := b.cfg.Graph.AddLightningNode(node, op...); err != nil {
return errors.Errorf("unable to add node %x to the "+
"graph: %v", node.PubKeyBytes, err)
return fmt.Errorf("unable to add node %x to the "+
"graph: %w", node.PubKeyBytes, err)
}
log.Tracef("Updated vertex data for node=%x", node.PubKeyBytes)
@@ -1045,7 +1045,7 @@ func (b *Builder) addEdge(edge *models.ChannelEdgeInfo,
edge.ChannelID,
)
if err != nil && !errors.Is(err, graphdb.ErrGraphNoEdgesFound) {
return errors.Errorf("unable to check for edge existence: %v",
return fmt.Errorf("unable to check for edge existence: %w",
err)
}
if isZombie {
@@ -1103,8 +1103,7 @@ func (b *Builder) addEdge(edge *models.ChannelEdgeInfo,
err = b.cfg.ChainView.UpdateFilter(filterUpdate, b.bestHeight.Load())
if err != nil {
return errors.Errorf("unable to update chain "+
"view: %v", err)
return fmt.Errorf("unable to update chain view: %w", err)
}
return nil
@@ -1146,8 +1145,7 @@ func (b *Builder) updateEdge(policy *models.ChannelEdgePolicy,
edge1Timestamp, edge2Timestamp, exists, isZombie, err :=
b.cfg.Graph.HasChannelEdge(policy.ChannelID)
if err != nil && !errors.Is(err, graphdb.ErrGraphNoEdgesFound) {
return errors.Errorf("unable to check for edge existence: %v",
err)
return fmt.Errorf("unable to check for edge existence: %w", err)
}
// If the channel is marked as a zombie in our database, and
@@ -1206,7 +1204,7 @@ func (b *Builder) updateEdge(policy *models.ChannelEdgePolicy,
// Now that we know this isn't a stale update, we'll apply the new edge
// policy to the proper directional edge within the channel graph.
if err = b.cfg.Graph.UpdateEdgePolicy(policy, op...); err != nil {
err := errors.Errorf("unable to add channel: %v", err)
err := fmt.Errorf("unable to add channel: %w", err)
log.Error(err)
return err
}