mindfork 0.19.0

//! Runtime — input batching and clipboard paste (Windows path): key coalescing, Chunk, reconciliation against the clipboard. Part of the [`super`] module, split out of the
//! runtime.rs monolith (see docs/history/refactoring-god-objects.md, stage 7).

use super::*;

/// The "burst" threshold for events in a single drain, at which we suspect a paste and
/// chase its tail (see `run_loop`). A human doesn't type that many keys in one
/// zero-timeout drain — several events at once mean a paste.
pub(super) const PASTE_BURST: usize = 2;

/// The pause detector for the end of a paste. On Windows a large paste arrives in
/// several chunks through the console buffer, and the loop drains them over different
/// iterations — at a chunk boundary a character run would break, and a lone `Enter`
/// at the boundary would slip through as a send. While events keep arriving with a gap
/// smaller than this threshold, we treat them as one paste; real human typing has
/// pauses much larger than that (>100ms reaction time).
pub(super) const PASTE_GAP: Duration = Duration::from_millis(20);

/// Reconciles a paste reconstructed from key events against the clipboard and, if it's
/// the same paste, returns its full version from the clipboard (with emoji restored).
///
/// **Why (Windows):** when pasting from the clipboard, the Windows console delivers the
/// text as ordinary key events, and crossterm 0.29 **loses** supplementary-plane
/// characters (emoji like 😊, U+1F60A): they're encoded as a UTF-16 surrogate pair, and
/// the console's key-down/key-up records break the pair assembly in crossterm — the
/// character is lost before it even reaches our layer. BMP characters (letters, ❤
/// U+2764, the U+FE0F selector) pass through. So the reconstruction = the paste minus
/// supplementary-plane emoji.
///
/// To recover the emoji, we read the clipboard and check: if we drop from it exactly the
/// characters the console loses (code points > U+FFFF), and normalize line breaks/tabs,
/// does it match the reconstruction? A match → it's the same paste, we hand out the full
/// clipboard text. No match (a stale clipboard/a different paste/unavailable) → the
/// reconstruction (without emoji, but with no risk of pasting someone else's data). On
/// non-Windows this is the identity function (a correct bracketed paste `Event::Paste`
/// arrives there).
#[cfg(windows)]
pub(super) fn reconcile_paste(
    reconstructed: String,
    clipboard: &mut Option<arboard::Clipboard>,
) -> String {
    match read_clipboard_text(clipboard) {
        Some(clip) if paste_projection_matches(&clip, &reconstructed) => clip,
        _ => reconstructed,
    }
}

/// On non-Windows a paste arrives as correct UTF-8 (`Event::Paste`) — no reconciliation needed.
#[cfg(not(windows))]
pub(super) fn reconcile_paste(
    reconstructed: String,
    _clipboard: &mut Option<arboard::Clipboard>,
) -> String {
    reconstructed
}

/// Does the clipboard match the paste reconstruction by its "BMP projection" (a pure
/// function, testable with no clipboard/terminal). Characters the Windows console loses
/// (code points > U+FFFF — surrogate pairs) are dropped from the clipboard, then both
/// sides are normalized on line breaks/tabs (as in [`InputBox::insert_str`]). See
/// [`reconcile_paste`].
#[cfg(windows)]
pub(super) fn paste_projection_matches(clipboard: &str, reconstructed: &str) -> bool {
    fn normalize(s: &str) -> String {
        s.replace("\r\n", "\n")
            .replace('\r', "\n")
            .replace('\t', "    ")
    }
    let projected: String = clipboard
        .chars()
        .filter(|c| (*c as u32) <= 0xFFFF)
        .collect();
    !reconstructed.is_empty() && normalize(&projected) == normalize(reconstructed)
}

/// Puts an event into the batch, dropping "release"/repeat key events: the app
/// ignores them anyway (`handle_key` only takes `Press`), and during paste coalescing
/// they would break the character run between keypresses (on Windows a paste arrives as
/// down/up pairs). Mouse/resize/`Paste` are passed through as is.
pub(super) fn collect_press(batch: &mut Vec<Event>, ev: Event) {
    if let Event::Key(k) = &ev
        && k.kind != KeyEventKind::Press
    {
        return;
    }
    batch.push(ev);
}

