darkfi/bin/app/src/ui/edit/mod.rs

/* This file is part of DarkFi (https://dark.fi)
 *
 * Copyright (C) 2020-2026 Dyne.org foundation
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */

use super::long_press_timeout;
use async_trait::async_trait;
use atomic_float::AtomicF32;
use darkfi::system::msleep;
use darkfi_serial::Decodable;
use futures::FutureExt;
use miniquad::{KeyCode, KeyMods, MouseButton, TouchPhase};
use parking_lot::Mutex as SyncMutex;
use rand::{rngs::OsRng, Rng};
use std::{
    io::Cursor,
    mem::swap,
    sync::{
        atomic::{AtomicBool, Ordering},
        Arc, Weak,
    },
};
use tracing::instrument;

#[cfg(target_os = "android")]
use crate::android::{is_ime_visible, textinput::AndroidTextInputState};
use crate::{
    clipboard,
    gfx::{
        anim::Frame as AnimFrame, gfxtag, DrawCall, DrawInstruction, DrawMesh, ManagedSeqAnimPtr,
        Point, Rectangle, RenderApi, Renderer, Vertex,
    },
    mesh::MeshBuilder,
    prop::{
        BatchGuardPtr, PropertyAtomicGuard, PropertyBool, PropertyColor, PropertyFloat32,
        PropertyPtr, PropertyRect, PropertyStr, PropertyUint32, Role,
    },
    scene::{MethodCallSub, Pimpl, SceneNodePtr, SceneNodeWeak},
    text::{self, Editor},
    ExecutorPtr,
};

const ACTION_COPY: u32 = 0;
const ACTION_PASTE: u32 = 1;
const ACTION_SELALL: u32 = 2;

use super::{DrawUpdate, OnModify, RedrawTrigger, UIObject};

mod action;
mod filter;
use filter::{ALLOWED_KEYCODES, DISALLOWED_CHARS};
mod behave;
pub use behave::BaseEditType;
use behave::{EditorBehavior, MultiLine, ScrollDir, SingleLine};
mod repeat;
use repeat::{PressedKey, PressedKeysSmoothRepeat};

/// The travel threshold on long hold select before activating select.
const HOLD_TRAVEL_THRESHOLD_SQ: f32 = 100.;

/// Minimum dist to update scroll when finger scrolling.
/// Avoid updating too much makes scrolling smoother.
const VERT_SCROLL_UPDATE_INC: f32 = 1.;

/// How often to update the scrolling selection with mouse.
const SELECT_TASK_UPDATE_TIME: u64 = 500;
// Should be a property
const SELECT_SCROLL_TRAVEL_SPEED: f32 = 1.;

macro_rules! d { ($($arg:tt)*) => { debug!(target: "ui::edit", $($arg)*); } }
macro_rules! t { ($($arg:tt)*) => { trace!(target: "ui::edit", $($arg)*); } }

/// Master switch for verbose edit/IME debugging.
/// When true, detailed diagnostics about text content, selection range,
/// compose region, focus state, and touch/keyboard events are emitted to
/// the `ui::edit` log target. Set to false to silence them.
const ENABLE_DEBUG: bool = true;

macro_rules! ed {
    ($($arg:tt)*) => {
        if ENABLE_DEBUG {
            d!($($arg)*);
        }
    };
}

#[derive(Debug, Clone)]
enum TouchStateAction {
    Inactive,
    Started { pos: Point, instant: std::time::Instant },
    StartSelect,
    Select,
    DragSelectHandle { side: isize },
    ScrollVert { start_pos: Point, scroll_start: f32 },
    SetCursorPos,
}

struct TouchInfo {
    state: TouchStateAction,
    scroll: Arc<AtomicF32>,
    scroll_ctrl: ScrollDir,
}

impl TouchInfo {
    fn new(scroll: Arc<AtomicF32>, scroll_ctrl: ScrollDir) -> Self {
        Self { state: TouchStateAction::Inactive, scroll, scroll_ctrl }
    }

    fn start(&mut self, pos: Point) {
        debug!(target: "ui::chatedit::touch", "start touch: Started state");
        self.state = TouchStateAction::Started { pos, instant: std::time::Instant::now() };
    }

    fn stop(&mut self) -> TouchStateAction {
        debug!(target: "ui::chatedit::touch", "stop touch: Inactive state");
        std::mem::replace(&mut self.state, TouchStateAction::Inactive)
    }

    fn update(&mut self, pos: &Point) {
        match &self.state {
            TouchStateAction::Started { pos: start_pos, instant } => {
                let travel_dist_sq = pos.dist_sq(*start_pos);
                let grad = (pos.y - start_pos.y) / (pos.x - start_pos.x);
                let elapsed = instant.elapsed().as_millis();
                //debug!(target: "ui::chatedit::touch", "TouchInfo::update() [travel_dist_sq={travel_dist_sq}, grad={grad}]");

                if travel_dist_sq < HOLD_TRAVEL_THRESHOLD_SQ {
                    if elapsed > long_press_timeout() as u128 {
                        debug!(target: "ui::chatedit::touch", "update touch state: Started -> StartSelect");
                        self.state = TouchStateAction::StartSelect;
                    }
                } else if self.scroll_ctrl.cmp(grad) {
                    // Vertical movement
                    debug!(target: "ui::chatedit::touch", "update touch state: Started -> ScrollVert");
                    let scroll_start = self.scroll.load(Ordering::Relaxed);
                    self.state =
                        TouchStateAction::ScrollVert { start_pos: *start_pos, scroll_start };
                } else {
                    // Horizontal movement
                    debug!(target: "ui::chatedit::touch", "update touch state: Started -> SetCursorPos");
                    self.state = TouchStateAction::SetCursorPos;
                }
            }
            _ => {}
        }
    }
}

pub type BaseEditPtr = Arc<BaseEdit>;

pub struct BaseEdit {
    node: SceneNodeWeak,
    tasks: SyncMutex<Vec<smol::Task<()>>>,
    ex: ExecutorPtr,
    me: Weak<Self>,
    renderer: Renderer,
    redraw: RedrawTrigger,
    key_repeat: SyncMutex<PressedKeysSmoothRepeat>,

    // Moves the draw cursor and applies scroll
    root_dc_key: u64,
    phone_select_handle_dc_key: u64,
    // Applies the clipping view
    content_dc_key: u64,
    select_dc_key: u64,
    text_dc_key: u64,
    cursor_dc_key: u64,
    cursor_anim: SyncMutex<Option<ManagedSeqAnimPtr>>,

    is_active: PropertyBool,
    is_focused: PropertyBool,
    rect: PropertyRect,
    baseline: PropertyFloat32,
    lineheight: PropertyFloat32,
    scroll_speed: PropertyFloat32,
    padding: PropertyPtr,
    font_size: PropertyFloat32,
    text: PropertyStr,
    text_color: PropertyColor,
    text_hi_color: PropertyColor,
    placeholder_text: PropertyStr,
    placeholder_color: PropertyColor,
    //text_cmd_color: PropertyColor,
    cursor_color: PropertyColor,
    cursor_width: PropertyFloat32,
    cursor_ascent: PropertyFloat32,
    cursor_descent: PropertyFloat32,
    cursor_blink_time: PropertyUint32,
    cursor_idle_time: PropertyUint32,
    hi_bg_color: PropertyColor,
    //cmd_bg_color: PropertyColor,
    select_ascent: PropertyFloat32,
    select_descent: PropertyFloat32,
    handle_descent: PropertyFloat32,
    select_text: PropertyPtr,
    z_index: PropertyUint32,
    priority: PropertyUint32,
    debug: PropertyBool,

    android_input_type: PropertyUint32,

    action_fg_color: PropertyColor,
    action_bg_color: PropertyColor,
    action_padding: PropertyFloat32,
    action_spacing: PropertyFloat32,

    mouse_btn_held: AtomicBool,
    /// Used to explicitly hide the cursor. Must be manually re-enabled.
    hide_cursor: AtomicBool,
    /// Used to start select and scroll when mouse moves outside widget rect.
    sel_sender: SyncMutex<Option<async_channel::Sender<Option<(Point, Option<isize>)>>>>,
    scroll: Arc<AtomicF32>,

    touch_info: SyncMutex<TouchInfo>,
    is_phone_select: AtomicBool,

    parent_rect: Arc<SyncMutex<Option<Rectangle>>>,
    window_scale: PropertyFloat32,
    is_mouse_hover: AtomicBool,
    action_mode: action::ActionMode,

    editor: Arc<SyncMutex<Editor>>,
    behave: Box<dyn EditorBehavior>,
}

