From 907f2b21f55c85ba1bb956887d97a72ffca8c4ab Mon Sep 17 00:00:00 2001 From: pk910 Date: Wed, 23 Aug 2023 08:38:42 +0200 Subject: [PATCH] fixed small issues --- indexer/client.go | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/indexer/client.go b/indexer/client.go index d7cd6167..ed451ee1 100644 --- a/indexer/client.go +++ b/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) }