Function currencyconvert

plugins/currencyrate-plugin/src/main.rs:129–183

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

}

async fn currencyconvert(plugin: Plugin<PluginState>, args: Value) -> Result<Value, anyhow::Error> {
    let (amount, currency) = match args {
        Value::Array(values) => {
            if values.len() > 2 {
                return Err(anyhow!(
                    "Too many arguments: Expected 2 arguments, got {}",
                    values.len()
                ));
            }
            let amount = values
                .first()
                .ok_or_else(|| anyhow!("Missing amount"))?
                .as_f64()
                .ok_or_else(|| anyhow!("amount must be a number"))?;
            let currency = values
                .get(1)
                .ok_or_else(|| anyhow!("Missing currency"))?
                .as_str()
                .ok_or_else(|| anyhow!("currency must be a string"))?
                .to_owned();
            (amount, currency.to_uppercase())
        }
        Value::Object(map) => {
            if map.len() > 2 {
                return Err(anyhow!(
                    "Too many arguments: Expected 2 arguments, got {}",
                    map.len()
                ));
            }
            let amount = map
                .get("amount")
                .ok_or_else(|| anyhow!("Missing amount"))?
                .as_f64()
                .ok_or_else(|| anyhow!("amount must be a number"))?;
            let currency = map
                .get("currency")
                .ok_or_else(|| anyhow!("Missing currency"))?
                .as_str()
                .ok_or_else(|| anyhow!("currency must be a string"))?
                .to_owned();
            (amount, currency.to_uppercase())
        }
        _ => return Err(anyhow!("Arguments must be an array or dictionary")),
    };

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

    match oracle.get_median_rate(&currency).await {
        Ok(rate) => Ok(json!({
            "msat": (amount * MSAT_PER_BTC / rate).round() as u64,
        })),
        Err(e) => Err(anyhow!("Error converting currency: {e}")),
    }
}

async fn currencyrate(plugin: Plugin<PluginState>, args: Value) -> Result<Value, anyhow::Error> {
    let (currency, source) = match args {