/// A character for paste coalescing: a text key / Enter / Tab without Ctrl/Alt.
/// `Enter → '\r'` (CRLF from the clipboard later collapses in `InputBox::insert_str`),
/// `Tab → '\t'`. Returns `None` for everything else (arrows, Ctrl shortcuts,
/// function keys) — those break the paste run.
pub(super) fn paste_char(key: &KeyEvent) -> Option<char> {
    if key.kind != KeyEventKind::Press
        || key
            .modifiers
            .intersects(KeyModifiers::CONTROL | KeyModifiers::ALT)
    {
        return None;
    }
    match key.code {
        KeyCode::Char(c) => Some(c),
        KeyCode::Enter => Some('\r'),
        KeyCode::Tab => Some('\t'),
        _ => None,
    }
}

/// A piece of the input batch: either a coalesced paste (a run of ≥2 text keys), or
/// a single event (a regular key/mouse/unix `Paste`).
pub(crate) enum Chunk {
    Paste(String),
    Event(Event),
}

/// Splits an event batch into chunks, coalescing consecutive text keys
/// (see [`paste_char`]) into a single paste when there are ≥2 of them. A pure function —
/// testable with no screen/terminal. A run of length 1 (regular character typing / a
/// single Enter) stays a single event, so Enter still works as a send.
pub(crate) fn chunk_batch(batch: Vec<Event>) -> Vec<Chunk> {
    let mut out = Vec::new();
    let mut iter = batch.into_iter().peekable();
    while let Some(ev) = iter.next() {
        if let Event::Key(key) = &ev
            && let Some(first) = paste_char(key)
        {
            let mut run = String::new();
            run.push(first);
            while let Some(Event::Key(k)) = iter.peek() {
                match paste_char(k) {
                    Some(c) => {
                        run.push(c);
                        iter.next();
                    }
                    None => break,
                }
            }
            if run.chars().count() >= 2 {
                out.push(Chunk::Paste(run));
                continue;
            }
            // A run of one key — hand it out as a regular event (below).
        }
        out.push(Chunk::Event(ev));
    }
    out
}

/// Whether a batch read under the "window too small" placeholder asks to
/// quit (spec §11.1.1, docs/research/small-terminal.md F2).
///
/// The two quit keys are the ones every screen answers to (spec §11.7),
/// matched the way the screens match them — `Ctrl+Q` by the physical key, so
/// it works under any layout.
pub(super) fn quit_requested(batch: &[Event]) -> bool {
    batch.iter().any(|event| match event {
        Event::Key(key) if key.kind == KeyEventKind::Press => {
            key.code == KeyCode::F(10)
                || (key.modifiers.contains(KeyModifiers::CONTROL)
                    && crate::shared::keys::hotkey_char(key) == Some('q'))
        }
        _ => false,
    })
}

/// One batch of terminal events, read against the frame that was on screen
/// when they were made. A screen takes all of it. The placeholder takes the
/// keys it names and drops the rest: the screen a key was meant for is not
/// the one on the terminal, so `Enter` would run a tool call whose question
/// nobody read and a typed line would be sent unseen.
///
/// * a quit key quits, whatever else is in the batch;
/// * **one** `Esc` reaches the layer in front, where the placeholder says it
///   does ([`WayOut::EscOrQuit`]) — it closes a popup, declines a question,
///   leaves a screen. One per batch: the second would act on whatever the
///   first uncovered, before a frame of it was drawn.
///
/// Apart from the tick that reads the terminal, so that the rule has a test.
/// Returns `true` if quitting was requested.
// The loop's state, one borrow each, and the frame's verdict.
#[allow(clippy::too_many_arguments)]
pub(super) fn route_batch(
    placeholder: Option<WayOut>,
    batch: Vec<Event>,
    screen: &mut ChatScreen,
    active: &mut ActiveScreen,
    help: &mut HelpOverlay,
    back: &mut Option<Back>,
    cmd_tx: &UnboundedSender<AppCommand>,
    clipboard: &mut Option<arboard::Clipboard>,
) -> bool {
    let Some(way_out) = placeholder else {
        return process_input_batch(batch, screen, active, help, back, cmd_tx, clipboard);
    };
    if quit_requested(&batch) {
        return true;
    }
    let esc = batch.into_iter().find(|event| {
        matches!(event, Event::Key(key)
            if key.kind == KeyEventKind::Press
                && key.code == KeyCode::Esc
                && key.modifiers.is_empty())
    });
    match (way_out, esc) {
        (WayOut::EscOrQuit, Some(esc)) => {
            process_input_batch(vec![esc], screen, active, help, back, cmd_tx, clipboard)
        }
        _ => false,
    }
}

