pkg/backend/pkgar_backend/

mod.rs

use std::{
    cell::RefCell,
    fs,
    path::{Path, PathBuf},
    rc::Rc,
};

use pkgar::{MergedTransaction, PackageFile, Transaction};
use pkgar_core::PublicKey;

use super::{Backend, Error};
use crate::{
    callback::Callback,
    package::{RemotePackage, Repository},
    package_state::PackageState,
    repo_manager::RepoManager,
    Package, PackageName, RepoPublicKeyFile,
};

/// Package backend using pkgar
pub struct PkgarBackend {
    /// Root path, usually "/"
    install_path: PathBuf,
    /// Things in "/etc/pkg/package.toml"
    packages: PackageState,
    /// Things in "/etc/pkg.d" and inet
    repo_manager: RepoManager,
    /// temporary commit
    commits: Option<MergedTransaction>,
    keys_synced: bool,
    callback: Rc<RefCell<dyn Callback>>,
}

impl PkgarBackend {
    pub fn new<P: AsRef<Path>>(install_path: P, repo_manager: RepoManager) -> Result<Self, Error> {
        let install_path = install_path.as_ref();

        let packages = PackageState::from_sysroot(install_path)?;

        // TODO: Use File::lock. This only checks permission
        packages.to_sysroot(install_path)?;

        fs::create_dir_all(install_path.join(crate::PACKAGES_HEAD_DIR))?;

        let callback = repo_manager.callback.clone();

        Ok(PkgarBackend {
            install_path: install_path.to_path_buf(),
            packages,
            repo_manager,
            // packages_lock,
            commits: Some(MergedTransaction::new()),
            keys_synced: false,
            callback,
        })
    }

    fn add_transaction(&mut self, transaction: Transaction, src: Option<&PackageFile>) {
        let mut commits = self
            .commits
            .take()
            .unwrap_or_else(|| MergedTransaction::new());
        commits.merge(transaction, src);
        self.commits = Some(commits);
    }

    // reads /var/lib/packages/[package].pkgar_head
    fn get_package_head(&self, package: &PackageName) -> Result<PackageFile, Error> {
        let path = self
            .install_path
            .join(crate::PACKAGES_HEAD_DIR)
            .join(format!("{package}.pkgar_head"));

        let Some(pkg) = self.packages.installed.get(package) else {
            return Err(Error::PackageNotInstalled(package.clone()));
        };
        let Some(remote) = self.packages.pubkeys.get(&pkg.remote) else {
            return Err(Error::RepoCacheNotFound(package.clone()));
        };

        let pkg = PackageFile::new(&path, &remote.pkey).map_err(Error::from)?;

        Ok(pkg)
    }

    fn remove_package_head(&mut self, package: &PackageName) -> Result<(), Error> {
        let path = self
            .install_path
            .join(crate::PACKAGES_HEAD_DIR)
            .join(format!("{package}.pkgar_head"));

        fs::remove_file(path)?;
        Ok(())
    }

    fn create_head(
        &self,
        archive_path: &Path,
        package: &PackageName,
        pubkey: &PublicKey,
    ) -> Result<(), Error> {
        // creates a head file
        let head_path = self
            .install_path
            .join(crate::PACKAGES_HEAD_DIR)
            .join(format!("{package}.pkgar_head"));

        let mut package = PackageFile::new(archive_path, &pubkey)?;
        package.split(&head_path, None::<&Path>)?;

        Ok(())
    }

    fn sync_keys(&mut self) -> Result<(), Error> {
        if self.keys_synced {
            return Ok(());
        }

        for (name, map) in &mut self.repo_manager.remote_map {
            if map.pubkey.is_none() {
                if let Some(pubk) = self.packages.pubkeys.get(name) {
                    map.pubkey = Some(pubk.pkey)
                }
            }
        }

        self.repo_manager.sync_keys()?;

        self.keys_synced = true;
        Ok(())
    }
}

impl Backend for PkgarBackend {
    fn install(&mut self, package: RemotePackage) -> Result<(), Error> {
        self.sync_keys()?;
        if package.package.version.is_empty() {
            return Ok(()); // metapackage
        }
        // TODO: Actually use that specific remote
        let (local_path, repo) = self
            .repo_manager
            .get_package_pkgar(&package.package.name, package.package.network_size)?;
        let mut pkg = PackageFile::new(&local_path, &repo.pubkey.unwrap())?;
        self.callback.borrow_mut().install_extract(&package);
        let install = Transaction::install(&mut pkg, &self.install_path)?;
        self.create_head(&local_path, &package.package.name, &repo.pubkey.unwrap())?;
        self.add_transaction(install, Some(&pkg));
        Ok(())
    }

