btpeer 0.7.0

Simple CLI tool and library to get peers from TCP/HTTP and UDP BitTorrent trackers
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

mod config;
mod http;
mod peer;
mod udp;

use peer::Peer;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    use clap::Parser;
    use colored::Colorize;
    use config::Config;
    use std::time::Duration;

    fn stats(interval: u32, leechers: u32, seeders: u32, peers: Vec<Peer>) {
        println!("{}", format!("Update interval: {interval}s").yellow());
        println!("{}: {seeders}, {}: {leechers}", "S".green(), "L".red());
        if peers.is_empty() {
            println!("{}", "No peers.".red());
        } else {
            for peer in peers {
                println!("{peer}")
            }
        }
    }

    let config = Config::parse();

    if config.http_tracker.as_ref().is_none_or(|h| h.is_empty())
        && config.udp_tracker.as_ref().is_none_or(|u| u.is_empty())
    {
        println!("{}", "Provide at least one HTTP or UDP tracker(s)".red());
        std::process::exit(1);
    }

    if let Some(http_tracker) = config.http_tracker {
        for url in http_tracker {
            let query = http::query::Announce::new(url.as_str(), &config.info_hash, config.port)?;
            println!(
                "{}",
                format!("Sending HTTP announce to `{query}`...").blue()
            );
            let mut peers = peer::new_buffer(Some(config.peers_buffer_capacity));
            match http::announce(
                &query,
                Duration::from_secs(config.timeout),
                config.proxy_url.as_deref(),
                Some(&mut peers),
            )
            .await
            {
                Ok(response) => stats(
                    response.interval,
                    response.leechers,
                    response.seeders,
                    peers,
                ),
                Err(e) => println!("{}", e.to_string().red()),
            }
        }
    }

    if let Some(udp_tracker) = config.udp_tracker {
        use std::net::{Ipv4Addr, Ipv6Addr, SocketAddr, SocketAddrV4, SocketAddrV6, UdpSocket};
        use udp::Server;

        let timeout = Duration::from_secs(config.timeout);

        for address in udp_tracker {
            let server = if address.is_ipv6() {
                UdpSocket::bind(SocketAddr::V6(SocketAddrV6::new(
                    Ipv6Addr::UNSPECIFIED,
                    config.port,
                    0,
                    0,
                )))?
            } else {
                UdpSocket::bind(SocketAddr::V4(SocketAddrV4::new(
                    Ipv4Addr::UNSPECIFIED,
                    config.port,
                )))?
            };
            server.set_read_timeout(Some(timeout))?;
            server.set_write_timeout(Some(timeout))?;

            println!(
                "{}",
                format!("Sending UDP announce to `{address}`...").blue()
            );
            let mut peers = peer::new_buffer(Some(config.peers_buffer_capacity));

            match server.announce(&config.info_hash, &address, Some(&mut peers)) {
                Ok(response) => stats(
                    response.interval,
                    response.leechers,
                    response.seeders,
                    peers,
                ),
                Err(e) => println!("{}", e.to_string().red()),
            }
        }
    }

    Ok(())
}