EIP-4844 support

abi/src/main/java/org/web3j/abi/datatypes/Bytes.java

@@ -17,16 +17,16 @@ public class Bytes extends BytesType {
 
     public static final String TYPE_NAME = "bytes";
 
-    protected Bytes(int byteSize, byte[] value) {
+    public Bytes(int byteSize, byte[] value) {
         super(value, TYPE_NAME + value.length);
         if (!isValid(byteSize)) {
             throw new UnsupportedOperationException(
-                    "Input byte array must be in range 0 < M <= 32 and length must match type");
+                    "Input byte array must be in range 0 < M <= 48 and length must match type");
         }
     }
 
     private boolean isValid(int byteSize) {
         int length = getValue().length;
-        return length > 0 && length <= 32 && length == byteSize;
+        return length > 0 && length <= 48 && length == byteSize;
     }
 }

besu/build.gradle

@@ -3,6 +3,10 @@ plugins {
 }
 description 'Besu JSON-RPC API'
 
+repositories {
+    maven { url "https://artifacts.consensys.net/public/maven/maven/" }
+}
+
 dependencies {
     api project(':eea')
     testImplementation project(path: ':core', configuration: 'testArtifacts')

codegen/build.gradle

@@ -1,5 +1,9 @@
 description 'web3j project code generators'
 
+repositories {
+    maven { url "https://artifacts.consensys.net/public/maven/maven/" }
+}
+
 dependencies {
     implementation project(':core'),
             "com.squareup:kotlinpoet:$kotlinPoetVersion",

core/build.gradle

@@ -5,9 +5,12 @@ plugins {
     id 'org.ajoberstar.git-publish'
 }
 
-
 description 'web3j is a lightweight Java library for integration with Ethereum clients'
 
+repositories {
+    maven { url "https://artifacts.consensys.net/public/maven/maven/" }
+}
+
 dependencies {
     api project(':abi'),
             project(':crypto'),

crypto/build.gradle

@@ -4,12 +4,17 @@ plugins {
 
 description 'web3j Ethereum crypto library'
 
+repositories {
+    maven { url "https://artifacts.consensys.net/public/maven/maven/" }
+}
+
 dependencies {
     api project(':abi'),
             project(':rlp'),
             project(':utils'),
             "org.slf4j:slf4j-api:$slf4jVersion",
             "com.fasterxml.jackson.core:jackson-databind:$jacksonVersion"
+    implementation("tech.pegasys:jc-kzg-4844:0.8.0")
 }
 
 configurations { testArtifacts.extendsFrom testRuntime }

crypto/src/main/java/org/web3j/crypto/Blob.java

@@ -0,0 +1,47 @@
+/*
+ * Copyright 2024 Web3 Labs Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package org.web3j.crypto;
+
+import org.web3j.abi.datatypes.Bytes;
+
+public class Blob {
+
+    final Bytes data;
+
+    /**
+     * Create a new Blob.
+     *
+     * @param data that represents the blob in Bytes.
+     */
+    public Blob(final Bytes data) {
+        this.data = data;
+    }
+
+    /**
+     * Create a new Blob.
+     *
+     * @param data that represents the blob in byte[].
+     */
+    public Blob(final byte[] data) {
+        this.data = new Bytes(data.length, data);
+    }
+
+    /**
+     * Get the data of the Blob.
+     *
+     * @return the data.
+     */
+    public Bytes getData() {
+        return data;
+    }
+}

crypto/src/main/java/org/web3j/crypto/BlobUtils.java

@@ -0,0 +1,80 @@
+/*
+ * Copyright 2024 Web3 Labs Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package org.web3j.crypto;
+
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.StandardCopyOption;
+
+import ethereum.ckzg4844.CKZG4844JNI;
+
+import org.web3j.abi.datatypes.Bytes;
+
+public class BlobUtils {
+    public static boolean libraryLoaded = false;
+    private static final byte blobCommitmentVersionKZG = 0x01;
+    private final Blob blobData;
+
+    public BlobUtils(Blob blobData) {
+        if (!libraryLoaded) {
+            throw new RuntimeException(
+                    "Please load CKZG4844JNI Library by running BlobUtils.loadTrustedSetupFromResource()");
+        }
+        this.blobData = blobData;
+    }
+
+    public static void loadTrustedSetupFromResource() {
+        CKZG4844JNI.loadNativeLibrary();
+        try (InputStream resourceStream =
+                BlobUtils.class.getClassLoader().getResourceAsStream("trusted_setup.txt")) {
+            if (resourceStream == null) {
+                throw new IllegalArgumentException("Resource not found");
+            }
+            Path tempFile = Files.createTempFile("trusted_setup", "txt");
+            Files.copy(resourceStream, tempFile, StandardCopyOption.REPLACE_EXISTING);
+            CKZG4844JNI.loadTrustedSetup(tempFile.toString());
+            tempFile.toFile().deleteOnExit(); // Delete temp file when JVM exits
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to load trusted setup from resource", e);
+        }
+        libraryLoaded = true;
+    }
+
+    public Bytes getCommitment() {
+        return new Bytes(48, CKZG4844JNI.blobToKzgCommitment(blobData.data.getValue()));
+    }
+
+    public Bytes getProof(Bytes commitment) {
+        return new Bytes(
+                48,
+                CKZG4844JNI.computeBlobKzgProof(blobData.data.getValue(), commitment.getValue()));
+    }
+
+    public boolean checkProofValidity(Bytes commitment, Bytes proof) {
+        return CKZG4844JNI.verifyBlobKzgProof(
+                blobData.data.getValue(), commitment.getValue(), proof.getValue());
+    }
+
+    public Bytes kzgToVersionedHash(Bytes commitment) {
+        byte[] hash = Hash.sha256(commitment.getValue());
+        hash[0] = blobCommitmentVersionKZG;
+        return new Bytes(32, hash);
+    }
+
+    public static void freeTrustedSetup() {
+        // the current trusted setup should be freed before a new one is loaded
+        CKZG4844JNI.freeTrustedSetup();
+        libraryLoaded = false;
+    }
+}

crypto/src/main/java/org/web3j/crypto/RawTransaction.java

@@ -15,10 +15,12 @@
 import java.math.BigInteger;
 import java.util.List;
 
+import org.web3j.abi.datatypes.Bytes;
 import org.web3j.crypto.transaction.type.ITransaction;
 import org.web3j.crypto.transaction.type.LegacyTransaction;
 import org.web3j.crypto.transaction.type.Transaction1559;
 import org.web3j.crypto.transaction.type.Transaction2930;
+import org.web3j.crypto.transaction.type.Transaction4844;
 import org.web3j.crypto.transaction.type.TransactionType;
 
 /**
@@ -118,6 +120,64 @@ public static RawTransaction createTransaction(
                         maxFeePerGas));
     }
 
+    public static RawTransaction createTransaction(
+            long chainId,
+            BigInteger nonce,
+            BigInteger maxPriorityFeePerGas,
+            BigInteger maxFeePerGas,
+            BigInteger gasLimit,
+            String to,
+            BigInteger value,
+            String data,
+            BigInteger maxFeePerBlobGas,
+            List<Bytes> versionedHashes) {
+
+        return new RawTransaction(
+                Transaction4844.createTransaction(
+                        chainId,
+                        nonce,
+                        maxPriorityFeePerGas,
+                        maxFeePerGas,
+                        gasLimit,
+                        to,
+                        value,
+                        data,
+                        maxFeePerBlobGas,
+                        versionedHashes));
+    }
+
+    public static RawTransaction createTransaction(
+            List<Blob> blobs,
+            List<Bytes> kzgCommitments,
+            List<Bytes> kzgProofs,
+            long chainId,
+            BigInteger nonce,
+            BigInteger maxPriorityFeePerGas,
+            BigInteger maxFeePerGas,
+            BigInteger gasLimit,
+            String to,
+            BigInteger value,
+            String data,
+            BigInteger maxFeePerBlobGas,
+            List<Bytes> versionedHashes) {
+
+        return new RawTransaction(
+                Transaction4844.createTransaction(
+                        blobs,
+                        kzgCommitments,
+                        kzgProofs,
+                        chainId,
+                        nonce,
+                        maxPriorityFeePerGas,
+                        maxFeePerGas,
+                        gasLimit,
+                        to,
+                        value,
+                        data,
+                        maxFeePerBlobGas,
+                        versionedHashes));
+    }
+
     public static RawTransaction createTransaction(
             long chainId,
             BigInteger nonce,