validate versioned hashes (#5546)

* wip - added versioned hashes checking Signed-off-by: Sally MacFarlane <macfarla.github@gmail.com> * optional handling, updated test mocks Signed-off-by: Sally MacFarlane <macfarla.github@gmail.com> --------- Signed-off-by: Sally MacFarlane <macfarla.github@gmail.com> Signed-off-by: Justin Florentine <justin+github@florentine.us> Co-authored-by: Justin Florentine <justin+github@florentine.us>
hyperledger · Jun 14, 2023 · aae8900 · aae8900
1 parent 8d9880a
commit aae8900
Show file tree

Hide file tree

Showing 3 changed files with 54 additions and 1 deletion.
diff --git a/...perledger/besu/ethereum/api/jsonrpc/internal/methods/engine/AbstractEngineNewPayload.java b/...perledger/besu/ethereum/api/jsonrpc/internal/methods/engine/AbstractEngineNewPayload.java
@@ -63,6 +63,7 @@
 import io.vertx.core.Vertx;
 import io.vertx.core.json.Json;
 import org.apache.tuweni.bytes.Bytes;
+import org.apache.tuweni.bytes.Bytes32;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -194,6 +195,50 @@ public JsonRpcResponse syncResponse(final JsonRpcRequestContext requestContext)
           "Block already present in bad block manager.");
     }
 
+    final List<Bytes32> transactionVersionedHashes = new ArrayList<>();
+    // get versioned hashes, in order, from all blob tx
+    transactions.stream()
+        .filter(tx -> tx.getBlobCount() > 0)
+        .forEachOrdered(
+            tx ->
+                transactionVersionedHashes.addAll(
+                    tx.getVersionedHashes().get().stream()
+                        .map(vh -> vh.toBytes())
+                        .collect(toList())));
+    // and compare with expected versioned hashes param
+    final Optional<List<Bytes32>> maybeVersionedHashes =
+        Optional.ofNullable(blockParam.getVersionedHashes());
+    // check if one is empty
+    if (maybeVersionedHashes.isPresent() && transactionVersionedHashes.isEmpty()) {
+      return respondWithInvalid(
+          reqId,
+          blockParam,
+          null,
+          INVALID,
+          "Versioned hashes from blob transactions (empty) do not match expected values");
+    }
+    if (maybeVersionedHashes.isEmpty() && !transactionVersionedHashes.isEmpty()) {
+      return respondWithInvalid(
+          reqId,
+          blockParam,
+          null,
+          INVALID,
+          "Versioned hashes from blob transactions do not match expected values (empty)");
+    }
+    if (maybeVersionedHashes.isEmpty() && transactionVersionedHashes.isEmpty()) {
+      LOG.trace("Versioned hashes from blob tx (empty) matches expected values (empty)");
+    } else {
+      // otherwise, check list contents
+      if (!maybeVersionedHashes.get().equals(transactionVersionedHashes)) {
+        return respondWithInvalid(
+            reqId,
+            blockParam,
+            null,
+            INVALID,
+            "Versioned hashes from blob transactions do not match expected values (empty)");
+      }
+    }
+
     final Optional<BlockHeader> maybeParentHeader =
         protocolContext.getBlockchain().getBlockHeader(blockParam.getParentHash());
     if (maybeParentHeader.isPresent()

diff --git a/...org/hyperledger/besu/ethereum/api/jsonrpc/internal/parameters/EnginePayloadParameter.java b/...org/hyperledger/besu/ethereum/api/jsonrpc/internal/parameters/EnginePayloadParameter.java
@@ -47,6 +47,7 @@ public class EnginePayloadParameter {
   private final LogsBloomFilter logsBloom;
   private final List<String> transactions;
   private final List<WithdrawalParameter> withdrawals;
+  private final List<Bytes32> versionedHashes;
   private final long dataGasUsed;
   private final String excessDataGas;
 
@@ -68,7 +69,8 @@ public EnginePayloadParameter(
       @JsonProperty("transactions") final List<String> transactions,
       @JsonProperty("withdrawals") final List<WithdrawalParameter> withdrawals,
       @JsonProperty("dataGasUsed") final UnsignedLongParameter dataGasUsed,
-      @JsonProperty("excessDataGas") final String excessDataGas) {
+      @JsonProperty("excessDataGas") final String excessDataGas,
+      @JsonProperty("versionedHashes") final List<Bytes32> versionedHashes) {
     this.blockHash = blockHash;
     this.parentHash = parentHash;
     this.feeRecipient = feeRecipient;
@@ -86,6 +88,7 @@ public EnginePayloadParameter(
     this.withdrawals = withdrawals;
     this.dataGasUsed = dataGasUsed.getValue();
     this.excessDataGas = excessDataGas;
+    this.versionedHashes = versionedHashes;
   }
 
   public Hash getBlockHash() {
@@ -155,4 +158,8 @@ public long getDataGasUsed() {
   public String getExcessDataGas() {
     return excessDataGas;
   }
+
+  public List<Bytes32> getVersionedHashes() {
+    return versionedHashes;
+  }
 }
diff --git a/...edger/besu/ethereum/api/jsonrpc/internal/methods/engine/AbstractEngineNewPayloadTest.java b/...edger/besu/ethereum/api/jsonrpc/internal/methods/engine/AbstractEngineNewPayloadTest.java
@@ -508,6 +508,7 @@ private EnginePayloadParameter mockPayload(
         header.getPrevRandao().map(Bytes32::toHexString).orElse("0x0"),
         txs,
         withdrawals,
+        null,
         new UnsignedLongParameter(header.getDataGasUsed()),
         header.getExcessDataGas().map(DataGas::toHexString).orElse(null));
   }