use unicode_segmentation::{GraphemeCursor, UnicodeSegmentation};
fn prev_grapheme(s: &str, byte: usize) -> Option<usize> {
GraphemeCursor::new(byte, s.len(), true)
.prev_boundary(s, 0)
.ok()
.flatten()
}
fn next_grapheme(s: &str, byte: usize) -> Option<usize> {
GraphemeCursor::new(byte, s.len(), true)
.next_boundary(s, 0)
.ok()
.flatten()
}
fn is_word(s: &str) -> bool {
s.chars()
.any(|c| !c.is_whitespace() && !c.is_ascii_punctuation())
}
fn prev_word_byte(s: &str, byte: usize) -> usize {
let mut words = s
.split_word_bound_indices()
.filter(|(i, _)| *i < byte)
.rev();
while let Some((i, word)) = words.next() {
if is_word(word) {
return i;
}
}
0
}
fn next_word_byte(s: &str, byte: usize) -> usize {
let mut words = s.split_word_bound_indices().filter(|(i, _)| *i > byte);
while let Some((i, word)) = words.next() {
if is_word(word) {
return i;
}
}
s.len()
}
fn codepoint_to_byte(s: &str, n: usize) -> usize {
s.char_indices().nth(n).map_or(s.len(), |(i, _)| i)
}
fn byte_to_codepoint(s: &str, byte: usize) -> usize {
s[..byte].chars().count()
}
enum Side {
Left,
Right,
}
#[derive(Debug, PartialOrd, PartialEq, Eq, Clone, Copy, Hash)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub enum InputRequest {
SetCursor(usize),
InsertChar(char),
GoToPrevChar,
GoToNextChar,
GoToPrevWord,
GoToNextWord,
GoToStart,
GoToEnd,
DeletePrevChar,
DeleteNextChar,
DeletePrevWord,
DeleteNextWord,
DeleteLine,
DeleteTillEnd,
Yank,
}
#[derive(Debug, PartialOrd, PartialEq, Eq, Clone, Copy, Hash)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct StateChanged {
pub value: bool,
pub cursor: bool,
}
pub type InputResponse = Option<StateChanged>;
#[derive(Default, Debug, Clone)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct Input {
value: String,
cursor: usize,
yank: String,
last_was_cut: bool,
}
impl Input {
pub fn new(value: String) -> Self {
let len = value.chars().count();
Self {
value,
cursor: len,
yank: String::new(),
last_was_cut: false,
}
}
pub fn with_value(mut self, value: String) -> Self {
self.cursor = value.chars().count();
self.value = value;
self
}
pub fn with_cursor(mut self, cursor: usize) -> Self {
self.cursor = cursor.min(self.value.chars().count());
self
}
pub fn reset(&mut self) {
self.cursor = Default::default();
self.value = Default::default();
}
pub fn value_and_reset(&mut self) -> String {
let val = self.value.clone();
self.reset();
val
}
fn add_to_yank(&mut self, deleted: String, side: Side) {
if self.last_was_cut {
match side {
Side::Left => self.yank.insert_str(0, &deleted),
Side::Right => self.yank.push_str(&deleted),
}
} else {
self.yank = deleted;
}
}
fn set_last_was_cut(&mut self, req: InputRequest) {
use InputRequest::*;
self.last_was_cut = matches!(
req,
DeleteLine | DeletePrevWord | DeleteNextWord | DeleteTillEnd
);
}
pub fn handle(&mut self, req: InputRequest) -> InputResponse {
use InputRequest::*;
let result = match req {
SetCursor(pos) => {
let pos = pos.min(self.value.chars().count());
if self.cursor == pos {
None
} else {
self.cursor = pos;
Some(StateChanged {
value: false,
cursor: true,
})
}
}
InsertChar(c) => {
if self.cursor == self.value.chars().count() {
self.value.push(c);
} else {
self.value = self
.value
.chars()
.take(self.cursor)
.chain(
std::iter::once(c)
.chain(self.value.chars().skip(self.cursor)),
)
.collect();
}
self.cursor += 1;
Some(StateChanged {
value: true,
cursor: true,
})
}
DeletePrevChar => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let prev = prev_grapheme(&self.value, byte)?;
let removed = self.value[prev..byte].chars().count();
self.value.replace_range(prev..byte, "");
self.cursor -= removed;
Some(StateChanged {
value: true,
cursor: true,
})
}
DeleteNextChar => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let next = next_grapheme(&self.value, byte)?;
self.value.replace_range(byte..next, "");
Some(StateChanged {
value: true,
cursor: false,
})
}
GoToPrevChar => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let prev = prev_grapheme(&self.value, byte)?;
self.cursor -= self.value[prev..byte].chars().count();
Some(StateChanged {
value: false,
cursor: true,
})
}
GoToPrevWord => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let prev = prev_word_byte(&self.value, byte);
if self.cursor == 0 {
None
} else {
self.cursor = byte_to_codepoint(&self.value, prev);
Some(StateChanged {
value: false,
cursor: true,
})
}
}
GoToNextChar => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let next = next_grapheme(&self.value, byte)?;
self.cursor += self.value[byte..next].chars().count();
Some(StateChanged {
value: false,
cursor: true,
})
}
GoToNextWord => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let next = next_word_byte(&self.value, byte);
if self.cursor == self.value.chars().count() {
None
} else {
self.cursor = byte_to_codepoint(&self.value, next);
Some(StateChanged {
value: false,
cursor: true,
})
}
}
DeleteLine => {
if self.value.is_empty() {
None
} else {
let side = if self.cursor == self.value.chars().count() {
Side::Left
} else {
Side::Right
};
self.add_to_yank(self.value.clone(), side);
self.value = "".into();
self.cursor = 0;
Some(StateChanged {
value: true,
cursor: true,
})
}
}
DeletePrevWord => {
if self.cursor == 0 {
None
} else {
let byte = codepoint_to_byte(&self.value, self.cursor);
let prev = prev_word_byte(&self.value, byte);
let deleted = self.value[prev..byte].to_string();
self.add_to_yank(deleted, Side::Left);
self.value.replace_range(prev..byte, "");
self.cursor = byte_to_codepoint(&self.value, prev);
Some(StateChanged {
value: true,
cursor: true,
})
}
}
DeleteNextWord => {
let byte = codepoint_to_byte(&self.value, self.cursor);
let next = next_word_byte(&self.value, byte);
if self.cursor == self.value.chars().count() {
None
} else {
let deleted = self.value[byte..next].to_string();
self.add_to_yank(deleted, Side::Right);
self.value.replace_range(byte..next, "");
Some(StateChanged {
value: true,
cursor: false,
})
}
}
GoToStart => {
if self.cursor == 0 {
None
} else {
self.cursor = 0;
Some(StateChanged {
value: false,
cursor: true,
})
}
}
GoToEnd => {
let count = self.value.chars().count();
if self.cursor == count {
None
} else {
self.cursor = count;
Some(StateChanged {
value: false,
cursor: true,
})
}
}
DeleteTillEnd => {
let deleted: String = self.value.chars().skip(self.cursor).collect();
self.add_to_yank(deleted, Side::Right);
self.value = self.value.chars().take(self.cursor).collect();
Some(StateChanged {
value: true,
cursor: false,
})
}
Yank => {
if self.yank.is_empty() {
None
} else if self.cursor == self.value.chars().count() {
self.value.push_str(&self.yank);
self.cursor += self.yank.chars().count();
Some(StateChanged {
value: true,
cursor: true,
})
} else {
self.value = self
.value
.chars()
.take(self.cursor)
.chain(self.yank.chars())
.chain(self.value.chars().skip(self.cursor))
.collect();
self.cursor += self.yank.chars().count();
Some(StateChanged {
value: true,
cursor: true,
})
}
}
};
self.set_last_was_cut(req);
result
}
pub fn value(&self) -> &str {
self.value.as_str()
}
pub fn cursor(&self) -> usize {
self.cursor
}
pub fn visual_cursor(&self) -> usize {
if self.cursor == 0 {
return 0;
}
unicode_width::UnicodeWidthStr::width(unsafe {
self.value.get_unchecked(
0..self
.value
.char_indices()
.nth(self.cursor)
.map_or_else(|| self.value.len(), |(index, _)| index),
)
})
}
pub fn visual_scroll(&self, width: usize) -> usize {
let scroll = (self.visual_cursor()).max(width) - width;
let mut uscroll = 0;
let mut chars = self.value().chars();
while uscroll < scroll {
match chars.next() {
Some(c) => {
uscroll += unicode_width::UnicodeWidthChar::width(c).unwrap_or(0);
}
None => break,
}
}
uscroll
}
}
impl From<Input> for String {
fn from(input: Input) -> Self {
input.value
}
}
impl From<String> for Input {
fn from(value: String) -> Self {
Self::new(value)
}
}
impl From<&str> for Input {
fn from(value: &str) -> Self {
Self::new(value.into())
}
}
impl std::fmt::Display for Input {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
self.value.fmt(f)
}
}
#[cfg(test)]
mod tests;