use std::sync::atomic::{AtomicBool, Ordering};
use rayon::prelude::*;
use crate::diff::{DiffLine, FileDiff, LineSource};
use super::{vcs_thread_pool, PARALLEL_THRESHOLD};
pub(crate) enum FileProcessResult {
Diff(FileDiff),
Binary { path: String },
Image { path: String },
Cancelled,
}
pub(crate) struct AssembledDiff {
pub files: Vec<FileDiff>,
pub lines: Vec<DiffLine>,
}
pub(crate) fn assemble_results(results: Vec<FileProcessResult>) -> AssembledDiff {
let mut files = Vec::new();
for result in results {
match result {
FileProcessResult::Diff(file_diff) => {
files.push(file_diff);
}
FileProcessResult::Binary { path } => {
let header = DiffLine::file_header(&path);
let marker = DiffLine::new(
LineSource::Base,
"[binary file]".to_string(),
' ',
None,
);
files.push(FileDiff::new(vec![header, marker]));
}
FileProcessResult::Image { path } => {
let header = DiffLine::file_header(&path);
let marker = DiffLine::image_marker(&path);
files.push(FileDiff::new(vec![header, marker]));
}
FileProcessResult::Cancelled => {}
}
}
crate::diff::block::match_blocks(&mut files);
let mut lines = Vec::new();
for file in &files {
lines.extend(file.lines.iter().cloned());
lines.push(DiffLine::new(LineSource::Base, String::new(), ' ', None));
}
AssembledDiff { files, lines }
}
pub(crate) fn process_files_parallel<T, F>(
items: &[T],
cancel: &AtomicBool,
process: F,
) -> Vec<FileProcessResult>
where
T: Sync,
F: Fn(&T) -> FileProcessResult + Sync,
{
let guarded = |item: &T| -> FileProcessResult {
if cancel.load(Ordering::Relaxed) {
FileProcessResult::Cancelled
} else {
process(item)
}
};
if items.len() >= PARALLEL_THRESHOLD {
vcs_thread_pool().install(|| items.par_iter().map(&guarded).collect())
} else {
items.iter().map(guarded).collect()
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::diff::{DiffLine, FileDiff, LineSource};
fn diff_result(path: &str) -> FileProcessResult {
FileProcessResult::Diff(FileDiff::new(vec![
DiffLine::file_header(path),
DiffLine::new(
LineSource::Base,
"content".to_string(),
' ',
None,
),
]))
}
#[test]
fn test_assemble_diff_results() {
let results = vec![
diff_result("src/a.rs"),
FileProcessResult::Binary {
path: "data.bin".to_string(),
},
FileProcessResult::Image {
path: "logo.png".to_string(),
},
];
let assembled = assemble_results(results);
assert_eq!(assembled.files.len(), 3);
assert_eq!(assembled.lines.len(), 9);
}
#[test]
fn test_assemble_empty_results() {
let assembled = assemble_results(vec![]);
assert!(assembled.files.is_empty());
assert!(assembled.lines.is_empty());
}
#[test]
fn test_assemble_binary_creates_header_and_marker() {
let results = vec![FileProcessResult::Binary {
path: "data.bin".to_string(),
}];
let assembled = assemble_results(results);
assert_eq!(assembled.files.len(), 1);
assert_eq!(assembled.lines.len(), 3);
let file = &assembled.files[0];
assert_eq!(file.lines.len(), 2);
assert_eq!(
file.lines[0].file_path.as_deref(),
Some("data.bin"),
);
assert_eq!(file.lines[1].content, "[binary file]");
}
#[test]
fn test_assemble_image_creates_header_and_marker() {
let results = vec![FileProcessResult::Image {
path: "logo.png".to_string(),
}];
let assembled = assemble_results(results);
assert_eq!(assembled.files.len(), 1);
assert_eq!(assembled.lines.len(), 3);
let file = &assembled.files[0];
assert_eq!(file.lines.len(), 2);
assert_eq!(
file.lines[0].file_path.as_deref(),
Some("logo.png"),
);
assert_eq!(file.lines[1].content, "[image]");
}
#[test]
fn test_process_files_parallel_serial_path() {
let items = vec!["a.rs", "b.rs"];
let cancel = AtomicBool::new(false);
let results = process_files_parallel(&items, &cancel, |path| diff_result(path));
assert_eq!(results.len(), 2);
}
#[test]
fn test_process_files_parallel_parallel_path() {
let items: Vec<String> = (0..5).map(|i| format!("file{i}.rs")).collect();
let cancel = AtomicBool::new(false);
let results = process_files_parallel(&items, &cancel, |path| diff_result(path));
assert_eq!(results.len(), 5);
}
#[test]
fn test_process_files_parallel_serial_skips_when_cancel_set() {
use std::sync::atomic::AtomicUsize;
let items = vec!["a.rs", "b.rs", "c.rs"];
let cancel = AtomicBool::new(true);
let invoked = AtomicUsize::new(0);
let results = process_files_parallel(&items, &cancel, |path| {
invoked.fetch_add(1, Ordering::Relaxed);
diff_result(path)
});
assert_eq!(invoked.load(Ordering::Relaxed), 0,
"per-file processor must not be called when cancel is pre-set");
assert_eq!(results.len(), 3);
assert!(matches!(results[0], FileProcessResult::Cancelled));
assert!(matches!(results[1], FileProcessResult::Cancelled));
assert!(matches!(results[2], FileProcessResult::Cancelled));
}
#[test]
fn test_assemble_drops_cancelled_results() {
let results = vec![
diff_result("src/a.rs"),
FileProcessResult::Cancelled,
FileProcessResult::Cancelled,
];
let assembled = assemble_results(results);
assert_eq!(assembled.files.len(), 1);
}
}