use rust_i18n::t;
use super::normalize_path;
use super::BufferId;
use super::BufferMetadata;
use super::Editor;
use crate::input::keybindings::Action;
use crate::primitives::path_utils::expand_tilde;
use crate::services::plugins::hooks::HookArgs;
use crate::view::prompt::PromptType;
pub enum PromptResult {
Done,
ExecuteAction(Action),
EarlyReturn,
}
impl Editor {
pub fn handle_prompt_confirm_input(
&mut self,
input: String,
prompt_type: PromptType,
selected_index: Option<usize>,
) -> PromptResult {
match prompt_type {
PromptType::OpenFile => {
let expanded_path = expand_tilde(&input);
let resolved_path = if expanded_path.is_absolute() {
normalize_path(&expanded_path)
} else {
normalize_path(&self.working_dir.join(&expanded_path))
};
if let Err(e) = self.open_file(&resolved_path) {
self.set_status_message(
t!("file.error_opening", error = e.to_string()).to_string(),
);
} else {
self.set_status_message(
t!("buffer.opened", name = resolved_path.display().to_string()).to_string(),
);
}
}
PromptType::SwitchProject => {
let expanded_path = expand_tilde(&input);
let resolved_path = if expanded_path.is_absolute() {
normalize_path(&expanded_path)
} else {
normalize_path(&self.working_dir.join(&expanded_path))
};
if resolved_path.is_dir() {
self.change_working_dir(resolved_path);
} else {
self.set_status_message(
t!(
"file.not_directory",
path = resolved_path.display().to_string()
)
.to_string(),
);
}
}
PromptType::SaveFileAs => {
self.handle_save_file_as(&input);
}
PromptType::Search => {
self.perform_search(&input);
}
PromptType::ReplaceSearch => {
self.perform_search(&input);
self.start_prompt(
t!("replace.prompt", search = &input).to_string(),
PromptType::Replace {
search: input.clone(),
},
);
}
PromptType::Replace { search } => {
if self.search_confirm_each {
self.start_interactive_replace(&search, &input);
} else {
self.perform_replace(&search, &input);
}
}
PromptType::QueryReplaceSearch => {
self.perform_search(&input);
self.start_prompt(
t!("replace.query_prompt", search = &input).to_string(),
PromptType::QueryReplace {
search: input.clone(),
},
);
}
PromptType::QueryReplace { search } => {
if self.search_confirm_each {
self.start_interactive_replace(&search, &input);
} else {
self.perform_replace(&search, &input);
}
}
PromptType::Command => {
let commands = self.command_registry.read().unwrap().get_all();
if let Some(cmd) = commands.iter().find(|c| c.get_localized_name() == input) {
let action = cmd.action.clone();
let cmd_name = cmd.get_localized_name();
self.command_registry
.write()
.unwrap()
.record_usage(&cmd_name);
return PromptResult::ExecuteAction(action);
} else {
self.set_status_message(
t!("error.unknown_command", input = &input).to_string(),
);
}
}
PromptType::GotoLine => match input.trim().parse::<usize>() {
Ok(line_num) if line_num > 0 => {
self.goto_line_col(line_num, None);
self.set_status_message(t!("goto.jumped", line = line_num).to_string());
}
Ok(_) => {
self.set_status_message(t!("goto.line_must_be_positive").to_string());
}
Err(_) => {
self.set_status_message(t!("error.invalid_line", input = &input).to_string());
}
},
PromptType::QuickOpen => {
return self.handle_quick_open_confirm(&input, selected_index);
}
PromptType::SetBackgroundFile => {
if let Err(e) = self.load_ansi_background(&input) {
self.set_status_message(
t!("error.background_load_failed", error = e.to_string()).to_string(),
);
}
}
PromptType::SetBackgroundBlend => match input.trim().parse::<f32>() {
Ok(val) => {
let clamped = val.clamp(0.0, 1.0);
self.background_fade = clamped;
self.set_status_message(
t!(
"error.background_blend_set",
value = format!("{:.2}", clamped)
)
.to_string(),
);
}
Err(_) => {
self.set_status_message(t!("error.invalid_blend", input = &input).to_string());
}
},
PromptType::SetComposeWidth => {
self.handle_set_compose_width(&input);
}
PromptType::RecordMacro => {
self.handle_register_input(
&input,
|editor, c| editor.toggle_macro_recording(c),
"Macro",
);
}
PromptType::PlayMacro => {
self.handle_register_input(&input, |editor, c| editor.play_macro(c), "Macro");
}
PromptType::SetBookmark => {
self.handle_register_input(&input, |editor, c| editor.set_bookmark(c), "Bookmark");
}
PromptType::JumpToBookmark => {
self.handle_register_input(
&input,
|editor, c| editor.jump_to_bookmark(c),
"Bookmark",
);
}
PromptType::Plugin { custom_type } => {
tracing::info!(
"prompt_confirmed: dispatching hook for prompt_type='{}', input='{}', selected_index={:?}",
custom_type, input, selected_index
);
self.plugin_manager.run_hook(
"prompt_confirmed",
HookArgs::PromptConfirmed {
prompt_type: custom_type.clone(),
input,
selected_index,
},
);
tracing::info!(
"prompt_confirmed: hook dispatched for prompt_type='{}'",
custom_type
);
}
PromptType::ConfirmRevert => {
let input_lower = input.trim().to_lowercase();
let revert_key = t!("prompt.key.revert").to_string().to_lowercase();
if input_lower == revert_key || input_lower == "revert" {
if let Err(e) = self.revert_file() {
self.set_status_message(
t!("file.revert_failed", error = e.to_string()).to_string(),
);
}
} else {
self.set_status_message(t!("buffer.revert_cancelled").to_string());
}
}
PromptType::ConfirmSaveConflict => {
let input_lower = input.trim().to_lowercase();
if input_lower == "o" || input_lower == "overwrite" {
if let Err(e) = self.save() {
self.set_status_message(
t!("file.save_failed", error = e.to_string()).to_string(),
);
}
} else {
self.set_status_message(t!("buffer.save_cancelled").to_string());
}
}
PromptType::ConfirmSudoSave { info } => {
let input_lower = input.trim().to_lowercase();
if input_lower == "y" || input_lower == "yes" {
self.cancel_prompt();
let cmd = format!(
"sudo sh -c \"cp '{}' '{}' && chmod {:o} '{}' && chown {}:{} '{}' && rm '{}'\"",
info.temp_path.display(),
info.dest_path.display(),
info.mode,
info.dest_path.display(),
info.uid,
info.gid,
info.dest_path.display(),
info.temp_path.display()
);
match self.run_shell_command_blocking(&cmd) {
Ok(_) => {
if let Err(e) = self
.active_state_mut()
.buffer
.finalize_external_save(info.dest_path.clone())
{
self.set_status_message(
t!("prompt.sudo_save_failed", error = e.to_string())
.to_string(),
);
} else if let Err(e) = self.finalize_save(Some(info.dest_path)) {
self.set_status_message(
t!("prompt.sudo_save_failed", error = e.to_string())
.to_string(),
);
}
}
Err(e) => {
self.set_status_message(
t!("prompt.sudo_save_failed", error = e.to_string()).to_string(),
);
let _ = self.filesystem.remove_file(&info.temp_path);
}
}
} else {
self.set_status_message(t!("buffer.save_cancelled").to_string());
let _ = self.filesystem.remove_file(&info.temp_path);
}
}
PromptType::ConfirmOverwriteFile { path } => {
let input_lower = input.trim().to_lowercase();
if input_lower == "o" || input_lower == "overwrite" {
self.perform_save_file_as(path);
} else {
self.set_status_message(t!("buffer.save_cancelled").to_string());
}
}
PromptType::ConfirmCloseBuffer { buffer_id } => {
if self.handle_confirm_close_buffer(&input, buffer_id) {
return PromptResult::EarlyReturn;
}
}
PromptType::ConfirmQuitWithModified => {
let input_lower = input.trim().to_lowercase();
let discard_key = t!("prompt.key.discard").to_string().to_lowercase();
if input_lower == discard_key || input_lower == "discard" {
self.should_quit = true;
} else {
self.set_status_message(t!("buffer.close_cancelled").to_string());
}
}
PromptType::LspRename {
original_text,
start_pos,
end_pos: _,
overlay_handle,
} => {
self.perform_lsp_rename(input, original_text, start_pos, overlay_handle);
}
PromptType::FileExplorerRename {
original_path,
original_name,
is_new_file,
} => {
self.perform_file_explorer_rename(original_path, original_name, input, is_new_file);
}
PromptType::ConfirmDeleteFile { path, is_dir } => {
let input_lower = input.trim().to_lowercase();
if input_lower == "y" || input_lower == "yes" {
self.perform_file_explorer_delete(path, is_dir);
} else {
self.set_status_message(t!("explorer.delete_cancelled").to_string());
}
}
PromptType::StopLspServer => {
self.handle_stop_lsp_server(&input);
}
PromptType::SelectTheme { .. } => {
self.apply_theme(input.trim());
}
PromptType::SelectKeybindingMap => {
self.apply_keybinding_map(input.trim());
}
PromptType::SelectCursorStyle => {
self.apply_cursor_style(input.trim());
}
PromptType::SelectLocale => {
self.apply_locale(input.trim());
}
PromptType::CopyWithFormattingTheme => {
self.copy_selection_with_theme(input.trim());
}
PromptType::SwitchToTab => {
if let Ok(id) = input.trim().parse::<usize>() {
self.switch_to_tab(BufferId(id));
}
}
PromptType::QueryReplaceConfirm => {
if let Some(c) = input.chars().next() {
let _ = self.handle_interactive_replace_key(c);
}
}
PromptType::SetTabSize => {
self.handle_set_tab_size(&input);
}
PromptType::SetLineEnding => {
self.handle_set_line_ending(&input);
}
PromptType::SetLanguage => {
self.handle_set_language(&input);
}
PromptType::ShellCommand { replace } => {
self.handle_shell_command(&input, replace);
}
PromptType::AsyncPrompt => {
if let Some(callback_id) = self.pending_async_prompt_callback.take() {
let json = serde_json::to_string(&input).unwrap_or_else(|_| "null".to_string());
self.plugin_manager.resolve_callback(callback_id, json);
}
}
}
PromptResult::Done
}
fn handle_save_file_as(&mut self, input: &str) {
let expanded_path = expand_tilde(input);
let full_path = if expanded_path.is_absolute() {
normalize_path(&expanded_path)
} else {
normalize_path(&self.working_dir.join(&expanded_path))
};
let current_file_path = self
.active_state()
.buffer
.file_path()
.map(|p| p.to_path_buf());
let is_different_file = current_file_path.as_ref() != Some(&full_path);
if is_different_file && full_path.is_file() {
let filename = full_path
.file_name()
.map(|n| n.to_string_lossy().to_string())
.unwrap_or_else(|| full_path.display().to_string());
self.start_prompt(
t!("buffer.overwrite_confirm", name = &filename).to_string(),
PromptType::ConfirmOverwriteFile { path: full_path },
);
return;
}
self.perform_save_file_as(full_path);
}
pub(crate) fn perform_save_file_as(&mut self, full_path: std::path::PathBuf) {
let before_idx = self.active_event_log().current_index();
let before_len = self.active_event_log().len();
tracing::debug!(
"SaveFileAs BEFORE: event_log index={}, len={}",
before_idx,
before_len
);
match self.active_state_mut().buffer.save_to_file(&full_path) {
Ok(()) => {
let after_save_idx = self.active_event_log().current_index();
let after_save_len = self.active_event_log().len();
tracing::debug!(
"SaveFileAs AFTER buffer.save_to_file: event_log index={}, len={}",
after_save_idx,
after_save_len
);
let metadata = BufferMetadata::with_file(full_path.clone(), &self.working_dir);
self.buffer_metadata.insert(self.active_buffer(), metadata);
if let Some(state) = self.buffers.get_mut(&self.active_buffer()) {
if state.language == "text" {
if let Some(filename) = full_path.file_name().and_then(|n| n.to_str()) {
state.set_language_from_name(filename, &self.grammar_registry);
}
}
}
self.active_event_log_mut().mark_saved();
tracing::debug!(
"SaveFileAs AFTER mark_saved: event_log index={}, len={}",
self.active_event_log().current_index(),
self.active_event_log().len()
);
if let Ok(metadata) = self.filesystem.metadata(&full_path) {
if let Some(mtime) = metadata.modified {
self.file_mod_times.insert(full_path.clone(), mtime);
}
}
self.notify_lsp_save();
self.emit_event(
crate::model::control_event::events::FILE_SAVED.name,
serde_json::json!({"path": full_path.display().to_string()}),
);
self.plugin_manager.run_hook(
"after_file_save",
crate::services::plugins::hooks::HookArgs::AfterFileSave {
buffer_id: self.active_buffer(),
path: full_path.clone(),
},
);
if let Some(buffer_to_close) = self.pending_close_buffer.take() {
if let Err(e) = self.force_close_buffer(buffer_to_close) {
self.set_status_message(
t!("file.saved_cannot_close", error = e.to_string()).to_string(),
);
} else {
self.set_status_message(t!("buffer.saved_and_closed").to_string());
}
} else {
self.set_status_message(
t!("file.saved_as", path = full_path.display().to_string()).to_string(),
);
}
}
Err(e) => {
self.pending_close_buffer = None;
self.set_status_message(t!("file.error_saving", error = e.to_string()).to_string());
}
}
}
fn handle_set_compose_width(&mut self, input: &str) {
let buffer_id = self.active_buffer();
let active_split = self.split_manager.active_split();
let trimmed = input.trim();
if trimmed.is_empty() {
if let Some(state) = self.buffers.get_mut(&buffer_id) {
state.compose_width = None;
}
if let Some(vs) = self.split_view_states.get_mut(&active_split) {
vs.compose_width = None;
}
self.set_status_message(t!("settings.compose_width_cleared").to_string());
} else {
match trimmed.parse::<u16>() {
Ok(val) if val > 0 => {
if let Some(state) = self.buffers.get_mut(&buffer_id) {
state.compose_width = Some(val);
}
if let Some(vs) = self.split_view_states.get_mut(&active_split) {
vs.compose_width = Some(val);
}
self.set_status_message(
t!("settings.compose_width_set", value = val).to_string(),
);
}
_ => {
self.set_status_message(
t!("error.invalid_compose_width", input = input).to_string(),
);
}
}
}
}
fn handle_set_tab_size(&mut self, input: &str) {
let buffer_id = self.active_buffer();
let trimmed = input.trim();
match trimmed.parse::<usize>() {
Ok(val) if val > 0 => {
if let Some(state) = self.buffers.get_mut(&buffer_id) {
state.tab_size = val;
}
self.set_status_message(t!("settings.tab_size_set", value = val).to_string());
}
Ok(_) => {
self.set_status_message(t!("settings.tab_size_positive").to_string());
}
Err(_) => {
self.set_status_message(t!("error.invalid_tab_size", input = input).to_string());
}
}
}
fn handle_set_line_ending(&mut self, input: &str) {
use crate::model::buffer::LineEnding;
let trimmed = input.trim();
let code = trimmed.split_whitespace().next().unwrap_or(trimmed);
let line_ending = match code.to_uppercase().as_str() {
"LF" => Some(LineEnding::LF),
"CRLF" => Some(LineEnding::CRLF),
"CR" => Some(LineEnding::CR),
_ => None,
};
match line_ending {
Some(le) => {
self.active_state_mut().buffer.set_line_ending(le);
self.set_status_message(
t!("settings.line_ending_set", value = le.display_name()).to_string(),
);
}
None => {
self.set_status_message(t!("error.unknown_line_ending", input = input).to_string());
}
}
}
fn handle_set_language(&mut self, input: &str) {
use crate::primitives::highlight_engine::HighlightEngine;
use crate::primitives::highlighter::Language;
let trimmed = input.trim();
if trimmed == "Plain Text" || trimmed.to_lowercase() == "text" {
let buffer_id = self.active_buffer();
if let Some(state) = self.buffers.get_mut(&buffer_id) {
state.language = "Plain Text".to_string();
state.highlighter = HighlightEngine::None;
self.set_status_message("Language set to Plain Text".to_string());
}
return;
}
if self.grammar_registry.find_syntax_by_name(trimmed).is_some() {
let ts_language = Language::from_name(trimmed);
let buffer_id = self.active_buffer();
if let Some(state) = self.buffers.get_mut(&buffer_id) {
state.language = trimmed.to_string();
state.highlighter =
HighlightEngine::for_syntax_name(trimmed, &self.grammar_registry, ts_language);
if let Some(lang) = ts_language {
state.reference_highlighter.set_language(&lang);
}
self.set_status_message(format!("Language set to {}", trimmed));
}
} else {
self.set_status_message(format!("Unknown language: {}", input));
}
}
fn handle_register_input<F>(&mut self, input: &str, action: F, register_type: &str)
where
F: FnOnce(&mut Self, char),
{
if let Some(c) = input.trim().chars().next() {
if c.is_ascii_digit() {
action(self, c);
} else {
self.set_status_message(
t!("register.must_be_digit", "type" = register_type).to_string(),
);
}
} else {
self.set_status_message(t!("register.not_specified").to_string());
}
}
fn handle_confirm_close_buffer(&mut self, input: &str, buffer_id: BufferId) -> bool {
let input_lower = input.trim().to_lowercase();
let save_key = t!("prompt.key.save").to_string().to_lowercase();
let discard_key = t!("prompt.key.discard").to_string().to_lowercase();
let first_char = input_lower.chars().next();
let save_first = save_key.chars().next();
let discard_first = discard_key.chars().next();
if first_char == save_first {
let has_path = self
.buffers
.get(&buffer_id)
.map(|s| s.buffer.file_path().is_some())
.unwrap_or(false);
if has_path {
let old_active = self.active_buffer();
self.set_active_buffer(buffer_id);
if let Err(e) = self.save() {
self.set_status_message(
t!("file.save_failed", error = e.to_string()).to_string(),
);
self.set_active_buffer(old_active);
return true; }
self.set_active_buffer(old_active);
if let Err(e) = self.force_close_buffer(buffer_id) {
self.set_status_message(
t!("file.cannot_close", error = e.to_string()).to_string(),
);
} else {
self.set_status_message(t!("buffer.saved_and_closed").to_string());
}
} else {
self.pending_close_buffer = Some(buffer_id);
self.start_prompt_with_initial_text(
t!("file.save_as_prompt").to_string(),
PromptType::SaveFileAs,
String::new(),
);
}
} else if first_char == discard_first {
if let Err(e) = self.force_close_buffer(buffer_id) {
self.set_status_message(t!("file.cannot_close", error = e.to_string()).to_string());
} else {
self.set_status_message(t!("buffer.changes_discarded").to_string());
}
} else {
self.set_status_message(t!("buffer.close_cancelled").to_string());
}
false
}
fn handle_stop_lsp_server(&mut self, input: &str) {
let language = input.trim();
if language.is_empty() {
return;
}
if let Some(lsp) = &mut self.lsp {
if lsp.shutdown_server(language) {
if let Some(lsp_config) = self.config.lsp.get_mut(language) {
lsp_config.auto_start = false;
if let Err(e) = self.save_config() {
tracing::warn!(
"Failed to save config after disabling LSP auto-start: {}",
e
);
} else {
let config_path = self.dir_context.config_path();
self.emit_event(
"config_changed",
serde_json::json!({
"path": config_path.to_string_lossy(),
}),
);
}
}
self.set_status_message(t!("lsp.server_stopped", language = language).to_string());
} else {
self.set_status_message(
t!("lsp.server_not_found", language = language).to_string(),
);
}
}
}
fn handle_quick_open_confirm(
&mut self,
input: &str,
selected_index: Option<usize>,
) -> PromptResult {
if input.starts_with('>') {
let query = &input[1..];
return self.handle_quick_open_command(query, selected_index);
}
if input.starts_with('#') {
let query = &input[1..];
return self.handle_quick_open_buffer(query, selected_index);
}
if input.starts_with(':') {
let line_str = &input[1..];
if let Ok(line_num) = line_str.parse::<usize>() {
if line_num > 0 {
self.goto_line_col(line_num, None);
self.set_status_message(t!("goto.jumped", line = line_num).to_string());
} else {
self.set_status_message(t!("goto.line_must_be_positive").to_string());
}
} else {
self.set_status_message(t!("error.invalid_line", input = line_str).to_string());
}
return PromptResult::Done;
}
self.handle_quick_open_file(input, selected_index)
}
fn handle_quick_open_command(
&mut self,
query: &str,
selected_index: Option<usize>,
) -> PromptResult {
let suggestions = {
let registry = self.command_registry.read().unwrap();
let selection_active = self.has_active_selection();
let active_buffer_mode = self
.buffer_metadata
.get(&self.active_buffer())
.and_then(|m| m.virtual_mode());
registry.filter(
query,
self.key_context,
&self.keybindings,
selection_active,
&self.active_custom_contexts,
active_buffer_mode,
)
};
if let Some(idx) = selected_index {
if let Some(suggestion) = suggestions.get(idx) {
if suggestion.disabled {
self.set_status_message(t!("status.command_not_available").to_string());
return PromptResult::Done;
}
let commands = self.command_registry.read().unwrap().get_all();
if let Some(cmd) = commands
.iter()
.find(|c| c.get_localized_name() == suggestion.text)
{
let action = cmd.action.clone();
let cmd_name = cmd.get_localized_name();
self.command_registry
.write()
.unwrap()
.record_usage(&cmd_name);
return PromptResult::ExecuteAction(action);
}
}
}
self.set_status_message(t!("status.no_selection").to_string());
PromptResult::Done
}
fn handle_quick_open_buffer(
&mut self,
query: &str,
selected_index: Option<usize>,
) -> PromptResult {
let suggestions = self.get_buffer_suggestions(query);
if let Some(idx) = selected_index {
if let Some(suggestion) = suggestions.get(idx) {
if let Some(value) = &suggestion.value {
if let Ok(buffer_id) = value.parse::<usize>() {
let buffer_id = crate::model::event::BufferId(buffer_id);
if self.buffers.contains_key(&buffer_id) {
self.set_active_buffer(buffer_id);
if let Some(name) = self.active_state().buffer.file_path() {
self.set_status_message(
t!("buffer.switched", name = name.display().to_string())
.to_string(),
);
}
return PromptResult::Done;
}
}
}
}
}
self.set_status_message(t!("status.no_selection").to_string());
PromptResult::Done
}
fn handle_quick_open_file(
&mut self,
input: &str,
selected_index: Option<usize>,
) -> PromptResult {
let suggestions = self.get_file_suggestions(input);
if let Some(idx) = selected_index {
if let Some(suggestion) = suggestions.get(idx) {
if let Some(path_str) = &suggestion.value {
let path = std::path::PathBuf::from(path_str);
let full_path = if path.is_absolute() {
path
} else {
self.working_dir.join(&path)
};
self.file_provider.record_access(path_str);
if let Err(e) = self.open_file(&full_path) {
self.set_status_message(
t!("file.error_opening", error = e.to_string()).to_string(),
);
} else {
self.set_status_message(
t!("buffer.opened", name = full_path.display().to_string()).to_string(),
);
}
return PromptResult::Done;
}
}
}
self.set_status_message(t!("status.no_selection").to_string());
PromptResult::Done
}
}