1 extern crate proxmox_backup
;
5 use proxmox_backup
::tools
;
6 use proxmox_backup
::cli
::*;
7 use proxmox_backup
::api_schema
::*;
8 use proxmox_backup
::api_schema
::router
::*;
10 use serde_json
::{Value}
;
13 use std
::path
::{Path, PathBuf}
;
14 use std
::fs
::OpenOptions
;
16 use std
::os
::unix
::fs
::OpenOptionsExt
;
17 use std
::os
::unix
::io
::AsRawFd
;
18 use std
::collections
::HashSet
;
20 use proxmox_backup
::pxar
;
22 fn dump_archive_from_reader
<R
: std
::io
::Read
>(
26 ) -> Result
<(), Error
> {
27 let mut decoder
= pxar
::SequentialDecoder
::new(reader
, feature_flags
, |_
| Ok(()));
29 let stdout
= std
::io
::stdout();
30 let mut out
= stdout
.lock();
32 let mut path
= PathBuf
::new();
33 decoder
.dump_entry(&mut path
, verbose
, &mut out
)?
;
41 _rpcenv
: &mut dyn RpcEnvironment
,
42 ) -> Result
<Value
, Error
> {
44 let archive
= tools
::required_string_param(¶m
, "archive")?
;
45 let verbose
= param
["verbose"].as_bool().unwrap_or(false);
47 let feature_flags
= pxar
::flags
::DEFAULT
;
50 let stdin
= std
::io
::stdin();
51 let mut reader
= stdin
.lock();
52 dump_archive_from_reader(&mut reader
, feature_flags
, verbose
)?
;
54 if verbose { println!("PXAR dump: {}
", archive); }
55 let file = std::fs::File::open(archive)?;
56 let mut reader = std::io::BufReader::new(file);
57 dump_archive_from_reader(&mut reader, feature_flags, verbose)?;
63 fn extract_archive_from_reader<R: std::io::Read>(
67 allow_existing_dirs: bool,
69 pattern: Option<Vec<pxar::MatchPattern>>
70 ) -> Result<(), Error> {
71 let mut decoder = pxar::SequentialDecoder::new(reader, feature_flags, |path| {
73 println!("{:?}
", path);
77 decoder.set_allow_existing_dirs(allow_existing_dirs);
79 let pattern = pattern.unwrap_or(Vec::new());
80 decoder.restore(Path::new(target), &pattern)?;
88 _rpcenv: &mut dyn RpcEnvironment,
89 ) -> Result<Value, Error> {
91 let archive = tools::required_string_param(¶m, "archive
")?;
92 let target = param["target
"].as_str().unwrap_or(".");
93 let verbose = param["verbose
"].as_bool().unwrap_or(false);
94 let no_xattrs = param["no
-xattrs
"].as_bool().unwrap_or(false);
95 let no_fcaps = param["no
-fcaps
"].as_bool().unwrap_or(false);
96 let no_acls = param["no
-acls
"].as_bool().unwrap_or(false);
97 let no_device_nodes = param["no
-device
-nodes
"].as_bool().unwrap_or(false);
98 let no_fifos = param["no
-fifos
"].as_bool().unwrap_or(false);
99 let no_sockets = param["no
-sockets
"].as_bool().unwrap_or(false);
100 let allow_existing_dirs = param["allow
-existing
-dirs
"].as_bool().unwrap_or(false);
101 let files_from = param["files
-from
"].as_str();
102 let empty = Vec::new();
103 let arg_pattern = param["pattern
"].as_array().unwrap_or(&empty);
105 let mut feature_flags = pxar::flags::DEFAULT;
107 feature_flags ^= pxar::flags::WITH_XATTRS;
110 feature_flags ^= pxar::flags::WITH_FCAPS;
113 feature_flags ^= pxar::flags::WITH_ACL;
116 feature_flags ^= pxar::flags::WITH_DEVICE_NODES;
119 feature_flags ^= pxar::flags::WITH_FIFOS;
122 feature_flags ^= pxar::flags::WITH_SOCKETS;
125 let mut pattern_list = Vec::new();
126 if let Some(filename) = files_from {
127 let dir = nix::dir::Dir::open("./", nix::fcntl::OFlag::O_RDONLY, nix::sys::stat::Mode::empty())?;
128 if let Some((mut pattern, _, _)) = pxar::MatchPattern::from_file(dir.as_raw_fd(), filename)? {
129 pattern_list.append(&mut pattern);
133 for s in arg_pattern {
134 let l = s.as_str().ok_or_else(|| format_err!("Invalid pattern string slice
"))?;
135 let p = pxar::MatchPattern::from_line(l.as_bytes())?
136 .ok_or_else(|| format_err!("Invalid
match pattern
in arguments
"))?;
137 pattern_list.push(p);
140 let pattern = if pattern_list.len() > 0 {
147 let stdin = std::io::stdin();
148 let mut reader = stdin.lock();
149 extract_archive_from_reader(&mut reader, target, feature_flags, allow_existing_dirs, verbose, pattern)?;
151 if verbose { println!("PXAR extract: {}", archive
); }
152 let file
= std
::fs
::File
::open(archive
)?
;
153 let mut reader
= std
::io
::BufReader
::new(file
);
154 extract_archive_from_reader(&mut reader
, target
, feature_flags
, allow_existing_dirs
, verbose
, pattern
)?
;
163 _rpcenv
: &mut dyn RpcEnvironment
,
164 ) -> Result
<Value
, Error
> {
166 let archive
= tools
::required_string_param(¶m
, "archive")?
;
167 let source
= tools
::required_string_param(¶m
, "source")?
;
168 let verbose
= param
["verbose"].as_bool().unwrap_or(false);
169 let all_file_systems
= param
["all-file-systems"].as_bool().unwrap_or(false);
170 let no_xattrs
= param
["no-xattrs"].as_bool().unwrap_or(false);
171 let no_fcaps
= param
["no-fcaps"].as_bool().unwrap_or(false);
172 let no_acls
= param
["no-acls"].as_bool().unwrap_or(false);
173 let no_device_nodes
= param
["no-device-nodes"].as_bool().unwrap_or(false);
174 let no_fifos
= param
["no-fifos"].as_bool().unwrap_or(false);
175 let no_sockets
= param
["no-sockets"].as_bool().unwrap_or(false);
177 let devices
= if all_file_systems { None }
else { Some(HashSet::new()) }
;
179 let source
= PathBuf
::from(source
);
181 let mut dir
= nix
::dir
::Dir
::open(
182 &source
, nix
::fcntl
::OFlag
::O_NOFOLLOW
, nix
::sys
::stat
::Mode
::empty())?
;
184 let file
= OpenOptions
::new()
190 let mut writer
= std
::io
::BufWriter
::with_capacity(1024*1024, file
);
191 let mut feature_flags
= pxar
::flags
::DEFAULT
;
193 feature_flags ^
= pxar
::flags
::WITH_XATTRS
;
196 feature_flags ^
= pxar
::flags
::WITH_FCAPS
;
199 feature_flags ^
= pxar
::flags
::WITH_ACL
;
202 feature_flags ^
= pxar
::flags
::WITH_DEVICE_NODES
;
205 feature_flags ^
= pxar
::flags
::WITH_FIFOS
;
208 feature_flags ^
= pxar
::flags
::WITH_SOCKETS
;
211 pxar
::Encoder
::encode(source
, &mut dir
, &mut writer
, devices
, verbose
, false, feature_flags
)?
;
220 let cmd_def
= CliCommandMap
::new()
221 .insert("create", CliCommand
::new(
224 ObjectSchema
::new("Create new .pxar archive.")
225 .required("archive", StringSchema
::new("Archive name"))
226 .required("source", StringSchema
::new("Source directory."))
227 .optional("verbose", BooleanSchema
::new("Verbose output.").default(false))
228 .optional("no-xattrs", BooleanSchema
::new("Ignore extended file attributes.").default(false))
229 .optional("no-fcaps", BooleanSchema
::new("Ignore file capabilities.").default(false))
230 .optional("no-acls", BooleanSchema
::new("Ignore access control list entries.").default(false))
231 .optional("all-file-systems", BooleanSchema
::new("Include mounted sudirs.").default(false))
232 .optional("no-device-nodes", BooleanSchema
::new("Ignore device nodes.").default(false))
233 .optional("no-fifos", BooleanSchema
::new("Ignore fifos.").default(false))
234 .optional("no-sockets", BooleanSchema
::new("Ignore sockets.").default(false))
236 .arg_param(vec
!["archive", "source"])
237 .completion_cb("archive", tools
::complete_file_name
)
238 .completion_cb("source", tools
::complete_file_name
)
241 .insert("extract", CliCommand
::new(
244 ObjectSchema
::new("Extract an archive.")
245 .required("archive", StringSchema
::new("Archive name."))
246 .optional("pattern", Arc
::new(
248 "List of paths or pattern matching files to restore",
249 Arc
::new(StringSchema
::new("Path or pattern matching files to restore.").into())
252 .optional("target", StringSchema
::new("Target directory."))
253 .optional("verbose", BooleanSchema
::new("Verbose output.").default(false))
254 .optional("no-xattrs", BooleanSchema
::new("Ignore extended file attributes.").default(false))
255 .optional("no-fcaps", BooleanSchema
::new("Ignore file capabilities.").default(false))
256 .optional("no-acls", BooleanSchema
::new("Ignore access control list entries.").default(false))
257 .optional("allow-existing-dirs", BooleanSchema
::new("Allows directories to already exist on restore.").default(false))
258 .optional("files-from", StringSchema
::new("Match pattern for files to restore."))
259 .optional("no-device-nodes", BooleanSchema
::new("Ignore device nodes.").default(false))
260 .optional("no-fifos", BooleanSchema
::new("Ignore fifos.").default(false))
261 .optional("no-sockets", BooleanSchema
::new("Ignore sockets.").default(false))
263 .arg_param(vec
!["archive", "pattern"])
264 .completion_cb("archive", tools
::complete_file_name
)
265 .completion_cb("target", tools
::complete_file_name
)
266 .completion_cb("files-from", tools
::complete_file_name
)
269 .insert("list", CliCommand
::new(
272 ObjectSchema
::new("List the contents of an archive.")
273 .required("archive", StringSchema
::new("Archive name."))
274 .optional("verbose", BooleanSchema
::new("Verbose output.").default(false))
276 .arg_param(vec
!["archive"])
277 .completion_cb("archive", tools
::complete_file_name
)
281 run_cli_command(cmd_def
.into());