btpeer 0.10.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

pub mod proxy;
pub mod query;
pub mod response;

pub use proxy::Proxy;

use crate::http::response::announce::{Default, I2p};
use anyhow::{Result, bail};
use bendy::decoding::FromBencode;
use reqwest::Client;
use response::Scrape;
use std::{str::FromStr, time::Duration};

pub async fn announce(
    query: &query::Announce,
    timeout: Duration,
    proxy_url: Option<&str>,
) -> Result<Default> {
    let response = client(timeout, proxy_url)?
        .get(query.to_string())
        .send()
        .await?;
    if !response.status().is_success() {
        bail!("Tracker returned status: {}", response.status());
    }
    Ok(Default::from_bencode(&response.bytes().await?)?)
}

pub async fn announce_i2p(
    query: &query::Announce,
    timeout: Duration,
    proxy_url: Option<&str>,
) -> Result<I2p> {
    let response = client(timeout, proxy_url)?
        .get(query.to_string())
        .send()
        .await?;

    if !response.status().is_success() {
        bail!("Tracker returned status: {}", response.status());
    }

    Ok(I2p::from_bencode(&response.bytes().await?)?)
}

pub async fn scrape(
    query: &query::Scrape,
    timeout: Duration,
    proxy_url: Option<&str>,
) -> Result<Scrape> {
    let response = client(timeout, proxy_url)?
        .get(query.to_string())
        .send()
        .await?;

    if !response.status().is_success() {
        bail!("Tracker returned status: {}", response.status());
    }

    Ok(Scrape::from_bencode(&response.bytes().await?)?)
}

pub fn client(timeout: Duration, proxy_url: Option<&str>) -> Result<Client> {
    let c = Client::builder().timeout(timeout);

    Ok(match proxy_url {
        Some(p) => c.proxy(Proxy::from_str(p)?.0),
        None => c,
    }
    .build()?)
}