use std::env::current_dir; use std::path::{Path, PathBuf}; use nu_engine::CallExt; use nu_protocol::ast::Call; use nu_protocol::engine::{Command, EvaluationContext}; use nu_protocol::{ShellError, Signature, SyntaxShape, Value}; pub struct Mv; impl Command for Mv { fn name(&self) -> &str { "mv" } fn usage(&self) -> &str { "Move files or directories." } fn signature(&self) -> nu_protocol::Signature { Signature::build("mv") .required( "source", SyntaxShape::GlobPattern, "the location to move files/directories from", ) .required( "destination", SyntaxShape::Filepath, "the location to move files/directories to", ) } fn run( &self, context: &EvaluationContext, call: &Call, _input: Value, ) -> Result { // TODO: handle invalid directory or insufficient permissions let source: String = call.req(context, 0)?; let destination: String = call.req(context, 1)?; let path: PathBuf = current_dir().unwrap(); let source = path.join(source.as_str()); let destination = path.join(destination.as_str()); let mut sources = glob::glob(&source.to_string_lossy()).map_or_else(|_| Vec::new(), Iterator::collect); if sources.is_empty() { return Err(ShellError::FileNotFound( call.positional.first().unwrap().span, )); } if (destination.exists() && !destination.is_dir() && sources.len() > 1) || (!destination.exists() && sources.len() > 1) { return Err(ShellError::MoveNotPossible { source_message: "Can't move many files".to_string(), source_span: call.positional[0].span, destination_message: "into single file".to_string(), destination_span: call.positional[1].span, }); } let some_if_source_is_destination = sources .iter() .find(|f| matches!(f, Ok(f) if destination.starts_with(f))); if destination.exists() && destination.is_dir() && sources.len() == 1 { if let Some(Ok(_filename)) = some_if_source_is_destination { return Err(ShellError::MoveNotPossible { source_message: "Can't move directory".to_string(), source_span: call.positional[0].span, destination_message: "into itself".to_string(), destination_span: call.positional[1].span, }); } } if let Some(Ok(_filename)) = some_if_source_is_destination { sources = sources .into_iter() .filter(|f| matches!(f, Ok(f) if !destination.starts_with(f))) .collect(); } for entry in sources.into_iter().flatten() { move_file(call, &entry, &destination)? } Ok(Value::Nothing { span: call.head }) } } fn move_file(call: &Call, from: &Path, to: &Path) -> Result<(), ShellError> { if to.exists() && from.is_dir() && to.is_file() { return Err(ShellError::MoveNotPossible { source_message: "Can't move a directory".to_string(), source_span: call.positional[0].span, destination_message: "to a file".to_string(), destination_span: call.positional[1].span, }); } let destination_dir_exists = if to.is_dir() { true } else { to.parent().map(Path::exists).unwrap_or(true) }; if !destination_dir_exists { return Err(ShellError::DirectoryNotFound(call.positional[1].span)); } let mut to = to.to_path_buf(); if to.is_dir() { let from_file_name = match from.file_name() { Some(name) => name, None => return Err(ShellError::DirectoryNotFound(call.positional[1].span)), }; to.push(from_file_name); } move_item(call, from, &to) } fn move_item(call: &Call, from: &Path, to: &Path) -> Result<(), ShellError> { // We first try a rename, which is a quick operation. If that doesn't work, we'll try a copy // and remove the old file/folder. This is necessary if we're moving across filesystems or devices. std::fs::rename(&from, &to).map_err(|_| ShellError::MoveNotPossible { source_message: "failed to move".to_string(), source_span: call.positional[0].span, destination_message: "into".to_string(), destination_span: call.positional[1].span, }) }