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
80
81
82
|
use std::fs;
use std::path::Path;
use std::sync::mpsc;
use std::thread;
use crate::context::JoshutoContext;
use crate::io::{IOWorkerThread, Options};
use super::local_state::LocalState;
use super::name_resolution::rename_filename_conflict;
pub fn recursive_copy(dest: &Path, src: &Path, options: &Options) -> std::io::Result<u64> {
let mut dest_buf = dest.to_path_buf();
if let Some(s) = src.file_name() {
dest_buf.push(s);
}
rename_filename_conflict(&mut dest_buf);
let file_type = fs::symlink_metadata(src)?.file_type();
if file_type.is_dir() {
fs::create_dir(dest_buf.as_path())?;
let mut total = 0;
for entry in fs::read_dir(src)? {
let entry = entry?;
let entry_path = entry.path();
total += recursive_copy(dest_buf.as_path(), entry_path.as_path(), options)?;
}
Ok(total)
} else if file_type.is_file() {
fs::copy(src, dest_buf)
} else if file_type.is_symlink() {
let link_path = fs::read_link(src)?;
std::os::unix::fs::symlink(link_path, dest_buf)?;
Ok(0)
} else {
Ok(0)
}
}
pub fn paste_copy(
context: &mut JoshutoContext,
options: Options,
) -> std::io::Result<IOWorkerThread> {
let paths = LocalState::take_selected_files()
.ok_or_else(|| std::io::Error::new(std::io::ErrorKind::Other, "no files selected"))?;
if paths.is_empty() {
return Err(std::io::Error::new(
std::io::ErrorKind::Other,
"no files selected",
));
}
let tab_dest = context.curr_tab_index;
let thread_dest = context.tabs[tab_dest].curr_path.clone();
let dest = thread_dest.clone();
let src = paths[0].parent().unwrap().to_path_buf();
let (tx_start, rx_start) = mpsc::channel();
let (tx, rx) = mpsc::channel();
let handle: thread::JoinHandle<std::io::Result<u64>> =
thread::spawn(move || match rx_start.recv() {
Ok(_) => {
let mut total = 0;
for path in paths {
total += recursive_copy(thread_dest.as_path(), path.as_path(), &options)?;
tx.send(total);
}
Ok(total)
}
Err(_) => Ok(0),
});
let thread = IOWorkerThread {
src,
dest,
handle,
tx_start,
rx,
};
Ok(thread)
}
|