/// Processes a batch of terminal events in one pass. Coalesced pastes
/// go into the active editor (the settings screen) or into the chat's input box as
/// text — never sending, even if they contain line breaks. Single events — the regular way.
/// Returns `true` if quitting was requested.
pub(super) fn process_input_batch(
    batch: Vec<Event>,
    screen: &mut ChatScreen,
    active: &mut ActiveScreen,
    help: &mut HelpOverlay,
    back: &mut Option<Back>,
    cmd_tx: &UnboundedSender<AppCommand>,
    clipboard: &mut Option<arboard::Clipboard>,
) -> bool {
    let mut quit = false;
    for chunk in chunk_batch(batch) {
        match chunk {
            // The help overlay is modal: it has no paste target, and a wheel
            // or click would act on a screen the dialog is covering — the same
            // rule the chat applied while it owned the dialog.
            Chunk::Paste(_) | Chunk::Event(Event::Paste(_) | Event::Mouse(_))
                if help.open.is_some() => {}
            // A clipboard paste: on the settings screen — into the active field editor; in
            // the chat — into the input box (never sends); the list has no paste target.
            // `Chunk::Paste` — a reconstruction from key events (Windows); we reconcile it
            // against the clipboard to recover crossterm's lost supplementary-plane
            // emoji (see [`reconcile_paste`]). `Event::Paste` — a real
            // bracketed paste (unix), already correct UTF-8.
            Chunk::Paste(text) | Chunk::Event(Event::Paste(text)) => {
                // `Chunk::Paste` — a reconstruction from key events (Windows); we reconcile it
                // against the clipboard to recover the emoji (see [`reconcile_paste`]).
                // Routing by screen is handled by `ActiveScreen::handle_paste`.
                let text = reconcile_paste(text, clipboard);
                active.handle_paste(screen, &text);
            }
            Chunk::Event(Event::Key(key)) => {
                if handle_key_event(key, screen, active, help, back, cmd_tx, clipboard) {
                    quit = true;
                }
            }
            // The mouse wheel scrolls the chat feed, and a left click can land on a
            // `chat://` reference (spec §11.3). On the list/settings (which have their
            // own navigation) mouse events are ignored.
            Chunk::Event(Event::Mouse(mouse)) if active.is_chat() => {
                if let Some(intent) = screen.handle_mouse(mouse) {
                    flush_draft(screen, cmd_tx);
                    if dispatch(intent, cmd_tx, screen, active, back) {
                        quit = true;
                    }
                }
            }
            Chunk::Event(_) => {}
        }
    }
    quit
}

/// Sends the chat input's pending draft **before** an intent is dispatched, so
/// the orchestrator never reads a stale one. The loop's own flush runs at the
/// top of the *next* iteration, one step after the intent — and every handler
/// that reads `chat.draft` in between saw the previous text: `/takeback` glued
/// the spent command onto the restored message, `/regen` re-loaded it into the
/// box via `ChatActivated`, `/clone` copied it into the clone, and `/new` left
/// it as the old chat's saved draft (the late `SetDraft` lands on the newly
/// active chat). One seam closes the class; see docs/history/commands-stage3.md §2.
fn flush_draft(screen: &mut ChatScreen, cmd_tx: &UnboundedSender<AppCommand>) {
    if let Some(draft) = screen.take_dirty_draft() {
        let _ = cmd_tx.send(AppCommand::SetDraft(draft));
    }
}

