Method load_diff_files

crates/devsql/src/engine.rs:567–644

(&mut self)

    }

    fn load_diff_files(&mut self) -> Result<()> {
        self.conn.execute(
            "CREATE TABLE IF NOT EXISTS diff_files (
                commit_id TEXT,
                path TEXT,
                status TEXT,
                insertions INTEGER,
                deletions INTEGER
            )",
            [],
        )?;

        if let Ok(repo) = git2::Repository::open(&self.git_repo_path) {
            let mut revwalk = repo.revwalk().map_err(|e| Error::Vcsql(e.to_string()))?;
            revwalk.push_head().ok();

            for oid in revwalk.filter_map(|r| r.ok()) {
                let Ok(commit) = repo.find_commit(oid) else {
                    continue;
                };

                let commit_tree = match commit.tree() {
                    Ok(t) => t,
                    Err(_) => continue,
                };

                let parent_tree = if commit.parent_count() > 0 {
                    commit.parent(0).ok().and_then(|p| p.tree().ok())
                } else {
                    None
                };

                let diff =
                    match repo.diff_tree_to_tree(parent_tree.as_ref(), Some(&commit_tree), None) {
                        Ok(d) => d,
                        Err(_) => continue,
                    };

                let commit_id = commit.id().to_string();

                for delta_idx in 0..diff.deltas().len() {
                    let delta = diff.deltas().nth(delta_idx).unwrap();

                    let path = delta
                        .new_file()
                        .path()
                        .or_else(|| delta.old_file().path())
                        .map(|p| p.to_string_lossy().to_string())
                        .unwrap_or_default();

                    let status = match delta.status() {
                        git2::Delta::Added => "A",
                        git2::Delta::Deleted => "D",
                        git2::Delta::Modified => "M",
                        git2::Delta::Renamed => "R",
                        git2::Delta::Copied => "C",
                        _ => "?",
                    };