rattler_solve 7.2.0

//! Contains business logic that loads information into libsolv in order to
//! solve a conda environment

use std::{cmp::Ordering, collections::HashMap};

use rattler_conda_types::{
    GenericVirtualPackage, RepoDataRecord, RepodataRevision,
    package::{ArchiveIdentifier, DistArchiveType},
};
use rattler_conda_types::{MatchSpec, MatchSpecCondition, ParseMatchSpecOptions};
use std::collections::HashSet;

use crate::ExcludeNewer;

use super::{
    c_string,
    libc_byte_slice::LibcByteSlice,
    wrapper::{
        keys::{
            REPOKEY_TYPE_MD5, REPOKEY_TYPE_SHA256, SOLVABLE_BUILDFLAVOR, SOLVABLE_BUILDTIME,
            SOLVABLE_BUILDVERSION, SOLVABLE_CHECKSUM, SOLVABLE_CONSTRAINS, SOLVABLE_DOWNLOADSIZE,
            SOLVABLE_EXTRA_NAME, SOLVABLE_EXTRA_PACKAGE, SOLVABLE_LICENSE, SOLVABLE_PKGID,
            SOLVABLE_REPODATA_RECORD_INDEX, SOLVABLE_TRACK_FEATURES,
        },
        pool::Pool,
        repo::Repo,
        repodata::Repodata,
        solvable::SolvableId,
    },
};
use crate::SolveError;

fn parse_libsolv_match_spec(match_spec_str: &str) -> Result<Option<MatchSpec>, SolveError> {
    let Ok(match_spec) = MatchSpec::from_str(
        match_spec_str,
        ParseMatchSpecOptions::lenient().with_repodata_revision(RepodataRevision::V3),
    ) else {
        return Ok(None);
    };

    super::ensure_matchspec_flags_supported(&match_spec)?;
    Ok(Some(match_spec))
}

#[cfg(not(target_family = "unix"))]
/// Adds solvables to a repo from an in-memory .solv file
///
/// Note: this function relies on primitives that are only available on
/// unix-like operating systems, and will panic if called from another platform
/// (e.g. Windows)
pub fn add_solv_file(_pool: &Pool, _repo: &Repo<'_>, _solv_bytes: &LibcByteSlice) {
    unimplemented!("this platform does not support in-memory .solv files");
}

#[cfg(target_family = "unix")]
/// Adds solvables to a repo from an in-memory .solv file
///
/// Note: this function relies on primitives that are only available on
/// unix-like operating systems, and will panic if called from another platform
/// (e.g. Windows)
pub fn add_solv_file(pool: &Pool, repo: &Repo<'_>, solv_bytes: &LibcByteSlice) {
    // Add solv file from memory if available
    let mode = c_string("r");
    let file = unsafe { libc::fmemopen(solv_bytes.as_ptr(), solv_bytes.len(), mode.as_ptr()) };
    repo.add_solv(pool, file);
    unsafe { libc::fclose(file) };
}

/// Parses a condition from a `MatchSpecCondition` and returns the corresponding libsolv Id
pub fn parse_condition(condition: &MatchSpecCondition, pool: &Pool) -> super::wrapper::ffi::Id {
    match condition {
        MatchSpecCondition::MatchSpec(match_spec) => {
            // Convert the match spec to a string and use conda_matchspec to parse it
            let match_spec_str = match_spec.to_string();
            let c_str = c_string(&match_spec_str);
            pool.conda_matchspec(&c_str)
        }
        MatchSpecCondition::And(left, right) => {
            let left_id = parse_condition(left, pool);
            let right_id = parse_condition(right, pool);
            pool.rel_and(left_id, right_id)
        }
        MatchSpecCondition::Or(left, right) => {
            let left_id = parse_condition(left, pool);
            let right_id = parse_condition(right, pool);
            pool.rel_or(left_id, right_id)
        }
    }
}

