1#![allow(clippy::disallowed_methods)] use crate::tools::subprocess::run_apr;
8use crate::types::{InputSchema, ToolCallResult, ToolDefinition};
9
10pub const NAME: &str = "apr.qa";
12
13#[must_use]
22pub fn qa_tool_definition() -> ToolDefinition {
23 let input_schema: InputSchema = serde_json::from_str(crate::schemas::APR_QA_SCHEMA).expect(
24 "FALSIFY-MCP-008: apr.qa codegen constant must parse as InputSchema; \
25 regenerate by editing contracts/apr-mcp-tool-schemas-v1.yaml and rebuilding",
26 );
27 ToolDefinition {
28 name: NAME.to_string(),
29 description: crate::schemas::APR_QA_DESCRIPTION.to_string(),
30 input_schema,
31 }
32}
33
34#[must_use]
36pub fn call(args: &serde_json::Value) -> ToolCallResult {
37 let Some(model_path) = args.get("model_path").and_then(|v| v.as_str()) else {
38 return ToolCallResult::error("Missing required argument: model_path");
39 };
40
41 let mut owned: Vec<String> = vec![
42 "qa".to_string(),
43 model_path.to_string(),
44 "--json".to_string(),
45 ];
46
47 if let Some(tps) = args.get("assert_tps").and_then(serde_json::Value::as_f64) {
48 owned.push("--assert-tps".to_string());
49 owned.push(tps.to_string());
50 }
51 if let Some(n) = args.get("max_tokens").and_then(serde_json::Value::as_u64) {
52 owned.push("--max-tokens".to_string());
53 owned.push(n.to_string());
54 }
55 if let Some(n) = args.get("iterations").and_then(serde_json::Value::as_u64) {
56 owned.push("--iterations".to_string());
57 owned.push(n.to_string());
58 }
59
60 let argv: Vec<&str> = owned.iter().map(String::as_str).collect();
61 run_apr(&argv)
62}
63
64pub fn dispatch(
66 args: &serde_json::Value,
67 _cancel: &std::sync::mpsc::Receiver<()>,
68 _sink: Option<&crate::server::NotificationSink>,
69 _token: Option<serde_json::Value>,
70) -> ToolCallResult {
71 call(args)
72}
73
74crate::register_mcp_tool!(
75 name: NAME,
76 definition: qa_tool_definition,
77 dispatch: dispatch,
78);
79
80#[cfg(test)]
81#[allow(clippy::disallowed_methods)]
82mod tests {
83 use super::*;
84
85 #[test]
86 fn definition_has_correct_name_and_required_field() {
87 let def = qa_tool_definition();
88 assert_eq!(def.name, "apr.qa");
89 assert_eq!(def.input_schema.schema_type, "object");
90 assert_eq!(def.input_schema.required, vec!["model_path".to_string()]);
91 for field in ["model_path", "assert_tps", "max_tokens", "iterations"] {
92 assert!(
93 def.input_schema.properties.contains_key(field),
94 "property {field} present"
95 );
96 }
97 }
98
99 #[test]
100 fn missing_model_path_returns_error() {
101 let result = call(&serde_json::json!({}));
102 assert_eq!(result.is_error, Some(true));
103 assert!(result.content[0].text.contains("model_path"));
104 }
105}