mirror of
https://github.com/ouch-org/ouch.git
synced 2025-06-07 20:15:27 +00:00
Merge branch 'master' into master
This commit is contained in:
commit
f94f5fd038
@ -103,7 +103,7 @@ For compiling, check [the wiki guide](https://github.com/ouch-org/ouch/wiki/Comp
|
|||||||
|
|
||||||
## Supported formats
|
## Supported formats
|
||||||
|
|
||||||
| | .tar | .zip | .bz, .bz2 | .gz | .xz, .lz, .lzma | .zst |
|
| | .tar, .tgz | .zip | .bz, .bz2 | .gz | .xz, .lz, .lzma | .zst |
|
||||||
|:-------------:|:----:|:----:|:---------:| --- |:---------------:| --- |
|
|:-------------:|:----:|:----:|:---------:| --- |:---------------:| --- |
|
||||||
| Decompression | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ |
|
| Decompression | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ |
|
||||||
| Compression | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ |
|
| Compression | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ |
|
||||||
|
@ -29,7 +29,7 @@ const BUFFER_CAPACITY: usize = 1024 * 64;
|
|||||||
|
|
||||||
fn represents_several_files(files: &[PathBuf]) -> bool {
|
fn represents_several_files(files: &[PathBuf]) -> bool {
|
||||||
let is_non_empty_dir = |path: &PathBuf| {
|
let is_non_empty_dir = |path: &PathBuf| {
|
||||||
let is_non_empty = || !dir_is_empty(&path);
|
let is_non_empty = || !dir_is_empty(path);
|
||||||
|
|
||||||
path.is_dir().then(is_non_empty).unwrap_or_default()
|
path.is_dir().then(is_non_empty).unwrap_or_default()
|
||||||
};
|
};
|
||||||
@ -51,7 +51,7 @@ pub fn run(command: Command, flags: &oof::Flags) -> crate::Result<()> {
|
|||||||
.hint("Examples:")
|
.hint("Examples:")
|
||||||
.hint(format!(" ouch compress ... {}.tar.gz", to_utf(&output_path)))
|
.hint(format!(" ouch compress ... {}.tar.gz", to_utf(&output_path)))
|
||||||
.hint(format!(" ouch compress ... {}.zip", to_utf(&output_path)))
|
.hint(format!(" ouch compress ... {}.zip", to_utf(&output_path)))
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
return Err(Error::with_reason(reason));
|
return Err(Error::with_reason(reason));
|
||||||
}
|
}
|
||||||
@ -80,7 +80,7 @@ pub fn run(command: Command, flags: &oof::Flags) -> crate::Result<()> {
|
|||||||
.hint(format!("Try inserting '.tar' or '.zip' before '{}'.", &formats[0]))
|
.hint(format!("Try inserting '.tar' or '.zip' before '{}'.", &formats[0]))
|
||||||
.hint(format!("From: {}", output_path))
|
.hint(format!("From: {}", output_path))
|
||||||
.hint(format!(" To : {}", suggested_output_path))
|
.hint(format!(" To : {}", suggested_output_path))
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
return Err(Error::with_reason(reason));
|
return Err(Error::with_reason(reason));
|
||||||
}
|
}
|
||||||
@ -91,7 +91,7 @@ pub fn run(command: Command, flags: &oof::Flags) -> crate::Result<()> {
|
|||||||
.detail(format!("'{}' can only be used at the start of the file extension.", format))
|
.detail(format!("'{}' can only be used at the start of the file extension.", format))
|
||||||
.hint(format!("If you wish to compress multiple files, start the extension with '{}'.", format))
|
.hint(format!("If you wish to compress multiple files, start the extension with '{}'.", format))
|
||||||
.hint(format!("Otherwise, remove the last '{}' from '{}'.", format, to_utf(&output_path)))
|
.hint(format!("Otherwise, remove the last '{}' from '{}'.", format, to_utf(&output_path)))
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
return Err(Error::with_reason(reason));
|
return Err(Error::with_reason(reason));
|
||||||
}
|
}
|
||||||
@ -170,14 +170,23 @@ fn compress_files(
|
|||||||
let file_writer = BufWriter::with_capacity(BUFFER_CAPACITY, output_file);
|
let file_writer = BufWriter::with_capacity(BUFFER_CAPACITY, output_file);
|
||||||
|
|
||||||
if formats.len() == 1 {
|
if formats.len() == 1 {
|
||||||
let build_archive_from_paths = match formats[0] {
|
match formats[0] {
|
||||||
Tar => archive::tar::build_archive_from_paths,
|
Tar => {
|
||||||
Zip => archive::zip::build_archive_from_paths,
|
let mut bufwriter = archive::tar::build_archive_from_paths(&files, file_writer)?;
|
||||||
|
bufwriter.flush()?;
|
||||||
|
}
|
||||||
|
Tgz => {
|
||||||
|
// Wrap it into an gz_decoder, and pass to the tar archive builder
|
||||||
|
let gz_decoder = flate2::write::GzEncoder::new(file_writer, Default::default());
|
||||||
|
let mut bufwriter = archive::tar::build_archive_from_paths(&files, gz_decoder)?;
|
||||||
|
bufwriter.flush()?;
|
||||||
|
}
|
||||||
|
Zip => {
|
||||||
|
let mut bufwriter = archive::zip::build_archive_from_paths(&files, file_writer)?;
|
||||||
|
bufwriter.flush()?;
|
||||||
|
}
|
||||||
_ => unreachable!(),
|
_ => unreachable!(),
|
||||||
};
|
};
|
||||||
|
|
||||||
let mut bufwriter = build_archive_from_paths(&files, file_writer)?;
|
|
||||||
bufwriter.flush()?;
|
|
||||||
} else {
|
} else {
|
||||||
let mut writer: Box<dyn Write> = Box::new(file_writer);
|
let mut writer: Box<dyn Write> = Box::new(file_writer);
|
||||||
|
|
||||||
@ -213,6 +222,12 @@ fn compress_files(
|
|||||||
let mut writer = archive::tar::build_archive_from_paths(&files, writer)?;
|
let mut writer = archive::tar::build_archive_from_paths(&files, writer)?;
|
||||||
writer.flush()?;
|
writer.flush()?;
|
||||||
}
|
}
|
||||||
|
Tgz => {
|
||||||
|
// Wrap it into an gz_decoder, and pass to the tar archive builder
|
||||||
|
let gz_decoder = flate2::write::GzEncoder::new(writer, Default::default());
|
||||||
|
let mut writer = archive::tar::build_archive_from_paths(&files, gz_decoder)?;
|
||||||
|
writer.flush()?;
|
||||||
|
}
|
||||||
Zip => {
|
Zip => {
|
||||||
eprintln!("{yellow}Warning:{reset}", yellow = colors::yellow(), reset = colors::reset());
|
eprintln!("{yellow}Warning:{reset}", yellow = colors::yellow(), reset = colors::reset());
|
||||||
eprintln!("\tCompressing .zip entirely in memory.");
|
eprintln!("\tCompressing .zip entirely in memory.");
|
||||||
@ -305,6 +320,12 @@ fn decompress_file(
|
|||||||
let _ = crate::archive::tar::unpack_archive(reader, output_folder, flags)?;
|
let _ = crate::archive::tar::unpack_archive(reader, output_folder, flags)?;
|
||||||
info!("Successfully uncompressed archive in '{}'.", to_utf(output_folder));
|
info!("Successfully uncompressed archive in '{}'.", to_utf(output_folder));
|
||||||
}
|
}
|
||||||
|
Tgz => {
|
||||||
|
utils::create_dir_if_non_existent(output_folder)?;
|
||||||
|
let reader = chain_reader_decoder(&Gzip, reader)?;
|
||||||
|
let _ = crate::archive::tar::unpack_archive(reader, output_folder, flags)?;
|
||||||
|
info!("Successfully uncompressed archive in '{}'.", to_utf(output_folder));
|
||||||
|
}
|
||||||
Zip => {
|
Zip => {
|
||||||
utils::create_dir_if_non_existent(output_folder)?;
|
utils::create_dir_if_non_existent(output_folder)?;
|
||||||
|
|
||||||
|
16
src/error.rs
16
src/error.rs
@ -79,10 +79,6 @@ impl FinalError {
|
|||||||
self.hints.push(hint.to_string());
|
self.hints.push(hint.to_string());
|
||||||
self
|
self
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn into_owned(&mut self) -> Self {
|
|
||||||
std::mem::take(self)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
impl fmt::Display for Error {
|
impl fmt::Display for Error {
|
||||||
@ -93,7 +89,7 @@ impl fmt::Display for Error {
|
|||||||
.detail("Ouch could not detect the compression format")
|
.detail("Ouch could not detect the compression format")
|
||||||
.hint("Use a supported format extension, like '.zip' or '.tar.gz'")
|
.hint("Use a supported format extension, like '.zip' or '.tar.gz'")
|
||||||
.hint("Check https://github.com/vrmiguel/ouch for a full list of supported formats")
|
.hint("Check https://github.com/vrmiguel/ouch for a full list of supported formats")
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
error
|
error
|
||||||
}
|
}
|
||||||
@ -111,7 +107,7 @@ impl fmt::Display for Error {
|
|||||||
let error = FinalError::with_title("It seems you're trying to compress the root folder.")
|
let error = FinalError::with_title("It seems you're trying to compress the root folder.")
|
||||||
.detail("This is unadvisable since ouch does compressions in-memory.")
|
.detail("This is unadvisable since ouch does compressions in-memory.")
|
||||||
.hint("Use a more appropriate tool for this, such as rsync.")
|
.hint("Use a more appropriate tool for this, such as rsync.")
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
error
|
error
|
||||||
}
|
}
|
||||||
@ -123,7 +119,7 @@ impl fmt::Display for Error {
|
|||||||
.hint(" - The output argument.")
|
.hint(" - The output argument.")
|
||||||
.hint("")
|
.hint("")
|
||||||
.hint("Example: `ouch compress image.png img.zip`")
|
.hint("Example: `ouch compress image.png img.zip`")
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
error
|
error
|
||||||
}
|
}
|
||||||
@ -134,7 +130,7 @@ impl fmt::Display for Error {
|
|||||||
.hint(" - At least one input argument.")
|
.hint(" - At least one input argument.")
|
||||||
.hint("")
|
.hint("")
|
||||||
.hint("Example: `ouch decompress imgs.tar.gz`")
|
.hint("Example: `ouch decompress imgs.tar.gz`")
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
error
|
error
|
||||||
}
|
}
|
||||||
@ -144,7 +140,7 @@ impl fmt::Display for Error {
|
|||||||
.detail("It's probably our fault")
|
.detail("It's probably our fault")
|
||||||
.detail("Please help us improve by reporting the issue at:")
|
.detail("Please help us improve by reporting the issue at:")
|
||||||
.detail(format!(" {}https://github.com/vrmiguel/ouch/issues ", cyan()))
|
.detail(format!(" {}https://github.com/vrmiguel/ouch/issues ", cyan()))
|
||||||
.into_owned();
|
.clone();
|
||||||
|
|
||||||
error
|
error
|
||||||
}
|
}
|
||||||
@ -152,7 +148,7 @@ impl fmt::Display for Error {
|
|||||||
Error::IoError { reason } => FinalError::with_title(reason),
|
Error::IoError { reason } => FinalError::with_title(reason),
|
||||||
Error::CompressionTypo => FinalError::with_title("Possible typo detected")
|
Error::CompressionTypo => FinalError::with_title("Possible typo detected")
|
||||||
.hint(format!("Did you mean '{}ouch compress{}'?", magenta(), reset()))
|
.hint(format!("Did you mean '{}ouch compress{}'?", magenta(), reset()))
|
||||||
.into_owned(),
|
.clone(),
|
||||||
Error::UnknownExtensionError(_) => todo!(),
|
Error::UnknownExtensionError(_) => todo!(),
|
||||||
Error::AlreadyExists => todo!(),
|
Error::AlreadyExists => todo!(),
|
||||||
Error::InvalidZipArchive(_) => todo!(),
|
Error::InvalidZipArchive(_) => todo!(),
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
//! Our representation of all the supported compression formats.
|
//! Our representation of all the supported compression formats.
|
||||||
|
|
||||||
use std::{fmt, path::Path};
|
use std::{ffi::OsStr, fmt, path::Path};
|
||||||
|
|
||||||
use self::CompressionFormat::*;
|
use self::CompressionFormat::*;
|
||||||
|
|
||||||
@ -11,6 +11,7 @@ pub enum CompressionFormat {
|
|||||||
Bzip, // .bz
|
Bzip, // .bz
|
||||||
Lzma, // .lzma
|
Lzma, // .lzma
|
||||||
Tar, // .tar (technically not a compression extension, but will do for now)
|
Tar, // .tar (technically not a compression extension, but will do for now)
|
||||||
|
Tgz, // .tgz
|
||||||
Zstd, // .zst
|
Zstd, // .zst
|
||||||
Zip, // .zip
|
Zip, // .zip
|
||||||
}
|
}
|
||||||
@ -26,6 +27,7 @@ impl fmt::Display for CompressionFormat {
|
|||||||
Zstd => ".zst",
|
Zstd => ".zst",
|
||||||
Lzma => ".lz",
|
Lzma => ".lz",
|
||||||
Tar => ".tar",
|
Tar => ".tar",
|
||||||
|
Tgz => ".tgz",
|
||||||
Zip => ".zip",
|
Zip => ".zip",
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
@ -44,18 +46,17 @@ pub fn separate_known_extensions_from_name(mut path: &Path) -> (&Path, Vec<Compr
|
|||||||
let mut extensions = vec![];
|
let mut extensions = vec![];
|
||||||
|
|
||||||
// While there is known extensions at the tail, grab them
|
// While there is known extensions at the tail, grab them
|
||||||
while let Some(extension) = path.extension() {
|
while let Some(extension) = path.extension().and_then(OsStr::to_str) {
|
||||||
let extension = match () {
|
extensions.push(match extension {
|
||||||
_ if extension == "tar" => Tar,
|
"tar" => Tar,
|
||||||
_ if extension == "zip" => Zip,
|
"tgz" => Tgz,
|
||||||
_ if extension == "bz" || extension == "bz2" => Bzip,
|
"zip" => Zip,
|
||||||
_ if extension == "gz" => Gzip,
|
"bz" | "bz2" => Bzip,
|
||||||
_ if extension == "xz" || extension == "lzma" || extension == "lz" => Lzma,
|
"gz" => Gzip,
|
||||||
_ if extension == "zst" => Zstd,
|
"xz" | "lzma" | "lz" => Lzma,
|
||||||
|
"zst" => Zstd,
|
||||||
_ => break,
|
_ => break,
|
||||||
};
|
});
|
||||||
|
|
||||||
extensions.push(extension);
|
|
||||||
|
|
||||||
// Update for the next iteration
|
// Update for the next iteration
|
||||||
path = if let Some(stem) = path.file_stem() { Path::new(stem) } else { Path::new("") };
|
path = if let Some(stem) = path.file_stem() { Path::new(stem) } else { Path::new("") };
|
||||||
|
@ -24,7 +24,7 @@ use lazy_static::lazy_static;
|
|||||||
/// The status code ouch has when an error is encountered
|
/// The status code ouch has when an error is encountered
|
||||||
pub const EXIT_FAILURE: i32 = libc::EXIT_FAILURE;
|
pub const EXIT_FAILURE: i32 = libc::EXIT_FAILURE;
|
||||||
|
|
||||||
const VERSION: &'static str = env!("CARGO_PKG_VERSION");
|
const VERSION: &str = env!("CARGO_PKG_VERSION");
|
||||||
|
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref NO_COLOR_IS_SET: bool = {
|
static ref NO_COLOR_IS_SET: bool = {
|
||||||
|
@ -27,12 +27,13 @@ fn sanity_check_through_mime() {
|
|||||||
let bytes = generate_random_file_content(&mut SmallRng::from_entropy());
|
let bytes = generate_random_file_content(&mut SmallRng::from_entropy());
|
||||||
test_file.write_all(&bytes).expect("to successfully write bytes to the file");
|
test_file.write_all(&bytes).expect("to successfully write bytes to the file");
|
||||||
|
|
||||||
let formats = ["tar", "zip", "tar.gz", "tar.bz", "tar.bz2", "tar.lzma", "tar.xz", "tar.zst"];
|
let formats = ["tar", "zip", "tar.gz", "tgz", "tar.bz", "tar.bz2", "tar.lzma", "tar.xz", "tar.zst"];
|
||||||
|
|
||||||
let expected_mimes = [
|
let expected_mimes = [
|
||||||
"application/x-tar",
|
"application/x-tar",
|
||||||
"application/zip",
|
"application/zip",
|
||||||
"application/gzip",
|
"application/gzip",
|
||||||
|
"application/gzip",
|
||||||
"application/x-bzip2",
|
"application/x-bzip2",
|
||||||
"application/x-bzip2",
|
"application/x-bzip2",
|
||||||
"application/x-xz",
|
"application/x-xz",
|
||||||
@ -67,6 +68,7 @@ fn test_each_format() {
|
|||||||
test_compressing_and_decompressing_archive("tar.lz");
|
test_compressing_and_decompressing_archive("tar.lz");
|
||||||
test_compressing_and_decompressing_archive("tar.lzma");
|
test_compressing_and_decompressing_archive("tar.lzma");
|
||||||
test_compressing_and_decompressing_archive("tar.zst");
|
test_compressing_and_decompressing_archive("tar.zst");
|
||||||
|
test_compressing_and_decompressing_archive("tgz");
|
||||||
test_compressing_and_decompressing_archive("zip");
|
test_compressing_and_decompressing_archive("zip");
|
||||||
test_compressing_and_decompressing_archive("zip.gz");
|
test_compressing_and_decompressing_archive("zip.gz");
|
||||||
test_compressing_and_decompressing_archive("zip.bz");
|
test_compressing_and_decompressing_archive("zip.bz");
|
||||||
|
Loading…
x
Reference in New Issue
Block a user