updates

store/errors.go

@@ -1,6 +1,8 @@
 package store
 
 import (
+	"fmt"
+
 	"cosmossdk.io/errors"
 )
 
@@ -32,7 +34,16 @@ var (
 	ErrClosed          = errors.Register(StoreCodespace, 8, "closed")
 	ErrRecordNotFound  = errors.Register(StoreCodespace, 9, "record not found")
 	ErrUnknownStoreKey = errors.Register(StoreCodespace, 10, "unknown store key")
-	ErrVersionPruned   = errors.Register(StoreCodespace, 11, "version pruned")
 	ErrKeyEmpty        = errors.Register(StoreCodespace, 12, "key empty")
 	ErrStartAfterEnd   = errors.Register(StoreCodespace, 13, "start key after end key")
 )
+
+// ErrVersionPruned defines an error returned when a version queried is pruned
+// or does not exist.
+type ErrVersionPruned struct {
+	EarliestVersion uint64
+}
+
+func (e ErrVersionPruned) Error() string {
+	return fmt.Sprintf("requested version is pruned; earliest available version is: %d", e.EarliestVersion)
+}

store/storage/pebbledb/db.go

@@ -137,7 +137,7 @@ func (db *Database) Has(storeKey string, version uint64, key []byte) (bool, erro
 
 func (db *Database) Get(storeKey string, targetVersion uint64, key []byte) ([]byte, error) {
 	if targetVersion < db.earliestVersion {
-		return nil, store.ErrVersionPruned
+		return nil, store.ErrVersionPruned{EarliestVersion: db.earliestVersion}
 	}
 
 	prefixedVal, err := getMVCCSlice(db.storage, storeKey, key, targetVersion)

store/storage/rocksdb/db.go

@@ -7,7 +7,6 @@ import (
 	"bytes"
 	"encoding/binary"
 	"fmt"
-	"strings"
 
 	"github.com/linxGnu/grocksdb"
 	"golang.org/x/exp/slices"
@@ -33,6 +32,10 @@ var (
 type Database struct {
 	storage  *grocksdb.DB
 	cfHandle *grocksdb.ColumnFamilyHandle
+
+	// tsLow reflects the full_history_ts_low CF value, which is earliest version
+	// supported
+	tsLow uint64
 }
 
 func New(dataDir string) (*Database, error) {
@@ -41,16 +44,40 @@ func New(dataDir string) (*Database, error) {
 		return nil, fmt.Errorf("failed to open RocksDB: %w", err)
 	}
 
+	slice, err := storage.GetFullHistoryTsLow(cfHandle)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get full_history_ts_low: %w", err)
+	}
+
+	var tsLow uint64
+	tsLowBz := copyAndFreeSlice(slice)
+	if len(tsLowBz) > 0 {
+		tsLow = binary.LittleEndian.Uint64(tsLowBz)
+	}
+
 	return &Database{
 		storage:  storage,
 		cfHandle: cfHandle,
+		tsLow:    tsLow,
 	}, nil
 }
 
 func NewWithDB(storage *grocksdb.DB, cfHandle *grocksdb.ColumnFamilyHandle) (*Database, error) {
+	slice, err := storage.GetFullHistoryTsLow(cfHandle)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get full_history_ts_low: %w", err)
+	}
+
+	var tsLow uint64
+	tsLowBz := copyAndFreeSlice(slice)
+	if len(tsLowBz) > 0 {
+		tsLow = binary.LittleEndian.Uint64(tsLowBz)
+	}
+
 	return &Database{
 		storage:  storage,
 		cfHandle: cfHandle,
+		tsLow:    tsLow,
 	}, nil
 }
 
@@ -64,16 +91,15 @@ func (db *Database) Close() error {
 }
 
 func (db *Database) getSlice(storeKey string, version uint64, key []byte) (*grocksdb.Slice, error) {
-	slice, err := db.storage.GetCF(
+	if version < db.tsLow {
+		return nil, store.ErrVersionPruned{EarliestVersion: db.tsLow}
+	}
+
+	return db.storage.GetCF(
 		newTSReadOptions(version),
 		db.cfHandle,
 		prependStoreKey(storeKey, key),
 	)
-	if err != nil && strings.Contains(err.Error(), "is smaller than full_history_ts_low") {
-		return nil, store.ErrVersionPruned
-	}
-
-	return slice, err
 }
 
 func (db *Database) SetLatestVersion(version uint64) error {

store/storage/sqlite/db.go

@@ -132,7 +132,7 @@ func (db *Database) Has(storeKey string, version uint64, key []byte) (bool, erro
 
 func (db *Database) Get(storeKey string, targetVersion uint64, key []byte) ([]byte, error) {
 	if targetVersion < db.earliestVersion {
-		return nil, store.ErrVersionPruned
+		return nil, store.ErrVersionPruned{EarliestVersion: db.earliestVersion}
 	}
 
 	stmt, err := db.storage.Prepare(`