update L1 data fee for curie

bus-mapping/Cargo.toml

@@ -54,4 +54,5 @@ rpc-legacy-tracer = []
 # For the trace obtained from erigon node, refund field is missed
 # and must be rebuild
 fix-refund = ["rpc-legacy-tracer"]
-retrace-tx = []
+retrace-tx = []
+l1_fee_curie = []

bus-mapping/src/circuit_input_builder/transaction.rs

@@ -5,7 +5,7 @@ use crate::{l2_predeployed::l1_gas_price_oracle, Error};
 use eth_types::{
     evm_types::{gas_utils::tx_data_gas_cost, OpcodeId},
     geth_types,
-    geth_types::{get_rlp_unsigned, TxType},
+    geth_types::{get_rlp_signed, get_rlp_unsigned, TxType},
     state_db::{CodeDB, StateDB},
     AccessList, Address, GethExecTrace, Signature, Word, H256,
 };
@@ -204,6 +204,8 @@ pub struct Transaction {
     pub rlp_bytes: Vec<u8>,
     /// RLP bytes for signing
     pub rlp_unsigned_bytes: Vec<u8>,
+    /// RLP bytes for signing
+    pub rlp_signed_bytes: Vec<u8>,
     /// Current values of L1 fee
     pub l1_fee: TxL1Fee,
     /// Committed values of L1 fee
@@ -233,6 +235,7 @@ impl From<&Transaction> for geth_types::Transaction {
             gas_fee_cap: Some(tx.gas_fee_cap),
             gas_tip_cap: Some(tx.gas_tip_cap),
             rlp_unsigned_bytes: tx.rlp_unsigned_bytes.clone(),
+            //rlp_signed_bytes: tx.rlp_signed_bytes.clone(),
             rlp_bytes: tx.rlp_bytes.clone(),
             tx_type: tx.tx_type,
             ..Default::default()
@@ -261,6 +264,7 @@ impl Transaction {
             },
             rlp_bytes: vec![],
             rlp_unsigned_bytes: vec![],
+            rlp_signed_bytes: vec![],
             calls: Vec::new(),
             steps: Vec::new(),
             block_num: Default::default(),
@@ -362,6 +366,7 @@ impl Transaction {
             tx_type,
             rlp_bytes: eth_tx.rlp().to_vec(),
             rlp_unsigned_bytes: get_rlp_unsigned(eth_tx),
+            rlp_signed_bytes: get_rlp_signed(eth_tx),
             nonce: eth_tx.nonce.as_u64(),
             gas: eth_tx.gas.as_u64(),
             gas_price: eth_tx.gas_price.unwrap_or_default(),
@@ -432,9 +437,18 @@ impl Transaction {
 
     /// Calculate L1 fee of this transaction.
     pub fn l1_fee(&self) -> u64 {
-        let tx_data_gas_cost = tx_data_gas_cost(&self.rlp_bytes);
-
-        self.l1_fee.tx_l1_fee(tx_data_gas_cost).0
+        //TODO: check if need to update for curie
+        #[cfg(not(feature = "l1_fee_curie"))]
+        {
+            let tx_data_gas_cost = tx_data_gas_cost(&self.rlp_bytes);
+            self.l1_fee.tx_l1_fee(tx_data_gas_cost, 0).0
+        }
+        #[cfg(feature = "l1_fee_curie")]
+        {
+            // TODO: calculate tx rlp signed length
+            let tx_signed_length = self.rlp_signed_bytes.len();
+            self.l1_fee.tx_l1_fee(0, tx_signed_length as u64).0
+        }
     }
 }
 
@@ -476,19 +490,43 @@ pub struct TxL1Fee {
     pub fee_overhead: u64,
     /// L1 fee scalar
     pub fee_scalar: u64,
+    #[cfg(feature = "l1_fee_curie")]
+    /// L1 blob fee
+    pub l1_blob_basefee: u64,
+    #[cfg(feature = "l1_fee_curie")]
+    /// L1 commit scalar
+    pub commit_scalar: u64,
+    #[cfg(feature = "l1_fee_curie")]
+    /// l1 blob scalar
+    pub blob_scalar: u64,
 }
 
 impl TxL1Fee {
     /// Calculate L1 fee and remainder of transaction.
-    pub fn tx_l1_fee(&self, tx_data_gas_cost: u64) -> (u64, u64) {
+    /// for non curie upgrade case, tx_rlp_signed_len is not used,  set to zero
+    pub fn tx_l1_fee(&self, tx_data_gas_cost: u64, tx_rlp_signed_len: u64) -> (u64, u64) {
         // <https://github.com/scroll-tech/go-ethereum/blob/49192260a177f1b63fc5ea3b872fb904f396260c/rollup/fees/rollup_fee.go#L118>
-        let tx_l1_gas = tx_data_gas_cost + self.fee_overhead + TX_L1_COMMIT_EXTRA_COST;
-        let tx_l1_fee = self.fee_scalar as u128 * self.base_fee as u128 * tx_l1_gas as u128;
-
-        (
-            (tx_l1_fee / TX_L1_FEE_PRECISION as u128) as u64,
-            (tx_l1_fee % TX_L1_FEE_PRECISION as u128) as u64,
-        )
+        // check if the calculation changes for curie upgrade
+        #[cfg(not(feature = "l1_fee_curie"))]
+        {
+            let tx_l1_gas = tx_data_gas_cost + self.fee_overhead + TX_L1_COMMIT_EXTRA_COST;
+            let tx_l1_fee = self.fee_scalar as u128 * self.base_fee as u128 * tx_l1_gas as u128;
+            (
+                (tx_l1_fee / TX_L1_FEE_PRECISION as u128) as u64,
+                (tx_l1_fee % TX_L1_FEE_PRECISION as u128) as u64,
+            )
+        }
+
+        #[cfg(feature = "l1_fee_curie")]
+        {
+            // "commitScalar * l1BaseFee + blobScalar * _data.length * l1BlobBaseFee",
+            let tx_l1_fee = self.commit_scalar as u128 * self.base_fee as u128
+                + self.blob_scalar as u128 * tx_rlp_signed_len as u128 * self.l1_blob_basefee as u128;
+            (
+                (tx_l1_fee / TX_L1_FEE_PRECISION as u128) as u64,
+                (tx_l1_fee % TX_L1_FEE_PRECISION as u128) as u64,
+            )
+        }
     }
 
     fn get_current_values_from_state_db(sdb: &StateDB) -> Self {
@@ -502,11 +540,28 @@ impl TxL1Fee {
                 .1
                 .as_u64()
         });
+        #[cfg(feature = "l1_fee_curie")]
+        let [l1_blob_basefee, commit_scalar, blob_scalar] = [
+            &l1_gas_price_oracle::L1_BLOB_BASEFEE_SLOT,
+            &l1_gas_price_oracle::COMMIT_SCALAR_SLOT,
+            &l1_gas_price_oracle::BLOB_SCALAR_SLOT,
+        ]
+        .map(|slot| {
+            sdb.get_storage(&l1_gas_price_oracle::ADDRESS, slot)
+                .1
+                .as_u64()
+        });
 
         Self {
             base_fee,
             fee_overhead,
             fee_scalar,
+            #[cfg(feature = "l1_fee_curie")]
+            l1_blob_basefee,
+            #[cfg(feature = "l1_fee_curie")]
+            commit_scalar,
+            #[cfg(feature = "l1_fee_curie")]
+            blob_scalar,
         }
     }
 
@@ -522,10 +577,28 @@ impl TxL1Fee {
                 .as_u64()
         });
 
+        #[cfg(feature = "l1_fee_curie")]
+        let [l1_blob_basefee, commit_scalar, blob_scalar] = [
+            &l1_gas_price_oracle::L1_BLOB_BASEFEE_SLOT,
+            &l1_gas_price_oracle::COMMIT_SCALAR_SLOT,
+            &l1_gas_price_oracle::BLOB_SCALAR_SLOT,
+        ]
+        .map(|slot| {
+            sdb.get_committed_storage(&l1_gas_price_oracle::ADDRESS, slot)
+                .1
+                .as_u64()
+        });
+
         Self {
             base_fee,
             fee_overhead,
             fee_scalar,
+            #[cfg(feature = "l1_fee_curie")]
+            l1_blob_basefee,
+            #[cfg(feature = "l1_fee_curie")]
+            commit_scalar,
+            #[cfg(feature = "l1_fee_curie")]
+            blob_scalar,
         }
     }
 }

bus-mapping/src/evm/opcodes/begin_end_tx.rs

@@ -95,7 +95,7 @@ pub fn gen_begin_tx_steps(state: &mut CircuitInputStateRef) -> Result<Vec<ExecSt
             }
         }
     } else {
-        // else, add 3 RW read operations for transaction L1 fee.
+        // else, add 3 ( or 6 after curie) RW read operations for transaction L1 fee.
         gen_tx_l1_fee_ops(state, &mut exec_step)?;
     }
 
