Method get_rate

plugins/currencyrate-plugin/src/oracle.rs:66–134

(&self, client: &Client, currency: &str)

    }

    async fn get_rate(&self, client: &Client, currency: &str) -> Result<f64, anyhow::Error> {
        let now = Instant::now();

        let currency_lc = currency.to_lowercase();
        let currency = currency.to_uppercase();
        let url = self.url(&currency_lc, &currency);

        let resp: Value = client
            .get(&url)
            .send()
            .await
            .map_err(|e| anyhow!("Failed to request url {url} caused by: {:?}", e.source()))?
            .json()
            .await
            .map_err(|e| {
                anyhow!(
                    "Failed to decode response body from {url}, caused by: {:?}",
                    e.source()
                )
            })?;

        let reply_members = self.reply_members(&currency_lc, &currency);

        let mut current = &mut resp.clone();
        for member in reply_members {
            if let Ok(pos) = member.parse::<usize>() {
                current = current.get_mut(pos).ok_or(anyhow!(
                    "Positional member `{}` not found in {} response: {}",
                    member,
                    self.name(),
                    resp
                ))?;
            } else {
                current = current.get_mut(&member).ok_or(anyhow!(
                    "Member `{}` not found in {} response: {}",
                    member,
                    self.name(),
                    resp
                ))?;
            }
        }
        let price = match current {
            Value::Number(number) => number
                .as_f64()
                .ok_or(anyhow!("Json number price could not be converted to float"))?,
            Value::String(string) => string
                .parse::<f64>()
                .map_err(|e| anyhow!("Price string could not be converted to float: {e}"))?,
            _ => return Err(anyhow!("Price is invalid json type")),
        };

        if price == 0.0 {
            log::warn!("{} returned 0.0 as price for {}", self.name, currency);
            return Err(anyhow!(
                "{} returned 0.0 as price for {}",
                self.name,
                currency
            ));