/// Handles one key event: the help overlay first (it is modal above every
/// screen, and `F1` opens it from any of them — no screen keeps an `F1`
/// handler of its own, spec §11.7); otherwise takes the intent off the active
/// screen and dispatches it — including the `CopyToClipboard` special case, a
/// UI-layer side effect executed right here. Returns `true` if quitting was
/// requested.
fn handle_key_event(
    key: KeyEvent,
    screen: &mut ChatScreen,
    active: &mut ActiveScreen,
    help: &mut HelpOverlay,
    back: &mut Option<Back>,
    cmd_tx: &UnboundedSender<AppCommand>,
    clipboard: &mut Option<arboard::Clipboard>,
) -> bool {
    if let Some(state) = help.open.as_mut() {
        return match state.handle_key(&key) {
            HelpKeyOutcome::Quit => true,
            HelpKeyOutcome::Close => {
                help.close();
                false
            }
            HelpKeyOutcome::Handled => false,
        };
    }
    // `F1` opens the help wherever the user is — even inside a sub-mode
    // (a rename field, an armed confirmation): the dialog is read-only, and
    // the sub-mode's state is exactly as they left it on `Esc`. It is the only
    // help *key*; the chat's `/help` arrives as [`ChatIntent::OpenHelp`] below.
    if key.code == KeyCode::F(1) {
        help.open_for(help_context(active));
        return false;
    }
    // Take the intent off the active screen (the borrow ends at the
    // owned `AnyIntent` value), then dispatch through a single ownership —
    // otherwise `active`/`screen` borrows would conflict.
    let intent = match active {
        ActiveScreen::Chat => screen.handle_key(key).map(AnyIntent::Chat),
        ActiveScreen::ChatList(list) => list.handle_key(key).map(AnyIntent::List),
        ActiveScreen::Settings(settings) => settings.handle_key(key).map(AnyIntent::Settings),
        ActiveScreen::SelfModel(view) => view.handle_key(key).map(AnyIntent::SelfModel),
        ActiveScreen::Search(search) => search.handle_key(key).map(AnyIntent::Search),
        ActiveScreen::Changes(changes) => changes.handle_key(key).map(AnyIntent::Changes),
        ActiveScreen::Tasks(tasks) => tasks.handle_key(key).map(AnyIntent::Tasks),
    };
    if intent.is_some() {
        flush_draft(screen, cmd_tx);
    }
    match intent {
        // Copying the selection to the clipboard (`Ctrl+C`/`Ctrl+X`) —
        // a UI-layer side effect: we already have the text, no need to go to the orchestrator.
        // The `arboard` slot is here (`dispatch` doesn't have it). Success is silent,
        // a failure (headless Linux with no X11) — a note in the feed.
        Some(AnyIntent::Chat(ChatIntent::CopyToClipboard(text))) => {
            let report = copy_text(clipboard, &text, screen.clipboard_osc52());
            // Success stays silent here, as it always has: a note on every
            // `Ctrl+C` would be noise. The exception is the terminal's half —
            // an unacknowledged protocol is worth one line, since the user has
            // no other way to learn it was even attempted.
            let (message, failed) = report.message(screen.loc());
            match report {
                CopyReport {
                    local: Ok(()),
                    terminal: TerminalCopy::NotTried,
                } => {}
                _ if failed => screen.push_error(&message),
                _ => screen.push_note(&message),
            }
            false
        }
        // Pasting from the clipboard (`Ctrl+V`, `/image paste`) — the same reasoning as
        // above: only this function holds the `arboard` client, so the read happens here
        // and the orchestrator receives pixels rather than a request to go and look.
        Some(AnyIntent::Chat(ChatIntent::PasteImage { text_fallback })) => {
            paste_from_clipboard(text_fallback, screen, active, cmd_tx, clipboard);
            false
        }
        // The chat's typed `/help` routes into the overlay, which lives here,
        // beside the `F1` interception above, not in `dispatch` (which turns
        // intents into orchestrator commands; this one never leaves the UI).
        Some(AnyIntent::Chat(ChatIntent::OpenHelp)) => {
            help.open_for(HelpContext::Chat);
            false
        }
        Some(intent) => dispatch_any(intent, cmd_tx, screen, active, back),
        None => false,
    }
}

/// Stages the clipboard's image, or falls back per `text_fallback` (see
/// [`ChatIntent::PasteImage`]).
///
/// The order matters: an image is checked **first**, because a screenshot copied from a
/// browser often puts both an image and its alt text on the clipboard, and the image is
/// what the user meant by pressing paste on it.
fn paste_from_clipboard(
    text_fallback: bool,
    screen: &mut ChatScreen,
    active: &mut ActiveScreen,
    cmd_tx: &UnboundedSender<AppCommand>,
    clipboard: &mut Option<arboard::Clipboard>,
) {
    if let Some((width, height, rgba)) = clipboard_image(clipboard) {
        let _ = cmd_tx.send(AppCommand::ImagePaste(Box::new(ClipboardImage {
            width,
            height,
            rgba,
        })));
        return;
    }
    if text_fallback {
        // No image: behave exactly as a paste always has. On a terminal that forwards
        // Ctrl+V this is what makes the key do what the help overlay says it does; on one
        // that swallows it, nothing reaches us and the terminal has already pasted.
        if let Some(text) = clipboard_text(clipboard) {
            active.handle_paste(screen, &text);
        }
        return;
    }
    // A typed `/image paste` with nothing to paste: say so, and name the route that does
    // not depend on the clipboard at all.
    let loc = screen.loc();
    screen.set_image_progress(crate::features::image_command::ImageProgress::Failed(
        loc.t("ui.err.image_no_clipboard").to_string(),
    ));
}