malvin 0.2.9

Non-interactive research and coding agent
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

use crate::acp::{AgentError, AttemptCeiling, backoff_after_agent_failure};
use crate::test_stderr_capture::capture_stderr_output;

#[test]
fn backoff_does_not_log_when_retry_policy_stops_immediately() {
    let stderr = capture_stderr_output(|| {
        let rt = tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .expect("runtime");
        let stop = rt
            .block_on(backoff_after_agent_failure(
                None,
                &AgentError::ordinary("timed out"),
                3,
                AttemptCeiling::at_most_u32(3),
            ))
            .expect("backoff");
        assert!(stop);
    });
    assert!(
        !stderr.contains("agent attempt"),
        "exhausted retries must not log at backoff; stderr={stderr:?}"
    );
}

#[test]
fn backoff_logs_before_sleep_when_retry_will_occur() {
    let stderr = capture_stderr_output(|| {
        let rt = tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .expect("runtime");
        let stop = rt
            .block_on(backoff_after_agent_failure(
                None,
                &AgentError::ordinary("request timed out"),
                1,
                AttemptCeiling::at_most_u32(3),
            ))
            .expect("backoff");
        assert!(!stop);
    });
    assert!(
        stderr.contains("agent attempt 1 failed"),
        "retriable failure should log once before sleep; stderr={stderr:?}"
    );
}