drep-ai 2.7.1

//! `api_key_command` in the LLM section: what doctor says about a credential
//! helper, and what it must never say.
//!
//! doctor's contract is "what will actually run here", so the helper is really
//! invoked. What that means for output is the whole point of these three tests: a
//! working helper is reported as working, a broken one as broken, and neither
//! line carries a byte of what the helper printed.

use std::path::Path;

use crate::test_support::{write_executable, write_site_policy};

/// Run `doctor` against `dir` with an auth store and a policy file scoped to it.
async fn report_with_policy(dir: &Path, policy: &Path) -> String {
    super::report_scoped_with_policy(dir, policy).await
}

/// Run `doctor` against `dir` with an auth store scoped to it.
async fn report_for(dir: &Path) -> String {
    report_with_policy(dir, &dir.join("absent-site.toml")).await
}

/// Write a `drep.toml` whose only provider mints its key by running `argv`.
fn write_config_running(dir: &Path, argv: &str) {
    std::fs::write(
        dir.join("drep.toml"),
        format!("[[llm]]\nendpoint = \"http://e/v1\"\nmodel = \"m\"\napi_key_command = [{argv}]\n"),
    )
    .expect("drep.toml");
}

#[tokio::test]
async fn a_working_command_is_reported_as_working_without_its_output() {
    let dir = tempfile::tempdir().expect("tempdir");
    let stub = dir.path().join("print-token");
    write_executable(&stub, "#!/bin/sh\nprintf '%s' 'sk-live-sekrit'\n");
    write_config_running(dir.path(), &format!("{:?}", stub.to_string_lossy()));

    let report = report_for(dir.path()).await;

    assert!(
        report.contains("from api_key_command"),
        "the source must be named, so `doctor` and `check` agree about it: {report}"
    );
    assert!(
        report.contains("the command ran and printed a credential"),
        "a helper that works is worth saying so: {report}"
    );
    assert!(
        !report.contains("sk-live-sekrit"),
        "doctor output is what people paste into bug reports and CI logs: {report}"
    );
}

#[tokio::test]
async fn a_failing_command_is_reported_with_its_status_and_never_its_output() {
    // The reason the probe exists. A helper that stopped authenticating is the
    // failure `api_key_command` was configured to surface, and a doctor that
    // reported it as fine would be describing a run that exits 2.
    let dir = tempfile::tempdir().expect("tempdir");
    let stub = dir.path().join("print-token");
    write_executable(
        &stub,
        "#!/bin/sh\nprintf '%s' 'sk-live-sekrit'\nprintf '%s' 'sk-live-sekrit' >&2\nexit 9\n",
    );
    write_config_running(dir.path(), &format!("{:?}", stub.to_string_lossy()));

    let report = report_for(dir.path()).await;

    assert!(report.contains("print-token"), "got {report}");
    assert!(
        report.contains('9'),
        "the exit status is the actionable half: {report}"
    );
    assert!(
        !report.contains("sk-live-sekrit"),
        "a misconfigured helper prints the token to both streams; the diagnostic \
         is thin so neither reaches the report: {report}"
    );
}

#[tokio::test]
async fn a_malformed_command_reference_never_echoes_argv_secrets() {
    let dir = tempfile::tempdir().expect("tempdir");
    write_config_running(dir.path(), "\"helper\", \"--token=doctor-sentinel${\"");

    let report = report_for(dir.path()).await;

    assert!(
        !report.contains("doctor-sentinel"),
        "doctor leaked argv: {report}"
    );
    assert!(report.contains("unterminated"), "got {report}");
}

#[tokio::test]
async fn a_command_naming_an_unset_variable_is_reported_as_not_attempted() {
    // The probe runs the *expanded* argv, so when the config does not load there
    // is no argv to run. Executing the raw one would report on a command
    // containing a literal `${VAR}`, which is not the command `check` runs.
    let dir = tempfile::tempdir().expect("tempdir");
    write_config_running(
        dir.path(),
        "\"print-token\", \"${DREP_DOCTOR_KEY_CMD_UNSET}\"",
    );

    let report = report_for(dir.path()).await;

    assert!(
        report.contains("not attempted"),
        "an argv drep cannot expand is not a command it can probe: {report}"
    );
    assert!(
        report.contains("DREP_DOCTOR_KEY_CMD_UNSET is NOT set"),
        "and the reader is told which variable to export: {report}"
    );
}

/// A repository site policy refuses is a repository `doctor` mints nothing for.
///
/// `check` establishes that a refused repository never runs its `api_key_command`,
/// and the two commands have to agree about the same checkout: a `doctor` that ran
/// the helper anyway would spend a real credential call - and trigger whatever
/// biometric or approval prompt sits behind it - on behalf of a review that will
/// not happen. The sentinel is what makes "did not run" checkable; asserting on the
/// wording alone would also pass if the helper ran and its result was discarded.
#[tokio::test]
async fn a_refused_repository_is_not_probed_for_a_credential() {
    let dir = tempfile::tempdir().expect("tempdir");
    crate::test_support::git_init(dir.path());
    let sentinel = dir.path().join("command-ran");
    let stub = dir.path().join("print-token");
    write_executable(
        &stub,
        format!(
            "#!/bin/sh\nprintf '%s' ran > {}\nprintf '%s' tok\n",
            sentinel.to_string_lossy()
        ),
    );
    write_config_running(dir.path(), &format!("{:?}", stub.to_string_lossy()));
    let policy = write_site_policy(dir.path(), &[".drep-no-llm"]);
    std::fs::write(dir.path().join(".drep-no-llm"), "").expect("marker");

    let report = report_with_policy(dir.path(), &policy).await;

    assert!(
        !sentinel.exists(),
        "the helper ran for a repository whose review is refused: {report}"
    );
    assert!(
        report.contains("not attempted, because site policy refuses semantic review here"),
        "and the reader has to be told why the line says nothing about the helper: {report}"
    );
}

