use super::IndexPackage;
use crate::{
lock::Lock,
util::{crate_walker, pkg_path},
};
use anyhow::{Context, Error};
use semver::VersionReq;
use std::{fs, path::Path};
pub fn list(
index: impl AsRef<Path>,
pkg_name: &str,
version_req: Option<&str>,
) -> Result<Vec<IndexPackage>, Error> {
let index = index.as_ref();
let lock = Lock::new_shared(index)?;
let version_req = if let Some(version) = version_req {
Some(VersionReq::parse(version)?)
} else {
None
};
let res = _list(index, pkg_name, version_req.as_ref())?;
drop(lock);
Ok(res)
}
pub fn list_all(
index: impl AsRef<Path>,
pkg_name: Option<&str>,
version_req: Option<&str>,
mut cb: impl FnMut(Vec<IndexPackage>),
) -> Result<(), Error> {
let index = index.as_ref();
let lock = Lock::new_shared(index)?;
let version_req = if let Some(version_req) = version_req {
Some(VersionReq::parse(version_req)?)
} else {
None
};
if let Some(pkg_name) = pkg_name {
let entries = _list(index, pkg_name, version_req.as_ref())?;
cb(entries);
} else {
for entry in crate_walker(index) {
let entry = entry?;
let pkg_name = entry.file_name().to_str().unwrap();
let entries = _list(index, pkg_name, version_req.as_ref())?;
cb(entries);
}
};
drop(lock);
Ok(())
}
pub(crate) fn _list(
index: &Path,
pkg_name: &str,
version_req: Option<&VersionReq>,
) -> Result<Vec<IndexPackage>, Error> {
let repo_path = pkg_path(pkg_name);
let path = index.join(repo_path);
if !path.exists() {
return Ok(vec![]);
}
let contents = fs::read_to_string(&path)
.with_context(|| format!("Failed to read `{}`.", path.display()))?;
contents
.lines()
.map(|line| {
Ok(serde_json::from_str(line).with_context(|| {
format!("Could not deserialize `{}` line:\n{}", path.display(), line)
})?)
})
.filter(|index_pkg: &Result<IndexPackage, Error>| -> bool {
if let Some(version_req) = &version_req {
if let Ok(index_pkg) = index_pkg {
version_req.matches(&index_pkg.vers)
} else {
true
}
} else {
true
}
})
.collect::<Result<Vec<IndexPackage>, Error>>()
}