Merge pull request #101 from availproject/feat/usd-fee-span

feat: Adds USD fee correlation span

Author: moraesjeremias

script/bin/operator.rs

@@ -1,4 +1,5 @@
 use alloy::network::{ReceiptResponse, TransactionBuilder};
+use alloy::primitives::utils::Unit;
 use alloy::signers::local::PrivateKeySigner;
 use alloy::{
     network::Network,
@@ -8,13 +9,13 @@ use alloy::{
 };
 use futures::future::{join_all, try_join_all};
 use std::env;
-use std::ops::Mul;
+use std::ops::{Div, Mul};
 use std::str::FromStr;
 use std::time::Duration;
 use std::{cmp::min, collections::HashMap};
 
 use anyhow::{Context, Result};
-use services::input::{HeaderRangeRequestData, RpcDataFetcher};
+use services::input::{fetch_eth_to_usd_rate, HeaderRangeRequestData, RpcDataFetcher};
 use services::Timeout;
 use sp1_sdk::network::FulfillmentStrategy;
 use sp1_sdk::EnvProver;
@@ -814,11 +815,17 @@ where
                 return Err(anyhow::anyhow!("Transaction reverted!"));
             }
 
-            let gas_used: u128 = receipt.gas_used() as u128;
+            let wei = Unit::ETHER.wei_const().to::<u128>() as f64;
+            let effective_gas_price: f64 = receipt.effective_gas_price() as f64;
+            let effective_gas_used = effective_gas_price.mul(receipt.gas_used() as f64).div(wei);
+
+            let eth_to_usd_rate = fetch_eth_to_usd_rate().await;
+            let usd_fee = effective_gas_used.mul(eth_to_usd_rate.from_asset.to_asset);
 
             info!(
                 message = "Transaction gas fee used",
-                gas_fee = gas_used.mul(receipt.effective_gas_price()),
+                gas_fee = effective_gas_used,
+                usd_fee = usd_fee,
                 tx_hash = %receipt.transaction_hash()
             );
 

services/src/input.rs

@@ -1,4 +1,6 @@
-use crate::types::{EncodedFinalityProof, FinalityProof, VectorXJustificationApiResponse};
+use crate::types::{
+    CoingekoApiResponse, EncodedFinalityProof, FinalityProof, VectorXJustificationApiResponse,
+};
 use alloy::primitives::{B256, B512};
 use anyhow::Result;
 use codec::{Compact, Decode, Encode};
@@ -543,6 +545,19 @@ impl RpcDataFetcher {
     }
 }
 
+pub async fn fetch_eth_to_usd_rate() -> CoingekoApiResponse {
+    let coingeko_url =
+        env::var("COINGEKO_URL").unwrap_or("https://api.coingecko.com/api".to_string());
+    let coingeko_api_key = env::var("COINGEKO_API_KEY").expect("Missing COINGEKO_API_KEY env");
+    let price_endpoint = format!(
+        "{}/v3/simple/price?ids={}&vs_currencies={}&x_cg_api_key={}",
+        coingeko_url, "ethereum", "usd", coingeko_api_key
+    );
+    let response = reqwest::get(price_endpoint).await.unwrap();
+
+    response.json::<CoingekoApiResponse>().await.unwrap()
+}
+
 /// Converts GrandpaJustification and validator set to CircuitJustification.
 pub fn convert_justification_and_valset_to_circuit(
     justification: GrandpaJustification,

services/src/types.rs

@@ -32,6 +32,18 @@ pub struct VectorXJustificationApiResponse {
     pub error: Option<String>,
 }
 
+#[derive(Debug, Deserialize)]
+pub struct CoingekoApiResponse {
+    #[serde(alias = "ethereum")]
+    pub from_asset: EthToUSDRate,
+}
+
+#[derive(Debug, Deserialize)]
+pub struct EthToUSDRate {
+    #[serde(alias = "usd")]
+    pub to_asset: f64,
+}
+
 #[cfg(test)]
 mod tests {
     use super::VectorXJustificationApiResponse;