impl BaseEdit {
    pub async fn new(
        node: SceneNodeWeak,
        window_scale: PropertyFloat32,
        renderer: Renderer,
        redraw: RedrawTrigger,
        edit_type: BaseEditType,
        ex: ExecutorPtr,
    ) -> Pimpl {
        let node_ref = &node.upgrade().unwrap();
        let is_active = PropertyBool::wrap(node_ref, Role::Internal, "is_active", 0).unwrap();
        let is_focused = PropertyBool::wrap(node_ref, Role::Internal, "is_focused", 0).unwrap();
        let rect = PropertyRect::wrap(node_ref, Role::Internal, "rect").unwrap();
        let baseline = PropertyFloat32::wrap(node_ref, Role::Internal, "baseline", 0).unwrap();
        let lineheight = PropertyFloat32::wrap(node_ref, Role::Internal, "lineheight", 0).unwrap();
        let scroll_speed =
            PropertyFloat32::wrap(node_ref, Role::Internal, "scroll_speed", 0).unwrap();
        let padding = node_ref.get_property("padding").unwrap();
        let font_size = PropertyFloat32::wrap(node_ref, Role::Internal, "font_size", 0).unwrap();
        let text = PropertyStr::wrap(node_ref, Role::Internal, "text", 0).unwrap();
        let text_color = PropertyColor::wrap(node_ref, Role::Internal, "text_color").unwrap();
        let text_hi_color = PropertyColor::wrap(node_ref, Role::Internal, "text_hi_color").unwrap();
        let placeholder_text =
            PropertyStr::wrap(node_ref, Role::Internal, "placeholder_text", 0).unwrap();
        let placeholder_color =
            PropertyColor::wrap(node_ref, Role::Internal, "placeholder_color").unwrap();
        //let text_cmd_color =
        //    PropertyColor::wrap(node_ref, Role::Internal, "text_cmd_color").unwrap();
        let cursor_color = PropertyColor::wrap(node_ref, Role::Internal, "cursor_color").unwrap();
        let cursor_width =
            PropertyFloat32::wrap(node_ref, Role::Internal, "cursor_width", 0).unwrap();
        let cursor_ascent =
            PropertyFloat32::wrap(node_ref, Role::Internal, "cursor_ascent", 0).unwrap();
        let cursor_descent =
            PropertyFloat32::wrap(node_ref, Role::Internal, "cursor_descent", 0).unwrap();
        let hi_bg_color = PropertyColor::wrap(node_ref, Role::Internal, "hi_bg_color").unwrap();
        //let cmd_bg_color = PropertyColor::wrap(node_ref, Role::Internal, "cmd_bg_color").unwrap();
        let select_ascent =
            PropertyFloat32::wrap(node_ref, Role::Internal, "select_ascent", 0).unwrap();
        let select_descent =
            PropertyFloat32::wrap(node_ref, Role::Internal, "select_descent", 0).unwrap();
        let handle_descent =
            PropertyFloat32::wrap(node_ref, Role::Internal, "handle_descent", 0).unwrap();
        let select_text = node_ref.get_property("select_text").unwrap();
        let cursor_blink_time =
            PropertyUint32::wrap(node_ref, Role::Internal, "cursor_blink_time", 0).unwrap();
        let cursor_idle_time =
            PropertyUint32::wrap(node_ref, Role::Internal, "cursor_idle_time", 0).unwrap();
        let z_index = PropertyUint32::wrap(node_ref, Role::Internal, "z_index", 0).unwrap();
        let priority = PropertyUint32::wrap(node_ref, Role::Internal, "priority", 0).unwrap();
        let debug = PropertyBool::wrap(node_ref, Role::Internal, "debug", 0).unwrap();

        let android_input_type =
            PropertyUint32::wrap(node_ref, Role::Internal, "android_input_type", 0).unwrap();

        let action_fg_color =
            PropertyColor::wrap(node_ref, Role::Internal, "action_fg_color").unwrap();
        let action_bg_color =
            PropertyColor::wrap(node_ref, Role::Internal, "action_bg_color").unwrap();
        let action_padding =
            PropertyFloat32::wrap(node_ref, Role::Internal, "action_padding", 0).unwrap();
        let action_spacing =
            PropertyFloat32::wrap(node_ref, Role::Internal, "action_spacing", 0).unwrap();

        let parent_rect = Arc::new(SyncMutex::new(None));
        let scroll = Arc::new(AtomicF32::new(0.));

        let editor = Arc::new(SyncMutex::new(Editor::new(
            text.clone(),
            font_size.clone(),
            text_color.clone(),
            window_scale.clone(),
            lineheight.clone(),
        )));

        let behave: Box<dyn EditorBehavior> = match edit_type {
            BaseEditType::SingleLine => Box::new(SingleLine {
                rect: rect.clone(),
                padding: padding.clone(),
                cursor_width: cursor_width.clone(),
                parent_rect: parent_rect.clone(),
                editor: editor.clone(),
                content_height: AtomicF32::new(0.),
                scroll: scroll.clone(),
            }),
            BaseEditType::MultiLine => {
                let min_height =
                    PropertyFloat32::wrap(node_ref, Role::Internal, "height_range", 0).unwrap();
                let max_height =
                    PropertyFloat32::wrap(node_ref, Role::Internal, "height_range", 1).unwrap();

                Box::new(MultiLine {
                    min_height: min_height.clone(),
                    max_height: max_height.clone(),
                    rect: rect.clone(),
                    baseline: baseline.clone(),
                    padding: padding.clone(),
                    cursor_descent: cursor_descent.clone(),
                    parent_rect: parent_rect.clone(),
                    editor: editor.clone(),
                    content_height: AtomicF32::new(0.),
                    scroll: scroll.clone(),
                })
            }
        };

        let action_mode = action::ActionMode::new(renderer.clone());

        let self_ = Arc::new_cyclic(|me| Self {
            node,
            tasks: SyncMutex::new(vec![]),
            ex,
            me: me.clone(),
            renderer,
            redraw,
            key_repeat: SyncMutex::new(PressedKeysSmoothRepeat::new(400, 50)),

            root_dc_key: OsRng.gen(),
            phone_select_handle_dc_key: OsRng.gen(),
            content_dc_key: OsRng.gen(),
            select_dc_key: OsRng.gen(),
            text_dc_key: OsRng.gen(),
            cursor_dc_key: OsRng.gen(),
            cursor_anim: SyncMutex::new(None),

            is_active,
            is_focused,
            rect,
            baseline,
            lineheight: lineheight.clone(),
            scroll_speed,
            padding,
            font_size: font_size.clone(),
            text: text.clone(),
            text_color: text_color.clone(),
            text_hi_color,
            placeholder_text,
            placeholder_color,
            //text_cmd_color,
            cursor_color,
            cursor_width,
            cursor_ascent,
            cursor_descent,
            cursor_blink_time,
            cursor_idle_time,
            hi_bg_color,
            //cmd_bg_color,
            select_ascent,
            select_descent,
            handle_descent,
            select_text,
            z_index,
            priority,
            debug,

            android_input_type,

            action_fg_color,
            action_bg_color,
            action_padding,
            action_spacing,

            mouse_btn_held: AtomicBool::new(false),
            hide_cursor: AtomicBool::new(false),
            sel_sender: SyncMutex::new(None),
            scroll: scroll.clone(),

            touch_info: SyncMutex::new(TouchInfo::new(scroll, behave.scroll_ctrl())),
            is_phone_select: AtomicBool::new(false),

            parent_rect,
            window_scale,
            is_mouse_hover: AtomicBool::new(false),
            action_mode,

            editor,
            behave,
        });

        Pimpl::Edit(self_)
    }

    #[inline]
    fn node(&self) -> SceneNodePtr {
        self.node.upgrade().unwrap()
    }

    /// Snapshot of the editor state useful for debugging editing bugs.
    fn dbg_state(&self) -> String {
        let focused = self.is_focused.get();
        let active = self.is_active.get();
        let phone_select = self.is_phone_select.load(Ordering::Relaxed);
        let editor = self.editor.lock();
        let selected = editor.selected_text();

        #[cfg(target_os = "android")]
        {
            format!(
                "text={:?} select={:?} compose={:?} selected={:?} focused={} active={} phone_select={}",
                editor.state.text,
                editor.state.select,
                editor.state.compose,
                selected,
                focused,
                active,
                phone_select,
            )
        }

        #[cfg(not(target_os = "android"))]
        {
            format!(
                "text={:?} selected={:?} focused={} active={} phone_select={}",
                self.text.get(),
                selected,
                focused,
                active,
                phone_select,
            )
        }
    }

    /// Reset the horizontal scroll to 0.
    /// Useful when the input width is dynamically changed and scrolling is not desired.
    pub fn reset_scroll(&self) {
        self.scroll.store(0., Ordering::Release);
    }

    /// Update the editor when the text property was changed externally.
    /// This should be called after setting the text property directly.
    pub fn on_text_prop_changed(&self) {
        self.editor.lock().on_text_prop_changed();
    }

    fn abs_to_local(&self, point: &mut Point) {
        let rect = self.rect.get();
        *point -= rect.pos();
        *point -= self.behave.inner_pos();
        *point -= self.behave.scroll();
    }

    /// Gets the real cursor pos within the rect.
    fn get_cursor_pos(&self) -> Point {
        // This is the position within the content.
        let cursor_pos = self.editor.lock().get_cursor_pos();
        // Apply the inner padding
        cursor_pos + self.behave.inner_pos()
    }

