wire cached store

Author: julienrbrt

node/full.go

@@ -82,9 +82,17 @@ func newFullNode(
 	blockMetrics, _ := metricsProvider(genesis.ChainID)
 
 	mainKV := store.NewEvNodeKVStore(database)
-	evstore := store.New(mainKV)
+	baseStore := store.New(mainKV)
+
+	// Wrap with cached store for LRU caching of headers and block data
+	cachedStore, err := store.NewCachedStore(baseStore)
+	if err != nil {
+		return nil, fmt.Errorf("failed to create cached store: %w", err)
+	}
+
+	var evstore store.Store = cachedStore
 	if nodeConfig.Instrumentation.IsTracingEnabled() {
-		evstore = store.WithTracingStore(evstore)
+		evstore = store.WithTracingStore(cachedStore)
 	}
 
 	var raftNode *raftpkg.Node

node/light.go

@@ -49,17 +49,23 @@ func newLightNode(
 	}
 
 	componentLogger := logger.With().Str("component", "HeaderSyncService").Logger()
-	store := store.New(database)
+	baseStore := store.New(database)
 
-	headerSyncService, err := sync.NewHeaderSyncService(database, store, conf, genesis, p2pClient, componentLogger)
+	// Wrap with cached store for LRU caching of headers
+	cachedStore, err := store.NewCachedStore(baseStore)
+	if err != nil {
+		return nil, fmt.Errorf("failed to create cached store: %w", err)
+	}
+
+	headerSyncService, err := sync.NewHeaderSyncService(database, cachedStore, conf, genesis, p2pClient, componentLogger)
 	if err != nil {
 		return nil, fmt.Errorf("error while initializing HeaderSyncService: %w", err)
 	}
 
 	node := &LightNode{
 		P2P:          p2pClient,
 		hSyncService: headerSyncService,
-		Store:        store,
+		Store:        cachedStore,
 		nodeConfig:   conf,
 	}