awaken-server 0.6.0

Multi-protocol HTTP server with SSE, mailbox, and protocol adapters for Awaken
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

use std::sync::Arc;

use awaken_ext_mcp::{McpPromptEntry, McpResourceEntry, McpServerStatusSnapshot};

use super::{ConfigRuntimeError, ConfigRuntimeManager};

pub struct McpServerInventory {
    pub status: McpServerStatusSnapshot,
    pub prompts: Vec<McpPromptEntry>,
    pub resources: Vec<McpResourceEntry>,
}

impl ConfigRuntimeManager {
    pub async fn mcp_server_inventory(
        &self,
        server_name: &str,
    ) -> Result<Option<McpServerInventory>, ConfigRuntimeError> {
        let handle = {
            let guard = self.active_mcp_registry.lock();
            guard.as_ref().map(|active| Arc::clone(&active.handle))
        };
        let Some(handle) = handle else {
            return Ok(None);
        };
        let Some(status) = handle.server_status(server_name).await else {
            return Ok(None);
        };
        let prompts = handle.server_prompts(server_name).await?;
        let resources = handle.server_resources(server_name).await?;
        Ok(Some(McpServerInventory {
            status,
            prompts,
            resources,
        }))
    }
}