x0x 0.14.8

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

//! Network timeout behavior tests

use saorsa_gossip_transport::GossipTransport;
use std::time::Duration;
use x0x::network::{NetworkConfig, NetworkNode};

#[tokio::test]
async fn test_receive_message_blocks_until_message() {
    // Create a network node
    let network = NetworkNode::new(NetworkConfig::default(), None, None)
        .await
        .expect("Failed to create network node");

    // Verify receive_message() correctly blocks when no messages available
    let result = tokio::time::timeout(Duration::from_millis(100), network.receive_message()).await;

    // Should timeout since no peers are connected and no messages sent
    assert!(
        result.is_err(),
        "receive_message() should timeout when no messages available"
    );
}

#[tokio::test]
async fn test_receive_message_with_timeout_context() {
    // This test verifies that receive_message() doesn't panic or leak resources
    // when timing out
    let network = NetworkNode::new(NetworkConfig::default(), None, None)
        .await
        .expect("Failed to create network node");

    // Multiple timeout attempts should be safe
    for _ in 0..3 {
        let result: Result<_, tokio::time::error::Elapsed> =
            tokio::time::timeout(Duration::from_millis(50), network.receive_message()).await;
        assert!(result.is_err());
    }

    // Network should still be functional
    assert!(network.peer_id().0.len() == 32);
}