cranpose_foundation/text/

state.rs

use std::{
    cell::{Cell, RefCell},
    collections::VecDeque,
    hash::{Hash, Hasher},
    rc::Rc,
};

use cranpose_core::MutableState;

use super::{TextFieldBuffer, TextRange};

/// Immutable snapshot of text field content.
///
/// This represents the text, selection, and composition state at a point in time.
#[derive(Debug, Clone, PartialEq, Eq, Default)]
pub struct TextFieldValue {
    /// The text content
    pub text: String,
    /// Current selection or cursor position
    pub selection: TextRange,
    /// IME composition range, if any
    pub composition: Option<TextRange>,
}

impl TextFieldValue {
    /// Creates a new value with the given text and cursor at end.
    pub fn new(text: impl Into<String>) -> Self {
        let text = text.into();
        let len = text.len();
        Self {
            text,
            selection: TextRange::cursor(len),
            composition: None,
        }
    }

    /// Creates a value with specified text and selection.
    pub fn with_selection(text: impl Into<String>, selection: TextRange) -> Self {
        let text = text.into();
        let selection = selection.coerce_in(text.len());
        Self {
            text,
            selection,
            composition: None,
        }
    }
}

type ChangeListener = Box<dyn Fn(&TextFieldValue)>;

const UNDO_CAPACITY: usize = 100;

const UNDO_COALESCE_MS: u128 = 1000;

pub struct TextFieldStateInner {
    is_editing: bool,
    listeners: Vec<ChangeListener>,
    undo_stack: VecDeque<TextFieldValue>,
    redo_stack: VecDeque<TextFieldValue>,
    desired_column: Cell<Option<usize>>,
    last_edit_time: Cell<Option<web_time::Instant>>,
    pending_undo_snapshot: RefCell<Option<TextFieldValue>>,
    line_offsets_cache: RefCell<Option<Vec<usize>>>,
}

struct EditGuard<'a> {
    inner: &'a RefCell<TextFieldStateInner>,
}

impl<'a> EditGuard<'a> {
    fn new(inner: &'a RefCell<TextFieldStateInner>) -> Result<Self, ()> {
        {
            let borrowed = inner.borrow();
            if borrowed.is_editing {
                return Err(());
            }
        }
        inner.borrow_mut().is_editing = true;
        Ok(Self { inner })
    }
}

impl Drop for EditGuard<'_> {
    fn drop(&mut self) {
        self.inner.borrow_mut().is_editing = false;
    }
}

/// Observable state holder for text field content.
///
/// This is the primary API for managing text field state. All edits go through
/// the [`edit`](Self::edit) method which provides a mutable buffer.
///
/// # Example
///
/// ```ignore
/// use cranpose_foundation::text::TextFieldState;
///
/// let state = TextFieldState::new("Hello");
///
/// // Edit the text
/// state.edit(|buffer| {
///     buffer.place_cursor_at_end();
///     buffer.insert(", World!");
/// });
///
/// assert_eq!(state.text(), "Hello, World!");
/// ```
///
/// # Thread Safety
///
/// `TextFieldState` uses `Rc<RefCell<...>>` internally and is not thread-safe.
/// It should only be used from the main thread.
#[derive(Clone, Copy)]
pub struct TextFieldState {
    /// Internal state for editing machinery.
    /// Public for cross-crate pointer-based identity comparison (Hash).
    pub inner: MutableState<Rc<RefCell<TextFieldStateInner>>>,

    value: MutableState<TextFieldValue>,
}

impl std::fmt::Debug for TextFieldState {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        self.value.with(|v| {
            f.debug_struct("TextFieldState")
                .field("text", &v.text)
                .field("selection", &v.selection)
                .finish()
        })
    }
}

impl TextFieldState {
    /// Creates a new text field state with the given initial text.
    pub fn new(initial_text: impl Into<String>) -> Self {
        let initial_value = TextFieldValue::new(initial_text);
        let runtime = cranpose_core::current_runtime_handle()
            .expect("TextFieldState::new requires an active runtime");
        Self {
            inner: MutableState::with_runtime(
                Rc::new(RefCell::new(TextFieldStateInner {
                    is_editing: false,
                    listeners: Vec::new(),
                    undo_stack: VecDeque::new(),
                    redo_stack: VecDeque::new(),
                    desired_column: Cell::new(None),
                    last_edit_time: Cell::new(None),
                    pending_undo_snapshot: RefCell::new(None),
                    line_offsets_cache: RefCell::new(None),
                })),
                runtime.clone(),
            ),
            value: MutableState::with_runtime(initial_value, runtime),
        }
    }

