theway-daemon 0.1.27

theway daemon — the single agent-runtime kernel (bin `thewayd`): harness assembly, local/sandbox tool policy, triggers/cron/session/DAG runtime, skills, MCP/LSP wiring, serving the gRPC/HTTP/MCP transports from theway-transport. Terminal UI lives in the theway-tui crate.
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

//! Shared ingestion for both execution paths. `by_file` feeds `content` mode
//! (per-line map dedups overlapping contexts); the occurrence list feeds
//! `count` / `files_with_matches` and the match cap (one entry per matching
//! line, mirroring the walker's semantics).

use std::collections::BTreeMap;

#[derive(Default)]
pub(super) struct Ingest {
    pub(super) by_file: BTreeMap<String, BTreeMap<usize, (String, bool)>>,
    pub(super) occurrences: Vec<String>,
    pub(super) truncated_lines: usize,
    pub(super) max_matches: usize,
}

impl Ingest {
    pub(super) fn new(max_matches: usize) -> Self {
        Self {
            max_matches,
            ..Default::default()
        }
    }

    pub(super) fn match_line(
        &mut self,
        path: &str,
        lineno: usize,
        preview: &str,
        was_truncated: bool,
    ) {
        self.by_file
            .entry(path.to_string())
            .or_default()
            .insert(lineno, (preview.to_string(), true));
        self.occurrences.push(path.to_string());
        if was_truncated {
            self.truncated_lines += 1;
        }
    }

    pub(super) fn context_line(&mut self, path: &str, lineno: usize, text: String) {
        self.by_file
            .entry(path.to_string())
            .or_default()
            .entry(lineno)
            .or_insert((text, false));
    }

    pub(super) fn match_count(&self) -> usize {
        self.occurrences.len()
    }

    pub(super) fn is_capped(&self) -> bool {
        self.match_count() >= self.max_matches
    }
}