dpc-tau-cli 0.1.0

A minimal Unix-first coding agent.
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
110

//! Bounded prompt, response, message-label, and timer projections.

use crate::event_renderer::TIMER_WAKEUP_CTX_PREFIX;
use crate::markdown_render::markdown_block_with_osc8;

/// Prefix for completed assistant response rows.
pub(super) const COMPLETED_AGENT_RESPONSE_PREFIX: &str = "◆ ";
/// Prefix for streaming assistant response rows.
pub(super) const STREAMING_AGENT_RESPONSE_PREFIX: &str = "◇ ";
/// Maximum rendered terminal columns for a supplemental agent message name.
pub(super) const AGENT_MESSAGE_NAME_MAX_COLUMNS: usize = 48;
/// Maximum rendered UTF-8 bytes for a supplemental agent message name.
pub(super) const AGENT_MESSAGE_NAME_MAX_BYTES: usize = 192;
/// Maximum bytes inspected at either end of a queued prompt.
pub(super) const QUEUED_PROJECTION_WINDOW_BYTES: usize = 16 * 1024;

/// Returns the bounded first logical line of queued prompt text.
pub(super) fn bounded_queued_line_start(text: &str) -> &str {
    let mut end = text.len().min(QUEUED_PROJECTION_WINDOW_BYTES);
    while !text.is_char_boundary(end) {
        end -= 1;
    }
    let window = &text[..end];
    window
        .find(['\n', '\r'])
        .map_or(window, |line_end| &window[..line_end])
}

/// Returns the bounded final logical line of queued prompt text.
pub(super) fn bounded_queued_line_end(text: &str) -> &str {
    let mut start = text.len().saturating_sub(QUEUED_PROJECTION_WINDOW_BYTES);
    while !text.is_char_boundary(start) {
        start += 1;
    }
    let window = &text[start..];
    window
        .rfind(['\n', '\r'])
        .map_or(window, |line_end| &window[line_end + 1..])
}

/// Builds the bounded two-line queued-prompt terminal projection.
pub(super) fn queued_prompt_projection(
    theme: &tau_themes::Theme,
    osc8_links: bool,
    prefix: tau_cli_term::StyledText,
    text: &str,
) -> tau_cli_term::TwoLineElision {
    let styled_prompt = |value| {
        markdown_block_with_osc8(
            theme,
            tau_themes::names::USER_PROMPT_QUEUED,
            value,
            osc8_links,
        )
        .content
    };
    let styled_marker = |value| {
        markdown_block_with_osc8(
            theme,
            tau_themes::names::USER_PROMPT_QUEUED_MARKER,
            value,
            osc8_links,
        )
        .content
    };
    let unabridged = (text.len() <= QUEUED_PROJECTION_WINDOW_BYTES).then(|| {
        let mut prompt = styled_prompt(text);
        for span in styled_marker(" (queued)").spans() {
            prompt.push(span.clone());
        }
        prompt
    });
    tau_cli_term::TwoLineElision {
        prefix,
        first: styled_prompt(bounded_queued_line_start(text)),
        last: styled_prompt(bounded_queued_line_end(text)),
        first_omissions: vec![styled_prompt("   ┄"), styled_prompt("┄")],
        last_omissions: vec![styled_prompt("┄ "), styled_prompt("┄")],
        labels: vec![
            styled_marker(" (queued)"),
            styled_marker(" (q)"),
            styled_marker("q"),
        ],
        unabridged,
    }
}

/// Parses the timer id and occurrence count from a wakeup context id.
pub(super) fn timer_wakeup_ctx(ctx_id: Option<&str>) -> Option<(&str, &str)> {
    let rest = ctx_id?.strip_prefix(TIMER_WAKEUP_CTX_PREFIX)?;
    rest.rsplit_once(':')
}

/// Builds user-visible timer wakeup summary text.
pub(super) fn timer_wakeup_summary(timer_id: &str, text: Option<&str>) -> String {
    let Some(text) = text else {
        return format!("Timer `{timer_id}` woke this agent");
    };
    let trimmed = text.trim();
    let timer_prefix = format!("Timer `{timer_id}` fired:");
    let message = trimmed
        .strip_prefix(&timer_prefix)
        .map(str::trim)
        .unwrap_or(trimmed);
    if message.is_empty() {
        format!("Timer `{timer_id}` woke this agent")
    } else {
        format!("Timer `{timer_id}` woke this agent: {message}")
    }
}