agent-trace 0.1.0

Git-backed document memory, trace continuity, and permissioned writes for agent workflows
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

use crate::llm::trace_insights::TraceDocument;

/// Unified synthesis interface for trace artifacts (running summary, context, logs, recaps).
pub trait SynthesisEngine: Send + Sync {
    fn summarize_change(&self, path: &str, doc_type: &str, diff: &str) -> Result<String, String>;
    fn synthesize_context(
        &self,
        documents: &[TraceDocument],
        updates: &[String],
    ) -> Result<String, String>;
    fn update_running_summary(
        &self,
        previous: &str,
        events: &str,
        plan: &str,
    ) -> Result<String, String>;
    fn summarize_session(&self, session_id: &str, events: &[String]) -> Result<String, String>;
    fn summarize_event_history(&self, events: &str) -> Result<String, String>;
    fn backend_label(&self) -> &str;
}

/// Mechanical fallback when no remote or Ollama backend is available.
pub struct DegradedBackend;

impl DegradedBackend {
    fn line_stats_summary(path: &str, diff: &str) -> String {
        let added = diff.lines().filter(|l| l.starts_with('+')).count();
        let removed = diff.lines().filter(|l| l.starts_with('-')).count();
        format!("{path}: +{added} lines, -{removed} lines.")
    }
}

impl SynthesisEngine for DegradedBackend {
    fn summarize_change(&self, path: &str, _doc_type: &str, diff: &str) -> Result<String, String> {
        Ok(Self::line_stats_summary(path, diff))
    }

    fn synthesize_context(
        &self,
        documents: &[TraceDocument],
        _updates: &[String],
    ) -> Result<String, String> {
        let mut out =
            String::from("# Project Context\n\n*(Synthesis degraded — configure `agent-trace model setup`)*\n\n## Documents\n\n");
        for doc in documents {
            out.push_str(&format!("- `{}` [{}]\n", doc.path, doc.doc_type));
        }
        Ok(out)
    }

    fn update_running_summary(
        &self,
        _previous: &str,
        events: &str,
        _plan: &str,
    ) -> Result<String, String> {
        let mut out = String::from(
            "# Running Summary\n\n*(Synthesis degraded — configure `agent-trace model setup`)*\n\n## Recent Activity\n\n",
        );
        for line in events.lines().take(15) {
            out.push_str(&format!("- {line}\n"));
        }
        Ok(out)
    }

    fn summarize_session(&self, session_id: &str, events: &[String]) -> Result<String, String> {
        Ok(format!(
            "Session {session_id}: {} event(s) recorded (degraded summary).",
            events.len()
        ))
    }

    fn summarize_event_history(&self, events: &str) -> Result<String, String> {
        let n = events.lines().filter(|l| !l.trim().is_empty()).count();
        Ok(format!(
            "{n} earlier events recorded (degraded summary); see plan.md for phase checklist."
        ))
    }

    fn backend_label(&self) -> &str {
        "degraded"
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::types::DocType;

    #[test]
    fn degraded_summarize_change_counts_lines() {
        let b = DegradedBackend;
        let s = b.summarize_change("a.md", "plan", "+a\n+b\n-c").unwrap();
        assert!(s.contains("+2"));
        assert!(s.contains("-1"));
    }

    #[test]
    fn degraded_context_lists_documents() {
        let b = DegradedBackend;
        let docs = vec![TraceDocument {
            path: "plan.md".into(),
            doc_type: DocType::Plan,
            content_snippet: "goals".into(),
        }];
        let out = b.synthesize_context(&docs, &[]).unwrap();
        assert!(out.contains("plan.md"));
    }
}