Function process_deleted_file

atomic-repository/src/parallel_record/worker.rs:195–231

Process a deleted file: create deletion hunks.

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

/// Process a deleted file: create deletion hunks.
fn process_deleted_file(
    input: &FileRecordInput,
    options: &RecordingOptions,
) -> Result<FileRecordOutput, String> {
    let mut detected = DetectedFile::deleted(&input.path);
    detected.inode = input.inode;
    detected.position = input.position;

    match record_deleted_file(&detected, options) {
        Ok(recorded) => {
            let crdt_stats = recorded.crdt_stats();
            let file_stats = FileRecordStats {
                hunks_created: recorded.hunk_count(),
                edges_modified: 1,
                lines_added: crdt_stats.map_or(0, |s| s.lines_added),
                lines_deleted: crdt_stats.map_or(0, |s| s.lines_deleted),
                lines_modified: crdt_stats.map_or(0, |s| s.lines_modified),
                tokens_added: crdt_stats.map_or(0, |s| s.tokens_added),
                tokens_deleted: crdt_stats.map_or(0, |s| s.tokens_deleted),
                tokens_replaced: crdt_stats.map_or(0, |s| s.tokens_replaced),
                ..FileRecordStats::default()
            };

            Ok(FileRecordOutput {
                path: input.path.clone(),
                kind: FileRecordKind::Deleted,
                recorded: Some(recorded),
                skipped: false,
                stats: file_stats,
            })
        }
        Err(e) => Err(format!(
            "Failed to record deletion of {}: {}",
            input.path, e
        )),
    }
}

/// Process an added directory.
fn process_directory_added(input: &FileRecordInput) -> Result<FileRecordOutput, String> {