Function validate_trunk_state

atomic-core/src/crdt/apply/trunk.rs:301–328

Validates that a trunk exists and is in the expected state. # Arguments `txn` - The transaction `trunk_id` - The trunk to validate `expected_state` - The expected state, or `None` for any state # Returns The trunk if validation passes.

(
    txn: &T,
    trunk_id: TrunkId,
    expected_state: Option<TrunkState>,
)

///
/// The trunk if validation passes.
pub fn validate_trunk_state<T: MutCrdtTxnT>(
    txn: &T,
    trunk_id: TrunkId,
    expected_state: Option<TrunkState>,
) -> ApplyResult<Trunk> {
    let trunk = txn
        .get_trunk(trunk_id)
        .map_err(|e| storage_err(e, "getting trunk"))?
        .ok_or_else(|| ApplyError::trunk_not_found(trunk_id))?;

    if let Some(expected) = expected_state {
        let matches = match expected {
            TrunkState::Alive => trunk.state().is_alive(),
            TrunkState::Deleted => trunk.state().is_deleted(),
            TrunkState::Zombie => trunk.state().is_zombie(),
        };

        if !matches {
            return Err(ApplyError::invalid_trunk_state(
                trunk_id,
                trunk.state().to_string(),
                format!("expected {}", expected),
            ));
        }
    }

    Ok(trunk)
}

/// Checks if a path is available (not taken by another file).
///