    /// Creates a state with initial text and selection.
    pub fn with_selection(initial_text: impl Into<String>, selection: TextRange) -> Self {
        let initial_value = TextFieldValue::with_selection(initial_text, selection);
        let runtime = cranpose_core::current_runtime_handle()
            .expect("TextFieldState::with_selection requires an active runtime");
        Self {
            inner: MutableState::with_runtime(
                Rc::new(RefCell::new(TextFieldStateInner {
                    is_editing: false,
                    listeners: Vec::new(),
                    undo_stack: VecDeque::new(),
                    redo_stack: VecDeque::new(),
                    desired_column: Cell::new(None),
                    last_edit_time: Cell::new(None),
                    pending_undo_snapshot: RefCell::new(None),
                    line_offsets_cache: RefCell::new(None),
                })),
                runtime.clone(),
            ),
            value: MutableState::with_runtime(initial_value, runtime),
        }
    }

    fn inner(&self) -> Rc<RefCell<TextFieldStateInner>> {
        self.inner.get_non_reactive()
    }

    pub fn id(&self) -> u64 {
        let mut hasher = std::collections::hash_map::DefaultHasher::new();
        self.inner.runtime_state_id().hash(&mut hasher);
        hasher.finish()
    }

    /// Gets the desired column for up/down navigation.
    pub fn desired_column(&self) -> Option<usize> {
        self.inner().borrow().desired_column.get()
    }

    /// Sets the desired column for up/down navigation.
    pub fn set_desired_column(&self, col: Option<usize>) {
        self.inner().borrow().desired_column.set(col);
    }

    /// Returns the current text content.
    /// Creates composition dependency when read during composition.
    pub fn text(&self) -> String {
        self.value.with(|v| v.text.clone())
    }

    /// Returns the current selection range.
    pub fn selection(&self) -> TextRange {
        self.value.with(|v| v.selection)
    }

    /// Returns the current composition (IME) range, if any.
    pub fn composition(&self) -> Option<TextRange> {
        self.value.with(|v| v.composition)
    }

    /// Returns cached line start offsets for efficient multiline operations.
    ///
    /// Each entry is the byte offset where a line starts. For example:
    /// - "ab\ncd" -> [0, 3] (line 0 starts at 0, line 1 starts at 3)
    /// - "" -> `0`
    ///
    /// The cache is lazily computed on first access and invalidated on text change.
    /// This avoids O(n) string splitting on every frame during selection rendering.
    pub fn line_offsets(&self) -> Vec<usize> {
        let inner_state = self.inner();
        let inner = inner_state.borrow();

        if let Some(ref offsets) = *inner.line_offsets_cache.borrow() {
            return offsets.clone();
        }

        let text = self.text();
        let mut offsets = vec![0];
        for (i, c) in text.char_indices() {
            if c == '\n' {
                offsets.push(i + 1);
            }
        }

        *inner.line_offsets_cache.borrow_mut() = Some(offsets.clone());
        offsets
    }

    fn invalidate_line_cache(&self) {
        self.inner().borrow().line_offsets_cache.borrow_mut().take();
    }

    /// Copies the selected text without modifying the clipboard.
    /// Returns the selected text, or None if no selection.
    pub fn copy_selection(&self) -> Option<String> {
        self.value.with(|v| {
            let selection = v.selection;
            if selection.collapsed() {
                return None;
            }
            let start = selection.min();
            let end = selection.max();
            Some(v.text[start..end].to_string())
        })
    }

    /// Returns the current value snapshot.
    /// Creates composition dependency when read during composition.
    pub fn value(&self) -> TextFieldValue {
        self.value.with(|v| v.clone())
    }

    /// Adds a listener that is called when the value changes.
    ///
    /// Returns the listener index for removal.
    pub fn add_listener(&self, listener: impl Fn(&TextFieldValue) + 'static) -> usize {
        let inner_state = self.inner();
        let mut inner = inner_state.borrow_mut();
        let index = inner.listeners.len();
        inner.listeners.push(Box::new(listener));
        index
    }

    /// Sets the selection directly without going through undo stack.
    /// Use this for transient selection changes like during drag selection.
    pub fn set_selection(&self, selection: TextRange) {
        let new_value = self.value.with(|v| {
            let len = v.text.len();
            TextFieldValue {
                text: v.text.clone(),
                selection: selection.coerce_in(len),
                composition: v.composition,
            }
        });
        self.value.set(new_value);
    }

    /// Returns true if undo is available.
    pub fn can_undo(&self) -> bool {
        !self.inner().borrow().undo_stack.is_empty()
    }

    /// Returns true if redo is available.
    pub fn can_redo(&self) -> bool {
        !self.inner().borrow().redo_stack.is_empty()
    }

