Function apply_insert

atomic-core/src/crdt/apply/leaf.rs:150–206

(
    txn: &mut T,
    context: &mut ApplyContext,
    branch_id: BranchId,
    leaf_id: LeafId,
    after: Option<LeafId>,
    kind: TokenKind,
    leaf_content: &[u8],
    _content: &[u8],
)

/// - `ContentOutOfBounds` - The content range is invalid
#[allow(clippy::too_many_arguments)]
fn apply_insert<T: MutCrdtTxnT>(
    txn: &mut T,
    context: &mut ApplyContext,
    branch_id: BranchId,
    leaf_id: LeafId,
    after: Option<LeafId>,
    kind: TokenKind,
    leaf_content: &[u8],
    _content: &[u8],
) -> ApplyResult<()> {
    // Check for duplicate ID
    if txn
        .has_leaf(leaf_id)
        .map_err(|e| storage_err(e, "checking leaf exists"))?
    {
        if context.options().allow_duplicate_ids() {
            context.record_skipped();
            return Ok(());
        }
        return Err(ApplyError::leaf_already_exists(leaf_id));
    }

    // Validate branch exists (optional based on validation settings)
    if context.options().validate_references()
        && !txn
            .has_branch(branch_id)
            .map_err(|e| storage_err(e, "checking branch exists"))?
    {
        return Err(ApplyError::branch_not_found(branch_id));
    }

    // Validate "after" reference if provided
    if context.options().validate_references() {
        if let Some(after_id) = after {
            if !txn
                .has_leaf(after_id)
                .map_err(|e| storage_err(e, "checking after leaf"))?
            {
                return Err(ApplyError::leaf_not_found(after_id));
            }
        }
    }

    // For now, we store the content length as the range
    // In a full implementation, we'd compute the actual offset in the content blob
    let content_len = leaf_content.len() as u32;
    let content_range = 0..content_len;

    // Create and store the leaf
    let leaf = Leaf::new(leaf_id, branch_id, kind, content_range);
    txn.put_leaf(&leaf, after)
        .map_err(|e| storage_err(e, "inserting leaf"))?;

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