eth-prices 0.0.3

A library for fetching Ethereum prices.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

use alloy::{primitives::map::HashMap, providers::DynProvider};
use figment::{
    Figment,
    providers::{Format, Toml},
};
use serde::Deserialize;

use crate::{
    Result,
    error::EthPricesError,
    quoter::{
        QuoterInstance,
        erc4626::{ERC4626Config, ERC4626Quoter},
        fixed::FixedQuoter,
        uniswap_v2::{UniswapV2Config, UniswapV2Quoter},
        uniswap_v3::{UniswapV3Quoter, factory::UniswapV3Config},
    },
};

#[derive(Debug, Deserialize, PartialEq)]
pub struct Config {
    pub chains: HashMap<String, ChainConfig>,
}

#[derive(Debug, Deserialize, PartialEq)]
pub struct ChainConfig {
    pub chain_id: u64,
    pub rpc_url: String,
    pub tokens: Vec<TokenConfig>,
    pub quoters: QuotersConfig,
}

#[derive(Debug, Deserialize, PartialEq)]
pub struct QuotersConfig {
    pub fixed: Vec<FixedQuoter>,
    pub uniswap_v2: Option<UniswapV2Config>,
    pub uniswap_v3: Option<UniswapV3Config>,
    pub erc4626: Vec<ERC4626Config>,
}

impl QuotersConfig {
    pub async fn all(&self, provider: &DynProvider) -> Result<Vec<QuoterInstance>> {
        let mut quoters = Vec::new();
        for tracker in &self.fixed {
            if tracker.fixed_rate <= 0.0 {
                return Err(EthPricesError::InvalidConfiguration(format!(
                    "Fixed rate for {} to {} must be > 0.0",
                    tracker.token_in, tracker.token_out
                )));
            }
            quoters.push(QuoterInstance::Fixed(tracker.clone()));
        }

        if let Some(uniswap_v2_config) = &self.uniswap_v2 {
            for uni_quoters in uniswap_v2_config.pairs.iter() {
                let quoter = UniswapV2Quoter::from_selector(provider, uni_quoters.clone()).await?;
                quoters.push(QuoterInstance::UniswapV2(quoter));
            }
        }

        if let Some(uniswap_v3_config) = &self.uniswap_v3 {
            for uni_quoters in uniswap_v3_config.pools.iter() {
                let quoter = UniswapV3Quoter::from_selector(provider, uni_quoters.clone()).await?;
                quoters.push(QuoterInstance::UniswapV3(quoter));
            }
        }

        for erc4626_config in &self.erc4626 {
            let quoter = ERC4626Quoter::new(erc4626_config.vault_address, provider).await?;
            quoters.push(QuoterInstance::ERC4626(quoter));
        }

        Ok(quoters)
    }
}

#[derive(Debug, Deserialize, PartialEq)]
pub struct TokenConfig {
    pub address: String,
    pub slug: Option<String>,
    pub decimals: u8,
}

impl Config {
    pub async fn load(path: &str) -> Result<Self> {
        let figment = Figment::new().merge(Toml::file(path));
        figment
            .extract::<Config>()
            .map_err(|e| EthPricesError::ConfigError(e.to_string()))
    }
}