use crate::completions::{Completer, CompletionOptions}; use nu_protocol::{ engine::{EngineState, StateWorkingSet}, levenshtein_distance, Span, }; use reedline::Suggestion; use std::path::{is_separator, Path}; use std::sync::Arc; const SEP: char = std::path::MAIN_SEPARATOR; #[derive(Clone)] pub struct FileCompletion { engine_state: Arc, } impl FileCompletion { pub fn new(engine_state: Arc) -> Self { Self { engine_state } } } impl Completer for FileCompletion { fn fetch( &mut self, _: &StateWorkingSet, prefix: Vec, span: Span, offset: usize, _: usize, ) -> (Vec, CompletionOptions) { let cwd = if let Some(d) = self.engine_state.env_vars.get("PWD") { match d.as_string() { Ok(s) => s, Err(_) => "".to_string(), } } else { "".to_string() }; let prefix = String::from_utf8_lossy(&prefix).to_string(); let output: Vec<_> = file_path_completion(span, &prefix, &cwd) .into_iter() .map(move |x| Suggestion { value: x.1, description: None, extra: None, span: reedline::Span { start: x.0.start - offset, end: x.0.end - offset, }, }) .collect(); // Options let options = CompletionOptions::default(); (output, options) } // Sort results prioritizing the non hidden folders fn sort( &self, items: Vec, prefix: Vec, _: CompletionOptions, // Ignore the given options, once it's a custom sorting ) -> Vec { let prefix_str = String::from_utf8_lossy(&prefix).to_string(); // Sort items let mut sorted_items = items; sorted_items.sort_by(|a, b| { let a_distance = levenshtein_distance(&prefix_str, &a.value); let b_distance = levenshtein_distance(&prefix_str, &b.value); a_distance.cmp(&b_distance) }); // Separate the results between hidden and non hidden let mut hidden: Vec = vec![]; let mut non_hidden: Vec = vec![]; for item in sorted_items.into_iter() { let item_path = Path::new(&item.value); if let Some(value) = item_path.file_name() { if let Some(value) = value.to_str() { if value.starts_with('.') { hidden.push(item); } else { non_hidden.push(item); } } } } // Append the hidden folders to the non hidden vec to avoid creating a new vec non_hidden.append(&mut hidden); non_hidden } // Replace base filter with no filter once all the results are already based in the current path fn filter(&self, _: Vec, items: Vec, _: CompletionOptions) -> Vec { items } } pub fn file_path_completion( span: nu_protocol::Span, partial: &str, cwd: &str, ) -> Vec<(nu_protocol::Span, String)> { let partial = partial.replace('\'', ""); let (base_dir_name, partial) = { // If partial is only a word we want to search in the current dir let (base, rest) = partial.rsplit_once(is_separator).unwrap_or((".", &partial)); // On windows, this standardizes paths to use \ let mut base = base.replace(is_separator, &SEP.to_string()); // rsplit_once removes the separator base.push(SEP); (base, rest) }; let base_dir = nu_path::expand_path_with(&base_dir_name, cwd); // This check is here as base_dir.read_dir() with base_dir == "" will open the current dir // which we don't want in this case (if we did, base_dir would already be ".") if base_dir == Path::new("") { return Vec::new(); } if let Ok(result) = base_dir.read_dir() { return result .filter_map(|entry| { entry.ok().and_then(|entry| { let mut file_name = entry.file_name().to_string_lossy().into_owned(); if matches(partial, &file_name) { let mut path = format!("{}{}", base_dir_name, file_name); if entry.path().is_dir() { path.push(SEP); file_name.push(SEP); } if path.contains(' ') { path = format!("\'{}\'", path); } Some((span, path)) } else { None } }) }) .collect(); } Vec::new() } pub fn matches(partial: &str, from: &str) -> bool { from.to_ascii_lowercase() .starts_with(&partial.to_ascii_lowercase()) }