/// A refused run never opens the HTTP credential store either.
///
/// The store may be corrupt while remaining irrelevant to a repository whose
/// semantic layer is structurally absent. Doctor should report the policy
/// refusal, not a setup failure `check` never reaches.
#[tokio::test]
async fn a_refused_repository_does_not_read_the_auth_store() {
    let dir = tempfile::tempdir().expect("tempdir");
    crate::test_support::git_init(dir.path());
    write_config_running(dir.path(), "\"unused-helper\"");
    std::fs::write(dir.path().join("auth.toml"), "not valid toml {{{").expect("corrupt store");
    let policy = write_site_policy(dir.path(), &[".drep-no-llm"]);
    std::fs::write(dir.path().join(".drep-no-llm"), "").expect("marker");

    let report = report_with_policy(dir.path(), &policy).await;

    assert!(
        report.contains("site policy refuses semantic review"),
        "got {report}"
    );
    assert!(
        !report.contains("auth store could not be read"),
        "doctor opened state the refused check never reaches: {report}"
    );
}

/// The discriminating half: the same fixture without the marker really does probe.
///
/// Without it, "never probe when a policy names markers" passes the test above.
#[tokio::test]
async fn an_unmarked_repository_under_a_marker_policy_is_still_probed() {
    let dir = tempfile::tempdir().expect("tempdir");
    crate::test_support::git_init(dir.path());
    let sentinel = dir.path().join("command-ran");
    let stub = dir.path().join("print-token");
    write_executable(
        &stub,
        format!(
            "#!/bin/sh\nprintf '%s' ran > {}\nprintf '%s' tok\n",
            sentinel.to_string_lossy()
        ),
    );
    write_config_running(dir.path(), &format!("{:?}", stub.to_string_lossy()));
    let policy = write_site_policy(dir.path(), &[".drep-no-llm"]);

    let report = report_with_policy(dir.path(), &policy).await;

    assert!(sentinel.exists(), "got {report}");
    assert!(
        report.contains("the command ran and printed a credential"),
        "got {report}"
    );
}

/// A policy that will not parse must not mint a credential either.
///
/// `check` exits 2 on an unloadable policy without contacting anything, so
/// probing here would make `doctor` the way to spend a real credential call - and
/// trigger whatever approval sits behind it - for a repository whose review never
/// happens. The state used to be indistinguishable from "permitted": the LLM
/// block was handed a `bool` meaning "refused", and an unloadable policy said
/// `false`.
#[tokio::test]
async fn an_unloadable_policy_is_not_probed() {
    let dir = tempfile::tempdir().expect("tempdir");
    crate::test_support::git_init(dir.path());
    let sentinel = dir.path().join("command-ran");
    let stub = dir.path().join("print-token");
    write_executable(
        &stub,
        format!(
            "#!/bin/sh\nprintf '%s' ran > {}\nprintf '%s' tok\n",
            sentinel.to_string_lossy()
        ),
    );
    write_config_running(dir.path(), &format!("{:?}", stub.to_string_lossy()));
    let policy = dir.path().join("site.toml");
    std::fs::write(&policy, "refuse_markers = \"not a list\"\n").expect("site.toml");

    let report = report_with_policy(dir.path(), &policy).await;

    assert!(
        !sentinel.exists(),
        "the helper ran for a repository whose policy could not be evaluated: {report}"
    );
    assert!(
        report.contains("not attempted, because the site policy above could not be evaluated"),
        "got {report}"
    );
}

/// The same rule for the other unevaluable state: the marker probe could not
/// resolve a repository root, so nobody knows whether a marker applies.
#[tokio::test]
async fn a_policy_whose_marker_probe_cannot_resolve_a_root_is_not_probed() {
    let dir = tempfile::tempdir().expect("tempdir");
    crate::test_support::git_unresolvable(dir.path());
    let sentinel = dir.path().join("command-ran");
    let stub = dir.path().join("print-token");
    write_executable(
        &stub,
        format!(
            "#!/bin/sh\nprintf '%s' ran > {}\nprintf '%s' tok\n",
            sentinel.to_string_lossy()
        ),
    );
    write_config_running(dir.path(), &format!("{:?}", stub.to_string_lossy()));
    let policy = write_site_policy(dir.path(), &[".drep-no-llm"]);

    let report = report_with_policy(dir.path(), &policy).await;

    assert!(
        !sentinel.exists(),
        "the helper ran for a repository whose marker probe could not be evaluated: {report}"
    );
    assert!(
        report.contains("not attempted, because the site policy above could not be evaluated"),
        "got {report}"
    );
}