pmat 3.15.0

PMAT - Zero-config AI context generation and code quality toolkit (CLI, MCP, HTTP)
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

#![cfg_attr(coverage_nightly, coverage(off))]
//! Agent command handlers for Claude Code integration
//!
//! This module implements handlers for the agent subcommands, providing
//! background daemon management and continuous quality monitoring capabilities.

use crate::agent::{AgentDaemon, DaemonConfig, DaemonManager};
use crate::cli::AgentCommands;
use anyhow::{anyhow, Result};
use std::path::PathBuf;
use std::time::Duration;
use tokio::fs;
use tracing::{error, info, warn};

/// Configuration for starting the agent daemon
#[derive(Debug, Clone)]
struct AgentStartConfig {
    _project_path: PathBuf,
    config_path: Option<PathBuf>,
    working_dir: Option<PathBuf>,
    pid_file: Option<PathBuf>,
    log_file: Option<PathBuf>,
    foreground: bool,
    health_interval: u64,
    max_memory_mb: u64,
    auto_restart: bool,
}

/// Handle agent commands
#[provable_contracts_macros::contract("pmat-core.yaml", equation = "check_compliance")]
pub async fn handle_agent_command(command: AgentCommands) -> Result<()> {
    match command {
        AgentCommands::Start {
            project_path,
            config,
            working_dir,
            pid_file,
            log_file,
            foreground,
            health_interval,
            max_memory_mb,
            no_auto_restart,
        } => {
            let start_config = AgentStartConfig {
                _project_path: project_path,
                config_path: config,
                working_dir,
                pid_file,
                log_file,
                foreground,
                health_interval,
                max_memory_mb,
                auto_restart: !no_auto_restart,
            };
            handle_agent_start(start_config).await
        }
        AgentCommands::Stop {
            pid_file,
            force,
            timeout,
        } => handle_agent_stop(pid_file, force, timeout).await,
        AgentCommands::Status { pid_file, format } => handle_agent_status(pid_file, format).await,
        AgentCommands::Monitor {
            project_path,
            project_id,
            thresholds,
        } => handle_agent_monitor(project_path, project_id, thresholds).await,
        AgentCommands::Unmonitor { project_id } => handle_agent_unmonitor(project_id).await,
        AgentCommands::Health { pid_file, detailed } => {
            handle_agent_health(pid_file, detailed).await
        }
        AgentCommands::Reload { pid_file, config } => handle_agent_reload(pid_file, config).await,
        AgentCommands::QualityGate {
            project,
            file,
            format,
        } => handle_agent_quality_gate(project, file, format).await,
        AgentCommands::McpServer { config, debug } => handle_agent_mcp_server(config, debug).await,
    }
}

// Daemon start/stop/status lifecycle handlers
include!("agent_daemon_lifecycle.rs");

// Monitoring, health, reload, and quality gate handlers
include!("agent_monitoring_handlers.rs");

// MCP server handler and config loading
include!("agent_mcp_server.rs");

// Unit tests
include!("agent_handlers_tests.rs");

// Property-based tests
include!("agent_handlers_property_tests.rs");