//! Every `--json` output is one JSON document on stdout and nothing else
//! (as `oxy`'s are), with and without the daemon; and `spectra say` with
//! `spectra inbox --follow` work as a terminal chat with the agents.

mod common;

use common::{add_agent, hermetic, run, setup, text, Serving};
use serde_json::{json, Value};
use spectra_mcp::client::Client;
use std::io::{BufRead, BufReader};
use std::process::Stdio;
use std::time::Duration;

fn json_of(d: &std::path::Path, args: &[&str]) -> Value {
    let o = run(d, args);
    assert!(o.status.success(), "{args:?}: {}", text(&o));
    serde_json::from_slice(&o.stdout)
        .unwrap_or_else(|e| panic!("{args:?} printed more than one JSON document ({e}): {}", String::from_utf8_lossy(&o.stdout)))
}

#[test]
fn every_json_output_parses_without_the_daemon() {
    let dir = setup();
    let d = dir.path();
    add_agent(d, "claude-oxygen", &[]);
    assert_eq!(json_of(d, &["version", "--json"])["ledger_format"], 1);
    assert_eq!(json_of(d, &["identity", "show", "--json"])["owner"]["name"], "Andy McCall");
    assert_eq!(json_of(d, &["agent", "list", "--json"])[0]["name"], "claude-oxygen");
    assert_eq!(json_of(d, &["project", "list", "--json"])[0]["name"], "oxygen");
    let posted = json_of(d, &["say", "--json", "-c", "general", "the release is tomorrow @claude-oxygen"]);
    assert_eq!(posted["channel"], "#general");
    assert!(json_of(d, &["inbox", "--json"]).as_array().unwrap().is_empty());
    assert_eq!(json_of(d, &["search", "--json", "release"]).as_array().unwrap().len(), 1);
    let v = json_of(d, &["admin", "verify", "--json"]);
    assert!(v["findings"].as_array().unwrap().is_empty(), "a CLI post verifies: {v}");
}

#[tokio::test]
async fn a_terminal_chat_with_the_agents() {
    let dir = setup();
    let d = dir.path();
    let claude = add_agent(d, "claude-oxygen", &[]);
    let srv = Serving::start(d);
    let a = Client::new(&srv.socket, Some(claude));

    // Through the running daemon: say, and the api proxy.
    assert_eq!(json_of(d, &["say", "--json", "hello from the terminal"])["channel"], "#general");
    let api: Value = serde_json::from_slice(&run(d, &["api", "GET", "/api/v1/brief"]).stdout).unwrap();
    assert_eq!(api["actor"], "human");

    let mut follow = hermetic(d).args(["inbox", "--follow", "--json"]).stdout(Stdio::piped()).stderr(Stdio::null()).spawn().unwrap();
    let mut lines = BufReader::new(follow.stdout.take().unwrap()).lines();
    tokio::time::sleep(Duration::from_millis(500)).await;
    let say = json!({ "jsonrpc": "2.0", "id": 1, "method": "tools/call", "params": { "name": "say", "arguments": { "body": "@andy the build is green", "channel": "general" } } });
    assert_eq!(a.mcp("2025-11-25", &say).await.unwrap().status, 200);
    let got = tokio::task::spawn_blocking(move || lines.next()).await.unwrap().expect("a line").unwrap();
    let item: Value = serde_json::from_str(&got).unwrap();
    assert_eq!(item["from"], "agent:claude-oxygen");
    assert!(item["summary"].as_str().unwrap().contains("the build is green"));
    follow.kill().ok();
    follow.wait().ok();
    srv.stop();
}