edda 0.2.1

Decision memory for coding agents — CLI and TUI
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

use edda_ask::{
    affected_paths_for_hits, ask, format_human, staleness::annotate_hits, AskOptions,
    ConversationHit, TranscriptSearchFn,
};
use edda_ledger::Ledger;
use std::path::Path;

/// `edda ask [query]` — query project decisions, history, and conversations.
pub fn execute(
    repo_root: &Path,
    query: Option<&str>,
    limit: usize,
    json: bool,
    all: bool,
    branch: Option<&str>,
    impact: bool,
) -> anyhow::Result<()> {
    let ledger = Ledger::open(repo_root)?;
    let q = query.unwrap_or("");

    let opts = AskOptions {
        limit,
        include_superseded: all,
        branch: branch.map(|s| s.to_string()),
        impact,
        ..Default::default()
    };

    // Build transcript search callback
    let transcript_cb = build_transcript_callback(repo_root);
    let transcript_ref: Option<&edda_ask::TranscriptSearchFn> =
        transcript_cb.as_ref().map(|f| f.as_ref());

    let mut result = ask(&ledger, q, &opts, transcript_ref)?;

    // EDDA-STALENESS1 q334: annotate decisions whose affected_paths have
    // shifted since the decision was recorded. Query-time derivation; ledger
    // untouched. Best-effort: file-system errors leave staleness=None.
    let decisions_paths = affected_paths_for_hits(&ledger, &result.decisions);
    annotate_hits(&mut result.decisions, &decisions_paths, Some(repo_root));
    let timeline_paths = affected_paths_for_hits(&ledger, &result.timeline);
    annotate_hits(&mut result.timeline, &timeline_paths, Some(repo_root));

    if json {
        println!("{}", serde_json::to_string_pretty(&result)?);
    } else {
        print!("{}", format_human(&result));
    }

    Ok(())
}

/// Build a transcript search callback using Tantivy, if index exists.
fn build_transcript_callback(repo_root: &Path) -> Option<Box<TranscriptSearchFn>> {
    let project_id = edda_store::project_id(repo_root);
    let index_dir = edda_store::project_dir(&project_id)
        .join("search")
        .join("tantivy");

    if !index_dir.exists() {
        return None;
    }

    let index = edda_search_fts::schema::ensure_index(&index_dir).ok()?;
    let pid = project_id.clone();

    Some(Box::new(move |query: &str, limit: usize| {
        let opts = edda_search_fts::search::SearchOptions {
            project_id: Some(&pid),
            doc_type: Some("turn"),
            ..Default::default()
        };
        let results =
            edda_search_fts::search::search(&index, query, &opts, limit).unwrap_or_default();
        results
            .into_iter()
            .map(|r| ConversationHit {
                doc_id: r.doc_id,
                session_id: r.session_id,
                ts: r.ts,
                snippet: r.snippet,
                rank: r.rank,
            })
            .collect()
    }))
}