feat: Minimal External API Fetcher

.github/workflows/ci-core-reusable.yml

@@ -135,7 +135,7 @@ jobs:
         base_token: ["Eth", "Custom"]
         deployment_mode: ["Rollup", "Validium"]
     env:
-      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,commitment_generator,vm_runner_protective_reads,vm_runner_bwip,da_dispatcher,base_token_ratio_persister${{ matrix.consensus && ',consensus' || '' }}"
+      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,commitment_generator,vm_runner_protective_reads,vm_runner_bwip,da_dispatcher${{ matrix.consensus && ',consensus' || '' }}${{ matrix.base_token == 'Custom' && ',base_token_ratio_persister' || '' }}"
 
     runs-on: [matterlabs-ci-runner]
     steps:
@@ -309,7 +309,7 @@ jobs:
     runs-on: [matterlabs-ci-runner]
 
     env:
-      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,commitment_generator,vm_runner_protective_reads,vm_runner_bwip,da_dispatcher,base_token_ratio_persister${{ matrix.consensus && ',consensus' || '' }}"
+      SERVER_COMPONENTS: "api,tree,eth,state_keeper,housekeeper,commitment_generator,vm_runner_protective_reads,vm_runner_bwip,da_dispatcher${{ matrix.consensus && ',consensus' || '' }}${{ matrix.base_token == 'Custom' && ',base_token_ratio_persister' || '' }}"
       EXT_NODE_FLAGS: "${{ matrix.consensus && '-- --enable-consensus' || '' }}"
 
     steps:

Cargo.toml

@@ -179,6 +179,7 @@ tracing-subscriber = "0.3"
 tracing-opentelemetry = "0.21.0"
 url = "2"
 web3 = "0.19.0"
+fraction = "0.15.3"
 
 # Proc-macro
 syn = "2.0"

core/bin/zksync_server/src/main.rs

@@ -12,9 +12,10 @@ use zksync_config::{
         fri_prover_group::FriProverGroupConfig,
         house_keeper::HouseKeeperConfig,
         BasicWitnessInputProducerConfig, ContractsConfig, DatabaseSecrets,
-        FriProofCompressorConfig, FriProverConfig, FriProverGatewayConfig,
-        FriWitnessGeneratorConfig, FriWitnessVectorGeneratorConfig, L1Secrets, ObservabilityConfig,
-        PrometheusConfig, ProofDataHandlerConfig, ProtectiveReadsWriterConfig, Secrets,
+        ExternalPriceApiClientConfig, FriProofCompressorConfig, FriProverConfig,
+        FriProverGatewayConfig, FriWitnessGeneratorConfig, FriWitnessVectorGeneratorConfig,
+        L1Secrets, ObservabilityConfig, PrometheusConfig, ProofDataHandlerConfig,
+        ProtectiveReadsWriterConfig, Secrets,
     },
     ApiConfig, BaseTokenAdjusterConfig, ContractVerifierConfig, DADispatcherConfig, DBConfig,
     EthConfig, EthWatchConfig, GasAdjusterConfig, GenesisConfig, ObjectStoreConfig, PostgresConfig,
@@ -43,7 +44,7 @@ struct Cli {
     /// Comma-separated list of components to launch.
     #[arg(
         long,
-        default_value = "api,tree,eth,state_keeper,housekeeper,tee_verifier_input_producer,commitment_generator,da_dispatcher,base_token_ratio_persister"
+        default_value = "api,tree,eth,state_keeper,housekeeper,tee_verifier_input_producer,commitment_generator,da_dispatcher"
     )]
     components: ComponentsToRun,
     /// Path to the yaml config. If set, it will be used instead of env vars.
@@ -230,5 +231,6 @@ fn load_env_config() -> anyhow::Result<TempConfigStore> {
         commitment_generator: None,
         pruning: None,
         snapshot_recovery: None,
+        external_price_api_client_config: ExternalPriceApiClientConfig::from_env().ok(),
     })
 }

core/bin/zksync_server/src/node_builder.rs

@@ -21,8 +21,12 @@ use zksync_node_api_server::{
 };
 use zksync_node_framework::{
     implementations::layers::{
-        base_token_ratio_persister::BaseTokenRatioPersisterLayer,
-        base_token_ratio_provider::BaseTokenRatioProviderLayer,
+        base_token::{
+            base_token_ratio_persister::BaseTokenRatioPersisterLayer,
+            base_token_ratio_provider::BaseTokenRatioProviderLayer,
+            coingecko_client::CoingeckoClientLayer, forced_price_client::ForcedPriceClientLayer,
+            no_op_external_price_api_client::NoOpExternalPriceApiClientLayer,
+        },
         circuit_breaker_checker::CircuitBreakerCheckerLayer,
         commitment_generator::CommitmentGeneratorLayer,
         consensus::MainNodeConsensusLayer,
@@ -516,6 +520,29 @@ impl MainNodeBuilder {
         Ok(self)
     }
 
+    fn add_external_api_client_layer(mut self) -> anyhow::Result<Self> {
+        let config = try_load_config!(self.configs.external_price_api_client_config);
+        match config.source.as_str() {
+            CoingeckoClientLayer::CLIENT_NAME => {
+                self.node.add_layer(CoingeckoClientLayer::new(config));
+            }
+            NoOpExternalPriceApiClientLayer::CLIENT_NAME => {
+                self.node.add_layer(NoOpExternalPriceApiClientLayer);
+            }
+            ForcedPriceClientLayer::CLIENT_NAME => {
+                self.node.add_layer(ForcedPriceClientLayer::new(config));
+            }
+            _ => {
+                anyhow::bail!(
+                    "Unknown external price API client source: {}",
+                    config.source
+                );
+            }
+        }
+
+        Ok(self)
+    }
+
     fn add_vm_runner_bwip_layer(mut self) -> anyhow::Result<Self> {
         let basic_witness_input_producer_config =
             try_load_config!(self.configs.basic_witness_input_producer_config);
@@ -529,8 +556,9 @@ impl MainNodeBuilder {
 
     fn add_base_token_ratio_persister_layer(mut self) -> anyhow::Result<Self> {
         let config = try_load_config!(self.configs.base_token_adjuster);
+        let contracts_config = self.contracts_config.clone();
         self.node
-            .add_layer(BaseTokenRatioPersisterLayer::new(config));
+            .add_layer(BaseTokenRatioPersisterLayer::new(config, contracts_config));
 
         Ok(self)
     }
@@ -669,7 +697,9 @@ impl MainNodeBuilder {
                     self = self.add_vm_runner_protective_reads_layer()?;
                 }
                 Component::BaseTokenRatioPersister => {
-                    self = self.add_base_token_ratio_persister_layer()?;
+                    self = self
+                        .add_external_api_client_layer()?
+                        .add_base_token_ratio_persister_layer()?;
                 }
                 Component::VmRunnerBwip => {
                     self = self.add_vm_runner_bwip_layer()?;

core/lib/config/Cargo.toml

@@ -15,6 +15,7 @@ zksync_crypto_primitives.workspace = true
 zksync_consensus_utils.workspace = true
 zksync_concurrency.workspace = true
 
+url.workspace = true
 anyhow.workspace = true
 rand.workspace = true
 secrecy.workspace = true