1use crate::recursive_parser::{Lexer, Token};
2
3pub struct TextNavigator;
6
7impl TextNavigator {
8 #[must_use]
10 pub fn get_cursor_token_position(query: &str, cursor_pos: usize) -> (usize, usize) {
11 if query.is_empty() {
12 return (0, 0);
13 }
14
15 let mut lexer = Lexer::new(query);
17 let tokens = lexer.tokenize_all_with_positions();
18
19 if tokens.is_empty() {
20 return (0, 0);
21 }
22
23 if cursor_pos == 0 {
25 return (0, tokens.len());
26 }
27
28 let mut current_token = 0;
30 for (i, (start, end, _)) in tokens.iter().enumerate() {
31 if cursor_pos >= *start && cursor_pos <= *end {
32 current_token = i + 1;
33 break;
34 } else if cursor_pos < *start {
35 current_token = i;
37 break;
38 }
39 }
40
41 if current_token == 0 && cursor_pos > 0 {
43 current_token = tokens.len();
44 }
45
46 (current_token, tokens.len())
47 }
48
49 #[must_use]
51 pub fn get_token_at_cursor(query: &str, cursor_pos: usize) -> Option<String> {
52 if query.is_empty() {
53 return None;
54 }
55
56 let mut lexer = Lexer::new(query);
58 let tokens = lexer.tokenize_all_with_positions();
59
60 for (start, end, token) in &tokens {
62 if cursor_pos >= *start && cursor_pos <= *end {
63 let token_str = Self::format_token(token);
65 return Some(token_str.to_string());
66 }
67 }
68
69 None
70 }
71
72 #[must_use]
74 pub fn calculate_prev_token_position(query: &str, cursor_pos: usize) -> Option<usize> {
75 if cursor_pos == 0 {
76 return None;
77 }
78
79 let mut lexer = Lexer::new(query);
80 let tokens = lexer.tokenize_all_with_positions();
81
82 let mut in_token = false;
84 let mut current_token_start = 0;
85 for (start, end, _) in &tokens {
86 if cursor_pos > *start && cursor_pos <= *end {
87 in_token = true;
88 current_token_start = *start;
89 break;
90 }
91 }
92
93 let target_pos = if in_token && cursor_pos > current_token_start {
95 current_token_start
97 } else {
98 let mut prev_start = 0;
100 for (start, _, _) in tokens.iter().rev() {
101 if *start < cursor_pos {
102 prev_start = *start;
103 break;
104 }
105 }
106 prev_start
107 };
108
109 if target_pos < cursor_pos {
110 Some(target_pos)
111 } else {
112 None
113 }
114 }
115
116 #[must_use]
118 pub fn calculate_next_token_position(query: &str, cursor_pos: usize) -> Option<usize> {
119 let query_len = query.len();
120 if cursor_pos >= query_len {
121 return None;
122 }
123
124 let mut lexer = Lexer::new(query);
125 let tokens = lexer.tokenize_all_with_positions();
126
127 let mut in_token = false;
129 let mut current_token_end = query_len;
130 for (start, end, _) in &tokens {
131 if cursor_pos >= *start && cursor_pos < *end {
132 in_token = true;
133 current_token_end = *end;
134 break;
135 }
136 }
137
138 let target_pos = if in_token && cursor_pos < current_token_end {
140 let mut next_start = query_len;
142 for (start, _, _) in &tokens {
143 if *start > current_token_end {
144 next_start = *start;
145 break;
146 }
147 }
148 next_start
149 } else {
150 let mut next_start = query_len;
152 for (start, _, _) in &tokens {
153 if *start > cursor_pos {
154 next_start = *start;
155 break;
156 }
157 }
158 next_start
159 };
160
161 if target_pos > cursor_pos && target_pos <= query_len {
162 Some(target_pos)
163 } else {
164 None
165 }
166 }
167
168 fn format_token(token: &Token) -> &str {
170 match token {
171 Token::Select => "SELECT",
172 Token::From => "FROM",
173 Token::Where => "WHERE",
174 Token::With => "WITH",
175 Token::GroupBy => "GROUP BY",
176 Token::OrderBy => "ORDER BY",
177 Token::Having => "HAVING",
178 Token::As => "AS",
179 Token::Asc => "ASC",
180 Token::Desc => "DESC",
181 Token::And => "AND",
182 Token::Or => "OR",
183 Token::In => "IN",
184 Token::DateTime => "DateTime",
185 Token::Case => "CASE",
186 Token::When => "WHEN",
187 Token::Then => "THEN",
188 Token::Else => "ELSE",
189 Token::End => "END",
190 Token::Distinct => "DISTINCT",
191 Token::Exclude => "EXCLUDE",
192 Token::Pivot => "PIVOT",
193 Token::Unpivot => "UNPIVOT",
194 Token::For => "FOR",
195 Token::Over => "OVER",
196 Token::Partition => "PARTITION",
197 Token::By => "BY",
198 Token::Rows => "ROWS",
200 Token::Range => "RANGE",
201 Token::Unbounded => "UNBOUNDED",
202 Token::Preceding => "PRECEDING",
203 Token::Following => "FOLLOWING",
204 Token::Current => "CURRENT",
205 Token::Row => "ROW",
206 Token::Union => "UNION",
208 Token::Intersect => "INTERSECT",
209 Token::Except => "EXCEPT",
210 Token::Web => "WEB",
212 Token::File => "FILE",
213 Token::Unnest => "UNNEST",
215 Token::Identifier(s) => s,
216 Token::QuotedIdentifier(s) => s,
217 Token::StringLiteral(s) => s,
218 Token::JsonBlock(s) => s,
219 Token::NumberLiteral(s) => s,
220 Token::Star => "*",
221 Token::Comma => ",",
222 Token::Colon => ":",
223 Token::Dot => ".",
224 Token::LeftParen => "(",
225 Token::RightParen => ")",
226 Token::Equal => "=",
227 Token::NotEqual => "!=",
228 Token::LessThan => "<",
229 Token::LessThanOrEqual => "<=",
230 Token::GreaterThan => ">",
231 Token::GreaterThanOrEqual => ">=",
232 Token::Like => "LIKE",
233 Token::ILike => "ILIKE",
234 Token::Not => "NOT",
235 Token::Is => "IS",
236 Token::Null => "NULL",
237 Token::Between => "BETWEEN",
238 Token::Limit => "LIMIT",
239 Token::Offset => "OFFSET",
240 Token::Into => "INTO",
241 Token::Plus => "+",
242 Token::Minus => "-",
243 Token::Divide => "/",
244 Token::Modulo => "%",
245 Token::Concat => "||",
246 Token::Join => "JOIN",
247 Token::Inner => "INNER",
248 Token::Left => "LEFT",
249 Token::Right => "RIGHT",
250 Token::Full => "FULL",
251 Token::Cross => "CROSS",
252 Token::Outer => "OUTER",
253 Token::On => "ON",
254 Token::LineComment(text) => text,
255 Token::BlockComment(text) => text,
256 Token::Eof => "EOF",
257 Token::Qualify => "QUALIFY",
258 }
259 }
260}
261
262pub struct TextEditor;
264
265impl TextEditor {
266 #[must_use]
269 pub fn kill_line_backward(text: &str, cursor_pos: usize) -> Option<(String, String)> {
270 if cursor_pos == 0 {
271 return None;
272 }
273
274 let killed_text = text.chars().take(cursor_pos).collect::<String>();
275 let remaining_text = text.chars().skip(cursor_pos).collect::<String>();
276
277 Some((killed_text, remaining_text))
278 }
279
280 #[must_use]
283 pub fn kill_line_forward(text: &str, cursor_pos: usize) -> Option<(String, String)> {
284 if cursor_pos >= text.len() {
285 return None;
286 }
287
288 let remaining_text = text.chars().take(cursor_pos).collect::<String>();
289 let killed_text = text.chars().skip(cursor_pos).collect::<String>();
290
291 Some((killed_text, remaining_text))
292 }
293
294 #[must_use]
297 pub fn delete_word_backward(text: &str, cursor_pos: usize) -> Option<(String, String, usize)> {
298 if cursor_pos == 0 {
299 return None;
300 }
301
302 let before_cursor = &text[..cursor_pos];
303 let after_cursor = &text[cursor_pos..];
304
305 let mut word_start = before_cursor.len();
307 let mut chars = before_cursor.chars().rev().peekable();
308
309 while let Some(&ch) = chars.peek() {
311 if ch.is_whitespace() {
312 word_start -= ch.len_utf8();
313 chars.next();
314 } else {
315 break;
316 }
317 }
318
319 while let Some(&ch) = chars.peek() {
321 if !ch.is_alphanumeric() && ch != '_' {
322 break;
323 }
324 word_start -= ch.len_utf8();
325 chars.next();
326 }
327
328 while let Some(&ch) = chars.peek() {
330 if ch.is_whitespace() {
331 word_start -= ch.len_utf8();
332 chars.next();
333 } else {
334 break;
335 }
336 }
337
338 let deleted_text = text[word_start..cursor_pos].to_string();
339 let remaining_text = format!("{}{}", &text[..word_start], after_cursor);
340
341 Some((deleted_text, remaining_text, word_start))
342 }
343
344 #[must_use]
347 pub fn delete_word_forward(text: &str, cursor_pos: usize) -> Option<(String, String)> {
348 if cursor_pos >= text.len() {
349 return None;
350 }
351
352 let before_cursor = &text[..cursor_pos];
353 let after_cursor = &text[cursor_pos..];
354
355 let mut chars = after_cursor.chars();
357 let mut word_end = 0;
358
359 while let Some(ch) = chars.next() {
361 word_end += ch.len_utf8();
362 if ch.is_alphanumeric() || ch == '_' {
363 for ch in chars.by_ref() {
365 if !ch.is_alphanumeric() && ch != '_' {
366 break;
367 }
368 word_end += ch.len_utf8();
369 }
370 break;
371 }
372 }
373
374 let deleted_text = text[cursor_pos..cursor_pos + word_end].to_string();
375 let remaining_text = format!("{}{}", before_cursor, &after_cursor[word_end..]);
376
377 Some((deleted_text, remaining_text))
378 }
379}
380
381#[cfg(test)]
382mod tests {
383 use super::*;
384
385 #[test]
386 fn test_cursor_token_position() {
387 let query = "SELECT * FROM users WHERE id = 1";
388
389 assert_eq!(TextNavigator::get_cursor_token_position(query, 0), (0, 8));
391
392 assert_eq!(TextNavigator::get_cursor_token_position(query, 3), (1, 8));
394
395 assert_eq!(TextNavigator::get_cursor_token_position(query, 7), (2, 8));
397 }
398
399 #[test]
400 fn test_kill_line_backward() {
401 let text = "SELECT * FROM users";
402
403 let result = TextEditor::kill_line_backward(text, 8);
405 assert_eq!(
406 result,
407 Some(("SELECT *".to_string(), " FROM users".to_string()))
408 );
409
410 let result = TextEditor::kill_line_backward(text, 0);
412 assert_eq!(result, None);
413 }
414
415 #[test]
416 fn test_delete_word_backward() {
417 let text = "SELECT * FROM users";
418
419 let result = TextEditor::delete_word_backward(text, 13);
421 assert_eq!(
422 result,
423 Some((" FROM".to_string(), "SELECT * users".to_string(), 8))
424 );
425 }
426}