You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
38 lines
1.7 KiB
Rust
38 lines
1.7 KiB
Rust
use std::collections::HashMap;
|
|
use std::fs::File;
|
|
use std::io::BufRead;
|
|
use futures::executor::block_on;
|
|
use reqwest::StatusCode;
|
|
|
|
pub fn find_package_in_repositories(package: &str, installed: Option<u64>) -> Option<Vec<String>> {
|
|
let mut hits: Vec<String> = vec!();
|
|
let client = reqwest::Client::new();
|
|
let repo_file = File::open("/var/gaypack/repositories.list").expect("Failed to open repository list");
|
|
let mut candidates: HashMap<String, u64> = HashMap::new();
|
|
for repository in std::io::BufReader::new(repo_file).lines() {
|
|
let repository = repository.expect("Unexpected error"); // i find this line kinda funny for some reason
|
|
let resp = block_on(client.get(format!("{}/gaypack/{}/latest/Package.toml", repository, package)).send()).expect("GET request failed");
|
|
let status = resp.status();
|
|
let text = block_on(resp.text()).expect("Failed to receive packet body");
|
|
if installed.is_some() {
|
|
candidates.insert("installed".to_string(), installed.unwrap());
|
|
}
|
|
let package_data = &crate::package::read_package(text);
|
|
dbg!(package_data);
|
|
if status == StatusCode::from_u16(200).unwrap() {
|
|
candidates.insert(repository, package_data.revision);
|
|
}
|
|
};
|
|
let mut sorted: Vec<_> = candidates.iter().collect();
|
|
sorted.sort_by_key(|entry| entry.1);
|
|
let mut highest_version: u64 = 0;
|
|
for (repository, version) in sorted.iter() {
|
|
if **version > highest_version {highest_version = **version};
|
|
hits.push(repository.as_str().to_string());
|
|
}
|
|
if candidates.get("installed") == Some(highest_version) {
|
|
None
|
|
} else {
|
|
Some(hits)
|
|
}
|
|
} |