lnd: make sure forward sync stops when synced

breez · Apr 9, 2024 · a76fcc8 · a76fcc8
1 parent e7a097a
commit a76fcc8
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/lnd/forwards_sync.go b/lnd/forwards_sync.go
@@ -31,6 +31,8 @@ func NewForwardSync(
 
 var forwardChannelSyncInterval time.Duration = time.Minute * 5
 
+const maxEvents = 10_000
+
 func (s *ForwardSync) ForwardsSynchronize(ctx context.Context) {
 	s.forwardsSynchronizeOnce(ctx)
 
@@ -60,7 +62,7 @@ func (s *ForwardSync) forwardsSynchronizeOnce(ctx context.Context) {
 	for {
 		forwardHistory, err := s.client.client.ForwardingHistory(context.Background(), &lnrpc.ForwardingHistoryRequest{
 			StartTime:    startTime / 1_000_000_000,
-			NumMaxEvents: 10000,
+			NumMaxEvents: maxEvents,
 		})
 		if err != nil {
 			log.Printf("forwardsSynchronizeOnce(%x) - ForwardingHistory error: %v", s.nodeid, err)
@@ -89,5 +91,9 @@ func (s *ForwardSync) forwardsSynchronizeOnce(ctx context.Context) {
 			log.Printf("forwardsSynchronizeOnce(%x) - store.InsertForwards() error: %v", s.nodeid, err)
 			return
 		}
+
+		if len(forwardHistory.ForwardingEvents) < maxEvents {
+			break
+		}
 	}
 }