Deneb container changes beacon-chain (#7420)

Adding container changes for Deneb:
https://github.com/ethereum/consensus-specs/blob/dev/specs/deneb/beacon-chain.md

Changed to use pointers for BlobSideCar
 
 #7389

cl/clparams/config.go

@@ -381,6 +381,7 @@ type BeaconChainConfig struct {
 	DomainApplicationMask             [4]byte `yaml:"DOMAIN_APPLICATION_MASK" spec:"true"`               // DomainApplicationMask defines the BLS signature domain for application mask.
 	DomainApplicationBuilder          [4]byte // DomainApplicationBuilder defines the BLS signature domain for application builder.
 	DomainBLSToExecutionChange        [4]byte // DomainBLSToExecutionChange defines the BLS signature domain to change withdrawal addresses to ETH1 prefix
+	DomainBlobSideCar                 [4]byte `yaml:"DOMAIN_BLOB_SIDECAR" spec:"true"` // DomainBlobSideCar defines the BLS signature domain for blob sidecar verification
 
 	// Prysm constants.
 	GweiPerEth                     uint64        // GweiPerEth is the amount of gwei corresponding to 1 eth.

cl/clparams/version.go

@@ -6,7 +6,8 @@ const (
 	Phase0Version    StateVersion = 0
 	AltairVersion    StateVersion = 1
 	BellatrixVersion StateVersion = 2
-	CapellaVersion   StateVersion = 3 // Unimplemented!
+	CapellaVersion   StateVersion = 3
+	DenebVersion     StateVersion = 4
 )
 
 // stringToClVersion converts the string to the current state version.
@@ -20,6 +21,8 @@ func StringToClVersion(s string) StateVersion {
 		return BellatrixVersion
 	case "capella":
 		return CapellaVersion
+	case "deneb":
+		return DenebVersion
 	default:
 		panic("unsupported fork version: " + s)
 	}

cl/cltypes/attestations.go

@@ -290,7 +290,7 @@ func (a *Attestation) DecodeSSZ(buf []byte, version int) error {
 	var err error
 	size := uint64(len(buf))
 	if size < 228 {
-		return ssz.ErrLowBufferSize
+		return fmt.Errorf("[Attestation] err: %s", ssz.ErrLowBufferSize)
 	}
 
 	tail := buf
@@ -385,7 +385,7 @@ func (i *IndexedAttestation) DecodeSSZ(buf []byte, version int) error {
 	var err error
 	size := uint64(len(buf))
 	if size < 228 {
-		return ssz.ErrLowBufferSize
+		return fmt.Errorf("[IndexedAttestation] err: %s", ssz.ErrLowBufferSize)
 	}
 
 	i.Data = new(AttestationData)
@@ -468,7 +468,7 @@ func (a *AttestationData) DecodeSSZ(buf []byte, version int) error {
 	var err error
 	size := uint64(len(buf))
 	if size != uint64(a.EncodingSizeSSZ()) {
-		return ssz.ErrLowBufferSize
+		return fmt.Errorf("[AttestationData] err: %s", ssz.ErrLowBufferSize)
 	}
 
 	a.Slot = ssz.UnmarshalUint64SSZ(buf)
@@ -542,7 +542,7 @@ func (a *PendingAttestation) EncodeSSZ(buf []byte) (dst []byte, err error) {
 func (a *PendingAttestation) DecodeSSZ(buf []byte, version int) error {
 	var err error
 	if len(buf) < a.EncodingSizeSSZ() {
-		return ssz.ErrLowBufferSize
+		return fmt.Errorf("[PendingAttestation] err: %s", ssz.ErrLowBufferSize)
 	}
 
 	tail := buf

cl/cltypes/beacon_blob_side_car.go

@@ -18,7 +18,7 @@ type BlobSideCar struct {
 	Slot            Slot
 	BlockParentRoot libcommon.Hash
 	ProposerIndex   uint64 // validator index
-	Blob            Blob
+	Blob            *Blob
 	KZGCommitment   KZGCommitment
 	KZGProof        KZGProof
 }
@@ -46,7 +46,7 @@ func (b *BlobSideCar) EncodeSSZ(buf []byte) ([]byte, error) {
 	return buf, nil
 }
 
-func (b *BlobSideCar) DecodeSSZ(buf []byte) error {
+func (b *BlobSideCar) DecodeSSZ(buf []byte, version int) error {
 	pos := 0 // current position at the buffer
 
 	copy(b.BlockRoot[:], buf[pos:32])
@@ -79,14 +79,14 @@ func (b *BlobSideCar) EncodingSizeSSZ() int {
 	return 131_256
 }
 
-func (b *BlobSideCar) HashSSZ() (libcommon.Hash, error) {
+func (b *BlobSideCar) HashSSZ() ([32]byte, error) {
 	KZGCommitmentLeave, err := merkle_tree.PublicKeyRoot(b.KZGCommitment)
 	if err != nil {
-		return libcommon.Hash{}, err
+		return [32]byte{}, err
 	}
 	KZGProofLeave, err := merkle_tree.PublicKeyRoot(b.KZGProof)
 	if err != nil {
-		return libcommon.Hash{}, err
+		return [32]byte{}, err
 	}
 
 	blobLeave := [][32]byte{}
@@ -98,7 +98,7 @@ func (b *BlobSideCar) HashSSZ() (libcommon.Hash, error) {
 
 	blobRoot, err := merkle_tree.ArraysRoot(blobLeave, 4096)
 	if err != nil {
-		return libcommon.Hash{}, err
+		return [32]byte{}, err
 	}
 
 	return merkle_tree.ArraysRoot([][32]byte{
@@ -114,7 +114,7 @@ func (b *BlobSideCar) HashSSZ() (libcommon.Hash, error) {
 }
 
 type SignedBlobSideCar struct {
-	Message   BlobSideCar
+	Message   *BlobSideCar
 	Signature [96]byte
 }
 
@@ -132,9 +132,9 @@ func (b *SignedBlobSideCar) EncodeSSZ(buf []byte) ([]byte, error) {
 	return buf, nil
 }
 
-func (b *SignedBlobSideCar) DecodeSSZ(buf []byte) error {
+func (b *SignedBlobSideCar) DecodeSSZ(buf []byte, version int) error {
 	pos := b.Message.EncodingSizeSSZ()
-	err := b.Message.DecodeSSZ(buf[:pos])
+	err := b.Message.DecodeSSZ(buf[:pos], version)
 	if err != nil {
 		return err
 	}
@@ -147,15 +147,15 @@ func (b *SignedBlobSideCar) EncodingSizeSSZ() int {
 	return b.Message.EncodingSizeSSZ() + 96
 }
 
-func (b *SignedBlobSideCar) HashSSZ() (libcommon.Hash, error) {
+func (b *SignedBlobSideCar) HashSSZ() ([32]byte, error) {
 	messageLeave, err := b.Message.HashSSZ()
 	if err != nil {
-		return libcommon.Hash{}, err
+		return [32]byte{}, err
 	}
 
 	signatureLeave, err := merkle_tree.SignatureRoot(b.Signature)
 	if err != nil {
-		return libcommon.Hash{}, err
+		return [32]byte{}, err
 	}
 
 	return merkle_tree.ArraysRoot([][32]byte{
@@ -181,7 +181,7 @@ func (b *BlobIdentifier) EncodeSSZ(buf []byte) ([]byte, error) {
 	return buf, nil
 }
 
-func (b *BlobIdentifier) DecodeSSZ(buf []byte) error {
+func (b *BlobIdentifier) DecodeSSZ(buf []byte, version int) error {
 	copy(b.BlockRoot[:], buf[:32])
 	b.Index = ssz.UnmarshalUint64SSZ(buf[32:])
 	return nil
@@ -191,9 +191,37 @@ func (b *BlobIdentifier) EncodingSizeSSZ() int {
 	return 40
 }
 
-func (b *BlobIdentifier) HashSSZ() (libcommon.Hash, error) {
+func (b *BlobIdentifier) HashSSZ() ([32]byte, error) {
 	return merkle_tree.ArraysRoot([][32]byte{
 		b.BlockRoot,
 		merkle_tree.Uint64Root(b.Index),
 	}, 2)
 }
+
+type BlobKZGCommitment struct {
+	Commitment KZGCommitment
+}
+
+func (b *BlobKZGCommitment) Copy() *BlobKZGCommitment {
+	copy := *b
+	return &copy
+}
+
+func (b *BlobKZGCommitment) EncodeSSZ(buf []byte) ([]byte, error) {
+	buf = append(buf, b.Commitment[:]...)
+	return buf, nil
+}
+
+func (b *BlobKZGCommitment) DecodeSSZ(buf []byte, version int) error {
+	copy(b.Commitment[:], buf)
+
+	return nil
+}
+
+func (b *BlobKZGCommitment) EncodingSizeSSZ() int {
+	return 48
+}
+
+func (b *BlobKZGCommitment) HashSSZ() ([32]byte, error) {
+	return merkle_tree.PublicKeyRoot(b.Commitment)
+}

cl/cltypes/beacon_blob_side_car_test.go

@@ -5,6 +5,7 @@ import (
 	"testing"
 
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
+	"github.com/ledgerwatch/erigon/cl/clparams"
 	"github.com/ledgerwatch/erigon/cl/cltypes"
 	"github.com/stretchr/testify/assert"
 )
@@ -15,7 +16,7 @@ func TestBlobSideCar_EncodeDecodeSSZ(t *testing.T) {
 	slot := cltypes.Slot(456)
 	blockParentRoot := libcommon.Hash{4, 5, 6}
 	proposerIndex := uint64(789)
-	blob := cltypes.Blob{}
+	blob := &cltypes.Blob{1, 2, 3, 4, 5, 6, 7, 8}
 	kzgCommitment := cltypes.KZGCommitment{7, 8, 9}
 	kzgProof := cltypes.KZGProof{10, 11, 12}
 
@@ -35,8 +36,8 @@ func TestBlobSideCar_EncodeDecodeSSZ(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	decoded := &cltypes.BlobSideCar{}
-	err = decoded.DecodeSSZ(encoded)
+	decoded := &cltypes.BlobSideCar{Blob: &cltypes.Blob{}}
+	err = decoded.DecodeSSZ(encoded, int(clparams.DenebVersion))
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -70,13 +71,13 @@ func TestBlobSideCar_EncodeDecodeSSZ(t *testing.T) {
 func TestSignedBlobSideCar(t *testing.T) {
 	// Create a BlobSideCar to use as the message for SignedBlobSideCar
 	blob := cltypes.Blob{1, 2, 3, 4, 5, 6, 7, 8}
-	blobSideCar := cltypes.BlobSideCar{
+	blobSideCar := &cltypes.BlobSideCar{
 		BlockRoot:       libcommon.Hash{1},
 		Index:           2,
 		Slot:            3,
 		BlockParentRoot: libcommon.Hash{4},
 		ProposerIndex:   5,
-		Blob:            blob,
+		Blob:            &blob,
 		KZGCommitment:   cltypes.KZGCommitment{6},
 		KZGProof:        cltypes.KZGProof{7},
 	}
@@ -93,8 +94,8 @@ func TestSignedBlobSideCar(t *testing.T) {
 	assert.NoError(t, err)
 
 	// Decode the encoded SignedBlobSideCar
-	decoded := cltypes.SignedBlobSideCar{}
-	err = decoded.DecodeSSZ(encoded)
+	decoded := cltypes.SignedBlobSideCar{Message: &cltypes.BlobSideCar{Blob: &cltypes.Blob{}}}
+	err = decoded.DecodeSSZ(encoded, int(clparams.DenebVersion))
 	assert.NoError(t, err)
 
 	// Assert that the decoded SignedBlobSideCar is equal to the original SignedBlobSideCar
@@ -126,7 +127,7 @@ func TestBlobIdentifier_EncodeDecodeSSZ(t *testing.T) {
 
 	// decode from SSZ
 	decoded := &cltypes.BlobIdentifier{}
-	if err := decoded.DecodeSSZ(encoded); err != nil {
+	if err := decoded.DecodeSSZ(encoded, int(clparams.DenebVersion)); err != nil {
 		t.Fatalf("DecodeSSZ failed: %v", err)
 	}