esed 1.1.32

Easy sed
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

mod cli;
mod error;
mod input;

pub(crate) mod replacer;
mod unescape;

use clap::Parser;
use memmap2::MmapMut;
use std::{
	fs,
	io::{Write, stdout},
	ops::DerefMut,
	path::PathBuf,
	process,
};

pub(crate) use self::error::{Error, FailedJobs, Result};
pub(crate) use self::input::Source;
use self::input::{make_mmap, make_mmap_stdin};
use self::replacer::Replacer;

fn main() {
	if let Err(e) = try_main() {
		eprintln!("error: {e}");
		process::exit(1);
	}
}

fn try_main() -> Result<()> {
	let options = cli::Options::parse();

	let replacer = Replacer::new(
		options.find,
		options.replace_with,
		options.literal_mode,
		options.no_multiline,
		options.dot_match_newline,
		options.case_insensitive,
		options.word,
		options.replacements,
	)?;

	let sources = if !options.files.is_empty() { Source::from_paths(options.files) } else { Source::from_stdin() };

	let mut mmaps = Vec::new();
	for source in sources.iter() {
		let mmap = match source {
			Source::File(path) => {
				if path.exists() {
					unsafe { make_mmap(path)? }
				} else {
					return Err(Error::InvalidPath(path.to_owned()));
				}
			}
			Source::Stdin => make_mmap_stdin()?,
		};

		mmaps.push(mmap);
	}

	let needs_separator = sources.len() > 1;

	let replaced: Vec<_> = {
		use rayon::prelude::*;
		mmaps.par_iter().map(|mmap| replacer.replace(mmap)).collect()
	};

	if !options.in_place || sources.first() == Some(&Source::Stdin) {
		let mut handle = stdout().lock();

		for (source, replaced) in sources.iter().zip(replaced) {
			if needs_separator {
				writeln!(handle, "----- {} -----", source.display())?;
			}
			handle.write_all(&replaced)?;
		}
	} else {
		// Windows requires closing mmap before writing:
		// > The requested operation cannot be performed on a file with a user-mapped section open
		#[cfg(target_family = "windows")]
		let replaced: Vec<Vec<u8>> = replaced.into_iter().map(|r| r.to_vec()).collect();
		#[cfg(target_family = "windows")]
		drop(mmaps);

		let mut failed_jobs = Vec::new();
		for (source, replaced) in sources.iter().zip(replaced) {
			match source {
				Source::File(path) => {
					if let Err(e) = write_with_temp(path, &replaced) {
						failed_jobs.push((path.to_owned(), e));
					}
				}
				_ => unreachable!("stdin should go previous branch"),
			}
		}
		if !failed_jobs.is_empty() {
			return Err(Error::FailedJobs(FailedJobs(failed_jobs)));
		}
	}

	Ok(())
}

fn write_with_temp(path: &PathBuf, data: &[u8]) -> Result<()> {
	let path = fs::canonicalize(path)?;

	let temp = tempfile::NamedTempFile::new_in(path.parent().ok_or_else(|| Error::InvalidPath(path.to_path_buf()))?)?;

	let file = temp.as_file();
	file.set_len(data.len() as u64)?;
	if let Ok(metadata) = fs::metadata(&path) {
		file.set_permissions(metadata.permissions()).ok();
	}

	if !data.is_empty() {
		let mut mmap_temp = unsafe { MmapMut::map_mut(file)? };
		mmap_temp.deref_mut().write_all(data)?;
		mmap_temp.flush_async()?;
	}

	temp.persist(&path)?;

	Ok(())
}