warmplane 0.16.0

Local control plane that keeps MCP sessions warm with compact capability/resource/prompt facades.
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

// Rust guideline compliant 2026-08-15

//! Core metadata, actor message types, error categories, and shared state aliases for daemon workers.

use serde_json::Value;
use std::{collections::HashMap, sync::Arc};
use tokio::sync::{mpsc, oneshot, RwLock};

use crate::config::ServerConfig;

/// Messages dispatched across worker threads to upstream MCP servers.
pub enum ServerMsg {
    /// Execute a tool call.
    CallTool {
        /// Tool name on upstream server.
        name: String,
        /// Execution parameters.
        params: Value,
        /// Multi-roundtrip client input responses.
        input_responses: Option<std::collections::BTreeMap<String, Value>>,
        /// Multi-roundtrip request state.
        request_state: Option<String>,
        /// Response reply channel.
        reply: oneshot::Sender<Result<Value, UpstreamCallError>>,
    },
    /// Read a resource URI.
    ReadResource {
        /// Resource URI identifier.
        uri: String,
        /// Multi-roundtrip client input responses.
        input_responses: Option<std::collections::BTreeMap<String, Value>>,
        /// Multi-roundtrip request state.
        request_state: Option<String>,
        /// Response reply channel.
        reply: oneshot::Sender<Result<Value, UpstreamCallError>>,
    },
    /// Render a prompt template.
    GetPrompt {
        /// Prompt identifier name.
        name: String,
        /// Arguments map for prompt rendering.
        arguments: Option<serde_json::Map<String, Value>>,
        /// Multi-roundtrip client input responses.
        input_responses: Option<std::collections::BTreeMap<String, Value>>,
        /// Multi-roundtrip request state.
        request_state: Option<String>,
        /// Response reply channel.
        reply: oneshot::Sender<Result<Value, UpstreamCallError>>,
    },
}

/// Upstream MCP execution error categories.
#[derive(Debug, Clone)]
pub enum UpstreamCallError {
    /// Upstream error message string.
    Upstream(String),
    /// Operation timed out.
    Timeout,
}

/// Metadata describing a registered capability tool.
#[derive(Clone, Debug)]
pub struct CapabilityMeta {
    /// Server identifier providing this capability.
    pub server: String,
    /// Tool name on upstream server.
    pub tool: String,
    /// Short summary description.
    pub summary: String,
    /// Detailed description.
    pub description: String,
    /// JSON schema for tool arguments.
    pub input_schema: Value,
    /// Metadata tags.
    pub tags: Vec<String>,
    /// Usage examples.
    pub examples: Vec<Value>,
}

/// Metadata describing a registered resource.
#[derive(Clone, Debug)]
pub struct ResourceMeta {
    /// Server identifier providing this resource.
    pub server: String,
    /// Resource URI identifier.
    pub uri: String,
    /// Resource human-readable name.
    pub name: String,
    /// Optional description.
    pub description: Option<String>,
    /// Optional MIME type string.
    pub mime_type: Option<String>,
    /// Metadata tags.
    pub tags: Vec<String>,
}

/// Metadata describing a registered prompt template.
#[derive(Clone, Debug)]
pub struct PromptMeta {
    /// Server identifier providing this prompt.
    pub server: String,
    /// Prompt identifier name.
    pub name: String,
    /// Optional human-readable title.
    pub title: Option<String>,
    /// Optional description.
    pub description: Option<String>,
    /// List of expected prompt arguments.
    pub arguments: Vec<Value>,
    /// Metadata tags.
    pub tags: Vec<String>,
}

/// Thread-safe map of active upstream server sender mailboxes.
pub type SharedServers = Arc<RwLock<HashMap<String, mpsc::Sender<ServerMsg>>>>;
/// Thread-safe map of registered capabilities.
pub type SharedCapabilities = Arc<RwLock<HashMap<String, CapabilityMeta>>>;
/// Thread-safe map of registered resources.
pub type SharedResources = Arc<RwLock<HashMap<String, ResourceMeta>>>;
/// Thread-safe map of registered prompt templates.
pub type SharedPrompts = Arc<RwLock<HashMap<String, PromptMeta>>>;
/// Thread-safe active security policy.
pub type SharedPolicy = Arc<RwLock<crate::daemon::policy::Policy>>;
/// Thread-safe active catalog SHA256 version string.
pub type SharedCatalogVersion = Arc<RwLock<String>>;
/// Thread-safe map of active server configurations.
pub type SharedServerConfigs = Arc<RwLock<HashMap<String, ServerConfig>>>;
/// Thread-safe map of server status envelopes.
pub type SharedServerStatuses = Arc<RwLock<HashMap<String, Value>>>;