Function get_file_lines_by_trunk

atomic-core/src/output/crdt.rs:331–409

Retrieve all lines for a file by trunk ID.

(
    txn: &mut T,
    trunk_id: TrunkId,
    options: &RetrievalOptions,
)

/// Retrieve all lines for a file by trunk ID.
pub fn get_file_lines_by_trunk<T: MutTxnT>(
    txn: &mut T,
    trunk_id: TrunkId,
    options: &RetrievalOptions,
) -> PristineResult<Vec<Line>> {
    // Get all branches for this trunk **in file order**.  The BRANCH_AFTER
    // chain produces top-of-file → bottom-of-file ordering — TRUNK_BRANCHES
    // alone gives BranchId sort order, which is wrong for prepended lines
    // from later commits.
    let branch_ids: Vec<BranchId> = iter_trunk_branches_in_file_order(txn, trunk_id)?;

    let mut lines = Vec::new();
    let mut line_number = 1usize;

    for branch_id in branch_ids {
        let branch_key = encode_branch_id(&branch_id);

        // Check line limit
        if let Some(max) = options.max_lines {
            if lines.len() >= max {
                break;
            }
        }
        let branch_data = match txn.get_crdt_branch(&branch_key)? {
            Some(data) => data,
            None => continue, // Branch not found, skip
        };

        // Skip deleted lines unless requested
        if branch_data.state.is_deleted() && !options.include_deleted_lines {
            continue;
        }

        let mut line = Line::new(
            branch_id,
            line_number,
            branch_data.state,
            branch_data.line_hash,
        );

        // Get all leaves for this branch
        let leaf_keys: Vec<[u8; 12]> = txn
            .iter_branch_leaves(&branch_key)?
            .collect::<Result<Vec<_>, _>>()?;

        for leaf_key in leaf_keys {
            let leaf_id = decode_leaf_id(&leaf_key);
            let leaf_data = match txn.get_crdt_leaf(&leaf_key)? {
                Some(data) => data,
                None => continue, // Leaf not found, skip
            };

            // Skip deleted tokens unless requested
            if leaf_data.state.is_deleted() && !options.include_deleted_tokens {
                continue;
            }

            // Note: content would need to come from the change's content blob