Function apply_replace

atomic-core/src/crdt/apply/leaf.rs:268–299

Applies a Replace operation to change a token's content. # Behavior 1. Verifies the leaf exists 2. Verifies the leaf is alive (not deleted) 3. Updates the leaf's content range to point to new content The leaf's ID is preserved, enabling accurate blame tracking. # Errors - `LeafNotFound` - The leaf doesn't exist - `InvalidLeafState` - The leaf is deleted

(
    txn: &mut T,
    context: &mut ApplyContext,
    leaf_id: LeafId,
    new_content: &[u8],
    _content: &[u8],
)

/// - `LeafNotFound` - The leaf doesn't exist
/// - `InvalidLeafState` - The leaf is deleted
fn apply_replace<T: MutCrdtTxnT>(
    txn: &mut T,
    context: &mut ApplyContext,
    leaf_id: LeafId,
    new_content: &[u8],
    _content: &[u8],
) -> ApplyResult<()> {
    // Verify leaf exists
    let leaf = txn
        .get_leaf(leaf_id)
        .map_err(|e| storage_err(e, "getting leaf"))?
        .ok_or_else(|| ApplyError::leaf_not_found(leaf_id))?;

    // Check current state
    if leaf.state().is_deleted() {
        return Err(ApplyError::invalid_leaf_state(
            leaf_id, "deleted", "replace",
        ));
    }

    // Update content range
    // In a full implementation, we'd compute the actual offset in the content blob
    let content_len = new_content.len() as u32;
    let new_range = 0..content_len;

    txn.update_leaf_content(leaf_id, new_range)
        .map_err(|e| storage_err(e, "updating leaf content"))?;

    context.record_leaf_replaced();
    context.record_content_bytes(content_len as u64);
    Ok(())
}

// Restore Operation