    fn regen_cursor_mesh<R: RenderApi>(&self, renderer: &R) -> DrawMesh {
        let cursor_width = self.cursor_width.get();
        let cursor_ascent = self.cursor_ascent.get();
        let cursor_descent = self.cursor_descent.get();
        let baseline = self.baseline.get();

        let cursor_rect = Rectangle {
            x: 0.,
            y: baseline - cursor_ascent,
            w: cursor_width,
            h: cursor_ascent + cursor_descent,
        };
        let cursor_color = self.cursor_color.get();

        let mut mesh = MeshBuilder::new(gfxtag!("chatedit_cursor"));
        mesh.draw_filled_box(&cursor_rect, cursor_color);
        mesh.alloc(renderer).draw_untextured()
    }

    fn draw_phone_select_handle(&self, mesh: &mut MeshBuilder, mut pos: Point, side: f32) {
        let baseline = self.baseline.get();
        let select_ascent = self.select_ascent.get();
        let handle_descent = self.handle_descent.get();
        let color = self.text_hi_color.get();
        // Transparent for fade
        let mut color_trans = color.clone();
        color_trans[3] = 0.;

        pos += self.behave.inner_pos();
        let x = pos.x;
        let mut y = pos.y + baseline;

        // We can cache this

        // Vertical line downwards. We use this instead of draw_box() so we have a fade.
        let verts = vec![
            Vertex { pos: [x - side * 1., y - select_ascent], color: color_trans, uv: [0., 0.] },
            Vertex { pos: [x + side * 4., y - select_ascent], color: color_trans, uv: [0., 0.] },
            Vertex { pos: [x - side * 1., y + handle_descent + 5.], color, uv: [0., 0.] },
            Vertex { pos: [x + side * 4., y + handle_descent + 5.], color, uv: [0., 0.] },
        ];
        let indices = vec![0, 2, 1, 1, 2, 3];
        mesh.append(verts, indices);

        y += handle_descent;

        // The arrow itself.
        // Go anti-clockwise
        let verts = vec![
            Vertex { pos: [x, y], color, uv: [0., 0.] },
            Vertex { pos: [x, y + 50.], color, uv: [0., 0.] },
            Vertex { pos: [x + side * 30., y + 50.], color, uv: [0., 0.] },
            Vertex { pos: [x + side * 50., y + 25.], color, uv: [0., 0.] },
        ];
        let indices = vec![0, 1, 2, 0, 2, 3];
        mesh.append(verts, indices);
    }

    async fn change_focus(self: Arc<Self>, _batch: BatchGuardPtr) {
        if !self.is_active.get() {
            ed!("change_focus: not active, skipping");
            return
        }
        ed!("change_focus: focused={} -> [{}]", self.is_focused.get(), self.dbg_state());
        t!("Focus changed");

        // Cursor visibility will change so just redraw everything lol
        self.redraw.trigger();
    }

    fn handle_shortcut(&self, key: char, mods: &KeyMods, atom: &mut PropertyAtomicGuard) -> bool {
        ed!("handle_shortcut({key:?}, {mods:?}) before=[{}]", self.dbg_state());
        t!("handle_shortcut({:?}, {:?})", key, mods);

        #[cfg(not(target_os = "macos"))]
        let action_mod = mods.ctrl;

        #[cfg(target_os = "macos")]
        let action_mod = mods.logo;

        match key {
            'a' => {
                if action_mod {
                    let mut editor = self.editor.lock();
                    editor.driver().select_all();
                    if let Some(seltext) = editor.selected_text() {
                        self.select_text.clone().set_str(atom, Role::Internal, 0, seltext).unwrap();
                    }
                }
            }
            'c' => {
                if action_mod {
                    let editor = self.editor.lock();
                    if let Some(txt) = editor.selected_text() {
                        clipboard::set(&txt);
                    }
                }
            }
            'v' => {
                if action_mod {
                    if let Some(txt) = clipboard::get() {
                        self.editor.lock().insert(&txt, atom);
                        // Maybe insert should call this?
                        self.behave.apply_cursor_scroll();
                    }
                }
            }
            _ => return false,
        }

        // Any edit invalidates the action menu's selection
        self.action_mode.clear();
        ed!("handle_shortcut: handled key={key:?} after=[{}]", self.dbg_state());
        true
    }

    fn handle_key(&self, key: &KeyCode, mods: &KeyMods, atom: &mut PropertyAtomicGuard) -> bool {
        #[cfg(not(target_os = "macos"))]
        let action_mod = mods.ctrl;
        #[cfg(target_os = "macos")]
        let action_mod = mods.logo;

        t!("handle_key({:?}, {:?}) action_mod={action_mod}", key, mods);
        {
            let mut editor = self.editor.lock();
            match key {
                KeyCode::Left => {
                    if action_mod {
                        if mods.shift {
                            editor.driver().select_word_left();
                        } else {
                            editor.driver().move_word_left();
                        }
                    } else if mods.shift {
                        editor.driver().select_left();
                    } else {
                        editor.driver().move_left();
                    }
                }
                KeyCode::Right => {
                    if action_mod {
                        if mods.shift {
                            editor.driver().select_word_right();
                        } else {
                            editor.driver().move_word_right();
                        }
                    } else if mods.shift {
                        editor.driver().select_right();
                    } else {
                        editor.driver().move_right();
                    }
                }
                KeyCode::Up => {
                    if mods.shift {
                        editor.driver().select_up();
                    } else {
                        editor.driver().move_up();
                    }
                }
                KeyCode::Down => {
                    if mods.shift {
                        editor.driver().select_down();
                    } else {
                        editor.driver().move_down();
                    }
                }
                KeyCode::Enter | KeyCode::KpEnter => {
                    if mods.shift {
                        if self.behave.allow_endl() {
                            editor.driver().insert_or_replace_selection("\n");
                            editor.on_buffer_changed(atom);
                        }
                    } else {
                        //let node = self.node.upgrade().unwrap();
                        //node.trigger("enter_pressed", vec![]).await.unwrap();
                        return false;
                    }
                }
                KeyCode::Delete => {
                    if action_mod {
                        editor.driver().delete_word();
                    } else {
                        editor.driver().delete();
                    }
                    editor.on_buffer_changed(atom);
                }
                KeyCode::Backspace => {
                    if action_mod {
                        editor.driver().backdelete_word();
                    } else {
                        editor.driver().backdelete();
                    }
                    editor.on_buffer_changed(atom);
                }
                KeyCode::Home => {
                    if action_mod {
                        if mods.shift {
                            editor.driver().select_to_text_start();
                        } else {
                            editor.driver().move_to_text_start();
                        }
                    } else if mods.shift {
                        editor.driver().select_to_line_start();
                    } else {
                        editor.driver().move_to_line_start();
                    }
                }
                KeyCode::End => {
                    if action_mod {
                        if mods.shift {
                            editor.driver().select_to_text_end();
                        } else {
                            editor.driver().move_to_text_end();
                        }
                    } else if mods.shift {
                        editor.driver().select_to_line_end();
                    } else {
                        editor.driver().move_to_line_end();
                    }
                }
                _ => return false,
            }

            if let Some(seltext) = editor.selected_text() {
                self.select_text.clone().set_str(atom, Role::Internal, 0, seltext).unwrap();
            } else {
                self.select_text.clone().set_null(atom, Role::Internal, 0).unwrap();
            }
        }

        self.behave.apply_cursor_scroll();
        self.pause_blinking();
        // Any edit invalidates the action menu's selection
        self.action_mode.clear();

        ed!("handle_key: handled {key:?} after=[{}]", self.dbg_state());
        true
    }

    /// This will select the entire word rather than move the cursor to that location
    fn start_touch_select(&self, touch_pos: Point, atom: &mut PropertyAtomicGuard) {
        ed!("start_touch_select({touch_pos:?}) before=[{}]", self.dbg_state());

        let mut editor = self.editor.lock();
        editor.select_word_at_point(touch_pos);
        editor.refresh();

        let seltext = editor.selected_text().unwrap();
        drop(editor);
        self.select_text.clone().set_str(atom, Role::Internal, 0, seltext).unwrap();

        self.is_phone_select.store(true, Ordering::Relaxed);
        self.hide_cursor.store(true, Ordering::Relaxed);
    }

