loopflow 0.12.30

//! W2-151: every `lf` command must resolve the ambient Wave the same way. The
//! bug was never that a resident exports `LF_WAVE_ID=<uuid>` — that is correct.
//! It was that consumers disagreed about how to read it: `status` handled a
//! UUID, `pm show` ignored the env entirely, others silently dropped a hand-set
//! name. This drives the ONE resolver directly across the seven environments,
//! then proves the shared Wave status projection honors the original reproduction
//! end to end from a resident wave's environment.

use std::path::Path;
use std::process::Command;

use loopflow::id::WaveId;
use loopflow::store::sqlite::SqliteStore;
use loopflow::store::{PmSnapshotRow, StorageConfig};
use loopflow::work::wave::context::{resolve_managed_wave, WaveResolveError};
use loopflow::work::wave::Wave;

/// The command matrix at the resolver itself: one durable Wave, driven from
/// every ambient environment. Each cell resolves the SAME wave name or returns
/// the SAME classified error — the whole contract in one place.
#[tokio::test]
async fn resolver_matrix_agrees_across_every_environment() {
    let tmp = tempfile::tempdir().expect("tempdir");
    let store = loopflow::store::open_ephemeral_store(&StorageConfig::sqlite(
        tmp.path().join("loopflow.db"),
    ))
    .await
    .expect("open store");
    let repo = tmp.path().join("repo");
    std::fs::create_dir_all(&repo).expect("repo");
    let wave = Wave::new(
        WaveId::new(),
        "product".to_string(),
        std::fs::canonicalize(&repo)
            .expect("canonical repo")
            .display()
            .to_string(),
    );
    store.create_wave(&wave).await.expect("register wave");
    let uuid = wave.id().as_str();

    // Wave / Project / Task processes all inherit the same durable UUID — the
    // Project/Task Work ids never touch Wave identity, so one cell covers
    // all three. UUID first: mapped to its registry name.
    assert_eq!(
        resolve_managed_wave(Some(&store), Some(&repo), None, Some(uuid))
            .await
            .expect("uuid resolves")
            .id(),
        wave.id()
    );

    // Hand-set name: the intentional fallback. `LF_WAVE_ID=product` resolves
    // even though it is not a UUID.
    assert_eq!(
        resolve_managed_wave(Some(&store), Some(&repo), None, Some("product"))
            .await
            .expect("hand-set name resolves")
            .id(),
        wave.id()
    );

    // Explicit `--wave` always wins, even over a (wrong) ambient id.
    assert_eq!(
        resolve_managed_wave(
            Some(&store),
            Some(&repo),
            Some("product"),
            Some("something-else"),
        )
        .await
        .expect("explicit wins")
        .id(),
        wave.id()
    );

    // Stale identity: a real UUID the registry has never seen. Not silently
    // re-read as a name — a distinct, classified error.
    let stale = WaveId::new();
    assert!(matches!(
        resolve_managed_wave(Some(&store), Some(&repo), None, Some(stale.as_str())).await,
        Err(WaveResolveError::StaleIdentity(value)) if value == stale.as_str()
    ));

    // No context: neither `--wave` nor `LF_WAVE_ID` (empty counts as absent).
    assert!(matches!(
        resolve_managed_wave(Some(&store), Some(&repo), None, None).await,
        Err(WaveResolveError::NoContext)
    ));
    assert!(matches!(
        resolve_managed_wave(Some(&store), Some(&repo), None, Some("   ")).await,
        Err(WaveResolveError::NoContext)
    ));

    // An empty `--wave` is an explicit-but-unusable request, not "no context".
    assert!(matches!(
        resolve_managed_wave(Some(&store), Some(&repo), Some("  "), None).await,
        Err(WaveResolveError::EmptyExplicit)
    ));

    // An explicit `--wave` naming a wave the registry has never seen is a
    // classified error — never a silent accept. The resolver owns this rule;
    // every consumer surfaces the same classification.
    assert!(matches!(
        resolve_managed_wave(
            Some(&store),
            Some(&repo),
            Some("definitely-unknown"),
            None,
        )
        .await,
        Err(WaveResolveError::UnknownExplicit(value)) if value == "definitely-unknown"
    ));

    // No registry on this machine + an explicit name → error, not silent
    // accept. A machine with no registry has no valid wave names.
    assert!(matches!(
        resolve_managed_wave(None, Some(&repo), Some("product"), None).await,
        Err(WaveResolveError::Registry(_))
    ));

    assert!(matches!(
        resolve_managed_wave(Some(&store), Some(&repo), None, Some("ghost")).await,
        Err(WaveResolveError::StaleIdentity(value)) if value == "ghost"
    ));

    let other_repo = tmp.path().join("other-repo");
    std::fs::create_dir_all(&other_repo).expect("other repo");
    let other = Wave::new(
        WaveId::new(),
        "product".to_string(),
        std::fs::canonicalize(&other_repo)
            .expect("canonical other repo")
            .display()
            .to_string(),
    );
    store
        .create_wave(&other)
        .await
        .expect("register other Wave");
    assert!(matches!(
        resolve_managed_wave(Some(&store), None, Some("product"), None).await,
        Err(WaveResolveError::AmbiguousWave { .. })
    ));
    assert!(matches!(
        resolve_managed_wave(Some(&store), Some(&repo), None, Some(other.id().as_str())).await,
        Err(WaveResolveError::RepositoryMismatch { .. })
    ));
}

