YGGverse/aquatic-crawler
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic-crawler.git synced 2026-04-02 10:05:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update librqbit api

Browse source
This commit is contained in:
yggverse 2025-07-10 16:01:15 +03:00
parent 4646500b66
commit e3dff43c1f
1 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/main.rs
View file

@ -13,7 +13,7 @@ use config::Config;
use index::Index; use index::Index;
use librqbit::{ use librqbit::{
AddTorrent, AddTorrentOptions, AddTorrentResponse, ByteBufOwned, ConnectionOptions, AddTorrent, AddTorrentOptions, AddTorrentResponse, ByteBufOwned, ConnectionOptions,
ListenerOptions, PeerConnectionOptions, SessionOptions, TorrentMetaV1Info, ListenerOptions, PeerConnectionOptions, SessionOptions, ValidatedTorrentMetaV1Info,
}; };
use peers::Peers; use peers::Peers;
use rss::Rss; use rss::Rss;
@ -214,7 +214,7 @@ async fn main() -> Result<()> {
} }
( (
m.info.name.as_ref().map(|n| n.to_string()), m.info.name().as_ref().map(|n| n.to_string()),
size(&m.info), size(&m.info),
list(&m.info, config.index_list_limit), list(&m.info, config.index_list_limit),
) )
@ -241,7 +241,7 @@ async fn main() -> Result<()> {
only_files_size, only_files_size,
size, size,
list, list,
name.map(|n| n.to_string()).filter(|s| !s.is_empty()), // librqbit#452 name.map(|n| n.to_string()),
) )
} }
Ok(AddTorrentResponse::ListOnly(r)) => { Ok(AddTorrentResponse::ListOnly(r)) => {
@ -262,7 +262,7 @@ async fn main() -> Result<()> {
0, 0,
size(&r.info), size(&r.info),
list(&r.info, config.index_list_limit), list(&r.info, config.index_list_limit),
r.info.name.map(|n| n.to_string()).filter(|s| !s.is_empty()), // librqbit#452 r.info.name().map(|n| n.to_string()),
) )
} }
// unexpected as should be deleted // unexpected as should be deleted
@ -357,12 +357,12 @@ fn magnet(infohash: &str, trackers: Option<&HashSet<Url>>) -> String {
} }
/// Count total size, including torrent files /// Count total size, including torrent files
fn size(info: &TorrentMetaV1Info<ByteBufOwned>) -> u64 { fn size(meta: &ValidatedTorrentMetaV1Info<ByteBufOwned>) -> u64 {
let mut t = 0; let mut t = 0;
if let Some(l) = info.length { if let Some(l) = meta.info().length {
t += l t += l
} }
if let Some(ref files) = info.files { if let Some(ref files) = meta.info().files {
for f in files { for f in files {
t += f.length t += f.length
} }
@ -371,10 +371,10 @@ fn size(info: &TorrentMetaV1Info<ByteBufOwned>) -> u64 {
} }
fn list( fn list(
info: &TorrentMetaV1Info<ByteBufOwned>, meta: &ValidatedTorrentMetaV1Info<ByteBufOwned>,
limit: usize, limit: usize,
) -> Option<Vec<(Option<String>, u64)>> { ) -> Option<Vec<(Option<String>, u64)>> {
info.files.as_ref().map(|files| { meta.info().files.as_ref().map(|files| {
let mut b = Vec::with_capacity(files.len()); let mut b = Vec::with_capacity(files.len());
let mut i = files.iter(); let mut i = files.iter();
let mut t = 0; let mut t = 0;