    fn handle_touch_start(&self, touch_pos: Point) -> bool {
        ed!("handle_touch_start({touch_pos:?}) before=[{}]", self.dbg_state());

        let rect = self.rect.get();
        let local_pos = touch_pos - rect.pos();

        // Grabbing a select handle must keep the action menu visible: the
        // user adjusts the selection, then taps Copy/Paste. Check the drag
        // BEFORE interact(), which consumes the menu.
        if self.try_handle_drag(touch_pos) {
            ed!("handle_touch_start: handled by drag handle");
            return true
        }

        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_touch_start_action"));
        if let Some(action_id) = self.action_mode.interact(local_pos) {
            match action_id {
                ACTION_COPY => {
                    if let Some(txt) = self.editor.lock().selected_text() {
                        clipboard::set(&txt);
                    }
                }
                ACTION_PASTE => {
                    if let Some(txt) = clipboard::get() {
                        self.editor.lock().insert(&txt, atom);
                        self.behave.apply_cursor_scroll();
                        self.finish_select(atom);
                    }
                }
                ACTION_SELALL => {
                    let mut editor = self.editor.lock();
                    editor.select_all();
                    if let Some(seltext) = editor.selected_text() {
                        self.select_text.clone().set_str(atom, Role::Internal, 0, seltext).unwrap();
                    }
                }
                _ => {}
            }

            return true;
        } else {
            // interact() already consumed the menu; the pass re-emits the
            // (now empty) action overlay when the batch settles.
        }

        if !rect.contains(touch_pos) {
            ed!("handle_touch_start: outside rect={rect:?}, ignoring");
            t!("rect!cont rect={rect:?}, touch_pos={touch_pos:?}");
            return false
        }

        let mut touch_info = self.touch_info.lock();
        touch_info.start(touch_pos);
        ed!("handle_touch_start: touch started, waiting for move/end");
        true
    }

    fn get_select_handles(&self, editor: &Editor) -> Option<(Point, Point)> {
        let endpoints = editor.selection_endpoints();
        if endpoints.is_none() {
            assert!(!self.is_phone_select.load(Ordering::Relaxed));
        }
        endpoints
    }

    fn try_handle_drag(&self, mut touch_pos: Point) -> bool {
        let editor = self.editor.lock();
        let Some((mut first, mut last)) = self.get_select_handles(&editor) else { return false };

        self.abs_to_local(&mut touch_pos);

        let baseline = self.baseline.get();
        let handle_off_y = self.handle_descent.get();

        first.y += baseline + handle_off_y;
        last.y += baseline + handle_off_y;

        // Are we within range of either one?
        t!("handle center points = ({first:?}, {last:?})");

        const TOUCH_RADIUS_SQ: f32 = 10_000.;

        let first_dist_sq = first.dist_sq(touch_pos);
        let last_dist_sq = last.dist_sq(touch_pos);

        let is_first = first_dist_sq <= TOUCH_RADIUS_SQ;
        let is_last = last_dist_sq <= TOUCH_RADIUS_SQ;

        let mut side = 0;

        if is_first && is_last {
            // Are we closer to the first or last?
            // Break the tie
            if first_dist_sq < last_dist_sq {
                side = -1;
            } else {
                side = 1;
            }
        } else if is_first {
            side = -1;
        } else if is_last {
            side = 1;
        }

        if side != 0 {
            d!("start touch: DragSelectHandle state [side={side}]");
            // Set touch_state status to enable begin dragging them
            let mut touch_info = self.touch_info.lock();
            touch_info.state = TouchStateAction::DragSelectHandle { side };
            ed!("try_handle_drag: grabbing select handle side={side}");
            return true
        }

        ed!("try_handle_drag: no handle grabbed");
        false
    }

    fn handle_touch_move(&self, mut touch_pos: Point) -> bool {
        if !self.is_active.get() {
            return false
        }

        // We must update with non relative touch_pos bcos when doing vertical scrolling
        // we will modify the scroll, which is used by abs_to_local(), which is used
        // to then calculate the max scroll. So it ends up jumping around.
        // We use the abs touch_pos without scroll adjust applied for vert scrolling.
        let touch_state = {
            let mut touch_info = self.touch_info.lock();
            touch_info.update(&touch_pos);
            touch_info.state.clone()
        };
        ed!("handle_touch_move({touch_pos:?}) touch_state={touch_state:?}");
        //t!("handle_touch_move({touch_pos:?})  touch_state={touch_state:?}");
        match &touch_state {
            TouchStateAction::Inactive => return false,
            TouchStateAction::StartSelect => {
                let mut menu = action::Menu::new(
                    self.font_size.get(),
                    self.action_fg_color.get(),
                    self.action_bg_color.get(),
                    self.action_padding.get(),
                    self.action_spacing.get(),
                    self.window_scale.get(),
                );

                let atom =
                    &mut self.redraw.make_guard(gfxtag!("BaseEdit::TouchStateAction::StartSelect"));

                if self.text.get().is_empty() {
                    menu.add("Paste", ACTION_PASTE);
                    // Set the menu pos to the current cursor pos
                    menu.pos = self.get_cursor_pos();

                    self.touch_info.lock().state = TouchStateAction::Inactive;
                } else {
                    menu.add("Copy", ACTION_COPY);
                    menu.add("Paste", ACTION_PASTE);
                    menu.add("Select All", ACTION_SELALL);

                    self.abs_to_local(&mut touch_pos);
                    self.start_touch_select(touch_pos, atom);

                    {
                        let editor = self.editor.lock();
                        let (curs_lhs, _) = self.get_select_handles(&editor).unwrap();
                        // Set the menu pos to the LHS of the selection
                        menu.pos = curs_lhs + self.behave.inner_pos();
                    }

                    // Adjust menu pos so RHS doesnt leave the RHS of this widget
                    let rect = self.rect.get();
                    if menu.pos.x + menu.total_width() > rect.w {
                        menu.pos.x = rect.w - menu.total_width();
                    }

                    d!("touch state: StartSelect -> Select");
                    self.touch_info.lock().state = TouchStateAction::Select;
                }
                self.action_mode.set(menu);
                ed!("handle_touch_move: StartSelect handled");
            }
            TouchStateAction::DragSelectHandle { side } => {
                // The IME can collapse the selection (finishing phone-select
                // mode) while a handle drag is in progress. Abort the drag
                // instead of asserting on the stale state.
                if !self.is_phone_select.load(Ordering::Relaxed) {
                    ed!("handle_touch_move: phone select finished mid-drag, aborting");
                    self.touch_info.lock().state = TouchStateAction::Inactive;
                    return true
                }

                let rect = self.rect.get();
                let is_touch_hover = rect.contains(touch_pos);

                let sel_sender = self.sel_sender.lock().clone().unwrap();
                // Mouse is outside rect?
                // If so we gotta scroll it while selecting.
                if !is_touch_hover {
                    // This process will begin selecting text and applying scroll too.
                    sel_sender.try_send(Some((touch_pos, Some(*side)))).unwrap();
                } else {
                    // Stop any existing select/scroll process
                    sel_sender.try_send(None).unwrap();
                    // Mouse is inside so just select the text once and be done.
                    self.handle_select(touch_pos, Some(*side));
                }
            }
            TouchStateAction::ScrollVert { start_pos, scroll_start } => {
                let travel_dist = self.behave.scroll_ctrl().travel(*start_pos, touch_pos);
                let mut scroll = scroll_start + travel_dist;
                scroll = scroll.clamp(0., self.behave.max_scroll());
                if (self.scroll.load(Ordering::Relaxed) - scroll).abs() < VERT_SCROLL_UPDATE_INC {
                    return true
                }
                self.scroll.store(scroll, Ordering::Release);
                self.redraw.trigger();
            }
            TouchStateAction::SetCursorPos => {
                // TBH I can't even see the cursor under my thumb so I'll just
                // comment this for now.
            }
            _ => {}
        }
        true
    }
    async fn handle_touch_end(&self, mut touch_pos: Point) -> bool {
        //t!("handle_touch_end({touch_pos:?})");
        self.abs_to_local(&mut touch_pos);

        let state = self.touch_info.lock().stop();
        ed!("handle_touch_end({touch_pos:?}) final_state={state:?}");
        match state {
            TouchStateAction::Inactive => return false,
            TouchStateAction::Started { pos: _, instant: _ } | TouchStateAction::SetCursorPos => {
                let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_touch_end"));
                self.touch_set_cursor_pos(atom, touch_pos);
            }
            _ => {}
        }

        // Stop any selection scrolling
        let scroll_sender = self.sel_sender.lock().clone().unwrap();
        scroll_sender.try_send(None).unwrap();

        let mut need_focus = !self.is_focused.get();
        #[cfg(target_os = "android")]
        if !is_ime_visible() {
            need_focus = true;
        }

        if need_focus {
            let node = self.node();
            node.trigger("focus_request", vec![]).await.unwrap();
        }

        true
    }

    fn touch_set_cursor_pos(&self, atom: &mut PropertyAtomicGuard, touch_pos: Point) {
        ed!("touch_set_cursor_pos({touch_pos:?}) before=[{}]", self.dbg_state());

        let mut editor = self.editor.lock();
        editor.move_to_pos(touch_pos);
        editor.refresh();
        drop(editor);
        ed!("touch_set_cursor_pos: moved cursor after=[{}]", self.dbg_state());

        self.pause_blinking();
        self.finish_select(atom);
    }

