YGGverse/btracker
1
0
Fork 0
mirror of https://github.com/YGGverse/btracker.git synced 2026-03-31 09:05:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix scrape response, parse inline

Browse source
This commit is contained in:
yggverse 2025-08-07 14:53:37 +03:00
parent a3e3cb0897
commit ff0c0aae36
1 changed files with 6 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

21
src/scraper/udp.rs
View file

@ -58,11 +58,13 @@ impl Udp {
let mut b = [0u8; 1024];
let l = route.socket.recv(&mut b)?;
let r = scrape_response(&b[..l]);
if l < 20 {
todo!()
}
t.leechers += r.leechers;
t.peers += r.peers;
t.seeders += r.seeders;
t.seeders += u32::from_be_bytes(b[8..12].try_into().unwrap());
t.leechers += u32::from_be_bytes(b[12..16].try_into().unwrap());
t.peers += u32::from_be_bytes(b[16..20].try_into().unwrap());
}
}
Ok(t)
@ -92,14 +94,3 @@ fn scrape_request(connection_id: u64, transaction_id: u32, info_hashes: &[Id20])
}
b
}
fn scrape_response(response: &[u8]) -> Scrape {
if response.len() < 20 {
todo!()
}
Scrape {
leechers: u32::from_be_bytes(response[12..16].try_into().unwrap()),
seeders: u32::from_be_bytes(response[16..20].try_into().unwrap()),
peers: 0, // @TODO
}
}