lernie 0.1.62

//! The model: the address a channel resolves, the door a reply comes in
//! through, and the notice that stands where content would have been.

use super::{Channel, Chunk, Model, Notice};
use crate::reply::roster::Workspaces;
use crate::reply::{Outcome, Read, Reply, read};
use crate::test_support::window::{own, wall};
use serde_json::json;

/// **The three addressing cases, and the third is a real one.** This box's own
/// engine rewrites nothing; an entry resolves by its leaf and by nothing else;
/// and an entry's engine may answer a row the entry does not name, which no
/// envelope this seat can write will reach.
#[test]
fn a_channel_says_what_a_gesture_must_carry_or_that_it_cannot_say() {
    let flat = Channel {
        name: "(this box's own engine)".to_owned(),
        named_there: None,
        dials: None,
    };
    assert_eq!(flat.address(&wall("home")), Some("home".to_owned()));
    let entry = Channel {
        name: "home".to_owned(),
        named_there: Some("personal".to_owned()),
        dials: None,
    };
    assert_eq!(entry.address(&wall("personal")), Some("home".to_owned()));
    assert_eq!(entry.address(&wall("somebody-elses")), None);
}

/// **Nothing that arrives is dropped.** An answer is filed; a refusal and an
/// unreadable frame become the notice the shell paints where that content would
/// have been, and they read differently because only one of them is fixed by an
/// upgrade.
#[test]
fn every_frame_becomes_content_or_a_visible_notice() {
    let mut model = Model::default();
    let flat = own().channel;
    model.absorb(
        &flat,
        read(&json!({"ok": false, "error": "unknown workspace"})),
    );
    assert_eq!(
        model.notice,
        Some(Notice::Refused("unknown workspace".to_owned()))
    );
    model.absorb(
        &flat,
        read(&json!({"ok": true, "kind": "invocations", "rows": []})),
    );
    let Some(Notice::Unreadable(why)) = &model.notice else {
        panic!("an unpainted kind is this seat's own sentence");
    };
    assert!(why.contains("\"invocations\""), "{why}");
    assert!(
        model
            .notice
            .as_ref()
            .expect("a notice")
            .line()
            .contains("this seat")
    );
}

/// A roster answer replaces **its own channel's** rows and leaves every other
/// channel standing — a box serving three engines does not lose the two that
/// are fine.
#[test]
fn a_roster_answer_replaces_one_channel_and_leaves_the_others() {
    let mut model = Model {
        roster: vec![own()],
        ..Model::default()
    };
    let other = Channel {
        name: "elsewhere".to_owned(),
        named_there: Some("elsewhere".to_owned()),
        dials: None,
    };
    model.absorb(
        &other,
        Read::Answer(Reply::Workspaces(Workspaces {
            rows: vec![wall("theirs")],
            stale: Some("4m behind".to_owned()),
            growth: None,
        })),
    );
    assert_eq!(model.roster.len(), 2);
    assert_eq!(model.roster[0], own(), "the first channel is untouched");
    assert_eq!(model.roster[1].stale.as_deref(), Some("4m behind"));
    // A second answer down the same channel replaces rather than piles up.
    model.absorb(
        &other,
        Read::Answer(Reply::Workspaces(Workspaces::default())),
    );
    assert_eq!(model.roster.len(), 2);
    assert!(model.roster[1].walls.is_empty());
    assert_eq!(model.roster[1].stale, None);
}

/// The four content kinds land in the four panes.
#[test]
fn each_kind_lands_in_the_pane_that_paints_it() {
    let mut model = Model::default();
    let flat = own().channel;
    model.absorb(
        &flat,
        read(&json!({"ok": true, "kind": "conversations", "rows": [
            {"root_id": "a", "display": "one", "state": "live", "uncertain": false, "preview": "",
             "age_secs": 0, "attention": 0, "members": 1, "depth": 0, "tone": "live"}]})),
    );
    assert_eq!(model.convs.len(), 1);
    model.absorb(
        &flat,
        read(&json!({"ok": true, "kind": "transcript", "rows": [
            {"name": "001-op.md", "raw": "hi", "kind": "delivered",
             "sender": "op", "body": "hi"}]})),
    );
    assert_eq!(model.transcript.entries.len(), 1);
    model.absorb(
        &flat,
        read(&json!({"ok": true, "kind": "follow", "tools": [], "stream": {"text": "so far"}})),
    );
    assert_eq!(
        model.live.as_ref().and_then(|s| s.text.clone()),
        Some("so far".to_owned())
    );
}

