mirror of
https://gitlab.com/pulsechaincom/erigon-pulse.git
synced 2024-12-22 03:30:37 +00:00
436493350e
1. changes sentinel to use an http-like interface 2. moves hexutil, crypto/blake2b, metrics packages to erigon-lib
118 lines
3.9 KiB
Go
118 lines
3.9 KiB
Go
package trie
|
|
|
|
import (
|
|
"encoding/binary"
|
|
"fmt"
|
|
"testing"
|
|
|
|
libcommon "github.com/ledgerwatch/erigon-lib/common"
|
|
"github.com/ledgerwatch/erigon-lib/kv"
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
"github.com/ledgerwatch/erigon/common"
|
|
"github.com/ledgerwatch/erigon/core/types/accounts"
|
|
)
|
|
|
|
func TestCreateLoadingPrefixes(t *testing.T) {
|
|
assert := assert.New(t)
|
|
|
|
tr := New(libcommon.Hash{})
|
|
kAcc1 := common.FromHex("0001cf1ce0664746d39af9f6db99dc3370282f1d9d48df7f804b7e6499558c83")
|
|
kInc := make([]byte, 8)
|
|
binary.BigEndian.PutUint64(kInc, uint64(1))
|
|
ks1 := common.FromHex("0000000000000000000000000000000000000000000000000000000000000001")
|
|
acc1 := accounts.NewAccount()
|
|
acc1.Balance.SetUint64(12345)
|
|
acc1.Incarnation = 1
|
|
acc1.Initialised = true
|
|
tr.UpdateAccount(kAcc1, &acc1)
|
|
tr.Update(concat(kAcc1, ks1...), []byte{1, 2, 3})
|
|
|
|
kAcc2 := common.FromHex("0002cf1ce0664746d39af9f6db99dc3370282f1d9d48df7f804b7e6499558c83")
|
|
ks2 := common.FromHex("0000000000000000000000000000000000000000000000000000000000000001")
|
|
ks22 := common.FromHex("0000000000000000000000000000000000000000000000000000000000000002")
|
|
acc2 := accounts.NewAccount()
|
|
acc2.Balance.SetUint64(6789)
|
|
acc2.Incarnation = 1
|
|
acc2.Initialised = true
|
|
tr.UpdateAccount(kAcc2, &acc2)
|
|
tr.Update(concat(kAcc2, ks2...), []byte{4, 5, 6})
|
|
tr.Update(concat(kAcc2, ks22...), []byte{7, 8, 9})
|
|
tr.Hash()
|
|
|
|
// Evict accounts only
|
|
tr.EvictNode(keybytesToHex(kAcc1))
|
|
tr.EvictNode(keybytesToHex(kAcc2))
|
|
rs := NewRetainList(0)
|
|
rs.AddKey(concat(concat(kAcc1, kInc...), ks1...))
|
|
rs.AddKey(concat(concat(kAcc2, kInc...), ks2...))
|
|
rs.AddKey(concat(concat(kAcc2, kInc...), ks22...))
|
|
dbPrefixes, fixedbits, hooks := tr.FindSubTriesToLoad(rs)
|
|
assert.Equal("[0001cf1ce0664746d39af9f6db99dc3370282f1d9d48df7f804b7e6499558c830000000000000001 0002cf1ce0664746d39af9f6db99dc3370282f1d9d48df7f804b7e6499558c830000000000000001]", fmt.Sprintf("%x", dbPrefixes))
|
|
assert.Equal("[320 320]", fmt.Sprintf("%d", fixedbits))
|
|
assert.Equal("[000000010c0f010c0e000606040704060d03090a0f090f060d0b09090d0c030307000208020f010d090d04080d0f070f0800040b070e060409090505080c0803 000000020c0f010c0e000606040704060d03090a0f090f060d0b09090d0c030307000208020f010d090d04080d0f070f0800040b070e060409090505080c0803]", fmt.Sprintf("%x", hooks))
|
|
|
|
// Evict everytning
|
|
tr.EvictNode([]byte{})
|
|
// if resolve only accounts
|
|
rs = NewRetainList(0)
|
|
rs.AddKey(kAcc1)
|
|
rs.AddKey(kAcc2)
|
|
dbPrefixes, fixedbits, hooks = tr.FindSubTriesToLoad(rs)
|
|
assert.Equal("[]", fmt.Sprintf("%x", dbPrefixes))
|
|
assert.Equal("[0]", fmt.Sprintf("%d", fixedbits))
|
|
assert.Equal("[]", fmt.Sprintf("%x", hooks))
|
|
}
|
|
|
|
func TestIsBefore(t *testing.T) {
|
|
assert := assert.New(t)
|
|
|
|
is := keyIsBefore([]byte("a"), []byte("b"))
|
|
assert.Equal(true, is)
|
|
|
|
is = keyIsBefore([]byte("b"), []byte("a"))
|
|
assert.Equal(false, is)
|
|
|
|
is = keyIsBefore([]byte("b"), []byte(""))
|
|
assert.Equal(false, is)
|
|
|
|
is = keyIsBefore(nil, []byte("b"))
|
|
assert.Equal(false, is)
|
|
|
|
is = keyIsBefore([]byte("b"), nil)
|
|
assert.Equal(true, is)
|
|
|
|
contract := fmt.Sprintf("2%063x", 0)
|
|
storageKey := libcommon.Hex2Bytes(contract + "ffffffff" + fmt.Sprintf("10%062x", 0))
|
|
cacheKey := libcommon.Hex2Bytes(contract + "ffffffff" + "20")
|
|
is = keyIsBefore(cacheKey, storageKey)
|
|
assert.False(is)
|
|
|
|
storageKey = libcommon.Hex2Bytes(contract + "ffffffffffffffff" + fmt.Sprintf("20%062x", 0))
|
|
cacheKey = libcommon.Hex2Bytes(contract + "ffffffffffffffff" + "10")
|
|
is = keyIsBefore(cacheKey, storageKey)
|
|
assert.True(is)
|
|
}
|
|
|
|
func TestIsSequence(t *testing.T) {
|
|
assert := assert.New(t)
|
|
|
|
type tc struct {
|
|
prev, next string
|
|
expect bool
|
|
}
|
|
|
|
cases := []tc{
|
|
{prev: "1234", next: "1235", expect: true},
|
|
{prev: "12ff", next: "13", expect: true},
|
|
{prev: "12ff", next: "13000000", expect: true},
|
|
{prev: "1234", next: "5678", expect: false},
|
|
}
|
|
for _, tc := range cases {
|
|
next, _ := kv.NextSubtree(common.FromHex(tc.prev))
|
|
res := isSequenceOld(next, common.FromHex(tc.next))
|
|
assert.Equal(tc.expect, res, "%s, %s", tc.prev, tc.next)
|
|
}
|
|
|
|
}
|