Method persist_view_conflicts

atomic-repository/src/repository/materialize.rs:94–144

Persist the conflict state discovered by a materialize into the `CONFLICTS` table for `view_id`. A full materialize (`only_paths` is `None`) replaces the view's entire conflict set: every prior entry is dropped and the current conflicts re-written. A partial materialize updates only the touched files, setting or clearing each. This keeps a partial run from wrongly discarding conflicts for files i

(
        &self,
        view_id: u64,
        path_to_inode: &std::collections::HashMap<String, u64>,
        conflicts_by_path: &std::collections::HashMap<String, u32>,
        only_paths: &Option<s

    /// setting or clearing each. This keeps a partial run from wrongly
    /// discarding conflicts for files it did not re-materialize.
    fn persist_view_conflicts(
        &self,
        view_id: u64,
        path_to_inode: &std::collections::HashMap<String, u64>,
        conflicts_by_path: &std::collections::HashMap<String, u32>,
        only_paths: &Option<std::collections::HashSet<String>>,
    ) -> Result<(), RepositoryError> {
        let mut wtxn = self
            .pristine
            .write_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;

        let mk = |path: &str, line: u32| StoredConflict {
            kind: StoredConflictKind::Order,
            path: path.to_string(),
            line: Some(line),
            sides: Vec::new(),
        };

        match only_paths {
            None => {
                wtxn.del_conflicts_prefix(view_id)
                    .map_err(|e| RepositoryError::Database(e.to_string()))?;
                for (path, line) in conflicts_by_path {
                    if let Some(&inode) = path_to_inode.get(path) {
                        let sc = mk(path, *line);
                        wtxn.put_conflicts(view_id, inode, std::slice::from_ref(&sc))
                            .map_err(|e| RepositoryError::Database(e.to_string()))?;
                    }
                }
            }
            Some(paths) => {
                for path in paths {
                    if let Some(&inode) = path_to_inode.get(path) {
                        if let Some(line) = conflicts_by_path.get(path) {
                            let sc = mk(path, *line);
                            wtxn.put_conflicts(view_id, inode, std::slice::from_ref(&sc))
                                .map_err(|e| RepositoryError::Database(e.to_string()))?;
                        } else {
                            wtxn.del_conflicts(view_id, inode)
                                .map_err(|e| RepositoryError::Database(e.to_string()))?;
                        }
                    }
                }
            }
        }

        wtxn.commit()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        Ok(())
    }
    /// Compute the set of file paths visible on a view.
    ///
    /// Visibility includes the view's own changes AND all changes