edikt 0.2.1

//! End-to-end CLI tests: drive the built `edikt` binary over stdin/files and
//! assert stdout + exit codes (the grep-shaped contract).

use std::io::Write;
use std::process::{Command, Stdio};

/// Run edikt with `args`, feeding `stdin`; return (stdout, stderr, exit code).
fn run(args: &[&str], stdin: &str) -> (String, String, i32) {
    let mut child = Command::new(env!("CARGO_BIN_EXE_edikt"))
        .args(args)
        .stdin(Stdio::piped())
        .stdout(Stdio::piped())
        .stderr(Stdio::piped())
        .spawn()
        .expect("spawn edikt");
    {
        // The child may exit before reading stdin (e.g. a bad expression or -i
        // error, which are detected first). A broken pipe on the write is then
        // expected - ignore it. Dropping the handle closes stdin (EOF).
        let mut sin = child.stdin.take().unwrap();
        let _ = sin.write_all(stdin.as_bytes());
    }
    let out = child.wait_with_output().unwrap();
    (
        String::from_utf8_lossy(&out.stdout).into_owned(),
        String::from_utf8_lossy(&out.stderr).into_owned(),
        out.status.code().unwrap_or(-1),
    )
}

const TSCONFIG: &str = "{ \"compilerOptions\": { \"strict\": true, \"target\": \"ES2020\", \"lib\": [\"ES2020\", \"DOM\"] } }";

#[test]
fn query_scalar_from_stdin() {
    let (out, _e, code) = run(&["-t", "jsonc", ".compilerOptions.strict"], TSCONFIG);
    assert_eq!(out, "true\n");
    assert_eq!(code, 0);
}

#[test]
fn strings_are_raw_by_default() {
    let (out, _e, code) = run(&["-t", "jsonc", ".compilerOptions.target"], TSCONFIG);
    assert_eq!(out, "ES2020\n");
    assert_eq!(code, 0);
}

#[test]
fn json_output_flag() {
    // `--json` is shorthand for `-T json`: structural results emit as pretty
    // JSON (jq-shaped), scalars JSON-encode.
    let (out, _e, code) = run(&["-t", "jsonc", "--json", ".compilerOptions.lib"], TSCONFIG);
    assert_eq!(out, "[\n  \"ES2020\",\n  \"DOM\"\n]\n");
    assert_eq!(code, 0);

    let (s, _e, c2) = run(
        &["-t", "jsonc", "--json", ".compilerOptions.target"],
        TSCONFIG,
    );
    assert_eq!(s, "\"ES2020\"\n");
    assert_eq!(c2, 0);
}

#[test]
fn iterate_yields_one_line_each() {
    let (out, _e, code) = run(&["-t", "jsonc", ".compilerOptions.lib[]"], TSCONFIG);
    assert_eq!(out, "ES2020\nDOM\n");
    assert_eq!(code, 0);
}

#[test]
fn computed_value() {
    let (out, _e, code) = run(
        &["-t", "jsonc", ".compilerOptions.target | ascii_downcase"],
        TSCONFIG,
    );
    assert_eq!(out, "es2020\n");
    assert_eq!(code, 0);
}

#[test]
fn miss_is_a_silent_noop() {
    // sed-shaped: no match, no output, no error - exit 0.
    let (out, err, code) = run(&["-t", "jsonc", ".nope"], TSCONFIG);
    assert_eq!(out, "");
    assert_eq!(err, "");
    assert_eq!(code, 0);
    // jq-shaped presence testing is an explicit opt-in.
    let (_o, _e, c2) = run(&["-t", "jsonc", "--exit-status", ".nope"], TSCONFIG);
    assert_eq!(c2, 1);
    let (_o, _e, c3) = run(
        &["-t", "jsonc", "--exit-status", ".compilerOptions.strict"],
        TSCONFIG,
    );
    assert_eq!(c3, 0);
}

