dtn7 0.21.0

Rust delay-tolerant-networking daemon and CLI tools implementing Bundle Protocol Version 7 (RFC9171)
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

use clap::{Parser, Subcommand};

/// A simple Bundle Protocol 7 Query Utility for Delay Tolerant Networking
#[derive(Parser, Debug)]
#[clap(version, author, long_about = None)]
struct Args {
    /// Local web port (default = 3000)
    #[clap(short, long, default_value_t = 3000)]
    port: u16,

    /// Use IPv6
    #[clap(short = '6', long)]
    ipv6: bool,

    #[clap(subcommand)]
    cmd: Commands,
}

#[derive(Subcommand, Debug)]
enum Commands {
    /// List registered endpoint IDs
    Eids,
    /// List known peers
    Peers,
    /// List bundles on node
    Bundles {
        /// Verbose output includes bundle destination
        #[clap(short, long)]
        verbose: bool,
        /// Just print hash digest of bundles known
        #[clap(short, long)]
        digest: bool,
        /// Filter for bundles with source or destination address
        #[clap(short, long)]
        addr: Option<String>,
    },
    /// List bundles status in store
    Store,
    /// General dtnd info
    Info,
    /// Local node id
    Nodeid,
}

fn main() {
    let args = Args::parse();
    let port = if let Ok(env_port) = std::env::var("DTN_WEB_PORT") {
        env_port // string is fine no need to parse number
    } else {
        args.port.to_string()
    };

    let localhost = if args.ipv6 { "[::1]" } else { "127.0.0.1" };

    let url = match &args.cmd {
        Commands::Eids => {
            println!("Listing registered endpoint IDs:");
            format!("http://{}:{}/status/eids", localhost, port)
        }
        Commands::Peers => {
            println!("Listing of known peers:");
            format!("http://{}:{}/status/peers", localhost, port)
        }
        Commands::Bundles {
            verbose,
            digest,
            addr,
        } => {
            println!("Listing of bundles in store:");
            if *verbose {
                format!("http://{}:{}/status/bundles/verbose", localhost, port)
            } else if let Some(addr) = addr {
                if *digest {
                    format!(
                        "http://{}:{}/status/bundles/filtered/digest?addr={}",
                        localhost, port, addr
                    )
                } else {
                    format!(
                        "http://{}:{}/status/bundles/filtered?addr={}",
                        localhost, port, addr
                    )
                }
            } else if *digest {
                format!("http://{}:{}/status/bundles/digest", localhost, port)
            } else {
                format!("http://{}:{}/status/bundles", localhost, port)
            }
        }
        Commands::Store => {
            println!("Listing of bundles status in store:");
            format!("http://{}:{}/status/store", localhost, port)
        }
        Commands::Info => {
            println!("Daemon info:");
            format!("http://{}:{}/status/info", localhost, port)
        }
        Commands::Nodeid => {
            println!("Local node ID:");
            format!("http://{}:{}/status/nodeid", localhost, port)
        }
    };
    let res = attohttpc::get(url)
        .send()
        .expect("error connecting to local dtnd")
        .text()
        .unwrap();
    println!("{}", res);
}