feat: conditional cbt l1 updates

core/lib/config/src/configs/base_token_adjuster.rs

@@ -35,6 +35,9 @@ const DEFAULT_PRICE_FETCHING_SLEEP_MS: u64 = 5_000;
 /// Default number of milliseconds to sleep between transaction sending attempts
 const DEFAULT_L1_TX_SENDING_SLEEP_MS: u64 = 30_000;
 
+/// Default number of percent that the quote should change in order for update to be propagated to L1
+const DEFAULT_L1_UPDATE_DEVIATION: u32 = 10;
+
 /// Default maximum acceptable priority fee in gwei to prevent sending transaction with extremely high priority fee.
 const DEFAULT_MAX_ACCEPTABLE_PRIORITY_FEE_IN_GWEI: u64 = 100_000_000_000;
 
@@ -79,6 +82,11 @@ pub struct BaseTokenAdjusterConfig {
     #[serde(default = "BaseTokenAdjusterConfig::default_l1_tx_sending_sleep_ms")]
     pub l1_tx_sending_sleep_ms: u64,
 
+    /// How many percent a quote needs to change in order for update to be propagated to L1.
+    /// Exists to save on gas.
+    #[serde(default = "BaseTokenAdjusterConfig::default_l1_update_deviation")]
+    pub l1_update_deviation: u32,
+
     /// Maximum number of attempts to fetch quote from a remote API before failing over
     #[serde(default = "BaseTokenAdjusterConfig::default_price_fetching_max_attempts")]
     pub price_fetching_max_attempts: u32,
@@ -107,6 +115,7 @@ impl Default for BaseTokenAdjusterConfig {
             l1_receipt_checking_sleep_ms: Self::default_l1_receipt_checking_sleep_ms(),
             l1_tx_sending_max_attempts: Self::default_l1_tx_sending_max_attempts(),
             l1_tx_sending_sleep_ms: Self::default_l1_tx_sending_sleep_ms(),
+            l1_update_deviation: Self::default_l1_update_deviation(),
             price_fetching_sleep_ms: Self::default_price_fetching_sleep_ms(),
             price_fetching_max_attempts: Self::default_price_fetching_max_attempts(),
             halt_on_error: Self::default_halt_on_error(),
@@ -170,6 +179,9 @@ impl BaseTokenAdjusterConfig {
     pub fn default_l1_tx_sending_sleep_ms() -> u64 {
         DEFAULT_L1_TX_SENDING_SLEEP_MS
     }
+    pub fn default_l1_update_deviation() -> u32 {
+        DEFAULT_L1_UPDATE_DEVIATION
+    }
 
     pub fn default_price_fetching_sleep_ms() -> u64 {
         DEFAULT_PRICE_FETCHING_SLEEP_MS

core/lib/config/src/testonly.rs

@@ -1046,6 +1046,7 @@ impl Distribution<configs::base_token_adjuster::BaseTokenAdjusterConfig> for Enc
             l1_receipt_checking_sleep_ms: self.sample(rng),
             l1_tx_sending_max_attempts: self.sample(rng),
             l1_tx_sending_sleep_ms: self.sample(rng),
+            l1_update_deviation: self.sample(rng),
             price_fetching_max_attempts: self.sample(rng),
             price_fetching_sleep_ms: self.sample(rng),
             halt_on_error: self.sample(rng),

core/lib/env_config/src/base_token_adjuster.rs

@@ -28,6 +28,7 @@ mod tests {
             l1_tx_sending_sleep_ms: 30_000,
             price_fetching_max_attempts: 20,
             price_fetching_sleep_ms: 10_000,
+            l1_update_deviation: 20,
             halt_on_error: true,
         }
     }
@@ -45,6 +46,7 @@ mod tests {
             l1_tx_sending_sleep_ms: 30_000,
             price_fetching_max_attempts: 3,
             price_fetching_sleep_ms: 5_000,
+            l1_update_deviation: 10,
             halt_on_error: false,
         }
     }
@@ -62,6 +64,7 @@ mod tests {
             BASE_TOKEN_ADJUSTER_L1_RECEIPT_CHECKING_SLEEP_MS=20000
             BASE_TOKEN_ADJUSTER_L1_TX_SENDING_MAX_ATTEMPTS=10
             BASE_TOKEN_ADJUSTER_L1_TX_SENDING_SLEEP_MS=30000
+            BASE_TOKEN_ADJUSTER_L1_UPDATE_DEVIATION=20
             BASE_TOKEN_ADJUSTER_PRICE_FETCHING_MAX_ATTEMPTS=20
             BASE_TOKEN_ADJUSTER_PRICE_FETCHING_SLEEP_MS=10000
             BASE_TOKEN_ADJUSTER_HALT_ON_ERROR=true
@@ -85,6 +88,7 @@ mod tests {
             "BASE_TOKEN_ADJUSTER_L1_RECEIPT_CHECKING_SLEEP_MS",
             "BASE_TOKEN_ADJUSTER_L1_TX_SENDING_MAX_ATTEMPTS",
             "BASE_TOKEN_ADJUSTER_L1_TX_SENDING_SLEEP_MS",
+            "BASE_TOKEN_ADJUSTER_L1_UPDATE_DEVIATION",
             "BASE_TOKEN_ADJUSTER_PRICE_FETCHING_MAX_ATTEMPTS",
             "BASE_TOKEN_ADJUSTER_PRICE_FETCHING_SLEEP_MS",
             "BASE_TOKEN_ADJUSTER_HALT_ON_ERROR",

core/lib/protobuf_config/src/base_token_adjuster.rs

@@ -42,6 +42,9 @@ impl ProtoRepr for proto::BaseTokenAdjuster {
             l1_tx_sending_sleep_ms: self
                 .l1_tx_sending_sleep_ms
                 .unwrap_or(Self::Type::default_l1_tx_sending_sleep_ms()),
+            l1_update_deviation: self
+                .l1_update_deviation
+                .unwrap_or(Self::Type::default_l1_update_deviation()),
         })
     }
 
@@ -53,6 +56,7 @@ impl ProtoRepr for proto::BaseTokenAdjuster {
             l1_receipt_checking_max_attempts: Some(this.l1_receipt_checking_max_attempts),
             l1_tx_sending_max_attempts: Some(this.l1_tx_sending_max_attempts),
             l1_tx_sending_sleep_ms: Some(this.l1_tx_sending_sleep_ms),
+            l1_update_deviation: Some(this.l1_update_deviation),
             price_fetching_max_attempts: Some(this.price_fetching_max_attempts),
             price_fetching_sleep_ms: Some(this.price_fetching_sleep_ms),
             max_tx_gas: Some(this.max_tx_gas),

core/lib/protobuf_config/src/proto/config/base_token_adjuster.proto

@@ -15,4 +15,5 @@ message BaseTokenAdjuster {
   optional bool halt_on_error = 10;
   optional uint32 price_fetching_max_attempts = 11;
   optional uint64 price_fetching_sleep_ms = 12;
+  optional uint32 l1_update_deviation = 13;
 }

core/node/base_token_adjuster/Cargo.toml

@@ -21,6 +21,7 @@ zksync_eth_client.workspace = true
 zksync_node_fee_model.workspace = true
 zksync_utils.workspace = true
 vise.workspace = true
+bigdecimal.workspace = true
 
 tokio = { workspace = true, features = ["time"] }
 anyhow.workspace = true

core/node/base_token_adjuster/src/base_token_ratio_persister.rs

@@ -1,6 +1,13 @@
-use std::{cmp::max, fmt::Debug, sync::Arc, time::Instant};
+use std::{
+    cmp::max,
+    fmt::Debug,
+    ops::{Div, Mul},
+    sync::{Arc, RwLock},
+    time::Instant,
+};
 
 use anyhow::Context as _;
+use bigdecimal::{BigDecimal, ToPrimitive};
 use tokio::{sync::watch, time::sleep};
 use zksync_config::configs::base_token_adjuster::BaseTokenAdjusterConfig;
 use zksync_dal::{ConnectionPool, Core, CoreDal};
@@ -33,6 +40,7 @@ pub struct BaseTokenRatioPersister {
     base_token_address: Address,
     price_api_client: Arc<dyn PriceAPIClient>,
     l1_params: Option<BaseTokenRatioPersisterL1Params>,
+    last_persisted_l1_ratio: Arc<RwLock<Option<BigDecimal>>>,
 }
 
 impl BaseTokenRatioPersister {
@@ -50,6 +58,7 @@ impl BaseTokenRatioPersister {
             base_token_address,
             price_api_client,
             l1_params,
+            last_persisted_l1_ratio: Arc::new(RwLock::new(None)),
         }
     }
 
@@ -124,6 +133,21 @@ impl BaseTokenRatioPersister {
             return Ok(());
         };
 
+        if let Some(ref prev_ratio) = *self.last_persisted_l1_ratio.read().unwrap() {
+            let current_ratio = BigDecimal::from(new_ratio.numerator.get())
+                .div(BigDecimal::from(new_ratio.denominator.get()));
+            let deviation = (prev_ratio - current_ratio.clone())
+                .abs()
+                .div(prev_ratio.clone())
+                .mul(BigDecimal::from(100))
+                .to_u32()
+                .unwrap();
+
+            if deviation < self.config.l1_update_deviation {
+                return Ok(());
+            }
+        }
+
         let max_attempts = self.config.l1_tx_sending_max_attempts;
         let sleep_duration = self.config.l1_tx_sending_sleep_duration();
         let mut prev_base_fee_per_gas: Option<u64> = None;
@@ -155,6 +179,11 @@ impl BaseTokenRatioPersister {
                     }]
                         .observe(start_time.elapsed());
 
+                    *self.last_persisted_l1_ratio.write().unwrap() = Some(
+                        BigDecimal::from(new_ratio.numerator.get())
+                            .div(BigDecimal::from(new_ratio.denominator.get())),
+                    );
+
                     return Ok(());
                 }
                 Err(err) => {