Function apply_move

atomic-core/src/crdt/apply/trunk.rs:206–242

Applies a Move operation to rename or relocate a file. # Behavior 1. Verifies the trunk exists 2. Verifies the trunk is alive (not deleted) 3. Checks the new path isn't already taken 4. Updates the trunk's path 5. Updates the PATH_TRUNK index # Errors - `TrunkNotFound` - The trunk doesn't exist - `InvalidTrunkState` - The trunk is deleted - `PathAlreadyExists` - The new path is occupied

(
    txn: &mut T,
    context: &mut ApplyContext,
    trunk_id: TrunkId,
    new_path: &str,
)

/// - `InvalidTrunkState` - The trunk is deleted
/// - `PathAlreadyExists` - The new path is occupied
fn apply_move<T: MutCrdtTxnT>(
    txn: &mut T,
    context: &mut ApplyContext,
    trunk_id: TrunkId,
    new_path: &str,
) -> ApplyResult<()> {
    // Verify trunk exists
    let trunk = txn
        .get_trunk(trunk_id)
        .map_err(|e| storage_err(e, "getting trunk"))?
        .ok_or_else(|| ApplyError::trunk_not_found(trunk_id))?;

    // Check current state
    if trunk.state().is_deleted() {
        return Err(ApplyError::invalid_trunk_state(trunk_id, "deleted", "move"));
    }

    // Check for path collision (unless it's the same trunk)
    if let Some(existing) = txn
        .get_trunk_by_path(new_path)
        .map_err(|e| storage_err(e, "checking path exists"))?
    {
        if existing != trunk_id {
            return Err(ApplyError::path_already_exists(new_path, existing));
        }
        // Moving to same path is a no-op
        context.record_skipped();
        return Ok(());
    }

    // Update path
    txn.update_trunk_path(trunk_id, new_path)
        .map_err(|e| storage_err(e, "updating trunk path"))?;

    context.record_trunk_moved();
    Ok(())
}

// Undelete Operation