Fix for batches in heartbeats tool

wormhole-foundation · Aug 26, 2024 · cc55e94 · cc55e94
1 parent 445fe3e
commit cc55e94
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/fly/cmd/heartbeats/main.go b/fly/cmd/heartbeats/main.go
@@ -374,11 +374,13 @@ func main() {
 				}
 				gossipLock.Unlock()
 			case batch := <-batchObsvC:
+				addr := "0x" + string(hex.EncodeToString(batch.Msg.Addr))
+				idx := guardianIndexMap[strings.ToLower(addr)]
+				gossipCounter[idx][GSM_signedObservationBatch]++
+				gossipCounter[totalsRow][GSM_signedObservationBatch]++
 				for _, o := range batch.Msg.Observations {
 					spl := strings.Split(o.MessageId, "/")
 					emitter := strings.ToLower(spl[1])
-					addr := "0x" + string(hex.EncodeToString(batch.Msg.Addr))
-					idx := guardianIndexMap[strings.ToLower(addr)]
 					if knownEmitters[emitter] {
 						gossipCounter[idx][GSM_tbObservation]++
 						gossipCounter[totalsRow][GSM_tbObservation]++