eth/protocols: add WithdrawalsHash check when handleNewBlock

eth/handler.go

@@ -320,22 +320,6 @@ func newHandler(config *handlerConfig) (*handler, error) {
 	}
 
 	broadcastBlockWithCheck := func(block *types.Block, propagate bool) {
-		// All the block fetcher activities should be disabled
-		// after the transition. Print the warning log.
-		if h.merger.PoSFinalized() {
-			log.Warn("Unexpected validation activity", "hash", block.Hash(), "number", block.Number())
-			return
-		}
-		// Reject all the PoS style headers in the first place. No matter
-		// the chain has finished the transition or not, the PoS headers
-		// should only come from the trusted consensus layer instead of
-		// p2p network.
-		if beacon, ok := h.chain.Engine().(*beacon.Beacon); ok {
-			if beacon.IsPoSHeader(block.Header()) {
-				log.Warn("unexpected post-merge header")
-				return
-			}
-		}
 		if propagate {
 			if err := core.IsDataAvailable(h.chain, block); err != nil {
 				log.Error("Propagating block with invalid sidecars", "number", block.Number(), "hash", block.Hash(), "err", err)

eth/protocols/eth/handlers.go

@@ -321,6 +321,11 @@ func handleNewBlock(backend Backend, msg Decoder, peer *Peer) error {
 		log.Warn("Propagated block has invalid body", "have", hash, "exp", ann.Block.TxHash())
 		return nil // TODO(karalabe): return error eventually, but wait a few releases
 	}
+	if !(ann.Block.Header().WithdrawalsHash == nil && ann.Block.Withdrawals() == nil) &&
+		!(ann.Block.Header().EmptyWithdrawalsHash() && len(ann.Block.Withdrawals()) == 0) {
+		return nil
+	}
+
 	ann.Block.ReceivedAt = msg.Time()
 	ann.Block.ReceivedFrom = peer