Struct MetadataRepository 

pub struct MetadataRepository;

Repository for package metadata operations.

Implementations

impl MetadataRepository

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

Lists all packages using Diesel DSL.

pub fn list_all_minimal( conn: &mut SqliteConnection, ) -> QueryResult<Vec<PackageListing>>

Lists all packages with only the fields needed for display. This is much more memory-efficient than list_all for large package lists.

pub fn list_paginated( conn: &mut SqliteConnection, page: i64, per_page: i64, ) -> QueryResult<Vec<Package>>

Lists packages with pagination and sorting using Diesel DSL.

pub fn get_repo_name(conn: &mut SqliteConnection) -> QueryResult<Option<String>>

Gets the repository name from the database.

pub fn get_repo_etag(conn: &mut SqliteConnection) -> QueryResult<Option<String>>

Gets the repository etag from the database.

pub fn update_repo_metadata( conn: &mut SqliteConnection, name: &str, etag: &str, ) -> QueryResult<usize>

Updates the repository metadata (name and etag).

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

Finds a package by ID using Diesel DSL.

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

Finds packages by name (exact match) using Diesel DSL.

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

Finds a package by pkg_id using Diesel DSL.

pub fn find_by_query( conn: &mut SqliteConnection, pkg_name: Option<&str>, pkg_id: Option<&str>, version: Option<&str>, ) -> QueryResult<Vec<Package>>

Finds packages that match pkg_name and optionally pkg_id and version using Diesel DSL.

pub fn search( conn: &mut SqliteConnection, pattern: &str, limit: Option<i64>, ) -> QueryResult<Vec<Package>>

Searches packages by pattern (case-insensitive LIKE query) using Diesel DSL. Searches across pkg_name and pkg_id fields.

pub fn search_case_sensitive( conn: &mut SqliteConnection, pattern: &str, limit: Option<i64>, ) -> QueryResult<Vec<Package>>

Searches packages (case-sensitive LIKE query) using Diesel DSL.

pub fn find_replacement_pkg_id( conn: &mut SqliteConnection, pkg_id: &str, ) -> QueryResult<Option<String>>

Checks if a package exists that replaces the given pkg_id. Returns the pkg_id of the replacement package if found. Uses raw SQL for JSON array search since Diesel doesn’t support json_each.

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

Counts total packages.

pub fn count_search( conn: &mut SqliteConnection, pattern: &str, ) -> QueryResult<i64>

Counts packages matching a search pattern using Diesel DSL.

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

Inserts a new package.

pub fn last_insert_id(conn: &mut SqliteConnection) -> QueryResult<i32>

Gets the last inserted package ID.

pub fn find_or_create_maintainer( conn: &mut SqliteConnection, contact: &str, name: &str, ) -> QueryResult<i32>

Finds or creates a maintainer.

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

Links a maintainer to a package.

pub fn get_maintainers( conn: &mut SqliteConnection, package_id: i32, ) -> QueryResult<Vec<Maintainer>>

Gets maintainers for a package.

pub fn delete_all(conn: &mut SqliteConnection) -> QueryResult<usize>

Deletes all packages (for reimport).

pub fn find_filtered( conn: &mut SqliteConnection, pkg_name: Option<&str>, pkg_id: Option<&str>, version: Option<&str>, limit: Option<i64>, sort_by_name: Option<SortDirection>, ) -> QueryResult<Vec<Package>>

Finds packages with flexible filtering using Diesel DSL.

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

Finds packages with a newer version than the given version. Used for update checking. Uses Diesel DSL with raw SQL filter for version comparison.

pub fn exists_by_pkg_id( conn: &mut SqliteConnection, pkg_id: &str, ) -> QueryResult<bool>

Checks if a package with the given pkg_id exists.

pub fn import_packages( conn: &mut SqliteConnection, metadata: &[RemotePackage], repo_name: &str, ) -> QueryResult<()>

Imports packages from remote metadata (JSON format).