From cc55e94d2ce0b6820bfa55448e7b1a814215279d Mon Sep 17 00:00:00 2001 From: Bruce Riley Date: Mon, 26 Aug 2024 12:30:13 -0500 Subject: [PATCH] Fix for batches in heartbeats tool --- fly/cmd/heartbeats/main.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/fly/cmd/heartbeats/main.go b/fly/cmd/heartbeats/main.go index 8a42e675..90b1c20a 100644 --- 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]++