mirror of
https://github.com/nushell/nushell
synced 2025-01-04 17:28:59 +00:00
208ffdc1da
# Description From nushell 0.8 philosophy: https://github.com/nushell/nushell.github.io/blob/main/contributor-book/philosophy_0_80.md#core-categories > The following categories should be moved to plugins: Uncommon format support So this pr is trying to move following commands to plugin: - [X] from eml - [x] from ics - [x] from ini - [x] from vcf And we can have a new plugin handles for these formatting, currently it's implemented here: https://github.com/WindSoilder/nu_plugin_format The command usage should be the same to original command. If it's ok, the plugin can support more formats like [parquet](https://github.com/fdncred/nu_plugin_from_parquet), or [EDN format](https://github.com/nushell/nushell/issues/6415), or something else. Just create a draft pr to show what's the blueprint looks like, and is it a good direction to move forward? # User-Facing Changes _(List of all changes that impact the user experience here. This helps us keep track of breaking changes.)_ # Tests + Formatting Don't forget to add tests that cover your changes. Make sure you've run and fixed any issues with these commands: - `cargo fmt --all -- --check` to check standard code formatting (`cargo fmt --all` applies these changes) - `cargo clippy --workspace -- -D warnings -D clippy::unwrap_used -A clippy::needless_collect` to check that you're using the standard code style - `cargo test --workspace` to check that all tests pass # After Submitting If your PR had any user-facing changes, update [the documentation](https://github.com/nushell/nushell.github.io) after the PR is merged, if necessary. This will help us keep the docs up to date.
267 lines
6.5 KiB
Rust
267 lines
6.5 KiB
Rust
use std::fmt::Display;
|
|
use std::io::Read;
|
|
use std::ops::Div;
|
|
use std::path::{Path, PathBuf};
|
|
|
|
pub struct AbsoluteFile {
|
|
inner: PathBuf,
|
|
}
|
|
|
|
impl AbsoluteFile {
|
|
pub fn new(path: impl AsRef<Path>) -> AbsoluteFile {
|
|
let path = path.as_ref();
|
|
|
|
if !path.is_absolute() {
|
|
panic!(
|
|
"AbsoluteFile::new must take an absolute path :: {}",
|
|
path.display()
|
|
)
|
|
} else if path.is_dir() {
|
|
// At the moment, this is not an invariant, but rather a way to catch bugs
|
|
// in tests.
|
|
panic!(
|
|
"AbsoluteFile::new must not take a directory :: {}",
|
|
path.display()
|
|
)
|
|
} else {
|
|
AbsoluteFile {
|
|
inner: path.to_path_buf(),
|
|
}
|
|
}
|
|
}
|
|
|
|
pub fn dir(&self) -> AbsolutePath {
|
|
AbsolutePath::new(if let Some(parent) = self.inner.parent() {
|
|
parent
|
|
} else {
|
|
unreachable!("Internal error: could not get parent in dir")
|
|
})
|
|
}
|
|
}
|
|
|
|
impl From<AbsoluteFile> for PathBuf {
|
|
fn from(file: AbsoluteFile) -> Self {
|
|
file.inner
|
|
}
|
|
}
|
|
|
|
pub struct AbsolutePath {
|
|
pub inner: PathBuf,
|
|
}
|
|
|
|
impl AbsolutePath {
|
|
pub fn new(path: impl AsRef<Path>) -> AbsolutePath {
|
|
let path = path.as_ref();
|
|
|
|
if path.is_absolute() {
|
|
AbsolutePath {
|
|
inner: path.to_path_buf(),
|
|
}
|
|
} else {
|
|
panic!("AbsolutePath::new must take an absolute path")
|
|
}
|
|
}
|
|
}
|
|
|
|
impl Div<&str> for &AbsolutePath {
|
|
type Output = AbsolutePath;
|
|
|
|
fn div(self, rhs: &str) -> Self::Output {
|
|
let parts = rhs.split('/');
|
|
let mut result = self.inner.clone();
|
|
|
|
for part in parts {
|
|
result = result.join(part);
|
|
}
|
|
|
|
AbsolutePath::new(result)
|
|
}
|
|
}
|
|
|
|
impl AsRef<Path> for AbsolutePath {
|
|
fn as_ref(&self) -> &Path {
|
|
self.inner.as_path()
|
|
}
|
|
}
|
|
|
|
pub struct RelativePath {
|
|
inner: PathBuf,
|
|
}
|
|
|
|
impl RelativePath {
|
|
pub fn new(path: impl Into<PathBuf>) -> RelativePath {
|
|
let path = path.into();
|
|
|
|
if path.is_relative() {
|
|
RelativePath { inner: path }
|
|
} else {
|
|
panic!("RelativePath::new must take a relative path")
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<T: AsRef<str>> Div<T> for &RelativePath {
|
|
type Output = RelativePath;
|
|
|
|
fn div(self, rhs: T) -> Self::Output {
|
|
let parts = rhs.as_ref().split('/');
|
|
let mut result = self.inner.clone();
|
|
|
|
for part in parts {
|
|
result = result.join(part);
|
|
}
|
|
|
|
RelativePath::new(result)
|
|
}
|
|
}
|
|
|
|
impl Display for AbsoluteFile {
|
|
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
|
write!(f, "{}", self.inner.display())
|
|
}
|
|
}
|
|
|
|
impl Display for AbsolutePath {
|
|
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
|
write!(f, "{}", self.inner.display())
|
|
}
|
|
}
|
|
|
|
impl Display for RelativePath {
|
|
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
|
write!(f, "{}", self.inner.display())
|
|
}
|
|
}
|
|
|
|
pub enum Stub<'a> {
|
|
FileWithContent(&'a str, &'a str),
|
|
FileWithContentToBeTrimmed(&'a str, &'a str),
|
|
EmptyFile(&'a str),
|
|
FileWithPermission(&'a str, bool),
|
|
}
|
|
|
|
pub fn file_contents(full_path: impl AsRef<Path>) -> String {
|
|
let mut file = std::fs::File::open(full_path.as_ref()).expect("can not open file");
|
|
let mut contents = String::new();
|
|
file.read_to_string(&mut contents)
|
|
.expect("can not read file");
|
|
contents
|
|
}
|
|
|
|
pub fn file_contents_binary(full_path: impl AsRef<Path>) -> Vec<u8> {
|
|
let mut file = std::fs::File::open(full_path.as_ref()).expect("can not open file");
|
|
let mut contents = Vec::new();
|
|
file.read_to_end(&mut contents).expect("can not read file");
|
|
contents
|
|
}
|
|
|
|
pub fn line_ending() -> String {
|
|
#[cfg(windows)]
|
|
{
|
|
String::from("\r\n")
|
|
}
|
|
|
|
#[cfg(not(windows))]
|
|
{
|
|
String::from("\n")
|
|
}
|
|
}
|
|
|
|
pub fn delete_file_at(full_path: impl AsRef<Path>) {
|
|
let full_path = full_path.as_ref();
|
|
|
|
if full_path.exists() {
|
|
std::fs::remove_file(full_path).expect("can not delete file");
|
|
}
|
|
}
|
|
|
|
pub fn create_file_at(full_path: impl AsRef<Path>) -> Result<(), std::io::Error> {
|
|
let full_path = full_path.as_ref();
|
|
|
|
if full_path.parent().is_some() {
|
|
panic!("path exists");
|
|
}
|
|
|
|
std::fs::write(full_path, b"fake data")
|
|
}
|
|
|
|
pub fn copy_file_to(source: &str, destination: &str) {
|
|
std::fs::copy(source, destination).expect("can not copy file");
|
|
}
|
|
|
|
pub fn files_exist_at(files: Vec<impl AsRef<Path>>, path: impl AsRef<Path>) -> bool {
|
|
files.iter().all(|f| {
|
|
let mut loc = PathBuf::from(path.as_ref());
|
|
loc.push(f);
|
|
loc.exists()
|
|
})
|
|
}
|
|
|
|
pub fn delete_directory_at(full_path: &str) {
|
|
std::fs::remove_dir_all(PathBuf::from(full_path)).expect("can not remove directory");
|
|
}
|
|
|
|
pub fn executable_path() -> PathBuf {
|
|
let mut path = binaries();
|
|
path.push("nu");
|
|
path
|
|
}
|
|
|
|
pub fn installed_nu_path() -> PathBuf {
|
|
let path = std::env::var_os(crate::NATIVE_PATH_ENV_VAR);
|
|
which::which_in("nu", path, ".").unwrap_or_else(|_| executable_path())
|
|
}
|
|
|
|
pub fn root() -> PathBuf {
|
|
let manifest_dir = if let Ok(manifest_dir) = std::env::var("CARGO_MANIFEST_DIR") {
|
|
PathBuf::from(manifest_dir)
|
|
} else {
|
|
PathBuf::from(env!("CARGO_MANIFEST_DIR"))
|
|
};
|
|
|
|
let test_path = manifest_dir.join("Cargo.lock");
|
|
if test_path.exists() {
|
|
manifest_dir
|
|
} else {
|
|
manifest_dir
|
|
.parent()
|
|
.expect("Couldn't find the debug binaries directory")
|
|
.parent()
|
|
.expect("Couldn't find the debug binaries directory")
|
|
.to_path_buf()
|
|
}
|
|
}
|
|
|
|
pub fn binaries() -> PathBuf {
|
|
let mut build_type = "debug".to_string();
|
|
if !cfg!(debug_assertions) {
|
|
build_type = "release".to_string()
|
|
}
|
|
if let Ok(target) = std::env::var("NUSHELL_CARGO_TARGET") {
|
|
build_type = target;
|
|
}
|
|
|
|
std::env::var("CARGO_TARGET_DIR")
|
|
.ok()
|
|
.map(|target_dir| PathBuf::from(target_dir).join(&build_type))
|
|
.unwrap_or_else(|| root().join(format!("target/{}", &build_type)))
|
|
}
|
|
|
|
pub fn fixtures() -> PathBuf {
|
|
root().join("tests").join("fixtures")
|
|
}
|
|
|
|
pub fn assets() -> PathBuf {
|
|
root().join("tests/assets")
|
|
}
|
|
|
|
pub fn in_directory(str: impl AsRef<Path>) -> String {
|
|
let path = str.as_ref();
|
|
let path = if path.is_relative() {
|
|
root().join(path)
|
|
} else {
|
|
path.to_path_buf()
|
|
};
|
|
|
|
path.display().to_string()
|
|
}
|