Sync store on new block

Author: alpe

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/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 {