x0x 0.14.5

Agent-to-agent gossip network for AI systems — no winners, no losers, just cooperation
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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

//! Integration tests for x0x agent network lifecycle.
//!
//! These tests verify the complete workflow of creating agents,
//! configuring network settings, and participating in the gossip network.

use tempfile::TempDir;
use x0x::{network, Agent};

/// Test agent creation with default network configuration.
#[tokio::test]
async fn test_agent_creation() {
    let agent = Agent::new().await;
    assert!(agent.is_ok());

    let agent = agent.unwrap();
    assert!(agent.identity().machine_id().as_bytes() != &[0u8; 32]);
    assert!(agent.identity().agent_id().as_bytes() != &[0u8; 32]);
}

/// Test agent creation with custom network configuration.
#[tokio::test]
async fn test_agent_with_network_config() {
    let temp_dir = TempDir::new().expect("Failed to create temp dir");

    let builder = Agent::builder();
    let builder = builder.with_machine_key(temp_dir.path().join("machine.key"));
    let builder = builder.with_network_config(network::NetworkConfig {
        bind_addr: Some("127.0.0.1:0".parse().unwrap()),
        bootstrap_nodes: vec!["127.0.0.1:5483".parse().unwrap()],
        ..Default::default()
    });

    let agent = builder.build().await.expect("Failed to build agent");
    assert!(agent.network().is_some());
}

/// Test agent joining network with configuration.
#[tokio::test]
async fn test_agent_join_network() {
    let agent = Agent::new().await.expect("Failed to create agent");

    let result = agent.join_network().await;
    assert!(result.is_ok());
}

/// Test agent subscribe functionality.
#[tokio::test]
async fn test_agent_subscribe() {
    let agent = Agent::new().await.expect("Failed to create agent");

    // Currently subscribe() returns an error (not yet implemented)
    // Will be implemented in Task 3
    let result = agent.subscribe("test-topic").await;
    assert!(result.is_err());
}

/// Test agent publish functionality.
#[tokio::test]
async fn test_agent_publish() {
    // Agent needs network to use pub/sub
    let agent = Agent::builder()
        .with_network_config(x0x::network::NetworkConfig::default())
        .build()
        .await
        .expect("Failed to create agent");

    let result = agent.publish("test-topic", b"hello world".to_vec()).await;
    assert!(result.is_ok());
}

/// Test agent identity stability across operations.
#[tokio::test]
async fn test_identity_stability() {
    // Agent needs network for subscribe/publish operations
    let agent = Agent::builder()
        .with_network_config(x0x::network::NetworkConfig::default())
        .build()
        .await
        .expect("Failed to create agent");

    let machine_id = agent.machine_id();
    let agent_id = agent.agent_id();

    // Perform network operations
    let _ = agent.join_network().await;
    let _ = agent.subscribe("test-topic").await;
    let _ = agent.publish("test-topic", vec![]).await;

    // Verify IDs are stable
    assert_eq!(agent.machine_id(), machine_id);
    assert_eq!(agent.agent_id(), agent_id);
}

/// Test agent builder with custom machine key path.
#[tokio::test]
async fn test_builder_custom_machine_key() {
    let temp_dir = TempDir::new().expect("Failed to create temp dir");
    let key_path = temp_dir.path().join("custom_machine.key");

    // Create first agent with custom machine key and agent key
    let agent1 = Agent::builder()
        .with_machine_key(&key_path)
        .with_agent_key_path(temp_dir.path().join("agent1.key"))
        .build()
        .await
        .expect("Failed to create agent1");

    let machine_id1 = agent1.machine_id();

    // Create second agent with same machine key but different agent key
    let agent2 = Agent::builder()
        .with_machine_key(&key_path)
        .with_agent_key_path(temp_dir.path().join("agent2.key"))
        .build()
        .await
        .expect("Failed to create agent2");

    let machine_id2 = agent2.machine_id();

    // Machine IDs should be the same (same machine key)
    assert_eq!(machine_id1, machine_id2);

    // Agent IDs should be different (different agent keys)
    assert_ne!(agent1.agent_id(), agent2.agent_id());
}

/// Test message format and structure.
#[tokio::test]
async fn test_message_format() {
    use x0x::Message;

    let msg = Message {
        origin: "test-agent".to_string(),
        payload: b"test payload".to_vec(),
        topic: "test-topic".to_string(),
    };

    assert_eq!(msg.origin, "test-agent");
    assert_eq!(msg.payload, b"test payload");
    assert_eq!(msg.topic, "test-topic");
}