bestool-psql 1.6.2

use std::ops::ControlFlow;

use rustyline::history::History;
use tokio::fs;
use tracing::debug;

use super::state::ReplContext;

pub async fn get_snippet(ctx: &mut ReplContext<'_>, name: &str) -> Option<String> {
	let file_path = {
		let state = ctx.repl_state.lock().unwrap();
		state.snippets.path(name).ok()
	};

	if let Some(file_path) = file_path {
		match fs::read_to_string(&file_path).await {
			Ok(content) => Some(content.trim().into()),
			Err(e) => {
				tracing::error!("Failed to read file '{file_path:?}': {e}");
				None
			}
		}
	} else {
		let state = ctx.repl_state.lock().unwrap();
		if let Some(lookup_provider) = &state.config.snippet_lookup {
			lookup_provider.lookup(name)
		} else {
			None
		}
	}
}

pub async fn handle_run_snippet(
	ctx: &mut ReplContext<'_>,
	name: String,
	vars: Vec<(String, String)>,
) -> ControlFlow<()> {
	match get_snippet(ctx, &name).await {
		Some(content) => {
			use crate::input::handle_input;

			let saved_vars: Vec<(String, Option<String>)> = {
				let mut state = ctx.repl_state.lock().unwrap();
				state.from_snippet_or_include = true;
				let saved: Vec<(String, Option<String>)> = vars
					.iter()
					.map(|(name, _)| (name.clone(), state.vars.get(name).cloned()))
					.collect();

				for (name, value) in &vars {
					state.vars.insert(name.clone(), value.clone());
				}
				saved
			};

			let (remaining, mut actions) =
				handle_input("", &content, &ctx.repl_state.lock().unwrap());

			if !remaining.trim().is_empty() {
				let completed = format!("{};", remaining);
				let (_, new_actions) =
					handle_input("", &completed, &ctx.repl_state.lock().unwrap());
				actions.extend(new_actions);
			}

			let mut result = ControlFlow::Continue(());
			for action in actions {
				// Boxed because a snippet may itself run another snippet/include,
				// making dispatch indirectly recursive.
				result = Box::pin(action.dispatch(ctx, "")).await;
				if result.is_break() {
					break;
				}
			}

			{
				let mut state = ctx.repl_state.lock().unwrap();
				state.from_snippet_or_include = false;
				for (name, original_value) in saved_vars {
					match original_value {
						Some(value) => state.vars.insert(name, value),
						None => state.vars.remove(&name),
					};
				}
			}

			result
		}
		None => {
			tracing::error!("Failed to find snippet '{name}'");
			ControlFlow::Continue(())
		}
	}
}

pub async fn handle_snippet_save(
	ctx: &mut ReplContext<'_>,
	name: String,
	line: &str,
) -> ControlFlow<()> {
	let history = ctx.rl.history();

	if history.is_empty() {
		eprintln!("No command history available");
	} else {
		let last_idx = history.len() - 1;
		let content = match history.get(last_idx, rustyline::history::SearchDirection::Forward) {
			Ok(Some(result)) => result.entry.to_string(),
			_ => {
				eprintln!("Failed to retrieve last command from history");
				String::new()
			}
		};

		if !content.is_empty() {
			let snippets = ctx.repl_state.lock().unwrap().snippets.clone();
			match snippets.save(&name, &content).await {
				Ok(path) => {
					println!("Snippet saved to {}", path.display());
				}
				Err(e) => eprintln!("Failed to save snippet '{name}': {e}"),
			}
		}
	}

	let history = ctx.rl.history_mut();
	if let Err(e) = history.add_entry(line.into()) {
		debug!("failed to add SnippetSave to history: {e}");
	}

	ControlFlow::Continue(())
}

pub async fn handle_snippet_list(ctx: &ReplContext<'_>) -> ControlFlow<()> {
	use comfy_table::{Row, Table};

	let state = ctx.repl_state.lock().unwrap();

	let mut all_snippets = std::collections::BTreeMap::new();

	// Add snippets from filesystem (highest priority)
	for dir in &state.snippets.dirs {
		if let Ok(entries) = std::fs::read_dir(dir) {
			for entry in entries.flatten() {
				if let Ok(file_name) = entry.file_name().into_string()
					&& file_name.ends_with(".sql")
				{
					let snippet_name = &file_name[..file_name.len() - 4];
					all_snippets
						.entry(snippet_name.to_string())
						.or_insert(("local".to_string(), None));
				}
			}
		}
	}

	// Add snippets from lookup provider (if not already present)
	if let Some(lookup_provider) = &state.config.snippet_lookup {
		for name in lookup_provider.list_names() {
			all_snippets.entry(name.clone()).or_insert_with(|| {
				let description = lookup_provider.get_description(&name);
				("remote".to_string(), description)
			});
		}
	}

	if all_snippets.is_empty() {
		println!("No snippets available");
	} else {
		let mut table = Table::new();
		table.load_preset(comfy_table::presets::NOTHING);
		table.set_header(Row::from(vec!["Name", "Source", "Description"]));

		for (name, (source, description)) in all_snippets {
			let desc = description.unwrap_or_else(String::new);
			table.add_row(Row::from(vec![name, source, desc]));
		}

		println!("{table}");
	}

	ControlFlow::Continue(())
}

pub async fn handle_snippet_edit(ctx: &mut ReplContext<'_>, name: String) -> ControlFlow<()> {
	if let Some(content) = get_snippet(ctx, &name).await {
		let mut state = ctx.repl_state.lock().unwrap();
		state.initial_content = Some(content);
		return ControlFlow::Continue(());
	}

	println!("Snippet '{name}' not found");
	ControlFlow::Continue(())
}

pub async fn handle_snippet_refetch(ctx: &ReplContext<'_>) -> ControlFlow<()> {
	let state = ctx.repl_state.lock().unwrap();
	if let Some(lookup_provider) = &state.config.snippet_lookup {
		lookup_provider.refresh();
		println!("Snippet cache refreshed");
	} else {
		println!("No remote snippet provider configured");
	}
	ControlFlow::Continue(())
}