/// Seed a machine home with one PM-linked wave and a fresh cache-only snapshot,
/// plus a separate repo directory the commands run inside.
fn seed(home: &Path, repo: &Path, wave_name: &str) -> Wave {
    std::fs::create_dir_all(home).expect("home");
    std::fs::create_dir_all(repo).expect("repo");
    let store = SqliteStore::new(&home.join("loopflow.db")).expect("open store");
    let wave = Wave::new(
        WaveId::new(),
        wave_name.to_string(),
        repo.display().to_string(),
    );
    store.create_wave(&wave).expect("register wave");
    store
        .put_pm_snapshot(&PmSnapshotRow {
            wave_id: wave.id().clone(),
            provider: "linear".to_string(),
            initiative: "initiative-1".to_string(),
            synced_at: chrono::Utc::now().timestamp(),
            snapshot: loopflow::pm::PmSnapshot {
                projects: vec![],
                items: vec![],
            },
        })
        .expect("seed pm snapshot");
    wave
}

fn lf(home: &Path, repo: &Path, args: &[&str], wave_id: Option<&str>) -> std::process::Output {
    let mut command = Command::new(env!("CARGO_BIN_EXE_lf"));
    command
        .args(args)
        .current_dir(repo)
        .env_clear()
        .env("PATH", std::env::var_os("PATH").unwrap_or_default())
        .env("HOME", home)
        .env("LF_HOME", home);
    if let Some(id) = wave_id {
        command.env("LF_WAVE_ID", id);
    }
    command.output().expect("lf runs")
}

fn wave_field(output: &std::process::Output) -> String {
    assert!(
        output.status.success(),
        "command failed: {}",
        String::from_utf8_lossy(&output.stderr)
    );
    let json: serde_json::Value = serde_json::from_slice(&output.stdout).expect("stdout is JSON");
    // `status` nests the wave; `pm show` names it at the top level.
    json.get("wave")
        .and_then(|wave| wave.get("name").or(Some(wave)))
        .and_then(serde_json::Value::as_str)
        .expect("a wave name")
        .to_string()
}

#[test]
fn cached_status_honors_the_shared_resolution_rules() {
    let tmp = tempfile::tempdir().expect("tempdir");
    let home = tmp.path().join("home");
    let repo = tmp.path().join("repo");
    let wave = seed(&home, &repo, "product");
    let uuid = wave.id().as_str();

    // Explicit override wins over a wrong ambient UUID.
    let overridden = lf(
        &home,
        &repo,
        &["wave", "status", "product", "--json"],
        Some(&WaveId::new().to_string()),
    );
    assert_eq!(wave_field(&overridden), "product");

    // Hand-set name resolves the same wave.
    let named = lf(&home, &repo, &["wave", "status", "--json"], Some("product"));
    assert_eq!(wave_field(&named), "product");

    // No context: the classified "pass --wave" error, not a UUID-as-name crash.
    let missing = lf(&home, &repo, &["wave", "status", "--json"], None);
    assert!(!missing.status.success());
    assert!(
        String::from_utf8_lossy(&missing.stderr).contains("no wave in context"),
        "missing-context stderr: {}",
        String::from_utf8_lossy(&missing.stderr)
    );

    // Stale identity: a real UUID with no registry row is a distinct error that
    // names the stale id, never a silent fallback.
    let stale_id = WaveId::new().to_string();
    let stale = lf(&home, &repo, &["wave", "status", "--json"], Some(&stale_id));
    assert!(!stale.status.success());
    let stale_err = String::from_utf8_lossy(&stale.stderr);
    assert!(
        stale_err.contains("stale") && stale_err.contains(&stale_id),
        "stale stderr: {stale_err}"
    );
    let _ = uuid;
}

/// W2-240: an explicit selector naming an unknown wave is rejected with the
/// same classified error from every consumer — never silently accepted (the
/// memory bug), never misdirected to a sync command (the PM bug), never given
/// a generic "not found" (the status bug). The error names the wave and the
/// safe next action. A valid ambient does not rescue an unknown explicit:
/// explicit always wins.
#[test]
fn unknown_explicit_wave_is_rejected_identically_by_every_consumer() {
    let tmp = tempfile::tempdir().expect("tempdir");
    let home = tmp.path().join("home");
    let repo = tmp.path().join("repo");
    let wave = seed(&home, &repo, "product");
    let uuid = wave.id().as_str();

    let assert_rejected = |output: std::process::Output, label: &str| {
        assert!(
            !output.status.success(),
            "{label}: unknown explicit wave should exit non-zero"
        );
        let stderr = String::from_utf8_lossy(&output.stderr);
        assert!(
            stderr.contains("definitely-unknown"),
            "{label}: stderr should name the unknown wave: {stderr}"
        );
        assert!(
            stderr.contains("is not registered on this machine"),
            "{label}: stderr should classify as unregistered: {stderr}"
        );
    };

    for ambient in [None, Some(uuid)] {
        assert_rejected(
            lf(
                &home,
                &repo,
                &["wave", "status", "definitely-unknown"],
                ambient,
            ),
            "Wave status",
        );
    }
}