    /// Undoes the last edit.
    /// Returns true if undo was performed.
    pub fn undo(&self) -> bool {
        self.flush_undo_group();

        let inner_state = self.inner();
        let mut inner = inner_state.borrow_mut();
        if let Some(previous_state) = inner.undo_stack.pop_back() {
            let current = self.value.with(|v| v.clone());
            inner.redo_stack.push_back(current);
            inner.last_edit_time.set(None);
            drop(inner);
            self.value.set(previous_state);
            true
        } else {
            false
        }
    }

    /// Redoes the last undone edit.
    /// Returns true if redo was performed.
    pub fn redo(&self) -> bool {
        let inner_state = self.inner();
        let mut inner = inner_state.borrow_mut();
        if let Some(redo_state) = inner.redo_stack.pop_back() {
            let current = self.value.with(|v| v.clone());
            inner.undo_stack.push_back(current);
            drop(inner);
            self.value.set(redo_state);
            true
        } else {
            false
        }
    }

    /// Edits the text field content.
    ///
    /// The provided closure receives a mutable buffer that can be used to
    /// modify the text and selection. After the closure returns, the changes
    /// are committed and listeners are notified.
    ///
    /// # Undo Coalescing
    ///
    /// Consecutive character insertions within the coalescing timeout are grouped
    /// into a single undo entry. The group breaks when:
    /// - Timeout expires (1 second between edits)
    /// - Whitespace or newline is typed
    /// - Cursor position jumps (non-consecutive insert)
    /// - A non-insert operation occurs (delete, paste multi-char, etc.)
    ///
    /// Returns `false` if another edit is already in progress.
    pub fn edit<F>(&self, f: F) -> bool
    where
        F: FnOnce(&mut TextFieldBuffer),
    {
        let inner = self.inner();
        let Ok(guard) = EditGuard::new(&inner) else {
            return false;
        };

        let current = self.value();
        let mut buffer = TextFieldBuffer::with_selection(&current.text, current.selection);
        if let Some(comp) = current.composition {
            buffer.set_composition(Some(comp));
        }

        f(&mut buffer);

        let new_value = TextFieldValue {
            text: buffer.text().to_string(),
            selection: buffer.selection(),
            composition: buffer.composition(),
        };

        let changed = new_value != current;
        let text_changed = new_value.text != current.text;

        if text_changed {
            self.invalidate_line_cache();
        }

        if changed {
            let now = web_time::Instant::now();

            let should_break_group = {
                let inner_state = self.inner();
                let inner = inner_state.borrow();

                let timeout_expired = inner
                    .last_edit_time
                    .get()
                    .map(|last| now.duration_since(last).as_millis() > UNDO_COALESCE_MS)
                    .unwrap_or(true);

                if timeout_expired {
                    true
                } else {
                    let text_delta = new_value.text.len() as i64 - current.text.len() as i64;
                    let is_single_char_insert = text_delta == 1;

                    let ends_with_whitespace = new_value.text.ends_with(char::is_whitespace);

                    let cursor_jumped = new_value.selection.start != current.selection.start + 1
                        && new_value.selection.start != current.selection.end + 1;

                    !is_single_char_insert || ends_with_whitespace || cursor_jumped
                }
            };

            {
                let inner_state = self.inner();
                let inner = inner_state.borrow();

                if should_break_group {
                    let pending = inner.pending_undo_snapshot.take();
                    drop(inner);

                    let inner_state = self.inner();
                    let mut inner = inner_state.borrow_mut();
                    if let Some(snapshot) = pending {
                        if inner.undo_stack.len() >= UNDO_CAPACITY {
                            inner.undo_stack.pop_front();
                        }
                        inner.undo_stack.push_back(snapshot);
                    }
                    inner.redo_stack.clear();
                    drop(inner);
                    self.inner()
                        .borrow()
                        .pending_undo_snapshot
                        .replace(Some(current.clone()));
                } else {
                    if inner.pending_undo_snapshot.borrow().is_none() {
                        inner.pending_undo_snapshot.replace(Some(current.clone()));
                    }
                    drop(inner);
                    self.inner().borrow_mut().redo_stack.clear();
                }

                self.inner().borrow().last_edit_time.set(Some(now));
            }

            self.value.set(new_value.clone());
        }

        drop(guard);

        if changed {
            let listener_count = self.inner().borrow().listeners.len();
            for i in 0..listener_count {
                let inner_state = self.inner();
                let inner = inner_state.borrow();
                if i < inner.listeners.len() {
                    (inner.listeners[i])(&new_value);
                }
            }
        }
        true
    }

