Add DB compaction following the deletion of a DB prefix

domain/consensus/processes/pruningmanager/pruningmanager.go

@@ -935,7 +935,7 @@ func (pm *pruningManager) PruningPointAndItsAnticone() ([]*externalapi.DomainHas
 		return nil, err
 	}
 
-	// By the Prunality proof, The pruning point anticone is a closed set (i.e., guaranteed not to change) ,
+	// By the Prunality proof, the pruning point anticone is a closed set (i.e., guaranteed not to change) ,
 	// so we can safely cache it.
 	if pm.cachedPruningPoint != nil && pm.cachedPruningPoint.Equal(pruningPoint) {
 		return append([]*externalapi.DomainHash{pruningPoint}, pm.cachedPruningPointAnticone...), nil

domain/prefixmanager/prefix.go

@@ -47,8 +47,8 @@ func InactivePrefix(dataAccessor database.DataAccessor) (*prefix.Prefix, bool, e
 }
 
 // DeleteInactivePrefix deletes all data associated with the inactive database prefix, including itself.
-func DeleteInactivePrefix(dataAccessor database.DataAccessor) error {
-	prefixBytes, err := dataAccessor.Get(inactivePrefixKey)
+func DeleteInactivePrefix(db database.Database) error {
+	prefixBytes, err := db.Get(inactivePrefixKey)
 	if database.IsNotFoundError(err) {
 		return nil
 	}
@@ -62,12 +62,18 @@ func DeleteInactivePrefix(dataAccessor database.DataAccessor) error {
 		return err
 	}
 
-	err = deletePrefix(dataAccessor, prefix)
+	err = deletePrefix(db, prefix)
+	if err != nil {
+		return err
+	}
+
+	err = db.Delete(inactivePrefixKey)
 	if err != nil {
 		return err
 	}
 
-	return dataAccessor.Delete(inactivePrefixKey)
+	log.Infof("Compacting database after prefix delete")
+	return db.Compact()
 }
 
 func deletePrefix(dataAccessor database.DataAccessor, prefix *prefix.Prefix) error {

infrastructure/db/database/database.go

@@ -14,6 +14,9 @@ type Database interface {
 	// Begin begins a new database transaction.
 	Begin() (Transaction, error)
 
+	// Compact compacts the database instance.
+	Compact() error
+
 	// Close closes the database.
 	Close() error
 }

infrastructure/db/database/ldb/leveldb.go

@@ -6,6 +6,7 @@ import (
 	"github.com/syndtr/goleveldb/leveldb"
 	ldbErrors "github.com/syndtr/goleveldb/leveldb/errors"
 	"github.com/syndtr/goleveldb/leveldb/opt"
+	"github.com/syndtr/goleveldb/leveldb/util"
 )
 
 // LevelDB defines a thin wrapper around leveldb.
@@ -47,6 +48,12 @@ func NewLevelDB(path string, cacheSizeMiB int) (*LevelDB, error) {
 	return db, nil
 }
 
+// Compact compacts the leveldb instance.
+func (db *LevelDB) Compact() error {
+	err := db.ldb.CompactRange(util.Range{Start: nil, Limit: nil})
+	return errors.WithStack(err)
+}
+
 // Close closes the leveldb instance.
 func (db *LevelDB) Close() error {
 	err := db.ldb.Close()