#[test]
fn alternative_operator_defaults_a_miss() {
    let (out, _e, code) = run(&["-t", "jsonc", r#".nope // "fallback""#], TSCONFIG);
    assert_eq!(out, "fallback\n");
    assert_eq!(code, 0);
    // The RHS of an assignment gets the default: set-with-fallback in one pass.
    let (out2, _e, c2) = run(
        &["-t", "jsonc", r#".target = .missing // "ES2022""#],
        "{ \"target\": \"ES5\" }",
    );
    assert_eq!(out2, "{ \"target\": \"ES2022\" }");
    assert_eq!(c2, 0);
}

#[test]
fn multiple_files_edit_like_sed() {
    // Shell globs expand to multiple operands; -i edits each in place.
    let dir = env!("CARGO_TARGET_TMPDIR");
    let a = format!("{dir}/multi-a.json");
    let b = format!("{dir}/multi-b.json");
    std::fs::write(&a, "{\"v\": 1}").unwrap();
    std::fs::write(&b, "{\"v\": 2}").unwrap();
    let (_o, _e, code) = run(&["-i", ".v = 9", &a, &b], "");
    assert_eq!(code, 0);
    assert_eq!(std::fs::read_to_string(&a).unwrap(), "{\"v\": 9}");
    assert_eq!(std::fs::read_to_string(&b).unwrap(), "{\"v\": 9}");
    // Queries over several files concatenate their results, in order.
    let (out, _e, c2) = run(&[".v", &a, &b], "");
    assert_eq!(out, "9\n9\n");
    assert_eq!(c2, 0);
}

#[test]
fn bad_expression_is_exit_2() {
    let (_o, err, code) = run(&["-t", "jsonc", "@bad"], TSCONFIG);
    assert_eq!(code, 2);
    assert!(err.contains("edikt"));
}

#[test]
fn stdin_without_type_errors() {
    let (_o, err, code) = run(&[".a"], "{}");
    assert_eq!(code, 2);
    assert!(err.contains("-t"));
}

#[test]
fn expr_via_dash_e() {
    let (out, _e, code) = run(&["-t", "jsonc", "-e", ".compilerOptions.strict"], TSCONFIG);
    assert_eq!(out, "true\n");
    assert_eq!(code, 0);
}

#[test]
fn in_place_requires_a_mutation() {
    let (_o, err, code) = run(&["-t", "jsonc", "-i", ".a"], "{\"a\":1}");
    assert_eq!(code, 2);
    assert!(err.contains("in-place"));
}

#[test]
fn mutation_writes_whole_doc_to_stdout() {
    let (out, _e, code) = run(&["-t", "jsonc", ".a = 5"], "{ \"a\": 1, \"b\": 2 }");
    assert_eq!(out, "{ \"a\": 5, \"b\": 2 }");
    assert_eq!(code, 0);
}

#[test]
fn update_assign_via_cli() {
    let (out, _e, code) = run(&["-t", "jsonc", ".count |= . + 1"], "{ \"count\": 9 }");
    assert_eq!(out, "{ \"count\": 10 }");
    assert_eq!(code, 0);
}

#[test]
fn in_place_edits_file_and_keeps_comments() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/edit.jsonc");
    std::fs::write(&path, "{\n  // keep me\n  \"strict\": true,\n}\n").unwrap();
    let (out, _e, code) = run(&["-i", ".strict = false", &path], "");
    assert_eq!(out, ""); // -i writes to the file, not stdout
    assert_eq!(code, 0);
    let after = std::fs::read_to_string(&path).unwrap();
    assert_eq!(after, "{\n  // keep me\n  \"strict\": false,\n}\n");
}

#[test]
fn in_place_on_stdin_errors() {
    let (_o, err, code) = run(&["-t", "jsonc", "-i", ".a = 1"], "{\"a\":0}");
    assert_eq!(code, 2);
    assert!(err.contains("stdin"));
}

#[test]
fn del_via_cli() {
    let (out, _e, code) = run(&["-t", "jsonc", "del(.a)"], "{ \"a\": 1, \"b\": 2 }");
    assert_eq!(out, "{ \"b\": 2 }");
    assert_eq!(code, 0);
}

#[test]
fn del_then_set_pipeline() {
    let (out, _e, code) = run(
        &["-t", "jsonc", "del(.a) | .b = 9"],
        "{ \"a\": 1, \"b\": 2 }",
    );
    assert_eq!(out, "{ \"b\": 9 }");
    assert_eq!(code, 0);
}

#[test]
fn append_via_cli() {
    let (out, _e, code) = run(
        &["-t", "jsonc", r#".lib += ["X"]"#],
        "{ \"lib\": [\"A\", \"B\"] }",
    );
    assert_eq!(out, "{ \"lib\": [\"A\", \"B\", \"X\"] }");
    assert_eq!(code, 0);
}

#[test]
fn add_assign_number_via_cli() {
    let (out, _e, code) = run(&["-t", "jsonc", ".count += 1"], "{ \"count\": 41 }");
    assert_eq!(out, "{ \"count\": 42 }");
    assert_eq!(code, 0);
}

#[test]
fn ini_query_via_type() {
    let (out, _e, code) = run(&["-t", "ini", ".server.port"], "[server]\nport = 8080\n");
    assert_eq!(out, "8080\n");
    assert_eq!(code, 0);
}

#[test]
fn ini_infers_by_extension() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/q.ini");
    std::fs::write(&path, "[a]\nb = c\n").unwrap();
    let (out, _e, code) = run(&[".a.b", &path], "");
    assert_eq!(out, "c\n");
    assert_eq!(code, 0);
}

#[test]
fn ini_edit_in_place_preserves_layout() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/edit.ini");
    std::fs::write(&path, "; keep me\n[server]\nport = 8080\n").unwrap();
    let (_o, _e, code) = run(&["-i", r#".server.port = "9090""#, &path], "");
    assert_eq!(code, 0);
    assert_eq!(
        std::fs::read_to_string(&path).unwrap(),
        "; keep me\n[server]\nport = 9090\n"
    );
}

#[test]
fn env_query_via_type() {
    let (out, _e, code) = run(&["-t", "env", ".DEBUG"], "# c\nDEBUG=true\n");
    assert_eq!(out, "true\n");
    assert_eq!(code, 0);
}

#[test]
fn env_detects_dotenv_by_name() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/.env");
    std::fs::write(&path, "PORT=8080\n").unwrap();
    let (out, _e, code) = run(&[".PORT", &path], "");
    assert_eq!(out, "8080\n");
    assert_eq!(code, 0);
}

#[test]
fn env_edit_in_place() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/edit.env");
    std::fs::write(&path, "# keep\nDATABASE_URL=old\nDEBUG=true\n").unwrap();
    let (_o, _e, code) = run(&["-i", "del(.DEBUG)", &path], "");
    assert_eq!(code, 0);
    assert_eq!(
        std::fs::read_to_string(&path).unwrap(),
        "# keep\nDATABASE_URL=old\n"
    );
}

#[test]
fn creates_new_key_jsonc() {
    let (out, _e, code) = run(
        &["-t", "jsonc", ".compilerOptions.noEmit = true"],
        "{ \"compilerOptions\": { \"strict\": true } }",
    );
    assert_eq!(
        out,
        "{ \"compilerOptions\": { \"strict\": true, \"noEmit\": true } }"
    );
    assert_eq!(code, 0);
}

#[test]
fn creates_new_key_env() {
    // The exact case the demo hit - now works.
    let (out, _e, code) = run(&["-t", "env", r#".K2 = "x""#], "K=v\n");
    assert_eq!(out, "K=v\nK2=x\n");
    assert_eq!(code, 0);
}

#[test]
fn convert_ini_to_json() {
    let (out, _e, code) = run(&["-t", "ini", "-T", "json"], "[a]\nb = c\n");
    assert_eq!(out, "{\n  \"a\": {\n    \"b\": \"c\"\n  }\n}\n");
    assert_eq!(code, 0);
}

#[test]
fn convert_jsonc_to_env_flattens_with_warning() {
    let (out, err, code) = run(&["-t", "jsonc", "-T", "env"], "{ \"A\": { \"B\": 1 } }");
    assert_eq!(out, "A.B=1\n");
    assert!(err.contains("flattened"));
    assert_eq!(code, 0);
}

#[test]
fn regex_builtins_via_cli() {
    // select + test: the filter real configs reach for.
    let y = "services:\n  web:\n    image: nginx:1.25\n  db:\n    image: postgres:16\n";
    let (out, _e, code) = run(
        &[
            "-t",
            "yaml",
            r#".services[] | select(.image | test("^nginx")) | .image"#,
        ],
        y,
    );
    assert_eq!(out, "nginx:1.25\n");
    assert_eq!(code, 0);

    // sub on the right side of a format-preserving mutation.
    let (out2, _e, c2) = run(
        &["-t", "env", r#".VERSION |= sub("^v"; "")"#],
        "# release\nVERSION=v1.2.3\n",
    );
    assert_eq!(out2, "# release\nVERSION=1.2.3\n");
    assert_eq!(c2, 0);

    // split / join round trip in an edit.
    let (out3, _e, c3) = run(
        &["-t", "env", r#".P |= (split(":") + ["/sbin"] | join(":"))"#],
        "P=/usr/bin:/bin\n",
    );
    assert_eq!(out3, "P=/usr/bin:/bin:/sbin\n");
    assert_eq!(c3, 0);

    // capture extracts named groups; a no-match is a grep-shaped miss.
    let (out4, _e, c4) = run(
        &["-t", "json", r#".image | capture("(?<tag>[^:]+$)") | .tag"#],
        "{\"image\": \"nginx:1.25\"}",
    );
    assert_eq!(out4, "1.25\n");
    assert_eq!(c4, 0);
    // A no-match `match` is a miss: silent by default, 1 under --exit-status.
    let (_o, _e, c5) = run(
        &["-t", "json", "--exit-status", r#".a | match("z")"#],
        "{\"a\": \"x\"}",
    );
    assert_eq!(c5, 1);

    // A bad regex is a clean expression error.
    let (_o, err, c6) = run(&["-t", "json", r#".a | test("(")"#], "{\"a\": \"x\"}");
    assert_eq!(c6, 2);
    assert!(err.contains("invalid regex"), "got: {err}");
}

#[test]
fn convert_carries_comments_across_formats() {
    // JSONC -> YAML: head and inline comments arrive in YAML syntax, silently
    // (nothing was lost, so nothing warns).
    let src =
        "{\n  // compiler settings\n  \"opts\": { \"target\": \"ES2020\" /* language level */ }\n}";
    let (out, err, code) = run(&["-t", "jsonc", "-T", "yaml"], src);
    assert_eq!(
        out,
        "# compiler settings\nopts:\n  target: ES2020 # language level\n"
    );
    assert_eq!(err, "", "a fully-carried conversion must not warn");
    assert_eq!(code, 0);

    // YAML -> TOML and YAML -> JSONC carry them too.
    let y = "# stack\nweb:\n  image: nginx # pinned\n";
    let (toml, err2, c2) = run(&["-t", "yaml", "-T", "toml"], y);
    assert!(toml.contains("# stack\n[web]"), "got: {toml}");
    assert!(toml.contains("image = \"nginx\" # pinned"), "got: {toml}");
    assert_eq!(err2, "");
    assert_eq!(c2, 0);

    let (jsonc, _e, c3) = run(&["-t", "yaml", "-T", "jsonc"], y);
    assert!(jsonc.contains("// stack"), "got: {jsonc}");
    assert!(
        jsonc.contains("\"image\": \"nginx\" // pinned"),
        "got: {jsonc}"
    );
    assert_eq!(c3, 0);
}

#[test]
fn convert_comment_remap_warns_and_strict_errors() {
    // env has no inline comments: the comment moves to its own line, warned.
    let (out, err, code) = run(&["-t", "yaml", "-T", "env"], "A: 1 # why\n");
    assert_eq!(out, "# why\nA=1\n");
    assert!(err.contains("inline comments moved"), "got: {err}");
    assert_eq!(code, 0);

    let (_o, err2, c2) = run(&["-t", "yaml", "-T", "env", "--strict"], "A: 1 # why\n");
    assert_eq!(c2, 2);
    assert!(err2.contains("inline comments moved"), "got: {err2}");
}

#[test]
fn synthesized_conversion_still_warns_on_commented_source() {
    // A computed result carries no comments; converting a commented source
    // through one stays an honest, warned drop.
    let y = "# stack\nweb:\n  a: 1\n  b: 2\n";
    let (out, err, code) = run(&["-t", "yaml", "-T", "json", ".web | keys"], y);
    assert_eq!(out, "[\n  \"a\",\n  \"b\"\n]\n");
    assert!(err.contains("comments were dropped"), "got: {err}");
    assert_eq!(code, 0);
}

#[test]
fn convert_warns_on_dropped_comments() {
    let (out, err, code) = run(&["-t", "jsonc", "-T", "json"], "{ /* c */ \"a\": 1 }");
    assert_eq!(out, "{\n  \"a\": 1\n}\n");
    assert!(err.contains("comments were dropped"));
    assert_eq!(code, 0);
}

#[test]
fn convert_strict_errors_on_loss() {
    let (_o, err, code) = run(
        &["-t", "jsonc", "-T", "json", "--strict"],
        "{ /* c */ \"a\": 1 }",
    );
    assert_eq!(code, 2);
    assert!(err.contains("comments"));
}

#[test]
fn convert_subtree_via_expr() {
    let (out, _e, code) = run(
        &["-t", "ini", "-T", "env", "-e", ".server"],
        "[server]\nhost=x\nport=8080\n",
    );
    assert_eq!(out, "host=x\nport=8080\n");
    assert_eq!(code, 0);
}

#[test]
fn ini_creates_new_section() {
    let (out, _e, code) = run(&["-t", "ini", r#".db.url = "pg""#], "[server]\nhost = x\n");
    assert_eq!(out, "[server]\nhost = x\n\n[db]\nurl = pg\n");
    assert_eq!(code, 0);
}

#[test]
fn toml_query_and_edit_keeps_comment() {
    let (out, _e, code) = run(
        &["-t", "toml", ".package.version"],
        "[package]\nversion = \"1.0.0\"\n",
    );
    assert_eq!(out, "1.0.0\n");
    assert_eq!(code, 0);

    let (edited, _e, code2) = run(
        &["-t", "toml", r#".version = "2.0.0""#],
        "version = \"1.0.0\"  # semver\n",
    );
    assert_eq!(edited, "version = \"2.0.0\"  # semver\n");
    assert_eq!(code2, 0);
}

#[test]
fn convert_toml_to_json_and_back() {
    let (out, _e, code) = run(&["-t", "toml", "-T", "json"], "[a]\nb = 1\n");
    assert_eq!(out, "{\n  \"a\": {\n    \"b\": 1\n  }\n}\n");
    assert_eq!(code, 0);

    let (toml, _e, code2) = run(
        &["-t", "jsonc", "-T", "toml"],
        "{ \"package\": { \"name\": \"x\", \"version\": \"1\" } }",
    );
    assert!(toml.contains("[package]"), "got: {toml}");
    assert!(toml.contains("name = \"x\""));
    assert_eq!(code2, 0);
}

#[test]
fn yaml_query_and_convert() {
    let (out, _e, code) = run(&["-t", "yaml", ".web.replicas"], "web:\n  replicas: 3\n");
    assert_eq!(out, "3\n");
    assert_eq!(code, 0);

    let (json, _e, c2) = run(&["-t", "yaml", "-T", "json"], "a:\n  b: 1\n");
    assert_eq!(json, "{\n  \"a\": {\n    \"b\": 1\n  }\n}\n");
    assert_eq!(c2, 0);

    let (yaml, _e, c3) = run(&["-t", "jsonc", "-T", "yaml"], "{ \"a\": { \"b\": 1 } }");
    assert_eq!(yaml, "a:\n  b: 1\n");
    assert_eq!(c3, 0);
}

#[test]
fn yaml_edit_is_lossless() {
    // A one-scalar edit preserves the comment and every untouched byte.
    let (out, _e, code) = run(
        &["-t", "yaml", ".replicas = 5"],
        "# stack\nreplicas: 3   # count\ndebug: false\n",
    );
    assert_eq!(out, "# stack\nreplicas: 5   # count\ndebug: false\n");
    assert_eq!(code, 0);

    // del + append through the CLI.
    let (out2, _e, c2) = run(&["-t", "yaml", "del(.debug)"], "a: 1\ndebug: true\n");
    assert_eq!(out2, "a: 1\n");
    assert_eq!(c2, 0);
}

#[test]
fn comments_stream_query_and_bulk_edit() {
    // comment -> key: which keys carry a TODO?
    let y =
        "web:\n  image: nginx  # TODO pin\n  port: 80  # ok\ndb:\n  image: pg  # TODO upgrade\n";
    let (out, _e, code) = run(
        &[
            "-t",
            "yaml",
            r#"comments | select(.text | test("TODO")) | .path"#,
        ],
        y,
    );
    assert_eq!(out, ".web.image\n.db.image\n");
    assert_eq!(code, 0);

    // Bulk edit every comment's text (TODO -> DONE), format-preserving.
    let (edited, _e, c2) = run(
        &["-t", "yaml", r#"comments |= gsub("TODO"; "DONE")"#],
        "a: 1  # TODO a\nb: 2  # TODO b\n",
    );
    assert_eq!(edited, "a: 1  # DONE a\nb: 2  # DONE b\n");
    assert_eq!(c2, 0);

    // Bulk delete removes all comments (JSONC, through the rowan re-parse path).
    let (stripped, _e, c3) = run(
        &["-t", "jsonc", "del(comments)"],
        "{\n  // drop\n  \"a\": 1,\n  \"b\": 2 // and this\n}\n",
    );
    assert_eq!(stripped, "{\n  \"a\": 1,\n  \"b\": 2\n}\n");
    assert_eq!(c3, 0);

    // `comments` as JSON does not spuriously warn "comments were dropped".
    let (_o, err, c4) = run(&["-t", "yaml", "--json", "comments"], "a: 1  # note\n");
    assert!(!err.contains("dropped"), "stray warning: {err}");
    assert_eq!(c4, 0);

    // Bulk append to every comment.
    let (app, _e, c5) = run(
        &["-t", "toml", r#"comments += " (done)""#],
        "# a\nk = 1  # b\n",
    );
    assert!(
        app.contains("# a (done)") && app.contains("# b (done)"),
        "got: {app}"
    );
    assert_eq!(c5, 0);
}

#[test]
fn comment_mutation_add_assign_pipe_and_errors() {
    // += appends to a single comment; piped comment edits chain.
    let (out, _e, code) = run(&["-t", "toml", r#".k.# = "note" | .k.# += "!""#], "k = 1\n");
    assert_eq!(out, "# note!\nk = 1\n");
    assert_eq!(code, 0);

    // `del` with two (`;`-separated) arguments is an arity error, not a panic.
    let (_o, err, c2) = run(&["-t", "toml", "del(.k.#; .j.#)"], "k = 1\n");
    assert_eq!(c2, 2);
    assert!(err.contains("one"), "got: {err}");
}

#[test]
fn comment_query_reads_by_kind() {
    // Head comment via `#` (JSONC).
    let (out, _e, code) = run(
        &["-t", "jsonc", ".strict.#"],
        "{\n  // the strict flag\n  \"strict\": true\n}",
    );
    assert_eq!(out, "the strict flag\n");
    assert_eq!(code, 0);

    // Inline via `#.inline` (YAML), and transform through a pipe.
    let (up, _e, c2) = run(
        &["-t", "yaml", ".web.image.#.inline | ascii_upcase"],
        "web:\n  image: nginx # pinned\n",
    );
    assert_eq!(up, "PINNED\n");
    assert_eq!(c2, 0);

    // Iterate comments in one path: `.services[].#.inline`.
    let (each, _e, c3) = run(
        &["-t", "yaml", ".services[].#.inline"],
        "services:\n  web: 1 # frontend\n  db: 2 # store\n",
    );
    assert_eq!(each, "frontend\nstore\n");
    assert_eq!(c3, 0);

    // A missing comment is a sed-shaped miss (silent, exit 0); `//` defaults it.
    let (miss, _e, c4) = run(&["-t", "jsonc", ".a.#"], "{ \"a\": 1 }");
    assert_eq!(miss, "");
    assert_eq!(c4, 0);
    let (dflt, _e, c5) = run(&["-t", "jsonc", r#".a.# // "none""#], "{ \"a\": 1 }");
    assert_eq!(dflt, "none\n");
    assert_eq!(c5, 0);
}

#[test]
fn comment_mutation_on_decor_formats() {
    // TOML: set a head comment in place, everything else byte-identical.
    let (out, _e, code) = run(
        &["-t", "toml", r#".b.z.# = "annotated""#],
        "# banner\n[a]\nx = 1  # inline x\n[b]\nz = 3\n",
    );
    assert_eq!(
        out,
        "# banner\n[a]\nx = 1  # inline x\n[b]\n# annotated\nz = 3\n"
    );
    assert_eq!(code, 0);

    // KDL: inline comment, then read it back through a pipe.
    let (out2, _e, c2) = run(
        &["-t", "kdl", r#".server.port.#.inline = "listen""#],
        "server {\n    port 8080\n}\n",
    );
    assert_eq!(out2, "server {\n    port 8080 // listen\n}\n");
    assert_eq!(c2, 0);

    // JSONC (rowan) head comment in place; surrounding bytes untouched.
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/comment-edit.jsonc");
    std::fs::write(&path, "{\n  // keep\n  \"a\": 1,\n  \"b\": 2\n}\n").unwrap();
    let (_o, _e, c3) = run(&["-i", r#".b.# = "note""#, &path], "");
    assert_eq!(c3, 0);
    assert_eq!(
        std::fs::read_to_string(&path).unwrap(),
        "{\n  // keep\n  \"a\": 1,\n  // note\n  \"b\": 2\n}\n"
    );

    // A compact object defers to the layout-reflow follow-up with a clear error.
    let (_o, err, c4) = run(&["-t", "jsonc", r#".b.# = "x""#], "{ \"a\": 1, \"b\": 2 }");
    assert_eq!(c4, 2);
    assert!(err.contains("layout expansion"), "got: {err}");
}

#[test]
fn kdl_query_edit_and_convert() {
    // Query a nested child node's argument.
    let src = "server {\n    port 8080\n    host \"0.0.0.0\"\n}\n";
    let (out, _e, code) = run(&["-t", "kdl", ".server.port"], src);
    assert_eq!(out, "8080\n");
    assert_eq!(code, 0);

    // Lossless edit: the leading + inline comments and layout survive.
    let (edited, _e, c2) = run(
        &["-t", "kdl", ".server.port = 9090"],
        "// prod\nserver {\n    port 8080 // listen\n}\n",
    );
    assert_eq!(edited, "// prod\nserver {\n    port 9090 // listen\n}\n");
    assert_eq!(c2, 0);

    // KDL -> JSON and JSON -> KDL.
    let (json, _e, c3) = run(&["-t", "kdl", "-T", "json"], src);
    assert_eq!(
        json,
        "{\n  \"server\": {\n    \"port\": 8080,\n    \"host\": \"0.0.0.0\"\n  }\n}\n"
    );
    assert_eq!(c3, 0);

    let (kdl, _e, c4) = run(
        &["-t", "json", "-T", "kdl"],
        "{ \"pkg\": { \"name\": \"edikt\" } }",
    );
    assert!(kdl.contains("pkg {"), "got: {kdl}");
    assert!(kdl.contains("name edikt"), "got: {kdl}");
    assert_eq!(c4, 0);

    // Comment carries KDL -> YAML (`//` becomes `#`).
    let (yaml, err, c5) = run(
        &["-t", "kdl", "-T", "yaml"],
        "// the server\nserver {\n    port 8080\n}\n",
    );
    assert_eq!(yaml, "# the server\nserver:\n  port: 8080\n");
    assert_eq!(err, "");
    assert_eq!(c5, 0);
}

#[test]
fn object_literal_and_bracket_key() {
    let (out, _e, code) = run(&["-t", "jsonc", ".config = {}"], "{ \"config\": 1 }");
    assert_eq!(out, "{ \"config\": {} }");
    assert_eq!(code, 0);

    let (out2, _e, code2) = run(
        &["-t", "properties", r#"."app.name""#],
        "app.name = edikt\n",
    );
    assert_eq!(out2, "edikt\n");
    assert_eq!(code2, 0);
}

#[test]
fn reads_a_file_and_infers_by_extension() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/sample.jsonc");
    std::fs::write(&path, "// comment\n{ \"a\": { \"b\": 42 } }\n").unwrap();
    let (out, _e, code) = run(&[".a.b", &path], "");
    assert_eq!(out, "42\n");
    assert_eq!(code, 0);
}

#[test]
fn unknown_extension_errors() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/sample.weird");
    std::fs::write(&path, "{}").unwrap();
    let (_o, err, code) = run(&[".a", &path], "");
    assert_eq!(code, 2);
    assert!(err.contains("-t"));
    // The error lists the formats to choose from.
    assert!(err.contains("yaml") && err.contains("toml"), "got: {err}");
}

#[test]
fn structural_query_returns_source_slice() {
    // A pure-path structural query stays in-format: exact source bytes,
    // comments included - not re-serialized JSON.
    let src = "{\n  \"lib\": [\"ES2020\", \"DOM\"], // pinned\n  \"opts\": { \"strict\": true }\n}";
    let (out, _e, code) = run(&["-t", "jsonc", ".lib"], src);
    assert_eq!(out, "[\"ES2020\", \"DOM\"]\n");
    assert_eq!(code, 0);

    // YAML block collections come back dedented, comments intact.
    let y = "web:\n  image: nginx   # pinned\n  ports:\n    - 80\n";
    let (yo, _e, yc) = run(&["-t", "yaml", ".web"], y);
    assert_eq!(yo, "image: nginx   # pinned\nports:\n  - 80\n");
    assert_eq!(yc, 0);
}

#[test]
fn synthesized_query_stays_in_format() {
    // A computed result has no source slice; it renders via the input format's
    // emitter - YAML in, YAML out.
    let y = "web:\n  image: nginx\n  ports:\n    - 80\n";
    let (out, _e, code) = run(&["-t", "yaml", ".web | keys"], y);
    assert_eq!(out, "- image\n- ports\n");
    assert_eq!(code, 0);
}

#[test]
fn infeasible_output_names_candidates() {
    // An array result cannot be a top-level env document; the error suggests
    // formats whose feature set can hold it.
    let (_o, err, code) = run(&["-t", "yaml", "-T", "env", ".xs"], "xs:\n  - 1\n  - 2\n");
    assert_eq!(code, 2);
    assert!(err.contains("cannot represent"), "got: {err}");
    assert!(err.contains("yaml") && err.contains("toml"), "got: {err}");
}

#[test]
fn script_directives_bake_formats() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let script = format!("{dir}/to_json.edk");
    std::fs::write(
        &script,
        "#!/usr/bin/env -S edikt -f\n# a comment\ntoFormat: json\ntype: yaml\n.web\n",
    )
    .unwrap();
    // The script bakes input+output formats; no -t/-T needed.
    let (out, _e, code) = run(&["-f", &script], "web:\n  a: 1\n");
    assert_eq!(out, "{\n  \"a\": 1\n}\n");
    assert_eq!(code, 0);

    // CLI flags override script directives.
    let (out2, _e2, c2) = run(&["-f", &script, "-T", "yaml"], "web:\n  a: 1\n");
    assert_eq!(out2, "a: 1\n");
    assert_eq!(c2, 0);
}

#[test]
fn to_with_expression_and_file() {
    // `-T json EXPR FILE`: the first operand is the expression (not a file).
    let dir = env!("CARGO_TARGET_TMPDIR");
    let path = format!("{dir}/tq.yaml");
    std::fs::write(&path, "a:\n  b: 2\n").unwrap();
    let (out, _e, code) = run(&["-T", "json", ".a", &path], "");
    assert_eq!(out, "{\n  \"b\": 2\n}\n");
    assert_eq!(code, 0);

    // `-T json FILE` still converts the whole document.
    let (out2, _e2, c2) = run(&["-T", "json", &path], "");
    assert_eq!(out2, "{\n  \"a\": {\n    \"b\": 2\n  }\n}\n");
    assert_eq!(c2, 0);
}

#[test]
fn output_file_infers_format_from_extension() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let out = format!("{dir}/o1.json");
    // YAML in, -o file.json -> JSON written to the file, nothing on stdout.
    let (stdout, _e, code) = run(&["-t", "yaml", "-o", &out, ".a"], "a:\n  b: 1\n");
    assert_eq!(stdout, "");
    assert_eq!(code, 0);
    assert_eq!(std::fs::read_to_string(&out).unwrap(), "{\n  \"b\": 1\n}\n");

    // Explicit -T beats the extension.
    let out2 = format!("{dir}/o2.json");
    let (_s, _e, c2) = run(
        &["-t", "yaml", "-T", "yaml", "-o", &out2, ".a"],
        "a:\n  b: 1\n",
    );
    assert_eq!(c2, 0);
    assert_eq!(std::fs::read_to_string(&out2).unwrap(), "b: 1\n");
}

#[test]
fn output_file_takes_mutation_result() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let out = format!("{dir}/edited.yaml");
    // A mutation with -o writes the edited document to FILE (extension is a
    // sink here, not a conversion).
    let (stdout, _e, code) = run(&["-t", "yaml", "-o", &out, ".a = 2"], "# keep\na: 1\n");
    assert_eq!(stdout, "");
    assert_eq!(code, 0);
    assert_eq!(std::fs::read_to_string(&out).unwrap(), "# keep\na: 2\n");
}

#[test]
fn output_file_untouched_on_miss() {
    let dir = env!("CARGO_TARGET_TMPDIR");
    let out = format!("{dir}/miss.json");
    let _ = std::fs::remove_file(&out);
    let (_s, _e, code) = run(&["-t", "yaml", "-o", &out, ".nope"], "a: 1\n");
    assert_eq!(code, 0); // a miss is a silent no-op...
    assert!(
        !std::path::Path::new(&out).exists(),
        "...and writes no file"
    );
}

#[test]
fn identity_expression_is_never_a_directory() {
    // `.` names a directory that always exists, but as an operand it is the
    // identity *expression* - with -T it must convert stdin, not try to read
    // the current directory.
    let (out, _e, code) = run(&["-t", "jsonc", "-T", "json", "."], "{ \"a\": 1 }");
    assert_eq!(out, "{\n  \"a\": 1\n}\n");
    assert_eq!(code, 0);
}

#[test]
fn packager_flags_emit_docs() {
    // The binary is its own doc generator: completions and the man page come
    // from hidden flags, so release archives and package builds need no
    // extra tooling.
    let (out, _e, code) = run(&["--completions", "zsh"], "");
    assert!(out.starts_with("#compdef edikt"), "got: {out:.40}");
    assert_eq!(code, 0);
    let (man, _e, c2) = run(&["--manpage"], "");
    assert!(man.contains(".TH edikt 1"), "got: {man:.80}");
    assert_eq!(c2, 0);
}

#[test]
fn helpful_error_messages() {
    // Unknown format names the valid choices.
    let (_o, err, code) = run(&["-t", "bogus", "."], "a: 1\n");
    assert_eq!(code, 2);
    assert!(err.contains("unknown format `bogus`"), "got: {err}");
    assert!(err.contains("jsonc") && err.contains("yaml"), "got: {err}");

    // A failed edit path is named in the error. (Deleting a *missing* key is a
    // no-op, jq-style - so use a create-through-scalar, which genuinely fails.)
    let (_o, err2, c2) = run(&["-t", "yaml", ".a.b = 1"], "a: 1\n");
    assert_eq!(c2, 2);
    assert!(err2.contains(".a.b"), "got: {err2}");

    // A bad expression chains its context.
    let (_o, err3, c3) = run(&["-t", "yaml", ".a |"], "a: 1\n");
    assert_eq!(c3, 2);
    assert!(err3.contains("bad expression"), "got: {err3}");
}