cache genesis rpc response (front page does not need any rpc calls now)

ethpandaops · Sep 8, 2023 · 52bfd04 · 52bfd04
1 parent 603fe4f
commit 52bfd04
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 1 deletion.
diff --git a/indexer/cache.go b/indexer/cache.go
@@ -28,6 +28,7 @@ type indexerCache struct {
 	epochStatsMap           map[uint64][]*EpochStats
 	lastValidatorsEpoch     int64
 	lastValidatorsResp      *rpctypes.StandardV1StateValidatorsResponse
+	genesisResp             *rpctypes.StandardV1GenesisResponse
 	validatorLoadingLimiter chan int
 }
 
@@ -79,6 +80,14 @@ func (cache *indexerCache) setFinalizedHead(epoch int64, root []byte) {
 	}
 }
 
+func (cache *indexerCache) setGenesis(genesis *rpctypes.StandardV1GenesisResponse) {
+	cache.cacheMutex.Lock()
+	defer cache.cacheMutex.Unlock()
+	if cache.genesisResp == nil {
+		cache.genesisResp = genesis
+	}
+}
+
 func (cache *indexerCache) getFinalizedHead() (int64, []byte) {
 	cache.cacheMutex.RLock()
 	defer cache.cacheMutex.RUnlock()

diff --git a/indexer/client.go b/indexer/client.go
@@ -153,6 +153,7 @@ func (client *IndexerClient) checkIndexerClient() error {
 	if genesis.Data.GenesisForkVersion.String() != utils.Config.Chain.Config.GenesisForkVersion {
 		return fmt.Errorf("genesis fork version from RPC does not match the genesis fork version explorer configuration")
 	}
+	client.indexerCache.setGenesis(genesis)
 
 	// check syncronization state
 	syncStatus, err := client.rpcClient.GetNodeSyncing()

diff --git a/indexer/indexer.go b/indexer/indexer.go
@@ -153,6 +153,10 @@ func (indexer *Indexer) GetRpcClient(archive bool, head []byte) *rpc.BeaconClien
 	return readyClient.rpcClient
 }
 
+func (indexer *Indexer) GetCachedGenesis() *rpctypes.StandardV1GenesisResponse {
+	return indexer.indexerCache.genesisResp
+}
+
 func (indexer *Indexer) GetFinalizedEpoch() (int64, []byte) {
 	return indexer.indexerCache.getFinalizedHead()
 }

diff --git a/services/beaconservice.go b/services/beaconservice.go
@@ -85,7 +85,7 @@ func (bs *BeaconService) GetCachedEpochStats(epoch uint64) *indexer.EpochStats {
 }
 
 func (bs *BeaconService) GetGenesis() (*rpctypes.StandardV1GenesisResponse, error) {
-	return bs.indexer.GetRpcClient(false, nil).GetGenesis()
+	return bs.indexer.GetCachedGenesis(), nil
 }
 
 func (bs *BeaconService) GetSlotDetailsByBlockroot(blockroot []byte) (*rpctypes.CombinedBlockResponse, error) {