Method insert_from_view

atomic-repository/src/repository/insert.rs:2428–2601

Insert changes from one view into another. This is the main method for cross-view operations. It can: - Insert all missing changes from source to target - Insert only changes up to a specific tag - Insert only specific changes # Arguments `options` - Options controlling the cross-view insert # Returns A `CrossViewInsertOutcome` with details about what was inserted. # Example ```rust,ignore

(
        &self,
        options: CrossViewInsertOptions,
    )

    /// let result = repo.insert_from_view(options)?;
    /// ```
    pub fn insert_from_view(
        &self,
        options: CrossViewInsertOptions,
    ) -> Result<CrossViewInsertOutcome, RepositoryError> {
        let trace_insert = std::env::var_os("ATOMIC_TRACE_INSERT").is_some();
        let t0 = std::time::Instant::now();

        let mut outcome = CrossViewInsertOutcome::new();
        outcome.was_dry_run = options.dry_run;

        // Determine which changes to consider
        let source_changes = if !options.only_changes.is_empty() {
            // Use only specified changes
            options.only_changes.clone()
        } else if let Some(ref tag_name) = options.up_to_tag {
            // Get changes up to the tag
            self.get_changes_up_to_tag(tag_name, Some(&options.from_view))?
        } else {
            // Get all changes from source view
            self.get_view_changes(Some(&options.from_view))?
                .into_iter()
                .map(|(_, hash)| hash)
                .collect()
        };

        if trace_insert {
            eprintln!(
                "[insert_from_view] start from={} to={} source_changes={}",
                options.from_view,
                options.to_view,
                source_changes.len(),
            );
            eprintln!(
                "[insert_from_view] source_changes collected count={} elapsed={:?}",
                source_changes.len(),
                t0.elapsed(),
            );
        }

        // Filter to changes not already in target
        let txn = self
            .pristine
            .read_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        let to_view = txn
            .get_view(&options.to_view)
            .map_err(|e| RepositoryError::Database(e.to_string()))?
            .ok_or_else(|| RepositoryError::ViewNotFound {
                name: options.to_view.clone(),
            })?;

        let missing = filter_missing_in_view(&txn, &to_view, &source_changes)
            .map_err(|e| RepositoryError::Apply(e.to_string()))?;

        // Track skipped changes
        let missing_set: std::collections::HashSet<_> = missing.iter().collect();
        for hash in &source_changes {