Function collect_tracked_files

atomic-core/src/record/workflow/collect.rs:359–404

Collect tracked files from the pristine database. Iterates over the TREE table to find all files tracked by the repository. Results can be filtered by path prefix. # Arguments `txn` - Read transaction for pristine database `prefix` - Path prefix filter (empty = all files) # Returns A `CollectionResult ` containing all tracked files. # Errors Returns `RecordError::Pristine` if da

(
    txn: &T,
    prefix: &str,
)

/// let result = collect_tracked_files(&txn, "src/")?;
/// ```
pub fn collect_tracked_files<T>(
    txn: &T,
    prefix: &str,
) -> RecordResult<CollectionResult<TrackedFile>>
where
    T: GraphTxnT + TreeTxnT + ViewTxnT,
{
    let mut result = CollectionResult::new();

    // Iterate over all tree entries (trait doesn't support prefix filtering)
    let iter = txn
        .iter_tree()
        .map_err(|e| RecordError::Pristine(Box::new(e)))?;

    for item in iter {
        match item {
            Ok((path, inode)) => {
                // Filter by prefix if specified
                if !prefix.is_empty() && !path.starts_with(prefix) {
                    result.add_skipped();
                    continue;
                }

                // Get the position for this inode
                match txn.inode_position(inode) {
                    Ok(Some(position)) => {
                        let file = TrackedFile::new(&path, inode, position);
                        result.add(file);
                    }
                    Ok(None) => {
                        // Inode exists but has no position - might be a bug or deleted
                        result.add_error(&path, "Inode has no graph position");
                    }
                    Err(e) => {
                        result.add_error(&path, format!("Failed to get position: {}", e));
                    }
                }
            }
            Err(e) => {
                result.add_error("<iteration error>", format!("Tree iteration failed: {}", e));
            }
        }
    }

    Ok(result)
}

/// Collect files from the working copy.
///