Function run

src/main.rs:120–269

(
	args: Command,
	mut formats: IndexMap<&'static str, Box<dyn Format>>,
)

}

fn run(
	args: Command,
	mut formats: IndexMap<&'static str, Box<dyn Format>>,
) -> Result<(), EachError> {
	let arg_matches = args.get_matches();
	info!("arguments: {:?}", arg_matches);

	for (format_id, ref mut format) in &mut formats {
		format
			.set_arguments(&arg_matches)
			.map_err(|e| EachError::Usage {
				message: format!("Invalid argument for format {}: {}", format_id, e),
			})?;
	}

	let max_procs = if let Some(max_procs_str) = arg_matches.value_of("max-procs") {
		max_procs_str
			.parse::<usize>()
			.map_err(|e| EachError::Usage {
				message: format!("Invalid max-procs: {} ({})", &max_procs_str, e),
			})?
	} else {
		1
	};

	rayon::ThreadPoolBuilder::new()
		.num_threads(max_procs)
		.build_global()
		.expect("build_global already called");

	let mut readers: Vec<(Option<String>, CachedReader)> = Vec::new();

	if let Some(input_paths) = arg_matches.values_of("input") {
		for input_path in input_paths {
			let path = Path::new(&input_path);
			let ext = path
				.extension()
				.map(|ext| ext.to_string_lossy().to_string());
			let reader = Box::new(FileReader::new(&input_path).map_err(|e| EachError::Data {
				message: format!("Couldn't open file {}: {}", &input_path, e),
			})?);

			let cached = CachedReader::new(reader);

			readers.push((ext, cached));
		}
	} else if atty::is(atty::Stream::Stdin) {
		return Err(EachError::Usage {
			message: "No input provided".to_owned(),
		});
	} else {
		let reader = Box::new(std::io::stdin());
		let cached = CachedReader::new(reader);
		readers.push((None, cached));
	}

	let action: Option<Action> = match arg_matches.values_of("command") {
		Some(ref mut commands) => {