/// **The two receipts, and a captured run that failed is told in the child's
/// own words.** A receipt with nothing to say clears the last notice; one that
/// says the act did not land replaces it.
#[test]
fn a_receipt_either_clears_the_notice_or_carries_the_child_s_own_refusal() {
    let mut model = Model {
        notice: Some(Notice::Refused("stale".to_owned())),
        ..Model::default()
    };
    let flat = own().channel;
    model.absorb(&flat, Read::Answer(Reply::Nudged));
    assert_eq!(model.notice, None);
    model.absorb(
        &flat,
        Read::Answer(Reply::Outcome(Outcome {
            exit: 1,
            stdout: String::new(),
            stderr: "the gate said no".to_owned(),
        })),
    );
    assert_eq!(
        model.notice,
        Some(Notice::Refused("the gate said no".to_owned()))
    );
    model.absorb(
        &flat,
        Read::Answer(Reply::Outcome(Outcome {
            exit: 0,
            stdout: "deposited".to_owned(),
            stderr: String::new(),
        })),
    );
    assert_eq!(model.notice, None);
}

/// A channel with nothing behind it yet is what the roster holds before any
/// answer has come down it — which is what a box that has never been asked
/// shows, and it is not the same as a channel that answered nothing.
#[test]
fn a_channel_can_be_held_before_it_has_answered() {
    let held = Chunk::of(own().channel);
    assert!(held.walls.is_empty());
    assert_eq!(held.stale, None);
}

/// **The capability boundary's two receipts carry a FACT, so each becomes the
/// bar's own line** (bl-bce2) — the sixth kind of notice, and the first that
/// is not a failure.
///
/// The two halves that matter are asserted here rather than in the sentence:
/// an answer says whether the conversation is running again, and a floor says
/// whether one **stands** — which is the engine's re-derivation, so a
/// `restore` under a still-floored ancestor reads as still floored.
#[test]
fn the_boundary_s_two_receipts_become_the_bar_s_one_line() {
    let mut model = Model::default();
    let flat = own().channel;
    model.absorb(
        &flat,
        Read::Answer(Reply::Answered {
            tool: "Bash".to_owned(),
            tool_use: "toolu_1".to_owned(),
            verdict: "pass".to_owned(),
            scope: "conversation".to_owned(),
            advanced: true,
        }),
    );
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(
        said.contains("answered Bash (toolu_1): pass for this conversation"),
        "the reach the boundary took is the receipt's, not an echo of the ask: {said}"
    );
    assert!(said.contains("running again"), "{said}");

    model.absorb(
        &flat,
        Read::Answer(Reply::Answered {
            tool: "Bash".to_owned(),
            tool_use: "toolu_1".to_owned(),
            verdict: "hold".to_owned(),
            scope: "call".to_owned(),
            advanced: false,
        }),
    );
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(said.contains("stays parked"), "{said}");

    model.absorb(&flat, Read::Answer(Reply::Floored { standing: true }));
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(
        said.contains("a floor stands over this conversation"),
        "{said}"
    );

    model.absorb(&flat, Read::Answer(Reply::Floored { standing: false }));
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(said.contains("the floor is lifted"), "{said}");
}

/// **The candidate family's two receipts become the bar's one line**, and each
/// optional identity is a FACT rather than a blank: no commit means the
/// delivery landed nothing, no source ref means there was none, and whether a
/// retirement also took the ref is the project's own declared retention — the
/// engine's answer, never this seat's prediction (§4.36).
#[test]
fn the_candidate_family_s_two_receipts_become_the_bar_s_one_line() {
    let mut model = Model::default();
    let flat = own().channel;
    model.absorb(
        &flat,
        Read::Answer(Reply::Delivered {
            base: "aaa1".to_owned(),
            target: "work/bl-1".to_owned(),
            source: Some("attempt/at-1".to_owned()),
            commit: Some("ccc3".to_owned()),
        }),
    );
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(said.contains("delivered onto work/bl-1 at ccc3"), "{said}");
    assert!(said.contains("from attempt/at-1"), "{said}");
    assert!(said.contains("the ball is not closed"), "{said}");

    model.absorb(
        &flat,
        Read::Answer(Reply::Delivered {
            base: "aaa1".to_owned(),
            target: "main".to_owned(),
            source: None,
            commit: None,
        }),
    );
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(said.contains("nothing landed"), "{said}");
    assert!(said.contains("no source ref"), "{said}");

    model.absorb(&flat, Read::Answer(Reply::Retired { discarded: false }));
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(said.contains("still addressable"), "{said}");

    model.absorb(&flat, Read::Answer(Reply::Retired { discarded: true }));
    let said = model.notice.clone().expect("a receipt is a line").line();
    assert!(said.contains("the keep had expired"), "{said}");
}

/// **The spread's answer reaches the model through the one door**, and what it
/// does there is compose the fires — §4.26's argument read over n.
#[test]
fn a_fanned_answer_composes_one_fire_per_candidate() {
    let mut model = Model::default();
    let row = crate::reply::start::Prepared {
        workspace: "there".to_owned(),
        goal: "the rung's own prefill".to_owned(),
        body: serde_json::json!({"goal": "the rung's own prefill", "workspace": "there"}),
    };
    model.absorb(
        &own().channel,
        Read::Answer(Reply::Fanned(vec![row.clone(), row])),
    );
    assert_eq!(model.outbox.len(), 2);
}