fix(en): more correct fees algorithm for external-node

core/lib/types/src/fee_model.rs

@@ -284,6 +284,10 @@ impl FeeParamsV2 {
         self.convert_to_base_token(self.l1_pubdata_price)
     }
 
+    pub fn conversion_ratio(&self) -> BaseTokenConversionRatio {
+        self.conversion_ratio
+    }
+
     /// Converts the fee param to the base token.
     fn convert_to_base_token(&self, price_in_wei: u64) -> u64 {
         let conversion_ratio = BigDecimal::from(self.conversion_ratio.numerator.get())

core/node/fee_model/src/l1_gas_price/main_node_fetcher.rs

@@ -4,7 +4,9 @@ use std::{
 };
 
 use tokio::sync::watch::Receiver;
-use zksync_types::fee_model::FeeParams;
+use zksync_types::fee_model::{
+    BatchFeeInput, FeeModelConfigV1, FeeParams, FeeParamsV1, FeeParamsV2,
+};
 use zksync_web3_decl::{
     client::{DynClient, L2},
     error::ClientRpcContext,
@@ -25,13 +27,15 @@ const SLEEP_INTERVAL: Duration = Duration::from_secs(5);
 pub struct MainNodeFeeParamsFetcher {
     client: Box<DynClient<L2>>,
     main_node_fee_params: RwLock<FeeParams>,
+    main_node_batch_fee_input: RwLock<Option<BatchFeeInput>>,
 }
 
 impl MainNodeFeeParamsFetcher {
     pub fn new(client: Box<DynClient<L2>>) -> Self {
         Self {
             client: client.for_component("fee_params_fetcher"),
             main_node_fee_params: RwLock::new(FeeParams::sensible_v1_default()),
+            main_node_batch_fee_input: RwLock::new(None),
         }
     }
 
@@ -58,6 +62,28 @@ impl MainNodeFeeParamsFetcher {
             };
             *self.main_node_fee_params.write().unwrap() = main_node_fee_params;
 
+            let fetch_result = self
+                .client
+                .get_batch_fee_input()
+                .rpc_context("get_batch_fee_input")
+                .await;
+            let main_node_fee_params = match fetch_result {
+                Ok(price) => price,
+                Err(err) => {
+                    tracing::warn!("Unable to get the batch fee input: {}", err);
+                    // A delay to avoid spamming the main node with requests.
+                    if tokio::time::timeout(SLEEP_INTERVAL, stop_receiver.changed())
+                        .await
+                        .is_ok()
+                    {
+                        break;
+                    }
+                    continue;
+                }
+            };
+            *self.main_node_batch_fee_input.write().unwrap() =
+                Some(BatchFeeInput::PubdataIndependent(main_node_fee_params));
+
             if tokio::time::timeout(SLEEP_INTERVAL, stop_receiver.changed())
                 .await
                 .is_ok()
@@ -73,6 +99,27 @@ impl MainNodeFeeParamsFetcher {
 
 impl BatchFeeModelInputProvider for MainNodeFeeParamsFetcher {
     fn get_fee_model_params(&self) -> FeeParams {
-        *self.main_node_fee_params.read().unwrap()
+        let fee_params = *self.main_node_fee_params.read().unwrap();
+        let batch_fee_input = *self.main_node_batch_fee_input.read().unwrap();
+        if batch_fee_input.is_none() {
+            return fee_params;
+        }
+        let batch_fee_input = batch_fee_input.unwrap();
+        match fee_params {
+            FeeParams::V1(..) => FeeParams::V1(FeeParamsV1 {
+                config: FeeModelConfigV1 {
+                    minimal_l2_gas_price: batch_fee_input.fair_l2_gas_price(),
+                },
+                l1_gas_price: batch_fee_input.l1_gas_price(),
+            }),
+            FeeParams::V2(params) => {
+                return FeeParams::V2(FeeParamsV2::new(
+                    params.config(),
+                    batch_fee_input.l1_gas_price(),
+                    batch_fee_input.fair_pubdata_price(),
+                    params.conversion_ratio(),
+                ));
+            }
+        }
     }
 }