Method index_git_shas

atomic-repository/src/repository/insert.rs:2764–2806

Record missing Git SHA → Atomic change mappings in one transaction. Existing mappings are skipped. If every mapping is already indexed the write transaction is dropped without committing, keeping incremental no-op imports free of per-change database writes.

(&self, mappings: &[(String, Hash)])

    /// write transaction is dropped without committing, keeping incremental
    /// no-op imports free of per-change database writes.
    pub fn index_git_shas(&self, mappings: &[(String, Hash)]) -> Result<usize, RepositoryError> {
        use atomic_core::pristine::{GitShaIndexMutTxnT, GitShaIndexTxnT};

        if mappings.is_empty() {
            return Ok(0);
        }

        let mut txn = self
            .pristine
            .write_txn()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        let mut inserted = 0;

        for (git_sha, change_hash) in mappings {
            if txn
                .has_git_sha(git_sha)
                .map_err(|e| RepositoryError::Database(e.to_string()))?
            {
                continue;
            }

            let entity_id = txn
                .get_internal(change_hash)
                .map_err(|e| RepositoryError::Database(e.to_string()))?
                .ok_or_else(|| {
                    RepositoryError::Database(format!(
                        "Change hash not found in INTERNAL: {}",
                        change_hash.to_base32()
                    ))
                })?;
            txn.put_git_sha(git_sha, entity_id)
                .map_err(|e| RepositoryError::Database(e.to_string()))?;
            inserted += 1;
        }

        if inserted == 0 {
            return Ok(0);
        }

        txn.commit()
            .map_err(|e| RepositoryError::Database(e.to_string()))?;
        Ok(inserted)
    }

    /// Check if a Git SHA has been indexed.
    pub fn has_git_sha(&self, git_sha: &str) -> Result<bool, RepositoryError> {