fixed small issues

indexer/client.go

@@ -56,7 +56,7 @@ func (client *IndexerClient) runIndexerClientLoop() {
 	for {
 		err := client.runIndexerClient()
 		if err != nil {
-			logger.WithField("client", client.clientName).Errorf("Indexer client error: %v, retrying in 10 sec...", err)
+			logger.WithField("client", client.clientName).Errorf("indexer client error: %v, retrying in 10 sec...", err)
 			time.Sleep(10 * time.Second)
 		} else {
 			return
@@ -170,6 +170,7 @@ func (client *IndexerClient) runIndexerClient() error {
 				client.isConnected = false
 				return err
 			}
+			client.lastStreamEvent = time.Now()
 		}
 
 		currentEpoch := utils.TimeToEpoch(time.Now())
@@ -248,11 +249,8 @@ func (client *IndexerClient) prefillCache(finalizedSlot uint64) error {
 	} else {
 		firstEpoch = utils.EpochOfSlot(finalizedSlot)
 	}
-	currentEpoch := utils.TimeToEpoch(time.Now())
-	if currentEpoch < 0 {
-		currentEpoch = -1
-	}
-	for epoch := firstEpoch; int64(epoch) <= currentEpoch; epoch++ {
+	currentEpoch := utils.EpochOfSlot(currentBlock.Slot)
+	for epoch := firstEpoch; epoch <= currentEpoch; epoch++ {
 		client.ensureEpochStats(epoch, currentBlock.Root)
 	}