    /// Flushes any pending undo snapshot to the undo stack.
    /// Call this when a coalescing break is desired (e.g., focus lost).
    pub fn flush_undo_group(&self) {
        let inner_state = self.inner();
        let inner = inner_state.borrow();
        if let Some(snapshot) = inner.pending_undo_snapshot.take() {
            drop(inner);
            let inner_state = self.inner();
            let mut inner = inner_state.borrow_mut();
            if inner.undo_stack.len() >= UNDO_CAPACITY {
                inner.undo_stack.pop_front();
            }
            inner.undo_stack.push_back(snapshot);
        }
    }

    /// Sets the text and places cursor at end.
    pub fn set_text(&self, text: impl Into<String>) -> bool {
        let text = text.into();
        self.edit(|buffer| {
            buffer.clear();
            buffer.insert(&text);
        })
    }
}

impl Default for TextFieldState {
    fn default() -> Self {
        Self::new("")
    }
}

impl PartialEq for TextFieldState {
    fn eq(&self, other: &Self) -> bool {
        self.inner == other.inner
    }
}

#[cfg(test)]
mod tests {
    use std::sync::Arc;

    use cranpose_core::{DefaultScheduler, Runtime};

    use super::*;

    fn with_test_runtime<T>(f: impl FnOnce() -> T) -> T {
        let _runtime = Runtime::new(Arc::new(DefaultScheduler));
        f()
    }

    #[test]
    fn a_desired_column_is_remembered_until_it_is_cleared() {
        with_test_runtime(|| {
            let state = TextFieldState::new("Hello");
            assert_eq!(
                state.desired_column(),
                None,
                "a field nobody navigated vertically had a remembered column"
            );

            state.set_desired_column(Some(7));
            assert_eq!(state.desired_column(), Some(7));

            state.set_desired_column(None);
            assert_eq!(state.desired_column(), None);
        });
    }

    #[test]
    fn flushing_an_undo_group_is_harmless_when_nothing_is_pending() {
        with_test_runtime(|| {
            let state = TextFieldState::new("Hello");
            state.flush_undo_group();
            state.flush_undo_group();
            assert_eq!(state.text(), "Hello");
        });
    }

    #[test]
    fn flushing_an_undo_group_breaks_the_coalescing_between_two_edits() {
        with_test_runtime(|| {
            let state = TextFieldState::new("");
            state.edit(|buffer| buffer.insert("ab"));
            state.flush_undo_group();
            state.edit(|buffer| buffer.insert("cd"));
            assert_eq!(state.text(), "abcd");

            state.undo();
            assert_eq!(
                state.text(),
                "ab",
                "the flush did not break the two edits apart"
            );
        });
    }

    #[test]
    fn new_state_has_cursor_at_end() {
        with_test_runtime(|| {
            let state = TextFieldState::new("Hello");
            assert_eq!(state.text(), "Hello");
            assert_eq!(state.selection(), TextRange::cursor(5));
        });
    }

    #[test]
    fn edit_updates_text() {
        with_test_runtime(|| {
            let state = TextFieldState::new("Hello");
            state.edit(|buffer| {
                buffer.place_cursor_at_end();
                buffer.insert(", World!");
            });
            assert_eq!(state.text(), "Hello, World!");
        });
    }

    #[test]
    fn edit_updates_selection() {
        with_test_runtime(|| {
            let state = TextFieldState::new("Hello");
            state.edit(|buffer| {
                buffer.select_all();
            });
            assert_eq!(state.selection(), TextRange::new(0, 5));
        });
    }

    #[test]
    fn set_text_replaces_content() {
        with_test_runtime(|| {
            let state = TextFieldState::new("Hello");
            state.set_text("Goodbye");
            assert_eq!(state.text(), "Goodbye");
            assert_eq!(state.selection(), TextRange::cursor(7));
        });
    }

    #[test]
    fn nested_edit_is_rejected() {
        with_test_runtime(|| {
            use std::{cell::Cell, rc::Rc};

            let state = TextFieldState::new("Hello");
            let state_clone = state;
            let nested_result = Rc::new(Cell::new(true));
            let nested_result_for_edit = nested_result.clone();
            let outer_result = state.edit(move |_buffer| {
                nested_result_for_edit.set(state_clone.edit(|_| {}));
            });
            assert!(outer_result);
            assert!(!nested_result.get());
        });
    }

    #[test]
    fn listener_is_called_on_change() {
        with_test_runtime(|| {
            use std::{cell::Cell, rc::Rc};

            let state = TextFieldState::new("Hello");
            let called = Rc::new(Cell::new(false));
            let called_clone = called.clone();

            state.add_listener(move |_value| {
                called_clone.set(true);
            });

            state.edit(|buffer| {
                buffer.insert("!");
            });

            assert!(called.get());
        });
    }
}