routa-core 0.15.1

Routa.js core domain — models, stores, protocols, and JSON-RPC (transport-agnostic)
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

//! RPC methods for skill management.
//!
//! Methods:
//! - `skills.list`   — list all discovered skills
//! - `skills.get`    — get a single skill by name
//! - `skills.reload` — re-discover skills from the filesystem

use serde::{Deserialize, Serialize};

use crate::rpc::error::RpcError;
use crate::skills::SkillDefinition;
use crate::state::AppState;

// ---------------------------------------------------------------------------
// skills.list
// ---------------------------------------------------------------------------

#[derive(Debug, Serialize)]
pub struct ListResult {
    pub skills: Vec<SkillDefinition>,
}

pub async fn list(state: &AppState) -> Result<ListResult, RpcError> {
    let skills = state.skill_registry.list_skills();
    Ok(ListResult { skills })
}

// ---------------------------------------------------------------------------
// skills.get
// ---------------------------------------------------------------------------

#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct GetParams {
    pub name: String,
}

pub async fn get(state: &AppState, params: GetParams) -> Result<SkillDefinition, RpcError> {
    state
        .skill_registry
        .get_skill(&params.name)
        .ok_or_else(|| RpcError::NotFound(format!("Skill {} not found", params.name)))
}

// ---------------------------------------------------------------------------
// skills.reload
// ---------------------------------------------------------------------------

#[derive(Debug, Serialize)]
pub struct ReloadResult {
    pub reloaded: bool,
    pub skills: Vec<SkillDefinition>,
}

pub async fn reload(state: &AppState) -> Result<ReloadResult, RpcError> {
    let cwd = std::env::current_dir()
        .map(|p| p.to_string_lossy().to_string())
        .unwrap_or_else(|_| ".".to_string());
    state.skill_registry.reload(&cwd);
    let skills = state.skill_registry.list_skills();
    Ok(ReloadResult {
        reloaded: true,
        skills,
    })
}