/// Adds [`RepoDataRecord`] to `repo`
///
/// Panics if the repo does not belong to the pool
pub fn add_repodata_records<'a>(
    pool: &Pool,
    repo: &Repo<'_>,
    repo_data: impl IntoIterator<Item = &'a RepoDataRecord>,
    exclude_newer: Option<&ExcludeNewer>,
) -> Result<Vec<SolvableId>, SolveError> {
    // Sanity check
    repo.ensure_belongs_to_pool(pool);

    // Get all the IDs (these strings are internal to libsolv and always present, so
    // we can unwrap them at will)
    let solvable_buildflavor_id = pool.find_interned_str(SOLVABLE_BUILDFLAVOR).unwrap();
    let solvable_buildtime_id = pool.find_interned_str(SOLVABLE_BUILDTIME).unwrap();
    let solvable_buildversion_id = pool.find_interned_str(SOLVABLE_BUILDVERSION).unwrap();
    let solvable_constraints = pool.find_interned_str(SOLVABLE_CONSTRAINS).unwrap();
    let solvable_download_size_id = pool.find_interned_str(SOLVABLE_DOWNLOADSIZE).unwrap();
    let solvable_license_id = pool.find_interned_str(SOLVABLE_LICENSE).unwrap();
    let solvable_pkg_id = pool.find_interned_str(SOLVABLE_PKGID).unwrap();
    let solvable_checksum = pool.find_interned_str(SOLVABLE_CHECKSUM).unwrap();
    let solvable_track_features = pool.find_interned_str(SOLVABLE_TRACK_FEATURES).unwrap();
    let repo_type_md5 = pool.find_interned_str(REPOKEY_TYPE_MD5).unwrap();
    let repo_type_sha256 = pool.find_interned_str(REPOKEY_TYPE_SHA256).unwrap();

    // Custom id
    let solvable_index_id = pool.intern_str(SOLVABLE_REPODATA_RECORD_INDEX);

    // Keeps a mapping from packages added to the repo to the type and solvable
    let mut package_to_type: HashMap<&ArchiveIdentifier, (DistArchiveType, SolvableId)> =
        HashMap::new();

    // Through `data` we can manipulate solvables (see the `Repodata` docs for
    // details)
    let data = repo.add_repodata();

    let mut solvable_ids = Vec::new();

    // Track all extras we encounter so we can create synthetic solvables for them
    let mut extras: HashSet<(String, String)> = HashSet::new();
    for (repo_data_index, repo_data) in repo_data.into_iter().enumerate() {
        if let Some(config) = exclude_newer
            && config.is_excluded(
                &repo_data.package_record.name,
                repo_data.channel.as_deref(),
                repo_data.package_record.timestamp.as_ref(),
            )
        {
            continue;
        }

        // Create a solvable for the package
        let solvable_id =
            match add_or_reuse_solvable(pool, repo, &data, &mut package_to_type, repo_data)? {
                Some(id) => id,
                None => continue,
            };

        // Store the current index so we can retrieve the original repo data record
        // from the final transaction
        data.set_num(solvable_id, solvable_index_id, repo_data_index as u64);

        // Safe because there are no other active references to any solvable (so no
        // aliasing)
        let solvable = unsafe { solvable_id.resolve_raw(pool).as_mut() };
        let record = &repo_data.package_record;

        // Name and version
        solvable.name = pool.intern_str(record.name.as_normalized()).into();
        solvable.evr = pool.intern_str(record.version.to_string()).into();
        let rel_eq = pool.rel_eq(solvable.name, solvable.evr);
        repo.add_provides(solvable, rel_eq);

        // Location (filename (fn) and subdir)
        data.set_location(
            solvable_id,
            &c_string(&record.subdir),
            &c_string(repo_data.identifier.to_string()),
        );

        // Dependencies
        for match_spec_str in record.depends.iter() {
            if let Some(match_spec) = parse_libsolv_match_spec(match_spec_str)?
                && let Some(condition) = match_spec.condition.as_ref()
            {
                // Create the dependency without the condition
                let mut dep_spec = match_spec.clone();
                dep_spec.condition = None;
                let dep_id = pool.conda_matchspec(&c_string(dep_spec.to_string()));

                // Parse the condition
                let condition_id = parse_condition(condition, pool);

                // Create a conditional dependency
                let conditional_dep_id = pool.rel_cond(dep_id, condition_id);

                // Add it to the list of requirements
                repo.add_requires(solvable, conditional_dep_id);
                continue;
            }

            // Regular dependency without condition
            let match_spec_id = pool.conda_matchspec(&c_string(match_spec_str));
            repo.add_requires(solvable, match_spec_id);
        }

        // Constraints
        for match_spec in record.constrains.iter() {
            parse_libsolv_match_spec(match_spec)?;

            // Create a reldep id from a matchspec
            let match_spec_id = pool.conda_matchspec(&c_string(match_spec));

            // Add it to the list of constraints of this solvable
            data.add_idarray(solvable_id, solvable_constraints, match_spec_id);
        }

        // Process extra_depends: convert them into conditional requirements
        for (extra_name, deps) in record.extra_depends.iter() {
            // Track this extra for synthetic solvable creation
            extras.insert((record.name.as_normalized().to_string(), extra_name.clone()));

            // Create conditional dependencies: dep[when="package[extra]"]
            for dep_str in deps.iter() {
                parse_libsolv_match_spec(dep_str)?;

                // Parse the dependency matchspec
                let dep_id = pool.conda_matchspec(&c_string(dep_str));

                // Create the condition: package[extra]
                let extra_name_str = format!("{}[{}]", record.name.as_normalized(), extra_name);
                let extra_condition_id = pool.intern_str(extra_name_str.as_str()).into();

                // Create a conditional dependency: dep[when="package[extra]"]
                let conditional_dep_id = pool.rel_cond(dep_id, extra_condition_id);

                // Add it as a requirement
                repo.add_requires(solvable, conditional_dep_id);
            }
        }

        // Track features
        for track_features in record.track_features.iter() {
            let track_feature = track_features.trim();
            if !track_feature.is_empty() {
                data.add_idarray(
                    solvable_id,
                    solvable_track_features,
                    pool.intern_str(track_features.trim()).into(),
                );
            }
        }

        // Timestamp
        if let Some(timestamp) = record.timestamp {
            data.set_num(
                solvable_id,
                solvable_buildtime_id,
                timestamp.timestamp() as u64,
            );
        }

        // Size
        if let Some(size) = record.size {
            data.set_num(solvable_id, solvable_download_size_id, size);
        }

        // Build string
        data.add_poolstr_array(
            solvable_id,
            solvable_buildflavor_id,
            &c_string(&record.build),
        );

        // Build number
        data.set_str(
            solvable_id,
            solvable_buildversion_id,
            &c_string(record.build_number.to_string()),
        );

        // License
        if let Some(license) = record.license.as_ref() {
            data.add_poolstr_array(solvable_id, solvable_license_id, &c_string(license));
        }

        // MD5 hash
        if let Some(md5) = record.md5.as_ref() {
            data.set_checksum(
                solvable_id,
                solvable_pkg_id,
                repo_type_md5,
                &c_string(hex::encode(md5)),
            );
        }

        // Sha256 hash
        if let Some(sha256) = record.sha256.as_ref() {
            data.set_checksum(
                solvable_id,
                solvable_checksum,
                repo_type_sha256,
                &c_string(hex::encode(sha256)),
            );
        }

        solvable_ids.push(solvable_id);
    }

    // Custom ids for storing extra info on synthetic solvables
    let extra_package_id = pool.intern_str(SOLVABLE_EXTRA_PACKAGE);
    let extra_name_id = pool.intern_str(SOLVABLE_EXTRA_NAME);

    // Add synthetic solvables for extras
    for (package_name, extra_name) in extras {
        // Create synthetic solvable with name "package[extra]"
        let solvable_id = repo.add_solvable();
        let solvable = unsafe { solvable_id.resolve_raw(pool).as_mut() };

        // Set the name to "package[extra]" using bracket notation
        let synthetic_name = format!("{package_name}[{extra_name}]");
        solvable.name = pool.intern_str(synthetic_name.as_str()).into();

        // Set a dummy version (version "0" to indicate this is a synthetic solvable)
        solvable.evr = pool.intern_str("0").into();

        // Add self-provides so the solver can find it
        let rel_eq = pool.rel_eq(solvable.name, solvable.evr);
        repo.add_provides(solvable, rel_eq);

        // Store extra info so we can retrieve it from the transaction
        let package_name_interned = pool.intern_str(package_name.as_str());
        let extra_name_interned = pool.intern_str(extra_name.as_str());
        data.set_id(solvable_id, extra_package_id, package_name_interned.into());
        data.set_id(solvable_id, extra_name_id, extra_name_interned.into());

        solvable_ids.push(solvable_id);
    }

    repo.internalize();

    Ok(solvable_ids)
}

