systemprompt-mcp 0.1.18

Core MCP (Model Context Protocol) functionality for systemprompt.io OS
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

use super::LifecycleManager;
use crate::McpServerConfig;
use crate::services::monitoring::health::{HealthCheckResult, HealthStatus, perform_health_check};
use crate::services::process::ProcessManager;
use anyhow::Result;

pub async fn check_server_health(
    manager: &LifecycleManager,
    config: &McpServerConfig,
) -> Result<bool> {
    if !is_process_running(manager, config).await? {
        return Ok(false);
    }

    let health_result = perform_health_check(config).await?;
    let is_healthy = matches!(
        health_result.status,
        HealthStatus::Healthy | HealthStatus::Degraded
    );

    if is_healthy {
        log_healthy_status(config, &health_result);
    } else {
        mark_service_error(manager, config, &health_result).await?;
    }

    Ok(is_healthy)
}

async fn is_process_running(manager: &LifecycleManager, config: &McpServerConfig) -> Result<bool> {
    let Some(pid) = ProcessManager::find_pid_by_port(config.port)? else {
        manager
            .database()
            .update_service_status(&config.name, "stopped")
            .await?;
        return Ok(false);
    };

    if !ProcessManager::is_running(pid) {
        manager
            .database()
            .update_service_status(&config.name, "stopped")
            .await?;
        return Ok(false);
    }

    Ok(true)
}

async fn mark_service_error(
    manager: &LifecycleManager,
    config: &McpServerConfig,
    health_result: &HealthCheckResult,
) -> Result<()> {
    manager
        .database()
        .update_service_status(&config.name, "error")
        .await?;

    if let Some(ref error) = health_result.details.error_message {
        tracing::warn!(
            service = %config.name,
            status = %health_result.status.as_str(),
            error = %error,
            "Service health check warning"
        );
    }

    Ok(())
}

fn log_healthy_status(config: &McpServerConfig, health_result: &HealthCheckResult) {
    if health_result.details.tools_available > 0 {
        tracing::debug!(
            service = %config.name,
            tools = health_result.details.tools_available,
            latency_ms = health_result.latency_ms,
            "Service health validated"
        );
    }
}