malvin 0.2.5

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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

use super::test_support::test_io;
use crate::model_id::ModelBackend;
use crate::model_id::parse_model_id;

#[test]
fn kiss_witness_backend_ops() {
    let _ = super::backend_ops::agent_backend_set_run_timing;
    let _ = super::backend_ops::agent_backend_attach_run_timing_for_session;
    let _ = super::backend_ops::agent_backend_ensure_run_timing_for_session;
    let _ = super::backend_ops::agent_backend_ensure_coder_session;
    let _ = super::backend_ops::agent_backend_start_coder_session;
    let _ = super::backend_ops::agent_backend_timing;
}

#[test]
fn ensure_run_timing_for_session_installs_when_missing() {
    let mut backend = crate::agent_backend::agent_backend_from_client(
        crate::cursor_sdk::cursor_sdk_client_from_raw("cursor:auto", test_io(), 1),
    );
    assert!(super::backend_ops::agent_backend_timing(&backend).is_none());
    let timing = super::backend_ops::agent_backend_ensure_run_timing_for_session(&mut backend);
    let again = super::backend_ops::agent_backend_ensure_run_timing_for_session(&mut backend);
    assert!(std::sync::Arc::ptr_eq(&timing, &again));
}

#[test]
fn kiss_witness_unified_sdk_client_and_backend() {
    let model = parse_model_id("cursor:auto").expect("model");
    let cursor = crate::agent_backend::new_cursor(model, test_io());
    assert_eq!(cursor.model.canonical(), "cursor:auto");
    assert!(matches!(cursor.model.backend, ModelBackend::Cursor));

    let pi_model = parse_model_id("pi:openai/gpt-4o").expect("pi");
    let pi = crate::agent_backend::new_pi(pi_model, test_io());
    assert!(matches!(pi.model.backend, ModelBackend::Pi));

    let codex_model = parse_model_id("codex:gpt-5.6").expect("codex");
    let codex = crate::agent_backend::sdk_client::new_codex(codex_model, test_io());
    assert!(matches!(codex.model.backend, ModelBackend::Codex));

    let mut backend = crate::agent_backend::agent_backend_from_client(cursor);
    assert!(backend.prompts_log_run_dir.is_none());
    backend.prompts_log_run_dir = Some(std::path::PathBuf::from("/tmp"));
    assert!(backend.prompts_log_run_dir.is_some());
    assert_eq!(
        backend.max_acp_retries,
        crate::support_paths::DEFAULT_MAX_ACP_RETRIES
    );
    assert!(!backend.has_open_coder_session());
    let _ = stringify!(ModelBackend);
    let _ = stringify!(new_cursor);
    let _ = stringify!(new_pi);
    let _ = stringify!(new_codex);
    let _ = stringify!(backend);
    let _ = stringify!(BegunCoderSession);
    let _ = stringify!(cursor_resume_id);
    let _ = stringify!(spawn_with_retries);
    let _ = stringify!(spawn_service_wire);
    let _ = stringify!(reject_no_force);
    let _ = stringify!(require_force);
    let _ = stringify!(CoderSessionEnsure);
    let _ = stringify!(start_coder_session);
    let _ = stringify!(bind_session_header);
    let _ = stringify!(deliver_session_header_if_needed);
    let _ = stringify!(emit_agent_started_log);
    let _ = stringify!(force_fresh_agent_for_retry);
    let _ = stringify!(NO_FORCE_MSG);
    let _ = stringify!(DRAIN_IDLE_PREFIX_BRIDGE);
    let _ = stringify!(DRAIN_IDLE_PREFIX_PI);
    let _ = stringify!(DRAIN_IDLE_PREFIX_CODEX);
    let _ = stringify!(prompts_log_run_dir);
}