pkgxdev / pkgx / 12768583963

pub async fn ls(project: &str, config: &Config) -> Result<Vec<Installation>, Box<dyn Error>> {

    let d = config.pkgx_dir.join(project);

    if !fs::metadata(&d).await?.is_dir() {

        return Ok(vec![]);

    let mut rv = vec![];

    let mut entries = fs::read_dir(&d).await?;

    while let Some(entry) = entries.next_entry().await? {

        let path = entry.path();

        let name = entry.file_name().to_string_lossy().to_string();

        if !name.starts_with('v') || name == "var" {

        if !fs::symlink_metadata(&path).await?.is_dir() {

        if let Ok(version) = Version::parse(&name[1..]) {

            rv.push(Installation {

                path,

                pkg: Package {

                    project: project.to_string(),

                    version,

    Ok(rv)

pub async fn resolve(pkgreq: &PackageReq, config: &Config) -> Result<Installation, Box<dyn Error>> {

    let installations = ls(&pkgreq.project, config).await?;

    if let Some(i) = installations

        .filter(|i| pkgreq.constraint.satisfies(&i.pkg.version))

        .max_by_key(|i| i.pkg.version.clone())

        Ok(i.clone())

        Err(format!("couldn’t resolve {:?}", pkgreq).into())

pub async fn has(pkg: &PackageReq, config: &Config) -> Option<Installation> {

    resolve(pkg, config).await.ok()

pub fn dst(pkg: &Package, config: &Config) -> PathBuf {

    config

        .join(pkg.project.clone())

        .join(format!("v{}", pkg.version.raw))