diff --git a/validator/client/propose.go b/validator/client/propose.go index 1975eb9dba47..90f375a30084 100644 --- a/validator/client/propose.go +++ b/validator/client/propose.go @@ -124,16 +124,16 @@ func (v *validator) ProposeBlock(ctx context.Context, slot primitives.Slot, pubK var genericSignedBlock *ethpb.GenericSignedBeaconBlock if blk.Version() >= version.Deneb && !blk.IsBlinded() { signedBlobs := make([]*ethpb.SignedBlobSidecar, len(b.GetDeneb().Blobs)) - for _, blob := range b.GetDeneb().Blobs { + for i, blob := range b.GetDeneb().Blobs { blobSig, err := v.signBlob(ctx, blob, pubKey) if err != nil { log.WithError(err).Error("Failed to sign blob") return } - signedBlobs = append(signedBlobs, ðpb.SignedBlobSidecar{ + signedBlobs[i] = ðpb.SignedBlobSidecar{ Message: blob, Signature: blobSig, - }) + } } denebBlock, err := blk.PbDenebBlock() if err != nil { diff --git a/validator/client/propose_test.go b/validator/client/propose_test.go index a8b8f7c54cfb..ce22f36864ea 100644 --- a/validator/client/propose_test.go +++ b/validator/client/propose_test.go @@ -673,6 +673,9 @@ func testProposeBlock(t *testing.T, graffiti []byte) { ).DoAndReturn(func(ctx context.Context, block *ethpb.GenericSignedBeaconBlock) (*ethpb.ProposeResponse, error) { sentBlock, err = blocktest.NewSignedBeaconBlockFromGeneric(block) assert.NoError(t, err, "Unexpected error unwrapping block") + if tt.version == version.Deneb { + require.Equal(t, 2, len(block.GetDeneb().Blobs)) + } return ðpb.ProposeResponse{BlockRoot: make([]byte, 32)}, nil }) @@ -680,6 +683,7 @@ func testProposeBlock(t *testing.T, graffiti []byte) { g := sentBlock.Block().Body().Graffiti() assert.Equal(t, string(validator.graffiti), string(g[:])) require.LogsContain(t, hook, "Submitted new block") + }) } }