Hashed value

README.md

@@ -8,6 +8,13 @@ KVVM defines a blockchain that is a key-value storage server. Each block in the
 
 KVVM is served over RPC with [go-plugin](https://github.com/hashicorp/go-plugin).
 
+# Features
+TODO: Extend on
+* PoW Transactions (no tokens)
+* Prefixes (address prefixes reserved)
+* Hashed Value Keys
+* Prefix Expiry (based on weight of all key-values)
+
 # Quick start
 
 At its core, the Avalanche protocol still maintains the immutable ordered sequence of states in a fully permissionless settings. And KVVM defines the rules and data structures to store key-value pairs.

chain/errors.go

@@ -27,6 +27,7 @@ var (
 	ErrValueTooBig       = errors.New("value too big")
 	ErrPrefixExpired     = errors.New("prefix expired")
 	ErrKeyMissing        = errors.New("key missing")
+	ErrInvalidKey        = errors.New("key is invalid")
 	ErrPublicKeyMismatch = errors.New("public key does not match decoded prefix")
 	ErrPrefixNotExpired  = errors.New("prefix not expired")
 	ErrPrefixMissing     = errors.New("prefix missing")

chain/set_tx.go

@@ -5,11 +5,16 @@ package chain
 
 import (
 	"bytes"
+	"fmt"
 
 	"github.com/ava-labs/avalanchego/database"
+	"github.com/ava-labs/avalanchego/ids"
 	"github.com/ava-labs/quarkvm/parser"
+	"golang.org/x/crypto/sha3"
 )
 
+const IDLen = 32
+
 var _ UnsignedTransaction = &SetTx{}
 
 type SetTx struct {
@@ -48,6 +53,18 @@ func (s *SetTx) Execute(db database.Database, blockTime uint64) error {
 	if i.Expiry < blockTime {
 		return ErrPrefixExpired
 	}
+	// If Key is equal to hash length, ensure it is equal to the hash of the
+	// value
+	if len(s.Key) == IDLen && len(s.Value) > 0 {
+		h := sha3.Sum256(s.Value)
+		id, err := ids.ToID(h[:])
+		if err != nil {
+			return err
+		}
+		if !bytes.Equal(s.Key, id[:]) {
+			return fmt.Errorf("%w: expected %x got %x", ErrInvalidKey, id[:], s.Key)
+		}
+	}
 	return s.updatePrefix(db, blockTime, i)
 }
 

chain/set_tx_test.go

@@ -10,6 +10,7 @@ import (
 
 	"github.com/ava-labs/avalanchego/database/memdb"
 	"github.com/ava-labs/avalanchego/ids"
+	"golang.org/x/crypto/sha3"
 
 	"github.com/ava-labs/quarkvm/parser"
 )
@@ -91,6 +92,53 @@ func TestSetTx(t *testing.T) {
 			blockTime: 1,
 			err:       nil,
 		},
+		{ // write hashed value
+			utx: &SetTx{
+				BaseTx: &BaseTx{
+					Sender:  sender,
+					Prefix:  []byte("foo"),
+					BlockID: ids.GenerateTestID(),
+				},
+				Key: func() []byte {
+					h := sha3.Sum256([]byte("value"))
+					return h[:]
+				}(),
+				Value: []byte("value"),
+			},
+			blockTime: 1,
+			err:       nil,
+		},
+		{ // write incorrect hashed value
+			utx: &SetTx{
+				BaseTx: &BaseTx{
+					Sender:  sender,
+					Prefix:  []byte("foo"),
+					BlockID: ids.GenerateTestID(),
+				},
+				Key: func() []byte {
+					h := sha3.Sum256([]byte("not value"))
+					return h[:]
+				}(),
+				Value: []byte("value"),
+			},
+			blockTime: 1,
+			err:       ErrInvalidKey,
+		},
+		{ // delete hashed value
+			utx: &SetTx{
+				BaseTx: &BaseTx{
+					Sender:  sender,
+					Prefix:  []byte("foo"),
+					BlockID: ids.GenerateTestID(),
+				},
+				Key: func() []byte {
+					h := sha3.Sum256([]byte("value"))
+					return h[:]
+				}(),
+			},
+			blockTime: 1,
+			err:       nil,
+		},
 		{
 			utx: &SetTx{
 				BaseTx: &BaseTx{