#![allow(clippy::disallowed_methods)]
use crate::tools::args::{self, try_arg};
use crate::tools::subprocess::run_apr;
use crate::types::{InputSchema, ToolCallResult, ToolDefinition};
pub const NAME: &str = "apr.trace";
#[must_use]
pub fn trace_tool_definition() -> ToolDefinition {
let input_schema: InputSchema = serde_json::from_str(crate::schemas::APR_TRACE_SCHEMA).expect(
"FALSIFY-MCP-008: apr.trace codegen constant must parse as InputSchema; \
regenerate by editing contracts/apr-mcp-tool-schemas-v1.yaml and rebuilding",
);
ToolDefinition {
name: NAME.to_string(),
description: crate::schemas::APR_TRACE_DESCRIPTION.to_string(),
input_schema,
}
}
pub fn build_argv(args: &serde_json::Value) -> Result<Vec<String>, String> {
let model_path = args::required_str(args, "model_path")?;
let mut owned: Vec<String> = vec![
"trace".to_string(),
model_path.to_string(),
"--json".to_string(),
];
if let Some(pat) = args::opt_str(args, "layer")? {
if !pat.is_empty() {
owned.push("--layer".to_string());
owned.push(pat.to_string());
}
}
if let Some(ref_path) = args::opt_str(args, "reference")? {
if !ref_path.is_empty() {
owned.push("--reference".to_string());
owned.push(ref_path.to_string());
}
}
Ok(owned)
}
#[must_use]
pub fn call(args: &serde_json::Value) -> ToolCallResult {
let owned = try_arg!(build_argv(args));
let argv: Vec<&str> = owned.iter().map(String::as_str).collect();
run_apr(&argv)
}
pub fn dispatch(
args: &serde_json::Value,
_cancel: &std::sync::mpsc::Receiver<()>,
_sink: Option<&crate::server::NotificationSink>,
_token: Option<serde_json::Value>,
) -> ToolCallResult {
call(args)
}
crate::register_mcp_tool!(
name: NAME,
definition: trace_tool_definition,
dispatch: dispatch,
);
#[cfg(test)]
#[allow(clippy::disallowed_methods)]
mod tests {
use super::*;
#[test]
fn definition_has_correct_name_and_required_field() {
let def = trace_tool_definition();
assert_eq!(def.name, "apr.trace");
assert_eq!(def.input_schema.schema_type, "object");
assert_eq!(def.input_schema.required, vec!["model_path".to_string()]);
for field in ["model_path", "layer"] {
assert!(
def.input_schema.properties.contains_key(field),
"property {field} present"
);
}
assert!(
!def.input_schema.properties.contains_key("reference"),
"`reference` is not implemented and must not be advertised"
);
}
#[test]
fn missing_model_path_returns_error() {
let result = call(&serde_json::json!({}));
assert_eq!(result.is_error, Some(true));
assert!(result.content[0].text.contains("model_path"));
}
#[test]
fn integer_layer_and_reference_are_errors_not_dropped_flags() {
let result = call(&serde_json::json!({ "model_path": "m.gguf", "layer": 7 }));
assert_eq!(result.is_error, Some(true));
assert!(result.content[0].text.contains("layer"));
let result = call(&serde_json::json!({ "model_path": "m.gguf", "reference": 42 }));
assert_eq!(result.is_error, Some(true));
assert!(result.content[0].text.contains("reference"));
}
#[test]
fn string_layer_and_reference_reach_the_cli() {
let argv = build_argv(&serde_json::json!({
"model_path": "m.gguf",
"layer": "blk.7",
"reference": "ref.gguf"
}))
.expect("strings are usable");
assert_eq!(
argv,
vec![
"trace",
"m.gguf",
"--json",
"--layer",
"blk.7",
"--reference",
"ref.gguf"
]
);
}
#[test]
fn non_string_layer_is_rejected() {
let result = call(&serde_json::json!({
"model_path": "/nonexistent/model.gguf",
"layer": 3,
}));
assert_eq!(result.is_error, Some(true));
assert!(result.content[0].text.contains("Invalid layer"));
}
}