Try a new forward filter

nyonson · Sep 5, 2023 · 8c41ea1 · 8c41ea1
1 parent 70b75f4
commit 8c41ea1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lightning/lnd.go b/lightning/lnd.go
@@ -324,6 +324,11 @@ func (l LndClient) SubscribeChannelUpdates(ctx context.Context) (<-chan Channels
 			case h := <-htlcs:
 				channels := make(Channels, 0)
 
+				// attempt to filter on forward events
+				if h.GetForwardEvent() == nil {
+					continue
+				}
+
 				if h.GetIncomingChannelId() != 0 {
 					c, err := l.GetChannel(ctx, ChannelID(h.GetIncomingChannelId()))
 					if err != nil {