Function apply_create

atomic-core/src/crdt/apply/trunk.rs:102–140

Applies a Create operation to create a new file. # Behavior 1. Checks if the trunk ID already exists (error if so, unless duplicates allowed) 2. Checks if the path is already taken (error if so) 3. Allocates a new inode 4. Creates the trunk entry in TRUNKS table 5. Updates PATH_TRUNK and INODE_TRUNK indexes # Errors - `TrunkAlreadyExists` - The trunk ID is already in use - `PathAlreadyExists`

(
    txn: &mut T,
    context: &mut ApplyContext,
    trunk_id: TrunkId,
    path: &str,
    encoding: Option<Encoding>,
)

/// - `TrunkAlreadyExists` - The trunk ID is already in use
/// - `PathAlreadyExists` - The path is occupied by another file
fn apply_create<T: MutCrdtTxnT>(
    txn: &mut T,
    context: &mut ApplyContext,
    trunk_id: TrunkId,
    path: &str,
    encoding: Option<Encoding>,
) -> ApplyResult<()> {
    // Check for duplicate ID
    if txn
        .has_trunk(trunk_id)
        .map_err(|e| storage_err(e, "checking trunk exists"))?
    {
        if context.options().allow_duplicate_ids() {
            context.record_skipped();
            return Ok(());
        }
        return Err(ApplyError::trunk_already_exists(trunk_id));
    }

    // Check for path collision
    if let Some(existing) = txn
        .get_trunk_by_path(path)
        .map_err(|e| storage_err(e, "checking path exists"))?
    {
        return Err(ApplyError::path_already_exists(path, existing));
    }

    // Allocate inode and create trunk
    let inode = txn
        .alloc_inode()
        .map_err(|e| storage_err(e, "allocating inode"))?;
    let trunk = Trunk::new(trunk_id, inode, path.to_string(), encoding);

    txn.put_trunk(&trunk)
        .map_err(|e| storage_err(e, "inserting trunk"))?;

    context.record_trunk_created();
    Ok(())
}

// Delete Operation