1use crate::recursive_parser::{Lexer, Token};
2
3pub struct TextNavigator;
6
7impl TextNavigator {
8 pub fn get_cursor_token_position(query: &str, cursor_pos: usize) -> (usize, usize) {
10 if query.is_empty() {
11 return (0, 0);
12 }
13
14 let mut lexer = Lexer::new(query);
16 let tokens = lexer.tokenize_all_with_positions();
17
18 if tokens.is_empty() {
19 return (0, 0);
20 }
21
22 if cursor_pos == 0 {
24 return (0, tokens.len());
25 }
26
27 let mut current_token = 0;
29 for (i, (start, end, _)) in tokens.iter().enumerate() {
30 if cursor_pos >= *start && cursor_pos <= *end {
31 current_token = i + 1;
32 break;
33 } else if cursor_pos < *start {
34 current_token = i;
36 break;
37 }
38 }
39
40 if current_token == 0 && cursor_pos > 0 {
42 current_token = tokens.len();
43 }
44
45 (current_token, tokens.len())
46 }
47
48 pub fn get_token_at_cursor(query: &str, cursor_pos: usize) -> Option<String> {
50 if query.is_empty() {
51 return None;
52 }
53
54 let mut lexer = Lexer::new(query);
56 let tokens = lexer.tokenize_all_with_positions();
57
58 for (start, end, token) in &tokens {
60 if cursor_pos >= *start && cursor_pos <= *end {
61 let token_str = Self::format_token(token);
63 return Some(token_str.to_string());
64 }
65 }
66
67 None
68 }
69
70 pub fn calculate_prev_token_position(query: &str, cursor_pos: usize) -> Option<usize> {
72 if cursor_pos == 0 {
73 return None;
74 }
75
76 let mut lexer = Lexer::new(query);
77 let tokens = lexer.tokenize_all_with_positions();
78
79 let mut in_token = false;
81 let mut current_token_start = 0;
82 for (start, end, _) in &tokens {
83 if cursor_pos > *start && cursor_pos <= *end {
84 in_token = true;
85 current_token_start = *start;
86 break;
87 }
88 }
89
90 let target_pos = if in_token && cursor_pos > current_token_start {
92 current_token_start
94 } else {
95 let mut prev_start = 0;
97 for (start, _, _) in tokens.iter().rev() {
98 if *start < cursor_pos {
99 prev_start = *start;
100 break;
101 }
102 }
103 prev_start
104 };
105
106 if target_pos < cursor_pos {
107 Some(target_pos)
108 } else {
109 None
110 }
111 }
112
113 pub fn calculate_next_token_position(query: &str, cursor_pos: usize) -> Option<usize> {
115 let query_len = query.len();
116 if cursor_pos >= query_len {
117 return None;
118 }
119
120 let mut lexer = Lexer::new(query);
121 let tokens = lexer.tokenize_all_with_positions();
122
123 let mut in_token = false;
125 let mut current_token_end = query_len;
126 for (start, end, _) in &tokens {
127 if cursor_pos >= *start && cursor_pos < *end {
128 in_token = true;
129 current_token_end = *end;
130 break;
131 }
132 }
133
134 let target_pos = if in_token && cursor_pos < current_token_end {
136 let mut next_start = query_len;
138 for (start, _, _) in &tokens {
139 if *start > current_token_end {
140 next_start = *start;
141 break;
142 }
143 }
144 next_start
145 } else {
146 let mut next_start = query_len;
148 for (start, _, _) in &tokens {
149 if *start > cursor_pos {
150 next_start = *start;
151 break;
152 }
153 }
154 next_start
155 };
156
157 if target_pos > cursor_pos && target_pos <= query_len {
158 Some(target_pos)
159 } else {
160 None
161 }
162 }
163
164 fn format_token(token: &Token) -> &str {
166 match token {
167 Token::Select => "SELECT",
168 Token::From => "FROM",
169 Token::Where => "WHERE",
170 Token::GroupBy => "GROUP BY",
171 Token::OrderBy => "ORDER BY",
172 Token::Having => "HAVING",
173 Token::As => "AS",
174 Token::Asc => "ASC",
175 Token::Desc => "DESC",
176 Token::And => "AND",
177 Token::Or => "OR",
178 Token::In => "IN",
179 Token::DateTime => "DateTime",
180 Token::Identifier(s) => s,
181 Token::QuotedIdentifier(s) => s,
182 Token::StringLiteral(s) => s,
183 Token::NumberLiteral(s) => s,
184 Token::Star => "*",
185 Token::Comma => ",",
186 Token::Dot => ".",
187 Token::LeftParen => "(",
188 Token::RightParen => ")",
189 Token::Equal => "=",
190 Token::NotEqual => "!=",
191 Token::LessThan => "<",
192 Token::LessThanOrEqual => "<=",
193 Token::GreaterThan => ">",
194 Token::GreaterThanOrEqual => ">=",
195 Token::Like => "LIKE",
196 Token::Not => "NOT",
197 Token::Is => "IS",
198 Token::Null => "NULL",
199 Token::Between => "BETWEEN",
200 Token::Limit => "LIMIT",
201 Token::Offset => "OFFSET",
202 Token::Plus => "+",
203 Token::Minus => "-",
204 Token::Divide => "/",
205 Token::Eof => "EOF",
206 }
207 }
208}
209
210pub struct TextEditor;
212
213impl TextEditor {
214 pub fn kill_line_backward(text: &str, cursor_pos: usize) -> Option<(String, String)> {
217 if cursor_pos == 0 {
218 return None;
219 }
220
221 let killed_text = text.chars().take(cursor_pos).collect::<String>();
222 let remaining_text = text.chars().skip(cursor_pos).collect::<String>();
223
224 Some((killed_text, remaining_text))
225 }
226
227 pub fn kill_line_forward(text: &str, cursor_pos: usize) -> Option<(String, String)> {
230 if cursor_pos >= text.len() {
231 return None;
232 }
233
234 let remaining_text = text.chars().take(cursor_pos).collect::<String>();
235 let killed_text = text.chars().skip(cursor_pos).collect::<String>();
236
237 Some((killed_text, remaining_text))
238 }
239
240 pub fn delete_word_backward(text: &str, cursor_pos: usize) -> Option<(String, String, usize)> {
243 if cursor_pos == 0 {
244 return None;
245 }
246
247 let before_cursor = &text[..cursor_pos];
248 let after_cursor = &text[cursor_pos..];
249
250 let mut word_start = before_cursor.len();
252 let mut chars = before_cursor.chars().rev().peekable();
253
254 while let Some(&ch) = chars.peek() {
256 if ch.is_whitespace() {
257 word_start -= ch.len_utf8();
258 chars.next();
259 } else {
260 break;
261 }
262 }
263
264 while let Some(&ch) = chars.peek() {
266 if !ch.is_alphanumeric() && ch != '_' {
267 break;
268 }
269 word_start -= ch.len_utf8();
270 chars.next();
271 }
272
273 while let Some(&ch) = chars.peek() {
275 if ch.is_whitespace() {
276 word_start -= ch.len_utf8();
277 chars.next();
278 } else {
279 break;
280 }
281 }
282
283 let deleted_text = text[word_start..cursor_pos].to_string();
284 let remaining_text = format!("{}{}", &text[..word_start], after_cursor);
285
286 Some((deleted_text, remaining_text, word_start))
287 }
288
289 pub fn delete_word_forward(text: &str, cursor_pos: usize) -> Option<(String, String)> {
292 if cursor_pos >= text.len() {
293 return None;
294 }
295
296 let before_cursor = &text[..cursor_pos];
297 let after_cursor = &text[cursor_pos..];
298
299 let mut chars = after_cursor.chars();
301 let mut word_end = 0;
302
303 while let Some(ch) = chars.next() {
305 word_end += ch.len_utf8();
306 if ch.is_alphanumeric() || ch == '_' {
307 while let Some(ch) = chars.next() {
309 if !ch.is_alphanumeric() && ch != '_' {
310 break;
311 }
312 word_end += ch.len_utf8();
313 }
314 break;
315 }
316 }
317
318 let deleted_text = text[cursor_pos..cursor_pos + word_end].to_string();
319 let remaining_text = format!("{}{}", before_cursor, &after_cursor[word_end..]);
320
321 Some((deleted_text, remaining_text))
322 }
323}
324
325#[cfg(test)]
326mod tests {
327 use super::*;
328
329 #[test]
330 fn test_cursor_token_position() {
331 let query = "SELECT * FROM users WHERE id = 1";
332
333 assert_eq!(TextNavigator::get_cursor_token_position(query, 0), (0, 8));
335
336 assert_eq!(TextNavigator::get_cursor_token_position(query, 3), (1, 8));
338
339 assert_eq!(TextNavigator::get_cursor_token_position(query, 7), (2, 8));
341 }
342
343 #[test]
344 fn test_kill_line_backward() {
345 let text = "SELECT * FROM users";
346
347 let result = TextEditor::kill_line_backward(text, 8);
349 assert_eq!(
350 result,
351 Some(("SELECT *".to_string(), " FROM users".to_string()))
352 );
353
354 let result = TextEditor::kill_line_backward(text, 0);
356 assert_eq!(result, None);
357 }
358
359 #[test]
360 fn test_delete_word_backward() {
361 let text = "SELECT * FROM users";
362
363 let result = TextEditor::delete_word_backward(text, 13);
365 assert_eq!(
366 result,
367 Some((" FROM".to_string(), "SELECT * users".to_string(), 8))
368 );
369 }
370}