Function apply_single_file_ops

atomic-core/src/apply/file_ops.rs:482–516

Apply FileOps for a single file.

(
    txn: &mut T,
    change_id: NodeId,
    ops: &FileOps,
    stats: &mut ApplyFileOpsStats,
    next_leaf_idx: &mut u32,
)

/// Apply FileOps for a single file.
fn apply_single_file_ops<T: MutTxnT>(
    txn: &mut T,
    change_id: NodeId,
    ops: &FileOps,
    stats: &mut ApplyFileOpsStats,
    next_leaf_idx: &mut u32,
) -> PristineResult<()> {
    // Resolve the TrunkId placeholder.  The recorder stores TrunkIds
    // with `change_id = NodeId::ROOT` as a placeholder meaning "this
    // change — fill in the real id at apply time" (same convention as
    // BranchId, see `apply_line_ops_with_position`).  Without this
    // resolution every file recorded in a single change shares
    // `TrunkId(ROOT, 0)` in the CRDT tables, so queries like
    // `get_file_content_via_crdt` return branches from every file
    // concatenated.
    let raw_trunk_id = ops.trunk_id();
    let trunk_id = if raw_trunk_id.change_id().is_root() {
        TrunkId::new(change_id, raw_trunk_id.file_idx())
    } else {
        raw_trunk_id
    };
    let path = ops.path();

    // Apply trunk operation if present
    if let Some(trunk_op) = ops.trunk_op() {
        apply_trunk_op(txn, change_id, trunk_id, path, trunk_op, stats)?;
    }

    // Apply line operations
    for line_ops in ops.line_ops() {
        apply_line_ops_with_position(txn, change_id, trunk_id, line_ops, stats, next_leaf_idx)?;
    }

    Ok(())
}

/// Apply a TrunkOp (file-level operation).
fn apply_trunk_op<T: MutTxnT>(