netscanner 0.6.43

Network Scanner
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 cidr::Ipv4Cidr;
use std::net::Ipv4Addr;
use tokio::task;
use std::time::Duration;

fn ping(ip: Ipv4Addr) -> Result<String, String> {
    // println!("pinging ip - {}", ip);
    Ok(ip.to_string())
}

#[tokio::main]
async fn main() {

    let pool_size = 8;
    let mut ips: Vec<Ipv4Addr> = Vec::new();

    let cidr_range = "192.168.1.0/24"; // Replace with your CIDR range
    match cidr_range.parse::<Ipv4Cidr>() {
        Ok(ip_cidr) => {
            for ip in ip_cidr.iter() {
                ips.push(ip.address());
            }
        }
        Err(e) => {
            eprintln!("Error parsing CIDR range: {}", e);
        }
    }

    // println!("{:?}", ips);
    
    let ip_chunks: Vec<_> = ips.chunks(pool_size).collect();
    for chunk in ip_chunks {
        // println!("{:?}", chunk);
        let tasks: Vec<_> = chunk.iter().map(|&ip| {
            let closure = || async move {
                tokio::time::sleep(Duration::from_secs(1)).await;
                match ping(ip) {
                    Ok(res) => {
                        println!("{} ping done", res);
                    }
                    Err(err) => {
                        println!("{:?} error", err);
                    }
                }
            };
            task::spawn(closure())
        }).collect();

        for task in tasks {
            task.await.unwrap();
            // match task.await {
            //     Ok(_) => {}
            //     Err(_) => {}
            // };
        }
    }
}