Function process

src/main.rs:271–300

(values: &[serde_json::Value], action: &Action)

}

fn process(values: &[serde_json::Value], action: &Action) -> Result<(), EachError> {
	let results: Result<Vec<()>, EachError> = values
		.par_iter()
		.map(|value| -> Result<(), EachError> {
			let cmd = action.prepare(value).map_err(|e| EachError::Data {
				message: format!("failed to prepare command: {:?}", e),
			})?;

			let run = if action.prompt {
				let prompt = action.prompt(&cmd, value).map_err(|e| EachError::Data {
					message: format!("failed to render stdin: {:?}", e),
				})?;

				Confirm::new().with_prompt(&prompt).interact()?
			} else {
				true
			};

			if run {
				action.run(cmd).map_err(|e| EachError::Data {
					message: format!("failed to run command: {:?}", e),
				})?;
			}

			Ok(())
		})
		.collect();

	results.map(|_| ())
}