sdtn 0.1.4

SpaceArth DTN - A Rust-based implementation of Delay Tolerant Networking (DTN) for resilient communication
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

use sdtn::{BundleStatus, DtnNode};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Create DTN CLI instance with default settings
    let node = DtnNode::new()?;

    // Insert a bundle
    println!("📦 Inserting a new bundle...");
    node.insert_bundle("Hello from SpaceArth DTN!".to_string())
        .await?;

    // List all bundles
    println!("📋 Listing all bundles...");
    let bundles = node.list_bundles()?;
    println!("Found {} bundles:", bundles.len());
    for id in &bundles {
        println!("  {}", id);
    }

    // Show details of a specific bundle
    if let Some(first_id) = bundles.first() {
        println!("📄 Showing details for bundle: {}", first_id);
        let bundle = node.show_bundle(first_id)?;
        println!("  Source: {}", bundle.primary.source);
        println!("  Destination: {}", bundle.primary.destination);
        println!("  Message: {}", String::from_utf8_lossy(&bundle.payload));
        println!("  Expired: {}", bundle.is_expired());
    }

    // Get status summary
    println!("📊 Getting status summary...");
    let status = node.get_bundle_status(None)?;
    match status {
        BundleStatus::Summary {
            active,
            expired,
            total,
        } => {
            println!("  Active bundles: {}", active);
            println!("  Expired bundles: {}", expired);
            println!("  Total bundles: {}", total);
        }
        _ => unreachable!(),
    }

    // Clean up expired bundles
    println!("🧹 Cleaning up expired bundles...");
    node.cleanup_expired()?;

    println!("✅ Basic usage example completed!");
    Ok(())
}