diff --git a/network/backend/lnd/lnd.go b/network/backend/lnd/lnd.go index 672d06f..6eed66b 100644 --- a/network/backend/lnd/lnd.go +++ b/network/backend/lnd/lnd.go @@ -251,6 +251,7 @@ func (l Backend) SubscribeRoutingEvents(ctx context.Context, channelEvents chan return err } + l.logger.Debug("routing event received", logging.Object("event", event.GetSubscribedEvent())) channelEvents <- protoToRoutingEvent(event) } } diff --git a/network/models/routingevent.go b/network/models/routingevent.go index 02d74a6..0b0aee3 100644 --- a/network/models/routingevent.go +++ b/network/models/routingevent.go @@ -67,8 +67,7 @@ func (u *RoutingEvent) Update(newer *RoutingEvent) { } func (u *RoutingEvent) IsEmpty() bool { - return u.IncomingChannelId == 0 && - u.OutgoingChannelId == 0 && - u.IncomingHtlcId == 0 && - u.OutgoingHtlcId == 0 + return u.OutgoingChannelId == 0 && + u.AmountMsat == 0 && + u.FeeMsat == 0 }