winx-code-agent 0.2.351

Remote-first Rust MCP runtime with Streamable HTTP, durable PTYs, and guarded agent tools
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

use std::path::Path;
use std::time::Duration;

use tempfile::TempDir;

use winx_code_agent::daemon::{
    DaemonClient, COMPACT_ACTION_OUTPUT_CAPABILITY, TYPED_ACTION_RESULT_CAPABILITY,
};
use winx_code_agent::runtime::{
    ensure_control_daemon_at, restart_control_daemon_at, select_runtime_mode, RuntimeMode,
};

#[test]
fn daemon_is_default_and_embedded_is_an_explicit_kill_switch() {
    assert!(matches!(select_runtime_mode(None, None, None), Ok(RuntimeMode::Daemon)));
    assert!(matches!(select_runtime_mode(Some("1"), None, None), Ok(RuntimeMode::Embedded)));
    assert!(matches!(select_runtime_mode(None, Some("embedded"), None), Ok(RuntimeMode::Embedded)));
    assert!(matches!(select_runtime_mode(None, None, Some("1")), Ok(RuntimeMode::Embedded)));
    assert!(select_runtime_mode(None, Some("surprise"), None).is_err());
}

/// Stop a test daemon: SIGTERM on Unix, the graceful `winx.shutdown` RPC on
/// Windows (guardians are separate detached processes and keep their PTYs).
#[cfg_attr(unix, allow(clippy::unused_async))] // only the Windows branch awaits
async fn terminate_test_daemon(socket: &Path, pid: u32) -> anyhow::Result<()> {
    #[cfg(unix)]
    {
        let _ = socket;
        let pid = i32::try_from(pid)?;
        // SAFETY: the pid came from the authenticated same-UID daemon handshake.
        if unsafe { libc::kill(pid, libc::SIGTERM) } == 0 {
            return Ok(());
        }
        let error = std::io::Error::last_os_error();
        if error.raw_os_error() == Some(libc::ESRCH) {
            Ok(())
        } else {
            Err(error.into())
        }
    }
    #[cfg(not(unix))]
    {
        let _ = pid;
        // The daemon may already be gone (e.g. after a control restart); a
        // failed shutdown is not a test failure.
        let _ = DaemonClient::new(socket).shutdown().await;
        Ok(())
    }
}

#[tokio::test(flavor = "multi_thread")]
async fn daemon_default_can_auto_spawn_the_sibling_binary() -> anyhow::Result<()> {
    let runtime_dir = TempDir::new()?;
    let socket = runtime_dir.path().join("winxd.sock");
    ensure_control_daemon_at(&socket, Path::new(env!("CARGO_BIN_EXE_winxd"))).await?;

    let hello = DaemonClient::new(&socket).hello().await?;
    let validation = if hello.protocol_major == 1
        && hello.protocol_minor >= 5
        && hello.capabilities.iter().any(|capability| capability == "guardian_activity_clock")
        && hello.capabilities.iter().any(|capability| capability == TYPED_ACTION_RESULT_CAPABILITY)
        && hello
            .capabilities
            .iter()
            .any(|capability| capability == COMPACT_ACTION_OUTPUT_CAPABILITY)
        && hello.daemon_pid != std::process::id()
    {
        Ok(())
    } else {
        Err(anyhow::anyhow!("unexpected control hello: {hello:?}"))
    };
    terminate_test_daemon(&socket, hello.daemon_pid).await?;
    tokio::time::sleep(Duration::from_millis(100)).await;
    validation
}

#[tokio::test(flavor = "multi_thread")]
async fn planned_control_restart_changes_epoch() -> anyhow::Result<()> {
    let runtime_dir = TempDir::new()?;
    let socket = runtime_dir.path().join("winxd.sock");
    let binary = Path::new(env!("CARGO_BIN_EXE_winxd"));
    ensure_control_daemon_at(&socket, binary).await?;
    let previous = DaemonClient::new(&socket).hello().await?;

    let restarted = restart_control_daemon_at(&socket, binary).await?;
    let validation = if restarted.daemon_epoch != previous.daemon_epoch
        && restarted.protocol_minor >= 5
        && restarted.capabilities.iter().any(|capability| capability == "guardian_activity_clock")
        && restarted
            .capabilities
            .iter()
            .any(|capability| capability == TYPED_ACTION_RESULT_CAPABILITY)
        && restarted
            .capabilities
            .iter()
            .any(|capability| capability == COMPACT_ACTION_OUTPUT_CAPABILITY)
    {
        Ok(())
    } else {
        Err(anyhow::anyhow!(
            "control restart did not produce the expected hello: before={previous:?} after={restarted:?}"
        ))
    };
    terminate_test_daemon(&socket, restarted.daemon_pid).await?;
    tokio::time::sleep(Duration::from_millis(100)).await;
    validation
}