oxios 1.23.0

Oxios Agent OS — Agent Operating System powered by oxi-sdk
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

//! Daemon lifecycle integration tests (RFC-040 C2).
//!
//! Tests DaemonManager's status resolution, stale pidfile cleanup,
//! and orphan detection — the multi-source liveness interpretation
//! that is the core of daemon reliability.

use oxios_kernel::{DaemonManager, DaemonStatus};

// ── PID file lifecycle ─────────────────────────────────────────────

/// Stale pidfile (dead PID) → Stale status → cleanup → Stopped.
#[test]
fn stale_pidfile_detected_and_cleaned() {
    let tmp = tempfile::tempdir().unwrap();
    let pid_file = tmp.path().join("oxios.pid");
    // Write a PID that is virtually guaranteed not to exist.
    std::fs::write(&pid_file, "999999").unwrap();
    let dm = DaemonManager::new(pid_file.to_str().unwrap(), tmp.path().to_str().unwrap());
    assert!(
        matches!(dm.status(), DaemonStatus::Stale { .. }),
        "dead PID in pidfile should be Stale"
    );
    dm.cleanup().unwrap();
    assert!(
        matches!(dm.status(), DaemonStatus::Stopped),
        "after cleanup, should be Stopped"
    );
}

/// No pidfile → Stopped.
#[test]
fn no_pidfile_is_stopped() {
    let tmp = tempfile::tempdir().unwrap();
    let dm = DaemonManager::new(
        tmp.path().join("nonexistent.pid").to_str().unwrap(),
        tmp.path().to_str().unwrap(),
    );
    assert!(matches!(dm.status(), DaemonStatus::Stopped));
}

/// Fresh pidfile (current PID) → Running.
#[cfg(unix)]
#[test]
fn fresh_pidfile_reports_running() {
    let tmp = tempfile::tempdir().unwrap();
    let pid_file = tmp.path().join("oxios.pid");
    std::fs::write(&pid_file, std::process::id().to_string()).unwrap();
    let dm = DaemonManager::new(pid_file.to_str().unwrap(), tmp.path().to_str().unwrap());
    assert!(
        matches!(dm.status(), DaemonStatus::Running { .. }),
        "current PID in pidfile should be Running"
    );
    dm.cleanup().unwrap();
}

// ── Orphan detection (Unix) ────────────────────────────────────────

/// Port probe detects a listener when no pidfile exists.
#[cfg(unix)]
#[test]
fn orphan_detection_finds_listener() {
    let listener = std::net::TcpListener::bind("127.0.0.1:0").unwrap();
    let port = listener.local_addr().unwrap().port();
    let tmp = tempfile::tempdir().unwrap();
    let dm = DaemonManager::new(
        tmp.path().join("oxios.pid").to_str().unwrap(),
        tmp.path().to_str().unwrap(),
    )
    .with_probe_port(port);
    // Hold the listener — don't drop until after status() returns.
    let status = dm.status();
    drop(listener);
    match status {
        DaemonStatus::Orphaned { port: p } => assert_eq!(p, port),
        other => panic!("expected Orphaned, got {other:?}"),
    }
}

/// No listener + no pidfile → Stopped (not Orphaned).
#[test]
fn no_listener_is_stopped() {
    let tmp = tempfile::tempdir().unwrap();
    // Use a privileged port that will never be bound in tests.
    let dm = DaemonManager::new(
        tmp.path().join("oxios.pid").to_str().unwrap(),
        tmp.path().to_str().unwrap(),
    )
    .with_probe_port(1);
    assert!(matches!(dm.status(), DaemonStatus::Stopped));
}

// ── DaemonStatus Display ───────────────────────────────────────────

/// DaemonStatus Display impl produces human-readable strings.
#[test]
fn daemon_status_display() {
    assert_eq!(
        DaemonStatus::Running { pid: 42 }.to_string(),
        "running (PID 42)"
    );
    assert_eq!(
        DaemonStatus::Stale { pid: 99 }.to_string(),
        "stale (PID 99 dead)"
    );
    assert_eq!(DaemonStatus::Stopped.to_string(), "stopped");
    assert_eq!(
        DaemonStatus::Orphaned { port: 4200 }.to_string(),
        "orphaned (no pidfile, port 4200 in use)"
    );
}