Function check_http_tracker

tracker-checker/src/main.rs:175–236

(url: &str, timeout: Duration)

}

fn check_http_tracker(url: &str, timeout: Duration) -> (Status, Option<u64>) {
    let client = match Client::builder().timeout(timeout).build() {
        Ok(c) => c,
        Err(_) => return (Status::Dead, None),
    };

    let mut rng = rand::thread_rng();
    let peer_id_random: String = (0..12)
        .map(|_| (rng.gen_range(0u8..=9) + b'0') as char)
        .collect();
    let peer_id = format!("-RS0001-{peer_id_random}");

    let started = Instant::now();
    let response = match client
        .get(url)
        .query(&[
            ("info_hash", "00000000000000000000"),
            ("peer_id", peer_id.as_str()),
            ("port", "6881"),
            ("uploaded", "0"),
            ("downloaded", "0"),
            ("left", "0"),
            ("compact", "1"),
            ("event", "started"),
        ])
        .send()
    {
        Ok(r) => r,
        Err(_) => return (Status::Dead, None),
    };
    let ping_ms = Some(started.elapsed().as_millis() as u64);

    let status_code = response.status();
    let body = response.bytes().unwrap_or_default().to_vec();

    if is_parked_or_expired_domain(&body) {
        return (Status::Invalid, ping_ms);
    }

    if bdecode_simple(&body) {
        return (Status::Alive, ping_ms);
    }

    if status_code == StatusCode::OK {
        let head = String::from_utf8_lossy(&body[..body.len().min(200)]).to_lowercase();
        if head.contains("<html") || head.contains("<body") || head.contains("<head") {
            return (Status::Invalid, ping_ms);
        }
        if body.len() > 50_000 {
            return (Status::Invalid, ping_ms);
        }
        return (Status::Dead, ping_ms);
    }

    if status_code == StatusCode::BAD_REQUEST || status_code == StatusCode::FORBIDDEN {
        if bdecode_simple(&body) {
            return (Status::Alive, ping_ms);
        }