decapod 0.59.1

use serde_json::Value;
use std::fs;
use std::path::{Path, PathBuf};
use std::process::Command;
use tempfile::TempDir;

fn run_decapod(dir: &Path, args: &[&str], envs: &[(&str, &str)]) -> std::process::Output {
    let mut cmd = Command::new(env!("CARGO_BIN_EXE_decapod"));
    cmd.current_dir(dir).args(args);
    for (k, v) in envs {
        cmd.env(k, v);
    }
    cmd.output().expect("run decapod")
}

fn setup_repo() -> (TempDir, PathBuf, String) {
    let tmp = TempDir::new().expect("tmpdir");
    let dir = tmp.path().to_path_buf();

    let git_init = Command::new("git")
        .current_dir(&dir)
        .args(["init", "-b", "master"])
        .output()
        .expect("git init");
    assert!(git_init.status.success(), "git init failed");

    let init = run_decapod(&dir, &["init", "--force"], &[]);
    assert!(
        init.status.success(),
        "decapod init failed: {}",
        String::from_utf8_lossy(&init.stderr)
    );

    let acquire = run_decapod(
        &dir,
        &["session", "acquire"],
        &[("DECAPOD_AGENT_ID", "unknown")],
    );
    assert!(
        acquire.status.success(),
        "session acquire failed: {}",
        String::from_utf8_lossy(&acquire.stderr)
    );
    let password = String::from_utf8_lossy(&acquire.stdout)
        .lines()
        .find_map(|line| {
            line.strip_prefix("Password: ")
                .map(|s| s.trim().to_string())
        })
        .expect("password in session acquire output");

    (tmp, dir, password)
}

#[test]
fn knowledge_promote_writes_append_only_ledger_event() {
    let (_tmp, dir, password) = setup_repo();

    let out = run_decapod(
        &dir,
        &[
            "data",
            "knowledge",
            "promote",
            "--source-entry-id",
            "K_001",
            "--evidence-ref",
            "commit:abc123",
            "--evidence-ref",
            "file:docs/spec.md#L10",
            "--approved-by",
            "human/reviewer-1",
            "--reason",
            "convert episodic finding into procedural norm",
        ],
        &[
            ("DECAPOD_AGENT_ID", "unknown"),
            ("DECAPOD_SESSION_PASSWORD", &password),
            ("DECAPOD_VALIDATE_SKIP_GIT_GATES", "1"),
        ],
    );
    assert!(
        out.status.success(),
        "knowledge promote failed: {}",
        String::from_utf8_lossy(&out.stderr)
    );

    let payload: Value = serde_json::from_slice(&out.stdout).expect("json");
    assert_eq!(payload["source_entry_id"], "K_001");
    assert_eq!(payload["target_class"], "procedural");
    assert_eq!(payload["approved_by"], "human/reviewer-1");

    let ledger_path = dir
        .join(".decapod")
        .join("data")
        .join("knowledge.promotions.jsonl");
    assert!(ledger_path.exists(), "ledger should exist");

    let lines = fs::read_to_string(&ledger_path).expect("read ledger");
    let last = lines
        .lines()
        .rfind(|l| !l.trim().is_empty())
        .expect("ledger last line");
    let event: Value = serde_json::from_str(last).expect("valid jsonl line");
    assert_eq!(event["source_entry_id"], "K_001");
    assert_eq!(event["target_class"], "procedural");
}

#[test]
fn knowledge_promote_rejects_missing_evidence_refs() {
    let (_tmp, dir, password) = setup_repo();

    let out = run_decapod(
        &dir,
        &[
            "data",
            "knowledge",
            "promote",
            "--source-entry-id",
            "K_002",
            "--approved-by",
            "human/reviewer-2",
            "--reason",
            "insufficient evidence should fail",
        ],
        &[
            ("DECAPOD_AGENT_ID", "unknown"),
            ("DECAPOD_SESSION_PASSWORD", &password),
            ("DECAPOD_VALIDATE_SKIP_GIT_GATES", "1"),
        ],
    );
    assert!(
        !out.status.success(),
        "promote should fail without evidence refs"
    );
    let stderr = String::from_utf8_lossy(&out.stderr);
    assert!(
        stderr.contains("at least one --evidence-ref is required"),
        "unexpected error: {stderr}"
    );
}

#[test]
fn procedural_knowledge_add_requires_promotion_event_provenance() {
    let (_tmp, dir, password) = setup_repo();

    let out = run_decapod(
        &dir,
        &[
            "data",
            "knowledge",
            "add",
            "--id",
            "procedural/commit_norms/no-event",
            "--title",
            "Commit norms",
            "--text",
            "Must include tests",
            "--provenance",
            "commit:abc123",
        ],
        &[
            ("DECAPOD_AGENT_ID", "unknown"),
            ("DECAPOD_SESSION_PASSWORD", &password),
            ("DECAPOD_VALIDATE_SKIP_GIT_GATES", "1"),
        ],
    );
    assert!(
        !out.status.success(),
        "procedural add should fail without event-backed provenance"
    );
    let stderr = String::from_utf8_lossy(&out.stderr);
    assert!(
        stderr.contains("procedural knowledge entries require provenance"),
        "unexpected error: {stderr}"
    );
}

#[test]
fn procedural_knowledge_add_accepts_valid_promotion_event_provenance() {
    let (_tmp, dir, password) = setup_repo();

    let promote = run_decapod(
        &dir,
        &[
            "data",
            "knowledge",
            "promote",
            "--source-entry-id",
            "K_source",
            "--evidence-ref",
            "commit:abc123",
            "--approved-by",
            "human/reviewer-3",
            "--reason",
            "promote proven workflow guidance",
        ],
        &[
            ("DECAPOD_AGENT_ID", "unknown"),
            ("DECAPOD_SESSION_PASSWORD", &password),
            ("DECAPOD_VALIDATE_SKIP_GIT_GATES", "1"),
        ],
    );
    assert!(
        promote.status.success(),
        "knowledge promote failed: {}",
        String::from_utf8_lossy(&promote.stderr)
    );
    let promote_payload: Value = serde_json::from_slice(&promote.stdout).expect("promotion json");
    let event_id = promote_payload["event_id"]
        .as_str()
        .expect("event_id from promotion output");
    let provenance = format!("event:{event_id}");

    let add = run_decapod(
        &dir,
        &[
            "data",
            "knowledge",
            "add",
            "--id",
            "procedural/commit_norms/with-event",
            "--title",
            "Commit norms",
            "--text",
            "Run tests before publish",
            "--provenance",
            &provenance,
        ],
        &[
            ("DECAPOD_AGENT_ID", "unknown"),
            ("DECAPOD_SESSION_PASSWORD", &password),
            ("DECAPOD_VALIDATE_SKIP_GIT_GATES", "1"),
        ],
    );
    assert!(
        add.status.success(),
        "procedural add should succeed with valid event-backed provenance: {}",
        String::from_utf8_lossy(&add.stderr)
    );
}