1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
use crate::file_utils::make_relative_path;
use std::fs::File;
use std::io;
use std::io::{Read, Write};
use std::path::PathBuf;
use zip::result::ZipResult;
use zip::write::FileOptions;
use zip::{write, CompressionMethod, ZipWriter};
pub fn zip_create_from_directory(archive_file: &PathBuf, directory: &PathBuf) -> ZipResult<()> {
let options = write::FileOptions::default().compression_method(CompressionMethod::Stored);
zip_create_from_directory_with_options(archive_file, directory, options)
}
pub fn zip_create_from_directory_with_options(
archive_file: &PathBuf,
directory: &PathBuf,
options: FileOptions,
) -> ZipResult<()> {
let file = File::create(archive_file)?;
let mut zip_writer = zip::ZipWriter::new(file);
zip_writer.create_from_directory_with_options(directory, options)
}
pub trait ZipWriterExtensions {
fn create_from_directory(&mut self, directory: &PathBuf) -> ZipResult<()>;
fn create_from_directory_with_options(
&mut self,
directory: &PathBuf,
options: FileOptions,
) -> ZipResult<()>;
}
impl<W: Write + io::Seek> ZipWriterExtensions for ZipWriter<W> {
fn create_from_directory(&mut self, directory: &PathBuf) -> ZipResult<()> {
let options = write::FileOptions::default().compression_method(CompressionMethod::Stored);
self.create_from_directory_with_options(directory, options)
}
fn create_from_directory_with_options(
&mut self,
directory: &PathBuf,
options: FileOptions,
) -> ZipResult<()> {
let mut paths_queue: Vec<PathBuf> = vec![];
paths_queue.push(directory.clone());
let mut buffer = Vec::new();
while let Some(next) = paths_queue.pop() {
let directory_entry_iterator = std::fs::read_dir(next)?;
for entry in directory_entry_iterator {
let entry_path = entry?.path();
let entry_metadata = std::fs::metadata(entry_path.clone())?;
if entry_metadata.is_file() {
let mut f = File::open(&entry_path)?;
f.read_to_end(&mut buffer)?;
let relative_path = make_relative_path(&directory, &entry_path);
self.start_file_from_path(&relative_path, options)?;
self.write_all(buffer.as_ref())?;
buffer.clear();
} else if entry_metadata.is_dir() {
let relative_path = make_relative_path(&directory, &entry_path);
self.add_directory_from_path(&relative_path, options)?;
paths_queue.push(entry_path.clone());
}
}
}
self.finish()?;
Ok(())
}
}