chore: sync store on new block

block/internal/executing/executor.go

@@ -413,6 +413,9 @@ func (e *Executor) produceBlock() error {
 	if err := batch.Commit(); err != nil {
 		return fmt.Errorf("failed to commit batch: %w", err)
 	}
+	if err := e.store.Sync(context.Background()); err != nil {
+		return fmt.Errorf("failed to sync store: %w", err)
+	}
 
 	// Update in-memory state after successful commit
 	e.setLastState(newState)

pkg/store/benchmark_test.go

@@ -0,0 +1,70 @@
+package store
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+
+	"github.com/evstack/ev-node/types"
+)
+
+func BenchmarkStoreSync(b *testing.B) {
+	chainID := "BenchmarkStoreSync"
+	testCases := []struct {
+		name      string
+		blockSize int
+	}{
+		{"empty", 0},
+		{"small", 10},
+		{"large", 1_000},
+	}
+
+	for _, tc := range testCases {
+		header, data := types.GetRandomBlock(1, tc.blockSize, chainID)
+		signature := &types.Signature{}
+
+		b.Run(fmt.Sprintf("WithoutSync_%s", tc.name), func(b *testing.B) {
+			tmpDir := b.TempDir()
+			kv, err := NewDefaultKVStore(tmpDir, "db", "test")
+			require.NoError(b, err)
+			store := New(kv)
+			b.Cleanup(func() { _ = store.Close() })
+
+			b.ResetTimer()
+			for i := 0; i < b.N; i++ {
+				batch, err := store.NewBatch(b.Context())
+				require.NoError(b, err)
+
+				err = batch.SaveBlockData(header, data, signature)
+				require.NoError(b, err)
+
+				err = batch.Commit()
+				require.NoError(b, err)
+			}
+		})
+
+		b.Run(fmt.Sprintf("WithSync_%s", tc.name), func(b *testing.B) {
+			tmpDir := b.TempDir()
+			kv, err := NewDefaultKVStore(tmpDir, "db", "test")
+			require.NoError(b, err)
+			store := New(kv)
+			b.Cleanup(func() { _ = store.Close() })
+
+			b.ResetTimer()
+			for i := 0; i < b.N; i++ {
+				batch, err := store.NewBatch(b.Context())
+				require.NoError(b, err)
+
+				err = batch.SaveBlockData(header, data, signature)
+				require.NoError(b, err)
+
+				err = batch.Commit()
+				require.NoError(b, err)
+
+				err = store.Sync(b.Context())
+				require.NoError(b, err)
+			}
+		})
+	}
+}

pkg/store/store.go

@@ -190,6 +190,11 @@ func (s *DefaultStore) GetMetadata(ctx context.Context, key string) ([]byte, err
 	return data, nil
 }
 
+// Sync flushes the store state to disk
+func (s *DefaultStore) Sync(ctx context.Context) error {
+	return s.db.Sync(ctx, ds.NewKey("/"))
+}
+
 // Rollback rolls back block data until the given height from the store.
 // When aggregator is true, it will check the latest data included height and prevent rollback further than that.
 // NOTE: this function does not rollback metadata. Those should be handled separately if required.

pkg/store/types.go

@@ -44,6 +44,9 @@ type Store interface {
 
 	// NewBatch creates a new batch for atomic operations.
 	NewBatch(ctx context.Context) (Batch, error)
+
+	// Sync flushes the store state to disk
+	Sync(ctx context.Context) error
 }
 
 type Reader interface {