84 lines
2.0 KiB
Go
84 lines
2.0 KiB
Go
package iavl
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
dbm "github.com/cosmos/cosmos-db"
|
|
"github.com/cosmos/iavl"
|
|
ics23 "github.com/cosmos/ics23/go"
|
|
|
|
log "cosmossdk.io/log"
|
|
"cosmossdk.io/store/v2/commitment"
|
|
)
|
|
|
|
var _ commitment.Tree = (*IavlTree)(nil)
|
|
|
|
// IavlTree is a wrapper around iavl.MutableTree.
|
|
type IavlTree struct {
|
|
tree *iavl.MutableTree
|
|
}
|
|
|
|
// NewIavlTree creates a new IavlTree instance.
|
|
func NewIavlTree(db dbm.DB, logger log.Logger, cfg *Config) *IavlTree {
|
|
tree := iavl.NewMutableTree(db, cfg.CacheSize, cfg.SkipFastStorageUpgrade, logger)
|
|
return &IavlTree{
|
|
tree: tree,
|
|
}
|
|
}
|
|
|
|
// Remove removes the given key from the tree.
|
|
func (t *IavlTree) Remove(key []byte) error {
|
|
_, res, err := t.tree.Remove(key)
|
|
if !res {
|
|
return fmt.Errorf("key %x not found", key)
|
|
}
|
|
return err
|
|
}
|
|
|
|
// Set sets the given key-value pair in the tree.
|
|
func (t *IavlTree) Set(key, value []byte) error {
|
|
_, err := t.tree.Set(key, value)
|
|
return err
|
|
}
|
|
|
|
// WorkingHash returns the working hash of the database.
|
|
func (t *IavlTree) WorkingHash() []byte {
|
|
return t.tree.WorkingHash()
|
|
}
|
|
|
|
// LoadVersion loads the state at the given version.
|
|
func (t *IavlTree) LoadVersion(version uint64) error {
|
|
return t.tree.LoadVersionForOverwriting(int64(version))
|
|
}
|
|
|
|
// Commit commits the current state to the database.
|
|
func (t *IavlTree) Commit() ([]byte, error) {
|
|
hash, _, err := t.tree.SaveVersion()
|
|
return hash, err
|
|
}
|
|
|
|
// GetProof returns a proof for the given key and version.
|
|
func (t *IavlTree) GetProof(version uint64, key []byte) (*ics23.CommitmentProof, error) {
|
|
imutableTree, err := t.tree.GetImmutable(int64(version))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return imutableTree.GetProof(key)
|
|
}
|
|
|
|
// GetLatestVersion returns the latest version of the database.
|
|
func (t *IavlTree) GetLatestVersion() uint64 {
|
|
return uint64(t.tree.Version())
|
|
}
|
|
|
|
// Prune prunes all versions up to and including the provided version.
|
|
func (t *IavlTree) Prune(version uint64) error {
|
|
return t.tree.DeleteVersionsTo(int64(version))
|
|
}
|
|
|
|
// Close closes the iavl tree.
|
|
func (t *IavlTree) Close() error {
|
|
return nil
|
|
}
|