online 4.0.2

📶 Library to check your Internet connectivity
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

use std::{io::Error, time::Duration};
use tokio::{net::TcpStream, time::timeout as tout};

#[path = "./utils.rs"]
mod utils;

// Custom version of 'TcpStream::connect_timeout' not present in 'tokio'.
async fn connect_timeout(addrs: &str, dur: Duration) -> Result<(), Error> {
    match tout(dur, TcpStream::connect(addrs)).await {
        Ok(_) => Ok(()),
        Err(e) => Err(Error::from(e)),
    }
}

/// Asynchronous implementation.
///
/// * `timeout` - Number of seconds to wait for a response
/// (default: OS dependent).
pub async fn check(timeout: Option<u64>) -> Result<(), Error> {
    // Avoiding `io:timeout` in this case to allow the OS decide for
    // better diagnostics.
    if let Some(t) = timeout {
        let dur = utils::parse_timeout(t)?;

        // First try, ignoring error (if any).
        return if connect_timeout(utils::ADDRS[0], dur).await.is_ok() {
            Ok(())
        } else {
            // Fallback.
            connect_timeout(utils::ADDRS[1], dur).await
        };
    }

    // No timeout.
    if TcpStream::connect(utils::ADDRS[0]).await.is_ok() {
        Ok(())
    } else if let Err(e) = TcpStream::connect(utils::ADDRS[1]).await {
        Err(e)
    } else {
        Ok(())
    }
}