mise 2026.9.12

//! Project daemons: custom pitchfork definitions and embedded database presets.
pub(crate) mod hook_env;
pub(crate) mod ports;
pub(crate) mod presets;
pub(crate) mod prune;
pub(crate) mod runtime;
pub(crate) mod tasks;
pub(crate) mod urls;

use crate::config::config_file::ConfigFile;
use crate::config::env_directive::EnvDirective;
use crate::config::{Config, ConfigMap, Settings};
use crate::toolset::{ToolRequest, ToolRequestSet, ToolSource};
use eyre::{Result, bail};
use indexmap::IndexMap;
use path_absolutize::Absolutize;
use ports::{PortClaim, PortRequest};
use serde::Deserialize;
use std::collections::BTreeMap;
use std::path::{Path, PathBuf};
use std::sync::Arc;

/// Gate shared by `[daemons]` loading and by tasks that require daemons, so
/// both report the same requirement.
pub(crate) const EXPERIMENTAL: &str = "[daemons] requires experimental = true";

/// Set on a daemon that runs a task, so the `mise run` it starts does not start
/// daemons of its own and recurse.
pub(crate) const DAEMON_TASK_MARKER: &str = "MISE_DAEMON_TASK";

#[derive(Debug, Clone, Deserialize)]
#[serde(untagged)]
pub(crate) enum Declaration {
    Preset(String),
    Definition(toml::Table),
}

/// Project-wide daemon options declared in `[daemons_settings]`.
///
/// Every field is optional so a higher-precedence file can set one key without
/// discarding the others; see [`DaemonSettings::merge`].
#[derive(Debug, Clone, Default, Deserialize)]
#[serde(deny_unknown_fields)]
pub(crate) struct DaemonSettings {
    /// Fixed pitchfork namespace for this project, replacing the hashed default.
    #[serde(default)]
    pub namespace: Option<String>,
    /// Keep linked git worktrees of one repository in separate namespaces.
    #[serde(default)]
    pub namespace_per_worktree: Option<bool>,
}

impl DaemonSettings {
    /// Overlay a higher-precedence file's table onto this one, key by key. A
    /// `mise.local.toml` that sets only `namespace_per_worktree` must not drop
    /// the `namespace` that `mise.toml` established, because other projects
    /// refer to daemons by the qualified ID that namespace produces.
    fn merge(&mut self, other: Self) {
        if other.namespace.is_some() {
            self.namespace = other.namespace;
        }
        if other.namespace_per_worktree.is_some() {
            self.namespace_per_worktree = other.namespace_per_worktree;
        }
    }

    pub(crate) fn namespace_per_worktree(&self) -> bool {
        self.namespace_per_worktree.unwrap_or(true)
    }
}

/// `[daemon_groups]` entry: a bare list of members or a table with `daemons`.
/// The table form, matching `additionalProperties: false` in schema/mise.json.
#[derive(Debug, Clone, Deserialize)]
#[serde(deny_unknown_fields)]
pub(crate) struct GroupTable {
    daemons: Vec<String>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(untagged)]
pub(crate) enum GroupDeclaration {
    List(Vec<String>),
    Table(GroupTable),
}

impl GroupDeclaration {
    fn members(&self) -> &[String] {
        match self {
            GroupDeclaration::List(members) => members,
            GroupDeclaration::Table(table) => &table.daemons,
        }
    }
}

#[derive(Debug, Clone)]
pub(crate) struct Group {
    pub name: String,
    pub source: PathBuf,
    pub root: PathBuf,
    /// Declared members, which may reference other groups in the same project.
    pub members: Vec<String>,
    /// Members expanded to daemon names declared in the same project root.
    pub daemons: Vec<String>,
}