    fn finish_select(&self, atom: &mut PropertyAtomicGuard) {
        ed!(
            "finish_select: phone_select={} -> false",
            self.is_phone_select.load(Ordering::Relaxed)
        );
        self.is_phone_select.store(false, Ordering::Release);
        self.hide_cursor.store(false, Ordering::Release);
        self.select_text.clone().set_null(atom, Role::Internal, 0).unwrap();
        // The action menu belongs to the selection; dismiss it too.
        self.action_mode.clear();
    }

    fn handle_select(&self, mouse_pos: Point, side: Option<isize>) {
        //t!("handle_select({mouse_pos:?}, {side:?})");
        let rect = self.rect.get();
        let is_mouse_hover = rect.contains(mouse_pos);

        let mut clip_mouse_pos = rect.clip_point(mouse_pos);

        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_mouse_move"));

        // Handle scrolling
        if !is_mouse_hover {
            let scroll_ctrl = self.behave.scroll_ctrl();
            // How far is the cursor outside the widget rect
            let travel = scroll_ctrl.travel(mouse_pos, clip_mouse_pos);
            //t!("select autoscroll travel={travel}");

            let max_scroll = self.behave.max_scroll();
            let delta = travel * SELECT_SCROLL_TRAVEL_SPEED;
            let scroll = (self.scroll.load(Ordering::Relaxed) + delta).clamp(0., max_scroll);
            self.scroll.store(scroll, Ordering::Release);
        }

        // Move mouse pos within this widget
        self.abs_to_local(&mut clip_mouse_pos);

        let mut sel_side = 1;
        if let Some(side) = side {
            sel_side = side;
        }

        let seltext = {
            let mut editor = self.editor.lock();

            // The below lines rely on parley driver which android does not use
            //let mut txt_ctx = text::TEXT_CTX.get().await;
            //let mut drv = editor.driver(&mut txt_ctx).unwrap();
            //drv.extend_selection_to_point(clip_mouse_pos.x, clip_mouse_pos.y);
            let layout = editor.layout();
            let prev_sel = editor.selection(sel_side);
            let sel = prev_sel.extend_to_point(layout, clip_mouse_pos.x, clip_mouse_pos.y);
            let (mut prev_start, mut prev_end) =
                (prev_sel.anchor().index(), prev_sel.focus().index());
            let (mut start, mut end) = (sel.anchor().index(), sel.focus().index());
            //t!("handle_select() setting ({start}, {end})");

            // When dragging phone handles we prevent the selection crossing over itself.
            // Mouse select does not have this limitation.
            if let Some(side) = side {
                assert!(side.abs() == 1);
                // Phone-select mode can be finished concurrently (e.g. the
                // IME collapsed the selection) while a queued drag update
                // was still in flight. Drop the stale update.
                if !self.is_phone_select.load(Ordering::Relaxed) {
                    ed!("handle_select: phone select finished mid-drag, dropping update");
                    return
                }

                // Prevent selection crossing itself
                if side == -1 {
                    let max_end = sel.anchor().previous_visual(layout).index();
                    end = std::cmp::min(end, max_end);
                    //t!("handle_select(): LHS set focus {end} before {max_end}");
                    // When selecting from the LHS these will be swapped so swap them back
                    swap(&mut start, &mut end);
                    swap(&mut prev_start, &mut prev_end);
                } else {
                    let min_end = sel.anchor().next_visual(layout).index();
                    end = std::cmp::max(end, min_end);
                    //t!("handle_select(): RHS set focus {end} after {min_end}");
                }
            }

            if start == prev_start && end == prev_end {
                // No change so just return
                //t!("handle_select(): no change early exit");
                return
            }
            #[cfg(target_os = "android")]
            assert!(start < end);

            //t!("handle_select(): set_selection({start}, {end})");
            ed!("handle_select: set_selection({start}, {end}) side={side:?} prev=({prev_start}, {prev_end})");
            editor.set_selection(start, end);
            editor.selected_text()
        };
        ed!("handle_select: seltext={seltext:?} clip_pos={clip_mouse_pos:?}");

        // Android editor impl detail: selection disappears when anchor == index
        // But we disallow this so it should never happen. Just making a note of it here.
        // See the android only assert that `start < end` in the block above.
        #[cfg(target_os = "android")]
        {
            //if sel_start == sel_end {
            //    self.finish_select(atom);
            //}
        }

        // Will be None when drag select just started
        if let Some(seltext) = seltext {
            self.select_text.clone().set_str(atom, Role::Internal, 0, seltext).unwrap();
        }

        self.pause_blinking();
        //self.behave.apply_cursor_scroll();
    }

    /// Holds the cursor solid while the user interacts. The renderer-managed
    /// anim resumes blinking by itself once the idle time passes; there is no
    /// app-side timed commit and the committed cursor draw call (which
    /// references the anim) never needs to change for pausing.
    fn pause_blinking(&self) {
        let anim = self.cursor_anim.lock().clone();
        let Some(anim) = anim else { return };
        anim.pause(0, self.cursor_idle_time.get() as u64);
    }

    #[instrument(target = "ui::edit")]
    fn get_cursor_instrs(&self) -> Vec<DrawInstruction> {
        if !self.is_focused.get() || self.hide_cursor.load(Ordering::Relaxed) {
            return vec![]
        }

        let pos = self.get_cursor_pos();
        let anim = self.cursor_anim.lock().clone().unwrap();
        vec![DrawInstruction::Move(pos), DrawInstruction::Animation(anim)]
    }

    fn regen_bg_mesh<R: RenderApi>(&self, renderer: &R) -> Vec<DrawInstruction> {
        if !self.debug.get() {
            return vec![]
        }

        let mut rect = self.rect.get().with_zero_pos();

        let mut mesh = MeshBuilder::new(gfxtag!("chatedit_bg"));
        mesh.draw_outline(&rect, [0., 1., 0., 1.], 1.);

        let pad_top = self.padding.get_f32(0).unwrap();
        let pad_right = self.padding.get_f32(1).unwrap();
        let pad_bottom = self.padding.get_f32(2).unwrap();
        let pad_left = self.padding.get_f32(3).unwrap();

        rect.x = pad_left;
        rect.y = pad_top;
        rect.w -= pad_left + pad_right;
        rect.h -= pad_top + pad_bottom;
        mesh.draw_outline(&rect, [0., 1., 0., 0.5], 1.);

        vec![DrawInstruction::Draw(mesh.alloc(renderer).draw_untextured())]
    }

    fn regen_txt_mesh(&self) -> Vec<DrawInstruction> {
        let mut instrs = vec![DrawInstruction::Move(self.behave.inner_pos())];

        // Render placeholder
        let current_text = self.text.get();
        if current_text.is_empty() {
            let placeholder_text = self.placeholder_text.get();
            if !placeholder_text.is_empty() {
                let placeholder_color = self.placeholder_color.get();
                let font_size = self.font_size.get();
                let lineheight = self.lineheight.get();
                let window_scale = self.window_scale.get();

                let placeholder_layout = text::make_layout(
                    &placeholder_text,
                    placeholder_color,
                    font_size,
                    lineheight,
                    window_scale,
                    None,
                    &[],
                );

                let mut render_instrs = text::render_layout(
                    &placeholder_layout,
                    &self.renderer,
                    gfxtag!("chatedit_placeholder_mesh"),
                );
                instrs.append(&mut render_instrs);
                return instrs;
            }
        }

        // Render text
        let editor = self.editor.lock();

        let mut render_instrs = editor.render_instrs(&self.renderer, gfxtag!("chatedit_txt_mesh"));
        instrs.append(&mut render_instrs);

        instrs
    }

    fn regen_select_mesh<R: RenderApi>(&self, renderer: &R) -> Vec<DrawInstruction> {
        let mut instrs = vec![DrawInstruction::Move(self.behave.inner_pos())];

        let editor = self.editor.lock();

        let sel_color = self.hi_bg_color.get();
        let sel_rects = editor.selection_rects();
        if !sel_rects.is_empty() {
            let mut mesh = MeshBuilder::new(gfxtag!("chatedit_select_mesh"));
            for rect in sel_rects {
                mesh.draw_filled_box(&rect, sel_color);
            }

            instrs.push(DrawInstruction::Draw(mesh.alloc(renderer).draw_untextured()));
        }

        instrs
    }

    fn regen_phone_select_handle_mesh<R: RenderApi>(&self, renderer: &R) -> Vec<DrawInstruction> {
        if !self.is_phone_select.load(Ordering::Acquire) {
            //t!("regen_phone_select_handle_mesh() [DISABLED]");
            return vec![]
        }
        let editor = self.editor.lock();
        let (first, last) = self.get_select_handles(&editor).unwrap();

        let sel = editor.selection(1);
        assert!(!sel.is_collapsed());

        // We could cache this and use Move instead but why bother?
        let mut mesh = MeshBuilder::new(gfxtag!("chatedit_phone_select_handle"));
        self.draw_phone_select_handle(&mut mesh, first, -1.);
        self.draw_phone_select_handle(&mut mesh, last, 1.);
        vec![DrawInstruction::Draw(mesh.alloc(renderer).draw_untextured())]
    }

