Function process_single_file

atomic-repository/src/parallel_record/worker.rs:21–41

Process a single file on a rayon worker thread. This function is the per-file workhorse. It reads the file from disk, diffs against old content, tokenizes, and builds hunks. It is designed to be called from a rayon parallel iterator and must not access any shared mutable state.

(
    input: &FileRecordInput,
    options: &RecordingOptions,
)

/// to be called from a rayon parallel iterator and must not access any
/// shared mutable state.
pub fn process_single_file(
    input: &FileRecordInput,
    options: &RecordingOptions,
) -> Result<FileRecordOutput, String> {
    let file_start = Instant::now();

    let result = match input.kind {
        FileRecordKind::Added => process_added_file(input, options),
        FileRecordKind::Modified => process_modified_file(input, options),
        FileRecordKind::Deleted => process_deleted_file(input, options),
        FileRecordKind::DirectoryAdded => process_directory_added(input),
        FileRecordKind::DirectoryDeleted => process_directory_deleted(input),
    };

    // Attach timing to the result
    let elapsed = file_start.elapsed().as_millis() as u64;
    result.map(|mut output| {
        output.stats.processing_time_ms = elapsed;
        output
    })
}

/// Process an added file: read content, detect encoding, create hunks, tokenize.
fn process_added_file(