tmp

network/backend/lnd/lnd.go

@@ -251,7 +251,12 @@ func (l Backend) SubscribeRoutingEvents(ctx context.Context, channelEvents chan
 				return err
 			}
 
-			channelEvents <- protoToRoutingEvent(event)
+			routingEvent := protoToRoutingEvent(event)
+			if !routingEvent.IsEmpty() {
+				channelEvents <- routingEvent
+			} else {
+				l.logger.Debug("receive htlcUpdate", logging.Object("routing_event", routingEvent))
+			}
 		}
 	}
 }

network/models/routingevent.go

@@ -1,6 +1,7 @@
 package models
 
 import (
+	"go.uber.org/zap/zapcore"
 	"time"
 )
 
@@ -33,6 +34,24 @@ type RoutingEvent struct {
 	FailureDetail     string
 }
 
+func (u *RoutingEvent) MarshalLogObject(enc zapcore.ObjectEncoder) error {
+	enc.AddUint64("incoming_channel_id", u.IncomingChannelId)
+	enc.AddUint64("outgoing_channel_id", u.OutgoingChannelId)
+	enc.AddUint64("incoming_htlc_id", u.IncomingHtlcId)
+	enc.AddUint64("outgoing_htlc_id", u.OutgoingHtlcId)
+	enc.AddTime("last_update", u.LastUpdate)
+	enc.AddInt("direction", u.Direction)
+	enc.AddInt("status", u.Status)
+	enc.AddUint32("incoming_timelock", u.IncomingTimelock)
+	enc.AddUint32("outgoing_timelock", u.OutgoingTimelock)
+	enc.AddUint64("amount_msat", u.AmountMsat)
+	enc.AddUint64("fee_msat", u.FeeMsat)
+	enc.AddInt32("failure_code", u.FailureCode)
+	enc.AddString("failure_detail", u.FailureDetail)
+
+	return nil
+}
+
 func (u *RoutingEvent) Equals(other *RoutingEvent) bool {
 	return u.IncomingChannelId == other.IncomingChannelId && u.IncomingHtlcId == other.IncomingHtlcId && u.OutgoingChannelId == other.OutgoingChannelId && u.OutgoingHtlcId == other.OutgoingHtlcId
 }
@@ -43,3 +62,7 @@ func (u *RoutingEvent) Update(newer *RoutingEvent) {
 	u.FailureCode = newer.FailureCode
 	u.FailureDetail = newer.FailureDetail
 }
+
+func (u *RoutingEvent) IsEmpty() bool {
+	return u.Equals(&RoutingEvent{})
+}

pubsub/pubsub.go

@@ -96,7 +96,12 @@ func (p *PubSub) routingUpdates(ctx context.Context, sub chan *events.Event) {
 	go func() {
 		for hu := range routingUpdates {
 			p.logger.Debug("receive htlcUpdate")
-			sub <- events.NewWithData(events.RoutingEventUpdated, hu)
+			if !hu.IsEmpty() {
+				p.logger.Debug("EMPTY BANG BANG")
+				sub <- events.NewWithData(events.RoutingEventUpdated, hu)
+			} else {
+				p.logger.Debug("NOT EMPTY BANG BANG")
+			}
 		}
 		p.wg.Done()
 	}()