nexo-driver-loop 0.1.9

Goal orchestrator + LlmDecider + Unix socket bridge for the nexo-rs driver subsystem. Phase 67.4.
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
111
112
113
114

//! Compose the prompt fed to Claude per turn.

use nexo_driver_types::{AcceptanceFailure, BudgetGuards, Goal};

/// Build the user prompt for turn `turn_index` (0-based).
///
/// Layout:
///
/// ```text
/// <goal description>
///
/// Previous attempt failed:
///   1. <criterion_label>: <message>
///   2. ...
///
/// [Turn N/M]
/// ```
///
/// `prior_failures` is the verdict of the previous turn's acceptance
/// run (empty on turn 0). `budget` is read for the trailing hint.
pub fn compose_turn_prompt(
    goal: &Goal,
    turn_index: u32,
    prior_failures: &[AcceptanceFailure],
    budget: &BudgetGuards,
) -> String {
    let mut out = String::new();
    out.push_str(goal.description.trim());

    if !prior_failures.is_empty() {
        out.push_str("\n\nPrevious attempt failed:");
        for (i, f) in prior_failures.iter().enumerate() {
            out.push_str(&format!(
                "\n  {}. {}: {}",
                i + 1,
                f.criterion_label,
                f.message
            ));
        }
    }

    out.push_str(&format!(
        "\n\n[Turn {}/{}]",
        turn_index + 1,
        budget.max_turns
    ));
    out
}

#[cfg(test)]
mod tests {
    use super::*;
    use nexo_driver_types::{AcceptanceCriterion, BudgetGuards, Goal, GoalId};
    use std::time::Duration;
    use uuid::Uuid;

    fn goal_for(text: &str) -> Goal {
        Goal {
            id: GoalId(Uuid::nil()),
            description: text.into(),
            acceptance: vec![AcceptanceCriterion::shell("true")],
            budget: BudgetGuards {
                max_turns: 5,
                max_wall_time: Duration::from_secs(60),
                max_tokens: 1_000,
                max_consecutive_denies: 3,
                max_consecutive_errors: 5,
                max_consecutive_413: 2,
            },
            workspace: None,
            metadata: serde_json::Map::new(),
        }
    }

    #[test]
    fn turn_zero_no_failures_has_budget_suffix() {
        let g = goal_for("Implement Phase 26.z");
        let p = compose_turn_prompt(&g, 0, &[], &g.budget);
        assert!(p.starts_with("Implement Phase 26.z"));
        assert!(p.ends_with("[Turn 1/5]"));
        assert!(!p.contains("Previous attempt failed"));
    }

    #[test]
    fn retry_turn_includes_failures_numbered() {
        let g = goal_for("Goal X");
        let failures = vec![
            AcceptanceFailure {
                criterion_index: 0,
                criterion_label: "cargo test".into(),
                message: "test x failed".into(),
                evidence: None,
            },
            AcceptanceFailure {
                criterion_index: 1,
                criterion_label: "cargo clippy".into(),
                message: "warning Z".into(),
                evidence: None,
            },
        ];
        let p = compose_turn_prompt(&g, 1, &failures, &g.budget);
        assert!(p.contains("Previous attempt failed:"));
        assert!(p.contains("1. cargo test: test x failed"));
        assert!(p.contains("2. cargo clippy: warning Z"));
        assert!(p.ends_with("[Turn 2/5]"));
    }

    #[test]
    fn budget_suffix_uses_one_based_index() {
        let g = goal_for("X");
        let p = compose_turn_prompt(&g, 4, &[], &g.budget);
        assert!(p.ends_with("[Turn 5/5]"));
    }
}