From 770f0a48ef00845651b6ec440a437add09c8da78 Mon Sep 17 00:00:00 2001
From: Henrik Hautakoski <henrik@eossweden.org>
Date: Tue, 29 Nov 2022 15:04:50 +0100
Subject: [PATCH] ship_processor.go: Send hearthbeat every 10'th block.

---
 ship_processor.go | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/ship_processor.go b/ship_processor.go
index 78331d3..0205ae1 100644
--- a/ship_processor.go
+++ b/ship_processor.go
@@ -44,6 +44,21 @@ func processBlock(block *ship.GetBlocksResultV0) {
 	if block.ThisBlock.BlockNum%100 == 0 {
 		log.Infof("Current: %d, Head: %d\n", block.ThisBlock.BlockNum, block.Head.BlockNum)
 	}
+
+	if block.ThisBlock.BlockNum%10 == 0 {
+		hb := HearthBeat{
+			BlockNum:                 block.ThisBlock.BlockNum,
+			LastIrreversibleBlockNum: block.LastIrreversible.BlockNum,
+			HeadBlockNum:             block.Head.BlockNum,
+		}
+
+		encodeQueue("hearthbeat", hb)
+
+		_, err := redis.Send()
+		if err != nil {
+			log.WithError(err).Error("Failed to send redis")
+		}
+	}
 }
 
 func processTraces(traces []*ship.TransactionTraceV0) {