forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

compute hashes from commitment

Browse source
This commit is contained in:
Sina Mahmoodi 2024-01-26 13:51:02 +01:00
parent 96dcc9eae8
commit dbfe2be321
1 changed files with 9 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
eth/catalyst/simulated_beacon.go
View file

@ -18,8 +18,8 @@ package catalyst
import ( import (
"crypto/rand" "crypto/rand"
"crypto/sha256"
"errors" "errors"
"fmt"
"math/big" "math/big"
"sync" "sync"
"time" "time"
@ -27,6 +27,7 @@ import (
"github.com/ethereum/go-ethereum/beacon/engine" "github.com/ethereum/go-ethereum/beacon/engine"
"github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/core/types" "github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/crypto/kzg4844"
"github.com/ethereum/go-ethereum/eth" "github.com/ethereum/go-ethereum/eth"
"github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/node" "github.com/ethereum/go-ethereum/node"
@ -192,15 +193,15 @@ func (c *SimulatedBeacon) sealBlock(withdrawals []*types.Withdrawal, timestamp u
// Mark the payload as canon // Mark the payload as canon
if isCancun { if isCancun {
txes, err := decodeTransactions(payload.Transactions)
if err != nil {
return err
}
blobHashes := make([]common.Hash, 0) blobHashes := make([]common.Hash, 0)
for _, tx := range txes { if envelope.BlobsBundle != nil {
blobHashes = append(blobHashes, tx.BlobHashes()...) hasher := sha256.New()
for _, commit := range envelope.BlobsBundle.Commitments {
c := kzg4844.Commitment(commit[:])
blobHashes = append(blobHashes, kzg4844.CalcBlobHashV1(hasher, &c))
}
} }
if _, err = c.engineAPI.NewPayloadV3(*payload, []common.Hash{}, &common.Hash{}); err != nil { if _, err = c.engineAPI.NewPayloadV3(*payload, blobHashes, &common.Hash{}); err != nil {
return err return err
} }
} else { } else {
@ -319,15 +320,3 @@ func RegisterSimulatedBeaconAPIs(stack *node.Node, sim *SimulatedBeacon) {
}, },
}) })
} }
func decodeTransactions(enc [][]byte) ([]*types.Transaction, error) {
var txs = make([]*types.Transaction, len(enc))
for i, encTx := range enc {
var tx types.Transaction
if err := tx.UnmarshalBinary(encTx); err != nil {
return nil, fmt.Errorf("invalid transaction %d: %v", i, err)
}
txs[i] = &tx
}
return txs, nil
}