ainl-failure-learning 0.1.2

Failure recall, FTS-backed search, and prevention prompt snippets for AINL (only ainl-* + contracts at boundaries)
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
82
83
84
85

//! Format a compact “do not repeat” block from [`super::search::FailureRecallHit`] rows.

use crate::search::FailureRecallHit;

/// Build markdown-flavored text for injection into a system or recall segment.
#[must_use]
pub fn format_failure_prevention_block(title: &str, hits: &[FailureRecallHit]) -> String {
    if hits.is_empty() {
        return String::new();
    }
    let mut s = String::new();
    s.push_str("### ");
    s.push_str(title);
    s.push_str("\n\n");
    s.push_str("Recent similar failures in memory (do not repeat):\n\n");
    for (i, h) in hits.iter().take(8).enumerate() {
        s.push_str(&format!("{}. ", i + 1));
        if let Some(t) = &h.tool_name {
            s.push('`');
            s.push_str(t);
            s.push_str("` ");
        }
        s.push_str(&h.message);
        s.push_str(" _(source: ");
        s.push_str(&h.source);
        if let (Some(ns), Some(st)) = (&h.source_namespace, &h.source_tool) {
            s.push_str("; `");
            s.push_str(ns);
            s.push_str("` / `");
            s.push_str(st);
            s.push('`');
        } else if let Some(ns) = &h.source_namespace {
            s.push_str("; namespace `");
            s.push_str(ns);
            s.push('`');
        } else if let Some(st) = &h.source_tool {
            s.push_str("; tool `");
            s.push_str(st);
            s.push('`');
        }
        s.push_str(")_\n");
    }
    s
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::search::FailureRecallHit;
    use uuid::Uuid;

    #[test]
    fn format_includes_message_and_source() {
        let hits = vec![FailureRecallHit {
            id: Uuid::nil(),
            source: "loop_guard:block".into(),
            message: "repeated tool".into(),
            tool_name: Some("x".into()),
            source_namespace: None,
            source_tool: None,
            score: 1.0,
        }];
        let t = format_failure_prevention_block("Caution", &hits);
        assert!(t.contains("Caution"));
        assert!(t.contains("repeated tool"));
        assert!(t.contains("loop_guard"));
    }

    #[test]
    fn format_includes_structured_mcp_source_when_set() {
        let hits = vec![FailureRecallHit {
            id: Uuid::nil(),
            source: "agent_loop:tool".into(),
            message: "validate failed".into(),
            tool_name: Some("mcp_ainl_ainl_validate".into()),
            source_namespace: Some("ainl".into()),
            source_tool: Some("mcp_ainl_ainl_validate".into()),
            score: 1.0,
        }];
        let t = format_failure_prevention_block("Caution", &hits);
        assert!(t.contains("validate failed"));
        assert!(t.contains("`ainl`"));
        assert!(t.contains("mcp_ainl_ainl_validate"));
    }
}