Struct CoreRepository 

pub struct CoreRepository;

Repository for installed package operations.

Implementations

impl CoreRepository

pub fn list_all(conn: &mut SqliteConnection) -> QueryResult<Vec<Package>>

Lists all installed packages.

pub fn list_filtered( conn: &mut SqliteConnection, repo_name: Option<&str>, pkg_name: Option<&str>, pkg_id: Option<&str>, version: Option<&str>, is_installed: Option<bool>, pinned: Option<bool>, limit: Option<i64>, sort_by_id: Option<SortDirection>, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Lists installed packages with flexible filtering.

pub fn list_broken( conn: &mut SqliteConnection, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Lists broken packages (is_installed = false).

pub fn list_updatable( conn: &mut SqliteConnection, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Lists installed packages that are not pinned (for updates).

pub fn find_exact( conn: &mut SqliteConnection, repo_name: &str, pkg_name: &str, pkg_id: &str, version: &str, ) -> QueryResult<Option<InstalledPackageWithPortable>>

Finds an installed package by exact match on repo_name, pkg_name, pkg_id, and version.

pub fn list_all_with_portable( conn: &mut SqliteConnection, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Lists all installed packages with portable configuration.

pub fn list_by_repo( conn: &mut SqliteConnection, repo_name: &str, ) -> QueryResult<Vec<Package>>

Lists installed packages filtered by repo_name.

pub fn list_by_repo_with_portable( conn: &mut SqliteConnection, repo_name: &str, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Lists installed packages filtered by repo_name with portable configuration.

pub fn count(conn: &mut SqliteConnection) -> QueryResult<i64>

Counts installed packages.

pub fn count_distinct_installed( conn: &mut SqliteConnection, repo_name: Option<&str>, ) -> QueryResult<i64>

Counts distinct installed packages.

pub fn find_by_id( conn: &mut SqliteConnection, id: i32, ) -> QueryResult<Option<Package>>

Finds an installed package by ID.

pub fn find_by_id_with_portable( conn: &mut SqliteConnection, id: i32, ) -> QueryResult<Option<InstalledPackageWithPortable>>

Finds an installed package by ID with portable configuration.

pub fn find_by_name( conn: &mut SqliteConnection, name: &str, ) -> QueryResult<Vec<Package>>

Finds installed packages by name.

pub fn find_by_name_with_portable( conn: &mut SqliteConnection, name: &str, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Finds installed packages by name with portable configuration.

pub fn find_alternates( conn: &mut SqliteConnection, pkg_name: &str, exclude_pkg_id: &str, exclude_version: &str, ) -> QueryResult<Vec<InstalledPackageWithPortable>>

Finds installed packages by name, excluding specific pkg_id and version.

pub fn find_by_pkg_id_and_repo( conn: &mut SqliteConnection, pkg_id: &str, repo_name: &str, ) -> QueryResult<Option<Package>>

Finds an installed package by pkg_id and repo_name.

pub fn find_by_pkg_id_name_and_repo( conn: &mut SqliteConnection, pkg_id: &str, pkg_name: &str, repo_name: &str, ) -> QueryResult<Option<Package>>

Finds an installed package by pkg_id, pkg_name, and repo_name.

pub fn insert( conn: &mut SqliteConnection, package: &NewPackage<'_>, ) -> QueryResult<i32>

Inserts a new installed package and returns the inserted ID.

pub fn update_version( conn: &mut SqliteConnection, id: i32, new_version: &str, ) -> QueryResult<usize>

Updates an installed package’s version.

pub fn record_installation( conn: &mut SqliteConnection, repo_name: &str, pkg_name: &str, pkg_id: &str, version: &str, size: i64, provides: Option<Vec<PackageProvide>>, checksum: Option<&str>, installed_date: &str, installed_path: &str, ) -> QueryResult<Option<i32>>

Updates an installed package after successful installation. Only updates the record with is_installed=false (the newly created one).

pub fn set_pinned( conn: &mut SqliteConnection, id: i32, pinned: bool, ) -> QueryResult<usize>

Sets the pinned status of a package.

pub fn set_unlinked( conn: &mut SqliteConnection, id: i32, unlinked: bool, ) -> QueryResult<usize>

Sets the unlinked status of a package.

pub fn unlink_others( conn: &mut SqliteConnection, pkg_name: &str, keep_pkg_id: &str, keep_version: &str, ) -> QueryResult<usize>

Unlinks all packages with a given name except those matching pkg_id and version.

pub fn update_pkg_id( conn: &mut SqliteConnection, repo_name: &str, old_pkg_id: &str, new_pkg_id: &str, ) -> QueryResult<usize>

Updates the pkg_id for packages matching repo_name and old pkg_id.

pub fn delete(conn: &mut SqliteConnection, id: i32) -> QueryResult<usize>

Deletes an installed package by ID.

pub fn has_pending_install( conn: &mut SqliteConnection, pkg_id: &str, pkg_name: &str, repo_name: &str, version: &str, ) -> QueryResult<bool>

Checks if a pending install (is_installed=false) exists for a specific package version. Used to check if we can resume a partial install.

pub fn delete_pending_installs( conn: &mut SqliteConnection, pkg_id: &str, pkg_name: &str, repo_name: &str, ) -> QueryResult<Vec<String>>

Deletes pending (is_installed=false) records for a package and returns their paths. Used to clean up orphaned partial installs before starting a new install.

pub fn get_portable( conn: &mut SqliteConnection, package_id: i32, ) -> QueryResult<Option<PortablePackage>>

Gets the portable package configuration for a package.

pub fn insert_portable( conn: &mut SqliteConnection, portable: &NewPortablePackage<'_>, ) -> QueryResult<usize>

Inserts portable package configuration.

pub fn upsert_portable( conn: &mut SqliteConnection, package_id: i32, portable_path: Option<&str>, portable_home: Option<&str>, portable_config: Option<&str>, portable_share: Option<&str>, portable_cache: Option<&str>, ) -> QueryResult<usize>

Updates or inserts portable package configuration.

pub fn delete_portable( conn: &mut SqliteConnection, package_id: i32, ) -> QueryResult<usize>

Deletes portable package configuration.

pub fn get_old_package_paths( conn: &mut SqliteConnection, pkg_id: &str, pkg_name: &str, repo_name: &str, force: bool, ) -> QueryResult<Vec<(i32, String)>>

Gets old package versions (all except the newest one) for cleanup. Returns the installed paths of packages to remove. If force is true, includes pinned packages. Otherwise only unpinned packages.

pub fn delete_old_packages( conn: &mut SqliteConnection, pkg_id: &str, pkg_name: &str, repo_name: &str, force: bool, ) -> QueryResult<usize>

Deletes old package versions (all except the newest one). If force is true, deletes pinned packages too. Otherwise only unpinned packages.

pub fn unlink_others_by_checksum( conn: &mut SqliteConnection, pkg_name: &str, keep_pkg_id: &str, keep_checksum: Option<&str>, ) -> QueryResult<usize>

Unlinks all packages with a given name except those matching pkg_id and checksum. Used when switching between alternate package versions.

pub fn link_by_checksum( conn: &mut SqliteConnection, pkg_name: &str, pkg_id: &str, checksum: Option<&str>, ) -> QueryResult<usize>

Links a package by pkg_name, pkg_id, and checksum. Used when switching to an alternate package version.