loopflow 0.9.11

Run steps and flows with coding agents
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

//! Wire-shape fixture tests for DTOs mirrored across Rust / Python / Swift.
//!
//! Each fixture under `tests/fixtures/dto/` is parsed here and in the Python
//! and Swift test suites. If any mirror drifts, one of the three fails.

use std::path::PathBuf;

use loopflow::lfd::http::dto::{CreateTerminalSessionRequestDto, TerminalSessionDto};
use serde_json::Value;

fn load_fixture(name: &str) -> Value {
    let path = PathBuf::from(env!("CARGO_MANIFEST_DIR"))
        .join("../../tests/fixtures/dto")
        .join(name);
    let bytes = std::fs::read(&path).unwrap_or_else(|err| {
        panic!("read fixture {}: {err}", path.display());
    });
    serde_json::from_slice(&bytes).expect("parse fixture json")
}

#[test]
fn session_fixture_has_codex_input_supported_true() {
    let session = load_fixture("session.json");
    assert_eq!(session["object"], "session");
    assert_eq!(session["harness"], "codex");
    assert_eq!(session["status"], "active");
    assert_eq!(session["input_supported"], true);
    assert_eq!(session["wave_run_id"], "run-abc");
    assert_eq!(session["provider_session_id"], "provider-xyz");
    assert_eq!(session["config"]["step"], "design");
    assert_eq!(session["config"]["repo_root"], "/tmp/repo");
    assert_eq!(session["config"]["yolo_mode"], false);
}

#[test]
fn session_unsupported_input_fixture_has_input_supported_false() {
    let session = load_fixture("session_unsupported_input.json");
    assert_eq!(session["harness"], "claude");
    assert_eq!(session["status"], "failed");
    assert_eq!(session["input_supported"], false);
    assert!(session["ended_at"].is_string());
}

#[test]
fn terminal_session_fixture_pins_palette_shape() {
    let terminal_session: TerminalSessionDto =
        serde_json::from_value(load_fixture("terminal_session.json"))
            .expect("terminal session fixture should parse");
    assert_eq!(terminal_session.object, "terminal_session");
    assert_eq!(terminal_session.step, "ship");
    assert_eq!(terminal_session.agent, "codex");
    assert_eq!(terminal_session.source, "palette");
    assert_eq!(terminal_session.status, "running");
    assert_eq!(terminal_session.wave_run_id, None);
    assert!(terminal_session.argv.contains(&"-m".to_string()));
}

#[test]
fn create_terminal_session_request_fixture_pins_required_fields() {
    let request: CreateTerminalSessionRequestDto =
        serde_json::from_value(load_fixture("create_terminal_session_request.json"))
            .expect("create request fixture should parse");
    assert_eq!(request.flow, "ship");
    assert_eq!(request.worktree, "/tmp/repo.Desktop");
    assert_eq!(request.agent, "codex");
}