Skip to content

Commit cd85af1

Browse files
committed
chain/ethereum: migrate genesis block fetching call to use alloy in net_identifiers
1 parent 1d5b555 commit cd85af1

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

chain/ethereum/src/ethereum_adapter.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1250,7 +1250,7 @@ impl EthereumAdapterTrait for EthereumAdapter {
12501250
})
12511251
.boxed();
12521252

1253-
let web3 = self.web3.clone();
1253+
let alloy_provider = self.alloy.clone();
12541254
let metrics = self.metrics.clone();
12551255
let provider = self.provider().to_string();
12561256
let retry_log_message = format!(
@@ -1262,20 +1262,20 @@ impl EthereumAdapterTrait for EthereumAdapter {
12621262
.no_limit()
12631263
.timeout_secs(30)
12641264
.run(move || {
1265-
let web3 = web3.cheap_clone();
1265+
let alloy_genesis = alloy_provider.cheap_clone();
12661266
let metrics = metrics.cheap_clone();
12671267
let provider = provider.clone();
12681268
async move {
1269-
web3.eth()
1270-
.block(BlockId::Number(Web3BlockNumber::Number(
1271-
ENV_VARS.genesis_block_number.into(),
1272-
)))
1269+
alloy_genesis
1270+
.get_block_by_number(alloy::rpc::types::BlockNumberOrTag::Number(
1271+
ENV_VARS.genesis_block_number as u64,
1272+
))
12731273
.await
12741274
.map_err(|e| {
12751275
metrics.set_status(ProviderStatus::GenesisFail, &provider);
12761276
e
12771277
})?
1278-
.and_then(|gen_block| gen_block.hash.map(BlockHash::from))
1278+
.map(|gen_block| BlockHash::from(gen_block.header.hash))
12791279
.ok_or_else(|| anyhow!("Ethereum node could not find genesis block"))
12801280
}
12811281
})

0 commit comments

Comments
 (0)