mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-24 21:56:43 +00:00
core/types/bal: add EncodeFullRLP
This commit is contained in:
parent
b9b3c6c06e
commit
ef5206359b
3 changed files with 97 additions and 1 deletions
|
|
@ -221,7 +221,7 @@ func (b *BlockAccessList) EncodeRLP(wr io.Writer) error {
|
||||||
return w.Flush()
|
return w.Flush()
|
||||||
}
|
}
|
||||||
|
|
||||||
// DecodeRLP decodes the access list
|
// DecodeRLP decodes the bloc accessList.
|
||||||
func (b *BlockAccessList) DecodeRLP(s *rlp.Stream) error {
|
func (b *BlockAccessList) DecodeRLP(s *rlp.Stream) error {
|
||||||
encBytes, err := s.Bytes()
|
encBytes, err := s.Bytes()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
@ -230,6 +230,25 @@ func (b *BlockAccessList) DecodeRLP(s *rlp.Stream) error {
|
||||||
return b.decodeSSZ(encBytes)
|
return b.decodeSSZ(encBytes)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// EncodeFullRLP returns the RLP-encoded access list wrapped into RLP bytes.
|
||||||
|
func (b *BlockAccessList) EncodeFullRLP(wr io.Writer) error {
|
||||||
|
return b.toEncodingObj().EncodeRLP(wr)
|
||||||
|
}
|
||||||
|
|
||||||
|
// DecodeFullRLP decodes the block accessList with full RLP format.
|
||||||
|
func (b *BlockAccessList) DecodeFullRLP(s *rlp.Stream) error {
|
||||||
|
var obj encodingBlockAccessList
|
||||||
|
if err := obj.DecodeRLP(s); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
al, err := obj.toBlockAccessList()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
*b = *al
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
var _ rlp.Encoder = &BlockAccessList{}
|
var _ rlp.Encoder = &BlockAccessList{}
|
||||||
var _ rlp.Decoder = &BlockAccessList{}
|
var _ rlp.Decoder = &BlockAccessList{}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -21,6 +21,7 @@ import (
|
||||||
"io/fs"
|
"io/fs"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
"reflect"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/ethereum/go-ethereum/common"
|
"github.com/ethereum/go-ethereum/common"
|
||||||
|
|
@ -28,6 +29,34 @@ import (
|
||||||
"github.com/holiman/uint256"
|
"github.com/holiman/uint256"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func equalBALs(a *BlockAccessList, b *BlockAccessList) bool {
|
||||||
|
if len(a.Accounts) != len(b.Accounts) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
for addr, aaA := range a.Accounts {
|
||||||
|
aaB, ok := b.Accounts[addr]
|
||||||
|
if !ok {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if !reflect.DeepEqual(aaA.StorageWrites, aaB.StorageWrites) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if !reflect.DeepEqual(aaA.StorageReads, aaB.StorageReads) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if !reflect.DeepEqual(aaA.BalanceChanges, aaB.BalanceChanges) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if !reflect.DeepEqual(aaA.NonceChanges, aaB.NonceChanges) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
if !reflect.DeepEqual(aaA.CodeChange, aaB.CodeChange) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
func makeTestBAL() *BlockAccessList {
|
func makeTestBAL() *BlockAccessList {
|
||||||
return &BlockAccessList{
|
return &BlockAccessList{
|
||||||
map[common.Address]*AccountAccess{
|
map[common.Address]*AccountAccess{
|
||||||
|
|
@ -97,6 +126,29 @@ func TestBALEncoding(t *testing.T) {
|
||||||
if dec.Hash() != bal.Hash() {
|
if dec.Hash() != bal.Hash() {
|
||||||
t.Fatalf("encoded block hash doesn't match decoded")
|
t.Fatalf("encoded block hash doesn't match decoded")
|
||||||
}
|
}
|
||||||
|
if !equalBALs(bal, &dec) {
|
||||||
|
t.Fatal("decoded BAL doesn't match")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// TestBALEncoding tests that a populated access list can be encoded/decoded correctly.
|
||||||
|
func TestBALFullRLPEncoding(t *testing.T) {
|
||||||
|
var buf bytes.Buffer
|
||||||
|
bal := makeTestBAL()
|
||||||
|
err := bal.EncodeFullRLP(&buf)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("encoding failed: %v\n", err)
|
||||||
|
}
|
||||||
|
var dec BlockAccessList
|
||||||
|
if err := dec.DecodeFullRLP(rlp.NewStream(bytes.NewReader(buf.Bytes()), 10000000)); err != nil {
|
||||||
|
t.Fatalf("decoding failed: %v\n", err)
|
||||||
|
}
|
||||||
|
if dec.Hash() != bal.Hash() {
|
||||||
|
t.Fatalf("encoded block hash doesn't match decoded")
|
||||||
|
}
|
||||||
|
if !equalBALs(bal, &dec) {
|
||||||
|
t.Fatal("decoded BAL doesn't match")
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TestBALDecoding tests that a mainnet BAL produced by https://github.com/nerolation/eth-bal-analysis
|
// TestBALDecoding tests that a mainnet BAL produced by https://github.com/nerolation/eth-bal-analysis
|
||||||
|
|
@ -120,3 +172,28 @@ func TestBALDecoding(t *testing.T) {
|
||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestBALEncodeSizeDifference(t *testing.T) {
|
||||||
|
filepath.WalkDir("testdata/ssz", func(path string, d fs.DirEntry, err error) error {
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if d.IsDir() {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
data, err := os.ReadFile(path)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
var b BlockAccessList
|
||||||
|
if err := b.decodeSSZ(data); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
var buf bytes.Buffer
|
||||||
|
if err := b.EncodeFullRLP(&buf); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
t.Logf("SSZ: %v, RLP: %v\n", common.StorageSize(len(data)), common.StorageSize(buf.Len()))
|
||||||
|
return nil
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
|
||||||
Binary file not shown.
Loading…
Reference in a new issue