    fn uninstall(&mut self, package: PackageName) -> Result<(), Error> {
        if self.packages.protected.contains(&package) {
            return Err(Error::ProtectedPackage(package));
        }
        self.sync_keys()?;

        let mut pkg = self.get_package_head(&package)?;
        let remove = Transaction::remove(&mut pkg, &self.install_path)?;
        self.add_transaction(remove, Some(&pkg));

        self.remove_package_head(&package)?;

        Ok(())
    }

    fn upgrade(&mut self, package: &RemotePackage) -> Result<(), Error> {
        self.sync_keys()?;

        let name = &package.package.name;
        let mut pkg = self.get_package_head(name)?;
        let (local_path, repo) = self
            .repo_manager
            .get_package_pkgar(name, package.package.network_size)?;
        let mut pkg2 = PackageFile::new(&local_path, &repo.pubkey.unwrap())?;
        let update = Transaction::replace(&mut pkg, &mut pkg2, &self.install_path)?;
        self.create_head(&local_path, &name, &repo.pubkey.unwrap())?;
        self.add_transaction(update, Some(&pkg));
        Ok(())
    }

    fn get_package_detail(&self, package: &PackageName) -> Result<RemotePackage, Error> {
        let (toml, remote) = self.repo_manager.get_package_toml(package)?;

        Ok(RemotePackage {
            package: Package::from_toml(&toml)?,
            remote,
        })
    }

    /// TODO: Multiple repository support
    fn get_repository_detail(&self) -> Result<Repository, Error> {
        let repo_str = PackageName::new("repo".to_string())?;
        let (toml, _) = self.repo_manager.get_package_toml(&repo_str)?;

        Ok(Repository::from_toml(&toml)?)
    }

    fn get_package_state(&self) -> PackageState {
        self.packages.clone()
    }

    fn commit_check_conflict(&self) -> Result<&Vec<pkgar::TransactionConflict>, Error> {
        let transaction = self
            .commits
            .as_ref()
            .ok_or_else(|| Error::Pkgar(Box::new(pkgar::Error::DataNotInitialized)))?;
        Ok(transaction.get_possible_conflicts())
    }

    fn commit_state(&mut self, new_state: PackageState) -> Result<usize, Error> {
        let mut transaction = self
            .commits
            .take()
            .ok_or_else(|| Error::Pkgar(Box::new(pkgar::Error::DataNotInitialized)))?
            .into_transaction();
        self.callback
            .borrow_mut()
            .commit_start(transaction.pending_commit());
        while transaction.pending_commit() > 0 {
            self.callback.borrow_mut().commit_increment(&transaction);
            if let Err(e) = transaction.commit_one() {
                self.add_transaction(transaction, None);
                return Err(Error::from(e));
            }
        }
        self.callback.borrow_mut().commit_end();

        self.packages = new_state;
        for (k, v) in &self.repo_manager.remote_map {
            let Some(pubkey) = v.pubkey else {
                return Err(Error::RepoNotLoaded(k.to_string()));
            };
            let pk = RepoPublicKeyFile::new(pubkey);
            self.packages.pubkeys.insert(k.to_string(), pk);
        }
        self.packages.to_sysroot(&self.install_path)?;
        Ok(transaction.total_committed())
    }

    fn abort_state(&mut self) -> Result<usize, Error> {
        let mut transaction = self
            .commits
            .take()
            .ok_or_else(|| Error::Pkgar(Box::new(pkgar::Error::DataNotInitialized)))?
            .into_transaction();
        self.callback
            .borrow_mut()
            .abort_start(transaction.pending_commit());
        while transaction.pending_commit() > 0 {
            self.callback.borrow_mut().commit_increment(&transaction);
            if let Err(e) = transaction.abort_one() {
                self.add_transaction(transaction, None);
                return Err(Error::from(e));
            }
        }
        self.callback.borrow_mut().abort_end();
        Ok(transaction.total_committed())
    }
}