//! Mentions by part of a name (spec §10.3): `@kimi` reaches the one agent

//! with that part in its name; a part two agents share reaches nobody.

//! `@channel` reaches the agents who belong in the channel, `@all` every

//! agent.

mod common;

use common::{run, setup, text, Serving};

use serde_json::{json, Value};

use spectra_core::keys::KeyPair;

use spectra_mcp::client::{rpc_result, Client};

async fn call(c: &Client, name: &str, args: Value) -> Value {

    let req = json!({ "jsonrpc": "2.0", "id": 1, "method": "tools/call", "params": { "name": name, "arguments": args } });

    rpc_result(&c.mcp("2025-11-25", &req).await.unwrap()).unwrap()["result"].clone()

}

#[tokio::test]

async fn a_unique_part_of_a_name_is_a_mention() {

    let dir = setup();

    let d = dir.path();

    for p in ["book", "web"] {

        assert!(run(d, &["project", "add", p]).status.success());

    }

    let mut keys = std::collections::HashMap::new();

    for (n, kind, p) in [("kimi-book", "kimi-code", "book"), ("claude-book", "claude-code", "book"), ("claude-web", "claude-code", "web")] {

        let home = d.join("agents").join(n);

        let o = run(d, &["agent", "add", n, "--kind", kind, "--project", p, "--home", home.to_str().unwrap(), "--yes"]);

        assert!(o.status.success(), "{}", text(&o));

        keys.insert(n, KeyPair::load_home(&home).unwrap());

    }

    let srv = Serving::start(d);

    let c = |n: &str| Client::new(&srv.socket, Some(keys[n].clone()));

    call(&c("claude-web"), "say", json!({ "body": "@Kimi and @WEB, and @book: hello", "channel": "general" })).await;

    let unread = |r: Value| r["structuredContent"]["items"].as_array().map(|a| a.len()).unwrap_or(0);

    assert_eq!(unread(call(&c("kimi-book"), "inbox", json!({})).await), 1, "@Kimi reaches kimi-book");

    assert_eq!(unread(call(&c("claude-book"), "inbox", json!({})).await), 0, "@book is two agents: nobody");

    // @channel: the agents who belong in #book; @all: everyone.

    assert!(run(d, &["agent", "allow", "claude-web", "--channel", "book"]).status.success());

    call(&c("claude-web"), "say", json!({ "body": "@channel the index moved", "channel": "book" })).await;

    assert_eq!(unread(call(&c("claude-book"), "inbox", json!({})).await), 1, "@channel in #book reaches claude-book");

    assert_eq!(unread(call(&c("kimi-book"), "inbox", json!({})).await), 2, "and kimi-book");

    call(&c("kimi-book"), "say", json!({ "body": "@all heads up", "channel": "general" })).await;

    assert_eq!(unread(call(&c("claude-web"), "inbox", json!({})).await), 1, "@all reaches claude-web too");

    srv.stop();

}