Skip to content

Commit f25137f

Browse files
apollo_l1_gas_price_types: rename get_eth_to_fri_rate to get_price on provider client
1 parent 1002ae4 commit f25137f

4 files changed

Lines changed: 10 additions & 13 deletions

File tree

crates/apollo_consensus_orchestrator/src/sequencer_consensus_context_test.rs

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -642,7 +642,7 @@ async fn gas_price_limits(#[case] maximum: bool) {
642642
0
643643
};
644644
let mut l1_gas_price_provider = MockL1GasPriceProviderClient::new();
645-
l1_gas_price_provider.expect_get_eth_to_fri_rate().returning(|_| Ok(ETH_TO_FRI_RATE));
645+
l1_gas_price_provider.expect_get_price().returning(|_| Ok(ETH_TO_FRI_RATE));
646646
l1_gas_price_provider.expect_get_price_info().returning(move |_| {
647647
Ok(PriceInfo {
648648
base_fee_per_gas: GasPrice(measured_price),
@@ -835,7 +835,7 @@ async fn oracle_fails_on_startup(#[case] l1_oracle_failure: bool) {
835835

836836
if l1_oracle_failure {
837837
let mut l1_prices_oracle_client = MockL1GasPriceProviderClient::new();
838-
l1_prices_oracle_client.expect_get_eth_to_fri_rate().returning(|_| Ok(ETH_TO_FRI_RATE));
838+
l1_prices_oracle_client.expect_get_price().returning(|_| Ok(ETH_TO_FRI_RATE));
839839
l1_prices_oracle_client.expect_get_price_info().times(1).return_const(Err(
840840
L1GasPriceClientError::L1GasPriceProviderError(
841841
// random error, these parameters don't mean anything
@@ -851,7 +851,7 @@ async fn oracle_fails_on_startup(#[case] l1_oracle_failure: bool) {
851851
blob_fee: GasPrice(TEMP_ETH_BLOB_GAS_FEE_IN_WEI),
852852
})
853853
});
854-
l1_prices_oracle_client.expect_get_eth_to_fri_rate().times(1).return_once(|_| {
854+
l1_prices_oracle_client.expect_get_price().times(1).return_once(|_| {
855855
Err(L1GasPriceClientError::PriceOracleClientError(
856856
PriceOracleClientError::MissingFieldError("".to_string(), "".to_string()),
857857
))
@@ -923,7 +923,7 @@ async fn oracle_fails_on_second_block(#[case] l1_oracle_failure: bool) {
923923
// set the oracle to succeed on first block and fail on second
924924
if l1_oracle_failure {
925925
let mut l1_prices_oracle_client = MockL1GasPriceProviderClient::new();
926-
l1_prices_oracle_client.expect_get_eth_to_fri_rate().returning(|_| Ok(ETH_TO_FRI_RATE));
926+
l1_prices_oracle_client.expect_get_price().returning(|_| Ok(ETH_TO_FRI_RATE));
927927
l1_prices_oracle_client.expect_get_price_info().times(1).return_const(Ok(PriceInfo {
928928
base_fee_per_gas: GasPrice(TEMP_ETH_GAS_FEE_IN_WEI),
929929
blob_fee: GasPrice(TEMP_ETH_BLOB_GAS_FEE_IN_WEI),
@@ -945,12 +945,9 @@ async fn oracle_fails_on_second_block(#[case] l1_oracle_failure: bool) {
945945
})
946946
});
947947
// Set the eth_to_fri_rate to succeed on first block and fail on second.
948-
l1_prices_oracle_client
949-
.expect_get_eth_to_fri_rate()
950-
.times(1)
951-
.return_once(|_| Ok(ETH_TO_FRI_RATE));
948+
l1_prices_oracle_client.expect_get_price().times(1).return_once(|_| Ok(ETH_TO_FRI_RATE));
952949
// Set the eth_to_fri_rate to fail on second block.
953-
l1_prices_oracle_client.expect_get_eth_to_fri_rate().times(1).return_once(|_| {
950+
l1_prices_oracle_client.expect_get_price().times(1).return_once(|_| {
954951
Err(L1GasPriceClientError::PriceOracleClientError(
955952
PriceOracleClientError::MissingFieldError("".to_string(), "".to_string()),
956953
))

crates/apollo_consensus_orchestrator/src/test_utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,7 @@ impl TestDeps {
318318
base_fee_per_gas: GasPrice(TEMP_ETH_GAS_FEE_IN_WEI),
319319
blob_fee: GasPrice(TEMP_ETH_BLOB_GAS_FEE_IN_WEI),
320320
}));
321-
self.l1_gas_price_provider.expect_get_eth_to_fri_rate().return_const(Ok(ETH_TO_FRI_RATE));
321+
self.l1_gas_price_provider.expect_get_price().return_const(Ok(ETH_TO_FRI_RATE));
322322
}
323323

324324
pub(crate) fn setup_default_batcher_get_block_hash(&mut self) {

crates/apollo_consensus_orchestrator/src/utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ pub(crate) async fn get_l1_prices_in_fri_and_wei_and_conversion_rate(
145145

146146
// Get the eth to fri rate from the oracle, and the L1 gas price (in wei) from the provider.
147147
let (eth_to_fri_rate, price_info) = tokio::join!(
148-
l1_gas_price_provider_client.get_eth_to_fri_rate(timestamp),
148+
l1_gas_price_provider_client.get_price(timestamp),
149149
l1_gas_price_provider_client.get_price_info(BlockTimestamp(timestamp))
150150
);
151151
if price_info.is_err() {

crates/apollo_l1_gas_price_types/src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ pub trait L1GasPriceProviderClient: Send + Sync {
9999
timestamp: BlockTimestamp,
100100
) -> L1GasPriceProviderClientResult<PriceInfo>;
101101

102-
async fn get_eth_to_fri_rate(&self, timestamp: u64) -> L1GasPriceProviderClientResult<u128>;
102+
async fn get_price(&self, timestamp: u64) -> L1GasPriceProviderClientResult<u128>;
103103
}
104104

105105
#[cfg_attr(any(feature = "testing", test), automock)]
@@ -157,7 +157,7 @@ where
157157
)
158158
}
159159
#[instrument(skip(self))]
160-
async fn get_eth_to_fri_rate(&self, timestamp: u64) -> L1GasPriceProviderClientResult<u128> {
160+
async fn get_price(&self, timestamp: u64) -> L1GasPriceProviderClientResult<u128> {
161161
let request = L1GasPriceRequest::GetEthToFriRate(timestamp);
162162
handle_all_response_variants!(
163163
self,

0 commit comments

Comments
 (0)