natpmp 0.5.0

NAT-PMP client library
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

use std::sync::Arc;

use natpmp::*;
use std::time::Duration;

fn main() -> Result<()> {
    use async_std::future;
    use async_std::task;

    task::block_on(async {
        let n = Arc::new(new_async_std_natpmp().await.unwrap());

        let n_cloned = n.clone();
        task::spawn(async {
            let n = n_cloned;
            loop {
                println!("Sending request...");
                if let Err(e) = n
                    .send_port_mapping_request(Protocol::UDP, 4020, 4020, 30)
                    .await
                {
                    eprintln!("Sending request error: {}", e);
                    break;
                }
                let _ = future::timeout(Duration::from_secs(3), async {}).await;
            }
        });

        loop {
            match n.read_response_or_retry().await {
                Ok(Response::UDP(ur)) => {
                    assert_eq!(ur.private_port(), 4020);
                    assert_eq!(ur.public_port(), 4020); // Could be another port chosen by gateway
                }
                _ => {
                    eprintln!("Expecting a udp response");
                    break;
                }
            }
        }
    });

    Ok(())
}