fix: change heartbeat to use maximum received timestamp

pyth-network · Oct 16, 2023 · 4693b45 · 4693b45
1 parent 4b9d386
commit 4693b45
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/receive.go b/receive.go
@@ -166,7 +166,9 @@ func ReceiveMessages(channel chan *vaa.VAA, heartbeat *Heartbeat, networkID stri
 				// Send message on channel, increment counter, and update heartbeat
 				channel <- vaa
 				messagesMetric.Inc()
-				heartbeat.Timestamp = vaa.Timestamp.Unix()
+				if vaa.Timestamp.Unix() > heartbeat.Timestamp {
+					heartbeat.Timestamp = vaa.Timestamp.Unix()
+				}
 
 				log.Debug().Str("id", vaa.MessageID()).Msg("Received message")
 			}