    /// This does not make use of its own batch since we want to de-atomize updating this
    /// widget from its dependencies so theres zero latency when typing.
    /// Runs inside the draw pass, so it borrows the pass's atom: property
    /// echoes are deferred there and no extra pass is triggered.
    /// Should be called when text contents changes.
    fn eval_rect(&self, atom: &mut PropertyAtomicGuard) {
        self.behave.eval_rect(atom);
    }

    fn make_draw_calls(&self) -> DrawUpdate {
        let rect = self.rect.get();

        let cursor_instrs = self.get_cursor_instrs();
        let txt_instrs = self.regen_txt_mesh();
        let sel_instrs = self.regen_select_mesh(&self.renderer);
        let phone_sel_instrs = self.regen_phone_select_handle_mesh(&self.renderer);

        let mut content_instrs = vec![DrawInstruction::ApplyView(rect.with_zero_pos())];
        let mut bg_instrs = self.regen_bg_mesh(&self.renderer);
        content_instrs.append(&mut bg_instrs);
        content_instrs.push(DrawInstruction::Move(self.behave.scroll()));

        let action_instrs = self.action_mode.get_instrs();

        // + root (move)
        // -+ content (apply view)
        //  └╴select
        //  └╴text
        //  └╴phone_handle
        //  └╴cursor
        // -- action bar

        // Why do we have such a complicated layout?
        // When adjusting selection, it's slow to redraw everything, so the selection
        // must be drawn separately.
        // Lastly the cursor is blinking and that's on top but with clipping.

        DrawUpdate {
            key: self.root_dc_key,
            draw_calls: vec![
                (
                    self.root_dc_key,
                    DrawCall::new(
                        vec![DrawInstruction::Move(rect.pos())],
                        vec![self.content_dc_key, self.action_mode.dc_key],
                        self.z_index.get(),
                        "chatedit_root",
                    ),
                ),
                (
                    self.content_dc_key,
                    DrawCall::new(
                        content_instrs,
                        vec![
                            self.text_dc_key,
                            self.phone_select_handle_dc_key,
                            self.cursor_dc_key,
                            self.select_dc_key,
                        ],
                        0,
                        "chatedit_content",
                    ),
                ),
                (self.select_dc_key, DrawCall::new(sel_instrs, vec![], 0, "chatedit_sel")),
                (self.text_dc_key, DrawCall::new(txt_instrs, vec![], 1, "chatedit_text")),
                (self.cursor_dc_key, DrawCall::new(cursor_instrs, vec![], 2, "chatedit_curs")),
                (
                    self.phone_select_handle_dc_key,
                    DrawCall::new(phone_sel_instrs, vec![], 1, "chatedit_phone_sel"),
                ),
                (
                    self.action_mode.dc_key,
                    DrawCall::new(action_instrs, vec![], 0, "chatedit_action"),
                ),
            ],
        }
    }

    async fn process_insert_text_method(me: &Weak<Self>, sub: &MethodCallSub) -> bool {
        let Ok(method_call) = sub.receive().await else {
            debug!(target: "ui::chatedit", "Event relayer closed");
            return false
        };

        t!("method called: insert_line({method_call:?})");
        assert!(method_call.send_res.is_none());

        fn decode_data(data: &[u8]) -> std::io::Result<String> {
            let mut cur = Cursor::new(&data);
            let text = String::decode(&mut cur)?;
            Ok(text)
        }

        let Ok(text) = decode_data(&method_call.data) else {
            error!(target: "ui::chatedit", "insert_text() method invalid arg data");
            return true
        };

        let Some(self_) = me.upgrade() else {
            // Should not happen
            panic!("self destroyed before insert_text_method_task was stopped!");
        };

        let atom = &mut self_.redraw.make_guard(gfxtag!("BaseEdit::process_insert_text_method"));
        self_.editor.lock().insert(&text, atom);
        self_.action_mode.clear();
        ed!("insert_text method: inserted {text:?} after=[{}]", self_.dbg_state());
        true
    }

    async fn process_focus_method(me: &Weak<Self>, sub: &MethodCallSub) -> bool {
        let Ok(method_call) = sub.receive().await else {
            debug!(target: "ui::chatedit", "Event relayer closed");
            return false
        };

        t!("method called: focus({method_call:?})");
        assert!(method_call.send_res.is_none());
        assert!(method_call.data.is_empty());

        let Some(self_) = me.upgrade() else {
            // Should not happen
            panic!("self destroyed before insert_text_method_task was stopped!");
        };

        // Set input type from property
        #[cfg(target_os = "android")]
        {
            let input_type = self_.android_input_type.get();
            ed!("focus method: setting android input_type={input_type}");
            self_.editor.lock().set_input_type(input_type);
        }
        self_.editor.lock().focus();

        let atom = &mut self_.redraw.make_guard(gfxtag!("BaseEdit::process_focus_method"));
        self_.is_focused.set(atom, true);
        ed!("focus method: done after=[{}]", self_.dbg_state());
        true
    }
    async fn process_unfocus_method(me: &Weak<Self>, sub: &MethodCallSub) -> bool {
        let Ok(method_call) = sub.receive().await else {
            debug!(target: "ui::chatedit", "Event relayer closed");
            return false
        };

        t!("method called: focus({method_call:?})");
        assert!(method_call.send_res.is_none());
        assert!(method_call.data.is_empty());

        let Some(self_) = me.upgrade() else {
            // Should not happen
            panic!("self destroyed before insert_text_method_task was stopped!");
        };

        self_.editor.lock().unfocus();
        let atom = &mut self_.redraw.make_guard(gfxtag!("BaseEdit::process_unfocus_method"));
        self_.is_focused.set(atom, false);
        ed!("unfocus method: done after=[{}]", self_.dbg_state());
        true
    }

    #[cfg(target_os = "android")]
    fn handle_android_event(&self, state: AndroidTextInputState) {
        if !self.is_active.get() {
            ed!("handle_android_event: DROP inactive state={state:?}");
            return
        }

        // A handle drag owns the selection. Our own `set_selection` calls
        // push state to the IME and Android's input connection echoes it
        // back, sometimes normalized to a collapsed (cursor-only)
        // selection. Applying such an echo mid-drag would collapse our
        // selection and finish phone-select mode, making the handles
        // vanish. Drop it: the next drag update re-asserts the real
        // selection.
        let drag_in_progress = {
            let touch_info = self.touch_info.lock();
            matches!(touch_info.state, TouchStateAction::DragSelectHandle { .. })
        };
        if drag_in_progress && state.select.0 == state.select.1 {
            ed!("handle_android_event: DROP collapsed IME echo mid-drag state={state:?}");
            return
        }

        ed!("handle_android_event: ENTER incoming={state:?} before=[{}]", self.dbg_state());
        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_android_event"));

        let is_new_select_collapsed = state.select.0 == state.select.1;
        let (is_text_changed, is_select_changed, is_compose_changed) = {
            let mut editor = self.editor.lock();
            // Diff old and new state so we know what changed
            let old_text = editor.state.text.clone();
            let old_select = editor.state.select;
            let old_compose = editor.state.compose;
            let diff = (
                editor.state.text != state.text,
                editor.state.select != state.select,
                editor.state.compose != state.compose,
            );
            ed!(
                "handle_android_event: diff text_changed={} (old={:?} new={:?}) select_changed={} (old={:?} new={:?}) compose_changed={} (old={:?} new={:?})",
                diff.0, old_text, state.text,
                diff.1, old_select, state.select,
                diff.2, old_compose, state.compose,
            );
            editor.state = state;
            editor.on_buffer_changed(atom);
            diff
        };

        // Nothing changed. Just return.
        if !is_text_changed && !is_select_changed && !is_compose_changed {
            ed!("handle_android_event: no-op (nothing changed), after=[{}]", self.dbg_state());
            return
        }

        ed!(
            "handle_android_event: applying text_changed={} select_changed={} compose_changed={} collapsed={}",
            is_text_changed, is_select_changed, is_compose_changed, is_new_select_collapsed
        );

        // Only redraw once we have the parent_rect
        // Can happen when we receive an Android event before the canvas is ready
        if self.parent_rect.lock().is_none() {
            ed!("handle_android_event: parent_rect not ready yet, bailing before redraw");
            return
        }

        // Not sure what to do if only compose changes lol
        // For now just ignore it.
        // Changing the cursor pos will change the compose state if a word is edited.
        // However making selection has a tendency to send spurious compose events.

        // Text changed - finish any active selection
        if is_text_changed {
            self.behave.apply_cursor_scroll();

            self.pause_blinking();
            //assert!(state.text != self.text.get());
            self.finish_select(atom);
            self.action_mode.clear();
            ed!("handle_android_event: handled text change, after=[{}]", self.dbg_state());
        } else if is_select_changed {
            // The IME can collapse a phone-style word selection out from under
            // us (e.g. it repositions the cursor when the keyboard is shown).
            // The selection handles are then stale, so finish phone-select mode.
            // A handle drag always maintains a range, so its IME echoes are
            // unaffected.
            if is_new_select_collapsed && self.is_phone_select.load(Ordering::Relaxed) {
                ed!("handle_android_event: IME collapsed the phone selection, finishing select");
                d!("IME has collapsed selection!");
                self.finish_select(atom);
            }
            ed!("handle_android_event: handled select change, after=[{}]", self.dbg_state());
        } else if is_compose_changed {
            self.editor.lock().refresh();
            ed!("handle_android_event: handled compose change, after=[{}]", self.dbg_state());
        }
    }
}

