Skip to content

Commit

Permalink
Change constructor name
Browse files Browse the repository at this point in the history
  • Loading branch information
dimartiro committed Mar 19, 2024
1 parent 86c9d35 commit 00a5f9b
Show file tree
Hide file tree
Showing 3 changed files with 31 additions and 30 deletions.
10 changes: 5 additions & 5 deletions lib/runtime/storage/storagediff.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ type storageDiff struct {
}

// newChangeSet initialises and returns a new storageDiff instance
func newChangeSet() *storageDiff {
func newStorageDiff() *storageDiff {
return &storageDiff{
upserts: make(map[string][]byte),
deletes: make(map[string]bool),
Expand Down Expand Up @@ -100,7 +100,7 @@ func (cs *storageDiff) deleteChildLimit(keyToChild string,
deleted uint32, allDeleted bool) {
childChanges := cs.childChangeSet[keyToChild]
if childChanges == nil {
childChanges = newChangeSet()
childChanges = newStorageDiff()
}

if limit == -1 {
Expand Down Expand Up @@ -133,7 +133,7 @@ func (cs *storageDiff) deleteChildLimit(keyToChild string,
func (cs *storageDiff) clearPrefixInChild(keyToChild string, prefix []byte, childKeys []string) {
childChanges := cs.childChangeSet[keyToChild]
if childChanges == nil {
childChanges = newChangeSet()
childChanges = newStorageDiff()
}
childChanges.clearPrefix(prefix, childKeys, -1)
cs.childChangeSet[keyToChild] = childChanges
Expand Down Expand Up @@ -201,7 +201,7 @@ func (cs *storageDiff) upsertChild(keyToChild, key string, value []byte) {

childChanges := cs.childChangeSet[keyToChild]
if childChanges == nil {
childChanges = newChangeSet()
childChanges = newStorageDiff()
}

childChanges.upserts[key] = value
Expand All @@ -219,7 +219,7 @@ func (cs *storageDiff) deleteFromChild(keyToChild, key string) {

childChanges := cs.childChangeSet[keyToChild]
if childChanges == nil {
childChanges = newChangeSet()
childChanges = newStorageDiff()
} else {
delete(cs.childChangeSet, keyToChild)
}
Expand Down
49 changes: 25 additions & 24 deletions lib/runtime/storage/storagediff_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,28 +9,29 @@ import (
"github.com/stretchr/testify/require"
)

func TestChangeSet_InsertGet(t *testing.T) {
changes := newChangeSet()

key := "key"
value := []byte("value")

changes.upsert(key, value)
val, deleted := changes.get(key)
require.False(t, deleted)
require.Equal(t, value, val)
}

func TestChangeSet_InsertDeleteGet(t *testing.T) {
changes := newChangeSet()

key := "key"
value := []byte("value")

changes.upsert(key, value)
changes.delete(key)

val, deleted := changes.get(key)
require.True(t, deleted)
require.Nil(t, val)
func TestStorageDiff_Get(t *testing.T) {
t.Run("Upsert", func(t *testing.T) {
changes := newStorageDiff()

key := "key"
value := []byte("value")
changes.upsert(key, value)

val, deleted := changes.get(key)
require.False(t, deleted)
require.Equal(t, value, val)
})

t.Run("Upsert then delete", func(t *testing.T) {
changes := newStorageDiff()

key := "key"
value := []byte("value")
changes.upsert(key, value)
changes.delete(key)

val, deleted := changes.get(key)
require.True(t, deleted)
require.Nil(t, val)
})
}
2 changes: 1 addition & 1 deletion lib/runtime/storage/trie.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ func (t *TrieState) StartTransaction() {

nextChangeSet := t.getCurrentTransaction()
if nextChangeSet == nil {
nextChangeSet = newChangeSet()
nextChangeSet = newStorageDiff()
}

t.transactions.PushBack(nextChangeSet.snapshot())
Expand Down

0 comments on commit 00a5f9b

Please sign in to comment.