From 7a9a52c7b9ce0cac4c9df71d31aa8e1cdd4c0952 Mon Sep 17 00:00:00 2001 From: Andrey Samokhvalov Date: Tue, 28 Mar 2017 20:27:00 +0300 Subject: [PATCH] channeldb: add ErrEdgeAlreadyExist error --- channeldb/error.go | 6 +++++- channeldb/graph.go | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/channeldb/error.go b/channeldb/error.go index 1f9434469..c97c5ba17 100644 --- a/channeldb/error.go +++ b/channeldb/error.go @@ -69,7 +69,11 @@ var ( // ErrEdgeNotFound is returned when an edge for the target chanID // can't be found. - ErrEdgeNotFound = fmt.Errorf("edge for chanID not found") + ErrEdgeNotFound = fmt.Errorf("edge not found") + + // ErrEdgeAlreadyExist is returned when edge with specific + // channel id can't be added because it already exist. + ErrEdgeAlreadyExist = fmt.Errorf("edge already exist") // ErrNodeAliasNotFound is returned when alias for node can't be found. ErrNodeAliasNotFound = fmt.Errorf("alias for node not found") diff --git a/channeldb/graph.go b/channeldb/graph.go index 34f762f02..bde130b28 100644 --- a/channeldb/graph.go +++ b/channeldb/graph.go @@ -424,7 +424,7 @@ func (c *ChannelGraph) AddChannelEdge(edge *ChannelEdgeInfo) error { // created. If so, then we can exit early as this method is // meant to be idempotent. if edgeInfo := edgeIndex.Get(chanKey[:]); edgeInfo != nil { - return nil + return ErrEdgeAlreadyExist } // If the edge hasn't been created yet, then we'll first add it