impl Drop for BaseEdit {
    fn drop(&mut self) {
        self.renderer.replace_draw_calls(vec![(self.text_dc_key, Default::default())]);
    }
}

#[async_trait]
impl UIObject for BaseEdit {
    fn priority(&self) -> u32 {
        self.priority.get()
    }

    async fn start(self: Arc<Self>, ex: ExecutorPtr) {
        let me = Arc::downgrade(&self);
        let node_ref = &self.node.upgrade().unwrap();

        let method_sub = node_ref.subscribe_method_call("insert_text").unwrap();
        let me2 = me.clone();
        let insert_text_task =
            ex.spawn(
                async move { while Self::process_insert_text_method(&me2, &method_sub).await {} },
            );

        let method_sub = node_ref.subscribe_method_call("focus").unwrap();
        let me2 = me.clone();
        let focus_task =
            ex.spawn(async move { while Self::process_focus_method(&me2, &method_sub).await {} });

        let method_sub = node_ref.subscribe_method_call("unfocus").unwrap();
        let me2 = me.clone();
        let unfocus_task =
            ex.spawn(async move { while Self::process_unfocus_method(&me2, &method_sub).await {} });

        let mut on_modify = OnModify::new(ex.clone(), self.node.clone(), me.clone());
        on_modify.when_change_external(self.is_focused.prop(), Self::change_focus);

        // When text has been changed.
        // Cursor and selection might be invalidated.
        async fn reset(self_: Arc<BaseEdit>, _batch: BatchGuardPtr) {
            //self_.select_text.set_null(Role::Internal, 0).unwrap();
            self_.scroll.store(0., Ordering::Release);
            self_.redraw.trigger();
        }
        async fn redraw(self_: Arc<BaseEdit>, _batch: BatchGuardPtr) {
            self_.redraw.trigger();
        }
        async fn set_text(self_: Arc<BaseEdit>, _batch: BatchGuardPtr) {
            self_.editor.lock().on_text_prop_changed();
            self_.redraw.trigger();
        }

        on_modify.when_change_external(self.rect.prop(), redraw);
        on_modify.when_change_external(self.baseline.prop(), redraw);
        on_modify.when_change_external(self.lineheight.prop(), redraw);
        on_modify.when_change_external(self.select_ascent.prop(), redraw);
        on_modify.when_change_external(self.select_descent.prop(), redraw);
        on_modify.when_change_external(self.handle_descent.prop(), redraw);
        on_modify.when_change_external(self.padding.clone(), redraw);
        on_modify.when_change_external(self.text.prop(), set_text);
        // The commented properties are modified on input events
        // So then redraw() will get repeatedly triggered when these properties
        // are changed. We should find a solution. For now the hooks are disabled.
        //on_modify.when_change(scroll.prop(), redraw);
        //on_modify.when_change(cursor_pos.prop(), redraw);
        on_modify.when_change_external(self.font_size.prop(), redraw);
        on_modify.when_change_external(self.text.prop(), reset);
        on_modify.when_change_external(self.text_color.prop(), redraw);
        on_modify.when_change_external(self.placeholder_text.prop(), redraw);
        on_modify.when_change_external(self.placeholder_color.prop(), redraw);
        on_modify.when_change_external(self.hi_bg_color.prop(), redraw);
        //on_modify.when_change(selected.clone(), redraw);
        on_modify.when_change_external(self.z_index.prop(), redraw);
        on_modify.when_change_external(self.debug.prop(), redraw);

        async fn regen_cursor(self_: Arc<BaseEdit>, _batch: BatchGuardPtr) {
            // Rebuild the visible frame so cursor style changes apply to
            // the blink animation.
            let mesh = self_.regen_cursor_mesh(&self_.renderer);
            let dc_visible =
                DrawCall::new(vec![DrawInstruction::Draw(mesh)], vec![], 2, "cursor_vis");
            if let Some(anim) = self_.cursor_anim.lock().as_ref() {
                anim.update(0, AnimFrame::new(self_.cursor_blink_time.get(), dc_visible));
            }
        }
        on_modify.when_change_external(self.cursor_color.prop(), regen_cursor);
        on_modify.when_change_external(self.cursor_ascent.prop(), regen_cursor);
        on_modify.when_change_external(self.cursor_descent.prop(), regen_cursor);
        on_modify.when_change_external(self.cursor_width.prop(), regen_cursor);

        // Create the blinking cursor animation using SeqAnim
        // Frame 0: visible cursor
        // Frame 1: invisible (empty)
        let cursor_anim = self.renderer.new_anim(2, false, gfxtag!("baseedit_cursor_blink"));
        let cursor_mesh = self.regen_cursor_mesh(&self.renderer);

        // Frame 0: visible cursor (just the draw, no position)
        let dc_visible =
            DrawCall::new(vec![DrawInstruction::Draw(cursor_mesh)], vec![], 2, "cursor_vis");
        cursor_anim.update(0, AnimFrame::new(self.cursor_blink_time.get(), dc_visible));

        // Frame 1: invisible (empty draw call)
        let dc_invisible = DrawCall::new(vec![], vec![], 2, "cursor_invis");
        cursor_anim.update(1, AnimFrame::new(self.cursor_blink_time.get(), dc_invisible));

        *self.cursor_anim.lock() = Some(cursor_anim);

        let (sel_sender, sel_recvr) = async_channel::unbounded();
        *self.sel_sender.lock() = Some(sel_sender);
        let me2 = me.clone();
        // We don't get continuous mouse move events. Instead this task is used to smoothly
        // scroll when selecting text.
        let sel_task = ex.spawn(async move {
            let mut scroll_stat = None;
            // Too much code duplication here but I didn't find a solution that looks any cleaner.
            loop {
                if scroll_stat.is_some() {
                    futures::select! {
                        rcv = sel_recvr.recv().fuse() => {
                            scroll_stat = rcv.unwrap();

                            if let Some((mouse_pos, side)) = scroll_stat {
                                let self_ = me2.upgrade().unwrap();
                                //t!("select task interrupt: {mouse_pos:?} (side={side:?})");
                                self_.handle_select(mouse_pos, side);
                            };
                        }
                        _ = msleep(SELECT_TASK_UPDATE_TIME).fuse() => {
                            if let Some((mouse_pos, side)) = scroll_stat {
                                let self_ = me2.upgrade().unwrap();
                                //t!("select task update: {mouse_pos:?} (side={side:?})");
                                self_.handle_select(mouse_pos, side);
                            };
                        }
                    }
                } else {
                    scroll_stat = sel_recvr.recv().await.unwrap();

                    if let Some((mouse_pos, side)) = scroll_stat {
                        let self_ = me2.upgrade().unwrap();
                        //t!("select task wake up: {mouse_pos:?} (side={side:?})");
                        self_.handle_select(mouse_pos, side);
                    };
                }
            }
        });

        let mut tasks = vec![insert_text_task, focus_task, unfocus_task, sel_task];
        tasks.append(&mut on_modify.tasks);

        #[cfg(target_os = "android")]
        {
            let recvr = self.editor.lock().recvr.clone();
            let me2 = me.clone();
            let autosuggest_task = ex.spawn(async move {
                loop {
                    let Ok(ev) = recvr.recv().await else {
                        t!("Event relayer closed");
                        break
                    };

                    let Some(self_) = me2.upgrade() else {
                        // Should not happen
                        panic!("self destroyed before autosuggest_task was stopped!");
                    };

                    self_.handle_android_event(ev);
                }
            });
            tasks.push(autosuggest_task);
        }

        *self.tasks.lock() = tasks;
    }

    fn stop(&self) {
        self.tasks.lock().clear();
        *self.parent_rect.lock() = None;
        self.key_repeat.lock().clear();
    }

    #[instrument(target = "ui::edit")]
    async fn draw(
        &self,
        parent_rect: Rectangle,
        atom: &mut PropertyAtomicGuard,
    ) -> Option<DrawUpdate> {
        *self.parent_rect.lock() = Some(parent_rect);
        self.eval_rect(atom);
        // The fresh eval may have changed the content height, so re-clamp
        // the scroll to keep the cursor in view before computing draw instrs.
        self.behave.apply_cursor_scroll();
        Some(self.make_draw_calls())
    }

