thenodes 0.2.0

TheNodes is a modular, plugin-driven P2P node framework for Rust, supporting node-embedded plugins (NEP) and core-as-a-library (CAL) modes with async-first APIs.
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

use std::fs;
use std::net::SocketAddr;

use thenodes::config::{Config, NetworkConfig, NetworkPersistenceConfig, NodeConfig};
use thenodes::network::peer_store::{PeerSource, PeerStore};

#[tokio::test]
async fn peer_store_cap_enforcement_on_load() {
    let base = "data/test-cap";
    let _ = fs::create_dir_all(base);
    let path = format!("{}/peers.json", base);

    // Persist many peers
    let store = PeerStore::new();
    for i in 0..50u16 {
        let addr: SocketAddr = format!("127.0.0.1:{}", 52000 + i).parse().unwrap();
        store.insert(addr, PeerSource::Gossip).await;
        store.mark_success(&addr).await;
    }
    store.save_to_file(&path).await.unwrap();

    // Load with max_entries small to enforce cap
    let cfg = Config {
        port: 50000,
        encryption: None,
        bootstrap_nodes: None,
        realm: None,
        app_name: Some("test-cap".to_string()),
        logging: None,
        node: Some(NodeConfig {
            id: None,
            state_dir: Some(base.to_string()),
            id_file: Some("node_id".to_string()),
            allow_ephemeral: Some(true),
            node_type: Some("daemon".to_string()),
        }),
        discovery: None,
        realm_access: None,
        network: Some(NetworkConfig {
            persistence: Some(NetworkPersistenceConfig {
                enabled: Some(true),
                path: Some(path.clone()),
                max_entries: Some(10), // cap to 10
                ttl_secs: Some(7 * 24 * 3600),
                save_interval_secs: Some(60),
            }),
            relay: None,
        }),
    };

    let loaded = PeerStore::from_config(&cfg).await;
    let all = loaded.all().await;
    assert_eq!(all.len(), 10);

    // Cleanup
    let _ = fs::remove_file(&path);
    let _ = fs::remove_dir_all(base);
}