/// What a bare name resolves to for a project; see [`DaemonSet::resolve_bare`].
pub(crate) enum BareName<'a> {
    /// A daemon this project or an ancestor declares. The caller qualifies it
    /// itself; what matters here is that the word is claimed, so no group of
    /// the same name elsewhere answers for it.
    Daemon,
    /// A group declared by this project or an ancestor, expanded per project.
    Group,
    /// A daemon reached with `project`, and the qualified ID it answers to.
    Import(&'a str),
    /// A `project` reference that could not be read, and why. Naming one is an
    /// error; a name some nearer declaration claims never reaches this.
    Unresolved(&'a str),
}

#[derive(Debug, Clone)]
pub(crate) struct Daemon {
    /// Name inside its own project; the key in the owning project's pitchfork config.
    pub name: String,
    pub source: PathBuf,
    pub root: PathBuf,
    pub table: toml::Table,
    pub preset: Option<String>,
    /// Resolved persistent storage for presets, independent of runtime state.
    pub data_dir: Option<PathBuf>,
    /// Task this daemon runs, when declared with `task = "..."`. Retained so
    /// the reference can be checked against the loaded task list, which is not
    /// available while configuration is still being parsed.
    pub task: Option<String>,
    pub tool: Option<(String, String)>,
    pub exports: IndexMap<String, String>,
    /// True when this daemon was declared by another project and pulled in with
    /// `project =`. Its tools and exported environment belong to that project.
    pub imported: bool,
    /// The resolved allocation for a `port = "auto"` daemon, persisted so it
    /// survives a later change to the slot derivation.
    pub port: Option<PortClaim>,
    /// The hostname pitchfork's proxy routes to this daemon, unless it set
    /// `proxy = false`. Unlike the port it does not move between checkouts.
    pub host: Option<String>,
}

#[derive(Debug, Default, Clone)]
pub(crate) struct DaemonSet {
    /// Keyed by local name for own daemons and by qualified ID for imported ones.
    pub daemons: IndexMap<String, Daemon>,
    /// Resolved pitchfork namespace for every project root in this set.
    pub namespaces: IndexMap<PathBuf, String>,
    /// (declaring root, local key) -> qualified ID for imported daemons, so a
    /// daemon renamed on the way in can still be selected by the name this
    /// project gave it.
    ///
    /// Keyed by root because the name is only meaningful in the project that
    /// chose it: another project may use the same word for a daemon of its own
    /// or for a group, and must not be answered with this project's import.
    pub aliases: IndexMap<(PathBuf, String), String>,
    /// Daemons that depend on an import which could not be resolved, mapping the
    /// daemon's key to the import's local key. Starting one would run it without
    /// something it declared it needs, so the command refuses instead.
    pub blocked: IndexMap<String, (String, String)>,
    /// Imports that could not be resolved, by local key.
    ///
    /// Daemons load on every command, so a sibling project that is missing or
    /// not trusted must not take `mise x`, `mise run` or the activation hook
    /// down with it. The failure is carried here and reported by `mise daemons`,
    /// which is the command that can act on it.
    pub import_errors: IndexMap<(PathBuf, String), String>,
    /// Group names are project scoped, so nested projects may each declare one
    /// with the same name. They stay in a root-aware list until `for_root`.
    pub groups: Vec<Group>,
    /// Hostname components per project root, including roots reached by import.
    pub labels: IndexMap<PathBuf, urls::RootLabels>,
}

impl Daemon {
    /// Stop advertising this daemon's hostname, because the proxy will not
    /// serve it to this daemon.
    ///
    /// Only what names the hostname goes. Deleting `<NAME>_URL` outright would
    /// take a preset's own connection string with it: a proxied `redis` preset
    /// publishes `REDIS_URL = redis://…`, which is not the derived URL and
    /// stays valid however the proxy routes.
    fn withdraw_host(&mut self) {
        let Some(host) = self.host.take() else {
            return;
        };
        self.exports.retain(|_, value| !value.contains(&host));
        urls::withdraw(&mut self.table);
    }
}

/// Validate a name that reaches pitchfork verbatim. Pitchfork rejects `--`
/// among other things, and these names land in filesystem paths under the
/// state directory.
fn validate_name(kind: &str, name: &str) -> Result<()> {
    if name.is_empty()
        || name == "."
        || name.contains("..")
        || name.contains("--")
        || name.starts_with('-')
        || name.ends_with('-')
        || !name
            .chars()
            .all(|c| c.is_ascii_alphanumeric() || matches!(c, '_' | '-' | '.'))
    {
        bail!("invalid {kind} name {name:?}; use letters, numbers, '.', '_' or '-'");
    }
    Ok(())
}

/// A namespace reaches pitchfork verbatim and lands in filesystem paths under
/// the state directory, so it follows the same rules as a daemon name.
pub(crate) fn validate_namespace(namespace: &str) -> Result<()> {
    if validate_name("daemon", namespace).is_err() {
        bail!("invalid daemon namespace {namespace:?}; use letters, numbers, '.', '_' or '-'");
    }
    Ok(())
}

pub(crate) fn state_dir(root: &Path) -> PathBuf {
    crate::dirs::STATE
        .join("daemons")
        .join(crate::hash::hash_to_str(
            &root.canonicalize().unwrap_or_else(|_| root.to_path_buf()),
        ))
}

/// The lock serializing everything that touches one project's daemon state.
///
/// Deliberately a sibling of [`state_dir`] rather than a file inside it.
/// `mise daemons prune` deletes that directory, and a lock living inside the
/// directory being deleted cannot be held across the deletion: releasing it
/// first leaves a window for another process to write fresh state into the
/// doomed directory, and Windows refuses to delete a file whose handle is still
/// open. As a sibling it stays valid through the removal.
///
/// Takes the state directory, not the project root, because prune works on
/// state whose root no longer exists.
pub(crate) fn lock_file_for_state_dir(dir: &Path) -> PathBuf {
    let name = dir.file_name().unwrap_or_default().to_string_lossy();
    dir.with_file_name(format!("{name}.lock"))
}

/// Where mise versions before the lock moved out of the state directory
/// coordinate. Still taken alongside [`lock_file_for_state_dir`] so that a
/// daemon start from an older mise and a prune from this one continue to
/// exclude each other. Removable once no supported version locks this path.
pub(crate) fn legacy_lock_file_for_state_dir(dir: &Path) -> PathBuf {
    dir.join("project.lock")
}

/// Both locks guarding one project's daemon state, held together.
///
/// Acquired sibling first, then legacy, by everything that takes both, so they
/// cannot deadlock against each other. Released together, which is what lets
/// `mise daemons prune` delete state without any window for a `prepare()` to
/// write into it.
pub(crate) struct ProjectLock {
    _sibling: fslock::LockFile,
    _legacy: fslock::LockFile,
}

impl ProjectLock {
    /// Waits for both locks. Used by `prepare()`, which must not give up.
    pub(crate) fn acquire(root: &Path) -> Result<Self> {
        let dir = state_dir(root);
        Ok(Self {
            _sibling: crate::lock_file::LockFile::at(&lock_file_for_state_dir(&dir)).lock()?,
            _legacy: crate::lock_file::LockFile::at(&legacy_lock_file_for_state_dir(&dir))
                .lock()?,
        })
    }

    /// Takes both locks or neither, without waiting. Used by prune, which skips
    /// state another process is using rather than blocking behind it.
    pub(crate) fn try_acquire(dir: &Path) -> Result<Option<Self>> {
        let Some(sibling) =
            crate::lock_file::LockFile::at(&lock_file_for_state_dir(dir)).try_lock()?
        else {
            return Ok(None);
        };
        let Some(legacy) =
            crate::lock_file::LockFile::at(&legacy_lock_file_for_state_dir(dir)).try_lock()?
        else {
            return Ok(None);
        };
        Ok(Some(Self {
            _sibling: sibling,
            _legacy: legacy,
        }))
    }
}

/// Which claimant of a contested hostname pitchfork still serves, by index,
/// or `None` when it serves none of them.
///
/// The claimants are not symmetric. A daemon this project only imported is
/// registered by the project that declares it, from that project's own
/// configuration, where nothing collides; mise rewrites that file whole and it
/// is not this project's to overrule. Mise withdraws every local claimant, so
/// exactly one imported claimant is left holding the hostname and pitchfork
/// serves it. Two or more imported claimants leave the proxy a contest it
/// refuses to settle, and none at all leave it nothing to route.
fn routed_claimant(imported: &[bool]) -> Option<usize> {
    let mut found = imported.iter().enumerate().filter(|(_, i)| **i);
    match (found.next(), found.next()) {
        (Some((only, _)), None) => Some(only),
        _ => None,
    }
}

pub(crate) fn load(files: &ConfigMap) -> Result<DaemonSet> {
    let mut declarations = IndexMap::new();
    let mut settings: IndexMap<PathBuf, DaemonSettings> = IndexMap::new();
    let mut group_declarations = IndexMap::new();
    // A nearer config replaces a same-name daemon outright, so the winning
    // declaration's root is not the only project that declared that name.
    let mut declared_in: IndexMap<String, Vec<PathBuf>> = IndexMap::new();
    for cf in files.values().rev() {
        let entries = cf.daemon_declarations();
        let file_settings = cf.daemon_settings();
        let groups = cf.daemon_group_declarations();
        // A file can carry only `[daemons_settings]`, which declares nothing.
        if entries.is_empty() && groups.is_empty() && file_settings.is_none() {
            continue;
        }
        if !Settings::get().experimental {
            if !entries.is_empty() || !groups.is_empty() {
                warn_once!("{EXPERIMENTAL}; ignoring daemon declarations");
            }
            continue;
        }
        if Settings::safe_mode() && !crate::config::is_global_config(cf.get_path()) {
            continue;
        }
        let source = cf.get_path().to_path_buf();
        let project_root = cf.project_root();
        let root = project_root.clone().unwrap_or_else(|| cf.config_root());
        if let Some(file_settings) = file_settings {
            match &project_root {
                // Settings are inherited down a project tree, and a global
                // config's root is the home directory. Honouring one there would
                // hand every project on the machine the same namespace, which is
                // the one thing a namespace must never be. It would also be
                // invisible to another project importing from here, which reads
                // project configuration only.
                None => warn_once!(
                    "[daemons_settings] in {} is ignored; it belongs in a project configuration",
                    crate::file::display_path(cf.get_path())
                ),
                Some(project_root) => settings
                    .entry(project_root.clone())
                    .or_default()
                    .merge(file_settings),
            }
        }
        for (name, declaration) in entries {
            let roots = declared_in.entry(name.clone()).or_default();
            if !roots.contains(&root) {
                roots.push(root.clone());
            }
            declarations.insert(name, (declaration, source.clone(), root.clone()));
        }
        for (name, declaration) in groups {
            // Keyed by root so a child project's group never displaces a parent's.
            group_declarations.insert(
                (root.clone(), name),
                (declaration, source.clone(), root.clone()),
            );
        }
    }
    let mut set = DaemonSet::default();
    // Local name -> qualified ID, so `depends` can name an imported daemon short.
    // Keyed by the importing root: a name means an import only in the project
    // that declared it, and a daemon elsewhere may use the same word.
    let mut imported_ids: IndexMap<(PathBuf, String), String> = IndexMap::new();
    let mut state = LoadState::default();
    for (name, (declaration, source, root)) in declarations {
        validate_name("daemon", &name)?;
        if let Declaration::Definition(table) = &declaration
            && table.contains_key("project")
        {
            let spec = parse_import(&name, table.clone())?;
            let (key, daemon) = match import(
                &name,
                &spec,
                &source,
                &root,
                &mut set.namespaces,
                &mut state,
            ) {
                Ok(imported) => imported,
                Err(err) => {
                    debug!("[daemons.{name}] import failed: {err:#}");
                    set.import_errors
                        .insert((root.clone(), name), format!("{err:#}"));
                    continue;
                }
            };
            // Two imports can resolve to one qualified ID when their projects
            // share a namespace. Inserting the second would replace the first
            // and leave both local names pointing at the later project.
            if let Some(existing) = set.daemons.get(&key)
                && existing.root != daemon.root
            {
                bail!(
                    "daemon {key} is imported from both {} and {}; they share a namespace, so one of those projects needs its own [daemons_settings] namespace",
                    existing.root.display(),
                    daemon.root.display()
                );
            }
            imported_ids.insert((root.clone(), name.clone()), key.clone());
            set.aliases.insert((root.clone(), name), key.clone());
            set.daemons.insert(key, daemon);
            continue;
        }
        let settings = settings_for(&settings, &root);
        set.daemons.insert(
            name.clone(),
            build(
                &name,
                declaration,
                source,
                root,
                &settings,
                &mut state,
                false,
            )?,
        );
    }
    // Both collision checks below identify a daemon by its root and its name:
    // two projects whose directories share a basename derive one project label,
    // so the names alone do not tell them apart. The root is the canonical one,
    // which is what the hostname and the port were derived from, so the identity
    // and the value it guards cannot disagree about which directory is meant.
    let mut canonical: BTreeMap<PathBuf, PathBuf> = BTreeMap::new();
    let mut canonical_root = |root: &Path| -> PathBuf {
        canonical
            .entry(root.to_path_buf())
            .or_insert_with(|| root.canonicalize().unwrap_or_else(|_| root.to_path_buf()))
            .clone()
    };
    // The proxy cannot route two daemons to one hostname, and pitchfork routes
    // neither side of a collision rather than choosing, so mise never
    // advertises one either. Checked once every daemon is built, because a
    // preset's hostname is resolved on its own path.
    // Gathered per hostname rather than pairwise: three claimants are settled
    // by all three together, and one warning names them all. Two declarations
    // reaching one directory by different paths are one claimant, which is why
    // identity is the canonical root and the name.
    let mut claimants: BTreeMap<String, Vec<String>> = BTreeMap::new();
    let mut seen: BTreeMap<String, std::collections::BTreeSet<(PathBuf, String)>> = BTreeMap::new();
    for (key, daemon) in set.daemons.iter() {
        let Some(host) = daemon.host.clone() else {
            continue;
        };
        let ident = (canonical_root(&daemon.root), daemon.name.clone());
        if seen.entry(host.clone()).or_default().insert(ident) {
            claimants.entry(host).or_default().push(key.clone());
        }
    }
    for (host, keys) in &claimants {
        if keys.len() < 2 {
            continue;
        }
        let imported: Vec<bool> = keys.iter().map(|k| set.daemons[k].imported).collect();
        let where_each = keys
            .iter()
            .map(|k| {
                let daemon = &set.daemons[k];
                format!("{} in {}", daemon.name, daemon.root.display())
            })
            .collect::<Vec<_>>()
            .join(", ");
        let winner = routed_claimant(&imported);
        match winner {
            Some(only) => warn_once!(
                "[daemons] {where_each} all resolve to {host}. {} is declared by the project it is imported from, which registers it from its own configuration, so pitchfork serves that one and the others get no URL. Give one of them a different proxy label, or set proxy = false on it.",
                set.daemons[&keys[only]].name
            ),
            None => warn_once!(
                "[daemons] {where_each} all resolve to {host}, so pitchfork routes none of them. Give one of them a different proxy label, or set proxy = false on it."
            ),
        }
        // Everyone the proxy will not serve, which is every claimant but the
        // one above. A local claimant is always among them: mise writes the
        // file that would claim the hostname, so it simply does not. An
        // imported claimant is there only when nothing is served at all,
        // because mise cannot stop the project declaring it from registering
        // it, but it must not advertise a URL that answers for no one either.
        state.withdrawn_hosts.extend(
            keys.iter()
                .enumerate()
                .filter(|(i, _)| Some(*i) != winner)
                .map(|(_, k)| k.clone()),
        );
    }
    // The first claimant of an ambiguous key or hostname kept it while it
    // looked unique; drop it now so neither side is handed the other's
    // endpoint, and so mise never advertises a hostname the proxy refuses.
    for (key, daemon) in set.daemons.iter_mut() {
        daemon
            .exports
            .retain(|key, _| !state.ambiguous.contains(key));
        if state.withdrawn_hosts.contains(key) {
            daemon.withdraw_host();
        }
    }
    // Two daemons in one project can resolve to one port: `auto` derives it
    // from the project root, so two presets of the same kind share a base, and
    // two explicit ports can simply be equal. Mise pins the number it resolved
    // and turns pitchfork's bumping off, so the second daemon would fail to
    // bind at start with nothing naming the first. Checked once every daemon is
    // built, because a preset's port is resolved on its own path.
    //
    // Keyed by the canonical root, because that is what the port was derived
    // from: two roots reaching one directory through different paths resolve to
    // one port, and comparing the paths as written would call them distinct.
    let mut claimed_ports: BTreeMap<(PathBuf, u16), String> = BTreeMap::new();
    for daemon in set.daemons.values() {
        let Some(claim) = daemon.port else {
            continue;
        };
        let root = canonical_root(&daemon.root);
        if let Some(other) = claimed_ports.insert((root, claim.port), daemon.name.clone())
            && other != daemon.name
        {
            bail!(
                "daemons {other} and {} both use port {} in {}; give one of them its own port, or a different `base` if they use port = \"auto\"",
                daemon.name,
                claim.port,
                daemon.root.display()
            );
        }
    }
    // A preset's exports are its declared interface; `<NAME>_PORT` and
    // `<NAME>_URL` are a convenience derived from a name. When a custom
    // daemon's name lands on a preset's variable, such as a daemon called
    // `database` beside a Postgres preset, the convenience gives way rather
    // than silently replacing the endpoint the preset published.
    // An imported preset's exports belong to the project that declares it and
    // never reach this environment, so they cannot be what a local daemon would
    // replace; counting them would take a legitimate export away for a clash
    // that does not happen here.
    let preset_keys: std::collections::BTreeSet<String> = set
        .daemons
        .values()
        .filter(|d| d.preset.is_some() && !d.imported)
        .flat_map(|d| d.exports.keys().cloned())
        .collect();
    for daemon in set.daemons.values_mut().filter(|d| d.preset.is_none()) {
        let name = daemon.name.clone();
        daemon.exports.retain(|key, _| {
            if preset_keys.contains(key) {
                warn_once!(
                    "[daemons] {name} would export {key}, which a preset already sets; the preset's value is kept. Rename {name} to get its own variable."
                );
                return false;
            }
            true
        });
    }
    set.labels = state.labels;
    for root in set
        .daemons
        .values()
        .filter(|d| !d.imported)
        .map(|d| d.root.clone())
        .collect::<indexmap::IndexSet<_>>()
    {
        let namespace = runtime::resolve_namespace(&root, Some(&settings_for(&settings, &root)))?;
        set.namespaces.insert(root, namespace);
    }
    // An inherited namespace is shared by every project beneath the config that
    // declares it, so two of them can name the same daemon and resolve to one
    // pitchfork ID. Say so instead of letting one silently shadow the other.
    let mut claimed: IndexMap<String, PathBuf> = IndexMap::new();
    for daemon in set.daemons.values() {
        let Some(namespace) = set.namespaces.get(&daemon.root) else {
            continue;
        };
        let id = format!("{namespace}/{}", daemon.name);
        if let Some(other) = claimed.insert(id.clone(), daemon.root.clone())
            && other != daemon.root
        {
            bail!(
                "daemon {id} is declared in both {} and {}; they share a namespace, so give one of them a different name or its own [daemons_settings] namespace",
                other.display(),
                daemon.root.display()
            );
        }
    }
    // Runs even with nothing imported, because it also rejects a `depends` this
    // project could not act on. An imported daemon's own `depends` is relative
    // to its project and is checked when that project loads.
    let failures = set.import_errors.clone();
    let mut blocked: IndexMap<String, (String, String)> = IndexMap::new();
    for (key, daemon) in set.daemons.iter_mut().filter(|(_, d)| !d.imported) {
        // What this daemon's project reaches by name: its own imports and the
        // ones it inherits, resolved or not. Nearest declaration wins, so a
        // working import here is unaffected by a broken one of the same name
        // further up, and vice versa.
        let mut reach: IndexMap<String, Result<String, String>> = IndexMap::new();
        for ancestor in daemon.root.ancestors() {
            for ((root, name), id) in &imported_ids {
                if root.as_path() == ancestor {
                    reach.entry(name.clone()).or_insert_with(|| Ok(id.clone()));
                }
            }
            for ((root, name), err) in &failures {
                if root.as_path() == ancestor {
                    reach
                        .entry(name.clone())
                        .or_insert_with(|| Err(err.clone()));
                }
            }
        }
        let imports: IndexMap<String, String> = reach
            .iter()
            .filter_map(|(name, id)| Some((name.clone(), id.as_ref().ok()?.clone())))
            .collect();
        let unresolved: IndexMap<String, String> = reach
            .iter()
            .filter_map(|(name, id)| Some((name.clone(), id.as_ref().err()?.clone())))
            .collect();
        if let Some(missing) = rewrite_depends(&mut daemon.table, &imports, &unresolved)? {
            let error = unresolved[&missing].clone();
            blocked.insert(key.clone(), (missing, error));
        }
    }
    set.blocked = blocked;
    load_groups(&mut set, group_declarations, &declared_in)?;
    Ok(set)
}

/// State shared across one `load`, so two daemons cannot claim one port slot or
/// one exported variable without it being noticed, and a project root's
/// hostname labels are derived once however many daemons it declares.
#[derive(Default)]
struct LoadState {
    /// Previously persisted allocations, read once per project root.
    claims: BTreeMap<PathBuf, BTreeMap<String, PortClaim>>,
    /// Port variables already taken, so two names cannot normalize onto one key.
    keys: BTreeMap<String, String>,
    ambiguous: std::collections::BTreeSet<String>,
    /// Hostnames two daemons derived independently; neither keeps it.
    /// Keys of the daemons whose hostname this load takes away, which is every
    /// local claimant of a contested one. An imported claimant is absent: this
    /// project does not write the file that registers it.
    withdrawn_hosts: std::collections::BTreeSet<String>,

    /// Hostname components per project root, including roots reached by import.
    labels: IndexMap<PathBuf, urls::RootLabels>,
}

impl LoadState {
    fn labels(&mut self, root: &Path, settings: &DaemonSettings) -> Result<urls::RootLabels> {
        if let Some(labels) = self.labels.get(root) {
            return Ok(labels.clone());
        }
        let labels = urls::labels(root, settings)?;
        self.labels.insert(root.to_path_buf(), labels.clone());
        Ok(labels)
    }
}

/// Turn one declaration into a daemon owned by `root`.
fn build(
    name: &str,
    declaration: Declaration,
    source: PathBuf,
    root: PathBuf,
    settings: &DaemonSettings,
    state: &mut LoadState,
    imported: bool,
) -> Result<Daemon> {
    let (preset, version, mut table) = match declaration {
        Declaration::Preset(version) => (Some(name.to_string()), Some(version), toml::Table::new()),
        Declaration::Definition(mut table) => {
            let preset = take_string(&mut table, "preset")?;
            let version = take_string(&mut table, "version")?;
            (preset, version, table)
        }
    };
    let request = table
        .remove("port")
        .map(|value| ports::parse(name, value))
        .transpose()?;
    // `auto` resolution reuses the allocation recorded by the last start, so
    // a change to the slot derivation cannot move a running daemon's port.
    let persisted = if matches!(request, Some(PortRequest::Auto { .. })) {
        state
            .claims
            .entry(root.clone())
            .or_insert_with(|| {
                runtime::read_state(&root)
                    .map(|s| s.ports)
                    .unwrap_or_default()
            })
            .get(name)
            .copied()
    } else {
        None
    };
    // `init`, `task` and `args` are mise concepts; pitchfork never sees them.
    let init = take_init(&mut table, name)?;
    let task = take_string(&mut table, "task")?;
    let args = take_args(&mut table, name)?;
    if preset.is_some() {
        // Name the key actually present; `args` without `task` is a
        // different mistake from `preset` with `task`.
        if task.is_some() {
            bail!("[daemons.{name}] cannot combine preset with task");
        }
        if args.is_some() {
            bail!("[daemons.{name}] args requires task, which a preset cannot use");
        }
    }
    if let Some(preset) = preset {
        let version =
            version.ok_or_else(|| eyre::eyre!("[daemons.{name}] requires version with preset"))?;
        let claim = match request {
            Some(PortRequest::Passthrough(_)) => bail!(
                "[daemons.{name}].port must be an integer or \"auto\"; pitchfork's structured port is only available on custom daemons"
            ),
            Some(PortRequest::Fixed(port)) => Some(PortClaim::fixed(port)),
            Some(PortRequest::Auto { base, stride }) => Some(ports::resolve(
                name,
                &root,
                base,
                stride,
                Some(presets::default_port(&preset)?),
                persisted,
            )?),
            None => None,
        };
        return presets::expand(
            name,
            &preset,
            &version,
            table,
            presets::Extras {
                init: &init,
                port: claim,
                labels: &state.labels(&root, settings)?,
                imported,
            },
            &source,
            &root,
        );
    }
    if version.is_some() || table.contains_key("options") {
        bail!("[daemons.{name}] requires preset when specifying version or options");
    }
    if task.is_some() && table.contains_key("run") {
        bail!("[daemons.{name}] cannot set both run and task");
    }
    if args.is_some() && task.is_none() {
        bail!("[daemons.{name}] args requires task");
    }
    if let Some(task) = &task {
        if task.is_empty() {
            bail!("[daemons.{name}] task must not be empty");
        }
        let mut run = format!(
            "exec {} run {}",
            presets::quote(crate::env::MISE_BIN.to_string_lossy()),
            presets::quote(task)
        );
        let args = args.unwrap_or_default();
        if !args.is_empty() {
            run.push_str(" --");
            for arg in args {
                run.push(' ');
                run.push_str(&presets::quote(arg));
            }
        }
        table.insert("run".into(), toml::Value::String(run));
        // The task runs through `mise run`, which would start this very
        // daemon again. This marker breaks that cycle in `tasks::start`
        // instead of `--skip-deps`, which would also have discarded the
        // task's own `depends`, leaving the daemon to supervise a stale
        // build.
        table
            .entry("env".to_string())
            .or_insert_with(|| toml::Value::Table(toml::Table::new()))
            .as_table_mut()
            .ok_or_else(|| eyre::eyre!("[daemons.{name}] env must be a table"))?
            .insert(
                DAEMON_TASK_MARKER.into(),
                toml::Value::String("1".to_string()),
            );
        // Preserve an explicit opt-out before inserting the task's own `mise =
        // false` default: probes still need the project environment by default.
        if cfg!(unix) && table.get("mise").and_then(toml::Value::as_bool) != Some(false) {
            presets::wrap_probe_commands(&mut table);
        }
        // mise is already the entry point, so pitchfork does not need
        // to wrap a bare task daemon in `mise x`. With `init` it does:
        // the setup steps and the task then share one shell inside the
        // project's tool environment, so a step can export a variable
        // or change directory for the ones after it, exactly as it can
        // for a daemon declared with `run`.
        if init.is_empty() {
            table
                .entry("mise".to_string())
                .or_insert(toml::Value::Boolean(false));
        }
    }
    if table.get("run").and_then(toml::Value::as_str).is_none() {
        bail!("[daemons.{name}] requires run, task, preset, or project");
    }
    let claim = match request {
        Some(PortRequest::Passthrough(value)) => {
            table.insert("port".into(), value);
            None
        }
        Some(PortRequest::Fixed(port)) => Some(PortClaim::fixed(port)),
        Some(PortRequest::Auto { base, stride }) => {
            Some(ports::resolve(name, &root, base, stride, None, persisted)?)
        }
        None => None,
    };
    if let Some(claim) = claim {
        table.insert("port".into(), expected_port(claim.port));
    }
    let proxy = urls::proxy_settings();
    let urls::Applied { host, .. } = urls::apply(
        name,
        &mut table,
        &state.labels(&root, settings)?,
        &proxy.tld,
    )?;
    // Without these a custom daemon's endpoint would reach pitchfork and
    // nothing else: `mise env` would export nothing, and the process
    // could only discover it through pitchfork's own injection.
    // An imported daemon exports into the project that declares it, never into
    // this one, so it must not claim a variable here: doing so would make a
    // local daemon of the same name look ambiguous and strip its exports.
    let mut exports = IndexMap::new();
    if !imported
        && (claim.is_some() || host.is_some())
        && let Some(base) = env_var_base(name)
    {
        match state.keys.insert(base.clone(), name.to_string()) {
            // Two names collapsing onto one key is ambiguous, and
            // picking a winner would hand somebody the wrong endpoint.
            // Neither is exported and both daemons still run, because
            // this convenience must not break a working project.
            Some(other) => {
                warn_once!(
                    "[daemons] {other} and {name} both map to {base}_PORT; their names differ only by punctuation, so neither endpoint is exported. Rename one of them."
                );
                state.ambiguous.insert(format!("{base}_PORT"));
                state.ambiguous.insert(format!("{base}_URL"));
            }
            None => {
                if let Some(c) = claim {
                    exports.insert(format!("{base}_PORT"), c.port.to_string());
                }
                if let Some(host) = &host {
                    exports.insert(format!("{base}_URL"), proxy.url(host));
                }
            }
        }
    }
    table
        .entry("mise".to_string())
        .or_insert(toml::Value::Boolean(true));
    if !init.is_empty() {
        let run = table["run"].as_str().unwrap().to_string();
        table.insert(
            "run".into(),
            toml::Value::String(presets::with_init(&init, &run)),
        );
    }
    Ok(Daemon {
        name: name.to_string(),
        source,
        root,
        table,
        preset: None,
        data_dir: None,
        task,
        tool: None,
        exports,
        imported,
        port: claim,
        host,
    })
}

/// The `[daemons_settings]` that apply to a project root.
///
/// A root inherits the table from its ancestors, nearest declaration winning,
/// the same way a daemon declared in a parent configuration belongs to that
/// parent. Resolving this identically here and when a referenced project is
/// imported is what keeps one namespace from being computed for a daemon and a
/// different one from being registered for it.
fn settings_for(settings: &IndexMap<PathBuf, DaemonSettings>, root: &Path) -> DaemonSettings {
    let mut resolved = DaemonSettings::default();
    // Farthest ancestor first, so a nearer declaration overrides it.
    for ancestor in root.ancestors().collect::<Vec<_>>().into_iter().rev() {
        if let Some(declared) = settings.get(ancestor) {
            resolved.merge(declared.clone());
        }
    }
    resolved
}

/// Refuse to start a daemon whose `depends` named an import that could not be
/// resolved. The dangling entry is dropped so nothing unresolvable is
/// registered, which is exactly why starting it anyway would run it without
/// something it declared.
///
/// Called with each view that can hold the answer, because no single one holds
/// all of it: the invoking project's merged configuration knows about imports
/// declared there, and each owning root's own configuration knows about the
/// imports that project declares.
pub(crate) fn ensure_not_blocked(
    set: &DaemonSet,
    starting: &DaemonSet,
    root: Option<&Path>,
) -> Result<()> {
    let Some((name, import)) = set.blocked.iter().find(|(name, _)| {
        set.daemons
            .get(*name)
            .is_some_and(|blocked| starting.contains(blocked))
    }) else {
        return Ok(());
    };
    let project = root
        .map(|root| format!(" in {}", root.display()))
        .unwrap_or_default();
    let (import, error) = import;
    bail!("daemon {name:?}{project} depends on [daemons.{import}], which is unavailable: {error}");
}

/// Config files that apply to a directory, lowest precedence first.
///
/// A referenced project is later reloaded through its whole configuration
/// hierarchy when its daemons are prepared, so discovery has to walk the same
/// ancestors. Reading only the directory itself would miss a daemon or a
/// `[daemons_settings] namespace` inherited from a parent config, and mise would
/// then compute one daemon ID here and register a different one there.
fn hierarchy_config_paths(dir: &Path) -> Result<Vec<PathBuf>> {
    let mut paths = Vec::new();
    // `all_dirs` yields the directory first and its ancestors after it; reverse
    // so the nearest config is read last and wins.
    for ancestor in crate::file::all_dirs(dir, &crate::env::MISE_CEILING_PATHS)?
        .into_iter()
        .rev()
    {
        // Honour the same ignore rules ordinary loading does, so a config the
        // user has told mise to skip is skipped here too rather than read and
        // reported as an error.
        if crate::config::config_dir_is_ignored(&ancestor, false) {
            continue;
        }
        // Within one directory this helper lists the highest-precedence file
        // first, which is the opposite of the order wanted here. It also lists
        // `.tool-versions`, which is not TOML and would fail to parse; only a
        // TOML config can carry [daemons] anyway.
        paths.extend(
            crate::config::config_paths_in_dir(&ancestor)
                .into_iter()
                .rev()
                .filter(|path| path.extension().is_some_and(|ext| ext == "toml"))
                .filter(|path| !crate::config::config_path_is_ignored(path, false)),
        );
    }
    // Two paths can reach one file through a symlinked prefix; reading it twice
    // would merge its settings onto themselves.
    let mut seen = std::collections::HashSet::new();
    paths.retain(|path| seen.insert(crate::file::desymlink_path(path)));
    Ok(paths)
}

/// Pull a daemon definition out of another project so it runs with that
/// project's root, state, and `mise x` environment rather than this one's.
/// What a `project =` declaration asks for, before anything is read from disk.
struct Import {
    project: String,
    remote_name: String,
}

/// Check the declaration itself. This is this project's own configuration, so a
/// mistake here is fatal like any other config error; only what has to be read
/// from the other project is allowed to fail softly.
fn parse_import(local_name: &str, mut table: toml::Table) -> Result<Import> {
    let project = take_string(&mut table, "project")?
        .ok_or_else(|| eyre::eyre!("[daemons.{local_name}].project must be a string"))?;
    let remote_name = take_string(&mut table, "name")?.unwrap_or_else(|| local_name.to_string());
    validate_name("daemon", &remote_name)?;
    if let Some(unexpected) = table.keys().next() {
        bail!(
            "[daemons.{local_name}] declares {unexpected:?} alongside project; define the daemon in the referenced project instead"
        );
    }
    Ok(Import {
        project,
        remote_name,
    })
}

fn import(
    local_name: &str,
    spec: &Import,
    source: &Path,
    root: &Path,
    namespaces: &mut IndexMap<PathBuf, String>,
    state: &mut LoadState,
) -> Result<(String, Daemon)> {
    let Import {
        project,
        remote_name,
    } = spec;
    let remote_name = remote_name.as_str();
    let expanded = crate::file::replace_path(project);
    let dir = if expanded.is_absolute() {
        expanded
    } else {
        root.join(expanded)
    };
    // Fold `..` before the path reaches an error message: a missing project is
    // the common case, and `/src/app/../mirror-pipeline` is not a path anyone
    // can act on. Absolutizing works on a path that does not exist yet.
    let dir = dir
        .absolutize()
        .map(|p| p.to_path_buf())
        .unwrap_or_else(|_| dir.clone());
    let dir = dir.canonicalize().unwrap_or(dir);
    if !dir.is_dir() {
        bail!(
            "[daemons.{local_name}].project expects a project directory at {}, which {}; check that project out there or point [daemons.{local_name}].project in {} at its directory",
            dir.display(),
            if dir.exists() {
                "is not a directory"
            } else {
                "does not exist"
            },
            crate::file::display_path(source)
        );
    }
    let paths = hierarchy_config_paths(&dir)?;
    if paths.is_empty() {
        bail!(
            "[daemons.{local_name}].project expects a mise configuration in {}, which has none; add a mise.toml declaring [daemons.{remote_name}] there",
            dir.display()
        );
    }
    let mut found: Option<(Declaration, PathBuf, PathBuf)> = None;
    // Keyed by config root, exactly as `load` keys it, so the namespace resolves
    // the same way here as it will when this root is prepared.
    let mut settings: IndexMap<PathBuf, DaemonSettings> = IndexMap::new();
    let mut available: Vec<String> = Vec::new();
    for path in &paths {
        // Require trust that already exists rather than letting the parse
        // establish it. `mise x`, `mise run`, `mise install`, `mise watch` and
        // `mise daemons start` mark the active config implicitly trusted, and
        // that branch would grant durable trust to whatever directory `project`
        // names, with no prompt, so a later `cd` into it would run its env,
        // hooks and templates. Safe mode makes config inert, so it needs no
        // trust of its own.
        if !Settings::safe_mode() && !crate::config::config_file::is_path_trusted(path) {
            // The untrusted file can be an ancestor of the referenced project,
            // so name the root that actually needs trusting; trusting the
            // project directory would not cover it. Ask the same question
            // `is_path_trusted` does: under `paranoid` that is the file itself,
            // and naming its directory would send the user nowhere.
            let untrusted = crate::config::config_file::config_trust_root(path);
            bail!(
                "[daemons.{local_name}].project needs {}, which is not trusted; run `mise trust {}` after reviewing it",
                crate::file::display_path(path),
                untrusted.display()
            );
        }
        let cf = crate::config::config_file::mise_toml::MiseToml::from_file(path)?;
        // Ask the same question `load` asks. `project_root` is the config root
        // narrowed to project scope, and the walk above reaches the home
        // directory, so a global config can appear in a referenced project's
        // ancestry. Honouring `[daemons_settings]` from one here while `load`
        // ignores it would hand every project that namespace through the back
        // door this project closed at the front.
        let project_root = cf.project_root();
        let remote_root = project_root
            .clone()
            .unwrap_or_else(|| crate::config::config_file::config_root::config_root(path));
        if let Some(file_settings) = cf.daemon_settings()
            && let Some(project_root) = &project_root
        {
            settings
                .entry(project_root.clone())
                .or_default()
                .merge(file_settings);
        }
        for (name, declaration) in cf.daemon_declarations() {
            if !available.contains(&name) {
                available.push(name.clone());
            }
            if name == remote_name {
                found = Some((declaration, path.clone(), remote_root.clone()));
            }
        }
    }
    let Some((declaration, remote_source, remote_root)) = found else {
        bail!(
            "[daemons.{local_name}].project expects [daemons.{remote_name}] in {}, which declares {}",
            dir.display(),
            if available.is_empty() {
                "no daemons".to_string()
            } else {
                available.join(", ")
            }
        );
    };
    if let Declaration::Definition(table) = &declaration
        && table.contains_key("project")
    {
        bail!(
            "[daemons.{remote_name}] in {} is itself imported with project; reference the project that declares it",
            dir.display()
        );
    }
    let remote_settings = settings_for(&settings, &remote_root);
    let daemon = build(
        remote_name,
        declaration,
        remote_source,
        remote_root.clone(),
        &remote_settings,
        state,
        true,
    )?;
    let namespace = runtime::resolve_namespace(&remote_root, Some(&remote_settings))?;
    let id = format!("{namespace}/{}", daemon.name);
    namespaces.insert(remote_root, namespace);
    Ok((id, daemon))
}

/// Rewrite short `depends` entries that name an imported daemon. Pitchfork
/// resolves bare names inside one namespace, so an imported dependency only
/// works when it is written out in full.
///
/// A dependency on an import that could not be resolved is dropped rather than
/// written out, because there is no ID to write. Leaving the bare name would
/// register a definition naming a daemon pitchfork cannot resolve; the import
/// failure itself is reported separately, so the reason is not lost.
fn rewrite_depends(
    table: &mut toml::Table,
    imported: &IndexMap<String, String>,
    unresolved: &IndexMap<String, String>,
) -> Result<Option<String>> {
    let Some(depends) = table.get_mut("depends") else {
        return Ok(None);
    };
    let mut missing: Option<String> = None;
    let rewrite = |value: &mut toml::Value| {
        if let Some(name) = value.as_str()
            && let Some(id) = imported.get(name)
        {
            *value = toml::Value::String(id.clone());
        }
    };
    let dangling = |value: &toml::Value| {
        value
            .as_str()
            .filter(|name| unresolved.contains_key(*name))
            .map(str::to_string)
    };
    let mut empty = false;
    match depends {
        toml::Value::String(_) => {
            if let Some(name) = dangling(depends) {
                missing = Some(name);
                empty = true;
            } else {
                rewrite(depends);
            }
        }
        toml::Value::Array(entries) => {
            if entries.iter().any(|entry| entry.as_str().is_none()) {
                bail!("daemon depends must be a string or an array of strings");
            }
            missing = entries.iter().find_map(dangling);
            entries.retain(|entry| dangling(entry).is_none());
            entries.iter_mut().for_each(rewrite);
            empty = entries.is_empty();
        }
        _ => bail!("daemon depends must be a string or an array of strings"),
    }
    // Dropping the last entry leaves nothing to depend on, so drop the key too
    // rather than registering an empty list.
    if empty {
        table.remove("depends");
    }
    Ok(missing)
}

/// The daemon names and qualified IDs a table's `depends` refers to.
fn depends_names(table: &toml::Table) -> Vec<String> {
    let Some(depends) = table.get("depends") else {
        return Vec::new();
    };
    let entries: Vec<&toml::Value> = match depends {
        toml::Value::String(_) => vec![depends],
        toml::Value::Array(entries) => entries.iter().collect(),
        _ => Vec::new(),
    };
    entries
        .into_iter()
        .filter_map(|entry| entry.as_str())
        .map(str::to_string)
        .collect()
}

/// A daemon name folded into the stem of a shell variable, or None when it
/// cannot be one.
fn env_var_base(name: &str) -> Option<String> {
    // A shell cannot export a name starting with a digit: `export 9API_PORT=1`
    // is an invalid identifier and would break the whole activation, not just
    // that variable. Such a name was legal before these exports existed, so it
    // keeps working and only goes without the variables.
    //
    // Only a leading digit is disqualifying. Names are letters, digits, `.`,
    // `_` and `-`, and cannot lead with `-`, so every other first character
    // either is a letter or becomes the underscore that `.api` turns into
    // `_API_PORT`, which a shell accepts.
    if name.starts_with(|c: char| c.is_ascii_digit()) {
        warn_once!(
            "[daemons] {name} starts with a digit, so its port and URL cannot be exported as shell variables; rename it to start with a letter to get them"
        );
        return None;
    }
    Some(
        name.chars()
            .map(|c| {
                if c.is_ascii_alphanumeric() {
                    c.to_ascii_uppercase()
                } else {
                    '_'
                }
            })
            .collect(),
    )
}

/// Pitchfork's structured `port`, pinned to the port mise already rendered into
/// the daemon's command line and `[env]` exports.
pub(crate) fn expected_port(port: u16) -> toml::Value {
    expected_ports(&[port])
}

/// A preset may bind several listeners, so every port it claims is reserved.
pub(crate) fn expected_ports(ports: &[u16]) -> toml::Value {
    toml::Value::Table(toml::Table::from_iter([
        (
            "expect".into(),
            toml::Value::Array(
                ports
                    .iter()
                    .map(|port| toml::Value::Integer(i64::from(*port)))
                    .collect(),
            ),
        ),
        ("bump".into(), toml::Value::Boolean(false)),
    ]))
}

type GroupKey = (PathBuf, String);
type GroupDeclarations = IndexMap<GroupKey, (GroupDeclaration, PathBuf, PathBuf)>;

/// Groups are project scoped: every member resolves to a daemon declared under the
/// same project root, so a group can never select daemons outside the project.
fn load_groups(
    set: &mut DaemonSet,
    declarations: GroupDeclarations,
    declared_in: &IndexMap<String, Vec<PathBuf>>,
) -> Result<()> {
    let declares = |root: &Path, name: &str| {
        declared_in
            .get(name)
            .is_some_and(|roots| roots.iter().any(|r| r == root))
    };
    let mut groups: IndexMap<GroupKey, Group> = IndexMap::new();
    for (key, (declaration, source, root)) in declarations {
        let name = key.1.clone();
        validate_name("daemon group", &name)?;
        if declares(&root, &name) {
            bail!("[daemon_groups.{name}] conflicts with the daemon of the same name");
        }
        let members = declaration.members().to_vec();
        if members.is_empty() {
            bail!("[daemon_groups.{name}] requires at least one daemon or group");
        }
        groups.insert(
            key,
            Group {
                name,
                source,
                root,
                members,
                daemons: Vec::new(),
            },
        );
    }
    for key in groups.keys().cloned().collect::<Vec<_>>() {
        let daemons = expand_group(&groups, &key, &declares, &mut Vec::new())?;
        // A group becomes a pitchfork group in this project's generated
        // configuration, and its members are that project's daemons. A daemon
        // reached with `project` belongs to another project and is registered
        // in that project's configuration under its own namespace, so naming it
        // here would produce a group mise expands and the registered one does
        // not. Say so rather than silently dropping the member.
        let group_root = groups[&key].root.clone();
        if let Some(member) = daemons
            .iter()
            .find(|member| set.imported_in(&group_root, member))
        {
            let name = &groups[&key].name;
            bail!(
                "[daemon_groups.{name}] names {member:?}, which this project reaches with `project`; a group covers the daemons this project declares, so name the imported daemon directly or list it in `depends`"
            );
        }
        groups[&key].daemons = daemons;
    }
    set.groups = groups.into_values().collect();
    Ok(())
}

fn expand_group(
    groups: &IndexMap<GroupKey, Group>,
    key: &GroupKey,
    declares: &impl Fn(&Path, &str) -> bool,
    seen: &mut Vec<String>,
) -> Result<Vec<String>> {
    let name = &key.1;
    if seen.iter().any(|s| s == name) {
        seen.push(name.clone());
        bail!(
            "[daemon_groups.{name}] references itself: {}",
            seen.join(" -> ")
        );
    }
    seen.push(name.clone());
    let group = &groups[key];
    let mut expanded: Vec<String> = Vec::new();
    for member in &group.members {
        // Membership follows what this project declared, so a same-name daemon
        // redefined by a nearer config keeps the group valid. Selection is still
        // per root, so the group only ever reaches this project's own daemons.
        if declares(&group.root, member) {
            if !expanded.contains(member) {
                expanded.push(member.clone());
            }
            continue;
        }
        // Nested members resolve within the declaring project only.
        let nested = (group.root.clone(), member.clone());
        if groups.contains_key(&nested) {
            for daemon in expand_group(groups, &nested, declares, seen)? {
                if !expanded.contains(&daemon) {
                    expanded.push(daemon);
                }
            }
            continue;
        }
        bail!(
            "{}: [daemon_groups.{name}] member {member:?} is not a daemon or group declared for {}",
            group.source.display(),
            group.root.display()
        );
    }
    seen.pop();
    Ok(expanded)
}

/// Remove `init`, accepting one command or an ordered list of them.
fn take_init(table: &mut toml::Table, name: &str) -> Result<Vec<String>> {
    let Some(value) = table.remove("init") else {
        return Ok(vec![]);
    };
    let steps = match value {
        toml::Value::String(step) => vec![step],
        toml::Value::Array(steps) => steps
            .into_iter()
            .map(|step| match step {
                toml::Value::String(step) => Ok(step),
                _ => bail!("[daemons.{name}] init entries must be strings"),
            })
            .collect::<Result<Vec<_>>>()?,
        _ => bail!("[daemons.{name}] init must be a string or an array of strings"),
    };
    if steps.iter().any(|step| step.trim().is_empty()) {
        bail!("[daemons.{name}] init entries must not be empty");
    }
    Ok(steps)
}

fn take_args(table: &mut toml::Table, name: &str) -> Result<Option<Vec<String>>> {
    table
        .remove("args")
        .map(|value| match value {
            toml::Value::Array(args) => args
                .into_iter()
                .map(|arg| match arg {
                    toml::Value::String(arg) => Ok(arg),
                    _ => bail!("[daemons.{name}] args entries must be strings"),
                })
                .collect::<Result<Vec<_>>>(),
            _ => bail!("[daemons.{name}] args must be an array of strings"),
        })
        .transpose()
}

fn take_string(table: &mut toml::Table, key: &str) -> Result<Option<String>> {
    table
        .remove(key)
        .map(|v| {
            v.as_str()
                .map(str::to_string)
                .ok_or_else(|| eyre::eyre!("daemon {key} must be a string"))
        })
        .transpose()
}

impl DaemonSet {
    pub(crate) fn add_tool_requests(&self, trs: &mut ToolRequestSet) -> Result<()> {
        for daemon in self.daemons.values() {
            // An imported daemon runs out of its own project, which installs and
            // resolves its tool there. Adding it here would force an unrelated
            // version onto this project's toolset.
            let Some((tool, version)) = daemon.tool.as_ref().filter(|_| !daemon.imported) else {
                continue;
            };
            let ba = crate::cli::args::BackendArg::from(tool.as_str());
            if let Some(existing) = trs.tools.get(&ba) {
                // Explicit declarations are validated against backend resolution before starting.
                if existing.iter().all(|tr| tr.source().is_mise_toml_daemon())
                    && existing.iter().any(|tr| tr.version() != *version)
                {
                    bail!(
                        "daemon {} requests {tool}@{version}, conflicting with another daemon; use one version per tool",
                        daemon.name
                    );
                }
                continue;
            }
            let source = ToolSource::MiseTomlDaemon(daemon.source.clone());
            let request = ToolRequest::new(ba.into(), version, source.clone())?;
            trs.add_version(request, &source);
        }
        Ok(())
    }

    pub(crate) fn env_entries(&self) -> Vec<(EnvDirective, PathBuf)> {
        self.daemons
            .values()
            .filter(|daemon| !daemon.imported)
            .flat_map(|daemon| {
                daemon.exports.iter().map(|(k, v)| {
                    (
                        EnvDirective::Val(k.clone(), v.clone(), Default::default()),
                        daemon.source.clone(),
                    )
                })
            })
            .collect()
    }

    pub(crate) fn roots(&self) -> Vec<PathBuf> {
        self.daemons
            .values()
            .map(|d| d.root.clone())
            .collect::<indexmap::IndexSet<_>>()
            .into_iter()
            .collect()
    }

    pub(crate) fn for_root(&self, root: &Path) -> Self {
        Self {
            daemons: self
                .daemons
                .iter()
                .filter(|(_, d)| d.root == root)
                .map(|(k, v)| (k.clone(), v.clone()))
                .collect(),
            namespaces: self
                .namespaces
                .iter()
                .filter(|(r, _)| r.as_path() == root)
                .map(|(r, n)| (r.clone(), n.clone()))
                .collect(),
            aliases: self
                .aliases
                .iter()
                .filter(|((r, _), _)| r.as_path() == root)
                .map(|(k, v)| (k.clone(), v.clone()))
                .collect(),
            import_errors: self.import_errors.clone(),
            blocked: self.blocked.clone(),
            // Narrowed like `namespaces`, so an imported project's checkout
            // name cannot reach this root's generated file.
            labels: self
                .labels
                .iter()
                .filter(|(r, _)| r.as_path() == root)
                .map(|(r, l)| (r.clone(), l.clone()))
                .collect(),
            groups: self
                .groups
                .iter()
                .filter(|g| g.root == root)
                .cloned()
                .collect(),
        }
    }

    /// The group named `name`. Call on a root-scoped set, where names are unique.
    pub(crate) fn group(&self, name: &str) -> Option<&Group> {
        self.groups.iter().find(|g| g.name == name)
    }

    /// Daemon names a declared group expands to, or None when `name` is not a group.
    pub(crate) fn expand(&self, name: &str) -> Option<&[String]> {
        self.group(name).map(|g| g.daemons.as_slice())
    }

    /// Resolve a local declaration or import alias to its qualified ID.
    /// A local name must not also select a same-named daemon from another root.
    pub(crate) fn resolve_alias(&self, name: &str) -> String {
        self.imported_as(name)
            .map(str::to_string)
            .or_else(|| {
                let daemon = self.daemons.get(name)?;
                let namespace = self.namespace_for(&daemon.root)?;
                Some(format!("{namespace}/{}", daemon.name))
            })
            .unwrap_or_else(|| name.to_string())
    }

    /// The qualified ID a name refers to when some project in this set imported
    /// a daemon under it. Callers holding a root-scoped set ask about that
    /// project alone, which is the question worth asking.
    pub(crate) fn imported_as(&self, name: &str) -> Option<&str> {
        self.aliases
            .iter()
            .find(|((_, key), _)| key == name)
            .map(|(_, id)| id.as_str())
    }

    /// What a bare name means to a project.
    ///
    /// A project inherits its ancestors' daemons and groups and may redefine
    /// them, so the nearest declaration wins. Within one project the two cannot
    /// collide: a group conflicting with a daemon of the same name there is
    /// rejected when configuration loads.
    pub(crate) fn resolve_bare(&self, root: &Path, name: &str) -> Option<BareName<'_>> {
        for ancestor in root.ancestors() {
            // A daemon declared here claims the word, so the walk stops: an
            // ancestor's group of the same name does not reach past a nearer
            // project's daemon, and neither does one in an unrelated project.
            if self
                .daemons
                .values()
                .any(|d| !d.imported && d.root == ancestor && d.name == name)
            {
                return Some(BareName::Daemon);
            }
            if self
                .groups
                .iter()
                .any(|g| g.root == ancestor && g.name == name)
            {
                return Some(BareName::Group);
            }
            let key = (ancestor.to_path_buf(), name.to_string());
            if let Some(id) = self.aliases.get(&key) {
                return Some(BareName::Import(id.as_str()));
            }
            if let Some(err) = self.import_errors.get(&key) {
                return Some(BareName::Unresolved(err.as_str()));
            }
        }
        None
    }

    /// Whether `root` reaches an import under this name, its own or inherited.
    pub(crate) fn imported_in(&self, root: &Path, name: &str) -> bool {
        matches!(self.resolve_bare(root, name), Some(BareName::Import(_)))
    }

    /// The pitchfork namespace for a project root, when this set declares daemons for it.
    pub(crate) fn namespace_for(&self, root: &Path) -> Option<&str> {
        self.namespaces.get(root).map(String::as_str)
    }

    /// The subset of this set that another set also names.
    ///
    /// Only for deciding what this invocation may act on or show. Never pass the
    /// result to `prepare`: a root's generated pitchfork config is rewritten
    /// whole, so registering a reduced set deletes that project's other daemons.
    pub(crate) fn restricted_to(&self, requested: &Self) -> Self {
        Self {
            daemons: self
                .daemons
                .iter()
                // Match the root too. A name alone is only unique within one
                // project, and nothing here promises both sets hold just one.
                .filter_map(|(k, v)| {
                    let asked = requested
                        .daemons
                        .values()
                        .find(|r| r.name == v.name && r.root == v.root)?;
                    let mut daemon = v.clone();
                    // The declaring project settled what is registered; the
                    // project asking settles what it advertises. It sees the
                    // other projects this one imports from, so it alone can
                    // tell that two of them claim one hostname and the proxy
                    // serves neither. Showing a URL from the narrower view
                    // would offer an endpoint that answers for no one.
                    if asked.host.is_none() {
                        daemon.withdraw_host();
                    }
                    Some((k.clone(), daemon))
                })
                .collect(),
            namespaces: self.namespaces.clone(),
            aliases: self.aliases.clone(),
            import_errors: self.import_errors.clone(),
            blocked: self.blocked.clone(),
            labels: self.labels.clone(),
            groups: self.groups.clone(),
        }
    }

    /// The daemons these names select, together with their dependency closure.
    /// Bare dependencies resolve within the declaring daemon's namespace;
    /// qualified dependencies can select another loaded project's daemon.
    pub(crate) fn with_dependencies(&self, names: &[String]) -> Self {
        let qualified = |d: &Daemon| match self.namespace_for(&d.root) {
            Some(namespace) => format!("{namespace}/{}", d.name),
            None => d.name.clone(),
        };
        let by_id: IndexMap<_, _> = self.daemons.values().map(|d| (qualified(d), d)).collect();
        let mut keep: indexmap::IndexSet<String> = by_id
            .iter()
            .filter(|(id, daemon)| {
                names.iter().any(|name| {
                    name == *id
                        // A bare name means the daemon that key refers to, not
                        // every daemon that happens to carry it: another project
                        // can have one of its own with the same name.
                        || self.daemons.get(name).is_some_and(|exact| {
                            exact.name == daemon.name && exact.root == daemon.root
                        })
                })
            })
            .map(|(id, _)| id.clone())
            .collect();
        let mut queue: Vec<String> = keep.iter().cloned().collect();
        while let Some(id) = queue.pop() {
            let Some(daemon) = by_id.get(&id) else {
                continue;
            };
            for dependency in depends_names(&daemon.table) {
                let dependency = if dependency.contains('/') {
                    dependency
                } else if let Some(namespace) = self.namespace_for(&daemon.root) {
                    format!("{namespace}/{dependency}")
                } else {
                    dependency
                };
                if by_id.contains_key(&dependency) && keep.insert(dependency.clone()) {
                    queue.push(dependency);
                }
            }
        }
        Self {
            daemons: self
                .daemons
                .iter()
                .filter(|(_, d)| keep.contains(&qualified(d)))
                .map(|(k, v)| (k.clone(), v.clone()))
                .collect(),
            namespaces: self.namespaces.clone(),
            aliases: self.aliases.clone(),
            import_errors: self.import_errors.clone(),
            blocked: self.blocked.clone(),
            labels: self.labels.clone(),
            groups: self.groups.clone(),
        }
    }

    /// Whether this set holds that exact daemon, matched by owning project and
    /// name. A name alone is unique only within one project, so two projects can
    /// each have an `api` and only one of them is the daemon in question.
    pub(crate) fn contains(&self, daemon: &Daemon) -> bool {
        self.daemons
            .values()
            .any(|d| d.name == daemon.name && d.root == daemon.root)
    }

    /// Look a daemon up by the name it carries inside its own project. Imported
    /// daemons are keyed by qualified ID, so the map key is not always the name.
    pub(crate) fn find(&self, name: &str) -> Option<&Daemon> {
        self.daemons.values().find(|d| d.name == name)
    }

    /// Check `task = "..."` references against the loaded task list. Task
    /// loading is asynchronous and reads the filesystem, so this cannot run
    /// while `[daemons]` is parsed. The three paths that register a generated
    /// pitchfork configuration call it first: `mise daemons start`, a task that
    /// requires daemons, and the shell auto-lifecycle hook.
    pub(crate) async fn validate_tasks(&self, config: &Arc<Config>) -> Result<()> {
        if self.daemons.values().all(|d| d.task.is_none()) {
            return Ok(());
        }
        let tasks = config.tasks_with_aliases().await?;
        for daemon in self.daemons.values() {
            let Some(task) = &daemon.task else {
                continue;
            };
            if !tasks.contains_key(task) {
                bail!("daemon {} runs unknown task {task:?}", daemon.name);
            }
        }
        Ok(())
    }

    /// The daemons pitchfork starts when a shell joins this project's session,
    /// together with everything they depend on. `auto` is passed through to the
    /// generated configuration and pitchfork acts on it, so mise mirrors the
    /// rule here to check a start it is about to hand over.
    pub(crate) fn auto_starting(&self) -> Self {
        let names: Vec<String> = self
            .daemons
            .iter()
            .filter(|(_, d)| {
                d.table
                    .get("auto")
                    .and_then(toml::Value::as_array)
                    .is_some_and(|a| a.iter().any(|v| v.as_str() == Some("start")))
            })
            .map(|(key, _)| key.clone())
            .collect();
        self.with_dependencies(&names)
    }

    pub(crate) fn auto(&self) -> bool {
        self.daemons.values().any(|d| {
            d.table
                .get("auto")
                .and_then(toml::Value::as_array)
                .is_some_and(|a| !a.is_empty())
        })
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::config::config_file::mise_toml::MiseToml;
    use std::sync::Arc;

    fn files(entries: &[(&str, &str)]) -> ConfigMap {
        entries
            .iter()
            .map(|(path, body)| {
                let path = PathBuf::from(path);
                let cf: Arc<dyn crate::config::config_file::ConfigFile> =
                    Arc::new(MiseToml::from_str(body, &path).unwrap());
                (path, cf)
            })
            .collect()
    }

    #[tokio::test]
    async fn daemons_merge_before_expanding_tools_and_exports() {
        crate::toolset::install_state::init().await.unwrap();
        let config = files(&[
            (
                "/parent/child/mise.toml",
                "[daemons.postgres]\nrun = 'echo custom'\n",
            ),
            (
                "/parent/mise.toml",
                "[daemons]\npostgres = '18'\nredis = '8'\n",
            ),
        ]);
        let set = load(&config).unwrap();
        assert!(set.daemons["postgres"].tool.is_none());
        // The preset's Postgres variables are gone with the preset, and this
        // custom daemon configures no port, so it gets no endpoint of its own.
        assert!(set.daemons["postgres"].exports.is_empty());
        assert_eq!(
            set.daemons["postgres"].table["run"].as_str(),
            Some("echo custom")
        );
        let mut requests = ToolRequestSet::default();
        set.add_tool_requests(&mut requests).unwrap();
        assert_eq!(requests.tools.len(), 1);
        assert!(
            requests
                .sources
                .values()
                .next()
                .unwrap()
                .is_mise_toml_daemon()
        );
    }

    #[tokio::test]
    async fn preset_names_and_version_conflicts_are_reported() {
        crate::toolset::install_state::init().await.unwrap();
        let config = files(&[("/project/mise.toml", "[daemons]\nunknown = '1'\n")]);
        assert!(
            load(&config)
                .unwrap_err()
                .to_string()
                .contains("available presets")
        );
        let config = files(&[(
            "/project/mise.toml",
            "[daemons]\npostgres = '18'\n[daemons.analytics]\npreset = 'postgres'\nversion = '17'\nport = 5433\n",
        )]);
        // A second instance needs its own port; this is about the tool
        // conflict two versions of one preset produce.
        let set = load(&config).unwrap();
        assert!(
            set.add_tool_requests(&mut ToolRequestSet::default())
                .is_err()
        );
    }

    #[test]
    fn preset_run_override_keeps_initialization() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\nrun = 'echo starting && exec postgres -D /data'\n",
        )]);
        let set = load(&config).unwrap();
        let run = set.daemons["db"].table["run"].as_str().unwrap();
        assert!(run.contains("daemons __init"));
        assert!(run.ends_with("&& echo starting && exec postgres -D /data"));
        let invalid = files(&[(
            "/project/mise.toml",
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\nrun = 42\n",
        )]);
        assert!(load(&invalid).is_err());
    }

    #[test]
    fn preset_tool_override_is_used_and_not_forwarded() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.cache]\npreset = 'redis'\nversion = '8'\ntool = 'github:example/redis'\n",
        )]);
        let set = load(&config).unwrap();
        assert_eq!(
            set.daemons["cache"].tool.as_ref().unwrap().0,
            "github:example/redis"
        );
        assert!(!set.daemons["cache"].table.contains_key("tool"));
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.cache]\npreset = 'redis'\nversion = '8'\ntool = 42\n",
        )]);
        assert!(
            load(&config)
                .unwrap_err()
                .to_string()
                .contains("tool must be a string")
        );
    }

    #[test]
    #[cfg(unix)]
    fn task_probe_environment_respects_explicit_opt_out() {
        for opt_out in [false, true] {
            let source = format!(
                "[daemons.api]\ntask = 'dev'\nready_cmd = 'echo ready'\nhealth_cmd = {{ run = 'echo {{{{ env.FOO }}}}', interval = '2s' }}\n{}",
                if opt_out { "mise = false\n" } else { "" }
            );
            let config = files(&[("/project/mise.toml", &source)]);
            let set = load(&config).unwrap();
            let table = &set.daemons["api"].table;
            let expected = if opt_out {
                "echo ready".to_string()
            } else {
                presets::in_tool_env("echo ready")
            };
            assert_eq!(table["ready_cmd"].as_str(), Some(expected.as_str()));
            let expected = if opt_out {
                "echo {{ env.FOO }}".to_string()
            } else {
                presets::in_tool_env("echo {{ env.FOO }}")
            };
            assert_eq!(table["health_cmd"]["run"].as_str(), Some(expected.as_str()));
            assert_eq!(table["health_cmd"]["interval"].as_str(), Some("2s"));
        }
    }

    #[test]
    fn task_daemons_run_mise_without_a_mise_wrapper() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.core]\ntask = 'dev:core'\nargs = ['--port', \"it's 3000\"]\nready_port = 3000\n",
        )]);
        let set = load(&config).unwrap();
        let daemon = &set.daemons["core"];
        let mise = presets::quote(crate::env::MISE_BIN.to_string_lossy());
        assert_eq!(
            daemon.table["run"].as_str(),
            Some(format!("exec {mise} run 'dev:core' -- '--port' 'it'\\''s 3000'").as_str())
        );
        // The task keeps its own `depends`; a marker in the daemon environment
        // is what stops the nested run from starting this daemon again.
        assert_eq!(daemon.table["env"][DAEMON_TASK_MARKER].as_str(), Some("1"));
        // mise is the entry point already, so pitchfork must not re-enter it.
        assert_eq!(daemon.table["mise"].as_bool(), Some(false));
        assert_eq!(daemon.task.as_deref(), Some("dev:core"));
        // Task plumbing stays in mise; pitchfork only sees its own keys.
        assert!(!daemon.table.contains_key("task"));
        assert!(!daemon.table.contains_key("args"));
        assert_eq!(daemon.table["ready_port"].as_integer(), Some(3000));
        // A task daemon with no args does not emit a dangling separator.
        let config = files(&[("/project/mise.toml", "[daemons.core]\ntask = 'dev'\n")]);
        assert_eq!(
            load(&config).unwrap().daemons["core"].table["run"].as_str(),
            Some(format!("exec {mise} run 'dev'").as_str())
        );
    }

    #[test]
    fn conflicting_daemon_process_declarations_are_rejected() {
        for body in [
            "[daemons.core]\ntask = 'dev'\nrun = 'server'\n",
            "[daemons.core]\npreset = 'postgres'\nversion = '18'\ntask = 'dev'\n",
            "[daemons.core]\nargs = ['--port']\nrun = 'server'\n",
            "[daemons.core]\ntask = ''\n",
            "[daemons.core]\nready_port = 3000\n",
        ] {
            assert!(
                load(&files(&[("/project/mise.toml", body)])).is_err(),
                "{body}"
            );
        }
    }

    #[test]
    fn conflict_errors_name_the_key_that_is_set() {
        // `args` without `task` is a different mistake from `preset` with
        // `task`, so the message must not blame a key the user never wrote.
        let err = load(&files(&[(
            "/project/mise.toml",
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\nargs = ['--flag']\n",
        )]))
        .unwrap_err()
        .to_string();
        assert!(err.contains("args requires task"), "{err}");
        let err = load(&files(&[(
            "/project/mise.toml",
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\ntask = 'dev'\n",
        )]))
        .unwrap_err()
        .to_string();
        assert!(err.contains("cannot combine preset with task"), "{err}");
    }

    #[test]
    fn init_steps_run_before_the_long_running_process() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\ninit = ['npm ci', 'npm run migrate']\nrun = 'exec npm start'\n",
        )]);
        let set = load(&config).unwrap();
        assert_eq!(
            set.daemons["api"].table["run"].as_str(),
            Some("npm ci && npm run migrate && exec npm start")
        );
        // A single string is the same as a one-entry list.
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\ninit = 'npm ci'\nrun = 'exec npm start'\n",
        )]);
        assert_eq!(
            load(&config).unwrap().daemons["api"].table["run"].as_str(),
            Some("npm ci && exec npm start")
        );
        // Preset initialization still comes first, before user setup.
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\ninit = 'echo ready'\n",
        )]);
        let run = load(&config).unwrap().daemons["db"].table["run"]
            .as_str()
            .unwrap()
            .to_string();
        let init = run.find(" daemons __init ").unwrap();
        assert!(init < run.find("echo ready").unwrap());
        assert!(run.contains("&& echo ready && exec "));
        // A task daemon with init keeps pitchfork's `mise x` wrapper, so the
        // steps and the task share one shell that has the project's tools.
        let wrapped = files(&[(
            "/project/mise.toml",
            "[daemons.core]\ntask = 'dev'\ninit = ['npm ci', 'npm run migrate']\n",
        )]);
        let daemon = &load(&wrapped).unwrap().daemons["core"];
        let run = daemon.table["run"].as_str().unwrap().to_string();
        assert!(
            run.starts_with("npm ci && npm run migrate && exec "),
            "{run}"
        );
        assert!(run.ends_with("run 'dev'"), "{run}");
        assert_eq!(daemon.table["mise"].as_bool(), Some(true));
        // An explicit `mise` value stays the user's call.
        let explicit = files(&[(
            "/project/mise.toml",
            "[daemons.core]\ntask = 'dev'\ninit = 'npm ci'\nmise = false\n",
        )]);
        assert_eq!(
            load(&explicit).unwrap().daemons["core"].table["mise"].as_bool(),
            Some(false)
        );
        // `init` is consumed by mise and never reaches pitchfork.
        assert!(
            !load(&config).unwrap().daemons["db"]
                .table
                .contains_key("init")
        );
        for body in [
            "[daemons.api]\ninit = 1\nrun = 'server'\n",
            "[daemons.api]\ninit = [1]\nrun = 'server'\n",
            "[daemons.api]\ninit = ' '\nrun = 'server'\n",
        ] {
            assert!(
                load(&files(&[("/project/mise.toml", body)])).is_err(),
                "{body}"
            );
        }
    }

    #[test]
    fn custom_daemons_accept_integer_ports() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\nrun = 'server'\nport = 3000\n",
        )]);
        let set = load(&config).unwrap();
        assert_eq!(
            set.daemons["api"].table["port"]["expect"][0].as_integer(),
            Some(3000)
        );
    }

    /// A project whose daemons another project can import. The filename has to
    /// be one this build actually looks for; unit tests override the list.
    fn referenced_project(dir: &Path, body: &str) -> PathBuf {
        let path = untrusted_project(dir, body);
        // Importing requires trust that already exists. These fixtures stand in
        // for projects the developer has reviewed and trusted.
        crate::config::config_file::trust(dir).unwrap();
        path
    }

    /// Every test that imports takes this lock. The paranoid-mode test changes a
    /// global setting, and under `paranoid` a fixture's directory-level trust no
    /// longer covers its config file, so an overlapping import would fail.
    static IMPORT_TESTS: std::sync::Mutex<()> = std::sync::Mutex::new(());

    fn import_lock() -> std::sync::MutexGuard<'static, ()> {
        crate::test::lock_ignoring_poison(&IMPORT_TESTS)
    }

    /// The recorded failure for an import, by the name the project gave it.
    fn failure(set: &DaemonSet, name: &str) -> String {
        set.import_errors
            .iter()
            .find(|((_, key), _)| key == name)
            .map(|(_, err)| err.clone())
            .unwrap_or_else(|| panic!("no import failure recorded for {name:?}"))
    }

    /// A referenced project the developer has never trusted.
    fn untrusted_project(dir: &Path, body: &str) -> PathBuf {
        std::fs::create_dir_all(dir).unwrap();
        let path = dir.join(&*crate::env::MISE_DEFAULT_CONFIG_FILENAME);
        std::fs::write(&path, body).unwrap();
        path
    }

    #[test]
    fn referenced_project_daemons_belong_to_that_project() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror-pipeline");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'mirror'\n[daemons.worker]\nrun = 'exec worker'\n[daemons.idle]\nrun = 'exec idle'\n",
        );
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.worker]\nproject = '../mirror-pipeline'\n[daemons.api]\nrun = 'exec api'\ndepends = ['worker']\n",
        )]);
        let set = load(&config).unwrap();
        let worker = &set.daemons["mirror/worker"];
        assert!(worker.imported);
        assert_eq!(worker.name, "worker");
        assert_eq!(worker.root, mirror.canonicalize().unwrap());
        assert_eq!(
            worker.source,
            mirror
                .canonicalize()
                .unwrap()
                .join(&*crate::env::MISE_DEFAULT_CONFIG_FILENAME)
        );
        // Only the named daemon is imported, and it keeps the referenced
        // project's namespace and root rather than this project's.
        assert!(!set.daemons.contains_key("idle"));
        let starting = set.with_dependencies(&["api".into()]);
        assert!(starting.daemons.contains_key("mirror/worker"));
        assert!(starting.daemons.contains_key("api"));
        assert!(set.roots().contains(&mirror.canonicalize().unwrap()));
        assert_eq!(
            set.namespace_for(&mirror.canonicalize().unwrap()),
            Some("mirror")
        );
        // A short depends on an imported daemon is rewritten; pitchfork resolves
        // bare names inside one namespace only.
        assert_eq!(
            set.daemons["api"].table["depends"][0].as_str(),
            Some("mirror/worker")
        );
        // The referenced project installs and exports for its own daemon, and
        // neither daemon here configures a port, so nothing is exported.
        let mut requests = ToolRequestSet::default();
        set.add_tool_requests(&mut requests).unwrap();
        assert!(requests.tools.is_empty());
        assert!(set.env_entries().is_empty());
    }

    #[test]
    fn referenced_daemon_may_be_renamed_locally() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(&mirror, "[daemons.worker]\nrun = 'exec worker'\n");
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons.pipeline]\nproject = {}\nname = 'worker'\n",
                toml::Value::String(mirror.to_string_lossy().into_owned())
            ),
        )]);
        let set = load(&config).unwrap();
        let daemon = set.daemons.values().next().unwrap();
        assert_eq!(daemon.name, "worker");
        assert!(daemon.imported);
        // The key this project chose still selects it on the command line.
        assert_eq!(
            set.resolve_alias("pipeline"),
            format!("{}/worker", set.namespace_for(&daemon.root).unwrap())
        );
        assert_eq!(set.resolve_alias("other"), "other");
    }

    #[test]
    fn an_unresolvable_import_does_not_break_other_commands() {
        let _serial = import_lock();
        // Daemons load on every command. A sibling that is not checked out must
        // leave `mise x`, `mise run` and the activation hook working.
        let tmp = tempfile::tempdir().unwrap();
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.pipeline]\nproject = '../mirror-pipeline'\n[daemons.api]\nrun = 'exec api'\n",
        )]);
        let set = load(&config).unwrap();
        // Nothing depends on the unresolved import here, so nothing is blocked.
        assert!(set.blocked.is_empty());
        // The local daemon still loads, so env and tool resolution are unaffected.
        assert!(set.daemons.contains_key("api"));
        assert!(!set.daemons.contains_key("pipeline"));
        // The failure is kept so `mise daemons` can report it with the path.
        let err = &failure(&set, "pipeline");
        assert!(err.contains("mirror-pipeline"), "{err}");
        assert!(err.contains("[daemons.pipeline].project"), "{err}");
        assert!(
            set.add_tool_requests(&mut ToolRequestSet::default())
                .is_ok(),
            "tool resolution must survive an unresolvable import"
        );
    }

    #[test]
    fn missing_referenced_projects_name_the_path_and_the_setting() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let source = app.join("mise.toml");
        let config = files(&[(
            source.to_str().unwrap(),
            "[daemons.worker]\nproject = '../mirror-pipeline'\n",
        )]);
        let err = failure(&load(&config).unwrap(), "worker");
        assert!(err.contains(&tmp.path().join("mirror-pipeline").display().to_string()));
        assert!(err.contains("[daemons.worker].project"));

        let empty = tmp.path().join("empty");
        std::fs::create_dir_all(&empty).unwrap();
        let config = files(&[(
            source.to_str().unwrap(),
            "[daemons.worker]\nproject = '../empty'\n",
        )]);
        assert!(failure(&load(&config).unwrap(), "worker").contains("mise configuration"));

        referenced_project(
            &tmp.path().join("other"),
            "[daemons.build]\nrun = 'exec build'\n",
        );
        let config = files(&[(
            source.to_str().unwrap(),
            "[daemons.worker]\nproject = '../other'\n",
        )]);
        let err = failure(&load(&config).unwrap(), "worker");
        assert!(err.contains("[daemons.worker]"), "{err}");
        assert!(err.contains("build"), "{err}");
    }

    #[test]
    fn referenced_projects_inherit_daemons_and_namespaces_from_parent_configs() {
        let _serial = import_lock();
        // The referenced root is reloaded through its whole hierarchy when its
        // daemons are prepared, so discovery has to agree with that.
        let tmp = tempfile::tempdir().unwrap();
        let group = tmp.path().join("group");
        referenced_project(
            &group,
            "[daemons_settings]\nnamespace = 'shared'\n[daemons.worker]\nrun = 'exec worker'\n",
        );
        let mirror = group.join("mirror-pipeline");
        std::fs::create_dir_all(&mirror).unwrap();
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons.worker]\nproject = {}\n",
                toml::Value::String(mirror.to_string_lossy().into_owned())
            ),
        )]);
        let set = load(&config).unwrap();
        // Both the daemon and the namespace come from the parent config.
        let daemon = &set.daemons["shared/worker"];
        assert!(daemon.imported);
        assert_eq!(daemon.root, group.canonicalize().unwrap());
        assert_eq!(
            set.namespace_for(&group.canonicalize().unwrap()),
            Some("shared")
        );
    }

    #[test]
    fn global_daemon_settings_do_not_capture_every_project() {
        // A global config's root is the home directory, so honouring a namespace
        // there would give every project on the machine the same one.
        let tmp = tempfile::tempdir().unwrap();
        let global = crate::dirs::HOME.join("config").join("config.toml");
        let config = files(&[
            (
                global.to_str().unwrap(),
                "[daemons_settings]\nnamespace = 'everything'\n",
            ),
            (
                tmp.path().join("app").join("mise.toml").to_str().unwrap(),
                "[daemons.api]\nrun = 'exec api'\n",
            ),
        ]);
        let set = load(&config).unwrap();
        let root = set.daemons["api"].root.clone();
        assert_ne!(set.namespace_for(&root), Some("everything"));
        assert_eq!(
            set.namespace_for(&root),
            Some(runtime::namespace(&root).unwrap().as_str())
        );
    }

    #[test]
    fn two_imports_cannot_claim_one_daemon_id() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        for dir in ["one", "two"] {
            referenced_project(
                &tmp.path().join(dir),
                "[daemons_settings]\nnamespace = 'shared'\n[daemons.worker]\nrun = 'exec worker'\n",
            );
        }
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.first]\nproject = '../one'\nname = 'worker'\n[daemons.second]\nproject = '../two'\nname = 'worker'\n",
        )]);
        let err = load(&config).unwrap_err().to_string();
        assert!(err.contains("shared/worker"), "{err}");
        assert!(err.contains("share a namespace"), "{err}");
    }

    #[test]
    fn depends_entries_must_be_strings() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\nrun = 'exec api'\ndepends = ['db', 3]\n",
        )]);
        assert!(
            load(&config)
                .unwrap_err()
                .to_string()
                .contains("array of strings")
        );
    }

    #[test]
    fn selecting_a_daemon_includes_what_it_depends_on() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\nrun = 'exec api'\ndepends = ['cache']\n[daemons.cache]\nrun = 'exec cache'\ndepends = ['db']\n[daemons.db]\nrun = 'exec db'\n[daemons.unrelated]\nrun = 'exec other'\n",
        )]);
        let set = load(&config).unwrap();
        let starting = set.with_dependencies(&["api".to_string()]);
        let mut names: Vec<_> = starting.daemons.values().map(|d| d.name.clone()).collect();
        names.sort();
        assert_eq!(names, ["api", "cache", "db"]);
    }

    #[test]
    fn qualified_selection_requires_the_daemons_namespace() {
        let config = files(&[(
            "/project/mise.toml",
            "[daemons_settings]\nnamespace = 'app'\n[daemons.worker]\nrun = 'exec worker'\n[daemons.api]\nrun = 'exec api'\n",
        )]);
        let set = load(&config).unwrap();
        let selected = set.with_dependencies(&["mirror/worker".into(), "api".into()]);
        assert!(selected.find("worker").is_none());
        assert!(selected.find("api").is_some());
        assert!(
            set.with_dependencies(&["app/worker".into()])
                .find("worker")
                .is_some()
        );
    }

    #[test]
    fn two_projects_cannot_claim_one_daemon_id() {
        let _serial = import_lock();
        // Fixed namespaces make this reachable: an import resolves to the same
        // namespace as a daemon declared here, and both want the same ID.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'shared'\n[daemons.worker]\nrun = 'exec worker'\n",
        );
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons_settings]\nnamespace = 'shared'\n[daemons.worker]\nrun = 'exec local'\n[daemons.pipeline]\nproject = {}\nname = 'worker'\n",
                toml::Value::String(mirror.to_string_lossy().into_owned())
            ),
        )]);
        let err = load(&config).unwrap_err().to_string();
        assert!(err.contains("shared/worker"), "{err}");
        assert!(err.contains("share a namespace"), "{err}");
    }

    #[test]
    fn nested_referenced_projects_resolve_the_same_namespace_both_ways() {
        let _serial = import_lock();
        // The namespace computed when importing has to be the one registered
        // when that root is prepared, or `depends` and `start` name an ID that
        // pitchfork never saw.
        let tmp = tempfile::tempdir().unwrap();
        let group = tmp.path().join("group");
        referenced_project(&group, "[daemons_settings]\nnamespace = 'shared'\n");
        let mirror = group.join("mirror-pipeline");
        referenced_project(&mirror, "[daemons.worker]\nrun = 'exec worker'\n");

        // What the referenced project computes for itself when it is prepared.
        let own = files(&[
            (
                mirror
                    .join(&*crate::env::MISE_DEFAULT_CONFIG_FILENAME)
                    .to_str()
                    .unwrap(),
                "[daemons.worker]\nrun = 'exec worker'\n",
            ),
            (
                group
                    .join(&*crate::env::MISE_DEFAULT_CONFIG_FILENAME)
                    .to_str()
                    .unwrap(),
                "[daemons_settings]\nnamespace = 'shared'\n",
            ),
        ]);
        let own = load(&own).unwrap();
        let own_root = own.daemons["worker"].root.clone();
        assert_eq!(own.namespace_for(&own_root), Some("shared"));

        // What another project computes when it imports that daemon.
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons.worker]\nproject = {}\n",
                toml::Value::String(mirror.to_string_lossy().into_owned())
            ),
        )]);
        let imported = load(&config).unwrap();
        assert!(imported.daemons.contains_key("shared/worker"));
        assert_eq!(
            imported.namespace_for(&mirror.canonicalize().unwrap()),
            Some("shared")
        );
    }

    #[test]
    fn starting_a_daemon_whose_import_is_unavailable_is_refused() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.pipeline]\nproject = '../gone'\n[daemons.api]\nrun = 'exec api'\ndepends = ['pipeline']\n[daemons.web]\nrun = 'exec web'\n",
        )]);
        let set = load(&config).unwrap();
        // Starting the daemon that lost the dependency is refused, naming the
        // import and why it is unavailable.
        let err = ensure_not_blocked(&set, &set.with_dependencies(&["api".into()]), None)
            .unwrap_err()
            .to_string();
        assert!(err.contains("[daemons.pipeline]"), "{err}");
        assert!(err.contains("gone"), "{err}");
        // A daemon that never depended on it is unaffected.
        assert!(ensure_not_blocked(&set, &set.with_dependencies(&["web".into()]), None).is_ok());
        // The owning project is named when one is given, since the daemon can
        // belong to a project other than the one being run.
        let err = ensure_not_blocked(&set, &set.with_dependencies(&["api".into()]), Some(&app))
            .unwrap_err()
            .to_string();
        assert!(err.contains(&app.display().to_string()), "{err}");
    }

    #[test]
    fn a_name_means_the_nearest_declaration_that_claims_it() {
        let _serial = import_lock();
        // A parent's `project` reference that cannot be read must not take the
        // word away from a group the child declares under it.
        let tmp = tempfile::tempdir().unwrap();
        let parent = tmp.path().join("parent");
        let child = parent.join("child");
        std::fs::create_dir_all(&child).unwrap();
        let config = files(&[
            (
                child.join("mise.toml").to_str().unwrap(),
                "[daemons.api]\nrun = 'exec api'\n[daemon_groups]\nops = ['api']\n",
            ),
            (
                parent.join("mise.toml").to_str().unwrap(),
                "[daemons.ops]\nproject = '../gone'\n",
            ),
        ]);
        let set = load(&config).unwrap();
        // To the child the word is its group; to the parent it is the failure.
        assert!(matches!(
            set.resolve_bare(&child, "ops"),
            Some(BareName::Group)
        ));
        assert!(matches!(
            set.resolve_bare(&parent, "ops"),
            Some(BareName::Unresolved(_))
        ));
        assert_eq!(set.expand("ops"), Some(["api".to_string()].as_slice()));
    }

    #[test]
    fn a_nearer_failure_is_not_hidden_by_an_ancestor_that_resolved() {
        let _serial = import_lock();
        // The child redefines a word its parent imported successfully, and the
        // child's own reference cannot be read. The nearest declaration decides,
        // so the word means the failure and not the parent's daemon.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'remote'\n[daemons.worker]\nrun = 'exec worker'\n",
        );
        let parent = tmp.path().join("parent");
        let child = parent.join("child");
        std::fs::create_dir_all(&child).unwrap();
        let config = files(&[
            (
                child.join("mise.toml").to_str().unwrap(),
                "[daemons.pipeline]\nproject = '../gone'\n",
            ),
            (
                parent.join("mise.toml").to_str().unwrap(),
                &format!(
                    "[daemons.pipeline]\nproject = {}\nname = 'worker'\n",
                    toml::Value::String(mirror.to_string_lossy().into_owned())
                ),
            ),
        ]);
        let set = load(&config).unwrap();
        assert!(matches!(
            set.resolve_bare(&child, "pipeline"),
            Some(BareName::Unresolved(_))
        ));
        assert!(!set.imported_in(&child, "pipeline"));
        // Nothing kept the parent's masked declaration, so no walk from any
        // root can answer the word with the daemon it would have imported.
        assert!(set.resolve_bare(&parent, "pipeline").is_none());
        assert!(set.imported_as("pipeline").is_none());
    }

    #[test]
    fn the_auto_lifecycle_checks_only_what_it_starts() {
        let _serial = import_lock();
        // The shell hook registers the whole project but pitchfork only starts
        // the `auto = ["start"]` daemons, so a blocked daemon nobody starts must
        // not take the project's automatic lifecycle down with it.
        let app = tempfile::tempdir().unwrap();
        let root = app.path().to_path_buf();
        let config = files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.api]\nrun = 'exec api'\nauto = ['start', 'stop']\ndepends = ['pipeline']\n\
             [daemons.manual]\nrun = 'exec manual'\ndepends = ['other']\n\
             [daemons.pipeline]\nproject = '../gone'\n[daemons.other]\nproject = '../gone'\n",
        )]);
        let set = load(&config).unwrap();
        let starting = set.auto_starting();
        assert!(starting.daemons.contains_key("api"));
        assert!(!starting.daemons.contains_key("manual"));
        let err = ensure_not_blocked(&set, &starting, Some(&root))
            .unwrap_err()
            .to_string();
        assert!(err.contains("\"api\""), "{err}");
        assert!(err.contains("[daemons.pipeline]"), "{err}");
        // Only the daemon nobody starts is blocked: the hook stays out of it.
        let config = files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.api]\nrun = 'exec api'\nauto = ['start']\n\
             [daemons.manual]\nrun = 'exec manual'\ndepends = ['other']\n\
             [daemons.other]\nproject = '../gone'\n",
        )]);
        let set = load(&config).unwrap();
        assert!(set.blocked.contains_key("manual"));
        assert!(ensure_not_blocked(&set, &set.auto_starting(), Some(&root)).is_ok());
    }

    #[test]
    fn a_broken_import_does_not_disturb_a_working_one() {
        let _serial = import_lock();
        // A project can reach one import that resolves and one that does not.
        // Each `depends` entry is answered by its own declaration.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'remote'\n[daemons.worker]\nrun = 'exec worker'\n",
        );
        let parent = tmp.path().join("parent");
        let child = parent.join("child");
        std::fs::create_dir_all(&child).unwrap();
        let config = files(&[
            (
                child.join("mise.toml").to_str().unwrap(),
                "[daemons.api]\nrun = 'exec api'\ndepends = ['pipeline', 'absent']\n",
            ),
            (
                parent.join("mise.toml").to_str().unwrap(),
                &format!(
                    "[daemons.pipeline]\nproject = {}\nname = 'worker'\n[daemons.absent]\nproject = '../gone'\n",
                    toml::Value::String(mirror.to_string_lossy().into_owned())
                ),
            ),
        ]);
        let set = load(&config).unwrap();
        // The resolved one is rewritten to the ID it answers to; the unresolved
        // one is dropped, so nothing unresolvable reaches pitchfork.
        let depends = set.daemons["api"].table["depends"].as_array().unwrap();
        assert_eq!(depends.len(), 1);
        assert_eq!(depends[0].as_str(), Some("remote/worker"));
        // Starting it is refused, naming the one that is unavailable.
        assert_eq!(
            set.blocked.get("api").map(|(name, _)| name.as_str()),
            Some("absent")
        );
        assert!(set.imported_in(&child, "pipeline"));
    }

    #[test]
    fn a_child_reaches_an_import_its_parent_declared() {
        let _serial = import_lock();
        // Configuration is inherited, so a child may name a `project` reference
        // its parent declared; the rewritten dependency has to carry the ID the
        // daemon answers to, or pitchfork looks it up in the child's namespace.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'remote'\n[daemons.worker]\nrun = 'exec worker'\n",
        );
        let parent = tmp.path().join("parent");
        let child = parent.join("child");
        std::fs::create_dir_all(&child).unwrap();
        let config = files(&[
            (
                child.join("mise.toml").to_str().unwrap(),
                "[daemons.api]\nrun = 'exec api'\ndepends = ['pipeline']\n",
            ),
            (
                parent.join("mise.toml").to_str().unwrap(),
                &format!(
                    "[daemons.pipeline]\nproject = {}\nname = 'worker'\n",
                    toml::Value::String(mirror.to_string_lossy().into_owned())
                ),
            ),
        ]);
        let set = load(&config).unwrap();
        assert_eq!(
            set.daemons["api"].table["depends"][0].as_str(),
            Some("remote/worker")
        );
        // The child reaches the inherited import by name on the command line too.
        assert!(set.imported_in(&child, "pipeline"));
    }

    #[test]
    fn an_import_belongs_to_the_project_that_declared_it() {
        let _serial = import_lock();
        // A parent imports `ops`; the child uses that word for a group of its
        // own. The parent's import must not answer for the child's name, and
        // the child's group must not be rejected as an imported member.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(&mirror, "[daemons.worker]\nrun = 'exec worker'\n");
        let parent = tmp.path().join("parent");
        let child = parent.join("child");
        std::fs::create_dir_all(&child).unwrap();
        let config = files(&[
            (
                child.join("mise.toml").to_str().unwrap(),
                "[daemons.api]\nrun = 'exec api'\n[daemon_groups]\nops = ['api']\n",
            ),
            (
                parent.join("mise.toml").to_str().unwrap(),
                &format!(
                    "[daemons.ops]\nproject = {}\nname = 'worker'\n",
                    toml::Value::String(mirror.to_string_lossy().into_owned())
                ),
            ),
        ]);
        // The child's group loads: the parent's import is not its member.
        let set = load(&config).unwrap();
        assert_eq!(set.expand("ops"), Some(["api".to_string()].as_slice()));
        // Each project is asked about its own name.
        assert!(set.imported_in(&parent, "ops"));
        assert!(!set.imported_in(&child, "ops"));
        // A bare name selects the daemon that key refers to, not every daemon
        // carrying it, so the child's `api` does not drag in a namesake.
        let starting = set.with_dependencies(&["api".to_string()]);
        assert_eq!(starting.daemons.len(), 1);
        assert_eq!(starting.daemons["api"].root, child);
    }

    #[test]
    fn a_group_cannot_name_a_daemon_reached_with_project() {
        let _serial = import_lock();
        // A group renders into this project's pitchfork configuration, where an
        // imported daemon has no definition, so accepting the member would
        // produce a group mise expands and the registered one does not.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(&mirror, "[daemons.worker]\nrun = 'exec worker'\n");
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.pipeline]\nproject = '../mirror'\nname = 'worker'\n[daemons.api]\nrun = 'exec api'\n[daemon_groups]\nweb = ['api', 'pipeline']\n",
        )]);
        let err = load(&config).unwrap_err().to_string();
        assert!(err.contains("[daemon_groups.web]"), "{err}");
        assert!(err.contains("pipeline"), "{err}");
        assert!(err.contains("depends"), "{err}");
        // A group naming only this project's own daemons still loads.
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.pipeline]\nproject = '../mirror'\nname = 'worker'\n[daemons.api]\nrun = 'exec api'\n[daemon_groups]\nweb = ['api']\n",
        )]);
        let set = load(&config).unwrap();
        assert_eq!(set.expand("web"), Some(["api".to_string()].as_slice()));
    }

    #[test]
    fn a_daemon_is_identified_by_its_project_not_just_its_name() {
        let _serial = import_lock();
        // Two projects can each declare `api`. Matching on the name alone made a
        // check about one of them fire for the other.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'remote'\n[daemons.api]\nrun = 'exec remote api'\n",
        );
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.remote_api]\nproject = '../mirror'\nname = 'api'\n[daemons.api]\nrun = 'exec local api'\n",
        )]);
        let set = load(&config).unwrap();
        let local = &set.daemons["api"];
        let imported = &set.daemons["remote/api"];
        assert_eq!(local.name, imported.name);
        assert_ne!(local.root, imported.root);
        // A set holding only one of them contains that one and not the other.
        let only_imported = set.with_dependencies(&["remote/api".into()]);
        assert!(only_imported.contains(imported));
        assert!(!only_imported.contains(local));
        // `find` cannot tell them apart, which is why `contains` exists.
        assert!(only_imported.find("api").is_some());
    }

    #[test]
    fn an_untrusted_referenced_project_is_not_imported() {
        let _serial = import_lock();
        // This exercises the real trust gate. `mise x`, `mise run` and
        // `mise daemons start` mark the active config implicitly trusted, and
        // reading a sibling through that branch would grant it durable trust
        // with no prompt.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        untrusted_project(&mirror, "[daemons.worker]\nrun = 'exec worker'\n");
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.worker]\nproject = '../mirror'\n[daemons.api]\nrun = 'exec api'\ndepends = ['worker']\n",
        )]);
        let config_path = mirror.join(&*crate::env::MISE_DEFAULT_CONFIG_FILENAME);
        // `is_trusted` trusts everything under `cfg!(test)`, except in paranoid
        // mode, where trust is bound to file contents and checked first. That is
        // the only way to exercise this gate without the bypass.
        let _paranoid = Paranoid::on();
        let set = load(&config).unwrap();
        assert!(set.find("worker").is_none());
        let err = &failure(&set, "worker");
        assert!(err.contains("not trusted"), "{err}");
        assert!(err.contains("mise trust"), "{err}");
        // Trying did not trust it as a side effect, which is the whole point:
        // the commands that reach here mark the active config implicitly
        // trusted, and that branch would have granted it durably.
        assert!(!crate::config::config_file::is_path_trusted(&config_path));
        // A dependency on an import that never resolved would name a daemon
        // pitchfork cannot find, so it is dropped rather than registered, and
        // the daemon that needed it is recorded so starting it can refuse.
        assert!(!set.daemons["api"].table.contains_key("depends"));
        assert_eq!(
            set.blocked.get("api").map(|(name, _)| name.as_str()),
            Some("worker")
        );

        // Trusting it makes the same configuration import.
        crate::config::config_file::trust(&config_path).unwrap();
        let set = load(&config).unwrap();
        assert_eq!(set.find("worker").map(|d| d.imported), Some(true));
    }

    /// Turns on `paranoid` for one test and restores the settings on drop, even
    /// if the test panics.
    struct Paranoid;

    impl Paranoid {
        fn on() -> Self {
            use confique::Layer;
            let mut settings = crate::config::settings::SettingsPartial::empty();
            settings.paranoid = Some(true);
            crate::config::Settings::reset(Some(settings));
            Self
        }
    }

    impl Drop for Paranoid {
        fn drop(&mut self) {
            crate::config::Settings::reset(None);
        }
    }

    #[test]
    fn referenced_projects_with_tool_versions_files_still_import() {
        let _serial = import_lock();
        // `.tool-versions` sits in the same config list but is not TOML; parsing
        // it would fail before the project's mise config is ever read.
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(&mirror, "[daemons.worker]\nrun = 'exec worker'\n");
        std::fs::write(
            mirror.join(&*crate::env::MISE_DEFAULT_TOOL_VERSIONS_FILENAME),
            "node 20.0.0\n",
        )
        .unwrap();
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.worker]\nproject = '../mirror'\n",
        )]);
        let set = load(&config).unwrap();
        assert_eq!(set.find("worker").map(|d| d.imported), Some(true));
    }

    #[test]
    fn daemon_settings_merge_across_files_instead_of_replacing() {
        // A file that sets one key must not discard a namespace another file
        // established; other projects refer to the IDs it produces.
        let tmp = tempfile::tempdir().unwrap();
        let root = tmp.path();
        let config = files(&[
            (
                root.join("mise.local.toml").to_str().unwrap(),
                "[daemons_settings]\nnamespace_per_worktree = false\n",
            ),
            (
                root.join("mise.toml").to_str().unwrap(),
                "[daemons_settings]\nnamespace = 'entiredb'\n[daemons.api]\nrun = 'exec api'\n",
            ),
        ]);
        let set = load(&config).unwrap();
        let declared = set.daemons["api"].root.clone();
        assert_eq!(set.namespace_for(&declared), Some("entiredb"));
        // The higher-precedence file still wins for the key it does set.
        let mut merged = DaemonSettings {
            namespace: Some("entiredb".into()),
            namespace_per_worktree: Some(true),
        };
        merged.merge(DaemonSettings {
            namespace: None,
            namespace_per_worktree: Some(false),
        });
        assert_eq!(merged.namespace.as_deref(), Some("entiredb"));
        assert!(!merged.namespace_per_worktree());
        assert!(DaemonSettings::default().namespace_per_worktree());
    }

    #[test]
    fn referenced_projects_cannot_be_chained_or_mixed_with_a_definition() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let far = tmp.path().join("far");
        referenced_project(&far, "[daemons.worker]\nrun = 'exec worker'\n");
        let middle = tmp.path().join("middle");
        referenced_project(
            &middle,
            &format!(
                "[daemons.worker]\nproject = {}\n",
                toml::Value::String(far.to_string_lossy().into_owned())
            ),
        );
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.worker]\nproject = '../middle'\n",
        )]);
        assert!(
            failure(&load(&config).unwrap(), "worker")
                .contains("reference the project that declares it")
        );
        let config = files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons.worker]\nproject = '../far'\nrun = 'exec local'\n",
        )]);
        assert!(
            load(&config)
                .unwrap_err()
                .to_string()
                .contains("define the daemon in the referenced project")
        );
    }

    #[test]
    fn explicit_namespaces_are_validated() {
        for namespace in ["entiredb", "entire.db", "entire_db", "db-1"] {
            assert!(validate_namespace(namespace).is_ok(), "{namespace}");
        }
        for namespace in ["", ".", "..", "a--b", "-a", "a-", "a/b", "a b"] {
            assert!(validate_namespace(namespace).is_err(), "{namespace}");
        }
        let tmp = tempfile::tempdir().unwrap();
        let config = files(&[(
            tmp.path().join("mise.toml").to_str().unwrap(),
            "[daemons_settings]\nnamespace = 'entire--db'\n[daemons.api]\nrun = 'exec api'\n",
        )]);
        assert!(
            load(&config)
                .unwrap_err()
                .to_string()
                .contains("invalid daemon namespace")
        );
    }

    #[test]
    fn explicit_namespace_replaces_the_hashed_default() {
        let tmp = tempfile::tempdir().unwrap();
        let config = files(&[(
            tmp.path().join("mise.toml").to_str().unwrap(),
            "[daemons_settings]\nnamespace = 'entiredb'\n[daemons.api]\nrun = 'exec api'\n",
        )]);
        let set = load(&config).unwrap();
        let root = set.daemons["api"].root.clone();
        assert_eq!(set.namespace_for(&root), Some("entiredb"));
    }

    #[test]
    fn auto_ports_separate_worktrees_but_leave_the_primary_checkout_alone() {
        let tmp = tempfile::tempdir().unwrap();
        let primary = tmp.path().join("project");
        std::fs::create_dir_all(primary.join(".git")).unwrap();
        let linked = tmp.path().join("worktree");
        std::fs::create_dir_all(&linked).unwrap();
        // A linked worktree's marker points into the main checkout's worktrees
        // directory, which carries a commondir pointer; that is what
        // distinguishes it from a submodule.
        let private = primary.join(".git").join("worktrees").join("worktree");
        std::fs::create_dir_all(&private).unwrap();
        std::fs::write(primary.join(".git").join("HEAD"), "ref: refs/heads/main\n").unwrap();
        std::fs::write(private.join("commondir"), "../..\n").unwrap();
        std::fs::write(
            linked.join(".git"),
            format!("gitdir: {}\n", private.display()),
        )
        .unwrap();

        let body = "[daemons.db]\npreset = 'postgres'\nversion = '18'\nport = 'auto'\n[daemons.api]\nrun = 'server'\n[daemons.api.port]\nauto = true\nbase = 3000\n";
        let ports = |root: &Path| {
            let set = load(&files(&[(root.join("mise.toml").to_str().unwrap(), body)])).unwrap();
            (
                set.daemons["db"].port.unwrap().port,
                set.daemons["api"].port.unwrap().port,
            )
        };

        // The single well-known checkout keeps the well-known ports.
        assert_eq!(ports(&primary), (5432, 3000));
        let (db, api) = ports(&linked);
        assert!(db > 5432 && db <= 5432 + ports::SLOTS);
        assert!(api > 3000 && api <= 3000 + ports::SLOTS);
        // Same root, same ports; and the port reaches the exports and the command.
        assert_eq!(ports(&linked), (db, api));
        let set = load(&files(&[(
            linked.join("mise.toml").to_str().unwrap(),
            body,
        )]))
        .unwrap();
        assert_eq!(set.daemons["db"].exports["PGPORT"], db.to_string());
        assert!(set.daemons["db"].exports["DATABASE_URL"].contains(&format!(":{db}/")));
        assert!(
            set.daemons["db"].table["run"]
                .as_str()
                .unwrap()
                .contains(&format!("-p {db}"))
        );
        assert_eq!(
            set.daemons["api"].table["port"]["expect"][0].as_integer(),
            Some(i64::from(api))
        );
    }

    #[test]
    fn custom_daemons_export_their_resolved_port() {
        let tmp = tempfile::tempdir().unwrap();
        let root = tmp.path().join("project");
        std::fs::create_dir_all(root.join(".git")).unwrap();
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.api]\nrun = 'server'\nport = 3000\n[daemons.web-ui]\nrun = 'ui'\n[daemons.web-ui.port]\nauto = true\nbase = 4000\n",
        )]))
        .unwrap();
        // Without an export the port would reach pitchfork only.
        assert_eq!(set.daemons["api"].exports["API_PORT"], "3000");
        // Punctuation is not valid in a variable name.
        assert_eq!(set.daemons["web-ui"].exports["WEB_UI_PORT"], "4000");
        // Two names that normalize onto one variable are ambiguous, so
        // neither is exported and both daemons keep working. Failing the load
        // would take `mise env` down for the whole project over a convenience.
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.web-ui]\nrun = 'a'\nport = 3000\n[daemons.web_ui]\nrun = 'b'\nport = 3001\n",
        )]))
        .unwrap();
        assert!(set.daemons["web-ui"].exports.is_empty());
        assert!(set.daemons["web_ui"].exports.is_empty());
        // Both still have their ports; only the variable is withheld.
        assert_eq!(set.daemons["web-ui"].port.unwrap().port, 3000);
        assert_eq!(set.daemons["web_ui"].port.unwrap().port, 3001);

        // A leading punctuation character becomes an underscore, which a shell
        // accepts, so such a name still gets its variables.
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.\".api\"]\nrun = 'a'\nport = 3000\n",
        )]))
        .unwrap();
        assert_eq!(set.daemons[".api"].exports["_API_PORT"], "3000");

        // A shell cannot export a name starting with a digit, but that name was
        // legal before this export existed, so it keeps working without one.
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.9api]\nrun = 'a'\nport = 3000\n",
        )]))
        .unwrap();
        assert!(set.daemons["9api"].exports.is_empty());
        assert_eq!(set.daemons["9api"].port.unwrap().port, 3000);
        assert_eq!(
            set.daemons["9api"].table["port"]["expect"][0].as_integer(),
            Some(3000)
        );

        // Pitchfork routes only a daemon that configures a port, so one
        // without a port gets neither variable.
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.api]\nrun = 'server'\n",
        )]))
        .unwrap();
        assert!(set.daemons["api"].exports.is_empty());
        assert!(set.daemons["api"].host.is_none());
        // Opting out of the proxy leaves only the port.
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy = false\n",
        )]))
        .unwrap();
        assert_eq!(
            set.daemons["api"].exports.keys().collect::<Vec<_>>(),
            vec!["API_PORT"]
        );
        // The exports reach the environment mise renders.
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            "[daemons.api]\nrun = 'server'\nport = 3000\n",
        )]))
        .unwrap();
        assert!(set.env_entries().iter().any(
            |(d, _)| matches!(d, EnvDirective::Val(k, v, _) if k == "API_PORT" && v == "3000")
        ));
    }

    #[test]
    fn a_persisted_allocation_wins_over_a_fresh_derivation() {
        let tmp = tempfile::tempdir().unwrap();
        let root = tmp.path().join("wt");
        std::fs::create_dir_all(&root).unwrap();
        let private = tmp.path().join(".git").join("worktrees").join("wt");
        std::fs::create_dir_all(&private).unwrap();
        std::fs::write(
            tmp.path().join(".git").join("HEAD"),
            "ref: refs/heads/main\n",
        )
        .unwrap();
        std::fs::write(private.join("commondir"), "../..\n").unwrap();
        std::fs::write(
            root.join(".git"),
            format!("gitdir: {}\n", private.display()),
        )
        .unwrap();

        let body = "[daemons.api]\nrun = 'server'\n[daemons.api.port]\nauto = true\nbase = 3000\n";
        let cfg = || files(&[(root.join("mise.toml").to_str().unwrap(), body)]);
        let derived = load(&cfg()).unwrap().daemons["api"].port.unwrap();
        assert_ne!(derived.port, 3000, "a worktree is offset");

        // A recorded claim for the same base and stride is what the next load
        // uses, so a started daemon cannot move when derivation changes.
        let state = runtime::State {
            root: root.clone(),
            ports: std::collections::BTreeMap::from([(
                "api".to_string(),
                PortClaim {
                    port: 3456,
                    base: 3000,
                    stride: 1,
                },
            )]),
            ..Default::default()
        };
        let dir = state_dir(&root);
        std::fs::create_dir_all(&dir).unwrap();
        std::fs::write(
            dir.join("state.json"),
            serde_json::to_vec_pretty(&state).unwrap(),
        )
        .unwrap();
        let set = load(&cfg()).unwrap();
        assert_eq!(set.daemons["api"].port.unwrap().port, 3456);
        assert_eq!(set.daemons["api"].exports["API_PORT"], "3456");
        assert_eq!(
            set.daemons["api"].table["port"]["expect"][0].as_integer(),
            Some(3456)
        );
    }

    #[test]
    fn invalid_auto_port_declarations_are_rejected() {
        // A custom daemon has no default port to offset.
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\nrun = 'server'\nport = 'auto'\n",
        )]);
        assert!(
            load(&config)
                .unwrap_err()
                .to_string()
                .contains("needs a base port")
        );
        // Presets do not take pitchfork's structured port.
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\n[daemons.db.port]\nexpect = [5432]\n",
        )]);
        assert!(load(&config).is_err());
        // Custom daemons still forward it verbatim.
        let config = files(&[(
            "/project/mise.toml",
            "[daemons.api]\nrun = 'server'\n[daemons.api.port]\nexpect = [3000, 3001]\nbump = true\n",
        )]);
        let set = load(&config).unwrap();
        assert_eq!(
            set.daemons["api"].table["port"]["bump"].as_bool(),
            Some(true)
        );
        assert!(set.daemons["api"].port.is_none());
    }

    #[test]
    fn groups_expand_members_and_nested_groups() {
        let set = load(&files(&[(
            "/project/mise.toml",
            r#"
[daemons.postgres]
run = 'postgres'
[daemons.nats]
run = 'nats'
[daemons.core]
run = 'core'
[daemons.core2]
run = 'core2'
[daemons.node0]
run = 'node0'
[daemon_groups]
default = ["postgres", "nats", "core", "node0"]
two-cluster = ["default", "core2"]
[daemon_groups.explicit]
daemons = ["core", "core2"]
"#,
        )]))
        .unwrap();
        assert_eq!(
            set.group("default").unwrap().daemons,
            ["postgres", "nats", "core", "node0"]
        );
        // A nested group expands in place and members are deduplicated.
        assert_eq!(
            set.group("two-cluster").unwrap().daemons,
            ["postgres", "nats", "core", "node0", "core2"]
        );
        assert_eq!(set.group("explicit").unwrap().daemons, ["core", "core2"]);
        assert_eq!(set.expand("default").unwrap().len(), 4);
        assert!(set.expand("postgres").is_none());
        // Roots are absolutized, so derive them instead of hardcoding a path.
        let root = set.daemons["postgres"].root.clone();
        assert_eq!(set.for_root(&root).groups.len(), 3);
        assert!(set.for_root(root.parent().unwrap()).groups.is_empty());
    }

    #[test]
    fn groups_nest_more_than_one_level() {
        let set = load(&files(&[(
            "/project/mise.toml",
            r#"
[daemons.a]
run = 'a'
[daemons.b]
run = 'b'
[daemons.c]
run = 'c'
[daemon_groups]
one = ["a"]
two = ["one", "b"]
three = ["two", "c"]
"#,
        )]))
        .unwrap();
        assert_eq!(set.group("three").unwrap().daemons, ["a", "b", "c"]);
        // A cycle is still caught through three levels.
        let err = load(&files(&[(
            "/project/mise.toml",
            "[daemons.a]\nrun = 'a'\n[daemon_groups]\none = ['two']\ntwo = ['three']\nthree = ['one']\n",
        )]))
        .unwrap_err()
        .to_string();
        assert!(err.contains("references itself"), "{err}");
    }

    #[test]
    fn the_table_form_rejects_unknown_keys() {
        // Matches `additionalProperties: false` in the schema, and catches a typo
        // that would otherwise leave the group silently empty. Rejection happens
        // when the configuration is parsed, before daemons are loaded.
        let parse = |body: &str| MiseToml::from_str(body, &PathBuf::from("/project/mise.toml"));
        assert!(parse("[daemon_groups.web]\ndaemons = ['api']\n").is_ok());
        let err = parse("[daemon_groups.web]\ndaemons = ['api']\ndeamons = ['api']\n")
            .unwrap_err()
            .to_string();
        assert!(err.contains("TOML"), "{err}");
        // The list form is unaffected.
        assert!(parse("[daemon_groups]\nweb = ['api']\n").is_ok());
    }

    #[test]
    fn same_group_name_in_two_projects_is_kept() {
        let set = load(&files(&[
            (
                "/parent/child/mise.toml",
                "[daemons.web]\nrun = 'web'\n[daemon_groups]\ndefault = ['web']\n",
            ),
            (
                "/parent/mise.toml",
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\ndefault = ['api']\n",
            ),
        ]))
        .unwrap();
        assert_eq!(set.groups.len(), 2);
        let child = set.daemons["web"].root.clone();
        let parent = set.daemons["api"].root.clone();
        assert_ne!(child, parent);
        assert_eq!(
            set.for_root(&child).group("default").unwrap().daemons,
            ["web"]
        );
        assert_eq!(
            set.for_root(&parent).group("default").unwrap().daemons,
            ["api"]
        );
    }

    #[test]
    fn a_child_overriding_a_daemon_keeps_the_parent_group_loadable() {
        // The child replaces the parent's postgres, which is documented behavior.
        // The parent's group still names a daemon the parent declared, so the
        // configuration has to keep loading.
        let set = load(&files(&[
            (
                "/parent/child/mise.toml",
                "[daemons.postgres]\nrun = 'child postgres'\n",
            ),
            (
                "/parent/mise.toml",
                "[daemons.postgres]\nrun = 'parent postgres'\n[daemons.api]\nrun = 'api'\n[daemon_groups]\ndefault = ['postgres', 'api']\n",
            ),
        ]))
        .unwrap();
        let parent = set.daemons["api"].root.clone();
        assert_eq!(
            set.for_root(&parent).group("default").unwrap().daemons,
            ["postgres", "api"]
        );
        // In this merged view, which supplies environment exports and tool requests,
        // the nearer definition wins and the name belongs to the child.
        assert_eq!(
            set.daemons["postgres"].table["run"].as_str(),
            Some("child postgres")
        );
        assert!(!set.for_root(&parent).daemons.contains_key("postgres"));
        // What each project registers and runs comes from its own hierarchy instead,
        // so the parent still has its own postgres and its group still names it.
        // e2e/cli/test_daemons covers that both start.
    }

    #[test]
    fn nested_group_references_stay_inside_one_project() {
        // `shared` exists only in the parent, so the child cannot reference it.
        let err = load(&files(&[
            (
                "/parent/child/mise.toml",
                "[daemons.web]\nrun = 'web'\n[daemon_groups]\nall = ['web', 'shared']\n",
            ),
            (
                "/parent/mise.toml",
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nshared = ['api']\n",
            ),
        ]))
        .unwrap_err()
        .to_string();
        assert!(
            err.contains("is not a daemon or group declared for"),
            "{err}"
        );
    }

    #[test]
    fn groups_are_scoped_to_one_project_root() {
        // A daemon declared by an outer project is not a valid member of an inner group.
        let err = load(&files(&[
            (
                "/parent/child/mise.toml",
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nall = ['api', 'outer']\n",
            ),
            ("/parent/mise.toml", "[daemons.outer]\nrun = 'outer'\n"),
        ]))
        .unwrap_err()
        .to_string();
        assert!(
            err.contains("is not a daemon or group declared for"),
            "{err}"
        );
    }

    #[test]
    fn invalid_groups_are_rejected() {
        let cases = [
            (
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nweb = ['missing']\n",
                "is not a daemon or group",
            ),
            (
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nweb = []\n",
                "requires at least one daemon or group",
            ),
            (
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\napi = ['api']\n",
                "conflicts with the daemon of the same name",
            ),
            (
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nweb = ['other']\nother = ['web']\n",
                "references itself",
            ),
            (
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nweb = ['web']\n",
                "references itself",
            ),
            (
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\n'bad name' = ['api']\n",
                "invalid daemon group name",
            ),
        ];
        for (body, expected) in cases {
            let err = load(&files(&[("/project/mise.toml", body)]))
                .unwrap_err()
                .to_string();
            assert!(err.contains(expected), "{body:?} produced {err}");
        }
    }

    #[test]
    fn daemon_names_cannot_escape_persistent_data_directory() {
        for name in [".", "..", "../outside", "a/b", "a\\b"] {
            let config = files(&[(
                "/project/mise.toml",
                &format!(
                    "[daemons.{}]\npreset = 'postgres'\nversion = '18'",
                    toml::Value::String(name.into())
                ),
            )]);
            assert!(load(&config).is_err());
        }
    }

    /// Build a primary checkout and a linked worktree of it, as
    /// `git worktree add` leaves them.
    fn checkout_pair(tmp: &Path) -> (PathBuf, PathBuf) {
        let primary = tmp.join("shop");
        std::fs::create_dir_all(primary.join(".git")).unwrap();
        std::fs::write(primary.join(".git").join("HEAD"), "ref: refs/heads/main\n").unwrap();
        let linked = tmp.join("shop-pr-42");
        std::fs::create_dir_all(&linked).unwrap();
        let private = primary.join(".git").join("worktrees").join("pr-42");
        std::fs::create_dir_all(&private).unwrap();
        std::fs::write(private.join("commondir"), "../..\n").unwrap();
        std::fs::write(
            linked.join(".git"),
            format!("gitdir: {}\n", private.display()),
        )
        .unwrap();
        (primary, linked)
    }

    #[test]
    fn a_hostname_names_the_daemon_the_checkout_and_the_project() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, linked) = checkout_pair(tmp.path());
        let body =
            "[daemons_settings]\nnamespace = 'shop'\n[daemons.api]\nrun = 'server'\nport = 3000\n";
        let host = |root: &Path| {
            let set = load(&files(&[(root.join("mise.toml").to_str().unwrap(), body)])).unwrap();
            set.daemons["api"].host.clone()
        };
        // The primary checkout's daemons sit directly under the project. A
        // worktree component here would be a hostname pitchfork cannot route.
        assert_eq!(host(&primary).as_deref(), Some("api.shop.localhost"));
        // A linked worktree adds its own component, named after its directory.
        assert_eq!(
            host(&linked).as_deref(),
            Some("api.shop-pr-42.shop.localhost")
        );

        // Pitchfork reads `worktree_label` from the checkout's own pitchfork
        // configuration, so mise reads it from there too and the two agree.
        std::fs::write(linked.join("pitchfork.toml"), "worktree_label = 'pr-42'\n").unwrap();
        assert_eq!(host(&linked).as_deref(), Some("api.pr-42.shop.localhost"));

        // Without an explicit namespace the project is named after the primary
        // checkout's directory, which is the same from either checkout.
        let bare = "[daemons.api]\nrun = 'server'\nport = 3000\n";
        for root in [&primary, &linked] {
            let set = load(&files(&[(root.join("mise.toml").to_str().unwrap(), bare)])).unwrap();
            assert!(
                set.daemons["api"]
                    .host
                    .as_deref()
                    .unwrap()
                    .ends_with("shop.localhost"),
                "{:?}",
                set.daemons["api"].host
            );
        }
    }

    #[test]
    fn a_daemons_url_is_exported_beside_its_port() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, _) = checkout_pair(tmp.path());
        let set = load(&files(&[(
            primary.join("mise.toml").to_str().unwrap(),
            "[daemons_settings]\nnamespace = 'shop'\n\
             [daemons.api]\nrun = 'server'\nport = 3000\n\
             [daemons.web]\nrun = 'web'\nport = 5173\nproxy = 'front'\n\
             [daemons.cache]\nrun = 'cache'\nproxy = false\nport = 6380\n",
        )]))
        .unwrap();
        assert_eq!(set.daemons["api"].exports["API_PORT"], "3000");
        assert_eq!(
            set.daemons["api"].exports["API_URL"],
            "https://api.shop.localhost"
        );
        // A declared label replaces only the daemon's own component.
        assert_eq!(
            set.daemons["web"].exports["WEB_URL"],
            "https://front.shop.localhost"
        );
        // An opted-out daemon keeps its port and gets no URL at all.
        assert_eq!(set.daemons["cache"].exports["CACHE_PORT"], "6380");
        assert!(!set.daemons["cache"].exports.contains_key("CACHE_URL"));
        assert!(set.daemons["cache"].host.is_none());
        // The URLs reach the environment mise renders.
        assert!(set.env_entries().iter().any(|(d, _)| matches!(
            d,
            EnvDirective::Val(k, v, _) if k == "API_URL" && v == "https://api.shop.localhost"
        )));
    }

    #[test]
    fn proxy_declarations_are_validated_and_forwarded() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, _) = checkout_pair(tmp.path());
        let load_body = |body: &str| {
            load(&files(&[(
                primary.join("mise.toml").to_str().unwrap(),
                &format!("[daemons_settings]\nnamespace = 'shop'\n{body}"),
            )]))
        };
        let set = load_body(
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy = 'front'\nproxy_tls = 'passthrough'\n",
        )
        .unwrap();
        // Both keys reach pitchfork, with the label normalized to what mise
        // derived the URL from.
        let table = &set.daemons["api"].table;
        assert_eq!(table["proxy"].as_str(), Some("front"));
        assert_eq!(table["proxy_tls"].as_str(), Some("passthrough"));
        assert_eq!(
            load_body("[daemons.api]\nrun = 'server'\nport = 3000\nproxy = false\n")
                .unwrap()
                .daemons["api"]
                .table["proxy"]
                .as_bool(),
            Some(false)
        );
        // `proxy = true` turns routing back on for a daemon a preset opted out
        // of, which is how a Postgres preset is put behind an HTTP proxy.
        let set =
            load_body("[daemons.db]\npreset = 'postgres'\nversion = '18'\nproxy = true\n").unwrap();
        assert_eq!(set.daemons["db"].host.as_deref(), Some("db.shop.localhost"));
        for invalid in [
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy = 3000\n",
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy = 'Front'\n",
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy = 'front_end'\n",
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy_tls = 'reencrypt'\n",
            "[daemons.api]\nrun = 'server'\nport = 3000\nproxy = false\nproxy_tls = 'terminate'\n",
        ] {
            assert!(load_body(invalid).is_err(), "{invalid:?}");
        }
    }

    #[test]
    fn an_imported_daemon_does_not_claim_this_projects_variables() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'mirror'\n[daemons.worker]\nrun = 'exec worker'\nport = 4000\n",
        );
        let root = tmp.path().join("app");
        std::fs::create_dir_all(root.join(".git")).unwrap();
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons_settings]\nnamespace = 'app'\n\
                 [daemons.worker]\nrun = 'exec worker'\nport = 4000\n\
                 [daemons.remote]\nproject = '{}'\nname = 'worker'\n",
                mirror.display()
            ),
        )]))
        .unwrap();
        // The import shares the remote daemon's name. Its exports belong to that
        // project, so it must not make this project's `worker` look ambiguous.
        assert_eq!(
            set.daemons["worker"].exports["WORKER_URL"],
            "https://worker.app.localhost"
        );
        assert!(set.env_entries().iter().any(|(d, _)| matches!(
            d,
            EnvDirective::Val(k, _, _) if k == "WORKER_URL"
        )));
    }

    #[test]
    fn two_daemons_cannot_share_one_hostname() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, _) = checkout_pair(tmp.path());
        let load_body = |body: &str| {
            load(&files(&[(
                primary.join("mise.toml").to_str().unwrap(),
                &format!("[daemons_settings]\nnamespace = 'shop'\n{body}"),
            )]))
        };

        // Pitchfork routes neither side of a label collision rather than
        // choosing, so mise withholds both URLs instead of advertising an
        // endpoint the proxy refuses. Both daemons still run on their ports.
        for body in [
            // A declared label landing on another daemon's name.
            "[daemons.api]\nrun = 'a'\nport = 3000\n[daemons.web]\nrun = 'b'\nport = 3001\nproxy = 'api'\n",
            // The same, declared first.
            "[daemons.web]\nrun = 'b'\nport = 3001\nproxy = 'api'\n[daemons.api]\nrun = 'a'\nport = 3000\n",
            // Two names folding onto one label.
            "[daemons.web-ui]\nrun = 'a'\nport = 3000\n[daemons.web_ui]\nrun = 'b'\nport = 3001\n",
            // Two declarations naming one label.
            "[daemons.web]\nrun = 'b'\nport = 3001\nproxy = 'front'\n[daemons.api]\nrun = 'a'\nport = 3000\nproxy = 'front'\n",
        ] {
            let set = load_body(body).unwrap();
            for daemon in set.daemons.values() {
                assert!(daemon.host.is_none(), "{} in {body:?}", daemon.name);
                assert_eq!(daemon.table["proxy"].as_bool(), Some(false), "{body:?}");
                assert!(
                    !daemon.exports.keys().any(|key| key.ends_with("_URL")),
                    "{body:?}"
                );
            }
            // The ports are untouched; only the hostname is withheld.
            assert!(set.daemons.values().all(|d| d.port.is_some()), "{body:?}");
        }

        // A preset resolves its hostname on its own path, so it has to reach
        // the same check: `proxy = true` puts one back on the proxy, and its
        // name can land on another daemon's label like any other.
        let set = load_body(
            "[daemons.db]\npreset = 'postgres'\nversion = '18'\nproxy = true\n\
             [daemons.web]\nrun = 'b'\nport = 3001\nproxy = 'db'\n",
        )
        .unwrap();
        for name in ["db", "web"] {
            assert!(set.daemons[name].host.is_none(), "{name} kept a hostname");
            assert_eq!(set.daemons[name].table["proxy"].as_bool(), Some(false));
        }

        // Withdrawing a hostname takes only what names it. A proxied preset
        // publishes its own connection string, which stays valid however the
        // proxy routes, so it must survive the collision that costs the
        // hostname.
        let set = load_body(
            "[daemons.redis]\npreset = 'redis'\nversion = '8'\nproxy = true\n\
             [daemons.web]\nrun = 'b'\nport = 3001\nproxy = 'redis'\n",
        )
        .unwrap();
        assert!(set.daemons["redis"].host.is_none());
        assert!(
            set.daemons["redis"].exports["REDIS_URL"].starts_with("redis://"),
            "the preset's own connection string is not the withdrawn URL: {:?}",
            set.daemons["redis"].exports
        );

        // A project whose labels do not collide keeps both hostnames.
        let set = load_body(
            "[daemons.api]\nrun = 'a'\nport = 3000\n[daemons.web]\nrun = 'b'\nport = 3001\n",
        )
        .unwrap();
        assert_eq!(
            set.daemons["api"].host.as_deref(),
            Some("api.shop.localhost")
        );
        assert_eq!(
            set.daemons["web"].host.as_deref(),
            Some("web.shop.localhost")
        );
    }

    /// Two projects whose directories share a basename derive one project
    /// label, so a same-named daemon in each lands on one hostname. The names
    /// are identical, so only the roots tell the two claims apart.
    #[test]
    fn two_projects_sharing_a_directory_name_collide_on_hostname() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("one").join("api");
        std::fs::create_dir_all(mirror.join(".git")).unwrap();
        referenced_project(&mirror, "[daemons.web]\nrun = 'exec web'\nport = 3000\n");
        let root = tmp.path().join("two").join("api");
        std::fs::create_dir_all(root.join(".git")).unwrap();
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons.web]\nrun = 'exec web'\nport = 3001\n\
                 [daemons.remote]\nproject = '{}'\nname = 'web'\n",
                mirror.display()
            ),
        )]))
        .unwrap();
        // Both are called `web` under a project called `api`. The local one
        // must not advertise the hostname, and exports no URL for it.
        assert!(set.daemons["web"].host.is_none());
        assert_eq!(set.daemons["web"].table["proxy"].as_bool(), Some(false));
        assert!(
            !set.daemons
                .values()
                .any(|d| d.exports.contains_key("WEB_URL"))
        );
        // The imported one keeps it. Its own project registers it from its own
        // configuration, where nothing collides, and mise rewrites that file
        // whole from that project's hierarchy rather than from this view. So
        // the proxy really does serve it, and clearing it here would leave
        // this state contradicting both the warning and the proxy.
        let imported = set.daemons.values().find(|d| d.imported).unwrap();
        assert_eq!(imported.host.as_deref(), Some("web.api.localhost"));
        assert_eq!(imported.table["proxy"].as_str(), Some("web"));
        // Ports are untouched either way.
        assert_eq!(set.daemons["web"].exports["WEB_PORT"], "3001");
    }

    /// Mise pins the port it resolves and turns pitchfork's bumping off, so
    /// two daemons handed one number would leave the second failing to bind
    /// with nothing naming the first.
    #[test]
    fn two_daemons_cannot_claim_one_port() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, _) = checkout_pair(tmp.path());
        let load_body = |body: &str| {
            load(&files(&[(
                primary.join("mise.toml").to_str().unwrap(),
                body,
            )]))
        };
        for body in [
            // Two presets of one kind share a base, and `auto` derives the
            // offset from the project root, which both have in common.
            "[daemons.main]\npreset = 'postgres'\nversion = '18'\nport = 'auto'\n\
             [daemons.analytics]\npreset = 'postgres'\nversion = '18'\nport = 'auto'\n",
            // Two explicit ports can simply be equal.
            "[daemons.api]\nrun = 'a'\nport = 3000\n[daemons.web]\nrun = 'b'\nport = 3000\n",
            // As can two custom daemons given the same base.
            "[daemons.api]\nrun = 'a'\n[daemons.api.port]\nauto = true\nbase = 3000\n\
             [daemons.web]\nrun = 'b'\n[daemons.web.port]\nauto = true\nbase = 3000\n",
        ] {
            let err = load_body(body).unwrap_err().to_string();
            assert!(err.contains("both use port"), "{body:?} produced {err}");
        }
        // A root reached through a symlink is the same directory, so it takes
        // the same slot and the same port; comparing the paths as written
        // would call the two daemons distinct and let the clash through.
        #[cfg(unix)]
        {
            let link = tmp.path().join("linked");
            std::os::unix::fs::symlink(&primary, &link).unwrap();
            let err = load(&files(&[
                (
                    primary.join("mise.toml").to_str().unwrap(),
                    "[daemons.api]\nrun = 'a'\n[daemons.api.port]\nauto = true\nbase = 3000\n",
                ),
                (
                    link.join("mise.local.toml").to_str().unwrap(),
                    "[daemons.web]\nrun = 'b'\n[daemons.web.port]\nauto = true\nbase = 3000\n",
                ),
            ]))
            .unwrap_err()
            .to_string();
            assert!(err.contains("both use port 3000"), "{err}");
        }

        // Distinct bases are what makes a second instance work.
        let set = load_body(
            "[daemons.main]\npreset = 'postgres'\nversion = '18'\nport = 'auto'\n\
             [daemons.analytics]\npreset = 'postgres'\nversion = '18'\n\
             [daemons.analytics.port]\nauto = true\nbase = 5500\n",
        )
        .unwrap();
        assert_ne!(
            set.daemons["main"].port.unwrap().port,
            set.daemons["analytics"].port.unwrap().port
        );
    }

    /// A group covers the daemons its project declares. Naming one reached
    /// with `project` is refused rather than silently dropped, because mise
    /// would expand a group the registered configuration does not.
    /// A daemon declared nearer claims its own name. An ancestor's group of the
    /// same word must not take it, or the daemon could not be started by the
    /// short name at all: a group selector never falls back to a daemon.
    #[test]
    fn a_nearer_daemon_outranks_an_ancestors_group_of_the_same_name() {
        let set = load(&files(&[
            (
                "/parent/child/mise.toml",
                "[daemons.web]\nrun = 'child web'\n",
            ),
            (
                "/parent/mise.toml",
                "[daemons.api]\nrun = 'api'\n[daemon_groups]\nweb = ['api']\n",
            ),
        ]))
        .unwrap();
        // Derived, not spelled out: a root's own path is what the walk compares,
        // and it is not the string the config was written under.
        let child = set.daemons["web"].root.clone();
        let parent = set.daemons["api"].root.clone();
        assert!(
            child != parent && child.starts_with(&parent),
            "the two projects must be nested and distinct for this to mean anything: {child:?} under {parent:?}"
        );
        // From the child, `web` is its daemon, not the parent's group. The word
        // has to come back claimed, not merely unresolved, or a group of the
        // same name in any loaded project answers for it instead.
        assert!(matches!(
            set.resolve_bare(&child, "web"),
            Some(BareName::Daemon)
        ));
        // From the parent, the same word is still that project's group.
        assert!(matches!(
            set.resolve_bare(&parent, "web"),
            Some(BareName::Group)
        ));
    }

    #[test]
    fn a_group_cannot_name_an_imported_daemon() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        let mirror = tmp.path().join("mirror");
        referenced_project(
            &mirror,
            "[daemons_settings]\nnamespace = 'mirror'\n[daemons.worker]\nrun = 'exec worker'\n",
        );
        let root = tmp.path().join("app");
        std::fs::create_dir_all(root.join(".git")).unwrap();
        let err = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons_settings]\nnamespace = 'app'\n\
                 [daemons.api]\nrun = 'exec api'\n\
                 [daemons.remote]\nproject = '{}'\nname = 'worker'\n\
                 [daemon_groups]\nstack = ['api', 'remote']\n",
                mirror.display()
            ),
        )]))
        .unwrap_err()
        .to_string();
        assert!(err.contains("reaches with `project`"), "{err}");
    }

    #[test]
    fn a_presets_export_is_not_replaced_by_a_derived_one() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, _) = checkout_pair(tmp.path());
        let set = load(&files(&[(
            primary.join("mise.toml").to_str().unwrap(),
            "[daemons_settings]\nnamespace = 'shop'\n\
             [daemons.db]\npreset = 'postgres'\nversion = '18'\n\
             [daemons.database]\nrun = 'gateway'\nport = 8080\n",
        )]))
        .unwrap();
        // The preset publishes DATABASE_URL; the daemon called `database` would
        // derive the same name for its hostname. The preset keeps it.
        assert!(
            set.daemons["db"].exports["DATABASE_URL"].starts_with("postgresql://"),
            "{:?}",
            set.daemons["db"].exports
        );
        assert!(!set.daemons["database"].exports.contains_key("DATABASE_URL"));
        // The daemon still runs and keeps its hostname; only the variable goes.
        assert_eq!(
            set.daemons["database"].host.as_deref(),
            Some("database.shop.localhost")
        );
    }

    /// A hostname collision has a winner only when exactly one side is
    /// imported: that project registers it from its own configuration, which
    /// this project neither sees nor rewrites on its behalf. Saying "pitchfork
    /// routes neither" there would describe a hostname that is in fact served.
    /// Two imported claimants leave pitchfork a contest it will not settle, so
    /// neither is served. Mise cannot stop either project from registering its
    /// own, but the project that can see both must not offer a URL for them.
    #[test]
    fn two_imported_claimants_leave_no_url_to_advertise() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        for (dir, port) in [("one", 3000), ("two", 3001)] {
            let project = tmp.path().join(dir).join("api");
            std::fs::create_dir_all(project.join(".git")).unwrap();
            referenced_project(
                &project,
                &format!("[daemons.web]\nrun = 'exec web'\nport = {port}\n"),
            );
        }
        let root = tmp.path().join("app");
        std::fs::create_dir_all(root.join(".git")).unwrap();
        let set = load(&files(&[(
            root.join("mise.toml").to_str().unwrap(),
            &format!(
                "[daemons.first]\nproject = '{}'\nname = 'web'\n\
                 [daemons.second]\nproject = '{}'\nname = 'web'\n",
                tmp.path().join("one").join("api").display(),
                tmp.path().join("two").join("api").display(),
            ),
        )]))
        .unwrap();
        let imported: Vec<_> = set.daemons.values().filter(|d| d.imported).collect();
        assert_eq!(imported.len(), 2, "both imports must have resolved");
        for daemon in imported {
            assert!(daemon.host.is_none(), "{} kept a hostname", daemon.name);
        }

        // Each declaring project still registers its own, because its own
        // hierarchy is what writes that file and nothing collides there. The
        // importing project's view is what decides whether a URL is shown, so
        // it withdraws the hostname the narrower view still carries.
        let mut declared = set.clone();
        for daemon in declared.daemons.values_mut() {
            daemon.host = Some("web.api.localhost".into());
            daemon
                .exports
                .insert("WEB_URL".into(), "https://web.api.localhost".into());
        }
        let visible = declared.restricted_to(&set);
        assert_eq!(visible.daemons.len(), set.daemons.len());
        for daemon in visible.daemons.values() {
            assert!(daemon.host.is_none(), "{} still shows a URL", daemon.name);
            assert!(!daemon.exports.contains_key("WEB_URL"));
        }
    }

    #[test]
    fn only_a_lone_imported_side_keeps_a_collided_hostname() {
        assert_eq!(routed_claimant(&[false, false]), None);
        assert_eq!(routed_claimant(&[true, true]), None);
        assert_eq!(routed_claimant(&[true, false]), Some(0));
        // The same pair in the order the other daemon was declared first.
        assert_eq!(routed_claimant(&[false, true]), Some(1));
        // More than two claimants are settled together, not pairwise: the lone
        // imported one is served however many local ones stand against it, and
        // a second imported one leaves the proxy a contest again.
        assert_eq!(routed_claimant(&[false, false, true]), Some(2));
        assert_eq!(routed_claimant(&[true, false, true]), None);
    }

    #[test]
    fn an_imported_presets_exports_do_not_take_a_local_ones() {
        let _serial = import_lock();
        let tmp = tempfile::tempdir().unwrap();
        referenced_project(
            &tmp.path().join("owner"),
            "[daemons_settings]\nnamespace = 'remote'\n\
             [daemons.db]\npreset = 'postgres'\nversion = '18'\n",
        );
        let app = tmp.path().join("app");
        std::fs::create_dir_all(&app).unwrap();
        let set = load(&files(&[(
            app.join("mise.toml").to_str().unwrap(),
            "[daemons_settings]\nnamespace = 'shop'\n\
             [daemons.store]\nproject = '../owner'\nname = 'db'\n\
             [daemons.database]\nrun = 'gateway'\nport = 8080\n",
        )]))
        .unwrap();
        assert!(set.daemons["remote/db"].imported);
        // The imported preset does publish DATABASE_URL, but into its own
        // project's environment: `env_entries` leaves every imported daemon
        // out. There is nothing here for the local daemon to replace, so it
        // keeps the variable it derives.
        let exported: Vec<_> = set
            .env_entries()
            .into_iter()
            .filter_map(|(directive, _)| match directive {
                EnvDirective::Val(key, value, _) if key == "DATABASE_URL" => Some(value),
                _ => None,
            })
            .collect();
        assert_eq!(exported, ["https://database.shop.localhost"]);
    }

    #[test]
    fn database_presets_stay_off_the_proxy() {
        let tmp = tempfile::tempdir().unwrap();
        let (primary, _) = checkout_pair(tmp.path());
        let set = load(&files(&[(
            primary.join("mise.toml").to_str().unwrap(),
            "[daemons_settings]\nnamespace = 'shop'\n[daemons]\npostgres = '18'\nredis = '8'\n",
        )]))
        .unwrap();
        for name in ["postgres", "redis"] {
            let daemon = &set.daemons[name];
            assert!(daemon.host.is_none(), "{name} is not an HTTP service");
            assert_eq!(daemon.table["proxy"].as_bool(), Some(false));
            assert!(
                !daemon
                    .exports
                    .values()
                    .any(|value| value.starts_with("http")),
                "{name} must not be handed a proxy URL"
            );
        }
        // A preset's own exports still reach the environment, including the one
        // whose name mise would otherwise have generated.
        assert!(set.daemons["postgres"].exports.contains_key("DATABASE_URL"));
        assert!(set.daemons["redis"].exports["REDIS_URL"].starts_with("redis://"));
    }
}