    async fn handle_char(&self, key: char, mods: KeyMods, repeat: bool) -> bool {
        ed!("handle_char({key}, {mods:?}, repeat={repeat}) before=[{}]", self.dbg_state());
        t!("handle_char({key}, {mods:?}, {repeat})");
        // First filter for only single digit keys
        if DISALLOWED_CHARS.contains(&key) {
            ed!("handle_char: {key:?} disallowed, ignoring");
            return false
        }

        if !self.is_focused.get() {
            ed!("handle_char: not focused, ignoring");
            return false
        }

        // Must be updated before checking the mods. You can press ctrl+a, then release ctrl
        // before a is released. Then the repeater never gets reset, and uses any old value
        // it has from before for a.
        let actions = {
            let mut repeater = self.key_repeat.lock();
            repeater.key_down(PressedKey::Char(key), repeat)
        };

        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_char"));

        if mods.ctrl || mods.alt || mods.logo {
            if repeat {
                return false
            }
            return self.handle_shortcut(key, &mods, atom);
        }

        // Do nothing
        if actions == 0 {
            return true
        }

        t!("Key {:?} has {} actions", key, actions);
        let key_str = key.to_string().repeat(actions as usize);
        self.editor.lock().insert(&key_str, atom);
        self.behave.apply_cursor_scroll();
        self.pause_blinking();
        // Any edit invalidates the action menu's selection
        self.action_mode.clear();
        ed!("handle_char: inserted {key_str:?} after=[{}]", self.dbg_state());
        true
    }

    async fn handle_key_down(&self, key: KeyCode, mods: KeyMods, repeat: bool) -> bool {
        ed!("handle_key_down({key:?}, {mods:?}, repeat={repeat}) before=[{}]", self.dbg_state());
        t!("handle_key_down({key:?}, {mods:?}, {repeat})");
        // First filter for only single digit keys
        // Avoid processing events handled by handle_char()
        if !ALLOWED_KEYCODES.contains(&key) {
            ed!("handle_key_down: {key:?} not in ALLOWED_KEYCODES, ignoring");
            return false
        }

        if !self.is_focused.get() {
            ed!("handle_key_down: not focused, ignoring");
            return false
        }

        let actions = {
            let mut repeater = self.key_repeat.lock();
            repeater.key_down(PressedKey::Key(key), repeat)
        };

        // Suppress noisy message
        if actions > 0 {
            t!("Key {:?} has {} actions", key, actions);
        }

        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_key_down"));

        let mut is_handled = false;
        for _ in 0..actions {
            is_handled = self.handle_key(&key, &mods, atom);
        }
        ed!("handle_key_down: {key:?} handled={is_handled} after=[{}]", self.dbg_state());
        is_handled
    }

    async fn handle_mouse_btn_down(&self, btn: MouseButton, mut mouse_pos: Point) -> bool {
        if !self.is_active.get() {
            return false
        }

        let rect = self.rect.get();
        if !rect.contains(mouse_pos) {
            return false
        }

        if btn == MouseButton::Right {
            let mut menu = action::Menu::new(
                self.font_size.get(),
                self.action_fg_color.get(),
                self.action_bg_color.get(),
                self.action_padding.get(),
                self.action_spacing.get(),
                self.window_scale.get(),
            );

            if self.text.get().is_empty() {
                menu.add("Paste", ACTION_PASTE);
            } else {
                menu.add("Copy", ACTION_COPY);
                menu.add("Paste", ACTION_PASTE);
                menu.add("Select All", ACTION_SELALL);
            }

            // Mouse pos relative to root layout
            menu.pos = mouse_pos - rect.pos();

            self.action_mode.set(menu);
            self.redraw.trigger();

            return true
        }

        // Handle main case
        if btn != MouseButton::Left {
            return false
        }

        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_mouse_btn_down"));

        // clicking inside box will:
        // 1. make it active
        // 2. begin selection
        if self.is_focused.get() {
            ed!("handle_mouse_btn_down({btn:?}, {mouse_pos:?}): already focused click");
            d!("BaseEdit clicked");
        } else {
            ed!("handle_mouse_btn_down({btn:?}, {mouse_pos:?}): focusing widget");
            d!("BaseEdit focused");
            self.is_focused.set(atom, true);

            let node = self.node();
            node.trigger("focus_request", vec![]).await.unwrap();
        }

        // Move mouse pos within this widget
        self.abs_to_local(&mut mouse_pos);

        self.editor.lock().driver().move_to_point(mouse_pos.x, mouse_pos.y);

        if !self.select_text.is_null(0).unwrap() {
            self.select_text.clone().set_null(atom, Role::Internal, 0).unwrap();
        }

        self.mouse_btn_held.store(true, Ordering::Relaxed);

        self.pause_blinking();
        // A click moves the cursor; any open action menu is stale now
        self.action_mode.clear();
        true
    }

    async fn handle_mouse_btn_up(&self, btn: MouseButton, mut mouse_pos: Point) -> bool {
        if !self.is_active.get() {
            return false
        }

        self.abs_to_local(&mut mouse_pos);

        // Check if action was clicked
        if btn != MouseButton::Left {
            return false
        }

        // releasing mouse button will end selection
        self.mouse_btn_held.store(false, Ordering::Relaxed);

        let atom = &mut self.redraw.make_guard(gfxtag!("BaseEdit::handle_mouse_btn_up"));
        if let Some(action_id) = self.action_mode.interact(mouse_pos) {
            match action_id {
                ACTION_COPY => {
                    if let Some(txt) = self.editor.lock().selected_text() {
                        clipboard::set(&txt);
                    }
                }
                ACTION_PASTE => {
                    if let Some(txt) = clipboard::get() {
                        self.editor.lock().insert(&txt, atom);
                        self.behave.apply_cursor_scroll();
                        self.finish_select(atom);
                    }
                }
                ACTION_SELALL => {
                    let mut editor = self.editor.lock();
                    editor.select_all();
                    if let Some(seltext) = editor.selected_text() {
                        self.select_text.clone().set_str(atom, Role::Internal, 0, seltext).unwrap();
                    }
                }
                _ => {}
            }

            return true;
        } else {
            // interact() already consumed the menu; the pass re-emits the
            // (now empty) action overlay when the batch settles.
        }

        // Stop any selection scrolling
        let scroll_sender = self.sel_sender.lock().clone().unwrap();
        scroll_sender.send(None).await.unwrap();

        false
    }

    async fn handle_mouse_move(&self, mouse_pos: Point) -> bool {
        if !self.is_active.get() {
            return false
        }

        let rect = self.rect.get();
        let is_mouse_hover = rect.contains(mouse_pos);
        self.is_mouse_hover.store(is_mouse_hover, Ordering::Relaxed);

        if !self.mouse_btn_held.load(Ordering::Relaxed) {
            return false
        }

        let sel_sender = self.sel_sender.lock().clone().unwrap();
        // Mouse is outside rect?
        // If so we gotta scroll it while selecting.
        if !is_mouse_hover {
            // This process will begin selecting text and applying scroll too.
            sel_sender.send(Some((mouse_pos, None))).await.unwrap();
        } else {
            // Stop any existing select/scroll process
            sel_sender.send(None).await.unwrap();
            // Mouse is inside so just select the text once and be done.
            self.handle_select(mouse_pos, None);
        }

        true
    }

    async fn handle_mouse_wheel(&self, wheel_pos: Point) -> bool {
        if !self.is_mouse_hover.load(Ordering::Relaxed) {
            return false
        }

        let mut scroll =
            self.scroll.load(Ordering::Relaxed) - wheel_pos.y * self.scroll_speed.get();
        scroll = scroll.clamp(0., self.behave.max_scroll());
        t!("handle_mouse_wheel({wheel_pos:?}) [scroll={scroll}]");
        self.scroll.store(scroll, Ordering::Release);
        self.redraw.trigger();

        true
    }

    /// Runs on the Stage thread inside the miniquad event callback.
    /// Converted to mutate + trigger: state mutations happen inline and the
    /// redraw is enqueued for the serialized draw pass (one extra hop of
    /// latency for drag-handle feedback; see design.md D6).
    fn handle_touch_sync(&self, phase: TouchPhase, id: u64, touch_pos: Point) -> bool {
        if !self.is_active.get() {
            return false
        }

        // Ignore multi-touch
        if id != 0 {
            return false
        }

        match phase {
            TouchPhase::Started => self.handle_touch_start(touch_pos),
            TouchPhase::Moved => self.handle_touch_move(touch_pos),
            TouchPhase::Ended | TouchPhase::Cancelled => false,
        }
    }

    async fn handle_touch(&self, phase: TouchPhase, id: u64, touch_pos: Point) -> bool {
        if !self.is_active.get() {
            return false
        }

        // Ignore multi-touch
        if id != 0 {
            return false
        }

        match phase {
            TouchPhase::Started | TouchPhase::Moved | TouchPhase::Cancelled => false,
            TouchPhase::Ended => self.handle_touch_end(touch_pos).await,
        }
    }
}

// TODO: impl Drop

impl std::fmt::Debug for BaseEdit {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        write!(f, "{:?}", self.node.upgrade().unwrap())
    }
}