use rust_mcp_sdk::{
macros::{mcp_tool, JsonSchema},
schema::{schema_utils::CallToolError, CallToolResult, TextContent},
};
use serde::{Deserialize, Serialize};
use std::path::Path;
use tokio::fs;
#[mcp_tool(
name = "validate_exit_criteria",
description = "Validate if a document's exit criteria are completed",
idempotent_hint = true,
destructive_hint = false,
open_world_hint = false,
read_only_hint = true
)]
#[derive(Debug, Serialize, Deserialize, JsonSchema)]
pub struct ValidateExitCriteriaTool {
pub project_path: String,
pub document_path: String,
}
impl ValidateExitCriteriaTool {
pub async fn call_tool(&self) -> std::result::Result<CallToolResult, CallToolError> {
let metis_dir = Path::new(&self.project_path);
if !metis_dir.exists() || !metis_dir.is_dir() {
return Err(CallToolError::new(std::io::Error::new(
std::io::ErrorKind::NotFound,
format!(
"Metis workspace not found at {}. Run initialize_project first.",
metis_dir.display()
),
)));
}
let full_document_path = metis_dir.join(&self.document_path);
if !full_document_path.exists() {
return Err(CallToolError::new(std::io::Error::new(
std::io::ErrorKind::NotFound,
format!("Document not found at {}", full_document_path.display()),
)));
}
let content = fs::read_to_string(&full_document_path)
.await
.map_err(|e| CallToolError::new(e))?;
let exit_criteria = self.parse_exit_criteria(&content);
let total_criteria = exit_criteria.len();
let completed_criteria = exit_criteria.iter().filter(|c| c.completed).count();
let all_completed = total_criteria > 0 && completed_criteria == total_criteria;
let response = serde_json::json!({
"all_criteria_met": all_completed,
"total_criteria": total_criteria,
"completed_criteria": completed_criteria,
"completion_percentage": if total_criteria > 0 {
(completed_criteria as f64 / total_criteria as f64 * 100.0).round()
} else {
0.0
},
"document_path": self.document_path,
"exit_criteria": exit_criteria
});
Ok(CallToolResult::text_content(vec![TextContent::from(
serde_json::to_string_pretty(&response).map_err(CallToolError::new)?,
)]))
}
fn parse_exit_criteria(&self, content: &str) -> Vec<ExitCriterion> {
let mut criteria = Vec::new();
let lines = content.lines();
for line in lines {
let trimmed = line.trim();
if trimmed.starts_with("- [") {
if let Some(checkbox_end) = trimmed.find(']') {
if checkbox_end >= 3 {
let checkbox_content = &trimmed[3..checkbox_end];
let completed =
checkbox_content.trim() == "x" || checkbox_content.trim() == "X";
let criterion_text = if trimmed.len() > checkbox_end + 1 {
trimmed[checkbox_end + 1..].trim().to_string()
} else {
"".to_string()
};
if !criterion_text.is_empty() {
criteria.push(ExitCriterion {
text: criterion_text,
completed,
});
}
}
}
}
}
criteria
}
}
#[derive(Debug, Serialize, Deserialize)]
struct ExitCriterion {
text: String,
completed: bool,
}