agentos-client 0.2.12

High-level Rust client SDK for the Agent OS native sidecar (1:1 port of the TypeScript AgentOs client)
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

mod common;

use std::fs;
use std::path::{Path, PathBuf};

use agentos_client::config::{AgentOsConfig, MountConfig, MountPlugin};
use agentos_client::AgentOs;
use uuid::Uuid;

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn create_forwards_native_mounts() {
    if !common::sidecar_available() {
        panic!(
            "create_forwards_native_mounts: sidecar binary is not built; build it with `cargo build -p agentos-sidecar`"
        );
    }

    let host_root = TempMountRoot::new();
    fs::write(host_root.path().join("marker.txt"), b"mounted").expect("write host marker");

    let os = create_vm_with_host_mount(host_root.path()).await;
    let contents = os
        .read_file("/mnt/host/marker.txt")
        .await
        .expect("read mounted host file");

    assert_eq!(contents, b"mounted");

    os.shutdown().await.expect("shutdown VM");
}

async fn create_vm_with_host_mount(host_root: &Path) -> AgentOs {
    common::ensure_sidecar_env();
    AgentOs::create(AgentOsConfig {
        mounts: vec![MountConfig::Native {
            path: "/mnt/host".to_string(),
            plugin: MountPlugin {
                id: "host_dir".to_string(),
                config: Some(serde_json::json!({
                    "hostPath": host_root.to_string_lossy().into_owned(),
                    "readOnly": true,
                })),
            },
            guest_source: Some("host_dir".to_string()),
            guest_fstype: Some("host_dir".to_string()),
            read_only: true,
        }],
        ..Default::default()
    })
    .await
    .expect("create VM with native host-dir mount")
}

struct TempMountRoot {
    path: PathBuf,
}

impl TempMountRoot {
    fn new() -> Self {
        let path = std::env::temp_dir().join(format!("agentos-client-mount-{}", Uuid::new_v4()));
        fs::create_dir_all(&path).expect("create host mount root");
        Self { path }
    }

    fn path(&self) -> &Path {
        &self.path
    }
}

impl Drop for TempMountRoot {
    fn drop(&mut self) {
        let _ = fs::remove_dir_all(&self.path);
    }
}