Function register_path

plugins/rest-plugin/src/main.rs:210–263

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

}

async fn register_path(
    plugin: Plugin<PluginState>,
    mut args: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    filter_json(&mut args);

    let (path_input, http_method, clnrest_map) = parse_register_path_args(args)?;

    if path_input.eq("/") {
        return Err(anyhow!("Path must not be root"));
    }

    let path = path_input.trim_matches('/');

    if path.is_empty() {
        return Err(anyhow!("Path must not be empty"));
    }
    if path.contains("{*") {
        return Err(anyhow!("Wildcards not supported"));
    }

    let mut dyn_router = plugin.state().dyn_router.lock().unwrap();
    if let Ok(p) = dyn_router.at_mut(path) {
        if p.value.contains_key(&http_method) {
            return Err(anyhow!(
                "Conflicting path '{}' already exists with http_method: {}",
                path,
                http_method,
            ));
        }

        p.value.insert(http_method.clone(), clnrest_map.clone());
    } else {
        let mut new_map = HashMap::new();
        new_map.insert(http_method.clone(), clnrest_map.clone());
        dyn_router.insert(path, new_map)?;
    }

    log::debug!(
        "Registered path: {} with http_method: {} to rpc_method: {} with rune_required:{} \
        and rune_restrictions:{}",
        path,
        http_method,
        clnrest_map.rpc_method,
        clnrest_map.rune_required,
        if let Some(restr) = clnrest_map.rune_restrictions {
            restr.to_string()
        } else {
            "{}".to_owned()
        },
    );

    Ok(json!({}))
}

async fn notification_background_task(io: SocketIo, mut receiver: Receiver<serde_json::Value>) {
    log::debug!("Background task spawned");