//! Example of querying logs from the Ethereum network.

use alloy::{

primitives::{address, b256},

providers::{Provider, ProviderBuilder},

rpc::types::Filter,

};

use eyre::Result;

#[tokio::main]

async fn main() -> Result<()> {

// Create a provider.

let rpc_url = "https://eth.merkle.io".parse()?;

let provider = ProviderBuilder::new().on_http(rpc_url);

// Get logs from the latest block

let latest_block = provider.get_block_number().await?;

// Create a filter to get all logs from the latest block.

let filter = Filter::new().from_block(latest_block);

// Get all logs from the latest block that match the filter.

let logs = provider.get_logs(&filter).await?;

for log in logs {

println!("{log:?}");

}

// Get all logs from the latest block that match the transfer event signature/topic.

let transfer_event_signature =

b256!("ddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef");

let filter = Filter::new().event_signature(transfer_event_signature).from_block(latest_block);

// You could also use the event name instead of the event signature like so:

// .event("Transfer(address,address,uint256)")

// Get all logs from the latest block that match the filter.

let logs = provider.get_logs(&filter).await?;

for log in logs {

println!("Transfer event: {log:?}");

}

// Get all logs from the latest block emitted by the UNI token address.

let uniswap_token_address = address!("1f9840a85d5aF5bf1D1762F925BDADdC4201F984");

let filter = Filter::new().address(uniswap_token_address).from_block(latest_block);

// Get all logs from the latest block that match the filter.

let logs = provider.get_logs(&filter).await?;

for log in logs {

println!("Uniswap token logs: {log:?}");

}

Ok(())

}