/// When adding packages, we want to make sure that `.conda` packages have
/// preference over `.tar.bz` packages. For that reason, when adding a solvable
/// we check first if a `.conda` version of the package has already been added,
/// in which case we forgo adding its `.tar.bz` version (and return `None`). If
/// no `.conda` version has been added, we create a new solvable (replacing any
/// existing solvable for the `.tar.bz` version of the package).
fn add_or_reuse_solvable<'a>(
    pool: &Pool,
    repo: &Repo<'_>,
    data: &Repodata<'_>,
    package_to_type: &mut HashMap<&'a ArchiveIdentifier, (DistArchiveType, SolvableId)>,
    repo_data: &'a RepoDataRecord,
) -> Result<Option<SolvableId>, SolveError> {
    // Sometimes we can reuse an existing solvable
    let identifier = &repo_data.identifier.identifier;
    let archive_type = repo_data.identifier.archive_type;

    if let Some(&(other_package_type, old_solvable_id)) = package_to_type.get(identifier) {
        match archive_type.cmp_preference(other_package_type) {
            Ordering::Less => {
                // A previous package that we already stored is actually a package of a better
                // "type" so we'll just use that instead (.conda > .tar.bz)
                Ok(None)
            }
            Ordering::Greater => {
                // A previous package has a worse package "type", we'll reuse the handle but
                // overwrite its attributes

                // Update the package to the new type mapping
                package_to_type.insert(identifier, (archive_type, old_solvable_id));

                // Reset and reuse the old solvable
                reset_solvable(pool, repo, data, old_solvable_id);
                Ok(Some(old_solvable_id))
            }
            Ordering::Equal => Err(SolveError::DuplicateRecords(identifier.to_string())),
        }
    } else {
        let solvable_id = repo.add_solvable();
        package_to_type.insert(identifier, (archive_type, solvable_id));
        Ok(Some(solvable_id))
    }
}

