Function apply_insert

atomic-core/src/crdt/apply/branch.rs:187–213

Applies an Insert operation to create a new line. # Behavior 1. Checks if the branch ID already exists (error if so, unless duplicates allowed) 2. Validates the trunk exists and is alive 3. Resolves the insertion position (handling concurrent inserts) 4. Creates the branch entry in BRANCHES table 5. Updates TRUNK_BRANCHES ordering multimap 6. Applies any nested leaf operations # Errors - `Bran

(
    txn: &mut T,
    context: &mut ApplyContext,
    trunk_id: TrunkId,
    branch_id: BranchId,
    after: Option<BranchId>,
    leaf_ops: &[LeafOp],
    content: &[u8],
)

/// - `TrunkNotFound` - The parent trunk doesn't exist
/// - `InvalidTrunkState` - The parent trunk is deleted
fn apply_insert<T: MutCrdtTxnT>(
    txn: &mut T,
    context: &mut ApplyContext,
    trunk_id: TrunkId,
    branch_id: BranchId,
    after: Option<BranchId>,
    leaf_ops: &[LeafOp],
    content: &[u8],
) -> ApplyResult<()> {
    // First apply the branch insert
    apply_insert_only(txn, context, trunk_id, branch_id, after)?;

    // Then apply nested leaf operations
    let mut leaf_idx: u32 = 0;
    let mut _prev_leaf = None;

    for leaf_op in leaf_ops {
        if let LeafOp::Insert { .. } = leaf_op {
            let leaf_id = crate::crdt::LeafId::new(branch_id.change_id(), leaf_idx);
            apply_leaf_op(txn, context, branch_id, leaf_id, leaf_op, content)?;
            _prev_leaf = Some(leaf_id);
            leaf_idx += 1;
        }
    }

    Ok(())
}

/// Applies an Insert operation without nested leaf operations.
fn apply_insert_only<T: MutCrdtTxnT>(