Function currencyrate

plugins/currencyrate-plugin/src/main.rs:185–245

(plugin: Plugin<PluginState>, args: Value)

}

async fn currencyrate(plugin: Plugin<PluginState>, args: Value) -> Result<Value, anyhow::Error> {
    let (currency, source) = match args {
        Value::Array(values) => {
            if values.len() > 2 {
                return Err(anyhow!(
                    "Too many arguments: Expected at most 2 arguments, got {}",
                    values.len()
                ));
            }
            let currency = values
                .first()
                .ok_or_else(|| anyhow!("Missing currency"))?
                .as_str()
                .ok_or_else(|| anyhow!("currency must be a string"))?
                .to_uppercase();
            let source = values.get(1).and_then(|v| {
                v.as_str()
                    .map(str::to_owned)
                    .or_else(|| v.as_number().map(std::string::ToString::to_string))
            });
            (currency, source)
        }
        Value::Object(map) => {
            if map.len() > 2 {
                return Err(anyhow!(
                    "Too many arguments: Expected at most 2 arguments, got {}",
                    map.len()
                ));
            }
            let currency = map
                .get("currency")
                .ok_or_else(|| anyhow!("Missing currency"))?
                .as_str()
                .ok_or_else(|| anyhow!("currency must be a string"))?
                .to_uppercase();
            let source = map.get("source").and_then(|v| {
                v.as_str()
                    .map(str::to_owned)
                    .or_else(|| v.as_number().map(std::string::ToString::to_string))
            });
            (currency, source)
        }
        _ => return Err(anyhow!("Arguments must be an array or dictionary")),
    };

    let oracle = plugin.state().oracle.lock().await;
    oracle.currency_requested(&currency).await;

    let rate = match source {
        Some(source_name) => oracle
            .get_source_rate(&currency, &source_name)
            .await
            .map_err(|e| anyhow!("Error getting rate from source: {e}"))?,
        None => oracle
            .get_median_rate(&currency)
            .await
            .map_err(|e| anyhow!("Error getting median rate: {e}"))?,
    };