crabtalk 0.0.21

Crabtalk library
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

//! MCP server registry — persisted in `local/settings.toml` under
//! `[mcps.<name>]`.

use super::FsStorage;
use anyhow::Result;
use std::collections::BTreeMap;
use wcore::{McpServerConfig, storage::validate_table_name};

pub(super) fn list_mcps(storage: &FsStorage) -> Result<BTreeMap<String, McpServerConfig>> {
    let mut file = storage.read_settings()?;
    // Fill in `name` from the key for entries hand-edited into the
    // file without one. In-memory only — caller sees normalized
    // values but the file on disk is left as-is.
    for (name, cfg) in file.mcps.iter_mut() {
        if cfg.name.is_empty() {
            cfg.name = name.clone();
        }
    }
    Ok(file.mcps)
}

pub(super) fn load_mcp(storage: &FsStorage, name: &str) -> Result<Option<McpServerConfig>> {
    Ok(storage.read_settings()?.mcps.remove(name).map(|mut cfg| {
        if cfg.name.is_empty() {
            cfg.name = name.to_owned();
        }
        cfg
    }))
}

pub(super) fn upsert_mcp(storage: &FsStorage, config: &McpServerConfig) -> Result<()> {
    validate_table_name("mcp", &config.name)?;
    let mut file = storage.read_settings()?;
    file.mcps.insert(config.name.clone(), config.clone());
    storage.write_settings(&file)
}

pub(super) fn delete_mcp(storage: &FsStorage, name: &str) -> Result<bool> {
    let mut file = storage.read_settings()?;
    let removed = file.mcps.remove(name).is_some();
    if removed {
        storage.write_settings(&file)?;
    }
    Ok(removed)
}