Skip to content

Commit 22f7d5c

Browse files
apollo_gateway_config: moving RpcStateReaderConfig out of config.rs (#11540)
1 parent 458f379 commit 22f7d5c

File tree

10 files changed

+55
-47
lines changed

10 files changed

+55
-47
lines changed

crates/apollo_gateway/src/rpc_state_reader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use apollo_gateway_config::config::RpcStateReaderConfig;
1+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
22
use apollo_rpc::CompiledContractClass;
33
use blockifier::execution::contract_class::{
44
CompiledClassV0,

crates/apollo_gateway/src/rpc_state_reader_test.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use apollo_gateway_config::config::RpcStateReaderConfig;
1+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
22
use apollo_rpc::CompiledContractClass;
33
use blockifier::execution::contract_class::RunnableCompiledClass;
44
use blockifier::state::state_api::StateReader;

crates/apollo_gateway_config/src/config.rs

Lines changed: 0 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ use validator::Validate;
2222

2323
use crate::compiler_version::VersionId;
2424

25-
const JSON_RPC_VERSION: &str = "2.0";
2625
const DEFAULT_BUCKET_NAME: &str = "proof-archive";
2726

2827
#[derive(Clone, Debug, Serialize, Deserialize, Validate, PartialEq)]
@@ -202,45 +201,6 @@ impl SerializeConfig for StatelessTransactionValidatorConfig {
202201
}
203202
}
204203

205-
#[derive(Clone, Debug, Serialize, Deserialize, Validate, PartialEq)]
206-
pub struct RpcStateReaderConfig {
207-
pub url: String,
208-
pub json_rpc_version: String,
209-
}
210-
211-
impl RpcStateReaderConfig {
212-
pub fn from_url(url: String) -> Self {
213-
Self { url, ..Default::default() }
214-
}
215-
}
216-
217-
impl Default for RpcStateReaderConfig {
218-
fn default() -> Self {
219-
Self { url: Default::default(), json_rpc_version: JSON_RPC_VERSION.to_string() }
220-
}
221-
}
222-
223-
#[cfg(any(feature = "testing", test))]
224-
impl RpcStateReaderConfig {
225-
pub fn create_for_testing() -> Self {
226-
Self::from_url("http://localhost:8080".to_string())
227-
}
228-
}
229-
230-
impl SerializeConfig for RpcStateReaderConfig {
231-
fn dump(&self) -> BTreeMap<ParamPath, SerializedParam> {
232-
BTreeMap::from_iter([
233-
ser_param("url", &self.url, "The url of the rpc server.", ParamPrivacyInput::Public),
234-
ser_param(
235-
"json_rpc_version",
236-
&self.json_rpc_version,
237-
"The json rpc version.",
238-
ParamPrivacyInput::Public,
239-
),
240-
])
241-
}
242-
}
243-
244204
#[derive(Clone, Debug, Serialize, Deserialize, Validate, PartialEq)]
245205
pub struct StatefulTransactionValidatorConfig {
246206
// If true, ensures the max L2 gas price exceeds (a configurable percentage of) the base gas
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,3 @@
11
pub mod compiler_version;
22
pub mod config;
3+
pub mod rpc_state_reader_config;
Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
use std::collections::BTreeMap;
2+
3+
use apollo_config::dumping::{ser_param, SerializeConfig};
4+
use apollo_config::{ParamPath, ParamPrivacyInput, SerializedParam};
5+
use serde::{Deserialize, Serialize};
6+
use validator::Validate;
7+
8+
const JSON_RPC_VERSION: &str = "2.0";
9+
10+
#[derive(Clone, Debug, Serialize, Deserialize, Validate, PartialEq)]
11+
pub struct RpcStateReaderConfig {
12+
pub url: String,
13+
pub json_rpc_version: String,
14+
}
15+
16+
impl RpcStateReaderConfig {
17+
pub fn from_url(url: String) -> Self {
18+
Self { url, ..Default::default() }
19+
}
20+
}
21+
22+
impl Default for RpcStateReaderConfig {
23+
fn default() -> Self {
24+
Self { url: Default::default(), json_rpc_version: JSON_RPC_VERSION.to_string() }
25+
}
26+
}
27+
28+
#[cfg(any(feature = "testing", test))]
29+
impl RpcStateReaderConfig {
30+
pub fn create_for_testing() -> Self {
31+
Self::from_url("http://localhost:8080".to_string())
32+
}
33+
}
34+
35+
impl SerializeConfig for RpcStateReaderConfig {
36+
fn dump(&self) -> BTreeMap<ParamPath, SerializedParam> {
37+
BTreeMap::from_iter([
38+
ser_param("url", &self.url, "The url of the rpc server.", ParamPrivacyInput::Public),
39+
ser_param(
40+
"json_rpc_version",
41+
&self.json_rpc_version,
42+
"The json rpc version.",
43+
ParamPrivacyInput::Public,
44+
),
45+
])
46+
}
47+
}

crates/blockifier_reexecution/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ pub mod serde_utils;
55
pub mod state_reader;
66
pub mod utils;
77

8-
use apollo_gateway_config::config::RpcStateReaderConfig;
8+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
99
use blockifier::blockifier::config::ContractClassManagerConfig;
1010
use blockifier::blockifier::transaction_executor::TransactionExecutionOutput;
1111
use blockifier::context::BlockContext;

crates/blockifier_reexecution/src/main.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use std::fs;
22
use std::path::Path;
33

4-
use apollo_gateway_config::config::RpcStateReaderConfig;
4+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
55
use blockifier::blockifier::config::ContractClassManagerConfig;
66
use blockifier::state::contract_class_manager::ContractClassManager;
77
use blockifier_reexecution::cli::{

crates/blockifier_reexecution/src/state_reader/rpc_state_reader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ use std::sync::{Arc, Mutex};
55
use apollo_gateway::errors::{serde_err_to_state_err, RPCStateReaderError};
66
use apollo_gateway::rpc_objects::{BlockHeader, BlockId, GetBlockWithTxHashesParams};
77
use apollo_gateway::rpc_state_reader::RpcStateReader as GatewayRpcStateReader;
8-
use apollo_gateway_config::config::RpcStateReaderConfig;
8+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
99
use assert_matches::assert_matches;
1010
use blockifier::abi::constants;
1111
use blockifier::blockifier::config::TransactionExecutorConfig;

crates/blockifier_reexecution/src/state_reader/rpc_state_reader_test.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ use std::sync::{Arc, Mutex};
1414

1515
use apollo_gateway::rpc_objects::BlockId;
1616
use apollo_gateway::rpc_state_reader::RpcStateReader as GatewayRpcStateReader;
17-
use apollo_gateway_config::config::RpcStateReaderConfig;
17+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
1818
use assert_matches::assert_matches;
1919
use blockifier::blockifier::config::ContractClassManagerConfig;
2020
use blockifier::state::contract_class_manager::ContractClassManager;

crates/blockifier_reexecution/src/utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ use std::collections::BTreeMap;
22
use std::env;
33
use std::sync::{Arc, LazyLock};
44

5-
use apollo_gateway_config::config::RpcStateReaderConfig;
5+
use apollo_gateway_config::rpc_state_reader_config::RpcStateReaderConfig;
66
use apollo_rpc_execution::{ETH_FEE_CONTRACT_ADDRESS, STRK_FEE_CONTRACT_ADDRESS};
77
use blockifier::context::{ChainInfo, FeeTokenAddresses};
88
use blockifier::execution::contract_class::{CompiledClassV0, CompiledClassV1};

0 commit comments

Comments
 (0)