@@ -729,7 +729,7 @@ fn write_tx_receipt(
     Ok(())
 }
 
-// Add 3 RW read operations for transaction L1 fee.
+// Add 3(or 6 after curie) RW read operations for transaction L1 fee.
 fn gen_tx_l1_fee_ops(
     state: &mut CircuitInputStateRef,
     exec_step: &mut ExecStep,
@@ -739,11 +739,24 @@ fn gen_tx_l1_fee_ops(
     let base_fee = Word::from(state.tx.l1_fee.base_fee);
     let fee_overhead = Word::from(state.tx.l1_fee.fee_overhead);
     let fee_scalar = Word::from(state.tx.l1_fee.fee_scalar);
+    #[cfg(feature = "l1_fee_curie")]
+    let l1_blob_basefee = Word::from(state.tx.l1_fee.l1_blob_basefee);
+    #[cfg(feature = "l1_fee_curie")]
+    let commit_scalar = Word::from(state.tx.l1_fee.commit_scalar);
+    #[cfg(feature = "l1_fee_curie")]
+    let blob_scalar = Word::from(state.tx.l1_fee.blob_scalar);
 
     let base_fee_committed = Word::from(state.tx.l1_fee_committed.base_fee);
     let fee_overhead_committed = Word::from(state.tx.l1_fee_committed.fee_overhead);
     let fee_scalar_committed = Word::from(state.tx.l1_fee_committed.fee_scalar);
 
+    #[cfg(feature = "l1_fee_curie")]
+    let l1_blob_basefee_committed = Word::from(state.tx.l1_fee_committed.l1_blob_basefee);
+    #[cfg(feature = "l1_fee_curie")]
+    let commit_scalar_committed = Word::from(state.tx.l1_fee_committed.commit_scalar);
+    #[cfg(feature = "l1_fee_curie")]
+    let blob_scalar_committed = Word::from(state.tx.l1_fee_committed.blob_scalar);
+
     state.push_op(
         exec_step,
         RW::READ,
@@ -780,6 +793,48 @@ fn gen_tx_l1_fee_ops(
             fee_scalar_committed,
         ),
     )?;
+
+    // curie operations
+    #[cfg(feature = "l1_fee_curie")]
+    {
+        state.push_op(
+            exec_step,
+            RW::READ,
+            StorageOp::new(
+                *l1_gas_price_oracle::ADDRESS,
+                *l1_gas_price_oracle::L1_BLOB_BASEFEE_SLOT,
+                l1_blob_basefee,
+                l1_blob_basefee,
+                tx_id,
+                l1_blob_basefee_committed,
+            ),
+        )?;
+        state.push_op(
+            exec_step,
+            RW::READ,
+            StorageOp::new(
+                *l1_gas_price_oracle::ADDRESS,
+                *l1_gas_price_oracle::COMMIT_SCALAR_SLOT,
+                commit_scalar,
+                commit_scalar,
+                tx_id,
+                commit_scalar_committed,
+            ),
+        )?;
+        state.push_op(
+            exec_step,
+            RW::READ,
+            StorageOp::new(
+                *l1_gas_price_oracle::ADDRESS,
+                *l1_gas_price_oracle::BLOB_SCALAR_SLOT,
+                blob_scalar,
+                blob_scalar,
+                tx_id,
+                blob_scalar_committed,
+            ),
+        )?;
+    }
+
     Ok(())
 }
 

bus-mapping/src/l2_predeployed.rs

@@ -36,8 +36,11 @@ pub mod l1_gas_price_oracle {
     pub static SCALAR_SLOT: LazyLock<U256> = LazyLock::new(|| U256::from(3));
 
     /// THe following 3 slots plus `BASE_FEE_SLOT` will be used for l1 fee after curie fork
+    /// L1 BlobBaseFee slot in L1GasPriceOracle after Curie fork
     pub static L1_BLOB_BASEFEE_SLOT: LazyLock<U256> = LazyLock::new(|| U256::from(5));
+    /// L1 commitScalar slot in L1GasPriceOracle after Curie fork
     pub static COMMIT_SCALAR_SLOT: LazyLock<U256> = LazyLock::new(|| U256::from(6));
+    /// L1 commitScalar slot in L1GasPriceOracle after Curie forks
     pub static BLOB_SCALAR_SLOT: LazyLock<U256> = LazyLock::new(|| U256::from(7));
     pub static IS_CURIE_SLOT: LazyLock<U256> = LazyLock::new(|| U256::from(8));
     pub static INITIAL_COMMIT_SCALAR: LazyLock<U256> =

eth-types/src/geth_types.rs

@@ -9,7 +9,7 @@ use crate::{
 };
 use ethers_core::types::{
     transaction::eip2718::TypedTransaction, Eip1559TransactionRequest, Eip2930TransactionRequest,
-    NameOrAddress, TransactionRequest, H256,
+    NameOrAddress, Signature, TransactionRequest, H256,
 };
 use halo2curves::{group::ff::PrimeField, secp256k1::Fq};
 use num::Integer;
@@ -158,6 +158,48 @@ pub fn get_rlp_unsigned(tx: &crate::Transaction) -> Vec<u8> {
     }
 }
 
+/// Get the RLP signed bytes
+/// NOTE: currently only used by curie upgrade calculating l1fee
+pub fn get_rlp_signed(tx: &crate::Transaction) -> Vec<u8> {
+    let sig_v = tx.v; // U64 type
+    let signature = Signature {
+        r: tx.r,
+        s: tx.s,
+        v: tx.v.as_u64(),
+    };
+
+    match TxType::get_tx_type(tx) {
+        TxType::Eip155 => {
+            let mut tx: TransactionRequest = tx.into();
+            tx.chain_id = Some(tx.chain_id.unwrap_or_else(|| {
+                let recv_v = TxType::Eip155.get_recovery_id(sig_v.as_u64()) as u64;
+                (sig_v - recv_v - 35) / 2
+            }));
+
+            tx.rlp_signed(&signature).to_vec()
+        }
+        TxType::PreEip155 => {
+            let tx: TransactionRequest = tx.into();
+            tx.rlp_signed(&signature).to_vec()
+        }
+        TxType::Eip1559 => {
+            let tx: Eip1559TransactionRequest = tx.into();
+            let typed_tx: TypedTransaction = tx.into();
+            typed_tx.rlp_signed(&signature).to_vec()
+        }
+        TxType::Eip2930 => {
+            let tx: Eip2930TransactionRequest = tx.into();
+            let typed_tx: TypedTransaction = tx.into();
+            //typed_tx.rlp().to_vec()
+            typed_tx.rlp_signed(&signature).to_vec()
+        }
+        TxType::L1Msg => {
+            // L1 msg does not have signature
+            vec![]
+        }
+    }
+}
+
 /// Definition of all of the data related to an account.
 #[serde_as]
 #[derive(PartialEq, Eq, Debug, Default, Clone, Serialize)]
@@ -289,7 +331,7 @@ pub struct Transaction {
     pub rlp_bytes: Vec<u8>,
     /// RLP unsigned bytes
     pub rlp_unsigned_bytes: Vec<u8>,
-
+    // TODO: add rlp_signed_bytes as well ?
     /// Transaction hash
     pub hash: H256,
 }

zkevm-circuits/Cargo.toml

@@ -71,3 +71,4 @@ debug-annotations = []
 enable-stack = ["bus-mapping/enable-stack"]
 enable-memory = ["bus-mapping/enable-memory"]
 enable-storage = ["bus-mapping/enable-storage"]
+l1_fee_curie = ["bus-mapping/l1_fee_curie"]