@@ -32,7 +32,6 @@ import (
32
32
"github.com/ethereum/go-ethereum/core/stateless"
33
33
"github.com/ethereum/go-ethereum/core/types"
34
34
"github.com/ethereum/go-ethereum/core/vm"
35
- "github.com/ethereum/go-ethereum/crypto/kzg4844"
36
35
"github.com/ethereum/go-ethereum/eth"
37
36
"github.com/ethereum/go-ethereum/eth/ethconfig"
38
37
"github.com/ethereum/go-ethereum/internal/version"
@@ -509,38 +508,15 @@ func (api *ConsensusAPI) GetPayloadV3(payloadID engine.PayloadID) (*engine.Execu
509
508
if ! payloadID .Is (engine .PayloadV3 ) {
510
509
return nil , engine .UnsupportedFork
511
510
}
512
- envelope , err := api .getPayload (payloadID , false )
513
- if err != nil {
514
- return nil , err
515
- }
516
- envelope .BlobsBundle .CellProofs = nil
517
- return envelope , nil
511
+ return api .getPayload (payloadID , false )
518
512
}
519
513
520
514
// GetPayloadV4 returns a cached payload by id.
521
515
func (api * ConsensusAPI ) GetPayloadV4 (payloadID engine.PayloadID ) (* engine.ExecutionPayloadEnvelope , error ) {
522
516
if ! payloadID .Is (engine .PayloadV3 ) {
523
517
return nil , engine .UnsupportedFork
524
518
}
525
- envelope , err := api .getPayload (payloadID , false )
526
- if err != nil {
527
- return nil , err
528
- }
529
- envelope .BlobsBundle .CellProofs = nil
530
- return envelope , nil
531
- }
532
-
533
- // GetPayloadV4 returns a cached payload by id.
534
- func (api * ConsensusAPI ) GetPayloadV5 (payloadID engine.PayloadID ) (* engine.ExecutionPayloadEnvelope , error ) {
535
- if ! payloadID .Is (engine .PayloadV3 ) {
536
- return nil , engine .UnsupportedFork
537
- }
538
- envelope , err := api .getPayload (payloadID , false )
539
- if err != nil {
540
- return nil , err
541
- }
542
- envelope .BlobsBundle .Proofs = nil
543
- return envelope , nil
519
+ return api .getPayload (payloadID , false )
544
520
}
545
521
546
522
func (api * ConsensusAPI ) getPayload (payloadID engine.PayloadID , full bool ) (* engine.ExecutionPayloadEnvelope , error ) {
@@ -571,33 +547,6 @@ func (api *ConsensusAPI) GetBlobsV1(hashes []common.Hash) ([]*engine.BlobAndProo
571
547
return res , nil
572
548
}
573
549
574
- // GetBlobsV2 returns a blob from the transaction pool.
575
- func (api * ConsensusAPI ) GetBlobsV2 (hashes []common.Hash ) ([]* engine.BlobAndProofV2 , error ) {
576
- if len (hashes ) > 128 {
577
- return nil , engine .TooLargeRequest .With (fmt .Errorf ("requested blob count too large: %v" , len (hashes )))
578
- }
579
- res := make ([]* engine.BlobAndProofV2 , len (hashes ))
580
-
581
- blobs , _ := api .eth .TxPool ().GetBlobs (hashes )
582
- for i := 0 ; i < len (blobs ); i ++ {
583
- if blobs [i ] != nil {
584
- cellProofs , err := kzg4844 .ComputeCells (blobs [i ])
585
- if err != nil {
586
- return nil , err
587
- }
588
- var proofs []hexutil.Bytes
589
- for _ , proof := range cellProofs {
590
- proofs = append (proofs , hexutil .Bytes (proof [:]))
591
- }
592
- res [i ] = & engine.BlobAndProofV2 {
593
- Blob : (* blobs [i ])[:],
594
- CellProofs : proofs ,
595
- }
596
- }
597
- }
598
- return res , nil
599
- }
600
-
601
550
// NewPayloadV1 creates an Eth1 block, inserts it in the chain, and returns the status of the chain.
602
551
func (api * ConsensusAPI ) NewPayloadV1 (params engine.ExecutableData ) (engine.PayloadStatusV1 , error ) {
603
552
if params .Withdrawals != nil {
0 commit comments