aboutsummaryrefslogtreecommitdiffstats
path: root/default-plugins/sequence/src/ui
diff options
context:
space:
mode:
authorAram Drevekenin <aram@poor.dev>2025-12-11 14:25:42 +0100
committerGitHub <noreply@github.com>2025-12-11 14:25:42 +0100
commit693fa082def5ef0fe030cd7fdc3b1df051b35dc6 (patch)
treeb3f651462bbc1cd2fa5b2d79207343413ef6b83c /default-plugins/sequence/src/ui
parentfix(zellij-server): unblock building on 32bit targets (#4484) (diff)
downloadsl0ppij-693fa082def5ef0fe030cd7fdc3b1df051b35dc6.tar.gz
sl0ppij-693fa082def5ef0fe030cd7fdc3b1df051b35dc6.tar.xz
sl0ppij-693fa082def5ef0fe030cd7fdc3b1df051b35dc6.zip
Command Sequences, Blocking CLI Commands, New Plugin APIs (#4546)
* fix deadlocks * initial logging to plugin implementation * only log actions, include keys as Action::Write * send actions to plugins as a new Event::UserAction * add Action::Write metadata to plugin API * run_action plugin command and permission * block-until-exit/success/failure in the cli * fix tests * add NewBlockingPane to the plugin API * run actions in a different thread so as not to block plugin execution * add custom context to run_action flow * fixes for floating pane z_index sorting and unknown protobuf events not crashing plugins * always render the frame of pinned panes * macros module * add macros to config * KDL macro parsing * thread macros to the plugin thread * get/update/delete macros from plugins * add macros updated event * add ability to rename macros * fix deadlock * fix z_indices with pinned unselectable panes bug * allow plugins to opt-in to show_cursor * change show_cursor(bool) to show_cursor(Option<coordinates>) * test * upgrade strum to allow proper enum iteration and case insensitive fromstr implementation for Actions * better cwd tracking for exited command panes * add initial panes to NewTab Action (no-op for now) * add initial panes to cli newtab action * make initial panes work * add close_on_exit and start_suspended to the cli * properly convert newtab action (potentially breaking for plugins) * allow first pane in tab to block * make distinction between opening panes with the last active client and the current pane in the cli * improve some apis * fix fixed size closing pane bug * fix plugin cursor coordinates * fix issues with launch-or-focus-plugin having to do with in-place and suppressed panes * fix: set affected pane in replace pane * allow setting a pane in place when it is suppressed and being focused (tests failing) * fix tests * some fixes for unsuppression of panes * some fixes for completion_tx in new tab action * allow replace/suppressed rather than replace/close only * fixes for inserting suppressed panes without conflicts * pane focus history and explicit unsuppress plugin api * fix: prefer explicitly provided pane id in placement in actions that provide it * fix floating pane coordinate change and z_index * fix plugin cache dir to persist between sessions * fix some stack focusing issues when adding panes without a client id * make sure pinned panes are always above non-pinned floating panes * allow plugins to copy to clipboard * initial text styling additions implementations - buggy * fix dimming issues * remove extras, stay with just dim and unbold * unbold and dim as indices * allow ui components to render success/error colors * allow plugins to send sigint/sigkill to processes, as well as receive their pid * ui component fixes and send originating plugin context with run_action * originating plugin for new tab too * make plugn show pane command also expand stacked panes * add sequence plugin * remove macros * remove snapshots * add shortcut for sequence plugin * fix plugin tests * plugin tests for new apis * update snapshots for sequence shortcut * cleanups and formatting * Event::CwdChanged * moar cleanups * remove some warnings * remove mroe warnings * remove dead code * remove more dead code * fix minor bugs in sequence plugin * update sequence help and format codebase * fix conditional blocking cli commands * fix initial-command new-tab cli flag * add client_ids to CwdChanged Event * last fixes * add pr
Diffstat (limited to 'default-plugins/sequence/src/ui')
-rw-r--r--default-plugins/sequence/src/ui/components.rs596
-rw-r--r--default-plugins/sequence/src/ui/fuzzy_complete.rs321
-rw-r--r--default-plugins/sequence/src/ui/layout_calculations.rs28
-rw-r--r--default-plugins/sequence/src/ui/mod.rs5
-rw-r--r--default-plugins/sequence/src/ui/text_input.rs997
-rw-r--r--default-plugins/sequence/src/ui/truncation.rs373
6 files changed, 2320 insertions, 0 deletions
diff --git a/default-plugins/sequence/src/ui/components.rs b/default-plugins/sequence/src/ui/components.rs
new file mode 100644
index 00000000..3fe2ae1a
--- /dev/null
+++ b/default-plugins/sequence/src/ui/components.rs
@@ -0,0 +1,596 @@
+use crate::path_formatting::format_cwd;
+use crate::state::{CommandStatus, State};
+use crate::ui::truncation::{calculate_available_cmd_width, truncate_middle};
+use std::path::PathBuf;
+use zellij_tile::prelude::*;
+
+const SPINNER_FRAMES: &[&str] = &["⠋", "⠙", "⠹", "⠸", "⠼", "⠴", "⠦", "⠧"];
+
+const HELP_RUNNING_WITH_SELECTION: &str = "<Ctrl c> - interrupt, <Enter> - run from selected";
+const HELP_RUNNING_NO_SELECTION: &str = "<Ctrl c> - interrupt, <↓↑> - navigate";
+const HELP_STOPPED_WITH_SELECTION: &str =
+ "<Ctrl w> - close all, <Enter> - run from selected, <e> - edit";
+const HELP_STOPPED_NO_SELECTION: &str =
+ "<Ctrl w> - close all, <↓↑> - navigate, <Enter> - run from first";
+
+const HELP_ONE_PENDING_COMMAND: &str = "<Enter> - run, <Ctrl Enter> - add command";
+
+const HELP_ALL_COMMANDS_PENDING: &str =
+ "<Enter> - run, <Ctrl Enter> - add command, <↓↑> - navigate";
+const HELP_ALL_COMMANDS_PENDING_WITH_SELECTION: &str =
+ "<Enter> - run, <Ctrl Enter> - add command, <↓↑> - navigate, <e> - edit selected";
+
+const HELP_EDITING_FIRST_LINE: &str =
+ "<Enter> - accept, <Ctrl Enter> - add command, <↓↑> - navigate";
+
+fn select_help_text(sequence: &State) -> &'static str {
+ let is_running = sequence
+ .execution
+ .all_commands
+ .iter()
+ .any(|command| matches!(command.get_status(), CommandStatus::Running(_)));
+ let all_pending = sequence
+ .execution
+ .all_commands
+ .iter()
+ .all(|command| matches!(command.get_status(), CommandStatus::Pending));
+ let has_selection = sequence.selection.current_selected_command_index.is_some();
+ let is_editing = sequence.editing.editing_input.is_some();
+
+ if all_pending && !sequence.execution.is_running {
+ if sequence.execution.all_commands.len() == 1 {
+ HELP_ONE_PENDING_COMMAND
+ } else if has_selection && !is_editing {
+ HELP_ALL_COMMANDS_PENDING_WITH_SELECTION
+ } else if is_editing {
+ HELP_EDITING_FIRST_LINE
+ } else {
+ HELP_ALL_COMMANDS_PENDING
+ }
+ } else if is_running {
+ if has_selection {
+ HELP_RUNNING_WITH_SELECTION
+ } else {
+ HELP_RUNNING_NO_SELECTION
+ }
+ } else {
+ if has_selection && !is_editing {
+ HELP_STOPPED_WITH_SELECTION
+ } else if is_editing {
+ HELP_EDITING_FIRST_LINE
+ } else {
+ HELP_STOPPED_NO_SELECTION
+ }
+ }
+}
+
+fn style_help_text(text: &str) -> Text {
+ Text::new(text)
+ .color_substring(3, "<Ctrl c>")
+ .color_substring(3, "<Ctrl w>")
+ .color_substring(3, "<↓↑>")
+ .color_substring(3, "<Esc>")
+ .color_substring(3, "<Enter>")
+ .color_substring(3, "<Ctrl Enter>")
+ .color_substring(3, "<e>")
+}
+
+pub fn render_help_lines(
+ sequence: &State,
+ max_width: Option<usize>,
+) -> (Text, usize, Option<(Text, usize)>) {
+ let is_editing = sequence.editing.editing_input.is_some();
+
+ if is_editing {
+ let help_text = select_help_text(sequence);
+ let (truncated_text, help_len) = if let Some(width) = max_width {
+ truncate_help_line(help_text, width)
+ } else {
+ (help_text.to_string(), help_text.chars().count())
+ };
+ let first_line = (style_help_text(&truncated_text).unbold_all(), help_len);
+
+ let editing_help_text = "Navigate with cd, chain with ||, &&, ; ";
+ let editing_help = Text::new(editing_help_text)
+ .color_substring(3, "cd")
+ .color_substring(3, "||")
+ .color_substring(3, "&&")
+ .color_substring(3, ";")
+ .unbold_all();
+ let editing_len = editing_help_text.len();
+
+ return (
+ first_line.0,
+ first_line.1,
+ Some((editing_help, editing_len)),
+ );
+ }
+
+ let help_text = select_help_text(sequence);
+
+ if let Some(width) = max_width {
+ if let Some((first_line, second_line)) = split_help_line(help_text, width) {
+ let first_len = first_line.chars().count();
+ let first_styled = style_help_text(&first_line).unbold_all();
+
+ let second_line_width = second_line.chars().count();
+ let (second_styled, second_len) = if second_line_width > width {
+ let (truncated, len) = truncate_help_line(&second_line, width);
+ (style_help_text(&truncated).unbold_all(), len)
+ } else {
+ (
+ style_help_text(&second_line).unbold_all(),
+ second_line_width,
+ )
+ };
+
+ return (first_styled, first_len, Some((second_styled, second_len)));
+ }
+
+ let (truncated_text, help_len) = truncate_help_line(help_text, width);
+ (
+ style_help_text(&truncated_text).unbold_all(),
+ help_len,
+ None,
+ )
+ } else {
+ let help_len = help_text.chars().count();
+ (style_help_text(help_text).unbold_all(), help_len, None)
+ }
+}
+
+fn split_help_line(help_text: &str, max_width: usize) -> Option<(String, String)> {
+ let text_width = help_text.chars().count();
+
+ if text_width <= max_width {
+ return None;
+ }
+
+ let keybindings = parse_help_keybindings(help_text);
+
+ if keybindings.is_empty() {
+ return None;
+ }
+
+ for split_point in 1..keybindings.len() {
+ let first_part: Vec<String> = keybindings
+ .iter()
+ .take(split_point)
+ .map(|(key, _, action)| format!("{} - {}", key, action))
+ .collect();
+ let first_line = first_part.join(", ");
+
+ let second_part: Vec<String> = keybindings
+ .iter()
+ .skip(split_point)
+ .map(|(key, _, action)| format!("{} - {}", key, action))
+ .collect();
+ let second_line = second_part.join(", ");
+
+ if first_line.chars().count() <= max_width && second_line.chars().count() <= max_width {
+ return Some((first_line, second_line));
+ }
+ }
+
+ None
+}
+
+fn folder_cell(cwd: &Option<PathBuf>) -> (Text, String) {
+ let cwd_display = if let Some(cwd) = cwd {
+ format_cwd(cwd)
+ } else {
+ "~".to_string()
+ };
+ let folder_display = format!("{} >", cwd_display);
+ let text = Text::new(&folder_display).color_range(0, 0..cwd_display.len());
+ (text, folder_display)
+}
+
+fn command_cell(text: &str) -> Text {
+ let text = if text.is_empty() { " " } else { text };
+ Text::new(text)
+}
+
+fn chain_cell(chain_type: &crate::state::ChainType) -> Text {
+ let text = chain_type_to_str(chain_type);
+ if !text.is_empty() {
+ Text::new(text).color_range(1, 0..text.len())
+ } else {
+ Text::new(text)
+ }
+}
+
+fn get_spinner_frame(frame: usize) -> &'static str {
+ SPINNER_FRAMES[frame % SPINNER_FRAMES.len()]
+}
+
+pub fn format_status_text(status: &CommandStatus, spinner_frame: usize) -> String {
+ match status {
+ CommandStatus::Running(_) => {
+ let spinner = get_spinner_frame(spinner_frame);
+ format!("[RUNNING] {}", spinner)
+ },
+ CommandStatus::Interrupted(_) => "[INTERRUPTED]".to_string(),
+ CommandStatus::Exited(Some(code), _) => format!("[EXIT CODE: {}]", code),
+ CommandStatus::Exited(None, _) => "[EXITED]".to_string(),
+ CommandStatus::Pending => " ".to_string(),
+ }
+}
+
+fn apply_status_color(text: Text, status: &CommandStatus, status_str: &str) -> Text {
+ match status {
+ CommandStatus::Running(_) => text.color_range(3, 0..status_str.len()),
+ CommandStatus::Interrupted(_) => text.error_color_range(0..status_str.len()),
+ CommandStatus::Exited(Some(0), _) => {
+ let number_start = 12;
+ let number_end = status_str.len() - 1;
+ text.success_color_range(number_start..number_end)
+ },
+ CommandStatus::Exited(Some(_), _) => {
+ let number_start = 12;
+ let number_end = status_str.len() - 1;
+ text.error_color_range(number_start..number_end)
+ },
+ _ => text,
+ }
+}
+
+fn status_cell(status: &CommandStatus, spinner_frame: usize) -> Text {
+ let status_str = format_status_text(status, spinner_frame);
+ let text = Text::new(&status_str);
+ apply_status_color(text, status, &status_str)
+}
+
+fn apply_row_styles(cells: Vec<Text>, is_selected: bool) -> Vec<Text> {
+ let mut styled_cells = cells;
+
+ if is_selected {
+ styled_cells = styled_cells.into_iter().map(|c| c.selected()).collect();
+ }
+
+ styled_cells
+}
+
+fn overflow_cell(indicator: &str, is_selected: bool) -> Text {
+ let mut text = Text::new(indicator).dim_all();
+ if is_selected {
+ text = text.selected();
+ }
+ text
+}
+
+fn command_sequence_row(
+ state: &State,
+ cwd: &Option<PathBuf>,
+ truncated_cmd_text: &str,
+ chain_type: &crate::state::ChainType,
+ status: &crate::state::CommandStatus,
+ is_selected: bool,
+ overflow_indicator: Option<String>,
+) -> (Vec<Text>, usize) {
+ let (folder_text, folder_display) = folder_cell(cwd);
+
+ let mut cells = vec![
+ folder_text,
+ command_cell(truncated_cmd_text),
+ chain_cell(chain_type),
+ status_cell(status, state.layout.spinner_frame),
+ ];
+
+ cells = apply_row_styles(cells, is_selected);
+
+ let truncated_cmd_text = if truncated_cmd_text.is_empty() {
+ " "
+ } else {
+ truncated_cmd_text
+ };
+ let mut row_length = folder_display.chars().count()
+ + truncated_cmd_text.chars().count()
+ + chain_type_to_str(chain_type).chars().count()
+ + format_status_text(status, state.layout.spinner_frame)
+ .chars()
+ .count()
+ + 3;
+
+ if let Some(indicator) = overflow_indicator {
+ let indicator_len = indicator.chars().count();
+ cells.push(overflow_cell(&indicator, is_selected));
+ row_length += indicator_len + 1;
+ }
+
+ (cells, row_length)
+}
+
+pub fn build_table_header(has_overflow: bool) -> Table {
+ let header_cols = if has_overflow {
+ vec![" ", " ", " ", " ", " "]
+ } else {
+ vec![" ", " ", " ", " "]
+ };
+ Table::new().add_row(header_cols)
+}
+
+fn calculate_overflow_indicator(
+ visible_idx: usize,
+ visible_count: usize,
+ hidden_above: usize,
+ hidden_below: usize,
+) -> Option<String> {
+ if visible_idx == 0 && hidden_above > 0 {
+ Some(format!("[+{}]", hidden_above))
+ } else if visible_idx == visible_count.saturating_sub(1) && hidden_below > 0 {
+ Some(format!("[+{}]", hidden_below))
+ } else if hidden_above > 0 || hidden_below > 0 {
+ Some(format!(" "))
+ } else {
+ None
+ }
+}
+
+pub fn calculate_row_layout_info(
+ index: usize,
+ offset: usize,
+ visible_count: usize,
+ hidden_above: usize,
+ hidden_below: usize,
+ cols: usize,
+ folder_width: usize,
+ max_chain_width: usize,
+ max_status_width: usize,
+) -> Option<(Option<String>, usize)> {
+ if index < offset || index >= offset + visible_count {
+ return None;
+ }
+
+ let visible_idx = index.saturating_sub(offset);
+ let overflow_indicator =
+ calculate_overflow_indicator(visible_idx, visible_count, hidden_above, hidden_below);
+
+ let available_cmd_width = calculate_available_cmd_width(
+ cols,
+ folder_width,
+ overflow_indicator.as_ref(),
+ max_chain_width,
+ max_status_width,
+ );
+
+ Some((overflow_indicator, available_cmd_width))
+}
+
+pub fn add_command_row(
+ table: Table,
+ state: &State,
+ index: usize,
+ offset: usize,
+ visible_count: usize,
+ hidden_above: usize,
+ hidden_below: usize,
+) -> Table {
+ let command = match state.execution.all_commands.get(index) {
+ Some(cmd) => cmd,
+ None => return table,
+ };
+
+ let cmd_text = &command.get_text();
+ let chain_type = &command.get_chain_type();
+ let status = &command.get_status();
+ let command_cwd = command.get_cwd().or_else(|| state.cwd.clone());
+
+ let cols = state.own_columns.unwrap_or(80);
+ let longest_cwd_display = state.execution.longest_cwd_display(&state.cwd);
+ let folder_display = format!("{} >", longest_cwd_display);
+ let folder_width = folder_display.chars().count();
+
+ let (max_chain_width, max_status_width) =
+ calculate_max_widths(&state.execution.all_commands, state.layout.spinner_frame);
+
+ let Some((overflow_indicator, available_cmd_width)) = calculate_row_layout_info(
+ index,
+ offset,
+ visible_count,
+ hidden_above,
+ hidden_below,
+ cols,
+ folder_width,
+ max_chain_width,
+ max_status_width,
+ ) else {
+ return table;
+ };
+
+ if let Some(text_input) = &state.editing.editing_input {
+ if state.selection.current_selected_command_index == Some(index) {
+ let (truncated_editing_text, _) = truncate_middle(
+ text_input.get_text(),
+ available_cmd_width,
+ Some(text_input.cursor_position()),
+ );
+ let (row, _) = command_sequence_row(
+ state,
+ &command_cwd,
+ &truncated_editing_text,
+ chain_type,
+ &CommandStatus::Pending,
+ false,
+ overflow_indicator,
+ );
+ return table.add_styled_row(row);
+ }
+ }
+
+ let truncated_cmd_text = truncate_middle(cmd_text, available_cmd_width, None).0;
+
+ let (row, _) = command_sequence_row(
+ state,
+ &command_cwd,
+ &truncated_cmd_text,
+ chain_type,
+ status,
+ state.selection.current_selected_command_index == Some(index),
+ overflow_indicator,
+ );
+
+ table.add_styled_row(row)
+}
+
+pub fn calculate_max_widths(
+ commands: &[crate::state::CommandEntry],
+ spinner_frame: usize,
+) -> (usize, usize) {
+ let max_chain_width = commands
+ .iter()
+ .map(|cmd| chain_type_to_str(&cmd.get_chain_type()).chars().count())
+ .max()
+ .unwrap_or(0);
+
+ let max_status_width = commands
+ .iter()
+ .map(|cmd| {
+ format_status_text(&cmd.get_status(), spinner_frame)
+ .chars()
+ .count()
+ })
+ .max()
+ .unwrap_or(0);
+
+ (max_chain_width, max_status_width)
+}
+
+pub fn calculate_longest_line(
+ longest_cwd_display: &str,
+ longest_command: usize,
+ max_chain_width: usize,
+ max_status_width: usize,
+) -> usize {
+ let folder_display = format!("{} >", longest_cwd_display);
+ let cell_padding = 3;
+ folder_display.chars().count()
+ + longest_command
+ + max_chain_width
+ + max_status_width
+ + cell_padding
+}
+
+pub fn chain_type_to_str(chain_type: &crate::state::ChainType) -> &'static str {
+ match chain_type {
+ crate::state::ChainType::And => "AND",
+ crate::state::ChainType::Or => "OR",
+ crate::state::ChainType::Then => "THEN",
+ crate::state::ChainType::None => " ",
+ }
+}
+
+pub fn truncate_help_line(help_text: &str, max_width: usize) -> (String, usize) {
+ let text_width = help_text.chars().count();
+
+ if text_width <= max_width {
+ return (help_text.to_string(), text_width);
+ }
+
+ let keybindings = parse_help_keybindings(help_text);
+
+ if let Some(result) = try_shortened_help(&keybindings, max_width) {
+ return result;
+ }
+
+ if let Some(result) = try_keys_spaced(&keybindings, max_width) {
+ return result;
+ }
+
+ if let Some(result) = try_keys_tight(&keybindings, max_width) {
+ return result;
+ }
+
+ truncate_with_ellipsis(
+ &keybindings
+ .iter()
+ .map(|(k, _, _)| *k)
+ .collect::<Vec<_>>()
+ .join("/"),
+ max_width,
+ )
+}
+
+fn parse_help_keybindings(help_text: &str) -> Vec<(&str, &str, &str)> {
+ help_text
+ .split(", ")
+ .filter_map(|part| {
+ part.find(" - ").map(|dash_pos| {
+ let key = &part[..dash_pos];
+ let action = &part[dash_pos + 3..];
+ let first_word = action.split_whitespace().next().unwrap_or(action);
+ (key, first_word, action)
+ })
+ })
+ .collect()
+}
+
+fn try_shortened_help(
+ keybindings: &[(&str, &str, &str)],
+ max_width: usize,
+) -> Option<(String, usize)> {
+ let shortened: Vec<String> = keybindings
+ .iter()
+ .map(|(key, first_word, _)| format!("{} - {}", key, first_word))
+ .collect();
+ let shortened_text = shortened.join(", ");
+ let shortened_width = shortened_text.chars().count();
+
+ if shortened_width <= max_width {
+ Some((shortened_text, shortened_width))
+ } else {
+ None
+ }
+}
+
+fn try_keys_spaced(
+ keybindings: &[(&str, &str, &str)],
+ max_width: usize,
+) -> Option<(String, usize)> {
+ let keys_spaced_text = keybindings
+ .iter()
+ .map(|(key, _, _)| *key)
+ .collect::<Vec<_>>()
+ .join(" / ");
+ let keys_spaced_width = keys_spaced_text.chars().count();
+
+ if keys_spaced_width <= max_width {
+ Some((keys_spaced_text, keys_spaced_width))
+ } else {
+ None
+ }
+}
+
+fn try_keys_tight(keybindings: &[(&str, &str, &str)], max_width: usize) -> Option<(String, usize)> {
+ let keys_tight_text = keybindings
+ .iter()
+ .map(|(key, _, _)| *key)
+ .collect::<Vec<_>>()
+ .join("/");
+ let keys_tight_width = keys_tight_text.chars().count();
+
+ if keys_tight_width <= max_width {
+ Some((keys_tight_text, keys_tight_width))
+ } else {
+ None
+ }
+}
+
+fn truncate_with_ellipsis(text: &str, max_width: usize) -> (String, usize) {
+ let available = max_width.saturating_sub(3);
+ let mut truncated = String::new();
+ let mut current_width = 0;
+
+ for ch in text.chars() {
+ if current_width + 1 <= available {
+ truncated.push(ch);
+ current_width += 1;
+ } else {
+ break;
+ }
+ }
+
+ truncated.push_str("...");
+ let truncated_width = truncated.chars().count();
+ (truncated, truncated_width)
+}
diff --git a/default-plugins/sequence/src/ui/fuzzy_complete.rs b/default-plugins/sequence/src/ui/fuzzy_complete.rs
new file mode 100644
index 00000000..0feae7e4
--- /dev/null
+++ b/default-plugins/sequence/src/ui/fuzzy_complete.rs
@@ -0,0 +1,321 @@
+use fuzzy_matcher::skim::SkimMatcherV2;
+use fuzzy_matcher::FuzzyMatcher;
+use std::collections::BTreeMap;
+use std::fs;
+use std::path::PathBuf;
+
+/// Result of a fuzzy completion operation
+#[derive(Debug, Clone)]
+pub struct CompletionResult {
+ pub completed_text: String,
+ pub score: i64,
+ pub is_directory: bool,
+ pub is_prefix_completion: bool, // True if this is the shortest of multiple matches with same prefix
+}
+
+/// Type of completion
+#[derive(Debug, Clone, Copy, PartialEq)]
+pub enum CompletionType {
+ Command,
+ Path,
+}
+
+/// Fuzzy match executables (commands) from the PATH
+pub fn fuzzy_complete_command(
+ query: &str,
+ executables: &BTreeMap<String, PathBuf>,
+) -> Option<CompletionResult> {
+ if query.is_empty() {
+ return None;
+ }
+
+ let matcher = SkimMatcherV2::default().ignore_case();
+
+ // Collect all matches with their scores
+ let mut all_matches: Vec<(String, i64)> = Vec::new();
+
+ for executable_name in executables.keys() {
+ if let Some((score, _indices)) = matcher.fuzzy_indices(executable_name, query) {
+ all_matches.push((executable_name.clone(), score));
+ }
+ }
+
+ if all_matches.is_empty() {
+ return None;
+ }
+
+ // Sort by score (highest first), then by length (shortest first)
+ all_matches.sort_by(|a, b| b.1.cmp(&a.1).then_with(|| a.0.len().cmp(&b.0.len())));
+
+ // Get the best match
+ let (best_name, best_score) = &all_matches[0];
+
+ // Check if there are multiple matches that share the same prefix
+ let is_prefix_completion = check_for_prefix_matches(&all_matches, best_name);
+
+ Some(CompletionResult {
+ completed_text: best_name.clone(),
+ score: *best_score,
+ is_directory: false, // Commands are not directories
+ is_prefix_completion,
+ })
+}
+
+/// Fuzzy match paths (directories and files) relative to the current working directory
+pub fn fuzzy_complete_path(query: &str, cwd: Option<&PathBuf>) -> Option<CompletionResult> {
+ if query.is_empty() {
+ return None;
+ }
+
+ let matcher = SkimMatcherV2::default().ignore_case();
+
+ // Determine the base directory to search in
+ let (base_dir, search_prefix) = if query.starts_with('/') {
+ // Absolute path
+ let parts: Vec<&str> = query.rsplitn(2, '/').collect();
+ if parts.len() == 2 {
+ // Has a directory component
+ let dir = parts[1];
+ let prefix = parts[0];
+ (PathBuf::from(dir), prefix.to_string())
+ } else {
+ // Just "/"
+ (PathBuf::from("/"), String::new())
+ }
+ } else if query.starts_with("~/") {
+ // Home directory
+ let home_dir = std::env::var("HOME").ok()?;
+ let query_without_tilde = &query[2..];
+ let parts: Vec<&str> = query_without_tilde.rsplitn(2, '/').collect();
+ if parts.len() == 2 {
+ let dir = PathBuf::from(&home_dir).join(parts[1]);
+ let prefix = parts[0];
+ (dir, prefix.to_string())
+ } else {
+ // Just "~/" or "~/something"
+ (PathBuf::from(home_dir), query_without_tilde.to_string())
+ }
+ } else {
+ // Relative path
+ let base = cwd?;
+ let parts: Vec<&str> = query.rsplitn(2, '/').collect();
+ if parts.len() == 2 {
+ // Has a directory component
+ let dir = base.join(parts[1]);
+ let prefix = parts[0];
+ (dir, prefix.to_string())
+ } else {
+ // Just a name in the current directory
+ (base.clone(), query.to_string())
+ }
+ };
+
+ // Convert to host path
+ let host_base_dir =
+ PathBuf::from("/host").join(base_dir.strip_prefix("/").unwrap_or(&base_dir));
+
+ // Read directory entries
+ let entries = fs::read_dir(&host_base_dir).ok()?;
+
+ // Collect all matches with their scores and directory status
+ let mut all_matches: Vec<(String, i64, bool)> = Vec::new();
+
+ for entry in entries.flatten() {
+ if let Some(name) = entry.file_name().to_str() {
+ // Skip hidden files unless the query starts with a dot
+ if name.starts_with('.') && !search_prefix.starts_with('.') {
+ continue;
+ }
+
+ if let Some((score, _indices)) = matcher.fuzzy_indices(name, &search_prefix) {
+ // Check if this entry is a directory
+ let is_dir = entry.metadata().ok().map(|m| m.is_dir()).unwrap_or(false);
+ all_matches.push((name.to_string(), score, is_dir));
+ }
+ }
+ }
+
+ if all_matches.is_empty() {
+ return None;
+ }
+
+ // Sort by score (highest first), then by length (shortest first)
+ all_matches.sort_by(|a, b| b.1.cmp(&a.1).then_with(|| a.0.len().cmp(&b.0.len())));
+
+ // Get the best match
+ let (name, score, is_directory) = all_matches[0].clone();
+
+ // Check if there are multiple matches that share the same prefix
+ let name_matches: Vec<(String, i64)> = all_matches
+ .iter()
+ .map(|(n, s, _)| (n.clone(), *s))
+ .collect();
+ let is_prefix_completion = check_for_prefix_matches(&name_matches, &name);
+
+ // Reconstruct the full path
+ let completed_text = if query.starts_with('/') {
+ // Absolute path
+ let dir_part = query.rsplitn(2, '/').nth(1).unwrap_or("");
+ if dir_part.is_empty() {
+ format!("/{}", name)
+ } else {
+ format!("{}/{}", dir_part, name)
+ }
+ } else if query.starts_with("~/") {
+ // Home directory
+ let query_without_tilde = &query[2..];
+ let dir_part = query_without_tilde.rsplitn(2, '/').nth(1).unwrap_or("");
+ if dir_part.is_empty() {
+ format!("~/{}", name)
+ } else {
+ format!("~/{}/{}", dir_part, name)
+ }
+ } else {
+ // Relative path
+ let dir_part = query.rsplitn(2, '/').nth(1).unwrap_or("");
+ if dir_part.is_empty() {
+ name.clone()
+ } else {
+ format!("{}/{}", dir_part, name)
+ }
+ };
+
+ Some(CompletionResult {
+ completed_text,
+ score,
+ is_directory,
+ is_prefix_completion,
+ })
+}
+
+/// Check if there are multiple matches that start with the best match's name
+/// Returns true if the best match is a prefix of other matches
+fn check_for_prefix_matches(matches: &[(String, i64)], best_match: &str) -> bool {
+ if matches.len() <= 1 {
+ return false;
+ }
+
+ // Count how many matches start with the best_match text
+ let prefix_count = matches
+ .iter()
+ .filter(|(name, _)| name.starts_with(best_match) && name != best_match)
+ .count();
+
+ prefix_count > 0
+}
+
+/// Perform fuzzy completion on the current input
+/// Returns the best completion (command or path) with appropriate suffix (space or slash)
+pub fn fuzzy_complete(
+ input: &str,
+ executables: &BTreeMap<String, PathBuf>,
+ cwd: Option<&PathBuf>,
+) -> Option<String> {
+ // If input is empty, nothing to complete
+ if input.is_empty() {
+ return None;
+ }
+
+ // Extract the last word/token to complete
+ // For simplicity, we'll complete the entire input if it's a single word,
+ // or the last space-separated token if there are multiple words
+ let tokens: Vec<&str> = input.split_whitespace().collect();
+ let to_complete = if tokens.is_empty() {
+ input
+ } else {
+ tokens.last().unwrap()
+ };
+
+ // Get both command and path completions
+ let command_result = fuzzy_complete_command(to_complete, executables);
+ let path_result = fuzzy_complete_path(to_complete, cwd);
+
+ // Choose the better match based on score
+ match (command_result, path_result) {
+ (Some(cmd), Some(path)) => {
+ // Both matched, use the higher score
+ let (result, completion_type, is_dir, is_prefix) = if cmd.score >= path.score {
+ (
+ cmd.completed_text,
+ CompletionType::Command,
+ false,
+ cmd.is_prefix_completion,
+ )
+ } else {
+ (
+ path.completed_text,
+ CompletionType::Path,
+ path.is_directory,
+ path.is_prefix_completion,
+ )
+ };
+
+ // Add appropriate suffix (skip slash if this is a prefix completion)
+ let suffix = get_completion_suffix(completion_type, is_dir, is_prefix);
+ let completed = format!("{}{}", result, suffix);
+
+ // Replace the last token with the completion
+ Some(replace_last_token(input, &completed))
+ },
+ (Some(cmd), None) => {
+ // Command completion - add space (unless it's a prefix completion)
+ let suffix = if cmd.is_prefix_completion { "" } else { " " };
+ let completed = format!("{}{}", cmd.completed_text, suffix);
+ Some(replace_last_token(input, &completed))
+ },
+ (None, Some(path)) => {
+ // Path completion - add slash if directory (unless it's a prefix completion)
+ let suffix = if path.is_prefix_completion {
+ ""
+ } else if path.is_directory {
+ "/"
+ } else {
+ ""
+ };
+ let completed = format!("{}{}", path.completed_text, suffix);
+ Some(replace_last_token(input, &completed))
+ },
+ (None, None) => None,
+ }
+}
+
+/// Get the appropriate suffix for a completion
+fn get_completion_suffix(
+ completion_type: CompletionType,
+ is_directory: bool,
+ is_prefix_completion: bool,
+) -> &'static str {
+ // No suffix for prefix completions
+ if is_prefix_completion {
+ return "";
+ }
+
+ match completion_type {
+ CompletionType::Command => " ",
+ CompletionType::Path => {
+ if is_directory {
+ "/"
+ } else {
+ ""
+ }
+ },
+ }
+}
+
+/// Replace the last whitespace-separated token in the input with the completion
+fn replace_last_token(input: &str, completion: &str) -> String {
+ let tokens: Vec<&str> = input.split_whitespace().collect();
+ if tokens.is_empty() {
+ return completion.to_string();
+ }
+
+ if tokens.len() == 1 {
+ completion.to_string()
+ } else {
+ // Join all tokens except the last one, then add the completion
+ let mut result = tokens[..tokens.len() - 1].join(" ");
+ result.push(' ');
+ result.push_str(completion);
+ result
+ }
+}
diff --git a/default-plugins/sequence/src/ui/layout_calculations.rs b/default-plugins/sequence/src/ui/layout_calculations.rs
new file mode 100644
index 00000000..911dbc62
--- /dev/null
+++ b/default-plugins/sequence/src/ui/layout_calculations.rs
@@ -0,0 +1,28 @@
+pub fn calculate_viewport(
+ total_commands: usize,
+ max_visible: usize,
+ selected_index: Option<usize>,
+ running_index: usize,
+) -> (usize, usize, usize, usize) {
+ if total_commands <= max_visible {
+ return (0, total_commands, 0, 0);
+ }
+
+ let focus_index = selected_index.unwrap_or(running_index);
+ let half_visible = max_visible / 2;
+
+ let offset = if focus_index < half_visible {
+ 0
+ } else if focus_index >= total_commands.saturating_sub(half_visible) {
+ total_commands.saturating_sub(max_visible)
+ } else {
+ focus_index.saturating_sub(half_visible)
+ };
+
+ let offset = offset.min(total_commands.saturating_sub(max_visible));
+ let visible_count = max_visible.min(total_commands.saturating_sub(offset));
+ let hidden_above = offset;
+ let hidden_below = total_commands.saturating_sub(offset + visible_count);
+
+ (offset, visible_count, hidden_above, hidden_below)
+}
diff --git a/default-plugins/sequence/src/ui/mod.rs b/default-plugins/sequence/src/ui/mod.rs
new file mode 100644
index 00000000..6d1ec303
--- /dev/null
+++ b/default-plugins/sequence/src/ui/mod.rs
@@ -0,0 +1,5 @@
+pub mod components;
+pub mod fuzzy_complete;
+pub mod layout_calculations;
+pub mod text_input;
+pub mod truncation;
diff --git a/default-plugins/sequence/src/ui/text_input.rs b/default-plugins/sequence/src/ui/text_input.rs
new file mode 100644
index 00000000..2694e17a
--- /dev/null
+++ b/default-plugins/sequence/src/ui/text_input.rs
@@ -0,0 +1,997 @@
+use zellij_tile::prelude::*;
+
+const MAX_UNDO_STACK_SIZE: usize = 100;
+
+/// Action returned by TextInput after handling a key event
+#[derive(Debug, Clone, PartialEq)]
+#[cfg_attr(test, derive(Eq))]
+pub enum InputAction {
+ /// Continue editing
+ Continue,
+ /// User pressed Enter to submit
+ Submit,
+ /// User pressed Esc to cancel
+ Cancel,
+ /// User pressed Tab to request completion
+ Complete,
+ /// Key was not handled by the input
+ NoAction,
+}
+
+/// A reusable text input component with cursor support and standard editing keybindings
+#[derive(Debug, Clone)]
+pub struct TextInput {
+ buffer: String,
+ cursor_position: usize, // Character position (0-based), NOT byte position
+ undo_stack: Vec<(String, usize)>, // (buffer, cursor) snapshots
+ redo_stack: Vec<(String, usize)>,
+ last_edit_was_insert: bool, // For coalescing consecutive inserts
+}
+
+impl TextInput {
+ /// Create a new TextInput with the given initial text
+ /// Cursor is positioned at the end of the text
+ pub fn new(initial_text: String) -> Self {
+ let cursor_position = initial_text.chars().count();
+ Self {
+ buffer: initial_text,
+ cursor_position,
+ undo_stack: Vec::new(),
+ redo_stack: Vec::new(),
+ last_edit_was_insert: false,
+ }
+ }
+
+ /// Create an empty TextInput
+ pub fn empty() -> Self {
+ Self::new(String::new())
+ }
+
+ /// Get the current text
+ pub fn get_text(&self) -> &str {
+ &self.buffer
+ }
+
+ /// Get the cursor position (in characters, not bytes)
+ pub fn get_cursor_position(&self) -> usize {
+ self.cursor_position
+ }
+
+ /// Check if the input is empty
+ pub fn is_empty(&self) -> bool {
+ self.buffer.is_empty()
+ }
+
+ /// Get a shorthand for cursor_position
+ pub fn cursor_position(&self) -> usize {
+ self.cursor_position
+ }
+
+ /// Get mutable access to the underlying buffer for direct manipulation
+ pub fn get_text_mut(&mut self) -> &mut String {
+ &mut self.buffer
+ }
+
+ /// Set the text and move cursor to the end
+ pub fn set_text(&mut self, text: String) {
+ self.break_coalescing();
+ self.save_undo_state();
+ self.cursor_position = text.chars().count();
+ self.buffer = text;
+ }
+
+ /// Set cursor position (clamped to text length)
+ pub fn set_cursor_position(&mut self, pos: usize) {
+ let text_len = self.buffer.chars().count();
+ self.cursor_position = pos.min(text_len);
+ }
+
+ /// Clear all text and reset cursor
+ pub fn clear(&mut self) {
+ self.break_coalescing();
+ self.save_undo_state();
+ self.buffer.clear();
+ self.cursor_position = 0;
+ }
+
+ /// Insert a character at the current cursor position
+ pub fn insert_char(&mut self, c: char) {
+ self.save_undo_state_unless_coalescing();
+ // Convert cursor position (char index) to byte index
+ let byte_index = self.char_index_to_byte_index(self.cursor_position);
+ self.buffer.insert(byte_index, c);
+ self.cursor_position += 1;
+ }
+
+ /// Delete the character before the cursor (backspace)
+ pub fn backspace(&mut self) {
+ if self.cursor_position > 0 {
+ self.break_coalescing();
+ self.save_undo_state();
+ self.cursor_position -= 1;
+ let byte_index = self.char_index_to_byte_index(self.cursor_position);
+ self.buffer.remove(byte_index);
+ }
+ }
+
+ /// Delete the character at the cursor position (delete key)
+ pub fn delete(&mut self) {
+ let len = self.buffer.chars().count();
+ if self.cursor_position < len {
+ self.break_coalescing();
+ self.save_undo_state();
+ let byte_index = self.char_index_to_byte_index(self.cursor_position);
+ self.buffer.remove(byte_index);
+ }
+ }
+
+ /// Delete the word before the cursor (Ctrl/Alt + Backspace)
+ pub fn delete_word_backward(&mut self) {
+ if self.cursor_position == 0 {
+ return;
+ }
+
+ self.break_coalescing();
+ self.save_undo_state();
+
+ let old_position = self.cursor_position;
+ self.move_word_left();
+ let new_position = self.cursor_position;
+
+ // Delete from new position to old position
+ let start_byte = self.char_index_to_byte_index(new_position);
+ let end_byte = self.char_index_to_byte_index(old_position);
+ self.buffer.drain(start_byte..end_byte);
+ }
+
+ /// Delete the word after the cursor (Ctrl/Alt + Delete)
+ pub fn delete_word_forward(&mut self) {
+ let chars: Vec<char> = self.buffer.chars().collect();
+ let len = chars.len();
+
+ if self.cursor_position >= len {
+ return;
+ }
+
+ self.break_coalescing();
+ self.save_undo_state();
+
+ let start_position = self.cursor_position;
+ let mut end_position = start_position;
+
+ // Skip the current word
+ while end_position < len && !chars[end_position].is_whitespace() {
+ end_position += 1;
+ }
+
+ // Skip any whitespace after the word
+ while end_position < len && chars[end_position].is_whitespace() {
+ end_position += 1;
+ }
+
+ // Delete from start to end position
+ let start_byte = self.char_index_to_byte_index(start_position);
+ let end_byte = self.char_index_to_byte_index(end_position);
+ self.buffer.drain(start_byte..end_byte);
+ }
+
+ /// Move cursor one position to the left
+ pub fn move_left(&mut self) {
+ if self.cursor_position > 0 {
+ self.break_coalescing();
+ self.cursor_position -= 1;
+ }
+ }
+
+ /// Move cursor one position to the right
+ pub fn move_right(&mut self) {
+ let len = self.buffer.chars().count();
+ if self.cursor_position < len {
+ self.break_coalescing();
+ self.cursor_position += 1;
+ }
+ }
+
+ /// Move cursor to the start of the text (Ctrl-A / Home)
+ pub fn move_to_start(&mut self) {
+ self.break_coalescing();
+ self.cursor_position = 0;
+ }
+
+ /// Move cursor to the end of the text (Ctrl-E / End)
+ pub fn move_to_end(&mut self) {
+ self.break_coalescing();
+ self.cursor_position = self.buffer.chars().count();
+ }
+
+ /// Move cursor to the start of the previous word (Ctrl/Alt + Left)
+ pub fn move_word_left(&mut self) {
+ if self.cursor_position == 0 {
+ return;
+ }
+
+ self.break_coalescing();
+
+ let chars: Vec<char> = self.buffer.chars().collect();
+ let mut pos = self.cursor_position;
+
+ // Skip any whitespace immediately to the left
+ while pos > 0 && chars[pos - 1].is_whitespace() {
+ pos -= 1;
+ }
+
+ // Skip the word characters
+ while pos > 0 && !chars[pos - 1].is_whitespace() {
+ pos -= 1;
+ }
+
+ self.cursor_position = pos;
+ }
+
+ /// Move cursor to the start of the next word (Ctrl/Alt + Right)
+ pub fn move_word_right(&mut self) {
+ let chars: Vec<char> = self.buffer.chars().collect();
+ let len = chars.len();
+
+ if self.cursor_position >= len {
+ return;
+ }
+
+ self.break_coalescing();
+
+ let mut pos = self.cursor_position;
+
+ // Skip the current word
+ while pos < len && !chars[pos].is_whitespace() {
+ pos += 1;
+ }
+
+ // Skip any whitespace
+ while pos < len && chars[pos].is_whitespace() {
+ pos += 1;
+ }
+
+ self.cursor_position = pos;
+ }
+
+ /// Handle a key event and return the appropriate action
+ /// This is the main entry point for key handling
+ pub fn handle_key(&mut self, key: KeyWithModifier) -> InputAction {
+ // Check for Ctrl modifiers
+ if key.has_modifiers(&[KeyModifier::Ctrl]) {
+ match key.bare_key {
+ BareKey::Char('a') => {
+ self.move_to_start();
+ return InputAction::Continue;
+ },
+ BareKey::Char('e') => {
+ self.move_to_end();
+ return InputAction::Continue;
+ },
+ BareKey::Char('c') => {
+ // Ctrl-C clears the prompt
+ return InputAction::Cancel;
+ },
+ BareKey::Char('z') => {
+ // Ctrl-Z: Undo
+ self.undo();
+ return InputAction::Continue;
+ },
+ BareKey::Char('y') => {
+ // Ctrl-Y: Redo
+ self.redo();
+ return InputAction::Continue;
+ },
+ BareKey::Left => {
+ self.move_word_left();
+ return InputAction::Continue;
+ },
+ BareKey::Right => {
+ self.move_word_right();
+ return InputAction::Continue;
+ },
+ BareKey::Backspace => {
+ self.delete_word_backward();
+ return InputAction::Continue;
+ },
+ BareKey::Delete => {
+ self.delete_word_forward();
+ return InputAction::Continue;
+ },
+ _ => {},
+ }
+ }
+
+ // Check for Ctrl+Shift modifiers (alternative redo: Ctrl+Shift+Z)
+ if key.has_modifiers(&[KeyModifier::Ctrl, KeyModifier::Shift]) {
+ match key.bare_key {
+ BareKey::Char('Z') => {
+ // Ctrl-Shift-Z: Redo (alternative)
+ self.redo();
+ return InputAction::Continue;
+ },
+ _ => {},
+ }
+ }
+
+ // Check for Alt modifiers
+ if key.has_modifiers(&[KeyModifier::Alt]) {
+ match key.bare_key {
+ BareKey::Left => {
+ self.move_word_left();
+ return InputAction::Continue;
+ },
+ BareKey::Right => {
+ self.move_word_right();
+ return InputAction::Continue;
+ },
+ BareKey::Backspace => {
+ self.delete_word_backward();
+ return InputAction::Continue;
+ },
+ BareKey::Delete => {
+ self.delete_word_forward();
+ return InputAction::Continue;
+ },
+ _ => {},
+ }
+ }
+
+ // Handle bare keys (no modifiers)
+ match key.bare_key {
+ BareKey::Enter => InputAction::Submit,
+ BareKey::Esc => InputAction::Cancel,
+ BareKey::Tab => InputAction::Complete,
+ BareKey::Backspace => {
+ self.backspace();
+ InputAction::Continue
+ },
+ BareKey::Delete => {
+ self.delete();
+ InputAction::Continue
+ },
+ BareKey::Left => {
+ self.move_left();
+ InputAction::Continue
+ },
+ BareKey::Right => {
+ self.move_right();
+ InputAction::Continue
+ },
+ BareKey::Home => {
+ self.move_to_start();
+ InputAction::Continue
+ },
+ BareKey::End => {
+ self.move_to_end();
+ InputAction::Continue
+ },
+ BareKey::Char(c) => {
+ self.insert_char(c);
+ InputAction::Continue
+ },
+ _ => InputAction::NoAction,
+ }
+ }
+
+ /// Helper: Convert character index to byte index
+ fn char_index_to_byte_index(&self, char_index: usize) -> usize {
+ self.buffer
+ .char_indices()
+ .nth(char_index)
+ .map(|(byte_idx, _)| byte_idx)
+ .unwrap_or(self.buffer.len())
+ }
+
+ /// Save current state to undo stack before making changes
+ fn save_undo_state(&mut self) {
+ if self.undo_stack.len() >= MAX_UNDO_STACK_SIZE {
+ self.undo_stack.remove(0);
+ }
+ self.undo_stack
+ .push((self.buffer.clone(), self.cursor_position));
+ self.redo_stack.clear();
+ }
+
+ /// Save state only if not coalescing with previous insert
+ fn save_undo_state_unless_coalescing(&mut self) {
+ if !self.last_edit_was_insert {
+ self.save_undo_state();
+ }
+ self.last_edit_was_insert = true;
+ }
+
+ /// Mark that a non-insert edit occurred (breaks coalescing)
+ fn break_coalescing(&mut self) {
+ self.last_edit_was_insert = false;
+ }
+
+ /// Undo last change
+ pub fn undo(&mut self) -> bool {
+ if let Some((buffer, cursor)) = self.undo_stack.pop() {
+ self.redo_stack
+ .push((self.buffer.clone(), self.cursor_position));
+ self.buffer = buffer;
+ self.cursor_position = cursor;
+ self.break_coalescing();
+ true
+ } else {
+ false
+ }
+ }
+
+ /// Redo last undone change
+ pub fn redo(&mut self) -> bool {
+ if let Some((buffer, cursor)) = self.redo_stack.pop() {
+ self.undo_stack
+ .push((self.buffer.clone(), self.cursor_position));
+ self.buffer = buffer;
+ self.cursor_position = cursor;
+ self.break_coalescing();
+ true
+ } else {
+ false
+ }
+ }
+
+ /// Check if undo is available
+ pub fn can_undo(&self) -> bool {
+ !self.undo_stack.is_empty()
+ }
+
+ /// Check if redo is available
+ pub fn can_redo(&self) -> bool {
+ !self.redo_stack.is_empty()
+ }
+
+ pub fn drain_text(&mut self) -> String {
+ self.cursor_position = 0;
+ self.buffer.drain(..).collect()
+ }
+}
+
+// run with:
+// cargo test --lib --target x86_64-unknown-linux-gnu
+//
+#[cfg(test)]
+mod tests {
+ use super::*;
+
+ #[test]
+ fn test_new_and_empty() {
+ let input = TextInput::new("hello".to_string());
+ assert_eq!(input.get_text(), "hello");
+ assert_eq!(input.get_cursor_position(), 5);
+
+ let empty = TextInput::empty();
+ assert_eq!(empty.get_text(), "");
+ assert_eq!(empty.get_cursor_position(), 0);
+ }
+
+ #[test]
+ fn test_insert_char() {
+ let mut input = TextInput::new("helo".to_string());
+ input.cursor_position = 3; // Position after "hel"
+ input.insert_char('l');
+ assert_eq!(input.get_text(), "hello");
+ assert_eq!(input.get_cursor_position(), 4);
+ }
+
+ #[test]
+ fn test_backspace() {
+ let mut input = TextInput::new("hello".to_string());
+ input.backspace();
+ assert_eq!(input.get_text(), "hell");
+ assert_eq!(input.get_cursor_position(), 4);
+
+ // Backspace at start does nothing
+ input.cursor_position = 0;
+ input.backspace();
+ assert_eq!(input.get_text(), "hell");
+ assert_eq!(input.get_cursor_position(), 0);
+ }
+
+ #[test]
+ fn test_delete() {
+ let mut input = TextInput::new("hello".to_string());
+ input.cursor_position = 0;
+ input.delete();
+ assert_eq!(input.get_text(), "ello");
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Delete at end does nothing
+ input.move_to_end();
+ input.delete();
+ assert_eq!(input.get_text(), "ello");
+ }
+
+ #[test]
+ fn test_cursor_movement() {
+ let mut input = TextInput::new("hello".to_string());
+ assert_eq!(input.get_cursor_position(), 5);
+
+ input.move_left();
+ assert_eq!(input.get_cursor_position(), 4);
+
+ input.move_right();
+ assert_eq!(input.get_cursor_position(), 5);
+
+ input.move_to_start();
+ assert_eq!(input.get_cursor_position(), 0);
+
+ input.move_to_end();
+ assert_eq!(input.get_cursor_position(), 5);
+ }
+
+ #[test]
+ fn test_unicode_support() {
+ let mut input = TextInput::new("hello 🦀 world".to_string());
+ assert_eq!(input.get_cursor_position(), 13); // 13 characters
+
+ input.cursor_position = 6; // After "hello "
+ input.insert_char('🐱');
+ assert_eq!(input.get_text(), "hello 🐱🦀 world");
+ }
+
+ #[test]
+ fn test_word_jump_right() {
+ let mut input = TextInput::new("hello world foo bar".to_string());
+ input.cursor_position = 0;
+
+ // Jump from start to "world"
+ input.move_word_right();
+ assert_eq!(input.get_cursor_position(), 6); // After "hello "
+
+ // Jump to "foo"
+ input.move_word_right();
+ assert_eq!(input.get_cursor_position(), 12); // After "world "
+
+ // Jump to "bar"
+ input.move_word_right();
+ assert_eq!(input.get_cursor_position(), 16); // After "foo "
+
+ // Jump to end
+ input.move_word_right();
+ assert_eq!(input.get_cursor_position(), 19); // At end
+ }
+
+ #[test]
+ fn test_word_jump_left() {
+ let mut input = TextInput::new("hello world foo bar".to_string());
+ input.move_to_end();
+ assert_eq!(input.get_cursor_position(), 19);
+
+ // Jump back to "bar"
+ input.move_word_left();
+ assert_eq!(input.get_cursor_position(), 16); // Start of "bar"
+
+ // Jump back to "foo"
+ input.move_word_left();
+ assert_eq!(input.get_cursor_position(), 12); // Start of "foo"
+
+ // Jump back to "world"
+ input.move_word_left();
+ assert_eq!(input.get_cursor_position(), 6); // Start of "world"
+
+ // Jump back to "hello"
+ input.move_word_left();
+ assert_eq!(input.get_cursor_position(), 0); // Start of "hello"
+ }
+
+ #[test]
+ fn test_word_jump_with_multiple_spaces() {
+ let mut input = TextInput::new("hello world".to_string());
+ input.cursor_position = 0;
+
+ // Jump over multiple spaces
+ input.move_word_right();
+ assert_eq!(input.get_cursor_position(), 8); // After "hello ", at start of "world"
+
+ // Jump back should skip spaces
+ input.move_word_left();
+ assert_eq!(input.get_cursor_position(), 0); // Back to start of "hello"
+ }
+
+ #[test]
+ fn test_word_jump_boundaries() {
+ let mut input = TextInput::new("test".to_string());
+
+ // At start - word left does nothing
+ input.cursor_position = 0;
+ input.move_word_left();
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // At end - word right does nothing
+ input.move_to_end();
+ let end_pos = input.get_cursor_position();
+ input.move_word_right();
+ assert_eq!(input.get_cursor_position(), end_pos);
+ }
+
+ #[test]
+ fn test_up_down_arrows() {
+ let mut input = TextInput::new("hello world".to_string());
+
+ // Start in the middle
+ input.cursor_position = 5;
+ assert_eq!(input.get_cursor_position(), 5);
+
+ // Up arrow should go to start
+ input.move_to_start();
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Move back to middle
+ input.cursor_position = 5;
+
+ // Down arrow should go to end
+ input.move_to_end();
+ assert_eq!(input.get_cursor_position(), 11);
+ }
+
+ #[test]
+ fn test_delete_word_backward() {
+ let mut input = TextInput::new("hello world foo".to_string());
+
+ // Delete "foo" from end
+ input.move_to_end();
+ input.delete_word_backward();
+ assert_eq!(input.get_text(), "hello world ");
+ assert_eq!(input.get_cursor_position(), 12);
+
+ // Delete "world "
+ input.delete_word_backward();
+ assert_eq!(input.get_text(), "hello ");
+ assert_eq!(input.get_cursor_position(), 6);
+
+ // Delete "hello "
+ input.delete_word_backward();
+ assert_eq!(input.get_text(), "");
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Delete on empty buffer does nothing
+ input.delete_word_backward();
+ assert_eq!(input.get_text(), "");
+ assert_eq!(input.get_cursor_position(), 0);
+ }
+
+ #[test]
+ fn test_delete_word_backward_middle() {
+ let mut input = TextInput::new("hello world foo".to_string());
+
+ // Position in middle of "world"
+ input.cursor_position = 8; // After "hello wo"
+ input.delete_word_backward();
+ assert_eq!(input.get_text(), "hello rld foo");
+ assert_eq!(input.get_cursor_position(), 6); // After "hello "
+ }
+
+ #[test]
+ fn test_delete_word_forward() {
+ let mut input = TextInput::new("hello world foo".to_string());
+
+ // Delete "hello " from start
+ input.cursor_position = 0;
+ input.delete_word_forward();
+ assert_eq!(input.get_text(), "world foo");
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Delete "world "
+ input.delete_word_forward();
+ assert_eq!(input.get_text(), "foo");
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Delete "foo"
+ input.delete_word_forward();
+ assert_eq!(input.get_text(), "");
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Delete on empty buffer does nothing
+ input.delete_word_forward();
+ assert_eq!(input.get_text(), "");
+ assert_eq!(input.get_cursor_position(), 0);
+ }
+
+ #[test]
+ fn test_delete_word_forward_middle() {
+ let mut input = TextInput::new("hello world foo".to_string());
+
+ // Position in middle of "world"
+ input.cursor_position = 8; // After "hello wo"
+ input.delete_word_forward();
+ assert_eq!(input.get_text(), "hello wofoo");
+ assert_eq!(input.get_cursor_position(), 8); // Same position, text deleted forward
+ }
+
+ #[test]
+ fn test_delete_word_with_multiple_spaces() {
+ let mut input = TextInput::new("hello world".to_string());
+
+ // Delete forward includes trailing spaces
+ input.cursor_position = 0;
+ input.delete_word_forward();
+ assert_eq!(input.get_text(), "world");
+ assert_eq!(input.get_cursor_position(), 0);
+ }
+
+ #[test]
+ fn test_undo_redo_basic() {
+ let mut input = TextInput::empty();
+
+ // Type "hello"
+ input.insert_char('h');
+ input.insert_char('e');
+ input.insert_char('l');
+ input.insert_char('l');
+ input.insert_char('o');
+ assert_eq!(input.get_text(), "hello");
+
+ // Undo should remove all characters (coalesced into one undo entry)
+ assert!(input.can_undo());
+ assert!(input.undo());
+ assert_eq!(input.get_text(), "");
+ assert_eq!(input.get_cursor_position(), 0);
+
+ // Redo should restore "hello"
+ assert!(input.can_redo());
+ assert!(input.redo());
+ assert_eq!(input.get_text(), "hello");
+ assert_eq!(input.get_cursor_position(), 5);
+ }
+
+ #[test]
+ fn test_undo_coalescing_breaks_on_cursor_move() {
+ let mut input = TextInput::empty();
+
+ // Type "he"
+ input.insert_char('h');
+ input.insert_char('e');
+
+ // Move cursor to start (breaks coalescing)
+ input.move_to_start();
+
+ // Type "llo"
+ input.insert_char('l');
+ input.insert_char('l');
+ input.insert_char('o');
+
+ assert_eq!(input.get_text(), "llohe");
+
+ // First undo removes "llo" (second coalesced group)
+ input.undo();
+ assert_eq!(input.get_text(), "he");
+
+ // Second undo removes "he" (first coalesced group)
+ input.undo();
+ assert_eq!(input.get_text(), "");
+ }
+
+ #[test]
+ fn test_undo_backspace() {
+ let mut input = TextInput::new("hello".to_string());
+
+ // Backspace once
+ input.backspace();
+ assert_eq!(input.get_text(), "hell");
+
+ // Undo should restore "hello"
+ input.undo();
+ assert_eq!(input.get_text(), "hello");
+ assert_eq!(input.get_cursor_position(), 5);
+ }
+
+ #[test]
+ fn test_undo_delete() {
+ let mut input = TextInput::new("hello".to_string());
+ input.cursor_position = 0;
+
+ // Delete first character
+ input.delete();
+ assert_eq!(input.get_text(), "ello");
+
+ // Undo should restore "hello"
+ input.undo();
+ assert_eq!(input.get_text(), "hello");
+ assert_eq!(input.get_cursor_position(), 0);
+ }
+
+ #[test]
+ fn test_undo_word_delete() {
+ let mut input = TextInput::new("hello world".to_string());
+
+ // Delete "world" backward
+ input.delete_word_backward();
+ assert_eq!(input.get_text(), "hello ");
+
+ // Undo should restore "hello world"
+ input.undo();
+ assert_eq!(input.get_text(), "hello world");
+ assert_eq!(input.get_cursor_position(), 11);
+ }
+
+ #[test]
+ fn test_undo_clear() {
+ let mut input = TextInput::new("hello world".to_string());
+
+ // Clear the buffer
+ input.clear();
+ assert_eq!(input.get_text(), "");
+
+ // Undo should restore the text
+ input.undo();
+ assert_eq!(input.get_text(), "hello world");
+ }
+
+ #[test]
+ fn test_undo_set_text() {
+ let mut input = TextInput::new("hello".to_string());
+
+ // Replace with new text
+ input.set_text("goodbye".to_string());
+ assert_eq!(input.get_text(), "goodbye");
+
+ // Undo should restore "hello"
+ input.undo();
+ assert_eq!(input.get_text(), "hello");
+ }
+
+ #[test]
+ fn test_redo_clears_on_new_edit() {
+ let mut input = TextInput::empty();
+
+ // Type "hello"
+ input.insert_char('h');
+ input.insert_char('e');
+ input.insert_char('l');
+ input.insert_char('l');
+ input.insert_char('o');
+
+ // Undo
+ input.undo();
+ assert_eq!(input.get_text(), "");
+ assert!(input.can_redo());
+
+ // Make a new edit (should clear redo stack)
+ input.insert_char('x');
+ assert!(!input.can_redo());
+ }
+
+ #[test]
+ fn test_multiple_undo_redo() {
+ let mut input = TextInput::empty();
+
+ // First edit: type "hello"
+ for c in "hello".chars() {
+ input.insert_char(c);
+ }
+
+ // Break coalescing
+ input.move_left();
+
+ // Second edit: type "world"
+ for c in "world".chars() {
+ input.insert_char(c);
+ }
+
+ assert_eq!(input.get_text(), "hellworldo");
+
+ // Undo "world"
+ input.undo();
+ assert_eq!(input.get_text(), "hello");
+
+ // Undo "hello"
+ input.undo();
+ assert_eq!(input.get_text(), "");
+
+ // Redo "hello"
+ input.redo();
+ assert_eq!(input.get_text(), "hello");
+
+ // Redo "world"
+ input.redo();
+ assert_eq!(input.get_text(), "hellworldo");
+ }
+
+ #[test]
+ fn test_undo_stack_limit() {
+ let mut input = TextInput::empty();
+
+ // Perform 102 separate edits (breaking coalescing each time)
+ for _i in 0..102 {
+ input.backspace(); // Break coalescing
+ input.insert_char('x');
+ }
+
+ // Should have at most 100 undo entries
+ let mut undo_count = 0;
+ while input.undo() {
+ undo_count += 1;
+ }
+
+ // We should have 100 undo entries (the stack limit)
+ // Plus the final state change from the last coalescing break
+ assert!(
+ undo_count <= 100,
+ "Undo count should be at most 100, got {}",
+ undo_count
+ );
+ }
+
+ #[test]
+ fn test_undo_redo_empty_stack() {
+ let mut input = TextInput::empty();
+
+ // Undo on empty stack should return false
+ assert!(!input.can_undo());
+ assert!(!input.undo());
+
+ // Redo on empty stack should return false
+ assert!(!input.can_redo());
+ assert!(!input.redo());
+ }
+
+ #[test]
+ fn test_undo_restores_cursor_position() {
+ let mut input = TextInput::new("hello world".to_string());
+
+ // Move cursor to position 5 (before "world")
+ input.cursor_position = 5;
+
+ // Insert a space
+ input.insert_char(' ');
+ assert_eq!(input.get_text(), "hello world");
+ assert_eq!(input.get_cursor_position(), 6);
+
+ // Undo should restore both text and cursor position
+ input.undo();
+ assert_eq!(input.get_text(), "hello world");
+ assert_eq!(input.get_cursor_position(), 5);
+ }
+
+ #[test]
+ fn test_coalescing_consecutive_inserts() {
+ let mut input = TextInput::empty();
+
+ // Type several characters
+ input.insert_char('a');
+ input.insert_char('b');
+ input.insert_char('c');
+
+ assert_eq!(input.get_text(), "abc");
+
+ // Single undo should remove all three (they were coalesced)
+ input.undo();
+ assert_eq!(input.get_text(), "");
+
+ // No more undo available
+ assert!(!input.can_undo());
+ }
+
+ #[test]
+ fn test_backspace_breaks_coalescing() {
+ let mut input = TextInput::empty();
+
+ // Type "ab"
+ input.insert_char('a');
+ input.insert_char('b');
+
+ // Backspace
+ input.backspace();
+ assert_eq!(input.get_text(), "a");
+
+ // Type "c"
+ input.insert_char('c');
+ assert_eq!(input.get_text(), "ac");
+
+ // Undo should remove just "c"
+ input.undo();
+ assert_eq!(input.get_text(), "a");
+
+ // Undo should remove backspace operation
+ input.undo();
+ assert_eq!(input.get_text(), "ab");
+
+ // Undo should remove "ab"
+ input.undo();
+ assert_eq!(input.get_text(), "");
+ }
+}
diff --git a/default-plugins/sequence/src/ui/truncation.rs b/default-plugins/sequence/src/ui/truncation.rs
new file mode 100644
index 00000000..0c4073a3
--- /dev/null
+++ b/default-plugins/sequence/src/ui/truncation.rs
@@ -0,0 +1,373 @@
+use unicode_width::UnicodeWidthStr;
+
+const BASE_SEPARATOR_WIDTH: usize = 2;
+
+pub fn calculate_available_cmd_width(
+ cols: usize,
+ folder_width: usize,
+ overflow_indicator: Option<&String>,
+ chain_width: usize,
+ status_width: usize,
+) -> usize {
+ let mut separator_width = BASE_SEPARATOR_WIDTH;
+ if overflow_indicator.is_some() {
+ separator_width += 1;
+ }
+ if status_width > 0 {
+ separator_width += 1;
+ }
+
+ let overflow_width = overflow_indicator.map(|s| s.chars().count()).unwrap_or(0);
+
+ cols.saturating_sub(folder_width)
+ .saturating_sub(chain_width)
+ .saturating_sub(status_width)
+ .saturating_sub(separator_width)
+ .saturating_sub(overflow_width)
+ .saturating_sub(2)
+ .max(1)
+}
+
+pub fn truncate_middle(
+ text: &str,
+ max_width: usize,
+ cursor_position: Option<usize>,
+) -> (String, Option<usize>) {
+ let text_width = text.width();
+
+ if text_width <= max_width {
+ return (text.to_string(), cursor_position);
+ }
+
+ if max_width < 5 {
+ return truncate_minimal(text, max_width, cursor_position);
+ }
+
+ if let Some(cursor_char_idx) = cursor_position {
+ return truncate_with_cursor(text, max_width, cursor_char_idx);
+ }
+
+ truncate_no_cursor(text, max_width)
+}
+
+fn truncate_minimal(
+ text: &str,
+ max_width: usize,
+ cursor_position: Option<usize>,
+) -> (String, Option<usize>) {
+ let mut result = String::new();
+ let mut current_width = 0;
+ let mut new_cursor_pos = None;
+ let mut char_pos = 0;
+
+ for ch in text.chars() {
+ let ch_width = ch.to_string().width();
+ if current_width + ch_width <= max_width {
+ result.push(ch);
+ if let Some(cursor_char) = cursor_position {
+ if char_pos == cursor_char {
+ new_cursor_pos = Some(char_pos);
+ }
+ }
+ char_pos += 1;
+ current_width += ch_width;
+ } else {
+ break;
+ }
+ }
+ (result, new_cursor_pos)
+}
+
+fn truncate_no_cursor(text: &str, max_width: usize) -> (String, Option<usize>) {
+ let available_for_text = max_width.saturating_sub(3);
+ let left_width = available_for_text / 2;
+ let right_width = available_for_text - left_width;
+
+ let mut left_part = String::new();
+ let mut current_width = 0;
+ for ch in text.chars() {
+ let ch_width = ch.to_string().width();
+ if current_width + ch_width <= left_width {
+ left_part.push(ch);
+ current_width += ch_width;
+ } else {
+ break;
+ }
+ }
+
+ let chars: Vec<char> = text.chars().collect();
+ let mut right_part = String::new();
+ let mut current_width = 0;
+ for ch in chars.iter().rev() {
+ let ch_width = ch.to_string().width();
+ if current_width + ch_width <= right_width {
+ right_part.insert(0, *ch);
+ current_width += ch_width;
+ } else {
+ break;
+ }
+ }
+
+ (format!("{}...{}", left_part, right_part), None)
+}
+
+fn truncate_with_cursor(
+ text: &str,
+ max_width: usize,
+ cursor_char_idx: usize,
+) -> (String, Option<usize>) {
+ let chars: Vec<char> = text.chars().collect();
+ let char_widths: Vec<usize> = chars.iter().map(|ch| ch.to_string().width()).collect();
+
+ let width_before_cursor: usize = char_widths[..cursor_char_idx].iter().sum();
+ let width_after_cursor: usize = char_widths[cursor_char_idx..].iter().sum();
+ let available_one_ellipsis = max_width.saturating_sub(3);
+
+ let (start_idx, end_idx) = if width_before_cursor <= available_one_ellipsis {
+ calculate_end_truncation(&chars, &char_widths, available_one_ellipsis)
+ } else if width_after_cursor <= available_one_ellipsis {
+ calculate_start_truncation(&chars, &char_widths, available_one_ellipsis)
+ } else {
+ calculate_middle_truncation(&char_widths, max_width, cursor_char_idx)
+ };
+
+ let (start_idx, end_idx) =
+ adjust_small_truncations(start_idx, end_idx, &char_widths, cursor_char_idx, &chars);
+ let (start_idx, end_idx) =
+ trim_excess(&char_widths, start_idx, end_idx, max_width, cursor_char_idx);
+
+ build_truncated_result(&chars, start_idx, end_idx, cursor_char_idx)
+}
+
+fn calculate_end_truncation(
+ chars: &[char],
+ char_widths: &[usize],
+ available: usize,
+) -> (usize, usize) {
+ let mut end_idx = 0;
+ let mut width = 0;
+ while end_idx < chars.len() && width + char_widths[end_idx] <= available {
+ width += char_widths[end_idx];
+ end_idx += 1;
+ }
+ (0, end_idx)
+}
+
+fn calculate_start_truncation(
+ chars: &[char],
+ char_widths: &[usize],
+ available: usize,
+) -> (usize, usize) {
+ let mut start_idx = chars.len();
+ let mut width = 0;
+ while start_idx > 0 && width + char_widths[start_idx - 1] <= available {
+ start_idx -= 1;
+ width += char_widths[start_idx];
+ }
+ (start_idx, chars.len())
+}
+
+fn calculate_middle_truncation(
+ char_widths: &[usize],
+ max_width: usize,
+ cursor_char_idx: usize,
+) -> (usize, usize) {
+ let available_both_ellipsis = max_width.saturating_sub(6);
+ let target_before = available_both_ellipsis / 2;
+ let target_after = available_both_ellipsis - target_before;
+
+ let mut start_idx = cursor_char_idx;
+ let mut width_before = 0;
+ while start_idx > 0 && width_before + char_widths[start_idx - 1] <= target_before {
+ start_idx -= 1;
+ width_before += char_widths[start_idx];
+ }
+
+ let mut end_idx = cursor_char_idx;
+ let mut width_after = 0;
+ while end_idx < char_widths.len() && width_after + char_widths[end_idx] <= target_after {
+ width_after += char_widths[end_idx];
+ end_idx += 1;
+ }
+
+ let leftover_before = target_before.saturating_sub(width_before);
+ let leftover_after = target_after.saturating_sub(width_after);
+
+ if leftover_before > 0 {
+ let mut extra = leftover_before;
+ while end_idx < char_widths.len() && char_widths[end_idx] <= extra {
+ extra -= char_widths[end_idx];
+ end_idx += 1;
+ }
+ }
+ if leftover_after > 0 {
+ let mut extra = leftover_after;
+ while start_idx > 0 && char_widths[start_idx - 1] <= extra {
+ start_idx -= 1;
+ extra -= char_widths[start_idx];
+ }
+ }
+
+ (start_idx, end_idx)
+}
+
+fn adjust_small_truncations(
+ start_idx: usize,
+ end_idx: usize,
+ char_widths: &[usize],
+ cursor_char_idx: usize,
+ chars: &[char],
+) -> (usize, usize) {
+ let width_truncated_start: usize = char_widths[..start_idx].iter().sum();
+ let width_truncated_end: usize = char_widths[end_idx..].iter().sum();
+
+ let mut start_idx = start_idx;
+ let mut end_idx = end_idx;
+
+ if width_truncated_start > 0 && width_truncated_start < 3 && end_idx < chars.len() {
+ let gained = width_truncated_start;
+ start_idx = 0;
+ let mut removed = 0;
+ while end_idx > cursor_char_idx + 1 && removed < gained {
+ end_idx -= 1;
+ removed += char_widths[end_idx];
+ }
+ } else if width_truncated_end > 0 && width_truncated_end < 3 && start_idx > 0 {
+ let gained = width_truncated_end;
+ end_idx = chars.len();
+ let mut removed = 0;
+ while start_idx < cursor_char_idx && removed < gained {
+ removed += char_widths[start_idx];
+ start_idx += 1;
+ }
+ }
+
+ (start_idx, end_idx)
+}
+
+fn trim_excess(
+ char_widths: &[usize],
+ start_idx: usize,
+ end_idx: usize,
+ max_width: usize,
+ cursor_char_idx: usize,
+) -> (usize, usize) {
+ let truncate_start = start_idx > 0;
+ let truncate_end = end_idx < char_widths.len();
+ let ellipsis_width = match (truncate_start, truncate_end) {
+ (true, true) => 6,
+ (true, false) | (false, true) => 3,
+ (false, false) => 0,
+ };
+
+ let visible_width: usize = char_widths[start_idx..end_idx].iter().sum();
+ let mut start_idx = start_idx;
+ let mut end_idx = end_idx;
+
+ if visible_width + ellipsis_width > max_width {
+ let mut excess = visible_width + ellipsis_width - max_width;
+ if truncate_end {
+ while excess > 0 && end_idx > cursor_char_idx + 1 {
+ end_idx -= 1;
+ excess = excess.saturating_sub(char_widths[end_idx]);
+ }
+ }
+ if excess > 0 && truncate_start {
+ while excess > 0 && start_idx < cursor_char_idx {
+ excess = excess.saturating_sub(char_widths[start_idx]);
+ start_idx += 1;
+ }
+ }
+ }
+
+ (start_idx, end_idx)
+}
+
+fn build_truncated_result(
+ chars: &[char],
+ start_idx: usize,
+ end_idx: usize,
+ cursor_char_idx: usize,
+) -> (String, Option<usize>) {
+ let mut result = String::new();
+ let mut new_cursor_char_pos = 0;
+ let mut current_char_pos = 0;
+
+ if start_idx > 0 {
+ result.push_str("...");
+ current_char_pos = 3;
+ }
+
+ for i in start_idx..end_idx {
+ if i == cursor_char_idx {
+ new_cursor_char_pos = current_char_pos;
+ }
+ result.push(chars[i]);
+ current_char_pos += 1;
+ }
+
+ if cursor_char_idx >= end_idx {
+ new_cursor_char_pos = current_char_pos;
+ }
+
+ if end_idx < chars.len() {
+ result.push_str("...");
+ }
+
+ (result, Some(new_cursor_char_pos))
+}
+
+#[cfg(test)]
+mod tests {
+ use super::*;
+
+ #[test]
+ fn test_truncate_middle_no_truncation_needed() {
+ let text = "hello world";
+ let (result, cursor_pos) = truncate_middle(text, 20, Some(6));
+ assert_eq!(result, "hello world");
+ assert_eq!(cursor_pos, Some(6));
+ }
+
+ #[test]
+ fn test_truncate_middle_no_cursor() {
+ let text = "this is a very long string that needs truncation";
+ let (result, cursor_pos) = truncate_middle(text, 20, None);
+ assert!(result.contains("..."));
+ assert_eq!(cursor_pos, None);
+ }
+
+ #[test]
+ fn test_truncate_middle_cursor_at_start() {
+ let text = "this is a very long string that needs truncation";
+ let (result, cursor_pos) = truncate_middle(text, 20, Some(0));
+ assert!(result.starts_with("this"));
+ assert!(result.ends_with("..."));
+ assert_eq!(cursor_pos, Some(0));
+ }
+
+ #[test]
+ fn test_truncate_middle_cursor_at_end() {
+ let text = "this is a very long string that needs truncation";
+ let cursor_char = text.chars().count();
+ let (result, _cursor_pos) = truncate_middle(text, 20, Some(cursor_char));
+ assert!(result.starts_with("..."));
+ assert!(result.ends_with("truncation"));
+ }
+
+ #[test]
+ fn test_truncate_middle_cursor_in_middle() {
+ let text = "this is a very long string that needs truncation";
+ let cursor_char = "this is a very ".chars().count();
+ let (result, cursor_pos) = truncate_middle(text, 20, Some(cursor_char));
+ assert!(result.contains("very"));
+ assert!(cursor_pos.is_some());
+ }
+
+ #[test]
+ fn test_truncate_middle_wide_chars() {
+ let text = "こんにちは世界";
+ let (result, _) = truncate_middle(text, 10, None);
+ assert!(result.width() <= 10);
+ }
+}