Merge pull request #78 from sei-protocol/IgnoreVersion

Set Earliest Version Ignore Version
sei-protocol · Nov 27, 2024 · a340563 · a340563
2 parents bfe1190 + cf2c44b
commit a340563
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/ss/pebbledb/db.go b/ss/pebbledb/db.go
@@ -181,8 +181,8 @@ func (db *Database) GetLatestVersion() (int64, error) {
 	return int64(binary.LittleEndian.Uint64(bz)), closer.Close()
 }
 
-func (db *Database) SetEarliestVersion(version int64) error {
-	if version > db.earliestVersion {
+func (db *Database) SetEarliestVersion(version int64, ignoreVersion bool) error {
+	if version > db.earliestVersion || ignoreVersion {
 		db.earliestVersion = version
 
 		var ts [VersionSize]byte
@@ -486,7 +486,7 @@ func (db *Database) Prune(version int64) error {
 		}
 	}
 
-	return db.SetEarliestVersion(earliestVersion)
+	return db.SetEarliestVersion(earliestVersion, false)
 }
 
 func (db *Database) Iterator(storeKey string, version int64, start, end []byte) (types.DBIterator, error) {

diff --git a/ss/rocksdb/db.go b/ss/rocksdb/db.go
@@ -127,7 +127,7 @@ func (db *Database) GetLatestVersion() (int64, error) {
 	return int64(binary.LittleEndian.Uint64(bz)), nil
 }
 
-func (db *Database) SetEarliestVersion(version int64) error {
+func (db *Database) SetEarliestVersion(version int64, ignoreVersion bool) error {
 	panic("not implemented")
 }
 

diff --git a/ss/sqlite/db.go b/ss/sqlite/db.go
@@ -142,7 +142,7 @@ func (db *Database) GetEarliestVersion() (int64, error) {
 	panic("not implemented")
 }
 
-func (db *Database) SetEarliestVersion(version int64) error {
+func (db *Database) SetEarliestVersion(version int64, ignoreVersion bool) error {
 	panic("not implemented")
 }
 

diff --git a/ss/types/store.go b/ss/types/store.go
@@ -17,7 +17,7 @@ type StateStore interface {
 	GetLatestVersion() (int64, error)
 	SetLatestVersion(version int64) error
 	GetEarliestVersion() (int64, error)
-	SetEarliestVersion(version int64) error
+	SetEarliestVersion(version int64, ignoreVersion bool) error
 	GetLatestMigratedKey() ([]byte, error)
 	SetLatestMigratedKey(key []byte) error
 	GetLatestMigratedModule() (string, error)