pub fn add_virtual_packages(pool: &Pool, repo: &Repo<'_>, packages: &[GenericVirtualPackage]) {
    let data = repo.add_repodata();

    let solvable_buildflavor_id = pool.find_interned_str(SOLVABLE_BUILDFLAVOR).unwrap();

    for package in packages {
        // Create a solvable for the package
        let solvable_id = repo.add_solvable();

        // Safe because there are no other references to this solvable_id (we just
        // created it)
        let solvable = unsafe { solvable_id.resolve_raw(pool).as_mut() };

        // Name and version
        solvable.name = pool.intern_str(package.name.as_normalized()).into();
        solvable.evr = pool.intern_str(package.version.to_string()).into();
        let rel_eq = pool.rel_eq(solvable.name, solvable.evr);
        repo.add_provides(solvable, rel_eq);

        // Build string
        data.add_poolstr_array(
            solvable_id,
            solvable_buildflavor_id,
            &c_string(&package.build_string),
        );
    }
}

fn reset_solvable(pool: &Pool, repo: &Repo<'_>, data: &Repodata<'_>, solvable_id: SolvableId) {
    let blank_solvable = repo.add_solvable();

    // Replace the existing solvable with the blank one
    pool.swap_solvables(blank_solvable, solvable_id);
    data.swap_attrs(blank_solvable, solvable_id);

    // It is safe to free the blank solvable, because there are no other references
    // to it than in this function
    unsafe { repo.free_solvable(blank_solvable) };
}

/// Caches the repodata as an in-memory `.solv` file
///
/// Note: this function relies on primitives that are only available on
/// unix-like operating systems, and will panic if called from another platform
/// (e.g. Windows)
#[cfg(not(target_family = "unix"))]
pub fn cache_repodata(_url: String, _data: &[RepoDataRecord]) -> Result<LibcByteSlice, SolveError> {
    unimplemented!("this function is only available on unix-like operating systems")
}

/// Caches the repodata as an in-memory `.solv` file
///
/// Note: this function relies on primitives that are only available on
/// unix-like operating systems, and will panic if called from another platform
/// (e.g. Windows)
#[cfg(target_family = "unix")]
pub fn cache_repodata(
    url: String,
    data: &[RepoDataRecord],
    channel_priority: Option<i32>,
) -> Result<LibcByteSlice, SolveError> {
    // Add repodata to a new pool + repo
    let pool = Pool::default();
    let repo = Repo::new(&pool, url, channel_priority.unwrap_or(0));
    add_repodata_records(&pool, &repo, data, None)?;

    // Export repo to .solv in memory
    let mut stream_ptr = std::ptr::null_mut();
    let mut stream_size = 0;
    let file = unsafe { libc::open_memstream(&mut stream_ptr, &mut stream_size) };
    assert!(!file.is_null(), "unable to open memstream");

    repo.write(&pool, file);
    unsafe { libc::fclose(file) };

    let stream_ptr = std::ptr::NonNull::new(stream_ptr).expect("stream_ptr was null");

    // Safe because we know `stream_ptr` points to an array of bytes of length
    // `stream_size`
    Ok(unsafe { LibcByteSlice::from_raw_parts(stream_ptr.cast(), stream_size) })
}